@@ -20,7 +20,7 @@ module Galley.API.Federation where
20
20
21
21
import Brig.Types.Connection (Relation (Accepted ))
22
22
import Control.Error
23
- import Control.Lens (itraversed , (<.>) )
23
+ import Control.Lens (itraversed , preview , to , (<.>) )
24
24
import Data.Bifunctor
25
25
import Data.ByteString.Conversion (toByteString' )
26
26
import Data.Containers.ListUtils (nubOrd )
@@ -68,6 +68,7 @@ import qualified System.Logger.Class as Log
68
68
import Wire.API.Conversation hiding (Member )
69
69
import qualified Wire.API.Conversation as Public
70
70
import Wire.API.Conversation.Action
71
+ import Wire.API.Conversation.Protocol
71
72
import Wire.API.Conversation.Role
72
73
import qualified Wire.API.Conversation.Role as Public
73
74
import Wire.API.Error
@@ -106,6 +107,7 @@ federationSitemap =
106
107
onConversationCreated ::
107
108
Members
108
109
'[ BrigAccess ,
110
+ ConversationStore ,
109
111
GundeckAccess ,
110
112
ExternalAccess ,
111
113
Input (Local () ),
@@ -139,7 +141,11 @@ onConversationCreated domain rc = do
139
141
-- Make sure to notify only about local users connected to the adder
140
142
let qrcConnected = qrc {F. rcNonCreatorMembers = connectedMembers}
141
143
142
- forM_ (fromNewRemoteConversation loc qrcConnected) $ \ (mem, c) -> do
144
+ -- update group_id -> conv_id mapping
145
+ for_ (preview (to F. rcProtocol . _ProtocolMLS) rc) $ \ mls -> do
146
+ E. setGroupId (cnvmlsGroupId mls) (qUntagged (F. rcCnvId qrc))
147
+
148
+ for_ (fromNewRemoteConversation loc qrcConnected) $ \ (mem, c) -> do
143
149
let event =
144
150
Event
145
151
(qUntagged (F. rcCnvId qrcConnected))
0 commit comments