Something went wrong. Try again.
A lexicon-driven AppView for ATProto.
Something went wrong. Try again.
8.8 kB · 300 lines
TypeScript
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301import type { Key } from "@atproto/jwk";import { ApiError } from "./errors";import { importJwk } from "./import-jwk";import { HappyViewSession } from "./session";import { MemoryStorage } from "./storage";import type { GetSessionResponse, HappyViewOAuthClientOptions, ProvisionKeyResponse, RegisterSessionParams, RegisterSessionResponse, SessionEventHooks, StorageAdapter, StoredSession,} from "./types";
const STORAGE_PREFIX = "happyview:session:";export const LAST_ACTIVE_KEY = "happyview:last-active-did";
export interface FetchMetadataOptions { clientId: string; fetch?: typeof globalThis.fetch; signal?: AbortSignal;}
export class HappyViewOAuthClient { static async fetchMetadata({ clientId, fetch: fetchFn = globalThis.fetch, signal, }: FetchMetadataOptions): Promise<Record<string, unknown>> { signal?.throwIfAborted(); const resp = await fetchFn(clientId, { redirect: "error", signal }); if (resp.status !== 200) { resp.body?.cancel?.(); throw new Error(`Failed to fetch client metadata: ${resp.status}`); } const mime = resp.headers.get("content-type")?.split(";")[0].trim(); if (mime !== "application/json") { resp.body?.cancel?.(); throw new Error(`Invalid client metadata content type: ${mime}`); } return resp.json() as Promise<Record<string, unknown>>; }
protected readonly instanceUrl: string; protected readonly clientKey: string; protected readonly storage: StorageAdapter; private readonly clientSecret: string | undefined; protected readonly _fetch: typeof globalThis.fetch; private readonly sessionHooks: SessionEventHooks;
constructor( options: HappyViewOAuthClientOptions & { fetch?: typeof globalThis.fetch; }, ) { this.instanceUrl = options.instanceUrl.replace(/\/+$/, ""); this.clientKey = options.clientKey; this.clientSecret = options.clientSecret; this.storage = options.storage ?? new MemoryStorage(); this._fetch = options.fetch ?? ((input: RequestInfo | URL, init?: RequestInit) => fetch(input, init)) as typeof globalThis.fetch; this.sessionHooks = options.sessionHooks ?? {}; }
get isConfidential(): boolean { return this.clientSecret !== undefined; }
async provisionDpopKey(): Promise<{ provisionId: string; dpopKey: Key; rawJwk: JsonWebKey; pkceVerifier?: string; }> { const headers: Record<string, string> = { "content-type": "application/json", "x-client-key": this.clientKey, }; if (this.clientSecret) { headers["x-client-secret"] = this.clientSecret; }
const body: Record<string, unknown> = {}; let pkceVerifier: string | undefined;
if (!this.isConfidential) { pkceVerifier = generatePkceVerifier(); const challenge = await computePkceChallenge(pkceVerifier); body.pkce_challenge = challenge; }
const resp = await this._fetch(`${this.instanceUrl}/oauth/dpop-keys`, { method: "POST", headers, body: JSON.stringify(body), });
if (!resp.ok) { const body = await resp.json().catch(() => ({})); throw new ApiError( `Failed to provision DPoP key: ${resp.status} ${(body as any).error ?? (body as any).message ?? resp.statusText}`, resp.status, body, ); }
const data: ProvisionKeyResponse = await resp.json(); const dpopKey = await importJwk(data.dpop_key); return { provisionId: data.provision_id, dpopKey, rawJwk: data.dpop_key, pkceVerifier, }; }
async registerSession( params: RegisterSessionParams, ): Promise<HappyViewSession> { const headers: Record<string, string> = { "content-type": "application/json", "x-client-key": this.clientKey, }; if (this.clientSecret) { headers["x-client-secret"] = this.clientSecret; }
const body: Record<string, unknown> = { provision_id: params.provisionId, did: params.did, access_token: params.accessToken, refresh_token: params.refreshToken, scopes: params.scopes, pds_url: params.pdsUrl, issuer: params.issuer, };
if (!this.isConfidential && params.pkceVerifier) { body.pkce_verifier = params.pkceVerifier; }
const resp = await this._fetch(`${this.instanceUrl}/oauth/sessions`, { method: "POST", headers, body: JSON.stringify(body), });
if (!resp.ok) { const body = await resp.json().catch(() => ({})); throw new ApiError( `Failed to register session: ${resp.status} ${(body as any).error ?? (body as any).message ?? resp.statusText}`, resp.status, body, ); }
const data: RegisterSessionResponse = await resp.json(); const dpopKey = await importJwk(params.dpopKey);
const storedSession: StoredSession = { did: data.did, dpopKey: params.dpopKey, accessToken: params.accessToken, clientKey: this.clientKey, instanceUrl: this.instanceUrl, scopes: params.scopes, pdsUrl: params.pdsUrl, issuer: params.issuer, }; await this.storage.set( `${STORAGE_PREFIX}${data.did}`, JSON.stringify(storedSession), ); await this.storage.set(LAST_ACTIVE_KEY, data.did);
const session = new HappyViewSession({ did: data.did, dpopKey, accessToken: params.accessToken, clientKey: this.clientKey, instanceUrl: this.instanceUrl, scopes: params.scopes, pdsUrl: params.pdsUrl, issuer: params.issuer, fetch: this._fetch, onSignOut: () => this.deleteSession(data.did), });
this.sessionHooks.onSessionUpdate?.(data.did);
return session; }
async deleteSession(did: string): Promise<void> { const session = await this.restoreSession(did); if (session) { const resp = await session.fetchHandler( `${this.instanceUrl}/oauth/sessions/${did}`, { method: "DELETE" }, );
if (!resp.ok && resp.status !== 404) { const body = await resp.json().catch(() => ({})); throw new ApiError( `Failed to delete session: ${resp.status} ${(body as any).error ?? (body as any).message ?? resp.statusText}`, resp.status, body, ); } }
await this.storage.delete(`${STORAGE_PREFIX}${did}`);
const lastActive = await this.storage.get(LAST_ACTIVE_KEY); if (lastActive === did) { await this.storage.delete(LAST_ACTIVE_KEY); }
this.sessionHooks.onSessionDelete?.(did); }
async restoreSession(did: string): Promise<HappyViewSession | null> { const stored = await this.storage.get(`${STORAGE_PREFIX}${did}`); if (!stored) return null;
const data: StoredSession = JSON.parse(stored); const dpopKey = await importJwk(data.dpopKey); return new HappyViewSession({ did: data.did, dpopKey, accessToken: data.accessToken, clientKey: data.clientKey, instanceUrl: data.instanceUrl, scopes: data.scopes, pdsUrl: data.pdsUrl, issuer: data.issuer, fetch: this._fetch, onSignOut: () => this.deleteSession(data.did), }); }
async getSession(did: string): Promise<GetSessionResponse> { const session = await this.restoreSession(did); if (!session) { throw new ApiError("No stored session for this DID", 404, {}); }
const resp = await session.fetchHandler( `${this.instanceUrl}/oauth/sessions/${did}`, { method: "GET" }, );
if (!resp.ok) { const body = await resp.json().catch(() => ({})); throw new ApiError( `Failed to get session: ${resp.status} ${(body as any).error ?? (body as any).message ?? resp.statusText}`, resp.status, body, ); }
return resp.json(); }
async restore(): Promise<HappyViewSession | null> { const did = await this.storage.get(LAST_ACTIVE_KEY); if (!did) return null; return this.restoreSession(did); }}
// PKCE helpers — inline since they're just a few lines of Web Cryptofunction generatePkceVerifier(): string { const bytes = crypto.getRandomValues(new Uint8Array(32)); let binary = ""; for (let i = 0; i < bytes.length; i++) { binary += String.fromCharCode(bytes[i]); } return btoa(binary) .replace(/\+/g, "-") .replace(/\//g, "_") .replace(/=+$/, "");}
async function computePkceChallenge(verifier: string): Promise<string> { const hash = await crypto.subtle.digest( "SHA-256", new TextEncoder().encode(verifier), ); const bytes = new Uint8Array(hash); let binary = ""; for (let i = 0; i < bytes.length; i++) { binary += String.fromCharCode(bytes[i]); } return btoa(binary) .replace(/\+/g, "-") .replace(/\//g, "_") .replace(/=+$/, "");}