store

type GetOption func(*GetOptions)

type GetOptions struct {
	WithExports bool
}

type ImageBuild struct {
	model.Resource

	// The desired state, stored as opaque JSON object.
	Spec *model.JSONField[domain.ImageBuildSpec] `gorm:"type:jsonb"`

	// The last reported state, stored as opaque JSON object.
	Status *model.JSONField[domain.ImageBuildStatus] `gorm:"type:jsonb"`

	// Logs contains the last 500 lines of build logs for completed builds.
	// This is separate from Status to keep the ImageBuild resource lightweight.
	// Logs are only accessible via the /log endpoint.
	Logs *string `gorm:"type:text"`
}

type ImageBuildDomainOption func(*imageBuildDomainOptions)

type ImageBuildStore interface {
	Create(ctx context.Context, orgId uuid.UUID, imageBuild *domain.ImageBuild) (*domain.ImageBuild, error)
	Get(ctx context.Context, orgId uuid.UUID, name string, opts ...GetOption) (*domain.ImageBuild, error)
	List(ctx context.Context, orgId uuid.UUID, listParams flightctlstore.ListParams, opts ...ListOption) (*domain.ImageBuildList, error)
	Delete(ctx context.Context, orgId uuid.UUID, name string) (*domain.ImageBuild, error)
	UpdateStatus(ctx context.Context, orgId uuid.UUID, imageBuild *domain.ImageBuild) (*domain.ImageBuild, error)
	UpdateLastSeen(ctx context.Context, orgId uuid.UUID, name string, timestamp time.Time) error
	UpdateLogs(ctx context.Context, orgId uuid.UUID, name string, logs string) error
	GetLogs(ctx context.Context, orgId uuid.UUID, name string) (string, error)
	InitialMigration(ctx context.Context) error
}

type ImageExport struct {
	model.Resource

	// The desired state, stored as opaque JSON object.
	Spec *model.JSONField[domain.ImageExportSpec] `gorm:"type:jsonb"`

	// The last reported state, stored as opaque JSON object.
	Status *model.JSONField[domain.ImageExportStatus] `gorm:"type:jsonb"`

	// Logs contains the last 500 lines of export logs for completed exports.
	// This is separate from Status to keep the ImageExport resource lightweight.
	// Logs are only accessible via the /log endpoint.
	Logs *string `gorm:"type:text"`
}

type ImageExportStore interface {
	Create(ctx context.Context, orgId uuid.UUID, imageExport *domain.ImageExport) (*domain.ImageExport, error)
	Get(ctx context.Context, orgId uuid.UUID, name string) (*domain.ImageExport, error)
	List(ctx context.Context, orgId uuid.UUID, listParams flightctlstore.ListParams) (*domain.ImageExportList, error)
	Delete(ctx context.Context, orgId uuid.UUID, name string) (*domain.ImageExport, error)
	UpdateStatus(ctx context.Context, orgId uuid.UUID, imageExport *domain.ImageExport) (*domain.ImageExport, error)
	UpdateLastSeen(ctx context.Context, orgId uuid.UUID, name string, timestamp time.Time) error
	UpdateLogs(ctx context.Context, orgId uuid.UUID, name string, logs string) error
	GetLogs(ctx context.Context, orgId uuid.UUID, name string) (string, error)
	InitialMigration(ctx context.Context) error
}

type ImagePromotion struct {
	model.Resource

	// The desired state, stored as opaque JSON object.
	Spec *model.JSONField[domain.ImagePromotionSpec] `gorm:"type:jsonb"`

	// The last reported state, stored as opaque JSON object.
	Status *model.JSONField[domain.ImagePromotionStatus] `gorm:"type:jsonb"`
}

type ImagePromotionStore interface {
	Create(ctx context.Context, orgId uuid.UUID, pub *domain.ImagePromotion) (*domain.ImagePromotion, error)
	Get(ctx context.Context, orgId uuid.UUID, name string) (*domain.ImagePromotion, error)
	List(ctx context.Context, orgId uuid.UUID, listParams flightctlstore.ListParams) (*domain.ImagePromotionList, error)
	Delete(ctx context.Context, orgId uuid.UUID, name string) (*domain.ImagePromotion, error)
	// Update updates the spec, labels, and status of an ImagePromotion atomically.
	// Used for PATCH/PUT operations that add new export formats.
	Update(ctx context.Context, orgId uuid.UUID, pub *domain.ImagePromotion) (*domain.ImagePromotion, error)
	UpdateStatus(ctx context.Context, orgId uuid.UUID, pub *domain.ImagePromotion) (*domain.ImagePromotion, error)
	// ListPendingForBuild returns all WaitingForArtifacts and AmendmentFailed promotions for the given imageBuildRef.
	// Used to re-evaluate promotions when an ImageBuild or ImageExport status changes.
	ListPendingForBuild(ctx context.Context, orgId uuid.UUID, imageBuildRef string) ([]domain.ImagePromotion, error)
	InitialMigration(ctx context.Context) error
}

type ListOption func(*ListOptions)

type ListOptions struct {
	WithExports bool
}

type Store interface {
	ImageBuild() ImageBuildStore
	ImageExport() ImageExportStore
	ImagePromotion() ImagePromotionStore
	RunMigrations(ctx context.Context) error
	Ping() error
	Close() error
}