docs, samples

Author: danielgerlag

README.md

@@ -2,7 +2,7 @@
 
 [![Build Status](https://travis-ci.org/danielgerlag/workflow-es.svg?branch=master)](https://travis-ci.org/danielgerlag/workflow-es)
 
-Workflow ES is a workflow / durable task library for Node.js (or modern browsers).  It supports pluggable persistence and concurrency providers to allow for multi-node clusters.
+Workflow ES is a workflow / saga library for Node.js (or modern browsers).  It supports pluggable persistence and concurrency providers to allow for multi-node clusters.
 
 ## Installing
 

core/README.md

@@ -2,7 +2,7 @@
 
 [![Build Status](https://travis-ci.org/danielgerlag/workflow-es.svg?branch=master)](https://travis-ci.org/danielgerlag/workflow-es)
 
-Workflow ES is a workflow / durable task library for Node.js (or modern browsers).  It supports pluggable persistence and concurrency providers to allow for multi-node clusters.
+Workflow ES is a workflow / saga library for Node.js (or modern browsers).  It supports pluggable persistence and concurrency providers to allow for multi-node clusters.
 
 ## Installing
 

core/package.json

@@ -10,7 +10,7 @@
     "test": "jasmine"
   },
   "keywords": [
-    "workflow"
+    "workflow", "saga"
   ],
   "author": {
     "email": "[email protected]",

core/src/models/execution-pointer.ts

@@ -14,12 +14,12 @@ export class ExecutionPointer {
     public eventData: any;
     public outcome: any;
     public stepName: string;
-    public retryCount: number;
+    public retryCount: number = 0;
     public children: string[] = [];
     public contextItem: any;
     public predecessorId: string;
     public scope: string[] = [];
-    public status: number;    
+    public status: number = 0;    
 }
 
 export var PointerStatus = {

core/src/models/workflow-step.ts

@@ -16,7 +16,7 @@ export abstract class WorkflowStepBase {
     public outcomes: Array<StepOutcome> = [];
     public children: Array<number> = [];
     public errorBehavior : number;
-    public retryInterval : number;
+    public retryInterval : number = 60000;
     public compensationStepId : number;
 
     public inputs: Array<(step: StepBody, data: any) => void> = [];

samples/node.js/javascript/12-saga.js

@@ -1,5 +1,5 @@
 const workflow_es = require("workflow-es");
-//const workflow_mongo = require("workflow-es-mongodb");
+const workflow_mongo = require("workflow-es-mongodb");
 
 
 class SayHello extends workflow_es.StepBody {
@@ -57,14 +57,17 @@ class Saga_Workflow {
         .saga(saga => saga
             .startWith(DoSomething)
             .then(DoSomethingBad)
-        )        
+        )
         .compensateWith(UndoSomething)
         .then(SayGoodbye);
     }
 }
 
 async function main() {
     var config = workflow_es.configureWorkflow();
+    //let mongoPersistence = new workflow_mongo.MongoDBPersistence("mongodb://127.0.0.1:27017/workflow-node");    
+    //await mongoPersistence.connect;    
+    //config.usePersistence(mongoPersistence);
     var host = config.getHost();
 
     host.registerWorkflow(Saga_Workflow);