[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/src/__tests__/handlers/manageListSubscription.test.ts

@@ -0,0 +1,26 @@
+import { manageListSubscription } from '../../handlers/manageListSubscription';
+
+// remove .skip to run the test, be aware it does real API calls
+describe('manage list subscription', () => {
+  const cognitoUserId = '66ae52a0-f051-7080-04a1-465b3a4f44cc';
+  const listName = 'test-webinar-1732097286071';
+
+  it('should subscriber 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/handlers/manageListSubscription.ts

@@ -0,0 +1,40 @@
+import { APIGatewayProxyResult } from 'aws-lambda';
+import { acClient } from '../utils/activeCampaignClient';
+
+export async function manageListSubscription(
+  username: string,
+  listName: string,
+  action: 'subscribe' | 'unsubscribe'
+): Promise<APIGatewayProxyResult> {
+  try {
+    const contactId = await acClient.getContactByCognitoId(username);
+    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/utils/activeCampaignClient.ts

@@ -111,6 +111,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(