queue

type AddOptions struct {
	Priority       int
	InputFolder    string // overrides processor's inferred root for relative-path → NZB output
	DeleteOriginal *bool  // overrides watcher.DeleteOriginalFile for this job only
}

type CompletedItem struct {
	ID                   string     `json:"id"`
	Path                 string     `json:"path"`
	Size                 int64      `json:"size"`
	Priority             int        `json:"priority"`
	NzbPath              string     `json:"nzbPath"`
	CreatedAt            time.Time  `json:"createdAt"`
	CompletedAt          time.Time  `json:"completedAt"`
	JobData              []byte     `json:"jobData"`
	ScriptRetryCount     int        `json:"scriptRetryCount"`     // Number of script retry attempts
	ScriptFirstFailureAt *time.Time `json:"scriptFirstFailureAt"` // When the first script failure occurred
}

type FileJob struct {
	Path       string    `json:"path"`
	Size       int64     `json:"size"`
	Priority   int       `json:"priority"`
	CreatedAt  time.Time `json:"createdAt"`
	RetryCount int       `json:"retryCount"`
	// TransferID is a stable identifier assigned when the job is first created.
	// It is carried through the persisted job body so it survives queue retries
	// and crash recovery, letting the durable upload architecture reuse the same
	// manifest and Message-IDs across attempts.
	TransferID string `json:"transferId,omitempty"`
	// InputFolder is the root directory used to derive the relative path
	// for NZB output. When empty, the processor falls back to its existing
	// inference (FOLDER: prefix → parent, watch folder match, or file dir).
	InputFolder string `json:"inputFolder,omitempty"`
	// DeleteOriginal optionally overrides the global delete-original setting
	// for this specific job. nil → use the processor's default.
	DeleteOriginal *bool `json:"deleteOriginal,omitempty"`
}

type PaginatedResult struct {
	Items        []QueueItem `json:"items"`
	TotalItems   int         `json:"totalItems"`
	TotalPages   int         `json:"totalPages"`
	CurrentPage  int         `json:"currentPage"`
	ItemsPerPage int         `json:"itemsPerPage"`
	HasNext      bool        `json:"hasNext"`
	HasPrev      bool        `json:"hasPrev"`
}

type PaginationParams struct {
	Page   int    `json:"page"`   // 1-based page number
	Limit  int    `json:"limit"`  // Items per page
	SortBy string `json:"sortBy"` // Sort field: "created", "priority", "status", "filename", "size"
	Order  string `json:"order"`  // Sort order: "asc", "desc"
	Status string `json:"status"` // Status filter: "pending", "complete", "error", or "" for all
}

type PendingArticleCheck struct {
	ID              int64
	CompletedItemID string
	MessageID       string
	Groups          string // JSON-encoded array of group names
	Status          string // pending, verified, failed
	RetryCount      int
	NextRetryAt     time.Time
	FirstFailureAt  time.Time
	LastCheckedAt   *time.Time
	CreatedAt       time.Time
}

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

type QueueInterface interface {
	AddFile(ctx context.Context, path string, size int64) error
	AddFileWithOptions(ctx context.Context, path string, size int64, opts AddOptions) error
	GetQueueItems(params PaginationParams) (*PaginatedResult, error)
	RemoveFromQueue(id string) error
	ClearQueue() error
	GetQueueStats() (map[string]any, error)
	SetQueueItemPriorityWithReorder(ctx context.Context, id string, newPriority int) error
	IsPathInQueue(path string) (bool, error)
	PendingTotalSize(ctx context.Context) (int64, error)
}

type QueueItem struct {
	ID           string     `json:"id"`
	Path         string     `json:"path"`
	FileName     string     `json:"fileName"`
	Size         int64      `json:"size"`
	Status       string     `json:"status"`
	RetryCount   int        `json:"retryCount"`
	Priority     int        `json:"priority"`
	ErrorMessage *string    `json:"errorMessage"`
	CreatedAt    time.Time  `json:"createdAt"`
	UpdatedAt    time.Time  `json:"updatedAt"`
	CompletedAt  *time.Time `json:"completedAt"`
	NzbPath      *string    `json:"nzbPath"`
	// Script execution tracking fields
	ScriptStatus      *string    `json:"scriptStatus"` // null, completed, pending_retry, failed_permanent
	ScriptRetryCount  int        `json:"scriptRetryCount"`
	ScriptLastError   *string    `json:"scriptLastError"`
	ScriptNextRetryAt *time.Time `json:"scriptNextRetryAt"`
	// Verification status for completed items (null for non-completed)
	VerificationStatus *string `json:"verificationStatus"` // verified, pending_verification, verification_failed
}