core

type DownloadService interface {
	// List returns the status of all active and completed downloads.
	List() ([]types.DownloadStatus, error)

	// History returns completed downloads
	History() ([]types.DownloadEntry, error)

	// Add queues a new download.
	Add(url string, path string, filename string, mirrors []string, headers map[string]string, isExplicitCategory bool, totalSize int64, supportsRange bool) (string, error)

	// AddWithID queues a new download with a caller-provided ID.
	AddWithID(url string, path string, filename string, mirrors []string, headers map[string]string, id string, totalSize int64, supportsRange bool) (string, error)

	// Pause pauses an active download.
	Pause(id string) error

	// Resume resumes a paused download.
	Resume(id string) error

	// ResumeBatch resumes multiple paused downloads efficiently.
	ResumeBatch(ids []string) []error

	// UpdateURL updates the URL of a paused or errored download
	UpdateURL(id string, newURL string) error

	// Delete cancels and removes a download.
	Delete(id string) error

	// StreamEvents returns a channel that receives real-time download events.
	// For local mode, this is a direct channel.
	// For remote mode, this is sourced from SSE.
	StreamEvents(ctx context.Context) (<-chan interface{}, func(), error)

	// Publish emits an event into the service's event stream.
	Publish(msg interface{}) error

	// GetStatus returns a status for a single download by id.
	GetStatus(id string) (*types.DownloadStatus, error)

	// Shutdown handles graceful shutdown of the service
	Shutdown() error
}

type LifecycleHooks struct {
	Pause       func(id string) error
	Resume      func(id string) error
	ResumeBatch func(ids []string) []error
	Cancel      func(id string) error
	UpdateURL   func(id, newURL string) error
}

type LocalDownloadService struct {
	Pool    *download.WorkerPool
	InputCh chan interface{}
	// contains filtered or unexported fields
}

type RemoteDownloadService struct {
	BaseURL   string
	Token     string
	Client    *http.Client
	SSEClient *http.Client
	// contains filtered or unexported fields
}