package download

import (
	"context"
	"sync"

	"github.com/open-policy-agent/opa/v1/ast"
	"github.com/open-policy-agent/opa/v1/bundle"
	"github.com/open-policy-agent/opa/v1/logging"
	"github.com/open-policy-agent/opa/v1/plugins/rest"
	"oras.land/oras-go/v2/content/oci"
)

type OCIDownloader struct {
	config           Config                              // downloader configuration for tuning polling and other downloader behaviour
	client           rest.Client                         // HTTP client to use for bundle downloading
	path             string                              // path for OCI image as <registry>/<org>/<repo>:<tag>
	localStorePath   string                              // path for the local OCI storage
	localStoreIsTemp bool                                // whether localStorePath should be removed when stopping
	stop             chan chan struct{}                  // used to signal plugin to stop running
	f                func(context.Context, Update) error // callback function invoked when download updates occur
	sizeLimitBytes   *int64                              // max bundle file size in bytes (passed to reader)
	bvc              *bundle.VerificationConfig
	wg               sync.WaitGroup
	triggerWG        sync.WaitGroup
	logger           logging.Logger
	stateMtx         sync.Mutex
	stopped          bool
	stopOnce         sync.Once
	persist          bool
	store            *oci.Store
	etag             string
	bundleParserOpts ast.ParserOptions
}