cachepreload

type DiscardingResponseWriter struct {
	// contains filtered or unexported fields
}

type FolderPreloadTask struct {
	FolderID        int64                     // folder to preload (direct children only)
	SessionID       string                    // for task cancellation when user navigates away
	ETagVersion     string                    // cache-busting query (e.g. "v=20260201-01")
	CacheableRoutes []string                  // route prefixes that are cacheable (e.g. "/gallery/", "/info/")
	DBRoPool        *dbconnpool.DbSQLConnPool // read-only pool for GetPreloadRoutesByFolderID
	TaskTracker     *TaskTracker              // deduplication; TryClaimTask before scheduling
	Scheduler       *scheduler.Scheduler      // schedules per-path PreloadTask
	RequestConfig   InternalRequestConfig     // handler and ETag version for internal requests
	Metrics         *PreloadMetrics           // optional; records skipped/scheduled
	GetQueries      func(*dbconnpool.CpConn) interfaces.HandlerQueries
}

type InternalRequestConfig struct {
	// Handler is the HTTP handler wrapped with full middleware chain
	// (cache middleware, etc.)
	Handler http.Handler

	// ETagVersion for cache key query string
	ETagVersion string
}

type PreloadConfig struct {
	TaskTracker    *TaskTracker
	SessionTracker *SessionTracker
	DBRoPool       *dbconnpool.DbSQLConnPool
	GetQueries     func(*dbconnpool.CpConn) interfaces.HandlerQueries
	GetHandler     func() http.Handler // Lazy: full middleware chain
	GetETagVersion func() string
	Metrics        *PreloadMetrics
}

type PreloadManager struct {
	// contains filtered or unexported fields
}

type PreloadMetrics struct {
	TasksScheduled atomic.Int64
	TasksCompleted atomic.Int64
	TasksFailed    atomic.Int64
	TasksCancelled atomic.Int64
	TasksSkipped   atomic.Int64 // Due to deduplication or existing cache
	TotalDuration  atomic.Int64 // Nanoseconds
}

type PreloadMetricsSnapshot struct {
	TasksScheduled int64         `json:"tasks_scheduled"`
	TasksCompleted int64         `json:"tasks_completed"`
	TasksFailed    int64         `json:"tasks_failed"`
	TasksCancelled int64         `json:"tasks_cancelled"`
	TasksSkipped   int64         `json:"tasks_skipped"`
	TotalDuration  time.Duration `json:"total_duration"`
}

type PreloadService interface {
	// ScheduleFolderPreload schedules background cache preload for a folder.
	// sessionID is used for task cancellation when user navigates away.
	// Non-blocking (fire-and-forget).
	ScheduleFolderPreload(ctx context.Context, folderID int64, sessionID string)

	// SetEnabled dynamically enables or disables cache preloading.
	// When disabled, all pending tasks are cancelled.
	SetEnabled(enabled bool)

	// IsEnabled returns whether cache preloading is currently enabled.
	IsEnabled() bool
}

type PreloadTask struct {
	CacheKey      string
	Path          string
	HXTarget      string // optional; when set, request uses HX-Request/HX-Target
	TaskTracker   *TaskTracker
	RequestConfig InternalRequestConfig
	Metrics       *PreloadMetrics
}

type SessionTracker struct {
	// contains filtered or unexported fields
}

type TaskTracker struct {
	// contains filtered or unexported fields
}