Feature/airflow trigger api (#4)

* added identified stage trigger

* changed the name of object with standard Fields

* added return statement to  execute API

---------

Co-authored-by: Shubham Pawar <[email protected]>

.gitignore

@@ -19,4 +19,5 @@
 coverage
 .vercel
 
-**/**/logs/**
+**/**/logs/**
+packages/twenty-server/src/campaign.zip

packages/twenty-server/src/campaign/campaign-execution.dto.ts

@@ -0,0 +1,24 @@
+import { Type } from 'class-transformer';
+import { IsISO8601, IsUUID, ValidateNested } from 'class-validator';
+
+import { IdList } from 'src/campaign/id-list.dto';
+
+export class CampaignExecutionDTO {
+  @IsUUID()
+  campaignId: string;
+
+  @IsISO8601({ strict: true })
+  queryTimestamp: string;
+
+  campaignTriggerId: string;
+
+  @IsISO8601({ strict: true })
+  startDate: Date;
+
+  @IsISO8601({ strict: true })
+  stopDate: Date;
+
+  @ValidateNested()
+  @Type(() => IdList)
+  id: IdList;
+}

packages/twenty-server/src/campaign/campaign.controller.ts

@@ -1,5 +1,6 @@
 import { Body, Controller, Get, Param, Post } from '@nestjs/common';
 
+import { CampaignExecutionDTO } from 'src/campaign/campaign-execution.dto';
 import { CampaignService } from 'src/campaign/campaign.service';
 import { FormDataDTO } from 'src/campaign/formdata.dto';
 @Controller('/campaign')
@@ -27,4 +28,14 @@ export class CampaignController {
       return error;
     }
   }
+
+  @Post('/execute')
+  async executeCampaign(@Body() campaignExecutionData: CampaignExecutionDTO) {
+    try {
+      return this.campaignService.triggerCampaignStartWorkflow(campaignExecutionData);
+    } catch (error) {
+      return error;
+    }
+  }
+
 }

packages/twenty-server/src/campaign/campaign.module.ts

@@ -2,10 +2,22 @@ import { Module } from '@nestjs/common';
 
 import { CampaignController } from 'src/campaign/campaign.controller';
 import { CampaignService } from 'src/campaign/campaign.service';
+import { CreateFormResponse } from 'src/campaign/create-form-response-query';
+import { GetCampaignTrigger } from 'src/campaign/get-campaign-trigger-query';
+import { GetFormTemplate } from 'src/campaign/get-form-template-query';
+import { GetLeadData } from 'src/campaign/get-lead-query';
+import { GetOpportunityData } from 'src/campaign/get-opportunity-query';
 
 @Module({
   imports: [],
   controllers: [CampaignController],
-  providers: [CampaignService],
+  providers: [
+    CampaignService,
+    CreateFormResponse,
+    GetCampaignTrigger,
+    GetFormTemplate,
+    GetLeadData,
+    GetOpportunityData,
+  ],
 })
 export class CampaignModule {}