index.js

require('dotenv').config();
const express = require('express');
const http = require('http');
const { Server } = require('socket.io');
const path = require('path');
const cors = require('cors');
const bodyParser = require('body-parser');
const db = require('./services/db');

const app = express();
const server = http.createServer(app);
const io = new Server(server, {
  cors: {
    origin: '*',
    methods: ['GET', 'POST']
  }
});

// Middleware
app.use(cors());
app.use(bodyParser.json());
app.use(express.static(path.join(__dirname, 'public')));

// API Routes
app.use('/api/auth', require('./routes/auth'));
app.use('/api/users', require('./routes/users'));
app.use('/api/chat', require('./routes/chat'));
app.use('/api/groups', require('./routes/groups'));
app.use('/api/status', require('./routes/status'));

// Fallback for SPA (though we use a simple index.html)
app.get('/', (req, res) => {
  res.sendFile(path.join(__dirname, 'public', 'index.html'));
});

// Socket.IO Connection Handling
io.on('connection', (socket) => {
  console.log('User connected:', socket.id);

  socket.on('join_room', (room) => {
    socket.join(room);
    console.log(`User ${socket.id} joined room: ${room}`);
  });

  socket.on('send_message', (data) => {
    // Save to DB
    const newMessage = db.insert('messages', {
      text: data.text,
      senderId: data.senderId,
      senderName: data.senderName,
      groupId: data.groupId || null,
      timestamp: new Date().toISOString()
    });

    // Broadcast to the room (or globally if no groupId)
    const target = data.groupId || 'global';
    if (data.groupId) {
      io.to(data.groupId).emit('receive_message', newMessage);
    } else {
      io.emit('receive_message', newMessage);
    }
  });

  socket.on('status_update', (data) => {
    // Broadcast status change to everyone
    io.emit('status_changed', {
      username: data.username,
      status: data.status,
      updatedAt: new Date().toISOString()
    });
  });

  socket.on('disconnect', () => {
    console.log('User disconnected:', socket.id);
  });
});

const PORT = process.env.PORT || 3000;
server.listen(PORT, () => {
  console.log(`ChatStream server running on port ${PORT}`);
});