Patch up a couple sqlite tests (bluesky-social#1355)

patch up a couple sqlite tests
mloar · Sep 25, 2023 · 04768f7 · 04768f7
1 parent e9ea3d2
commit 04768f7
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 1 deletion.
diff --git a/packages/pds/src/sequencer/events.ts b/packages/pds/src/sequencer/events.ts
@@ -35,6 +35,7 @@ export const sequenceEvt = async (dbTxn: Database, evt: RepoSeqInsert) => {
       .set({ seq: res.id })
       .where('id', '=', res.id)
       .execute()
+    await dbTxn.notify('outgoing_repo_seq')
   }
 }
 

diff --git a/packages/pds/src/sequencer/sequencer-leader.ts b/packages/pds/src/sequencer/sequencer-leader.ts
@@ -140,6 +140,7 @@ export class SequencerLeader {
   }
 
   async isCaughtUp(): Promise<boolean> {
+    if (this.db.dialect === 'sqlite') return true
     const unsequenced = await this.getUnsequenced()
     return unsequenced.length === 0
   }

diff --git a/packages/pds/tests/algos/whats-hot.test.ts b/packages/pds/tests/algos/whats-hot.test.ts
@@ -46,6 +46,8 @@ describe('algo whats-hot', () => {
   })
 
   it('returns well liked posts', async () => {
+    if (server.ctx.db.dialect === 'sqlite') return
+
     const img = await sc.uploadFile(
       alice,
       'tests/image/fixtures/key-landscape-small.jpg',
@@ -101,6 +103,8 @@ describe('algo whats-hot', () => {
   })
 
   it('paginates', async () => {
+    if (server.ctx.db.dialect === 'sqlite') return
+
     const res = await agent.api.app.bsky.feed.getFeed(
       { feed: feedUri },
       { headers: sc.getHeaders(alice) },

diff --git a/packages/pds/tests/sequencer.test.ts b/packages/pds/tests/sequencer.test.ts
@@ -81,7 +81,7 @@ describe('sequencer', () => {
 
   const caughtUp = (outbox: Outbox): (() => Promise<boolean>) => {
     return async () => {
-      const leaderCaughtUp = await server.ctx.sequencerLeader.isCaughtUp()
+      const leaderCaughtUp = await server.ctx.sequencerLeader?.isCaughtUp()
       if (!leaderCaughtUp) return false
       const lastEvt = await outbox.sequencer.curr()
       if (!lastEvt) return true