Skip to content

Commit ea70575

Browse files
authored
agent: use server cert hash when selecting server queues to subscribe (#1679)
1 parent 49e9ce1 commit ea70575

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2147,12 +2147,12 @@ getSubscriptionServers db onlyNeeded =
21472147
toUserServer (userId, host, port, keyHash) = (userId, SMPServer host port keyHash)
21482148

21492149
getUserServerRcvQueueSubs :: DB.Connection -> UserId -> SMPServer -> Bool -> IO [RcvQueueSub]
2150-
getUserServerRcvQueueSubs db userId srv onlyNeeded =
2150+
getUserServerRcvQueueSubs db userId (SMPServer h p kh) onlyNeeded =
21512151
map toRcvQueueSub
21522152
<$> DB.query
21532153
db
2154-
(rcvQueueSubQuery <> toSubscribe <> " c.deleted = 0 AND q.deleted = 0 AND c.user_id = ? AND q.host = ? AND q.port = ?")
2155-
(userId, host srv, port srv)
2154+
(rcvQueueSubQuery <> toSubscribe <> " c.deleted = 0 AND q.deleted = 0 AND c.user_id = ? AND q.host = ? AND q.port = ? AND COALESCE(q.server_key_hash, s.key_hash) = ?")
2155+
(userId, h, p, kh)
21562156
where
21572157
toSubscribe
21582158
| onlyNeeded = " WHERE q.to_subscribe = 1 AND "

0 commit comments

Comments
 (0)