feat: dispatch emails on sso based logins

backend/api/views.py

@@ -30,11 +30,22 @@
 from rest_framework import status
 from django.views.decorators.csrf import csrf_exempt
 from django.utils import timezone
+from backend.api.email import send_email
 
 CLOUD_HOSTED = settings.APP_HOST == 'cloud'
 
 # for custom gitlab adapter class
 
+def get_client_ip(request):
+    """
+    Get client IP address from request.
+    """
+    x_forwarded_for = request.META.get('HTTP_X_FORWARDED_FOR')
+    if x_forwarded_for:
+        ip = x_forwarded_for.split(',')[0]
+    else:
+        ip = request.META.get('REMOTE_ADDR')
+    return ip
 
 def _check_errors(response):
     #  403 error's are presented as user-facing errors
@@ -85,9 +96,38 @@ def complete_login(self, request, app, token, response, **kwargs):
             raise OAuth2Error("Invalid id_token") from e
         login = self.get_provider().sociallogin_from_response(request, identity_data)
         email = login.email_addresses[0]
+
         if CLOUD_HOSTED and not CustomUser.objects.filter(email=email).exists():
-            # new user
-            notify_slack(f"New user signup: {email}")
+            try:
+                # Notify Slack
+                notify_slack(f"New user signup: {email}")
+            except Exception as e:
+                print(f"Error notifying Slack: {e}")
+
+        # Grabbing metadata
+        user_agent = request.META.get('HTTP_USER_AGENT', 'Unknown')
+        ip_address = get_client_ip(request)
+        timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+
+        # Creating context dictionary
+        context = {
+            'auth': 'GitHub',
+            'email': email,
+            'ip': ip_address,
+            'user_agent': user_agent,
+            'timestamp': timestamp
+        }
+
+        try:
+            # Calling send_email function
+            send_email(
+                'New Login Alert - Phase Console',
+                [email],
+                'backend/api/email_templates/login.html',
+                context
+            )
+        except Exception as e:
+            print(f"Error sending email: {e}")
 
         return login
 
@@ -117,9 +157,39 @@ def complete_login(self, request, app, token, **kwargs):
             extra_data["email"] = self.get_email(headers)
 
         email = extra_data["email"]
+
         if CLOUD_HOSTED and not CustomUser.objects.filter(email=email).exists():
-            # new user
-            notify_slack(f"New user signup: {email}")
+            try:
+                # Notify Slack
+                notify_slack(f"New user signup: {email}")
+            except Exception as e:
+                print(f"Error notifying Slack: {e}")
+
+            # Grabbing metadata
+            user_agent = request.META.get('HTTP_USER_AGENT', 'Unknown')
+            ip_address = get_client_ip(request)
+            timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+
+            # Creating context dictionary
+            context = {
+                'auth': 'GitHub',
+                'email': email,
+                'ip': ip_address,
+                'user_agent': user_agent,
+                'timestamp': timestamp
+            }
+
+            try:
+                # Calling send_email function
+                send_email(
+                    'New Login Alert - Phase Console',
+                    [email],
+                    'backend/api/email_templates/login.html',
+                    context
+                )
+            except Exception as e:
+                print(f"Error sending email: {e}")
+
         return self.get_provider().sociallogin_from_response(request, extra_data)
 
 
@@ -145,9 +215,39 @@ def complete_login(self, request, app, token, response):
 
         email = login.email_addresses[0]
 
-        if CLOUD_HOSTED and not CustomUser.objects.filter(email=email).exists():
-            # new user
-            notify_slack(f"New user signup: {email}")
+        if CLOUD_HOSTED:
+            # Check if user exists and notify Slack for new user signup
+            if not CustomUser.objects.filter(email=email).exists():
+                try:
+                    notify_slack(f"New user signup: {email}")
+                except Exception as e:
+                    print(f"Error notifying Slack: {e}")
+
+                # Grabbing metadata
+                user_agent = request.META.get('HTTP_USER_AGENT', 'Unknown')
+                ip_address = get_client_ip(request)
+                timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+
+                # Creating context dictionary
+                context = {
+                    'auth': 'GitLab',
+                    'email': email,
+                    'ip': ip_address,
+                    'user_agent': user_agent,
+                    'timestamp': timestamp
+                }
+
+                try:
+                    # Calling send_email function
+                    send_email(
+                        'New Login Alert - Phase Console',
+                        [email],
+                        'backend/api/email_templates/login.html',
+                        context
+                    )
+                except Exception as e:
+                    print(f"Error sending email: {e}")
+
         return login