Merge pull request #5975 from Countly/hooks-remote-config-addition

[hooks] Added remote config changes to internal actions

Author: coskunaydinoglu

CHANGELOG.md

@@ -1,5 +1,6 @@
-## Version xx.xx.xx
+## Version 24.05.XX
 Features:
+- [hooks] Added remote config changes to internal actions
 - [system-utility] New endpoint: /take-heap-snapshot.
 - [system-utility] Using nodejs fs to write profiler files instead of gridfs.
 

plugins/hooks/api/parts/triggers/internal_event.js

@@ -212,6 +212,19 @@ class InternalEventTrigger {
                 }
                 break;
             }
+            case "/i/remote-config/add-parameter":
+            case "/i/remote-config/update-parameter":
+            case "/i/remote-config/remove-parameter":
+            case "/i/remote-config/add-condition":
+            case "/i/remote-config/update-condition":
+            case "/i/remote-config/remove-condition":
+                utils.updateRuleTriggerTime(rule._id);
+                this.pipeline({
+                    params: ob,
+                    rule: rule,
+                    eventType,
+                });
+                break;
             case "/alerts/trigger": {
                 this.pipeline({
                     params: ob,
@@ -255,4 +268,10 @@ const InternalEvents = [
     "/i/app_users/delete",
     "/hooks/trigger",
     "/alerts/trigger",
-];
+    "/i/remote-config/add-parameter",
+    "/i/remote-config/update-parameter",
+    "/i/remote-config/remove-parameter",
+    "/i/remote-config/add-condition",
+    "/i/remote-config/update-condition",
+    "/i/remote-config/remove-condition",
+];

plugins/hooks/frontend/public/javascripts/countly.views.js

@@ -402,6 +402,12 @@
                     {value: "/systemlogs", label: "/systemlogs"},
                     {value: "/crashes/new", label: "/crashes/new"},
                     {value: "/hooks/trigger", label: "/hooks/trigger"},
+                    {value: "/i/remote-config/add-parameter", label: "/i/remote-config/add-parameter"},
+                    {value: "/i/remote-config/update-parameter", label: "/i/remote-config/update-parameter"},
+                    {value: "/i/remote-config/remove-parameter", label: "/i/remote-config/remove-parameter"},
+                    {value: "/i/remote-config/add-condition", label: "/i/remote-config/add-condition"},
+                    {value: "/i/remote-config/update-condition", label: "/i/remote-config/update-condition"},
+                    {value: "/i/remote-config/remove-condition", label: "/i/remote-config/remove-condition"},
                     {value: "/alerts/trigger", label: "/alerts/trigger"}
                 ],
                 cohortOptions: [],

plugins/remote-config/api/api.js

@@ -440,6 +440,11 @@ plugins.setConfigs("remote-config", {
                 }
                 return common.returnMessage(params, 500, message);
             }
+
+            plugins.dispatch("/i/remote-config/add-parameter", {
+                params: parameter
+            });
+
             if (params.internal) {
                 return true;
             }
@@ -967,6 +972,10 @@ plugins.setConfigs("remote-config", {
                 return common.returnMessage(params, 500, message);
             }
 
+            plugins.dispatch("/i/remote-config/update-parameter", {
+                params: parameter
+            });
+
             return common.returnMessage(params, 200);
         });
     }
@@ -1089,6 +1098,9 @@ plugins.setConfigs("remote-config", {
                 common.outDb.collection(collectionName).remove({_id: common.outDb.ObjectID(parameterId)}, function(removeErr) {
                     if (!removeErr) {
                         plugins.dispatch("/systemlogs", {params: params, action: "rc_parameter_removed", data: parameter});
+                        plugins.dispatch("/i/remote-config/remove-parameter", {
+                            params: parameter
+                        });
                         return common.returnMessage(params, 200, 'Success');
                     }
 
@@ -1175,6 +1187,9 @@ plugins.setConfigs("remote-config", {
             }
 
             var conditionId = result && result[1] || null;
+            plugins.dispatch("/i/remote-config/add-condition", {
+                params: condition
+            });
             if (params.internal) {
                 return conditionId;
             }
@@ -1353,6 +1368,10 @@ plugins.setConfigs("remote-config", {
                 return common.returnMessage(params, 500, message);
             }
 
+            plugins.dispatch("/i/remote-config/update-condition", {
+                params: condition
+            });
+
             return common.returnMessage(params, 200);
         });
 
@@ -1396,6 +1415,13 @@ plugins.setConfigs("remote-config", {
 
         async.parallel(asyncTasks, function(err) {
             if (!err) {
+                plugins.dispatch("/i/remote-config/remove-condition", {
+                    params: {
+                        conditionId: conditionId,
+                        appId: appId,
+                        ts: Date.now()
+                    }
+                });
                 return common.returnMessage(params, 200, 'Success');
             }