feat(redis): implement redis in wasip2

Signed-off-by: Andrew Steurer <[email protected]>

Author: asteurer

v3/examples/mqtt-outbound/go.mod

@@ -1,4 +1,4 @@
-module github.com/http_go
+module github.com/spinframework/spin-go-sdk/v3/examples/mqtt-outbound
 
 go 1.24
 

v3/examples/redis-outbound/README.md

@@ -0,0 +1,20 @@
+# Requirements
+- Latest version of [TinyGo](https://tinygo.org/getting-started/)
+- Latest version of [Docker](https://docs.docker.com/get-started/get-docker/)
+
+# Usage
+
+In one terminal window, run:
+```sh
+docker run -p 6379:6379 redis:8.2
+```
+
+In another terminal, you'll run your Spin app:
+```sh
+spin up --build
+```
+
+In yet another terminal, you'll interact with the Spin app:
+```sh
+curl localhost:3000
+```

v3/examples/redis-outbound/go.mod

@@ -0,0 +1,12 @@
+module github.com/spinframework/spin-go-sdk/v3/examples/redis-outbound
+
+go 1.24
+
+require github.com/spinframework/spin-go-sdk/v3 v3.0.0
+
+require (
+	github.com/julienschmidt/httprouter v1.3.0 // indirect
+	go.bytecodealliance.org/cm v0.2.2 // indirect
+)
+
+replace github.com/spinframework/spin-go-sdk/v3 => ../../

v3/examples/redis-outbound/go.sum

@@ -0,0 +1,4 @@
+github.com/julienschmidt/httprouter v1.3.0 h1:U0609e9tgbseu3rBINet9P48AI/D3oJs4dN7jwJOQ1U=
+github.com/julienschmidt/httprouter v1.3.0/go.mod h1:JR6WtHb+2LUe8TCKY3cZOxFyyO8IZAc4RVcycCCAKdM=
+go.bytecodealliance.org/cm v0.2.2 h1:M9iHS6qs884mbQbIjtLX1OifgyPG9DuMs2iwz8G4WQA=
+go.bytecodealliance.org/cm v0.2.2/go.mod h1:JD5vtVNZv7sBoQQkvBvAAVKJPhR/bqBH7yYXTItMfZI=

v3/examples/redis-outbound/main.go

@@ -0,0 +1,137 @@
+package main
+
+import (
+	"fmt"
+	"net/http"
+	"os"
+	"strings"
+
+	spinhttp "github.com/spinframework/spin-go-sdk/v3/http"
+	"github.com/spinframework/spin-go-sdk/v3/redis"
+)
+
+func init() {
+	spinhttp.Handle(func(w http.ResponseWriter, r *http.Request) {
+		redisEndpoint := os.Getenv("REDIS_ENDPOINT")
+		conn, err := redis.Open(redisEndpoint)
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to open redis connection: " + err.Error()))
+			return
+		}
+
+		// Set command
+		if err := conn.Set("key1", []byte("value1")); err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform set operation: " + err.Error()))
+			return
+		}
+
+		// Get command
+		value, err := conn.Get("key1")
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform get operation: " + err.Error()))
+			return
+		}
+
+		fmt.Println("key1: " + string(value))
+
+		// Incr command
+		if _, err := conn.Incr("incr1"); err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform incr operation: " + err.Error()))
+			return
+		}
+
+		// Incrementing the same key twice
+		incrVal, err := conn.Incr("incr1")
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform incr operation: " + err.Error()))
+			return
+		}
+
+		fmt.Printf("incr1: %d\n", incrVal)
+
+		// Del command
+		numKeysDeleted, err := conn.Del([]string{"incr1", "key1"})
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform del operation: " + err.Error()))
+			return
+		}
+
+		fmt.Printf("deleted %d keys\n", numKeysDeleted)
+
+		// Sadd command
+		languages := []string{"Go", "Rust", "JavaScript", "Python"}
+		setName := "programming_languages"
+		numAdded, err := conn.Sadd(setName, languages)
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform sadd operation: " + err.Error()))
+			return
+		}
+
+		fmt.Printf("added %d items to the %s set\n", numAdded, setName)
+
+		// Smembers command
+		setEntries, err := conn.Smembers(setName)
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform smembers operation: " + err.Error()))
+			return
+		}
+
+		fmt.Println(setName + ": " + strings.Join(setEntries, ", "))
+
+		// Srem command
+		numRemoved, err := conn.Srem(setName, []string{"JavaScript"})
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform srem operation: " + err.Error()))
+			return
+		}
+
+		fmt.Printf("deleted %d entries from set %s\n", numRemoved, setName)
+
+		// Execute command
+		if _, err := conn.Execute("SET", "execKey", "execValue"); err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform execute set operation: " + err.Error()))
+			return
+		}
+
+		// Validating initial Execute command
+		execResults, err := conn.Execute("GET", "execKey")
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte("failed to perform execute get operation: " + err.Error()))
+			return
+		}
+
+		for _, r := range execResults {
+			if r.IsBinary() {
+				data, ok := r.AsBytes()
+				if !ok {
+					w.WriteHeader(http.StatusInternalServerError)
+					w.Write([]byte("failed to convert result type to bytes"))
+					return
+				}
+
+				fmt.Println("execKey: " + string(data))
+
+			} else {
+				w.WriteHeader(http.StatusInternalServerError)
+				w.Write([]byte("incorrect result type received"))
+				return
+			}
+		}
+
+		w.WriteHeader(http.StatusOK)
+		w.Write([]byte("Hello, Spin!"))
+	})
+}
+
+func main() {}

v3/examples/redis-outbound/spin.toml

@@ -0,0 +1,20 @@
+spin_manifest_version = 2
+
+[application]
+name = "go-redis-outbound-example"
+version = "0.1.0"
+authors = ["Andrew Steurer <[email protected]>"]
+description = "Using Spin with Redis"
+
+[[trigger.http]]
+route = "/"
+component = "redis-outbound"
+
+[component.redis-outbound]
+source = "main.wasm"
+environment = { REDIS_ENDPOINT = "redis://localhost:6379" }
+allowed_outbound_hosts = ["redis://localhost:6379"]
+
+[component.redis-outbound.build]
+command = "tinygo build -target=wasip2 --wit-package $(go list -mod=readonly -m -f '{{.Dir}}' github.com/spinframework/spin-go-sdk/v3)/wit --wit-world http-trigger -gc=leaking -o main.wasm main.go"
+watch = ["**/*.go", "go.mod"]