Fix --useSeparateProcesses

CoorpAcademy · Apr 27, 2019 · 7a10ad6 · 7a10ad6
1 parent 71cb00a
commit 7a10ad6
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 9 deletions.
diff --git a/packages/serverless-offline-dynamodb-streams/src/index.js b/packages/serverless-offline-dynamodb-streams/src/index.js
@@ -16,7 +16,7 @@ const {
   pipe,
   startsWith
 } = require('lodash/fp');
-const {createHandler, getFunctionOptions} = require('serverless-offline/src/functionHelper');
+const functionHelper = require('serverless-offline/src/functionHelper');
 const createLambdaContext = require('serverless-offline/src/createLambdaContext');
 const DynamoDBReadable = require('dynamodb-streams-readable');
 
@@ -96,8 +96,13 @@ class ServerlessOfflineDynamoDBStreams {
 
     const serviceRuntime = this.service.provider.runtime;
     const servicePath = join(this.serverless.config.servicePath, location);
-    const funOptions = getFunctionOptions(__function, functionName, servicePath, serviceRuntime);
-    const handler = createHandler(funOptions, this.config);
+    const funOptions = functionHelper.getFunctionOptions(
+      __function,
+      functionName,
+      servicePath,
+      serviceRuntime
+    );
+    const handler = functionHelper.createHandler(funOptions, this.config);
 
     const lambdaContext = createLambdaContext(__function, (err, data) => {
       this.serverless.cli.log(

diff --git a/packages/serverless-offline-kinesis/src/index.js b/packages/serverless-offline-kinesis/src/index.js
@@ -16,7 +16,7 @@ const {
   pipe,
   startsWith
 } = require('lodash/fp');
-const {createHandler, getFunctionOptions} = require('serverless-offline/src/functionHelper');
+const functionHelper = require('serverless-offline/src/functionHelper');
 const createLambdaContext = require('serverless-offline/src/createLambdaContext');
 
 const fromCallback = fun =>
@@ -86,8 +86,13 @@ class ServerlessOfflineKinesis {
 
     const serviceRuntime = this.service.provider.runtime;
     const servicePath = join(this.serverless.config.servicePath, location);
-    const funOptions = getFunctionOptions(__function, functionName, servicePath, serviceRuntime);
-    const handler = createHandler(funOptions, this.config);
+    const funOptions = functionHelper.getFunctionOptions(
+      __function,
+      functionName,
+      servicePath,
+      serviceRuntime
+    );
+    const handler = functionHelper.createHandler(funOptions, this.config);
     const lambdaContext = createLambdaContext(__function, (err, data) => {
       this.serverless.cli.log(
         `[${err ? figures.cross : figures.tick}] ${JSON.stringify(data) || ''}`

diff --git a/packages/serverless-offline-sqs/src/index.js b/packages/serverless-offline-sqs/src/index.js
@@ -13,7 +13,7 @@ const {
   omitBy,
   pipe
 } = require('lodash/fp');
-const {createHandler, getFunctionOptions} = require('serverless-offline/src/functionHelper');
+const functionHelper = require('serverless-offline/src/functionHelper');
 const createLambdaContext = require('serverless-offline/src/createLambdaContext');
 
 const fromCallback = fun =>
@@ -109,8 +109,13 @@ class ServerlessOfflineSQS {
     const serviceRuntime = this.service.provider.runtime;
     const servicePath = join(this.serverless.config.servicePath, location);
 
-    const funOptions = getFunctionOptions(__function, functionName, servicePath, serviceRuntime);
-    const handler = createHandler(funOptions, this.config);
+    const funOptions = functionHelper.getFunctionOptions(
+      __function,
+      functionName,
+      servicePath,
+      serviceRuntime
+    );
+    const handler = functionHelper.createHandler(funOptions, this.config);
 
     const lambdaContext = createLambdaContext(__function, (err, data) => {
       this.serverless.cli.log(