Update old references to get_new_messages_for_device

anoadragon453 · anoadragon453 · commit 25488fa88092 · 2022-01-25T18:00:39.000Z
diff --git a/synapse/handlers/appservice.py b/synapse/handlers/appservice.py
@@ -510,7 +510,7 @@ async def _get_to_device_messages(
             return []
 
         # Retrieve the to-device messages for each user
-        recipient_device_to_messages = await self.store.get_new_messages(
+        recipient_device_to_messages = await self.store.get_messages_for_user_devices(
             users_appservice_is_interested_in,
             from_key,
             new_token,
diff --git a/synapse/handlers/sync.py b/synapse/handlers/sync.py
@@ -1336,7 +1336,7 @@ async def _generate_sync_entry_for_to_device(
             since_stream_id = int(sync_result_builder.since_token.to_device_key)
 
         if since_stream_id != int(now_token.to_device_key):
-            messages, stream_id = await self.store.get_new_messages_for_device(
+            messages, stream_id = await self.store.get_messages_for_device(
                 user_id, device_id, since_stream_id, now_token.to_device_key
             )
 

Original file line number	Diff line number	Diff line change
`@@ -1336,7 +1336,7 @@ async def _generate_sync_entry_for_to_device(`
`1336`	`1336`	`since_stream_id = int(sync_result_builder.since_token.to_device_key)`
`1337`	`1337`
`1338`	`1338`	`if since_stream_id != int(now_token.to_device_key):`
`1339`		`- messages, stream_id = await self.store.get_new_messages_for_device(`
	`1339`	`+ messages, stream_id = await self.store.get_messages_for_device(`
`1340`	`1340`	`user_id, device_id, since_stream_id, now_token.to_device_key`
`1341`	`1341`	`)`
`1342`	`1342`