Something went wrong. Try again.
PDS software with bells & whistles you didn’t even know you needed. will move this to its own account when ready.
Something went wrong. Try again.
12 kB · 462 lines
TypeScript
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463import { z } from "zod";import { err, ok, type Result } from "./types/result.ts";import { ApiError } from "./api.ts";import type { AccessToken, Did, Nsid, RefreshToken, Rkey,} from "./types/branded.ts";import { accountInfoSchema, appPasswordSchema, createBackupResponseSchema, createdAppPasswordSchema, createRecordResponseSchema, didDocumentSchema, enableTotpResponseSchema, legacyLoginPreferenceSchema, listBackupsResponseSchema, listPasskeysResponseSchema, listRecordsResponseSchema, listSessionsResponseSchema, listTrustedDevicesResponseSchema, notificationPrefsSchema, passwordStatusSchema, reauthStatusSchema, recordResponseSchema, repoDescriptionSchema, searchAccountsResponseSchema, serverConfigSchema, serverDescriptionSchema, serverStatsSchema, sessionSchema, successResponseSchema, totpSecretSchema, totpStatusSchema, type ValidatedAccountInfo, type ValidatedAppPassword, type ValidatedCreateBackupResponse, type ValidatedCreatedAppPassword, type ValidatedCreateRecordResponse, type ValidatedDidDocument, type ValidatedEnableTotpResponse, type ValidatedLegacyLoginPreference, type ValidatedListBackupsResponse, type ValidatedListPasskeysResponse, type ValidatedListRecordsResponse, type ValidatedListSessionsResponse, type ValidatedListTrustedDevicesResponse, type ValidatedNotificationPrefs, type ValidatedPasswordStatus, type ValidatedReauthStatus, type ValidatedRecordResponse, type ValidatedRepoDescription, type ValidatedSearchAccountsResponse, type ValidatedServerConfig, type ValidatedServerDescription, type ValidatedServerStats, type ValidatedSession, type ValidatedSuccessResponse, type ValidatedTotpSecret, type ValidatedTotpStatus,} from "./types/schemas.ts";
const API_BASE = "/xrpc";
interface XrpcOptions { method?: "GET" | "POST"; params?: Record<string, string>; body?: unknown; token?: string;}
class ValidationError extends Error { constructor( public issues: z.ZodIssue[], message: string = "API response validation failed", ) { super(message); this.name = "ValidationError"; }}
async function xrpcValidated<T>( method: string, schema: z.ZodType<T>, options?: XrpcOptions,): Promise<Result<T, ApiError | ValidationError>> { const { method: httpMethod = "GET", params, body, token } = options ?? {}; let url = `${API_BASE}/${method}`; if (params) { const searchParams = new URLSearchParams(params); url += `?${searchParams}`; } const headers: Record<string, string> = {}; if (token) { headers["Authorization"] = `Bearer ${token}`; } if (body) { headers["Content-Type"] = "application/json"; }
try { const res = await fetch(url, { method: httpMethod, headers, body: body ? JSON.stringify(body) : undefined, });
if (!res.ok) { const errData = await res.json().catch(() => ({ error: "Unknown", message: res.statusText, })); return err(new ApiError(res.status, errData.error, errData.message)); }
const data = await res.json(); const parsed = schema.safeParse(data);
if (!parsed.success) { return err(new ValidationError(parsed.error.issues)); }
return ok(parsed.data); } catch (e) { if (e instanceof ApiError || e instanceof ValidationError) { return err(e); } return err( new ApiError(0, "Unknown", e instanceof Error ? e.message : String(e)), ); }}
export const validatedApi = { getSession( token: AccessToken, ): Promise<Result<ValidatedSession, ApiError | ValidationError>> { return xrpcValidated("com.atproto.server.getSession", sessionSchema, { token, }); },
refreshSession( refreshJwt: RefreshToken, ): Promise<Result<ValidatedSession, ApiError | ValidationError>> { return xrpcValidated("com.atproto.server.refreshSession", sessionSchema, { method: "POST", token: refreshJwt, }); },
createSession( identifier: string, password: string, ): Promise<Result<ValidatedSession, ApiError | ValidationError>> { return xrpcValidated("com.atproto.server.createSession", sessionSchema, { method: "POST", body: { identifier, password }, }); },
describeServer(): Promise< Result<ValidatedServerDescription, ApiError | ValidationError> > { return xrpcValidated( "com.atproto.server.describeServer", serverDescriptionSchema, ); },
listAppPasswords( token: AccessToken, ): Promise< Result<{ passwords: ValidatedAppPassword[] }, ApiError | ValidationError> > { return xrpcValidated( "com.atproto.server.listAppPasswords", z.object({ passwords: z.array(appPasswordSchema) }), { token }, ); },
createAppPassword( token: AccessToken, name: string, scopes?: string, ): Promise<Result<ValidatedCreatedAppPassword, ApiError | ValidationError>> { return xrpcValidated( "com.atproto.server.createAppPassword", createdAppPasswordSchema, { method: "POST", token, body: { name, scopes }, }, ); },
listSessions( token: AccessToken, ): Promise< Result<ValidatedListSessionsResponse, ApiError | ValidationError> > { return xrpcValidated("_account.listSessions", listSessionsResponseSchema, { token, }); },
getTotpStatus( token: AccessToken, ): Promise<Result<ValidatedTotpStatus, ApiError | ValidationError>> { return xrpcValidated("com.atproto.server.getTotpStatus", totpStatusSchema, { token, }); },
createTotpSecret( token: AccessToken, ): Promise<Result<ValidatedTotpSecret, ApiError | ValidationError>> { return xrpcValidated( "com.atproto.server.createTotpSecret", totpSecretSchema, { method: "POST", token, }, ); },
enableTotp( token: AccessToken, code: string, ): Promise<Result<ValidatedEnableTotpResponse, ApiError | ValidationError>> { return xrpcValidated( "com.atproto.server.enableTotp", enableTotpResponseSchema, { method: "POST", token, body: { code }, }, ); },
listPasskeys( token: AccessToken, ): Promise< Result<ValidatedListPasskeysResponse, ApiError | ValidationError> > { return xrpcValidated( "com.atproto.server.listPasskeys", listPasskeysResponseSchema, { token }, ); },
listTrustedDevices( token: AccessToken, ): Promise< Result<ValidatedListTrustedDevicesResponse, ApiError | ValidationError> > { return xrpcValidated( "_account.listTrustedDevices", listTrustedDevicesResponseSchema, { token }, ); },
getReauthStatus( token: AccessToken, ): Promise<Result<ValidatedReauthStatus, ApiError | ValidationError>> { return xrpcValidated("_account.getReauthStatus", reauthStatusSchema, { token, }); },
getNotificationPrefs( token: AccessToken, ): Promise<Result<ValidatedNotificationPrefs, ApiError | ValidationError>> { return xrpcValidated( "_account.getNotificationPrefs", notificationPrefsSchema, { token }, ); },
getDidDocument( token: AccessToken, ): Promise<Result<ValidatedDidDocument, ApiError | ValidationError>> { return xrpcValidated("_account.getDidDocument", didDocumentSchema, { token, }); },
describeRepo( token: AccessToken, repo: Did, ): Promise<Result<ValidatedRepoDescription, ApiError | ValidationError>> { return xrpcValidated( "com.atproto.repo.describeRepo", repoDescriptionSchema, { token, params: { repo }, }, ); },
listRecords( token: AccessToken, repo: Did, collection: Nsid, options?: { limit?: number; cursor?: string; reverse?: boolean }, ): Promise<Result<ValidatedListRecordsResponse, ApiError | ValidationError>> { const params: Record<string, string> = { repo, collection }; if (options?.limit) params.limit = String(options.limit); if (options?.cursor) params.cursor = options.cursor; if (options?.reverse) params.reverse = "true"; return xrpcValidated( "com.atproto.repo.listRecords", listRecordsResponseSchema, { token, params, }, ); },
getRecord( token: AccessToken, repo: Did, collection: Nsid, rkey: Rkey, ): Promise<Result<ValidatedRecordResponse, ApiError | ValidationError>> { return xrpcValidated("com.atproto.repo.getRecord", recordResponseSchema, { token, params: { repo, collection, rkey }, }); },
createRecord( token: AccessToken, repo: Did, collection: Nsid, record: unknown, rkey?: Rkey, ): Promise< Result<ValidatedCreateRecordResponse, ApiError | ValidationError> > { return xrpcValidated( "com.atproto.repo.createRecord", createRecordResponseSchema, { method: "POST", token, body: { repo, collection, record, rkey }, }, ); },
getServerStats( token: AccessToken, ): Promise<Result<ValidatedServerStats, ApiError | ValidationError>> { return xrpcValidated("_admin.getServerStats", serverStatsSchema, { token }); },
getServerConfig(): Promise< Result<ValidatedServerConfig, ApiError | ValidationError> > { return xrpcValidated("_server.getConfig", serverConfigSchema); },
getPasswordStatus( token: AccessToken, ): Promise<Result<ValidatedPasswordStatus, ApiError | ValidationError>> { return xrpcValidated("_account.getPasswordStatus", passwordStatusSchema, { token, }); },
changePassword( token: AccessToken, currentPassword: string, newPassword: string, ): Promise<Result<ValidatedSuccessResponse, ApiError | ValidationError>> { return xrpcValidated("_account.changePassword", successResponseSchema, { method: "POST", token, body: { currentPassword, newPassword }, }); },
getLegacyLoginPreference( token: AccessToken, ): Promise< Result<ValidatedLegacyLoginPreference, ApiError | ValidationError> > { return xrpcValidated( "_account.getLegacyLoginPreference", legacyLoginPreferenceSchema, { token }, ); },
getAccountInfo( token: AccessToken, did: Did, ): Promise<Result<ValidatedAccountInfo, ApiError | ValidationError>> { return xrpcValidated( "com.atproto.admin.getAccountInfo", accountInfoSchema, { token, params: { did }, }, ); },
searchAccounts( token: AccessToken, options?: { handle?: string; cursor?: string; limit?: number }, ): Promise< Result<ValidatedSearchAccountsResponse, ApiError | ValidationError> > { const params: Record<string, string> = {}; if (options?.handle) params.handle = options.handle; if (options?.cursor) params.cursor = options.cursor; if (options?.limit) params.limit = String(options.limit); return xrpcValidated( "com.atproto.admin.searchAccounts", searchAccountsResponseSchema, { token, params, }, ); },
listBackups( token: AccessToken, ): Promise<Result<ValidatedListBackupsResponse, ApiError | ValidationError>> { return xrpcValidated("_backup.listBackups", listBackupsResponseSchema, { token, }); },
createBackup( token: AccessToken, ): Promise< Result<ValidatedCreateBackupResponse, ApiError | ValidationError> > { return xrpcValidated("_backup.createBackup", createBackupResponseSchema, { method: "POST", token, }); },};
export { ValidationError };