fix: Fixed cron job and added tests - EVent Invoice Due Marking

Author: mrsaicharan1

app/api/helpers/scheduled_jobs.py

@@ -164,12 +164,13 @@ def expire_pending_tickets():
 def event_invoices_mark_due():
     from app import current_app as app
     with app.app_context():
-        db.session.query(EventInvoice).\
-                    filter(EventInvoice.status == 'upcoming',
-                           EventInvoice.event.ends_at >= datetime.datetime.now(),
-                           (EventInvoice.created_at + datetime.timedelta(days=30) <=
-                            datetime.datetime.now())).\
-                    update({'status': 'due'})
+        event_invoices =  db.session.query(EventInvoice).join(Event).\
+                                filter(EventInvoice.status == 'upcoming',
+                                    Event.ends_at >= datetime.datetime.now(),
+                                    (EventInvoice.created_at + datetime.timedelta(days=30) <=
+                                        datetime.datetime.now())).all()
+        for invoice in event_invoices:
+            invoice.status = "due"
 
         db.session.commit()
 

tests/all/integration/api/helpers/test_scheduled_jobs.py

@@ -0,0 +1,32 @@
+import unittest
+import datetime
+
+from app import current_app as app, db
+from app.factories.event_invoice import EventInvoiceFactory
+from app.api.helpers.db import save_to_db
+from app.models.event_invoice import EventInvoice
+from app.factories.event import EventFactoryBasic
+from app.api.helpers.scheduled_jobs import event_invoices_mark_due
+
+from tests.all.integration.setup_database import Setup
+from tests.all.integration.utils import OpenEventTestCase
+
+
+class TestScheduledJobs(OpenEventTestCase):
+    def setUp(self):
+        self.app = Setup.create_app()
+
+    def test_event_invoices_mark_due(self):
+        """Method to test marking of event invoices as due"""
+
+        with app.test_request_context():
+            event_invoice_obj = EventInvoiceFactory(event__ends_at=datetime.datetime(2019, 7, 20))
+            save_to_db(event_invoice_obj)
+            event_invoices_mark_due()
+            status = db.session.query(EventInvoice).\
+                        filter(EventInvoice.id == event_invoice_obj.id).first().status
+            self.assertEqual(status, "due")
+
+
+if __name__ == '__main__':
+    unittest.main()