Refetch the campaign when it is updated for hateaid

Author: 1v4n4

data/hateaid.json

@@ -18,16 +18,15 @@
     "actionPageId": 3012,
     "campaign": {
         "contactSchema": "basic",
-        "externalId": 62198700,
-        "name": "ha_testone",
-        "title": "HA Test-One 11"
+        "name": "ha_testone"
+
     },
     "campaignId": 492,
     "contact": {
         "area": null,
         "contactRef": "1E4HalXr1WJkKnaeSyOgI8zTG8cKMu-vgFzWqeICtxY",
         "dupeRank": 16,
-        "email": "ivana@fixthestatusquo.org",
+        "email": "brucewayne@test.fixthestatusquo.org",
         "firstName": "Bruce"
     },
     "org": {

dist/crm/cleverreach.js

@@ -17,12 +17,15 @@ class CleverreachCRM extends crm_1.CRM {
     constructor(opt) {
         super(opt);
         this.token = null;
+        this.campaignCache = new Map(); // Store campaigns in memory
         this.handleCampaignUpdate = (message) => __awaiter(this, void 0, void 0, function* () {
-            //we are handling campaign updates to remove them from the queue
+            //we need to refetch campaign when it is updated
+            yield this.fetchCampaign(message.campaignId);
             return true;
         });
-        this.fetchCampaign = (campaign) => __awaiter(this, void 0, void 0, function* () {
-            const r = yield (0, proca_1.fetchCampaign)(campaign.id);
+        this.fetchCampaign = (id) => __awaiter(this, void 0, void 0, function* () {
+            const r = yield (0, proca_1.fetchCampaign)(id);
+            this.campaignCache.set(id, r);
             return r;
         });
         this.initializeToken = () => __awaiter(this, void 0, void 0, function* () {
@@ -38,18 +41,19 @@ class CleverreachCRM extends crm_1.CRM {
             if (this.verbose) {
                 console.log(message);
             }
-            const camp = yield this.campaign(message.campaign);
+            let camp = this.campaignCache.get(message.campaign.id);
+            if (!camp) {
+                camp = yield this.fetchCampaign(message.campaign.id);
+            }
             // listId might be different for each campaign
             // custom label is different for each campaign
             if (!((_c = (_b = (_a = camp.config) === null || _a === void 0 ? void 0 : _a.component) === null || _b === void 0 ? void 0 : _b.sync) === null || _c === void 0 ? void 0 : _c.listId) || !((_f = (_e = (_d = camp.config) === null || _d === void 0 ? void 0 : _d.component) === null || _e === void 0 ? void 0 : _e.sync) === null || _f === void 0 ? void 0 : _f.customLabel)) {
                 console.error(`Campaign config params missing, set the listId and custom label for the campaign ${message.campaign.name}`);
             }
             ;
             yield this.initializeToken();
-            const listId = ((_j = (_h = (_g = camp.config) === null || _g === void 0 ? void 0 : _g.component) === null || _h === void 0 ? void 0 : _h.sync) === null || _j === void 0 ? void 0 : _j.listId)
-                || process.env.CRM_LIST_ID || "666";
-            const customLabel = ((_m = (_l = (_k = camp.config) === null || _k === void 0 ? void 0 : _k.component) === null || _l === void 0 ? void 0 : _l.sync) === null || _m === void 0 ? void 0 : _m.customLabel)
-                || message.campaign.id + " " + message.campaign.title;
+            const listId = (_j = (_h = (_g = camp.config) === null || _g === void 0 ? void 0 : _g.component) === null || _h === void 0 ? void 0 : _h.sync) === null || _j === void 0 ? void 0 : _j.listId;
+            const customLabel = (_m = (_l = (_k = camp.config) === null || _k === void 0 ? void 0 : _k.component) === null || _l === void 0 ? void 0 : _l.sync) === null || _m === void 0 ? void 0 : _m.customLabel;
             if (!this.token) {
                 throw new Error("Token is not available");
             }

dist/crm/cleverreach/client.js

@@ -87,7 +87,6 @@ const getGroups = (token, listId) => __awaiter(void 0, void 0, void 0, function*
             throw new Error(`Get groups failed: ${response.statusText}`);
         }
         const data = yield response.text();
-        console.log('Get groups response status:', data);
         return data;
     }
     catch (error) {

src/crm/cleverreach.ts

@@ -15,6 +15,7 @@ export type Message = ActionMessage | EventMessage;
 
 class CleverreachCRM extends CRM {
   token: string | null = null;
+  campaignCache = new Map<number, ProcaCampaign>(); // Store campaigns in memory
 
   constructor(opt: {}) {
     super(opt);
@@ -23,12 +24,14 @@ class CleverreachCRM extends CRM {
   }
 
   handleCampaignUpdate = async (message: CampaignUpdatedEvent): Promise<handleResult | boolean> => {
-    //we are handling campaign updates to remove them from the queue
+    //we need to refetch campaign when it is updated
+    await this.fetchCampaign(message.campaignId);
     return true;
   }
 
- fetchCampaign = async (campaign: ProcaCampaign): Promise<any> => {
-  const r = await procaCampaign(campaign.id);
+ fetchCampaign = async (id: number): Promise<any> => {
+   const r = await procaCampaign(id);
+   this.campaignCache.set(id, r);
   return r;
 }
 
@@ -44,8 +47,10 @@ class CleverreachCRM extends CRM {
     if (this.verbose) {
       console.log(message);
     }
-
-    const camp = await this.campaign(message.campaign);
+    let camp = this.campaignCache.get(message.campaign.id);
+    if (!camp) {
+      camp = await this.fetchCampaign(message.campaign.id);
+    }
 
     // listId might be different for each campaign
     // custom label is different for each campaign
@@ -55,11 +60,8 @@ class CleverreachCRM extends CRM {
 
     await this.initializeToken();
 
-    const listId = camp.config?.component?.sync?.listId
-      || process.env.CRM_LIST_ID || "666";
-
-    const customLabel = camp.config?.component?.sync?.customLabel
-      || message.campaign.id + " " + message.campaign.title;
+    const listId = camp.config?.component?.sync?.listId;
+    const customLabel = camp.config?.component?.sync?.customLabel;
 
     if (!this.token) {
       throw new Error("Token is not available");

src/crm/cleverreach/client.ts

@@ -81,7 +81,6 @@ export const getGroups = async (token: string, listId: number) => {
         }
 
         const data = await response.text();
-        console.log('Get groups response status:', data);
         return data;
     } catch (error) {
         console.error('Get groups contact error:', error.message);