···104104 let cursor_did: Option<Did> = params.cursor.as_ref().and_then(|s| s.parse().ok());
105105 let cursor_ref = cursor_did.as_ref();
106106 let result = state
107107- .repos.repo
107107+ .repos
108108+ .repo
108109 .list_repos_paginated(cursor_ref, limit + 1)
109110 .await;
110111 match result {
+10-5
crates/tranquil-sync/src/listener.rs
···8899pub async fn start_sequencer_listener(state: AppState) {
1010 let initial_seq = state
1111- .repos.repo
1111+ .repos
1212+ .repo
1213 .get_max_seq()
1314 .await
1415 .unwrap_or(SequenceNumber::ZERO);
···30313132async fn listen_loop(state: AppState) -> anyhow::Result<()> {
3233 let mut receiver = state
3333- .repos.event_notifier
3434+ .repos
3535+ .event_notifier
3436 .subscribe()
3537 .await
3638 .map_err(|e| anyhow::anyhow!("Failed to subscribe to events: {:?}", e))?;
3739 info!("Connected to database and listening for repo updates");
3840 let catchup_start = SequenceNumber::from_raw(LAST_BROADCAST_SEQ.load(Ordering::SeqCst));
3941 let events = state
4040- .repos.repo
4242+ .repos
4343+ .repo
4144 .get_events_since_seq(catchup_start, None)
4245 .await
4346 .map_err(|e| anyhow::anyhow!("Failed to fetch catchup events: {:?}", e))?;
···7073 }
7174 if seq_id > last_seq + 1 {
7275 let gap_events = state
7373- .repos.repo
7676+ .repos
7777+ .repo
7478 .get_events_in_seq_range(
7579 SequenceNumber::from_raw(last_seq),
7680 SequenceNumber::from_raw(seq_id),
···8892 }
8993 }
9094 let event = state
9191- .repos.repo
9595+ .repos
9696+ .repo
9297 .get_event_by_seq(SequenceNumber::from_raw(seq_id))
9398 .await
9499 .ok()
+2-1
crates/tranquil-sync/src/repo.rs
···179179 };
180180181181 let block_cid_bytes = match state
182182- .repos.repo
182182+ .repos
183183+ .repo
183184 .get_user_block_cids_since_rev(user_id, since)
184185 .await
185186 {