Some marker event implemntation trials

This commit is contained in:
Eric Eastwood 2021-07-14 01:24:13 -05:00
parent 66cf5beaf3
commit ab8011bb5d
3 changed files with 17 additions and 6 deletions

View File

@ -65,4 +65,4 @@ if [[ -n "$1" ]]; then
fi fi
# Run the tests! # Run the tests!
go test -v -tags synapse_blacklist,msc2946,msc3083,msc2716,msc2403 -count=1 $EXTRA_COMPLEMENT_ARGS ./tests -run TestBackfillingHistory go test -v -tags synapse_blacklist,msc2946,msc3083,msc2716,msc2403 -count=1 $EXTRA_COMPLEMENT_ARGS ./tests -run TestBackfillingHistory/parallel/Historical_messages_are_visible_when_already_joined_on_federated_server

View File

@ -196,9 +196,6 @@ class EventContentFields:
MSC2716_CHUNK_ID = "org.matrix.msc2716.chunk_id" MSC2716_CHUNK_ID = "org.matrix.msc2716.chunk_id"
# For "marker" events # For "marker" events
MSC2716_MARKER_INSERTION = "org.matrix.msc2716.marker.insertion" MSC2716_MARKER_INSERTION = "org.matrix.msc2716.marker.insertion"
MSC2716_MARKER_INSERTION_PREV_EVENTS = (
"org.matrix.msc2716.marker.insertion_prev_events"
)
class RoomTypes: class RoomTypes:

View File

@ -1819,10 +1819,24 @@ class PersistEventsStore:
# TODO: We should attempt to backfill the insertion event instead # TODO: We should attempt to backfill the insertion event instead
# of trying to pack all of the info in the marker event. Otherwise, # of trying to pack all of the info in the marker event. Otherwise,
# we need to pack in the insertion_prev_events and insertion_next_chunk_id. # we need to pack in the insertion_prev_events and insertion_next_chunk_id.
# GET /_matrix/federation/v1/event/{eventId}
# insertion_event_id = event.content.get( insertion_event_id = event.content.get(
# EventContentFields.MSC2716_MARKER_INSERTION EventContentFields.MSC2716_MARKER_INSERTION
)
# We will trust that the application service sending the marker event is
# also the one that knows about the insertion event
# insertion_event_origin = get_domain_from_id(event.sender)
# m_ev = await self.federation_client.get_event(
# [insertion_event_origin],
# insertion_event_id,
# outlier=True,
# timeout=10000,
# ) # )
# _auth_and_persist_events
# handle_new_client_event
# insertion_prev_event_ids = event.content.get( # insertion_prev_event_ids = event.content.get(
# EventContentFields.MSC2716_MARKER_INSERTION_PREV_EVENTS # EventContentFields.MSC2716_MARKER_INSERTION_PREV_EVENTS
# ) # )