switch to WebMIDI driver when building JS

mess around with support WASM builds
2026-04-26 21:05:30 +00:00 · 2026-03-30 15:16:35 -05:00 · 2026-03-30 14:46:35 -05:00
39 changed files with 454 additions and 14 deletions
--- a/app/demo/document.go
+++ b/app/demo/document.go
@@ -0,0 +1,5 @@
+package main
+
+import "syscall/js"
+
+var document = js.Global().Get("document")
--- a/app/demo/index.html
+++ b/app/demo/index.html
@@ -0,0 +1,71 @@
+<html>
+  <head>
+    <meta charset="utf-8" />
+    <script src="wasm_exec.js"></script>
+    <style>
+      body {
+        font-family: Arial, sans-serif;
+        display: flex;
+        flex-direction: column;
+        height: 100vh;
+        margin: 0;
+        padding: 0;
+      }
+      #output-container {
+        flex-grow: 1;
+      }
+      #log-container {
+        background-color: #1e1e1e;
+        width: 100%;
+        height: 200px;
+        overflow-y: auto;
+        overflow-x: scroll;
+        box-shadow: inset 0 2px 8px rgba(0, 0, 0, 0.5);
+      }
+      #logs {
+        margin: 0;
+        padding-left: 2px;
+        font-family: 'Consolas', 'Monaco', 'Courier New', monospace;
+        font-size: 13px;
+        line-height: 1.4;
+        color: #a8cc8c;
+      }
+    </style>
+
+    <script>
+      const container = document.getElementById("log-container");
+
+      function isScrolledToBottom() {
+        const scrollThreshold = 1;
+        return (
+          container.scrollHeight - container.clientHeight <=
+          container.scrollTop + scrollThreshold
+        );
+      }
+      function scrollToBottomManual() {
+        const container = document.getElementById("log-container");
+        // Set scrollTop to the maximum value possible (scrollHeight - clientHeight)
+        container.scrollTop = container.scrollHeight - container.clientHeight;
+      }
+    </script>
+  </head>
+  <body>
+    <div id="output-container">
+      <div id="output"></div>
+    </div>
+
+    <div id="log-container">
+      <pre id="logs"></pre>
+    </div>
+
+    <script>
+      const go = new Go();
+      WebAssembly.instantiateStreaming(
+        fetch("main.wasm"),
+        go.importObject,
+      ).then((result) => {
+        go.run(result.instance);
+      });
+    </script>
+  </body>
+</html>
--- a/app/demo/log.go
+++ b/app/demo/log.go
@@ -0,0 +1,42 @@
+package main
+
+import "syscall/js"
+
+type LogWriter struct {
+	Element   js.Value
+	Container js.Value
+}
+
+func (pw *LogWriter) ScrollToBottom() {
+	scrollHeight := pw.Container.Get("scrollHeight").Int()
+	clientHeight := pw.Container.Get("clientHeight").Int()
+	pw.Container.Set("scrollTop", scrollHeight-clientHeight)
+}
+
+func (pw *LogWriter) IsScrolledToBottom() bool {
+	scrollHeight := pw.Container.Get("scrollHeight").Int()
+	clientHeight := pw.Container.Get("clientHeight").Int()
+	scrollTop := pw.Container.Get("scrollTop").Int()
+	return scrollHeight-clientHeight <= scrollTop+25
+}
+
+func (pw *LogWriter) Write(p []byte) (n int, err error) {
+	if !pw.Element.IsUndefined() {
+		currentText := pw.Element.Get("textContent").String()
+		newText := currentText + string(p)
+		pw.Element.Set("textContent", newText)
+		if pw.IsScrolledToBottom() {
+			pw.ScrollToBottom()
+		}
+	}
+	return len(p), nil
+}
+
+func NewLogWriter(id string) *LogWriter {
+	element := document.Call("getElementById", id)
+	container := element.Get("parentElement")
+	return &LogWriter{
+		Element:   element,
+		Container: container,
+	}
+}
--- a/app/demo/main.go
+++ b/app/demo/main.go
@@ -0,0 +1,71 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"log/slog"
+
+	"github.com/jwetzell/showbridge-go"
+	"github.com/jwetzell/showbridge-go/internal/config"
+)
+
+func main() {
+
+	slog.SetLogLoggerLevel(slog.LevelDebug)
+	slog.SetDefault(slog.New(slog.NewTextHandler(NewLogWriter("logs"), &slog.HandlerOptions{
+		Level: slog.LevelDebug,
+	})))
+
+	router, moduleConfigErrors, routeConfigErrors := showbridge.NewRouter(config.Config{
+		Api: config.ApiConfig{
+			Enabled: false,
+			Port:    0,
+		},
+		Modules: []config.ModuleConfig{
+			{
+				Id:   "midi",
+				Type: "midi.input",
+				Params: map[string]any{
+					"port": "Launchpad S",
+				},
+			},
+		},
+		Routes: []config.RouteConfig{
+			{
+				Input: "midi",
+				Processors: []config.ProcessorConfig{
+					{
+						Type: "debug.log",
+					},
+					{
+						Type: "web.set",
+						Params: map[string]any{
+							"id":       "output",
+							"property": "textContent",
+							"value":    "{{.Payload}}",
+						},
+					},
+				},
+			},
+		},
+	})
+
+	if len(moduleConfigErrors) > 0 {
+		for _, err := range moduleConfigErrors {
+			println("Module config error:", err.Error)
+		}
+	}
+
+	if len(routeConfigErrors) > 0 {
+		for _, err := range routeConfigErrors {
+			println("Route config error:", err.Error)
+		}
+	}
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+	go func() {
+		router.Start(ctx)
+		fmt.Println("router stopped")
+	}()
+	<-ctx.Done()
+}
--- a/internal/module/db-sqlite.go
+++ b/internal/module/db-sqlite.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/desktop.go
+++ b/internal/module/desktop.go
@@ -0,0 +1,7 @@
+//go:build cgo
+
+package module
+
+import (
+	_ "gitlab.com/gomidi/midi/v2/drivers/rtmididrv"
+)
--- a/internal/module/http-server.go
+++ b/internal/module/http-server.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/midi-input.go
+++ b/internal/module/midi-input.go
@@ -1,4 +1,4 @@
-//go:build cgo
+//go:build cgo || js

 package module

@@ -12,7 +12,6 @@ import (
 	"github.com/jwetzell/showbridge-go/internal/common"
 	"github.com/jwetzell/showbridge-go/internal/config"
 	"gitlab.com/gomidi/midi/v2"
-	_ "gitlab.com/gomidi/midi/v2/drivers/rtmididrv"
 )

 type MIDIInput struct {
--- a/internal/module/midi-output.go
+++ b/internal/module/midi-output.go
@@ -1,4 +1,4 @@
-//go:build cgo
+//go:build cgo || js

 package module

@@ -12,7 +12,6 @@ import (
 	"github.com/jwetzell/showbridge-go/internal/common"
 	"github.com/jwetzell/showbridge-go/internal/config"
 	"gitlab.com/gomidi/midi/v2"
-	_ "gitlab.com/gomidi/midi/v2/drivers/rtmididrv"
 )

 type MIDIOutput struct {
--- a/internal/module/mqtt-client.go
+++ b/internal/module/mqtt-client.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/nats-client.go
+++ b/internal/module/nats-client.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/nats-server.go
+++ b/internal/module/nats-server.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/psn-client.go
+++ b/internal/module/psn-client.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/redis-client.go
+++ b/internal/module/redis-client.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/sip-call-server.go
+++ b/internal/module/sip-call-server.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/sip-dtmf-server.go
+++ b/internal/module/sip-dtmf-server.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/tcp-client.go
+++ b/internal/module/tcp-client.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/tcp-server.go
+++ b/internal/module/tcp-server.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/time-timer.go
+++ b/internal/module/time-timer.go
@@ -64,7 +64,7 @@ func (t *TimeTimer) Start(ctx context.Context) error {
 	router, ok := ctx.Value(common.RouterContextKey).(common.RouteIO)

 	if !ok {
-		return errors.New("net.tcp.client unable to get router from context")
+		return errors.New("time.timer unable to get router from context")
 	}
 	t.router = router
 	moduleContext, cancel := context.WithCancel(ctx)
--- a/internal/module/udp-client.go
+++ b/internal/module/udp-client.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/udp-multicast.go
+++ b/internal/module/udp-multicast.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/udp-server.go
+++ b/internal/module/udp-server.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package module

 import (
--- a/internal/module/web-onclick.go
+++ b/internal/module/web-onclick.go
@@ -0,0 +1,91 @@
+//go:build js
+
+package module
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"log/slog"
+	"syscall/js"
+	"time"
+
+	"github.com/google/jsonschema-go/jsonschema"
+	"github.com/jwetzell/showbridge-go/internal/common"
+	"github.com/jwetzell/showbridge-go/internal/config"
+)
+
+type WebOnClick struct {
+	config    config.ModuleConfig
+	ctx       context.Context
+	router    common.RouteIO
+	logger    *slog.Logger
+	ElementId string
+}
+
+func init() {
+	RegisterModule(ModuleRegistration{
+		Type:  "web.onclick",
+		Title: "On Click",
+		ParamsSchema: &jsonschema.Schema{
+			Type: "object",
+			Properties: map[string]*jsonschema.Schema{
+				"id": {
+					Title:       "Element ID",
+					Type:        "string",
+					Description: "ID of the HTML element to attach the click listener to",
+				},
+			},
+			Required:             []string{"duration"},
+			AdditionalProperties: nil,
+		},
+		New: func(config config.ModuleConfig) (common.Module, error) {
+			params := config.Params
+
+			idString, err := params.GetString("id")
+			if err != nil {
+				return nil, fmt.Errorf("web.onclick id error: %w", err)
+			}
+
+			return &WebOnClick{ElementId: idString, config: config, logger: CreateLogger(config)}, nil
+		},
+	})
+}
+
+func (woc *WebOnClick) Id() string {
+	return woc.config.Id
+}
+
+func (woc *WebOnClick) Type() string {
+	return woc.config.Type
+}
+
+func (woc *WebOnClick) Start(ctx context.Context) error {
+	woc.logger.Debug("running")
+	router, ok := ctx.Value(common.RouterContextKey).(common.RouteIO)
+
+	if !ok {
+		return errors.New("net.tcp.client unable to get router from context")
+	}
+	woc.router = router
+	woc.ctx = ctx
+
+	element := js.Global().Get("document").Call("getElementById", woc.ElementId)
+
+	if element.IsNull() || element.IsUndefined() {
+		return fmt.Errorf("web.onclick unable to find element with id: %s", woc.ElementId)
+	}
+
+	element.Set("onclick", js.FuncOf(func(js.Value, []js.Value) interface{} {
+		if woc.router != nil {
+			woc.router.HandleInput(woc.ctx, woc.Id(), time.Now())
+		}
+		return nil
+	}))
+
+	<-ctx.Done()
+	return nil
+}
+
+func (woc *WebOnClick) Stop() {
+}
--- a/internal/module/web.go
+++ b/internal/module/web.go
@@ -0,0 +1,7 @@
+//go:build js
+
+package module
+
+import (
+	_ "gitlab.com/gomidi/midi/v2/drivers/webmididrv"
+)
--- a/internal/processor/artnet-packet-decode.go
+++ b/internal/processor/artnet-packet-decode.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
--- a/internal/processor/artnet-packet-encode.go
+++ b/internal/processor/artnet-packet-encode.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
--- a/internal/processor/http-request-do.go
+++ b/internal/processor/http-request-do.go
@@ -21,6 +21,11 @@ type HTTPRequestDo struct {
 	URL    *template.Template
 }

+type HTTPResponse struct {
+	Status int
+	Body   []byte
+}
+
 func (hrd *HTTPRequestDo) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {

 	templateData := wrappedPayload
--- a/internal/processor/http-response-create.go
+++ b/internal/processor/http-response-create.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
@@ -17,11 +19,6 @@ type HTTPResponseCreate struct {
 	config   config.ProcessorConfig
 }

-type HTTPResponse struct {
-	Status int
-	Body   []byte
-}
-
 func (hrc *HTTPResponseCreate) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
 	templateData := wrappedPayload

--- a/internal/processor/midi-message-create.go
+++ b/internal/processor/midi-message-create.go
@@ -1,4 +1,4 @@
-//go:build cgo
+//go:build cgo || js

 package processor

--- a/internal/processor/midi-message-decode.go
+++ b/internal/processor/midi-message-decode.go
@@ -1,4 +1,4 @@
-//go:build cgo
+//go:build cgo || js

 package processor

--- a/internal/processor/midi-message-encode.go
+++ b/internal/processor/midi-message-encode.go
@@ -1,4 +1,4 @@
-//go:build cgo
+//go:build cgo || js

 package processor

--- a/internal/processor/midi-message-unpack.go
+++ b/internal/processor/midi-message-unpack.go
@@ -1,4 +1,4 @@
-//go:build cgo
+//go:build cgo || js

 package processor

--- a/internal/processor/mqtt-message-create.go
+++ b/internal/processor/mqtt-message-create.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
--- a/internal/processor/nats-message-create.go
+++ b/internal/processor/nats-message-create.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
--- a/internal/processor/script-js.go
+++ b/internal/processor/script-js.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
--- a/internal/processor/script-wasm.go
+++ b/internal/processor/script-wasm.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
--- a/internal/processor/sip-response-audio-create.go
+++ b/internal/processor/sip-response-audio-create.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
--- a/internal/processor/sip-response-dtmf-create.go
+++ b/internal/processor/sip-response-dtmf-create.go
@@ -1,3 +1,5 @@
+//go:build !js
+
 package processor

 import (
--- a/internal/processor/web-set.go
+++ b/internal/processor/web-set.go
@@ -0,0 +1,102 @@
+//go:build js
+
+package processor
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"html/template"
+	"log/slog"
+	"syscall/js"
+
+	"github.com/google/jsonschema-go/jsonschema"
+	"github.com/jwetzell/showbridge-go/internal/common"
+	"github.com/jwetzell/showbridge-go/internal/config"
+)
+
+type WebSet struct {
+	config    config.ProcessorConfig
+	ModuleId  string
+	ElementId string
+	Property  string
+	Value     *template.Template
+	logger    *slog.Logger
+}
+
+func (kvs *WebSet) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
+
+	element := js.Global().Get("document").Call("getElementById", kvs.ElementId)
+
+	if element.IsNull() || element.IsUndefined() {
+		wrappedPayload.End = true
+		return wrappedPayload, fmt.Errorf("web.set unable to find element with id: %s", kvs.ElementId)
+	}
+
+	var valueBuffer bytes.Buffer
+	err := kvs.Value.Execute(&valueBuffer, wrappedPayload)
+
+	if err != nil {
+		wrappedPayload.End = true
+		return wrappedPayload, err
+	}
+
+	element.Set(kvs.Property, valueBuffer.String())
+	return wrappedPayload, nil
+}
+
+func (kvs *WebSet) Type() string {
+	return kvs.config.Type
+}
+
+func init() {
+	RegisterProcessor(ProcessorRegistration{
+		Type:  "web.set",
+		Title: "Set Web Element Property",
+		ParamsSchema: &jsonschema.Schema{
+			Type: "object",
+			Properties: map[string]*jsonschema.Schema{
+				"id": {
+					Title: "Element ID",
+					Type:  "string",
+				},
+				"property": {
+					Title: "Property",
+					Type:  "string",
+				},
+				"value": {
+					Title: "Value",
+					Type:  "string",
+				},
+			},
+			Required:             []string{"id", "property", "value"},
+			AdditionalProperties: nil,
+		},
+		New: func(config config.ProcessorConfig) (Processor, error) {
+
+			params := config.Params
+
+			idString, err := params.GetString("id")
+			if err != nil {
+				return nil, fmt.Errorf("web.set id error: %w", err)
+			}
+
+			propertyString, err := params.GetString("property")
+			if err != nil {
+				return nil, fmt.Errorf("web.set property error: %w", err)
+			}
+
+			valueString, err := params.GetString("value")
+			if err != nil {
+				return nil, fmt.Errorf("web.set value error: %w", err)
+			}
+			valueTemplate, err := template.New("template").Parse(valueString)
+
+			if err != nil {
+				return nil, err
+			}
+
+			return &WebSet{config: config, ElementId: idString, Property: propertyString, Value: valueTemplate, logger: slog.Default().With("component", "processor", "type", config.Type)}, nil
+		},
+	})
+}
Author	SHA1	Message	Date
Joel Wetzell	1d4cb251e9	switch to WebMIDI driver when building JS	2026-03-30 15:16:35 -05:00
Joel Wetzell	050ada6a70	mess around with support WASM builds	2026-03-30 14:46:35 -05:00