Function parseSse

clients/t-code-cli/src/runtime-client.ts:114–132

(body: string)

}

export function parseSse(body: string): RuntimeEvent[] {
  return body
    .split(/\r?\n\r?\n/)
    .map(block => block.trim())
    .filter(Boolean)
    .map(block => {
      let id = 0;
      let type = "message";
      const data: string[] = [];
      for (const line of block.split(/\r?\n/)) {
        if (line.startsWith("id:")) id = Number(line.slice(3).trim());
        if (line.startsWith("event:")) type = line.slice(6).trim();
        if (line.startsWith("data:")) data.push(line.slice(5).trimStart());
      }
      const payload = JSON.parse(data.join("\n")) as Record<string, unknown>;
      const schemaVersion = typeof payload.schema_version === "number" ? payload.schema_version : 1;
      return { id, type, schemaVersion, data: payload };
    });
}

function isRecord(value: unknown): value is Record<string, unknown> {
  return typeof value === "object" && value !== null;