index.ts

import readline from "node:readline/promises";
import { app } from "./src/app/graph";
import { printBanner, printMessage, printDivider } from "./src/cli/tui";
import { createLogger } from "./src/lib/logger";

const appLogger = createLogger("cli");

async function main() {
  printBanner();
  appLogger.info("Agent CLI started.");

  const rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout,
  });

  while (true) {
    const userInput = await rl.question("\n> ");
    if (userInput.toLowerCase() === "exit") break;

    appLogger.info("User input received.");

    try {
      const finalState = await app.invoke(
        {
          messages: [{ role: "human", content: userInput }],
        },
        {
          configurable: {
            thread_id: "1",
          },
        },
      );

      appLogger.info("Agent response generated.");

      const lastMessage = finalState.messages.at(-1);

      if (lastMessage?.content) {
        printMessage("AI:", lastMessage.content as string);
      }

      printDivider();
    } catch (err) {
      appLogger.error("Failed to process user input.", {
        error: err instanceof Error ? err.message : String(err),
      });
    }
  }

  rl.close();
  appLogger.info("Agent CLI stopped.");
}

main().catch((err) => {
  appLogger.error("Fatal startup error.", {
    error: err instanceof Error ? err.message : String(err),
  });
  process.exit(1);
});