--update backend core

Author: divyanshu-khudiya

apps/backend-core/unpod/space/services.py

@@ -1,3 +1,4 @@
+import datetime
 import json
 import logging
 
@@ -1078,49 +1079,80 @@ def get_calls(space_id: int, query_params: dict):
     collection_name = "tasks"
     skip, limit = getPagination(query_params, 30)
     query = {
-        "space_id": str(space_id),
-        "output": {"$ne": {}, "$exists": True},
+        "space_id": str(space_id)
+    }
+    search_str = query_params.get("search")
+    call_type = query_params.get("call_type")
+    date_from = query_params.get("from_ts")
+    date_to = query_params.get("to_ts")
+    status = query_params.get("status")
+
+    filters = []
+    if date_from or date_to:
+      date_filter = {}
+      try:
+        if date_from:
+          date_filter["$gte"] = datetime.fromtimestamp(int(date_from))
+        if date_to:
+          date_filter["$lte"] = datetime.fromtimestamp(int(date_to))
+        filters.append({"created": date_filter})
+      except Exception:
+        pass
+
+    if call_type:
+      if call_type == "inbound":
+        call_type_values = ["inbound", "inboundPhoneCall"]
+      elif call_type == "outbound":
+        call_type_values = ["outbound", "outboundPhoneCall"]
+      else:
+        call_type_values = [call_type]
+      filters.append(
+        {
+          "$or": [
+            {"output.call_type": {"$in": call_type_values}},
+            {"output.type": {"$in": call_type_values}},
+          ]
+        }
+      )
+
+    if search_str:
+      filters.append(
+        {
+          "$or": [
+            {"input.name": {"$regex": search_str, "$options": "i"}},
+            {"input.phone": {"$regex": search_str, "$options": "i"}},
+            {"output.customer": {"$regex": search_str, "$options": "i"}},
+            {
+              "output.contact_number": {
+                "$regex": search_str,
+                "$options": "i",
+              }
+            },
+          ]
+        }
+      )
+
+    if status:
+      status_values = [s.strip().replace("+", " ") for s in status.split(",")]
+
+      filters.append(
+        {"output.post_call_data.summary.status": {"$in": status_values}}
+      )
+
+    if filters:
+      query = {**query, **{"$and": filters}}
+
+    projection = {
+      "_id": 1,
+      "task_id": 1,
+      "created": 1,
+      "status": 1,
+      "input.call_type": 1,
+      "input.name": 1,
+      "input.contact_number": 1,
+      "output.call_type": 1,
+      "output.customer": 1,
     }
-    exclude_fields = [
-        "retry_attempt",
-        "thread_id",
-        "user_info",
-        "call_analytics",
-        "execution_analytics",
-        "last_status_change",
-        "provider",
-        "attachments",
-        "ref_id",
-        "failure_count",
-        "last_failure_reason",
-        "scheduled_timestamp",
-        "task",
-        "collection_ref",
-        "run_id",
-        "user_org_id",
-        "user",
-        "space_id",
-        "modified",
-        "assignee",
-        "execution_type",
-        "input.token",
-        "input.quality",
-        "output.call_id",
-        "output.contact_number",
-        "output.transcript",
-        "output.post_call_data",
-        "output.metadata",
-        "output.call_end_reason",
-        "output.recording_url",
-        "output.start_time",
-        "output.end_time",
-        "output.assistant_number",
-        "output.call_summary",
-        "output.duration",
-        "output.cost",
-        "output.call_status",
-    ]
-    projection = {field: 0 for field in exclude_fields}
 
     try:
         collection = MongoDBQueryManager.get_collection(collection_name)

apps/backend-core/unpod/space/utils.py

@@ -178,6 +178,8 @@ def checkPostSpaceAccess(
 def getAllSpaceQuery(request, space_type, case=None):
     query = Q(space_type=space_type)
     if request.user.is_authenticated:
+        space_query = Q()  # Initialize an empty Q object
+
         if case:
             if case in ["all", "home"]:
                 space_query = Q(

apps/backend-core/unpod/space/views.py

@@ -608,7 +608,13 @@ def list(self, request, *args, **kwargs):
                 evals_map = KnowledgeBaseEvals.objects.filter(
                     eval_type="knowledgebase", linked_handle__in=space_tokens
                 ).values("eval_name", "linked_handle", "gen_status", "eval_data")
+                eval_space_tokens = []
+                for item in evals_map:
+                    if item.get("eval_data", {}).get("space_token"):
+                        eval_space_tokens.append(item.get("eval_data", {}).get("space_token"))
                 evals_map = {item["linked_handle"]: item for item in evals_map}
+                space_infos = Space.objects.filter(token__in=eval_space_tokens).values('token', "slug")
+                space_info_map = {item["token"]: item for item in space_infos}
 
             private_thread_space = {}
             public_threads_space = {}
@@ -650,9 +656,11 @@ def list(self, request, *args, **kwargs):
                 if space_type == "knowledge_base":
                     space["has_evals"] = space.get("token") in evals_map
                     if space["has_evals"]:
-                      evals_info = evals_map.get(space.get("token"))
+                      evals_info = evals_map.get(space.get("token"), {})
                       eval_data = evals_info.pop("eval_data", {})
                       evals_info["eval_token"] = eval_data.get("space_token")
+                      sp_evals_info = space_info_map.get(evals_info["eval_token"], {})
+                      evals_info["eval_slug"] = sp_evals_info.get("slug")
                       space["evals_info"] = evals_info
             # if len(space_list):
             #     space_list.insert(0, getAllSpaceObject())

apps/backend-core/unpod/users/admin_view/views.py

@@ -14,6 +14,7 @@ def get(self, request):
         form = LoginForm()
         config_file = os.environ.get('DJANGO_SETTINGS_MODULE')
         button_value = 'Log in' if 'local' in config_file.lower() else 'Send OTP'
+
         return render(request, settings.ADMIN_LOGIN_TEMPLATE, {"form": form, "button_value": button_value})
 
     def post(self, request):
@@ -41,6 +42,7 @@ def post(self, request):
             if _form.is_valid():
                 config_file = os.environ.get('DJANGO_SETTINGS_MODULE')
                 button_value = 'Log in' if 'local' in config_file.lower() else 'Send OTP'
+
                 user = authenticate(username=_form.data["username"],
                                     password=_form.data["password"])
                 if user is not None: