diff options
| author | Erik Johnston <erik@matrix.org> | 2021-04-28 14:43:10 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2021-04-28 14:43:10 +0100 |
| commit | 802560211ae0472cb54e643089b039cc077d4ab0 (patch) | |
| tree | 428dd0039a908eba510984a087d00a44475aed31 /tests/handlers/test_presence.py | |
| parent | Use the parent's logging context name for runWithConnection. (#9895) (diff) | |
| parent | Fix tight loop handling presence replication. (#9900) (diff) | |
| download | synapse-802560211ae0472cb54e643089b039cc077d4ab0.tar.xz | |
Merge remote-tracking branch 'origin/release-v1.33.0' into develop
Diffstat (limited to 'tests/handlers/test_presence.py')
| -rw-r--r-- | tests/handlers/test_presence.py | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/tests/handlers/test_presence.py b/tests/handlers/test_presence.py index 61271cd084..ce330e79cc 100644 --- a/tests/handlers/test_presence.py +++ b/tests/handlers/test_presence.py @@ -509,6 +509,14 @@ class PresenceFederationQueueTestCase(unittest.HomeserverTestCase): self.assertCountEqual(rows, expected_rows) + now_token = self.queue.get_current_token(self.instance_name) + rows, upto_token, limited = self.get_success( + self.queue.get_replication_rows("master", upto_token, now_token, 10) + ) + self.assertEqual(upto_token, now_token) + self.assertFalse(limited) + self.assertCountEqual(rows, []) + def test_send_and_get_split(self): state1 = UserPresenceState.default("@user1:test") state2 = UserPresenceState.default("@user2:test") @@ -538,6 +546,20 @@ class PresenceFederationQueueTestCase(unittest.HomeserverTestCase): self.assertCountEqual(rows, expected_rows) + now_token = self.queue.get_current_token(self.instance_name) + rows, upto_token, limited = self.get_success( + self.queue.get_replication_rows("master", upto_token, now_token, 10) + ) + + self.assertEqual(upto_token, now_token) + self.assertFalse(limited) + + expected_rows = [ + (2, ("dest3", "@user3:test")), + ] + + self.assertCountEqual(rows, expected_rows) + def test_clear_queue_all(self): state1 = UserPresenceState.default("@user1:test") state2 = UserPresenceState.default("@user2:test") |