/** * GENERATED CODE - DO NOT MODIFY */ import { AuthVerifier, createServer as createXrpcServer, StreamAuthVerifier, Options as XrpcOptions, Server as XrpcServer, } from '@atproto/xrpc-server' import { schemas } from './lexicons.js' import * as ComAtprotoRepoApplyWrites from './types/com/atproto/repo/applyWrites.js' import * as ComAtprotoRepoCreateRecord from './types/com/atproto/repo/createRecord.js' import * as ComAtprotoRepoDeleteRecord from './types/com/atproto/repo/deleteRecord.js' import * as ComAtprotoRepoDescribeRepo from './types/com/atproto/repo/describeRepo.js' import * as ComAtprotoRepoGetRecord from './types/com/atproto/repo/getRecord.js' import * as ComAtprotoRepoImportRepo from './types/com/atproto/repo/importRepo.js' import * as ComAtprotoRepoListMissingBlobs from './types/com/atproto/repo/listMissingBlobs.js' import * as ComAtprotoRepoListRecords from './types/com/atproto/repo/listRecords.js' import * as ComAtprotoRepoPutRecord from './types/com/atproto/repo/putRecord.js' import * as ComAtprotoRepoUploadBlob from './types/com/atproto/repo/uploadBlob.js' import * as XyzStatusphereGetStatuses from './types/xyz/statusphere/getStatuses.js' import * as XyzStatusphereGetUser from './types/xyz/statusphere/getUser.js' import * as XyzStatusphereSendStatus from './types/xyz/statusphere/sendStatus.js' export function createServer(options?: XrpcOptions): Server { return new Server(options) } export class Server { xrpc: XrpcServer xyz: XyzNS com: ComNS app: AppNS constructor(options?: XrpcOptions) { this.xrpc = createXrpcServer(schemas, options) this.xyz = new XyzNS(this) this.com = new ComNS(this) this.app = new AppNS(this) } } export class XyzNS { _server: Server statusphere: XyzStatusphereNS constructor(server: Server) { this._server = server this.statusphere = new XyzStatusphereNS(server) } } export class XyzStatusphereNS { _server: Server constructor(server: Server) { this._server = server } getStatuses( cfg: ConfigOf< AV, XyzStatusphereGetStatuses.Handler>, XyzStatusphereGetStatuses.HandlerReqCtx> >, ) { const nsid = 'xyz.statusphere.getStatuses' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } getUser( cfg: ConfigOf< AV, XyzStatusphereGetUser.Handler>, XyzStatusphereGetUser.HandlerReqCtx> >, ) { const nsid = 'xyz.statusphere.getUser' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } sendStatus( cfg: ConfigOf< AV, XyzStatusphereSendStatus.Handler>, XyzStatusphereSendStatus.HandlerReqCtx> >, ) { const nsid = 'xyz.statusphere.sendStatus' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } } export class ComNS { _server: Server atproto: ComAtprotoNS constructor(server: Server) { this._server = server this.atproto = new ComAtprotoNS(server) } } export class ComAtprotoNS { _server: Server repo: ComAtprotoRepoNS constructor(server: Server) { this._server = server this.repo = new ComAtprotoRepoNS(server) } } export class ComAtprotoRepoNS { _server: Server constructor(server: Server) { this._server = server } applyWrites( cfg: ConfigOf< AV, ComAtprotoRepoApplyWrites.Handler>, ComAtprotoRepoApplyWrites.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.applyWrites' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } createRecord( cfg: ConfigOf< AV, ComAtprotoRepoCreateRecord.Handler>, ComAtprotoRepoCreateRecord.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.createRecord' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } deleteRecord( cfg: ConfigOf< AV, ComAtprotoRepoDeleteRecord.Handler>, ComAtprotoRepoDeleteRecord.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.deleteRecord' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } describeRepo( cfg: ConfigOf< AV, ComAtprotoRepoDescribeRepo.Handler>, ComAtprotoRepoDescribeRepo.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.describeRepo' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } getRecord( cfg: ConfigOf< AV, ComAtprotoRepoGetRecord.Handler>, ComAtprotoRepoGetRecord.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.getRecord' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } importRepo( cfg: ConfigOf< AV, ComAtprotoRepoImportRepo.Handler>, ComAtprotoRepoImportRepo.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.importRepo' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } listMissingBlobs( cfg: ConfigOf< AV, ComAtprotoRepoListMissingBlobs.Handler>, ComAtprotoRepoListMissingBlobs.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.listMissingBlobs' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } listRecords( cfg: ConfigOf< AV, ComAtprotoRepoListRecords.Handler>, ComAtprotoRepoListRecords.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.listRecords' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } putRecord( cfg: ConfigOf< AV, ComAtprotoRepoPutRecord.Handler>, ComAtprotoRepoPutRecord.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.putRecord' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } uploadBlob( cfg: ConfigOf< AV, ComAtprotoRepoUploadBlob.Handler>, ComAtprotoRepoUploadBlob.HandlerReqCtx> >, ) { const nsid = 'com.atproto.repo.uploadBlob' // @ts-ignore return this._server.xrpc.method(nsid, cfg) } } export class AppNS { _server: Server bsky: AppBskyNS constructor(server: Server) { this._server = server this.bsky = new AppBskyNS(server) } } export class AppBskyNS { _server: Server actor: AppBskyActorNS constructor(server: Server) { this._server = server this.actor = new AppBskyActorNS(server) } } export class AppBskyActorNS { _server: Server constructor(server: Server) { this._server = server } } type SharedRateLimitOpts = { name: string calcKey?: (ctx: T) => string | null calcPoints?: (ctx: T) => number } type RouteRateLimitOpts = { durationMs: number points: number calcKey?: (ctx: T) => string | null calcPoints?: (ctx: T) => number } type HandlerOpts = { blobLimit?: number } type HandlerRateLimitOpts = SharedRateLimitOpts | RouteRateLimitOpts type ConfigOf = | Handler | { auth?: Auth opts?: HandlerOpts rateLimit?: HandlerRateLimitOpts | HandlerRateLimitOpts[] handler: Handler } type ExtractAuth = Extract< Awaited>, { credentials: unknown } >