Rename tasks/mailer.py to tasks/email.py

Author: mtomilov

h/jinja_extensions/navbar_data_admin.py

@@ -68,10 +68,10 @@ def navbar_data_admin(request):
         ],
     },
     {
-        "id": "mailer",
+        "id": "email",
         "permission": Permission.AdminPage.LOW_RISK,
-        "title": "Mailer",
-        "route": "admin.mailer",
+        "title": "Email",
+        "route": "admin.email",
     },
     {
         "id": "nipsa",

h/routes.py

@@ -52,11 +52,11 @@ def includeme(config):  # noqa: PLR0915
         factory="h.traversal.GroupRequiredRoot",
         traverse="/{id}",
     )
-    config.add_route("admin.mailer", "/admin/mailer")
-    config.add_route("admin.mailer_test", "/admin/mailer/test")
+    config.add_route("admin.email", "/admin/email")
+    config.add_route("admin.email_test", "/admin/email/test")
     config.add_route(
-        "admin.mailer.preview.mention_notification",
-        "/admin/mailer/preview/mention-notification",
+        "admin.email.preview.mention_notification",
+        "/admin/email/preview/mention-notification",
     )
     config.add_route("admin.nipsa", "/admin/nipsa")
     config.add_route("admin.oauthclients", "/admin/oauthclients")

h/services/user_signup.py

@@ -9,7 +9,7 @@
 from h.services import SubscriptionService
 from h.services.exceptions import ConflictError
 from h.services.user_password import UserPasswordService
-from h.tasks import mailer as tasks_mailer
+from h.tasks import email
 
 log = logging.getLogger(__name__)
 
@@ -124,13 +124,13 @@ def _require_activation(self, user):
         self.session.flush()
 
         # Send the activation email
-        email = signup.generate(
+        email_data = signup.generate(
             request=self.request,
             user_id=user.id,
             email=user.email,
             activation_code=user.activation.code,
         )
-        tasks_mailer.send.delay(asdict(email))
+        email.send.delay(asdict(email_data))
 
 
 def user_signup_service_factory(_context, request):

h/subscribers.py

@@ -12,7 +12,7 @@
 from h.notification import mention, reply
 from h.services import NotificationService
 from h.services.annotation_read import AnnotationReadService
-from h.tasks import mailer
+from h.tasks import email
 
 logger = logging.getLogger(__name__)
 
@@ -108,9 +108,9 @@ def send_reply_notifications(event):
             logger.info("Skipping reply notification for %s", notification.parent_user)
             return
 
-        email = emails.reply_notification.generate(request, notification)
+        email_data = emails.reply_notification.generate(request, notification)
         try:
-            mailer.send.delay(asdict(email))
+            email.send.delay(asdict(email_data))
         except OperationalError as err:  # pragma: no cover
             # We could not connect to rabbit! So carry on
             report_exception(err)
@@ -146,9 +146,9 @@ def send_mention_notifications(event):
                 )
                 continue
 
-            email = emails.mention_notification.generate(request, notification)
+            email_data = emails.mention_notification.generate(request, notification)
             try:
-                mailer.send.delay(asdict(email))
+                email.send.delay(asdict(email_data))
             except OperationalError as err:  # pragma: no cover
                 # We could not connect to rabbit! So carry on
                 report_exception(err)

h/tasks/celery.py

@@ -81,7 +81,7 @@
         "h.tasks.cleanup",
         "h.tasks.indexer",
         "h.tasks.job_queue",
-        "h.tasks.mailer",
+        "h.tasks.email",
         "h.tasks.url_migration",
     ),
     task_routes={

h/tasks/mailer.py renamed to h/tasks/email.py

@@ -2,7 +2,7 @@
 A module for sending email.
 
 This module defines a Celery task for sending emails in a worker process.
-"""
+"""  # noqa: A005
 
 from typing import Any
 
@@ -21,11 +21,11 @@
     max_retries=3,
     retry_jitter=False,
 )
-def send(self, email_data: dict[str, Any]) -> None:  # noqa: ARG001
+def send(self, data: dict[str, Any]) -> None:  # noqa: ARG001
     """Send an email.
 
-    :param email_data: A dictionary containing email data compatible with EmailData class.
+    :param data: A dictionary containing email data compatible with EmailData class.
     """
     service: EmailService = celery.request.find_service(EmailService)
-    email = EmailData(**email_data)
+    email = EmailData(**data)
     service.send(email)

h/templates/admin/mailer.html.jinja2 renamed to h/templates/admin/email.html.jinja2

@@ -1,7 +1,7 @@
 {% extends "h:templates/layouts/admin.html.jinja2" %}
 
-{% set page_id = 'mailer' %}
-{% set page_title = 'Mailer' %}
+{% set page_id = 'email' %}
+{% set page_title = 'Email' %}
 
 {% block content %}
 
@@ -17,7 +17,7 @@
       <h3 class="card-title mb-0">Send a test email</h3>
     </div>
     <div class="card-body">
-      <form method="POST" action="{{ request.route_path('admin.mailer_test') }}" class="form-inline">
+      <form method="POST" action="{{ request.route_path('admin.email_test') }}" class="form-inline">
         <input type="hidden" name="csrf_token" value="{{ get_csrf_token() }}">
         <div class="form-group">
           <label for="recipient">Recipient</label>
@@ -35,7 +35,7 @@
     <iframe
       class="card-body p-0"
       style="height: 40em; border: none;"
-      src="{{ request.route_url("admin.mailer.preview.mention_notification") }}"
+      src="{{ request.route_url("admin.email.preview.mention_notification") }}"
     >
     </iframe>
   </div>

h/views/accounts.py

@@ -30,7 +30,7 @@
     ResetPasswordSchema,
 )
 from h.services import SubscriptionService
-from h.tasks import mailer
+from h.tasks import email
 from h.util.view import json_view
 
 _ = i18n.TranslationString
@@ -211,8 +211,8 @@ def _redirect_if_logged_in(self):
             raise httpexceptions.HTTPFound(self.request.route_path("index"))
 
     def _send_forgot_password_email(self, user):
-        email = reset_password.generate(self.request, user)
-        mailer.send.delay(asdict(email))
+        email_data = reset_password.generate(self.request, user)
+        email.send.delay(asdict(email_data))
 
 
 @view_defaults(

h/views/admin/mailer.py renamed to h/views/admin/email.py

@@ -1,44 +1,44 @@
-from dataclasses import asdict
+from dataclasses import asdict  # noqa: A005
 
 from pyramid.httpexceptions import HTTPSeeOther
 from pyramid.view import view_config
 
 from h.emails import test
 from h.security import Permission
-from h.tasks import mailer
+from h.tasks import email
 
 
 @view_config(
-    route_name="admin.mailer",
+    route_name="admin.email",
     request_method="GET",
-    renderer="h:templates/admin/mailer.html.jinja2",
+    renderer="h:templates/admin/email.html.jinja2",
     permission=Permission.AdminPage.LOW_RISK,
 )
-def mailer_index(request):
-    """Show the mailer test tools."""
+def email_index(request):
+    """Show the email test tools."""
     return {"taskid": request.params.get("taskid")}
 
 
 @view_config(
-    route_name="admin.mailer_test",
+    route_name="admin.email_test",
     request_method="POST",
     permission=Permission.AdminPage.LOW_RISK,
     require_csrf=True,
 )
-def mailer_test(request):
+def email_test(request):
     """Send a test email."""
     if "recipient" not in request.params:
-        index = request.route_path("admin.mailer")
+        index = request.route_path("admin.email")
         return HTTPSeeOther(location=index)
 
-    email = test.generate(request, request.params["recipient"])
-    result = mailer.send.delay(asdict(email))
-    index = request.route_path("admin.mailer", _query={"taskid": result.task_id})
+    email_data = test.generate(request, request.params["recipient"])
+    result = email.send.delay(asdict(email_data))
+    index = request.route_path("admin.email", _query={"taskid": result.task_id})
     return HTTPSeeOther(location=index)
 
 
 @view_config(
-    route_name="admin.mailer.preview.mention_notification",
+    route_name="admin.email.preview.mention_notification",
     request_method="GET",
     permission=Permission.AdminPage.LOW_RISK,
     renderer="h:templates/emails/mention_notification.html.jinja2",

h/views/api/flags.py

@@ -6,7 +6,7 @@
 from h.emails import flag_notification
 from h.security import Permission
 from h.security.permission_map import GROUP_MODERATE_PREDICATES
-from h.tasks import mailer
+from h.tasks import email
 from h.views.api.config import api_config
 
 
@@ -38,6 +38,6 @@ def _email_group_moderators(request, annotation):
     )
 
     for membership in memberships:
-        if email := membership.user.email:
-            email = flag_notification.generate(request, email, incontext_link)
-            mailer.send.delay(asdict(email))
+        if user_email := membership.user.email:
+            email_data = flag_notification.generate(request, user_email, incontext_link)
+            email.send.delay(asdict(email_data))