Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2025-02-05 16:55:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

Update some of the docs in event_federation

Browse Source
This commit is contained in:
Erik Johnston 2014-11-12 15:02:31 +00:00
parent 813125e122
commit e715741abc
1 changed files with 20 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
synapse/storage/event_federation.py
View File

@ -23,6 +23,14 @@ logger = logging.getLogger(__name__)
class EventFederationStore(SQLBaseStore): class EventFederationStore(SQLBaseStore):
""" Responsible for storing and serving up the various graphs associated
with an event. Including the main event graph and the auth chains for an
event.
Also has methods for getting the front (latest) and back (oldest) edges
of the event graphs. These are used to generate the parents for new events
and backfilling from another server respectively.
"""
def get_auth_chain(self, event_id): def get_auth_chain(self, event_id):
return self.runInteraction( return self.runInteraction(
@ -205,6 +213,8 @@ class EventFederationStore(SQLBaseStore):
return results return results
def get_min_depth(self, room_id): def get_min_depth(self, room_id):
""" For hte given room, get the minimum depth we have seen for it.
"""
return self.runInteraction( return self.runInteraction(
"get_min_depth", "get_min_depth",
self._get_min_depth_interaction, self._get_min_depth_interaction,
@ -240,6 +250,10 @@ class EventFederationStore(SQLBaseStore):
def _handle_prev_events(self, txn, outlier, event_id, prev_events, def _handle_prev_events(self, txn, outlier, event_id, prev_events,
room_id): room_id):
"""
For the given event, update the event edges table and forward and
backward extremities tables.
"""
for e_id, _ in prev_events: for e_id, _ in prev_events:
# TODO (erikj): This could be done as a bulk insert # TODO (erikj): This could be done as a bulk insert
self._simple_insert_txn( self._simple_insert_txn(
@ -267,8 +281,8 @@ class EventFederationStore(SQLBaseStore):
} }
) )
# We only insert as a forward extremity the new pdu if there are # We only insert as a forward extremity the new event if there are
# no other pdus that reference it as a prev pdu # no other events that reference it as a prev event
query = ( query = (
"INSERT OR IGNORE INTO %(table)s (event_id, room_id) " "INSERT OR IGNORE INTO %(table)s (event_id, room_id) "
"SELECT ?, ? WHERE NOT EXISTS (" "SELECT ?, ? WHERE NOT EXISTS ("
@ -284,7 +298,7 @@ class EventFederationStore(SQLBaseStore):
txn.execute(query, (event_id, room_id, event_id)) txn.execute(query, (event_id, room_id, event_id))
# Insert all the prev_pdus as a backwards thing, they'll get # Insert all the prev_events as a backwards thing, they'll get
# deleted in a second if they're incorrect anyway. # deleted in a second if they're incorrect anyway.
for e_id, _ in prev_events: for e_id, _ in prev_events:
# TODO (erikj): This could be done as a bulk insert # TODO (erikj): This could be done as a bulk insert
@ -299,7 +313,7 @@ class EventFederationStore(SQLBaseStore):
) )
# Also delete from the backwards extremities table all ones that # Also delete from the backwards extremities table all ones that
# reference pdus that we have already seen # reference events that we have already seen
query = ( query = (
"DELETE FROM event_backward_extremities WHERE EXISTS (" "DELETE FROM event_backward_extremities WHERE EXISTS ("
"SELECT 1 FROM events " "SELECT 1 FROM events "
@ -311,17 +325,14 @@ class EventFederationStore(SQLBaseStore):
txn.execute(query) txn.execute(query)
def get_backfill_events(self, room_id, event_list, limit): def get_backfill_events(self, room_id, event_list, limit):
"""Get a list of Events for a given topic that occured before (and """Get a list of Events for a given topic that occurred before (and
including) the pdus in pdu_list. Return a list of max size `limit`. including) the events in event_list. Return a list of max size `limit`
Args: Args:
txn txn
room_id (str) room_id (str)
event_list (list) event_list (list)
limit (int) limit (int)
Return:
list: A list of PduTuples
""" """
return self.runInteraction( return self.runInteraction(
"get_backfill_events", "get_backfill_events",
@ -334,7 +345,6 @@ class EventFederationStore(SQLBaseStore):
room_id, repr(event_list), limit room_id, repr(event_list), limit
) )
# We seed the pdu_results with the things from the pdu_list.
event_results = event_list event_results = event_list
front = event_list front = event_list
@ -373,5 +383,4 @@ class EventFederationStore(SQLBaseStore):
front = new_front front = new_front
event_results += new_front event_results += new_front
# We also want to update the `prev_pdus` attributes before returning.
return self._get_events_txn(txn, event_results) return self._get_events_txn(txn, event_results)