Notifications accept.
This commit is contained in:
parent
dd11c8da5a
commit
8f137cf8e6
@ -39,7 +39,6 @@ class NotificationService(BaseService):
|
|||||||
if not channel_member['new_count']:
|
if not channel_member['new_count']:
|
||||||
channel_member['new_count'] = 0
|
channel_member['new_count'] = 0
|
||||||
channel_member['new_count'] += 1
|
channel_member['new_count'] += 1
|
||||||
print("INSERTED!!",flush=True)
|
|
||||||
await self.services.channel_member.save(channel_member)
|
await self.services.channel_member.save(channel_member)
|
||||||
|
|
||||||
model = await self.new()
|
model = await self.new()
|
||||||
|
@ -49,6 +49,7 @@ class BaseMapper:
|
|||||||
if not model.record.get("uid"):
|
if not model.record.get("uid"):
|
||||||
raise Exception(f"Attempt to save without uid: {model.record}.")
|
raise Exception(f"Attempt to save without uid: {model.record}.")
|
||||||
model.updated_at.update()
|
model.updated_at.update()
|
||||||
|
print(model.record,flush=True)
|
||||||
return self.table.upsert(model.record, ["uid"])
|
return self.table.upsert(model.record, ["uid"])
|
||||||
|
|
||||||
async def find(self, **kwargs) -> typing.AsyncGenerator:
|
async def find(self, **kwargs) -> typing.AsyncGenerator:
|
||||||
|
Loading…
Reference in New Issue
Block a user