Navigate to the Pinned events timeline (#3139)

ElementX/Sources/Services/Room/RoomProxy.swift

@@ -23,21 +23,38 @@ class RoomProxy: RoomProxyProtocol {
     private let roomListItem: RoomListItemProtocol
     private let room: RoomProtocol
     let timeline: TimelineProxyProtocol
+    
     private var innerPinnedEventsTimeline: TimelineProxyProtocol?
+    private var innerPinnedEventsTimelineTask: Task<TimelineProxyProtocol?, Never>?
     var pinnedEventsTimeline: TimelineProxyProtocol? {
         get async {
+            // Check if is alrrady available.
             if let innerPinnedEventsTimeline {
                 return innerPinnedEventsTimeline
+                // Otherwise check if there is already a task loading it, and wait for it.
+            } else if let innerPinnedEventsTimelineTask,
+                      let value = await innerPinnedEventsTimelineTask.value {
+                return value
+                // Else create and store a new task to load it and wait for it.
             } else {
-                do {
-                    let timeline = try await TimelineProxy(timeline: room.pinnedEventsTimeline(internalIdPrefix: nil, maxEventsToLoad: 100), isLive: false)
-                    await timeline.subscribeForUpdates()
-                    innerPinnedEventsTimeline = timeline
-                    return timeline
-                } catch {
-                    MXLog.error("Failed creating pinned events timeline with error: \(error)")
-                    return nil
+                let task = Task<TimelineProxyProtocol?, Never> { [weak self] in
+                    guard let self else {
+                        return nil
+                    }
+                    
+                    do {
+                        let timeline = try await TimelineProxy(timeline: room.pinnedEventsTimeline(internalIdPrefix: nil, maxEventsToLoad: 100), isLive: false)
+                        await timeline.subscribeForUpdates()
+                        innerPinnedEventsTimeline = timeline
+                        return timeline
+                    } catch {
+                        MXLog.error("Failed creating pinned events timeline with error: \(error)")
+                        return nil
+                    }
                 }
+                
+                innerPinnedEventsTimelineTask = task
+                return await task.value
             }
         }
     }

ElementX/Sources/Services/Timeline/TimelineItemProxy.swift

@@ -53,6 +53,15 @@ enum TimelineItemProxy {
             self = .unknown(item)
         }
     }
+    
+    var isEvent: Bool {
+        switch self {
+        case .event:
+            return true
+        default:
+            return false
+        }
+    }
 }
 
 /// The delivery status for the item.

ElementX/Sources/Services/UserSession/UserSessionStore.swift

@@ -21,6 +21,7 @@ import MatrixRustSDK
 class UserSessionStore: UserSessionStoreProtocol {
     private let keychainController: KeychainControllerProtocol
     private let appSettings: AppSettings
+    private let networkMonitor: NetworkMonitorProtocol
     private let appHooks: AppHooks
     private let matrixSDKStateKey = "matrix-sdk-state"
     
@@ -31,10 +32,14 @@ class UserSessionStore: UserSessionStoreProtocol {
     
     var clientSessionDelegate: ClientSessionDelegate { keychainController }
     
-    init(keychainController: KeychainControllerProtocol, appSettings: AppSettings, appHooks: AppHooks) {
+    init(keychainController: KeychainControllerProtocol,
+         appSettings: AppSettings,
+         appHooks: AppHooks,
+         networkMonitor: NetworkMonitorProtocol) {
         self.keychainController = keychainController
         self.appSettings = appSettings
         self.appHooks = appHooks
+        self.networkMonitor = networkMonitor
     }
     
     /// Deletes all data stored in the shared container and keychain
@@ -146,8 +151,8 @@ class UserSessionStore: UserSessionStoreProtocol {
     
     private func setupProxyForClient(_ client: Client) async -> ClientProxyProtocol {
         await ClientProxy(client: client,
-                          networkMonitor: ServiceLocator.shared.networkMonitor,
-                          appSettings: ServiceLocator.shared.settings)
+                          networkMonitor: networkMonitor,
+                          appSettings: appSettings)
     }
     
     private func deleteSessionDirectory(for credentials: KeychainCredentials) {