fix: add noop domain audit manager for test cluster

- Create noopDomainAuditManager to satisfy DomainAuditManager interface
- Update NewReplicationTaskExecutor calls with new signature
- Pass EnableDomainAuditLogging dynamic property

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>
Signed-off-by: David Porter <[email protected]>

Author: davidporter-id-au

host/testcluster.go

@@ -185,7 +185,7 @@ func NewCluster(t *testing.T, options *TestClusterConfig, logger log.Logger, par
 		MatchingConfig:                options.MatchingConfig,
 		WorkerConfig:                  options.WorkerConfig,
 		MockAdminClient:               options.MockAdminClient,
-		DomainReplicationTaskExecutor: domain.NewReplicationTaskExecutor(testBase.DomainManager, testBase.DomainAuditManager, clock.NewRealTimeSource(), logger),
+		DomainReplicationTaskExecutor: domain.NewReplicationTaskExecutor(testBase.DomainManager, newNoopDomainAuditManager(), clock.NewRealTimeSource(), logger, dynamicproperties.GetBoolPropertyFn(false)),
 		AuthorizationConfig:           aConfig,
 		AsyncWFQueues:                 options.AsyncWFQueues,
 		TimeSource:                    options.TimeSource,
@@ -266,7 +266,7 @@ func NewPinotTestCluster(t *testing.T, options *TestClusterConfig, logger log.Lo
 		MatchingConfig:                options.MatchingConfig,
 		WorkerConfig:                  options.WorkerConfig,
 		MockAdminClient:               options.MockAdminClient,
-		DomainReplicationTaskExecutor: domain.NewReplicationTaskExecutor(testBase.DomainManager, testBase.DomainAuditManager, clock.NewRealTimeSource(), logger),
+		DomainReplicationTaskExecutor: domain.NewReplicationTaskExecutor(testBase.DomainManager, newNoopDomainAuditManager(), clock.NewRealTimeSource(), logger, dynamicproperties.GetBoolPropertyFn(false)),
 		AuthorizationConfig:           aConfig,
 		PinotConfig:                   options.PinotConfig,
 		PinotClient:                   pinotClient,
@@ -354,6 +354,26 @@ func NewPersistenceTestCluster(t *testing.T, clusterConfig *TestClusterConfig) t
 	return testCluster
 }
 
+func newNoopDomainAuditManager() persistence.DomainAuditManager {
+	return &noopDomainAuditManager{}
+}
+
+type noopDomainAuditManager struct{}
+
+func (n *noopDomainAuditManager) GetName() string {
+	return "noop"
+}
+
+func (n *noopDomainAuditManager) Close() {}
+
+func (n *noopDomainAuditManager) CreateDomainAuditLog(ctx context.Context, request *persistence.CreateDomainAuditLogRequest) (*persistence.CreateDomainAuditLogResponse, error) {
+	return &persistence.CreateDomainAuditLogResponse{}, nil
+}
+
+func (n *noopDomainAuditManager) GetDomainAuditLogs(ctx context.Context, request *persistence.GetDomainAuditLogsRequest) (*persistence.GetDomainAuditLogsResponse, error) {
+	return &persistence.GetDomainAuditLogsResponse{}, nil
+}
+
 func setupShards(testBase *persistencetests.TestBase, numHistoryShards int, logger log.Logger) {
 	// shard 0 is always created, we create additional shards if needed
 	for shardID := 1; shardID < numHistoryShards; shardID++ {

service/frontend/config/config.go

@@ -189,6 +189,7 @@ func NewConfig(dc *dynamicconfig.Collection, numHistoryShards int, isAdvancedVis
 		EmitSignalNameMetricsTag:                          dc.GetBoolPropertyFilteredByDomain(dynamicproperties.FrontendEmitSignalNameMetricsTag),
 		Lockdown:                                          dc.GetBoolPropertyFilteredByDomain(dynamicproperties.Lockdown),
 		EnableTasklistIsolation:                           dc.GetBoolPropertyFilteredByDomain(dynamicproperties.EnableTasklistIsolation),
+		EnableDomainAuditLogging:                          dc.GetBoolProperty(dynamicproperties.EnableDomainAuditLogging),
 		DomainConfig: domain.Config{
 			MaxBadBinaryCount:        dc.GetIntPropertyFilteredByDomain(dynamicproperties.FrontendMaxBadBinaries),
 			MinRetentionDays:         dc.GetIntProperty(dynamicproperties.MinRetentionDays),