Skip to content

Commit

Permalink
remove profile & identity record from watching
Browse files Browse the repository at this point in the history
  • Loading branch information
Bossett committed Oct 2, 2024
1 parent dc12a54 commit 4dbc908
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 11 deletions.
2 changes: 1 addition & 1 deletion src/firehoseWatcher.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down
12 changes: 2 additions & 10 deletions src/lib/processCommit.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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 {}
Expand Down Expand Up @@ -170,9 +165,6 @@ export function _processCommit(commit: Commit): Promise<void> {
)
break

case 'app.bsky.actor.profile':
break

default:
clearTimeout(failTimeout)
return
Expand Down

0 comments on commit 4dbc908

Please sign in to comment.