generate TeamMemberDiscoveryAgent

Author: caldrian

WireDomain/Sources/WireDomain/Components/ClientSessionComponent.swift

@@ -398,6 +398,8 @@ public final class ClientSessionComponent {
         mlsService: mlsService
     )
 
+    private lazy var teamMemberDiscoveryAgent = TeamMemberDiscoveryAgent()
+
     public private(set) lazy var incrementalSync = IncrementalSync(
         selfClientID: selfClientID,
         pushChannelAPI: pushChannelAPI,
@@ -411,8 +413,8 @@ public final class ClientSessionComponent {
         liveBrokenGroupSubject: liveBrokenGroupSubject,
         journal: journal,
         mlsGroupRepairAgent: mlsGroupRepairAgent,
-        earService: earService
-        // TODO: pass team-member discovery use case
+        earService: earService,
+        teamMemberDiscoveryAgent: teamMemberDiscoveryAgent
     )
 
     public lazy var incrementalSyncV2: IncrementalSyncV2 = if let sharedContainerURL {
@@ -431,7 +433,7 @@ public final class ClientSessionComponent {
             journal: journal,
             mlsGroupRepairAgent: mlsGroupRepairAgent,
             earService: earService,
-            // TODO: pass team-member discovery use case
+            teamMemberDiscoveryAgent: teamMemberDiscoveryAgent,
             createPushChannelState: { [selfClientID] in
                 PushChannelState(sharedContainerURL: sharedContainerURL, clientID: selfClientID)
             }

WireDomain/Sources/WireDomain/Synchronization/IncrementalSync.swift

@@ -45,7 +45,7 @@ public struct IncrementalSync: IncrementalSyncProtocol {
     private let journal: Journal
     private let mlsGroupRepairAgent: MLSGroupRepairAgentProtocol
     private let earService: EARServiceInterface
-    // TODO: add team-member discovery use case stored property
+    private let teamMemberDiscoveryAgent: any TeamMemberDiscoveryAgentProtocol
 
     public init(
         selfClientID: String,
@@ -60,8 +60,8 @@ public struct IncrementalSync: IncrementalSyncProtocol {
         liveBrokenGroupSubject: PassthroughSubject<Set<String>, Never>,
         journal: Journal,
         mlsGroupRepairAgent: MLSGroupRepairAgentProtocol,
-        earService: EARServiceInterface
-        // TODO: add team-member discovery use case init parameter
+        earService: EARServiceInterface,
+        teamMemberDiscoveryAgent: any TeamMemberDiscoveryAgentProtocol
     ) {
         self.selfClientID = selfClientID
         self.pushChannelAPI = pushChannelAPI
@@ -76,6 +76,7 @@ public struct IncrementalSync: IncrementalSyncProtocol {
         self.journal = journal
         self.mlsGroupRepairAgent = mlsGroupRepairAgent
         self.earService = earService
+        self.teamMemberDiscoveryAgent = teamMemberDiscoveryAgent
     }
 
     public func perform() async throws -> Token {
@@ -163,7 +164,9 @@ public struct IncrementalSync: IncrementalSyncProtocol {
 
             await mlsGroupRepairAgent.repairConversations()
 
-            // TODO: invoke team-member discovery use case here (skip when backgroundAccessibleOnly)
+            if !backgroundAccessibleOnly {
+                await teamMemberDiscoveryAgent.discoverMembers()
+            }
 
             let liveEventTask = Task { @Sendable [self] in
                 logger.info("handling live event stream", attributes: .incrementalSyncV2, .safePublic)

WireDomain/Sources/WireDomain/Synchronization/IncrementalSyncV2.swift

@@ -52,7 +52,7 @@ public struct IncrementalSyncV2: LiveSyncProtocol {
     private let createPushChannelState: CreatePushChannelStateClosure
     private let mlsGroupRepairAgent: MLSGroupRepairAgentProtocol
     private let earService: EARServiceInterface
-    // TODO: add team-member discovery use case stored property
+    private let teamMemberDiscoveryAgent: any TeamMemberDiscoveryAgentProtocol
 
     weak var delegate: (any LiveSyncDelegate)?
 
@@ -71,7 +71,7 @@ public struct IncrementalSyncV2: LiveSyncProtocol {
         journal: Journal,
         mlsGroupRepairAgent: MLSGroupRepairAgentProtocol,
         earService: EARServiceInterface,
-        // TODO: add team-member discovery use case init parameter
+        teamMemberDiscoveryAgent: any TeamMemberDiscoveryAgentProtocol,
         createPushChannelState: @escaping CreatePushChannelStateClosure,
         syncMarkerGenerator: @escaping SyncMarkerGenerator = { UUID().uuidString }
     ) {
@@ -89,6 +89,7 @@ public struct IncrementalSyncV2: LiveSyncProtocol {
         self.journal = journal
         self.mlsGroupRepairAgent = mlsGroupRepairAgent
         self.earService = earService
+        self.teamMemberDiscoveryAgent = teamMemberDiscoveryAgent
         self.syncMarkerGenerator = syncMarkerGenerator
         self.createPushChannelState = createPushChannelState
     }
@@ -154,7 +155,7 @@ public struct IncrementalSyncV2: LiveSyncProtocol {
 
         await mlsGroupRepairAgent.repairConversations()
 
-        // TODO: invoke team-member discovery use case here
+        await teamMemberDiscoveryAgent.discoverMembers()
 
         let task = Task { @Sendable [self] in
             logger.debug("handling live event stream", attributes: logAttributes)

WireDomain/Sources/WireDomain/Synchronization/Protocols/TeamMemberDiscoveryAgentProtocol.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 Foundation
+
+// sourcery: AutoMockable
+/// Discovers self-team members by replaying recent team notifications,
+/// working around the 2000-member cap on the legacy bulk team-members endpoint.
+public protocol TeamMemberDiscoveryAgentProtocol {
+
+    /// Fetch recent team notifications and apply any discovered
+    /// `team.member-join` events to local storage.
+    func discoverMembers() async
+
+}

WireDomain/Sources/WireDomain/Synchronization/TeamMemberDiscoveryAgent.swift

@@ -0,0 +1,38 @@
+//
+// 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 Foundation
+import WireLogging
+
+final class TeamMemberDiscoveryAgent: TeamMemberDiscoveryAgentProtocol {
+
+    // MARK: - Life cycle
+
+    public init() {}
+
+    // MARK: - TeamMemberDiscoveryAgentProtocol
+
+    public func discoverMembers() async {
+        // TODO: WPB-24947 — use teamsAPI.getNotifications(sinceNotificationID:)
+        // to fetch recent team notifications, then extract & apply
+        // `team.member-join` events to discover all team members
+        // (works around the 2000-member cap on the legacy bulk endpoint).
+        WireLogger.sync.debug("team member discovery: not implemented yet")
+    }
+
+}