Class RuntimeServer

projects/runtime/src/server.ts:141–540

}

export class RuntimeServer {
    private readonly handlers = new Map<string, RegisteredRuntimeHandler>()
    private readonly connections = new Map<string, ConnectedRuntimeConnection>()
    private readonly notifications = new Set<string>()
    private readonly runtimeStopHandlers: RuntimeStopHandler[] = []
    private readonly agentProviders: AgentProviderSummary[]
    private readonly agentProviderResolvers = new Set<() => AgentProviderSummary[]>()
    private readonly protocolVersion: number
    private readonly serverName: string
    private readonly serverVersion?: string
    private readonly notificationLogSize: number
    private readonly clientRequestRetentionMs: number
    private readonly notificationLog: RuntimeNotification[] = []
    private readonly initializedConnections = new Set<string>()
    private readonly clientRequests = new Map<string, RetainedRuntimeRequest>()
    private nextNotificationCursor = 1
    readonly supervisor: RuntimeSupervisor

    constructor(options: RuntimeServerOptions) {
        this.serverName = options.serverName
        this.serverVersion = options.serverVersion
        this.protocolVersion = options.protocolVersion ?? 1
        this.notificationLogSize = Math.max(0, Math.floor(options.notificationLogSize ?? DEFAULT_NOTIFICATION_LOG_SIZE))
        this.clientRequestRetentionMs = Math.max(0, Math.floor(options.clientRequestRetentionMs ?? DEFAULT_CLIENT_REQUEST_RETENTION_MS))
        this.agentProviders = options.agentProviders ?? []
        this.supervisor = new RuntimeSupervisor({ checkpointStore: options.checkpointStore, livenessProbe: options.livenessProbe })

        this.register("initialize", (params, context) => this.initialize(params as RuntimeInitializeParams, context), {
            validateParams: validateRuntimeInitializeParams,
        })
        this.register("server/status/read", (_params, context) => this.serverStatus(context))
        this.register("subscription/update", (params, context) => this.updateSubscription(params as RuntimeSubscriptionUpdateParams, context), {
            validateParams: validateRuntimeSubscriptionUpdateParams,
        })
        this.register("agent/provider/list", () => this.agentProviders)
        this.register("agent/provider/status", (params) => this.agentProviderStatus(params as AgentProviderIdParams), {
            validateParams: validateAgentProviderIdParams,
        })
        this.register("runtime/list", (params) => this.listRuntimes(params as RuntimeListParams), {
            validateParams: validateRuntimeListParams,
        })
        this.register("runtime/read", (params) => this.readRuntime(params as RuntimeIdParams), {
            validateParams: validateRuntimeIdParams,
        })
        this.register("runtime/reconcile", (params) => this.reconcileRuntime(params as RuntimeIdParams), {
            validateParams: validateRuntimeIdParams,
        })
        this.register("runtime/stop", (params, context) => this.stopRuntime(params as RuntimeStopParams, context), {
            validateParams: validateRuntimeStopParams,
        })
        this.registerNotification("runtime/created")
        this.registerNotification("runtime/updated")
        this.registerNotification("runtime/completed")
        this.registerNotification("runtime/failed")
        this.registerNotification("runtime/stopped")
        this.registerNotification("connection/lagged")
    }