Support docker

Author: frozenbonito

package-lock.json

@@ -151,15 +151,18 @@
     "chalk": "^3.0.0",
     "cuid": "^2.1.6",
     "execa": "^3.4.0",
+    "fs-extra": "^8.1.0",
     "hapi-swagger": "^11.0.1",
     "js-string-escape": "^1.0.1",
     "jsonpath-plus": "^2.0.0",
     "jsonwebtoken": "^8.5.1",
+    "jszip": "^3.2.2",
     "luxon": "^1.21.3",
     "node-fetch": "^2.6.0",
     "node-schedule": "^1.3.2",
     "object.fromentries": "^2.0.1",
     "please-upgrade-node": "^3.2.0",
+    "portfinder": "^1.0.25",
     "semver": "^6.3.0",
     "update-notifier": "^3.0.1",
     "velocityjs": "^2.0.0",

package.json

@@ -7,6 +7,7 @@ import {
   CUSTOM_OPTION,
   defaultOptions,
   SERVER_SHUTDOWN_TIMEOUT,
+  supportedRuntimesOnlyWithDocker,
 } from './config/index.js'
 import pkg from '../package.json'
 
@@ -16,6 +17,7 @@ export default class ServerlessOffline {
     this._schedule = null
     this._webSocket = null
     this._lambda = null
+    this._docker = null
 
     this._cliOptions = cliOptions
     this._serverless = serverless
@@ -68,6 +70,10 @@ export default class ServerlessOffline {
       webSocketEvents,
     } = this._getEvents()
 
+    if (this._checkDockerIsRequired(lambdas)) {
+      await this._createDocker(lambdas)
+    }
+
     // if (lambdas.length > 0) {
     await this._createLambda(lambdas)
     // }
@@ -122,6 +128,10 @@ export default class ServerlessOffline {
 
     await Promise.all(eventModules)
 
+    if (this._docker) {
+      await this._docker.cleanup()
+    }
+
     if (!skipExit) {
       process.exit(0)
     }
@@ -152,10 +162,18 @@ export default class ServerlessOffline {
     serverlessLog(`Got ${command} signal. Offline Halting...`)
   }
 
+  async _createDocker(lambdas) {
+    const { default: Docker } = await import('./docker/index.js')
+
+    this._docker = new Docker(this._serverless, this._options, lambdas)
+
+    return this._docker.initialize()
+  }
+
   async _createLambda(lambdas, skipStart) {
     const { default: Lambda } = await import('./lambda/index.js')
 
-    this._lambda = new Lambda(this._serverless, this._options)
+    this._lambda = new Lambda(this._serverless, this._options, this._docker)
 
     lambdas.forEach(({ functionKey, functionDefinition }) => {
       this._lambda.add(functionKey, functionDefinition)
@@ -343,4 +361,19 @@ export default class ServerlessOffline {
       )
     }
   }
+
+  _checkDockerIsRequired(lambdas) {
+    if (this._options.useDocker) {
+      return true
+    }
+
+    const { service } = this._serverless
+    if (supportedRuntimesOnlyWithDocker.has(service.provider.runtime)) {
+      return true
+    }
+
+    return lambdas.some(({ functionDefinition }) => {
+      return supportedRuntimesOnlyWithDocker.has(functionDefinition.runtime)
+    })
+  }
 }