fishtank-dashboard/server.js

const http = require('http');
const https = require('https');
const fs = require('fs');
const path = require('path');
const url = require('url');
const WebSocket = require('ws');

const PORT = 3000;
const API_TARGET = 'api.fishtank.live';
const CAM_TARGET = 'epyc.goran.jetzt';
const FT_WS_URL = 'wss://ws.fishtank.live/socket.io/?EIO=4&transport=websocket';

// ── Local WS clients (dashboard connections) ────────────────
const localClients = new Set();

// ── Fishtank WS state ────────────────────────────────────────
let ftSocket = null;
let ftToken = null;       // raw JWT (access token only)
let reconnectTimer = null;
let namespaceReady = false;

function broadcast(msg) {
  const data = typeof msg === 'string' ? msg : JSON.stringify(msg);
  for (const client of localClients) {
    if (client.readyState === WebSocket.OPEN) client.send(data);
  }
}

// ── msgpack helpers ──────────────────────────────────────────
function mpStr(s) {
  const b = Buffer.from(s, 'utf8');
  const n = b.length;
  if (n <= 31)  return Buffer.concat([Buffer.from([0xa0 | n]), b]);
  if (n <= 255) return Buffer.concat([Buffer.from([0xd9, n]), b]);
  return Buffer.concat([Buffer.from([0xda, n >> 8, n & 0xff]), b]);
}
function mpBool(v) { return Buffer.from([v ? 0xc3 : 0xc2]); }
function mpMap(pairs) {
  const n = pairs.length;
  const header = n <= 15 ? Buffer.from([0x80 | n]) : Buffer.from([0xde, n >> 8, n & 0xff]);
  return Buffer.concat([header, ...pairs.map(([k, v]) => Buffer.concat([k, v]))]);
}

// Auth frame: { type: 0, data: { token: "<jwt>" }, nsp: "/" }
// type=0 is integer CONNECT, data is a nested map containing the token
function buildAuthFrame(token) {
  const dataMap = mpMap([[mpStr('token'), mpStr(token)]]);
  return mpMap([
    [mpStr('type'), Buffer.from([0x00])],  // integer 0 = CONNECT
    [mpStr('data'), dataMap],
    [mpStr('nsp'),  mpStr('/')],
  ]);
}

// Subscribe frame: { type: 2, data: ['<channel>'], options: {compress:true}, nsp: "/" }
function mpArray(items) {
  const result = [Buffer.from([0x90 | items.length])];
  for (const v of items) result.push(v);
  return Buffer.concat(result);
}
function buildSubscribeFrame(channel) {
  const opts = mpMap([[mpStr('compress'), mpBool(true)]]);
  return mpMap([
    [mpStr('type'),    Buffer.from([0x02])],          // integer 2 = EVENT
    [mpStr('data'),    mpArray([mpStr(channel)])],     // array wrapping channel name
    [mpStr('options'), opts],
    [mpStr('nsp'),     mpStr('/')],
  ]);
}

function sendBinary(buf) {
  if (ftSocket && ftSocket.readyState === WebSocket.OPEN) {
    ftSocket.send(buf, { binary: true });
  }
}

function sendAuthFrame() {
  if (!ftToken) {
    return;
  }
  sendBinary(buildAuthFrame(ftToken));
}

function sendSubscriptions() {
  sendBinary(buildSubscribeFrame('chat:presence'));
  sendBinary(buildSubscribeFrame('presence'));
}

// Presence is client-driven — must re-request every 30s to get updated counts
let presenceTimer = null;

function startPresencePolling() {
  if (presenceTimer) clearInterval(presenceTimer);
  presenceTimer = setInterval(() => {
    if (ftSocket && ftSocket.readyState === 1) {
      sendBinary(buildSubscribeFrame('presence'));
    }
  }, 30000);
}

function stopPresencePolling() {
  if (presenceTimer) { clearInterval(presenceTimer); presenceTimer = null; }
}

// ── Simple msgpack decoder (enough for fishtank events) ─────
function mpDecode(buf, offset = 0) {
  if (offset >= buf.length) return [null, offset];
  const b = buf[offset++];

  // Positive fixint
  if ((b & 0x80) === 0) return [b, offset];
  // Fixmap
  if ((b & 0xf0) === 0x80) {
    const n = b & 0x0f;
    const obj = {};
    for (let i = 0; i < n; i++) {
      const [k, o1] = mpDecode(buf, offset); offset = o1;
      const [v, o2] = mpDecode(buf, offset); offset = o2;
      obj[k] = v;
    }
    return [obj, offset];
  }
  // Fixarray
  if ((b & 0xf0) === 0x90) {
    const n = b & 0x0f;
    const arr = [];
    for (let i = 0; i < n; i++) {
      const [v, o] = mpDecode(buf, offset); offset = o;
      arr.push(v);
    }
    return [arr, offset];
  }
  // Fixstr
  if ((b & 0xe0) === 0xa0) {
    const n = b & 0x1f;
    return [buf.slice(offset, offset + n).toString('utf8'), offset + n];
  }
  // nil
  if (b === 0xc0) return [null, offset];
  // false/true
  if (b === 0xc2) return [false, offset];
  if (b === 0xc3) return [true, offset];
  // str8
  if (b === 0xd9) { const n = buf[offset++]; return [buf.slice(offset, offset + n).toString('utf8'), offset + n]; }
  // str16
  if (b === 0xda) { const n = (buf[offset] << 8) | buf[offset+1]; offset += 2; return [buf.slice(offset, offset + n).toString('utf8'), offset + n]; }
  // str32
  if (b === 0xdb) { const n = (buf[offset] << 16) | (buf[offset+1] << 8) | buf[offset+2] << 8 | buf[offset+3]; offset += 4; return [buf.slice(offset, offset + n).toString('utf8'), offset + n]; }
  // uint8
  if (b === 0xcc) return [buf[offset++], offset];
  // uint16
  if (b === 0xcd) { const n = (buf[offset] << 8) | buf[offset+1]; return [n, offset + 2]; }
  // uint32
  if (b === 0xce) { const n = buf.readUInt32BE(offset); return [n, offset + 4]; }
  // uint64 — read as Number (may lose precision for huge values but fine for timestamps)
  if (b === 0xcf) { const hi = buf.readUInt32BE(offset); const lo = buf.readUInt32BE(offset+4); return [hi * 4294967296 + lo, offset + 8]; }
  // int8
  if (b === 0xd0) return [buf.readInt8(offset), offset + 1];
  // int16
  if (b === 0xd1) return [buf.readInt16BE(offset), offset + 2];
  // int32
  if (b === 0xd2) return [buf.readInt32BE(offset), offset + 4];
  // int64
  if (b === 0xd3) { const hi = buf.readInt32BE(offset); const lo = buf.readUInt32BE(offset+4); return [hi * 4294967296 + lo, offset + 8]; }
  // map16
  if (b === 0xde) {
    const n = (buf[offset] << 8) | buf[offset+1]; offset += 2;
    const obj = {};
    for (let i = 0; i < n; i++) {
      const [k, o1] = mpDecode(buf, offset); offset = o1;
      const [v, o2] = mpDecode(buf, offset); offset = o2;
      obj[k] = v;
    }
    return [obj, offset];
  }
  // array16
  if (b === 0xdc) {
    const n = (buf[offset] << 8) | buf[offset+1]; offset += 2;
    const arr = [];
    for (let i = 0; i < n; i++) {
      const [v, o] = mpDecode(buf, offset); offset = o;
      arr.push(v);
    }
    return [arr, offset];
  }
  // fixext 1,2,4,8,16 — skip type byte + data bytes
  if (b === 0xd4) { offset += 2; return [null, offset]; }   // fixext 1
  if (b === 0xd5) { offset += 3; return [null, offset]; }   // fixext 2
  if (b === 0xd6) { offset += 5; return [null, offset]; }   // fixext 4
  if (b === 0xd7) { offset += 9; return [null, offset]; }   // fixext 8
  if (b === 0xd8) { offset += 17; return [null, offset]; }  // fixext 16
  // ext8, ext16, ext32
  if (b === 0xc7) { const n = buf[offset++]; offset += 1 + n; return [null, offset]; }
  if (b === 0xc8) { const n = (buf[offset] << 8) | buf[offset+1]; offset += 2 + 1 + n; return [null, offset]; }
  if (b === 0xc9) { const n = buf.readUInt32BE(offset); offset += 4 + 1 + n; return [null, offset]; }
  // bin8, bin16, bin32
  if (b === 0xc4) { const n = buf[offset++]; return [buf.slice(offset, offset+n), offset+n]; }
  if (b === 0xc5) { const n = (buf[offset] << 8) | buf[offset+1]; offset += 2; return [buf.slice(offset, offset+n), offset+n]; }
  if (b === 0xc6) { const n = buf.readUInt32BE(offset); offset += 4; return [buf.slice(offset, offset+n), offset+n]; }
  // negative fixint
  if ((b & 0xe0) === 0xe0) return [b - 256, offset];

  return [null, offset];
}

function handleBinaryFrame(buf) {
  try {
    const [packet] = mpDecode(buf);
    if (!packet || typeof packet !== 'object') return;

    const type = packet.type;
    const data = packet.data;

    // type=0 = CONNECT ack: { type: 0, data: { sid, pid }, nsp: "/" }
    if (type === 0 && data && typeof data === 'object' && data.sid) {
      console.log(`[WS] Namespace connected — sid=${data.sid}`);
      namespaceReady = true;
      broadcast({ _ft: 'ws_status', status: 'connected' });
      sendSubscriptions();
      startPresencePolling();
      return;
    }

    // type=2 = EVENT: { type: 2, data: [eventName, ...payloads], nsp: "/" }
    if (type === 2 && Array.isArray(data) && data.length >= 1) {
      const eventName = data[0];
      const eventPayload = data.length === 2 ? data[1] : data.slice(1);

      // Skip internal room/presence bookkeeping
      if (eventName === 'chat:room') {
        return;
      }

      if (eventName !== 'chat:message') {
      }
      broadcast({ _ft: 'event', event: eventName, data: eventPayload });
      return;
    }

    // Anything else — log raw for debugging

  } catch(e) {
    console.log('[WS] Binary decode error:', e.message, e.stack);
  }
}

// ── Connect to fishtank ──────────────────────────────────────
function connectFishtankWS(token) {
  if (ftSocket) { ftSocket.removeAllListeners(); ftSocket.terminate(); ftSocket = null; }
  if (reconnectTimer) { clearTimeout(reconnectTimer); reconnectTimer = null; }
  namespaceReady = false;
  if (token) ftToken = token;

  console.log('\n[WS] Connecting to fishtank...');

  ftSocket = new WebSocket(FT_WS_URL, {
    headers: {
      'origin': 'https://www.fishtank.live',
      'host': 'ws.fishtank.live',
      'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:148.0) Gecko/20100101 Firefox/148.0',
    }
  });

  ftSocket.on('open', () => {
    console.log('[WS] Connected to ws.fishtank.live');
  });

  ftSocket.on('message', (data, isBinary) => {
    if (isBinary) {
      handleBinaryFrame(Buffer.isBuffer(data) ? data : Buffer.from(data));
      return;
    }

    const msg = (Buffer.isBuffer(data) ? data : Buffer.from(data)).toString('utf8');

    // Engine.IO handshake
    if (msg.startsWith('0')) {
      try {
        const info = JSON.parse(msg.slice(1));
        console.log(`[WS] Handshake: sid=${info.sid} pingInterval=${info.pingInterval}ms`);
        broadcast({ _ft: 'ws_status', status: 'connecting' });
      } catch(e) {}
      // Send auth frame right after handshake
      sendAuthFrame();
      return;
    }

    // Server ping — pong back
    if (msg === '2') { ftSocket.send('3'); return; }

  });

  ftSocket.on('close', (code, reason) => {
    console.log(`[WS] Disconnected (${code} ${reason || ''}). Reconnecting in 5s...`);
    broadcast({ _ft: 'ws_status', status: 'disconnected' });
    namespaceReady = false;
    stopPresencePolling();
    reconnectTimer = setTimeout(() => connectFishtankWS(null), 5000);
  });

  ftSocket.on('error', (err) => {
    console.log(`[WS] Error: ${err.message}`);
  });
}

// ── HTTP helpers ─────────────────────────────────────────────
function fetchRemote(hostname, targetPath, callback) {
  const req = https.request({
    hostname, port: 443, path: targetPath, method: 'GET',
    headers: {
      'host': hostname,
      'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
      'accept': '*/*',
      'origin': 'https://www.fishtank.live',
      'referer': 'https://www.fishtank.live/',
    },
  }, (res) => {
    const chunks = [];
    res.on('data', c => chunks.push(c));
    res.on('end', () => callback(null, res, Buffer.concat(chunks)));
  });
  req.on('error', err => callback(err));
  req.end();
}

function rewriteM3u8(body, basePath) {
  return body.split('\n').map(line => {
    const t = line.trim();
    if (!t || t.startsWith('#')) {
      return t.replace(/URI="([^"]+)"/g, (m, uri) =>
        uri.startsWith('http') ? m : `URI="http://localhost:${PORT}/cam${basePath}${uri}"`);
    }
    if (t.startsWith('http')) return t;
    return `http://localhost:${PORT}/cam${basePath}${t}`;
  }).join('\n');
}

function proxyApi(req, res, targetPath) {
  const opts = {
    hostname: API_TARGET, port: 443, path: targetPath, method: req.method,
    headers: { ...req.headers, host: API_TARGET, origin: 'https://www.fishtank.live', referer: 'https://www.fishtank.live/' },
  };
  delete opts.headers['accept-encoding'];
  const proxy = https.request(opts, (apiRes) => {
    res.writeHead(apiRes.statusCode, { ...apiRes.headers, 'access-control-allow-origin': '*', 'access-control-allow-headers': 'Authorization, Content-Type' });
    apiRes.pipe(res);
  });
  proxy.on('error', err => { res.writeHead(502); res.end(err.message); });
  req.pipe(proxy);
}

// ── HTTP server ──────────────────────────────────────────────
const server = http.createServer((req, res) => {
  const parsed = url.parse(req.url);

  if (req.method === 'OPTIONS') {
    res.writeHead(204, { 'access-control-allow-origin': '*', 'access-control-allow-methods': 'GET, POST, OPTIONS', 'access-control-allow-headers': 'Authorization, Content-Type' });
    res.end(); return;
  }

  if (parsed.pathname === '/' || parsed.pathname === '/dashboard') {
    const file = path.join(__dirname, 'fishtank-dashboard.html');
    fs.readFile(file, (err, data) => {
      if (err) { res.writeHead(404); res.end('Dashboard not found'); return; }
      res.writeHead(200, { 'Content-Type': 'text/html' });
      res.end(data);
    }); return;
  }

  if (parsed.pathname === '/chat') {
    const file = path.join(__dirname, 'chat-popout.html');
    fs.readFile(file, (err, data) => {
      if (err) { res.writeHead(404); res.end('Chat not found'); return; }
      res.writeHead(200, { 'Content-Type': 'text/html' });
      res.end(data);
    }); return;
  }

  // Token registration from dashboard
  if (parsed.pathname === '/ws-token' && req.method === 'POST') {
    let body = '';
    req.on('data', c => body += c);
    req.on('end', () => {
      try {
        const { token } = JSON.parse(body);
        if (token && token !== ftToken) {
          console.log('[WS] Token received, reconnecting with auth...');
          connectFishtankWS(token);
        }
      } catch(e) {}
      res.writeHead(200, { 'Content-Type': 'application/json', 'access-control-allow-origin': '*' });
      res.end(JSON.stringify({ ok: true }));
    }); return;
  }

  if (parsed.pathname.startsWith('/api/')) {
    proxyApi(req, res, parsed.pathname.replace('/api', '') + (parsed.search || ''));
    return;
  }

  if (parsed.pathname.startsWith('/cam/')) {
    const targetPath = parsed.pathname.replace('/cam', '') + (parsed.search || '');
    if (!targetPath.includes('.m3u8')) {
      fetchRemote(CAM_TARGET, targetPath, (err, remoteRes, body) => {
        if (err) { res.writeHead(502); res.end(err.message); return; }
        res.writeHead(remoteRes.statusCode, { ...remoteRes.headers, 'access-control-allow-origin': '*' });
        res.end(body);
      }); return;
    }
    fetchRemote(CAM_TARGET, targetPath, (err, remoteRes, body) => {
      if (err) { res.writeHead(502); res.end(err.message); return; }
      if (remoteRes.statusCode !== 200) { res.writeHead(remoteRes.statusCode); res.end(body); return; }
      const basePath = targetPath.substring(0, targetPath.lastIndexOf('/') + 1);
      const rewritten = rewriteM3u8(body.toString('utf8'), basePath);
      res.writeHead(200, { 'content-type': 'application/vnd.apple.mpegurl', 'access-control-allow-origin': '*', 'cache-control': 'no-cache' });
      res.end(rewritten);
    }); return;
  }

  res.writeHead(404); res.end('Not found');
});

// ── Local WebSocket server ───────────────────────────────────
const wss = new WebSocket.Server({ server });
wss.on('connection', (ws) => {
  localClients.add(ws);
  ws.send(JSON.stringify({ _ft: 'ws_status', status: namespaceReady ? 'connected' : 'disconnected' }));
  ws.on('close', () => localClients.delete(ws));
  ws.on('error', () => localClients.delete(ws));
});

// ── Start ────────────────────────────────────────────────────
server.listen(PORT, () => {
  console.log('✓ Dashboard → http://localhost:' + PORT);
  console.log('\nPress Ctrl+C to stop\n');
  connectFishtankWS(null);
});