simplify logging and remove partial data tracking

Author: itslenny

src/http/plugins/log-request.ts

@@ -1,4 +1,3 @@
-import { PartialHttpData, parsePartialHttp } from '@internal/http'
 import { logger, logSchema, redactQueryParamFromRequest } from '@internal/monitoring'
 import { FastifyInstance } from 'fastify'
 import { FastifyReply } from 'fastify/types/reply'
@@ -49,9 +48,6 @@ export const logRequest = (options: RequestLoggerOptions) =>
       // Watch for connections that timeout or disconnect before complete HTTP headers are received
       // For keep-alive connections, track each potential request independently
       const onConnection = (socket: Socket) => {
-        const captureByteLimit = 2048
-        let currentRequestData: Buffer[] = []
-        let currentRequestDataSize = 0
         let currentRequestStart = Date.now()
         let waitingForRequest = false
         let pendingRequestLogged = false
@@ -60,27 +56,16 @@ export const logRequest = (options: RequestLoggerOptions) =>
         socketCleanupMap.set(socket, () => {
           pendingRequestLogged = true
           waitingForRequest = false
-          currentRequestData = []
-          currentRequestDataSize = 0
         })
 
-        // Capture partial data sent before connection closes
-        const onData = (chunk: Buffer) => {
+        // Track when data arrives for a potential request
+        const onData = () => {
           // Start tracking a new potential request when we receive data after a completed one
           if (!waitingForRequest) {
             waitingForRequest = true
-            currentRequestData = []
-            currentRequestDataSize = 0
             currentRequestStart = Date.now()
             pendingRequestLogged = false
           }
-
-          const remaining = captureByteLimit - currentRequestDataSize
-          if (remaining > 0) {
-            const slicedChunk = chunk.subarray(0, Math.min(chunk.length, remaining))
-            currentRequestData.push(slicedChunk)
-            currentRequestDataSize += slicedChunk.length
-          }
         }
         socket.on('data', onData)
 
@@ -94,12 +79,11 @@ export const logRequest = (options: RequestLoggerOptions) =>
           socketCleanupMap.delete(socket)
 
           // Only log if we were waiting for a request that was never properly logged
-          if (!waitingForRequest || currentRequestData.length === 0 || pendingRequestLogged) {
+          if (!waitingForRequest || pendingRequestLogged) {
             return
           }
 
-          const parsedHttp = parsePartialHttp(currentRequestData)
-          const req = createPartialLogRequest(fastify, socket, parsedHttp, currentRequestStart)
+          const req = createPartialLogRequest(fastify, socket, currentRequestStart)
 
           doRequestLog(req, {
             excludeUrls: options.excludeUrls,
@@ -272,30 +256,25 @@ function getFirstDefined<T>(...values: any[]): T | undefined {
 }
 
 /**
- * Creates a minimal FastifyRequest from partial HTTP data.
- * Used for consistent logging when request parsing fails.
+ * Creates a minimal FastifyRequest for logging aborted connections.
+ * Used when connection closes before a complete HTTP request is received.
  */
 export function createPartialLogRequest(
   fastify: FastifyInstance,
   socket: Socket,
-  httpData: PartialHttpData,
   startTime: number
 ) {
   return {
-    method: httpData.method,
-    url: httpData.url,
-    headers: httpData.headers,
+    method: 'UNKNOWN',
+    headers: {},
+    url: '/',
     ip: socket.remoteAddress || 'unknown',
     id: 'no-request',
     log: fastify.log.child({
-      tenantId: httpData.tenantId,
-      project: httpData.tenantId,
       reqId: 'no-request',
       appVersion: version,
-      dataLength: httpData.length,
     }),
     startTime,
-    tenantId: httpData.tenantId,
     raw: {},
     routeOptions: { config: {} },
     resources: [],

src/internal/http/index.ts

@@ -1,2 +1 @@
 export * from './agent'
-export * from './partial-http-parser'