Autoresolve for "expired" tickets

manage.py

@@ -42,17 +42,30 @@ def seed():
             student = User(name=real_name, email=email)
             db.session.add(student)
             db.session.commit()
-
         delta = datetime.timedelta(minutes=random.randrange(0, 30))
-        ticket = Ticket(
-            user=student,
-            status=TicketStatus.pending,
-            created=datetime.datetime.utcnow() - delta,
-            assignment=random.choice(['Hog', 'Scheme']),
-            description=random.choice(['', 'SyntaxError on Line 5']),
-            question=random.randrange(1, 6),
-            location=random.choice(['109 Morgan', '247 Cory']),
-        )
+        if i % 2 == 0:
+            ticket = Ticket(
+                user=student,
+                status=TicketStatus.pending,
+                created=datetime.datetime.utcnow() - delta,
+                assignment=random.choice(['Hog', 'Scheme']),
+                description=random.choice(['', 'SyntaxError on Line 5']),
+                question=random.randrange(1, 6),
+                location=random.choice(['109 Morgan', '247 Cory']),
+            )
+        else:
+            ticket = Ticket(
+                user=student,
+                status=TicketStatus.assigned,
+                created=datetime.datetime.utcnow() - delta,
+                updated= datetime.datetime.utcnow(),
+                assignment=random.choice(['Hog', 'Scheme']),
+                description=random.choice(['', 'SyntaxError on Line 5']),
+                question=random.randrange(1, 6),
+                location=random.choice(['109 Morgan', '247 Cory']),
+                helper_id = 61
+            )
+
         db.session.add(ticket)
         db.session.commit()
 

oh_queue/models.py

@@ -42,7 +42,7 @@ def short_name(self):
             return first_name.rsplit('@')[0]
         return first_name
 
-TicketStatus = enum.Enum('TicketStatus', 'pending assigned resolved deleted')
+TicketStatus = enum.Enum('TicketStatus', 'pending assigned resolved deleted autoresolved autodeleted')
 
 class Ticket(db.Model):
     """Represents an ticket in the queue. A student submits a ticket and receives
@@ -87,7 +87,7 @@ def by_status(cls, status=None):
 
 TicketEventType = enum.Enum(
     'TicketEventType',
-    'create assign unassign resolve delete describe',
+    'create assign unassign resolve delete describe autoresolve autodelete',
 )
 
 class TicketEvent(db.Model):

oh_queue/views.py

@@ -41,11 +41,24 @@ def ticket_json(ticket):
     }
 
 def emit_event(ticket, event_type):
-    ticket_event = TicketEvent(
+    if event_type == TicketEventType.autodelete:
+        ticket_event = TicketEvent(
         event_type=event_type,
         ticket=ticket,
-        user=current_user,
+        user_id=0 # assuming ids start @ 1, 0 signifies admin/autodelete
+    )
+    elif event_type == TicketEventType.autoresolve:
+        ticket_event = TicketEvent(
+        event_type=event_type,
+        ticket=ticket,
+        user_id=ticket.helper_id
     )
+    else:
+        ticket_event = TicketEvent(
+            event_type=event_type,
+            ticket=ticket,
+            user=current_user,
+        )
     db.session.add(ticket_event)
     db.session.commit()
     socketio.emit('event', {
@@ -131,6 +144,21 @@ def disconnect():
 
 @socketio.on('refresh')
 def refresh(ticket_ids):
+    """ Cuts out tickets that have elapsed time beyond cuttoff in minutes"""
+    pending_cutoff = 180
+    assigned_cutoff = 30
+
+    pending_cutoff_time = datetime.datetime.utcnow() - datetime.timedelta(minutes = pending_cutoff)
+    assigned_cutoff_time = datetime.datetime.utcnow() - datetime.timedelta(minutes = assigned_cutoff)
+
+    exp_pending_tickets = Ticket.query.filter(Ticket.created < pending_cutoff_time, Ticket.status == TicketStatus.pending).all()
+    exp_pending_ticket_ids = [tick.id for tick in exp_pending_tickets]
+    autodelete(exp_pending_ticket_ids)
+
+    exp_assigned_tickets = Ticket.query.filter(Ticket.updated < assigned_cutoff_time, Ticket.status == TicketStatus.assigned).all()
+    exp_assigned_ticket_ids = [tick.id for tick in exp_assigned_tickets]
+    autoresolve(exp_assigned_ticket_ids)
+
     tickets = Ticket.query.filter(Ticket.id.in_(ticket_ids)).all()
     return {
         'tickets': [ticket_json(ticket) for ticket in tickets],
@@ -204,6 +232,14 @@ def delete(ticket_ids):
         emit_event(ticket, TicketEventType.delete)
     db.session.commit()
 
+@socketio.on('autodelete')
+def autodelete(ticket_ids):
+    tickets = get_tickets(ticket_ids)
+    for ticket in tickets:
+        ticket.status = TicketStatus.autodeleted
+        emit_event(ticket, TicketEventType.autodelete)
+    db.session.commit()
+
 @socketio.on('resolve')
 @logged_in
 def resolve(ticket_ids):
@@ -216,6 +252,15 @@ def resolve(ticket_ids):
     db.session.commit()
     return get_next_ticket()
 
+@socketio.on('resolve')
+def autoresolve(ticket_ids):
+    tickets = get_tickets(ticket_ids)
+    for ticket in tickets:
+        ticket.status = TicketStatus.autoresolved
+        emit_event(ticket, TicketEventType.autoresolve)
+    db.session.commit()
+    #return get_next_ticket()
+
 @socketio.on('assign')
 @is_staff
 def assign(ticket_ids):