Function readRequestBody

src/utils.ts:254–303

(
  req: Request,
  maxSize: number = 10485760,
)

// NOTE, if proxying request elsewhere, you must re-stream the body again
export const readRequestBody = async (
  req: Request,
  maxSize: number = 10485760,
): Promise<string> => {
  return new Promise((resolve, reject) => {
    const body: Uint8Array[] = [];
    let hasResolved = false;
    let totalSize = 0;

    const resolveOnce = (results: string) => {
      if (hasResolved) {
        return;
      }
      hasResolved = true;
      resolve(results);
    };

    const rejectOnce = (error: Error) => {
      if (hasResolved) {
        return;
      }
      hasResolved = true;
      reject(error);
    };

    req
      .on('data', (chunk) => {
        totalSize += chunk.length;
        if (totalSize > maxSize) {
          rejectOnce(
            new BadRequest(
              `Request payload size (${totalSize} bytes) exceeds maximum allowed size of ${maxSize} bytes`,
            ),
          );
          return;
        }
        body.push(chunk);
      })
      .on('end', () => {
        const final = Buffer.concat(body).toString();
        resolveOnce(final);
      })
      .on('aborted', () => {
        resolveOnce('');
      })
      .on('error', (error) => {
        rejectOnce(error);
      });
  });
};

export const safeParse = (maybeJson: string): unknown | null => {
  try {