fix(alarm): add due alarm watchdog

lib/app.dart

@@ -50,6 +50,7 @@ class _PaginaPrincipalState extends State<_PaginaPrincipal> {
   int _indice = 0;
   StreamSubscription<String>? _errorSubscription;
   StreamSubscription<EventoAlarmaAndroid>? _alarmaSubscription;
+  StreamSubscription<AlarmaMusical>? _alarmaVencidaSubscription;
   EstadoRadio? _estadoSuscrito;
   bool _alarmaInicialProcesada = false;
 
@@ -129,6 +130,12 @@ class _PaginaPrincipalState extends State<_PaginaPrincipal> {
       if (!mounted) return;
       _abrirAlarmaSonando(evento);
     });
+    _alarmaVencidaSubscription ??= alarmas.alarmasVencidasStream.listen((
+      alarma,
+    ) {
+      if (!mounted) return;
+      _abrirAlarmaDirecta(alarma);
+    });
     if (!_alarmaInicialProcesada) {
       _alarmaInicialProcesada = true;
       unawaited(_procesarAlarmaInicial(alarmas));
@@ -139,6 +146,7 @@ class _PaginaPrincipalState extends State<_PaginaPrincipal> {
   void dispose() {
     _errorSubscription?.cancel();
     _alarmaSubscription?.cancel();
+    _alarmaVencidaSubscription?.cancel();
     super.dispose();
   }
 
@@ -223,6 +231,15 @@ class _PaginaPrincipalState extends State<_PaginaPrincipal> {
     );
   }
 
+  Future<void> _abrirAlarmaDirecta(AlarmaMusical alarma) async {
+    await Navigator.of(context).push(
+      MaterialPageRoute<void>(
+        builder: (_) => PantallaAlarmaSonando(alarma: alarma),
+        fullscreenDialog: true,
+      ),
+    );
+  }
+
   void _mostrarTimerDialog(BuildContext context) {
     final estado = context.read<EstadoRadio>();
     showModalBottomSheet(

lib/estado/estado_alarmas.dart

@@ -26,6 +26,9 @@ class EstadoAlarmas extends ChangeNotifier {
   List<ExcepcionAlarma> _excepciones = [];
   DiagnosticoAlarmasAndroid? _diagnostico;
   Timer? _refresco;
+  Timer? _vigilancia;
+  final _alarmasVencidasController = StreamController<AlarmaMusical>.broadcast();
+  final Set<String> _ejecucionesEmitidas = {};
   bool _cargando = false;
   String? _error;
 
@@ -35,6 +38,8 @@ class EstadoAlarmas extends ChangeNotifier {
   DiagnosticoAlarmasAndroid? get diagnostico => _diagnostico;
   bool get cargando => _cargando;
   String? get error => _error;
+  Stream<AlarmaMusical> get alarmasVencidasStream =>
+      _alarmasVencidasController.stream;
 
   AlarmaMusical? get proximaAlarma {
     final candidatas =
@@ -168,11 +173,31 @@ class EstadoAlarmas extends ChangeNotifier {
     _refresco = Timer.periodic(const Duration(minutes: 1), (_) {
       refrescarProgramacion();
     });
+    _vigilarAlarmasVencidas();
+    _vigilancia?.cancel();
+    _vigilancia = Timer.periodic(const Duration(seconds: 10), (_) {
+      _vigilarAlarmasVencidas();
+    });
+  }
+
+  void _vigilarAlarmasVencidas() {
+    final ahora = DateTime.now();
+    for (final alarma in _alarmas) {
+      final proxima = alarma.proximaEjecucion;
+      if (!alarma.activa || proxima == null) continue;
+      if (proxima.isAfter(ahora)) continue;
+      final key = '${alarma.id}:${proxima.millisecondsSinceEpoch}';
+      if (_ejecucionesEmitidas.add(key)) {
+        _alarmasVencidasController.add(alarma);
+      }
+    }
   }
 
   @override
   void dispose() {
     _refresco?.cancel();
+    _vigilancia?.cancel();
+    _alarmasVencidasController.close();
     super.dispose();
   }
 }