decode()

in streaming.ts [323:364]

• 31 lines of code
• 9 McCabe index (conditional complexity)

  decode(line: string) {
    if (line.endsWith("\r")) {
      line = line.substring(0, line.length - 1);
    }

    if (!line) {
      // empty line and we didn't previously encounter any messages
      if (!this.event && !this.data.length) return null;

      const sse: ServerSentEvent = {
        event: this.event,
        data: this.data.join("\n"),
        raw: this.chunks,
      };

      this.event = null;
      this.data = [];
      this.chunks = [];

      return sse;
    }

    this.chunks.push(line);

    if (line.startsWith(":")) {
      return null;
    }

    let [fieldname, _, value] = partition(line, ":");

    if (value.startsWith(" ")) {
      value = value.substring(1);
    }

    if (fieldname === "event") {
      this.event = value;
    } else if (fieldname === "data") {
      this.data.push(value);
    }

    return null;
  }