diff --git a/pkg/appview/jetstream/processor.go b/pkg/appview/jetstream/processor.go index 5f15f3d..3423f57 100644 --- a/pkg/appview/jetstream/processor.go +++ b/pkg/appview/jetstream/processor.go @@ -264,7 +264,9 @@ func (p *Processor) ProcessRecord(ctx context.Context, did, collection, rkey str switch collection { case atproto.ManifestCollection: if isDelete { - return db.DeleteManifest(p.db, did, "", rkey) + // Manifest rkey is the digest with "sha256:" stripped; the digest + // column stores the full form, so reconstruct it for the WHERE clause. + return db.DeleteManifest(p.db, did, "", "sha256:"+rkey) } _, err := p.ProcessManifest(ctx, did, data) return err