Something went wrong. Try again.
leaflet fork for copy edit / bug fixes forked from leaflet.pub/leaflet
Something went wrong. Try again.
TypeScript
at ghost-import
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121import { AtUri } from "@atproto/api";import { getPublicationURL } from "src/utils/getPublicationURL";import { getConstellationBacklinks } from "src/utils/getPostPageData";import { getDocumentURL } from "src/utils/getPublicationURL";import { getDocumentPages, normalizeDocumentRecord, normalizePublicationRecord,} from "src/utils/normalizeRecords";import { truncatePagesAtMembersDelimiter } from "src/membership";import { idResolver } from "src/identity";import { supabaseServerClient } from "supabase/serverClient";import { resolveBylineProfiles } from "src/utils/resolveBylineProfiles";import type { Post } from "actions/reader/getReaderFeed";
type RawDocument = { data: unknown; uri: string; sort_date: string; comments_on_documents: { count: number }[]; document_mentions_in_bsky: { count: number }[]; recommends_on_documents: { count: number }[]; documents_in_publications: { publications: { uri: string; record: unknown; name: string | null; [key: string]: unknown; } | null; }[];};
export async function enrichDocumentToPost( doc: RawDocument,): Promise<Post | null> { const pub = doc.documents_in_publications?.[0]?.publications; const uri = new AtUri(doc.uri); const handle = await idResolver.did.resolve(uri.host);
const normalizedData = normalizeDocumentRecord(doc.data, doc.uri); if (!normalizedData) { console.log( "[enrichPost] normalizeDocumentRecord returned null for:", doc.uri, ); return null; }
// The reader feed has no per-user membership context, so members-only posts // only surface their preview; the post page itself unlocks for members. const docPages = getDocumentPages(normalizedData); if (docPages) truncatePagesAtMembersDelimiter(docPages);
const normalizedPubRecord = pub ? normalizePublicationRecord(pub.record) : null;
const mentionsCount = await getAccurateMentionsCount( normalizedData, doc.uri, normalizedPubRecord, doc.document_mentions_in_bsky?.[0]?.count || 0, );
const contributors = await resolveBylineProfiles(normalizedData, uri.host);
return { publication: pub ? { href: getPublicationURL(pub), pubRecord: normalizedPubRecord, uri: pub.uri || "", } : undefined, ownerDid: handle?.alsoKnownAs?.[0] ? `@${handle.alsoKnownAs[0].slice(5)}` : null, contributors, documents: { comments_on_documents: doc.comments_on_documents, document_mentions_in_bsky: doc.document_mentions_in_bsky, recommends_on_documents: doc.recommends_on_documents, mentionsCount, data: normalizedData, uri: doc.uri, sort_date: doc.sort_date, }, };}
async function getAccurateMentionsCount( normalizedData: NonNullable<ReturnType<typeof normalizeDocumentRecord>>, docUri: string, normalizedPubRecord: ReturnType<typeof normalizePublicationRecord>, dbMentionsCount: number,): Promise<number> { const postUrl = getDocumentURL(normalizedData, docUri, normalizedPubRecord); const absoluteUrl = postUrl.startsWith("/") ? `https://leaflet.pub${postUrl}` : postUrl; const constellationBacklinks = await getConstellationBacklinks( absoluteUrl, docUri, ); if (constellationBacklinks.length === 0) return dbMentionsCount;
// Quote posts published through our share flow are both a DB mention and an // associatedRefs backlink, so a plain count sum double-counts them. Count the // union of uris instead; the feed query only carries the mention count, so // fetch the uris here (only for the posts that actually have backlinks). const { data: dbMentions } = await supabaseServerClient .from("document_mentions_in_bsky") .select("uri") .eq("document", docUri); const uris = new Set([ ...(dbMentions ?? []).map((m) => m.uri), ...constellationBacklinks.map((b) => b.uri), ]); return uris.size;}