Class JsPackagerClient

local-cli/server/util/jsPackagerClient.js:24–113

}

class JsPackagerClient {
  constructor(url) {
    this.ws = new WebSocket(url);
    this.msgCallbacks = new Map();

    this.openPromise = new Promise((resolve, reject) => {
      this.ws.on('error', error => reject(error));
      this.ws.on('open', resolve);
    });

    this.ws.on('message', (data, flags) => {
      const message = parseMessage(data, flags.binary);
      const msgCallback = this.msgCallbacks.get(message.id);
      if (message === undefined || message.id === undefined) {
        // gracefully ignore wrong messages or broadcasts
      } else if (msgCallback === undefined) {
        console.warn(`Response with non-existing message id: '${message.id}'`);
      } else {
        if (message.error === undefined) {
          msgCallback.resolve(message.result);
        } else {
          msgCallback.reject(message.error);
        }
      }
    });
  }

  sendRequest(method, target, params) {
    return this.openPromise.then(() => new Promise((resolve, reject) => {
      const messageId = getMessageId();
      this.msgCallbacks.set(messageId, {resolve: resolve, reject: reject});
      this.ws.send(
        JSON.stringify({
          version: PROTOCOL_VERSION,
          target: target,
          method: method,
          id: messageId,
          params: params,
        }),
        error => {
          if (error !== undefined) {
            this.msgCallbacks.delete(messageId);
            reject(error);
          }
        });
    }));
  }

  sendNotification(method, target, params) {
    return this.openPromise.then(() => new Promise((resolve, reject) => {
      this.ws.send(
        JSON.stringify({
          version: PROTOCOL_VERSION,
          target: target,
          method: method,
          params: params,
        }),
        error => {