Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465import type { Did } from "@atcute/lexicons/syntax";import { OAuthUserAgent, deleteStoredSession, getSession, type Session} from "@atcute/oauth-browser-client";import { clearOrgDids, forgetOrgDid, loadOrgControllers, loadOrgDids, orgDidsControlledBy} from "$lib/auth/accounts";
// org sessions are minted from a controller's session and are useless to the// user once that controller signs out, so they get revoked alongside itexport interface OrgSessionDependencies { loadOrgDids: () => Did[]; loadOrgControllers: () => Record<string, Did>; getSession: (sub: Did, options?: { allowStale?: boolean }) => Promise<Session>; createAgent: (session: Session) => Pick<OAuthUserAgent, "signOut">; deleteStoredSession: (sub: Did) => void; forgetOrgDid: (did: Did) => void; clearOrgDids: () => void;}
const defaultDependencies: OrgSessionDependencies = { loadOrgDids, loadOrgControllers, getSession, createAgent: (session) => new OAuthUserAgent(session), deleteStoredSession, forgetOrgDid, clearOrgDids};
const revokeOne = async (orgDid: Did, deps: OrgSessionDependencies): Promise<void> => { try { // allowStale skips a refresh, the token is about to be revoked anyway const session = await deps.getSession(orgDid, { allowStale: true }); await deps.createAgent(session).signOut(); } catch { // nothing to revoke, or the pds refused, either way drop the local copy deps.deleteStoredSession(orgDid); }};
export const revokeOrgSessionsFor = async ( controllerDid: Did, deps: OrgSessionDependencies = defaultDependencies): Promise<void> => { const orgDids = orgDidsControlledBy(deps.loadOrgControllers(), controllerDid); await Promise.allSettled(orgDids.map((orgDid) => revokeOne(orgDid, deps))); for (const orgDid of orgDids) deps.forgetOrgDid(orgDid);};
export const revokeAllOrgSessions = async ( deps: OrgSessionDependencies = defaultDependencies): Promise<void> => { const orgDids = deps.loadOrgDids(); await Promise.allSettled(orgDids.map((orgDid) => revokeOne(orgDid, deps))); deps.clearOrgDids();};