core: relay key and member id as immutable relay link data (#6713)

src/Simplex/Chat/Store/Groups.hs

@@ -88,6 +88,9 @@ module Simplex.Chat.Store.Groups
     updateRelayStatus,
     updateRelayStatusFromTo,
     setRelayLinkAccepted,
+    setRelayLinkConfId,
+    getRelayConfId,
+    updateRelayMemberData,
     setGroupInProgressDone,
     createRelayRequestGroup,
     updateRelayOwnStatusFromTo,
@@ -197,7 +200,7 @@ import Simplex.Chat.Types.MemberRelations (IntroductionDirection (..), MemberRel
 import Simplex.Chat.Types.Preferences
 import Simplex.Chat.Types.Shared
 import Simplex.Chat.Types.UITheme
-import Simplex.Messaging.Agent.Protocol (ConnId, CreatedConnLink (..), InvitationId, OwnerAuth (..), UserId)
+import Simplex.Messaging.Agent.Protocol (ConfirmationId, ConnId, CreatedConnLink (..), InvitationId, OwnerAuth (..), UserId)
 import Simplex.Messaging.Agent.Store.AgentStore (firstRow, fromOnlyBI, maybeFirstRow)
 import Simplex.Messaging.Agent.Store.DB (Binary (..), BoolInt (..))
 import Simplex.Messaging.Agent.Store.Entity (DBEntityId)
@@ -1417,26 +1420,74 @@ updateRelayStatus_ db relayId relayStatus = do
   currentTs <- getCurrentTime
   DB.execute db "UPDATE group_relays SET relay_status = ?, updated_at = ? WHERE group_relay_id = ?" (relayStatus, currentTs, relayId)
 
-setRelayLinkAccepted :: DB.Connection -> GroupRelay -> ShortLinkContact -> MemberKey -> IO GroupRelay
-setRelayLinkAccepted db relay@GroupRelay {groupRelayId, groupMemberId} relayLink (MemberKey k) = do
+setRelayLinkAccepted :: DB.Connection -> VersionRangeChat -> User -> GroupMember -> MemberKey -> Profile -> ExceptT StoreError IO (GroupMember, GroupRelay)
+setRelayLinkAccepted db vr user m (MemberKey relayKey) profile = do
+  let gmId = groupMemberId' m
+  currentTs <- liftIO getCurrentTime
+  liftIO $ DB.execute
+    db
+    [sql|
+      UPDATE group_relays
+      SET relay_status = ?, updated_at = ?
+      WHERE group_member_id = ?
+    |]
+    (RSAccepted, currentTs, gmId)
+  liftIO $ DB.execute
+    db
+    [sql|
+      UPDATE group_members
+      SET member_pub_key = ?, updated_at = ?
+      WHERE group_member_id = ?
+    |]
+    (relayKey, currentTs, gmId)
+  void $ updateMemberProfile db user m profile
+  (,) <$> getGroupMemberById db vr user gmId <*> getGroupRelayByGMId db gmId
+
+setRelayLinkConfId :: DB.Connection -> GroupMember -> ConfirmationId -> ShortLinkContact -> IO ()
+setRelayLinkConfId db m confId relayLink = do
   currentTs <- getCurrentTime
   DB.execute
     db
     [sql|
       UPDATE group_relays
-      SET relay_link = ?, relay_status = ?, updated_at = ?
-      WHERE group_relay_id = ?
+      SET conf_id = ?, relay_link = ?, updated_at = ?
+      WHERE group_member_id = ?
     |]
-    (relayLink, RSAccepted, currentTs, groupRelayId)
+    (confId, relayLink, currentTs, groupMemberId' m)
   DB.execute
     db
     [sql|
       UPDATE group_members
-      SET relay_link = ?, member_pub_key = ?, updated_at = ?
+      SET relay_link = ?, updated_at = ?
       WHERE group_member_id = ?
     |]
-    (relayLink, k, currentTs, groupMemberId)
-  pure relay {relayStatus = RSAccepted, relayLink = Just relayLink}
+    (relayLink, currentTs, groupMemberId' m)
+
+getRelayConfId :: DB.Connection -> GroupMember -> ExceptT StoreError IO ConfirmationId
+getRelayConfId db m =
+  ExceptT . firstRow fromOnly (SEGroupRelayNotFoundByMemberId $ groupMemberId' m) $
+    DB.query
+      db
+      [sql|
+        SELECT conf_id
+        FROM group_relays
+        WHERE group_member_id = ? AND conf_id IS NOT NULL
+      |]
+      (Only (groupMemberId' m))
+
+updateRelayMemberData :: DB.Connection -> User -> GroupMember -> MemberId -> MemberKey -> Profile -> ExceptT StoreError IO ()
+updateRelayMemberData db user m memberId (MemberKey relayKey) profile = do
+  currentTs <- liftIO getCurrentTime
+  liftIO $
+    DB.execute
+      db
+      [sql|
+        UPDATE group_members
+        SET member_id = ?, member_pub_key = ?, updated_at = ?
+        WHERE group_member_id = ?
+      |]
+      (memberId, relayKey, currentTs, groupMemberId' m)
+  void $ updateMemberProfile db user m profile
 
 setGroupInProgressDone :: DB.Connection -> GroupInfo -> IO ()
 setGroupInProgressDone db GroupInfo {groupId} = do
@@ -2852,14 +2903,13 @@ getXGrpLinkMemReceived db mId =
   ExceptT . firstRow fromOnlyBI (SEGroupMemberNotFound mId) $
     DB.query db "SELECT xgrplinkmem_received FROM group_members WHERE group_member_id = ?" (Only mId)
 
-setXGrpLinkMemReceived :: DB.Connection -> GroupMemberId -> Bool -> Maybe MemberKey -> IO ()
-setXGrpLinkMemReceived db mId xGrpLinkMemReceived memberKey_ = do
+setXGrpLinkMemReceived :: DB.Connection -> GroupMemberId -> Bool -> IO ()
+setXGrpLinkMemReceived db mId xGrpLinkMemReceived = do
   currentTs <- getCurrentTime
-  let k = (\(MemberKey k') -> k') <$> memberKey_
   DB.execute
     db
-    "UPDATE group_members SET xgrplinkmem_received = ?, member_pub_key = ?, updated_at = ? WHERE group_member_id = ?"
-    (BI xGrpLinkMemReceived, k, currentTs, mId)
+    "UPDATE group_members SET xgrplinkmem_received = ?, updated_at = ? WHERE group_member_id = ?"
+    (BI xGrpLinkMemReceived, currentTs, mId)
 
 createNewUnknownGroupMember :: DB.Connection -> VersionRangeChat -> User -> GroupInfo -> MemberId -> Text -> GroupMemberRole -> ExceptT StoreError IO GroupMember
 createNewUnknownGroupMember db vr user@User {userId, userContactId} GroupInfo {groupId} memberId memberName unknownMemberRole = do

src/Simplex/Chat/Store/Postgres/Migrations/M20260222_chat_relays.hs

@@ -54,6 +54,7 @@ CREATE TABLE group_relays(
   chat_relay_id BIGINT NOT NULL REFERENCES chat_relays ON DELETE CASCADE,
   relay_status TEXT NOT NULL,
   relay_link BYTEA,
+  conf_id BYTEA,
   created_at TEXT NOT NULL DEFAULT (now()),
   updated_at TEXT NOT NULL DEFAULT (now())
 );

src/Simplex/Chat/Store/SQLite/Migrations/M20250813_delivery_tasks.hs

@@ -5,10 +5,6 @@ module Simplex.Chat.Store.SQLite.Migrations.M20250813_delivery_tasks where
 import Database.SQLite.Simple (Query)
 import Database.SQLite.Simple.QQ (sql)
 
--- TODO [relays] add later in new migration for MemberProfileUpdate delivery jobs:
--- TODO   - ALTER TABLE group_members ADD COLUMN last_profile_delivery_ts TEXT;
--- TODO   - ALTER TABLE group_members ADD COLUMN join_ts TEXT;
-
 -- How columns correspond to types:
 
 -- both tables:

src/Simplex/Chat/Store/SQLite/Migrations/M20260222_chat_relays.hs

@@ -67,6 +67,7 @@ CREATE TABLE group_relays(
   chat_relay_id INTEGER NOT NULL REFERENCES chat_relays ON DELETE CASCADE,
   relay_status TEXT NOT NULL,
   relay_link BLOB,
+  conf_id BLOB,
   created_at TEXT NOT NULL DEFAULT(datetime('now')),
   updated_at TEXT NOT NULL DEFAULT(datetime('now'))
 ) STRICT;

src/Simplex/Chat/Store/SQLite/Migrations/chat_query_plans.txt

@@ -3482,6 +3482,14 @@ Query:
 Plan:
 SEARCH commands USING INTEGER PRIMARY KEY (rowid=?)
 
+Query: 
+        SELECT conf_id
+        FROM group_relays
+        WHERE group_member_id = ? AND conf_id IS NOT NULL
+      
+Plan:
+SEARCH group_relays USING INDEX idx_group_relays_group_member_id (group_member_id=?)
+
 Query: 
         SELECT connection_id, agent_conn_id, conn_level, via_contact, via_user_contact_link, via_group_link, group_link_id, xcontact_id, custom_user_profile_id,
           conn_status, conn_type, contact_conn_initiated, local_alias, contact_id, group_member_id, user_contact_link_id,
@@ -3921,6 +3929,14 @@ Query:
 Plan:
 SEARCH group_members USING INTEGER PRIMARY KEY (rowid=?)
 
+Query: 
+        UPDATE group_members
+        SET member_id = ?, member_pub_key = ?, updated_at = ?
+        WHERE group_member_id = ?
+      
+Plan:
+SEARCH group_members USING INTEGER PRIMARY KEY (rowid=?)
+
 Query: 
         UPDATE group_members
         SET member_relations_vector = ?
@@ -4889,6 +4905,14 @@ Query:
 Plan:
 SEARCH contacts USING INTEGER PRIMARY KEY (rowid=?)
 
+Query: 
+      UPDATE group_members
+      SET member_pub_key = ?, updated_at = ?
+      WHERE group_member_id = ?
+    
+Plan:
+SEARCH group_members USING INTEGER PRIMARY KEY (rowid=?)
+
 Query: 
       UPDATE group_members
       SET member_relations_vector = ?, updated_at = ?
@@ -4931,7 +4955,7 @@ SEARCH group_members USING INTEGER PRIMARY KEY (rowid=?)
 
 Query: 
       UPDATE group_members
-      SET relay_link = ?, member_pub_key = ?, updated_at = ?
+      SET relay_link = ?, updated_at = ?
       WHERE group_member_id = ?
     
 Plan:
@@ -4974,11 +4998,19 @@ SEARCH groups USING INTEGER PRIMARY KEY (rowid=?)
 
 Query: 
       UPDATE group_relays
-      SET relay_link = ?, relay_status = ?, updated_at = ?
-      WHERE group_relay_id = ?
+      SET conf_id = ?, relay_link = ?, updated_at = ?
+      WHERE group_member_id = ?
     
 Plan:
-SEARCH group_relays USING INTEGER PRIMARY KEY (rowid=?)
+SEARCH group_relays USING INDEX idx_group_relays_group_member_id (group_member_id=?)
+
+Query: 
+      UPDATE group_relays
+      SET relay_status = ?, updated_at = ?
+      WHERE group_member_id = ?
+    
+Plan:
+SEARCH group_relays USING INDEX idx_group_relays_group_member_id (group_member_id=?)
 
 Query: 
       UPDATE group_snd_item_statuses
@@ -6973,7 +7005,7 @@ Query: UPDATE group_members SET support_chat_ts = ? WHERE group_member_id = ?
 Plan:
 SEARCH group_members USING INTEGER PRIMARY KEY (rowid=?)
 
-Query: UPDATE group_members SET xgrplinkmem_received = ?, member_pub_key = ?, updated_at = ? WHERE group_member_id = ?
+Query: UPDATE group_members SET xgrplinkmem_received = ?, updated_at = ? WHERE group_member_id = ?
 Plan:
 SEARCH group_members USING INTEGER PRIMARY KEY (rowid=?)
 

src/Simplex/Chat/Store/SQLite/Migrations/chat_schema.sql

@@ -765,6 +765,7 @@ CREATE TABLE group_relays(
   chat_relay_id INTEGER NOT NULL REFERENCES chat_relays ON DELETE CASCADE,
   relay_status TEXT NOT NULL,
   relay_link BLOB,
+  conf_id BLOB,
   created_at TEXT NOT NULL DEFAULT(datetime('now')),
   updated_at TEXT NOT NULL DEFAULT(datetime('now'))
 ) STRICT;