From 0248ca6973ffb509fdfb6456fb65a5f7fb29ad27 Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Sun, 28 Dec 2025 16:17:56 -0600 Subject: [PATCH 1/3] add processor to encode json bytes --- internal/processor/json-encode.go | 38 +++++++++++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 internal/processor/json-encode.go diff --git a/internal/processor/json-encode.go b/internal/processor/json-encode.go new file mode 100644 index 0000000..5036a39 --- /dev/null +++ b/internal/processor/json-encode.go @@ -0,0 +1,38 @@ +package processor + +import ( + "bytes" + "context" + "encoding/json" + + "github.com/jwetzell/showbridge-go/internal/config" +) + +type JsonEncode struct { + config config.ProcessorConfig +} + +func (je *JsonEncode) Process(ctx context.Context, payload any) (any, error) { + var payloadBuffer bytes.Buffer + + err := json.NewEncoder(&payloadBuffer).Encode(payload) + + if err != nil { + return nil, err + } + + return payloadBuffer.Bytes(), nil +} + +func (je *JsonEncode) Type() string { + return je.config.Type +} + +func init() { + RegisterProcessor(ProcessorRegistration{ + Type: "json.encode", + New: func(config config.ProcessorConfig) (Processor, error) { + return &JsonEncode{config: config}, nil + }, + }) +} From 70f4636522d4c66712a37a364f6d0d1bb731cf4f Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Sun, 28 Dec 2025 16:25:57 -0600 Subject: [PATCH 2/3] add test for json.encode --- internal/processor/json-encode_test.go | 45 ++++++++++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 internal/processor/json-encode_test.go diff --git a/internal/processor/json-encode_test.go b/internal/processor/json-encode_test.go new file mode 100644 index 0000000..501f0c4 --- /dev/null +++ b/internal/processor/json-encode_test.go @@ -0,0 +1,45 @@ +package processor_test + +import ( + "slices" + "testing" + + "github.com/jwetzell/osc-go" + "github.com/jwetzell/showbridge-go/internal/processor" +) + +func TestGoodJsonEncode(t *testing.T) { + stringEncoder := processor.JsonEncode{} + tests := []struct { + processor processor.Processor + name string + payload any + expected []byte + }{ + { + processor: &stringEncoder, + name: "hello", + payload: osc.OSCMessage{ + Address: "/hello", + }, + expected: []byte("{\"address\":\"/hello\",\"args\":null}"), + }, + } + + for _, test := range tests { + t.Run(test.name, func(t *testing.T) { + got, err := test.processor.Process(t.Context(), test.payload) + + gotBytes, ok := got.([]byte) + if !ok { + t.Fatalf("json.encode returned a %T payload: %s", got, got) + } + if err != nil { + t.Fatalf("json.encode failed: %s", err) + } + if !slices.Equal(gotBytes, test.expected) { + t.Fatalf("json.encode got %x, expected %s", got, test.expected) + } + }) + } +} From 477d70fad0d1b71afc2f1e8c3a140a5a8296ca4d Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Sun, 28 Dec 2025 16:26:11 -0600 Subject: [PATCH 3/3] remove last byte in json.encode because of new line --- internal/processor/json-encode.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/processor/json-encode.go b/internal/processor/json-encode.go index 5036a39..acfd12f 100644 --- a/internal/processor/json-encode.go +++ b/internal/processor/json-encode.go @@ -21,7 +21,11 @@ func (je *JsonEncode) Process(ctx context.Context, payload any) (any, error) { return nil, err } - return payloadBuffer.Bytes(), nil + payloadBytes := payloadBuffer.Bytes() + + payloadBytes = payloadBytes[0 : len(payloadBytes)-1] + + return payloadBytes, nil } func (je *JsonEncode) Type() string {