Allow to choose a single network interface to publish referee messages

Author: g3force

config/ssl-game-controller.yaml

@@ -1,6 +1,8 @@
 time-acquisition-mode: system
 network:
   publish-address: 224.5.23.1:10003
+  # set a network IP to only publish to that network - else messages will be published to all network interfaces 
+  publish-nif:
   vision-address: 224.5.23.2:10006
   tracker-address: 224.5.23.2:10010
   skip-interfaces: []

internal/app/config/config.go

@@ -67,6 +67,7 @@ type Game struct {
 // Network holds configs for network communication
 type Network struct {
 	PublishAddress string   `yaml:"publish-address"`
+	PublishNif     string   `yaml:"publish-nif"`
 	VisionAddress  string   `yaml:"vision-address"`
 	TrackerAddress string   `yaml:"tracker-address"`
 	SkipInterfaces []string `yaml:"skip-interfaces"`
@@ -167,6 +168,7 @@ func (c *Controller) WriteTo(fileName string) (err error) {
 // DefaultControllerConfig creates a config with default values
 func DefaultControllerConfig() (c Controller) {
 	c.Network.PublishAddress = "224.5.23.1:10003"
+	c.Network.PublishNif = ""
 	c.Network.VisionAddress = "224.5.23.2:10006"
 	c.Network.TrackerAddress = "224.5.23.2:10010"
 	c.Network.SkipInterfaces = []string{}

internal/app/config/testdata/config.yaml

@@ -1,6 +1,7 @@
 time-acquisition-mode: system
 network:
   publish-address: 224.5.23.1:10003
+  publish-nif:
   vision-address: 224.5.23.2:10006
   tracker-address: 224.5.23.2:10010
   skip-interfaces: []

internal/app/gc/gc.go

@@ -35,7 +35,7 @@ func NewGameController(cfg config.Controller) (c *GameController) {
 	c.config = cfg
 	c.gcEngine = engine.NewEngine(cfg.Game, cfg.Engine)
 	c.messageGenerator = publish.NewMessageGenerator()
-	c.publisher = publish.NewPublisher(c.config.Network.PublishAddress)
+	c.publisher = publish.NewPublisher(c.config.Network.PublishAddress, c.config.Network.PublishNif)
 	c.apiServer = api.NewServer(c.gcEngine)
 	c.autoRefServer = rcon.NewAutoRefServer(cfg.Server.AutoRef.Address, c.gcEngine)
 	c.autoRefServerTls = rcon.NewAutoRefServer(cfg.Server.AutoRef.AddressTls, c.gcEngine)

internal/app/publish/publisher.go

@@ -12,13 +12,15 @@ const maxDatagramSize = 8192
 // Publisher can publish state and commands to the teams
 type Publisher struct {
 	address string
+	nif     string
 	conns   []*net.UDPConn
 }
 
 // NewPublisher creates a new publisher that publishes referee messages via UDP to the teams
-func NewPublisher(address string) (p *Publisher) {
+func NewPublisher(address, nif string) (p *Publisher) {
 	p = new(Publisher)
 	p.address = address
+	p.nif = nif
 	p.conns = []*net.UDPConn{}
 	return
 }
@@ -38,6 +40,9 @@ func (p *Publisher) connect() bool {
 		if ip.To4() == nil {
 			continue
 		}
+		if p.nif != "" && ip.String() != p.nif {
+			continue
+		}
 		laddr := &net.UDPAddr{
 			IP: ip,
 		}