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

Author: mrsaicharan1

app/api/helpers/scheduled_jobs.py

@@ -164,14 +164,12 @@ 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'})
-
-        db.session.commit()
+        db.session.query(EventInvoice).filter(
+            EventInvoice.status == 'upcoming',
+            Event.id == EventInvoice.event_id,
+            Event.ends_at >= datetime.datetime.now(),
+            (EventInvoice.created_at + datetime.timedelta(days=30) <= datetime.datetime.now())
+        ).update({EventInvoice.status: 'due'}, synchronize_session=False)
 
 
 def send_monthly_event_invoice():

app/factories/event_invoice.py

@@ -25,6 +25,7 @@ class Meta:
     paid_via = "stripe"
     payment_mode = common.string_
     brand = common.string_
+    created_at = common.date_
     exp_month = "10"
     exp_year = "2100"
     last4 = "1234"

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

@@ -0,0 +1,36 @@
+import datetime
+
+from app import current_app as app, db
+from app.factories.event_invoice import EventInvoiceFactory
+from app.models.event_invoice import EventInvoice
+from app.api.helpers.scheduled_jobs import event_invoices_mark_due
+
+from tests.all.integration.utils import OpenEventTestCase
+
+
+class TestScheduledJobs(OpenEventTestCase):
+
+    def test_event_invoices_mark_due(self):
+        """Method to test marking of event invoices as due"""
+
+        with app.test_request_context():
+            event_invoice = EventInvoiceFactory(event__ends_at=datetime.datetime(2019, 7, 20))
+            db.session.commit()
+            event_invoice_id = event_invoice.id
+            status_1 = EventInvoice.query.get(event_invoice_id).status
+
+            event_invoice = EventInvoiceFactory(status="paid")
+            db.session.commit()
+            event_invoice_id = event_invoice.id
+            status_2 = EventInvoice.query.get(event_invoice_id).status
+
+            event_invoice = EventInvoiceFactory()
+            event_invoice.created_at = datetime.datetime.now()
+            db.session.commit()
+            event_invoice_id = event_invoice.id
+            status_3 = EventInvoice.query.get(event_invoice_id).status
+
+            event_invoices_mark_due()
+            self.assertEqual(status_1, "due")
+            self.assertNotEqual(status_2, "due")
+            self.assertNotEqual(status_3, "due")