Make workflow of uploader configurable via upload.workflow (#1268)

elan-ev · Nov 4, 2024 · b5c2244 · b5c2244
2 parents d252b97 + 0a74e01
commit b5c2244
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 0 deletions.
diff --git a/backend/src/config/upload.rs b/backend/src/config/upload.rs
@@ -5,4 +5,8 @@ pub(crate) struct UploadConfig {
     /// Whether specifying a series is required when uploading.
     #[config(default = false)]
     pub require_series: bool,
+
+    /// Specify workflow to start after ingesting. If unset, Tobira does not
+    /// send any workflow ID, meaning Opencast will choose its default.
+    pub workflow: Option<String>,
 }
diff --git a/backend/src/http/assets.rs b/backend/src/http/assets.rs
@@ -273,6 +273,7 @@ fn frontend_config(config: &Config) -> serde_json::Value {
         },
         "upload": {
             "requireSeries": config.upload.require_series,
+            "workflow": config.upload.workflow,
         },
         "siteTitle": config.general.site_title,
         "initialConsent": config.general.initial_consent,

diff --git a/docs/docs/setup/config.toml b/docs/docs/setup/config.toml
@@ -583,6 +583,10 @@
 # Default value: false
 #require_series = false
 
+# Specify workflow to start after ingesting. If unset, Tobira does not
+# send any workflow ID, meaning Opencast will choose its default.
+#workflow =
+
 
 # Matomo integration (optional). Currently only used by Paella if configured.
 [matomo]

diff --git a/frontend/src/config.ts b/frontend/src/config.ts
@@ -95,6 +95,7 @@ type VersionInfo = {
 
 type UploadConfig = {
     requireSeries: boolean;
+    workflow: string | null;
 };
 
 type SyncConfig = {

diff --git a/frontend/src/routes/Upload.tsx b/frontend/src/routes/Upload.tsx
@@ -1056,6 +1056,9 @@ const finishUpload = async (
         {
             const body = new FormData();
             body.append("mediaPackage", mediaPackage);
+            if (CONFIG.upload.workflow) {
+                body.append("workflowDefinitionId", CONFIG.upload.workflow);
+            }
             await ocRequest("/ingest/ingest", { method: "post", body: body });
         }