Method recordLegacy

pkg/agent/proxy/integrations/http/http.go:135–151

recordLegacy is the original RecordOutgoing body preserved unchanged. It consumes the legacy RecordSession fields (Ingress / Egress / Mocks) and forwards bytes between the real sockets itself. The V2 path in recordV2 relies on the supervisor's relay to do the forwarding and only observes teed chunks

(ctx context.Context, session *integrations.RecordSession)

// recordV2 relies on the supervisor's relay to do the forwarding and
// only observes teed chunks via FakeConn streams.
func (h *HTTP) recordLegacy(ctx context.Context, session *integrations.RecordSession) error {
	logger := session.Logger

	h.Logger.Debug("Recording the outgoing http call in record mode")

	reqBuf, err := util.ReadInitialBuf(ctx, logger, session.Ingress)
	if err != nil {
		utils.LogError(logger, err, "failed to read the initial http message")
		return err
	}
	err = h.encodeHTTP(ctx, reqBuf, session.Ingress, session.Egress, session.Mocks, session.Opts, session.OnMockRecorded)
	if err != nil {
		utils.LogError(logger, err, "failed to encode the http message into the yaml")
		return err
	}
	return nil
}

func (h *HTTP) MockOutgoing(ctx context.Context, src net.Conn, dstCfg *models.ConditionalDstCfg, mockDb integrations.MockMemDb, opts models.OutgoingOptions) error {
	// h.Logger = h.Logger.With(zap.Any("Client ConnectionID", ctx.Value(models.ClientConnectionIDKey).(string)), zap.Any("Destination ConnectionID", ctx.Value(models.DestConnectionIDKey).(string)), zap.Any("Client IP Address", src.RemoteAddr().String()))