basic email sending

Author: Mayank808

backend/app/interfaces/email_service.py

@@ -8,7 +8,7 @@ class IEmailService(ABC):
     """
 
     @abstractmethod
-    def send_email(self, to: str, subject: str, body: str) -> dict:
+    def send_email(self, subject: str, recipient: str, body_html: str) -> None:
         """
         Sends an email with the given parameters.
 
@@ -23,50 +23,3 @@ def send_email(self, to: str, subject: str, body: str) -> dict:
         :raises Exception: if email was not sent successfully
         """
         pass
-
-    @abstractmethod
-    def send_welcome_email(self, recipient: str, user_name: str) -> dict:
-        """
-        Sends a welcome email to the specified user.
-
-        :param recipient: Email address of the user
-        :type recipient: str
-        :param user_name: Name of the user
-        :type user_name: str
-        :return: Provider-specific metadata for the sent email
-        :rtype: dict
-        :raises Exception: if email was not sent successfully
-        """
-        pass
-
-    @abstractmethod
-    def send_password_reset_email(self, recipient: str, reset_link: str) -> dict:
-        """
-        Sends a password reset email with the provided reset link.
-
-        :param recipient: Email address of the user requesting the reset
-        :type recipient: str
-        :param reset_link: Password reset link
-        :type reset_link: str
-        :return: Provider-specific metadata for the sent email
-        :rtype: dict
-        :raises Exception: if email was not sent successfully
-        """
-        pass
-
-    @abstractmethod
-    def send_notification_email(self, recipient: str, notification_text: str) -> dict:
-        """
-        Sends a notification email to the user with the provided notification text.
-        Examples of use case include matches completed and ready to view, new messages,
-        meeting time scheduled, etc.
-
-        :param recipient: Email address of the user
-        :type recipient: str
-        :param notification_text: The notification content
-        :type notification_text: str
-        :return: Provider-specific metadata for the sent email
-        :rtype: dict
-        :raises Exception: if email was not sent successfully
-        """
-        pass

backend/app/interfaces/email_service_provider.py

@@ -8,9 +8,7 @@ class IEmailServiceProvider(ABC):
     """
 
     @abstractmethod
-    def send_email(
-        self, recipient: str, subject: str, body_html: str, body_text: str
-    ) -> dict:
+    def send_email(self, recipient: str, subject: str) -> None:
         """
         Sends an email using the provider's service.
 

backend/app/routes/email.py

@@ -1,28 +1,36 @@
+import logging
 from typing import Annotated
 
 from fastapi import APIRouter, Depends
 
 from app.interfaces.email_service import IEmailService
 from app.services.email.email_service import EmailService
-from app.services.email.email_service_provider import AmazonSESEmailProvider
+from app.services.email.email_service_provider import (
+    get_email_service_provider,
+)
 
 router = APIRouter(
     prefix="/email",
     tags=["email"],
 )
 
+log = logging.getLogger("uvicorn")
+
 
 def get_email_service() -> IEmailService:
-    email_provider = AmazonSESEmailProvider(aws_access_key="", aws_secret_key="")
-    return EmailService(email_provider)
+    return EmailService(get_email_service_provider())
 
 
 # TODO (Mayank, Nov 30th) - Remove test emails once email service is fully implemented
-@router.post("/send-test-email/")
+@router.post("/send-test")
 async def send_welcome_email(
     recipient: str,
     user_name: str,
     email_service: Annotated[IEmailService, Depends(get_email_service)],
 ):
-    email_service.send_welcome_email(recipient, user_name)
+    log.info(f"Main Sending welcome email to {user_name} at {recipient}")
+    email_service.send_email(
+        subject="Welcome to the app!",
+        recipient=recipient,
+    )
     return {"message": f"Welcome email sent to {user_name}!"}

backend/app/server.py

@@ -10,18 +10,16 @@
 load_dotenv()
 
 # we need to load env variables before initialization code runs
-from . import models  # noqa: E402
 from .routes import user  # noqa: E402
-from .utilities.firebase_init import initialize_firebase  # noqa: E402
 
 log = logging.getLogger("uvicorn")
 
 
 @asynccontextmanager
 async def lifespan(_: FastAPI):
     log.info("Starting up...")
-    models.run_migrations()
-    initialize_firebase()
+    # models.run_migrations()
+    # initialize_firebase()
     yield
     log.info("Shutting down...")
 
@@ -36,6 +34,7 @@ async def lifespan(_: FastAPI):
 
 @app.get("/")
 def read_root():
+    log.info("Hello World")
     return {"Hello": "World"}
 
 

backend/app/services/email/email_service.py

@@ -1,3 +1,5 @@
+import logging
+
 from app.interfaces.email_service import IEmailService
 from app.interfaces.email_service_provider import IEmailServiceProvider
 
@@ -6,15 +8,8 @@
 class EmailService(IEmailService):
     def __init__(self, provider: IEmailServiceProvider):
         self.provider = provider
+        self.logger = logging.getLogger(__name__)
 
-    def send_email(self, to: str, subject: str, body: str) -> dict:
-        pass
-
-    def send_welcome_email(self, recipient: str, user_name: str) -> dict:
-        pass
-
-    def send_password_reset_email(self, recipient: str, reset_link: str) -> dict:
-        pass
-
-    def send_notification_email(self, recipient: str, notification_text: str) -> dict:
-        pass
+    def send_email(self, subject: str, recipient: str, body_html: str = "") -> None:
+        self.logger.info(f"Sending email to {recipient} with subject: {subject}")
+        self.provider.send_email(subject, recipient)

backend/app/services/email/email_service_provider.py

@@ -1,12 +1,63 @@
+import os
+
+import boto3
+from botocore.exceptions import BotoCoreError, ClientError
+from fastapi import HTTPException
+
 from app.interfaces.email_service_provider import IEmailServiceProvider
 
 
 class AmazonSESEmailProvider(IEmailServiceProvider):
-    def __init__(self, aws_access_key: str, aws_secret_key: str):
-        pass
-
-    # TODO (Mayank, Nov 30th) - Create an email object to pass into this method
-    def send_email(
-        self, recipient: str, subject: str, body_html: str, body_text: str
-    ) -> dict:
-        pass
+    def __init__(
+        self,
+        aws_access_key: str,
+        aws_secret_key: str,
+        region: str,
+        source_email: str,
+        is_sandbox: bool = True,
+    ):
+        self.source_email = source_email
+        self.is_sandbox = is_sandbox
+        self.ses_client = boto3.client(
+            "ses",
+            region_name=region,
+            aws_access_key_id=aws_access_key,
+            aws_secret_access_key=aws_secret_key,
+        )
+
+    def _verify_email(self, email: str):
+        if not self.is_sandbox:
+            return
+        try:
+            self.client.verify_email_identity(EmailAddress=email)
+            print(f"Verification email sent to {email}.")
+        except Exception as e:
+            print(f"Failed to verify email: {e}")
+
+    def send_email(self, subject: str, recipient: str) -> None:
+        try:
+            self._verify_email(recipient)
+            self.ses_client.send_email(
+                Source=self.source_email,
+                Destination={"ToAddresses": [recipient]},
+                Message={
+                    "Subject": {"Data": subject},
+                    "Body": {"Text": {"Data": "Hello, this is a test email!"}},
+                },
+            )
+        except BotoCoreError as e:
+            raise HTTPException(status_code=500, detail=f"SES BotoCoreError: {e}")
+        except ClientError as e:
+            raise HTTPException(
+                status_code=500,
+                detail=f"SES ClientError: {e.response['Error']['Message']}",
+            )
+
+
+def get_email_service_provider() -> IEmailServiceProvider:
+    return AmazonSESEmailProvider(
+        aws_access_key=os.getenv("AWS_ACCESS_KEY"),
+        aws_secret_key=os.getenv("AWS_SECRET_KEY"),
+        region=os.getenv("AWS_REGION"),
+        source_email=os.getenv("SES_SOURCE_EMAIL"),
+    )

backend/pdm.lock

@@ -17,6 +17,7 @@ dependencies = [
     "inflection>=0.5.1",
     "pre-commit>=4.0.0",
     "psycopg2>=2.9.9",
+    "boto3>=1.35.71",
 ]
 requires-python = "==3.12.*"
 readme = "README.md"