core: send agent DEL events to view (#1832)

src/Simplex/Chat/Controller.hs

@@ -53,7 +53,7 @@ import qualified Simplex.Messaging.Crypto as C
 import Simplex.Messaging.Encoding.String
 import Simplex.Messaging.Notifications.Protocol (DeviceToken (..), NtfTknStatus)
 import Simplex.Messaging.Parsers (dropPrefix, enumJSON, parseAll, parseString, sumTypeJSON)
-import Simplex.Messaging.Protocol (AProtocolType, CorrId, MsgFlags, NtfServer)
+import Simplex.Messaging.Protocol (AProtocolType, CorrId, MsgFlags, NtfServer, QueueId)
 import Simplex.Messaging.TMap (TMap)
 import Simplex.Messaging.Transport (simplexMQVersion)
 import Simplex.Messaging.Transport.Client (TransportHost)
@@ -477,6 +477,9 @@ data ChatResponse
   | CRDebugLocks {chatLockName :: Maybe String, agentLocks :: AgentLocks}
   | CRAgentStats {agentStats :: [[String]]}
   | CRConnectionDisabled {connectionEntity :: ConnectionEntity}
+  | CRAgentRcvQueueDeleted {agentConnId :: AgentConnId, server :: SMPServer, agentQueueId :: AgentQueueId, agentError_ :: Maybe AgentErrorType}
+  | CRAgentConnDeleted {agentConnId :: AgentConnId}
+  | CRAgentUserDeleted {agentUserId :: Int64}
   | CRMessageError {user :: User, severity :: Text, errorMessage :: Text}
   | CRChatCmdError {user_ :: Maybe User, chatError :: ChatError}
   | CRChatError {user_ :: Maybe User, chatError :: ChatError}
@@ -486,6 +489,18 @@ instance ToJSON ChatResponse where
   toJSON = J.genericToJSON . sumTypeJSON $ dropPrefix "CR"
   toEncoding = J.genericToEncoding . sumTypeJSON $ dropPrefix "CR"
 
+newtype AgentQueueId = AgentQueueId QueueId
+  deriving (Eq, Show)
+
+instance StrEncoding AgentQueueId where
+  strEncode (AgentQueueId qId) = strEncode qId
+  strDecode s = AgentQueueId <$> strDecode s
+  strP = AgentQueueId <$> strP
+
+instance ToJSON AgentQueueId where
+  toJSON = strToJSON
+  toEncoding = strToJEncoding
+
 data SMPServersConfig = SMPServersConfig {smpServers :: [ServerCfg]}
   deriving (Show, Generic, FromJSON)
 

src/Simplex/Chat/View.hs

@@ -217,6 +217,15 @@ responseToView user_ ChatConfig {logLevel, testView} liveItems ts = \case
     ]
   CRAgentStats stats -> map (plain . intercalate ",") stats
   CRConnectionDisabled entity -> viewConnectionEntityDisabled entity
+  CRAgentRcvQueueDeleted acId srv aqId err_ ->
+    [ "completed deleting rcv queue, agent connection id: " <> sShow acId
+        <> (", server: " <> sShow srv)
+        <> (", agent queue id: " <> sShow aqId)
+        <> maybe "" (\e -> ", error: " <> sShow e) err_
+      | logLevel <= CLLInfo
+    ]
+  CRAgentConnDeleted acId -> ["completed deleting connection, agent connection id: " <> sShow acId | logLevel <= CLLInfo]
+  CRAgentUserDeleted auId -> ["completed deleting user" <> if logLevel <= CLLInfo then ", agent user id: " <> sShow auId else ""]
   CRMessageError u prefix err -> ttyUser u [plain prefix <> ": " <> plain err | prefix == "error" || logLevel <= CLLWarning]
   CRChatCmdError u e -> ttyUser' u $ viewChatError logLevel e
   CRChatError u e -> ttyUser' u $ viewChatError logLevel e