Adiciona Infraestrutura local de E-mails

.env.development

@@ -3,4 +3,12 @@ POSTGRES_PORT=5432
 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
+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-dev"
+    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

@@ -33,6 +33,7 @@
     "next": "16.2.6",
     "next-connect": "1.0.0",
     "node-pg-migrate": "^7.9.1",
+    "nodemailer": "7.0.5",
     "pg": "8.20.0",
     "react": "19.2.6",
     "react-dom": "19.2.6",

tests/integration/api/v1/migrations/get.test.js

@@ -1,4 +1,4 @@
-import orchestrator from "../orchestrator";
+import orchestrator from "../../../../orchestrator";
 
 beforeAll(async () => {
   await orchestrator.waitForAllServices();

tests/integration/api/v1/migrations/post.test.js

@@ -1,4 +1,4 @@
-import orchestrator from "../orchestrator";
+import orchestrator from "../../../../orchestrator";
 
 beforeAll(async () => {
   await orchestrator.waitForAllServices();

tests/integration/api/v1/sessions/delete.test.js

@@ -1,6 +1,6 @@
 import { version as uuidVersion } from "uuid";
 import setCookieParser from "set-cookie-parser";
-import orchestrator from "../orchestrator";
+import orchestrator from "../../../../orchestrator";
 import session from "models/session";
 
 beforeAll(async () => {

tests/integration/api/v1/sessions/post.test.js

@@ -1,6 +1,6 @@
 import { version as uuidVersion } from "uuid";
 import setCookieParser from "set-cookie-parser";
-import orchestrator from "../orchestrator";
+import orchestrator from "../../../../orchestrator";
 import session from "models/session";
 
 beforeAll(async () => {

tests/integration/api/v1/status/get.test.js

@@ -1,4 +1,4 @@
-import orchestrator from "../orchestrator.js";
+import orchestrator from "../../../../orchestrator.js";
 
 beforeAll(async () => {
   await orchestrator.waitForAllServices();

tests/integration/api/v1/status/post.test.js

@@ -1,4 +1,4 @@
-import orchestrator from "../orchestrator.js";
+import orchestrator from "../../../../orchestrator.js";
 
 beforeAll(async () => {
   await orchestrator.waitForAllServices();

tests/integration/api/v1/user/get.test.js

@@ -1,6 +1,6 @@
 import { version as uuidVersion } from "uuid";
 import setCookieParser from "set-cookie-parser";
-import orchestrator from "../orchestrator";
+import orchestrator from "../../../../orchestrator";
 import session from "models/session";
 
 beforeAll(async () => {

tests/integration/api/v1/users/[username]/get.test.js

@@ -1,5 +1,5 @@
 import { version as uuidVersion } from "uuid";
-import orchestrator from "../../orchestrator";
+import orchestrator from "../../../../../orchestrator";
 
 beforeAll(async () => {
   await orchestrator.waitForAllServices();

tests/integration/api/v1/users/[username]/patch.test.js

@@ -1,5 +1,5 @@
 import { version as uuidVersion } from "uuid";
-import orchestrator from "../../orchestrator";
+import orchestrator from "../../../../../orchestrator";
 import user from "models/user";
 import password from "models/password";
 

tests/integration/api/v1/users/post.test.js

@@ -1,5 +1,5 @@
 import { version as uuidVersion } from "uuid";
-import orchestrator from "../orchestrator";
+import orchestrator from "../../../../orchestrator";
 import user from "models/user";
 import password from "models/password";
 

tests/integration/infra/email.test.js

@@ -0,0 +1,31 @@
+import email from "infra/email.js";
+import orchestrator from "tests/orchestrator";
+
+beforeAll(async () => {
+  await orchestrator.waitForAllServices();
+});
+
+describe("infra/email.js", () => {
+  test("Send()", async () => {
+    await orchestrator.deleteAllEmails();
+
+    await email.send({
+      from: "Xedit <contato@xedit.com.br>",
+      to: "contato@gmail.com",
+      subject: "Teste de assunto",
+      text: "Teste de corpo.",
+    });
+    await email.send({
+      from: "Xedit <contato@xedit.com.br>",
+      to: "contato@gmail.com",
+      subject: "Último email enviado.",
+      text: "Corpo do ultimo email.",
+    });
+
+    const lastEmail = await orchestrator.getLastEmail();
+    expect(lastEmail.sender).toBe("<contato@xedit.com.br>");
+    expect(lastEmail.recipients[0]).toBe("<contato@gmail.com>");
+    expect(lastEmail.subject).toBe("Último email enviado.");
+    expect(lastEmail.text).toBe("Corpo do ultimo email.\n");
+  });
+});

tests/integration/api/v1/orchestrator.js → tests/orchestrator.js

@@ -1,13 +1,21 @@
 import retry from "async-retry";
 import { faker } from "@faker-js/faker";
+import dotenv from "dotenv";
 
 import database from "infra/database";
 import migrator from "models/migrator";
 import user from "models/user";
 import session from "models/session";
 
+dotenv.config({
+  path: ".env.development", // ou .env.test, se você usar isso
+});
+
+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, {
@@ -24,6 +32,23 @@ async function waitForAllServices() {
       await response.json();
     }
   }
+
+  async function waitForEmailServer() {
+    return retry(fetchEmailPage, {
+      retries: 100,
+      maxTimeout: 1000,
+    });
+
+    async function fetchEmailPage() {
+      const response = await fetch(`${emailHttpUrl}/messages`);
+
+      if (response.status !== 200) {
+        throw Error();
+      }
+
+      await response.json();
+    }
+  }
 }
 
 async function clearDatabase() {
@@ -47,12 +72,34 @@ async function createUser(userObject) {
   });
 }
 
+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 emailTextResponse = await fetch(
+    `${emailHttpUrl}/messages/${lastEmailItem.id}.plain`,
+  );
+  const emailTextBody = await emailTextResponse.text();
+
+  lastEmailItem.text = emailTextBody;
+  return lastEmailItem;
+}
+
 const orchestrator = {
   waitForAllServices,
   clearDatabase,
   runPendingMigrations,
   createUser,
   createSession,
+  deleteAllEmails,
+  getLastEmail,
 };
 
 export default orchestrator;