sendgrid-api 0.7.0

#![allow(clippy::field_reassign_with_default)]
use crate::ClientError;
use crate::{ClientResult, Response};

#[async_trait::async_trait]
pub trait MailOps {
    /// Send a plain text email.
    ///
    /// This is a nicer experience than using `post`.
    async fn send_plain_text(
        &self,
        subject: &str,
        message: &str,
        to: &[String],
        cc: &[String],
        bcc: &[String],
        from: &str,
    ) -> ClientResult<Response<()>>;
}

#[async_trait::async_trait]
impl MailOps for crate::mail_send::MailSend {
    /// Send a plain text email.
    ///
    /// This is a nicer experience than using `post`.
    async fn send_plain_text(
        &self,
        subject: &str,
        message: &str,
        tos: &[String],
        ccs: &[String],
        bccs: &[String],
        from: &str,
    ) -> ClientResult<Response<()>> {
        let mut mail = crate::types::PostMailSendRequest {
            subject: subject.to_string(),
            from: crate::types::FromEmailObject {
                email: from.to_string(),
                name: String::new(),
            },
            content: vec![crate::types::Content {
                value: message.to_string(),
                type_: "text/plain".to_string(),
            }],
            ..Default::default()
        };
        let mut p = crate::types::Personalizations {
            from: Some(mail.from.clone()),
            ..Default::default()
        };
        for to in tos {
            p.to.push(crate::types::ReplyTo {
                email: to.to_string(),
                name: String::new(),
            });
        }
        for cc in ccs {
            p.cc.push(crate::types::CcBccEmailObject {
                email: cc.to_string(),
                name: String::new(),
            });
        }
        for bcc in bccs {
            p.bcc.push(crate::types::CcBccEmailObject {
                email: bcc.to_string(),
                name: String::new(),
            });
        }
        mail.personalizations = vec![p];

        let url = self.client.url("/mail/send", None);
        let resp = self
            .client
            .request_raw(
                reqwest::Method::POST,
                &url,
                crate::Message {
                    body: Some(reqwest::Body::from(serde_json::to_vec(&mail).unwrap())),
                    content_type: None,
                },
            )
            .await?;

        match resp.status() {
            http::StatusCode::ACCEPTED => Ok(Response::new(
                http::StatusCode::ACCEPTED,
                resp.headers().clone(),
                (),
            )),
            s => Err(ClientError::HttpError {
                status: s,
                headers: resp.headers().clone(),
                error: "Posting to /mail/send".to_string(),
            }),
        }
    }
}