Push along reactor position to prevent default event timestamp 0

Author: Fizzadar

tests/replication/slave/storage/test_receipts.py

@@ -29,6 +29,8 @@ class SlavedReceiptTestCase(BaseSlavedStoreTestCase):
     STORE_TYPE = SlavedReceiptsStore
 
     def prepare(self, reactor, clock, homeserver):
+        self.clock._reactor.advance(1)
+
         super().prepare(reactor, clock, homeserver)
         self.room_creator = homeserver.get_room_creation_handler()
         self.persist_event_storage_controller = (

tests/server_notices/test_resource_limits_server_notices.py

@@ -53,6 +53,8 @@ def default_config(self):
         return config
 
     def prepare(self, reactor, clock, hs):
+        self.clock._reactor.advance(1)
+
         self.server_notices_sender = self.hs.get_server_notices_sender()
 
         # relying on [1] is far from ideal, but the only case where
@@ -246,6 +248,8 @@ def default_config(self):
         return c
 
     def prepare(self, reactor, clock, hs):
+        self.clock._reactor.advance(1)
+
         self.store = self.hs.get_datastores().main
         self.server_notices_sender = self.hs.get_server_notices_sender()
         self.server_notices_manager = self.hs.get_server_notices_manager()

tests/storage/test_cleanup_extrems.py

@@ -30,6 +30,7 @@ class CleanupExtremBackgroundUpdateStoreTestCase(HomeserverTestCase):
     """
 
     def prepare(self, reactor, clock, homeserver):
+        self.clock._reactor.advance(1)
         self.store = homeserver.get_datastores().main
         self.room_creator = homeserver.get_room_creation_handler()
 

tests/storage/test_event_metrics.py

@@ -19,6 +19,9 @@
 
 
 class ExtremStatisticsTestCase(HomeserverTestCase):
+    def prepare(self, reactor, clock, hs):
+        self.clock._reactor.advance(1)
+
     def test_exposed_to_prometheus(self):
         """
         Forward extremity counts are exposed via Prometheus.

tests/storage/test_redaction.py

@@ -30,6 +30,7 @@ def default_config(self):
         return config
 
     def prepare(self, reactor, clock, hs):
+        self.clock._reactor.advance(1)
         self.store = hs.get_datastores().main
         self._storage = hs.get_storage_controllers()
         self.event_builder_factory = hs.get_event_builder_factory()

tests/storage/test_roommember.py

@@ -47,6 +47,8 @@ def prepare(self, reactor: MemoryReactor, clock: Clock, hs: TestHomeServer) -> N
         # User elsewhere on another host
         self.u_charlie = UserID.from_string("@charlie:elsewhere")
 
+        self.clock._reactor.advance(1)
+
     def test_one_member(self) -> None:
 
         # Alice creates the room, and is automatically joined
@@ -218,6 +220,8 @@ def prepare(self, reactor: MemoryReactor, clock: Clock, hs: HomeServer) -> None:
         self.store = hs.get_datastores().main
         self.room_creator = hs.get_room_creation_handler()
 
+        self.clock._reactor.advance(1)
+
     def test_can_rerun_update(self) -> None:
         # First make sure we have completed all updates.
         self.wait_for_background_updates()

tests/storage/test_state.py

@@ -48,6 +48,8 @@ def prepare(self, reactor, clock, hs):
             )
         )
 
+        self.clock._reactor.advance(1)
+
     def inject_state_event(self, room, sender, typ, state_key, content):
         builder = self.event_builder_factory.for_room_version(
             RoomVersions.V1,

tests/test_federation.py

@@ -36,6 +36,7 @@ def setUp(self):
         self.http_client = Mock()
         self.reactor = ThreadedMemoryReactorClock()
         self.hs_clock = Clock(self.reactor)
+        self.reactor.advance(1)
         self.homeserver = setup_test_homeserver(
             self.addCleanup,
             federation_http_client=self.http_client,

tests/test_visibility.py

@@ -35,6 +35,7 @@ def setUp(self) -> None:
         self.event_creation_handler = self.hs.get_event_creation_handler()
         self.event_builder_factory = self.hs.get_event_builder_factory()
         self._storage_controllers = self.hs.get_storage_controllers()
+        self.clock._reactor.advance(1)
 
         self.get_success(create_room(self.hs, TEST_ROOM_ID, "@someone:ROOM"))
 
@@ -258,6 +259,10 @@ def _inject_outlier(self) -> EventBase:
 
 
 class FilterEventsForClientTestCase(unittest.FederatingHomeserverTestCase):
+    def setUp(self) -> None:
+        super(FilterEventsForClientTestCase, self).setUp()
+        self.clock._reactor.advance(1)
+
     def test_out_of_band_invite_rejection(self):
         # this is where we have received an invite event over federation, and then
         # rejected it.