Added task ready notification emails, minor fixes in the send_email utility.

services/webapp/code/rosetta/base_app/api.py

@@ -3,10 +3,11 @@ from django.http import HttpResponse
 from django.utils import timezone
 from django.contrib.auth import authenticate, login, logout
 from django.contrib.auth.models import User, Group
+from django.conf import settings
 from rest_framework.response import Response
 from rest_framework import status, serializers, viewsets
 from rest_framework.views import APIView
-from .utils import format_exception
+from .utils import format_exception, send_email
 from .models import Profile, Task, TaskStatuses
  
 # Setup logging
@@ -308,6 +309,15 @@ print(port)
                 task.ip     = task_ip
                 task.port   = int(task_port)
                 task.save()
+                        
+                # Notify the user that the task called back home
+                logger.info('Sending task ready mail notification to "{}"'.format(task.user.email))
+                mail_subject = 'Your Task "{}" is up and running'.format(task.container.name)
+                mail_text = 'Hello,\n\nyour Task "{}" on {} is up and running: {}/tasks/?uuid={}\n\nThe Rosetta notifications bot.'.format(task.container.name, task.computing, settings.DJANGO_PUBLIC_HTTP_HOST, task.uuid)
+                try:
+                    send_email(to=task.user.email, subject=mail_subject, text=mail_text)
+                except Exception as e:
+                    logger.error('Cannot send task ready email: "{}"'.format(e))
                 return HttpResponse('OK')
                 
     

services/webapp/code/rosetta/base_app/utils.py

@@ -59,8 +59,17 @@ def send_email(to, subject, text):
         subject = subject
         content = Content('text/plain', text)
         mail = Mail(from_email, subject, to_email, content)
-        response = sg.client.mail.send.post(request_body=mail.get())
-        logger.debug(response)
+        
+        try:
+            response = sg.client.mail.send.post(request_body=mail.get())
+
+            #logger.debug(response.status_code)
+            #logger.debug(response.body)
+            #logger.debug(response.headers)
+        except Exception as e:
+            logger.error(e)
+        
+        #logger.debug(response)
     
 
 def format_exception(e, debug=False):