import { rtkRouteStream } from "../codec/rtkRouteStream.ts";

export class RtkRouteLayer {
  readonly id = "rtk-route";

  wrapResponse(res: Response): Response {
    if (!res.body || res.status !== 200) return res;
    const headers = new Headers(res.headers);
    headers.delete("content-length");
    return new Response(res.body.pipeThrough(rtkRouteStream()), {
      status: res.status,
      statusText: res.statusText,
      headers,
    });
  }
}