update email events

enrollments-events/app/events/emails/email_.py

@@ -0,0 +1,71 @@
+from typing import TYPE_CHECKING, TypedDict
+
+from aws_lambda_powertools import Logger
+from layercake.dateutils import now
+from layercake.dynamodb import DynamoDBPersistenceLayer
+from layercake.email_ import Message
+from layercake.strutils import first_word, truncate_str
+
+logger = Logger(__name__)
+
+if TYPE_CHECKING:
+    from mypy_boto3_sesv2 import SESV2Client
+else:
+    SESV2Client = object
+
+Event = TypedDict('Event', {'id': str, 'sk': str})
+
+
+def send_email(
+    to: tuple[str, str],
+    subject: str,
+    message: str,
+    context: dict = {},
+    *,
+    sender: tuple[str, str],
+    event: Event,
+    sesv2_client: SESV2Client,
+    dynamodb_persistence_layer: DynamoDBPersistenceLayer,
+) -> bool:
+    now_ = now()
+    name, _ = to
+    emailmsg = Message(
+        from_=sender,
+        to=to,
+        subject=subject.format(course=truncate_str(context['course'])),
+    )
+    emailmsg.add_alternative(
+        message.format(first_name=first_word(name), course=context['course'])
+    )
+
+    try:
+        sesv2_client.send_email(
+            Content={
+                'Raw': {
+                    'Data': emailmsg.as_bytes(),
+                },
+            }
+        )
+        logger.info('Email sent')
+    except Exception as exc:
+        logger.exception(exc)
+
+        dynamodb_persistence_layer.put_item(
+            item={
+                'id': event['id'],
+                'sk': f'{event["sk"]}#FAILED',
+                'created_at': now_,
+            }
+        )
+
+        return False
+    else:
+        dynamodb_persistence_layer.put_item(
+            item={
+                'id': event['id'],
+                'sk': f'{event["sk"]}#EXECUTED',
+                'created_at': now_,
+            }
+        )
+
+        return True