feat(api): add origin backward compatibility mapping (#6973)

apps/api/src/app/workflows-v2/usecases/generate-preview/generate-preview.usecase.ts

@@ -9,10 +9,12 @@ import {
   StepContentIssueEnum,
   StepTypeEnum,
   WorkflowOriginEnum,
+  WorkflowTypeEnum,
 } from '@novu/shared';
 import { merge } from 'lodash/fp';
 import _ = require('lodash');
 import { GetWorkflowByIdsUseCase } from '@novu/application-generic';
+import { NotificationTemplateEntity } from '@novu/dal';
 import { GeneratePreviewCommand } from './generate-preview-command';
 import { PreviewStep, PreviewStepCommand } from '../../../bridge/usecases/preview-step';
 import { StepMissingControlsException, StepNotFoundException } from '../../exceptions/step-not-found-exception';
@@ -117,15 +119,37 @@ export class GeneratePreviewUsecase {
     if (!step.template || !step.template.controls) {
       throw new StepMissingControlsException(command.stepDatabaseId, step);
     }
+    const origin = this.buildOrigin(persistedWorkflow);
 
     return {
       workflowId: persistedWorkflow.triggers[0].identifier,
       stepId: step.stepId,
       stepType: step.template.type,
       stepControlSchema: step.template.controls,
-      origin: persistedWorkflow.origin,
+      origin,
     };
   }
+
+  /**
+   * Builds the origin of the workflow based on the workflow type.
+   * If the origin is not set, it will be built based on the workflow type.
+   * We need to do so for backward compatibility reasons.
+   */
+  private buildOrigin(persistedWorkflow: NotificationTemplateEntity): WorkflowOriginEnum {
+    if (persistedWorkflow.origin) {
+      return persistedWorkflow.origin;
+    }
+
+    if (persistedWorkflow.type === WorkflowTypeEnum.ECHO || persistedWorkflow.type === WorkflowTypeEnum.BRIDGE) {
+      return WorkflowOriginEnum.EXTERNAL;
+    }
+
+    if (persistedWorkflow.type === WorkflowTypeEnum.REGULAR) {
+      return WorkflowOriginEnum.NOVU_CLOUD_V1;
+    }
+
+    return WorkflowOriginEnum.NOVU_CLOUD;
+  }
 }
 
 function buildResponse(

apps/api/src/app/workflows-v2/usecases/generate-preview/step-id-missing.exception.ts

@@ -7,7 +7,10 @@ export class StepIdMissingException extends InternalServerErrorException {
 }
 
 export class OriginMissingException extends InternalServerErrorException {
-  constructor(stepId: string) {
-    super({ message: `Origin is missing for the stepId: ${stepId}`, stepId });
+  constructor(workflowId: string) {
+    super({
+      message: 'Origin is missing on the workflow',
+      workflowId,
+    });
   }
 }