summary refs log tree commit diff
path: root/synapse/notifier.py (follow)
Commit message (Expand)AuthorAgeFilesLines
* Bump black from 23.10.1 to 24.2.0 (#16936)dependabot[bot]2024-03-131-6/+3
* Correctly mention previous copyright (#16820)Erik Johnston2024-01-231-0/+1
* Update license headersPatrick Cloke2023-11-211-10/+16
* Allow multiple workers to write to receipts stream. (#16432)Erik Johnston2023-10-251-2/+43
* Some refactors around receipts stream (#16426)Erik Johnston2023-10-041-9/+8
* Use StrCollection in additional places. (#16301)Patrick Cloke2023-09-131-3/+3
* Add ability to wait for locks and add locks to purge history / room deletion ...Erik Johnston2023-07-311-0/+16
* Move ThirdPartyEventRules into module_api/callbacks (#15535)Andrew Morgan2023-05-041-1/+1
* Fix a bug in the send_local_online_presence_to module API (#14880)Patrick Cloke2023-01-251-1/+2
* Faster joins: omit partial rooms from eager syncs until the resync completes ...David Robertson2023-01-231-0/+26
* Always notify replication when a stream advances (#14877)Erik Johnston2023-01-201-5/+26
* Batch up notifications after event persistence (#14033)Shay2022-10-051-34/+41
* Notifier: accept callbacks to fire on room joins (#13254)David Robertson2022-07-131-0/+18
* Reduce the amount of state we pull from the DB (#12811)Erik Johnston2022-06-061-1/+1
* Rename storage classes (#12913)Erik Johnston2022-05-311-2/+2
* Additional constants for EDU types. (#12884)Patrick Cloke2022-05-271-2/+2
* Add `StreamKeyType` class and replace string literals with constants (#12567)Andrew Morgan2022-05-161-2/+3
* Immediately retry any requests that have backed off when a server comes back ...Erik Johnston2022-05-101-3/+5
* Remove `HomeServer.get_datastore()` (#12031)Richard van der Hoff2022-02-231-1/+1
* Add some tests for propagation of device list changes between local users (#1...Andrew Morgan2022-02-151-2/+2
* Adds misc missing type hints (#11953)Patrick Cloke2022-02-111-19/+24
* Send to-device messages to application services (#11215)Andrew Morgan2022-02-011-1/+3
* Remove `log_function` and its uses (#11761)Richard van der Hoff2022-01-181-3/+0
* Use auto_attribs/native type hints for attrs classes. (#11692)Patrick Cloke2022-01-131-7/+7
* Convert EventStreamResult to attrs. (#11574)Patrick Cloke2021-12-151-6/+19
* Fix providing a `RoomStreamToken` instance to `_notify_app_services_ephemeral...Andrew Morgan2021-11-021-29/+9
* Implement an `on_new_event` callback (#11126)Brendan Abolivier2021-10-261-4/+13
* Improve docstrings for methods related to sending EDUs to application service...Andrew Morgan2021-10-211-2/+16
* Add type hints for event streams. (#10856)Patrick Cloke2021-09-211-1/+1
* Generics for `ObservableDeferred` (#10491)Richard van der Hoff2021-07-281-2/+3
* Use inline type hints in various other places (in `synapse/`) (#10380)Jonathan de Jong2021-07-151-9/+9
* Improve opentracing annotations for Notifier (#10111)Richard van der Hoff2021-06-031-33/+33
* Add debug logging for issue #9533 (#9959)Richard van der Hoff2021-05-111-0/+8
* Remove `synapse.types.Collection` (#9856)Richard van der Hoff2021-04-221-7/+2
* Remove redundant "coding: utf-8" lines (#9786)Jonathan de Jong2021-04-141-1/+0
* Bugbear: Add Mutable Parameter fixes (#9682)Jonathan de Jong2021-04-081-8/+11
* Update mypy configuration: `no_implicit_optional = True` (#9742)Jonathan de Jong2021-04-051-1/+1
* Improve tracing for to device messages (#9686)Erik Johnston2021-04-011-2/+43
* Update black, and run auto formatting over the codebase (#9381)Eric Eastwood2021-02-161-12/+18
* Fix "Starting metrics collection from sentinel context" errors (#9053)Erik Johnston2021-01-081-20/+19
* Do not assume that the contents dictionary includes history_visibility. (#8945)Patrick Cloke2020-12-161-2/+4
* Don't pull event from DB when handling replication traffic. (#8669)Erik Johnston2020-10-281-13/+55
* Start fewer opentracing spans (#8640)Erik Johnston2020-10-261-23/+11
* Fix typos and spelling errors. (#8639)Patrick Cloke2020-10-231-1/+1
* Send some ephemeral events to appservices (#8437)Will Hunt2020-10-151-0/+25
* Fix not sending events over federation when using sharded event persisters (#...Erik Johnston2020-10-141-3/+3
* Add type hints to some handlers (#8505)Patrick Cloke2020-10-091-1/+1
* Various clean ups to room stream tokens. (#8423)Erik Johnston2020-09-291-2/+2
* Add EventStreamPosition type (#8388)Erik Johnston2020-09-241-26/+29
* Use slots in attrs classes where possible (#8296)Patrick Cloke2020-09-141-3/+1
* Make `StreamToken.room_key` be a `RoomStreamToken` instance. (#8281)Erik Johnston2020-09-111-4/+12
* Clean up `Notifier.on_new_room_event` code path (#8288)Erik Johnston2020-09-101-23/+39
* Clean up types for PaginationConfig (#8250)Erik Johnston2020-09-081-2/+3
* Stop sub-classing object (#8249)Patrick Cloke2020-09-041-3/+3
* Fix typing for notifier (#8064)Erik Johnston2020-08-121-4/+8
* Add typing info to Notifier (#8058)Erik Johnston2020-08-111-48/+83
* Convert streams to async. (#8014)Patrick Cloke2020-08-041-2/+2
* Fix some spelling mistakes / typos. (#7811)Patrick Cloke2020-07-091-1/+1
* Fix new flake8 errors (#7470)Erik Johnston2020-05-121-4/+6
* Convert the synapse.notifier module to async/await. (#7395)Patrick Cloke2020-05-011-10/+7
* Don't relay REMOTE_SERVER_UP cmds to same conn. (#7352)Erik Johnston2020-04-291-9/+0
* Wake up transaction queue when remote server comes back online (#6706)Erik Johnston2020-01-171-3/+28
* Port SyncHandler to async/awaitErik Johnston2019-12-051-16/+13
* Port to use state storageErik Johnston2019-10-301-1/+5
* Remove unnecessary parentheses around return statements (#5931)Andrew Morgan2019-08-301-3/+3
* Replace returnValue with return (#5736)Amber Brown2019-07-231-9/+9
* Move logging utilities out of the side drawer of util/ and into logging/ (#5606)Amber Brown2019-07-041-2/+2
* Run Black. (#5482)Amber Brown2019-06-201-34/+36
* Remove redundant PreserveLoggingContextRichard van der Hoff2019-03-041-10/+5
* Remove unused `wait_for_replication` methodRichard van der Hoff2019-03-041-50/+0
* Make the metrics less racy (#4061)Amber Brown2018-10-191-3/+3
* Run notify_app_services as a bg processRichard van der Hoff2018-09-261-2/+6
* FixupErik Johnston2018-09-191-4/+1
* Replace custom DeferredTimeoutError with defer.TimeoutErrorErik Johnston2018-09-191-3/+2
* Update to use new timeout function everywhere.Erik Johnston2018-09-191-6/+7
* Rename async to async_helpers because `async` is a keyword on Python 3.7 (#3678)Amber Brown2018-08-101-1/+1
* WIP to announce deleted devices over federationMatthew Hodgson2018-07-121-1/+1
* run isortAmber Brown2018-07-091-11/+10
* Pass around the reactor explicitly (#3385)Amber Brown2018-06-221-0/+3
* cleanup pep8 errorsAmber Brown2018-05-221-1/+2
* fixesAmber Brown2018-05-221-3/+3
* replacing portionsAmber Brown2018-05-211-13/+10
* Merge remote-tracking branch 'origin/develop' into rav/deferred_timeoutRichard van der Hoff2018-04-271-4/+9
|\
| * Improve exception handling for background processesRichard van der Hoff2018-04-271-4/+9
* | Backport deferred.addTimeoutRichard van der Hoff2018-04-271-8/+14
* | Use deferred.addTimeout instead of time_bound_deferredRichard van der Hoff2018-04-231-12/+11
|/
* add __bool__ alias to __nonzero__ methodsAdrian Tschira2018-04-151-0/+1
* Clear logcontext before starting fed txn queue runnerRichard van der Hoff2017-11-281-7/+10
* replace 'except:' with 'except Exception:'Richard van der Hoff2017-10-231-1/+1
* Don't start user_directory handling on workersErik Johnston2017-06-071-3/+0
* Add user_directory to databaseErik Johnston2017-05-311-1/+5
* Merge branch 'develop' of github.com:matrix-org/synapse into erikj/repl_tcp_s...Erik Johnston2017-04-041-13/+10
|\
| * Remove spurious PreserveLoggingContextRichard van der Hoff2017-04-031-6/+5
| * preserve_fn some deferred-returning thingsRichard van der Hoff2017-04-031-2/+5
| * Remove spurious @preserve_fn decoratorsRichard van der Hoff2017-04-031-5/+0
* | Use callbacks to notify tcp replication rather than deferredsErik Johnston2017-03-311-6/+11
* | Add a simple hook to wait for replication trafficErik Johnston2017-03-301-0/+6
|/
* Don't recreate so many setsErik Johnston2017-03-161-4/+2
* Format presence events on the edges instead of reformatting them multiple timesErik Johnston2017-03-151-0/+10
* Add some metrics on notifierErik Johnston2017-03-151-0/+6
* Reduce spurious calls to generate syncErik Johnston2017-03-141-13/+31
* Make presence.get_new_events a bit fasterErik Johnston2017-02-021-0/+1
* Correctly handle timeout errorsErik Johnston2016-12-091-6/+14
* Fix rare notifier bug where listeners dont timeoutErik Johnston2016-12-091-11/+9
* Ensure only main or federation_sender process can send federation trafficErik Johnston2016-11-231-2/+9
* Handle sending events and device messages over federationErik Johnston2016-11-171-0/+2
* Explicitly specify state_key for history_visibility fetchingErik Johnston2016-09-021-1/+2
* Preserve some logcontextsErik Johnston2016-08-241-1/+6
* defer.returnValue must not be called within MeasureErik Johnston2016-08-191-2/+1
* Add measure blocks to notifierErik Johnston2016-08-191-15/+18
* Make AppserviceHandler stream events from databaseErik Johnston2016-08-181-1/+1
* Remove dead appservice codeErik Johnston2016-08-171-39/+2
* Notify users for events in rooms they join.Mark Haines2016-06-071-8/+6
* Move the AS handler out of the Handlers object.Mark Haines2016-05-311-6/+4
* move filter_events_for_client out of base handlerMark Haines2016-05-111-2/+3
* Run filter_events_for_clientDavid Baker2016-04-271-1/+1
* Use google style doc strings.Mark Haines2016-04-011-7/+8
* Hook up adding a pusher to the notifier for replication.Mark Haines2016-03-151-0/+6
* Hook up the push rules to the notifierMark Haines2016-03-031-1/+1
* Add a /replication API for extracting the updates that happened onMark Haines2016-03-011-0/+48
* Fix up logcontextsErik Johnston2016-02-081-29/+29
* Fix flake8 warnings for new flake8Daniel Wagner-Hall2016-02-021-1/+1
* Don't use before_token. Its wrong. Use actual limit.Erik Johnston2016-01-311-6/+3
* Deal with None limitErik Johnston2016-01-291-1/+5
* Make /events always return a newer token, if one existsErik Johnston2016-01-291-9/+10
* Only fetch events for rooms and receiptsErik Johnston2016-01-211-3/+3
* SYN-606: Peeking does not wake up /eventsErik Johnston2016-01-211-1/+3
* Allow non-guests to peek on rooms using /eventsDaniel Wagner-Hall2016-01-201-23/+48
* Skip, rather than erroring, invalid guest requestsDaniel Wagner-Hall2016-01-051-2/+1
* Missing yield on guest access auth checkMark Haines2015-12-231-1/+1
* Return non-room events from guest /events callsDaniel Wagner-Hall2015-11-121-3/+17
* Open up /events to anonymous users for room events onlyDaniel Wagner-Hall2015-11-051-8/+34
* Merge branch 'develop' into daniel/removesomeliesMark Haines2015-11-041-1/+1
|\
| * Inform the client of new room tags using v1 /eventsMark Haines2015-10-291-1/+1
* | Remove unused arguments and codeDaniel Wagner-Hall2015-11-021-3/+3
|/
* Don't make pushers handle presence/typing eventsErik Johnston2015-08-241-1/+6
* Improve namingDaniel Wagner-Hall2015-07-201-2/+2
* Consolidate duplicate code in notifierErik Johnston2015-07-021-24/+11
* Add receipts_key to StreamTokenErik Johnston2015-07-021-1/+1
* Fix typoErik Johnston2015-06-191-1/+1
* PEP8Erik Johnston2015-06-181-2/+3
* DocumentationErik Johnston2015-06-181-4/+11
* Don't bother proxying lookups on _NotificationListener to underlying deferredErik Johnston2015-06-181-10/+2
* Refactor the notifier.wait_for_events code to be clearer. Add _NotifierUserSt...Erik Johnston2015-06-181-66/+56
* Fix notifier leakErik Johnston2015-06-181-21/+20
* Iterate over the user_streams not the user_idsMark Haines2015-05-261-1/+1
* Oops, get_rooms_for_user returns a namedtuple, not a room_idMark Haines2015-05-211-0/+1
* Don't bother sorting by the room_stream_ids, it shouldn't matter which order ...Mark Haines2015-05-181-1/+1
* Make sure the notifier stream token goes forward when it is updated. Sort the...Mark Haines2015-05-181-4/+4
* Add some doc-strings to notifierMark Haines2015-05-141-19/+33
* Use the current token when timing out a notifier, make sure the user_id is a ...Mark Haines2015-05-141-2/+2
* Fix v2 sync, update the last_notified_ms only if there was an active listenerMark Haines2015-05-141-5/+6
* Fix metric counterMark Haines2015-05-131-2/+2
* Discard unused NotifierUserStreamsMark Haines2015-05-131-16/+34
* Don't set a timer if there's already a result to returnMark Haines2015-05-131-3/+10
* Don't bother checking for new events from a source if the stream token hasn't...Mark Haines2015-05-131-2/+6
* Don't bother checking for updates if the stream token hasn't advanced for a userMark Haines2015-05-131-24/+51
* Merge branch 'notifier_unify' into notifier_performanceMark Haines2015-05-121-13/+10
|\
| * Merge branch 'develop' into notifier_unifyMark Haines2015-05-121-13/+10
| |\
| | * PEP8Erik Johnston2015-05-081-3/+2
| | * Change the way we do logging contexts so that they survive divergencesErik Johnston2015-05-081-9/+7
* | | Merge branch 'notifier_unify' into notifier_performanceMark Haines2015-05-121-1/+1
|\| |
| * | Update the end_token correctly, otherwise the token doesn't advance and the c...Mark Haines2015-05-121-1/+1
* | | Add a NotifierUserStream to hold all the notification listeners for a userMark Haines2015-05-121-114/+116
|/ /
* | Don't bother passing the events to the notifier since it isn't using themMark Haines2015-05-111-95/+18
* | Use wait_for_events to implement 'get_events'Mark Haines2015-05-111-79/+30
|/
* Remove some run_on_reactorsErik Johnston2015-05-011-5/+0
* Change from exception to warnErik Johnston2015-04-151-1/+1
* Add commentMark Haines2015-04-091-0/+1
* Unset the timer in the timeout callback so that we don't try to cancel it if ...Mark Haines2015-04-091-0/+1
* SYN-339: Cancel the notifier timeout when the notifier firesMark Haines2015-04-091-4/+26
* Move comment into docstringErik Johnston2015-04-081-5/+2
* Factor out loops into '_discard_if_notified'Erik Johnston2015-04-081-15/+14
* Also perform paranoia checks in 'on_new_user_event'Erik Johnston2015-04-081-2/+16
* Add paranoia checks to make sure that we evict stale NotificationListeners wh...Erik Johnston2015-04-081-5/+31
* Fix bug where we didn't inform the NotificataionListeners about new rooms the...Erik Johnston2015-04-081-0/+3
* Appease pep8Paul "LeoNerd" Evans2015-03-121-6/+9
* Add a counter to track total number of events served by the notifierPaul "LeoNerd" Evans2015-03-121-0/+3
* Use _ instead of . as a metric namespacing separator, for PrometheusPaul "LeoNerd" Evans2015-03-121-1/+1
* Put some gauge metrics on the number of notifier listeners, and notified-on o...Paul "LeoNerd" Evans2015-03-121-0/+39
* Rename rooms_to_listeners to room_to_listeners, for consistency with user_ an...Paul "LeoNerd" Evans2015-03-051-8/+8
* Notify appservices of invites mid-poll.Kegan Dougal2015-02-271-1/+29
* Merge branch 'consumeErrors' of github.com:matrix-org/synapse into developErik Johnston2015-02-171-2/+4
|\
| * Use consumeErrors=True on all DeferredLists.Erik Johnston2015-02-171-2/+4
* | Glue AS work to general event notifications. Add more exception handling when...Kegan Dougal2015-02-051-0/+6
|/
* Fix FormattingMark Haines2015-01-271-2/+2
* Wait for events if the incremental sync is empty and a timeout is givenMark Haines2015-01-271-0/+48
* Only start the notifier timeout once we've had a chance to check for updates....Mark Haines2015-01-191-2/+2
* Update copyright noticesMark Haines2015-01-061-1/+1
* Remember to hook up the typing event stream to the notifier as wellPaul "LeoNerd" Evans2014-12-151-7/+25
* Fix pep8 codestyle warningsMark Haines2014-11-201-0/+1
* Add a few missing yields, Move deferred lists inside PreserveLoggingContext b...Mark Haines2014-11-201-0/+3
* remove unused importMark Haines2014-11-191-1/+1
* Preserve logging context in a few more places, drop the logging context after...Mark Haines2014-11-191-18/+22
* Fix pep8 warningsMark Haines2014-10-301-1/+2
* Use floating-point rather than integer division to handle timeouts so that no...Paul "LeoNerd" Evans2014-10-291-1/+1
* fix the copyright holder from matrix.org to OpenMarket Ltd, as matrix.org has...Matthew Hodgson2014-09-031-1/+1
* Make sure to print exceptions properly from notifier failuresPaul "LeoNerd" Evans2014-09-031-1/+6
* Merge branch 'master' of github.com:matrix-org/synapse into release-v0.2.0Erik Johnston2014-09-021-2/+19
|\
| * When notifying listeners, don't do so in a serial fashionErik Johnston2014-08-291-2/+19
* | Have EventSource's get_new_events_for_user() API work only on keys within tha...Paul "LeoNerd" Evans2014-08-291-10/+20
|/
* Turn of trace_function loggingErik Johnston2014-08-281-2/+2
* And more logging.Erik Johnston2014-08-281-1/+2
* If timeout=0, return immediatelyErik Johnston2014-08-271-1/+5
* Comments!Erik Johnston2014-08-271-0/+35
* Index sources in a nicer fashion.Erik Johnston2014-08-271-3/+3
* Implement presence event source. Change the way the notifier indexes listenersErik Johnston2014-08-271-43/+42
* Enable presence again. Fix up api to match old api.Erik Johnston2014-08-261-1/+19
* WIP: Completely change how event streaming and pagination work. This reflects...Erik Johnston2014-08-261-0/+184