Method recordV2

pkg/agent/proxy/integrations/http/recordv2.go:42–162

recordV2 is the FakeConn-based record path. The relay owns and writes the real sockets; recordV2 only observes the teed chunks via sess.ClientStream sess.DestStream and emits mocks with timestamps derived from the chunks' ReadAt / WrittenAt fields (never from time.Now()). The mock payload (headers,

(ctx context.Context, sess *supervisor.Session)

// case it marks the session's mock incomplete so the supervisor can
// abort and fall through to passthrough).
func (h *HTTP) recordV2(ctx context.Context, sess *supervisor.Session) error {
	if sess == nil {
		return errors.New("recordV2: nil supervisor session")
	}
	logger := sess.Logger
	if logger == nil {
		logger = h.Logger
	}

	destPort := destPortFromAddr(sess.DestStream)

	for {
		if err := ctx.Err(); err != nil {
			return err
		}

		// --- Request side ---------------------------------------------
		//
		// First chunk's ReadAt is the request arrival timestamp. We grab
		// it via ReadChunk so the timestamp is carried regardless of
		// what ReadBytes does underneath.
		firstChunk, err := sess.ClientStream.ReadChunk()
		if err != nil {
			if errors.Is(err, io.EOF) || errors.Is(err, fakeconn.ErrClosed) {
				logger.Debug("V2 HTTP record: client stream ended at start of request", zap.Error(err))
				return nil
			}
			if ctx.Err() != nil {
				return ctx.Err()
			}
			utils.LogError(logger, err, "V2 HTTP record: initial request read failed")
			return err
		}
		if len(firstChunk.Bytes) == 0 {
			// Empty synthetic chunk (channel close sentinel): treat as EOF.
			return nil
		}
		reqTs := firstChunk.ReadAt
		finalReq := append([]byte(nil), firstChunk.Bytes...)

		// Complete the request: read more chunks until headers + body
		// are on hand. We use chunk-level reads (not HandleChunkedRequests
		// which wraps bufio-like bulk reads over the conn) so we never
		// over-read past the end of one request into the start of the
		// next pipelined request. This is essential for HTTP/1.1
		// keepalive correctness.
		if err := h.readRequestV2(ctx, sess.ClientStream, &finalReq); err != nil {
			if errors.Is(err, io.EOF) || errors.Is(err, fakeconn.ErrClosed) {
				logger.Debug("V2 HTTP record: client stream closed mid-request", zap.Error(err))
				return nil
			}
			if ctx.Err() != nil {
				return ctx.Err()
			}
			sess.MarkMockIncomplete("http decode error: request read failed: " + err.Error())
			utils.LogError(logger, err, "V2 HTTP record: failed to read full request")
			return err
		}