Notifications accept.
This commit is contained in:
parent
8f137cf8e6
commit
30fe0bfae7
@ -5,6 +5,7 @@ class ChannelMemberService(BaseService):
|
|||||||
|
|
||||||
mapper_name = "channel_member"
|
mapper_name = "channel_member"
|
||||||
|
|
||||||
|
|
||||||
async def create(
|
async def create(
|
||||||
self,
|
self,
|
||||||
channel_uid,
|
channel_uid,
|
||||||
|
@ -61,7 +61,7 @@ class BaseService:
|
|||||||
if not "_limit" in kwargs or int(kwargs.get("_limit")) > 30:
|
if not "_limit" in kwargs or int(kwargs.get("_limit")) > 30:
|
||||||
kwargs["_limit"] = 60
|
kwargs["_limit"] = 60
|
||||||
async for model in self.mapper.find(**kwargs):
|
async for model in self.mapper.find(**kwargs):
|
||||||
yield model
|
yield await self.get(uid=model["uid"])
|
||||||
|
|
||||||
async def delete(self, **kwargs):
|
async def delete(self, **kwargs):
|
||||||
return await self.mapper.delete(**kwargs)
|
return await self.mapper.delete(**kwargs)
|
||||||
|
Loading…
Reference in New Issue
Block a user