mirror of
https://github.com/LukeMathWalker/zero-to-production.git
synced 2024-06-02 08:49:50 +00:00
101 lines
2.9 KiB
Rust
101 lines
2.9 KiB
Rust
use crate::domain::{NewSubscriber, SubscriberEmail, SubscriberName};
|
|
use crate::email_client::EmailClient;
|
|
use crate::startup::ApplicationBaseUrl;
|
|
use actix_web::{web, HttpResponse};
|
|
use chrono::Utc;
|
|
use sqlx::PgPool;
|
|
use std::convert::TryInto;
|
|
use uuid::Uuid;
|
|
|
|
#[derive(serde::Deserialize)]
|
|
pub struct FormData {
|
|
email: String,
|
|
name: String,
|
|
}
|
|
|
|
impl TryInto<NewSubscriber> for FormData {
|
|
type Error = String;
|
|
|
|
fn try_into(self) -> Result<NewSubscriber, Self::Error> {
|
|
let name = SubscriberName::parse(self.name)?;
|
|
let email = SubscriberEmail::parse(self.email)?;
|
|
Ok(NewSubscriber { email, name })
|
|
}
|
|
}
|
|
|
|
#[tracing::instrument(
|
|
name = "Adding a new subscriber",
|
|
skip(form, pool, email_client, base_url),
|
|
fields(
|
|
email = %form.email,
|
|
name = %form.name
|
|
)
|
|
)]
|
|
pub async fn subscribe(
|
|
form: web::Form<FormData>,
|
|
pool: web::Data<PgPool>,
|
|
email_client: web::Data<EmailClient>,
|
|
base_url: web::Data<ApplicationBaseUrl>,
|
|
) -> Result<HttpResponse, HttpResponse> {
|
|
let new_subscriber = form
|
|
.0
|
|
.try_into()
|
|
.map_err(|_| HttpResponse::BadRequest().finish())?;
|
|
insert_subscriber(&pool, &new_subscriber)
|
|
.await
|
|
.map_err(|_| HttpResponse::InternalServerError().finish())?;
|
|
// We are swallowing the error for the time being.
|
|
let _ = send_confirmation_email(&email_client, new_subscriber, &base_url.0).await;
|
|
Ok(HttpResponse::Ok().finish())
|
|
}
|
|
|
|
#[tracing::instrument(
|
|
name = "Send a confirmation email to a new subscriber",
|
|
skip(email_client, new_subscriber, base_url)
|
|
)]
|
|
pub async fn send_confirmation_email(
|
|
email_client: &EmailClient,
|
|
new_subscriber: NewSubscriber,
|
|
base_url: &str,
|
|
) -> Result<(), reqwest::Error> {
|
|
let confirmation_link = format!("{}/subscriptions/confirm?subscription_token=mytoken", base_url);
|
|
let plain_body = format!(
|
|
"Welcome to our newsletter!\nVisit {} to confirm your subscription.",
|
|
confirmation_link
|
|
);
|
|
let html_body = format!(
|
|
"Welcome to our newsletter!<br />Click <a href=\"{}\">here</a> to confirm your subscription.",
|
|
confirmation_link
|
|
);
|
|
email_client
|
|
.send_email(new_subscriber.email, "Welcome!", &html_body, &plain_body)
|
|
.await
|
|
}
|
|
|
|
#[tracing::instrument(
|
|
name = "Saving new subscriber details in the database",
|
|
skip(new_subscriber, pool)
|
|
)]
|
|
pub async fn insert_subscriber(
|
|
pool: &PgPool,
|
|
new_subscriber: &NewSubscriber,
|
|
) -> Result<(), sqlx::Error> {
|
|
sqlx::query!(
|
|
r#"
|
|
INSERT INTO subscriptions (id, email, name, subscribed_at, status)
|
|
VALUES ($1, $2, $3, $4, 'pending_confirmation')
|
|
"#,
|
|
Uuid::new_v4(),
|
|
new_subscriber.email.as_ref(),
|
|
new_subscriber.name.as_ref(),
|
|
Utc::now()
|
|
)
|
|
.execute(pool)
|
|
.await
|
|
.map_err(|e| {
|
|
tracing::error!("Failed to execute query: {:?}", e);
|
|
e
|
|
})?;
|
|
Ok(())
|
|
}
|