listen.js

import { WebSocket } from "ws";

const AUTH_TOKEN = process.env.AUTH_TOKEN;

if (!AUTH_TOKEN) {
  console.error("❌ Error: Please provide an AUTH_TOKEN variable to run this script.");
  process.exit(1);
}

const subprotocols = ["access_token", AUTH_TOKEN];
const ws = new WebSocket("ws://localhost:5000/ws", subprotocols);

ws.on("open", () => {
  console.log("✅ Connected to WebSocket Server! Watching for database updates...");
});

ws.on("message", (buffer) => {
  try {
    const payload = JSON.parse(buffer.toString());
    console.log("🚀 Live Notification Received:\n", JSON.stringify(payload, null, 2));
  } catch (err) {
    console.log("📡 Raw Notification:", buffer.toString());
  }
});

ws.on("error", (err) => {
  console.error("❌ WebSocket Client Connection Error:", err.message);
});

ws.on("close", () => {
  console.log("🔒 Connection closed safely by the server.");
});