const WebSocket = require('ws');
const http = require('http');
const express = require('express');
const app = express();


/**
 *  Map(7) {
  '1111' => {
    roomId: '1111',
    createUser: '1',
    createTime: 1693574119564,
    password: '',
    userList: [
      [Object]
    ],
    messageList: [
      [Object]
    ]
  },
 */
let roomMap = new Map() // 房间信息存储对象
// 创建一个HTTP服务器
const server = http.createServer(app);

// 创建WebSocket服务器并将其附加到HTTP服务器
const wss = new WebSocket.Server({ noServer: true });

server.on('upgrade', (request, socket, head) => {
	switch (request.url) {
		case '/ws':
			// 只允许 这个主机下的请求访问
			if (
				// true||
				request.headers.origin.includes('localhost')
			) {
				wss.handleUpgrade(request, socket, head, (ws) => {
					Socket = socket
					wss.emit('connection', ws, request);
				});
			} else {
				console.log(
					'Unauthorized request from:',
					request.headers.origin
				);
			}
			break;
		default:
			break;
	}
});

// 监听WebSocket连接事件
wss.on('connection', (socket) => {
		console.log('WebSocket 连接已建立');
		// 监听客户端发送的消息
		socket.on('message', async(message) => {
			const msg = JSON.parse(message);
			const { type } = msg || {};
			const room = roomMap.get(roomId);
			const time = new Date().getTime()
			if (type == 'create') {
			} else if (type === 'join') { // 处理用户加入房间
			} else if (type === 'leave') {  // 处理用户离开房间
			} else if(type === 'ping'){ // 处理心跳检测机制
        /**
         * 1 判断消息类型为 心跳检测包
         * 2. 响应pong
         * 3. 标记用户信息并记录时间active：true && activeTime = time
         * 4. 返回消息时遍历房间的用户列表信息 根据活跃时间判断是否为活跃
         * 5. 返回更新后的状态
         */
				msg.status = 'pong' 
				room.userList.some(item => {
					if (item.name === name) {
						// 用户活跃
						item.active = true
						item.activeTime = time
						console.log('ping', JSON.stringify(item))
					}
				})
			} else { // 处理其它逻辑
			}
      // 用户列表
			msg.users = roomMap.get(roomId)?.userList?.length || 0;  
      // 用户数
			msg.totalUserList = roomMap.get(roomId)?.userList || [] 
      // 活跃数===>>> 遍历房间的用户列表信息 根据活跃时间判断是否为活跃
			msg.activityUsers = roomMap.get(roomId)?.userList?.filter(item => {
				if (item.active && item.activeTime && (time - item.activeTime) < 1000 * 8) {
					item.active = true
					return true
				} else {
					item.active = false
					item.activeTime = 0
				}
			})?.length
			// 广播消息给所有连接的客户端
			wss.clients.forEach((client) => {
				if (client.readyState === WebSocket.OPEN) {
					client.send(JSON.stringify(msg));
				}
			});
		});

		wss.on('error', (message) => {
			console.log('报错了');
		});
		wss.on('close', (message) => {
			console.log('连接关闭：')
		})
		wss.on('open', (message) => {
			console.log('open', message)
		})
	});

// 启动HTTP服务器
server.listen(3000, () => {
  console.log('HTTP服务器已启动，监听端口3000');
});