diff --git a/src/firehoseWatcher.ts b/src/firehoseWatcher.ts index 77ff66a..64552c6 100644 --- a/src/firehoseWatcher.ts +++ b/src/firehoseWatcher.ts @@ -204,7 +204,7 @@ export default async function firehoseWatcher() { seq: seq, timeout: env.limits.MAX_FIREHOSE_DELAY, maxPending: env.limits.FIREHOSE_MAX_PENDING, - includeTypes: ['app.bsky.feed.post', 'app.bsky.actor.profile'], + includeTypes: ['app.bsky.feed.post'], }) for await (const commit of firehose) { diff --git a/src/lib/processCommit.ts b/src/lib/processCommit.ts index f8975c1..99c0f7a 100644 --- a/src/lib/processCommit.ts +++ b/src/lib/processCommit.ts @@ -35,13 +35,8 @@ const regexDid = /(did:[^:]+:[^\/]+)/ export function validateCommit(commit: Commit): { seq?: number; did?: string } { if ( !( - (commit.record['$type'] && - ['app.bsky.feed.post', 'app.bsky.actor.profile'].includes( - commit.record['$type'], - )) || - ['com.atproto.sync.subscribeRepos#identity'].includes( - commit.meta['$type'], - ) + commit.record['$type'] && + ['app.bsky.feed.post'].includes(commit.record['$type']) ) ) { return {} @@ -170,9 +165,6 @@ export function _processCommit(commit: Commit): Promise { ) break - case 'app.bsky.actor.profile': - break - default: clearTimeout(failTimeout) return