updated request body for campaign trigger and created api

synapsenet-arena · Apr 30, 2024 · 26033f1 · 26033f1
1 parent 83aec61
commit 26033f1
Show file tree

Hide file tree

Showing 3 changed files with 41 additions and 6 deletions.
diff --git a/packages/twenty-server/src/campaign/campaign.controller.ts b/packages/twenty-server/src/campaign/campaign.controller.ts
@@ -37,5 +37,16 @@ export class CampaignController {
       return error;
     }
   }
+  @Post('/lead/register/:id')
+  executeLeadRegistration(@Param() id: any,@Body() data:any){
+    // console.log(id.id)
+    try {
+      console.log(id.id)
+       this.campaignService.triggerLeadRegistrationWorkflow(id.id);
+       return true
+    } catch (error) {
+      return error;
+    }
+  }
 
 }
diff --git a/packages/twenty-server/src/campaign/campaign.service.ts b/packages/twenty-server/src/campaign/campaign.service.ts
@@ -16,13 +16,41 @@ import { response } from 'express';
 
 @Injectable()
 export class CampaignService {
+
   constructor(
     private createFormResponse: CreateFormResponse,
     private getCampaignTrigger: GetCampaignTrigger,
     private getFormTemplate: GetFormTemplate,
     private getLeadData: GetLeadData,
     private getOpportunityData: GetOpportunityData,
   ) {}
+
+  async triggerLeadRegistrationWorkflow(id: any) {
+    const data={
+      conf:{
+        patient_uuid:id
+      }
+    }
+    try {
+      let response = await fetch(
+        `${process.env.AIRFLOW_HOST}/api/v1/dags/${process.env.DAG_CONTACTED_OPPORTUNITIES}/dagRuns`,
+        {
+          method: 'post',
+          body: JSON.stringify(data),
+          headers: {
+            'Content-Type': 'application/json',
+            Authorization: `Basic ${process.env.AIRFLOW_AUTH_TOKEN}`,
+          },
+        },
+      );
+
+      response = await response.json();
+      console.log(response)
+      return response;
+    } catch (error) {
+      return error;
+    }  
+  }
 
   async triggerIdentifiedWorkflow(requestBody: any) {
     const data = {

diff --git a/packages/twenty-server/src/campaign/id-list.dto.ts b/packages/twenty-server/src/campaign/id-list.dto.ts
@@ -5,12 +5,8 @@ import { IdDto } from 'src/campaign/id.dto';
 
 export class IdList {
   @IsOptional()
-  @ValidateNested({ each: true })
-  @Type(() => IdDto)
-  selectedID: IdDto[];
+  selectedID: [];
 
   @IsOptional()
-  @ValidateNested({ each: true })
-  @Type(() => IdDto)
-  unselectedID: IdDto[];
+  unselectedID: [];
 }