Function registerRuntimeNodeProcessModule

projects/runtime-node/src/process.ts:110–228

(server: RuntimeServer, adapter: RuntimeNodeProcessAdapter)

}

export function registerRuntimeNodeProcessModule(server: RuntimeServer, adapter: RuntimeNodeProcessAdapter): () => void {
    server.registerNotification("process/started")
    server.registerNotification("process/output")
    server.registerNotification("process/exit")
    server.registerNotification("process/error")

    const removeLifecycleListener = adapter.addLifecycleListener((event) => {
        if (event.type === "started") {
            const runtime = server.supervisor.create({
                runtimeId: processRuntimeId(event.processId),
                kind: "process",
                status: "running",
                scope: {
                    ownerType: "process",
                    ownerId: event.processId,
                    rootPath: event.cwd,
                },
                nativeId: event.processId,
                pid: event.pid,
                pgid: event.pgid,
                processLabel: event.label,
                processStartedAt: event.processStartedAt ?? now(),
            })
            server.notify("runtime/created", runtime)
            server.notify("process/started", { ...event, runtimeId: runtime.runtimeId })
            return
        }

        if (event.type === "output") {
            server.supervisor.touchByOwner("process", event.processId)
            server.notify("process/output", event)
            return
        }

        if (event.type === "exit") {
            const status = event.signal ? "stopped" : event.exitCode === 0 ? "completed" : "failed"
            const runtimeId = processRuntimeId(event.processId)
            const current = server.supervisor.get(runtimeId)
            if (!isTerminalStatus(current?.status)) {
                const runtime = server.supervisor.update(runtimeId, {
                    status,
                    exitedAt: now(),
                    exitCode: event.exitCode,
                    signal: event.signal,
                })
                server.notify(status === "completed" ? "runtime/completed" : status === "stopped" ? "runtime/stopped" : "runtime/failed", runtime)
            }
            server.notify("process/exit", event)
            return
        }

        const runtimeId = processRuntimeId(event.processId)
        const current = server.supervisor.get(runtimeId)
        if (!isTerminalStatus(current?.status)) {
            const runtime = server.supervisor.update(runtimeId, {
                status: "failed",
                error: event.error,
            })