[DEV-1983][DEV-1986] Add function to subscribe and unsubscribe contact from active campaign list

.changeset/plenty-parrots-attend.md

@@ -0,0 +1,5 @@
+---
+"active-campaign-client": minor
+---
+
+Add function to subscribe and upsubscribe contact from active campaign list

packages/active-campaign-client/.env.example

@@ -3,3 +3,5 @@ AC_API_KEY=your_api_key
 SENDER_URL=localhost:3000
 AWS_REGION="region"
 AWS_USER_POOL_ID="region_DFWF81fRa"
+COGNITO_USER_ID = 66ae52a0-f051-7080-04a1-465b3a4f44cc
+LIST_NAME = test-webinar-1732097286071

packages/active-campaign-client/src/__tests__/helpers/manageListSubscription.test.ts

@@ -0,0 +1,26 @@
+// remove .skip to run the test, be aware it does real API calls
+import { manageListSubscription } from '../../helpers/manageListSubscription';
+
+describe.skip('manage list subscription', () => {
+  const cognitoUserId = process.env.COGNITO_USER_ID || '';
+  const listName = process.env.LIST_NAME || '';
+
+  it('should subscribe the contact to the list', async () => {
+    const result = await manageListSubscription(
+      cognitoUserId,
+      listName,
+      'subscribe'
+    );
+
+    expect(result.statusCode).toBe(200);
+  });
+
+  it('should unsubscribe the contact from the list', async () => {
+    const result = await manageListSubscription(
+      cognitoUserId,
+      listName,
+      'unsubscribe'
+    );
+    expect(result.statusCode).toBe(200);
+  });
+});

packages/active-campaign-client/src/clients/activeCampaignClient.ts

@@ -1,6 +1,7 @@
 import * as https from 'https';
 import { ContactPayload } from '../types/contactPayload';
 import { ListPayload } from '../types/listPayload';
+import { ListStatusPayload } from '../types/listStatusPayload';
 
 export class ActiveCampaignClient {
   private readonly baseUrl: string;
@@ -22,7 +23,7 @@ export class ActiveCampaignClient {
   private async makeRequest<T>(
     method: string,
     path: string,
-    data?: ContactPayload | ListPayload,
+    data?: ContactPayload | ListPayload | ListStatusPayload,
     params?: Record<string, string>
   ): Promise<T> {
     return new Promise((resolve, reject) => {
@@ -111,6 +112,26 @@ export class ActiveCampaignClient {
   async deleteList(id: number) {
     return this.makeRequest('DELETE', `/api/3/lists/${id}`);
   }
+
+  async addContactToList(contactId: string, listId: number) {
+    return this.makeRequest('POST', `/api/3/contactLists`, {
+      contactList: {
+        contact: contactId,
+        list: listId,
+        status: 1, // subscribe
+      },
+    });
+  }
+
+  async removeContactFromList(contactId: string, listId: number) {
+    return this.makeRequest('POST', `/api/3/contactLists`, {
+      contactList: {
+        contact: contactId,
+        list: listId,
+        status: 2, // unsubscrbe
+      },
+    });
+  }
 }
 
 export const acClient = new ActiveCampaignClient(

packages/active-campaign-client/src/helpers/manageListSubscription.ts

@@ -0,0 +1,40 @@
+import { APIGatewayProxyResult } from 'aws-lambda';
+import { acClient } from '../clients/activeCampaignClient';
+
+export async function manageListSubscription(
+  cognitoUserId: string,
+  listName: string,
+  action: 'subscribe' | 'unsubscribe'
+): Promise<APIGatewayProxyResult> {
+  try {
+    const contactId = await acClient.getContactByCognitoId(cognitoUserId);
+    if (!contactId) {
+      return {
+        statusCode: 404,
+        body: JSON.stringify({ message: 'Contact not found' }),
+      };
+    }
+
+    const listId = await acClient.getListIdByName(listName);
+
+    if (action == 'subscribe') {
+      const response = await acClient.addContactToList(contactId, listId);
+      return {
+        statusCode: 200,
+        body: JSON.stringify(response),
+      };
+    } else {
+      const response = await acClient.removeContactFromList(contactId, listId);
+      return {
+        statusCode: 200,
+        body: JSON.stringify(response),
+      };
+    }
+  } catch (error) {
+    console.error('Error:', error);
+    return {
+      statusCode: 500,
+      body: JSON.stringify({ message: 'Internal server error' }),
+    };
+  }
+}

packages/active-campaign-client/src/types/listStatusPayload.ts

@@ -1,7 +1,7 @@
 export type ListStatusPayload = {
   readonly contactList: {
-    readonly list: string;
+    readonly list: number;
     readonly contact: string;
-    readonly status: string;
+    readonly status: number;
   };
 };