From 05b0de1dfde0360360b7567e9300d4a4a7d0305b Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Sun, 1 Mar 2026 23:02:56 -0600 Subject: [PATCH] remote http request/response encoding --- internal/processor/http-request-encode.go | 42 ------------------ internal/processor/http-response-encode.go | 43 ------------------- .../test/http-request-encode_test.go | 27 ------------ .../test/http-response-encode_test.go | 27 ------------ schema/processors.schema.json | 24 ----------- 5 files changed, 163 deletions(-) delete mode 100644 internal/processor/http-request-encode.go delete mode 100644 internal/processor/http-response-encode.go delete mode 100644 internal/processor/test/http-request-encode_test.go delete mode 100644 internal/processor/test/http-response-encode_test.go diff --git a/internal/processor/http-request-encode.go b/internal/processor/http-request-encode.go deleted file mode 100644 index 0fd503d..0000000 --- a/internal/processor/http-request-encode.go +++ /dev/null @@ -1,42 +0,0 @@ -package processor - -import ( - "context" - "errors" - "io" - "net/http" - - "github.com/jwetzell/showbridge-go/internal/config" -) - -type HTTPRequestEncode struct { - config config.ProcessorConfig -} - -func (hre *HTTPRequestEncode) Process(ctx context.Context, payload any) (any, error) { - payloadRequest, ok := payload.(*http.Request) - - if !ok { - return nil, errors.New("http.request.encode processor only accepts an http.Request") - } - - bytes, err := io.ReadAll(payloadRequest.Body) - if err != nil { - return nil, err - } - - return bytes, nil -} - -func (hre *HTTPRequestEncode) Type() string { - return hre.config.Type -} - -func init() { - RegisterProcessor(ProcessorRegistration{ - Type: "http.request.encode", - New: func(config config.ProcessorConfig) (Processor, error) { - return &HTTPRequestEncode{config: config}, nil - }, - }) -} diff --git a/internal/processor/http-response-encode.go b/internal/processor/http-response-encode.go deleted file mode 100644 index ea5973b..0000000 --- a/internal/processor/http-response-encode.go +++ /dev/null @@ -1,43 +0,0 @@ -package processor - -import ( - "context" - "errors" - "io" - "net/http" - - "github.com/jwetzell/showbridge-go/internal/config" -) - -type HTTPResponseEncode struct { - config config.ProcessorConfig -} - -func (hre *HTTPResponseEncode) Process(ctx context.Context, payload any) (any, error) { - payloadResponse, ok := payload.(*http.Response) - - if !ok { - return nil, errors.New("http.response.encode processor only accepts an http.Response") - } - defer payloadResponse.Body.Close() - - bytes, err := io.ReadAll(payloadResponse.Body) - if err != nil { - return nil, err - } - - return bytes, nil -} - -func (hre *HTTPResponseEncode) Type() string { - return hre.config.Type -} - -func init() { - RegisterProcessor(ProcessorRegistration{ - Type: "http.response.encode", - New: func(config config.ProcessorConfig) (Processor, error) { - return &HTTPResponseEncode{config: config}, nil - }, - }) -} diff --git a/internal/processor/test/http-request-encode_test.go b/internal/processor/test/http-request-encode_test.go deleted file mode 100644 index 4a5328b..0000000 --- a/internal/processor/test/http-request-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 TestHTTPRequestEncodeFromRegistry(t *testing.T) { - registration, ok := processor.ProcessorRegistry["http.request.encode"] - if !ok { - t.Fatalf("http.request.encode processor not registered") - } - - processorInstance, err := registration.New(config.ProcessorConfig{ - Type: "http.request.encode", - }) - - if err != nil { - t.Fatalf("failed to create http.request.encode processor: %s", err) - } - - if processorInstance.Type() != "http.request.encode" { - t.Fatalf("http.request.encode processor has wrong type: %s", processorInstance.Type()) - } -} diff --git a/internal/processor/test/http-response-encode_test.go b/internal/processor/test/http-response-encode_test.go deleted file mode 100644 index c078d50..0000000 --- a/internal/processor/test/http-response-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 TestHTTPResponseEncodeFromRegistry(t *testing.T) { - registration, ok := processor.ProcessorRegistry["http.response.encode"] - if !ok { - t.Fatalf("http.response.encode processor not registered") - } - - processorInstance, err := registration.New(config.ProcessorConfig{ - Type: "http.response.encode", - }) - - if err != nil { - t.Fatalf("failed to create http.response.encode processor: %s", err) - } - - if processorInstance.Type() != "http.response.encode" { - t.Fatalf("http.response.encode processor has wrong type: %s", processorInstance.Type()) - } -} diff --git a/schema/processors.schema.json b/schema/processors.schema.json index fbbd7b3..41eeb3f 100644 --- a/schema/processors.schema.json +++ b/schema/processors.schema.json @@ -182,18 +182,6 @@ "required": ["type", "params"], "additionalProperties": false }, - { - "type": "object", - "title": "Encode HTTP Request", - "properties": { - "type": { - "type": "string", - "const": "http.request.encode" - } - }, - "required": ["type"], - "additionalProperties": false - }, { "type": "object", "title": "Filter HTTP Request", @@ -245,18 +233,6 @@ "required": ["type", "params"], "additionalProperties": false }, - { - "type": "object", - "title": "Encode HTTP Response", - "properties": { - "type": { - "type": "string", - "const": "http.response.encode" - } - }, - "required": ["type"], - "additionalProperties": false - }, { "type": "object", "title": "Parse Int",