+1 -1

src/modules/atproto/application/useCases/ProcessFollowFirehoseEventUseCase.ts

View file Reviewed

··· 156 156 return ok(undefined); 157 157 } 158 158 159 159 - targetId = collectionIdResult.value.toString(); 159 159 + targetId = collectionIdResult.value.getStringValue(); 160 160 } else { 161 161 if (ENABLE_FIREHOSE_LOGGING) { 162 162 console.warn(

+8

src/modules/atproto/infrastructure/services/DrizzleFirehoseEventDuplicationService.ts

View file Reviewed

··· 101 101 // If a record exists, it hasn't been deleted 102 102 return ok(records.length === 0); 103 103 } 104 104 + case collections.follow: { 105 105 + const followInfoResult = 106 106 + await this.atUriResolver.resolveFollowId(atUri); 107 107 + if (followInfoResult.isErr()) { 108 108 + return err(followInfoResult.error); 109 109 + } 110 110 + return ok(followInfoResult.value === null); 111 111 + } 104 112 default: 105 113 return err(new Error(`Unknown collection type: ${collection}`)); 106 114 }