index.ts

import "dotenv/config";
import OpenAI from "openai";
import readline from "readline";
import { createAssistant } from "./openai/createAssistant.js";
import { createThread } from "./openai/createThread.js";
import { createRun } from "./openai/createRun.js";
import { performRun } from "./openai/performRuns.js";

import type { Thread } from "openai/resources/beta/threads/threads";
import type { Assistant } from "openai/resources/beta/assistants";

const client = new OpenAI();

// Create interface for reading from command line
const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout,
});

// Type-safe promise-based question function
const question = (query: string): Promise<string> => {
  return new Promise((resolve) => rl.question(query, resolve));
};

async function chat(thread: Thread, assistant: Assistant): Promise<void> {
  while (true) {
    // Get user input
    const userInput = await question("\nYou: ");

    // Allow user to exit
    if (userInput.toLowerCase() === "exit") {
      rl.close();
      break;
    }

    try {
      // Add the user's message to the thread
      await client.beta.threads.messages.create(thread.id, {
        role: "user",
        content: userInput,
      });

      // Create and perform the run
      const run = await createRun(client, thread, assistant.id);
      const result = await performRun(run, client, thread);

      if (result?.type === "text") {
        console.log("\nAlt:", result.text.value);
      }
    } catch (error) {
      console.error(
        "Error during chat:",
        error instanceof Error ? error.message : "Unknown error"
      );
      rl.close();
      break;
    }
  }
}

async function main(): Promise<void> {
  try {
    const assistant = await createAssistant(client);
    const thread = await createThread(client);

    console.log('Chat started! Type "exit" to end the conversation.');
    await chat(thread, assistant);
  } catch (error) {
    console.error(
      "Error in main:",
      error instanceof Error ? error.message : "Unknown error"
    );
    rl.close();
    process.exit(1);
  }
}

main().catch((error) => {
  console.error(
    "Unhandled error:",
    error instanceof Error ? error.message : "Unknown error"
  );
  process.exit(1);
});