import { setupWatch } from "./fileWatch";
import { config, loadConfig } from "./config";
import { setupSocket } from "./networking/webSocket";
import { WebSocket } from "ws";
import signal from "signal-js";
import { RawData } from "ws";
import {
  fileChangeEventToMsg,
  fileRemovalEventToMsg,
  requestFilenames,
  requestDefinitionFile,
} from "./networking/messageGenerators";
import { EventType } from "./eventTypes";
import { messageHandler } from "./networking/messageHandler";
import { FileEvent } from "./interfaces";
import { exit } from "process";
import CheapWatch from "cheap-watch";

export async function start() {
  loadConfig();
  const watch = await setupWatch(signal);
  const socket = setupSocket(signal);

  // Add a handler for received messages.
  signal.on(EventType.MessageReceived, (msg: RawData) => messageHandler(signal, msg, watch.paths));

  console.log(`Server is ready, running on ${config.get("port")}!`);

  process.on("SIGINT", function () {
    console.log("Shutting down!");

    watch.close();
    socket.close();
    process.exit();
  });
}

async function watchMode(watch: CheapWatch) {
  // Add a handler for when a connection to a game is made.
  signal.on(EventType.ConnectionMade, () => {
    console.log("Connection made!");

    if (config.get("definitionFile").update) {
      signal.emit(EventType.MessageSend, requestDefinitionFile());
    }

    if (config.get("pushAllOnConnection")) {
      const extensions = config.get("allowedFiletypes");
      for (const path of watch.paths.keys()) {
        if (extensions.some((extension) => path.endsWith(extension)))
          signal.emit(EventType.MessageSend, fileChangeEventToMsg({ path }));
      }
    } else {
      // Upload missing files to the game.
      signal.emit(EventType.MessageSend, requestFilenames());
    }
  });

  // Add a handler for changed files.
  signal.on(EventType.FileChanged, (fileEvent: FileEvent) => {
    if (!config.get("quiet")) console.log(fileEvent.path + " changed");
    signal.emit(EventType.MessageSend, fileChangeEventToMsg(fileEvent));
  });

  // Add a handler for removed files, if allowed.
  if (config.get("allowDeletingFiles"))
    signal.on(EventType.FileDeleted, (fileEvent: FileEvent) =>
      signal.emit(EventType.MessageSend, fileRemovalEventToMsg(fileEvent)),
    );
}

export async function pull() {
  loadConfig();
  const ws = new WebSocket(`ws://localhost:${config.get("port")}`);

  ws.onopen = () => {
    ws.send(JSON.stringify({ jsonrpc: "2.0", method: "manualPullFromGame", id: Number.MAX_SAFE_INTEGER }));
    ws.close();
    exit(0);
  };
}

export async function push() {
  loadConfig();
  const ws = new WebSocket(`ws://localhost:${config.get("port")}`);

  ws.onopen = () => {
    ws.send(JSON.stringify({ jsonrpc: "2.0", method: "manualPushToGame", id: Number.MAX_SAFE_INTEGER }));
    ws.close();
    exit(0);
  };
}