fix: add logging for file-descriptor debugging

Author: tannerlinsley

src/routes/api/uploadthing.ts

@@ -1,14 +1,51 @@
 import { createFileRoute } from '@tanstack/react-router'
 import { createRouteHandler } from 'uploadthing/server'
+import { logUploadthingProbe } from '~/utils/prod-diagnostics.server'
 import { uploadRouter } from '~/server/uploadthing'
 
 const handlers = createRouteHandler({ router: uploadRouter })
 
+async function handleUploadthingRequest(
+  method: 'GET' | 'POST',
+  request: Request,
+): Promise<Response> {
+  const url = new URL(request.url)
+  const startedAt = Date.now()
+
+  logUploadthingProbe(method, 'start', {
+    pathname: url.pathname,
+    search: url.search,
+    userAgent: request.headers.get('user-agent') ?? 'unknown',
+  })
+
+  try {
+    const response = await handlers(request)
+    logUploadthingProbe(method, 'end', {
+      pathname: url.pathname,
+      status: response.status,
+      durationMs: Date.now() - startedAt,
+    })
+    return response
+  } catch (error) {
+    const errorMessage = error instanceof Error ? error.message : String(error)
+    const errorStack = error instanceof Error ? error.stack : undefined
+    logUploadthingProbe(method, 'error', {
+      pathname: url.pathname,
+      durationMs: Date.now() - startedAt,
+      errorMessage,
+      errorStack,
+    })
+    throw error
+  }
+}
+
 export const Route = createFileRoute('/api/uploadthing')({
   server: {
     handlers: {
-      GET: async ({ request }: { request: Request }) => handlers(request),
-      POST: async ({ request }: { request: Request }) => handlers(request),
+      GET: async ({ request }: { request: Request }) =>
+        handleUploadthingRequest('GET', request),
+      POST: async ({ request }: { request: Request }) =>
+        handleUploadthingRequest('POST', request),
     },
   },
 })

src/server.ts

@@ -1,41 +1,66 @@
 import './instrument.server.mjs'
 
 import handler, { createServerEntry } from '@tanstack/react-start/server-entry'
+import {
+  installProductionFetchProbe,
+  installProductionProcessProbe,
+  logRequestEnd,
+  logRequestError,
+  logRequestStart,
+  runWithRequestDiagnostics,
+} from '~/utils/prod-diagnostics.server'
+
+installProductionFetchProbe()
+installProductionProcessProbe()
 
 export default createServerEntry({
   async fetch(request) {
-    const url = new URL(request.url)
-
-    // Redirect to markdown version if AI/LLM requests text/markdown for doc pages
-    const acceptHeader = request.headers.get('Accept') || ''
-    if (
-      acceptHeader.includes('text/markdown') &&
-      url.pathname.includes('/docs/') &&
-      !url.pathname.endsWith('.md')
-    ) {
-      return new Response(null, {
-        status: 303,
-        headers: {
-          Location: `${url.pathname}.md`,
-        },
-      })
-    }
-
-    const response = await handler.fetch(request)
-
-    // Add COOP/COEP headers for /builder route (required for WebContainer)
-    if (url.pathname === '/builder' || url.pathname.startsWith('/builder/')) {
-      const newHeaders = new Headers(response.headers)
-      newHeaders.set('Cross-Origin-Opener-Policy', 'same-origin')
-      newHeaders.set('Cross-Origin-Embedder-Policy', 'require-corp')
-
-      return new Response(response.body, {
-        status: response.status,
-        statusText: response.statusText,
-        headers: newHeaders,
-      })
-    }
-
-    return response
+    return runWithRequestDiagnostics(request, async (context) => {
+      const url = new URL(request.url)
+      logRequestStart(context)
+
+      try {
+        const acceptHeader = request.headers.get('Accept') || ''
+        if (
+          acceptHeader.includes('text/markdown') &&
+          url.pathname.includes('/docs/') &&
+          !url.pathname.endsWith('.md')
+        ) {
+          logRequestEnd(context, 303, { redirectToMarkdown: true })
+          return new Response(null, {
+            status: 303,
+            headers: {
+              Location: `${url.pathname}.md`,
+            },
+          })
+        }
+
+        const response = await handler.fetch(request)
+
+        if (
+          url.pathname === '/builder' ||
+          url.pathname.startsWith('/builder/')
+        ) {
+          const newHeaders = new Headers(response.headers)
+          newHeaders.set('Cross-Origin-Opener-Policy', 'same-origin')
+          newHeaders.set('Cross-Origin-Embedder-Policy', 'require-corp')
+
+          logRequestEnd(context, response.status, {
+            builderIsolatedHeaders: true,
+          })
+          return new Response(response.body, {
+            status: response.status,
+            statusText: response.statusText,
+            headers: newHeaders,
+          })
+        }
+
+        logRequestEnd(context, response.status)
+        return response
+      } catch (error) {
+        logRequestError(context, error)
+        throw error
+      }
+    })
   },
 })