From 0cb13a30f9a18df4639e7dfb773111861dd8811f Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Wed, 4 Feb 2026 18:30:41 -0600 Subject: [PATCH] add test for int.random processor --- internal/processor/int-random_test.go | 103 ++++++++++++++++++++++++++ 1 file changed, 103 insertions(+) create mode 100644 internal/processor/int-random_test.go diff --git a/internal/processor/int-random_test.go b/internal/processor/int-random_test.go new file mode 100644 index 0000000..b29c51f --- /dev/null +++ b/internal/processor/int-random_test.go @@ -0,0 +1,103 @@ +package processor_test + +import ( + "testing" + + "github.com/jwetzell/showbridge-go/internal/config" + "github.com/jwetzell/showbridge-go/internal/processor" +) + +func TestIntRandomFromRegistry(t *testing.T) { + registration, ok := processor.ProcessorRegistry["int.random"] + if !ok { + t.Fatalf("int.random processor not registered") + } + + processorInstance, err := registration.New(config.ProcessorConfig{ + Type: "int.random", + Params: map[string]any{ + "min": 1.0, + "max": 10.0, + }, + }) + + if err != nil { + t.Fatalf("failed to create int.random processor: %s", err) + } + + if processorInstance.Type() != "int.random" { + t.Fatalf("int.random processor has wrong type: %s", processorInstance.Type()) + } +} + +func TestIntRandomGoodConfig(t *testing.T) { + registration, ok := processor.ProcessorRegistry["int.random"] + if !ok { + t.Fatalf("int.random processor not registered") + } + + processorInstance, err := registration.New(config.ProcessorConfig{ + Type: "int.random", + Params: map[string]any{ + "min": 1.0, + "max": 10.0, + }, + }) + + if err != nil { + t.Fatalf("int.random should have created processor but got error: %s", err) + } + + payload := "12345" + + got, err := processorInstance.Process(t.Context(), payload) + if err != nil { + t.Fatalf("int.random processing failed: %s", err) + } + + gotInt, ok := got.(int) + if !ok { + t.Fatalf("int.random returned a %T payload: %s", got, got) + } + + if gotInt < 1 || gotInt > 10 { + t.Fatalf("int.random got %d, expected between %d and %d", gotInt, 1, 10) + } +} + +func TestGoodIntRandom(t *testing.T) { + tests := []struct { + processor processor.Processor + name string + payload any + min int + max int + }{ + { + name: "1-10", + payload: "12345", + min: 1, + max: 10, + }, + } + + for _, test := range tests { + t.Run(test.name, func(t *testing.T) { + intRandom := processor.IntRandom{ + Min: test.min, + Max: test.max, + } + got, err := intRandom.Process(t.Context(), test.payload) + gotInt, ok := got.(int) + if !ok { + t.Fatalf("int.random returned a %T payload: %s", got, got) + } + if err != nil { + t.Fatalf("int.random failed: %s", err) + } + if gotInt < test.min || gotInt > test.max { + t.Fatalf("int.random got %d, expected between %d and %d", gotInt, test.min, test.max) + } + }) + } +}