Something went wrong. Try again.
leaflet fork for copy edit / bug fixes forked from leaflet.pub/leaflet
Something went wrong. Try again.
TypeScript
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394"use server";
import { AtpAgent } from "@atproto/api";import { ProfileViewDetailed } from "@atproto/api/dist/client/types/app/bsky/actor/defs";import { getAuthIdentity } from "src/auth";import { Json } from "supabase/database.types";import { supabaseServerClient } from "supabase/serverClient";import { idResolver } from "src/identity";import { Cursor } from "./getReaderFeed";import { normalizePublicationRecord, type NormalizedPublication,} from "src/utils/normalizeRecords";
export async function getSubscriptions( did?: string | null, cursor?: Cursor | null,): Promise<{ nextCursor: null | Cursor; subscriptions: PublicationSubscription[];}> { // If no DID provided, use logged-in user's DID let identity = did; if (!identity) { const auth_res = await getAuthIdentity(); if (!auth_res?.atp_did) return { subscriptions: [], nextCursor: null }; identity = auth_res.atp_did; }
let query = supabaseServerClient .from("publication_subscriptions") .select( `*, publications(*, publication_subscriptions(*), publication_newsletter_settings(enabled), documents_in_publications(*, documents(*)))`, ) .order(`created_at`, { ascending: false }) .order(`uri`, { ascending: false }) .order("documents(sort_date)", { ascending: false, referencedTable: "publications.documents_in_publications", }) .limit(1, { referencedTable: "publications.documents_in_publications" }) .limit(25) .eq("identity", identity);
if (cursor) { query = query.or( `created_at.lt.${cursor.timestamp},and(created_at.eq.${cursor.timestamp},uri.lt.${cursor.uri})`, ); } let { data: pubs, error } = await query;
const hydratedSubscriptions = ( await Promise.all( pubs?.map(async (pub) => { const normalizedRecord = normalizePublicationRecord( pub.publications?.record, ); if (!normalizedRecord) return null; let id = await idResolver.did.resolve(pub.publications?.identity_did!); return { ...pub.publications!, record: normalizedRecord, authorProfile: id?.alsoKnownAs?.[0] ? { handle: `@${id.alsoKnownAs[0].slice(5)}` } : undefined, } as PublicationSubscription; }) || [], ) ).filter((sub): sub is PublicationSubscription => sub !== null); const nextCursor = pubs && pubs.length > 0 ? { timestamp: pubs[pubs.length - 1].created_at, uri: pubs[pubs.length - 1].uri, } : null;
return { subscriptions: hydratedSubscriptions, nextCursor, };}
export type PublicationSubscription = { authorProfile?: { handle: string }; record: NormalizedPublication; publication_subscriptions: { identity: string }[]; publication_newsletter_settings: { enabled: boolean } | null; uri: string; documents_in_publications: { documents: { data?: Json; sort_date: string } | null; }[];};