Update module github.com/jwetzell/osc-go to v0.3.1

update to golang 1.27.0
go mod tidy
2026-08-30 18:28:59 +00:00 · 2026-08-30 16:55:33 +00:00 · 2026-08-30 08:29:12 -05:00 · 2026-08-30 08:23:46 -05:00 · 2026-08-28 15:08:31 -05:00 · 2026-08-28 15:06:40 -05:00
135 changed files with 1119 additions and 483 deletions
@@ -1,10 +0,0 @@
-version: 2
-updates:
-  - package-ecosystem: "github-actions"
-    directory: "/"
-    schedule:
-      interval: "weekly"
-  - package-ecosystem: gomod
-    directory: /
-    schedule:
-      interval: "weekly"
@@ -17,7 +17,7 @@ jobs:
      short_commit: ${{ steps.set_commit.outputs.short_commit }}
    steps:
      - name: checkout
-        uses: actions/checkout@v6
+        uses: actions/checkout@v7
        with:
          fetch-depth: 0
      - name: set environment variables
@@ -45,11 +45,11 @@ jobs:
      SHORT_COMMIT: ${{ needs.setup_release.outputs.short_commit }}
    steps:
      - name: checkout
-        uses: actions/checkout@v6
+        uses: actions/checkout@v7
        with:
          fetch-depth: 0
      - name: setup go
-        uses: actions/setup-go@v6
+        uses: actions/setup-go@v7
        with:
          go-version-file: "go.mod"
      - name: install alsa lib
@@ -79,11 +79,11 @@ jobs:
      SHORT_COMMIT: ${{ needs.setup_release.outputs.short_commit }}
    steps:
      - name: checkout
-        uses: actions/checkout@v6
+        uses: actions/checkout@v7
        with:
          fetch-depth: 0
      - name: setup go
-        uses: actions/setup-go@v6
+        uses: actions/setup-go@v7
        with:
          go-version-file: "go.mod"
      - name: install alsa lib
@@ -113,11 +113,11 @@ jobs:
      SHORT_COMMIT: ${{ needs.setup_release.outputs.short_commit }}
    steps:
      - name: checkout
-        uses: actions/checkout@v6
+        uses: actions/checkout@v7
        with:
          fetch-depth: 0
      - name: setup go
-        uses: actions/setup-go@v6
+        uses: actions/setup-go@v7
        with:
          go-version-file: "go.mod"
      - name: setup zig
@@ -153,11 +153,11 @@ jobs:
      SHORT_COMMIT: ${{ needs.setup_release.outputs.short_commit }}
    steps:
      - name: checkout
-        uses: actions/checkout@v6
+        uses: actions/checkout@v7
        with:
          fetch-depth: 0
      - name: setup go
-        uses: actions/setup-go@v6
+        uses: actions/setup-go@v7
        with:
          go-version-file: "go.mod"
      - name: build
@@ -185,11 +185,11 @@ jobs:
      SHORT_COMMIT: ${{ needs.setup_release.outputs.short_commit }}
    steps:
      - name: checkout
-        uses: actions/checkout@v6
+        uses: actions/checkout@v7
        with:
          fetch-depth: 0
      - name: setup go
-        uses: actions/setup-go@v6
+        uses: actions/setup-go@v7
        with:
          go-version-file: "go.mod"
      - name: build
@@ -215,29 +215,29 @@ jobs:
    if: github.ref_type == 'tag' && github.event_name != 'workflow_dispatch'
    steps:
      - name: Check out repository
-        uses: actions/checkout@1af3b93b6815bc44a9784bd300feb67ff0d1eeb3 # v6.0.0
+        uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1

      - name: Set up QEMU
-        uses: docker/setup-qemu-action@ce360397dd3f832beb865e1373c09c0e9f86d70a # v4.0.0
+        uses: docker/setup-qemu-action@96fe6ef7f33517b61c61be40b68a1882f3264fb8 # v4.2.0

      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@d7f5e7f509e45cec5c76c4d5afdd7de93d0b3df5 # v4.1.0
+        uses: docker/setup-buildx-action@37fe631027851001ddb9b187196cc803df7f5f0e # v4.3.0

      - name: Login to Docker Hub
-        uses: docker/login-action@650006c6eb7dba73a995cc03b0b2d7f5ca915bee # v4.2.0
+        uses: docker/login-action@dbcb813823bdd20940b903addbd779551569679f # v4.6.0
        with:
          username: ${{ secrets.DOCKERHUB_USERNAME }}
          password: ${{ secrets.DOCKERHUB_TOKEN }}

      - name: Setup Docker metadata
        id: meta
-        uses: docker/metadata-action@80c7e94dd9b9319bd5eb7a0e0fe9291e23a2a2e9 # v6.1.0
+        uses: docker/metadata-action@dc802804100637a589fabce1cb79ff13a1411302 # v6.2.0
        with:
          images: |
            jwetzell/showbridge

      - name: Build and push
-        uses: docker/build-push-action@f9f3042f7e2789586610d6e8b85c8f03e5195baf # v7.2.0
+        uses: docker/build-push-action@53b7df96c91f9c12dcc8a07bcb9ccacbed38856a # v7.3.0
        with:
          push: true
          context: ./
@@ -26,8 +26,8 @@ jobs:
      - name: Install alsa
        run: sudo apt-get install -y libasound2-dev

-      - uses: actions/checkout@v6
-      - uses: actions/setup-go@v6
+      - uses: actions/checkout@v7
+      - uses: actions/setup-go@v7
        with:
          go-version-file: "go.mod"
      - name: mod tidy
@@ -38,12 +38,9 @@ jobs:

      - name: clean up coverage report
        run: cat coverage.out | grep -v "github.com/jwetzell/showbridge-go/cmd" > coverage.nocmd.out
-      - name: Update coverage report
-        uses: ncruces/go-coverage-report@v0.3.2
+      
+      - name: Upload coverage reports to Codecov
+        uses: codecov/codecov-action@v7
        with:
-          coverage-file: coverage.nocmd.out
-          report: true
-          chart: true
-          amend: true
-        if: github.event_name == 'push'
-        continue-on-error: true
+          token: ${{ secrets.CODECOV_TOKEN }}
+          files: coverage.nocmd.out
@@ -1,4 +1,4 @@
-ARG GO_VERSION=1.26.3
+ARG GO_VERSION=1.27.0
 FROM golang:${GO_VERSION}-alpine AS build
 RUN apk --no-cache add ca-certificates tzdata git
 WORKDIR /build
@@ -2,7 +2,8 @@

 # showbridge (go edition)

-[![Coverage](https://github.com/jwetzell/showbridge-go/wiki/coverage.svg)](https://raw.githack.com/wiki/jwetzell/showbridge-go/coverage.html)
+[![codecov](https://codecov.io/gh/jwetzell/showbridge-go/graph/badge.svg?token=T4XAAKZN14)](https://codecov.io/gh/jwetzell/showbridge-go)
+
 Simple protocol router _/s_

 </div>
@@ -13,11 +13,15 @@ modules:
      port: 8000
 routes:
  - input: http
+    id: http-to-osc
    processors:
-      - type: osc.message.create
+      - id: create-osc
+        type: osc.message.create
        params:
          address: "{{.Payload.URL.Path}}"
-      - type: osc.message.encode
-      - type: module.output
+      - id: encode-osc
+        type: osc.message.encode
+      - id: output-osc
+        type: module.output
        params:
          module: udp
@@ -1,33 +1,33 @@
 module github.com/jwetzell/showbridge-go

-go 1.26.3
+go 1.27.0

 require (
 	github.com/eclipse/paho.mqtt.golang v1.5.1
-	github.com/emiago/diago v0.28.0
-	github.com/emiago/sipgo v1.3.1
+	github.com/emiago/diago v0.32.0
+	github.com/emiago/sipgo v1.6.0
 	github.com/expr-lang/expr v1.17.8
 	github.com/extism/go-sdk v1.7.1
 	github.com/google/jsonschema-go v0.4.3
 	github.com/gorilla/websocket v1.5.3
 	github.com/jwetzell/artnet-go v0.3.0
 	github.com/jwetzell/free-d-go v0.2.0
-	github.com/jwetzell/osc-go v0.3.0
+	github.com/jwetzell/osc-go v0.3.1
 	github.com/jwetzell/psn-go v0.3.0
-	github.com/nats-io/nats-server/v2 v2.14.1
-	github.com/nats-io/nats.go v1.52.0
-	github.com/redis/go-redis/v9 v9.19.0
-	github.com/urfave/cli/v3 v3.9.0
-	gitlab.com/gomidi/midi/v2 v2.3.23
-	go.bug.st/serial v1.7.1
+	github.com/nats-io/nats-server/v2 v2.14.6
+	github.com/nats-io/nats.go v1.53.1
+	github.com/redis/go-redis/v9 v9.22.0
+	github.com/urfave/cli/v3 v3.11.0
+	gitlab.com/gomidi/midi/v2 v2.3.24
+	go.bug.st/serial v1.8.0
 	golang.org/x/time v0.15.0
-	modernc.org/quickjs v0.18.2
-	modernc.org/sqlite v1.50.1
+	modernc.org/quickjs v0.24.2
+	modernc.org/sqlite v1.57.0
 	sigs.k8s.io/yaml v1.6.0
 )

 require (
-	github.com/antithesishq/antithesis-sdk-go v0.7.0 // indirect
+	github.com/antithesishq/antithesis-sdk-go v0.7.2-default-no-op // indirect
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/dustin/go-humanize v1.0.1 // indirect
 	github.com/dylibso/observe-sdk/go v0.0.0-20240828172851-9145d8ad07e1 // indirect
@@ -41,11 +41,11 @@ require (
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/ianlancetaylor/demangle v0.0.0-20260505044615-1ff4bf46051f // indirect
 	github.com/icholy/digest v1.1.0 // indirect
-	github.com/klauspost/compress v1.18.6 // indirect
-	github.com/mattn/go-isatty v0.0.22 // indirect
+	github.com/klauspost/compress v1.19.2 // indirect
+	github.com/mattn/go-isatty v0.0.24 // indirect
 	github.com/minio/highwayhash v1.0.4 // indirect
-	github.com/nats-io/jwt/v2 v2.8.1 // indirect
-	github.com/nats-io/nkeys v0.4.15 // indirect
+	github.com/nats-io/jwt/v2 v2.8.2 // indirect
+	github.com/nats-io/nkeys v0.4.16 // indirect
 	github.com/nats-io/nuid v1.0.1 // indirect
 	github.com/ncruces/go-strftime v1.0.0 // indirect
 	github.com/pion/logging v0.2.4 // indirect
@@ -63,15 +63,14 @@ require (
 	go.uber.org/atomic v1.11.0 // indirect
 	go.yaml.in/yaml/v2 v2.4.2 // indirect
 	go.yaml.in/yaml/v3 v3.0.4 // indirect
-	golang.org/x/crypto v0.51.0 // indirect
-	golang.org/x/net v0.54.0 // indirect
-	golang.org/x/sync v0.20.0 // indirect
-	golang.org/x/sys v0.44.0 // indirect
-	golang.org/x/tools v0.44.0 // indirect
+	golang.org/x/crypto v0.55.0 // indirect
+	golang.org/x/net v0.57.0 // indirect
+	golang.org/x/sync v0.22.0 // indirect
+	golang.org/x/sys v0.47.0 // indirect
 	google.golang.org/protobuf v1.36.11 // indirect
 	gopkg.in/hraban/opus.v2 v2.0.0-20230925203106-0188a62cb302 // indirect
-	modernc.org/libc v1.72.3 // indirect
-	modernc.org/libquickjs v0.12.8 // indirect
+	modernc.org/libc v1.75.4 // indirect
+	modernc.org/libquickjs v0.13.1 // indirect
 	modernc.org/mathutil v1.7.1 // indirect
-	modernc.org/memory v1.11.0 // indirect
+	modernc.org/memory v1.12.1 // indirect
 )
@@ -1,5 +1,5 @@
-github.com/antithesishq/antithesis-sdk-go v0.7.0 h1:uWDG8BqLD1lI2ps38WDz2vXflrTX2+vLX0SvZtztJtE=
-github.com/antithesishq/antithesis-sdk-go v0.7.0/go.mod h1:FQyySiasQQM8735Ddel3MRojmy4dA1IqCeyJ5jmPMbI=
+github.com/antithesishq/antithesis-sdk-go v0.7.2-default-no-op h1:p2zFsAzvhIpFya8AIOHIbWf7NGvO34QpLGclyf7nXj8=
+github.com/antithesishq/antithesis-sdk-go v0.7.2-default-no-op/go.mod h1:FQyySiasQQM8735Ddel3MRojmy4dA1IqCeyJ5jmPMbI=
 github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
 github.com/bsm/ginkgo/v2 v2.12.0/go.mod h1:SwYbGRRDovPVboqFv0tPTcG1sN61LM1Z4ARdbAV9g4c=
 github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
@@ -14,12 +14,12 @@ github.com/dylibso/observe-sdk/go v0.0.0-20240828172851-9145d8ad07e1 h1:idfl8M8r
 github.com/dylibso/observe-sdk/go v0.0.0-20240828172851-9145d8ad07e1/go.mod h1:C8DzXehI4zAbrdlbtOByKX6pfivJTBiV9Jjqv56Yd9Q=
 github.com/eclipse/paho.mqtt.golang v1.5.1 h1:/VSOv3oDLlpqR2Epjn1Q7b2bSTplJIeV2ISgCl2W7nE=
 github.com/eclipse/paho.mqtt.golang v1.5.1/go.mod h1:1/yJCneuyOoCOzKSsOTUc0AJfpsItBGWvYpBLimhArU=
-github.com/emiago/diago v0.28.0 h1:VCiimhFYLoBTsxH6WrufLSt6tKWG8Fv7LfCkZHqct2E=
-github.com/emiago/diago v0.28.0/go.mod h1:eQT6j9co9PMQ/25aUiM2jpvwxxWFXLWi2w5R3lZNmKg=
+github.com/emiago/diago v0.32.0 h1:U6urbJc/LD2HwrHVe1d/yT0lMgyDMRUFle7gMqJe0Jg=
+github.com/emiago/diago v0.32.0/go.mod h1:CP7p9/aBZG/fQEYdtGdQkCblr1jLr1zbxODcu8MryVU=
 github.com/emiago/dtls/v3 v3.0.0-20260122183559-8b8d23e359c0 h1:o4LxpUnZ1zxiQ+Qjc9kLwXcjz31NGAHmnZ7xoJto3VM=
 github.com/emiago/dtls/v3 v3.0.0-20260122183559-8b8d23e359c0/go.mod h1:ydcZ977eS1I6uOWodzMuw30BwvNAzT9su/xcNYSJqjA=
-github.com/emiago/sipgo v1.3.1 h1:JwcmYJtCmcjuLwB2ZxtupYilNQgwXN/JIcxp+CDq16A=
-github.com/emiago/sipgo v1.3.1/go.mod h1:DuwAxBZhKMqIzQFPGZb1MVAGU6Wuxj64oTOhd5dx/FY=
+github.com/emiago/sipgo v1.6.0 h1:6EuOP7c6f0VRatKYTPEYNezt4hslBEsaCzZZOhT2n3s=
+github.com/emiago/sipgo v1.6.0/go.mod h1:DuwAxBZhKMqIzQFPGZb1MVAGU6Wuxj64oTOhd5dx/FY=
 github.com/expr-lang/expr v1.17.8 h1:W1loDTT+0PQf5YteHSTpju2qfUfNoBt4yw9+wOEU9VM=
 github.com/expr-lang/expr v1.17.8/go.mod h1:8/vRC7+7HBzESEqt5kKpYXxrxkr31SaO8r40VO/1IT4=
 github.com/extism/go-sdk v1.7.1 h1:lWJos6uY+tRFdlIHR+SJjwFDApY7OypS/2nMhiVQ9Sw=
@@ -40,8 +40,8 @@ github.com/google/go-tpm v0.9.8 h1:slArAR9Ft+1ybZu0lBwpSmpwhRXaa85hWtMinMyRAWo=
 github.com/google/go-tpm v0.9.8/go.mod h1:h9jEsEECg7gtLis0upRBQU+GhYVH6jMjrFxI8u6bVUY=
 github.com/google/jsonschema-go v0.4.3 h1:/DBOLZTfDow7pe2GmaJNhltueGTtDKICi8V8p+DQPd0=
 github.com/google/jsonschema-go v0.4.3/go.mod h1:r5quNTdLOYEz95Ru18zA0ydNbBuYoo9tgaYcxEYhJVE=
-github.com/google/pprof v0.0.0-20250317173921-a4b03ec1a45e h1:ijClszYn+mADRFY17kjQEVQ1XRhq2/JR1M3sGqeJoxs=
-github.com/google/pprof v0.0.0-20250317173921-a4b03ec1a45e/go.mod h1:boTsfXsheKC2y+lKOCMpSfarhxDeIzfZG1jqGcPl3cA=
+github.com/google/pprof v0.0.0-20260802141513-ef3492d7dac3 h1:LMLX+LgTNWpfvCBdFebv6EsYotImrt/Ppc5cXIriCSo=
+github.com/google/pprof v0.0.0-20260802141513-ef3492d7dac3/go.mod h1:jl5iWTm0/hd5PjEYEOuwAJ57L/CibdZfrqZ5XA5GrCk=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
@@ -56,30 +56,30 @@ github.com/jwetzell/artnet-go v0.3.0 h1:MDHElOSbpgmIbYGHO9SoxsT7ynrYtV5/UHGT82ge
 github.com/jwetzell/artnet-go v0.3.0/go.mod h1:zqRsSsrd6rPwJacwscPteDqGIqevjZ3Z6dpp092VJ1w=
 github.com/jwetzell/free-d-go v0.2.0 h1:8WQW4du8Sf3d18aUzk9n5jZtHE6WdDQHDFjkFffvycc=
 github.com/jwetzell/free-d-go v0.2.0/go.mod h1:yHuRy51NeDfN26eJ6wzZgys8qyQiS7hkYILw8yF+UJ4=
-github.com/jwetzell/osc-go v0.3.0 h1:z75TxuQSEmdcmZ56OAepkDa3m88SdZh//3m4nBb/XZI=
-github.com/jwetzell/osc-go v0.3.0/go.mod h1:kCs329JxY6Qjga08tRQ/Gl0PqhgQzLIMpOhm6uszvIc=
+github.com/jwetzell/osc-go v0.3.1 h1:IyXCUxzMFjiUFOeqOpz57zNv5D3Zf9yEYs2tKmPQnxA=
+github.com/jwetzell/osc-go v0.3.1/go.mod h1:vdfsVQ0fvtaOVwnvaz7IJ0gqtx2bLcswsVU9k7h2UGo=
 github.com/jwetzell/psn-go v0.3.0 h1:WVpCEmExYE8a+I5hQak5jNJJp2x35VdGX/VuMUKPmhY=
 github.com/jwetzell/psn-go v0.3.0/go.mod h1:bcEAeti4sQM375buujb3mIfmUstD4Aby18gq3ENb6+o=
-github.com/klauspost/compress v1.18.6 h1:2jupLlAwFm95+YDR+NwD2MEfFO9d4z4Prjl1XXDjuao=
-github.com/klauspost/compress v1.18.6/go.mod h1:cwPg85FWrGar70rWktvGQj8/hthj3wpl0PGDogxkrSQ=
+github.com/klauspost/compress v1.19.2 h1:hMRETovs/pu/dVWN7zIT1PGG8t509MwT6bO7XSi26R8=
+github.com/klauspost/compress v1.19.2/go.mod h1:cwPg85FWrGar70rWktvGQj8/hthj3wpl0PGDogxkrSQ=
 github.com/klauspost/cpuid/v2 v2.2.10 h1:tBs3QSyvjDyFTq3uoc/9xFpCuOsJQFNPiAhYdw2skhE=
 github.com/klauspost/cpuid/v2 v2.2.10/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
-github.com/mattn/go-isatty v0.0.22 h1:j8l17JJ9i6VGPUFUYoTUKPSgKe/83EYU2zBC7YNKMw4=
-github.com/mattn/go-isatty v0.0.22/go.mod h1:ZXfXG4SQHsB/w3ZeOYbR0PrPwLy+n6xiMrJlRFqopa4=
+github.com/mattn/go-isatty v0.0.24 h1:tGZZoVgT/KiqK1c8ocVLeDS8BSWMRd47J3Lbz7vsReI=
+github.com/mattn/go-isatty v0.0.24/go.mod h1:nMCL3Zebbrt45jsMDgnfIwz6ydEQApk5oEI3HqDio6A=
 github.com/minio/highwayhash v1.0.4 h1:asJizugGgchQod2ja9NJlGOWq4s7KsAWr5XUc9Clgl4=
 github.com/minio/highwayhash v1.0.4/go.mod h1:GGYsuwP/fPD6Y9hMiXuapVvlIUEhFhMTh0rxU3ik1LQ=
-github.com/nats-io/jwt/v2 v2.8.1 h1:V0xpGuD/N8Mi+fQNDynXohVvp7ZztevW5io8CUWlPmU=
-github.com/nats-io/jwt/v2 v2.8.1/go.mod h1:nWnOEEiVMiKHQpnAy4eXlizVEtSfzacZ1Q43LIRavZg=
-github.com/nats-io/nats-server/v2 v2.14.1 h1:wXs/a5fw9Hzm3CvuzLxGeIwpjPulSa7gMT3eSuhGkcg=
-github.com/nats-io/nats-server/v2 v2.14.1/go.mod h1:4N17zLpuS7WMbG8T9gsE2B7z9hC9PraPyulVBfpK6nU=
-github.com/nats-io/nats.go v1.52.0 h1:n3avV4VBsCgsdwh71TppsTwtv+QdPs7ntSKM8qJLGsc=
-github.com/nats-io/nats.go v1.52.0/go.mod h1:26HypzazeOkyO3/mqd1zZd53STJN0EjCYF9Uy2ZOBno=
-github.com/nats-io/nkeys v0.4.15 h1:JACV5jRVO9V856KOapQ7x+EY8Jo3qw1vJt/9Jpwzkk4=
-github.com/nats-io/nkeys v0.4.15/go.mod h1:CpMchTXC9fxA5zrMo4KpySxNjiDVvr8ANOSZdiNfUrs=
+github.com/nats-io/jwt/v2 v2.8.2 h1:XXRgB60MSTnqsRwejQurVDs/hcv2dkt+86GjI+I/bMc=
+github.com/nats-io/jwt/v2 v2.8.2/go.mod h1:Ag/56sq9OblL4JgdYufDd16Egb17Kr/8WwwuO/forVc=
+github.com/nats-io/nats-server/v2 v2.14.6 h1:dHjEHa49lUTxIb5jrsk5kz/AmOyOQ4T9ti8djcBumDQ=
+github.com/nats-io/nats-server/v2 v2.14.6/go.mod h1:u/0bNBzN/m5orQGz7q2NNzxCQ6PWdwaOSwPNDADZn/A=
+github.com/nats-io/nats.go v1.53.1 h1:Otsq3uLc/kLdjmkNHkXH0jBqwUquwdKFoe3fq6/3/Xo=
+github.com/nats-io/nats.go v1.53.1/go.mod h1:26HypzazeOkyO3/mqd1zZd53STJN0EjCYF9Uy2ZOBno=
+github.com/nats-io/nkeys v0.4.16 h1:rd5oAuLOb8mnAycB0xleuEBNS1pVVnN0fv/FF34Eypg=
+github.com/nats-io/nkeys v0.4.16/go.mod h1:llLgWoI0o4z/Q57q2R1kHfmocyhGV6VG/U18Glg1Afs=
 github.com/nats-io/nuid v1.0.1 h1:5iA8DT8V7q8WK2EScv2padNa/rTESc1KdnPw4TC2paw=
 github.com/nats-io/nuid v1.0.1/go.mod h1:19wcPz3Ph3q0Jbyiqsd0kePYG7A95tJPxeL+1OSON2c=
 github.com/ncruces/go-strftime v1.0.0 h1:HMFp8mLCTPp341M/ZnA4qaf7ZlsbTc+miZjCLOFAw7w=
@@ -98,8 +98,8 @@ github.com/pion/transport/v4 v4.0.1 h1:sdROELU6BZ63Ab7FrOLn13M6YdJLY20wldXW2Cu2k
 github.com/pion/transport/v4 v4.0.1/go.mod h1:nEuEA4AD5lPdcIegQDpVLgNoDGreqM/YqmEx3ovP4jM=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/redis/go-redis/v9 v9.19.0 h1:XPVaaPSnG6RhYf7p+rmSa9zZfeVAnWsH5h3lxthOm/k=
-github.com/redis/go-redis/v9 v9.19.0/go.mod h1:v/M13XI1PVCDcm01VtPFOADfZtHf8YW3baQf57KlIkA=
+github.com/redis/go-redis/v9 v9.22.0 h1:laDvpYXTJtZLloinw1fA5Kqd6HAEH2XKxOkG/PDq2F0=
+github.com/redis/go-redis/v9 v9.22.0/go.mod h1:y2g0Wj8rQvuK0ELM+oxSudcLtC09JScs98I/X9gRWY4=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
 github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
@@ -110,16 +110,16 @@ github.com/tetratelabs/wabin v0.0.0-20230304001439-f6f874872834 h1:ZF+QBjOI+tILZ
 github.com/tetratelabs/wabin v0.0.0-20230304001439-f6f874872834/go.mod h1:m9ymHTgNSEjuxvw8E7WWe4Pl4hZQHXONY8wE6dMLaRk=
 github.com/tetratelabs/wazero v1.11.0 h1:+gKemEuKCTevU4d7ZTzlsvgd1uaToIDtlQlmNbwqYhA=
 github.com/tetratelabs/wazero v1.11.0/go.mod h1:eV28rsN8Q+xwjogd7f4/Pp4xFxO7uOGbLcD/LzB1wiU=
-github.com/urfave/cli/v3 v3.9.0 h1:AV9lIiPv3ukYnxunaCUsHnEozptYmDN2F0+yWqLMn/c=
-github.com/urfave/cli/v3 v3.9.0/go.mod h1:ysVLtOEmg2tOy6PknnYVhDoouyC/6N42TMeoMzskhso=
+github.com/urfave/cli/v3 v3.11.0 h1:P/euJp99kb9p0tlVY+iYTLYYTAQlfl0hR2gUO1Img1Q=
+github.com/urfave/cli/v3 v3.11.0/go.mod h1:ysVLtOEmg2tOy6PknnYVhDoouyC/6N42TMeoMzskhso=
 github.com/zaf/g711 v1.4.0 h1:XZYkjjiAg9QTBnHqEg37m2I9q3IIDv5JRYXs2N8ma7c=
 github.com/zaf/g711 v1.4.0/go.mod h1:eCDXt3dSp/kYYAoooba7ukD/Q75jvAaS4WOMr0l1Roo=
 github.com/zeebo/xxh3 v1.1.0 h1:s7DLGDK45Dyfg7++yxI0khrfwq9661w9EN78eP/UZVs=
 github.com/zeebo/xxh3 v1.1.0/go.mod h1:IisAie1LELR4xhVinxWS5+zf1lA4p0MW4T+w+W07F5s=
-gitlab.com/gomidi/midi/v2 v2.3.23 h1:P8NxV4EzV9c+BjpwTeB+G/qa+Xdq/UTazS2fKxY0O0g=
-gitlab.com/gomidi/midi/v2 v2.3.23/go.mod h1:jDpP4O4skYi+7iVwt6Zyp18bd2M4hkjtMuw2cmgKgfw=
-go.bug.st/serial v1.7.1 h1:5aP8wYL0UjEYOVs3oPAGscjaSfRQLHtCvBFXNN/rwtc=
-go.bug.st/serial v1.7.1/go.mod h1:d0MmS16Qt9b1m06yoYRNUXhRRTJV5Qg2S5EKqQtnayQ=
+gitlab.com/gomidi/midi/v2 v2.3.24 h1:afkq5nhlzKvZaj9QK80YbK8tH3lIlKLnPPP9HxxD7Do=
+gitlab.com/gomidi/midi/v2 v2.3.24/go.mod h1:jDpP4O4skYi+7iVwt6Zyp18bd2M4hkjtMuw2cmgKgfw=
+go.bug.st/serial v1.8.0 h1:ZtnmN8aYXtPlTghwSvDWPHKBHL9TM6oFDa+KpSn4SQE=
+go.bug.st/serial v1.8.0/go.mod h1:d0MmS16Qt9b1m06yoYRNUXhRRTJV5Qg2S5EKqQtnayQ=
 go.opentelemetry.io/proto/otlp v1.10.0 h1:IQRWgT5srOCYfiWnpqUYz9CVmbO8bFmKcwYxpuCSL2g=
 go.opentelemetry.io/proto/otlp v1.10.0/go.mod h1:/CV4QoCR/S9yaPj8utp3lvQPoqMtxXdzn7ozvvozVqk=
 go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=
@@ -128,22 +128,22 @@ go.yaml.in/yaml/v2 v2.4.2 h1:DzmwEr2rDGHl7lsFgAHxmNz/1NlQ7xLIrlN2h5d1eGI=
 go.yaml.in/yaml/v2 v2.4.2/go.mod h1:081UH+NErpNdqlCXm3TtEran0rJZGxAYx9hb/ELlsPU=
 go.yaml.in/yaml/v3 v3.0.4 h1:tfq32ie2Jv2UxXFdLJdh3jXuOzWiL1fo0bu/FbuKpbc=
 go.yaml.in/yaml/v3 v3.0.4/go.mod h1:DhzuOOF2ATzADvBadXxruRBLzYTpT36CKvDb3+aBEFg=
-golang.org/x/crypto v0.51.0 h1:IBPXwPfKxY7cWQZ38ZCIRPI50YLeevDLlLnyC5wRGTI=
-golang.org/x/crypto v0.51.0/go.mod h1:8AdwkbraGNABw2kOX6YFPs3WM22XqI4EXEd8g+x7Oc8=
-golang.org/x/mod v0.36.0 h1:JJjpVx6myfUsUdAzZuOSTTmRE0PfZeNWzzvKrP7amb4=
-golang.org/x/mod v0.36.0/go.mod h1:moc6ELqsWcOw5Ef3xVprK5ul/MvtVvkIXLziUOICjUQ=
-golang.org/x/net v0.54.0 h1:2zJIZAxAHV/OHCDTCOHAYehQzLfSXuf/5SoL/Dv6w/w=
-golang.org/x/net v0.54.0/go.mod h1:Sj4oj8jK6XmHpBZU/zWHw3BV3abl4Kvi+Ut7cQcY+cQ=
-golang.org/x/sync v0.20.0 h1:e0PTpb7pjO8GAtTs2dQ6jYa5BWYlMuX047Dco/pItO4=
-golang.org/x/sync v0.20.0/go.mod h1:9xrNwdLfx4jkKbNva9FpL6vEN7evnE43NNNJQ2LF3+0=
+golang.org/x/crypto v0.55.0 h1:+KWHjbgOaAQ66dh/YlkZKHlz9ZUlq61AFirAR9ntP8M=
+golang.org/x/crypto v0.55.0/go.mod h1:uq0V9dE/fzQuJtbnL+2EhWOE63vo164FY8xqEnV9xis=
+golang.org/x/mod v0.38.0 h1:MECBjubtXD7yj4HrhIUcywNaGeNVUdfVnxmPajOk4yk=
+golang.org/x/mod v0.38.0/go.mod h1:V6Xz0pq8TQ3dGqVQ1FVHuelZpAL0uNhSkk9ogYP3c40=
+golang.org/x/net v0.57.0 h1:K5+3DljvIuDG9/Jv9rvyMywYNFCQ9RSUY6OOTTkT+tE=
+golang.org/x/net v0.57.0/go.mod h1:KpXc8iv+r3XplLAG/f7Jsf9RPszJzdR0f58q9vGOuEU=
+golang.org/x/sync v0.22.0 h1:SZjpbeLmrCk4xhRSZFNZW5gFUeCeFgjekvI/+gfScek=
+golang.org/x/sync v0.22.0/go.mod h1:9xrNwdLfx4jkKbNva9FpL6vEN7evnE43NNNJQ2LF3+0=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.21.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
-golang.org/x/sys v0.44.0 h1:ildZl3J4uzeKP07r2F++Op7E9B29JRUy+a27EibtBTQ=
-golang.org/x/sys v0.44.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
+golang.org/x/sys v0.47.0 h1:o7XGOvZQCADBQQ4Y7VNq2dRWQR7JmOUW8Kxx4ZsNgWs=
+golang.org/x/sys v0.47.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
 golang.org/x/time v0.15.0 h1:bbrp8t3bGUeFOx08pvsMYRTCVSMk89u4tKbNOZbp88U=
 golang.org/x/time v0.15.0/go.mod h1:Y4YMaQmXwGQZoFaVFk4YpCt4FLQMYKZe9oeV/f4MSno=
-golang.org/x/tools v0.44.0 h1:UP4ajHPIcuMjT1GqzDWRlalUEoY+uzoZKnhOjbIPD2c=
-golang.org/x/tools v0.44.0/go.mod h1:KA0AfVErSdxRZIsOVipbv3rQhVXTnlU6UhKxHd1seDI=
+golang.org/x/tools v0.48.0 h1:3+hClM1aLL5mjMKm5ovokw9epgRXPuu2tILgismM6RE=
+golang.org/x/tools v0.48.0/go.mod h1:08xX0orndb/F7jJxGDicx061tyd5pcMto75YMAXr6lk=
 google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
 google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
@@ -155,34 +155,34 @@ gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gotest.tools/v3 v3.5.2 h1:7koQfIKdy+I8UTetycgUqXWSDwpgv193Ka+qRsmBY8Q=
 gotest.tools/v3 v3.5.2/go.mod h1:LtdLGcnqToBH83WByAAi/wiwSFCArdFIUV/xxN4pcjA=
-modernc.org/cc/v4 v4.28.2 h1:3tQ0lf2ADtoby2EtSP+J7IE2SHwEJdP8ioR59wx7XpY=
-modernc.org/cc/v4 v4.28.2/go.mod h1:OnovgIhbbMXMu1aISnJ0wvVD1KnW+cAUJkIrAWh+kVI=
-modernc.org/ccgo/v4 v4.34.0 h1:yRLPFZieg532OT4rp4JFNIVcquwalMX26G95WQDqwCQ=
-modernc.org/ccgo/v4 v4.34.0/go.mod h1:AS5WYMyBakQ+fhsHhtP8mWB82KTGPkNNJDGfGQCe0/A=
+modernc.org/cc/v4 v4.29.2 h1:h6+9ciCnPKutf4I03CvheAvDLX7+IHlqR6Iy6J+cgd8=
+modernc.org/cc/v4 v4.29.2/go.mod h1:OnovgIhbbMXMu1aISnJ0wvVD1KnW+cAUJkIrAWh+kVI=
+modernc.org/ccgo/v4 v4.35.0 h1:F+TUsmw09QxLzmi3aeYYGxjAXarmZaKgj3mKQHNaA8w=
+modernc.org/ccgo/v4 v4.35.0/go.mod h1:qrVGs9S3Sr2Ztcg9ve+kTAYMp5a3YvWjo+SoN06kJ5I=
 modernc.org/fileutil v1.4.0 h1:j6ZzNTftVS054gi281TyLjHPp6CPHr2KCxEXjEbD6SM=
 modernc.org/fileutil v1.4.0/go.mod h1:EqdKFDxiByqxLk8ozOxObDSfcVOv/54xDs/DUHdvCUU=
 modernc.org/gc/v2 v2.6.5 h1:nyqdV8q46KvTpZlsw66kWqwXRHdjIlJOhG6kxiV/9xI=
 modernc.org/gc/v2 v2.6.5/go.mod h1:YgIahr1ypgfe7chRuJi2gD7DBQiKSLMPgBQe9oIiito=
-modernc.org/gc/v3 v3.1.2 h1:ZtDCnhonXSZexk/AYsegNRV1lJGgaNZJuKjJSWKyEqo=
-modernc.org/gc/v3 v3.1.2/go.mod h1:HFK/6AGESC7Ex+EZJhJ2Gni6cTaYpSMmU/cT9RmlfYY=
+modernc.org/gc/v3 v3.1.5 h1:21ldfPfRYE31Tb7B3mwAK8gy1AxP4+dKjrOQPfqakoc=
+modernc.org/gc/v3 v3.1.5/go.mod h1:HFK/6AGESC7Ex+EZJhJ2Gni6cTaYpSMmU/cT9RmlfYY=
 modernc.org/goabi0 v0.2.0 h1:HvEowk7LxcPd0eq6mVOAEMai46V+i7Jrj13t4AzuNks=
 modernc.org/goabi0 v0.2.0/go.mod h1:CEFRnnJhKvWT1c1JTI3Avm+tgOWbkOu5oPA8eH8LnMI=
-modernc.org/libc v1.72.3 h1:ZnDF4tXn4NBXFutMMQC4vtbTFSXhhKzR73fv0beZEAU=
-modernc.org/libc v1.72.3/go.mod h1:dn0dZNnnn1clLyvRxLxYExxiKRZIRENOfqQ8XEeg4Qs=
-modernc.org/libquickjs v0.12.8 h1:wJ2GGxEDcQb7j8ILZScNNP1WsXFILlo1qQ8cS3q/tPw=
-modernc.org/libquickjs v0.12.8/go.mod h1:nIPezuUN/J6aDLSaR76qNaPNNy79FH5Gkjb/x9wa/gU=
+modernc.org/libc v1.75.4 h1:EHQJNYDC6LiDIOqM76862xe4frbDc7IzEOZTtGxZV8Q=
+modernc.org/libc v1.75.4/go.mod h1:bO5o2ztHxBb2rjz0PgdHN0sSMw57CgxGFLZ3Qd/QpVQ=
+modernc.org/libquickjs v0.13.1 h1:uCb9AYyEyL1JS2dnKtLZKWH/vDb36cx1Mr1SIdbzb8A=
+modernc.org/libquickjs v0.13.1/go.mod h1:tCEsA1Zda1+C5JagFIJGqjYZOxDPFOUYjK3dGhEeq0g=
 modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU=
 modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg=
-modernc.org/memory v1.11.0 h1:o4QC8aMQzmcwCK3t3Ux/ZHmwFPzE6hf2Y5LbkRs+hbI=
-modernc.org/memory v1.11.0/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw=
+modernc.org/memory v1.12.1 h1:nFMiWrpStgZczNl6XI9GnIk/rWhYIyHGUaR04pGbp9g=
+modernc.org/memory v1.12.1/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw=
 modernc.org/opt v0.2.0 h1:tGyef5ApycA7FSEOMraay9SaTk5zmbx7Tu+cJs4QKZg=
 modernc.org/opt v0.2.0/go.mod h1:03fq9lsNfvkYSfxrfUhZCWPk1lm4cq4N+Bh//bEtgns=
-modernc.org/quickjs v0.18.2 h1:v/KDawJfs4L7jSCItAKrkrHCmOL5VnDLMJOXpU8Evdk=
-modernc.org/quickjs v0.18.2/go.mod h1:U11Fhn2hC71v+DyvEN3cY4IXkjU5XxrYT0DQWvZ43+A=
+modernc.org/quickjs v0.24.2 h1:wfVrO+6ailTzKHA7LAlknnOXH/rJyiIgw4+WNI0m6ew=
+modernc.org/quickjs v0.24.2/go.mod h1:4SZg8rXHeX2pO2VpBVmqSDrIOYD/UF5Cnh3ew4tzFng=
 modernc.org/sortutil v1.2.1 h1:+xyoGf15mM3NMlPDnFqrteY07klSFxLElE2PVuWIJ7w=
 modernc.org/sortutil v1.2.1/go.mod h1:7ZI3a3REbai7gzCLcotuw9AC4VZVpYMjDzETGsSMqJE=
-modernc.org/sqlite v1.50.1 h1:l+cQvn0sd0zJJtfygGHuQJ5AjlrwXmWPw4KP3ZMwr9w=
-modernc.org/sqlite v1.50.1/go.mod h1:tcNzv5p84E0skkmJn038y+hWJbLQXQqEnQfeh5r2JLM=
+modernc.org/sqlite v1.57.0 h1:qNQP6xnx5M0ISNtlnxoOX0+cD5bJ0/gr9aMmndFczzg=
+modernc.org/sqlite v1.57.0/go.mod h1:yCJ2cmAaIkHQ25oXWrF8H4O1lIfPYPR26yCEDj2P3pQ=
 modernc.org/strutil v1.2.1 h1:UneZBkQA+DX2Rp35KcM69cSsNES9ly8mQWD71HKlOA0=
 modernc.org/strutil v1.2.1/go.mod h1:EHkiggD70koQxjVdSBM3JKM7k6L0FbGE5eymy9i3B9A=
 modernc.org/token v1.1.0 h1:Xl7Ap9dKaEs5kLoOQeQmPWevfnk/DM5qcLcYlA8ys6Y=
@@ -0,0 +1,24 @@
+package common_test
+
+import (
+	"testing"
+
+	"github.com/jwetzell/showbridge-go/internal/common"
+)
+
+func TestEventToJson(t *testing.T) {
+	e := common.Event{
+		Type: "test.event",
+		Data: map[string]any{
+			"key": "value",
+		},
+	}
+	jsonData, err := e.ToJSON()
+	if err != nil {
+		t.Fatalf("Failed to convert event to JSON: %v", err)
+	}
+	expectedJson := `{"type":"test.event","data":{"key":"value"}}`
+	if string(jsonData) != expectedJson {
+		t.Errorf("Expected JSON: %s, got: %s", expectedJson, string(jsonData))
+	}
+}
@@ -1,6 +1,7 @@
 package config

 type ProcessorConfig struct {
+	Id     string `json:"id"`
 	Type   string `json:"type"`
 	Params Params `json:"params,omitempty"`
 }
@@ -1,6 +1,7 @@
 package config

 type RouteConfig struct {
+	Id         string            `json:"id"`
 	Input      string            `json:"input"`
 	Processors []ProcessorConfig `json:"processors"`
 }
@@ -22,8 +22,10 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"dsn": {
-					Type:      "string",
-					MinLength: new(1),
+					Title:       "Data Source Name",
+					Description: "the data source name (DSN) for the SQLite database",
+					Type:        "string",
+					MinLength:   new(1),
 				},
 			},
 			Required:             []string{"dsn"},
@@ -24,10 +24,11 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1024),
-					Maximum: jsonschema.Ptr[float64](65535),
+					Title:       "Port",
+					Description: "the port for the HTTP server to listen on",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1024),
+					Maximum:     jsonschema.Ptr[float64](65535),
 				},
 			},
 			Required:             []string{"port"},
@@ -22,8 +22,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"port": {
-					Title: "Port",
-					Type:  "string",
+					Title:       "Port",
+					Description: "the name of the MIDI port to listen to",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"port"},
@@ -24,8 +24,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"port": {
-					Title: "Port",
-					Type:  "string",
+					Title:       "Port",
+					Description: "the name of the MIDI port to send messages to",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"port"},
@@ -30,7 +30,8 @@ func RegisterModule(mod ModuleRegistration) {
 	moduleRegistryMu.Lock()
 	defer moduleRegistryMu.Unlock()

-	if _, ok := moduleRegistry[string(mod.Type)]; ok {
+	_, exists := moduleRegistry[string(mod.Type)]
+	if exists {
 		panic(fmt.Sprintf("module already registered: %s", mod.Type))
 	}
 	moduleRegistry[string(mod.Type)] = mod
@@ -22,28 +22,33 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"broker": {
-					Title: "Broker URL",
-					Type:  "string",
+					Title:       "Broker URL",
+					Description: "the URL of the MQTT broker to connect to",
+					Type:        "string",
 				},
 				"topic": {
-					Title: "Topic",
-					Type:  "string",
+					Title:       "Topic",
+					Description: "an MQTT topic to subscribe to",
+					Type:        "string",
 				},
 				"clientId": {
-					Title: "Client ID",
-					Type:  "string",
+					Title:       "Client ID",
+					Description: "the client ID to use when connecting to the MQTT broker",
+					Type:        "string",
 				},
 				"qos": {
-					Title:   "QoS",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](0),
-					Maximum: jsonschema.Ptr[float64](2),
-					Default: json.RawMessage(`0`),
+					Title:       "QoS",
+					Description: "the QoS level to use when publishing messages",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](0),
+					Maximum:     jsonschema.Ptr[float64](2),
+					Default:     json.RawMessage(`0`),
 				},
 				"retained": {
-					Title:   "Retained",
-					Type:    "boolean",
-					Default: json.RawMessage(`false`),
+					Title:       "Retained",
+					Description: "whether to set the retained flag when publishing messages",
+					Type:        "boolean",
+					Default:     json.RawMessage(`false`),
 				},
 			},
 			Required:             []string{"broker", "topic", "clientId"},
@@ -143,13 +148,13 @@ func (mc *MQTTClient) Start(ctx context.Context, inputHandler common.InputHandle
 	mc.client = mqtt.NewClient(opts)

 	token := mc.client.Connect()
+	mc.clientMu.Unlock()

 	token.Wait()
 	err := token.Error()
 	if err != nil {
 		return err
 	}
-	mc.clientMu.Unlock()

 	<-mc.ctx.Done()
 	mc.logger.Debug("done")
@@ -20,12 +20,14 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"url": {
-					Title: "NATS Server URL",
-					Type:  "string",
+					Title:       "NATS Server URL",
+					Description: "the URL of the NATS server to connect to",
+					Type:        "string",
 				},
 				"subject": {
-					Title: "Subject",
-					Type:  "string",
+					Title:       "Subject",
+					Description: "the subject to subscribe to",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"url", "subject"},
@@ -24,16 +24,18 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"ip": {
-					Title:   "IP",
-					Type:    "string",
-					Default: json.RawMessage(`"0.0.0.0"`),
+					Title:       "IP",
+					Description: "the IP address to bind the NATS server to",
+					Type:        "string",
+					Default:     json.RawMessage(`"0.0.0.0"`),
 				},
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1024),
-					Maximum: jsonschema.Ptr[float64](65535),
-					Default: json.RawMessage(`4222`),
+					Title:       "Port",
+					Description: "the port for the NATS server to listen on",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1024),
+					Maximum:     jsonschema.Ptr[float64](65535),
+					Default:     json.RawMessage(`4222`),
 				},
 			},
 			Required:             []string{},
@@ -75,7 +75,8 @@ func (pc *PSNClient) Start(ctx context.Context, inputHandler common.InputHandler
 			pc.connMu.Unlock()
 			if err != nil {
 				//NOTE(jwetzell) we hit deadline
-				if opErr, ok := err.(*net.OpError); ok && opErr.Timeout() {
+				opErr, ok := err.(*net.OpError)
+				if ok && opErr.Timeout() {
 					continue
 				}
 				return err
@@ -21,12 +21,16 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"host": {
-					Type: "string",
+					Title:       "Host",
+					Description: "the hostname or IP address of the Redis server to connect to",
+					Type:        "string",
 				},
 				"port": {
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1),
-					Maximum: jsonschema.Ptr[float64](65535),
+					Title:       "Port",
+					Description: "the port to use when connecting to the Redis server",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1),
+					Maximum:     jsonschema.Ptr[float64](65535),
 				},
 			},
 			Required:             []string{"host", "port"},
@@ -25,17 +25,20 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"port": {
-					Title: "Port",
-					Type:  "string",
+					Title:       "Port",
+					Description: "the name of the serial port to connect to",
+					Type:        "string",
 				},
 				"baudRate": {
-					Title: "Baud Rate",
-					Type:  "integer",
+					Title:       "Baud Rate",
+					Description: "the baud rate to use when connecting to the serial port",
+					Type:        "integer",
 				},
 				"framing": {
-					Title: "Framing Method",
-					Type:  "string",
-					Enum:  []any{"LF", "CR", "CRLF", "SLIP", "RAW"},
+					Title:       "Framing Method",
+					Description: "the method to use for framing messages on the serial port",
+					Type:        "string",
+					Enum:        []any{"LF", "CR", "CRLF", "SLIP", "RAW"},
 				},
 			},
 			Required:             []string{"port", "baudRate", "framing"},
@@ -53,12 +56,14 @@ func init() {
 				return nil, fmt.Errorf("serial.client framing error: %w", err)
 			}

-			framer := framer.GetFramer(framingMethodString)
+			inFramer := framer.GetFramer(framingMethodString)

-			if framer == nil {
+			if inFramer == nil {
 				return nil, fmt.Errorf("serial.client unknown framing method: %s", framingMethodString)
 			}

+			outFramer := framer.GetFramer(framingMethodString)
+
 			baudRateInt, err := params.GetInt("baudRate")
 			if err != nil {
 				return nil, fmt.Errorf("serial.client baudRate error: %w", err)
@@ -68,7 +73,7 @@ func init() {
 				BaudRate: baudRateInt,
 			}

-			return &SerialClient{config: config, Port: portString, Framer: framer, Mode: &mode, logger: CreateLogger(config)}, nil
+			return &SerialClient{config: config, Port: portString, inFramer: inFramer, outFramer: outFramer, Mode: &mode, logger: CreateLogger(config)}, nil
 		},
 	})
 }
@@ -78,7 +83,8 @@ type SerialClient struct {
 	ctx          context.Context
 	inputHandler common.InputHandler
 	Port         string
-	Framer       framer.Framer
+	inFramer     framer.Framer
+	outFramer    framer.Framer
 	Mode         *serial.Mode
 	port         serial.Port
 	logger       *slog.Logger
@@ -139,13 +145,13 @@ func (sc *SerialClient) Start(ctx context.Context, inputHandler common.InputHand
 					byteCount, err := sc.port.Read(buffer)

 					if err != nil {
-						sc.Framer.Clear()
+						sc.inFramer.Clear()
 						break READ
 					}

-					if sc.Framer != nil {
+					if sc.inFramer != nil {
 						if byteCount > 0 {
-							messages := sc.Framer.Decode(buffer[0:byteCount])
+							messages := sc.inFramer.Decode(buffer[0:byteCount])
 							for _, message := range messages {
 								if sc.inputHandler != nil {
 									sc.inputHandler(sc.ctx, sc.Id(), message)
@@ -172,7 +178,7 @@ func (sc *SerialClient) Output(ctx context.Context, payload any) error {
 		return errors.New("serial.client can only output bytes")
 	}

-	_, err := sc.port.Write(sc.Framer.Encode(payloadBytes))
+	_, err := sc.port.Write(sc.outFramer.Encode(payloadBytes))
 	return err
 }

@@ -185,4 +191,12 @@ func (sc *SerialClient) Stop() {
 	if sc.port != nil {
 		sc.port.Close()
 	}
+
+	if sc.inFramer != nil {
+		sc.inFramer.Clear()
+	}
+
+	if sc.outFramer != nil {
+		sc.outFramer.Clear()
+	}
 }
@@ -29,27 +29,31 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"ip": {
-					Title:   "IP",
-					Type:    "string",
-					Default: json.RawMessage(`"0.0.0.0"`),
+					Title:       "IP",
+					Description: "the IP address to bind the SIP server to",
+					Type:        "string",
+					Default:     json.RawMessage(`"0.0.0.0"`),
 				},
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1024),
-					Maximum: jsonschema.Ptr[float64](65535),
-					Default: json.RawMessage(`5060`),
+					Title:       "Port",
+					Description: "the port for the SIP server to listen on",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1024),
+					Maximum:     jsonschema.Ptr[float64](65535),
+					Default:     json.RawMessage(`5060`),
 				},
 				"transport": {
-					Title:   "Transport",
-					Type:    "string",
-					Enum:    []any{"udp", "tcp", "ws", "udp4", "tcp4"},
-					Default: json.RawMessage(`"udp"`),
+					Title:       "Transport",
+					Description: "the transport protocol to use for the SIP server",
+					Type:        "string",
+					Enum:        []any{"udp", "tcp", "ws", "udp4", "tcp4"},
+					Default:     json.RawMessage(`"udp"`),
 				},
 				"userAgent": {
-					Title:   "User Agent",
-					Type:    "string",
-					Default: json.RawMessage(`"showbridge"`),
+					Title:       "User Agent",
+					Description: "the user agent string to use",
+					Type:        "string",
+					Default:     json.RawMessage(`"showbridge"`),
 				},
 			},
 			Required:             []string{},
@@ -208,7 +212,10 @@ func (scs *SIPCallServer) Output(ctx context.Context, payload any) error {
 	payloadDTMFResponse, ok := common.GetAnyAs[processor.SipDTMFResponse](payload)

 	if ok {
-		dtmfWriter := call.inDialog.AudioWriterDTMF()
+		dtmfWriter, err := call.inDialog.AudioWriterDTMF()
+		if err != nil {
+			return err
+		}
 		time.Sleep(time.Millisecond * time.Duration(payloadDTMFResponse.PreWait))
 		for i, dtmfRune := range payloadDTMFResponse.Digits {
 			err := dtmfWriter.WriteDTMF(dtmfRune)
@@ -30,33 +30,38 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"ip": {
-					Title:   "IP",
-					Type:    "string",
-					Default: json.RawMessage(`"0.0.0.0"`),
+					Title:       "IP",
+					Description: "the IP address to bind the SIP server to",
+					Type:        "string",
+					Default:     json.RawMessage(`"0.0.0.0"`),
 				},
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1024),
-					Maximum: jsonschema.Ptr[float64](65535),
-					Default: json.RawMessage(`5060`),
+					Title:       "Port",
+					Description: "the port for the SIP server to listen on",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1024),
+					Maximum:     jsonschema.Ptr[float64](65535),
+					Default:     json.RawMessage(`5060`),
 				},
 				"transport": {
-					Title:   "Transport",
-					Type:    "string",
-					Enum:    []any{"udp", "tcp", "ws", "udp4", "tcp4"},
-					Default: json.RawMessage(`"udp"`),
+					Title:       "Transport",
+					Description: "the transport protocol to use for the SIP server",
+					Type:        "string",
+					Enum:        []any{"udp", "tcp", "ws", "udp4", "tcp4"},
+					Default:     json.RawMessage(`"udp"`),
 				},
 				"userAgent": {
-					Title:   "User Agent",
-					Type:    "string",
-					Default: json.RawMessage(`"showbridge"`),
+					Title:       "User Agent",
+					Description: "the user agent string to use",
+					Type:        "string",
+					Default:     json.RawMessage(`"showbridge"`),
 				},
 				"separator": {
-					Title:     "DTMF Separator",
-					Type:      "string",
-					MinLength: new(1),
-					MaxLength: new(1),
+					Title:       "DTMF Separator",
+					Description: "the DTMF character to use as a separator between DTMF digit groups",
+					Type:        "string",
+					MinLength:   new(1),
+					MaxLength:   new(1),
 				},
 			},
 			Required:             []string{"separator"},
@@ -199,7 +204,10 @@ func (sds *SIPDTMFServer) HandleCall(inDialog *diago.DialogServerSession) error
 	inDialog.Ringing()
 	inDialog.Answer()

-	reader := inDialog.AudioReaderDTMF()
+	reader, err := inDialog.AudioReaderDTMF()
+	if err != nil {
+		return err
+	}
 	userString := ""

 	return reader.Listen(func(dtmf rune) error {
@@ -241,7 +249,10 @@ func (sds *SIPDTMFServer) Output(ctx context.Context, payload any) error {
 	payloadDTMFResponse, ok := common.GetAnyAs[processor.SipDTMFResponse](payload)

 	if ok {
-		dtmfWriter := call.inDialog.AudioWriterDTMF()
+		dtmfWriter, err := call.inDialog.AudioWriterDTMF()
+		if err != nil {
+			return err
+		}

 		time.Sleep(time.Millisecond * time.Duration(payloadDTMFResponse.PreWait))
 		for i, dtmfRune := range payloadDTMFResponse.Digits {
@@ -23,19 +23,22 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"host": {
-					Title: "Host",
-					Type:  "string",
+					Title:       "Host",
+					Description: "the hostname or IP address of the TCP server to connect to",
+					Type:        "string",
 				},
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1),
-					Maximum: jsonschema.Ptr[float64](65535),
+					Title:       "Port",
+					Description: "the port of the TCP server to connect to",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1),
+					Maximum:     jsonschema.Ptr[float64](65535),
 				},
 				"framing": {
-					Title: "Framing Method",
-					Type:  "string",
-					Enum:  []any{"LF", "CR", "CRLF", "SLIP", "RAW"},
+					Title:       "Framing Method",
+					Description: "the method used to frame messages over the TCP connection",
+					Type:        "string",
+					Enum:        []any{"LF", "CR", "CRLF", "SLIP", "RAW"},
 				},
 			},
 			Required:             []string{"host", "port", "framing"},
@@ -63,19 +66,22 @@ func init() {
 				return nil, fmt.Errorf("net.tcp.client framing error: %w", err)
 			}

-			framer := framer.GetFramer(framingMethodString)
+			inFramer := framer.GetFramer(framingMethodString)

-			if framer == nil {
+			if inFramer == nil {
 				return nil, fmt.Errorf("net.tcp.client unknown framing method: %s", framingMethodString)
 			}
-			return &TCPClient{framer: framer, Addr: addr, config: config, logger: CreateLogger(config)}, nil
+
+			outFramer := framer.GetFramer(framingMethodString)
+			return &TCPClient{inFramer: inFramer, outFramer: outFramer, Addr: addr, config: config, logger: CreateLogger(config)}, nil
 		},
 	})
 }

 type TCPClient struct {
 	config       config.ModuleConfig
-	framer       framer.Framer
+	inFramer     framer.Framer
+	outFramer    framer.Framer
 	conn         *net.TCPConn
 	ctx          context.Context
 	inputHandler common.InputHandler
@@ -120,7 +126,8 @@ CONNECT_RETRY:
 			byteCount, err := tc.conn.Read(buffer)

 			if err != nil {
-				if opErr, ok := err.(*net.OpError); ok {
+				opErr, ok := err.(*net.OpError)
+				if ok {
 					//NOTE(jwetzell) we hit deadline
 					if opErr.Timeout() {
 						continue
@@ -132,9 +139,9 @@ CONNECT_RETRY:
 				break READ
 			}

-			if tc.framer != nil {
+			if tc.inFramer != nil {
 				if byteCount > 0 {
-					messages := tc.framer.Decode(buffer[0:byteCount])
+					messages := tc.inFramer.Decode(buffer[0:byteCount])
 					for _, message := range messages {
 						if tc.inputHandler != nil {
 							tc.inputHandler(tc.ctx, tc.Id(), message)
@@ -169,7 +176,7 @@ func (tc *TCPClient) Output(ctx context.Context, payload any) error {
 	if !ok {
 		return errors.New("net.tcp.client is only able to output bytes")
 	}
-	_, err := tc.conn.Write(tc.framer.Encode(payloadBytes))
+	_, err := tc.conn.Write(tc.inFramer.Encode(payloadBytes))
 	return err
 }

@@ -182,4 +189,12 @@ func (tc *TCPClient) Stop() {
 	if tc.conn != nil {
 		tc.conn.Close()
 	}
+
+	if tc.inFramer != nil {
+		tc.inFramer.Clear()
+	}
+
+	if tc.outFramer != nil {
+		tc.outFramer.Clear()
+	}
 }
@@ -26,20 +26,23 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"ip": {
-					Title:   "IP",
-					Type:    "string",
-					Default: json.RawMessage(`"0.0.0.0"`),
+					Title:       "IP",
+					Description: "the IP address to bind the TCP server to",
+					Type:        "string",
+					Default:     json.RawMessage(`"0.0.0.0"`),
 				},
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1024),
-					Maximum: jsonschema.Ptr[float64](65535),
+					Title:       "Port",
+					Description: "the port for the TCP server to listen on",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1024),
+					Maximum:     jsonschema.Ptr[float64](65535),
 				},
 				"framing": {
-					Title: "Framing Method",
-					Type:  "string",
-					Enum:  []any{"LF", "CR", "CRLF", "SLIP", "RAW"},
+					Title:       "Framing Method",
+					Description: "the method used to frame messages over the TCP connection",
+					Type:        "string",
+					Enum:        []any{"LF", "CR", "CRLF", "SLIP", "RAW"},
 				},
 			},
 			Required:             []string{"port", "framing"},
@@ -78,7 +81,7 @@ func init() {
 			if err != nil {
 				return nil, err
 			}
-			return &TCPServer{InFramer: inFramer, OutFramer: outFramer, framerType: framingMethodString, Addr: addr, config: moduleConfig, logger: CreateLogger(moduleConfig)}, nil
+			return &TCPServer{inFramer: inFramer, outFramer: outFramer, framerType: framingMethodString, Addr: addr, config: moduleConfig, logger: CreateLogger(moduleConfig)}, nil
 		},
 	})
 }
@@ -91,8 +94,8 @@ type tcpConnection struct {
 type TCPServer struct {
 	config                config.ModuleConfig
 	Addr                  *net.TCPAddr
-	InFramer              framer.Framer
-	OutFramer             framer.Framer
+	inFramer              framer.Framer
+	outFramer             framer.Framer
 	framerType            string
 	ctx                   context.Context
 	inputHandler          common.InputHandler
@@ -138,7 +141,8 @@ func (ts *TCPServer) handleClient(client *net.TCPConn) {
 		client.SetDeadline(time.Now().Add(time.Millisecond * 200))
 		byteCount, err := client.Read(buffer)
 		if err != nil {
-			if opErr, ok := err.(*net.OpError); ok {
+			opErr, ok := err.(*net.OpError)
+			if ok {
 				//NOTE(jwetzell) we hit deadline
 				if opErr.Timeout() {
 					continue
@@ -146,9 +150,9 @@ func (ts *TCPServer) handleClient(client *net.TCPConn) {
 			}
 			break
 		}
-		if ts.InFramer != nil {
+		if ts.inFramer != nil {
 			if byteCount > 0 {
-				messages := ts.InFramer.Decode(buffer[0:byteCount])
+				messages := ts.inFramer.Decode(buffer[0:byteCount])
 				for _, message := range messages {
 					if ts.inputHandler != nil {
 						ts.inputHandler(ts.ctx, ts.Id(), message)
@@ -216,11 +220,11 @@ func (ts *TCPServer) Output(ctx context.Context, payload any) error {
 	defer ts.connectionsMu.Unlock()
 	var errorString strings.Builder

-	if ts.OutFramer == nil {
+	if ts.outFramer == nil {
 		return errors.New("no output framer configured")
 	}

-	outputBytes := ts.OutFramer.Encode(payloadBytes)
+	outputBytes := ts.outFramer.Encode(payloadBytes)

 	for _, connection := range ts.connections {
 		_, err := connection.conn.Write(outputBytes)
@@ -11,7 +11,8 @@ import (

 func TestModuleBadRegistrationNoType(t *testing.T) {
 	defer func() {
-		if r := recover(); r == nil {
+		r := recover()
+		if r == nil {
 			t.Fatalf("module registration should have panicked but did not")
 		}
 	}()
@@ -26,7 +27,8 @@ func TestModuleBadRegistrationNoType(t *testing.T) {

 func TestModuleBadRegistrationNoNew(t *testing.T) {
 	defer func() {
-		if r := recover(); r == nil {
+		r := recover()
+		if r == nil {
 			t.Fatalf("processor registration should have panicked but did not")
 		}
 	}()
@@ -39,7 +41,8 @@ func TestModuleBadRegistrationNoNew(t *testing.T) {

 func TestModuleBadRegistrationExistingType(t *testing.T) {
 	defer func() {
-		if r := recover(); r == nil {
+		r := recover()
+		if r == nil {
 			t.Fatalf("processor registration should have panicked but did not")
 		}
 	}()
@@ -20,8 +20,8 @@ func init() {
 			Properties: map[string]*jsonschema.Schema{
 				"duration": {
 					Title:       "Duration",
+					Description: "time in milliseconds between emitted events",
 					Type:        "integer",
-					Description: "Interval duration in milliseconds",
 				},
 			},
 			Required:             []string{"duration"},
@@ -20,8 +20,8 @@ func init() {
 			Properties: map[string]*jsonschema.Schema{
 				"duration": {
 					Title:       "Duration",
+					Description: "time in milliseconds before the timer fires",
 					Type:        "integer",
-					Description: "Interval duration in milliseconds",
 				},
 			},
 			Required:             []string{"duration"},
@@ -21,14 +21,16 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"host": {
-					Title: "Host",
-					Type:  "string",
+					Title:       "Host",
+					Description: "the hostname or IP address of the UDP server to connect to",
+					Type:        "string",
 				},
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1),
-					Maximum: jsonschema.Ptr[float64](65535),
+					Title:       "Port",
+					Description: "the port of the UDP server to connect to",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1),
+					Maximum:     jsonschema.Ptr[float64](65535),
 				},
 			},
 			Required:             []string{"host", "port"},
@@ -22,14 +22,16 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"ip": {
-					Title: "IP",
-					Type:  "string",
+					Title:       "IP",
+					Description: "the multicast address to listen on",
+					Type:        "string",
 				},
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1024),
-					Maximum: jsonschema.Ptr[float64](65535),
+					Title:       "Port",
+					Description: "the port to listen on",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1024),
+					Maximum:     jsonschema.Ptr[float64](65535),
 				},
 			},
 			Required:             []string{"ip", "port"},
@@ -102,7 +104,8 @@ func (um *UDPMulticast) Start(ctx context.Context, inputHandler common.InputHand
 				break
 			}
 			//NOTE(jwetzell) we hit deadline
-			if opErr, ok := err.(*net.OpError); ok && opErr.Timeout() {
+			opErr, ok := err.(*net.OpError)
+			if ok && opErr.Timeout() {
 				continue
 			}
 			return err
@@ -23,22 +23,25 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"ip": {
-					Title:   "IP",
-					Type:    "string",
-					Default: json.RawMessage(`"0.0.0.0"`),
+					Title:       "IP",
+					Description: "the IP address to bind the UDP server to",
+					Type:        "string",
+					Default:     json.RawMessage(`"0.0.0.0"`),
 				},
 				"port": {
-					Title:   "Port",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1024),
-					Maximum: jsonschema.Ptr[float64](65535),
+					Title:       "Port",
+					Description: "the port for the UDP server to listen on",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1024),
+					Maximum:     jsonschema.Ptr[float64](65535),
 				},
 				"bufferSize": {
-					Title:   "Buffer Size",
-					Type:    "integer",
-					Minimum: jsonschema.Ptr[float64](1),
-					Maximum: jsonschema.Ptr[float64](65535),
-					Default: json.RawMessage("2048"),
+					Title:       "Buffer Size",
+					Description: "the size of the buffer for incoming UDP messages",
+					Type:        "integer",
+					Minimum:     jsonschema.Ptr[float64](1),
+					Maximum:     jsonschema.Ptr[float64](65535),
+					Default:     json.RawMessage("2048"),
 				},
 			},
 			Required:             []string{"port"},
@@ -120,7 +123,8 @@ func (us *UDPServer) Start(ctx context.Context, inputHandler common.InputHandler
 		numBytes, _, err := listener.ReadFromUDP(buffer)
 		if err != nil {
 			//NOTE(jwetzell) we hit deadline
-			if opErr, ok := err.(*net.OpError); ok && opErr.Timeout() {
+			opErr, ok := err.(*net.OpError)
+			if ok && opErr.Timeout() {
 				continue
 			}
 			break
@@ -23,8 +23,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"url": {
-					Title: "URL",
-					Type:  "string",
+					Title:       "URL",
+					Description: "the URL of the WebSocket server to connect",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"url"},
@@ -44,6 +44,10 @@ func (apd *ArtNetPacketDecode) Process(ctx context.Context, wrappedPayload commo
 	return wrappedPayload, nil
 }

+func (apd *ArtNetPacketDecode) Id() string {
+	return apd.config.Id
+}
+
 func (apd *ArtNetPacketDecode) Type() string {
 	return apd.config.Type
-}
+}
@@ -43,6 +43,10 @@ func (ape *ArtNetPacketEncode) Process(ctx context.Context, wrappedPayload commo
 	return wrappedPayload, nil
 }

+func (ape *ArtNetPacketEncode) Id() string {
+	return ape.config.Id
+}
+
 func (ape *ArtNetPacketEncode) Type() string {
 	return ape.config.Type
 }
@@ -22,13 +22,13 @@ func init() {
 			Properties: map[string]*jsonschema.Schema{
 				"module": {
 					Title:       "Module ID",
-					Type:        "string",
 					Description: "ID of the database module to query",
+					Type:        "string",
 				},
 				"query": {
 					Title:       "Query",
-					Type:        "string",
 					Description: "SQL query to execute",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"module", "query"},
@@ -143,6 +143,10 @@ func (dq *DbQuery) Process(ctx context.Context, wrappedPayload common.WrappedPay
 	return wrappedPayload, nil
 }

+func (dq *DbQuery) Id() string {
+	return dq.config.Id
+}
+
 func (dq *DbQuery) Type() string {
 	return dq.config.Type
 }
@@ -33,7 +33,10 @@ func (dl *DebugLog) Process(ctx context.Context, wrappedPayload common.WrappedPa
 	return wrappedPayload, nil
 }

+func (dl *DebugLog) Id() string {
+	return dl.config.Id
+}
+
 func (dl *DebugLog) Type() string {
 	return dl.config.Type
 }
-
@@ -35,6 +35,10 @@ func (fc *FilterChange) Process(ctx context.Context, wrappedPayload common.Wrapp
 	return wrappedPayload, nil
 }

+func (fc *FilterChange) Id() string {
+	return fc.config.Id
+}
+
 func (fc *FilterChange) Type() string {
 	return fc.config.Type
 }
@@ -19,8 +19,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"expression": {
-					Title: "Expression",
-					Type:  "string",
+					Title:       "Expression",
+					Description: "Expr expression to evaluate, must return a boolean",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"expression"},
@@ -75,6 +76,10 @@ func (fe *FilterExpr) Process(ctx context.Context, wrappedPayload common.Wrapped
 	return wrappedPayload, nil
 }

+func (fe *FilterExpr) Id() string {
+	return fe.config.Id
+}
+
 func (fe *FilterExpr) Type() string {
 	return fe.config.Type
 }
@@ -18,9 +18,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"rate": {
-					Type:        "integer",
 					Title:       "Rate",
-					Description: "The number of events to allow per second.",
+					Description: "number of events to allow per second",
+					Type:        "integer",
 				},
 			},
 			Required: []string{"rate"},
@@ -53,6 +53,10 @@ func (fc *FilterRate) Process(ctx context.Context, wrappedPayload common.Wrapped
 	return wrappedPayload, nil
 }

+func (fc *FilterRate) Id() string {
+	return fc.config.Id
+}
+
 func (fc *FilterRate) Type() string {
 	return fc.config.Type
 }
@@ -19,8 +19,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"pattern": {
-					Title: "Pattern",
-					Type:  "string",
+					Title:       "Pattern",
+					Description: "regex pattern to match against",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"pattern"},
@@ -68,6 +69,10 @@ func (fr *FilterRegex) Process(ctx context.Context, wrappedPayload common.Wrappe
 	return wrappedPayload, nil
 }

+func (fr *FilterRegex) Id() string {
+	return fr.config.Id
+}
+
 func (fr *FilterRegex) Type() string {
 	return fr.config.Type
 }
@@ -20,10 +20,11 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"bitSize": {
-					Title:   "Bit Size",
-					Type:    "integer",
-					Enum:    []any{32, 64},
-					Default: json.RawMessage("64"),
+					Title:       "Bit Size",
+					Description: "bit size of the resulting float",
+					Type:        "integer",
+					Enum:        []any{32, 64},
+					Default:     json.RawMessage("64"),
 				},
 			},
 			AdditionalProperties: &jsonschema.Schema{Not: &jsonschema.Schema{}},
@@ -67,6 +68,10 @@ func (fp *FloatParse) Process(ctx context.Context, wrappedPayload common.Wrapped
 	return wrappedPayload, nil
 }

+func (fp *FloatParse) Id() string {
+	return fp.config.Id
+}
+
 func (fp *FloatParse) Type() string {
 	return fp.config.Type
 }
@@ -20,18 +20,21 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"bitSize": {
-					Title:   "Bit Size",
-					Type:    "integer",
-					Enum:    []any{32, 64},
-					Default: json.RawMessage("32"),
+					Title:       "Bit Size",
+					Description: "bit size of the resulting float",
+					Type:        "integer",
+					Enum:        []any{32, 64},
+					Default:     json.RawMessage("32"),
 				},
 				"min": {
-					Title: "Minimum",
-					Type:  "number",
+					Title:       "Minimum",
+					Description: "inclusive minimum value of the random float",
+					Type:        "number",
 				},
 				"max": {
-					Title: "Maximum",
-					Type:  "number",
+					Title:       "Maximum",
+					Description: "exclusive maximum value of the random float",
+					Type:        "number",
 				},
 			},
 			Required:             []string{"min", "max"},
@@ -94,6 +97,10 @@ func (fr *FloatRandom) Process(ctx context.Context, wrappedPayload common.Wrappe
 	return wrappedPayload, errors.New("float.random bitSize error: must be 32 or 64")
 }

+func (fr *FloatRandom) Id() string {
+	return fr.config.Id
+}
+
 func (fr *FloatRandom) Type() string {
 	return fr.config.Type
 }
@@ -21,40 +21,49 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"id": {
-					Title: "Camera ID",
-					Type:  "string",
+					Title:       "Camera ID",
+					Description: "ID of the camera this FreeD position corresponds to",
+					Type:        "string",
 				},
 				"pan": {
-					Title: "Pan",
-					Type:  "string",
+					Title:       "Pan",
+					Description: "pan angle of the camera",
+					Type:        "string",
 				},
 				"tilt": {
-					Title: "Tilt",
-					Type:  "string",
+					Title:       "Tilt",
+					Description: "tilt angle of the camera",
+					Type:        "string",
 				},
 				"roll": {
-					Title: "Roll",
-					Type:  "string",
+					Title:       "Roll",
+					Description: "roll angle of the camera",
+					Type:        "string",
 				},
 				"posX": {
-					Title: "Position X",
-					Type:  "string",
+					Title:       "Position X",
+					Description: "X coordinate of the camera's position",
+					Type:        "string",
 				},
 				"posY": {
-					Title: "Position Y",
-					Type:  "string",
+					Title:       "Position Y",
+					Description: "Y coordinate of the camera's position",
+					Type:        "string",
 				},
 				"posZ": {
-					Title: "Position Z",
-					Type:  "string",
+					Title:       "Position Z",
+					Description: "Z coordinate of the camera's position",
+					Type:        "string",
 				},
 				"zoom": {
-					Title: "Zoom",
-					Type:  "string",
+					Title:       "Zoom",
+					Description: "zoom level of the camera",
+					Type:        "string",
 				},
 				"focus": {
-					Title: "Focus",
-					Type:  "string",
+					Title:       "Focus",
+					Description: "focus level of the camera",
+					Type:        "string",
 				},
 			},
 			Required: []string{
@@ -173,32 +182,32 @@ func init() {
 			}

 			return &FreeDCreate{
-				config: config,
-				Id:     idTemplate,
-				Pan:    panTemplate,
-				Tilt:   tiltTemplate,
-				Roll:   rollTemplate,
-				PosX:   posXTemplate,
-				PosY:   posYTemplate,
-				PosZ:   posZTemplate,
-				Zoom:   zoomTemplate,
-				Focus:  focusTemplate,
+				config:        config,
+				IdTemplate:    idTemplate,
+				PanTemplate:   panTemplate,
+				TiltTemplate:  tiltTemplate,
+				RollTemplate:  rollTemplate,
+				PosXTemplate:  posXTemplate,
+				PosYTemplate:  posYTemplate,
+				PosZTemplate:  posZTemplate,
+				ZoomTemplate:  zoomTemplate,
+				FocusTemplate: focusTemplate,
 			}, nil
 		},
 	})
 }

 type FreeDCreate struct {
-	config config.ProcessorConfig
-	Id     *template.Template
-	Pan    *template.Template
-	Tilt   *template.Template
-	Roll   *template.Template
-	PosX   *template.Template
-	PosY   *template.Template
-	PosZ   *template.Template
-	Zoom   *template.Template
-	Focus  *template.Template
+	config        config.ProcessorConfig
+	IdTemplate    *template.Template
+	PanTemplate   *template.Template
+	TiltTemplate  *template.Template
+	RollTemplate  *template.Template
+	PosXTemplate  *template.Template
+	PosYTemplate  *template.Template
+	PosZTemplate  *template.Template
+	ZoomTemplate  *template.Template
+	FocusTemplate *template.Template
 }

 func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
@@ -206,7 +215,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	templateData := wrappedPayload

 	var idBuffer bytes.Buffer
-	err := fc.Id.Execute(&idBuffer, templateData)
+	err := fc.IdTemplate.Execute(&idBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -223,7 +232,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	}

 	var panBuffer bytes.Buffer
-	err = fc.Pan.Execute(&panBuffer, templateData)
+	err = fc.PanTemplate.Execute(&panBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -240,7 +249,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	}

 	var tiltBuffer bytes.Buffer
-	err = fc.Tilt.Execute(&tiltBuffer, templateData)
+	err = fc.TiltTemplate.Execute(&tiltBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -257,7 +266,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	}

 	var rollBuffer bytes.Buffer
-	err = fc.Roll.Execute(&rollBuffer, templateData)
+	err = fc.RollTemplate.Execute(&rollBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -274,7 +283,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	}

 	var posXBuffer bytes.Buffer
-	err = fc.PosX.Execute(&posXBuffer, templateData)
+	err = fc.PosXTemplate.Execute(&posXBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -291,7 +300,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	}

 	var posYBuffer bytes.Buffer
-	err = fc.PosY.Execute(&posYBuffer, templateData)
+	err = fc.PosYTemplate.Execute(&posYBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -308,7 +317,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	}

 	var posZBuffer bytes.Buffer
-	err = fc.PosZ.Execute(&posZBuffer, templateData)
+	err = fc.PosZTemplate.Execute(&posZBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -325,7 +334,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	}

 	var zoomBuffer bytes.Buffer
-	err = fc.Zoom.Execute(&zoomBuffer, templateData)
+	err = fc.ZoomTemplate.Execute(&zoomBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -342,7 +351,7 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	}

 	var focusBuffer bytes.Buffer
-	err = fc.Focus.Execute(&focusBuffer, templateData)
+	err = fc.FocusTemplate.Execute(&focusBuffer, templateData)

 	if err != nil {
 		wrappedPayload.End = true
@@ -375,6 +384,10 @@ func (fc *FreeDCreate) Process(ctx context.Context, wrappedPayload common.Wrappe
 	return wrappedPayload, nil
 }

+func (fc *FreeDCreate) Id() string {
+	return fc.config.Id
+}
+
 func (fc *FreeDCreate) Type() string {
 	return fc.config.Type
 }
@@ -21,9 +21,9 @@ func init() {

 type FreeDDecode struct {
 	config config.ProcessorConfig
-	buf [29]byte
+	buf    [29]byte
 }
-	
+
 func (fd *FreeDDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
 	payload := wrappedPayload.Payload
 	payloadBytes, ok := common.GetAnyAsByteSlice(payload)
@@ -49,6 +49,10 @@ func (fd *FreeDDecode) Process(ctx context.Context, wrappedPayload common.Wrappe
 	return wrappedPayload, nil
 }

+func (fd *FreeDDecode) Id() string {
+	return fd.config.Id
+}
+
 func (fd *FreeDDecode) Type() string {
 	return fd.config.Type
 }
@@ -38,6 +38,10 @@ func (fe *FreeDEncode) Process(ctx context.Context, wrappedPayload common.Wrappe
 	return wrappedPayload, nil
 }

+func (fe *FreeDEncode) Id() string {
+	return fe.config.Id
+}
+
 func (fe *FreeDEncode) Type() string {
 	return fe.config.Type
 }
@@ -22,13 +22,15 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"method": {
-					Title: "HTTP Method",
-					Type:  "string",
-					Enum:  []any{"GET", "POST", "PUT", "PATCH", "DELETE"},
+					Title:       "HTTP Method",
+					Description: "method to use for the HTTP request",
+					Type:        "string",
+					Enum:        []any{"GET", "POST", "PUT", "PATCH", "DELETE"},
 				},
 				"url": {
-					Title: "URL",
-					Type:  "string",
+					Title:       "URL",
+					Description: "URL to send the HTTP request to",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"method", "url"},
@@ -112,6 +114,10 @@ func (hrd *HTTPRequestDo) Process(ctx context.Context, wrappedPayload common.Wra
 	return wrappedPayload, nil
 }

+func (hrd *HTTPRequestDo) Id() string {
+	return hrd.config.Id
+}
+
 func (hrd *HTTPRequestDo) Type() string {
 	return hrd.config.Type
 }
@@ -19,12 +19,14 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"status": {
-					Title: "Status Code",
-					Type:  "integer",
+					Title:       "Status Code",
+					Description: "status code to set on the response",
+					Type:        "integer",
 				},
 				"bodyTemplate": {
-					Title: "Body Template",
-					Type:  "string",
+					Title:       "Body Template",
+					Description: "template for the response body",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"status", "bodyTemplate"},
@@ -83,6 +85,10 @@ func (hrc *HTTPResponseCreate) Process(ctx context.Context, wrappedPayload commo
 	return wrappedPayload, nil
 }

+func (hrc *HTTPResponseCreate) Id() string {
+	return hrc.config.Id
+}
+
 func (hrc *HTTPResponseCreate) Type() string {
 	return hrc.config.Type
 }
@@ -20,16 +20,18 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"base": {
-					Title:   "Base",
-					Type:    "integer",
-					Enum:    []any{0, 2, 8, 10, 16},
-					Default: json.RawMessage("10"),
+					Title:       "Base",
+					Description: "numerical base to use for parsing the integer",
+					Type:        "integer",
+					Enum:        []any{0, 2, 8, 10, 16},
+					Default:     json.RawMessage("10"),
 				},
 				"bitSize": {
-					Title:   "Bit Size",
-					Type:    "integer",
-					Enum:    []any{0, 8, 16, 32, 64},
-					Default: json.RawMessage("64"),
+					Title:       "Bit Size",
+					Description: "bit size of the resulting integer",
+					Type:        "integer",
+					Enum:        []any{0, 8, 16, 32, 64},
+					Default:     json.RawMessage("64"),
 				},
 			},
 			AdditionalProperties: &jsonschema.Schema{Not: &jsonschema.Schema{}},
@@ -83,6 +85,10 @@ func (ip *IntParse) Process(ctx context.Context, wrappedPayload common.WrappedPa
 	return wrappedPayload, nil
 }

+func (ip *IntParse) Id() string {
+	return ip.config.Id
+}
+
 func (ip *IntParse) Type() string {
 	return ip.config.Type
 }
@@ -19,12 +19,14 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"min": {
-					Title: "Minimum",
-					Type:  "integer",
+					Title:       "Minimum",
+					Description: "inclusive minimum value of the random integer",
+					Type:        "integer",
 				},
 				"max": {
-					Title: "Maximum",
-					Type:  "integer",
+					Title:       "Maximum",
+					Description: "inclusive maximum value of the random integer",
+					Type:        "integer",
 				},
 			},
 			Required:             []string{"min", "max"},
@@ -64,6 +66,10 @@ func (ir *IntRandom) Process(ctx context.Context, wrappedPayload common.WrappedP
 	return wrappedPayload, nil
 }

+func (ir *IntRandom) Id() string {
+	return ir.config.Id
+}
+
 func (ir *IntRandom) Type() string {
 	return ir.config.Type
 }
@@ -18,20 +18,24 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"inMin": {
-					Title: "Input Minimum",
-					Type:  "integer",
+					Title:       "Input Minimum",
+					Description: "minimum value of the input integer",
+					Type:        "integer",
 				},
 				"inMax": {
-					Title: "Input Maximum",
-					Type:  "integer",
+					Title:       "Input Maximum",
+					Description: "maximum value of the input integer",
+					Type:        "integer",
 				},
 				"outMin": {
-					Title: "Output Minimum",
-					Type:  "integer",
+					Title:       "Output Minimum",
+					Description: "minimum value of the output integer",
+					Type:        "integer",
 				},
 				"outMax": {
-					Title: "Output Maximum",
-					Type:  "integer",
+					Title:       "Output Maximum",
+					Description: "maximum value of the output integer",
+					Type:        "integer",
 				},
 			},
 			Required:             []string{"inMin", "inMax", "outMin", "outMax"},
@@ -94,6 +98,10 @@ func (is *IntScale) Process(ctx context.Context, wrappedPayload common.WrappedPa
 	return wrappedPayload, nil
 }

+func (is *IntScale) Id() string {
+	return is.config.Id
+}
+
 func (is *IntScale) Type() string {
 	return is.config.Type
 }
@@ -50,6 +50,10 @@ func (jd *JsonDecode) Process(ctx context.Context, wrappedPayload common.Wrapped

 }

+func (jd *JsonDecode) Id() string {
+	return jd.config.Id
+}
+
 func (jd *JsonDecode) Type() string {
 	return jd.config.Type
 }
@@ -42,6 +42,10 @@ func (je *JsonEncode) Process(ctx context.Context, wrappedPayload common.Wrapped
 	return wrappedPayload, nil
 }

+func (je *JsonEncode) Id() string {
+	return je.config.Id
+}
+
 func (je *JsonEncode) Type() string {
 	return je.config.Type
 }
@@ -19,12 +19,14 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"module": {
-					Title: "Module ID",
-					Type:  "string",
+					Title:       "Module ID",
+					Description: "ID of the key-value module to get the value from",
+					Type:        "string",
 				},
 				"key": {
-					Title: "Key",
-					Type:  "string",
+					Title:       "Key",
+					Description: "key to retrieve from the key-value module",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"module", "key"},
@@ -87,6 +89,10 @@ func (kvg *KVGet) Process(ctx context.Context, wrappedPayload common.WrappedPayl
 	return wrappedPayload, nil
 }

+func (kvg *KVGet) Id() string {
+	return kvg.config.Id
+}
+
 func (kvg *KVGet) Type() string {
 	return kvg.config.Type
 }
@@ -19,12 +19,14 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"module": {
-					Title: "Module ID",
-					Type:  "string",
+					Title:       "Module ID",
+					Description: "ID of the key-value module to set the value in",
+					Type:        "string",
 				},
 				"key": {
-					Title: "Key",
-					Type:  "string",
+					Title:       "Key",
+					Description: "key to set in the key-value module",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"module", "key"},
@@ -87,6 +89,10 @@ func (kvs *KVSet) Process(ctx context.Context, wrappedPayload common.WrappedPayl
 	return wrappedPayload, nil
 }

+func (kvs *KVSet) Id() string {
+	return kvs.config.Id
+}
+
 func (kvs *KVSet) Type() string {
 	return kvs.config.Type
 }
@@ -23,16 +23,19 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"channel": {
-					Title: "Channel",
-					Type:  "string",
+					Title:       "Channel",
+					Description: "channel number for the control change message",
+					Type:        "string",
 				},
 				"control": {
-					Title: "Control",
-					Type:  "string",
+					Title:       "Control",
+					Description: "control number for the control change message",
+					Type:        "string",
 				},
 				"value": {
-					Title: "Value",
-					Type:  "string",
+					Title:       "Value",
+					Description: "value for the control change message",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"channel", "control", "value"},
@@ -144,6 +147,10 @@ func (mccc *MIDIControlChangeCreate) Process(ctx context.Context, wrappedPayload
 	return wrappedPayload, nil
 }

+func (mccc *MIDIControlChangeCreate) Id() string {
+	return mccc.config.Id
+}
+
 func (mccc *MIDIControlChangeCreate) Type() string {
 	return mccc.config.Type
 }
@@ -40,6 +40,10 @@ func (mmd *MIDIMessageDecode) Process(ctx context.Context, wrappedPayload common
 	return wrappedPayload, nil
 }

+func (mmd *MIDIMessageDecode) Id() string {
+	return mmd.config.Id
+}
+
 func (mmd *MIDIMessageDecode) Type() string {
 	return mmd.config.Type
 }
@@ -38,6 +38,10 @@ func (mme *MIDIMessageEncode) Process(ctx context.Context, wrappedPayload common
 	return wrappedPayload, nil
 }

+func (mme *MIDIMessageEncode) Id() string {
+	return mme.config.Id
+}
+
 func (mme *MIDIMessageEncode) Type() string {
 	return mme.config.Type
 }
@@ -96,6 +96,10 @@ func (mmu *MIDIMessageUnpack) Process(ctx context.Context, wrappedPayload common
 	}
 }

+func (mmu *MIDIMessageUnpack) Id() string {
+	return mmu.config.Id
+}
+
 func (mmu *MIDIMessageUnpack) Type() string {
 	return mmu.config.Type
 }
@@ -23,16 +23,19 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"channel": {
-					Title: "Channel",
-					Type:  "string",
+					Title:       "Channel",
+					Description: "channel number for the note off message",
+					Type:        "string",
 				},
 				"note": {
-					Title: "Note",
-					Type:  "string",
+					Title:       "Note",
+					Description: "note number for the note off message",
+					Type:        "string",
 				},
 				"velocity": {
-					Title: "Velocity",
-					Type:  "string",
+					Title:       "Velocity",
+					Description: "velocity for the note off message",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"channel", "note", "velocity"},
@@ -143,6 +146,10 @@ func (mnoc *MIDINoteOffCreate) Process(ctx context.Context, wrappedPayload commo
 	return wrappedPayload, nil
 }

+func (mnoc *MIDINoteOffCreate) Id() string {
+	return mnoc.config.Id
+}
+
 func (mnoc *MIDINoteOffCreate) Type() string {
 	return mnoc.config.Type
 }
@@ -23,16 +23,19 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"channel": {
-					Title: "Channel",
-					Type:  "string",
+					Title:       "Channel",
+					Description: "channel number for the note on message",
+					Type:        "string",
 				},
 				"note": {
-					Title: "Note",
-					Type:  "string",
+					Title:       "Note",
+					Description: "note number for the note on message",
+					Type:        "string",
 				},
 				"velocity": {
-					Title: "Velocity",
-					Type:  "string",
+					Title:       "Velocity",
+					Description: "velocity for the note on message",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"channel", "note", "velocity"},
@@ -142,6 +145,10 @@ func (mnoc *MIDINoteOnCreate) Process(ctx context.Context, wrappedPayload common
 	return wrappedPayload, nil
 }

+func (mnoc *MIDINoteOnCreate) Id() string {
+	return mnoc.config.Id
+}
+
 func (mnoc *MIDINoteOnCreate) Type() string {
 	return mnoc.config.Type
 }
@@ -23,12 +23,14 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"channel": {
-					Title: "Channel",
-					Type:  "string",
+					Title:       "Channel",
+					Description: "channel number for the program change message",
+					Type:        "string",
 				},
 				"program": {
-					Title: "Program",
-					Type:  "string",
+					Title:       "Program",
+					Description: "program number for the program change message",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"type", "channel", "program"},
@@ -111,6 +113,10 @@ func (mpcc *MIDIProgramChangeCreate) Process(ctx context.Context, wrappedPayload
 	return wrappedPayload, nil
 }

+func (mpcc *MIDIProgramChangeCreate) Id() string {
+	return mpcc.config.Id
+}
+
 func (mpcc *MIDIProgramChangeCreate) Type() string {
 	return mpcc.config.Type
 }
@@ -20,8 +20,8 @@ func init() {
 			Properties: map[string]*jsonschema.Schema{
 				"module": {
 					Title:       "Module ID",
-					Type:        "string",
 					Description: "ID of module to send output to",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"module"},
@@ -81,6 +81,10 @@ func (mo *ModuleOutput) Process(ctx context.Context, wrappedPayload common.Wrapp
 	return wrappedPayload, nil
 }

+func (mo *ModuleOutput) Id() string {
+	return mo.config.Id
+}
+
 func (mo *ModuleOutput) Type() string {
 	return mo.config.Type
 }
@@ -23,19 +23,22 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"address": {
-					Title: "Address",
-					Type:  "string",
+					Title:       "Address",
+					Description: "OSC address for the message",
+					Type:        "string",
 				},
 				"args": {
-					Title: "Arguments",
-					Type:  "array",
+					Title:       "Arguments",
+					Description: "arguments for the OSC message",
+					Type:        "array",
 					Items: &jsonschema.Schema{
 						Type: "string",
 					},
 				},
 				"types": {
-					Title: "Argument Types",
-					Type:  "string",
+					Title:       "Argument Types",
+					Description: "string of OSC types corresponding to the arguments in args",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"address"},
@@ -154,6 +157,10 @@ func (omc *OSCMessageCreate) Process(ctx context.Context, wrappedPayload common.
 	return wrappedPayload, nil
 }

+func (omc *OSCMessageCreate) Id() string {
+	return omc.config.Id
+}
+
 func (omc *OSCMessageCreate) Type() string {
 	return omc.config.Type
 }
@@ -52,6 +52,10 @@ func (omd *OSCMessageDecode) Process(ctx context.Context, wrappedPayload common.
 	return wrappedPayload, nil
 }

+func (omd *OSCMessageDecode) Id() string {
+	return omd.config.Id
+}
+
 func (omd *OSCMessageDecode) Type() string {
 	return omd.config.Type
 }
@@ -42,6 +42,10 @@ func (ome *OSCMessageEncode) Process(ctx context.Context, wrappedPayload common.
 	return wrappedPayload, nil
 }

+func (ome *OSCMessageEncode) Id() string {
+	return ome.config.Id
+}
+
 func (ome *OSCMessageEncode) Type() string {
 	return ome.config.Type
 }
@@ -11,6 +11,7 @@ import (
 )

 type Processor interface {
+	Id() string
 	Type() string
 	Process(context.Context, common.WrappedPayload) (common.WrappedPayload, error)
 }
@@ -35,7 +36,8 @@ func RegisterProcessor(processor ProcessorRegistration) {
 	processorRegistryMu.Lock()
 	defer processorRegistryMu.Unlock()

-	if _, ok := processorRegistry[string(processor.Type)]; ok {
+	_, exists := processorRegistry[string(processor.Type)]
+	if exists {
 		panic(fmt.Sprintf("processor already registered: %s", processor.Type))
 	}
 	processorRegistry[string(processor.Type)] = processor
@@ -22,13 +22,13 @@ func init() {
 			Properties: map[string]*jsonschema.Schema{
 				"module": {
 					Title:       "Module ID",
-					Type:        "string",
 					Description: "ID of the module to publish to",
+					Type:        "string",
 				},
 				"topic": {
 					Title:       "Topic",
+					Description: "topic to publish to",
 					Type:        "string",
-					Description: "Topic to publish to",
 				},
 			},
 			Required:             []string{"module", "topic"},
@@ -104,6 +104,10 @@ func (psp *PubSubPublish) Process(ctx context.Context, wrappedPayload common.Wra
 	return wrappedPayload, nil
 }

+func (psp *PubSubPublish) Id() string {
+	return psp.config.Id
+}
+
 func (psp *PubSubPublish) Type() string {
 	return psp.config.Type
 }
@@ -20,8 +20,8 @@ func init() {
 			Properties: map[string]*jsonschema.Schema{
 				"source": {
 					Title:       "Source",
-					Type:        "string",
 					Description: "source to report as to the router",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"source"},
@@ -68,6 +68,10 @@ func (ri *RouterInput) Process(ctx context.Context, wrappedPayload common.Wrappe
 	return wrappedPayload, nil
 }

+func (ri *RouterInput) Id() string {
+	return ri.config.Id
+}
+
 func (ri *RouterInput) Type() string {
 	return ri.config.Type
 }
@@ -25,8 +25,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"expression": {
-					Title: "Expression",
-					Type:  "string",
+					Title:       "Expression",
+					Description: "Expr expression to evaluate",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"expression"},
@@ -64,6 +65,10 @@ func (se *ScriptExpr) Process(ctx context.Context, wrappedPayload common.Wrapped
 	return wrappedPayload, nil
 }

+func (se *ScriptExpr) Id() string {
+	return se.config.Id
+}
+
 func (se *ScriptExpr) Type() string {
 	return se.config.Type
 }
@@ -18,8 +18,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"program": {
-					Title: "Program",
-					Type:  "string",
+					Title:       "Program",
+					Description: "JavaScript program to run",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"program"},
@@ -134,6 +135,10 @@ func (sj *ScriptJS) Process(ctx context.Context, wrappedPayload common.WrappedPa
 	return wrappedPayload, nil
 }

+func (sj *ScriptJS) Id() string {
+	return sj.config.Id
+}
+
 func (sj *ScriptJS) Type() string {
 	return sj.config.Type
 }
@@ -20,18 +20,21 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"path": {
-					Title: "Path",
-					Type:  "string",
+					Title:       "Path",
+					Description: "path to the WASM plugin to load",
+					Type:        "string",
 				},
 				"function": {
-					Title:   "Function",
-					Type:    "string",
-					Default: json.RawMessage(`"process"`),
+					Title:       "Function",
+					Description: "exported function to call on the WASM plugin",
+					Type:        "string",
+					Default:     json.RawMessage(`"process"`),
 				},
 				"enableWasi": {
-					Title:   "Enable WASI",
-					Type:    "boolean",
-					Default: json.RawMessage("false"),
+					Title:       "Enable WASI",
+					Description: "whether to enable WASI when running the WASM plugin",
+					Type:        "boolean",
+					Default:     json.RawMessage("false"),
 				},
 			},
 			Required:             []string{"path"},
@@ -117,6 +120,10 @@ func (sw *ScriptWASM) Process(ctx context.Context, wrappedPayload common.Wrapped
 	return wrappedPayload, nil
 }

+func (sw *ScriptWASM) Id() string {
+	return sw.config.Id
+}
+
 func (sw *ScriptWASM) Type() string {
 	return sw.config.Type
 }
@@ -19,15 +19,19 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"preWait": {
-					Title: "Pre Wait (ms)",
-					Type:  "integer",
-				},
-				"postWait": {
-					Title: "Post Wait (ms)",
-					Type:  "integer",
+					Title:       "Pre Wait (ms)",
+					Description: "number of milliseconds to wait before playing the audio",
+					Type:        "integer",
 				},
 				"audioFile": {
-					Type: "string",
+					Title:       "Audio File",
+					Description: "path to the audio file to play",
+					Type:        "string",
+				},
+				"postWait": {
+					Title:       "Post Wait (ms)",
+					Description: "number of milliseconds to wait after playing the audio",
+					Type:        "integer",
 				},
 			},
 			Required:             []string{"preWait", "postWait", "audioFile"},
@@ -96,6 +100,10 @@ func (srac *SipResponseAudioCreate) Process(ctx context.Context, wrappedPayload
 	return wrappedPayload, nil
 }

+func (srac *SipResponseAudioCreate) Id() string {
+	return srac.config.Id
+}
+
 func (srac *SipResponseAudioCreate) Type() string {
 	return srac.config.Type
 }
@@ -21,15 +21,19 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"preWait": {
-					Title: "Pre Wait (ms)",
-					Type:  "integer",
-				},
-				"postWait": {
-					Title: "Post Wait (ms)",
-					Type:  "integer",
+					Title:       "Pre Wait (ms)",
+					Description: "number of milliseconds to wait before sending the DTMF tones",
+					Type:        "integer",
 				},
 				"digits": {
-					Type: "string",
+					Title:       "Digits",
+					Description: "DTMF digits to send",
+					Type:        "string",
+				},
+				"postWait": {
+					Title:       "Post Wait (ms)",
+					Description: "number of milliseconds to wait after sending the DTMF tones",
+					Type:        "integer",
 				},
 			},
 			Required:             []string{"preWait", "postWait", "digits"},
@@ -106,6 +110,10 @@ func (srdc *SipResponseDTMFCreate) Process(ctx context.Context, wrappedPayload c
 	return wrappedPayload, nil
 }

+func (srdc *SipResponseDTMFCreate) Id() string {
+	return srdc.config.Id
+}
+
 func (srdc *SipResponseDTMFCreate) Type() string {
 	return srdc.config.Type
 }
@@ -19,8 +19,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"template": {
-					Title: "Template",
-					Type:  "string",
+					Title:       "Template",
+					Description: "template to evaluate",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"template"},
@@ -64,6 +65,10 @@ func (sc *StringCreate) Process(ctx context.Context, wrappedPayload common.Wrapp
 	return wrappedPayload, nil
 }

+func (sc *StringCreate) Id() string {
+	return sc.config.Id
+}
+
 func (sc *StringCreate) Type() string {
 	return sc.config.Type
 }
@@ -37,6 +37,10 @@ func (sd *StringDecode) Process(ctx context.Context, wrappedPayload common.Wrapp
 	return wrappedPayload, nil
 }

+func (sd *StringDecode) Id() string {
+	return sd.config.Id
+}
+
 func (sd *StringDecode) Type() string {
 	return sd.config.Type
 }
@@ -36,6 +36,10 @@ func (se *StringEncode) Process(ctx context.Context, wrappedPayload common.Wrapp
 	return wrappedPayload, nil
 }

+func (se *StringEncode) Id() string {
+	return se.config.Id
+}
+
 func (se *StringEncode) Type() string {
 	return se.config.Type
 }
@@ -19,8 +19,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"separator": {
-					Title: "Separator",
-					Type:  "string",
+					Title:       "Separator",
+					Description: "separator to split the string on",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"separator"},
@@ -58,6 +59,10 @@ func (ss *StringSplit) Process(ctx context.Context, wrappedPayload common.Wrappe
 	return wrappedPayload, nil
 }

+func (ss *StringSplit) Id() string {
+	return ss.config.Id
+}
+
 func (ss *StringSplit) Type() string {
 	return ss.config.Type
 }
@@ -19,8 +19,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"name": {
-					Title: "Field Name",
-					Type:  "string",
+					Title:       "Field Name",
+					Description: "name of the struct field to extract",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"name"},
@@ -66,6 +67,10 @@ func (sfg *StructFieldGet) Process(ctx context.Context, wrappedPayload common.Wr
 	return wrappedPayload, nil
 }

+func (sfg *StructFieldGet) Id() string {
+	return sfg.config.Id
+}
+
 func (sfg *StructFieldGet) Type() string {
 	return sfg.config.Type
 }
@@ -19,8 +19,9 @@ func init() {
 			Type: "object",
 			Properties: map[string]*jsonschema.Schema{
 				"name": {
-					Title: "Method Name",
-					Type:  "string",
+					Title:       "Method Name",
+					Description: "name of the struct method to extract and call (with no arguments)",
+					Type:        "string",
 				},
 			},
 			Required:             []string{"name"},
@@ -85,6 +86,10 @@ func (smg *StructMethodGet) Process(ctx context.Context, wrappedPayload common.W
 	return wrappedPayload, nil
 }

+func (smg *StructMethodGet) Id() string {
+	return smg.config.Id
+}
+
 func (smg *StructMethodGet) Type() string {
 	return smg.config.Type
 }
@@ -17,6 +17,7 @@ func TestArtnetPacketDecodeFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "artnet.packet.decode",
 	})

@@ -24,6 +25,10 @@ func TestArtnetPacketDecodeFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create artnet.packet.decode processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("artnet.packet.decode processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "artnet.packet.decode" {
 		t.Fatalf("artnet.packet.decode processor has wrong type: %s", processorInstance.Type())
 	}
@@ -17,6 +17,7 @@ func TestArtnetPacketEncodeFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "artnet.packet.encode",
 	})

@@ -24,6 +25,10 @@ func TestArtnetPacketEncodeFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create artnet.packet.encode processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("artnet.packet.encode processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "artnet.packet.encode" {
 		t.Fatalf("artnet.packet.encode processor has wrong type: %s", processorInstance.Type())
 	}
@@ -18,6 +18,7 @@ func TestDbQueryFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "db.query",
 		Params: map[string]any{
 			"module": "test",
@@ -28,6 +29,10 @@ func TestDbQueryFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create db.query processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("db.query processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "db.query" {
 		t.Fatalf("db.query processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,6 +16,7 @@ func TestDebugLogFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "debug.log",
 	})

@@ -23,6 +24,10 @@ func TestDebugLogFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create debug.log processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("debug.log processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "debug.log" {
 		t.Fatalf("debug.log processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,12 +16,17 @@ func TestFilterChangeFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "filter.change",
 	})
 	if err != nil {
 		t.Fatalf("failed to create filter.change processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("filter.change processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "filter.change" {
 		t.Fatalf("filter.change processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,6 +16,7 @@ func TestFilterExprFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "filter.expr",
 		Params: map[string]any{
 			"expression": "foo + bar",
@@ -25,6 +26,10 @@ func TestFilterExprFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create filter.expr processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("filter.expr processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "filter.expr" {
 		t.Fatalf("filter.expr processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,6 +16,7 @@ func TestFilterRateFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "filter.rate",
 		Params: map[string]any{
 			"rate": 1,
@@ -25,6 +26,10 @@ func TestFilterRateFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create filter.rate processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("filter.rate processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "filter.rate" {
 		t.Fatalf("filter.rate processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,6 +16,7 @@ func TestFilterRegexFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "filter.regex",
 		Params: map[string]any{
 			"pattern": "hello",
@@ -25,6 +26,10 @@ func TestFilterRegexFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create filter.regex processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("filter.regex processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "filter.regex" {
 		t.Fatalf("filter.regex processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,6 +16,7 @@ func TestFloatParseFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "float.parse",
 	})

@@ -23,6 +24,9 @@ func TestFloatParseFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create float.parse processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("float.parse processor has wrong id: %s", processorInstance.Id())
+	}
 	if processorInstance.Type() != "float.parse" {
 		t.Fatalf("float.parse processor has wrong type: %s", processorInstance.Type())
 	}
@@ -15,6 +15,7 @@ func TestFloatRandomFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "float.random",
 		Params: map[string]any{
 			"min": 1.0,
@@ -26,6 +27,10 @@ func TestFloatRandomFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create float.random processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("float.random processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "float.random" {
 		t.Fatalf("float.random processor has wrong type: %s", processorInstance.Type())
 	}
@@ -17,6 +17,7 @@ func TestFreeDCreateFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "freed.create",
 		Params: map[string]any{
 			"id":    "0",
@@ -35,6 +36,10 @@ func TestFreeDCreateFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create freed.create processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("freed.create processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "freed.create" {
 		t.Fatalf("freed.create processor has wrong type: %s", processorInstance.Type())
 	}
@@ -17,6 +17,7 @@ func TestFreeDDecodeFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "freed.decode",
 	})

@@ -24,6 +25,10 @@ func TestFreeDDecodeFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create freed.decode processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("freed.decode processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "freed.decode" {
 		t.Fatalf("freed.decode processor has wrong type: %s", processorInstance.Type())
 	}
@@ -17,6 +17,7 @@ func TestFreeDEncodeFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "freed.encode",
 	})

@@ -24,6 +25,10 @@ func TestFreeDEncodeFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create freed.encode processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("freed.encode processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "freed.encode" {
 		t.Fatalf("freed.encode processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,6 +16,7 @@ func TestHTTPRequestCreateFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "http.request.do",
 		Params: map[string]any{
 			"method": "GET",
@@ -27,6 +28,10 @@ func TestHTTPRequestCreateFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create http.request.do processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("http.request.do processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "http.request.do" {
 		t.Fatalf("http.request.do processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,6 +16,7 @@ func TestHTTPResponseCreateFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "http.response.create",
 		Params: map[string]any{
 			"status":       200,
@@ -27,6 +28,10 @@ func TestHTTPResponseCreateFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create http.response.create processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("http.response.create processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "http.response.create" {
 		t.Fatalf("http.response.create processor has wrong type: %s", processorInstance.Type())
 	}
@@ -16,6 +16,7 @@ func TestIntParseFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "int.parse",
 	})

@@ -23,6 +24,10 @@ func TestIntParseFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create int.parse processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("int.parse processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "int.parse" {
 		t.Fatalf("int.parse processor has wrong type: %s", processorInstance.Type())
 	}
@@ -15,6 +15,7 @@ func TestIntRandomFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "int.random",
 		Params: map[string]any{
 			"min": 1,
@@ -26,6 +27,10 @@ func TestIntRandomFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create int.random processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("int.random processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "int.random" {
 		t.Fatalf("int.random processor has wrong type: %s", processorInstance.Type())
 	}
@@ -15,6 +15,7 @@ func TestIntScaleFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "int.scale",
 		Params: map[string]any{
 			"inMin":  0,
@@ -28,6 +29,10 @@ func TestIntScaleFromRegistry(t *testing.T) {
 		t.Fatalf("failed to create int.scale processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("int.scale processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "int.scale" {
 		t.Fatalf("int.scale processor has wrong type: %s", processorInstance.Type())
 	}
@@ -17,12 +17,17 @@ func TestJsonDecodeFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "json.decode",
 	})
 	if err != nil {
 		t.Fatalf("failed to create json.decode processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("json.decode processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "json.decode" {
 		t.Fatalf("json.decode processor has wrong type: %s", processorInstance.Type())
 	}
@@ -18,12 +18,17 @@ func TestJsonEncodeFromRegistry(t *testing.T) {
 	}

 	processorInstance, err := registration.New(config.ProcessorConfig{
+		Id:   "test-id",
 		Type: "json.encode",
 	})
 	if err != nil {
 		t.Fatalf("failed to create json.encode processor: %s", err)
 	}

+	if processorInstance.Id() != "test-id" {
+		t.Fatalf("json.encode processor has wrong id: %s", processorInstance.Id())
+	}
+
 	if processorInstance.Type() != "json.encode" {
 		t.Fatalf("json.encode processor has wrong type: %s", processorInstance.Type())
 	}
--- a/Show More
+++ b/Show More