Function handleSpawn

projects/electron/src/modules/code/pty.ts:193–249

(params: SpawnParams)

}

async function handleSpawn(params: SpawnParams): Promise<SpawnResponse> {
    logger.info("[Pty:spawn] Starting", JSON.stringify({ ptyId: params.ptyId, cwd: params.cwd, cols: params.cols, rows: params.rows }))

    try {
        validateCwd(params.cwd)

        if (activePtys.size >= MAX_ACTIVE_PTYS) {
            throw new Error(`Maximum active PTYs (${MAX_ACTIVE_PTYS}) reached`)
        }

        // If PTY already exists, just reconnect
        if (activePtys.has(params.ptyId)) {
            return { ok: true }
        }

        const shell = getDefaultShell()
        const ptyProcess = pty.spawn(shell, [], {
            name: "xterm-256color",
            cols: params.cols,
            rows: params.rows,
            cwd: params.cwd,
            env: { ...(process.env as Record<string, string>), ...params.env },
        })

        activePtys.set(params.ptyId, {
            pty: ptyProcess,
            outputBuffer: [],
            bufferSizeBytes: 0,
            exited: false,
            exitCode: null,
        })

        ptyProcess.onData((data) => {
            sendOutput(params.ptyId, data)
        })

        ptyProcess.onExit(({ exitCode }) => {
            logger.info("[Pty] Process exited", JSON.stringify({ ptyId: params.ptyId, exitCode }))
            sendExit(params.ptyId, exitCode)
        })

        emitLifecycle({
            type: "started",
            ptyId: params.ptyId,
            pid: ptyProcess.pid,
            cwd: params.cwd,
            shell,
        })

        logger.info("[Pty:spawn] PTY created", JSON.stringify({ ptyId: params.ptyId, shell, pid: ptyProcess.pid }))
        return { ok: true }
    } catch (error: unknown) {
        const errorMessage = error instanceof Error ? error.message : "Unknown error"
        logger.error("[Pty:spawn] Error:", JSON.stringify({ error: errorMessage }))
        return { ok: false, error: errorMessage }
    }
}