vphone-cli/sources/vphone-cli/VPhoneVMLaunchCLI.swift

import ArgumentParser
import Foundation
import VPhoneCore

struct VPhoneVMLaunchCommand: ParsableCommand {
    static let configuration = CommandConfiguration(
        commandName: "launch", abstract: "Boot a VM bundle (runs host preflight first)")

    @OptionGroup var lib: VPhoneLibraryOption
    @Argument(help: "VM name") var name: String?
    @Flag(name: .shortAndLong, help: "Boot into DFU mode (headless)") var dfu = false
    @Option(name: [.customShort("V"), .long], help: "Firmware variant") var variant: String?
    @Flag(name: .customLong("no-vphoned"), help: "Do not stage/use vphoned") var noVphoned = false
    @Option(help: "Kernel GDB debug stub port on host (omit for system-assigned; valid: 6000...65535)")
    var kernelDebugPort: Int?
    @Option(name: .shortAndLong, help: "Resource base override (default: inferred from the running binary path)")
    var projectRoot: String?
    @Flag(name: .customShort("v"), help: "Increase verbosity: -v tool detail, -vv guest serial, -vvv internal trace")
    var verboseCount: Int

    func run() throws {
        let v = VPhoneVerbosity(count: verboseCount)
        let name = try VPhoneVMSelection.resolveExisting(name, in: lib.library)
        let bundle = try lib.library.bundle(named: name)
        let resources = projectRoot.map { VPhoneResources(base: URL(fileURLWithPath: $0)) } ?? .resolve()
        let layout = VPhoneLaunchLayout(resources: resources)

        // The running executable is BOTH what we boot from and what preflight
        // should check — a bundled .app is its own boot binary.
        let bootBinary = VPhoneResources.runningExecutable()
        guard FileManager.default.isExecutableFile(atPath: bootBinary.path) else {
            FileHandle.standardError.write(Data(
                "error: \(bootBinary.path) not found — build it first (make build/bundle).\n".utf8))
            throw ExitCode(1)
        }

        // Host preflight — same gate make boot applies. Point it at THIS binary
        // (VPHONE_CLI_BIN) so it checks the vphone-cli we're running, not a dev
        // .build/release path that doesn't exist inside the bundled .app.
        var preflightArgs = ["--assert-bootable"]
        if variant == "less" { preflightArgs.append("--less") }
        var preflightEnv = ProcessInfo.processInfo.environment
        preflightEnv["VPHONE_CLI_BIN"] = bootBinary.path
        let pre = try VPhoneProcessRunner.runCapturing(
            URL(fileURLWithPath: "/bin/zsh"), [layout.preflightScript.path] + preflightArgs,
            cwd: resources.base, env: preflightEnv)
        if !pre.stdout.isEmpty { print(pre.stdout, terminator: "") }
        guard pre.succeeded else {
            FileHandle.standardError.write(Data(pre.stderr.utf8))
            throw ExitCode(pre.exitCode == 0 ? 1 : pre.exitCode)
        }

        if !dfu && !noVphoned {
            do {
                _ = try layout.stageVphoned(into: bundle)
            } catch {
                FileHandle.standardError.write(Data(
                    "warning: could not stage vphoned into \(bundle.name): \(error)\n".utf8))
            }
        }

        var args = ["--config", bundle.configURL.path]
        if dfu { args.append("--dfu") }
        if let variant { args += ["--variant", variant] }
        if noVphoned { args.append("--no-vphoned") }
        if let kernelDebugPort { args += ["--kernel-debug-port", String(kernelDebugPort)] }

        if v.tracesInternals {
            print("[trace] spawning: \(bootBinary.path) \(args.joined(separator: " "))")
        }

        let child = Process()
        child.executableURL = bootBinary
        child.arguments = args
        child.currentDirectoryURL = bundle.url
        // `vm launch` always streams the guest serial console (inherits our
        // stdio); it is intentionally not gated on verbosity.
        try child.run()

        // Forward SIGINT to the child so Ctrl+C stops the VM cleanly.
        let sigint = DispatchSource.makeSignalSource(signal: SIGINT, queue: .main)
        signal(SIGINT, SIG_IGN)
        sigint.setEventHandler { child.interrupt() }
        sigint.resume()

        child.waitUntilExit()
        throw ExitCode(child.terminationStatus)
    }
}

// MARK: - vm stop

struct VPhoneVMStopCommand: ParsableCommand {
    static let configuration = CommandConfiguration(
        commandName: "stop", abstract: "Stop a running VM bundle")

    @OptionGroup var lib: VPhoneLibraryOption
    @Argument(help: "VM name") var name: String?
    @Option(name: .shortAndLong, help: "Seconds to wait for graceful shutdown before SIGKILL") var timeout: Int = 20

    func run() throws {
        let name = try VPhoneVMSelection.resolveExisting(name, in: lib.library)
        let bundle = try lib.library.bundle(named: name)
        let disk = bundle.url.appendingPathComponent(bundle.manifest.diskImage)

        func runningPIDs() -> [Int32] {
            guard let r = try? VPhoneProcessRunner.runCapturing(
                URL(fileURLWithPath: "/usr/sbin/lsof"), ["-t", "--", disk.path]) else { return [] }
            return VPhoneLsof.parsePIDs(r.stdout)
        }

        let pids = runningPIDs()
        guard !pids.isEmpty else { print("\(name): not running"); return }

        print("\(name): sending SIGINT to \(pids.map(String.init).joined(separator: ", "))")
        for pid in pids { kill(pid, SIGINT) }

        var waited = 0
        while waited < timeout, !runningPIDs().isEmpty {
            Thread.sleep(forTimeInterval: 1)
            waited += 1
        }
        let survivors = runningPIDs()
        if !survivors.isEmpty {
            print("\(name): force-killing \(survivors.map(String.init).joined(separator: ", "))")
            for pid in survivors { kill(pid, SIGKILL) }
        }
        print("\(name): stopped")
    }
}