Method dial

ui/socket.js:130–225

* Connect to the server * * @param {object} callbacks Callbacks * * @returns {object} A pair of ReadWriter which can be used to read and * send data to the underlaying websocket connection *

(callbacks)

   *
   */
  async dial(callbacks) {
    let ws = await this.connect(this.timeout),
      rd = new reader.Reader(new reader.Multiple(() => {}), data => {
        return new Promise(resolve => {
          let bufferReader = new FileReader();

          bufferReader.onload = event => {
            let d = new Uint8Array(event.target.result);

            resolve(d);

            callbacks.inboundUnpacked(d);
          };

          bufferReader.readAsArrayBuffer(data);
        });
      }),
      sdDataConvert = rawData => {
        return rawData;
      },
      sd = new sender.Sender(
        async rawData => {
          let data = await sdDataConvert(rawData);

          ws.send(data.buffer);
          callbacks.outbound(data);
        },
        15,
        4096 - 64 // Server has a 4096 bytes receive buffer, can be no greater
      );

    ws.addEventListener("message", event => {
      callbacks.inbound(event.data);

      rd.feed(event.data);
    });

    ws.addEventListener("error", event => {
      rd.close();
    });

    ws.addEventListener("close", event => {
      rd.close();
    });

    let senderNonce = crypt.generateNonce();
    sd.send(senderNonce);

    let receiverNonce = await reader.readN(rd, crypt.GCMNonceSize);

    let key = await this.buildKey();

    sdDataConvert = async rawData => {
      let encoded = await crypt.encryptGCM(key, senderNonce, rawData);

      crypt.increaseNonce(senderNonce);

      let dataToSend = new Uint8Array(encoded.byteLength + 2);