From c71f0d7beb447cd132fe603cd7aa9b825d4df1b7 Mon Sep 17 00:00:00 2001
From: spaced4ndy <8711996+spaced4ndy@users.noreply.github.com>
Date: Mon, 30 Sep 2024 13:54:32 +0400
Subject: [PATCH] log using events

---
 src/Simplex/Messaging/Agent/NtfSubSupervisor.hs | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/Simplex/Messaging/Agent/NtfSubSupervisor.hs b/src/Simplex/Messaging/Agent/NtfSubSupervisor.hs
index 95b1bc61b..5f3770416 100644
--- a/src/Simplex/Messaging/Agent/NtfSubSupervisor.hs
+++ b/src/Simplex/Messaging/Agent/NtfSubSupervisor.hs
@@ -60,6 +60,7 @@ runNtfSupervisor c = do
   ns <- asks ntfSupervisor
   forever $ do
     logInfo "#################### runNtfSupervisor - in forever loop"
+    notifyInternalError' c "#################### runNtfSupervisor - in forever loop"
     cmd <- atomically . readTBQueue $ ntfSubQ ns
     handleErr . agentOperationBracket c AONtfNetwork waitUntilActive $
       runExceptT (processNtfCmd c cmd) >>= \case
@@ -198,6 +199,7 @@ runNtfWorker :: AgentClient -> NtfServer -> Worker -> AM ()
 runNtfWorker c srv Worker {doWork} =
   forever $ do
     logInfo "#################### runNtfWorker - in forever loop"
+    notifyInternalError' c "#################### runNtfWorker - in forever loop"
     waitForWork doWork
     ExceptT $ agentOperationBracket c AONtfNetwork throwWhenInactive $ runExceptT runNtfOperation
   where
@@ -367,6 +369,7 @@ runNtfWorker c srv Worker {doWork} =
 runNtfSMPWorker :: AgentClient -> SMPServer -> Worker -> AM ()
 runNtfSMPWorker c srv Worker {doWork} = forever $ do
   logInfo "#################### runNtfSMPWorker - in forever loop"
+  notifyInternalError' c "#################### runNtfSMPWorker - in forever loop"
   waitForWork doWork
   ExceptT $ agentOperationBracket c AONtfNetwork throwWhenInactive $ runExceptT runNtfSMPOperation
   where