Upload 126 files

archives/neonstrike/app/server/index.js

@@ -197,7 +197,7 @@ const server = http.createServer((req, res) => {
 
 // ---------------- websocket wiring ----------------
 
-const wss = new WebSocketServer({ server, path: '/ws' });
+const wss = new WebSocketServer({ server, path: '/ws', perMessageDeflate: false });
 
 wss.on('connection', (ws) => {
   ws.isAlive = true;

archives/rblx/app/server/realtime.js

@@ -343,12 +343,14 @@ function handleStudioMsg(ws, member, st, msg) {
 // ---------------- wiring ----------------
 
 function attach(server, apiRouter) {
-  const wss = new WebSocketServer({ server, path: '/ws' });
+  const wss = new WebSocketServer({ server, path: '/ws', perMessageDeflate: false });
   wss.on('error', () => {}); // http server owns error handling (port retry)
   apiRouter.presence = () => presence;
 
   wss.on('connection', (ws, req) => {
+    console.log('[RBLX-WS] Connection request, cookie:', req.headers.cookie);
     const user = userFromReq(req);
+    console.log('[RBLX-WS] User resolved:', user ? user.username : 'null');
     if (!user) {
       send(ws, { t: 'error', error: 'Not logged in' });
       ws.close();

server/index.js

@@ -102,32 +102,73 @@ function getRefererProxy(port) {
     refererProxies[port] = createProxyMiddleware({
       target: `http://localhost:${port}`,
       changeOrigin: true,
-      ws: true,
       logLevel: 'silent',
     });
   }
   return refererProxies[port];
 }
 
-// 1. Redirect /play/:id to /play/:id/ to ensure proper relative asset resolution
+// 1. Redirect /play/:id to /play/:id/ to ensure proper relative asset resolution and set active_game cookie
 app.use((req, res, next) => {
-  const match = req.path.match(/^\/play\/([^\/]+)$/);
+  const match = req.path.match(/^\/play\/([^\/]+)/);
   if (match) {
-    return res.redirect(301, `${req.path}/`);
+    const gameId = match[1];
+    const isSecure = req.secure || req.headers['x-forwarded-proto'] === 'https';
+    res.cookie('active_game', gameId, {
+      path: '/',
+      sameSite: isSecure ? 'none' : 'lax',
+      secure: isSecure
+    });
+    if (req.path === `/play/${gameId}`) {
+      return res.redirect(301, `${req.path}/`);
+    }
   }
   next();
 });
 
-// 2. Referer-based HTTP proxy for absolute paths (e.g. /css/..., /js/..., /api/...)
+// Helper to extract game ID from referer or cookies
+function getGameId(req) {
+  const referer = req.headers.referer || '';
+  
+  // 1. Try to extract game ID directly from Referer (e.g. /play/rblx/...)
+  const refMatch = referer.match(/\/play\/([^\/]+)/);
+  if (refMatch) {
+    return refMatch[1];
+  }
+
+  // 2. Determine if the referer is the main portal page (path is exactly "/")
+  let isPortal = false;
+  if (referer) {
+    try {
+      const refUrl = new URL(referer);
+      if (refUrl.pathname === '/') {
+        isPortal = true;
+      }
+    } catch (e) {
+      // Ignore URL parsing errors
+    }
+  }
+
+  // 3. Fallback to cookie if we are not on the portal page
+  if (!isPortal) {
+    const cookieHeader = req.headers.cookie || '';
+    const cookieMatch = cookieHeader.match(/(?:^|; )active_game=([^;]*)/);
+    if (cookieMatch) {
+      return cookieMatch[1];
+    }
+  }
+
+  return null;
+}
+
+// 2. Referer/Cookie-based HTTP proxy for absolute paths (e.g. /css/..., /js/..., /api/...)
 app.use((req, res, next) => {
   if (req.path === '/ws') return next();
   if (req.path.startsWith('/api/entries') || req.path.startsWith('/archives') || req.path.startsWith('/play/')) {
     return next();
   }
-  const referer = req.headers.referer || '';
-  const match = referer.match(/\/play\/([^\/]+)/);
-  if (match) {
-    const gameId = match[1];
+  const gameId = getGameId(req);
+  if (gameId) {
     const port = gamePorts[gameId];
     if (port) {
       const proxy = getRefererProxy(port);
@@ -138,13 +179,11 @@ app.use((req, res, next) => {
 });
 
 // 3. WS Proxy specifically for WebSocket connections to /ws
-app.use('/ws', createProxyMiddleware({
+const wsProxy = createProxyMiddleware({
   target: 'http://localhost:3000', // dummy fallback, overridden by router
   router: (req) => {
-    const referer = req.headers.referer || '';
-    const match = referer.match(/\/play\/([^\/]+)/);
-    if (match) {
-      const gameId = match[1];
+    const gameId = getGameId(req);
+    if (gameId) {
       const port = gamePorts[gameId];
       if (port) {
         return `http://localhost:${port}`;
@@ -155,7 +194,13 @@ app.use('/ws', createProxyMiddleware({
   changeOrigin: true,
   ws: true,
   logLevel: 'silent',
-}));
+  on: {
+    error: (err, req, res) => {
+      console.error('[ws-proxy] error:', err);
+    }
+  }
+});
+app.use('/ws', wsProxy);
 
 app.use('/archives', express.static(ARCHIVES_DIR));
 app.use(express.static(path.join(__dirname, '..', 'public')));
@@ -203,7 +248,6 @@ async function startGameServers() {
     app.use(`/play/${entry.id}`, createProxyMiddleware({
       target: `http://localhost:${port}`,
       changeOrigin: true,
-      ws: true,
     }));
 
     console.log(`[proxy] /play/${entry.id} -> http://localhost:${port}`);
@@ -234,6 +278,7 @@ function cleanup() {
 
 function listen(port) {
   const srv = app.listen(port);
+  srv.on('upgrade', wsProxy.upgrade);
   srv.on('error', (err) => {
     if (err.code === 'EADDRINUSE') {
       console.log(`port ${port} busy, trying ${port + 1}`);