Method send

www/data-module/src/data/WebSocketClient.ts:61–87

(data: any)

     received has the same id
  */
  send(data: any) {
    // add _id to each message
    const id = this.generateId();
    data._id = id;

    const promiseData = {} as PromiseData<void>;
    promiseData.promise = new Promise<void>((resolve, reject) => {
      promiseData.resolve = resolve;
      promiseData.reject = reject;
    });
    this.promises[id] = promiseData;

    const jsonData = JSON.stringify(data);
    if (this.socket.readyState === this.socket.OPEN) {
      this.socket.send(jsonData);
    } else {
      // if the WebSocket is not open yet, add the data to the queue
      this.queue.push(jsonData);
    }
    // socket is not watched by cypress, so we need to
    // create a timeout while we are using the socket so that protractor waits for it
    const to = setTimeout(() => {}, 20000);

    return promiseData.promise.then(() => {
      clearTimeout(to);
    });
  }

  flush() {
    // send all the data waiting in the queue