index.ts

import { file, serve } from "bun";
import ChatManager from "./chatManager";
import UserManager, { User } from "./userManager";
import TTS from "./tts-openai";

const tts = new TTS();
const userManager = new UserManager();
const chatManager = new ChatManager(userManager);

const CORS_HEADERS = {
  headers: {
    "Access-Control-Allow-Origin":
      process.env.FRONTEND_URL || "http://localhost:8080",
    "Access-Control-Allow-Methods": "OPTIONS, POST, GET, PATCH, DELETE",
    "Access-Control-Allow-Headers":
      "Origin, X-Requested-With, Content-Type, Accept",
  },
};

const port = process.env.PORT || 3000;

const server = serve({
  async fetch(req) {
    const url = new URL(req.url);

    // Handle CORS preflight requests
    if (req.method === "OPTIONS") {
      const res = new Response("Departed", CORS_HEADERS);
      return res;
    }

    if (url.pathname === "/") return new Response("Home page!", CORS_HEADERS);

    if (url.pathname === "/tts" && req.method === "POST") {
      // const res = new Response();
      // return res;

      const data = await req.json();
      const text = data?.text;

      const audioBuffer = await tts.create(text);
      if (!audioBuffer) return new Response("An error occured!", CORS_HEADERS);

      const res = new Response(audioBuffer, CORS_HEADERS);
      return res;
    }

    if (url.pathname === "/chat" && req.method === "POST") {
      const message = await req.json();
      if (typeof message !== "object")
        return new Response("An error occured!", CORS_HEADERS);

      const response = await chatManager.handleMessage(message);
      if (!response) return new Response("An error occured!", CORS_HEADERS);
      const answer = {
        content: response,
      };

      return new Response(JSON.stringify(answer), {
        headers: {
          ...CORS_HEADERS.headers,
          "Content-Type": "application/json",
        },
      });
    }

    if (url.pathname === "/profile" && req.method === "POST") {
      const message = await req.json();
      if (typeof message !== "object")
        return new Response("An error occured!", CORS_HEADERS);

      const response = await chatManager.handleProfile(message);
      if (!response) return new Response("An error occured!", CORS_HEADERS);
      const answer = {
        content: response,
      };

      return new Response(JSON.stringify(answer), {
        headers: {
          ...CORS_HEADERS.headers,
          "Content-Type": "application/json",
        },
      });
    }

    if (url.pathname === "/user") {
      // Create user
      if (req.method === "POST") {
        const user = (await req.json()) as User;

        try {
          await userManager.createUser(user);
        } catch (error) {
          console.log(error);
          return new Response("An error occured!", CORS_HEADERS);
        }

        return new Response("200", CORS_HEADERS);
      }

      // Update user
      if (req.method === "PATCH") {
        const user = (await req.json()) as Partial<User> & { id: string };

        try {
          await userManager.updateUser(user);
        } catch (error) {
          return new Response("An error occured!", CORS_HEADERS);
        }

        return new Response("200", CORS_HEADERS);
      }

      // Delete users
    }

    if (url.pathname === "/users") {
      if (req.method === "GET") {
        const users = await userManager.getAllUsers();

        if (!users) return new Response("An error occured!", CORS_HEADERS);

        return new Response(JSON.stringify(users), {
          headers: {
            ...CORS_HEADERS.headers,
            "Content-Type": "application/json",
          },
        });
      }

      if (req.method === "DELETE") {
        const userIds = (await req.json()) as string[];

        // const deletedIds = await userManager.deleteAllUsersExcept(userIds);

        // if (deletedIds === undefined)
        //   return new Response("An error occured!", CORS_HEADERS);

        return new Response("200", CORS_HEADERS);
      }
    }

    return new Response("404!", CORS_HEADERS);
  },
  port,
});

console.log(`Listening on ${server.hostname}:${server.port}`);

// userManager.deleteAllUsersExcept([]);