/**
 * 伪代码,ES6改写
 */

let socket = {};

/**
 * 封装client
 * 利用事件来包装，一个管道解决send异步拿到结果问题
 */

const isFunction = fn => {
  return Object.prototype.toString.call(fn) === '[object Function]';
};

const uuid = () => {
  return `${Math.random()
    .toString(36)
    .substr(2)}${Math.random()
    .toString(36)
    .substr(2)}`;
};

// Client 类
class Client {
  constructor() {
    this.ep = new EventProxy();
    this.addListener();
  }
  /**
   * 发送
   * @param {Object} body 参数
   */
  send(body) {
    return new Promise((resolve, reject) => {
      let msgId = uuid();
      // 发送到后端之前，根据msgId自定义监听事件名称，onMessage会自动触发此事件，然后执行cb回调，可以达到异步回调效果
      // once 是只监听一次这个事件，执行后自动解绑
      this.ep.once(`ep_message_${msgId}`, function(data) {
        return resolve(data);
      });

      socket.emit(body);
    });
  }

  addListener() {
    socket.on('message', function(data) {
      let msgId = data.msgId;
      // 根据msgId唯一触发执行的事件，并传送数据data
      this.ep.emit(`ep_message_${msgId}`, data);
    });
  }
}

// =====使用======

let client = new Client();

// 写法1
client.send({ waybillId: '1zt123213214' }).then(result => {
  // 结果
  console.log(result);
  // 业务代码
});

// 同步写法2
async function test() {
  let result;
  try {
    result = await client.send({ waybillId: '1zt123213214' });
  } catch (e) {
    console.log(e);
  }
  // 结果
  console.log(result);
  // 业务代码
}