Cleanup

Author: cyberwombat

.babelrc

@@ -0,0 +1,23 @@
+{
+  "plugins": [
+    [
+      "module-resolver",
+      {
+        "root": [
+          "./src",
+          "./test"
+        ]
+      }
+    ]
+  ],
+  "presets": [
+    [
+      "@babel/preset-env",
+      {
+        "targets": {
+          "node": "current"
+        }
+      }
+    ]
+  ]
+}

.eslintrc.json

@@ -1,15 +1,29 @@
 {
+  "parser": "babel-eslint",
   "extends": [
-    "plugin:prettier/recommended"
+    "standard"
   ],
   "env": {
     "jest": true,
     "node": true
   },
+  "plugins": [],
   "parserOptions": {
-    "ecmaVersion": 2018
+    "ecmaVersion": 2018,
+    "allowImportExportEverywhere": true
   },
   "rules": {
+    "template-curly-spacing": "off",
+    "indent": [
+      "warn",
+      2,
+      {
+        "ignoredNodes": [
+          "TemplateLiteral"
+        ],
+        "SwitchCase": 1
+      }
+    ],
     "no-unused-vars": 1
   }
 }

.npmignore

@@ -4,7 +4,7 @@ const path = require('path')
 const createServer = require('./lib/server')
 
 class ServerlessAppSyncPlugin {
-  constructor(serverless, options) {
+  constructor (serverless, options) {
     this.serverless = serverless
     this.servicePath = serverless.config.servicePath
     this.serverlessLog = serverless.cli.log.bind(serverless.cli)
@@ -82,19 +82,18 @@ class ServerlessAppSyncPlugin {
     }
   }
 
-  get port() {
+  get port () {
     const config = (this.service.custom && this.service.custom.dynamodb) || {}
     const port = _.get(config, 'start.port', null)
     return port
   }
 
-  async startHandler(isStandalone = false) {
+  async startHandler (isStandalone = false) {
     this._setOptions()
     let dynamodb = null
 
     try {
-      if (!this.options.dynamodb.client.endpoint)
-        throw new Error('Provide a DynamoDB endpoint')
+      if (!this.options.dynamodb.client.endpoint) { throw new Error('Provide a DynamoDB endpoint') }
 
       const { DynamoDB } = require('aws-sdk')
       dynamodb = new DynamoDB(this.options.dynamodb.client)
@@ -133,14 +132,14 @@ class ServerlessAppSyncPlugin {
     }
   }
 
-  async startStandaloneHandler() {
+  async startStandaloneHandler () {
     this.serverlessLog('AppSync Standalone')
     return Promise.resolve(this.startHandler(true)).then(() =>
       this._listenForTermination()
     )
   }
 
-  endHandler() {
+  endHandler () {
     if (this.emulator) {
       // DynamoDB only needs stopping if we actually started it. If an external
       // connection was specified then this.emulator will be undefined.
@@ -154,10 +153,10 @@ class ServerlessAppSyncPlugin {
     }
   }
 
-  _setOptions() {
+  _setOptions () {
     // Merge the different sources of values for this.options
     // Precedence is: command line options, YAML options, defaults.
-    //this.serverlessLog(JSON.stringify(this.options));
+    // this.serverlessLog(JSON.stringify(this.options));
     const defaultOpts = {
       port: null,
       elastic: {
@@ -177,9 +176,7 @@ class ServerlessAppSyncPlugin {
       }
     }
 
-    let appSyncOfflineOptions = (this.serverless.service.custom || {})[
-      'appSyncOffline'
-    ]
+    const appSyncOfflineOptions = (this.serverless.service.custom || {}).appSyncOffline
 
     this.options = _.merge(
       {},
@@ -211,7 +208,7 @@ class ServerlessAppSyncPlugin {
     )
   }
 
-  _listenForTermination() {
+  _listenForTermination () {
     // SIGINT will be usually sent when user presses ctrl+c
     const waitForSigInt = new Promise(resolve => {
       process.on('SIGINT', () => resolve('SIGINT'))

.prettierrc

@@ -43,37 +43,6 @@ const lambdaSource = async (
   )
   let child = null
 
-  if (fnConfig.runtime && !fnConfig.runtime.includes('node')) {
-    let extHandlerMethod = ''
-    let runner = null
-    if (fnConfig.runtime.indexOf('python') >= 0) {
-      extHandlerMethod = fn
-      runner = PythonRunner
-    } else if (fnConfig.runtime.indexOf('ruby') >= 0) {
-      extHandlerMethod = fn
-      runner = RubyRunner
-    } else if (fnConfig.runtime.indexOf('go') >= 0) {
-      extHandlerMethod = fnConfig.handler.split('/').pop()
-      runner = GoRunner
-    }
-
-    child = fork(runner, [], {
-      env: {
-        ...process.env,
-        ...dynamodbTableAliases,
-        DYNAMODB_ENDPOINT: dynamodbEndpoint,
-        ...provider.environment,
-        ...fnConfig.environment
-      },
-      stdio: [0, 1, 2, 'ipc']
-    })
-
-    child.send({
-      serverlessDirectory,
-      handlerMethod: extHandlerMethod,
-      payload
-    })
-  } else {
     const childOptions = {
       env: {
         ...process.env,
@@ -93,7 +62,7 @@ const lambdaSource = async (
       handlerMethod,
       payload
     })
-  }
+  
 
   const response = await e2p(child, 'message')
 

__tests__/lambdaRunnerGo.test.js

@@ -1,4 +1,3 @@
-process.env.CONSOLA_LEVEL = process.env.DEBUG_LEVEL
-  ? process.env.DEBUG_LEVEL
-  : 'silent'
+process.env.CONSOLA_LEVEL = process.env.DEBUG ? 'debug' : 'silent'
+
 module.exports = require('consola')