📦 create release v0.0.6

Author: k33g

.gitignore

@@ -21,3 +21,5 @@ site
 slingshot.code-workspace
 
 linux
+
+localtonet

README.md

@@ -1,6 +1,8 @@
 # SlingShot
 
-**SlingShot** is a **Wasm** runner to run or serve **[Extism](https://extism.org/)** **Wasm** plug-ins
+> How to run serverless applications augmented by Wasm
+
+**SlingShot** is a **Wasm** runner to run or serve **[Extism](https://extism.org/)** **Wasm** plug-ins.
 
 **Run a wasm plug-in**:
 ```bash title="Run a wasm plug-in"

docker-compose-demo/.gitignore

@@ -0,0 +1 @@
+node_modules

docker-compose-demo/.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "editor.fontSize": 16,
+}

docker-compose-demo/compose.yml

@@ -0,0 +1,65 @@
+services:
+  hello-world:
+    image: "botsgarden/slingshot:0.0.5"
+    command: |
+      /slingshot start
+        --wasm=./wasm-plugins/hello-service/hello.wasm 
+        --handler=handle 
+        --http-port=7071
+    ports:
+      - target: 7071
+        published: 7071
+    networks:
+      - slingshot-net
+    volumes:
+      - ./wasm-plugins:/wasm-plugins
+
+  hey-people:
+    image: "botsgarden/slingshot:0.0.5"
+    command: |
+      /slingshot start
+        --wasm=./wasm-plugins/hey-service/hey.wasm 
+        --handler=handle 
+        --http-port=7072
+    ports:
+      - target: 7072
+        published: 7072
+    networks:
+      - slingshot-net
+    volumes:
+      - ./wasm-plugins:/wasm-plugins
+
+  test-hello-service:
+    image: yauritux/busybox-curl
+    #image: ubuntu:latest
+    depends_on:
+      - hello-world
+    networks:
+      - slingshot-net
+    command:
+      - /bin/sh 
+      - -c 
+      - |
+        curl http://hello-world:7071 \
+          -H 'content-type: text/plain; charset=utf-8' \
+          -d '😄 Bob Morane 🤖'
+
+  test-hey-service:
+    image: yauritux/busybox-curl
+    #image: ubuntu:latest
+    depends_on:
+      - hey-people
+    networks:
+      - slingshot-net
+    command:
+      - /bin/sh 
+      - -c 
+      - |
+        curl http://hey-people:7072 \
+          -H 'content-type: text/plain; charset=utf-8' \
+          -d '😄 Bob Morane 🤖'
+
+networks:
+  slingshot-net:
+    #driver: bridge
+    #external: true

docker-compose-demo/go.work

@@ -0,0 +1,8 @@
+go 1.20
+
+use (
+	./wasm-plugins/hello-service
+	./wasm-plugins/hey-service
+)
+
+// go work sync

docker-compose-demo/go.work.sum

@@ -0,0 +1,2 @@
+github.com/extism/go-pdk v0.0.0-20230816024928-ee09fee7466e/go.mod h1:3qe+ObKvmOVwzmQDC5A7KzTuvfjImOnWsB1MWU6mWA4=
+github.com/valyala/fastjson v1.6.3/go.mod h1:CLCAqky6SMuOcxStkYQvblddUtoRxhYMGLrsQns1aXY=

docker-compose-demo/query.sh

@@ -0,0 +1,23 @@
+#!/bin/bash
+
+curl --verbose \
+http://localhost:7071 \
+-H 'content-type: text/plain; charset=utf-8' \
+-d '😄 Bob Morane'
+echo ""
+
+curl --verbose \
+http://localhost:7072 \
+-H 'content-type: text/plain; charset=utf-8' \
+-d '😄 Bob Morane'
+echo ""
+
+
+#curl http://198.19.249.146:7071 -H "content-type: text/plain; charset=utf-8" -d "😄 Bob Morane"
+#curl http://198.19.249.146:7072 -H "content-type: text/plain; charset=utf-8" -d "😄 Bob Morane"
+
+curl https://hello-wasm.localto.net -H "content-type: text/plain; charset=utf-8" -d "😄 Bob Morane"
+
+curl https://hello-one.localto.net -H "content-type: text/plain; charset=utf-8" -d "😄 Bob Morane"
+curl https://hello-two.localto.net -H "content-type: text/plain; charset=utf-8" -d "😄 Bob Morane"
+

docker-compose-demo/serve-with-docker.sh

@@ -0,0 +1,22 @@
+#!/bin/bash
+DOCKER_USER="botsgarden"
+IMAGE_NAME="slingshot"
+IMAGE_TAG="0.0.5"
+echo "🖼️ ${IMAGE_NAME}"
+HTTP_PORT="7070"
+
+#docker run \
+#  -p ${HTTP_PORT}:${HTTP_PORT} \
+#  -v $(pwd):/app --rm ${DOCKER_USER}/${IMAGE_NAME}:${IMAGE_TAG} \
+#  /slingshot start \
+#  --wasm=./app/hello.wasm \
+#  --handler=callHandler \
+#  --http-port=${HTTP_PORT} 
+
+docker run \
+  -p ${HTTP_PORT}:${HTTP_PORT} \
+  -v $(pwd):/app/wasm-plugins --rm ${DOCKER_USER}/${IMAGE_NAME}:${IMAGE_TAG} \
+  /slingshot start \
+  --wasm=./app/wasm-plugins/hello.wasm \
+  --handler=handle \
+  --http-port=${HTTP_PORT} 

docker-compose-demo/start-docker.sh

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+sudo chmod 666 /var/run/docker.sock
+ls -l /var/run/docker.sock
+sudo systemctl restart docker.service
+

docker-compose-demo/wasm-plugins/hello-service/.gitignore

@@ -0,0 +1,2 @@
+*.wasm
+slingshot

docker-compose-demo/wasm-plugins/hello-service/build.sh

@@ -0,0 +1,7 @@
+#!/bin/bash
+
+tinygo build -scheduler=none --no-debug \
+    -o hello.wasm \
+    -target wasi main.go
+
+ls -lh *.wasm

docker-compose-demo/wasm-plugins/hello-service/go.mod

@@ -0,0 +1,8 @@
+module hello
+
+go 1.20
+
+require (
+	github.com/extism/go-pdk v0.0.0-20230816024928-ee09fee7466e
+	github.com/valyala/fastjson v1.6.3
+)

docker-compose-demo/wasm-plugins/hello-service/go.sum

@@ -0,0 +1,2 @@
+github.com/extism/go-pdk v0.0.0-20230816024928-ee09fee7466e h1:y6pBlzMRaYEBriiyzmT8e82927vBpum357VWi7Lg3/U=
+github.com/valyala/fastjson v1.6.3 h1:tAKFnnwmeMGPbwJ7IwxcTPCNr3uIzoIj3/Fh90ra4xc=

docker-compose-demo/wasm-plugins/hello-service/main.go

@@ -0,0 +1,48 @@
+package main
+
+import (
+	"strings"
+
+	"github.com/extism/go-pdk"
+	"github.com/valyala/fastjson"
+)
+
+var parser = fastjson.Parser{}
+
+//export handle
+func handle()  {
+	// read function argument from the memory
+	http_request_data := pdk.Input()
+
+	var text string
+	var code string
+
+	JSONData, err := parser.ParseBytes(http_request_data)
+	if err != nil {
+		text = "😡 Error: " + err.Error()
+		code = "500"
+	} else {
+		text = "🩵 Hello " + string(JSONData.GetStringBytes("body"))
+		code = "200"
+	}
+
+	headers := []string{
+		`"Content-Type": "application/json; charset=utf-8"`,
+		`"X-Slingshot-version": "0.0.0"`,
+	}
+
+	headersStr := strings.Join(headers, ",")
+
+	// if "Content-Type": "text/plain; charset=utf-8" => use textBody
+	// if "Content-Type": "application/json; charset=utf-8" => use jsonBody
+	
+	response := `{"headers":{` + headersStr + `}, "jsonBody": {"message":"` + text + `"}, "statusCode": `+ code +`}`
+
+	mem := pdk.AllocateString(response)
+	// copy output to host memory
+	pdk.OutputMemory(mem)	
+}
+
+func main() {}
+
+//jsonBody

docker-compose-demo/wasm-plugins/hello-service/query.sh

@@ -0,0 +1,8 @@
+#!/bin/bash
+
+curl --verbose \
+http://localhost:7070 \
+-H 'content-type: text/plain; charset=utf-8' \
+-d '😄 Bob Morane'
+echo ""
+

docker-compose-demo/wasm-plugins/hello-service/serve-with-docker.sh

@@ -0,0 +1,15 @@
+#!/bin/bash
+DOCKER_USER="botsgarden"
+IMAGE_NAME="slingshot"
+IMAGE_TAG="0.0.5"
+echo "🖼️ ${IMAGE_NAME}"
+HTTP_PORT="7070"
+
+docker run \
+  -p ${HTTP_PORT}:${HTTP_PORT} \
+  -v $(pwd):/app --rm ${DOCKER_USER}/${IMAGE_NAME}:${IMAGE_TAG} \
+  /slingshot start \
+  --wasm=./app/hello.wasm \
+  --handler=handle \
+  --http-port=${HTTP_PORT} 
+

docker-compose-demo/wasm-plugins/hey-service/.gitignore

@@ -0,0 +1,2 @@
+*.wasm
+slingshot

docker-compose-demo/wasm-plugins/hey-service/build.sh

@@ -0,0 +1,7 @@
+#!/bin/bash
+
+tinygo build -scheduler=none --no-debug \
+    -o hey.wasm \
+    -target wasi main.go
+
+ls -lh *.wasm

docker-compose-demo/wasm-plugins/hey-service/go.mod

@@ -0,0 +1,8 @@
+module hey
+
+go 1.20
+
+require (
+	github.com/extism/go-pdk v0.0.0-20230816024928-ee09fee7466e
+	github.com/valyala/fastjson v1.6.3
+)

docker-compose-demo/wasm-plugins/hey-service/go.sum

@@ -0,0 +1,2 @@
+github.com/extism/go-pdk v0.0.0-20230816024928-ee09fee7466e h1:y6pBlzMRaYEBriiyzmT8e82927vBpum357VWi7Lg3/U=
+github.com/valyala/fastjson v1.6.3 h1:tAKFnnwmeMGPbwJ7IwxcTPCNr3uIzoIj3/Fh90ra4xc=

docker-compose-demo/wasm-plugins/hey-service/main.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"strings"
+
+	"github.com/extism/go-pdk"
+	"github.com/valyala/fastjson"
+)
+
+var parser = fastjson.Parser{}
+
+//export handle
+func handle()  {
+	// read function argument from the memory
+	http_request_data := pdk.Input()
+
+	var text string
+	var code string
+
+	JSONData, err := parser.ParseBytes(http_request_data)
+	if err != nil {
+		text = "😡 Error: " + err.Error()
+		code = "500"
+	} else {
+		text = "💜 Hey " + string(JSONData.GetStringBytes("body"))
+		code = "200"
+	}
+
+	headers := []string{
+		`"Content-Type": "text/plain; charset=utf-8"`,
+		`"X-Slingshot-version": "0.0.0"`,
+	}
+
+	headersStr := strings.Join(headers, ",")
+	
+	// if "Content-Type": "text/plain; charset=utf-8" => use textBody
+	// if "Content-Type": "application/json; charset=utf-8" => use jsonBody
+	
+	response := `{"headers":{` + headersStr + `}, "textBody": "` + text + `", "statusCode": `+ code +`}`
+
+	mem := pdk.AllocateString(response)
+	// copy output to host memory
+	pdk.OutputMemory(mem)	
+}
+
+func main() {}
+

docker-compose-demo/wasm-plugins/hey-service/query.sh

@@ -0,0 +1,8 @@
+#!/bin/bash
+
+curl --verbose \
+http://localhost:7070 \
+-H 'content-type: text/plain; charset=utf-8' \
+-d '😄 Bob Morane'
+echo ""
+

docker-compose-demo/wasm-plugins/hey-service/serve-with-docker.sh

@@ -0,0 +1,15 @@
+#!/bin/bash
+DOCKER_USER="botsgarden"
+IMAGE_NAME="slingshot"
+IMAGE_TAG="0.0.5"
+echo "🖼️ ${IMAGE_NAME}"
+HTTP_PORT="7070"
+
+docker run \
+  -p ${HTTP_PORT}:${HTTP_PORT} \
+  -v $(pwd):/app --rm ${DOCKER_USER}/${IMAGE_NAME}:${IMAGE_TAG} \
+  /slingshot start \
+  --wasm=./app/hey.wasm \
+  --handler=handle \
+  --http-port=${HTTP_PORT} 
+

examples-pdk/go/02-hello-service/Taskfile.yml

@@ -54,3 +54,11 @@ tasks:
         hey -n 300 -c 100 -m POST \
         -d '👋 John Doe' \
         "http://localhost:7070" 
+
+  # task stress-report
+  stress-report:
+    cmds:
+      - |
+        hey -n 300 -c 100 -m POST \
+        -d '👋 John Doe' \
+        "http://localhost:7070" > $(./slingshot version).txt

examples-pdk/go/02-hello-service/main.go

@@ -28,12 +28,15 @@ func helloHandler(http_request_data []byte) []byte {
 	}
 
 	headers := []string{
-		`"Content-Type": "application/json; charset=utf-8"`,
+		`"Content-Type": "text/plain; charset=utf-8"`,
 		`"X-Slingshot-version": "0.0.0"`,
 	}
 
 	headersStr := strings.Join(headers, ",")
 
+	// if "Content-Type": "text/plain; charset=utf-8" => use textBody
+	// if "Content-Type": "application/json; charset=utf-8" => use jsonBody
+	
 	response := `{"headers":{` + headersStr + `}, "textBody": "` + text + `", "statusCode": ` + code + `}`
 
 	return []byte(response)