WPB-21964: Move Conversation-related code to wire-subsystems

Author: blackheaven

changelog.d/5-internal/WPB-21964-delete-conv

@@ -1,6 +1,6 @@
-- Moved conversation deletion logic from `Galley.API.Action` to `Wire.ConversationSubsystem.Interpreter`
+- Moved conversation deletion logic from `Wire.ConversationSubsystem.Action` to `Wire.ConversationSubsystem.Interpreter`
 - Relocated remote member deletion utilities:
-  - `Galley.API.Action.deleteMembersInRemoteConversation` → `Wire.ConversationSubsystem.Util.deleteMembersInRemoteConversation`
+  - `Wire.ConversationSubsystem.Action.deleteMembersInRemoteConversation` → `Wire.ConversationSubsystem.Util.deleteMembersInRemoteConversation`
 - Updated conversation deletion implementation to handle:
   - MLS group cleanup (clients and proposals)
   - Sub-conversation removal

libs/wire-subsystems/default.nix

@@ -23,6 +23,7 @@
 , bytestring-conversion
 , case-insensitive
 , cassandra-util
+, comonad
 , conduit
 , constraints
 , containers
@@ -66,6 +67,7 @@
 , imports
 , iproute
 , iso639
+, kan-extensions
 , lens
 , lib
 , lrucaching
@@ -158,6 +160,7 @@ mkDerivation {
     bytestring-conversion
     case-insensitive
     cassandra-util
+    comonad
     conduit
     constraints
     containers
@@ -197,6 +200,7 @@ mkDerivation {
     imports
     iproute
     iso639
+    kan-extensions
     lens
     lrucaching
     memory
@@ -279,6 +283,7 @@ mkDerivation {
     bytestring-conversion
     case-insensitive
     cassandra-util
+    comonad
     conduit
     constraints
     containers
@@ -319,6 +324,7 @@ mkDerivation {
     imports
     iproute
     iso639
+    kan-extensions
     lens
     lrucaching
     memory

libs/wire-subsystems/src/Wire/ConversationSubsystem.hs

@@ -68,5 +68,6 @@ data ConversationSubsystem m a where
     UserId ->
     ConversationSubsystem m (Maybe LocalMember)
   DeleteConversation :: ConvId -> ConversationSubsystem m ()
+  InternalDeleteConversation :: ConvId -> ConversationSubsystem m ()
 
 makeSem ''ConversationSubsystem

services/galley/src/Galley/API/Action.hs …src/Wire/ConversationSubsystem/Action.hsservices/galley/src/Galley/API/Action.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action.hs services/galley/src/Galley/API/Action.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action.hs

@@ -15,7 +15,7 @@
 -- You should have received a copy of the GNU Affero General Public License along
 -- with this program. If not, see <https://www.gnu.org/licenses/>.
 
-module Galley.API.Action
+module Wire.ConversationSubsystem.Action
   ( -- * Conversation action types
     ConversationActionTag (..),
     ConversationJoin (..),
@@ -61,17 +61,6 @@ import Data.Set qualified as Set
 import Data.Singletons
 import Data.Time.Clock
 import GHC.TypeLits (KnownNat)
-import Galley.API.Action.Kick
-import Galley.API.Action.Leave
-import Galley.API.Action.Notify
-import Galley.API.Action.Reset
-import Galley.API.MLS.Conversation
-import Galley.API.MLS.Migration
-import Galley.API.MLS.Removal
-import Galley.API.Teams.Features.Get
-import Galley.Effects
-import Galley.Env (Env)
-import Galley.Options (Opts)
 import Galley.Types.Error
 import Imports hiding ((\\))
 import Polysemy
@@ -106,23 +95,41 @@ import Wire.API.Team.LegalHold
 import Wire.API.Team.Member
 import Wire.API.Team.Permission (Perm (AddRemoveConvMember, ModifyConvName))
 import Wire.API.User as User
+import Wire.BackendNotificationQueueAccess
+import Wire.BrigAPIAccess
 import Wire.BrigAPIAccess qualified as E
 import Wire.CodeStore
 import Wire.CodeStore qualified as E
+import Wire.ConversationStore
 import Wire.ConversationStore qualified as E
-import Wire.ConversationSubsystem (ConversationSubsystem)
-import Wire.ConversationSubsystem qualified as ConversationSubsystem
+import Wire.ConversationSubsystem
+import Wire.ConversationSubsystem.Action.Kick
+import Wire.ConversationSubsystem.Action.Leave
+import Wire.ConversationSubsystem.Action.Notify
+import Wire.ConversationSubsystem.Action.Reset
+import Wire.ConversationSubsystem.MLS.Conversation
+import Wire.ConversationSubsystem.MLS.Migration
+import Wire.ConversationSubsystem.MLS.Removal
 import Wire.ConversationSubsystem.Util
+import Wire.ExternalAccess
 import Wire.FeaturesConfigSubsystem
+import Wire.FederationAPIAccess
 import Wire.FederationAPIAccess qualified as E
 import Wire.FederationSubsystem
+import Wire.FireAndForget
 import Wire.FireAndForget qualified as E
+import Wire.LegalHoldStore
 import Wire.NotificationSubsystem
+import Wire.ProposalStore
+import Wire.ProposalStore qualified as E
 import Wire.Sem.Now (Now)
 import Wire.Sem.Now qualified as Now
+import Wire.Sem.Random
 import Wire.StoredConversation
 import Wire.StoredConversation qualified as Data
 import Wire.TeamCollaboratorsSubsystem
+import Wire.TeamFeatureStore
+import Wire.TeamStore
 import Wire.TeamSubsystem (TeamSubsystem)
 import Wire.TeamSubsystem qualified as TeamSubsystem
 import Wire.UserList
@@ -166,7 +173,6 @@ type family HasConversationActionEffects (tag :: ConversationActionTag) r :: Con
       Member (FederationAPIAccess FederatorClient) r,
       Member NotificationSubsystem r,
       Member Now r,
-      Member (Input Env) r,
       Member (Input ConversationSubsystemConfig) r,
       Member ProposalStore r,
       Member ConversationStore r,
@@ -177,7 +183,6 @@ type family HasConversationActionEffects (tag :: ConversationActionTag) r :: Con
     ( Member (Error NoChanges) r,
       Member ConversationStore r,
       Member ProposalStore r,
-      Member (Input Env) r,
       Member (Input ConversationSubsystemConfig) r,
       Member Now r,
       Member ExternalAccess r,
@@ -220,7 +225,6 @@ type family HasConversationActionEffects (tag :: ConversationActionTag) r :: Con
       Member (FederationAPIAccess FederatorClient) r,
       Member FireAndForget r,
       Member NotificationSubsystem r,
-      Member (Input Env) r,
       Member (Input ConversationSubsystemConfig) r,
       Member ProposalStore r,
       Member TeamStore r,
@@ -251,8 +255,6 @@ type family HasConversationActionEffects (tag :: ConversationActionTag) r :: Con
       Member ExternalAccess r,
       Member (FederationAPIAccess FederatorClient) r,
       Member NotificationSubsystem r,
-      Member (Input Env) r,
-      Member (Input Opts) r,
       Member Now r,
       Member ProposalStore r,
       Member Random r,
@@ -266,8 +268,7 @@ type family HasConversationActionEffects (tag :: ConversationActionTag) r :: Con
       Member (ErrorS 'InvalidTargetAccess) r
     )
   HasConversationActionEffects 'ConversationResetTag r =
-    ( Member (Input Env) r,
-      Member Now r,
+    ( Member Now r,
       Member (ErrorS ConvNotFound) r,
       Member (ErrorS InvalidOperation) r,
       Member ConversationStore r,
@@ -311,7 +312,7 @@ type family HasConversationActionGalleyErrors (tag :: ConversationActionTag) ::
        ErrorS 'ConvMemberNotFound
      ]
   HasConversationActionGalleyErrors 'ConversationDeleteTag =
-    '[ ErrorS ('ActionDenied 'DeleteConversation),
+    '[ ErrorS ('ActionDenied Wire.API.Conversation.Role.DeleteConversation),
        ErrorS 'NotATeamMember,
        ErrorS 'InvalidOperation,
        ErrorS 'ConvNotFound
@@ -497,7 +498,25 @@ performAction tag origUser lconv action = do
       E.setOtherMember lcnv (cmuTarget action) (cmuUpdate action)
       pure $ mkPerformActionResult action
     SConversationDeleteTag -> do
-      ConversationSubsystem.deleteConversation (tUnqualified lcnv)
+      let deleteGroup groupId = do
+            E.removeAllMLSClients groupId
+            E.deleteAllProposals groupId
+
+      let cid = storedConv.id_
+      for_ (storedConv & mlsMetadata <&> cnvmlsGroupId . fst) $ \gidParent -> do
+        sconvs <- E.listSubConversations cid
+        for_ (Map.assocs sconvs) $ \(subid, mlsData) -> do
+          let gidSub = cnvmlsGroupId mlsData
+          E.deleteSubConversation cid subid
+          deleteGroup gidSub
+        deleteGroup gidParent
+
+      key <- E.makeKey (tUnqualified lcnv)
+      E.deleteCode key
+      case convTeam storedConv of
+        Nothing -> E.deleteConversation (tUnqualified lcnv)
+        Just tid -> E.deleteTeamConversation tid (tUnqualified lcnv)
+
       pure $ mkPerformActionResult action
     SConversationRenameTag -> do
       zusrMembership <- join <$> forM storedConv.metadata.cnvmTeam (TeamSubsystem.internalGetTeamMember (qUnqualified origUser))
@@ -643,7 +662,7 @@ performConversationJoin qusr lconv (ConversationJoin invited role joinType) = do
     --   - ensure that a consented conv admin exists
     --   - and kick all existing members that do not consent to LH from the conversation
     -- See also: "Brig.API.Connection.checkLegalholdPolicyConflict"
-    -- and "Galley.API.LegalHold.Conflicts.guardLegalholdPolicyConflictsUid".
+    -- and "Wire.LegalHoldStore.Conflicts.guardLegalholdPolicyConflictsUid".
     checkLHPolicyConflictsLocal ::
       [UserId] ->
       Sem r ()

…ces/galley/src/Galley/API/Action/Kick.hs …ire/ConversationSubsystem/Action/Kick.hsservices/galley/src/Galley/API/Action/Kick.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action/Kick.hs services/galley/src/Galley/API/Action/Kick.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action/Kick.hs

@@ -15,15 +15,12 @@
 -- You should have received a copy of the GNU Affero General Public License along
 -- with this program. If not, see <https://www.gnu.org/licenses/>.
 
-module Galley.API.Action.Kick where
+module Wire.ConversationSubsystem.Action.Kick where
 
 import Data.Default
 import Data.Id
 import Data.Qualified
 import Data.Singletons
-import Galley.API.Action.Leave
-import Galley.API.Action.Notify
-import Galley.Effects
 import Imports hiding ((\\))
 import Polysemy
 import Polysemy.Error
@@ -34,10 +31,17 @@ import Wire.API.Conversation.Action
 import Wire.API.Conversation.Config (ConversationSubsystemConfig)
 import Wire.API.Event.LeaveReason
 import Wire.API.Federation.Error
+import Wire.BackendNotificationQueueAccess
+import Wire.ConversationStore
 import Wire.ConversationSubsystem
+import Wire.ConversationSubsystem.Action.Leave
+import Wire.ConversationSubsystem.Action.Notify
 import Wire.ConversationSubsystem.Util
+import Wire.ExternalAccess
 import Wire.NotificationSubsystem
+import Wire.ProposalStore
 import Wire.Sem.Now (Now)
+import Wire.Sem.Random
 import Wire.StoredConversation
 
 -- | Kick a user from a conversation and send notifications.

…es/galley/src/Galley/API/Action/Leave.hs …re/ConversationSubsystem/Action/Leave.hsservices/galley/src/Galley/API/Action/Leave.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action/Leave.hs services/galley/src/Galley/API/Action/Leave.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action/Leave.hs

@@ -15,23 +15,28 @@
 -- You should have received a copy of the GNU Affero General Public License along
 -- with this program. If not, see <https://www.gnu.org/licenses/>.
 
-module Galley.API.Action.Leave (leaveConversation) where
+module Wire.ConversationSubsystem.Action.Leave (leaveConversation) where
 
 import Control.Lens
 import Data.Id
 import Data.Qualified
-import Galley.API.MLS.Removal
-import Galley.Effects
+-- import Galley.Effects
 import Imports hiding ((\\))
 import Polysemy
 import Polysemy.Error
 import Polysemy.Input
 import Polysemy.TinyLog
 import Wire.API.Conversation.Config (ConversationSubsystemConfig)
 import Wire.API.Federation.Error
+import Wire.BackendNotificationQueueAccess
+import Wire.ConversationStore
+import Wire.ConversationSubsystem.MLS.Removal
 import Wire.ConversationSubsystem.Util
+import Wire.ExternalAccess
 import Wire.NotificationSubsystem
+import Wire.ProposalStore
 import Wire.Sem.Now (Now)
+import Wire.Sem.Random
 import Wire.StoredConversation
 import Wire.UserList
 

…s/galley/src/Galley/API/Action/Notify.hs …e/ConversationSubsystem/Action/Notify.hsservices/galley/src/Galley/API/Action/Notify.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action/Notify.hs services/galley/src/Galley/API/Action/Notify.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action/Notify.hs

@@ -15,12 +15,12 @@
 -- You should have received a copy of the GNU Affero General Public License along
 -- with this program. If not, see <https://www.gnu.org/licenses/>.
 
-module Galley.API.Action.Notify where
+module Wire.ConversationSubsystem.Action.Notify where
 
 import Data.Id
 import Data.Qualified
 import Data.Singletons
-import Galley.Effects
+-- import Galley.Effects
 import Imports hiding ((\\))
 import Polysemy
 import Wire.API.Conversation hiding (Conversation, Member)

…es/galley/src/Galley/API/Action/Reset.hs …re/ConversationSubsystem/Action/Reset.hsservices/galley/src/Galley/API/Action/Reset.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action/Reset.hs services/galley/src/Galley/API/Action/Reset.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/Action/Reset.hs

@@ -15,16 +15,13 @@
 -- You should have received a copy of the GNU Affero General Public License along
 -- with this program. If not, see <https://www.gnu.org/licenses/>.
 
-module Galley.API.Action.Reset (resetLocalMLSMainConversation) where
+module Wire.ConversationSubsystem.Action.Reset (resetLocalMLSMainConversation) where
 
 import Control.Monad.Codensity hiding (reset)
 import Data.Aeson qualified as A
 import Data.ByteString.Conversion (toByteString')
 import Data.Id
 import Data.Qualified
-import Galley.API.Action.Kick
-import Galley.API.MLS.Util
-import Galley.Effects
 import Imports
 import Polysemy
 import Polysemy.Error
@@ -46,12 +43,18 @@ import Wire.API.MLS.Group.Serialisation qualified as Group
 import Wire.API.MLS.SubConversation
 import Wire.API.Routes.Public.Galley.MLS
 import Wire.API.VersionInfo
+import Wire.BackendNotificationQueueAccess
 import Wire.ConversationStore
 import Wire.ConversationSubsystem
+import Wire.ConversationSubsystem.Action.Kick
+import Wire.ConversationSubsystem.MLS.Util
 import Wire.ConversationSubsystem.Util
+import Wire.ExternalAccess
 import Wire.FederationAPIAccess
 import Wire.NotificationSubsystem
+import Wire.ProposalStore
 import Wire.Sem.Now (Now)
+import Wire.Sem.Random
 import Wire.StoredConversation as Data
 
 resetLocalMLSMainConversation ::

libs/wire-subsystems/src/Wire/ConversationSubsystem/Interpreter.hs

@@ -155,6 +155,8 @@ interpretConversationSubsystem = interpret $ \case
     ConvStore.getLocalMember cid uid
   ConversationSubsystem.DeleteConversation cid ->
     deleteConversationImpl cid
+  ConversationSubsystem.InternalDeleteConversation cid ->
+    internalDeleteConversationImpl cid
 
 createGroupConversationGeneric ::
   forall r.
@@ -839,6 +841,16 @@ deleteConversationImpl ::
   ConvId ->
   Sem r ()
 deleteConversationImpl cid = do
+  internalDeleteConversationImpl cid
+
+internalDeleteConversationImpl ::
+  ( Member ConversationStore r,
+    Member CodeStore r,
+    Member ProposalStore r
+  ) =>
+  ConvId ->
+  Sem r ()
+internalDeleteConversationImpl cid = do
   mConv <- ConvStore.getConversation cid
   forM_ mConv $ \storedConv -> do
     let deleteGroup groupId = do

services/galley/src/Galley/API/MLS.hs …ms/src/Wire/ConversationSubsystem/MLS.hsservices/galley/src/Galley/API/MLS.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/MLS.hs services/galley/src/Galley/API/MLS.hs renamed to libs/wire-subsystems/src/Wire/ConversationSubsystem/MLS.hs

@@ -15,7 +15,7 @@
 -- You should have received a copy of the GNU Affero General Public License along
 -- with this program. If not, see <https://www.gnu.org/licenses/>.
 
-module Galley.API.MLS
+module Wire.ConversationSubsystem.MLS
   ( isMLSEnabled,
     assertMLSEnabled,
     postMLSMessage,
@@ -27,9 +27,6 @@ module Galley.API.MLS
 where
 
 import Data.Default
-import Galley.API.MLS.Enabled
-import Galley.API.MLS.Message
-import Galley.Env
 import Galley.Types.Error
 import Imports
 import Polysemy
@@ -38,9 +35,11 @@ import Polysemy.Input
 import Wire.API.Error
 import Wire.API.Error.Galley
 import Wire.API.MLS.Keys
+import Wire.ConversationSubsystem.MLS.Enabled
+import Wire.ConversationSubsystem.MLS.Message
 
 getMLSPublicKeys ::
-  ( Member (Input Env) r,
+  ( Member (Input (Maybe (MLSKeysByPurpose MLSPrivateKeys))) r,
     Member (ErrorS 'MLSNotEnabled) r,
     Member (Error InternalError) r
   ) =>