From 58cb7766fe9c3b9296cfe9ed040ccf669ac3a106 Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Wed, 24 Dec 2025 15:28:25 -0600 Subject: [PATCH] change namespace --- .../{artnet-decode.go => artnet-packet-decode.go} | 14 +++++++------- .../{artnet-encode.go => artnet-packet-encode.go} | 14 +++++++------- 2 files changed, 14 insertions(+), 14 deletions(-) rename internal/processor/{artnet-decode.go => artnet-packet-decode.go} (57%) rename internal/processor/{artnet-encode.go => artnet-packet-encode.go} (57%) diff --git a/internal/processor/artnet-decode.go b/internal/processor/artnet-packet-decode.go similarity index 57% rename from internal/processor/artnet-decode.go rename to internal/processor/artnet-packet-decode.go index cbdbb06..9bda0d8 100644 --- a/internal/processor/artnet-decode.go +++ b/internal/processor/artnet-packet-decode.go @@ -8,15 +8,15 @@ import ( "github.com/jwetzell/showbridge-go/internal/config" ) -type ArtNetDecode struct { +type ArtNetPacketDecode struct { config config.ProcessorConfig } -func (ad *ArtNetDecode) Process(ctx context.Context, payload any) (any, error) { +func (apd *ArtNetPacketDecode) Process(ctx context.Context, payload any) (any, error) { payloadBytes, ok := payload.([]byte) if !ok { - return nil, fmt.Errorf("artnet.decode processor only accepts a []byte") + return nil, fmt.Errorf("artnet.packet.decode processor only accepts a []byte") } payloadMessage, err := artnet.Decode(payloadBytes) @@ -28,15 +28,15 @@ func (ad *ArtNetDecode) Process(ctx context.Context, payload any) (any, error) { return payloadMessage, nil } -func (ad *ArtNetDecode) Type() string { - return ad.config.Type +func (apd *ArtNetPacketDecode) Type() string { + return apd.config.Type } func init() { RegisterProcessor(ProcessorRegistration{ - Type: "artnet.decode", + Type: "artnet.packet.decode", New: func(config config.ProcessorConfig) (Processor, error) { - return &ArtNetDecode{config: config}, nil + return &ArtNetPacketDecode{config: config}, nil }, }) } diff --git a/internal/processor/artnet-encode.go b/internal/processor/artnet-packet-encode.go similarity index 57% rename from internal/processor/artnet-encode.go rename to internal/processor/artnet-packet-encode.go index a26bd4b..b820909 100644 --- a/internal/processor/artnet-encode.go +++ b/internal/processor/artnet-packet-encode.go @@ -8,15 +8,15 @@ import ( "github.com/jwetzell/showbridge-go/internal/config" ) -type ArtNetEncode struct { +type ArtNetPacketEncode struct { config config.ProcessorConfig } -func (ad *ArtNetEncode) Process(ctx context.Context, payload any) (any, error) { +func (ape *ArtNetPacketEncode) Process(ctx context.Context, payload any) (any, error) { payloadPacket, ok := payload.(artnet.ArtNetPacket) if !ok { - return nil, fmt.Errorf("artnet.encode processor only accepts an ArtNetPacket") + return nil, fmt.Errorf("artnet.packet.encode processor only accepts an ArtNetPacket") } payloadBytes, err := payloadPacket.MarshalBinary() @@ -27,15 +27,15 @@ func (ad *ArtNetEncode) Process(ctx context.Context, payload any) (any, error) { return payloadBytes, nil } -func (ad *ArtNetEncode) Type() string { - return ad.config.Type +func (ape *ArtNetPacketEncode) Type() string { + return ape.config.Type } func init() { RegisterProcessor(ProcessorRegistration{ - Type: "artnet.encode", + Type: "artnet.packet.encode", New: func(config config.ProcessorConfig) (Processor, error) { - return &ArtNetEncode{config: config}, nil + return &ArtNetPacketEncode{config: config}, nil }, }) }