diff --git a/internal/processor/test/processor_test.go b/internal/processor/test/processor_test.go index 0aa0fb7..71dbfdc 100644 --- a/internal/processor/test/processor_test.go +++ b/internal/processor/test/processor_test.go @@ -53,3 +53,20 @@ func TestProcessorBadRegistrationExistingType(t *testing.T) { }, }) } + +func TestTestProcessor(t *testing.T) { + testProcessor := &test.TestProcessor{ + Config: config.ProcessorConfig{ + Id: "test-id", + Type: "test", + }, + } + + if testProcessor.Id() != "test-id" { + t.Fatalf("test processor has wrong id: %s", testProcessor.Id()) + } + + if testProcessor.Type() != "test" { + t.Fatalf("test processor has wrong type: %s", testProcessor.Type()) + } +} diff --git a/internal/test/processor.go b/internal/test/processor.go index f017020..fc38462 100644 --- a/internal/test/processor.go +++ b/internal/test/processor.go @@ -4,17 +4,19 @@ import ( "context" "github.com/jwetzell/showbridge-go/internal/common" + "github.com/jwetzell/showbridge-go/internal/config" ) type TestProcessor struct { + Config config.ProcessorConfig } func (p *TestProcessor) Id() string { - return "test-id" + return p.Config.Id } func (p *TestProcessor) Type() string { - return "test" + return p.Config.Type } func (p *TestProcessor) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { return wrappedPayload, nil