Vigilante del buzón de entrada de denuncias

1Registrar el directorio a vigilar

WatchService se suscribe a eventos del sistema de ficheros: en vez de comprobar el directorio en bucle, el SO avisa cuando cambia algo.

Path directorio = Path.of("buzon-entrada");
WatchService watcher = FileSystems.getDefault().newWatchService();
directorio.register(watcher, StandardWatchEventKinds.ENTRY_CREATE);

• Implementar VigilanteBuzonEntrada registrando buzon-entrada/ en un WatchService al arrancar

2Atender el evento ENTRY_CREATE

Solo interesa la creación de ficheros nuevos, no su modificación ni su borrado.

• Suscribirse específicamente al evento ENTRY_CREATE

3Bucle de procesamiento y reset()

Cada WatchKey debe reiniciarse tras procesar sus eventos. Olvidarlo hace que «el vigilante deje de funcionar en silencio»: sin excepción visible, simplemente deja de recibir eventos.

while (activo) {
    WatchKey clave = watcher.take(); // bloquea hasta que hay eventos
    for (WatchEvent<?> evento : clave.pollEvents()) {
        if (evento.kind() == StandardWatchEventKinds.ENTRY_CREATE) {
            Path rutaCompleta = directorio.resolve((Path) evento.context());
            log.info("Fichero detectado: {}", rutaCompleta);
            procesar(rutaCompleta);
            ultimoDetectado = rutaCompleta;
        }
    }
    boolean sigueValida = clave.reset(); // obligatorio para seguir recibiendo eventos
    if (!sigueValida) {
        break;
    }
}

• Al detectar un fichero nuevo, invocar su procesamiento y dejar constancia (log) de la ruta detectada
• Llamar a clave.reset() tras procesar los eventos de cada iteración

4take() vs. poll(timeout)

Decide y documenta cuál usar: no es una elección neutra.

• Elegir entre take() o poll(timeout) y justificar la decisión por escrito (diario técnico)

5Ciclo de vida: hilo propio, arranque y parada

El vigilante vive en su propio hilo, arrancado al iniciar la aplicación y detenido de forma ordenada al pararla — no debe quedar un hilo colgado.

@Component
public class VigilanteBuzonEntrada {

    private Thread hilo;
    private volatile boolean activo;

    @PostConstruct
    void iniciar() {
        activo = true;
        hilo = new Thread(this::vigilar, "vigilante-buzon");
        hilo.start();
    }

    @PreDestroy
    void detener() throws InterruptedException {
        activo = false;
        hilo.interrupt();
        hilo.join();
    }
}

• Arrancar el vigilante en un hilo propio (@PostConstruct o equivalente) al iniciar la aplicación
• Detener el hilo de forma ordenada al parar la aplicación (@PreDestroy), sin dejarlo colgado

6Endpoint de estado

@GetMapping("/buzon-entrada/estado")
public EstadoBuzon estado() {
    return new EstadoBuzon(vigilante.isActivo(), vigilante.getUltimoDetectado());
}

• Exponer GET /buzon-entrada/estado reportando si el vigilante está activo y cuál fue el último fichero detectado
• Verificar en pruebas que el registro se hace sobre el directorio correcto y que se detectan eventos en tiempo razonable

!Problemas frecuentes

✓Criterios de aceptación

• El registro se hace sobre el directorio correcto al arrancar
• La detección ocurre en un tiempo razonable
• Se llama a reset() de la WatchKey tras procesar los eventos
• La detención es ordenada, sin hilos colgados
• La decisión entre take()/poll() está justificada en el diario técnico
• El endpoint refleja correctamente el estado activo y el último fichero detectado