watcha-synapse

History

Erik Johnston c9dbee50ae Fixup pusher pool notifications (#8287 ) `pusher_pool.on_new_notifications` expected a min and max stream ID, however that was not what we were passing in. Instead, let's just pass it the current max stream ID and have it track the last stream ID it got passed. I believe that it mostly worked as we called the function for every event. However, it would break for events that got persisted out of order, i.e, that were persisted but the max stream ID wasn't incremented as not all preceding events had finished persisting, and push for that event would be delayed until another event got pushed to the effected users.		4 years ago
..
__init__.py	…
action_generator.py	Stop sub-classing object (#8249 )	4 years ago
baserules.py	…
bulk_push_rule_evaluator.py	Only add rows to the push actions table if the event notifies or should be marked unread (#8274 )	4 years ago
clientformat.py	…
emailpusher.py	Fixup pusher pool notifications (#8287 )	4 years ago
httppusher.py	Fixup pusher pool notifications (#8287 )	4 years ago
mailer.py	Stop sub-classing object (#8249 )	4 years ago
presentable_names.py	…
push_rule_evaluator.py	Stop sub-classing object (#8249 )	4 years ago
push_tools.py	Unread counts fixes (#8254 )	4 years ago
pusher.py	Stop sub-classing object (#8249 )	4 years ago
pusherpool.py	Fixup pusher pool notifications (#8287 )	4 years ago
rulekinds.py	…