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-alpha16"),
         .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()
     }
 
@@ -153,7 +156,8 @@ public extension WireMessagingFactory {
                 nodeCache: nodeCache,
                 nodeRenameNotifier: nodeRenameNotifier,
                 fileCache: fileCache,
-                isFoldersEnabled: isFoldersEnabled
+                isFoldersEnabled: isFoldersEnabled,
+                isCollaboraEnabled: isCollaboraEnabled
             )
             .environment(\.wireAccentColor, accentColor)
         )
@@ -165,7 +169,7 @@ public extension WireMessagingFactory {
             rootView: FilesBrowserView(
                 viewModel: FilesViewModel(
                     useCases: .init(
-                        fetchNodes: WireCellsFetchNodesUseCase(
+                        fetchNodes: WireCellsFetchNodesPageUseCase(
                             configuration: .filesBrowserView,
                             repository: nodesAPI
                         ),
@@ -183,11 +187,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
+                    isFoldersEnabled: false,
+                    isCollaboraEnabled: isCollaboraEnabled
                 )
             )
         )

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

@@ -22,9 +22,11 @@ package import WireMessagingDomain
 
 package enum NodesAPIError: Error {
     case failedToCreateWriteStream
+    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
@@ -79,7 +81,13 @@ package final actor NodesAPI: NodesAPIProtocol, WireCellsNodesRepositoryProtocol
     }
 
     package func renameNode(nodeID: UUID, targetPath: String) async throws -> Bool {
-        try await restAPI.renameNode(nodeID: nodeID, targetPath: targetPath)
+        try await restAPI.renameNode(nodeID: nodeID, targetPath: targetPath, targetIsParent: false)
+    }
+
+    package func moveNode(nodeID: UUID, newContainerPath: String) async throws {
+        guard try await restAPI.renameNode(nodeID: nodeID, targetPath: newContainerPath, targetIsParent: true) else {
+            throw NodesAPIError.moveFailed
+        }
     }
 
     package func publishDraft(nodeID: UUID, versionID: UUID) async throws {
@@ -138,6 +146,10 @@ package final actor NodesAPI: NodesAPIProtocol, WireCellsNodesRepositoryProtocol
         }
     }
 
+    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

@@ -70,11 +70,22 @@ final class RestAPI: Sendable {
                 if let urlError = error as? URLError, urlError.code == .cancelled {
                     throw CancellationError()
                 } else {
-                    throw sdkError
+                    throw sdkError.underlyingError
                 }
             }
-        } catch {
-            throw error
+        }
+    }
+
+    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
         }
     }
 
@@ -83,32 +94,38 @@ final class RestAPI: Sendable {
     /// - Parameters:
     ///  - nodeID: The `UUID`s of the node to rename.
     ///  - targetPath: The new path for the node.
+    ///  - targetIsParent: Whether the `targetPath` is the parent folder of the node.
     /// - Returns: Whether the renaming was successful.
 
-    func renameNode(nodeID: UUID, targetPath: String) async throws -> Bool {
+    func renameNode(nodeID: UUID, targetPath: String, targetIsParent: Bool) async throws -> Bool {
         let node = RestNodeLocator(uuid: nodeID.uuidString)
 
         let parameters = RestActionParameters(
             awaitStatus: .finished,
             awaitTimeout: "5s",
             copyMoveOptions: RestActionOptionsCopyMove(
-                targetIsParent: false,
+                targetIsParent: targetIsParent,
                 targetPath: targetPath
             ),
             nodes: [node],
         )
 
-        let response = try await NodeServiceAPI.performAction(
-            name: .move,
-            parameters: parameters,
-            apiConfiguration: makeConfiguration()
-        )
-        guard
-            let actions = response.backgroundActions,
-            let renameAction = actions.first(where: { $0.name == Constants.renameBackgroundActionName }) else {
-            return false
+        do {
+            let response = try await NodeServiceAPI.performAction(
+                name: .move,
+                parameters: parameters,
+                apiConfiguration: makeConfiguration()
+            )
+
+            guard
+                let actions = response.backgroundActions,
+                let renameAction = actions.first(where: { $0.name == Constants.renameBackgroundActionName }) else {
+                return false
+            }
+            return renameAction.status == .finished
+        } catch let error as ErrorResponse {
+            throw error.underlyingError
         }
-        return renameAction.status == .finished
     }
 
     /// Deletes nodes by their `UUID`s.
@@ -381,8 +398,45 @@ private extension WireCellsGetNodesRequest {
             )
             request.sortDirDesc = true
             request.sortField = "mtime"
+        case let .moveToFolder(root):
+            request.filters = RestLookupFilter(
+                status: LookupFilterStatusFilter(
+                    deleted: .not,
+                    isDraft: false
+                ),
+                type: .collection
+            )
+            request.scope = RestLookupScope(
+                recursive: false,
+                root: RestNodeLocator(path: root)
+            )
         }
         return request
     }
 
 }
+
+private extension ErrorResponse {
+
+    var underlyingError: any Error {
+        switch self {
+        case let .error(_, _, _, error):
+            error
+        }
+    }
+}
+
+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/WireCellsNodesRepositoryProtocol.swift

@@ -55,6 +55,13 @@ package protocol WireCellsNodesRepositoryProtocol: Sendable {
     /// - Returns: Whether the renaming was successful.
     func renameNode(nodeID: UUID, targetPath: String) async throws -> Bool
 
+    /// Moves a node to a new container path.
+    ///
+    /// - Parameters:
+    ///  - nodeID: The `UUID` of the node to move.
+    ///  - newContainerPath: The new container path for the node.
+    func moveNode(nodeID: UUID, newContainerPath: String) async throws
+
     /// Apply some pre-validation checks on node name before sending an upload
     ///
     /// - Parameters:
@@ -75,6 +82,9 @@ package struct WireCellsGetNodesRequest: Equatable, Sendable {
 
         /// A `Configuration` suitable for the files browser view.
         case filesBrowserView
+
+        /// A `Configuration` suitable for moving nodes to a folder.
+        case moveToFolder(root: String)
     }
 
     /// An optional search term to filter nodes by name.

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/WireCellsFetchNodesPageUseCase.swift

@@ -0,0 +1,61 @@
+//
+// 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/.
+//
+
+import Foundation
+
+/// Fetches `WireCellNodes`s for the given parameters.
+package struct WireCellsFetchNodesPageUseCase: Sendable {
+
+    private let configuration: WireCellsGetNodesRequest.Configuration
+    private let repository: any WireCellsNodesRepositoryProtocol
+
+    /// Initializes the use case with the required parameters.
+    /// - Parameters:
+    ///   - configuration: The configuration for the use case.
+    ///   - repository: The repository to use for fetching nodes.
+    package init(
+        configuration: WireCellsGetNodesRequest.Configuration,
+        repository: any WireCellsNodesRepositoryProtocol
+    ) {
+        self.configuration = configuration
+        self.repository = repository
+    }
+
+    /// Fetches nodes based on the provided search term and pagination token.
+    ///
+    /// - Parameters:
+    ///   - searchTerm: An optional search term to filter nodes by their name.
+    ///   - token: An optional pagination token. If `nil`, the first page of results will be fetched.
+    /// - Returns: An array of `WireCellsNode` values and an optional pagination token for the next page of results. If
+    /// `nil`, there are no more pages to fetch.
+    package func invoke(
+        searchTerm: String?,
+        offset: Int
+    ) async throws -> (nodes: [WireCellsNode], isLastPage: Bool) {
+        let request = WireCellsGetNodesRequest(
+            searchTerm: searchTerm,
+            limit: 30,
+            offset: offset,
+            configuration: configuration
+        )
+        let (nodes, nextOffset) = try await repository.getNodes(request)
+
+        return (nodes, nextOffset == nil)
+    }
+
+}