Add durable orchestration and entity examples

package.json

@@ -10,16 +10,17 @@
         "test": "mocha 'dist/test/**/*.test.js'"
     },
     "dependencies": {
-        "@azure/functions": "^4.0.0-alpha.5"
+        "@azure/functions": "^4.0.0-alpha.5",
+        "durable-functions": "file:../../../durable/js-sdk"
     },
     "devDependencies": {
         "@types/chai": "^4.0.0",
         "@types/mocha": "^9.0.0",
         "@types/node": "^18.0.0",
         "chai": "^4.0.0",
+        "func-cli-nodejs-v4": "4.0.4764",
         "mocha": "^9.0.0",
-        "typescript": "^4.0.0",
-        "func-cli-nodejs-v4": "4.0.4764"
+        "typescript": "^4.0.0"
     },
-    "main": "dist/src/index.js"
+    "main": "dist/src/functions/*.js"
 }

src/functions/durableEntity.ts

@@ -0,0 +1,40 @@
+import { HttpRequest, InvocationContext, output, trigger } from '@azure/functions';
+import * as df from 'durable-functions';
+import { DurableClientHandler, EntityHandler } from 'durable-functions';
+
+// Replace with your own Durable entity name
+const entityName = 'Counter';
+
+const clientHandler: DurableClientHandler = async (_context: InvocationContext, req: HttpRequest, client) => {
+    const id: string = req.params.id;
+    const entityId = new df.EntityId(entityName, id);
+
+    if (req.method === 'POST') {
+        // increment value
+        await client.signalEntity(entityId, 'add', 1);
+    } else {
+        // read current state of entity
+        const stateResponse = await client.readEntityState(entityId);
+        return {
+            body: stateResponse.entityState,
+        };
+    }
+};
+df.client('durableEntityStart1', trigger.http({ route: 'entity/{id}' }), output.http({}), clientHandler);
+
+const entityHandler: EntityHandler<number> = (context) => {
+    const currentValue: number = context.df.getState(() => 0);
+    switch (context.df.operationName) {
+        case 'add':
+            const amount: number = context.df.getInput();
+            context.df.setState(currentValue + amount);
+            break;
+        case 'reset':
+            context.df.setState(0);
+            break;
+        case 'get':
+            context.df.return(currentValue);
+            break;
+    }
+};
+df.entity(entityName, entityHandler);

src/functions/durableOrchestration-complex.ts

@@ -0,0 +1,41 @@
+import { HttpRequest, InvocationContext, output, trigger } from '@azure/functions';
+import * as df from 'durable-functions';
+import { ActivityHandler, DurableClientHandler, OrchestrationHandler } from 'durable-functions';
+
+// Replace with the name of your Durable Functions Activity
+const activityName = 'hello2';
+
+const orchestrator: OrchestrationHandler = function* (context) {
+    const outputs = [];
+    outputs.push(yield context.df.callActivity(activityName, 'Tokyo'));
+    outputs.push(yield context.df.callActivity(activityName, 'Seattle'));
+    outputs.push(yield context.df.callActivity(activityName, 'Cairo'));
+
+    return outputs;
+};
+df.orchestration('durableOrchestrator2', orchestrator);
+
+const helloActivity: ActivityHandler<string> = (_context: InvocationContext, input: string) => {
+    return `Hello, ${input}`;
+};
+df.activityComplex<string>(activityName, {
+    extraInputs: [], // could be used to add extra inputs
+    extraOutputs: [], // could be used to add extra outputs
+    handler: helloActivity,
+});
+
+const clientHandler: DurableClientHandler = async (context: InvocationContext, request: HttpRequest, client) => {
+    const instanceId = await client.startNew(request.params.orchestratorName, undefined, request.text());
+    context.log(`Started orchestration with ID = '${instanceId}'.`);
+    return client.createCheckStatusResponse(request, instanceId);
+};
+
+df.clientComplex('durableOrchestrationStart2', {
+    trigger: trigger.http({
+        route: 'orchestrators/{orchestratorName}',
+    }),
+    return: output.http({}),
+    extraInputs: [], // could be used to add extra inputs
+    extraOutputs: [], // could be used to add extra outputs
+    handler: clientHandler,
+});

src/functions/durableOrchestration.ts

@@ -0,0 +1,28 @@
+import { HttpRequest, InvocationContext } from '@azure/functions';
+import * as df from 'durable-functions';
+import { ActivityHandler, DurableClientHandler, OrchestrationHandler } from 'durable-functions';
+
+// Replace with the name of your Durable Functions Activity
+const activityName = 'hello';
+
+const orchestrator: OrchestrationHandler = function* (context) {
+    const outputs = [];
+    outputs.push(yield context.df.callActivity(activityName, 'Tokyo'));
+    outputs.push(yield context.df.callActivity(activityName, 'Seattle'));
+    outputs.push(yield context.df.callActivity(activityName, 'Cairo'));
+
+    return outputs;
+};
+df.orchestration('durableOrchestrator1', orchestrator);
+
+const helloActivity: ActivityHandler<string> = (_context: InvocationContext, input: string) => {
+    return `Hello, ${input}`;
+};
+df.activity<string>(activityName, helloActivity);
+
+const clientHandler: DurableClientHandler = async (context: InvocationContext, request: HttpRequest, client) => {
+    const instanceId = await client.startNew(request.query.get('orchestratorName'), undefined, request.text());
+    context.log(`Started orchestration with ID = '${instanceId}'.`);
+    return client.createCheckStatusResponse(request, instanceId);
+};
+df.httpClient('durableOrchestrationStart1', clientHandler);