See the best posts from any Bluesky account
Parse jetstream like-delete events into LikeDeleteEvent
The firehose virality worker needs to observe unlikes so it can
decrement the per-post like count. Extend parseJetstreamEvent to emit
a new LikeDeleteEvent kind for app.bsky.feed.like deletes; repost
deletes remain ignored (no use case yet). The existing jetstream
consumer is unaffected because it only switches on the kinds it cares
about.
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
+446
-6
+1
app/lib/atproto/index.ts
+1
app/lib/atproto/index.ts
+29
-4
app/lib/atproto/parsers/jetstream.ts
+29
-4
app/lib/atproto/parsers/jetstream.ts
···
2
2
import type {
3
3
JetstreamEvent,
4
4
LikeEvent,
5
+
LikeDeleteEvent,
5
6
RepostEvent,
6
7
PostEvent,
7
8
PostDeleteEvent,
···
303
304
}
304
305
}
305
306
307
+
function parseLikeDelete(
308
+
did: string,
309
+
timeUs: number,
310
+
commit: Record<string, unknown>
311
+
): LikeDeleteEvent | null {
312
+
const rkey = getString(commit, 'rkey')
313
+
const collection = getString(commit, 'collection')
314
+
if (!rkey || !collection) return null
315
+
316
+
const likeUri = `at://${did}/${collection}/${rkey}`
317
+
318
+
return {
319
+
kind: 'like-delete',
320
+
actorDid: did,
321
+
rkey,
322
+
likeUri,
323
+
ingestedAt: timeUsToDate(timeUs),
324
+
}
325
+
}
326
+
306
327
function parseRepostCreate(
307
328
did: string,
308
329
timeUs: number,
···
452
473
* - The event is malformed / not an object
453
474
* - The kind/collection is one favs.blue v1 doesn't care about
454
475
*
455
-
* **Like and repost DELETE events return null intentionally.**
456
-
* Per spec §10: "Unlikes / unreposts are not tracked. Counts may drift up
457
-
* over time. The alternative is a multi-billion-row rkey-to-post mapping
476
+
* **Like DELETE events are now parsed as `LikeDeleteEvent`** (consumed by
477
+
* the firehose virality worker, which resolves the subject URI via the
478
+
* `like_events_lookup` ClickHouse table).
479
+
*
480
+
* **Repost DELETE events still return null intentionally.**
481
+
* Per spec §10: "Unreposts are not tracked. Counts may drift up over
482
+
* time. The alternative is a multi-billion-row rkey-to-post mapping
458
483
* table, which is not worth the storage cost for v1."
459
484
*
460
485
* @param rawJson - A parsed JSON value (not a string — JSON parsing is
···
489
514
// Like events
490
515
if (collection === 'app.bsky.feed.like') {
491
516
if (operation === 'create') return parseLikeCreate(did, timeUs, commit)
492
-
// DELETE: intentionally ignored (spec §10 — unlikes not tracked)
517
+
if (operation === 'delete') return parseLikeDelete(did, timeUs, commit)
493
518
return null
494
519
}
495
520
+22
app/lib/atproto/types.ts
+22
app/lib/atproto/types.ts
···
27
27
}
28
28
29
29
/**
30
+
* A like was deleted (an unlike) by an actor.
31
+
* Source: commit event with collection=app.bsky.feed.like, operation=delete
32
+
*
33
+
* Unlike `LikeEvent`, we do NOT have the subject post URI here — the delete
34
+
* commit only carries `(did, collection, rkey)`. The firehose worker is
35
+
* responsible for resolving the original subject via the ClickHouse
36
+
* `like_events_lookup` table.
37
+
*/
38
+
export interface LikeDeleteEvent {
39
+
kind: 'like-delete'
40
+
/** DID of the user who performed the unlike */
41
+
actorDid: string
42
+
/** rkey of the original like record (the one being deleted) */
43
+
rkey: string
44
+
/** AT-URI of the original like record, reconstructed from did + collection + rkey */
45
+
likeUri: string
46
+
/** When the event was ingested (from top-level time_us, converted from µs) */
47
+
ingestedAt: Date
48
+
}
49
+
50
+
/**
30
51
* A repost was created by an actor on a post.
31
52
* Source: commit event with collection=app.bsky.feed.repost, operation=create
32
53
*/
···
135
156
*/
136
157
export type JetstreamEvent =
137
158
| LikeEvent
159
+
| LikeDeleteEvent
138
160
| RepostEvent
139
161
| PostEvent
140
162
| PostDeleteEvent
+10
-2
tests/unit/atproto/jetstream.spec.ts
+10
-2
tests/unit/atproto/jetstream.spec.ts
···
365
365
})
366
366
367
367
test.group('parseJetstreamEvent — ignored events', () => {
368
-
test('returns null for like delete (spec §10: unlikes not tracked)', ({ assert }) => {
368
+
test('parses a like delete into a LikeDeleteEvent', ({ assert }) => {
369
369
const result = parseJetstreamEvent(LIKE_DELETE_EVENT)
370
-
assert.isNull(result)
370
+
if (result === null) return assert.fail('expected LikeDeleteEvent, got null')
371
+
if (result.kind !== 'like-delete') return assert.fail(`expected kind=like-delete, got ${result.kind}`)
372
+
assert.equal(result.actorDid, 'did:plc:unlikingactor')
373
+
assert.equal(result.rkey, '3l3likedeletedkey')
374
+
assert.equal(
375
+
result.likeUri,
376
+
'at://did:plc:unlikingactor/app.bsky.feed.like/3l3likedeletedkey'
377
+
)
378
+
assert.instanceOf(result.ingestedAt, Date)
371
379
})
372
380
373
381
test('returns null for repost delete (spec §10: unreposts not tracked)', ({ assert }) => {