Method UpdateMockParams

pkg/service/agent/agent.go:724–887

UpdateMockParams applies filtering parameters and updates the agent's mock manager

(ctx context.Context, params models.MockFilterParams)

// UpdateMockParams applies filtering parameters and updates the agent's mock manager
func (a *Agent) UpdateMockParams(ctx context.Context, params models.MockFilterParams) error {

	a.logger.Debug("UpdateMockParams called",
		zap.Time("afterTime", params.AfterTime),
		zap.Time("beforeTime", params.BeforeTime),
		zap.Bool("useMappingBased", params.UseMappingBased),
		zap.Int("mockMappingCount", len(params.MockMapping)),
		zap.Bool("strictMockWindow", params.StrictMockWindow))

	// Strict mock-window is OPT-IN via either the per-call flag
	// (params.StrictMockWindow) or the process-wide KEPLOY_STRICT_MOCK_WINDOW
	// env override. Surface the EFFECTIVE state so operators searching
	// agent logs for "strict mock window enabled" find hits regardless of
	// which route they used — previously the log fired only on the per-call
	// flag, making env-only opt-ins invisible.
	if strictEnabled := pkg.IsStrictMockWindow(params.StrictMockWindow); strictEnabled {
		// Fire the activation message at most once per agent process
		// (sync.Once). Info (project logging policy disallows Warn for
		// expected-default state); the escape-hatch names are embedded
		// inline so operators hitting unexpected "missing mock" errors
		// after an upgrade can opt out without digging through docs.
		// Per-test diagnostics drop to Debug.
		a.strictLogOnce.Do(func() {
			a.logger.Info(
				"strict mock-window containment is ACTIVE for this session — per-test mocks whose request "+
					"timestamp falls outside the outer test window will be dropped rather than promoted "+
					"across tests. If your replays start reporting missing mocks after an upgrade, this "+
					"is likely why. To opt out: set KEPLOY_STRICT_MOCK_WINDOW=0 in the environment, OR "+
					"test.strictMockWindow: false in keploy.yaml.",
				zap.Bool("viaPerCallFlag", params.StrictMockWindow),
				zap.Bool("viaEnvOverride", !params.StrictMockWindow && strictEnabled),
				zap.String("escape_hatch_env", "KEPLOY_STRICT_MOCK_WINDOW=0"),
				zap.String("escape_hatch_config", "test.strictMockWindow: false"))
		})
		a.logger.Debug("strict mock window active for test",
			zap.Time("windowStart", params.AfterTime),
			zap.Time("windowEnd", params.BeforeTime))
	}

	// Get stored mocks for the client
	storageInterface, exists := a.clientMocks.Load(uint64(0))
	if !exists {
		return fmt.Errorf("no mocks stored for client ID")
	}
	storage := storageInterface.(*ClientMockStorage)

	storage.mu.RLock()
	originalFiltered := make([]*models.Mock, len(storage.filtered))
	originalUnfiltered := make([]*models.Mock, len(storage.unfiltered))
	copy(originalFiltered, storage.filtered)
	copy(originalUnfiltered, storage.unfiltered)
	storage.mu.RUnlock()

	a.logger.Debug("Original mocks before filtering",
		zap.Int("originalFiltered", len(originalFiltered)),
		zap.Int("originalUnfiltered", len(originalUnfiltered)))

	var filteredMocks, unfilteredMocks []*models.Mock