Moving analytics to Core app

OurPlanscape · Dec 19, 2024 · 77e9f22 · 77e9f22
1 parent 80be7fb
commit 77e9f22
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 22 deletions.
diff --git a/src/planscape/analytics/services.py b/src/planscape/analytics/services.py
diff --git a/src/planscape/analytics/tasks.py → src/planscape/core/analytics.py b/src/planscape/analytics/tasks.py → src/planscape/core/analytics.py
@@ -2,14 +2,31 @@
 import requests
 import json
 from typing import Dict, AnyStr, Any
+
 from django.conf import settings
+from django.utils.timezone import now
 from planscape.celery import app
 
 log = logging.getLogger(__name__)
 
 
+def collect_metric(event_name: AnyStr, **kwargs) -> None:
+    if not settings.ANALYTICS_ENABLED:
+        return
+
+    event_params = {
+        "timestamp": now(),
+        **kwargs
+    }
+    if settings.ANALYTICS_DEBUG_MODE:
+        event_params.update({"debug_mode": True})
+
+    _async_collect_metric.delay(event_name, event_params)
+
+
+
 @app.task()
-def async_collect_metric(event_name: AnyStr, event_params: Dict[str, Any]) -> None:
+def _async_collect_metric(event_name: AnyStr, event_params: Dict[str, Any]) -> None:
     """ """
     if not all(
         (

diff --git a/src/planscape/planscape/settings.py b/src/planscape/planscape/settings.py
@@ -404,7 +404,7 @@
     "planning.tasks.*": {"queue": "forsys"},
     "impacts.tasks.*": {"queue": "impacts"},
     "e2e.tasks.*": {"queue": "default"},
-    "analytics.tasks.*": {"queue": "default"},
+    "core.tasks.*": {"queue": "default"},
 }
 
 CELERY_ALWAYS_EAGER = config("CELERY_ALWAYS_EAGER", False)