fixup! Add SynapseReader support for access tokens and refresh tokens

Author: sandhose

crates/syn2mas/src/synapse_reader/fixtures/access_token_alice_with_unused_refresh_token.sql

@@ -0,0 +1,56 @@
+INSERT INTO access_tokens
+  (
+  id,
+  user_id,
+  device_id,
+  token,
+  refresh_token_id,
+  used
+  )
+  VALUES
+  (
+    42,
+    '@alice:example.com',
+    'ADEVICE',
+    'syt_aaaaaaaaaaaaaa_aaaa',
+    7,
+    TRUE
+  ),
+  (
+    43,
+    '@alice:example.com',
+    'ADEVICE',
+    'syt_AAAAAAAAAAAAAA_AAAA',
+    8,
+    FALSE
+  );
+
+INSERT INTO refresh_tokens
+  (
+  id,
+  user_id,
+  device_id,
+  token,
+  next_token_id,
+  expiry_ts,
+  ultimate_session_expiry_ts
+  )
+  VALUES
+  (
+    7,
+    '@alice:example.com',
+    'ADEVICE',
+    'syr_bbbbbbbbbbbbb_bbbb',
+    8,
+    1738096199000,
+    1778096199000
+  ),
+  (
+    8,
+    '@alice:example.com',
+    'ADEVICE',
+    'syr_cccccccccccc_cccc',
+    NULL,
+    1748096199000,
+    1778096199000
+  );

crates/syn2mas/src/synapse_reader/mod.rs

@@ -608,4 +608,33 @@ mod test {
         );
         assert_debug_snapshot!(refresh_tokens);
     }
+
+    #[sqlx::test(
+        migrator = "MIGRATOR",
+        fixtures("user_alice", "access_token_alice_with_unused_refresh_token")
+    )]
+    async fn test_read_access_and_unused_refresh_tokens(pool: PgPool) {
+        let mut conn = pool.acquire().await.expect("failed to get connection");
+        let mut reader = SynapseReader::new(&mut conn, false)
+            .await
+            .expect("failed to make SynapseReader");
+
+        let access_tokens: BTreeSet<SynapseAccessToken> = reader
+            .read_unrefreshable_access_tokens()
+            .try_collect()
+            .await
+            .expect("failed to read Synapse access tokens");
+
+        let refresh_tokens: BTreeSet<SynapseRefreshableTokenPair> = reader
+            .read_refreshable_token_pairs()
+            .try_collect()
+            .await
+            .expect("failed to read Synapse refresh tokens");
+
+        assert!(
+            access_tokens.is_empty(),
+            "there are no unrefreshable access tokens"
+        );
+        assert_debug_snapshot!(refresh_tokens);
+    }
 }

crates/syn2mas/src/synapse_reader/snapshots/syn2mas__synapse_reader__test__read_access_and_unused_refresh_tokens.snap

@@ -0,0 +1,26 @@
+---
+source: crates/syn2mas/src/synapse_reader/mod.rs
+expression: refresh_tokens
+---
+{
+    SynapseRefreshableTokenPair {
+        user_id: FullUserId(
+            "@alice:example.com",
+        ),
+        device_id: "ADEVICE",
+        access_token: "syt_AAAAAAAAAAAAAA_AAAA",
+        refresh_token: "syr_cccccccccccc_cccc",
+        valid_until_ms: None,
+        last_validated: None,
+    },
+    SynapseRefreshableTokenPair {
+        user_id: FullUserId(
+            "@alice:example.com",
+        ),
+        device_id: "ADEVICE",
+        access_token: "syt_aaaaaaaaaaaaaa_aaaa",
+        refresh_token: "syr_bbbbbbbbbbbbb_bbbb",
+        valid_until_ms: None,
+        last_validated: None,
+    },
+}