import store from "@/store";
import config from "@/config/config";
import WsSocket from "@/plugins/ws-socket";
import { getToken } from "@/utils/auth";
import { Notification } from "element-ui";

// 引入消息处理类
import KeyboardEvent from "@/im-server/event/keyboard";
import LoginEvent from "@/im-server/event/login";
import TalkEvent from "@/im-server/event/talk";
import RevokeEvent from "@/im-server/event/revoke";
import GroupJoinEvent from "@/im-server/event/group-join";
import FriendApplyEvent from "@/im-server/event/friend-apply";

/**
 * SocketInstance 连接实例
 *
 * 注释: 所有 WebSocket 消息接收处理在此实例中处理
 */
class SocketInstance {
  /**
   * WsSocket 实例
   */
  socket;

  /**
   * SocketInstance 初始化实例
   */
  constructor() {
    this.socket = new WsSocket(
      () => {
        return `${config.BASE_WS_URL}/` + getToken();
      },
      {
        onError: (evt) => {
          console.log("Websocket 连接失败回调方法");
        },
        // Websocket 连接成功回调方法
        onOpen: (evt) => {
          this.updateSocketStatus(true);
        },
        // Websocket 断开连接回调方法
        onClose: (evt) => {
          this.updateSocketStatus(false);
        },
      }
    );

    this.registerEvents();
  }

  // 连接 WebSocket 服务
  connect () {
    console.log("🔗连接 WebSocket");
    this.socket.connection();
  }

  /**
   * 注册回调消息处理事件
   */
  registerEvents () {
    this.socket.on("event_talk", (data) => {
      console.log("接收到消息,event_talk", data);
      new TalkEvent(data).handle();
    });

    this.socket.on("event_online_status", (data) => {
      new LoginEvent(data).handle();
    });

    this.socket.on("event_keyboard", (data) => {
      console.log("推送", data);
      new KeyboardEvent(data).handle();
    });

    this.socket.on("event_revoke_talk", (data) => {
      new RevokeEvent(data).handle();
    });

    this.socket.on("event_friend_apply", (data) => {
      new FriendApplyEvent(data).handle();
    });

    this.socket.on("join_group", (data) => {
      new GroupJoinEvent(data).handle();
    });

    this.socket.on("event_error", (data) => {
      Notification({
        title: "友情提示",
        message: data.message,
        type: "warning",
      });
    });
  }

  /**
   * 更新 WebSocket 连接状态
   *
   * @param {Boolean} status 连接状态
   */
  updateSocketStatus (status) {
    store.commit("UPDATE_SOCKET_STATUS", status);
  }

  /**
   * 推送消息
   *
   * @param {String} event 事件名
   * @param {Object} data 数据
   */
  emit (event, data) {
    this.socket.emit(event, data);
  }
}

export default new SocketInstance();