Adopt a linear-time replay algorithm

.vscode/settings.json

@@ -11,5 +11,7 @@
     "azureFunctions.projectLanguage": "TypeScript",
     "azureFunctions.projectRuntime": "~3",
     "debug.internalConsoleOptions": "neverOpen",
-    "azureFunctions.preDeployTask": "npm prune"
-}
+    "azureFunctions.preDeployTask": "npm prune",
+    "mochaExplorer.require": "ts-node/register",
+    "mochaExplorer.files": "test/**/*.ts"
+}

package.json

@@ -30,7 +30,7 @@
         "validate:samples": "npm run build && npm --prefix samples install && npm run build:samples",
         "build:nolint": "npm run clean && npm run stripInternalDocs && echo Done",
         "stripInternalDocs": "tsc --pretty -p tsconfig.nocomments",
-        "test": "npm run validate:samples && npm run build && mocha --recursive ./lib/test/**/*-spec.js",
+        "test": "npm run build && mocha --recursive ./lib/test/**/*-spec.js",
         "test:nolint": "npm run build:nolint && mocha --recursive ./lib/test/**/*-spec.js",
         "watch": "tsc --watch",
         "watch:test": "npm run test -- --watch",
@@ -58,7 +58,7 @@
         "@types/chai-string": "~1.4.1",
         "@types/commander": "~2.3.31",
         "@types/debug": "0.0.29",
-        "@types/mocha": "~7.0.2",
+        "@types/mocha": "^7.0.2",
         "@types/nock": "^9.3.0",
         "@types/rimraf": "0.0.28",
         "@types/sinon": "~5.0.5",

src/actions/actiontype.ts

@@ -17,4 +17,8 @@ export enum ActionType {
     WaitForExternalEvent = 6,
     CallEntity = 7,
     CallHttp = 8,
+    // ActionType 9 and 10 correspond to SignalEntity and ScheduledSignalEntity
+    // Those two are not supported yet.
+    WhenAny = 11,
+    WhenAll = 12,
 }

src/actions/createtimeraction.ts

@@ -5,7 +5,7 @@ import { ActionType, IAction } from "../classes";
 export class CreateTimerAction implements IAction {
     public readonly actionType: ActionType = ActionType.CreateTimer;
 
-    constructor(public readonly fireAt: Date, public isCanceled: boolean = false) {
+    constructor(public readonly fireAt: Date, public isCancelled: boolean = false) {
         if (!isDate(fireAt)) {
             throw new TypeError(`fireAt: Expected valid Date object but got ${fireAt}`);
         }

src/actions/whenallaction.ts

@@ -0,0 +1,12 @@
+import { ActionType, IAction } from "../classes";
+import { DFTask } from "../task";
+
+/** @hidden */
+export class WhenAllAction implements IAction {
+    public readonly actionType: ActionType = ActionType.WhenAll;
+    public readonly compoundActions: IAction[];
+
+    constructor(tasks: DFTask[]) {
+        this.compoundActions = tasks.map((t) => t.actionObj);
+    }
+}

src/actions/whenanyaction.ts

@@ -0,0 +1,12 @@
+import { ActionType, IAction } from "../classes";
+import { DFTask } from "../task";
+
+/** @hidden */
+export class WhenAnyAction implements IAction {
+    public readonly actionType: ActionType = ActionType.WhenAny;
+    public readonly compoundActions: IAction[];
+
+    constructor(tasks: DFTask[]) {
+        this.compoundActions = tasks.map((t) => t.actionObj);
+    }
+}

src/aggregatederror.ts

@@ -2,7 +2,7 @@
 const separator = "-----------------------------------";
 
 /**
- * A specfic error thrown when context.df.Task.all() fails. Its message
+ * A specific error thrown when context.df.Task.all() fails. Its message
  * contains an aggregation of all the exceptions that failed. It should follow the
  * below format:
  *

src/classes.ts

@@ -42,13 +42,6 @@ export { TaskScheduledEvent } from "./history/taskscheduledevent";
 export { TimerCreatedEvent } from "./history/timercreatedevent";
 export { TimerFiredEvent } from "./history/timerfiredevent";
 
-export { ITaskMethods } from "./tasks/itaskmethods";
-export { Task } from "./tasks/task";
-export { TaskFactory } from "./tasks/taskfactory";
-export { TaskFilter } from "./tasks/taskfilter";
-export { TaskSet } from "./tasks/taskset";
-export { TimerTask } from "./tasks/timertask";
-
 export { OrchestratorState } from "./orchestratorstate";
 export { IOrchestratorState } from "./iorchestratorstate";
 

src/durableorchestrationbindinginfo.ts

@@ -1,12 +1,28 @@
 import { HistoryEvent } from "./classes";
+import { LatestReplaySchema, ReplaySchema } from "./replaySchema";
 
 /** @hidden */
 export class DurableOrchestrationBindingInfo {
+    public readonly upperSchemaVersion: ReplaySchema;
+
     constructor(
         public readonly history: HistoryEvent[] = [],
         public readonly input?: unknown,
         public readonly instanceId: string = "",
         public readonly isReplaying: boolean = false,
-        public readonly parentInstanceId?: string // TODO: Implement entity locking // public readonly contextLocks?: EntityId[],
-    ) {}
+        public readonly parentInstanceId?: string,
+        upperSchemaVersion = 0 // TODO: Implement entity locking // public readonly contextLocks?: EntityId[],
+    ) {
+        // It is assumed that the extension supports all schemas in range [0, upperSchemaVersion].
+        // Similarly, it is assumed that this SDK supports all schemas in range [0, LatestReplaySchema].
+
+        // Therefore, if the extension supplies a upperSchemaVersion included in our ReplaySchema enum, we use it.
+        // But if the extension supplies an upperSchemaVersion not included in our ReplaySchema enum, then we
+        // assume that upperSchemaVersion is larger than LatestReplaySchema and therefore use LatestReplaySchema instead.
+        if (Object.values(ReplaySchema).includes(upperSchemaVersion)) {
+            this.upperSchemaVersion = upperSchemaVersion;
+        } else {
+            this.upperSchemaVersion = LatestReplaySchema;
+        }
+    }
 }