feat: add parse json & text utils

Author: skoshx

packages/core/src/index.ts

@@ -4,6 +4,8 @@ import {
   catchUncaughtAction,
   catchUncaughtRoute,
   json,
+  parseJson,
+  parseText,
   redirect,
   response,
 } from "./request-utils"
@@ -134,13 +136,23 @@ export function createFlytrapLogger<T>({
       // @ts-expect-error: `addContext` is incompatible due to `T`
       return catchUncaughtAction(fn, addContext, flush, options)
     },
+    // Request utils
     catchUncaughtRoute<T extends { params: Record<string, unknown> }>(
       fn: (request: Request, context: T) => Promise<Response> | Response,
       options?: Partial<z.infer<typeof baseLogSchema>>
     ) {
       // @ts-expect-error: `addContext` is incompatible due to `T`
       return catchUncaughtRoute(fn, addContext, flush, options)
     },
+    parseJson(request: Request) {
+      // @ts-expect-error: `addContext` is incompatible due to `T`
+      return parseJson(request, addContext)
+    },
+    parseText(request: Request) {
+      // @ts-expect-error: `addContext` is incompatible due to `T`
+      return parseText(request, addContext)
+    },
+    // Response utils
     response(body: BodyInit, opts: ResponseInit = {}) {
       // @ts-expect-error: `addContext` is incompatible due to `T`
       return response(body, opts, addContext)

packages/core/src/request-utils.ts

@@ -40,6 +40,42 @@ export function redirect(
   return Response.redirect(url, status)
 }
 
+export async function parseJson(
+  request: Request,
+  addContext: AddContextFn<z.infer<typeof baseLogSchema>>
+) {
+  try {
+    const requestBody = await request.json()
+    addContext({
+      req: requestBody,
+    })
+    return requestBody
+  } catch (error) {
+    addContext({
+      error: serializeError(error),
+    })
+    throw error
+  }
+}
+
+export async function parseText(
+  request: Request,
+  addContext: AddContextFn<z.infer<typeof baseLogSchema>>
+) {
+  try {
+    const requestBody = await request.text()
+    addContext({
+      req: requestBody,
+    })
+    return requestBody
+  } catch (error) {
+    addContext({
+      error: serializeError(error),
+    })
+    throw error
+  }
+}
+
 export function catchUncaughtRoute<
   T extends { params: Record<string, unknown> },
 >(