Chore/file link sync service refactoring

modules/storages/app/common/storages/peripherals/storage_file_info_converter.rb

@@ -0,0 +1,46 @@
+#-- copyright
+# OpenProject is an open source project management software.
+# Copyright (C) 2012-2023 the OpenProject GmbH
+#
+# This program is free software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License version 3.
+#
+# OpenProject is a fork of ChiliProject, which is a fork of Redmine. The copyright follows:
+# Copyright (C) 2006-2013 Jean-Philippe Lang
+# Copyright (C) 2010-2013 the ChiliProject Team
+#
+# 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 2
+# 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, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+#
+# See COPYRIGHT and LICENSE files for more details.
+#++
+
+module Storages::Peripherals
+  module StorageFileInfoConverter
+    def to_storage_file(storage_file_info)
+      Storages::StorageFile.new(
+        id: storage_file_info.id,
+        name: storage_file_info.name,
+        size: storage_file_info.size,
+        mime_type: storage_file_info.mime_type,
+        created_at: storage_file_info.created_at,
+        last_modified_at: storage_file_info.last_modified_at,
+        created_by_name: storage_file_info.owner_name,
+        last_modified_by_name: storage_file_info.last_modified_by_name,
+        location: storage_file_info.location,
+        permissions: storage_file_info.permissions
+      )
+    end
+  end
+end

modules/storages/app/common/storages/peripherals/storage_interaction/nextcloud/file_ids_query.rb

@@ -0,0 +1,45 @@
+#-- copyright
+# OpenProject is an open source project management software.
+# Copyright (C) 2012-2023 the OpenProject GmbH
+#
+# This program is free software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License version 3.
+#
+# OpenProject is a fork of ChiliProject, which is a fork of Redmine. The copyright follows:
+# Copyright (C) 2006-2013 Jean-Philippe Lang
+# Copyright (C) 2010-2013 the ChiliProject Team
+#
+# 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 2
+# 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, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+#
+# See COPYRIGHT and LICENSE files for more details.
+#++
+
+module Storages::Peripherals::StorageInteraction::Nextcloud
+  class FileIdsQuery
+    def initialize(storage)
+      @query = ::Storages::Peripherals::StorageInteraction::Nextcloud::Internal::PropfindQuery.new(storage)
+    end
+
+    def call(path:)
+      query_params = {
+        depth: '1',
+        path:,
+        props: %w[oc:fileid]
+      }
+
+      @query.call(**query_params)
+    end
+  end
+end

modules/storages/app/common/storages/peripherals/storage_interaction/nextcloud/files_info_query.rb

@@ -0,0 +1,145 @@
+#-- copyright
+# OpenProject is an open source project management software.
+# Copyright (C) 2012-2023 the OpenProject GmbH
+#
+# This program is free software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License version 3.
+#
+# OpenProject is a fork of ChiliProject, which is a fork of Redmine. The copyright follows:
+# Copyright (C) 2006-2013 Jean-Philippe Lang
+# Copyright (C) 2010-2013 the ChiliProject Team
+#
+# 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 2
+# 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, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+#
+# See COPYRIGHT and LICENSE files for more details.
+#++
+
+module Storages::Peripherals::StorageInteraction::Nextcloud
+  class FilesInfoQuery
+    using Storages::Peripherals::ServiceResultRefinements
+
+    FILES_INFO_PATH = 'ocs/v1.php/apps/integration_openproject/filesinfo'.freeze
+
+    def initialize(storage)
+      @uri = URI(storage.host).normalize
+      @oauth_client = storage.oauth_client
+    end
+
+    def call(user:, file_ids: [])
+      if file_ids.nil?
+        return Util.error(:error, 'File IDs can not be nil', file_ids)
+      end
+
+      if file_ids.empty?
+        return ServiceResult.success(result: [])
+      end
+
+      Util.token(user:, oauth_client: @oauth_client) do |token|
+        files_info(file_ids, token).map(&parse_json) >> handle_failure >> create_storage_file_infos
+      end
+    end
+
+    private
+
+    def files_info(file_ids, token)
+      ServiceResult.success(
+        result: RestClient::Request.execute(
+          method: :post,
+          url: Util.join_uri_path(@uri, FILES_INFO_PATH),
+          payload: { fileIds: file_ids }.to_json,
+          headers: {
+            'Authorization' => "Bearer #{token.access_token}",
+            'Accept' => 'application/json',
+            'Content-Type' => 'application/json',
+            'OCS-APIRequest' => true
+          }
+        )
+      ).map(&:body)
+    rescue RestClient::Unauthorized => e
+      Util.error(:not_authorized, 'Outbound request not authorized!', e.response)
+    rescue RestClient::NotFound => e
+      Util.error(:not_found, 'Outbound request destination not found!', e.response)
+    rescue RestClient::ExceptionWithResponse => e
+      Util.error(:error, 'Outbound request failed!', e.response)
+    rescue StandardError
+      Util.error(:error, 'Outbound request failed!')
+    end
+
+    def parse_json
+      ->(response_body) do
+        # rubocop:disable Style/OpenStructUse
+        JSON.parse(response_body, object_class: OpenStruct)
+        # rubocop:enable Style/OpenStructUse
+      end
+    end
+
+    def handle_failure
+      ->(response_object) do
+        if response_object.ocs.meta.status == 'ok'
+          ServiceResult.success(result: response_object)
+        else
+          Util.error(:error, 'Outbound request failed!', response_object)
+        end
+      end
+    end
+
+    # rubocop:disable Metrics/AbcSize
+    def create_storage_file_infos
+      ->(response_object) do
+        ServiceResult.success(
+          result: response_object.ocs.data.each_pair.map do |key, value|
+            if value.statuscode == 200
+              ::Storages::StorageFileInfo.new(
+                status: value.status,
+                status_code: value.statuscode,
+                id: value.id,
+                name: value.name,
+                last_modified_at: Time.zone.at(value.mtime),
+                created_at: Time.zone.at(value.ctime),
+                mime_type: value.mimetype,
+                size: value.size,
+                owner_name: value.owner_name,
+                owner_id: value.owner_id,
+                trashed: value.trashed,
+                last_modified_by_name: value.modifier_name,
+                last_modified_by_id: value.modifier_id,
+                permissions: value.dav_permissions,
+                location: location(value.path)
+              )
+            else
+              ::Storages::StorageFileInfo.new(
+                status: value.status,
+                status_code: value.statuscode,
+                id: key.to_s.to_i
+              )
+            end
+          end
+        )
+      end
+    end
+
+    # rubocop:enable Metrics/AbcSize
+
+    def location(file_path)
+      prefix = 'files/'
+      idx = file_path.rindex(prefix)
+      return '/' if idx == nil
+
+      idx += prefix.length - 1
+
+      Util.escape_path(file_path[idx..])
+    end
+  end
+end