manifest

type ChainManifestFetcher interface {
	// FetchManifest attempts to fetch a manifest from the chain
	// Returns nil if no manifest is stored on-chain for this deployment
	FetchManifest(ctx context.Context, owner string, dseq uint64) (maniv2beta3.Manifest, error)
}

type ChainManifestResponse struct {
	Owner     string `json:"owner"`
	DSeq      uint64 `json:"dseq"`
	Manifest  []byte `json:"manifest"`
	SDL       string `json:"sdl"`
	Hash      []byte `json:"hash"`
	Version   uint32 `json:"version"`
	CreatedAt int64  `json:"created_at"`
	UpdatedAt int64  `json:"updated_at"`
	Found     bool   `json:"found"`
}

type Client interface {
	Submit(context.Context, dtypes.DeploymentID, manifest.Manifest) error
	IsActive(context.Context, dtypes.DeploymentID) (bool, error)
}

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

type ManifestBackend interface {
	// Get returns the stored bytes and their sha256 hex digest. A
	// non-nil error signals "not found" or a transport-level problem;
	// callers should treat errors as cache misses and fall back to
	// authoritative sources (on-chain, default manifest, etc).
	Get(ctx context.Context, key string) ([]byte, string, error)

	// Put writes the given bytes to the backend and returns their
	// sha256 hex digest. Implementations must be safe under concurrent
	// writes with the same key (last-write-wins is acceptable).
	Put(ctx context.Context, key string, body []byte) (sha string, err error)

	// Name identifies the backend in logs / the /health response.
	Name() string

	// Ping round-trips a tiny key to prove the backend is reachable
	// and writeable. Used by the /health handler and the manifest
	// store watchdog. Implementations should keep the probe cheap.
	Ping(ctx context.Context) error
}

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

type S3BackendConfig struct {
	Bucket          string
	Endpoint        string // empty means AWS default resolver
	Region          string // required; defaults to "us-east-1"
	AccessKeyID     string
	SecretAccessKey string
	// UsePathStyle flips virtual-host-style addressing off. MinIO and
	// many other self-hosted providers require path-style.
	UsePathStyle bool
	// KeyPrefix is prepended to every key (e.g. "manifests/"). Left
	// empty means keys land at the bucket root.
	KeyPrefix string
}

type Service interface {
	StatusClient
	Client
	Done() <-chan struct{}
}

type ServiceConfig struct {
	HTTPServicesRequireAtLeastOneHost bool
	ManifestTimeout                   time.Duration
	RPCQueryTimeout                   time.Duration
	CachedResultMaxAge                time.Duration
}

type StatusClient interface {
	Status(context.Context) (*apclient.ManifestStatus, error)
	StatusV1(context.Context) (*provider.ManifestStatus, error)
}