send email to fogbugz

Author: matusdrobuliak66

services/web/server/src/simcore_service_webserver/conversations/_controller/_conversations_messages_rest.py

@@ -27,8 +27,10 @@
 from servicelib.rest_constants import RESPONSE_MODEL_POLICY
 
 from ..._meta import API_VTAG as VTAG
+from ...email import email_service
 from ...login.decorators import login_required
 from ...models import AuthenticatedRequestContext
+from ...products import products_web
 from ...users import users_service
 from ...utils_aiohttp import envelope_json_response
 from .. import _conversation_message_service, _conversation_service
@@ -70,27 +72,66 @@ async def create_conversation_message(request: web.Request):
         _ConversationMessageCreateBodyParams, request
     )
 
-    user_primary_gid = await users_service.get_user_primary_group_id(
-        request.app, user_id=req_ctx.user_id
-    )
+    user = await users_service.get_user(request.app, user_id=req_ctx.user_id)
     conversation = await _conversation_service.get_conversation_for_user(
         app=request.app,
         conversation_id=path_params.conversation_id,
-        user_group_id=user_primary_gid,
+        user_group_id=user["primary_gid"],
     )
     # Ensure only support conversations are allowed
     if conversation.type != ConversationType.SUPPORT:
         raise_unsupported_type(conversation.type)
 
-    message = await _conversation_message_service.create_message(
-        app=request.app,
-        user_id=req_ctx.user_id,
-        project_id=None,  # Support conversations don't use project_id
-        conversation_id=path_params.conversation_id,
-        content=body_params.content,
-        type_=body_params.type,
+    message, is_first_message = (
+        await _conversation_message_service.create_support_message_and_check_if_it_is_first_message(
+            app=request.app,
+            user_id=req_ctx.user_id,
+            project_id=None,  # Support conversations don't use project_id
+            conversation_id=path_params.conversation_id,
+            content=body_params.content,
+            type_=body_params.type,
+        )
     )
 
+    # NOTE: This is done here in the Controller layer, as the interface around email currently needs request
+    if is_first_message:
+        try:
+            product = products_web.get_current_product(request)
+            template_name = "request_support.jinja2"
+            destination_email = product.support_email
+            email_template_path = await products_web.get_product_template_path(
+                request, template_name
+            )
+            _conversation_url = (
+                f"{request.url}/#/conversations/{path_params.conversation_id}"
+            )
+            _extra_context = conversation.extra_context
+            await email_service.send_email_from_template(
+                request,
+                from_=product.support_email,
+                to=destination_email,
+                template=email_template_path,
+                context={
+                    "host": request.host,
+                    "product": product.model_dump(
+                        include={
+                            "display_name",
+                        }
+                    ),
+                    "first_name": user["first_name"],
+                    "last_name": user["last_name"],
+                    "user_email": user["email"],
+                    "conversation_url": _conversation_url,
+                    "extra_context": _extra_context,
+                },
+            )
+        except Exception:  # pylint: disable=broad-except
+            _logger.exception(
+                "Failed while sending '%s' email to %s",
+                template_name,
+                user["email"],
+            )
+
     data = ConversationMessageRestGet.from_domain_model(message)
     return envelope_json_response(data, web.HTTPCreated)
 

services/web/server/src/simcore_service_webserver/conversations/_conversation_message_service.py

@@ -60,6 +60,28 @@ async def create_message(
     return created_message
 
 
+async def create_support_message_and_check_if_it_is_first_message(
+    app: web.Application,
+    *,
+    user_id: UserID,
+    project_id: ProjectID | None,
+    conversation_id: ConversationID,
+    # Creation attributes
+    content: str,
+    type_: ConversationMessageType,
+) -> tuple[ConversationMessageGetDB, bool]:
+    created_message = await create_message(
+        app,
+        user_id=user_id,
+        project_id=project_id,
+        conversation_id=conversation_id,
+        content=content,
+        type_=type_,
+    )
+
+    return created_message, True
+
+
 async def get_message(
     app: web.Application,
     *,

services/web/server/src/simcore_service_webserver/email/_core.py

@@ -15,6 +15,7 @@
 from aiohttp_jinja2 import render_string
 from settings_library.email import EmailProtocol, SMTPSettings
 
+from ..products import products_web
 from .settings import get_plugin_settings
 
 _logger = logging.getLogger(__name__)
@@ -225,6 +226,10 @@ def _render_template(
     return subject, html_body
 
 
+async def get_template_path(request: web.Request, filename: str) -> Path:
+    return await products_web.get_product_template_path(request, filename)
+
+
 async def send_email_from_template(
     request: web.Request,
     *,

services/web/server/src/simcore_service_webserver/email/email_service.py

@@ -0,0 +1,19 @@
+import logging
+
+from ._core import AttachmentTuple, get_template_path, send_email_from_template
+
+log = logging.getLogger(__name__)
+
+
+# prevents auto-removal by pycln
+# mypy: disable-error-code=truthy-function
+assert AttachmentTuple  # nosec
+assert send_email_from_template  # nosec
+assert get_template_path  # nosec
+
+
+__all__: tuple[str, ...] = (
+    "AttachmentTuple",
+    "send_email_from_template",
+    "get_template_path",
+)

services/web/server/src/simcore_service_webserver/email/utils.py

@@ -1,11 +1,12 @@
 import logging
 from pathlib import Path
 
-from aiohttp import web
-
 from .._resources import webserver_resources
-from ..email.utils import AttachmentTuple, send_email_from_template
-from ..products import products_web
+from ..email.email_service import (
+    AttachmentTuple,
+    get_template_path,
+    send_email_from_template,
+)
 
 log = logging.getLogger(__name__)
 
@@ -15,17 +16,15 @@ def themed(dirname: str, template: str) -> Path:
     return path
 
 
-async def get_template_path(request: web.Request, filename: str) -> Path:
-    return await products_web.get_product_template_path(request, filename)
-
-
 # prevents auto-removal by pycln
 # mypy: disable-error-code=truthy-function
 assert AttachmentTuple  # nosec
 assert send_email_from_template  # nosec
+assert get_template_path  # nosec
 
 
 __all__: tuple[str, ...] = (
     "AttachmentTuple",
     "send_email_from_template",
+    "get_template_path",
 )

services/web/server/src/simcore_service_webserver/login/_emails_service.py

@@ -14,7 +14,7 @@
 from pydantic import EmailStr, PositiveInt, TypeAdapter, ValidationError
 from servicelib.utils_secrets import generate_passcode
 
-from ..email.utils import send_email_from_template
+from ..email.email_service import send_email_from_template
 from ..products import products_web
 from ..products.models import Product
 from ..users import _accounts_service

services/web/server/src/simcore_service_webserver/login_accounts/_service.py

@@ -0,0 +1,31 @@
+Request for Support on {{ host }}
+<!--
+NOTE: this header is only for testing purposes and is removed automatically before sending
+TEST host: {{ host }}
+TEST first_name: {{ first_name }}
+TEST last_name: {{ last_name }}
+TEST user_email: {{ user_email }}
+TEST product: {{ product }}
+TEST conversation_url: {{ conversation_url }}
+TEST extra_context: {{ extra_context }}
+-->
+<p>
+  Dear Support Team,
+</p>
+
+<p>
+  We have received a support request from {{ first_name }} {{ last_name }} ({{ user_email }}) regarding an account in <b>{{ product.display_name }}</b> on <b>{{ host }}</b>.
+</p>
+
+<p>
+  All communication should take place in the Platform Support Center at the following link:
+  <a href="{{ conversation_url }}">{{ conversation_url }}</a>
+</p>
+
+<p>
+  Additional Information:
+</p>
+
+<pre>
+{{ dumps(extra_context) }}
+</pre>