Function registerRuntimeNodePtyModule

projects/runtime-node/src/pty.ts:104–195

(server: RuntimeServer, adapter: RuntimeNodePtyAdapter)

}

export function registerRuntimeNodePtyModule(server: RuntimeServer, adapter: RuntimeNodePtyAdapter): () => void {
    server.registerNotification("pty/started")
    server.registerNotification("pty/output")
    server.registerNotification("pty/exit")
    server.registerNotification("pty/killed")

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

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

        const status = event.type === "killed" ? "stopped" : event.exitCode === 0 ? "completed" : "failed"
        const runtime = server.supervisor.update(ptyRuntimeId(event.ptyId), {
            status,
            exitedAt: now(),
            exitCode: event.type === "killed" ? null : event.exitCode,
            signal: event.type === "killed" ? "killed" : null,
        })
        server.notify(status === "completed" ? "runtime/completed" : status === "stopped" ? "runtime/stopped" : "runtime/failed", runtime)
        server.notify(event.type === "killed" ? "pty/killed" : "pty/exit", event)
    })

    server.register(
        "pty/spawn",
        async (params) => {
            const parsed = ptySpawnParams(params)
            const result = await adapter.spawn(parsed)
            return { ...result, ptyId: parsed.ptyId, runtimeId: ptyRuntimeId(parsed.ptyId) }
        },
        {
            validateParams: validateParams(
                requiredStringParam("cwd"),
                optionalString("ptyId"),
                optionalStringRecordParam("env"),
                optionalPositiveInteger("cols"),