(READ ONLY) Margin is an open annotation layer for the internet. Powered by the AT Protocol.
Something went wrong. Try again.
TypeScript
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225import { atom } from "nanostores";import type { UserProfile, FeedResponse, AnnotationItem, Collection, NotificationItem, Target, Selector, HydratedLabel,} from "../types";export type { Collection } from "../types";
export const sessionAtom = atom<UserProfile | null>(null);
export async function checkSession(): Promise<UserProfile | null> { try { const res = await fetch("/auth/session"); if (!res.ok) { sessionAtom.set(null); return null; } const data = await res.json();
if (data.authenticated || data.did) { const baseProfile: UserProfile = { did: data.did, handle: data.handle, displayName: data.displayName, avatar: data.avatar, description: data.description, website: data.website, links: data.links, followersCount: data.followersCount, followsCount: data.followsCount, postsCount: data.postsCount, };
try { const bskyRes = await fetch( `https://public.api.bsky.app/xrpc/app.bsky.actor.getProfile?actor=${encodeURIComponent(data.did)}`, ); if (bskyRes.ok) { const bskyData = await bskyRes.json(); if (bskyData.avatar) baseProfile.avatar = bskyData.avatar; if (bskyData.displayName) baseProfile.displayName = bskyData.displayName; } } catch (e) { console.warn("Failed to fetch Bsky profile for session", e); }
try { const res = await fetch(`/api/profile/${data.did}`); if (res.ok) { const marginProfile = await res.json(); if (marginProfile) { if (marginProfile.description) baseProfile.description = marginProfile.description; if (marginProfile.followersCount) baseProfile.followersCount = marginProfile.followersCount; if (marginProfile.followsCount) baseProfile.followsCount = marginProfile.followsCount; if (marginProfile.postsCount) baseProfile.postsCount = marginProfile.postsCount; if (marginProfile.website) baseProfile.website = marginProfile.website; if (marginProfile.links) baseProfile.links = marginProfile.links; } } } catch (e) { console.debug("Failed to fetch Margin profile:", e); }
sessionAtom.set(baseProfile); return baseProfile; }
sessionAtom.set(null); return null; } catch (e) { console.error("Session check failed:", e); sessionAtom.set(null); return null; }}
async function apiRequest( path: string, options: RequestInit & { skipAuthRedirect?: boolean } = {},): Promise<Response> { const { skipAuthRedirect, ...fetchOptions } = options; const headers = { "Content-Type": "application/json", ...(fetchOptions.headers || {}), };
const apiPath = path.startsWith("/api") || path.startsWith("/auth") ? path : `/api${path}`;
const response = await fetch(apiPath, { ...fetchOptions, headers, });
if (response.status === 401 && !skipAuthRedirect) { sessionAtom.set(null); if (window.location.pathname !== "/login") { window.location.href = "/login"; } }
return response;}
interface GetFeedParams { source?: string; type?: string; limit?: number; offset?: number; motivation?: string; tag?: string; creator?: string;}
interface RawItem { type?: string; collectionUri?: string; annotation?: RawItem; highlight?: RawItem; bookmark?: RawItem; uri?: string; id?: string; cid?: string; author?: UserProfile; creator?: UserProfile; collection?: { uri: string; name: string; icon?: string; }; created?: string; createdAt?: string; target?: string | { source?: string; title?: string; selector?: Selector }; url?: string; targetUrl?: string; title?: string; selector?: Selector; viewer?: { like?: string; [key: string]: unknown }; viewerHasLiked?: boolean; motivation?: string; [key: string]: unknown;}
function normalizeItem(raw: RawItem): AnnotationItem { if (raw.type === "CollectionItem" || raw.collectionUri) { const inner = raw.annotation || raw.highlight || raw.bookmark || {}; const normalizedInner = normalizeItem(inner);
return { ...normalizedInner, uri: normalizedInner.uri || raw.uri || "", cid: raw.cid || "", author: (normalizedInner.author || raw.author || raw.creator) as UserProfile, collection: raw.collection ? { uri: raw.collection.uri, name: raw.collection.name, icon: raw.collection.icon, } : undefined, addedBy: raw.creator || raw.author, createdAt: raw.created || raw.createdAt || new Date().toISOString(), collectionItemUri: raw.id || raw.uri, }; }
let target: Target | undefined;
if (raw.target) { if (typeof raw.target === "string") { target = { source: raw.target, title: raw.title, selector: raw.selector }; } else { target = { source: raw.target.source || "", title: raw.target.title || raw.title, selector: raw.target.selector || raw.selector, }; } }
if (!target || !target.source) { const url = raw.url || raw.targetUrl || (typeof raw.target === "string" ? raw.target : raw.target?.source); if (url) { target = { source: url, title: raw.title || (typeof raw.target !== "string" ? raw.target?.title : undefined), selector: raw.selector || (typeof raw.target !== "string" ? raw.target?.selector : undefined), }; } }
return { ...raw, uri: raw.id || raw.uri || "", cid: raw.cid || "", author: (raw.creator || raw.author) as UserProfile, createdAt: raw.created || raw.createdAt || new Date().toISOString(), target: target, viewer: raw.viewer || { like: raw.viewerHasLiked ? "true" : undefined }, motivation: raw.motivation || "highlighting", parentUri: (raw as Record<string, unknown>).inReplyTo as string | undefined, };}
export async function getFeed({ source, type = "all", limit = 50, offset = 0, motivation, tag, creator,}: GetFeedParams): Promise<FeedResponse> { const params = new URLSearchParams(); if (source) params.append("source", source); if (type) params.append("type", type); if (limit) params.append("limit", limit.toString()); if (offset) params.append("offset", offset.toString()); if (motivation) params.append("motivation", motivation); if (tag) params.append("tag", tag); if (creator) params.append("creator", creator);
const endpoint = source ? "/api/targets" : "/api/annotations/feed";
try { const res = await apiRequest(`${endpoint}?${params.toString()}`, { skipAuthRedirect: true, }); if (!res.ok) throw new Error("Failed to fetch feed"); const data = await res.json(); return { cursor: data.cursor, items: (data.items || []).map(normalizeItem), }; } catch (e) { console.error(e); return { items: [] }; }}
interface CreateAnnotationParams { url: string; text?: string; title?: string; selector?: { exact: string; prefix?: string; suffix?: string }; tags?: string[]; labels?: string[];}
export async function createAnnotation({ url, text, title, selector, tags, labels,}: CreateAnnotationParams) { try { const res = await apiRequest("/api/annotations", { method: "POST", body: JSON.stringify({ url, text, title, selector, tags, labels }), }); if (!res.ok) throw new Error(await res.text()); const raw = await res.json(); return normalizeItem(raw); } catch (e) { console.error(e); return { error: e instanceof Error ? e.message : "Unknown error" }; }}
interface CreateHighlightParams { url: string; selector: { exact: string; prefix?: string; suffix?: string }; color?: string; tags?: string[]; title?: string; labels?: string[];}
export async function createHighlight({ url, selector, color, tags, title, labels,}: CreateHighlightParams) { try { const res = await apiRequest("/api/highlights", { method: "POST", body: JSON.stringify({ url, selector, color, tags, title, labels }), }); if (!res.ok) throw new Error(await res.text()); const raw = await res.json(); return normalizeItem(raw); } catch (e) { console.error(e); return { error: e instanceof Error ? e.message : "Unknown error" }; }}
export async function createBookmark({ url, title, description,}: { url: string; title?: string; description?: string;}) { try { const res = await apiRequest("/api/bookmarks", { method: "POST", body: JSON.stringify({ url, title, description }), }); if (!res.ok) throw new Error(await res.text()); const raw = await res.json(); return normalizeItem(raw); } catch (e) { console.error(e); return { error: e instanceof Error ? e.message : "Unknown error" }; }}
export async function uploadAvatar( file: File,): Promise<{ blob: Blob | string }> { const formData = new FormData(); formData.append("file", file); const res = await fetch("/api/upload/avatar", { method: "POST", headers: { Authorization: `Bearer ${(await checkSession())?.did}`, }, body: formData, }); if (!res.ok) throw new Error("Failed to upload avatar"); return res.json();}
export async function updateProfile(updates: { displayName?: string; description?: string; avatar?: Blob | string | null; website?: string; links?: string[];}): Promise<boolean> { try { const res = await apiRequest("/api/profile", { method: "PUT", body: JSON.stringify(updates), }); return res.ok; } catch (e) { console.error(e); return false; }}
export async function likeItem(uri: string, cid: string): Promise<boolean> { try { const res = await apiRequest("/api/annotations/like", { method: "POST", body: JSON.stringify({ subjectUri: uri, subjectCid: cid }), }); return res.ok; } catch (e) { console.error("Failed to like item:", e); return false; }}
export async function unlikeItem(uri: string): Promise<boolean> { try { const res = await apiRequest( `/api/annotations/like?uri=${encodeURIComponent(uri)}`, { method: "DELETE", }, ); return res.ok; } catch (e) { console.error("Failed to unlike item:", e); return false; }}
export async function deleteItem( uri: string, _type: string = "annotation",): Promise<boolean> { const rkey = (uri || "").split("/").pop(); let endpoint = "/api/annotations"; if (uri.includes("highlight")) endpoint = "/api/highlights"; if (uri.includes("bookmark")) endpoint = "/api/bookmarks";
try { const res = await apiRequest(`${endpoint}?rkey=${rkey}`, { method: "DELETE", }); return res.ok; } catch (e) { console.error("Failed to delete item:", e); return false; }}
export async function updateAnnotation( uri: string, text: string, tags?: string[], labels?: string[],): Promise<boolean> { try { const res = await apiRequest( `/api/annotations?uri=${encodeURIComponent(uri)}`, { method: "PUT", body: JSON.stringify({ text, tags, labels }), }, ); return res.ok; } catch (e) { console.error("Failed to update annotation:", e); return false; }}
export async function updateHighlight( uri: string, color: string, tags?: string[], labels?: string[],): Promise<boolean> { try { const res = await apiRequest( `/api/highlights?uri=${encodeURIComponent(uri)}`, { method: "PUT", body: JSON.stringify({ color, tags, labels }), }, ); return res.ok; } catch (e) { console.error("Failed to update highlight:", e); return false; }}
export async function updateBookmark( uri: string, title?: string, description?: string, tags?: string[], labels?: string[],): Promise<boolean> { try { const res = await apiRequest( `/api/bookmarks?uri=${encodeURIComponent(uri)}`, { method: "PUT", body: JSON.stringify({ title, description, tags, labels }), }, ); return res.ok; } catch (e) { console.error("Failed to save bookmark:", e); return false; }}
export async function getCollectionsContaining( annotationUri: string,): Promise<string[]> { try { const res = await apiRequest( `/api/collections/containing?uri=${encodeURIComponent(annotationUri)}`, ); if (!res.ok) return []; return await res.json(); } catch (e) { console.error("Failed to fetch containing collections:", e); return []; }}
import type { EditHistoryItem } from "../types";
export async function getEditHistory(uri: string): Promise<EditHistoryItem[]> { try { const res = await apiRequest( `/api/annotations/history?uri=${encodeURIComponent(uri)}`, ); if (!res.ok) return []; return await res.json(); } catch (e) { console.error("Failed to fetch edit history:", e); return []; }}
export async function getProfile(did: string): Promise<UserProfile | null> { try { const res = await apiRequest(`/api/profile/${did}`); if (!res.ok) return null; return await res.json(); } catch (e) { console.error("Failed to fetch profile:", e); return null; }}
export interface ActorSearchItem { did: string; handle: string; displayName?: string; avatar?: string;}
export function getAvatarUrl( did?: string, avatar?: string,): string | undefined { if (!avatar && !did) return undefined; if (avatar && !avatar.includes("cdn.bsky.app")) return avatar; if (!did) return avatar;
return `/api/avatar/${encodeURIComponent(did)}`;}
export async function searchActors( query: string,): Promise<{ actors: ActorSearchItem[] }> { try { const res = await fetch( `https://public.api.bsky.app/xrpc/app.bsky.actor.searchActorsTypeahead?q=${encodeURIComponent(query)}&limit=5`, ); if (!res.ok) throw new Error("Search failed"); return await res.json(); } catch (e) { console.error("Failed to search actors:", e); return { actors: [] }; }}
export async function resolveHandle(handle: string): Promise<string | null> { try { const res = await fetch( `https://public.api.bsky.app/xrpc/com.atproto.identity.resolveHandle?handle=${encodeURIComponent(handle)}`, ); if (!res.ok) throw new Error("Failed to resolve handle"); const data = await res.json(); return data.did; } catch (e) { console.error("Failed to resolve handle:", e); return null; }}
export async function startLogin( handle: string,): Promise<{ authorizationUrl?: string }> { const res = await apiRequest("/auth/start", { method: "POST", body: JSON.stringify({ handle }), }); if (!res.ok) throw new Error("Failed to start login"); return await res.json();}
export async function startSignup( pdsUrl: string,): Promise<{ authorizationUrl?: string }> { const res = await apiRequest("/auth/signup", { method: "POST", body: JSON.stringify({ pds_url: pdsUrl }), }); if (!res.ok) throw new Error("Failed to start signup"); return await res.json();}
export async function getNotifications( limit = 50, offset = 0,): Promise<NotificationItem[]> { try { const res = await apiRequest( `/api/notifications?limit=${limit}&offset=${offset}`, ); if (!res.ok) throw new Error("Failed to fetch notifications"); const data = await res.json(); return (data.items || []).map((n: NotificationItem) => ({ ...n, subject: n.subject ? normalizeItem(n.subject as RawItem) : undefined, })); } catch (e) { console.error("Failed to fetch notifications:", e); return []; }}
export async function getUnreadNotificationCount(): Promise<number> { try { const res = await apiRequest("/api/notifications/count", { skipAuthRedirect: true, }); if (!res.ok) return 0; const data = await res.json(); return data.count || 0; } catch (e) { console.error("Failed to fetch unread notification count:", e); return 0; }}
export async function markNotificationsRead(): Promise<boolean> { try { const res = await apiRequest("/api/notifications/read", { method: "POST" }); return res.ok; } catch (e) { console.error("Failed to mark notifications as read:", e); return false; }}
export interface APIKey { id: string; name: string; key?: string; createdAt: string;}
export async function getAPIKeys(): Promise<APIKey[]> { try { const res = await apiRequest("/api/keys"); if (!res.ok) return []; const data = await res.json(); return Array.isArray(data) ? data : data.keys || []; } catch (e) { console.error("Failed to fetch API keys:", e); return []; }}
export async function createAPIKey(name: string): Promise<APIKey | null> { try { const res = await apiRequest("/api/keys", { method: "POST", body: JSON.stringify({ name }), }); if (!res.ok) return null; return await res.json(); } catch (e) { console.error("Failed to create API key:", e); return null; }}
export async function deleteAPIKey(id: string): Promise<boolean> { try { const res = await apiRequest(`/api/keys/${id}`, { method: "DELETE" }); return res.ok; } catch (e) { console.error("Failed to delete API key:", e); return false; }}
export interface Tag { tag: string; count: number;}
export async function getTrendingTags(limit = 10): Promise<Tag[]> { try { const res = await apiRequest(`/api/tags/trending?limit=${limit}`, { skipAuthRedirect: true, }); if (!res.ok) return []; const data = await res.json(); return Array.isArray(data) ? data : data.tags || []; } catch (e) { console.error("Failed to fetch trending tags:", e); return []; }}
export async function getCollections(creator?: string): Promise<Collection[]> { try { const query = creator ? `?author=${encodeURIComponent(creator)}` : ""; const res = await apiRequest(`/api/collections${query}`); if (!res.ok) throw new Error("Failed to fetch collections"); const data = await res.json(); let items = Array.isArray(data) ? data : data.items || data.collections || [];
items = items.map((item: Record<string, unknown>) => { if (!item.id && item.uri) { item.id = (item.uri as string).split("/").pop(); } return item; });
return items; } catch (e) { console.error(e); return []; }}
export async function getCollection(uri: string): Promise<Collection | null> { try { const res = await apiRequest( `/api/collection?uri=${encodeURIComponent(uri)}`, ); if (!res.ok) throw new Error("Failed to fetch collection"); return await res.json(); } catch (e) { console.error(e); return null; }}
export async function createCollection( name: string, description?: string, icon?: string,): Promise<Collection | null> { try { const res = await apiRequest("/api/collections", { method: "POST", body: JSON.stringify({ name, description, icon }), }); if (!res.ok) throw new Error("Failed to create collection"); return await res.json(); } catch (e) { console.error(e); return null; }}
export async function deleteCollection(id: string): Promise<boolean> { try { const res = await apiRequest( `/api/collections?uri=${encodeURIComponent(id)}`, { method: "DELETE" }, ); return res.ok; } catch (e) { console.error(e); return false; }}
export async function getCollectionItems( uri: string,): Promise<AnnotationItem[]> { try { const res = await apiRequest( `/api/collections/${encodeURIComponent(uri)}/items`, ); if (!res.ok) throw new Error("Failed to fetch collection items"); const data = await res.json(); return (data || []).map(normalizeItem); } catch (e) { console.error(e); return []; }}
export async function updateCollection( uri: string, name: string, description?: string, icon?: string,): Promise<Collection | null> { try { const res = await apiRequest( `/api/collections?uri=${encodeURIComponent(uri)}`, { method: "PUT", body: JSON.stringify({ name, description, icon }), }, ); if (!res.ok) throw new Error("Failed to update collection"); return await res.json(); } catch (e) { console.error(e); return null; }}
export async function addCollectionItem( collectionUri: string, annotationUri: string, position: number = 0,): Promise<boolean> { try { const res = await apiRequest( `/api/collections/${encodeURIComponent(collectionUri)}/items`, { method: "POST", body: JSON.stringify({ annotationUri, position }), }, ); return res.ok; } catch (e) { console.error(e); return false; }}
export async function removeCollectionItem(itemUri: string): Promise<boolean> { try { const res = await apiRequest( `/api/collections/items?uri=${encodeURIComponent(itemUri)}`, { method: "DELETE", }, ); return res.ok; } catch (e) { console.error(e); return false; }}
export async function createReply( parentUri: string, parentCid: string, rootUri: string, rootCid: string, text: string,): Promise<string | null> { try { const res = await apiRequest("/api/annotations/reply", { method: "POST", body: JSON.stringify({ parentUri, parentCid, rootUri, rootCid, text }), }); if (!res.ok) throw new Error("Failed to create reply"); const data = await res.json(); return data.uri; } catch (e) { console.error(e); return null; }}
export async function deleteReply(uri: string): Promise<boolean> { try { const res = await apiRequest( `/api/annotations/reply?uri=${encodeURIComponent(uri)}`, { method: "DELETE", }, ); return res.ok; } catch (e) { console.error(e); return false; }}
export async function getAnnotation( uri: string,): Promise<AnnotationItem | null> { try { const res = await apiRequest( `/api/annotation?uri=${encodeURIComponent(uri)}`, ); if (!res.ok) return null; return normalizeItem(await res.json()); } catch { return null; }}
export async function getReplies( uri: string,): Promise<{ items: AnnotationItem[] }> { try { const res = await apiRequest(`/api/replies?uri=${encodeURIComponent(uri)}`); if (!res.ok) return { items: [] }; const data = await res.json(); return { items: (data.items || []).map(normalizeItem) }; } catch { return { items: [] }; }}
export async function getByTarget( url: string, limit = 50, offset = 0,): Promise<{ annotations: AnnotationItem[]; highlights: AnnotationItem[] }> { try { const res = await apiRequest( `/api/targets?source=${encodeURIComponent(url)}&limit=${limit}&offset=${offset}`, ); if (!res.ok) return { annotations: [], highlights: [] }; const data = await res.json(); return { annotations: (data.annotations || []).map(normalizeItem), highlights: (data.highlights || []).map(normalizeItem), }; } catch { return { annotations: [], highlights: [] }; }}
export async function getUserTargetItems( did: string, url: string, limit = 50, offset = 0,): Promise<{ annotations: AnnotationItem[]; highlights: AnnotationItem[] }> { try { const res = await apiRequest( `/api/users/${encodeURIComponent(did)}/targets?source=${encodeURIComponent(url)}&limit=${limit}&offset=${offset}`, ); if (!res.ok) return { annotations: [], highlights: [] }; const data = await res.json(); return { annotations: (data.annotations || []).map(normalizeItem), highlights: (data.highlights || []).map(normalizeItem), }; } catch { return { annotations: [], highlights: [] }; }}import type { LabelerSubscription, LabelPreference, LabelerInfo,} from "../types";
export interface PreferencesResponse { externalLinkSkippedHostnames?: string[]; subscribedLabelers?: LabelerSubscription[]; labelPreferences?: LabelPreference[];}
export async function getPreferences(): Promise<PreferencesResponse> { try { const res = await apiRequest("/api/preferences", { skipAuthRedirect: true, }); if (!res.ok) return {}; return await res.json(); } catch (e) { console.error(e); return {}; }}
export async function updatePreferences(prefs: { externalLinkSkippedHostnames?: string[]; subscribedLabelers?: LabelerSubscription[]; labelPreferences?: LabelPreference[];}): Promise<boolean> { try { const res = await apiRequest("/api/preferences", { method: "PUT", body: JSON.stringify(prefs), }); return res.ok; } catch (e) { console.error(e); return false; }}
export async function getLabelerInfo(): Promise<LabelerInfo | null> { try { const res = await apiRequest("/moderation/labeler", { skipAuthRedirect: true, }); if (!res.ok) return null; return await res.json(); } catch (e) { console.error("Failed to fetch labeler info:", e); return null; }}
import type { ModerationRelationship, BlockedUser, MutedUser, ModerationReport, ReportReasonType,} from "../types";
export async function blockUser(did: string): Promise<boolean> { try { const res = await apiRequest("/api/moderation/block", { method: "POST", body: JSON.stringify({ did }), }); return res.ok; } catch (e) { console.error("Failed to block user:", e); return false; }}
export async function unblockUser(did: string): Promise<boolean> { try { const res = await apiRequest( `/api/moderation/block?did=${encodeURIComponent(did)}`, { method: "DELETE" }, ); return res.ok; } catch (e) { console.error("Failed to unblock user:", e); return false; }}
export async function getBlocks(): Promise<BlockedUser[]> { try { const res = await apiRequest("/api/moderation/blocks"); if (!res.ok) return []; const data = await res.json(); return data.items || []; } catch (e) { console.error("Failed to fetch blocks:", e); return []; }}
export async function muteUser(did: string): Promise<boolean> { try { const res = await apiRequest("/api/moderation/mute", { method: "POST", body: JSON.stringify({ did }), }); return res.ok; } catch (e) { console.error("Failed to mute user:", e); return false; }}
export async function unmuteUser(did: string): Promise<boolean> { try { const res = await apiRequest( `/api/moderation/mute?did=${encodeURIComponent(did)}`, { method: "DELETE" }, ); return res.ok; } catch (e) { console.error("Failed to unmute user:", e); return false; }}
export async function getMutes(): Promise<MutedUser[]> { try { const res = await apiRequest("/api/moderation/mutes"); if (!res.ok) return []; const data = await res.json(); return data.items || []; } catch (e) { console.error("Failed to fetch mutes:", e); return []; }}
export async function getModerationRelationship( did: string,): Promise<ModerationRelationship> { try { const res = await apiRequest( `/api/moderation/relationship?did=${encodeURIComponent(did)}`, { skipAuthRedirect: true }, ); if (!res.ok) return { blocking: false, muting: false, blockedBy: false }; return await res.json(); } catch (e) { console.error("Failed to get moderation relationship:", e); return { blocking: false, muting: false, blockedBy: false }; }}
export async function reportUser(params: { subjectDid: string; subjectUri?: string; reasonType: ReportReasonType; reasonText?: string;}): Promise<boolean> { try { const res = await apiRequest("/api/moderation/report", { method: "POST", body: JSON.stringify(params), }); return res.ok; } catch (e) { console.error("Failed to submit report:", e); return false; }}
export async function checkAdminAccess(): Promise<boolean> { try { const res = await apiRequest("/api/moderation/admin/check", { skipAuthRedirect: true, }); if (!res.ok) return false; const data = await res.json(); return data.isAdmin || false; } catch { return false; }}
export async function getAdminReports( status?: string, limit = 50, offset = 0,): Promise<{ items: ModerationReport[]; totalItems: number; pendingCount: number;}> { try { const params = new URLSearchParams(); if (status) params.append("status", status); params.append("limit", limit.toString()); params.append("offset", offset.toString()); const res = await apiRequest( `/api/moderation/admin/reports?${params.toString()}`, ); if (!res.ok) return { items: [], totalItems: 0, pendingCount: 0 }; return await res.json(); } catch (e) { console.error("Failed to fetch admin reports:", e); return { items: [], totalItems: 0, pendingCount: 0 }; }}
export async function adminTakeAction(params: { reportId: number; action: string; comment?: string;}): Promise<boolean> { try { const res = await apiRequest("/api/moderation/admin/action", { method: "POST", body: JSON.stringify(params), }); return res.ok; } catch (e) { console.error("Failed to take moderation action:", e); return false; }}
export async function adminCreateLabel(params: { src: string; uri?: string; val: string;}): Promise<boolean> { try { const res = await apiRequest("/api/moderation/admin/label", { method: "POST", body: JSON.stringify(params), }); return res.ok; } catch (e) { console.error("Failed to create label:", e); return false; }}
export async function adminDeleteLabel(id: number): Promise<boolean> { try { const res = await apiRequest(`/api/moderation/admin/label?id=${id}`, { method: "DELETE", }); return res.ok; } catch (e) { console.error("Failed to delete label:", e); return false; }}
export async function adminGetLabels( limit = 50, offset = 0,): Promise<{ items: HydratedLabel[] }> { try { const res = await apiRequest( `/api/moderation/admin/labels?limit=${limit}&offset=${offset}`, ); if (!res.ok) return { items: [] }; return await res.json(); } catch (e) { console.error("Failed to fetch labels:", e); return { items: [] }; }}