package scheduler

import (
	"context"
	"log"
	"time"

	"task-dashboard/internal/config"
	"task-dashboard/internal/store"
)

// RunBucketCycleCheck ticks every interval, calling RunBucketCycles until
// ctx is cancelled. Mirrors RunRecurrenceCheck's shape -- errors are
// logged, not fatal, so one bad tick doesn't kill the loop.
func RunBucketCycleCheck(ctx context.Context, s *store.Store, interval time.Duration) {
	ticker := time.NewTicker(interval)
	defer ticker.Stop()
	for {
		select {
		case <-ctx.Done():
			return
		case <-ticker.C:
			n, err := s.RunBucketCycles(config.Now())
			if err != nil {
				log.Printf("ERROR [BucketCycleCheck]: %v", err)
				continue
			}
			if n > 0 {
				log.Printf("BucketCycleCheck: activated %d item(s)", n)
			}
		}
	}
}