index.ts

import { watch } from "fs";

import { RPCManager } from "./src/RPCManager";
import { CLIENT_ID, NOW_PLAYING_PATH } from "./src/constants";
import readNowPlaying from "./src/utils/readNowPlaying";
import statesEqual from "./src/utils/statesEqual";


async function main() {
  const rpc = new RPCManager(CLIENT_ID);

  console.log("VLC Discord RPC with Catbox support + Timestamps");
  console.log("Watching:", NOW_PLAYING_PATH);
  console.log();

  let currentState = await readNowPlaying(NOW_PLAYING_PATH);
  await rpc.update(currentState);

  let debounceTimer: Timer | null = null;

  const cleanup = async () => {
    console.log("\nShutting down...");
    await rpc.close();
    console.log("Stopped.");
    process.exit(0);
  };

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

  watch(NOW_PLAYING_PATH, async (eventType) => {
    if (eventType === "change") {
      if (debounceTimer) {
        clearTimeout(debounceTimer);
      }

      debounceTimer = setTimeout(async () => {
        try {
          const newState = await readNowPlaying(NOW_PLAYING_PATH);
          if (!statesEqual(currentState, newState)) {
            await rpc.update(newState);
            currentState = newState;
          }
        } catch (error) {
        }
      }, 50);
    }
  });

  console.log("Watching for changes...");
}

main().catch(console.error);