Function parseJsonBody

web/src/app/api/v1/_helpers.ts:34–83

(params: {
  req: NextRequest
  schema: ZodType<T>
  logger: Logger
  trackEvent: TrackEventFn
  validationErrorEvent: AnalyticsEvent
  userId?: string
})

  | { ok: false; response: NextResponse }

export const parseJsonBody = async <T>(params: {
  req: NextRequest
  schema: ZodType<T>
  logger: Logger
  trackEvent: TrackEventFn
  validationErrorEvent: AnalyticsEvent
  userId?: string
}): Promise<HandlerResult<T>> => {
  const { req, schema, logger, trackEvent, validationErrorEvent, userId } =
    params
  const trackingUserId = userId ?? 'unknown'

  let json: unknown
  try {
    json = await req.json()
  } catch {
    trackEvent({
      event: validationErrorEvent,
      userId: trackingUserId,
      properties: { error: 'Invalid JSON' },
      logger,
    })
    return {
      ok: false,
      response: NextResponse.json(
        { error: 'Invalid JSON in request body' },
        { status: 400 },
      ),
    }
  }

  const parsed = schema.safeParse(json)
  if (!parsed.success) {
    trackEvent({
      event: validationErrorEvent,
      userId: trackingUserId,
      properties: { issues: parsed.error.format() },
      logger,
    })
    return {
      ok: false,
      response: NextResponse.json(
        { error: 'Invalid request body', details: parsed.error.format() },
        { status: 400 },
      ),
    }
  }

  return { ok: true, data: parsed.data }
}

export const requireUserFromApiKey = async (params: {
  req: NextRequest