Function registerRuntimeNodeAgentModule

projects/runtime-node/src/agents.ts:642–1004

(
    server: RuntimeServer,
    executor: RuntimeNodeAgentExecutor = createRuntimeNodeHarnessAgentExecutor(),
    options: RuntimeNodeAgentModuleOptions = {}
)

}

export function registerRuntimeNodeAgentModule(
    server: RuntimeServer,
    executor: RuntimeNodeAgentExecutor = createRuntimeNodeHarnessAgentExecutor(),
    options: RuntimeNodeAgentModuleOptions = {}
): void {
    const bridgeRegistry = options.bridgeRegistry ?? defaultServerProtocolBridgeRegistry

    server.registerNotification("agent/event")
    server.registerNotification("agent/thread/started")
    server.registerNotification("agent/thread/resumed")
    server.registerNotification("agent/turn/started")
    server.registerNotification("agent/turn/delta")
    server.registerNotification("agent/turn/completed")
    server.registerNotification("agent/turn/failed")
    server.registerNotification("agent/approval/requested")
    server.registerNotification("agent/goal/updated")
    server.registerNotification("agent/goal/cleared")
    server.registerAgentProviderResolver(() => [...executor.providers(), ...[...bridgeRegistry.bridges.values()].map(bridgeSummary)])

    server.register("agent/provider/list", () => server.capabilities().agentProviders)
    server.register("agent/provider/status", async (params) => {
        const providerId = optionalString(asRecord(params).providerId)
        const bridge = providerId ? bridgeRegistry.bridges.get(providerId) : undefined
        if (bridge) {
            return {
                providerId,
                connected: true,
                state: "available",
                capabilities: bridgeCapabilities(bridge),
                detail: bridge.status ? await bridge.status() : undefined,
            }
        }
        const status = await executor.status(providerId)
        const providerKnown = providerId ? executor.providers().some((provider) => provider.providerId === providerId) : true
        return { providerId: providerId ?? "all", connected: providerKnown && status !== null, state: providerKnown && status ? "available" : "unavailable", status: providerKnown ? status : null }
    })
    server.register("agent/provider/read", (params) => {
        const id = providerId(params)
        return server.capabilities().agentProviders.find((provider) => provider.providerId === id) ?? null
    }, providerParams)
    server.register("agent/model/list", async (params) => {
        const record = asRecord(params)
        const id = optionalString(record.providerId)
        const bridge = id ? bridgeRegistry.bridges.get(id) : undefined
        if (bridge) {
            if (!bridge.listModels) throw new RuntimeHandlerError("unsupported_capability", `Agent provider ${id} does not support model listing`)
            return bridge.listModels({ providerId: bridge.providerId })
        }
        return executor.models?.(id) ?? []
    })
    server.register("agent/serverProtocol/list", () =>
        [...bridgeRegistry.bridges.values()].map((bridge) => ({
            providerId: bridge.providerId,
            label: bridge.label ?? bridge.providerId,
            connected: true,
            capabilities: bridgeCapabilities(bridge),
        }))
    )