Skip to content

Commit 7bbd996

Browse files
authored
agent: fix query that updates last message timestamps for notification processing (#1536)
1 parent cb59a44 commit 7bbd996

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Simplex/Messaging/Agent/Store/AgentStore.hs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -860,7 +860,7 @@ createRcvMsg db connId rq@RcvQueue {dbQueueId} rcvMsgData@RcvMsgData {msgMeta =
860860

861861
setLastBrokerTs :: DB.Connection -> ConnId -> DBQueueId 'QSStored -> UTCTime -> IO ()
862862
setLastBrokerTs db connId dbQueueId brokerTs =
863-
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)
863+
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)
864864

865865
createSndMsgBody :: DB.Connection -> AMessage -> IO Int64
866866
createSndMsgBody db aMessage =

0 commit comments

Comments
 (0)