debug: More logging and reduced timeout for engine hooks

Author: g3force

internal/app/ci/ci.go

@@ -107,6 +107,8 @@ func (s *Server) serve(conn net.Conn) {
 			case <-time.After(1 * time.Second):
 				log.Printf("tickChan unresponsive! Failed to sent %v", s.latestTime)
 			}
+		} else {
+			log.Println("CiInput without timestamp!")
 		}
 	}
 }

internal/app/engine/engine.go

@@ -284,15 +284,17 @@ func (e *Engine) processChange(change *statemachine.Change) {
 		e.queue <- newChange
 	}
 
+	log.Println("Add entry to state store")
 	if err := e.stateStore.Add(&entry); err != nil {
 		log.Println("Could not add new state to store: ", err)
 	}
 	stateCopy := e.currentState.Clone()
 	hookOut := HookOut{Change: entry.Change, State: stateCopy}
 	for name, hook := range e.hooks {
+		log.Println("Notify hook ", name)
 		select {
 		case hook <- hookOut:
-		case <-time.After(1 * time.Second):
+		case <-time.After(500 * time.Millisecond):
 			log.Printf("Hook %v unresponsive! Failed to sent %v", name, hookOut)
 		}
 	}