mirror of
https://git.anonymousland.org/anonymousland/synapse-product.git
synced 2024-12-25 04:59:23 -05:00
Merge branch 'release-v0.19.1' of github.com:matrix-org/synapse
This commit is contained in:
commit
27c005ae2c
@ -1,3 +1,10 @@
|
|||||||
|
Changes in synapse v0.19.1 (2017-02-09)
|
||||||
|
=======================================
|
||||||
|
|
||||||
|
* Fix bug where state was incorrectly reset in a room when synapse received an
|
||||||
|
event over federation that did not pass auth checks (PR #1892)
|
||||||
|
|
||||||
|
|
||||||
Changes in synapse v0.19.0 (2017-02-04)
|
Changes in synapse v0.19.0 (2017-02-04)
|
||||||
=======================================
|
=======================================
|
||||||
|
|
||||||
|
@ -16,4 +16,4 @@
|
|||||||
""" This is a reference implementation of a Matrix home server.
|
""" This is a reference implementation of a Matrix home server.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
__version__ = "0.19.0"
|
__version__ = "0.19.1"
|
||||||
|
@ -302,7 +302,7 @@ class EventsStore(SQLBaseStore):
|
|||||||
room_id
|
room_id
|
||||||
)
|
)
|
||||||
new_latest_event_ids = yield self._calculate_new_extremeties(
|
new_latest_event_ids = yield self._calculate_new_extremeties(
|
||||||
room_id, [ev for ev, _ in ev_ctx_rm]
|
room_id, ev_ctx_rm, latest_event_ids
|
||||||
)
|
)
|
||||||
|
|
||||||
if new_latest_event_ids == set(latest_event_ids):
|
if new_latest_event_ids == set(latest_event_ids):
|
||||||
@ -329,27 +329,24 @@ class EventsStore(SQLBaseStore):
|
|||||||
persist_event_counter.inc_by(len(chunk))
|
persist_event_counter.inc_by(len(chunk))
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def _calculate_new_extremeties(self, room_id, events):
|
def _calculate_new_extremeties(self, room_id, event_contexts, latest_event_ids):
|
||||||
"""Calculates the new forward extremeties for a room given events to
|
"""Calculates the new forward extremeties for a room given events to
|
||||||
persist.
|
persist.
|
||||||
|
|
||||||
Assumes that we are only persisting events for one room at a time.
|
Assumes that we are only persisting events for one room at a time.
|
||||||
"""
|
"""
|
||||||
latest_event_ids = yield self.get_latest_event_ids_in_room(
|
|
||||||
room_id
|
|
||||||
)
|
|
||||||
new_latest_event_ids = set(latest_event_ids)
|
new_latest_event_ids = set(latest_event_ids)
|
||||||
# First, add all the new events to the list
|
# First, add all the new events to the list
|
||||||
new_latest_event_ids.update(
|
new_latest_event_ids.update(
|
||||||
event.event_id for event in events
|
event.event_id for event, ctx in event_contexts
|
||||||
if not event.internal_metadata.is_outlier()
|
if not event.internal_metadata.is_outlier() and not ctx.rejected
|
||||||
)
|
)
|
||||||
# Now remove all events that are referenced by the to-be-added events
|
# Now remove all events that are referenced by the to-be-added events
|
||||||
new_latest_event_ids.difference_update(
|
new_latest_event_ids.difference_update(
|
||||||
e_id
|
e_id
|
||||||
for event in events
|
for event, ctx in event_contexts
|
||||||
for e_id, _ in event.prev_events
|
for e_id, _ in event.prev_events
|
||||||
if not event.internal_metadata.is_outlier()
|
if not event.internal_metadata.is_outlier() and not ctx.rejected
|
||||||
)
|
)
|
||||||
|
|
||||||
# And finally remove any events that are referenced by previously added
|
# And finally remove any events that are referenced by previously added
|
||||||
|
Loading…
Reference in New Issue
Block a user