diff --git a/src/util/subscription.ts b/src/util/subscription.ts index ab077d6..1cec32d 100755 --- a/src/util/subscription.ts +++ b/src/util/subscription.ts @@ -13,11 +13,7 @@ import { } from '../lexicon/types/com/atproto/sync/subscribeRepos' import { Database } from '../db' -const ignoredRecords = new Set([ - 'app.bsky.feed.repost', - 'app.bsky.graph.follow', - 'app.bsky.feed.like', -]) +const includedRecords = new Set(['app.bsky.feed.post']) export abstract class FirehoseSubscriptionBase { public sub: Subscription @@ -87,7 +83,7 @@ export const getOpsByType = async (evt: Commit): Promise => { const uri = `at://${evt.repo}/${op.path}` const [collection] = op.path.split('/') - if (ignoredRecords.has(collection)) continue + if (!includedRecords.has(collection)) continue if (op.action === 'update') continue // updates not supported yet