Function ProcessEvents

app/pkg/comdb/WatchComDB.go:13–42

()

)

func ProcessEvents() (string, error) {
	functionName := "ProcessEvents"

	var comDB ComDB
	// Read comDB from file
	if readErr := ReadComFile(auxiliary.StateInstance.ComDBPath, &comDB); readErr != nil {
		return "", fmt.Errorf("reading ComDB failed -> %v: %w", functionName, readErr)
	}

	// Iteratve over comDB events
	for _, event := range comDB.Events {
		// Filter for confirm events (the only events targeted at CLI)
		if event.Path == auxiliary.StateInstance.WorkingPath && event.Receiver == "CLI" && !event.Received {
			// Mark event as received in comDB
			if markErr := MarkComDBReceived(event); markErr != nil {
				return "", fmt.Errorf("could not mark event as received -> %v --- %v: %w", event.Type, functionName, markErr)
			}

			if event.Type == "confirmed" {
				return "confirmed", nil
			}

			if event.Type == "canceled" {
				return "canceled", nil
			}
		}
	}

	return "", nil
}

func WatchComDBFallback() (bool, error) {
	functionName := "WatchComDBFallback"