core

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 13, 2026 License: GPL-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Core

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

Core composes the upload, prepared-release, duplicate-check, media, description, and history capabilities over one dependency snapshot. It owns the repository only when construction opened that repository internally. Operation contexts are per call and are not retained by Core.

func NewWithContext

func NewWithContext(ctx context.Context, deps api.CoreDependencies) (*Core, error)

NewWithContext constructs a Core and applies ctx to initialization work such as opening and migrating an internally created repository. The context is not retained after construction.

func (*Core) CancelReleaseWorkflowOperation added in v0.3.0

func (c *Core) CancelReleaseWorkflowOperation(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	operationID api.WorkflowOperationID,
) (api.WorkflowOperationStatus, error)

CancelReleaseWorkflowOperation requests cancellation of one active operation.

func (*Core) Close

func (c *Core) Close() error

Close closes the repository only when this Core opened and owns it.

func (*Core) ContinueReleaseWorkflow added in v0.3.0

func (c *Core) ContinueReleaseWorkflow(
	ctx context.Context,
	ownerID string,
	request api.ContinueReleaseWorkflowRequest,
) (releaseworkflow.CommandResult, error)

ContinueReleaseWorkflow reconciles typed desired state through the central planner.

func (*Core) CurrentReleaseWorkflow added in v0.3.0

func (c *Core) CurrentReleaseWorkflow(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
) (releaseworkflow.CommandResult, error)

CurrentReleaseWorkflow returns the current aggregate and immutable stage projections.

func (*Core) DVDMenuCapability added in v0.2.4

func (c *Core) DVDMenuCapability(ctx context.Context) (api.DVDMenuEngineInfo, error)

DVDMenuCapability reports the pure-Go engine version and the external FFmpeg dvdvideo menu capability without returning executable paths.

func (*Core) DeleteAllHistoryReleases

func (c *Core) DeleteAllHistoryReleases(ctx context.Context) (int, error)

DeleteAllHistoryReleases deletes stored releases sequentially. On cancellation or failure, the returned count includes releases deleted before the error.

func (*Core) DeleteHistoryRelease

func (c *Core) DeleteHistoryRelease(ctx context.Context, sourcePath string) error

DeleteHistoryRelease purges a stored source and related stored child paths, removing only artifacts validated beneath the configured tmp, cache, or nfo roots.

func (*Core) DiscoverPlaylists

func (c *Core) DiscoverPlaylists(ctx context.Context, sourcePath string) ([]api.PlaylistInfo, error)

DiscoverPlaylists scans the local source for Blu-ray playlists and returns them by descending score. Durations are seconds and item sizes are bytes.

func (*Core) ExecuteReleaseWorkflow added in v0.3.0

func (c *Core) ExecuteReleaseWorkflow(
	ctx context.Context,
	ownerID string,
	command releaseworkflow.Command,
) (releaseworkflow.CommandResult, error)

ExecuteReleaseWorkflow applies one owner-scoped typed workflow command.

func (*Core) GetHistoryOverview

func (c *Core) GetHistoryOverview(ctx context.Context, sourcePath string) (api.HistoryOverview, error)

GetHistoryOverview assembles persisted metadata, overrides, media, tracker state, and upload history for one source path.

func (*Core) ListHistory

func (c *Core) ListHistory(ctx context.Context) ([]api.HistoryEntry, error)

ListHistory returns stored releases with their latest display status.

func (*Core) OpenReleaseWorkflowMediaArtifact added in v0.3.0

func (c *Core) OpenReleaseWorkflowMediaArtifact(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	media api.MediaArtifactSetRef,
	artifactID api.PublicResourceID,
) (releaseworkflow.MediaArtifactContent, error)

OpenReleaseWorkflowMediaArtifact returns one owner-scoped opaque workflow media resource without exposing its retained filesystem path.

func (*Core) OpenReleaseWorkflowPreview added in v0.3.0

func (c *Core) OpenReleaseWorkflowPreview(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	previewID api.PublicResourceID,
) (releaseworkflow.MediaArtifactContent, error)

OpenReleaseWorkflowPreview returns one owner-scoped opaque transient preview.

func (*Core) PreviewReleaseWorkflowFrame added in v0.3.0

func (c *Core) PreviewReleaseWorkflowFrame(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	expectedRevision api.WorkflowRevision,
	timestampSeconds float64,
) (api.FramePreview, error)

PreviewReleaseWorkflowFrame creates one owner-scoped non-authoritative frame preview.

func (*Core) ReleaseWorkflowMediaPlan added in v0.3.0

func (c *Core) ReleaseWorkflowMediaPlan(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
) (api.MediaPlan, error)

ReleaseWorkflowMediaPlan returns the safe media plan for the workflow's current exact release and tracker projections.

func (*Core) ReleaseWorkflowOperation added in v0.3.0

func (c *Core) ReleaseWorkflowOperation(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	operationID api.WorkflowOperationID,
) (api.WorkflowOperationStatus, error)

ReleaseWorkflowOperation returns one pollable workflow operation.

func (*Core) ReleaseWorkflowOperationEvents added in v0.3.0

func (c *Core) ReleaseWorkflowOperationEvents(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	operationID api.WorkflowOperationID,
	after uint64,
	limit int,
) ([]api.WorkflowEvent, error)

ReleaseWorkflowOperationEvents returns retained operation events after one workflow-global cursor.

func (*Core) RenderDescription

func (c *Core) RenderDescription(ctx context.Context, raw string) (string, error)

RenderDescription renders raw BBCode after rejecting a pre-canceled context.

func (*Core) StageReleaseWorkflowMediaResource added in v0.3.0

func (c *Core) StageReleaseWorkflowMediaResource(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	expectedRevision api.WorkflowRevision,
	content releaseworkflow.StagedMediaContent,
) (api.WorkflowResourceRef, error)

StageReleaseWorkflowMediaResource retains private image bytes for a later exact workflow attachment command.

func (*Core) StartReleaseWorkflow added in v0.3.0

func (c *Core) StartReleaseWorkflow(
	ctx context.Context,
	ownerID string,
	command releaseworkflow.Command,
) (api.WorkflowOperationStatus, error)

StartReleaseWorkflow durably accepts one long-running workflow command.

func (*Core) StartReleaseWorkflowUpload added in v0.3.0

func (c *Core) StartReleaseWorkflowUpload(
	ctx context.Context,
	ownerID string,
	request api.CreateReleaseWorkflowUploadRequest,
) (releaseworkflow.CommandResult, error)

StartReleaseWorkflowUpload starts or idempotently replays one owner-scoped durable composite upload.

func (*Core) SubmitReleaseWorkflowUploadFeedback added in v0.3.0

func (c *Core) SubmitReleaseWorkflowUploadFeedback(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	feedback api.ReleaseWorkflowUploadFeedback,
) (releaseworkflow.CommandResult, error)

SubmitReleaseWorkflowUploadFeedback applies one exact required-action response and starts the resumed composite operation.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL