cleaning example and console.logs

Author: vibou

example/event.json renamed to example/event_map_reduce.json

@@ -1,10 +1,11 @@
 {
   "name": "@vibou/map-reduce-example",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "main": "index.js",
   "license": "MIT",
   "scripts": {
-    "workflow": "sls step-functions-offline -l --stateMachine=map_reduce --event='./event.json' --lambdaEndpoint http://localhost:3002",
+    "workflow": "sls step-functions-offline --lambdaEndpoint http://localhost:3002",
+    "workflow:map_reduce": "yarn workflow --stateMachine=map_reduce --event='./event_map_reduce.json'",
     "invoke:producer": "sls invoke local --stage=local -f producer --path './event.json'",
     "start": "sls offline start"
   },
@@ -13,4 +14,4 @@
     "serverless-offline": "^11.1.3",
     "serverless-step-functions": "^3.10.0"
   }
-}
+}

example/package.json

@@ -29,13 +29,13 @@ custom:
     MappingFunction: mapper
 
 functions: 
-  ${file(functions.yml)}
+  ${file(sls_functions.yml)}
 
 stepFunctions:
   stateMachines:
-    map_reduce:
+    map_reduce: 
       definition: 
         Comment: 'Export a PDF document for the given dashboard'
         StartAt: Producer
-        States: ${file(states.yml)}
+        States: ${file(sls_map_reduce.yml)}
 

example/serverless.yml

@@ -1,6 +1,6 @@
 {
   "name": "@vibou/serverless-step-functions-offline",
-  "version": "3.1.0",
+  "version": "3.1.1",
   "description": "Serverlesss plugin to support step function offline",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
@@ -65,4 +65,4 @@
   "files": [
     "dist/**/*"
   ]
-}
+}

example/functions.yml renamed to example/sls_functions.yml

@@ -304,26 +304,6 @@ export default class StepFunctionsOfflinePlugin implements Plugin {
     throw new this.serverless.classes.Error(`stateMachine "${stateMachineName}" doesn't exist in this Service`);
   }
 
-  // findFunctionsPathAndHandler() {
-  //     for (const functionName in this.variables) {
-  //         const functionHandler = this.variables[functionName];
-  //         const {handler, filePath} = this._findFunctionPathAndHandler(functionHandler);
-  //
-  //         this.variables[functionName] = {handler, filePath};
-  //     }
-  //     console.log('this.va', this.variables)
-  // },
-  //
-  _findFunctionPathAndHandler(functionHandler: string): { handler: string; filePath: string } {
-    const dir = path.dirname(functionHandler);
-    const handler = path.basename(functionHandler);
-    const splitHandler = handler.split('.');
-    const filePath = `${dir}/${splitHandler[0]}.js`;
-    const handlerName = `${splitHandler[1]}`;
-
-    return { handler: handlerName, filePath };
-  }
-
   async _loadStates(states: StateMachine['States'] | string): Promise<StateMachine['States']> {
     if (isString(states)) {
       const serverlessPath = this.serverless.config.servicePath;
@@ -393,7 +373,6 @@ export default class StepFunctionsOfflinePlugin implements Plugin {
       return this._runChoice(data, event);
     } else if (!stateIsChoiceConditional(data)) {
       const callback = data.f(event);
-      console.log('callback', callback);
       return this._run(callback, event, stateName);
     }
   }