Function parseFrames

integration/microservices/e2e/tcp-json-socket-pipeline.spec.ts:35–59

* Decode as many complete `"<len>#<json>"` frames as possible from `raw`, * returning parsed objects and the leftover bytes.

(raw: string)

 * returning parsed objects and the leftover bytes.
 */
function parseFrames(raw: string): {
  frames: Record<string, unknown>[];
  remaining: string;
} {
  const frames: Record<string, unknown>[] = [];
  let buf = raw;

  while (true) {
    const delim = buf.indexOf('#');
    if (delim === -1) break;

    const len = parseInt(buf.substring(0, delim), 10);
    if (isNaN(len)) break;

    const payload = buf.substring(delim + 1);
    if (payload.length < len) break;

    frames.push(
      JSON.parse(payload.substring(0, len)) as Record<string, unknown>,
    );
    buf = payload.substring(len);
  }

  return { frames, remaining: buf };
}

const TEST_PORT = 4500;