v1alpha1

type Blueprint struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   BlueprintSpec   `json:"spec,omitempty"`
	Status BlueprintStatus `json:"status,omitempty"`
}

type BlueprintList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Blueprint `json:"items"`
}

type BlueprintSpec struct {
	Storage          StorageSpec `json:"storage,omitempty"`
	MaxParallelTasks int         `json:"maxParallelTasks,omitempty"`

	Suspend                 bool                `json:"suspend,omitempty"`
	TaskConcurrencyStrategy ClustercodeStrategy `json:"taskConcurrencyStrategy,omitempty"`

	Scan    ScanSpec    `json:"scan,omitempty"`
	Encode  EncodeSpec  `json:"encode,omitempty"`
	Cleanup CleanupSpec `json:"cleanup,omitempty"`
}

type BlueprintStatus struct {
	Conditions   []metav1.Condition `json:"conditions,omitempty"`
	CurrentTasks []TaskRef          `json:"currentTasks,omitempty"`
}

type CleanupSpec struct {
	// PodTemplate contains a selection of fields to customize the spawned ffmpeg-based pods.
	// Some fields will be overwritten:
	//  * Volumes and volume mounts will be set based on StorageSpec.
	//  * Container args of the `ffmpeg` container will be set based on SplitCommandArgs, TranscodeCommandArgs, MergeCommandArgs.
	PodTemplate PodTemplate `json:"podTemplate,omitempty"`
}

type ClusterCodeUrl string

type ClustercodeCountStrategy struct {
	MaxCount int `json:"maxCount,omitempty"`
}

type ClustercodeSliceRef struct {
	JobName    string `json:"jobName,omitempty"`
	SliceIndex int    `json:"sliceIndex"`
}

type ClustercodeStrategy struct {
	ConcurrentCountStrategy *ClustercodeCountStrategy `json:"concurrentCountStrategy,omitempty"`
}

type ClustercodeTaskId string

type ContainerTemplate struct {
	// Name of the container specified as a DNS_LABEL.
	// Each container in a pod must have a unique name (DNS_LABEL).
	Name string `json:"name"`

	// Image name.
	// More info: https://kubernetes.io/docs/concepts/containers/images
	Image string `json:"image,omitempty"`

	// Command Entrypoint array.
	// More info: https://kubernetes.io/docs/tasks/inject-data-application/define-command-argument-container/#running-a-command-in-a-shell
	Command []string `json:"command,omitempty"`

	// Args to the entrypoint.
	// More info: https://kubernetes.io/docs/tasks/inject-data-application/define-command-argument-container/#running-a-command-in-a-shell
	Args []string `json:"args,omitempty"`

	// EnvFrom is a List of sources to populate environment variables in the container.
	EnvFrom []corev1.EnvFromSource `json:"envFrom,omitempty"`

	// Env is a list of environment variables to set in the container.
	Env []corev1.EnvVar `json:"env,omitempty" patchStrategy:"merge" patchMergeKey:"name"`

	// ImagePullPolicy.
	// One of Always, Never, IfNotPresent.
	// Defaults to Always if `latest` tag is specified, or `IfNotPresent` otherwise.
	// More info: https://kubernetes.io/docs/concepts/containers/images#updating-images
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`

	// VolumeMounts to mount into the container's filesystem.
	VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty" patchStrategy:"merge" patchMergeKey:"mountPath"`

	// Compute Resources required by this container.
	// More info: https://kubernetes.io/docs/concepts/configuration/manage-compute-resources-container/
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`

	// SecurityContext defines the security options the container should be run with.
	// If set, the fields of SecurityContext override the equivalent fields of PodSecurityContext.
	// More info: https://kubernetes.io/docs/tasks/configure-pod-container/security-context/
	SecurityContext *corev1.SecurityContext `json:"securityContext,omitempty"`
}

type EncodeSpec struct {
	SplitCommandArgs     []string `json:"splitCommandArgs"`
	TranscodeCommandArgs []string `json:"transcodeCommandArgs"`
	MergeCommandArgs     []string `json:"mergeCommandArgs"`

	// PodTemplate contains a selection of fields to customize the spawned ffmpeg-based pods.
	// Some fields will be overwritten:
	//  * Volumes and volume mounts will be set based on StorageSpec, if the claim names are given.
	//  * Container args of the `ffmpeg` container will be set based on SplitCommandArgs, TranscodeCommandArgs, MergeCommandArgs.
	PodTemplate PodTemplate `json:"podTemplate,omitempty"`

	// SliceSize is the time in seconds of the slice lengths.
	// Higher values yield lower parallelization but less overhead.
	// Lower values yield high parallelization but more overhead.
	// If SliceSize is higher than the total length of the media, there may be just 1 slice with effectively no parallelization.
	SliceSize int `json:"sliceSize,omitempty"`
}

type PodMetadata struct {
	// Map of string keys and values that can be used to organize and categorize (scope and select) objects.
	// This will only affect labels on the pod, not the pod selector.
	// Labels will be merged with internal labels used by crossplane, and labels with a `clustercode.github.io` key might be overwritten.
	// More info: http://kubernetes.io/docs/user-guide/labels
	Labels map[string]string `json:"labels,omitempty"`

	// Annotations is an unstructured key value map stored with a Pod that may be set by external tools to store and retrieve arbitrary metadata.
	// More info: http://kubernetes.io/docs/user-guide/annotations
	Annotations map[string]string `json:"annotations,omitempty"`
}

type PodTemplate struct {

	// Metadata that will be added to the Job's Pod.
	Metadata *PodMetadata `json:"metadata,omitempty"`

	// PodSecurityContext holds pod-level security attributes and common container settings.
	// Defaults to empty.
	// See type description for default values of each field.
	PodSecurityContext *corev1.PodSecurityContext `json:"podSecurityContext,omitempty"`

	// Containers configures the init containers within a Pod.
	InitContainers []ContainerTemplate `json:"initContainers,omitempty" patchStrategy:"merge" patchMergeKey:"name"`

	// Containers configures the containers within a Pod.
	Containers []ContainerTemplate `json:"containers,omitempty" patchStrategy:"merge" patchMergeKey:"name"`

	// List of volumes that can be mounted by containers belonging to the pod.
	// More info: https://kubernetes.io/docs/concepts/storage/volumes
	Volumes []corev1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name"`
}

type ScanSpec struct {
	Schedule            string   `json:"schedule"`
	MediaFileExtensions []string `json:"mediaFileExtensions,omitempty"`
}

type StorageSpec struct {
	// SourcePvc is a reference to the PVC which contains the source media files to encode.
	// If `sourcePvc.claimName` is empty, then you need to specify a pod template that configures a volume named "source".
	SourcePvc VolumeRef `json:"sourcePvc"`
	// SourcePvc is a reference to the PVC which contains the intermediate media files as part of the splitting and merging.
	// If `intermediatePvc.claimName` is empty, then you need to specify a pod template that configures a volume named "intermediate".
	IntermediatePvc VolumeRef `json:"intermediatePvc"`
	// SourcePvc is a reference to the PVC which contains the final result files.
	// If `targetPvc.claimName` is empty, then you need to specify a pod template that configures a volume named "target".
	TargetPvc VolumeRef `json:"targetPvc"`
}

type Task struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   TaskSpec   `json:"spec,omitempty"`
	Status TaskStatus `json:"status,omitempty"`
}

type TaskList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Task `json:"items"`
}

type TaskRef struct {
	TaskName string `json:"taskName,omitempty"`
}

type TaskSpec struct {
	TaskId               ClustercodeTaskId   `json:"taskId,omitempty"`
	Storage              StorageSpec         `json:"storage,omitempty"`
	SourceUrl            ClusterCodeUrl      `json:"sourceUrl,omitempty"`
	TargetUrl            ClusterCodeUrl      `json:"targetUrl,omitempty"`
	Suspend              bool                `json:"suspend,omitempty"`
	Encode               EncodeSpec          `json:"encode,omitempty"`
	Cleanup              CleanupSpec         `json:"cleanup,omitempty"`
	ServiceAccountName   string              `json:"serviceAccountName,omitempty"`
	FileListConfigMapRef string              `json:"fileListConfigMapRef,omitempty"`
	ConcurrencyStrategy  ClustercodeStrategy `json:"concurrencyStrategy,omitempty"`
	SlicesPlannedCount   int                 `json:"slicesPlannedCount,omitempty"`
}

type TaskStatus struct {
	Conditions           []metav1.Condition    `json:"conditions,omitempty"`
	SlicesScheduledCount int                   `json:"slicesScheduledCount,omitempty"`
	SlicesFinishedCount  int                   `json:"slicesFinishedCount,omitempty"`
	SlicesScheduled      []ClustercodeSliceRef `json:"slicesScheduled,omitempty"`
	SlicesFinished       []ClustercodeSliceRef `json:"slicesFinished,omitempty"`
}

type VolumeRef struct {
	// ClaimName is the name of the PVC.
	ClaimName string `json:"claimName"`
	// SubPath is an optional path within the referenced PVC.
	// This is useful if the same PVC is shared.
	SubPath string `json:"subPath,omitempty"`
}