releaseworkflow

type Application interface {
	Continue(context.Context, string, api.ContinueReleaseWorkflowRequest) (CommandResult, error)
	StartUpload(context.Context, string, api.CreateReleaseWorkflowUploadRequest) (CommandResult, error)
	SubmitUploadFeedback(context.Context, string, api.WorkflowID, api.ReleaseWorkflowUploadFeedback) (CommandResult, error)
	Execute(context.Context, string, Command) (CommandResult, error)
	Start(context.Context, string, Command) (api.WorkflowOperationStatus, error)
	Workflow(context.Context, string, api.WorkflowID) (api.ReleaseWorkflow, error)
	Current(context.Context, string, api.WorkflowID) (CommandResult, error)
	Operation(context.Context, string, api.WorkflowID, api.WorkflowOperationID) (api.WorkflowOperationStatus, error)
	CancelOperation(context.Context, string, api.WorkflowID, api.WorkflowOperationID) (api.WorkflowOperationStatus, error)
	MediaPlan(context.Context, string, api.WorkflowID) (api.MediaPlan, error)
	PreviewFrame(context.Context, string, api.WorkflowID, api.WorkflowRevision, string, float64) (api.FramePreview, error)
	PreviewArtifact(context.Context, string, api.WorkflowID, api.PublicResourceID) (MediaArtifactContent, error)
	StageMediaResource(context.Context, string, api.WorkflowID, api.WorkflowRevision, StagedMediaContent) (api.WorkflowResourceRef, error)
	MediaArtifact(context.Context, string, api.WorkflowID, api.MediaArtifactSetRef, api.PublicResourceID) (MediaArtifactContent, error)
}

type ApproveTrackersCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Approval         api.TrackerApproval
	IdempotencyKey   string
}

type AttachMediaArtifactsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Media            *api.MediaArtifactSetRef
	Attachments      []api.MediaAttachment
	IdempotencyKey   string
}

type CancelWorkflowCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Reason           string
	IdempotencyKey   string
}

type CaptureMediaCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Instructions     api.MediaCaptureInstructions
	IdempotencyKey   string
}

type CheckDuplicatesCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	SkipRemote       bool
	CheckOrdinal     uint8
	IdempotencyKey   string
}

type Clock interface {
	Now() time.Time
}

type Command interface {
	// contains filtered or unexported methods
}

type CommandResult = api.ReleaseWorkflowCurrent

type CompositeUploadCommand struct {
	WorkflowID         api.WorkflowID
	ExpectedRevision   api.WorkflowRevision
	SessionFingerprint api.WorkflowFingerprint
	Goal               api.WorkflowGoal
	IdempotencyKey     string
}

type CompositeUploadMediaInputs struct {
	Comparisons []StagedMediaContent
	DVDMenus    []StagedMediaContent
}

type CreateWorkflowCommand struct {
	WorkflowID          api.WorkflowID
	Instructions        api.ReleaseFactInstructions
	IdempotencyKey      string
	RequestFingerprint  api.WorkflowFingerprint
	TrackerDecisionMode TrackerDecisionMode
	Composite           *compositeUploadSession
}

type DecideDuplicatesCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Decisions        map[api.TrackerID]api.DupeDecision
	IdempotencyKey   string
}

type DeleteMediaArtifactsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Media            api.MediaArtifactSetRef
	ArtifactIDs      []api.PublicResourceID
	IdempotencyKey   string
}

type DescriptionBuilder interface {
	Fingerprints(
		context.Context,
		api.ReleaseRef,
		api.TrackerReleaseProjectionSet,
		api.MediaArtifactSet,
		any,
		api.DescriptionInstructions,
	) (api.WorkflowFingerprint, api.WorkflowFingerprint, error)
	Build(
		context.Context,
		api.ReleaseRef,
		api.TrackerReleaseProjectionSet,
		api.MediaArtifactSet,
		any,
		api.DescriptionInstructions,
		time.Time,
	) (api.DescriptionSet, error)
}

type DryRunUploadsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	NoSeed           bool
	TrackerIDs       []api.TrackerID
	IdempotencyKey   string
}

type DupeAssessmentBuilder interface {
	Build(
		context.Context,
		api.DuplicateSubject,
		api.TrackerReleaseProjectionSet,
		api.TrackerPreflightAssessment,
		time.Time,
		bool,
	) (api.DupeAssessment, any, error)
}

type DurabilityRepository interface {
	AcceptIntent(context.Context, api.ReleaseWorkflowIntentRecord) (api.ReleaseWorkflowIntentRecord, bool, error)
	SaveContinuation(context.Context, api.ReleaseWorkflowContinuationRecord) error
	AppendEvents(context.Context, string, api.WorkflowID, []api.WorkflowEvent) ([]api.WorkflowEvent, error)
	LoadEvents(context.Context, string, api.WorkflowID, uint64, int) ([]api.WorkflowEvent, error)
	BeginEffect(context.Context, api.ReleaseWorkflowEffectRecord) (api.ReleaseWorkflowEffectRecord, bool, error)
	CompleteEffect(context.Context, api.WorkflowEffectStatus, api.ReleaseWorkflowEffectRecord) error
	MarkOperationEffectsUnknown(context.Context, string, api.WorkflowID, api.WorkflowOperationID, time.Time) error
	ResolveEffectUnknown(context.Context, string, api.WorkflowID, api.WorkflowExternalEffectKind, string, time.Time) error
	LoadWork(context.Context, string, api.WorkflowID, api.WorkflowOperationID) (api.ReleaseWorkflowWorkRecord, error)
	ClaimWork(context.Context, api.ReleaseWorkflowWorkRecord) error
	RenewWork(context.Context, api.ReleaseWorkflowWorkRecord) error
	CheckpointWork(context.Context, api.ReleaseWorkflowWorkRecord) error
	CompleteWork(context.Context, api.ReleaseWorkflowWorkRecord) error
}

type DurablePrivateResource interface {
	MarshalPrivateResource() (kind string, payload []byte, err error)
}

type EvaluateInputReadinessCommand struct {
	WorkflowID          api.WorkflowID
	ExpectedRevision    api.WorkflowRevision
	TrackerIDs          []api.TrackerID
	TrackerInputAnswers map[api.TrackerID]map[string]*string
	IdempotencyKey      string
}

type ExecuteUploadsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	NoSeed           bool
	TrackerIDs       []api.TrackerID
	Interaction      api.InteractionMode
	IdempotencyKey   string
}

type GenerateDescriptionsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Instructions     api.DescriptionInstructions
	IdempotencyKey   string
}

type IDGenerator interface {
	NewID(prefix string) (string, error)
}

type IncrementalMediaArtifactBuilder interface {
	BuildIncremental(
		context.Context,
		api.ReleaseRef,
		api.TrackerReleaseProjectionSet,
		api.MediaCaptureInstructions,
		*api.MediaArtifactSet,
		any,
		time.Time,
	) (api.MediaArtifactSet, RetainedMediaResource, error)
}

type InputReadinessEvaluator interface {
	Requirements(context.Context, []api.TrackerID) (api.MetadataRequirementSet, error)
	Evaluate(context.Context, api.UploadSubject, []api.TrackerID) (api.InputReadinessEvaluation, error)
}

type InvalidateTrackersCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	TrackerIDs       []api.TrackerID
	Reason           string
	IdempotencyKey   string
}

type MediaArtifactBuilder interface {
	Build(
		context.Context,
		api.ReleaseRef,
		api.TrackerReleaseProjectionSet,
		api.MediaCaptureInstructions,
		time.Time,
	) (api.MediaArtifactSet, any, error)
}

type MediaArtifactContent struct {
	Body        io.ReadCloser
	ContentType string
}

type MediaArtifactMutator interface {
	Attach(
		context.Context,
		api.ReleaseRef,
		api.TrackerReleaseProjectionSet,
		*api.MediaArtifactSet,
		any,
		[]StagedMediaAttachment,
		time.Time,
	) (api.MediaArtifactSet, RetainedMediaResource, error)
	UploadImages(
		context.Context,
		api.ReleaseRef,
		api.TrackerReleaseProjectionSet,
		api.MediaArtifactSet,
		any,
		[]api.PublicResourceID,
		string,
		bool,
		time.Time,
	) (api.MediaArtifactSet, RetainedMediaResource, []api.HostedImageAttempt, error)
	RemoveHostedImages(
		context.Context,
		api.ReleaseRef,
		api.MediaArtifactSet,
		any,
		[]api.PublicResourceID,
		time.Time,
	) (api.MediaArtifactSet, RetainedMediaResource, error)
}

type MediaPlanner interface {
	Plan(context.Context, api.ReleaseRef, api.TrackerReleaseProjectionSet, time.Time) (api.MediaPlan, error)
	PreviewFrame(context.Context, api.ReleaseRef, string, float64) (MediaPreviewContent, error)
}

type MediaPreviewContent struct {
	// DiscID identifies the prepared disc used for this preview.
	DiscID string
	// DiscName is the safe page-facing label for DiscID.
	DiscName    string
	Bytes       []byte
	ContentType string
	Width       int
	Height      int
}

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

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

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

type OperationRepository interface {
	CreateOperation(context.Context, api.ReleaseWorkflowOperationRecord) (api.ReleaseWorkflowOperationRecord, bool, error)
	LoadOperation(context.Context, string, api.WorkflowID, api.WorkflowOperationID) (api.ReleaseWorkflowOperationRecord, error)
	LoadOperationByIdempotency(context.Context, string, api.WorkflowID, string, string) (api.ReleaseWorkflowOperationRecord, error)
	LoadLatestOperation(context.Context, string, api.WorkflowID) (api.ReleaseWorkflowOperationRecord, error)
	SaveOperation(context.Context, uint64, api.ReleaseWorkflowOperationRecord) error
	ListActiveOperations(context.Context) ([]api.ReleaseWorkflowOperationRecord, error)
}

type Option func(*Module) error

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

type PreflightTrackersCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	InputFingerprint api.WorkflowFingerprint
	Interaction      api.InteractionMode
	ExecutionMode    api.WorkflowExecutionMode
	IdempotencyKey   string
}

type PrepareReleaseCommand struct {
	WorkflowID          api.WorkflowID
	ExpectedRevision    api.WorkflowRevision
	Input               api.PrepareInput
	TrackerIDs          []api.TrackerID
	TrackerInputAnswers map[api.TrackerID]map[string]*string
	IdempotencyKey      string
}

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

type PrivateResourceCodec struct {
	Kind   string
	Decode func([]byte) (any, error)
}

type PrivateResourceStore interface {
	Put(ownerID string, workflowID api.WorkflowID, resourceID string, value any, expiresAt time.Time) error
	Get(ownerID string, workflowID api.WorkflowID, resourceID string, now time.Time) (any, error)
	Consume(ownerID string, workflowID api.WorkflowID, resourceID string, now time.Time) (any, error)
	Delete(ownerID string, workflowID api.WorkflowID, resourceID string)
	InvalidateWorkflow(ownerID string, workflowID api.WorkflowID)
	// InvalidateWorkflowExcept invalidates one workflow while retaining named resources.
	InvalidateWorkflowExcept(ownerID string, workflowID api.WorkflowID, preservedResourceIDs ...string)
	InvalidateAll()
}

type ProjectTrackersCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	TrackerIDs       []api.TrackerID
	Instructions     map[api.TrackerID]api.TrackerProjectionInstructions
	ExecutionMode    api.WorkflowExecutionMode
	IdempotencyKey   string
}

type RegisteredArtifactAuthority struct {
	ClientSubject api.ClientSubject
	Torrents      map[api.TrackerID]api.TorrentResult
}

type ReleasePreparer interface {
	CorrectionsCurrent(context.Context, string, uint64) (bool, error)
	Prepare(context.Context, api.PrepareInput) (api.PrepareResult, error)
	ResolveInput(context.Context, api.PrepareInput, api.ReleaseCorrectionUpdate) (api.ResolvedPreparationInput, error)
	PrepareResolved(context.Context, api.ResolvedPreparationInput) (api.PrepareResult, error)
	ResolveDisplay(context.Context, api.ReleaseRef) (api.PreparedReleaseDisplay, error)
	ResolveUploadSubject(context.Context, api.UploadSubjectInput) (api.UploadSubject, error)
	ResolveDuplicateSubject(context.Context, api.DuplicateCheckInput) (api.DuplicateSubject, error)
}

type ReleasePreparerFunc struct {
	CorrectionsCurrentFunc func(context.Context, string, uint64) (bool, error)
	PrepareFunc            func(context.Context, api.PrepareInput) (api.PrepareResult, error)
	ResolveInputFunc       func(context.Context, api.PrepareInput, api.ReleaseCorrectionUpdate) (api.ResolvedPreparationInput, error)
	PrepareResolvedFunc    func(context.Context, api.ResolvedPreparationInput) (api.PrepareResult, error)
	DisplayFunc            func(context.Context, api.ReleaseRef) (api.PreparedReleaseDisplay, error)
	SubjectFunc            func(context.Context, api.UploadSubjectInput) (api.UploadSubject, error)
	DuplicateFunc          func(context.Context, api.DuplicateCheckInput) (api.DuplicateSubject, error)
}

type RemoveHostedImagesCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Media            api.MediaArtifactSetRef
	ArtifactIDs      []api.PublicResourceID
	IdempotencyKey   string
}

type ReorderMediaArtifactsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Media            api.MediaArtifactSetRef
	ArtifactIDs      []api.PublicResourceID
	IdempotencyKey   string
}

type ReplaceFactInstructionsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Instructions     api.ReleaseFactInstructions
	CorrectionPatch  *api.ReleaseCorrectionPatch
	SourcePath       string
	IdempotencyKey   string
}

type Repository interface {
	Create(context.Context, string, string, api.WorkflowFingerprint, State) (State, bool, error)
	Load(context.Context, string, api.WorkflowID) (State, error)
	Save(context.Context, string, api.WorkflowRevision, State) error
	Delete(context.Context, string, api.WorkflowID) error
}

type ResetDescriptionOverrideCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Descriptions     api.DescriptionSetRef
	GroupKey         string
	IdempotencyKey   string
}

type ResetReleaseCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Input            api.PrepareInput
	TrackerIDs       []api.TrackerID
	IdempotencyKey   string
}

type ResolveActionCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Answer           api.RequiredActionAnswer
	IdempotencyKey   string
}

type RetainedMediaCommitter interface {
	Commit(context.Context) error
}

type RetainedMediaResource interface {
	OpenArtifact(context.Context, api.MediaArtifactSet, api.PublicResourceID) (MediaArtifactContent, error)
	DeleteArtifacts(context.Context, api.MediaArtifactSet, []api.PublicResourceID) (RetainedMediaResource, error)
}

type RetainedUploadExecution interface {
	ResolveAction(context.Context, api.TrackerID, api.RequiredActionKind, bool) (api.UploadPlanTracker, error)
	Execute(context.Context, []api.TrackerID) ([]api.UploadTrackerResult, error)
	RegisteredArtifactAuthority() RegisteredArtifactAuthority
	Release() error
}

type RetryClientInjectionsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Retry            api.ClientInjectionRetryRef
	IdempotencyKey   string
}

type RetryFailedUploadsCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Retry            api.FailedTrackerRetryRef
	NoSeed           bool
	IdempotencyKey   string
}

type SaveDescriptionOverrideCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Descriptions     api.DescriptionSetRef
	GroupKey         string
	Source           string
	IdempotencyKey   string
}

type SelectBlurayCandidateCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	ReleaseID        string
	IdempotencyKey   string
}

type SetMediaSelectionCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Media            api.MediaArtifactSetRef
	ArtifactIDs      []api.PublicResourceID
	Selected         bool
	IdempotencyKey   string
}

type StagedMediaAttachment struct {
	Attachment api.MediaAttachment
	Content    StagedMediaContent
}

type StagedMediaContent struct {
	Name        string
	Bytes       []byte
	ContentType string
}

type State struct {
	OwnerID             string
	ProcessEpoch        string
	TrackerDecisionMode TrackerDecisionMode
	Workflow            api.ReleaseWorkflow
	Corrections         *api.ReleaseCorrectionsSnapshot
	// PendingCorrectionConfirmation retains workflow-validated confirmation
	// authority until canonical preparation completes.
	PendingCorrectionConfirmation *api.CorrectionConfirmation
	PreparationInput              *api.PrepareInput
	// PreparationDemand retains normalized metadata requirements separately because
	// PrepareInput omits its internal-only requirements from persisted JSON used for hydration.
	PreparationDemand      api.MetadataRequirementSet
	TrackerInputAnswers    map[api.TrackerID]map[string]string
	FactInstructions       map[api.ReleaseFactInstructionSnapshotID]api.ReleaseFactInstructionSnapshot
	Releases               map[api.ReleaseSnapshotID]api.ReleaseSnapshot
	InputReadiness         map[api.InputReadinessSnapshotID]api.InputReadinessSnapshot
	Catalogs               map[api.TrackerCatalogSnapshotID]api.TrackerCatalogSnapshot
	Runtimes               map[api.TrackerRuntimeSnapshotID]api.TrackerRuntimeSnapshot
	Selections             map[api.TrackerSelectionID]api.TrackerSelection
	ProjectionInstructions map[api.TrackerProjectionInstructionSnapshotID]api.TrackerProjectionInstructionSnapshot
	Projections            map[api.TrackerReleaseProjectionSetID]api.TrackerReleaseProjectionSet
	Preflights             map[api.TrackerPreflightAssessmentID]api.TrackerPreflightAssessment
	Dupes                  map[api.DupeAssessmentID]api.DupeAssessment
	TrackerApprovals       map[api.TrackerApprovalSnapshotID]api.TrackerApprovalSnapshot
	Media                  map[api.MediaArtifactSetID]api.MediaArtifactSet
	Descriptions           map[api.DescriptionSetID]api.DescriptionSet
	DryRuns                map[api.UploadDryRunResultID]api.UploadDryRunResult
	UploadResults          map[api.UploadResultID]api.UploadResult
	Operations             map[api.WorkflowOperationID]api.WorkflowOperationStatus
	Receipts               map[string]commandReceipt
	Composite              *compositeUploadSession
}

type TrackerDecisionMode string

type TrackerPreflightBuilder interface {
	Build(
		context.Context,
		api.UploadSubject,
		api.TrackerCatalogSnapshot,
		api.TrackerRuntimeSnapshot,
		api.TrackerReleaseProjectionSet,
		time.Time,
	) (api.TrackerPreflightAssessment, []api.TrackerReleaseProjection, error)
}

type TrackerProjectionBuilder interface {
	Build(
		context.Context,
		api.ReleaseSnapshot,
		api.UploadSubject,
		[]api.TrackerID,
		map[api.TrackerID]api.TrackerProjectionInstructions,
		map[api.TrackerID]api.WorkflowFingerprint,
		api.WorkflowExecutionMode,
	) (
		api.TrackerCatalogSnapshot,
		api.TrackerRuntimeSnapshot,
		api.TrackerSelection,
		api.TrackerReleaseProjectionSet,
		error,
	)
}

type UploadMediaImagesCommand struct {
	WorkflowID       api.WorkflowID
	ExpectedRevision api.WorkflowRevision
	Media            api.MediaArtifactSetRef
	ArtifactIDs      []api.PublicResourceID
	Host             string
	Retry            bool
	IdempotencyKey   string
}

type UploadPlanBuildOptions struct {
	DryRun               bool
	NoSeed               bool
	TrackerIDs           []api.TrackerID
	TrackerApproval      *api.TrackerApprovalSnapshotRef
	AuthorityFingerprint api.WorkflowFingerprint
}

type UploadPlanBuilder interface {
	Fingerprint(
		context.Context,
		api.TrackerReleaseProjectionSet,
		api.DupeAssessment,
		api.MediaArtifactSet,
		api.DescriptionSet,
		UploadPlanBuildOptions,
	) (api.WorkflowFingerprint, error)
	Build(
		context.Context,
		api.TrackerReleaseProjectionSet,
		api.DupeAssessment,
		any,
		api.MediaArtifactSet,
		any,
		api.DescriptionSet,
		any,
		UploadPlanBuildOptions,
		time.Time,
	) (api.UploadPlan, RetainedUploadExecution, error)
	RetryClientInjections(
		context.Context,
		RegisteredArtifactAuthority,
		[]api.TrackerID,
	) ([]api.UploadTrackerResult, error)
}