aboutsummaryrefslogtreecommitdiffstats
path: root/src/notifier/manager.py
diff options
context:
space:
mode:
authorSawyer Bergeron <sbergeron@iol.unh.edu>2020-10-05 16:13:03 -0400
committerSawyer Bergeron <sbergeron@iol.unh.edu>2020-10-05 16:13:54 -0400
commit0d20968698aa4a5fc58bad9ae30857df504e170c (patch)
tree615e00ef5090accde08e913e431057e11cf706ea /src/notifier/manager.py
parent836ba6a22ece7590c203c837669b73259f02540a (diff)
Make emails send asynchronously (using celery job)
Change-Id: I9f4d5d05a0b72c883d667cf3910b3b318cbe82fa Signed-off-by: Sawyer Bergeron <sbergeron@iol.unh.edu>
Diffstat (limited to 'src/notifier/manager.py')
-rw-r--r--src/notifier/manager.py29
1 files changed, 5 insertions, 24 deletions
diff --git a/src/notifier/manager.py b/src/notifier/manager.py
index 8ea8021..e2afdec 100644
--- a/src/notifier/manager.py
+++ b/src/notifier/manager.py
@@ -8,9 +8,8 @@
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
import os
-from notifier.models import Notification, Emailed
+from notifier.models import Notification, Emailed, Email
-from django.core.mail import send_mail
from django.template.loader import render_to_string
from django.utils import timezone
@@ -99,14 +98,8 @@ class NotificationHandler(object):
# render email template
message = render_to_string(template_name, context)
- # finally, send the email
- send_mail(
- "Your Booking is Ready",
- message,
- os.environ.get("DEFAULT_FROM_EMAIL", "opnfv@laas-dashboard"),
- [user.userprofile.email_addr],
- fail_silently=False
- )
+ # finally, queue email for sending
+ Email.objects.create(title="Your Booking is Ready", message=message, recipient=user.userprofile.email_addr)
@classmethod
def email_booking_over(cls, booking):
@@ -124,13 +117,7 @@ class NotificationHandler(object):
message = render_to_string(template_name, context)
- send_mail(
- "Your Booking has Expired",
- message,
- os.environ.get("DEFAULT_FROM_EMAIL", "opnfv@laas-dashboard"),
- [user.userprofile.email_addr],
- fail_silently=False
- )
+ Email.objects.create(title="Your Booking has Expired", message=message, recipient=user.userprofile.email_addr)
@classmethod
def email_booking_expiring(cls, booking):
@@ -148,13 +135,7 @@ class NotificationHandler(object):
message = render_to_string(template_name, context)
- send_mail(
- "Your Booking is Expiring",
- message,
- os.environ.get("DEFAULT_FROM_EMAIL", "opnfv@laas-dashboard"),
- [user.userprofile.email_addr],
- fail_silently=False
- )
+ Email.objects.create(title="Your Booking is Expiring", message=message, recipient=user.userprofile.email_addr)
@classmethod
def task_updated(cls, task):