daemon: wire StatusWatcher into reconciler and daemon

Add --poll-interval flag to the daemon binary and wire the
StatusWatcher channel into the reconciler as a second
WatchesRawSource alongside switchDone.

Assisted-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Signed-off-by: Alice Frosi <afrosi@redhat.com>

Author: alicefr

cmd/daemon/main.go

@@ -6,6 +6,7 @@ import (
 	"flag"
 	"fmt"
 	"os"
+	"time"
 
 	"k8s.io/apimachinery/pkg/fields"
 	"k8s.io/apimachinery/pkg/runtime"
@@ -14,6 +15,7 @@ import (
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/cache"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/event"
 	"sigs.k8s.io/controller-runtime/pkg/log/zap"
 
 	bootcv1alpha1 "github.com/jlebon/bootc-operator/api/v1alpha1"
@@ -32,6 +34,9 @@ func init() {
 }
 
 func main() {
+	var pollInterval time.Duration
+	flag.DurationVar(&pollInterval, "poll-interval", 5*time.Minute, "Interval for polling bootc status as a fallback to fsnotify")
+
 	opts := zap.Options{
 		Development: true,
 	}
@@ -62,17 +67,32 @@ func main() {
 		os.Exit(1)
 	}
 
+	statusChanged := make(chan event.GenericEvent, 1)
+
 	if err := (&daemon.BootcNodeReconciler{
-		Client:   mgr.GetClient(),
-		Scheme:   mgr.GetScheme(),
-		NodeName: nodeName,
-		Executor: bootc.NewHostExecutor(),
+		Client:        mgr.GetClient(),
+		Scheme:        mgr.GetScheme(),
+		NodeName:      nodeName,
+		Executor:      bootc.NewHostExecutor(),
+		StatusChanged: statusChanged,
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "Failed to create controller", "controller", "bootcnode")
 		os.Exit(1)
 	}
 
-	setupLog.Info("Starting daemon", "node", nodeName)
+	watcher := &daemon.StatusWatcher{
+		PollInterval: pollInterval,
+		PrimaryPath:  daemon.DefaultPrimaryPath,
+		FallbackPath: daemon.DefaultFallbackPath,
+		Events:       statusChanged,
+		NodeName:     nodeName,
+	}
+	if err := mgr.Add(watcher); err != nil {
+		setupLog.Error(err, "Failed to add status watcher")
+		os.Exit(1)
+	}
+
+	setupLog.Info("Starting daemon", "node", nodeName, "pollInterval", pollInterval)
 	if err := mgr.Start(ctrl.SetupSignalHandler()); err != nil {
 		setupLog.Error(err, "Failed to run daemon")
 		os.Exit(1)

internal/daemon/reconciler.go

@@ -58,17 +58,23 @@ type BootcNodeReconciler struct {
 	stageDone chan event.GenericEvent
 	// rebootIssued tracks whether a reboot has been issued so classifyAction
 	// can distinguish the Staged→Rebooting.
-	rebootIssued bool
+	rebootIssued      bool
+	StatusChanged chan event.GenericEvent
 }
 
 func (r *BootcNodeReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	r.stageDone = make(chan event.GenericEvent, 1)
 
-	return ctrl.NewControllerManagedBy(mgr).
+	builder := ctrl.NewControllerManagedBy(mgr).
 		For(&bootcv1alpha1.BootcNode{}).
 		WatchesRawSource(source.Channel(r.stageDone, &handler.EnqueueRequestForObject{})).
-		Named("bootcnode").
-		Complete(r)
+		Named("bootcnode")
+
+	if r.StatusChanged != nil {
+		builder = builder.WatchesRawSource(source.Channel(r.StatusChanged, &handler.EnqueueRequestForObject{}))
+	}
+
+	return builder.Complete(r)
 }
 
 func (r *BootcNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {

internal/daemon/watcher_test.go

@@ -23,12 +23,12 @@ func startWatcher(t *testing.T, w *StatusWatcher) (done <-chan error, cancel con
 
 func TestWatcherEvents(t *testing.T) {
 	tests := []struct {
-		name         string
-		mkPrimary    bool
-		mkFallback   bool
-		touchPrimary bool
+		name          string
+		mkPrimary     bool
+		mkFallback    bool
+		touchPrimary  bool
 		touchFallback bool
-		pollInterval time.Duration
+		pollInterval  time.Duration
 	}{
 		{
 			name:         "Fsnotify",