Server : Apache/2 System : Linux server-15-235-50-60 5.15.0-164-generic #174-Ubuntu SMP Fri Nov 14 20:25:16 UTC 2025 x86_64 User : gositeme ( 1004) PHP Version : 8.2.29 Disable Function : exec,system,passthru,shell_exec,proc_close,proc_open,dl,popen,show_source,posix_kill,posix_mkfifo,posix_getpwuid,posix_setpgid,posix_setsid,posix_setuid,posix_setgid,posix_seteuid,posix_setegid,posix_uname Directory :  /home/gositeme/domains/lavocat.quebec/public_html/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

// Production HTTPS server for lavocat.quebec
// DirectAdmin handles SSL certificates, this server runs on HTTP internally
require('dotenv').config({ path: '.env.production' });

const { createServer } = require('http');
const { parse } = require('url');
const next = require('next');
const WebSocket = require('ws');
const os = require('os');

const dev = false; // Production mode
const hostname = process.env.HOSTNAME || '0.0.0.0';
const port = process.env.PORT || 3443;

// Production Next.js app
const app = next({ 
  dev,
  hostname,
  port,
  conf: require('./next.config.production.js')
});

const handle = app.getRequestHandler();

// Global variables for WebSocket management
global.wsClients = new Map();
global.wsRoomSubscriptions = new Map();
global.wsUserPresence = new Map();

// Helper function to get network IP
const getNetworkIP = () => {
  const interfaces = os.networkInterfaces();
  for (const name of Object.keys(interfaces)) {
    for (const iface of interfaces[name]) {
      if (iface.family === 'IPv4' && !iface.internal) {
        return iface.address;
      }
    }
  }
  return 'localhost';
};

function initializeWebSocketServer(server) {
  if (global.wsServer) {
    console.log('WebSocket server is already running.');
    return;
  }

  const wss = new WebSocket.Server({ 
    server,
    path: '/_ws',
    clientTracking: true,
    maxPayload: 1024 * 1024 // 1MB max payload
  });

  global.wsServer = wss;
  console.log('🚀 WebSocket server initialized for production');

  // WebSocket connection handling
  wss.on('connection', (ws, req) => {
    console.log('✅ WebSocket connection established');
    
    // Message handling
    ws.on('message', (data) => {
      try {
        const message = JSON.parse(data.toString());
        console.log('📨 WebSocket message received:', message.type);
        
        // Handle different message types
        switch (message.type) {
          case 'JOIN_ROOM': {
            const { chatRoomId } = message.data;
            if (chatRoomId) {
              if (!global.wsRoomSubscriptions.has(chatRoomId)) {
                global.wsRoomSubscriptions.set(chatRoomId, new Set());
              }
              global.wsRoomSubscriptions.get(chatRoomId).add(ws);
              console.log(`User joined room ${chatRoomId}`);
            }
            break;
          }
          
          case 'LEAVE_ROOM': {
            const { chatRoomId } = message.data;
            if (chatRoomId && global.wsRoomSubscriptions.has(chatRoomId)) {
              global.wsRoomSubscriptions.get(chatRoomId).delete(ws);
              console.log(`User left room ${chatRoomId}`);
            }
            break;
          }
          
          case 'CHAT_MESSAGE': {
            const { chatRoomId } = message.data;
            if (chatRoomId && global.wsRoomSubscriptions.has(chatRoomId)) {
              const outboundMessage = JSON.stringify(message);
              global.wsRoomSubscriptions.get(chatRoomId).forEach(clientWs => {
                if (clientWs.readyState === WebSocket.OPEN) {
                  clientWs.send(outboundMessage);
                }
              });
            }
            break;
          }
          
          case 'ping': {
            ws.send(JSON.stringify({ type: 'pong' }));
            break;
          }
        }
      } catch (error) {
        console.error('WebSocket message error:', error);
      }
    });

    // Connection close handling
    ws.on('close', (code, reason) => {
      console.log(`🔌 WebSocket connection closed - Code: ${code}, Reason: ${reason}`);
    });

    // Error handling
    ws.on('error', (error) => {
      console.error('❌ WebSocket error:', error);
    });
  });

  // Heartbeat interval
  const interval = setInterval(() => {
    wss.clients.forEach((ws) => {
      if (ws.isAlive === false) {
        return ws.terminate();
      }
      ws.isAlive = false;
      ws.ping();
    });
  }, 30000);

  wss.on('close', () => {
    clearInterval(interval);
  });
}

// Start the application
app.prepare().then(() => {
  // HTTP Server (DirectAdmin handles HTTPS)
  const httpServer = createServer((req, res) => {
    const parsedUrl = parse(req.url, true);
    handle(req, res, parsedUrl);
  });

  initializeWebSocketServer(httpServer);

  httpServer.listen(port, hostname, (err) => {
    if (err) throw err;
    console.log(`🚀 Production HTTP server running on http://${hostname}:${port}`);
    console.log(`🌐 Domain: avocat.quebec (HTTPS handled by DirectAdmin)`);
    console.log(`📊 Environment: Production`);
    console.log(`🔌 WebSocket endpoint: ws://${hostname}:${port}/_ws`);
  });
}).catch((err) => {
  console.error('❌ Error starting production server:', err);
  process.exit(1);
});