Add Abekas RAW

Author: KillerX

workflows/ingest/masters.go

@@ -179,7 +179,7 @@ func uploadMaster(ctx workflow.Context, params MasterParams) (*MasterResult, err
 			return acc + err.Error() + "\n"
 		}, "")
 
-		return nil, fmt.Errorf(errText)
+		return nil, fmt.Errorf("%s", errText)
 	}
 
 	parentAbandonOptions := workflow.GetChildWorkflowOptions(ctx)

workflows/vb_export/vb_export.go

@@ -25,6 +25,7 @@ type Destination enum.Member[string]
 
 var (
 	DestinationAbekas    = Destination{Value: "abekas"}
+	DestinationRawAbekas = Destination{Value: "raw-abekas"}
 	DestinationBStage    = Destination{Value: "b-stage"}
 	DestinationHyperdeck = Destination{Value: "hyperdeck"}
 	DestinationGfx       = Destination{Value: "gfx"}
@@ -34,6 +35,7 @@ var (
 	DestinationXDCAM     = Destination{Value: "xdcam"}
 	Destinations         = enum.New(
 		DestinationAbekas,
+		DestinationRawAbekas,
 		DestinationBStage,
 		DestinationGfx,
 		DestinationHippo,
@@ -202,6 +204,8 @@ func VBExport(ctx workflow.Context, params VBExportParams) ([]wfutils.ResultOrEr
 		switch *dest {
 		case DestinationAbekas:
 			w = VBExportToAbekas
+		case DestinationRawAbekas:
+			w = VBExportToRawAbekas
 		case DestinationBStage:
 			w = VBExportToBStage
 		case DestinationHyperdeck:

workflows/vb_export/vb_export_raw_abekas.go

@@ -0,0 +1,35 @@
+package vb_export
+
+import (
+	"github.com/bcc-code/bcc-media-flows/services/rclone"
+	"github.com/bcc-code/bcc-media-flows/services/telegram"
+	wfutils "github.com/bcc-code/bcc-media-flows/utils/workflows"
+	"go.temporal.io/sdk/workflow"
+)
+
+// VBExportToRawAbekas copies the input file directly to Abekas-RAW without transcoding.
+func VBExportToRawAbekas(ctx workflow.Context, params VBExportChildWorkflowParams) (*VBExportResult, error) {
+	logger := workflow.GetLogger(ctx)
+	logger.Info("Starting ExportToRawAbekas")
+
+	ctx = workflow.WithActivityOptions(ctx, wfutils.GetDefaultActivityOptions())
+
+	rcloneDestination := deliveryFolder.Append("Abekas-RAW", params.InputFile.Base())
+
+	err := wfutils.RcloneWaitForFileGone(ctx, rcloneDestination, telegram.ChatOslofjord, 10)
+	if err != nil {
+		return nil, err
+	}
+
+	err = wfutils.RcloneCopyFileWithNotifications(ctx, params.InputFile, rcloneDestination, rclone.PriorityHigh, rcloneNotificationOptions)
+	if err != nil {
+		return nil, err
+	}
+
+	notifyExportDone(ctx, params, "raw-abekas", params.InputFile)
+
+	return &VBExportResult{
+		ID:    params.ParentParams.VXID,
+		Title: params.OriginalFilenameWithoutExt,
+	}, nil
+}

workflows/workflows.go

@@ -72,6 +72,7 @@ var WorkerWorkflows = []any{
 	miscworkflows.FixDurationVX,
 	vb_export.VBExport,
 	vb_export.VBExportToAbekas,
+	vb_export.VBExportToRawAbekas,
 	vb_export.VBExportToBStage,
 	vb_export.VBExportToGfx,
 	vb_export.VBExportToHippo,