From bcf929950518e727aa102ddaf185ae6f4a78df05 Mon Sep 17 00:00:00 2001
From: Joel Wetzell <git@jwetzell.com>
Date: Sun, 1 Mar 2026 13:03:26 -0600
Subject: [PATCH] remove nats message encode

---
 internal/processor/nats-message-encode.go     | 36 -------------------
 .../test/nats-message-encode_test.go          | 27 --------------
 schema/processors.schema.json                 | 11 ------
 3 files changed, 74 deletions(-)
 delete mode 100644 internal/processor/nats-message-encode.go
 delete mode 100644 internal/processor/test/nats-message-encode_test.go

diff --git a/internal/processor/nats-message-encode.go b/internal/processor/nats-message-encode.go
deleted file mode 100644
index 8494866..0000000
--- a/internal/processor/nats-message-encode.go
+++ /dev/null
@@ -1,36 +0,0 @@
-package processor
-
-import (
-	"context"
-	"errors"
-
-	"github.com/jwetzell/showbridge-go/internal/config"
-	"github.com/nats-io/nats.go"
-)
-
-type NATSMessageEncode struct {
-	config config.ProcessorConfig
-}
-
-func (nme *NATSMessageEncode) Process(ctx context.Context, payload any) (any, error) {
-	payloadMessage, ok := payload.(*nats.Msg)
-
-	if !ok {
-		return nil, errors.New("nats.message.encode processor only accepts a nats.Msg")
-	}
-
-	return payloadMessage.Data, nil
-}
-
-func (nme *NATSMessageEncode) Type() string {
-	return nme.config.Type
-}
-
-func init() {
-	RegisterProcessor(ProcessorRegistration{
-		Type: "nats.message.encode",
-		New: func(config config.ProcessorConfig) (Processor, error) {
-			return &NATSMessageEncode{config: config}, nil
-		},
-	})
-}
diff --git a/internal/processor/test/nats-message-encode_test.go b/internal/processor/test/nats-message-encode_test.go
deleted file mode 100644
index 94a5cf7..0000000
--- a/internal/processor/test/nats-message-encode_test.go
+++ /dev/null
@@ -1,27 +0,0 @@
-package processor_test
-
-import (
-	"testing"
-
-	"github.com/jwetzell/showbridge-go/internal/config"
-	"github.com/jwetzell/showbridge-go/internal/processor"
-)
-
-func TestNATSMessageEncodeFromRegistry(t *testing.T) {
-	registration, ok := processor.ProcessorRegistry["nats.message.encode"]
-	if !ok {
-		t.Fatalf("nats.message.encode processor not registered")
-	}
-
-	processorInstance, err := registration.New(config.ProcessorConfig{
-		Type: "nats.message.encode",
-	})
-
-	if err != nil {
-		t.Fatalf("failed to create nats.message.encode processor: %s", err)
-	}
-
-	if processorInstance.Type() != "nats.message.encode" {
-		t.Fatalf("nats.message.encode processor has wrong type: %s", processorInstance.Type())
-	}
-}
diff --git a/schema/processors.schema.json b/schema/processors.schema.json
index 58c13f5..5e2cbe2 100644
--- a/schema/processors.schema.json
+++ b/schema/processors.schema.json
@@ -514,17 +514,6 @@
         "required": ["type", "params"],
         "additionalProperties": false
       },
-      {
-        "type": "object",
-        "properties": {
-          "type": {
-            "type": "string",
-            "const": "nats.message.encode"
-          }
-        },
-        "required": ["type"],
-        "additionalProperties": false
-      },
       {
         "type": "object",
         "properties": {