jobs

type Artifacts struct {
	Bouquets      map[string]string // Bouquet name -> reference
	Services      [][]string        // Raw services from OpenWebIF
	PlaylistItems []playlist.Item   // Processed playlist items
	EPGProgrammes int               // Number of EPG programmes collected
	Stats         RefreshStats
}

type Config struct {
	Version       string
	DataDir       string
	OWIBase       string
	OWIUsername   string // Optional: HTTP Basic Auth username
	OWIPassword   string // Optional: HTTP Basic Auth password
	Bouquet       string // Comma-separated list of bouquets (e.g., "Premium,Favourites")
	XMLTVPath     string
	PiconBase     string
	FuzzyMax      int
	StreamPort    int
	APIToken      string // Optional: for securing the /api/refresh endpoint
	OWITimeout    time.Duration
	OWIRetries    int
	OWIBackoff    time.Duration
	OWIMaxBackoff time.Duration

	// EPG Configuration
	EPGEnabled        bool
	EPGDays           int    // Number of days to fetch EPG data (1-14)
	EPGMaxConcurrency int    // Max parallel EPG requests (1-10)
	EPGTimeoutMS      int    // Timeout per EPG request in milliseconds
	EPGRetries        int    // Retry attempts for EPG requests
	EPGSource         string // EPG fetch strategy: "bouquet" (fast, single request) or "per-service" (default, per-channel requests)
}

type Deps struct {
	Logger      Logger
	Config      Config
	Client      OpenWebIFClient
	Metrics     MetricsRecorder
	FileWriter  FileWriter
	Clock       func() time.Time
	Parallelism int // Max parallel EPG fetches
}

type FileWriter interface {
	WriteAtomic(ctx context.Context, path string, data []byte) error
}

type Logger interface {
	Info() *zerolog.Event
	Warn() *zerolog.Event
	Error() *zerolog.Event
	Debug() *zerolog.Event
}

type MetricsRecorder interface {
	RecordBouquetsCount(count int)
	RecordServicesCount(bouquet string, count int)
	RecordChannelTypeCounts(hd, sd, radio, unknown int)
	IncStreamURLBuild(status string)
	IncRefreshFailure(reason string)
	RecordXMLTV(enabled bool, channels int, err error)
	RecordPlaylistFileValidity(fileType string, valid bool)
	RecordEPGCollection(programmes, channels int, duration float64)
}

type OpenWebIFClient interface {
	Bouquets(ctx context.Context) (map[string]string, error)
	Services(ctx context.Context, bouquetRef string) ([][]string, error)
	StreamURL(ctx context.Context, serviceRef, serviceName string) (string, error)
}

type Options struct {
	Force       bool // Force refresh even if recent data exists
	IncludeEPG  bool // Include EPG data collection
	DryRun      bool // Skip actual file writes
	Parallelism int  // Max parallel workers (0 = GOMAXPROCS)
}

type RefreshStats struct {
	StartTime       time.Time
	EndTime         time.Time
	DurationMS      int64
	ChannelsTotal   int
	BouquetsTotal   int
	EPGProgrammes   int
	HDChannels      int
	SDChannels      int
	RadioChannels   int
	UnknownChannels int
	Errors          []string
}

type Status struct {
	Version       string    `json:"version"`
	LastRun       time.Time `json:"lastRun"`
	Channels      int       `json:"channels"`
	Bouquets      int       `json:"bouquets,omitempty"`      // Number of bouquets processed
	EPGProgrammes int       `json:"epgProgrammes,omitempty"` // Number of EPG programmes collected
	DurationMS    int64     `json:"durationMs,omitempty"`    // Duration of last refresh in milliseconds
	Error         string    `json:"error,omitempty"`
}