server.js

const http = require('http');

// Простой HTTP сервер для проверки
const httpServer = http.createServer((req, res) => {
    res.writeHead(200, { 'Content-Type': 'text/plain' });
    res.end('USCaller Server is running!');
});

httpServer.listen(8081, () => {
    console.log('✅ HTTP test server on port 8081');
});

const WebSocket = require('ws');

const PORT = process.env.PORT || 8080;
const wss = new WebSocket.Server({ port: PORT });

console.log(`🎧 USCaller Server started on port ${PORT}`);
console.log('📡 Waiting for connections...');

const users = new Map();

wss.on('connection', (ws, request) => {
    const clientIp = request.socket.remoteAddress;
    console.log(`✅ New connection from: ${clientIp}`);
    
    let currentUser = null;

    ws.on('message', (message) => {
        try {
            const data = JSON.parse(message);
            console.log(`📨 ${data.type} from ${data.nickname || 'unknown'}`);
            
            switch (data.type) {
                case 'register':
                    currentUser = data.nickname;
                    users.set(data.nickname, ws);
                    console.log(`👤 User registered: ${data.nickname}`);
                    broadcastUserList();
                    break;
                    
                case 'call':
                    console.log(`📞 Call from ${currentUser} to ${data.target}`);
                    const targetUser = users.get(data.target);
                    if (targetUser && targetUser.readyState === WebSocket.OPEN) {
                        targetUser.send(JSON.stringify({
                            type: 'incoming_call',
                            from: currentUser
                        }));
                        console.log(`✅ Call request sent to ${data.target}`);
                    } else {
                        console.log(`❌ User ${data.target} not found or offline`);
                        ws.send(JSON.stringify({
                            type: 'error',
                            message: 'User not available'
                        }));
                    }
                    break;
                    
                case 'answer':
                    console.log(`✅ Call answered by ${currentUser}`);
                    const caller = users.get(data.target);
                    if (caller && caller.readyState === WebSocket.OPEN) {
                        caller.send(JSON.stringify({
                            type: 'call_accepted',
                            from: currentUser
                        }));
                    }
                    break;
                    
                case 'end_call':
                    console.log(`❌ Call ended by ${currentUser}`);
                    users.forEach((userWs, nickname) => {
                        if (userWs.readyState === WebSocket.OPEN && userWs !== ws) {
                            userWs.send(JSON.stringify({
                                type: 'call_ended'
                            }));
                        }
                    });
                    break;
                    
                case 'get_users':
                    broadcastUserList();
                    break;
            }
        } catch (error) {
            console.error('❌ Error parsing message:', error);
        }
    });
    
    ws.on('close', () => {
        console.log(`❌ User disconnected: ${currentUser || clientIp}`);
        if (currentUser) {
            users.delete(currentUser);
            broadcastUserList();
        }
    });
    
    ws.on('error', (error) => {
        console.error(`💥 WebSocket error: ${error}`);
    });
});

function broadcastUserList() {
    const userList = Array.from(users.keys()).map(nickname => ({
        nickname,
        isOnline: true
    }));
    
    console.log(`📋 Broadcasting user list: ${userList.length} users online`);
    
    const message = JSON.stringify({
        type: 'user_list',
        users: userList
    });
    
    users.forEach((ws, nickname) => {
        if (ws.readyState === WebSocket.OPEN) {
            ws.send(message);
        }
    });
}

// Автоматическая рассылка списка пользователей каждые 10 секунд
setInterval(broadcastUserList, 10000);

process.on('SIGINT', () => {
    console.log('🛑 Shutting down server...');
    wss.close(() => {
        console.log('✅ Server closed');
        process.exit(0);
    });
});