From 3f8455dfa93b81bf5b44ad1e35cfc60de7360f1a Mon Sep 17 00:00:00 2001
From: rcourtman <courtmanr@gmail.com>
Date: Tue, 2 Dec 2025 14:21:25 +0000
Subject: [PATCH] test: Add DispatchDue enqueue error test for monitoring
 package

---
 internal/monitoring/scheduler_test.go | 30 +++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)

diff --git a/internal/monitoring/scheduler_test.go b/internal/monitoring/scheduler_test.go
index 7c625cd..e79a2df 100644
--- a/internal/monitoring/scheduler_test.go
+++ b/internal/monitoring/scheduler_test.go
@@ -2,6 +2,7 @@ package monitoring
 
 import (
 	"context"
+	"errors"
 	"math/rand"
 	"testing"
 	"time"
@@ -2225,6 +2226,35 @@ func TestDispatchDue_NoDueTasks(t *testing.T) {
 	}
 }
 
+// mockFailingEnqueuer is a test enqueuer that always returns an error
+type mockFailingEnqueuer struct{}
+
+func (m *mockFailingEnqueuer) Enqueue(ctx context.Context, task ScheduledTask) error {
+	return errors.New("enqueue failed")
+}
+
+// TestDispatchDue_EnqueueError tests DispatchDue when enqueue returns an error
+func TestDispatchDue_EnqueueError(t *testing.T) {
+	t.Parallel()
+
+	enqueuer := &mockFailingEnqueuer{}
+	cfg := DefaultSchedulerConfig()
+	scheduler := NewAdaptiveScheduler(cfg, nil, nil, enqueuer)
+
+	now := time.Now()
+	tasks := []ScheduledTask{
+		{InstanceName: "pve1", NextRun: now.Add(-1 * time.Second)},
+		{InstanceName: "pve2", NextRun: now.Add(-2 * time.Second)},
+	}
+
+	// Should still return due tasks even if enqueue fails
+	due := scheduler.DispatchDue(context.Background(), now, tasks)
+
+	if len(due) != 2 {
+		t.Fatalf("expected 2 due tasks returned even with enqueue error, got %d", len(due))
+	}
+}
+
 // TestLastScheduled_NilScheduler tests LastScheduled with nil scheduler
 func TestLastScheduled_NilScheduler(t *testing.T) {
 	t.Parallel()