Class AwsSesMailTransport

packages/emails/src/transports/aws-ses.ts:10–67

}

export class AwsSesMailTransport implements MailTransport {
  #client: nodemailer.Transporter;

  constructor(options: AwsSesMailTransportOptions) {
    const ses = new awsSes.SESClient()

    this.#client = nodemailer.createTransport({
      SES: {
        aws: awsSes,
        ses
      }
    })
  }

  async send({to, from, replyTo, subject, react}: MailMessage): Promise<void> {
    try {
      await this.#client.sendMail({
        from: from,
        to,
        replyTo: replyTo,
        subject,
        html: await render(react),
      });
    }
    catch (error) {
      if (error instanceof Error) {
        console.error(
          `Failed to send email to ${to}, ${subject}. Error ${error.name}: ${error.message}`
        );
        throw new EmailError(error);
      } else {
        throw error;
      }
    }
  }

  async sendPlainText({to, from, replyTo, subject, text, html}: PlainTextMailMessage): Promise<void> {
    try {
      await this.#client.sendMail({
        from: from,
        to,
        replyTo: replyTo,
        subject,
        ...(html ? { html, text } : { text }),
      });
    }
    catch (error) {
      if (error instanceof Error) {
        console.error(
          `Failed to send email to ${to}, ${subject}. Error ${error.name}: ${error.message}`
        );
        throw new EmailError(error);
      } else {
        throw error;
      }
    }
  }
}