Merge pull request hasgeek#295 from abijith-kp/master

Add sweep command under manage.py. Fixes hasgeek#221

manage.py

@@ -1,13 +1,30 @@
 #!/usr/bin/env python
 
-from coaster.manage import init_manager
+from coaster.manage import init_manager, manager
 
 import hasjob
 import hasjob.models as models
 import hasjob.forms as forms
 import hasjob.views as views
 from hasjob.models import db
 from hasjob import app, init_for
+from datetime import datetime, timedelta
+from sqlalchemy.exc import IntegrityError
+
+@manager.option('-e', '--env', default='dev', help="runtime env [default 'dev']")
+def sweep(env):
+    """Sweep the user database to close all the inactive sessions"""
+    manager.init_for(env)
+    print "Sweeping all the inactive sessions"
+    es = models.EventSession
+    # Inactive sessions are only kept for 30mins
+    es.query.filter((es.ended_at==None) & (es.active_at<(datetime.utcnow() - \
+        timedelta(minutes=30)))).update({es.ended_at: es.active_at})
+    try:
+        db.session.commit()
+    except IntegrityError:
+        print "Could not commit changes made. Please try again later."
+        db.session.rollback()
 
 
 if __name__ == '__main__':