domain

type DownloadFile struct {
	// Persistent fields (saved in release_files table)
	ID        int64
	ReleaseID string
	FileName  string // Sanitized filename
	Size      int64  // Expected total size from NZB
	Index     int    // Original order in the NZB
	IsPars    bool   // True if the file is a repar volume
	Subject   string
	Date      int64
	Groups    []string
	Poster    string

	// App State (calulated at hydration)
	PartPath   string
	FinalPath  string
	IsComplete bool
	Password   string

	Segments []Segment
	// contains filtered or unexported fields
}

type JobStatus string

type PreparationResult struct {
	Tasks     []*DownloadFile
	TotalSize int64
	Password  string
}

type QueueItem struct {
	ID        string   // Unique KSUID for this job
	ReleaseID string   // Reference to the shared Release
	Release   *Release // Populated via JOIN from store
	Status    JobStatus
	OutDir    string

	// MIlestone 3 snapshot/reference fields
	SourceKind          string // manaual | aggregator | usenet_index
	SourceReleaseID     string
	ReleaseTitle        string
	ReleaseSize         int64
	ReleaseSnapshotJSON string

	// payload durability fields.
	PayloadMode string // cached | ephemeral
	Resumable   bool

	// Tasks are only present in RAM. When loaded from queue_items,
	// this is nil until hydrated from BLOB store.
	Tasks []*DownloadFile

	BytesWritten atomic.Int64

	CreatedAt time.Time
	UpdatedAt time.Time
	StartedAt time.Time
	// CompletedAt is when the queue item reaches a terminal state.
	CompletedAt time.Time

	// Historical metrics persisted for queue history.
	DownloadedBytes    int64
	AvgBps             int64
	DownloadSeconds    int64
	PostProcessSeconds int64

	// Internal runtime markers used to compute durations.
	DownloadStartedAt   time.Time
	ProcessingStartedAt time.Time

	Error *string

	CancelFunc context.CancelFunc
}

type QueueItemEvent struct {
	ID        int64
	QueueID   string
	Stage     string
	Status    string
	Message   string
	MetaJSON  string
	CreatedAt time.Time
}

type Release struct {
	ID              string    `json:"id"`
	Title           string    `json:"title"`
	Password        string    `json:"password"`
	GUID            string    `json:"guid"`
	Source          string    `json:"source"`
	DownloadURL     string    `json:"downloadUrl"`
	Size            int64     `json:"size"`
	PublishDate     time.Time `json:"publishDate"`
	Category        string    `json:"category"`
	CachePresent    bool      `json:"cache_present"`
	CacheBlobSize   int64     `json:"cache_blob_size"`
	CacheVerifiedAt time.Time `json:"cache_verified_at"`
	RedirectAllowed bool
	Poster          string
}

type Segment struct {
	Number      int
	Bytes       int64
	MessageID   string
	MissingFrom map[string]bool
}