Permalink
Browse files

Fix AS retries, but with correct ordering

  • Loading branch information...
1 parent 310197b commit 84379062f9ec259abc302af321d4ed8f5a958c01 @erikjohnston erikjohnston committed Jun 7, 2016
Showing with 6 additions and 6 deletions.
  1. +2 −2 synapse/storage/appservice.py
  2. +4 −4 tests/storage/test_appservice.py
@@ -320,10 +320,10 @@ def get_oldest_unsent_txn(self, service):
event_ids = json.loads(entry["event_ids"])
- event_map = yield self.get_events(event_ids)
+ events = yield self._get_events(event_ids)
defer.returnValue(AppServiceTransaction(
- service=service, id=entry["txn_id"], events=event_map.values()
+ service=service, id=entry["txn_id"], events=events
))
def _get_oldest_unsent_txn(self, txn, service):
@@ -353,21 +353,21 @@ def test_get_oldest_unsent_txn_none(self):
@defer.inlineCallbacks
def test_get_oldest_unsent_txn(self):
service = Mock(id=self.as_list[0]["id"])
- events = {"e1": Mock(event_id="e1"), "e2": Mock(event_id="e2")}
+ events = [Mock(event_id="e1"), Mock(event_id="e2")]
other_events = [Mock(event_id="e5"), Mock(event_id="e6")]
# we aren't testing store._base stuff here, so mock this out
- self.store.get_events = Mock(return_value=events)
+ self.store._get_events = Mock(return_value=events)
yield self._insert_txn(self.as_list[1]["id"], 9, other_events)
- yield self._insert_txn(service.id, 10, events.values())
+ yield self._insert_txn(service.id, 10, events)
yield self._insert_txn(service.id, 11, other_events)
yield self._insert_txn(service.id, 12, other_events)
txn = yield self.store.get_oldest_unsent_txn(service)
self.assertEquals(service, txn.service)
self.assertEquals(10, txn.id)
- self.assertEquals(events.values(), txn.events)
+ self.assertEquals(events, txn.events)
@defer.inlineCallbacks
def test_get_appservices_by_state_single(self):

0 comments on commit 8437906

Please sign in to comment.