Async task configuration for automation

Author: drona-gyawali

management/core/api/viewset.py

@@ -237,7 +237,7 @@ class TicketAssignview(APIView):
     API endpoint to assign a ticket to an available agent.
 
     Request Method: GET
-    URL: /app/ticket/<id>/assign/
+    URL: /app/ticket/`str:id`/assign/
 
     Path Parameter:
     - id: Ticket ID to be assigned.
@@ -330,7 +330,20 @@ def get(self, request, id, format=None):
 
 class TicketReopen(APIView):
     """
-    API endpoint to reopen a ticket.
+    API endpoint to reopen the ticket.
+
+    Request Method: GET
+    URL: /app/ticket/`str:id`/reopen/
+
+    Path Parameter:
+    - id: Ticket ID to be reopened.
+
+    Responses:
+    - 200 OK:
+        - Ticket successfully reopend.
+    - 400 Bad Request: Invalid ticket ID or Status is not closed.
+    - 404 Not Found: Ticket with the given ID does not exist.
+    - 500 Internal Server Error: Server side error.
     """
 
     permission_classes = [IsAuthenticated | CanEditOwnOrAdmin]

management/core/tasks.py

@@ -1,13 +1,16 @@
+import logging
 from datetime import timedelta
 
 from celery import shared_task
-from core.automation.state_machine import TicketStateMachine
+from core.automation.rule_runner import RuleEngine
 from core.constants import Status
 from core.models import Agent, Ticket
 from django.db import transaction
 from django.db.models import Q
 from django.utils import timezone
 
+logger = logging.getLogger(__name__)
+
 
 @shared_task(bind=True)
 def process_ticket_queue(self):
@@ -37,7 +40,7 @@ def process_ticket_queue(self):
             agent.max_customers -= 1
             agent.save()
 
-            print(f"Ticket {ticket.ticket_id} assigned to {agent.user.username}")
+            logger.info(f"Ticket {ticket.ticket_id} assigned to {agent.user.username}")
 
 
 @shared_task(bind=True)
@@ -51,12 +54,27 @@ def delete_completed_tickets(self):
         deleted_count, _ = Ticket.objects.filter(
             status=Status.COMPLETED | Q(Status.CLOSED), updated_at__lte=cutoff
         ).delete()
-    print(f"Deleted {deleted_count} completed tickets older than 60 days.")
+    logger.info(f"Deleted {deleted_count} completed tickets older than 60 days.")
 
 
+# Todo: implement the batch processing[!important][Memmory Issue]
 @shared_task(bind=True)
-def process_state_changed(ticket_id, new_status):
-    with transaction.atomic:
-        ticket_id = Ticket.objects.select_for_update.get(ticket_id=ticket_id)
-        state_machine = TicketStateMachine(ticket_id)
-        return state_machine.transition_to(new_status)
+def apply_rules_to_all_tickets():
+    """
+    Celery task to apply RuleEngine to all tickets in the database.
+    """
+    tickets = Ticket.objects.all()
+    results = []
+
+    for ticket in tickets:
+        try:
+            engine = RuleEngine(ticket.ticket_id)
+            result = engine.run()
+            results.append({"ticket_id": ticket.ticket_id, "result": result})
+            logger.info(f"Rules applied to ticket {ticket.ticket_id}: {result}")
+        except Exception as e:
+            logger.exception(
+                f"Failed to apply rules to ticket {ticket.ticket_id}: {str(e)}"
+            )
+
+    return results

management/main/settings.py

@@ -192,4 +192,8 @@
         "task": "core.tasks.delete_completed_tickets",
         "schedule": crontab(hour=3, minute=0),
     },
+    "automation_rule_on_every_tickets": {
+        "task": "core.tasks.apply_rules_to_all_tickets",
+        "schedule": crontab(hour=1, minute=0),
+    },
 }