Method decompress

github-actions/browserstack/set-browserstack-env.js:17717–17763

* Decompress a compressed payload. * @param {Buffer} chunk Compressed data * @param {boolean} fin Final fragment flag * @param {Function} callback Callback function

(chunk, fin, callback)

        } else if (!isEstablished(ws)) {
          failWebsocketConnection(ws, "Connection was closed before it was established.");
          ws[kReadyState] = states.CLOSING;
        } else if (ws[kSentClose] === sentCloseFrameState.NOT_SENT) {
          ws[kSentClose] = sentCloseFrameState.PROCESSING;
          const frame = new WebsocketFrameSend();
          if (code !== void 0 && reason === void 0) {
            frame.frameData = Buffer.allocUnsafe(2);
            frame.frameData.writeUInt16BE(code, 0);
          } else if (code !== void 0 && reason !== void 0) {
            frame.frameData = Buffer.allocUnsafe(2 + reasonByteLength);
            frame.frameData.writeUInt16BE(code, 0);
            frame.frameData.write(reason, 2, "utf-8");
          } else {
            frame.frameData = emptyBuffer;
          }
          const socket = ws[kResponse].socket;
          socket.write(frame.createFrame(opcodes.CLOSE));
          ws[kSentClose] = sentCloseFrameState.SENT;
          ws[kReadyState] = states.CLOSING;
        } else {
          ws[kReadyState] = states.CLOSING;
        }
      }
      function onSocketData(chunk) {
        if (!this.ws[kByteParser].write(chunk)) {
          this.pause();
        }
      }
      function onSocketClose() {
        var _a;
        const { ws } = this;
        const { [kResponse]: response } = ws;
        response.socket.off("data", onSocketData);
        response.socket.off("close", onSocketClose);
        response.socket.off("error", onSocketError);
        const wasClean = ws[kSentClose] === sentCloseFrameState.SENT && ws[kReceivedClose];
        let code = 1005;
        let reason = "";
        const result = ws[kByteParser].closingInfo;
        if (result && !result.error) {
          code = (_a = result.code) != null ? _a : 1005;
          reason = result.reason;
        } else if (!ws[kReceivedClose]) {
          code = 1006;
        }
        ws[kReadyState] = states.CLOSED;
        fireEvent("close", ws, (type, init) => new CloseEvent(type, init), {
          wasClean,
          code,
          reason
        });