Adiciona infrestrutura Local de emails

.env.development

@@ -4,3 +4,10 @@ POSTGRES_USER=local_user
 POSTGRES_DB=local_db
 POSTGRES_PASSWORD=local_password
 DATABASE_URL=postgres://$POSTGRES_USER:$POSTGRES_PASSWORD@$POSTGRES_HOST:$POSTGRES_PORT/$POSTGRES_DB
+
+EMAIL_SMTP_HOST=localhost
+EMAIL_SMTP_PORT=1025
+EMAIL_SMTP_USER=
+EMAIL_SMTP_PASSWORD=
+EMAIL_HTTP_HOST=localhost
+EMAIL_HTTP_PORT=1080

infra/compose.yaml

@@ -6,3 +6,9 @@ services:
       - ../.env.development
     ports:
       - "5432:5432"
+  mailcatcher:
+    container_name: "mailcatcher"
+    image: "sj26/mailcatcher"
+    ports:
+      - "1025:1025"
+      - "1080:1080"

infra/email.js

@@ -0,0 +1,21 @@
+import nodemailer from "nodemailer";
+
+const transporter = nodemailer.createTransport({
+  host: process.env.EMAIL_SMTP_HOST,
+  port: process.env.EMAIL_SMTP_PORT,
+  auth: {
+    user: process.env.EMAIL_SMTP_USER,
+    pass: process.env.EMAIL_SMTP_PASSWORD,
+  },
+  secure: process.env.NODE_ENV === "production" ? true : false,
+});
+
+async function send(mailOptions) {
+  await transporter.sendMail(mailOptions);
+}
+
+const email = {
+  send,
+};
+
+export default email;

package.json

@@ -32,6 +32,7 @@
     "next": "15.3.1",
     "next-connect": "1.0.0",
     "node-pg-migrate": "7.9.1",
+    "nodemailer": "7.0.5",
     "pg": "8.15.6",
     "react": "19.1.0",
     "react-dom": "19.1.0",

tests/integration/infra/email.test.js

@@ -0,0 +1,25 @@
+import email from "infra/email.js";
+import orchestrator from "tests/orchestrator.js";
+
+beforeAll(async () => {
+  await orchestrator.waitForAllServices();
+});
+
+describe("infra/email.js", () => {
+  test("send()", async () => {
+    await orchestrator.deleteAllEmails();
+
+    await email.send({
+      from: "Diego Santos <contato@diegosantos.com.br>",
+      to: "contato@curso.dev",
+      subject: "Teste de assunto",
+      text: "Teste de corpo.",
+    });
+
+    const lastEmail = await orchestrator.getLastEmail();
+    expect(lastEmail.sender).toBe("<contato@diegosantos.com.br>");
+    expect(lastEmail.recipients[0]).toBe("<contato@curso.dev>");
+    expect(lastEmail.subject).toBe("Teste de assunto");
+    expect(lastEmail.text).toBe("Teste de corpo.\n");
+  });
+});

tests/orchestrator.js

@@ -6,8 +6,11 @@ import migrator from "models/migrator.js";
 import user from "models/user";
 import session from "models/session";
 
+const emailHttpUrl = `http://${process.env.EMAIL_HTTP_HOST}:${process.env.EMAIL_HTTP_PORT}`;
+
 async function waitForAllServices() {
   await waitForWebServer();
+  await waitForEmailServer();
 
   async function waitForWebServer() {
     return retry(fetchStatusPage, {
@@ -22,6 +25,20 @@ async function waitForAllServices() {
       }
     }
   }
+
+  async function waitForEmailServer() {
+    return retry(fetchEmailPage, {
+      retries: 100,
+      maxTimeout: 6000,
+    });
+
+    async function fetchEmailPage() {
+      const response = await fetch(emailHttpUrl);
+      if (response.status !== 200) {
+        throw Error();
+      }
+    }
+  }
 }
 
 async function clearDatabase() {
@@ -45,12 +62,35 @@ async function createSession(userId) {
   return await session.create(userId);
 }
 
+async function deleteAllEmails() {
+  await fetch(`${emailHttpUrl}/messages`, {
+    method: "DELETE",
+  });
+}
+
+async function getLastEmail() {
+  const emailListResponse = await fetch(`${emailHttpUrl}/messages`);
+  const emailListBody = await emailListResponse.json();
+  const lastEmailItem = emailListBody.pop();
+
+  const textEmailResponse = await fetch(
+    `${emailHttpUrl}/messages/${lastEmailItem.id}.plain`,
+  );
+  const emailTextBody = await textEmailResponse.text();
+
+  lastEmailItem.text = emailTextBody;
+
+  return lastEmailItem;
+}
+
 const orchestrator = {
   waitForAllServices,
   clearDatabase,
   runPendingMigrations,
   createUser,
   createSession,
+  deleteAllEmails,
+  getLastEmail,
 };
 
 export default orchestrator;