Replication support for all history events (cadence-workflow#659)

IDL changes to replicator and history to also include history of next
run with the same replication task.
Mutable state changes to have replication api directly invoked by
replicator when it is applying history events on the passive
cluster.
Fixed ContinuedAsNew processing to lookup parentDomainName from cache
and correctly create history events using ParentDomainInfo.

host/integration_test.go

@@ -4059,6 +4059,7 @@ func (s *integrationSuite) TestChildWorkflowWithContinueAsNew() {
 
 	// Process ChildExecution Started event and all generations of child executions
 	for i := 0; i < 11; i++ {
+		s.logger.Warnf("decision: %v", i)
 		_, err = poller.pollAndProcessDecisionTask(false, false)
 		s.logger.Infof("pollAndProcessDecisionTask: %v", err)
 		s.Nil(err)
@@ -4068,7 +4069,7 @@ func (s *integrationSuite) TestChildWorkflowWithContinueAsNew() {
 	s.NotNil(startedEvent)
 
 	// Process Child Execution final decision to complete it
-	_, err = poller.pollAndProcessDecisionTask(false, false)
+	_, err = poller.pollAndProcessDecisionTask(true, false)
 	s.logger.Infof("pollAndProcessDecisionTask: %v", err)
 	s.Nil(err)
 	s.True(childComplete)

idl/github.com/uber/cadence/history.thrift

@@ -201,6 +201,7 @@ struct ReplicateEventsRequest {
   40: optional i64 (js.type = "Long") nextEventId
   50: optional i64 (js.type = "Long") version
   60: optional shared.History history
+  70: optional shared.History newRunHistory
 }
 
 /**

idl/github.com/uber/cadence/replicator.thrift

@@ -50,6 +50,7 @@ struct HistoryTaskAttributes {
   50: optional i64 (js.type = "Long") nextEventId
   60: optional i64 (js.type = "Long") version
   70: optional shared.History history
+  80: optional shared.History newRunHistory
 }
 
 struct ReplicationTask {

service/history/historyEngine.go

@@ -1141,8 +1141,20 @@ Update_History_Loop:
 				}
 				domainName := domainEntry.GetInfo().Name
 
+				// Extract parentDomainName so it can be passed down to next run of workflow execution
+				var parentDomainName string
+				if msBuilder.hasParentExecution() {
+					parentDomainID := msBuilder.executionInfo.ParentDomainID
+					parentDomainEntry, err := e.shard.GetDomainCache().GetDomainByID(parentDomainID)
+					if err != nil {
+						return err
+					}
+					parentDomainName = parentDomainEntry.GetInfo().Name
+				}
+
 				runID := uuid.New()
-				_, newStateBuilder, err := msBuilder.AddContinueAsNewEvent(completedID, domainID, domainName, runID, attributes)
+				_, newStateBuilder, err := msBuilder.AddContinueAsNewEvent(completedID, domainID, domainName, runID,
+					parentDomainName, attributes)
 				if err != nil {
 					return err
 				}