More logging

Author: g3force

internal/app/engine/engine.go

@@ -188,6 +188,7 @@ func (e *Engine) ResetMatch() {
 func (e *Engine) processChange(change *statemachine.Change) {
 	e.mutex.Lock()
 	defer e.mutex.Unlock()
+	log.Printf("Engine: Process change '%v'", change)
 
 	var newChanges []*statemachine.Change
 	entry := statemachine.StateChange{}
@@ -231,6 +232,7 @@ func (e *Engine) processChange(change *statemachine.Change) {
 
 	e.postProcessChange(entry)
 
+	log.Printf("Enqueue %d new changes", len(newChanges))
 	for _, newChange := range newChanges {
 		e.queue <- newChange
 	}
@@ -245,6 +247,8 @@ func (e *Engine) processChange(change *statemachine.Change) {
 		default:
 		}
 	}
+
+	log.Printf("Change '%v' processed", change)
 }
 
 // initialStateFromStore gets the current state or returns a new default state

internal/app/statemachine/statemachine.go

@@ -56,7 +56,7 @@ func (s *StateMachine) Process(currentState *state.State, change *Change) (newSt
 
 	newState = new(state.State)
 	proto.Merge(newState, currentState)
-	log.Printf("Processing change: %v", change)
+	log.Printf("Processing change '%v'", change)
 	if change.GetNewCommand() != nil {
 		newChanges = s.processChangeNewCommand(newState, change.GetNewCommand())
 	} else if change.GetChangeStage() != nil {
@@ -93,6 +93,7 @@ func (s *StateMachine) Process(currentState *state.State, change *Change) (newSt
 		newChanges[i].Origin = new(string)
 		*newChanges[i].Origin = changeOriginStateMachine
 	}
+	log.Printf("Change '%v' processed:\nfrom: %v\n  to: %v", change, currentState, newState)
 
 	return
 }