Something went wrong. Try again.
Explore blocks, labels, lists, and posts on Bluesky. skytrace.aly.town
typescript react bluesky atproto
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141import { AppBskyGraphBlock } from '@atcute/bluesky'import { queryOptions } from '@tanstack/react-query'import type { ActorIdentity, Page, RelationshipEntry, UnavailableItem } from '../../types'import { CACHE_TTL_MS } from '../runtime/cachePolicy'import { tryParseRecordUri } from '../../lib/atproto/uri'import type { PublicDataCore } from '../publicDataCore'import { actorReference, isUnavailableRecord, unavailable } from '../recordResults'import type { DataRequestContext } from '../runtime/sharedQueryRequests'import { deadlineSignal } from '../../lib/abort'import { getBacklinksCount } from '../api/backlinks'import { countRecords } from '../api/repository'import { verifiedBacklinkPublishers } from './verifiedBacklinks'import { queryKeys } from '../queryKeys'import { parsedRecord } from '../recordValues'
const RELATIONSHIP_PAGE_SIZE = 24
export class BlockDataService { constructor( private readonly core: PublicDataCore, private readonly context: Pick<DataRequestContext, 'requestTimeoutMs'>, ) {}
blockedCountQueryOptions(identity?: ActorIdentity) { return queryOptions({ queryKey: queryKeys.blockedCount(identity), queryFn: ({ signal }) => identity ? countRecords({ identity, collection: 'app.bsky.graph.block', signal, requestTimeoutMs: this.context.requestTimeoutMs, }) : Promise.resolve(undefined), enabled: identity !== undefined, staleTime: CACHE_TTL_MS.activity, }) }
blockedByCountQueryOptions(did?: ActorIdentity['did']) { return queryOptions({ queryKey: queryKeys.blockedByCount(did), queryFn: ({ signal }) => did ? getBacklinksCount({ subject: did, source: 'app.bsky.graph.block:subject', signal: deadlineSignal(signal, this.context.requestTimeoutMs), }) : Promise.resolve(undefined), enabled: did !== undefined, staleTime: CACHE_TTL_MS.activity, }) }
async actorBlocksActor( { blockerDid, subjectDid }: { blockerDid: ActorIdentity['did']; subjectDid: ActorIdentity['did'] }, signal?: AbortSignal, ): Promise<boolean> { for await (const publisher of verifiedBacklinkPublishers( this.core, { subject: subjectDid, collection: 'app.bsky.graph.block', did: blockerDid }, signal, )) { if (publisher === blockerDid) return true } return false }
async blocking( identity: ActorIdentity, cursor?: string, signal?: AbortSignal, ): Promise<Page<RelationshipEntry | UnavailableItem>> { const page = await this.core.repositoryRecords({ identity, collection: 'app.bsky.graph.block', cursor, limit: 25, signal, }) const items = page.items.map((record) => { if (isUnavailableRecord(record)) return record const block = parsedRecord(AppBskyGraphBlock.mainSchema, record) if (!block) return unavailable(record.uri, 'This block record is malformed.') return { kind: 'relationship' as const, id: record.uri, actor: actorReference(block.subject), createdAt: block.createdAt, } }) return { items, cursor: page.cursor } }
async blockedBy( did: string, cursor?: string, signal?: AbortSignal, ): Promise<Page<RelationshipEntry | UnavailableItem>> { const page = await this.core.backlinks({ subject: did, source: 'app.bsky.graph.block:subject', limit: RELATIONSHIP_PAGE_SIZE, cursor, signal, }) const items = page.items.map((reference) => { const blockerDid = tryParseRecordUri(reference.uri)?.repo if (!blockerDid) return unavailable(reference.uri, 'Constellation returned an invalid block reference.') return { kind: 'relationship' as const, id: reference.uri, actor: actorReference(blockerDid), } }) return { items, cursor: page.cursor } }
blockedByRecordQueryOptions(entry: RelationshipEntry | undefined, subjectDid: string) { return queryOptions({ queryKey: queryKeys.blockedByRecord(entry?.id, subjectDid), queryFn: async ({ signal }) => { if (!entry) throw new Error('This block reference is unavailable.') const record = await this.core.record(entry.id, signal) const value = parsedRecord(AppBskyGraphBlock.mainSchema, record) if ( tryParseRecordUri(entry.id)?.collection !== 'app.bsky.graph.block' || !value || value.subject !== subjectDid ) return unavailable(entry.id, 'This block record is malformed.') return { ...entry, createdAt: value.createdAt } }, enabled: entry !== undefined, staleTime: CACHE_TTL_MS.activity, }) }}