Function notifyRuntimeNodeAgentBridgeEvent

projects/runtime-node/src/agents.ts:442–462

(server: RuntimeServer, method: string, params: unknown)

}

export function notifyRuntimeNodeAgentBridgeEvent(server: RuntimeServer, method: string, params: unknown): void {
    const record = asRecord(params)
    const providerId = optionalString(record.providerId)
    const threadId = threadIdFromValue(params)
    const turnId = turnIdFromValue(params)
    if (providerId && threadId && turnId && method === "agent/turn/started") {
        createOrUpdateServerProtocolTurnRuntime(server, { providerId, threadId, turnId, status: "running" })
    } else if (providerId && threadId && (method === "agent/turn/completed" || method === "agent/turn/failed")) {
        const targetTurnId = turnId ?? latestServerProtocolTurnRuntime(server, providerId, threadId)?.nativeId
        if (targetTurnId) {
            createOrUpdateServerProtocolTurnRuntime(server, {
                providerId,
                threadId,
                turnId: targetTurnId,
                status: method === "agent/turn/completed" ? "completed" : "failed",
                error: typeof record.error === "string" ? record.error : undefined,
            })
        }
    }
    server.notify(method, params)
}

export function registerRuntimeNodeServerProtocolAgentBridge(
    bridge: RuntimeNodeServerProtocolAgentBridge,