Fix send email request body

src/domain/subscriber_email.rs

@@ -62,6 +62,6 @@ mod tests {
 
     #[quickcheck_macros::quickcheck]
     fn valid_emails_are_parsed_successfully(valid_email: ValidEmailFixture) -> bool {
-        SubscriberEmail::parse(dbg!(valid_email.0)).is_ok()
+        SubscriberEmail::parse(valid_email.0).is_ok()
     }
 }

src/email_client.rs

@@ -32,8 +32,12 @@ impl EmailClient {
     ) -> Result<(), reqwest::Error> {
         let url = self.base_url.join("v1/email").unwrap();
         let request_body = SendEmailRequest {
-            from: self.sender.as_ref(),
+            from: EmailField {
-            to: vec![recipient.as_ref()],
+                email: self.sender.as_ref(),
+            },
+            to: vec![EmailField {
+                email: recipient.as_ref(),
+            }],
             subject,
             text: text_content,
             html: html_content,
@@ -56,13 +60,18 @@ impl EmailClient {
 
 #[derive(serde::Serialize)]
 struct SendEmailRequest<'a> {
-    from: &'a str,
+    from: EmailField<'a>,
-    to: Vec<&'a str>,
+    to: Vec<EmailField<'a>>,
     subject: &'a str,
     text: &'a str,
     html: &'a str,
 }
 
+#[derive(serde::Serialize)]
+struct EmailField<'a> {
+    email: &'a str,
+}
+
 #[cfg(test)]
 mod tests {
     use std::time::Duration;

src/routes/subscriptions.rs

@@ -20,7 +20,7 @@ fn generate_subscription_token() -> String {
 
 #[tracing::instrument(
     name = "Adding a new subscriber",
-    skip(connection_pool, form, email_client),
+    skip(connection_pool, email_client, base_url, form),
     fields(
         subscriber_email = %form.email,
         subscriber_name = %form.name
@@ -50,18 +50,19 @@ pub async fn subscribe(
     {
         return StatusCode::INTERNAL_SERVER_ERROR;
     }
-    if send_confirmation_email(
+    if let Err(e) = send_confirmation_email(
         &email_client,
         &new_subscriber,
         &base_url,
         &subscription_token,
     )
     .await
-    .is_err()
     {
+        tracing::error!("Could not send confirmation email: {:?}", e);
         return StatusCode::INTERNAL_SERVER_ERROR;
     }
-    if transaction.commit().await.is_err() {
+    if let Err(e) = transaction.commit().await {
+        tracing::error!("Failed to commit transaction: {:?}", e);
         return StatusCode::INTERNAL_SERVER_ERROR;
     }
     StatusCode::OK