domain

type Article struct {
	MessageID string
	Size      int
}

type ArticleRespository interface {
	FetchBody(messageID string) (io.Reader, error)
	Authenticate() error
	Close() error
}

type DownloadFile struct {
	Source    *NZBFile
	Segments  []NZBSegment
	CleanName string
	PartPath  string
	FinalPath string
	Size      int64
	// contains filtered or unexported fields
}

type DownloadJob struct {
	Segment    NZBSegment
	File       *DownloadFile
	Groups     []string
	Offset     int64
	RetryCount int
}

type DownloadResult struct {
	Job   DownloadJob
	Error error
}

type NZB struct {
	XMLName xml.Name  `xml:"nzb"`
	Files   []NZBFile `xml:"file"`
}

type NZBFile struct {
	Subject  string       `xml:"subject,attr"`
	Poster   string       `xml:"poster,attr"`
	Groups   []string     `xml:"groups>group"`
	Segments []NZBSegment `xml:"segments>segment"`
}

type NZBSegment struct {
	XMLName   xml.Name `xml:"segment"`
	Number    int      `xml:"number,attr"`
	Bytes     int64    `xml:"bytes,attr"`
	MessageID string   `xml:",chardata"`
}

type Provider interface {
	ID() string
	Priority() int
	MaxConnection() int
	Fetch(ctx context.Context, msgID string, groups []string) (io.Reader, error)
	TestConnection() error
	Close() error
}

type ProviderConfig struct {
	ID            string
	Host          string
	Port          int
	Username      string
	Password      string
	TLS           bool
	MaxConnection int
	Priority      int
}

type WriteRequest struct {
	FilePath string
	Offset   int64
	Data     []byte
	Done     chan error // Feedback loop for the worker
}