diff --git a/packages/pds/src/sequencer/events.ts b/packages/pds/src/sequencer/events.ts index 75b5263e700..fc6e98729cd 100644 --- 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 index 32964243f2e..fab3a3b4602 100644 --- 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 { + 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 index 08d9f1a1b82..0b0a292c530 100644 --- 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 index dab71fba74d..c41cedafb58 100644 --- 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) => { 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