make tests

bluesky-social · Oct 4, 2023 · 9de92a8 · 9de92a8
1 parent 2ee83f9
commit 9de92a8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/packages/pds/src/api/com/atproto/sync/subscribeRepos.ts b/packages/pds/src/api/com/atproto/sync/subscribeRepos.ts
@@ -31,7 +31,7 @@ export default function (server: Server, ctx: AppContext) {
           message: 'Requested cursor exceeded limit. Possibly missing events',
         }
         const startEvt = await ctx.sequencer.earliestAfterTime(backfillTime)
-        outboxCursor = startEvt?.seq ?? undefined
+        outboxCursor = startEvt?.seq ? startEvt.seq - 1 : undefined
       } else {
         outboxCursor = cursor
       }

diff --git a/packages/pds/src/sequencer/sequencer.ts b/packages/pds/src/sequencer/sequencer.ts
@@ -60,9 +60,9 @@ export class Sequencer extends (EventEmitter as new () => SequencerEmitter) {
       .selectFrom('repo_seq')
       .selectAll()
       .where('seq', 'is not', null)
-      .where('sequencedAt', '>', time)
+      .where('sequencedAt', '>=', time)
+      .orderBy('sequencedAt', 'asc')
       .limit(1)
-      .orderBy('sequencedAt', 'desc')
       .executeTakeFirst()
     return got || null
   }