Notificaciones sencillas en NestJS mediante eventos del lado del servidor para operaciones masivas

Entrega de notificaciones simplificada para operaciones de inserción masiva

Imagine que está administrando un sistema en el que a cientos de empleados se les asignan vales según diversos criterios, como departamento, grado o experiencia. Es una tarea colosal notificar a cada empleado de manera eficiente sin causar cuellos de botella en el sistema. 🔔 Este desafío se vuelve aún más desalentador cuando se intenta evitar las complejidades de los sockets o los mecanismos de sondeo.

En tales escenarios, los eventos del lado del servidor (SSE) surgen como una solución poderosa pero sencilla. Al aprovechar SSE en su aplicación NestJS, puede establecer un canal de comunicación en tiempo real para notificar a grupos específicos de empleados según criterios dinámicos. Por ejemplo, cuando se asignan vales al departamento de Ventas, solo esos empleados deben recibir notificaciones, lo que garantiza actualizaciones precisas y significativas.

A lo largo de este artículo, profundizaremos en un ejemplo práctico que demuestra cómo integrar SSE en un proceso de inserción masiva utilizando NestJS. Recorreremos el ciclo de vida, desde la activación de eventos en el backend hasta la escucha de actualizaciones en el frontend, todo ello manteniendo un rendimiento perfecto. 💼

Ya sea que esté desarrollando una herramienta de recursos humanos o una aplicación de finanzas, comprender este flujo de trabajo le permitirá enviar notificaciones personalizadas en tiempo real. Analicemos la simplicidad de SSE y cómo puede mejorar la experiencia del usuario de su aplicación.

Notificaciones eficientes con colas y eventos del lado del servidor

Los scripts proporcionados ilustran un sistema en el que se envían notificaciones en tiempo real a los empleados después de la inserción masiva de registros de comprobantes en la base de datos. El proceso comienza en el Controlador de asignación de cupones, que expone un punto final para crear tareas de asignación de cupones. Cuando se crea una tarea, emite un evento llamado vale después de la asignación. Este evento es esencial para desencadenar los pasos siguientes, asegurando que el sistema esté impulsado por eventos y sea modular. Este diseño permite una clara separación de preocupaciones, lo que hace que el sistema sea más mantenible y escalable. 🎯

En la capa de servicio, el Asignar servicio de vales maneja la lógica para poner en cola tareas usando BullMQ. Después de recibir el vale después de la asignación evento, agrega un trabajo a la cola denominada vale de asignación. Esta cola permite el procesamiento asincrónico, lo que garantiza que el sistema siga respondiendo incluso cuando se procesan grandes conjuntos de datos. Por ejemplo, si asigna vales a 200 empleados en el departamento de Ventas, la cola garantiza que la operación no bloquee otras solicitudes. La configuración de la cola incluye opciones como eliminar al completar para mantener Redis limpio una vez finalizado el trabajo.

Los trabajos en cola son procesados ​​por el AllotVoucherConsumidor clase. Aquí se implementa la lógica para identificar a los empleados relevantes e insertar registros de comprobantes en la base de datos. El comando Prisma crearmuchos se utiliza para insertar registros por lotes en el empleadovale tabla, que está optimizada para el rendimiento. Una vez completada la operación de la base de datos, se emite otro evento para notificar a los suscriptores. Este evento garantiza que los empleados solo sean notificados después de que la inserción masiva se haya procesado exitosamente, lo que agrega confiabilidad al sistema de notificación. 🌟

En el frontend, el componente React escucha los eventos enviados por el servidor a través de un Fuente del evento. A medida que se notifica a los empleados, sus detalles se actualizan dinámicamente en la interfaz de usuario sin necesidad de actualizar la página. Este enfoque proporciona una experiencia de usuario perfecta, similar a las actualizaciones en tiempo real que se ven en las aplicaciones web modernas, como resultados deportivos en vivo o notificaciones de redes sociales. Por ejemplo, los empleados del departamento de recursos humanos no verán las actualizaciones destinadas a Ventas, ya que el backend filtra con precisión los eventos según los criterios de asignación. Esta especificidad mejora tanto el rendimiento como la relevancia, creando un sistema centrado en el usuario. 🖥️

// Backend: AllocateVoucherController
import { Controller, Post, Body, Sse, OnEvent } from '@nestjs/common';
import { AllocateVoucherService } from './allocate-voucher.service';
import { EventEmitter2 } from '@nestjs/event-emitter';
import { Observable } from 'rxjs';
import { map, fromEvent } from 'rxjs';
@Controller('allocate-voucher')
export class AllocateVoucherController {
  constructor(
    private readonly allocateVoucherService: AllocateVoucherService,
    private readonly eventEmitter: EventEmitter2
  ) {}
  @Post()
  async create(@Body() createDto: any) {
    const result = await this.allocateVoucherService.create(createDto);
    return result;
  }
  @Sse('vouchered-employee')
  updatedEmployeeEvent(): Observable<MessageEvent> {
    return fromEvent(this.eventEmitter, 'after-added-voucher').pipe(
      map((data) => new MessageEvent('after-added-voucher', { data })),
    );
  }
}

// Frontend: React Component for SSE
import React, { useEffect, useState } from 'react';
const EmployeeUpdates = () => {
  const [employees, setEmployees] = useState([]);
  useEffect(() => {
    const eventSource = new EventSource('http://localhost:3000/allocate-voucher/vouchered-employee');
    eventSource.onmessage = (event) => {
      const newEmployee = JSON.parse(event.data);
      setEmployees((prev) => [...prev, newEmployee]);
    };
    return () => eventSource.close();
  }, []);
  return (
    <table>
      <thead>
        <tr><th>Name</th><th>Voucher</th></tr>
      </thead>
      <tbody>
        {employees.map((emp) => (
          <tr key={emp.id}><td>{emp.name}</td><td>{emp.voucher}</td></tr>
        ))}
      </tbody>
    </table>
  );
};
export default EmployeeUpdates;

// Jest Test: AllocateVoucherService
import { Test, TestingModule } from '@nestjs/testing';
import { AllocateVoucherService } from './allocate-voucher.service';
import { EventEmitter2 } from '@nestjs/event-emitter';
describe('AllocateVoucherService', () => {
  let service: AllocateVoucherService;
  let eventEmitter: EventEmitter2;
  beforeEach(async () => {
    const module: TestingModule = await Test.createTestingModule({
      providers: [AllocateVoucherService, EventEmitter2],
    }).compile();
    service = module.get(AllocateVoucherService);
    eventEmitter = module.get(EventEmitter2);
  });
  it('should emit after-allocate-voucher event', async () => {
    jest.spyOn(eventEmitter, 'emit');
    const result = await service.create({ someData: 'test' });
    expect(eventEmitter.emit).toHaveBeenCalledWith('after-allocate-voucher', result);
  });
});

Mejora de los sistemas en tiempo real con SSE en NestJS

Si bien hemos explorado la implementación de eventos del lado del servidor (SSE) para notificar a los empleados sobre la asignación de cupones, existe un caso de uso más amplio para SSE en sistemas en tiempo real. SSE brilla en escenarios donde los clientes necesitan mantenerse actualizados con los datos del servidor sin realizar encuestas constantemente. Por ejemplo, piense en una plataforma minorista en línea que rastrea las actualizaciones de inventario en vivo durante una venta flash. Con SSE, puede enviar actualizaciones de manera eficiente a todos los clientes conectados, asegurándose de que vean los niveles de existencias más recientes sin una carga innecesaria del servidor. Este enfoque garantiza la escalabilidad y al mismo tiempo mantiene la experiencia del usuario sin interrupciones. 🛒

Incorporar sistemas de colas avanzados como BullMQ, como hicimos con el vale de asignación cola, agrega solidez a las tareas de procesamiento de datos masivos. La cola garantiza que incluso si se reinicia el servidor, las tareas pendientes permanezcan intactas y el procesamiento se reanude. Además, se pueden configurar mecanismos de reintento, lo que garantiza que los trabajos fallidos (por ejemplo, debido a un tiempo de inactividad temporal de la base de datos) se reintenten automáticamente. Por ejemplo, si una asignación a 300 empleados en todos los departamentos encuentra un error temporal, la resistencia de la cola garantiza que no queden registros sin procesar, lo que agrega confiabilidad a su sistema.

Más allá de las notificaciones en tiempo real, SSE también puede complementar los servicios de correo electrónico para tareas que requieren resúmenes detallados. Después de que todas las notificaciones de cupones se envíen a través de SSE, el backend puede generar un informe de forma asincrónica y enviar un correo electrónico consolidado a los gerentes. Esta comunicación multicanal garantiza notificaciones inmediatas y seguimientos integrales, atendiendo a una amplia gama de preferencias de los usuarios. Dicha integración mejora la flexibilidad de su sistema, creando una experiencia de usuario integral. 📧