(READ ONLY) Margin is an open annotation layer for the internet. Powered by the AT Protocol.
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111import type { UserProfile } from "../types";
const API_URL = process.env.API_URL || `http://localhost:${process.env.API_PORT || 8081}`;
function serverFetch(path: string, cookie?: string): Promise<Response> { const headers: Record<string, string> = { "Content-Type": "application/json", }; if (cookie) headers["Cookie"] = cookie; return fetch(`${API_URL}${path}`, { headers });}
const sessionCache = new Map<string, { user: UserProfile; expires: number }>();
export function clearSessionCacheForCookie(cookie: string) { const cacheKey = cookie.match(/margin_session=([^;]+)/)?.[1] || ""; if (cacheKey) sessionCache.delete(cacheKey);}
export async function getSession(cookie: string): Promise<UserProfile | null> { try { const cacheKey = cookie.match(/margin_session=([^;]+)/)?.[1] || ""; const cached = sessionCache.get(cacheKey); if (cached && Date.now() < cached.expires) { return cached.user; }
const res = await serverFetch("/auth/session", cookie); if (!res.ok) return null; const data = await res.json(); if (!data.authenticated && !data.did) return null;
const profile: 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, };
if (cacheKey) { sessionCache.set(cacheKey, { user: profile, expires: Date.now() + 5 * 60_000, }); if (sessionCache.size > 100) { const now = Date.now(); for (const [k, v] of sessionCache) { if (now > v.expires) sessionCache.delete(k); } } }
const controller = new AbortController(); const timeout = setTimeout(() => controller.abort(), 3000);
Promise.allSettled([ fetch( `https://public.api.bsky.app/xrpc/app.bsky.actor.getProfile?actor=${encodeURIComponent(data.did)}`, { signal: controller.signal }, ), serverFetch(`/api/profile/${data.did}`, cookie), ]) .then(([bskyRes, marginRes]) => { clearTimeout(timeout);
if (bskyRes.status === "fulfilled" && bskyRes.value.ok) { bskyRes.value .json() .then((bsky) => { if (bsky.avatar) profile.avatar = bsky.avatar; if (bsky.displayName) profile.displayName = bsky.displayName; }) .catch(() => { /* ignore */ }); }
if (marginRes.status === "fulfilled" && marginRes.value.ok) { marginRes.value .json() .then((mp) => { if (mp?.description) profile.description = mp.description; if (mp?.followersCount) profile.followersCount = mp.followersCount; if (mp?.followsCount) profile.followsCount = mp.followsCount; if (mp?.postsCount) profile.postsCount = mp.postsCount; if (mp?.website) profile.website = mp.website; if (mp?.links) profile.links = mp.links; }) .catch(() => { /* ignore */ }); } }) .catch(() => { clearTimeout(timeout); });
return profile; } catch { return null; }}