fix: reset pipelines on stop

src/api/manager/workflow.ts

@@ -384,6 +384,14 @@ export async function stopProduction(
       success: true
     } as StopProductionStep
   };
+  let resetPipelineStatus = {
+    ok: true,
+    value: {
+      step: 'reset_pipeline',
+      success: true
+    } as StopProductionStep
+  };
+
   const pipelineIds = production.production_settings.pipelines.map(
     (p) => p.pipeline_id
   );
@@ -553,17 +561,34 @@ export async function stopProduction(
     Log().info(`Pipeline '${id}' stopped`);
   }
 
+  const resetPipelinePromises = pipelineIds.map((pipeline) => {
+    Log().info(`Resetting pipeline: ${pipeline!}`);
+    return resetPipeline(pipeline!);
+  });
+  await Promise.all(resetPipelinePromises).catch((error) => {
+    resetPipelineStatus = {
+      ok: false,
+      value: {
+        step: 'reset_pipeline',
+        success: false,
+        message: `Failed to reset pipelines: ${error}`
+      }
+    };
+  });
+
   if (
     !disconnectConnectionsStatus.ok ||
     !removePipelineStreamsStatus.ok ||
-    !deleteMultiviewsStatus.ok
+    !deleteMultiviewsStatus.ok ||
+    !resetPipelineStatus.ok
   ) {
     return {
       ok: false,
       value: [
         disconnectConnectionsStatus.value,
         removePipelineStreamsStatus.value,
-        deleteMultiviewsStatus.value
+        deleteMultiviewsStatus.value,
+        resetPipelineStatus.value
       ],
       error: 'Failed to stop production properly'
     };
@@ -573,7 +598,8 @@ export async function stopProduction(
     value: [
       disconnectConnectionsStatus.value,
       removePipelineStreamsStatus.value,
-      deleteMultiviewsStatus.value
+      deleteMultiviewsStatus.value,
+      resetPipelineStatus.value
     ]
   };
 }

src/components/startProduction/StopProductionFeed.tsx

@@ -18,6 +18,7 @@ export default function StopProductionFeed({
     remove_pipeline_multiviews: t(
       'stop_production_status.remove_pipeline_multiviews'
     ),
+    reset_pipeline: t('stop_production_status.reset_pipeline'),
     unexpected: t('stop_production_status.unexpected')
   };
   return (

src/i18n/locales/en.ts

@@ -35,6 +35,7 @@ export const en = {
     disconnect_connections: 'Disconnect connections',
     remove_pipeline_streams: 'Remove streams',
     remove_pipeline_multiviews: 'Remove multiviews',
+    reset_pipeline: 'Reset pipelines',
     unexpected: 'Unexpected error'
   },
   source: {

src/i18n/locales/sv.ts

@@ -37,6 +37,7 @@ export const sv = {
     disconnect_connections: 'Frånkoppla anslutningar',
     remove_pipeline_streams: 'Ta bort strömmar',
     remove_pipeline_multiviews: 'Ta bort multiviews',
+    reset_pipeline: 'Rensa pipelines',
     unexpected: 'Oväntat fel'
   },
   source: {

src/interfaces/production.ts

@@ -59,6 +59,7 @@ export interface StopProductionStep {
     | 'disconnect_connections'
     | 'remove_pipeline_streams'
     | 'remove_pipeline_multiviews'
+    | 'reset_pipeline'
     | 'unexpected';
   success: boolean;
   message?: string;