OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Lint

pull/7673/head
Brendan Abolivier 2020-06-12 15:31:59 +01:00
parent e47e5a2dcd
commit e186c660b1
No known key found for this signature in database
GPG Key ID: 1E015C145F1916CD
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
synapse/storage/data_stores/main/event_push_actions.py
View File

@ -16,9 +16,9 @@
import logging import logging
from typing import Dict, Tuple from typing import Dict, Tuple
import attr
from six import iteritems from six import iteritems
import attr
from canonicaljson import json from canonicaljson import json
from twisted.internet import defer from twisted.internet import defer
@ -42,6 +42,7 @@ DEFAULT_HIGHLIGHT_ACTION = [
@attr.s @attr.s
class EventPushSummary(object): class EventPushSummary(object):
"""Summary of pending event push actions for a given user in a given room.""" """Summary of pending event push actions for a given user in a given room."""
user_id = attr.ib() user_id = attr.ib()
room_id = attr.ib() room_id = attr.ib()
unread_count = attr.ib() unread_count = attr.ib()
@ -885,8 +886,12 @@ class EventPushActionsStore(EventPushActionsWorkerStore):
summaries = {} # type: Dict[Tuple[str, str], EventPushSummary] summaries = {} # type: Dict[Tuple[str, str], EventPushSummary]
for row in txn: for row in txn:
summaries[(row[0], row[1])] = EventPushSummary( summaries[(row[0], row[1])] = EventPushSummary(
user_id=row[0], room_id=row[1], unread_count=row[2], user_id=row[0],
stream_ordering=row[3], old_user_id=row[4], notif_count=0, room_id=row[1],
unread_count=row[2],
stream_ordering=row[3],
old_user_id=row[4],
notif_count=0,
) )
# Then get the count of notifications. # Then get the count of notifications.