backup/showbridge-go
1
0
Fork 0
mirror of https://github.com/jwetzell/showbridge-go.git synced 2026-04-26 21:05:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename filter.unique to filter.change

Browse Source
This commit is contained in:
Joel Wetzell
2026-03-23 10:16:17 -05:00
parent 2fe2250a57
commit 4c7dd1b4d8
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
internal/processor/filter-unique.go → internal/processor/filter-change.go
View File

@@ -8,32 +8,32 @@ import (
"github.com/jwetzell/showbridge-go/internal/config" "github.com/jwetzell/showbridge-go/internal/config"
) )
type FilterUnique struct { type FilterChange struct {
config config.ProcessorConfig config config.ProcessorConfig
previous any 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 payload := wrappedPayload.Payload
if reflect.DeepEqual(payload, fr.previous) { if reflect.DeepEqual(payload, fc.previous) {
wrappedPayload.End = true wrappedPayload.End = true
return wrappedPayload, nil return wrappedPayload, nil
} }
fr.previous = payload fc.previous = payload
return wrappedPayload, nil return wrappedPayload, nil
} }
func (fr *FilterUnique) Type() string { func (fc *FilterChange) Type() string {
return fr.config.Type return fc.config.Type
} }
func init() { func init() {
RegisterProcessor(ProcessorRegistration{ RegisterProcessor(ProcessorRegistration{
Type: "filter.unique", Type: "filter.change",
New: func(config config.ProcessorConfig) (Processor, error) { New: func(config config.ProcessorConfig) (Processor, error) {
return &FilterUnique{config: config}, nil return &FilterChange{config: config}, nil
}, },
}) })
} }