diff --git a/packages/ingest/test/poller.test.mjs b/packages/ingest/test/poller.test.mjs index f640e8e..d2ecca4 100644 --- a/packages/ingest/test/poller.test.mjs +++ b/packages/ingest/test/poller.test.mjs @@ -1,5 +1,6 @@ import assert from 'node:assert/strict' import { describe, it } from 'node:test' +import { radialCollections } from '../../atproto/dist/index.js' import { COLLECTIONS, MemoryRecordStore } from '../../core/dist/index.js' import { MemorySyncStateStore, REPO_SCANNER_GENERATION, RepoPoller } from '../dist/index.js' @@ -51,7 +52,7 @@ describe('stable repo polling', () => { const fallback = transport({ describeError: true, empty: true }) await new RepoPoller(fallback, new MemoryRecordStore()).pollDid(did) - assert.equal(new Set(fallback.calls.map((call) => call.collection)).size, 26) + assert.equal(new Set(fallback.calls.map((call) => call.collection)).size, radialCollections.length) }) it('paginates, stores validated records, and skips an unchanged head', async () => {