Merge pull request #123 from lxfontes/lxfontes/wasmbus

wasmbus: New package

Author: lxfontes

.github/workflows/wasmbus-go.yaml

@@ -0,0 +1,119 @@
+name: wasmbus
+
+on:
+  push:
+    branches: ["main"]
+    paths:
+      - ".github/workflows/wasmbus-go.yaml"
+      - "x/wasmbus/**"
+  pull_request:
+    branches: ["main"]
+    paths:
+      - ".github/workflows/wasmbus-go.yaml"
+      - "x/wasmbus/**"
+
+env:
+  GOLANGCI_VERSION: "v1.61"
+  WASH_VERSION: "0.37.0"
+
+permissions:
+  contents: read
+
+jobs:
+  lint:
+    # Context: https://github.com/golangci/golangci-lint-action/blob/v6.1.1/README.md#annotations
+    permissions:
+      # Required: allow read access to the content for analysis.
+      contents: read
+      # Optional: allow write access to checks to allow the action to annotate code in the PR.
+      checks: write
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2
+      - uses: golangci/golangci-lint-action@971e284b6050e8a5849b72094c50ab08da042db8 # v6.1.1
+        with:
+          version: ${{ env.GOLANGCI_VERSION }}
+          working-directory: x/wasmbus
+
+      - name: Go generate
+        working-directory: x/wasmbus
+        run: |
+          go generate ./...
+          if ! test -z "$(git status --porcelain)"; then
+            echo "Go generate modified files. Please run go generate and commit the changes."
+            git status
+            exit 1
+          fi
+
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2
+      - uses: taiki-e/install-action@ed8c79bccf0b1cb1544a358f81684d3acaa5133f # v2.46.11
+        with:
+          tool: ${{ format('wash-cli@{0}', env.WASH_VERSION) }}
+      - uses: actions/setup-go@3041bf56c941b39c61721a86cd11f3bb1338122a # v5.2.0
+        with:
+          go-version-file: "x/wasmbus/go.mod"
+
+      - name: Build
+        working-directory: x/wasmbus
+        run: go build -v ./...
+
+        # NOTE(lxf): Tests are split into multiple steps to avoid wash race conditions.
+
+      - name: wasmbus
+        working-directory: x/wasmbus
+        run: go test -cover -v -wash-output
+
+      - name: wasmbus/control
+        working-directory: x/wasmbus/control
+        run: go test -cover -v -wash-output
+
+      - name: wasmbus/wadm
+        working-directory: x/wasmbus/wadm
+        run: go test -cover -v -wash-output
+
+      - name: wasmbus/events
+        working-directory: x/wasmbus/events
+        run: go test -cover -v -wash-output
+
+  examples:
+    # Context: https://github.com/golangci/golangci-lint-action/blob/v6.1.1/README.md#annotations
+    permissions:
+      # Required: allow read access to the content for analysis.
+      contents: read
+      # Optional: allow write access to checks to allow the action to annotate code in the PR.
+      checks: write
+    strategy:
+      matrix:
+        example:
+          - wasmcloud-rpc
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2
+      - uses: actions/setup-go@3041bf56c941b39c61721a86cd11f3bb1338122a # v5.2.0
+        with:
+          go-version-file: "./examples/wasmbus/${{ matrix.example }}/go.mod"
+      - uses: golangci/golangci-lint-action@971e284b6050e8a5849b72094c50ab08da042db8 # v6.1.1
+        with:
+          version: ${{ env.GOLANGCI_VERSION }}
+          working-directory: "./examples/wasmbus/${{ matrix.example }}"
+      - uses: taiki-e/install-action@ed8c79bccf0b1cb1544a358f81684d3acaa5133f # v2.46.11
+        with:
+          tool: ${{ format('wash-cli@{0}', env.WASH_VERSION) }}
+
+      - name: Go generate
+        working-directory: "./examples/wasmbus/${{ matrix.example }}"
+        run: |
+          go generate ./...
+          if ! test -z "$(git status --porcelain)"; then
+            echo "Go generate modified files. Please run go generate and commit the changes."
+            git status
+            exit 1
+          fi
+
+      - name: build
+        working-directory: "./examples/wasmbus/${{ matrix.example }}"
+        run: |
+          go build -v

docs/x/wasmbus/index.html

@@ -0,0 +1,8 @@
+<html>
+  <head>
+    <meta
+      name="go-import"
+      content="go.wasmcloud.dev git https://github.com/wasmCloud/go"
+    />
+  </head>
+</html>

examples/wasmbus/wasmcloud-rpc/config.go

@@ -0,0 +1,148 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"os"
+
+	"github.com/joho/godotenv"
+	"github.com/urfave/cli/v3"
+	"go.wasmcloud.dev/x/wasmbus/control"
+)
+
+func configCommand() *cli.Command {
+	var targetName string
+	nameArg := &cli.StringArg{
+		Name:        "name",
+		Destination: &targetName,
+		Max:         1,
+	}
+	return &cli.Command{
+		Name:  "config",
+		Usage: "Interact with Lattice Config",
+		Flags: []cli.Flag{},
+		Commands: []*cli.Command{
+			{
+				Name:   "get",
+				Usage:  "Get a config",
+				Action: wrapNamedAction(getConfigCommand, &targetName),
+				Arguments: []cli.Argument{
+					nameArg,
+				},
+			},
+			{
+				Name:   "delete",
+				Usage:  "Delete a config",
+				Action: wrapNamedAction(deleteConfigCommand, &targetName),
+				Arguments: []cli.Argument{
+					nameArg,
+				},
+			},
+			{
+				Name:   "put",
+				Usage:  "Put a config",
+				Action: putConfigCommand,
+				Flags: []cli.Flag{
+					&cli.StringFlag{
+						Name:     "name",
+						Usage:    "Name of the config to store",
+						Required: true,
+					},
+					&cli.StringFlag{
+						Name:     "file",
+						Aliases:  []string{"f"},
+						Usage:    "File to read config from, in dotenv format (one KEY=VALUE per line)",
+						Required: true,
+					},
+				},
+				Arguments: []cli.Argument{
+					nameArg,
+				},
+			},
+		},
+	}
+}
+
+func deleteConfigCommand(ctx context.Context, cmd *cli.Command, name string) error {
+	client, err := controlClientFromCommand(cmd)
+	if err != nil {
+		return err
+	}
+
+	resp, err := client.ConfigDelete(ctx, &control.ConfigDeleteRequest{
+		Name: name,
+	})
+	if err != nil {
+		return err
+	}
+	if !resp.Success {
+		return fmt.Errorf("received error response: %s", resp.Message)
+	}
+
+	fmt.Println(titleStyle.Render("⁜", name), "deleted")
+
+	return nil
+}
+
+func getConfigCommand(ctx context.Context, cmd *cli.Command, name string) error {
+	client, err := controlClientFromCommand(cmd)
+	if err != nil {
+		return err
+	}
+
+	resp, err := client.ConfigGet(ctx, &control.ConfigGetRequest{
+		Name: name,
+	})
+	if err != nil {
+		return err
+	}
+	if !resp.Success {
+		return fmt.Errorf("received error response: %s", resp.Message)
+	}
+
+	// NOTE(lxf): This feels like a bug in hosts' crates/host/src/wasmbus/mod.rs
+	if resp.Message == "Configuration not found" {
+		return fmt.Errorf("configuration not found")
+	}
+
+	config, err := godotenv.Marshal(resp.Response)
+	if err != nil {
+		return err
+	}
+	fmt.Println(config)
+
+	return nil
+}
+
+func putConfigCommand(ctx context.Context, cmd *cli.Command) error {
+	name := cmd.String("name")
+	client, err := controlClientFromCommand(cmd)
+	if err != nil {
+		return err
+	}
+
+	f, err := os.ReadFile(cmd.String("file"))
+	if err != nil {
+		return err
+	}
+
+	var values map[string]string
+	if values, err = godotenv.UnmarshalBytes(f); err != nil {
+		return err
+	}
+
+	resp, err := client.ConfigPut(ctx, &control.ConfigPutRequest{
+		Name:   name,
+		Values: values,
+	})
+	if err != nil {
+		return err
+	}
+	if !resp.Success {
+		return fmt.Errorf("received error response: %s", resp.Message)
+	}
+
+	fmt.Println(titleStyle.Render("⁜", name), "stored")
+
+	return nil
+}

examples/wasmbus/wasmcloud-rpc/events.go

@@ -0,0 +1,67 @@
+package main
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/urfave/cli/v3"
+	"go.wasmcloud.dev/x/wasmbus"
+	"go.wasmcloud.dev/x/wasmbus/events"
+)
+
+func eventCommand() *cli.Command {
+	return &cli.Command{
+		Name:  "events",
+		Usage: "listen for lattice events",
+		Flags: []cli.Flag{
+			&cli.StringFlag{
+				Name:  "pattern",
+				Value: wasmbus.PatternAll,
+				Usage: "The event pattern to subscribe to",
+			},
+			&cli.IntFlag{
+				Name:  "backlog",
+				Value: wasmbus.NoBackLog,
+				Usage: "Bus backlog size. Default is no backlog",
+			},
+		},
+		Action: func(ctx context.Context, cmd *cli.Command) error {
+			bus, err := busFromCommand(cmd)
+			if err != nil {
+				return err
+			}
+
+			lattice := cmd.String("lattice")
+			pattern := cmd.String("pattern")
+			backlog := cmd.Int("backlog")
+
+			callback := func(_ context.Context, ev events.Event) {
+				jsonEv, err := json.MarshalIndent(ev.BusEvent, "", "  ")
+				if err != nil {
+					log.Printf("Error marshalling event: %s", err)
+					return
+				}
+
+				fmt.Println(titleStyle.Render("⁜", ev.CloudEvent.Type()))
+				renderKv("Time", ev.CloudEvent.Time().Format(time.RFC3339))
+				renderKv("Source", ev.CloudEvent.Source())
+				renderKv("Id", ev.CloudEvent.ID())
+				fmt.Println(string(jsonEv))
+			}
+			subscription, err := events.Subscribe(bus, lattice, pattern, int(backlog), events.DiscardErrorsHandler(callback))
+			if err != nil {
+				return err
+			}
+			defer func() { _ = subscription.Drain() }()
+
+			log.Printf("Listening for events on lattice '%s' with pattern '%s'", lattice, pattern)
+			<-ctx.Done()
+			log.Printf("Shutting down event listener")
+
+			return nil
+		},
+	}
+}

examples/wasmbus/wasmcloud-rpc/go.mod

@@ -0,0 +1,42 @@
+module wasmcloud-rpc
+
+go 1.23.3
+
+require (
+	github.com/charmbracelet/lipgloss v1.0.0
+	github.com/google/go-cmp v0.6.0
+	github.com/joho/godotenv v1.5.1
+	github.com/urfave/cli/v3 v3.0.0-beta1
+	go.wasmcloud.dev/x/wasmbus v0.1.0
+)
+
+require (
+	github.com/aymanbagabas/go-osc52/v2 v2.0.1 // indirect
+	github.com/charmbracelet/x/ansi v0.4.2 // indirect
+	github.com/cloudevents/sdk-go/v2 v2.15.2 // indirect
+	github.com/goccy/go-yaml v1.15.13 // indirect
+	github.com/google/uuid v1.1.1 // indirect
+	github.com/json-iterator/go v1.1.10 // indirect
+	github.com/klauspost/compress v1.17.11 // indirect
+	github.com/lucasb-eyer/go-colorful v1.2.0 // indirect
+	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/mattn/go-runewidth v0.0.15 // indirect
+	github.com/minio/highwayhash v1.0.3 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect
+	github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742 // indirect
+	github.com/muesli/termenv v0.15.2 // indirect
+	github.com/nats-io/jwt/v2 v2.7.3 // indirect
+	github.com/nats-io/nats-server/v2 v2.10.24 // indirect
+	github.com/nats-io/nats.go v1.38.0 // indirect
+	github.com/nats-io/nkeys v0.4.9 // indirect
+	github.com/nats-io/nuid v1.0.1 // indirect
+	github.com/rivo/uniseg v0.4.7 // indirect
+	go.uber.org/atomic v1.4.0 // indirect
+	go.uber.org/multierr v1.1.0 // indirect
+	go.uber.org/zap v1.10.0 // indirect
+	golang.org/x/crypto v0.31.0 // indirect
+	golang.org/x/sys v0.28.0 // indirect
+	golang.org/x/time v0.8.0 // indirect
+)
+
+replace go.wasmcloud.dev/x/wasmbus => ../../../x/wasmbus