asynccharmdownloader

type ApplicationService interface {
	// WatchApplicationsWithPendingCharms returns a watcher that notifies of
	// changes to applications that reference charms that have not yet been
	// downloaded.
	// Each string will be an individual application ID. It's possible to
	// have the same application ID multiple times in the list.
	WatchApplicationsWithPendingCharms(ctx context.Context) (watcher.StringsWatcher, error)

	// GetAsyncCharmDownloadInfo reserves a charm download slot for the specified
	// application. If the charm is already being downloaded, the method will
	// return [applicationerrors.AlreadyDownloadingCharm]. The charm download
	// information is returned which includes the charm name, origin and the
	// digest.
	GetAsyncCharmDownloadInfo(ctx context.Context, appID application.ID) (domainapplication.CharmDownloadInfo, error)

	// ResolveCharmDownload resolves the charm download slot for the specified
	// application. The method will update the charm with the specified charm
	// information.
	ResolveCharmDownload(ctx context.Context, appID application.ID, resolve domainapplication.ResolveCharmDownload) error
}

type Config struct {
	ApplicationService     ApplicationService
	HTTPClientGetter       corehttp.HTTPClientGetter
	NewHTTPClient          NewHTTPClientFunc
	NewDownloader          NewDownloaderFunc
	NewAsyncDownloadWorker NewAsyncDownloadWorkerFunc
	Logger                 logger.Logger
	Clock                  clock.Clock
}

type Downloader interface {
	// Download looks up the requested charm using the appropriate store, downloads
	// it to a temporary file and passes it to the configured storage API so it can
	// be persisted.
	//
	// The resulting charm is verified to be the right hash. It expected that the
	// origin will always have the correct hash following this call.
	//
	// Returns [ErrInvalidHash] if the hash of the downloaded charm does not match
	// the expected hash.
	Download(ctx context.Context, curl *url.URL, hash string) (*charmdownloader.DownloadResult, error)
}

type ManifoldConfig struct {
	DomainServicesName     string
	HTTPClientName         string
	NewDownloader          NewDownloaderFunc
	NewHTTPClient          NewHTTPClientFunc
	NewAsyncDownloadWorker NewAsyncDownloadWorkerFunc
	Logger                 logger.Logger
	Clock                  clock.Clock
}

type NewAsyncDownloadWorkerFunc func(
	appID application.ID,
	applicationService ApplicationService,
	downloader Downloader,
	clock clock.Clock,
	logger logger.Logger,
) worker.Worker

type NewDownloaderFunc func(charmhub.HTTPClient, logger.Logger) Downloader

type NewHTTPClientFunc func(context.Context, corehttp.HTTPClientGetter) (corehttp.HTTPClient, error)

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