Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 4 additions & 6 deletions services/galley/src/Galley/API/MLS/Message.hs
Original file line number Diff line number Diff line change
Expand Up @@ -365,7 +365,7 @@ processCommit qusr con lconv epoch sender commit = do
senderRef <-
maybe
(pure currentRef)
( (& note (mlsProtocolError "Could not compute key package ref"))
( note (mlsProtocolError "Could not compute key package ref")
. kpRef'
. upLeaf
)
Expand Down Expand Up @@ -670,7 +670,7 @@ executeProposalAction qusr con lconv action = do
$ ConversationJoin users roleNameWireMember

removeMembers :: NonEmpty (Qualified UserId) -> Sem r [LocalConversationUpdate]
removeMembers users =
removeMembers =
handleNoChanges
. handleMLSProposalFailures @ProposalErrors
. fmap pure
Expand All @@ -679,7 +679,6 @@ executeProposalAction qusr con lconv action = do
lconv
qusr
con
$ users

handleNoChanges :: Monoid a => Sem (Error NoChanges ': r) a -> Sem r a
handleNoChanges = fmap fold . runError
Expand Down Expand Up @@ -728,9 +727,8 @@ propagateMessage loc qusr conv con raw = do
foldMap (uncurry mkPush) (cToList =<< lclients)

-- send to remotes
(traverse_ handleError =<<)
. runFederatedConcurrentlyEither (map remoteMemberQualify (Data.convRemoteMembers conv))
$ \(tUnqualified -> rs) ->
traverse_ handleError <=< runFederatedConcurrentlyEither (map remoteMemberQualify (Data.convRemoteMembers conv)) $
\(tUnqualified -> rs) ->
fedClient @'Galley @"on-mls-message-sent" $
RemoteMLSMessage
{ rmmTime = now,
Expand Down