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

use GetAnyAsByteSlice whenever possible

Browse Source
This commit is contained in:
Joel Wetzell
2026-03-18 21:57:21 -05:00
parent 0763b4d720
commit 012c416432
13 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/module/midi-output.go
View File

@@ -87,7 +87,7 @@ func (mo *MIDIOutput) Output(ctx context.Context, payload any) error {
payloadMessage, ok := common.GetAnyAs[midi.Message](payload) payloadMessage, ok := common.GetAnyAs[midi.Message](payload)
if !ok { if !ok {
return errors.New("midi.output can only ouptut midi.Message") return errors.New("midi.output can only output midi.Message")
} }
return mo.SendFunc(payloadMessage) return mo.SendFunc(payloadMessage)

4
internal/module/serial-client.go
View File

@@ -156,10 +156,10 @@ func (sc *SerialClient) Start(ctx context.Context) error {
func (sc *SerialClient) Output(ctx context.Context, payload any) error { func (sc *SerialClient) Output(ctx context.Context, payload any) error {
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
return errors.New("serial.client can only ouptut bytes") return errors.New("serial.client can only output bytes")
} }
_, err := sc.port.Write(sc.Framer.Encode(payloadBytes)) _, err := sc.port.Write(sc.Framer.Encode(payloadBytes))

2
internal/module/tcp-client.go
View File

@@ -152,7 +152,7 @@ func (tc *TCPClient) Output(ctx context.Context, payload any) error {
return err return err
} }
} }
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
return errors.New("net.tcp.client is only able to output bytes") return errors.New("net.tcp.client is only able to output bytes")
} }

2
internal/module/tcp-server.go
View File

@@ -206,7 +206,7 @@ AcceptLoop:
} }
func (ts *TCPServer) Output(ctx context.Context, payload any) error { func (ts *TCPServer) Output(ctx context.Context, payload any) error {
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
return errors.New("net.tcp.server is only able to output bytes") return errors.New("net.tcp.server is only able to output bytes")

2
internal/module/udp-client.go
View File

@@ -87,7 +87,7 @@ func (uc *UDPClient) Start(ctx context.Context) error {
func (uc *UDPClient) Output(ctx context.Context, payload any) error { func (uc *UDPClient) Output(ctx context.Context, payload any) error {
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
return errors.New("net.udp.client is only able to output bytes") return errors.New("net.udp.client is only able to output bytes")
} }

2
internal/module/udp-multicast.go
View File

@@ -108,7 +108,7 @@ func (um *UDPMulticast) Start(ctx context.Context) error {
func (um *UDPMulticast) Output(ctx context.Context, payload any) error { func (um *UDPMulticast) Output(ctx context.Context, payload any) error {
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
return errors.New("net.udp.multicast can only output bytes") return errors.New("net.udp.multicast can only output bytes")
} }

2
internal/processor/artnet-packet-decode.go
View File

@@ -15,7 +15,7 @@ type ArtNetPacketDecode struct {
func (apd *ArtNetPacketDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { func (apd *ArtNetPacketDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
payload := wrappedPayload.Payload payload := wrappedPayload.Payload
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
wrappedPayload.End = true wrappedPayload.End = true

2
internal/processor/free-d-decode.go
View File

@@ -15,7 +15,7 @@ type FreeDDecode struct {
func (fd *FreeDDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { func (fd *FreeDDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
payload := wrappedPayload.Payload payload := wrappedPayload.Payload
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
wrappedPayload.End = true wrappedPayload.End = true

2
internal/processor/midi-message-decode.go
View File

@@ -17,7 +17,7 @@ type MIDIMessageDecode struct {
func (mmd *MIDIMessageDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { func (mmd *MIDIMessageDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
payload := wrappedPayload.Payload payload := wrappedPayload.Payload
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
wrappedPayload.End = true wrappedPayload.End = true

2
internal/processor/osc-message-decode.go
View File

@@ -16,7 +16,7 @@ type OSCMessageDecode struct {
func (omd *OSCMessageDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { func (omd *OSCMessageDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
payload := wrappedPayload.Payload payload := wrappedPayload.Payload
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
wrappedPayload.End = true wrappedPayload.End = true

2
internal/processor/script-wasm.go
View File

@@ -19,7 +19,7 @@ type ScriptWASM struct {
func (sw *ScriptWASM) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { func (sw *ScriptWASM) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
payload := wrappedPayload.Payload payload := wrappedPayload.Payload
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
wrappedPayload.End = true wrappedPayload.End = true

2
internal/processor/string-decode.go
View File

@@ -14,7 +14,7 @@ type StringDecode struct {
func (sd *StringDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) { func (sd *StringDecode) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
payload := wrappedPayload.Payload payload := wrappedPayload.Payload
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
wrappedPayload.End = true wrappedPayload.End = true

2
internal/route/route_test.go
View File

@@ -60,7 +60,7 @@ func TestGoodRouteHandleInput(t *testing.T) {
t.Fatalf("route ProcessPayload returned error: %v", err) t.Fatalf("route ProcessPayload returned error: %v", err)
} }
payloadBytes, ok := common.GetAnyAs[[]byte](payload) payloadBytes, ok := common.GetAnyAsByteSlice(payload)
if !ok { if !ok {
t.Fatalf("payload should be []byte got %T", payload) t.Fatalf("payload should be []byte got %T", payload)
} }