Replicate custom search attributes aliases with namespace replication (#3922)

Author: alexshtin

common/namespace/replicationTaskExecutor.go

@@ -164,11 +164,12 @@ func (h *namespaceReplicationTaskExecutorImpl) handleNamespaceCreationReplicatio
 				Data:        task.Info.Data,
 			},
 			Config: &persistencespb.NamespaceConfig{
-				Retention:               task.Config.GetWorkflowExecutionRetentionTtl(),
-				HistoryArchivalState:    task.Config.GetHistoryArchivalState(),
-				HistoryArchivalUri:      task.Config.GetHistoryArchivalUri(),
-				VisibilityArchivalState: task.Config.GetVisibilityArchivalState(),
-				VisibilityArchivalUri:   task.Config.GetVisibilityArchivalUri(),
+				Retention:                    task.Config.GetWorkflowExecutionRetentionTtl(),
+				HistoryArchivalState:         task.Config.GetHistoryArchivalState(),
+				HistoryArchivalUri:           task.Config.GetHistoryArchivalUri(),
+				VisibilityArchivalState:      task.Config.GetVisibilityArchivalState(),
+				VisibilityArchivalUri:        task.Config.GetVisibilityArchivalUri(),
+				CustomSearchAttributeAliases: task.Config.GetCustomSearchAttributeAliases(),
 			},
 			ReplicationConfig: &persistencespb.NamespaceReplicationConfig{
 				ActiveClusterName: task.ReplicationConfig.GetActiveClusterName(),
@@ -279,11 +280,12 @@ func (h *namespaceReplicationTaskExecutorImpl) handleNamespaceUpdateReplicationT
 			Data:        task.Info.Data,
 		}
 		request.Namespace.Config = &persistencespb.NamespaceConfig{
-			Retention:               task.Config.GetWorkflowExecutionRetentionTtl(),
-			HistoryArchivalState:    task.Config.GetHistoryArchivalState(),
-			HistoryArchivalUri:      task.Config.GetHistoryArchivalUri(),
-			VisibilityArchivalState: task.Config.GetVisibilityArchivalState(),
-			VisibilityArchivalUri:   task.Config.GetVisibilityArchivalUri(),
+			Retention:                    task.Config.GetWorkflowExecutionRetentionTtl(),
+			HistoryArchivalState:         task.Config.GetHistoryArchivalState(),
+			HistoryArchivalUri:           task.Config.GetHistoryArchivalUri(),
+			VisibilityArchivalState:      task.Config.GetVisibilityArchivalState(),
+			VisibilityArchivalUri:        task.Config.GetVisibilityArchivalUri(),
+			CustomSearchAttributeAliases: task.Config.GetCustomSearchAttributeAliases(),
 		}
 		if task.Config.GetBadBinaries() != nil {
 			request.Namespace.Config.BadBinaries = task.Config.GetBadBinaries()

common/namespace/transmissionTaskHandler.go

@@ -118,6 +118,7 @@ func (namespaceReplicator *namespaceReplicatorImpl) HandleTransmissionTask(
 				VisibilityArchivalState:       config.VisibilityArchivalState,
 				VisibilityArchivalUri:         config.VisibilityArchivalUri,
 				BadBinaries:                   config.BadBinaries,
+				CustomSearchAttributeAliases:  config.CustomSearchAttributeAliases,
 			},
 			ReplicationConfig: &replicationpb.NamespaceReplicationConfig{
 				ActiveClusterName: replicationConfig.ActiveClusterName,

service/frontend/namespace_handler.go

@@ -237,12 +237,13 @@ func (d *namespaceHandlerImpl) RegisterNamespace(
 		Data:        registerRequest.Data,
 	}
 	config := &persistencespb.NamespaceConfig{
-		Retention:               registerRequest.GetWorkflowExecutionRetentionPeriod(),
-		HistoryArchivalState:    nextHistoryArchivalState.State,
-		HistoryArchivalUri:      nextHistoryArchivalState.URI,
-		VisibilityArchivalState: nextVisibilityArchivalState.State,
-		VisibilityArchivalUri:   nextVisibilityArchivalState.URI,
-		BadBinaries:             &namespacepb.BadBinaries{Binaries: map[string]*namespacepb.BadBinaryInfo{}},
+		Retention:                    registerRequest.GetWorkflowExecutionRetentionPeriod(),
+		HistoryArchivalState:         nextHistoryArchivalState.State,
+		HistoryArchivalUri:           nextHistoryArchivalState.URI,
+		VisibilityArchivalState:      nextVisibilityArchivalState.State,
+		VisibilityArchivalUri:        nextVisibilityArchivalState.URI,
+		BadBinaries:                  &namespacepb.BadBinaries{Binaries: map[string]*namespacepb.BadBinaryInfo{}},
+		CustomSearchAttributeAliases: nil,
 	}
 	replicationConfig := &persistencespb.NamespaceReplicationConfig{
 		ActiveClusterName: activeClusterName,
@@ -720,6 +721,7 @@ func (d *namespaceHandlerImpl) createResponse(
 		VisibilityArchivalState:       config.VisibilityArchivalState,
 		VisibilityArchivalUri:         config.VisibilityArchivalUri,
 		BadBinaries:                   config.BadBinaries,
+		CustomSearchAttributeAliases:  config.CustomSearchAttributeAliases,
 	}
 
 	var clusters []*replicationpb.ClusterReplicationConfig