feature: Allow publishing referee messages in CI mode

Author: g3force

internal/app/gc/gc.go

@@ -57,19 +57,21 @@ func NewGameController(cfg config.Controller) (c *GameController) {
 // Start starts all go routines
 func (c *GameController) Start() {
 
+	if len(c.config.Network.PublishAddress) > 0 {
+		c.messageGenerator.MessageConsumers = append(c.messageGenerator.MessageConsumers, c.publisher.SendMessage)
+	}
+
 	switch c.config.TimeAcquisitionMode {
 	case config.TimeAcquisitionModeSystem:
-		c.messageGenerator.MessageConsumer = c.publisher.SendMessage
 		c.visionReceiver.Start()
 		c.trackerReceiver.Start()
 		break
 	case config.TimeAcquisitionModeVision:
-		c.messageGenerator.MessageConsumer = c.publisher.SendMessage
 		c.gcEngine.SetTimeProvider(c.visionReceiver.Time)
 		c.visionReceiver.Start()
 		c.trackerReceiver.Start()
 	case config.TimeAcquisitionModeCi:
-		c.messageGenerator.MessageConsumer = c.ciServer.SendMessage
+		c.messageGenerator.MessageConsumers = append(c.messageGenerator.MessageConsumers, c.ciServer.SendMessage)
 		c.gcEngine.SetTimeProvider(c.ciServer.Time)
 		c.gcEngine.SetTickChanProvider(c.ciServer.TickChanProvider)
 		c.ciServer.SetEngine(c.gcEngine)

internal/app/publish/messagegenerator.go

@@ -14,7 +14,7 @@ type MessageGenerator struct {
 	commandTimestamp uint64
 	quit             chan int
 	gcEngine         *engine.Engine
-	MessageConsumer  func(*state.Referee)
+	MessageConsumers []func(*state.Referee)
 	EngineHook       chan engine.HookOut
 }
 
@@ -48,12 +48,16 @@ func (g *MessageGenerator) listen() {
 		case hookOut := <-g.EngineHook:
 			if hookOut.Change != nil {
 				refereeMessages := g.GenerateRefereeMessages(hookOut)
-				for _, refereeMsg := range refereeMessages {
-					g.MessageConsumer(refereeMsg)
+				for _, refMsg := range refereeMessages {
+					for _, consumer := range g.MessageConsumers {
+						consumer(refMsg)
+					}
 				}
 			} else if hookOut.State != nil {
 				refMsg := g.StateToRefereeMessage(hookOut.State)
-				g.MessageConsumer(refMsg)
+				for _, consumer := range g.MessageConsumers {
+					consumer(refMsg)
+				}
 			}
 		}
 	}