Add XDCAM export

Author: KillerX

workflows/export/vx_export.go

@@ -21,13 +21,13 @@ import (
 type AssetExportDestination enum.Member[string]
 
 var (
-	AssetExportDestinationPlayout        = AssetExportDestination{Value: "playout"}
+	AssetExportDestinationXDCAM          = AssetExportDestination{Value: "xdcam"}
 	AssetExportDestinationVOD            = AssetExportDestination{Value: "vod"}
 	AssetExportDestinationBMM            = AssetExportDestination{Value: "bmm"}
 	AssetExportDestinationBMMIntegration = AssetExportDestination{Value: "bmm-integration"}
 	AssetExportDestinationIsilon         = AssetExportDestination{Value: "isilon"}
 	AssetExportDestinations              = enum.New(
-		AssetExportDestinationPlayout,
+		AssetExportDestinationXDCAM,
 		AssetExportDestinationVOD,
 		AssetExportDestinationBMM,
 		AssetExportDestinationBMMIntegration,
@@ -39,7 +39,7 @@ type VXExportParams struct {
 	VXID                      string
 	WithChapters              bool
 	WatermarkPath             string
-	Destinations              []string `jsonschema:"enum=vod,enum=playout,enum=bmm,enum=bmm-integration,enum=isilon"`
+	Destinations              []string `jsonschema:"enum=vod,enum=xdcam,enum=bmm,enum=bmm-integration,enum=isilon"`
 	AudioSource               string
 	Languages                 []string
 	Subclip                   string
@@ -218,8 +218,8 @@ func VXExport(ctx workflow.Context, params VXExportParams) ([]wfutils.ResultOrEr
 			fallthrough
 		case AssetExportDestinationVOD:
 			w = VXExportToVOD
-		case AssetExportDestinationPlayout:
-			w = VXExportToPlayout
+		case AssetExportDestinationXDCAM:
+			w = VXExportToXDCAM
 		case AssetExportDestinationBMM, AssetExportDestinationBMMIntegration:
 			w = VXExportToBMM
 		default:

workflows/export/vx_export_playout.go

@@ -4,19 +4,16 @@ import (
 	"github.com/bcc-code/bcc-media-flows/services/rclone"
 	"github.com/bcc-code/bcc-media-flows/services/telegram"
 	"github.com/bcc-code/bcc-media-flows/utils"
-	"path/filepath"
 
 	"github.com/bcc-code/bcc-media-flows/activities"
 	"github.com/bcc-code/bcc-media-flows/common"
 	wfutils "github.com/bcc-code/bcc-media-flows/utils/workflows"
 	"go.temporal.io/sdk/workflow"
 )
 
-// VXExportToPlayout is a workflow that exports a VX to the playout system
-// It transcodes the video to XDCAM HD 50Mbit/s and muxes it with the audio and subtitle files
-func VXExportToPlayout(ctx workflow.Context, params VXExportChildWorkflowParams) (*VXExportResult, error) {
+func VXExportToXDCAM(ctx workflow.Context, params VXExportChildWorkflowParams) (*VXExportResult, error) {
 	logger := workflow.GetLogger(ctx)
-	logger.Info("Starting ExportToPlayout")
+	logger.Info("Starting ExportToXDCAM")
 
 	ctx = workflow.WithActivityOptions(ctx, wfutils.GetDefaultActivityOptions())
 
@@ -53,25 +50,13 @@ func VXExportToPlayout(ctx workflow.Context, params VXExportChildWorkflowParams)
 		return nil, err
 	}
 
-	// Rclone to playout
-	destination := "playout:/tmp"
-	if err != nil {
-		return nil, err
-	}
+	destination := "brunstad:/Delivery/XDCAM"
 	err = wfutils.RcloneCopyDir(ctx, params.OutputDir.Rclone(), destination, rclone.PriorityNormal)
 	if err != nil {
 		return nil, err
 	}
 
-	err = wfutils.Execute(ctx, activities.Util.FtpPlayoutRename, activities.FtpPlayoutRenameParams{
-		From: filepath.Join("/tmp/", muxResult.Path.Base()),
-		To:   filepath.Join("/dropbox/", muxResult.Path.Base()),
-	}).Get(ctx, nil)
-	if err != nil {
-		return nil, err
-	}
-
-	notifyExportDone(ctx, telegram.ChatOslofjord, params, "playout", '🟩')
+	notifyExportDone(ctx, telegram.ChatOslofjord, params, "xdcam", '🟩')
 
 	return &VXExportResult{
 		ID:       params.ParentParams.VXID,

workflows/vb_export/vb_export.go

@@ -31,6 +31,7 @@ var (
 	DestinationHippo     = Destination{Value: "hippo"}
 	DestinationHippoV2   = Destination{Value: "hippo_v2"}
 	DestinationDubbing   = Destination{Value: "dubbing"}
+	DestinationXDCAM     = Destination{Value: "xdcam"}
 	Destinations         = enum.New(
 		DestinationAbekas,
 		DestinationBStage,
@@ -39,6 +40,7 @@ var (
 		DestinationHippoV2,
 		DestinationDubbing,
 		DestinationHyperdeck,
+		DestinationXDCAM,
 	)
 	deliveryFolder = paths.New(paths.BrunstadDrive, "/Delivery/FraMB/")
 )
@@ -212,6 +214,8 @@ func VBExport(ctx workflow.Context, params VBExportParams) ([]wfutils.ResultOrEr
 			w = VBExportToHippoV2
 		case DestinationDubbing:
 			w = VBExportToDubbing
+		case DestinationXDCAM:
+			w = VBExportToXDCAM
 
 		default:
 			return nil, fmt.Errorf("destination not implemented: %s", dest)

workflows/vb_export/vb_export_xdcam.go

@@ -0,0 +1,60 @@
+package vb_export
+
+import (
+	"github.com/bcc-code/bcc-media-flows/activities"
+	"github.com/bcc-code/bcc-media-flows/services/rclone"
+	"github.com/bcc-code/bcc-media-flows/services/telegram"
+	"github.com/bcc-code/bcc-media-flows/utils"
+	wfutils "github.com/bcc-code/bcc-media-flows/utils/workflows"
+	"go.temporal.io/sdk/workflow"
+)
+
+func VBExportToXDCAM(ctx workflow.Context, params VBExportChildWorkflowParams) (*VBExportResult, error) {
+	logger := workflow.GetLogger(ctx)
+	logger.Info("Starting XDCAM")
+
+	ctx = workflow.WithActivityOptions(ctx, wfutils.GetDefaultActivityOptions())
+
+	outputDir := params.TempDir.Append("xdcam_output")
+	err := wfutils.CreateFolder(ctx, outputDir)
+	if err != nil {
+		return nil, err
+	}
+
+	videoResult, err := wfutils.Execute(ctx, activities.Video.TranscodeToXDCAMActivity, activities.EncodeParams{
+		FilePath:       params.InputFile,
+		OutputDir:      outputDir,
+		Resolution:     utils.Resolution1080,
+		FrameRate:      25,
+		Interlace:      true,
+		Bitrate:        "50M",
+		BurnInSubtitle: params.SubtitleFile,
+		SubtitleStyle:  params.SubtitleStyle,
+	}).Result(ctx)
+	if err != nil {
+		return nil, err
+	}
+
+	extraFileName := ""
+	if params.SubtitleFile != nil {
+		extraFileName += "_SUB_NOR"
+	}
+
+	rcloneDestination := deliveryFolder.Append("XDCAM", params.OriginalFilenameWithoutExt+extraFileName+videoResult.OutputPath.Ext())
+
+	err = wfutils.RcloneWaitForFileGone(ctx, rcloneDestination, telegram.ChatOslofjord, 10)
+	if err != nil {
+		return nil, err
+	}
+
+	err = wfutils.RcloneCopyFileWithNotifications(ctx, videoResult.OutputPath, rcloneDestination, rclone.PriorityHigh, rcloneNotificationOptions)
+	if err != nil {
+		return nil, err
+	}
+
+	notifyExportDone(ctx, params, "xdcam", videoResult.OutputPath)
+
+	return &VBExportResult{
+		ID: params.ParentParams.VXID,
+	}, nil
+}

workflows/workflows.go

@@ -44,7 +44,7 @@ var WorkerWorkflows = []any{
 	ingestworkflows.BmmIngestUpload,
 	export.VXExport,
 	export.VXExportToVOD,
-	export.VXExportToPlayout,
+	export.VXExportToXDCAM,
 	export.MergeExportData,
 	export.VXExportToBMM,
 	export.IsilonExport,
@@ -76,6 +76,7 @@ var WorkerWorkflows = []any{
 	vb_export.VBExportToHippoV2,
 	vb_export.VBExportToDubbing,
 	vb_export.VBExportToHyperdeck,
+	vb_export.VBExportToXDCAM,
 	scheduled.CleanupTemp,
 	scheduled.MediabankenPurgeTrash,
 	// Massive.app import workflow