|
|
|
@ -62,7 +62,6 @@ class RelationsWorkerStore(SQLBaseStore): |
|
|
|
|
room_id: str, |
|
|
|
|
relation_type: Optional[str] = None, |
|
|
|
|
event_type: Optional[str] = None, |
|
|
|
|
aggregation_key: Optional[str] = None, |
|
|
|
|
limit: int = 5, |
|
|
|
|
direction: str = "b", |
|
|
|
|
from_token: Optional[StreamToken] = None, |
|
|
|
@ -76,7 +75,6 @@ class RelationsWorkerStore(SQLBaseStore): |
|
|
|
|
room_id: The room the event belongs to. |
|
|
|
|
relation_type: Only fetch events with this relation type, if given. |
|
|
|
|
event_type: Only fetch events with this event type, if given. |
|
|
|
|
aggregation_key: Only fetch events with this aggregation key, if given. |
|
|
|
|
limit: Only fetch the most recent `limit` events. |
|
|
|
|
direction: Whether to fetch the most recent first (`"b"`) or the |
|
|
|
|
oldest first (`"f"`). |
|
|
|
@ -105,10 +103,6 @@ class RelationsWorkerStore(SQLBaseStore): |
|
|
|
|
where_clause.append("type = ?") |
|
|
|
|
where_args.append(event_type) |
|
|
|
|
|
|
|
|
|
if aggregation_key: |
|
|
|
|
where_clause.append("aggregation_key = ?") |
|
|
|
|
where_args.append(aggregation_key) |
|
|
|
|
|
|
|
|
|
pagination_clause = generate_pagination_where_clause( |
|
|
|
|
direction=direction, |
|
|
|
|
column_names=("topological_ordering", "stream_ordering"), |
|
|
|
|