Function WatchComDB

app/pkg/comdb/WatchComDB.go:66–117

()

}

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

	// Check if bus file already exists
	_, existErr := os.Stat(auxiliary.StateInstance.ComDBPath)
	if errors.Is(existErr, os.ErrNotExist) {
		// Create file if it doesn't exist yet
		if _, fileMkErr := os.Create(auxiliary.StateInstance.ComDBPath); fileMkErr != nil {
			return false, fmt.Errorf("%v: %w", functionName, fileMkErr)
		}
	}

	// Define file watcher
	watcherInstance, watchErr := fsnotify.NewWatcher()
	if watchErr != nil {
		return false, fmt.Errorf("%v: %w", functionName, watchErr)
	}
	defer watcherInstance.Close()

	// Add bus file to watcher
	addErr := watcherInstance.Add(auxiliary.StateInstance.ComDBPath)
	if addErr != nil {
		return false, fmt.Errorf("%v: %w", functionName, addErr)
	}

	// Handle watcher events
	for {
		select {
		case event := <-watcherInstance.Events:
			// Switch different watcher event types
			switch {
			// If a write event happens
			case event.Op&fsnotify.Write == fsnotify.Write:
				status, processErr := ProcessEvents()
				if processErr != nil {
					return false, fmt.Errorf("processing events failed -> %v: %w", functionName, processErr)
				}

				if status == "confirmed" {
					return true, nil
				}

				if status == "canceled" {
					return false, nil
				}
			}
		// Handle watcher error
		case err := <-watcherInstance.Errors:
			return false, fmt.Errorf("%v: %w", functionName, err)
		}
	}
}