Construir Aplicaciones Mantenibles con Arquitectura
Cómo estructurar aplicaciones usando ports y adapters para aislar lógica de negocio de frameworks, bases de datos y servicios externos para testabilidad y flexibilidad.
Visión general
La arquitectura tradicional en capas organiza el código en capas horizontales: los controllers llaman a services, los services llaman a repositories, los repositories consultan bases de datos. El problema es que las dependencias fluyen hacia abajo, acoplando la lógica de negocio a frameworks e infraestructura. Si cambias de PostgreSQL a MongoDB, la capa de servicio cambia. Si reemplazas Express con Fastify, la capa de controller cambia. Las reglas de negocio — el código más valioso y estable — se contaminan con detalles técnicos volátiles.
La arquitectura hexagonal (también llamada ports and adapters) invierte esto. El dominio se sienta en el centro, sin depender de nada. Define ports — interfaces describiendo qué capacidades necesita (ej. UserRepository, PaymentGateway). Los adapters implementan estos ports para tecnologías específicas (PostgreSQLUserRepository, StripePaymentGateway). El dominio no sabe si está hablando con una base de datos o un array en memoria. Esto hace al core trivialmente testeable sin bases de datos, frameworks o servicios externos.
Cuándo usarlo
Usa esta receta cuando:
- Las reglas de negocio son complejas y cambian menos frecuentemente que los frameworks. Consulta Domain-Driven Design para modelar lógica de negocio.
- Necesitas testear lógica core sin levantar bases de datos o servidores HTTP
- Migrando entre tecnologías de infraestructura (ORMs, message brokers, proveedores cloud). Consulta Adapter Pattern para cambios de tecnología.
- Trabajando con múltiples interfaces de cliente (API REST, CLI, cola de mensajes) que comparten el mismo core. Consulta API REST para patrones de interfaz.
- Construyendo bibliotecas o frameworks donde el core debe permanecer independiente de consumidores
Solución
Core de Dominio con Ports (TypeScript)
interface UserRepository {
findById(id: string): Promise<User | null>;
save(user: User): Promise<void>;
}
interface EmailService {
send(user: User, subject: string, body: string): Promise<void>;
}
class User {
constructor(
public readonly id: string,
public email: string,
public name: string,
public isVerified: boolean = false
) {}
verify() {
this.isVerified = true;
}
}
class UserRegistrationService {
constructor(
private users: UserRepository,
private email: EmailService
) {}
async register(email: string, name: string): Promise<User> {
const existing = await this.users.findById(email);
if (existing) throw new Error("User already exists");
const user = new User(crypto.randomUUID(), email, name);
await this.users.save(user);
await this.email.send(user, "Welcome", `Hello ${name}, welcome aboard!`);
return user;
}
}
Adapters (Infraestructura)
class PostgresUserRepository implements UserRepository {
constructor(private db: Pool) {}
async findById(id: string): Promise<User | null> {
const result = await this.db.query('SELECT * FROM users WHERE id = $1', [id]);
if (result.rows.length === 0) return null;
const row = result.rows[0];
return new User(row.id, row.email, row.name, row.is_verified);
}
async save(user: User): Promise<void> {
await this.db.query(
`INSERT INTO users (id, email, name, is_verified) VALUES ($1, $2, $3, $4)
ON CONFLICT (id) DO UPDATE SET email = $2, name = $3, is_verified = $4`,
[user.id, user.email, user.name, user.isVerified]
);
}
}
class InMemoryUserRepository implements UserRepository {
private users: Map<string, User> = new Map();
async findById(id: string): Promise<User | null> {
return this.users.get(id) ?? null;
}
async save(user: User): Promise<void> {
this.users.set(user.id, user);
}
}
class MockEmailService implements EmailService {
sentEmails: Array<{ user: User; subject: string; body: string }> = [];
async send(user: User, subject: string, body: string): Promise<void> {
this.sentEmails.push({ user, subject, body });
}
}
Bootstrap de Aplicación
const pool = new Pool({ connectionString: process.env.DATABASE_URL });
const userRepository = new PostgresUserRepository(pool);
const emailService = new SmtpEmailService();
const registrationService = new UserRegistrationService(userRepository, emailService);
app.post('/users', async (req, res) => {
try {
const user = await registrationService.register(req.body.email, req.body.name);
res.status(201).json(user);
} catch (err) {
res.status(400).json({ error: err.message });
}
});
Explicación
- Dominio: el centro del hexágono. Contiene entidades de negocio, value objects y domain services. Tiene cero dependencias de frameworks, bases de datos o APIs externas. Solo conoce ports — interfaces que necesita para hacer su trabajo.
- Ports: interfaces definidas por el dominio.
UserRepositorydescribe qué operaciones de persistencia necesita el dominio.EmailServicedescribe qué capacidades de notificación necesita. El dominio depende de abstracciones, no implementaciones. - Adapters: implementaciones concretas de ports. Un adapter en memoria implementa la misma interfaz usando un Map. El dominio no distingue entre ellos. Los adapters también adaptan concerns externos — los HTTP controllers adaptan requests entrantes a llamadas de métodos de dominio.
- Inversión de dependencias: el dominio no depende de PostgreSQL. PostgreSQL depende del dominio (vía la interfaz
UserRepository). Este es el principio SOLID de inversión de dependencias. La flecha de dependencia apunta hacia adentro, hacia el dominio.
Variantes
| Capa | Contenidos | Dependencias | Testeabilidad |
|---|---|---|---|
| Dominio | Entities, value objects, domain services | Ninguna (solo lenguaje) | Unit tests, sin I/O |
| Aplicación | Casos de uso, orquestación, ports | Dominio | Unit tests con mocks |
| Adapters | Controllers, repositories, clientes externos | Dominio + frameworks | Tests de integración |
| Framework | Servidor HTTP, base de datos, cola de mensajes | Adapters | Tests E2E |
Lo que funciona
- Mantén el dominio puro: sin imports de
node_modulesen código de dominio. Solo primitivas del lenguaje y biblioteca estándar. Si vesimport expressoimport typeormen el dominio, el límite está violado. - Usa inyección de dependencias: pasa adapters a los domain services vía constructores. No uses service locators o singletons globales. La inyección por constructor hace las dependencias explícitas y testeables.
- Escribe tests contra adapters en memoria: los unit tests para lógica de dominio deberían usar repositories en memoria, no bases de datos de test. Consulta Soft Deletes para patrones de repository. Corren en milisegundos, no requieren setup, y prueban que la lógica de dominio funciona independientemente de infraestructura.
- Un composition root: el archivo de bootstrap de la aplicación (frecuentemente
main. tsoindex. js) es el único lugar donde los adapters se instancian y conectan. Este es el único archivo que sabe sobre PostgreSQL, Express y SMTP. Todo lo demás es agnóstico a la tecnología. - No filtres tipos de framework al dominio: si tu domain service acepta un objeto
Requesto retorna unResponse, está acoplado a HTTP. El dominio debería aceptar primitivas y objetos de dominio. Los adapters extraen datos de requests HTTP y llaman métodos de dominio.
Errores comunes
- Modelo de dominio anémico: un dominio con solo getters y setters, donde toda la lógica vive en application services. Esto es solo data transfer objects. Empuja comportamiento a las entidades —
order. submit(), noorderService. submit(order). - Filtrar entidades de ORM al dominio: usar modelos de TypeORM o Prisma directamente como entidades de dominio ata el dominio al esquema de base de datos.
- Sobre-ingeniería CRUD simple: un todo list con create, read, update, delete no necesita ports, adapters e inversión de dependencias.
- Dependencias circulares: la capa de aplicación orquesta casos de uso llamando domain services y adapters. Si la capa de aplicación importa un adapter, y el adapter importa la capa de aplicación, tienes una dependencia circular. Los adapters deben depender solo del dominio.
Preguntas frecuentes
Implementación en Python
from abc import ABC, abstractmethod
from dataclasses import dataclass
from typing import Optional
import uuid
# Dominio — sin dependencias externas
class UserRepository(ABC):
@abstractmethod
async def find_by_id(self, id: str) -> Optional["User"]:
...
@abstractmethod
async def save(self, user: "User") -> None:
...
class EmailService(ABC):
@abstractmethod
async def send(self, user: "User", subject: str, body: str) -> None:
...
@dataclass
class User:
id: str
email: str
name: str
is_verified: bool = False
def verify(self) -> None:
self.is_verified = True
class UserRegistrationService:
def __init__(self, users: UserRepository, email: EmailService):
self._users = users
self._email = email
async def register(self, email: str, name: str) -> User:
existing = await self._users.find_by_id(email)
if existing:
raise ValueError("User already exists")
user = User(id=str(uuid.uuid4()), email=email, name=name)
await self._users.save(user)
await self._email.send(user, "Welcome", f"Hello {name}, welcome aboard!")
return user
async def verify_email(self, user_id: str) -> None:
user = await self._users.find_by_id(user_id)
if not user:
raise ValueError("User not found")
user.verify()
await self._users.save(user)
Tests Unitarios del Dominio
import { describe, it, expect, beforeEach } from 'vitest';
describe('UserRegistrationService', () => {
let users: InMemoryUserRepository;
let email: MockEmailService;
let service: UserRegistrationService;
beforeEach(() => {
users = new InMemoryUserRepository();
email = new MockEmailService();
service = new UserRegistrationService(users, email);
});
it('registra un nuevo usuario', async () => {
const user = await service.register('alice@example.com', 'Alice');
expect(user.id).toBeDefined();
expect(user.email).toBe('alice@example.com');
expect(user.isVerified).toBe(false);
expect(email.sentEmails).toHaveLength(1);
expect(email.sentEmails[0].subject).toBe('Welcome');
});
it('rechaza registro duplicado', async () => {
await service.register('alice@example.com', 'Alice');
await expect(
service.register('alice@example.com', 'Alice Again')
).rejects.toThrow('User already exists');
});
it('verifica email de usuario', async () => {
const user = await service.register('bob@example.com', 'Bob');
await service.verifyEmail(user.id);
const saved = await users.findById(user.id);
expect(saved?.isVerified).toBe(true);
});
it('lanza error al verificar usuario inexistente', async () => {
await expect(
service.verifyEmail('nonexistent-id')
).rejects.toThrow('User not found');
});
});
Patrón Unit of Work para Transacciones
// Port — definido por el dominio
interface UnitOfWork {
begin(): Promise<void>;
commit(): Promise<void>;
rollback(): Promise<void>;
}
// Application service con soporte de transacciones
class OrderService {
constructor(
private orders: OrderRepository,
private inventory: InventoryRepository,
private uow: UnitOfWork
) {}
async placeOrder(items: OrderItem[]): Promise<Order> {
await this.uow.begin();
try {
const order = new Order(crypto.randomUUID(), items);
await this.orders.save(order);
for (const item of items) {
await this.inventory.decrement(item.sku, item.quantity);
}
await this.uow.commit();
return order;
} catch (err) {
await this.uow.rollback();
throw err;
}
}
}
// Adapter PostgreSQL de Unit of Work
class PostgresUnitOfWork implements UnitOfWork {
private client?: PoolClient;
constructor(private pool: Pool) {}
async begin(): Promise<void> {
this.client = await this.pool.connect();
await this.client.query('BEGIN');
}
async commit(): Promise<void> {
if (!this.client) throw new Error('Transaction not started');
await this.client.query('COMMIT');
this.client.release();
}
async rollback(): Promise<void> {
if (!this.client) throw new Error('Transaction not started');
await this.client.query('ROLLBACK');
this.client.release();
}
}
Recursos Relacionados
Modelar Dominios de Negocio Complejos con Domain-Driven
Cómo estructurar código alrededor de conceptos de negocio usando bounded contexts, aggregates, entities, value objects y domain events para gestionar complejidad en aplicaciones grandes.
RecipeDiseñar Microservicios Resilientes con Circuit Breakers,
Cómo construir sistemas distribuidos tolerantes a fallos usando patrones de microservicios incluyendo circuit breakers, bulkheads, retries con backoff y sagas para gestión de transacciones.
RecipeEscribir Unit Tests con Mocks y Stubs
Cómo aislar código bajo test usando objetos mock, stubs y spies para reemplazar dependencias externas como bases de datos, APIs y sistemas de archivos.
RecipeTestear Contratos de API con Consumer-Driven Contracts
Cómo prevenir cambios breaking entre microservicios usando contract testing consumer-driven con Pact y validadores de OpenAPI.
RecipeImplementar Sistemas Reactivos con el Observer Pattern
Cómo construir sistemas event-driven y reactivos usando el observer pattern con pub/sub, event emitters y reactive streams en JavaScript, Java y Python.
RecipePuente entre Interfaces Incompatibles con el Adapter Pattern
Cómo integrar APIs legacy, librerías de terceros e interfaces incompatibles usando object adapters, class adapters y facade adapters en Java, TypeScript y Python.