diff options
author | Andrej Shadura <andrewsh@debian.org> | 2021-12-14 17:36:00 +0100 |
---|---|---|
committer | Andrej Shadura <andrewsh@debian.org> | 2021-12-14 17:36:00 +0100 |
commit | e894f36b081e694a99c1829d05a2382edd8c4533 (patch) | |
tree | 094399067207ada06f538d472bf44b608e984cac /synapse/storage/databases/main/event_push_actions.py | |
parent | 7eba982950257d89142cd5a793320be25c5d669a (diff) |
New upstream version 1.49.0
Diffstat (limited to 'synapse/storage/databases/main/event_push_actions.py')
-rw-r--r-- | synapse/storage/databases/main/event_push_actions.py | 19 |
1 files changed, 17 insertions, 2 deletions
diff --git a/synapse/storage/databases/main/event_push_actions.py b/synapse/storage/databases/main/event_push_actions.py index d957e770..3efdd0c9 100644 --- a/synapse/storage/databases/main/event_push_actions.py +++ b/synapse/storage/databases/main/event_push_actions.py @@ -16,6 +16,7 @@ import logging from typing import TYPE_CHECKING, Dict, List, Optional, Tuple, Union import attr +from typing_extensions import TypedDict from synapse.metrics.background_process_metrics import wrap_as_background_process from synapse.storage._base import SQLBaseStore, db_to_json @@ -37,6 +38,20 @@ DEFAULT_HIGHLIGHT_ACTION = [ ] +class BasePushAction(TypedDict): + event_id: str + actions: List[Union[dict, str]] + + +class HttpPushAction(BasePushAction): + room_id: str + stream_ordering: int + + +class EmailPushAction(HttpPushAction): + received_ts: Optional[int] + + def _serialize_action(actions, is_highlight): """Custom serializer for actions. This allows us to "compress" common actions. @@ -221,7 +236,7 @@ class EventPushActionsWorkerStore(SQLBaseStore): min_stream_ordering: int, max_stream_ordering: int, limit: int = 20, - ) -> List[dict]: + ) -> List[HttpPushAction]: """Get a list of the most recent unread push actions for a given user, within the given stream ordering range. Called by the httppusher. @@ -326,7 +341,7 @@ class EventPushActionsWorkerStore(SQLBaseStore): min_stream_ordering: int, max_stream_ordering: int, limit: int = 20, - ) -> List[dict]: + ) -> List[EmailPushAction]: """Get a list of the most recent unread push actions for a given user, within the given stream ordering range. Called by the emailpusher |