inkos/packages/cli/src/commands/daemon.ts

import { Command } from "commander";
import { Scheduler } from "@actalk/inkos-core";
import { loadConfig, findProjectRoot, buildPipelineConfig, log, logError } from "../utils.js";
import { createWriteStream, type WriteStream } from "node:fs";
import { writeFile, readFile, unlink } from "node:fs/promises";
import { join } from "node:path";

const PID_FILE = "inkos.pid";

export const upCommand = new Command("up")
  .description("Start the InkOS daemon (autonomous mode)")
  .option("-q, --quiet", "Suppress console output")
  .action(async (opts) => {
    let logStream: WriteStream | undefined;
    try {
      const config = await loadConfig();
      const root = findProjectRoot();

      // Check if already running
      const pidPath = join(root, PID_FILE);
      try {
        const existingPid = await readFile(pidPath, "utf-8");
        logError(`Daemon already running (PID: ${existingPid.trim()}). Run 'inkos down' first.`);
        process.exit(1);
      } catch {
        // No PID file, good
      }

      log("Starting InkOS daemon...");
      log(`  Write cycle: ${config.daemon.schedule.writeCron}`);
      log(`  Radar scan: ${config.daemon.schedule.radarCron}`);
      log(`  Max concurrent books: ${config.daemon.maxConcurrentBooks}`);
      log("");

      // Write PID file
      await writeFile(pidPath, String(process.pid), "utf-8");

      // File logging for daemon
      const logPath = join(root, "inkos.log");
      logStream = createWriteStream(logPath, { flags: "a" });

      const scheduler = new Scheduler({
        ...buildPipelineConfig(config, root, { logFile: logStream, quiet: opts.quiet }),
        radarCron: config.daemon.schedule.radarCron,
        writeCron: config.daemon.schedule.writeCron,
        maxConcurrentBooks: config.daemon.maxConcurrentBooks,
        chaptersPerCycle: config.daemon.chaptersPerCycle,
        retryDelayMs: config.daemon.retryDelayMs,
        cooldownAfterChapterMs: config.daemon.cooldownAfterChapterMs,
        maxChaptersPerDay: config.daemon.maxChaptersPerDay,
        onChapterComplete: (bookId, chapter, status) => {
          const icon = status === "ready-for-review" ? "+" : "!";
          log(`  [${icon}] ${bookId} Ch.${chapter} — ${status}`);
        },
        onError: (bookId, error) => {
          logError(`${bookId}: ${error.message}`);
        },
      });

      // Handle shutdown
      const shutdown = async () => {
        log("\nShutting down daemon...");
        scheduler.stop();
        logStream?.end();
        try {
          await unlink(pidPath);
        } catch {
          // ignore
        }
        process.exit(0);
      };

      process.on("SIGINT", shutdown);
      process.on("SIGTERM", shutdown);

      await scheduler.start();
      log("Daemon running. Press Ctrl+C to stop.");

      // Keep process alive
      await new Promise(() => {});
    } catch (e) {
      logStream?.end();
      logError(`Failed to start daemon: ${e}`);
      process.exit(1);
    }
  });

export const downCommand = new Command("down")
  .description("Stop the InkOS daemon")
  .action(async () => {
    const root = findProjectRoot();
    const pidPath = join(root, PID_FILE);

    try {
      const pid = (await readFile(pidPath, "utf-8")).trim();
      try {
        process.kill(parseInt(pid, 10), "SIGTERM");
        log(`Daemon (PID: ${pid}) stopped.`);
      } catch {
        log(`Daemon (PID: ${pid}) not found. Cleaning up.`);
      }
      try { await unlink(pidPath); } catch { /* already cleaned up by daemon */ }
    } catch {
      log("No daemon running.");
    }
  });