WIP

server/src/services/job.service.ts

@@ -16,6 +16,7 @@ import {
   JobStatus,
   QueueCleanType,
   QueueName,
+  WorkflowTriggerType,
 } from 'src/interfaces/job.interface';
 import { ILoggerRepository } from 'src/interfaces/logger.interface';
 import { IMetricRepository } from 'src/interfaces/metric.interface';
@@ -294,6 +295,13 @@ export class JobService {
         if (asset && asset.isVisible) {
           this.eventRepository.clientSend(ClientEvent.UPLOAD_SUCCESS, asset.ownerId, mapAsset(asset));
         }
+
+        if (asset) {
+          await this.jobRepository.queue({
+            name: JobName.WORKFLOW_TRIGGER,
+            data: { type: WorkflowTriggerType.ASSET_UPLOAD, data: { assetId: asset.id } },
+          });
+        }
         break;
       }