♻️ refactor(payments): use Notification service for emails ⚠️ 🚨 (#9042)

Author: giancarloromeo

.env-devel

@@ -187,7 +187,6 @@ PAYMENTS_AUTORECHARGE_DEFAULT_TOP_UP_AMOUNT=100.0
 PAYMENTS_AUTORECHARGE_ENABLED=1
 PAYMENTS_AUTORECHARGE_MIN_BALANCE_IN_CREDITS=100
 PAYMENTS_BCC_EMAIL=none
-PAYMENTS_EMAIL={}
 PAYMENTS_FAKE_COMPLETION_DELAY_SEC=10
 PAYMENTS_FAKE_COMPLETION=0
 PAYMENTS_GATEWAY_API_SECRET=adminadmin

packages/models-library/src/models_library/notifications/celery/__init__.py

@@ -1,6 +1,7 @@
-from ._email import EmailContact, EmailContent, EmailMessage
+from ._email import EmailAttachment, EmailContact, EmailContent, EmailMessage
 
 __all__: tuple[str, ...] = (
+    "EmailAttachment",
     "EmailContact",
     "EmailContent",
     "EmailMessage",

packages/models-library/src/models_library/notifications/rpc/__init__.py

@@ -6,6 +6,7 @@
 from ._email import (
     Addressing,
     EmailAddressing,
+    EmailAttachment,
     EmailContact,
     EmailContent,
     EmailMessage,
@@ -28,6 +29,7 @@
 __all__: tuple[str, ...] = (
     "Addressing",
     "EmailAddressing",
+    "EmailAttachment",
     "EmailContact",
     "EmailContent",
     "EmailMessage",

packages/models-library/src/models_library/notifications/rpc/_email.py

@@ -10,6 +10,11 @@ class EmailContact(BaseModel):
     email: EmailStr
 
 
+class EmailAttachment(BaseModel):
+    content: bytes
+    filename: str
+
+
 class EmailContent(BaseModel):
     subject: Annotated[str, Field(min_length=1, max_length=998)]
     body_html: str | None = None
@@ -19,8 +24,11 @@ class EmailContent(BaseModel):
 class EmailAddressing(BaseModel):
     from_: Annotated[EmailContact, Field(alias="from")]
     to: list[EmailContact]
+    bcc: EmailContact | None = None
     reply_to: EmailContact | None = None
 
+    attachments: list[EmailAttachment] | None = None
+
     model_config = ConfigDict(
         frozen=True,
         validate_by_alias=True,

packages/notifications-library/src/notifications_library/templates/email/paid/body_html.j2

@@ -8,7 +8,7 @@
 <p>We are delighted to confirm the successful processing of your payment of <strong>{{ payment.price_dollars }}</strong> <strong><em>USD</em></strong> for the purchase of <strong>{{ payment.osparc_credits }}</strong> <strong><em>credits</em></strong>.
   The credits have been added to your {{ product.display_name }} account, and you are all set to utilize them.</p>
 <p>For more details you can view or download your <a href="{{ payment.invoice_url }}">receipt</a>.</p>
-<p>Please don't hesitate to contact us at {{ product.support_email }} if you need further help.</p>
+<p>Please don't hesitate to contact us at <a href="mailto:{{ product.support_email }}">{{ product.support_email }}</a> if you need further help.</p>
 <p>Best Regards,</p>
 <p>The <i>{{ product.display_name }}</i> Team</p>
 

services/docker-compose.yml

@@ -1549,7 +1549,6 @@ services:
       PAYMENTS_AUTORECHARGE_ENABLED: ${PAYMENTS_AUTORECHARGE_ENABLED}
       PAYMENTS_AUTORECHARGE_MIN_BALANCE_IN_CREDITS: ${PAYMENTS_AUTORECHARGE_MIN_BALANCE_IN_CREDITS}
       PAYMENTS_BCC_EMAIL: ${PAYMENTS_BCC_EMAIL}
-      PAYMENTS_EMAIL: ${PAYMENTS_EMAIL}
       PAYMENTS_GATEWAY_API_SECRET: ${PAYMENTS_GATEWAY_API_SECRET}
       PAYMENTS_GATEWAY_URL: ${PAYMENTS_GATEWAY_URL}
       PAYMENTS_LOGLEVEL: ${PAYMENTS_LOGLEVEL}

services/notifications/src/simcore_service_notifications/api/celery/_email.py

@@ -9,6 +9,7 @@
 from models_library.celery import TaskKey
 from models_library.notifications.celery import EmailContact, EmailContent, EmailMessage
 from notifications_library._email import (
+    add_attachments,
     compose_email,
     create_email_session,
 )
@@ -33,22 +34,29 @@ async def send_email_message(
     msg = EmailMessage(
         from_=EmailContact(**message.from_.model_dump()),
         to=EmailContact(**message.to.model_dump()),
+        bcc=EmailContact(**message.bcc.model_dump()) if message.bcc else None,
         reply_to=EmailContact(**message.reply_to.model_dump()) if message.reply_to else None,
         content=EmailContent(**message.content.model_dump()),
+        attachments=message.attachments,
     )
 
     with log_context(_logger, logging.INFO, "Send email to %s", msg.to.email):
         settings = SMTPSettings.create_from_envs()
 
         async with create_email_session(settings=settings) as smtp:
-            await smtp.send_message(
-                compose_email(
-                    from_=_to_address(msg.from_),
-                    to=_to_address(msg.to),
-                    subject=msg.content.subject,
-                    content_text=msg.content.body_text,
-                    content_html=msg.content.body_html,
-                    reply_to=_to_address(msg.reply_to) if msg.reply_to else None,
-                    extra_headers=settings.SMTP_EXTRA_HEADERS,
-                )
+            email_msg = compose_email(
+                from_=_to_address(msg.from_),
+                to=_to_address(msg.to),
+                subject=msg.content.subject,
+                content_text=msg.content.body_text,
+                content_html=msg.content.body_html,
+                reply_to=_to_address(msg.reply_to) if msg.reply_to else None,
+                bcc=[_to_address(msg.bcc)] if msg.bcc else None,
+                extra_headers=settings.SMTP_EXTRA_HEADERS,
             )
+            if msg.attachments:
+                add_attachments(
+                    email_msg,
+                    [(a.content, a.filename) for a in msg.attachments],
+                )
+            await smtp.send_message(email_msg)

services/notifications/src/simcore_service_notifications/models/template_contexts/__init__.py

@@ -5,6 +5,7 @@
 from ._credit_reimbursement import CreditReimbursementTemplateContext
 from ._empty import EmptyTemplateContext
 from ._new_2fa_code import New2faCodeTemplateContext
+from ._paid import PaidTemplateContext
 from ._registered import RegisteredTemplateContext
 from ._reset_password import ResetPasswordTemplateContext
 from ._unregister import UnregisterTemplateContext
@@ -17,6 +18,7 @@
     "CreditReimbursementTemplateContext",
     "EmptyTemplateContext",
     "New2faCodeTemplateContext",
+    "PaidTemplateContext",
     "RegisteredTemplateContext",
     "ResetPasswordTemplateContext",
     "UnregisterTemplateContext",

services/notifications/src/simcore_service_notifications/models/template_contexts/_paid.py

@@ -0,0 +1,25 @@
+"""Context model for the 'paid' email template."""
+
+from models_library.notifications import Channel
+from pydantic import BaseModel, HttpUrl
+
+from ..template import BaseTemplateContext, register_template_context
+
+
+class User(BaseModel):
+    first_name: str | None = None
+    last_name: str | None = None
+    user_name: str | None = None
+    email: str | None = None
+
+
+class Payment(BaseModel):
+    price_dollars: str
+    osparc_credits: str
+    invoice_url: HttpUrl
+
+
+@register_template_context(channel=Channel.email, template_name="paid")
+class PaidTemplateContext(BaseTemplateContext):
+    user: User
+    payment: Payment

services/notifications/src/simcore_service_notifications/services/channel_handlers/_email.py

@@ -22,19 +22,31 @@ class EmailChannelHandler(ChannelHandler):
     def prepare_messages(message: EmailMessage) -> list[dict[str, Any]]:
         content_dict = message.content.model_dump()
         from_dict = message.addressing.from_.model_dump()
+        bcc_dict = message.addressing.bcc.model_dump() if message.addressing.bcc else None
         reply_to_dict = message.addressing.reply_to.model_dump() if message.addressing.reply_to else None
 
         recipients = _interleave_recipients_by_domain(message.addressing.to)
 
+        attachments_list = (
+            [a.model_dump() for a in message.addressing.attachments] if message.addressing.attachments else None
+        )
+
         payload_base: dict[str, Any] = {
             "channel": message.channel,
             "from": from_dict,
             "content": content_dict,
         }
+        if bcc_dict:
+            payload_base["bcc"] = bcc_dict
         if reply_to_dict:
             payload_base["reply_to"] = reply_to_dict
 
+        if attachments_list:
+            payload_base["attachments"] = attachments_list
+
         return [
-            CeleryEmailMessage.model_validate({**payload_base, "to": recipient.model_dump()}).model_dump(by_alias=True)
+            CeleryEmailMessage.model_validate({**payload_base, "to": recipient.model_dump()}).model_dump(
+                by_alias=True, exclude_none=True
+            )
             for recipient in recipients
         ]