kwargify ints

Author: reivilibre

synapse/storage/databases/main/thread_subscriptions.py

@@ -439,7 +439,7 @@ def get_max_thread_subscriptions_stream_id(self) -> int:
         return self._thread_subscriptions_id_gen.get_current_token()
 
     async def get_updated_thread_subscriptions(
-        self, from_id: int, to_id: int, limit: int
+        self, *, from_id: int, to_id: int, limit: int
     ) -> List[Tuple[int, str, str, str]]:
         """Get updates to thread subscriptions between two stream IDs.
 
@@ -472,7 +472,7 @@ def get_updated_thread_subscriptions_txn(
         )
 
     async def get_updated_thread_subscriptions_for_user(
-        self, user_id: str, from_id: int, to_id: int, limit: int
+        self, user_id: str, *, from_id: int, to_id: int, limit: int
     ) -> List[Tuple[int, str, str]]:
         """Get updates to thread subscriptions for a specific user.
 

tests/storage/test_thread_subscriptions.py

@@ -240,13 +240,17 @@ def test_get_updated_thread_subscriptions(self) -> None:
 
         # Get updates since initial ID (should include both changes)
         updates = self.get_success(
-            self.store.get_updated_thread_subscriptions(0, stream_id2, 10)
+            self.store.get_updated_thread_subscriptions(
+                from_id=0, to_id=stream_id2, limit=10
+            )
         )
         self.assertEqual(len(updates), 2)
 
         # Get updates since first change (should include only the second change)
         updates = self.get_success(
-            self.store.get_updated_thread_subscriptions(stream_id1, stream_id2, 10)
+            self.store.get_updated_thread_subscriptions(
+                from_id=stream_id1, to_id=stream_id2, limit=10
+            )
         )
         self.assertEqual(
             updates,
@@ -278,15 +282,15 @@ def test_get_updated_thread_subscriptions_for_user(self) -> None:
         # Get updates for main user
         updates = self.get_success(
             self.store.get_updated_thread_subscriptions_for_user(
-                self.user_id, 0, stream_id2, 10
+                self.user_id, from_id=0, to_id=stream_id2, limit=10
             )
         )
         self.assertEqual(updates, [(stream_id1, self.room_id, self.thread_root_id)])
 
         # Get updates for other user
         updates = self.get_success(
             self.store.get_updated_thread_subscriptions_for_user(
-                other_user_id, 0, max(stream_id1, stream_id2), 10
+                other_user_id, from_id=0, to_id=max(stream_id1, stream_id2), limit=10
             )
         )
         self.assertEqual(