Add rewind support (#296)

Author: YunchuWang

internal/protocol/SOURCE_COMMIT

@@ -1 +1 @@
-1caadbd7ecfdf5f2309acbeac28a3e36d16aa156
+3145f9337fca9de57d2f89a6ff6f07150d34f1c2

internal/protocol/protos/orchestrator_service.proto

@@ -25,6 +25,7 @@ message ActivityRequest {
     OrchestrationInstance orchestrationInstance = 4;
     int32 taskId = 5;
     TraceContext parentTraceContext = 6;
+    map<string, string> tags = 7;
 }
 
 message ActivityResponse {
@@ -320,6 +321,10 @@ message SendEntityMessageAction {
     }
 }
 
+message RewindOrchestrationAction {
+    repeated HistoryEvent newHistory = 1;
+}
+
 message OrchestratorAction {
     int32 id = 1;
     oneof orchestratorActionType {
@@ -330,6 +335,7 @@ message OrchestratorAction {
         CompleteOrchestrationAction completeOrchestration = 6;
         TerminateOrchestrationAction terminateOrchestration = 7;
         SendEntityMessageAction sendEntityMessage = 8;
+        RewindOrchestrationAction rewindOrchestration = 9;
     }
 }
 
@@ -364,12 +370,14 @@ message OrchestratorResponse {
     // Whether or not a history is required to complete the original OrchestratorRequest and none was provided.
     bool requiresHistory = 7;
 
+    /* Chunking logic has since been deprecated and fields related to it are marked as such */
+
     // True if this is a partial (chunked) completion. The backend must keep the work item open until the final chunk (isPartial=false).
-    bool isPartial = 8;
+    bool isPartial = 8 [deprecated=true];
 
     // Zero-based position of the current chunk within a chunked completion sequence.
     // This field is omitted for non-chunked completions.
-    google.protobuf.Int32Value chunkIndex = 9;
+    google.protobuf.Int32Value chunkIndex = 9 [deprecated=true];
 }
 
 message CreateInstanceRequest {
@@ -517,6 +525,7 @@ message PurgeInstanceFilter {
     google.protobuf.Timestamp createdTimeFrom = 1;
     google.protobuf.Timestamp createdTimeTo = 2;
     repeated OrchestrationStatus runtimeStatus = 3;
+    google.protobuf.Duration timeout = 4;
 }
 
 message PurgeInstancesResponse {

packages/durabletask-js/src/proto/orchestrator_service_pb.d.ts

@@ -63,6 +63,9 @@ export class ActivityRequest extends jspb.Message {
     getParenttracecontext(): TraceContext | undefined;
     setParenttracecontext(value?: TraceContext): ActivityRequest;
 
+    getTagsMap(): jspb.Map<string, string>;
+    clearTagsMap(): void;
+
     serializeBinary(): Uint8Array;
     toObject(includeInstance?: boolean): ActivityRequest.AsObject;
     static toObject(includeInstance: boolean, msg: ActivityRequest): ActivityRequest.AsObject;
@@ -81,6 +84,8 @@ export namespace ActivityRequest {
         orchestrationinstance?: OrchestrationInstance.AsObject,
         taskid: number,
         parenttracecontext?: TraceContext.AsObject,
+
+        tagsMap: Array<[string, string]>,
     }
 }
 
@@ -1613,6 +1618,28 @@ export namespace SendEntityMessageAction {
 
 }
 
+export class RewindOrchestrationAction extends jspb.Message { 
+    clearNewhistoryList(): void;
+    getNewhistoryList(): Array<HistoryEvent>;
+    setNewhistoryList(value: Array<HistoryEvent>): RewindOrchestrationAction;
+    addNewhistory(value?: HistoryEvent, index?: number): HistoryEvent;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): RewindOrchestrationAction.AsObject;
+    static toObject(includeInstance: boolean, msg: RewindOrchestrationAction): RewindOrchestrationAction.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: RewindOrchestrationAction, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): RewindOrchestrationAction;
+    static deserializeBinaryFromReader(message: RewindOrchestrationAction, reader: jspb.BinaryReader): RewindOrchestrationAction;
+}
+
+export namespace RewindOrchestrationAction {
+    export type AsObject = {
+        newhistoryList: Array<HistoryEvent.AsObject>,
+    }
+}
+
 export class OrchestratorAction extends jspb.Message { 
     getId(): number;
     setId(value: number): OrchestratorAction;
@@ -1652,6 +1679,11 @@ export class OrchestratorAction extends jspb.Message {
     getSendentitymessage(): SendEntityMessageAction | undefined;
     setSendentitymessage(value?: SendEntityMessageAction): OrchestratorAction;
 
+    hasRewindorchestration(): boolean;
+    clearRewindorchestration(): void;
+    getRewindorchestration(): RewindOrchestrationAction | undefined;
+    setRewindorchestration(value?: RewindOrchestrationAction): OrchestratorAction;
+
     getOrchestratoractiontypeCase(): OrchestratorAction.OrchestratoractiontypeCase;
 
     serializeBinary(): Uint8Array;
@@ -1674,6 +1706,7 @@ export namespace OrchestratorAction {
         completeorchestration?: CompleteOrchestrationAction.AsObject,
         terminateorchestration?: TerminateOrchestrationAction.AsObject,
         sendentitymessage?: SendEntityMessageAction.AsObject,
+        rewindorchestration?: RewindOrchestrationAction.AsObject,
     }
 
     export enum OrchestratoractiontypeCase {
@@ -1685,6 +1718,7 @@ export namespace OrchestratorAction {
         COMPLETEORCHESTRATION = 6,
         TERMINATEORCHESTRATION = 7,
         SENDENTITYMESSAGE = 8,
+        REWINDORCHESTRATION = 9,
     }
 
 }
@@ -2557,6 +2591,11 @@ export class PurgeInstanceFilter extends jspb.Message {
     setRuntimestatusList(value: Array<OrchestrationStatus>): PurgeInstanceFilter;
     addRuntimestatus(value: OrchestrationStatus, index?: number): OrchestrationStatus;
 
+    hasTimeout(): boolean;
+    clearTimeout(): void;
+    getTimeout(): google_protobuf_duration_pb.Duration | undefined;
+    setTimeout(value?: google_protobuf_duration_pb.Duration): PurgeInstanceFilter;
+
     serializeBinary(): Uint8Array;
     toObject(includeInstance?: boolean): PurgeInstanceFilter.AsObject;
     static toObject(includeInstance: boolean, msg: PurgeInstanceFilter): PurgeInstanceFilter.AsObject;
@@ -2572,6 +2611,7 @@ export namespace PurgeInstanceFilter {
         createdtimefrom?: google_protobuf_timestamp_pb.Timestamp.AsObject,
         createdtimeto?: google_protobuf_timestamp_pb.Timestamp.AsObject,
         runtimestatusList: Array<OrchestrationStatus>,
+        timeout?: google_protobuf_duration_pb.Duration.AsObject,
     }
 }