feat: integrate collabora - WPB-21651

WireMessaging/Package.swift

@@ -14,7 +14,7 @@ let package = Package(
         .library(name: "WireMessagingUI", targets: ["WireMessagingUI"])
     ],
     dependencies: [
-        .package(url: "https://github.com/pydio/cells-sdk-swift.git", from: "0.1.1-alpha15"),
+        .package(url: "https://github.com/pydio/cells-sdk-swift.git", from: "0.1.1-alpha17"),
         .package(url: "https://github.com/awslabs/aws-sdk-swift.git", from: "1.0.0"),
         .package(url: "https://github.com/apple/swift-collections.git", from: "1.1.4"),
         .package(name: "WireFoundation", path: "../WireFoundation"),

WireMessaging/Sources/WireMessagingAssembly/WireMessagingFactory.swift

@@ -37,6 +37,7 @@ public struct WireMessagingFactory {
     private let lastOpenRequest: WireCellsLastOpenRequest
     private let nodeCache = WireCellsNodeCache()
     private let isFoldersEnabled: Bool
+    private let isCollaboraEnabled: Bool
     private let nodeRenameNotifier: WireCellsNodeRenameNotifier
 
     @MainActor var lastOpenRequestNodeID: UUID?
@@ -47,7 +48,8 @@ public struct WireMessagingFactory {
         accessToken: any AccessTokenProvider,
         fileCache: any FileCache,
         contextProvider: any ManagedObjectContextProvider,
-        isFoldersEnabled: Bool
+        isFoldersEnabled: Bool,
+        isCollaboraEnabled: Bool
     ) {
         // TODO: [WPB-18798] Remove serverURL temporary override when there exists a method to obtain the correct URL.
         let serverURL = switch serverURL.host {
@@ -75,6 +77,7 @@ public struct WireMessagingFactory {
         )
         self.lastOpenRequest = WireCellsLastOpenRequest()
         self.isFoldersEnabled = isFoldersEnabled
+        self.isCollaboraEnabled = isCollaboraEnabled
         self.nodeRenameNotifier = WireCellsNodeRenameNotifier()
     }
 
@@ -154,6 +157,7 @@ public extension WireMessagingFactory {
                 nodeRenameNotifier: nodeRenameNotifier,
                 fileCache: fileCache,
                 isFoldersEnabled: isFoldersEnabled,
+                isCollaboraEnabled: isCollaboraEnabled,
                 accentColorProvider: accentColorProvider
             ).environment(\.wireAccentColor, accentColorProvider())
         )
@@ -190,12 +194,18 @@ public extension WireMessagingFactory {
                         updateTags: WireCellsUpdateTagsUseCase(nodesAPI: nodesAPI),
                         getTagSuggestions: WireCellsGetTagSuggestionsUseCase(nodesAPI: nodesAPI),
                         createFolder: WireCellsCreateFolderUseCase(nodesRepository: nodesAPI),
+                        getEditingURL: WireCellsGetEditingURLUseCase(editingURLRepository: nodesAPI),
+                        getAssetUseCase: WireCellsGetAssetUseCase(
+                            localAssetRepository: localAssetRepository,
+                            fileCache: fileCache
+                        )
                     ),
                     isCellsStatePending: false,
                     localAssetRepository: localAssetRepository,
                     nodesRepository: nodesAPI,
                     fileCache: fileCache,
                     isFoldersEnabled: false,
+                    isCollaboraEnabled: isCollaboraEnabled,
                     accentColorProvider: accentColorProvider
                 )
             )

WireMessaging/Sources/WireMessagingData/WireCells/Model/WireCellsNodeNetworkModel.swift

@@ -31,6 +31,7 @@ package struct WireCellsNodeNetworkModel: Equatable, Hashable, Sendable {
     package let type: String?
     package let isRecycled: Bool
     package let isDraft: Bool
+    package let isEditable: Bool
     package let contentUrl: URL?
     package let contentHash: String?
     package let mimeType: String?
@@ -51,6 +52,7 @@ package struct WireCellsNodeNetworkModel: Equatable, Hashable, Sendable {
         type: String? = nil,
         isRecycled: Bool = false,
         isDraft: Bool = false,
+        isEditable: Bool = false,
         contentUrl: URL? = nil,
         contentHash: String? = nil,
         mimeType: String? = nil,
@@ -70,6 +72,7 @@ package struct WireCellsNodeNetworkModel: Equatable, Hashable, Sendable {
         self.type = type
         self.isRecycled = isRecycled
         self.isDraft = isDraft
+        self.isEditable = isEditable
         self.contentUrl = contentUrl
         self.contentHash = contentHash
         self.mimeType = mimeType
@@ -94,6 +97,7 @@ package extension WireCellsNodeNetworkModel {
             type: type.flatMap { WireCellsNodeType(rawValue: $0) },
             isRecycled: isRecycled,
             isDraft: isDraft,
+            isEditable: isEditable,
             contentUrl: contentUrl,
             contentHash: contentHash,
             mimeType: mimeType,
@@ -145,6 +149,7 @@ package extension RestNode {
             type: type?.rawValue ?? "",
             isRecycled: isRecycled ?? false,
             isDraft: isDraft ?? false,
+            isEditable: editorURLsKeys?.contains("collabora") ?? false,
             contentUrl: preSignedGET?.url.flatMap(URL.init(string:)),
             contentHash: contentHash,
             mimeType: contentType,

WireMessaging/Sources/WireMessagingData/WireCells/NodesAPI/NodesAPI.swift

@@ -25,7 +25,8 @@
     case moveFailed
 }
 
-package final actor NodesAPI: NodesAPIProtocol, WireCellsNodesRepositoryProtocol {
+package final actor NodesAPI: NodesAPIProtocol, WireCellsNodesRepositoryProtocol,
+    WireCellsEditingURLRepositoryProtocol {
     private let awsClient: AWSClient
     private let restAPI: RestAPI
     private let fileManager: FileManager
@@ -105,7 +106,7 @@
         out: URL,
         cellPath: String,
         onProgressUpdate: @escaping @Sendable (UInt64) -> Void
     ) async throws {
         guard let stream = OutputStream(url: out, append: true) else {
             throw NodesAPIError.failedToCreateWriteStream
         }
@@ -149,6 +150,10 @@
         }
     }
 
+    package func getEditorURL(id: UUID) async throws -> (url: URL, date: Date)? {
+        try await restAPI.getEditorURL(id: id)
+    }
+
     package func createPublicLink(nodeID: UUID, fileName: String) async throws -> WireCellsPublicLink {
         try await restAPI.createPublicLink(uuid: nodeID, fileName: fileName)
     }

WireMessaging/Sources/WireMessagingData/WireCells/NodesAPI/RestAPI.swift

@@ -77,6 +77,19 @@ final class RestAPI: Sendable {
         }
     }
 
+    func getEditorURL(id: UUID) async throws -> (url: URL, date: Date)? {
+        do {
+            let response = try await NodeServiceAPI.getByUuid(
+                uuid: id.transportString(),
+                flags: [.withEditorURLs],
+                apiConfiguration: makeConfiguration()
+            )
+            return response.editorURLs?["collabora"]?.info
+        } catch let error as ErrorResponse {
+            throw error.underlyingError
+        }
+    }
+
     /// Renames a node.
     ///
     /// - Parameters:
@@ -449,3 +462,18 @@ private extension ErrorResponse {
         }
     }
 }
+
+private extension RestPreSignedURL {
+
+    var info: (url: URL, date: Date)? {
+        guard
+            let urlString = url,
+            let url = URL(string: urlString),
+            let expiresAtString = expiresAt,
+            let expiresAtTimeInterval = TimeInterval(expiresAtString)
+        else {
+            return nil
+        }
+        return (url: url, date: Date(timeIntervalSinceNow: expiresAtTimeInterval))
+    }
+}

WireMessaging/Sources/WireMessagingDomain/WireCells/Model/WireCellsLocalAssetRepositoryError.swift

@@ -28,10 +28,6 @@ public enum WireCellsLocalAssetRepositoryError: Error, Equatable {
 
     case missingETag
 
-    /// A download for the requested asset is already in progress.
-
-    case downloadAlreadyInProgress
-
     /// The requested asset is unknown to the repository.
 
     case unknownAsset

WireMessaging/Sources/WireMessagingDomain/WireCells/Model/WireCellsNode.swift

@@ -36,6 +36,7 @@ public struct WireCellsNode: Equatable, Identifiable, Sendable {
     public let type: WireCellsNodeType?
     public let isRecycled: Bool
     public let isDraft: Bool
+    public let isEditable: Bool
     public let contentUrl: URL?
     public let contentHash: String?
     public let mimeType: String?
@@ -59,6 +60,7 @@ public struct WireCellsNode: Equatable, Identifiable, Sendable {
         type: WireCellsNodeType? = nil,
         isRecycled: Bool = false,
         isDraft: Bool = false,
+        isEditable: Bool = false,
         contentUrl: URL? = nil,
         contentHash: String? = nil,
         mimeType: String? = nil,
@@ -78,6 +80,7 @@ public struct WireCellsNode: Equatable, Identifiable, Sendable {
         self.type = type
         self.isRecycled = isRecycled
         self.isDraft = isDraft
+        self.isEditable = isEditable
         self.contentUrl = contentUrl
         self.contentHash = contentHash
         self.mimeType = mimeType

WireMessaging/Sources/WireMessagingDomain/WireCells/Protocols/WireCellsEditingURLRepositoryProtocol.swift

@@ -0,0 +1,27 @@
+//
+// Wire
+// Copyright (C) 2025 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/.
+//
+
+package import Foundation
+
+// sourcery: AutoMockable
+package protocol WireCellsEditingURLRepositoryProtocol: Sendable {
+
+    /// Returns a URL to an online editor where the document can be edited.
+    func getEditorURL(id: UUID) async throws -> (url: URL, date: Date)?
+
+}

WireMessaging/Sources/WireMessagingDomain/WireCells/UseCases/WireCellsGetAssetUseCase.swift

@@ -37,12 +37,10 @@ package struct WireCellsGetAssetUseCase {
         self.fileCache = fileCache
     }
 
-    package func invoke(nodeID: UUID) async throws -> URL {
+    package func invoke(nodeID: UUID, eTag: String?) async throws -> URL {
         // If the file is already downloaded, return the local URL.
-        if
-            let cacheKey = try await localAssetRepository.asset(nodeID: nodeID)?.downloadState.cacheKey,
-            let url = fileCache.fileURL(forKey: cacheKey) {
-            return url
+        if let fileURL = try await cachedAssetURL(for: nodeID, eTag: eTag) {
+            return fileURL
         }
 
         try await localAssetRepository.downloadAsset(nodeID: nodeID)
@@ -57,4 +55,24 @@ package struct WireCellsGetAssetUseCase {
         return fileURL
     }
 
+    // MARK: - Private helpers
+
+    /// Returns the cached asset URL if it exists and matches the provided eTag.
+    private func cachedAssetURL(for nodeID: UUID, eTag: String?) async throws -> URL? {
+        if
+            let eTag,
+            let asset = try await localAssetRepository.asset(nodeID: nodeID),
+            eTag == asset.eTag,
+            let cacheKey = asset.downloadState.cacheKey {
+            return fileCache.fileURL(forKey: cacheKey)
+        }
+
+        if let cacheKey = try await localAssetRepository.refreshAssetMetadata(nodeID: nodeID).asset.downloadState
+            .cacheKey {
+            return fileCache.fileURL(forKey: cacheKey)
+        }
+
+        return nil
+    }
+
 }

WireMessaging/Sources/WireMessagingDomain/WireCells/UseCases/WireCellsGetEditingURLUseCase.swift

@@ -0,0 +1,41 @@
+//
+// Wire
+// Copyright (C) 2025 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/.
+//
+
+package import Foundation
+
+/// Returns a URL to an online editor where a document can be edited, along with the date when the URL was generated.
+package struct WireCellsGetEditingURLUseCase {
+
+    private let editingURLRepository: any WireCellsEditingURLRepositoryProtocol
+
+    package init(
+        editingURLRepository: any WireCellsEditingURLRepositoryProtocol
+    ) {
+        self.editingURLRepository = editingURLRepository
+    }
+
+    /// Fetches the editor URL for a given node ID.
+    ///
+    /// - Parameter nodeID: The unique identifier of the node/document.
+    /// - Returns: The editor URL, or `nil` if no URL is available.
+    /// - Throws: An error if the request fails.
+    package func invoke(nodeID: UUID) async throws -> URL? {
+        try await editingURLRepository.getEditorURL(id: nodeID)?.url
+    }
+
+}

WireMessaging/Sources/WireMessagingUI/Resources/Localization/en.lproj/Localizable.strings

@@ -117,6 +117,7 @@
 "conversation.wireCells.files.loadMore.title" = "Load more";
 "conversation.wireCells.files.item.menu.open" = "Open";
 "conversation.wireCells.files.item.menu.download" = "Download";
+"conversation.wireCells.files.item.menu.editFile" = "Edit file";
 "conversation.wireCells.files.item.menu.rename" = "Rename";
 "conversation.wireCells.files.item.menu.moveToFolder" = "Move to folder";
 "conversation.wireCells.files.item.menu.addOrRemoveTags" = "Add or remove tags";

WireMessaging/Sources/WireMessagingUI/WireCells/Components/AttachmentsPreviewView/WireCellsAttachmentsPreviewItemView.swift

@@ -113,7 +113,8 @@ struct WireCellsAttachmentsPreviewItemView: View {
             }
         }
         .contentShape(Rectangle()) // Constrains the tappable content area of the view.
-        .onAppear(perform: refresh)
+        .onAppear(perform: viewModel.startPolling)
+        .onDisappear(perform: viewModel.stopPolling)
         .onTapGesture(perform: open)
         .quickLookPreview($viewModel.viewingURL)
     }