diff --git a/go.mod b/go.mod index ec984df..0f008cc 100644 --- a/go.mod +++ b/go.mod @@ -1,10 +1,11 @@ module github.com/jwetzell/showbridge-go -go 1.25.1 +go 1.25.3 require ( github.com/eclipse/paho.mqtt.golang v1.5.1 github.com/jwetzell/osc-go v0.1.0 + github.com/jwetzell/psn-go v0.2.0 github.com/urfave/cli/v3 v3.6.1 gitlab.com/gomidi/midi/v2 v2.3.16 sigs.k8s.io/yaml v1.6.0 diff --git a/go.sum b/go.sum index d7ff843..d9191d4 100644 --- a/go.sum +++ b/go.sum @@ -8,6 +8,8 @@ github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aN github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE= github.com/jwetzell/osc-go v0.1.0 h1:EXxup5VWBErHot2Ri4MFToPf6KCzLDTbCt2x6GLfw8I= github.com/jwetzell/osc-go v0.1.0/go.mod h1:xLz0jTwebSxtx1TkKN1YVdeRqvpFNweDhTut5TE393A= +github.com/jwetzell/psn-go v0.2.0 h1:2uPYGDRu9o2qUeFQOi+tp59WFPCWgHqJA4/Ff2dwnXM= +github.com/jwetzell/psn-go v0.2.0/go.mod h1:bcEAeti4sQM375buujb3mIfmUstD4Aby18gq3ENb6+o= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U= diff --git a/psn-client.go b/psn-client.go new file mode 100644 index 0000000..fb0fb1f --- /dev/null +++ b/psn-client.go @@ -0,0 +1,96 @@ +package showbridge + +import ( + "fmt" + "log/slog" + "net" + "time" + + "github.com/jwetzell/psn-go" +) + +type PSNClient struct { + config ModuleConfig + conn *net.UDPConn + router *Router + decoder *psn.Decoder +} + +func init() { + RegisterModule(ModuleRegistration{ + Type: "net.psn.client", + New: func(config ModuleConfig) (Module, error) { + + return &PSNClient{config: config, decoder: psn.NewDecoder()}, nil + }, + }) +} + +func (uc *PSNClient) Id() string { + return uc.config.Id +} + +func (uc *PSNClient) Type() string { + return uc.config.Type +} + +func (uc *PSNClient) RegisterRouter(router *Router) { + uc.router = router +} + +func (uc *PSNClient) Run() error { + + addr, err := net.ResolveUDPAddr("udp", "236.10.10.10:56565") + if err != nil { + return err + } + + client, err := net.ListenMulticastUDP("udp", nil, addr) + if err != nil { + return err + } + defer client.Close() + + uc.conn = client + + buffer := make([]byte, 2048) + for { + select { + case <-uc.router.Context.Done(): + // TODO(jwetzell): cleanup? + slog.Debug("router context done in module", "id", uc.config.Id) + return nil + default: + uc.conn.SetDeadline(time.Now().Add(time.Millisecond * 200)) + + numBytes, _, err := uc.conn.ReadFromUDP(buffer) + if err != nil { + //NOTE(jwetzell) we hit deadline + if opErr, ok := err.(*net.OpError); ok && opErr.Timeout() { + continue + } + return err + } + + if numBytes > 0 { + message := buffer[:numBytes] + err := uc.decoder.Decode(message) + if err != nil { + slog.Error("net.psn.client problem decoding psn traffic", "id", uc.config.Id, "error", err) + } + + if uc.router != nil { + for _, tracker := range uc.decoder.Trackers { + uc.router.HandleInput(uc.config.Id, tracker) + } + } else { + slog.Error("net.psn.client has no router", "id", uc.config.Id) + } + } + } + } +} + +func (uc *PSNClient) Output(payload any) error { + return fmt.Errorf("net.psn.client output is not implemented") +}