chore: add support for meeting events - WPB-26733

WireCalling/Sources/WireCallingData/MeetingRepository.swift

@@ -75,18 +75,21 @@ public final class MeetingRepository: MeetingRepositoryProtocol {
         changeBroadcaster.broadcast()
     }
 
-    public func pullMeeting(id: QualifiedID) async throws {
+    @discardableResult
+    public func pullMeeting(id: QualifiedID) async throws -> Meeting? {
         // There is no endpoint to fetch a single meeting,
         // so refetch the list to get the details.
         let meetings = try await meetingsAPI.listMeetings()
 
-        if let meeting = meetings.first(where: { $0.id == id }) {
-            await localStore.storeMeeting(meeting.toDomainMeeting())
+        let meeting = meetings.first(where: { $0.id == id })?.toDomainMeeting()
+        if let meeting {
+            await localStore.storeMeeting(meeting)
         } else {
             // The meeting no longer exists on the backend.
             await localStore.deleteMeeting(id: id)
         }
         changeBroadcaster.broadcast()
+        return meeting
     }
 
     public func pullMeetings() async throws {

WireCalling/Sources/WireCallingDomain/WireMeetings/Protocols/MeetingRepositoryProtocol.swift

@@ -52,8 +52,10 @@ public protocol MeetingRepositoryProtocol: Sendable {
     /// If the meeting no longer exists on the server, the locally stored copy is deleted.
     ///
     /// - Parameter id: The qualified id of the meeting to pull.
+    /// - Returns: The pulled meeting, or `nil` if it no longer exists on the server.
 
-    func pullMeeting(id: QualifiedID) async throws
+    @discardableResult
+    func pullMeeting(id: QualifiedID) async throws -> Meeting?
 
     /// Pulls all meetings from the server, replacing the locally stored
     /// meetings, e.g. as part of a sync.

WireCalling/Tests/WireCallingTests/WireMeetings/DataTests/MeetingRepositoryTests.swift

@@ -50,10 +50,11 @@ struct MeetingRepositoryTests {
 
         // When
 
-        try await sut.pullMeeting(id: Scaffolding.meetingID)
+        let meeting = try await sut.pullMeeting(id: Scaffolding.meetingID)
 
         // Then
 
+        #expect(meeting?.id == Scaffolding.meetingID)
         #expect(localStore.storeMeetingMeetingMeetingVoidReceivedInvocations.count == 1)
         #expect(localStore.storeMeetingMeetingMeetingVoidReceivedInvocations.first?.id == Scaffolding.meetingID)
         #expect(
@@ -75,10 +76,11 @@ struct MeetingRepositoryTests {
 
         // When
 
-        try await sut.pullMeeting(id: Scaffolding.meetingID)
+        let meeting = try await sut.pullMeeting(id: Scaffolding.meetingID)
 
         // Then
 
+        #expect(meeting == nil)
         #expect(localStore.storeMeetingMeetingMeetingVoidReceivedInvocations.isEmpty)
         #expect(localStore.deleteMeetingIdQualifiedIDVoidReceivedInvocations == [Scaffolding.meetingID])
     }

WireDomain/Sources/WireDomain/Components/ClientSessionComponent.swift

@@ -712,6 +712,20 @@ public final class ClientSessionComponent {
         localStore: MeetingLocalStore(context: syncContext)
     )
 
+    private lazy var meetingCreateEventProcessor = MeetingCreateEventProcessor(
+        repository: meetingRepository,
+        conversationRepository: conversationRepository
+    )
+
+    private lazy var meetingDeleteEventProcessor = MeetingDeleteEventProcessor(
+        repository: meetingRepository
+    )
+
+    private lazy var meetingUpdateEventProcessor = MeetingUpdateEventProcessor(
+        repository: meetingRepository,
+        conversationRepository: conversationRepository
+    )
+
     private lazy var conversationEventProcessor = ConversationEventProcessor(
         accessUpdateEventProcessor: conversationAccessUpdateEventProcessor,
         createEventProcessor: conversationCreateEventProcessor,
@@ -763,12 +777,19 @@ public final class ClientSessionComponent {
             createEventProcessor: teamCreateEventProcessor
         )
 
+        let meetingEventProcessor = MeetingEventProcessor(
+            createEventProcessor: meetingCreateEventProcessor,
+            deleteEventProcessor: meetingDeleteEventProcessor,
+            updateEventProcessor: meetingUpdateEventProcessor
+        )
+
         return UpdateEventProcessor(
             conversationEventProcessor: conversationEventProcessor,
             featureConfigEventProcessor: featureConfigEventProcessor,
             federationEventProcessor: federationEventProcessor,
             userEventProcessor: userEventProcessor,
-            teamEventProcessor: teamEventProcessor
+            teamEventProcessor: teamEventProcessor,
+            meetingEventProcessor: meetingEventProcessor
         )
     }()
 

WireDomain/Sources/WireDomain/Event Processing/MeetingEventProcessor/MeetingCreateEventProcessor.swift

@@ -0,0 +1,48 @@
+//
+// Wire
+// Copyright (C) 2026 Wire Swiss GmbH
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see http://www.gnu.org/licenses/.
+//
+
+import WireCallingDomain
+import WireNetwork
+
+struct MeetingCreateEventProcessor: MeetingCreateEventProcessorProtocol {
+
+    let repository: any MeetingRepositoryProtocol
+    let conversationRepository: any ConversationRepositoryProtocol
+
+    func processEvent(_ event: MeetingCreateEvent) async throws {
+        guard let meeting = try await repository.pullMeeting(id: event.meetingID) else { return }
+
+        // The backend doesn't send a conversation.create event for the meeting's
+        // conversation (see `CreateMeetingUseCase`), so a meeting created on
+        // another client references a conversation this client doesn't know yet.
+        // Pull it and store the meeting again so the two are linked; meetings
+        // without a locally stored conversation are not listed.
+        let conversationID = meeting.conversationID
+        guard await conversationRepository.fetchConversation(
+            id: conversationID.id,
+            domain: conversationID.domain
+        ) == nil else { return }
+
+        try await conversationRepository.pullConversation(
+            id: conversationID.id,
+            domain: conversationID.domain
+        )
+        await repository.storeMeeting(meeting)
+    }
+
+}

WireDomain/Sources/WireDomain/Event Processing/MeetingEventProcessor/MeetingDeleteEventProcessor.swift

@@ -0,0 +1,30 @@
+//
+// Wire
+// Copyright (C) 2026 Wire Swiss GmbH
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see http://www.gnu.org/licenses/.
+//
+
+import WireCallingDomain
+import WireNetwork
+
+struct MeetingDeleteEventProcessor: MeetingDeleteEventProcessorProtocol {
+
+    let repository: any MeetingRepositoryProtocol
+
+    func processEvent(_ event: MeetingDeleteEvent) async {
+        await repository.deleteLocalMeeting(id: event.meetingID)
+    }
+
+}

WireDomain/Sources/WireDomain/Event Processing/MeetingEventProcessor/MeetingEventProcessor.swift

@@ -0,0 +1,40 @@
+//
+// Wire
+// Copyright (C) 2026 Wire Swiss GmbH
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see http://www.gnu.org/licenses/.
+//
+
+import WireNetwork
+
+struct MeetingEventProcessor: MeetingEventProcessorProtocol {
+
+    let createEventProcessor: any MeetingCreateEventProcessorProtocol
+    let deleteEventProcessor: any MeetingDeleteEventProcessorProtocol
+    let updateEventProcessor: any MeetingUpdateEventProcessorProtocol
+
+    func processEvent(_ event: MeetingEvent) async throws {
+        switch event {
+        case let .create(event):
+            try await createEventProcessor.processEvent(event)
+
+        case let .delete(event):
+            await deleteEventProcessor.processEvent(event)
+
+        case let .update(event):
+            try await updateEventProcessor.processEvent(event)
+        }
+    }
+
+}

WireDomain/Sources/WireDomain/Event Processing/MeetingEventProcessor/MeetingUpdateEventProcessor.swift

@@ -0,0 +1,48 @@
+//
+// Wire
+// Copyright (C) 2026 Wire Swiss GmbH
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see http://www.gnu.org/licenses/.
+//
+
+import WireCallingDomain
+import WireNetwork
+
+struct MeetingUpdateEventProcessor: MeetingUpdateEventProcessorProtocol {
+
+    let repository: any MeetingRepositoryProtocol
+    let conversationRepository: any ConversationRepositoryProtocol
+
+    func processEvent(_ event: MeetingUpdateEvent) async throws {
+        guard let meeting = try await repository.pullMeeting(id: event.meetingID) else { return }
+
+        // The backend doesn't send a conversation.create event for the meeting's
+        // conversation (see `CreateMeetingUseCase`), so a meeting created on
+        // another client references a conversation this client doesn't know yet.
+        // Pull it and store the meeting again so the two are linked; meetings
+        // without a locally stored conversation are not listed.
+        let conversationID = meeting.conversationID
+        guard await conversationRepository.fetchConversation(
+            id: conversationID.id,
+            domain: conversationID.domain
+        ) == nil else { return }
+
+        try await conversationRepository.pullConversation(
+            id: conversationID.id,
+            domain: conversationID.domain
+        )
+        await repository.storeMeeting(meeting)
+    }
+
+}

WireDomain/Sources/WireDomain/Event Processing/MeetingEventProcessor/Protocols/MeetingCreateEventProcessorProtocol.swift

@@ -0,0 +1,31 @@
+//
+// Wire
+// Copyright (C) 2026 Wire Swiss GmbH
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see http://www.gnu.org/licenses/.
+//
+
+import WireNetwork
+
+/// Process meeting create events.
+
+protocol MeetingCreateEventProcessorProtocol {
+
+    /// Process a meeting create event.
+    ///
+    /// - Parameter event: A meeting create event.
+
+    func processEvent(_ event: MeetingCreateEvent) async throws
+
+}

WireDomain/Sources/WireDomain/Event Processing/MeetingEventProcessor/Protocols/MeetingDeleteEventProcessorProtocol.swift

@@ -0,0 +1,31 @@
+//
+// Wire
+// Copyright (C) 2026 Wire Swiss GmbH
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see http://www.gnu.org/licenses/.
+//
+
+import WireNetwork
+
+/// Process meeting delete events.
+
+protocol MeetingDeleteEventProcessorProtocol {
+
+    /// Process a meeting delete event.
+    ///
+    /// - Parameter event: A meeting delete event.
+
+    func processEvent(_ event: MeetingDeleteEvent) async
+
+}

WireDomain/Sources/WireDomain/Event Processing/MeetingEventProcessor/Protocols/MeetingEventProcessorProtocol.swift

@@ -0,0 +1,31 @@
+//
+// Wire
+// Copyright (C) 2026 Wire Swiss GmbH
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see http://www.gnu.org/licenses/.
+//
+
+import WireNetwork
+
+/// Process meeting events.
+
+protocol MeetingEventProcessorProtocol {
+
+    /// Process a meeting event.
+    ///
+    /// - Parameter event: A meeting event.
+
+    func processEvent(_ event: MeetingEvent) async throws
+
+}