Improve error handling and reporting

Author: g3force

cmd/ssl-tracker-producer-test-client/main.go

@@ -113,7 +113,7 @@ func publish(frame tracker.TrackedFrame, conn *net.UDPConn) {
 			return
 		} else {
 			if _, err = conn.Write(bytes); err != nil {
-				log.Printf("Could not write message: %v", err)
+				log.Println("Could not write tracker message:", err)
 				return
 			}
 		}

internal/app/api/server.go

@@ -198,7 +198,7 @@ func (s *ServerConnection) publishOutput(wrapper *Output) {
 
 	err = s.conn.WriteMessage(websocket.TextMessage, []byte(b))
 	if err != nil {
-		log.Println("Could not write message.", err)
+		log.Println("Could not write message to api client:", err)
 	}
 }
 

internal/app/engine/process_tick.go

@@ -68,11 +68,11 @@ func (e *Engine) processTick() {
 
 	stateCopy := e.currentState.Clone()
 	hookOut := HookOut{State: stateCopy}
-	for _, hook := range e.hooks {
+	for hookId, hook := range e.hooks {
 		select {
 		case hook <- hookOut:
 		case <-time.After(1 * time.Second):
-			log.Printf("processTick: Hook unresponsive! Failed to sent %v", hookOut)
+			log.Printf("processTick: Hook %v unresponsive! Failed to sent %v", hookId, hookOut)
 		}
 	}
 }

internal/app/publish/publisher.go

@@ -58,6 +58,12 @@ func (p *Publisher) connect() bool {
 }
 
 func (p *Publisher) disconnect() {
+	for _, conn := range p.conns {
+		if err := conn.Close(); err != nil {
+			log.Println("Failed to close referee connection:", err)
+		}
+	}
+
 	p.conns = []*net.UDPConn{}
 }
 
@@ -73,7 +79,7 @@ func (p *Publisher) SendMessage(refereeMsg *state.Referee) {
 		}
 		_, err = conn.Write(bytes)
 		if err != nil {
-			log.Printf("Could not write message: %v", err)
+			log.Println("Could not write referee message:", err)
 			p.disconnect()
 		}
 	}