Function parseEvent

out/cli.cjs:34152–34209

(chunk, decoder)

      return sequence;
    }
    function parseEvent(chunk, decoder) {
      var _a5;
      if (!chunk.length) {
        return null;
      }
      const td = new TextDecoder();
      const raw = td.decode(chunk);
      const lines = raw.split(/\r?\n|\r/g);
      let publish = false;
      const rawEvent = {};
      for (const line of lines) {
        if (!line) {
          continue;
        }
        const delim = line.indexOf(":");
        if (delim === 0) {
          continue;
        }
        const field = delim > 0 ? line.substring(0, delim) : "";
        let value = delim > 0 ? line.substring(delim + 1) : "";
        if (value.charAt(0) === " ") {
          value = value.substring(1);
        }
        switch (field) {
          case "event": {
            publish = true;
            rawEvent.event = value;
            break;
          }
          case "data": {
            publish = true;
            (_a5 = rawEvent.data) !== null && _a5 !== void 0 ? _a5 : rawEvent.data = "";
            rawEvent.data += value + "\n";
            break;
          }
          case "id": {
            publish = true;
            rawEvent.id = value;
            break;
          }
          case "retry": {
            const r3 = parseInt(value, 10);
            if (!Number.isNaN(r3)) {
              publish = true;
              rawEvent.retry = r3;
            }
            break;
          }
        }
      }
      if (!publish) {
        return null;
      }
      if (rawEvent.data != null) {
        rawEvent.data = rawEvent.data.slice(0, -1);
      }
      return decoder(rawEvent);
    }