feat(framework,api): add source when triggered from workflow

apps/api/src/app/events/usecases/parse-event-request/parse-event-request.usecase.ts

@@ -84,10 +84,19 @@ export class ParseEventRequest {
     if (environment) {
       const discoveredWorkflow = await this.queryDiscoverWorkflow(command, environment);
 
+      const template = await this.getNotificationTemplateByTriggerIdentifier({
+        environmentId: command.environmentId,
+        triggerIdentifier: command.identifier,
+      });
+
       if (!discoveredWorkflow) {
         throw new UnprocessableEntityException('workflow_not_found');
       }
 
+      if (!template && command.payload?.__source === 'framework-workflow-trigger') {
+        throw new UnprocessableEntityException('workflow_not_synced');
+      }
+
       return await this.dispatchEvent(command, transactionId, discoveredWorkflow);
     }
 

packages/framework/src/resources/workflow/index.ts

@@ -62,6 +62,7 @@ export function workflow<
       to: event.to,
       payload: {
         ...validatedData,
+        __source: 'framework-workflow-trigger',
       },
       ...(event.transactionId && { transactionId: event.transactionId }),
       ...(event.overrides && { overrides: event.overrides }),

packages/framework/src/resources/workflow/workflow.test.ts

@@ -350,6 +350,7 @@ describe('workflow function', () => {
             to: '[email protected]',
             payload: {
               free: 'field',
+              __source: 'framework-workflow-trigger',
             },
           }),
           headers: {
@@ -399,6 +400,7 @@ describe('workflow function', () => {
             to: '[email protected]',
             payload: {
               foo: 'bar',
+              __source: 'framework-workflow-trigger',
             },
           }),
           headers: {