Method constructor

projects/runtime/src/server.ts:159–197

(options: RuntimeServerOptions)

    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")
    }

    register(method: string, handler: RuntimeHandler, options: RuntimeRegisterOptions = {}): void {
        this.handlers.set(method, { handler, validateParams: options.validateParams })