fix: 大小写

src/network/webSocket.ts

@@ -0,0 +1,96 @@
+import { Socket, io } from 'socket.io-client';
+
+import { useNetworkStore } from '@/store/network';
+
+// websocket连接状态
+export enum WsConnectStatusEnum {
+  /** 已连接 */
+  connection = 'connection',
+  /** 连接中 */
+  connecting = 'connecting',
+  /** 已连接 */
+  connected = 'connected',
+  /** 断开连接中 */
+  disconnecting = 'disconnecting',
+  /** 已断开连接 */
+  disconnect = 'disconnect',
+  /** 重新连接 */
+  reconnect = 'reconnect',
+  /** 客户端的已连接 */
+  connect = 'connect',
+}
+
+// websocket消息类型
+export enum WsMsgTypeEnum {
+  /** 用户进入聊天 */
+  join = 'join',
+  /** 用户进入聊天完成 */
+  joined = 'joined',
+  /** 用户进入聊天 */
+  otherJoin = 'otherJoin',
+  /** 用户退出聊天 */
+  leave = 'leave',
+  /** 用户退出聊天完成 */
+  leaved = 'leaved',
+  /** 当前所有在线用户 */
+  liveUser = 'liveUser',
+  /** 用户发送消息 */
+  message = 'message',
+  /** 房间正在直播 */
+  roomLiveing = 'roomLiveing',
+  /** 房间不在直播 */
+  roomNoLive = 'roomNoLive',
+  /** sendBlob */
+  sendBlob = 'sendBlob',
+  offer = 'offer',
+  answer = 'answer',
+  candidate = 'candidate',
+}
+
+export class WebSocketClass {
+  socketIo: Socket | null = null;
+  status: WsConnectStatusEnum = WsConnectStatusEnum.disconnect;
+  url = '';
+
+  roomId = '-1';
+  isAdmin = false;
+
+  constructor({ roomId, url, isAdmin }) {
+    if (!window.WebSocket) {
+      alert('当前环境不支持WebSocket！');
+      return;
+    }
+    this.roomId = roomId;
+    this.isAdmin = isAdmin;
+
+    this.url = url;
+    this.socketIo = io(url, { transports: ['websocket'], forceBase64: false });
+    this.update();
+  }
+
+  // 发送websocket消息
+  send = ({ msgType, data }: { msgType: WsMsgTypeEnum; data?: any }) => {
+    console.log('【websocket】发送websocket消息', msgType, data);
+    this.socketIo?.emit(msgType, {
+      roomId: this.roomId,
+      socketId: this.socketIo.id,
+      data,
+      isAdmin: this.isAdmin,
+    });
+  };
+
+  // 更新store
+  update = () => {
+    const networkStore = useNetworkStore();
+    networkStore.updateWsMap(this.roomId, this);
+  };
+
+  // 手动关闭websocket连接
+  close = () => {
+    console.warn('手动关闭websocket连接', this.socketIo?.id);
+    this.socketIo?.close();
+  };
+
+  // 连接websocket
+  connect = () => {};
+}