Function startRuntimeNodeServe

projects/runtime-node/src/cli.ts:144–194

(config: RuntimeNodeServeConfig)

}

export async function startRuntimeNodeServe(config: RuntimeNodeServeConfig): Promise<RuntimeNodeHttpServer> {
    const agentExecutor = createRuntimeNodeHarnessAgentExecutor()
    const runtime = createRuntimeNodeServer({
        serverName: "runtime-node",
        serverVersion: process.env.RELEASE ?? "headless",
        checkpointStore: createRuntimeNodeCheckpointStore(config.checkpointFile ?? defaultCheckpointFile()),
    })
    const bridgeRegistry = createRuntimeNodeAgentBridgeRegistry()
    const bridgeRegistrations: Array<{ bridge: RuntimeNodeCodexAppServerBridge; unregister: () => void }> = []
    const cleanupRuntimeModules: Array<() => void> = []
    for (const bridgeConfig of config.codexAppServers ?? []) {
        const bridge = createRuntimeNodeCodexAppServerBridge({
            ...bridgeConfig,
            onNotification(method, params) {
                notifyRuntimeNodeAgentBridgeEvent(runtime, method, params)
            },
        })
        bridgeRegistrations.push({ bridge, unregister: registerRuntimeNodeServerProtocolAgentBridge(bridge, bridgeRegistry) })
    }
    const processAdapter = createRuntimeNodeLocalProcessAdapter()
    const ptyAdapter = createRuntimeNodeLocalPtyAdapter()
    registerRuntimeNodeFilesModule(runtime, createRuntimeNodeLocalFilesAdapter())
    registerRuntimeNodeGitModule(runtime, createRuntimeNodeLocalGitAdapter())
    cleanupRuntimeModules.push(registerRuntimeNodeProcessModule(runtime, processAdapter))
    cleanupRuntimeModules.push(registerRuntimeNodePtyModule(runtime, ptyAdapter))
    cleanupRuntimeModules.push(registerRuntimeNodeFsWatchModule(runtime))
    registerRuntimeNodeAgentModule(runtime, agentExecutor, { bridgeRegistry })

    const options: RuntimeNodeHttpServerOptions = {
        runtime,
        host: config.host,
        port: config.port,
        path: config.path,
        token: config.token,
        allowUnauthenticatedLoopback: config.allowUnauthenticatedLoopback,
    }
    const server = await serveRuntimeNodeHttp(options)
    return {
        ...server,
        async close() {
            try {
                await Promise.all(bridgeRegistrations.map(({ bridge }) => bridge.disconnect()))
                await Promise.all([processAdapter.killAll(), ptyAdapter.killAll()])
            } finally {
                for (const cleanup of cleanupRuntimeModules.splice(0).reverse()) cleanup()
                for (const { unregister } of bridgeRegistrations) unregister()
                await server.close()
            }
        },
    }
}

export async function startRuntimeNodeCli(args: string[] = process.argv.slice(2), env: NodeJS.ProcessEnv = process.env): Promise<RuntimeNodeHttpServer> {
    if (args[0] !== "serve") {