123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
import {  mimesToArrayBuffer,  mimesToBlob,  mimesToFormData,  mimesToJSON,  mimesToText,} from "./mimes.ts";
import { delay } from "https://deno.land/std@0.161.0/async/delay.ts";
import { type _Request, _Response, type Block } from "./types.ts";
export async function fetchBlock(  block: Block,): Promise<Block> {  const { request } = block;  if (!request) {    throw new Error("block.request is undefined");  }  const ctl = new AbortController();  const signal = ctl.signal;  let timeoutId;  const _delay = Number(block.meta.delay);  if (delay) {    await delay(_delay);  }  const timeout = Number(block.meta.timeout);  if (timeout) {    timeoutId = setTimeout(() => ctl.abort(), timeout);  }
  try {    const response = await fetch(request, { signal });    const actualResponse = _Response.fromResponse(response, request.bodyRaw);    block.actualResponse = actualResponse;  } catch (error) {    if (error.name === "AbortError") {      throw new error.constructor(        `Timeout of ${block.meta.timeout}ms exceeded`,      );    }
    throw error;  } finally {    clearTimeout(timeoutId);  }  return block;}
export async function extractBody(  re: _Response | _Request,): Promise<_Response | _Request> {  const contentType = re.headers.get("content-type") || "";  const includes = (ct: string) => contentType.includes(ct);
  if (re.bodyUsed) {    if (re.bodyExtracted !== undefined) {      return re;    }    if (typeof re.bodyRaw === "string") {      const requestExtracted = mimesToJSON.some((ct) =>        contentType.includes(ct)      )        ? JSON.parse(re.bodyRaw as string)        : re.bodyRaw;      re.bodyExtracted = requestExtracted;      return re;    }    return re;  }
  if (!contentType) {    re.bodyExtracted = undefined;    return re;  }  if (mimesToArrayBuffer.some(includes)) {    const body = await re.arrayBuffer();    re.bodyExtracted = body;    return re;  }  if (mimesToText.some(includes)) {    const body = await re.text();    re.bodyExtracted = body;    return re;  }  if (mimesToJSON.some(includes)) {    const body = await re.json();    re.bodyExtracted = body;    return re;  }  if (mimesToBlob.some(includes)) {    const body = await re.blob();    re.bodyExtracted = body;    return re;  }  if (mimesToFormData.some(includes)) {    const body = await re.formData();    re.bodyExtracted = body;    return re;  }  throw new Error("Unknown content type " + contentType);}
export async function consumeBodies(block: Block): Promise<void> {  const promises = [];  if (!block.expectedResponse?.bodyUsed) {    promises.push(block.expectedResponse?.body?.cancel());  }  if (!block.actualResponse?.bodyUsed) {    promises.push(block.actualResponse?.body?.cancel());  }  await Promise.all(promises);}