// 导入类（ES6 模块化）
import { webSocket_ModuleSimple } from "./newWebRtcSync.js";

class rtcCallee {
  constructor(userIdentity, user_id) {
    this.current_time = new Date();
    this.identity = userIdentity;
    // websocket对象
    this.wsClient = null;
    // WebRTC 核心对象
    this.rtcPeer = null;
    this.dataChannel = null;
    this.state;
    // webRTC 信令
    this.clientCandidates = [];
    this.remoteOffer;
    this.localAnswer;
    this.localStream;
    this.remoteStream;
    this._init_ws(user_id);
  }
  _init_ws(user_id) {
    // websocket初始化
    if (this.wsClient) {
      this.wsClient = null;
    }
    console.info(`初始化websocket`);
    // const wsService = `ws://localhost:8000/wsSignaling/${user_id}/`
    const wsService = `wss://api.vlos.net/wsSignaling/${user_id}/`;
    this.wsClient = new webSocket_ModuleSimple(wsService);
    this.wsClient.connect();
    this.handlerWsSignalingLisioner();
  }
  /**
   * 监听websocket信息 回调函数方式监控websocket数据
   */
  async handlerWsSignalingLisioner() {
    this.wsClient.on({
      onMessage: async (msg) => {
        const res_dict = JSON.parse(msg);
        console.info(
          `[exportWebRtcCallee.js]->[handlerWsSignalingLisioner函数][${this.identity}][${this.current_time.toLocaleTimeString()}]>>>收到信息`,
          "type:",
          res_dict.type,
          "长度",
          msg.length,
        );
        switch (res_dict.type) {
          case "candidate":
            console.info(
              `[exportWebRtcCallee.js][${this.identity}][${this.current_time.toLocaleTimeString()}]>>>监听candidate`,
              res_dict.data,
            );
            break;
          case "offer":
            this.remoteOffer = res_dict.data;
            console.info(
              `[exportWebRtcCallee.js][${this.identity}][${this.current_time.toLocaleTimeString()}]>>>收到远程offer`,
            );
            console.warn(`收到的offer,`, this.remoteOffer);
            break;
        }
      },
    });
  }
}

new rtcCallee("callee", 123);