From 4c7dd1b4d8396f38f02146e19bfe74a8bb605a93 Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Mon, 23 Mar 2026 10:16:17 -0500 Subject: [PATCH] rename filter.unique to filter.change --- .../{filter-unique.go => filter-change.go} | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) rename internal/processor/{filter-unique.go => filter-change.go} (64%) diff --git a/internal/processor/filter-unique.go b/internal/processor/filter-change.go similarity index 64% rename from internal/processor/filter-unique.go rename to internal/processor/filter-change.go index a4b1405..8e36896 100644 --- a/internal/processor/filter-unique.go +++ b/internal/processor/filter-change.go @@ -8,32 +8,32 @@ import ( "github.com/jwetzell/showbridge-go/internal/config" ) -type FilterUnique struct { +type FilterChange struct { config config.ProcessorConfig previous any } -func (fr *FilterUnique) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { +func (fc *FilterChange) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { payload := wrappedPayload.Payload - if reflect.DeepEqual(payload, fr.previous) { + if reflect.DeepEqual(payload, fc.previous) { wrappedPayload.End = true return wrappedPayload, nil } - fr.previous = payload + fc.previous = payload return wrappedPayload, nil } -func (fr *FilterUnique) Type() string { - return fr.config.Type +func (fc *FilterChange) Type() string { + return fc.config.Type } func init() { RegisterProcessor(ProcessorRegistration{ - Type: "filter.unique", + Type: "filter.change", New: func(config config.ProcessorConfig) (Processor, error) { - return &FilterUnique{config: config}, nil + return &FilterChange{config: config}, nil }, }) }