environment

Author: lbernardo

bin/darwin/lambda-local

@@ -85,7 +85,7 @@ func (se *Server) StartConfig() {
 		for _, functions := range se.JSON.Functions {
 			check, parameters := checkPath(functions.Events[0].HttpEvent, r.URL.RequestURI(), r.Method)
 			if check {
-				result, off := lambda.ExecuteDockerLambda(se.Volume, se.Network, functions.Handler, se.JSON.Provider["runtime"], r.Body, parameters)
+				result, off := lambda.ExecuteDockerLambda(se.Volume, se.Network, functions.Handler, se.JSON.Provider["runtime"], se.JSON.Environment, r.Body, parameters)
 				if result.StatusCode == 0 {
 					w.WriteHeader(400)
 					fmt.Println(off)

bin/linux/lambda-local

@@ -1,13 +1,15 @@
 package main
 
 import (
+	"os"
+
 	"github.com/aws/aws-lambda-go/events"
 	"github.com/aws/aws-lambda-go/lambda"
 )
 
 func HandleRequest(request events.APIGatewayProxyRequest) (events.APIGatewayProxyResponse, error) {
 	return events.APIGatewayProxyResponse{
-		Body:       "Hello",
+		Body:       "Hello:" + os.Getenv("DATABASE") + os.Getenv("TABLE_NAME"),
 		StatusCode: 200,
 	}, nil
 }

controller/server.go

@@ -4,6 +4,10 @@ provider:
   name: aws
   runtime: go1.x
 
+environment:
+  DATABASE: "mydatabase"
+  TABLE_NAME: table-${opt:stage, self:provider.stage}
+
 functions:
   hello:
     handler: bin/hello

example/go/adapters/hello/hello.go

@@ -37,16 +37,25 @@ func PullImageDocker(runtime string) {
 	io.Copy(os.Stdout, reader)
 }
 
-func ExecuteDockerLambda(volume string, net string, handler string, runtime string, body io.ReadCloser, parameters map[string]string) (model.Result, string) {
+func ReplaceEnvironment(env string) string {
+	return strings.ReplaceAll(env, "${opt:stage, self:provider.stage}", "dev")
+}
+
+func ExecuteDockerLambda(volume string, net string, handler string, runtime string, environment map[string]string, body io.ReadCloser, parameters map[string]string) (model.Result, string) {
 	var result model.Result
 	var output bytes.Buffer
 	var contentRequest ContentRequest
 	buf := new(bytes.Buffer)
 	buf.ReadFrom(body)
 	bodyStr := buf.String()
+	var strEnv []string
 
 	imageName := "lambci/lambda:" + runtime
 
+	for n, env := range environment {
+		strEnv = append(strEnv, n+"="+ReplaceEnvironment(env))
+	}
+
 	ctx := context.Background()
 	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
 	if err != nil {
@@ -76,6 +85,7 @@ func ExecuteDockerLambda(volume string, net string, handler string, runtime stri
 	resp, err := cli.ContainerCreate(ctx, &container.Config{
 		Image: imageName,
 		Cmd:   executeCommand,
+		Env:   strEnv,
 	}, &container.HostConfig{
 		Binds: []string{volume + ":/var/task"},
 	}, networkingConfig, "")

example/go/bin/hello

@@ -1,8 +1,9 @@
 package model
 
 type Serverless struct {
-	Functions map[string]Functions `json:"functions"`
-	Provider  map[string]string    `json:"provider"`
+	Functions   map[string]Functions `json:"functions"`
+	Provider    map[string]string    `json:"provider"`
+	Environment map[string]string    `json:"environment"`
 }
 
 type Functions struct {