Function withRouteHandler

apps/sim/lib/core/utils/with-route-handler.ts:47–96

(handler: RouteHandler<T>)

 * - Attaches `x-request-id` response header
 */
export function withRouteHandler<T>(handler: RouteHandler<T>): RouteHandler<T> {
  return async (request: NextRequest, context: T) => {
    const requestId = generateRequestId()
    const startTime = Date.now()
    const method = request?.method ?? 'UNKNOWN'
    const path =
      request?.nextUrl?.pathname ?? new URL(request?.url ?? '/', 'http://localhost').pathname

    return runWithRequestContext({ requestId, method, path }, async () => {
      let response: NextResponse | Response
      try {
        response = await handler(request, context)
      } catch (error) {
        const duration = Date.now() - startTime
        const message = getErrorMessage(error, 'Unknown error')
        const typedStatus = readTypedErrorStatus(error)
        if (typedStatus !== undefined) {
          if (typedStatus >= 500) {
            logger.error('Unhandled route error', { duration, status: typedStatus, error: message })
          } else {
            logger.warn('Typed route error', { duration, status: typedStatus, error: message })
          }
          response = NextResponse.json({ error: message, requestId }, { status: typedStatus })
        } else {
          logger.error('Unhandled route error', { duration, error: message })
          response = NextResponse.json(
            { error: 'Internal server error', requestId },
            { status: 500 }
          )
        }
        response?.headers?.set('x-request-id', requestId)
        return response
      }

      const status = response?.status ?? 0
      const duration = Date.now() - startTime

      if (status >= 500) {
        logger.error('Server error response', { status, duration })
      } else if (status >= 400) {
        logger.warn('Client error response', { status, duration })
      } else if (status > 0) {
        logger.info('OK', { status, duration })
      }

      response?.headers?.set('x-request-id', requestId)
      return response
    })
  }
}