download

type Adopter interface {
	AdoptManualTorrents(ctx context.Context) ([]uint32, error)
}

type Checker interface {
	CheckStatus(ctx context.Context) ([]CompletedDownload, error)
	ReconcileEpisodeStatuses(ctx context.Context) error
}

type Cleaner interface {
	PurgeOldRecords(ctx context.Context) error
	PurgeOrphanedTorrents(ctx context.Context) error
}

type Client interface {
	AddTorrent(ctx context.Context, src TorrentSource) (string, error)
	GetTorrent(ctx context.Context, hash string) (*Torrent, error)
	ListTorrents(ctx context.Context) ([]Torrent, error)
	RemoveTorrent(ctx context.Context, hash string, deleteFiles bool) error
	PauseTorrent(ctx context.Context, hash string) error
	ResumeTorrent(ctx context.Context, hash string) error
	TestConnection(ctx context.Context) error
}

type CompletedDownload struct {
	Record   *ent.DownloadRecord
	SavePath string
}

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

type Downloader interface {
	Test(ctx context.Context, p TestParams) error
	TestByName(ctx context.Context, name string) error
	Grab(
		ctx context.Context,
		result indexer.SearchResult,
		movieID uint32,
	) (*ent.DownloadRecord, error)
	GrabEpisode(
		ctx context.Context,
		result indexer.SearchResult,
		episodeID uint32,
	) (*ent.DownloadRecord, error)
	CheckStatus(ctx context.Context) ([]CompletedDownload, error)
	ReconcileEpisodeStatuses(ctx context.Context) error
	RemoveTorrent(
		ctx context.Context,
		downloadClientName string,
		torrentHash string,
	) error
	Queue(ctx context.Context) (QueueSnapshot, error)
	CancelQueueItem(ctx context.Context, recordID uint32) error
	PauseQueueItem(ctx context.Context, recordID uint32) error
	ResumeQueueItem(ctx context.Context, recordID uint32) error
}

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

type QueueEntry struct {
	RecordID     uint32
	Status       string // downloading | importing | paused | error
	Title        string
	Quality      string
	ReleaseGroup string
	Movie        *ent.Movie
	// Episode is set for TV download records (with season + show eager-loaded);
	// nil for movie records. Drives the "<show> · SxxExx" row title.
	Episode        *ent.Episode
	Indexer        string
	DownloadClient string
	Size           int64
	Progress       float64
	DownloadSpeed  int64
	ETA            int64
	FailureReason  string
	CreatedAt      time.Time
}

type QueueSnapshot struct {
	Items       []QueueEntry
	RefreshedAt time.Time
}

type TestParams struct {
	ClientType string
	Host       string
	Port       uint16
	UseSSL     bool
	AuthMethod string
	Username   string
	Password   string
	APIKey     string
}

type Torrent struct {
	Hash     string
	Name     string
	Status   TorrentStatus
	Progress float64
	Size     int64
	SavePath string
	// DownloadSpeed is bytes/sec (0 when idle/unknown). ETA is seconds to
	// completion; the qBittorrent ∞ sentinel (8640000) is normalized to 0.
	DownloadSpeed int64
	ETA           int64
}

type TorrentSource struct {
	Bytes  []byte // raw .torrent file contents
	Magnet string // magnet:?xt=urn:btih:... URI
}

type TorrentStatus string

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