Function createRuntimeNodeLocalPtyAdapter

projects/runtime-node/src/localPty.ts:48–157

()

}

export function createRuntimeNodeLocalPtyAdapter(): RuntimeNodePtyAdapter {
    const local: LocalPtyState = {
        active: new Map(),
        listeners: new Set(),
    }

    return {
        addLifecycleListener(listener) {
            local.listeners.add(listener)
            return () => local.listeners.delete(listener)
        },
        async spawn(params: RuntimeNodePtySpawnParams) {
            await assertDirectory(params.cwd)
            const ptyId = params.ptyId || `pty-${randomUUID()}`
            if (local.active.has(ptyId)) return { ok: true }

            const shell = shellCommand()
            const child = spawn(shell, [], {
                cwd: params.cwd,
                env: { ...process.env, ...params.env, TERM: process.env.TERM || "xterm-256color" },
                detached: process.platform !== "win32",
                windowsHide: true,
            })
            const state: ActivePty = {
                process: child,
                output: [],
                completed: false,
                exitCode: null,
                cwd: params.cwd,
            }
            local.active.set(ptyId, state)

            child.stdout?.on("data", (data: Buffer) => {
                const text = data.toString("utf8")
                bufferOutput(state, text)
                emit(local, { type: "output", ptyId, chunk: text })
            })
            child.stderr?.on("data", (data: Buffer) => {
                const text = data.toString("utf8")
                bufferOutput(state, text)
                emit(local, { type: "output", ptyId, chunk: text })
            })
            child.once("exit", (exitCode) => {
                if (state.completed) return
                state.completed = true
                state.exitCode = exitCode ?? 0
                emit(local, { type: "exit", ptyId, exitCode: state.exitCode })
            })
            child.once("error", (error) => {
                if (state.completed) return
                state.completed = true
                state.exitCode = 1
                emit(local, { type: "output", ptyId, chunk: error.message })
                emit(local, { type: "exit", ptyId, exitCode: 1 })
            })

            emit(local, {
                type: "started",