"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.createSocketServer=createSocketServer;var _socket=_interopRequireDefault(require("socket.io")),_utils=require("../lib/utils");function _interopRequireDefault(e){return e&&e.__esModule?e:{default:e}}function createSocketServer(e,o){const r=(0,_socket.default)(e);o.context.io=r,r.on("connection",e=>{r.on("error",e=>{_utils.colorconsole.error(`### App Socket Server ### websocket server发生错误: ${e.message}`)}),_utils.colorconsole.info(`### App Socket Server ### websocket用户(${(0,_utils.stripPrefixForIPV4MappedIPV6Address)(e.conn.remoteAddress)})连入到websocket server`),e.on("disconnect",()=>{_utils.colorconsole.info("### App Socket Server ### websocket client与websocket server断开"),r.emit("user disconnected")})})}
|
