Merge branch 'feat/create_database_notification' into 'dev'

Database create notification

See merge request dbdev/dbaas!15

Author: Marcelo Rodrigues Da Silva Soares

dbaas/notification/tasks.py

@@ -151,6 +151,7 @@ def create_database(
         database_create.set_success()
         task.set_status_success('Database created')
         database_create.database.finish_task()
+        email_notifications.notify_new_database_creation(database_create)
     else:
         database_create.set_error()
         task.set_status_error(

dbaas/notification/templates/email_extras/database_create_notification.html

@@ -0,0 +1,22 @@
+<h2>{{ database_name }} database was created</h2>
+
+Database <a href="{{ database_url }}">{{ database_name }}</a> was created in DBaaS in environment {{ environment }} by user {{ user }}.
+<br><br>
+The database features are:
+- Offering: {{ offering }}
+- Database type: {{ database_type }}
+- Disk size: {{ disk_size }}
+<br><br>
+Any questions please contact the DBDevops responsible for your team.
+<br><br>
+
+{% if database.team.email %}
+You are receiving this email because in our records you are in team {{ database.team.name }}.<br>
+If this is not right, contact the DBaaS system administrators.
+{% else %}
+<h3>Team {{ database.team.name }} has no email set!</h3>
+{% endif %}
+<br><br><br>
+Regards,<br>
+DBaaS notification robot<br>
+{{domain}}<br>

dbaas/notification/templates/email_extras/database_create_notification.txt

@@ -0,0 +1,19 @@
+Database {{ database_name }} was created in DBaaS in environment {{ environment }} by user {{ user }}.
+
+The database features are:
+- Offering: {{ offering }}
+- Database type: {{ database_type }}
+- Disc size: {{ disk_size }}
+
+Any questions please contact the DBDevops responsible for your team.
+
+{% if database.team.email %}
+You are receiving this email because in our records you are in team {{ database.team.name }}.<br>
+If this is not right, contact the DBaaS system administrators.
+{% else %}
+Team {{ database.team.name }} has no email set!
+{% endif %}
+
+Regards,
+DBaaS notification robot
+{{domain}}

dbaas/util/email_notifications.py

@@ -14,7 +14,6 @@ def get_domain():
     domain = Site.objects.get(id=1).domain
     if not domain.startswith('http'):
         return "http://" + domain
-
     return domain
 
 
@@ -29,25 +28,50 @@ def email_to(team):
 
 
 def get_database_url(uuid):
-    return get_domain() + reverse('admin:logical_database_hosts',
-                                  kwargs={'id': uuid})
+    return get_domain() + reverse('admin:logical_database_hosts', kwargs={'id': uuid})
+
+
+def notify_new_database_creation(database=None):
+    subject = _("[DBAAS] a new database has just been created: {} by {}".format(database.name, database.team.name))
+    template = "database_create_notification"
+    addr_from = Configuration.get_by_name("email_addr_from")
+    addr_to = Configuration.get_by_name_as_list("new_user_notify_email")
+    domain = get_domain()
+
+    context = {
+        "database": database,
+        "database_name": database.name,
+        "offering": database.infra.offering.name,
+        "environment": database.environment.name,
+        "database_type": database.infra.engine.name,
+        "disk_size": database.infra.disk_offering.name,
+        "user": database.user,
+        "database_url": domain + reverse('admin:account_team_changelist'),
+        "domain": domain
+    }
+    LOG.debug("user: %s | addr_from: %s | addr_to: %s" % (database.user, addr_from, addr_to))
+    if database.user and addr_from and addr_to:
+        send_mail_template(
+            subject, template, addr_from, addr_to, fail_silently=False, attachments=None, context=context
+        )
+    else:
+        LOG.warning("could not send email for new user creation")
 
 
 def notify_new_user_creation(user=None):
     subject = _("[DBAAS] a new user has just been created: %s" % user.username)
     template = "new_user_notification"
     addr_from = Configuration.get_by_name("email_addr_from")
     addr_to = Configuration.get_by_name_as_list("new_user_notify_email")
+
     context = {}
     context['user'] = user
     domain = get_domain()
     context['url'] = domain + reverse('admin:account_team_changelist')
-    LOG.debug("user: %s | addr_from: %s | addr_to: %s" %
-              (user, addr_from, addr_to))
+    LOG.debug("user: %s | addr_from: %s | addr_to: %s" % (user, addr_from, addr_to))
     if user and addr_from and addr_to:
         send_mail_template(
-            subject, template, addr_from, addr_to,
-            fail_silently=False, attachments=None, context=context
+            subject, template, addr_from, addr_to, fail_silently=False, attachments=None, context=context
         )
     else:
         LOG.warning("could not send email for new user creation")
@@ -163,7 +187,7 @@ def upgrade_offering_notification(database, resize_target):
     current_offering = database.databaseinfra.offering
     future_offering = database.get_future_offering(resize_target)
 
-    subject = _('[DBaaS] Database {} auto upgrade offering to {}').format(database, future_offering.name)
+    subject = _('[DBaaS] Database {} is being auto upgrade offering to {}').format(database, future_offering.name)
     template = "auto_upgrade_offering_notification"
 
     context = {