Function handler

apps/sim/app/ingest/[[...path]]/route.ts:37–67

(request: NextRequest)

}

async function handler(request: NextRequest) {
  const { url, hostname } = buildTargetUrl(request.nextUrl.pathname, request.nextUrl.search)
  const headers = buildHeaders(request, hostname)

  const hasBody = !['GET', 'HEAD'].includes(request.method)

  try {
    const response = await fetch(url, {
      method: request.method,
      headers,
      ...(hasBody ? { body: request.body, duplex: 'half' } : {}),
    } as RequestInit)

    const responseHeaders = new Headers(response.headers)
    responseHeaders.delete('content-encoding')
    responseHeaders.delete('content-length')
    responseHeaders.delete('transfer-encoding')

    return new NextResponse(response.body, {
      status: response.status,
      headers: responseHeaders,
    })
  } catch (error) {
    logger.error('PostHog proxy error', {
      url,
      method: request.method,
      error: toError(error).message,
    })
    return new NextResponse(null, { status: 502 })
  }
}

export const GET = handler
export const POST = handler