From 7bbd99644ae2f7e49033742c22d7fb8f51500ced Mon Sep 17 00:00:00 2001 From: Evgeny Date: Tue, 6 May 2025 23:19:58 +0100 Subject: [PATCH] agent: fix query that updates last message timestamps for notification processing (#1536) --- src/Simplex/Messaging/Agent/Store/AgentStore.hs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Simplex/Messaging/Agent/Store/AgentStore.hs b/src/Simplex/Messaging/Agent/Store/AgentStore.hs index 9f0cb823e..446681b70 100644 --- a/src/Simplex/Messaging/Agent/Store/AgentStore.hs +++ b/src/Simplex/Messaging/Agent/Store/AgentStore.hs @@ -860,7 +860,7 @@ createRcvMsg db connId rq@RcvQueue {dbQueueId} rcvMsgData@RcvMsgData {msgMeta = setLastBrokerTs :: DB.Connection -> ConnId -> DBQueueId 'QSStored -> UTCTime -> IO () setLastBrokerTs db connId dbQueueId brokerTs = - DB.execute db "UPDATE rcv_queues SET last_broker_ts = ? WHERE conn_id = ? AND rcv_queue_id = ? AND last_broker_ts < ?" (brokerTs, connId, dbQueueId, brokerTs) + DB.execute db "UPDATE rcv_queues SET last_broker_ts = ? WHERE conn_id = ? AND rcv_queue_id = ? AND (last_broker_ts IS NULL OR last_broker_ts < ?)" (brokerTs, connId, dbQueueId, brokerTs) createSndMsgBody :: DB.Connection -> AMessage -> IO Int64 createSndMsgBody db aMessage =