feat(services/koofr): set test for koofr

.env.example

@@ -205,10 +205,10 @@ OPENDAL_PCLOUD_PASSWORD=<password>
 OPENDAL_YANDEX_DISK_ROOT=/path/to/dir
 OPENDAL_YANDEX_DISK_ACCESS_TOKEN=<access_token>
 # koofr
-OPENDAL_KOOFR_DISK_ROOT=/path/to/dir
+OPENDAL_KOOFR_ROOT=/path/to/dir
 OPENDAL_KOOFR_ENDPOINT=<endpoint>
 OPENDAL_KOOFR_EMAIL=<email>
-OPENDAL_KOOFR_PASSWORD=<password>>
+OPENDAL_KOOFR_PASSWORD=<password>
 # icloud
 OPENDAL_ICLOUD_ROOT=/
 OPENDAL_ICLOUD_APPLE_ID=<apple_id>

.github/services/koofr/koofr/action.yml

@@ -0,0 +1,32 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+name: koofr
+description: 'Behavior test for Koofr. This service is sponsored by @suyanhanx.'
+
+runs:
+  using: "composite"
+  steps:
+    - name: Setup
+      uses: 1password/load-secrets-action@v1
+      with:
+        export-env: true
+      env:
+        OPENDAL_KOOFR_ROOT: op://services/koofr/root
+        OPENDAL_KOOFR_ENDPOINT: op://services/koofr/endpoint
+        OPENDAL_KOOFR_EMAIL: op://services/koofr/email
+        OPENDAL_KOOFR_PASSWORD: op://services/koofr/password

bindings/java/Cargo.toml

@@ -72,6 +72,7 @@ services-all = [
   "services-onedrive",
   "services-persy",
   "services-postgresql",
+  "services-koofr",
   "services-mysql",
   "services-redb",
   "services-redis",
@@ -125,6 +126,7 @@ services-gridfs = ["opendal/services-gridfs"]
 services-hdfs = ["opendal/services-hdfs"]
 services-huggingface = ["opendal/services-huggingface"]
 services-ipfs = ["opendal/services-ipfs"]
+services-koofr = ["opendal/services-koofr"]
 services-libsql = ["opendal/services-libsql"]
 services-memcached = ["opendal/services-memcached"]
 services-mini-moka = ["opendal/services-mini-moka"]

bindings/java/src/test/java/org/apache/opendal/test/behavior/AsyncCopyTest.java

@@ -22,6 +22,7 @@
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static org.junit.jupiter.api.Assertions.assertNotEquals;
 import static org.junit.jupiter.api.Assumptions.assumeTrue;
+import java.util.Objects;
 import java.util.UUID;
 import org.apache.opendal.Capability;
 import org.apache.opendal.OpenDALException;
@@ -64,6 +65,9 @@ public void testCopyFileWithAsciiName() {
      */
     @Test
     public void testCopyFileWithNonAsciiName() {
+        // Services-koofr doesn't support non-ascii name (https://github.com/apache/opendal/issues/4051)
+        assumeTrue(!Objects.equals(op().info.scheme, "koofr"), "Services-koofr doesn't support non-ascii name");
+
         final String sourcePath = "🐂🍺中文.docx";
         final String targetPath = "😈🐅Français.docx";
         final byte[] content = generateBytes();

bindings/nodejs/Cargo.toml

@@ -49,7 +49,9 @@ default = [
 services-all = [
   "default",
 
+  "services-alluxio",
   "services-azfile",
+  "services-b2",
   "services-cacache",
   "services-dashmap",
   "services-dropbox",
@@ -59,34 +61,33 @@ services-all = [
   # FIXME waiting for this issue close https://github.com/async-rs/async-tls/issues/55
   #  "services-ftp",
   "services-gdrive",
+  "services-gridfs",
   # FIXME how to support HDFS services in bindings?
   # "services-hdfs",
   "services-huggingface",
   "services-ipfs",
+  "services-koofr",
+  "services-libsql",
   "services-memcached",
   "services-mini-moka",
   "services-moka",
+  "services-mongodb",
   "services-onedrive",
   "services-persy",
   "services-postgresql",
   "services-mysql",
   "services-redb",
   "services-redis",
   "services-rocksdb",
+  "services-seafile",
   "services-sled",
+  "services-sqlite",
   "services-supabase",
   "services-swift",
   "services-tikv",
+  "services-upyun",
   "services-vercel-artifacts",
   "services-wasabi",
-  "services-mongodb",
-  "services-gridfs",
-  "services-sqlite",
-  "services-libsql",
-  "services-alluxio",
-  "services-b2",
-  "services-seafile",
-  "services-upyun",
 ]
 
 # Default services provided by opendal.
@@ -120,6 +121,7 @@ services-gridfs = ["opendal/services-gridfs"]
 services-hdfs = ["opendal/services-hdfs"]
 services-huggingface = ["opendal/services-huggingface"]
 services-ipfs = ["opendal/services-ipfs"]
+services-koofr = ["opendal/services-koofr"]
 services-libsql = ["opendal/services-libsql"]
 services-memcached = ["opendal/services-memcached"]
 services-mini-moka = ["opendal/services-mini-moka"]

bindings/python/Cargo.toml

@@ -89,6 +89,7 @@ services-all = [
   "services-b2",
   "services-seafile",
   "services-upyun",
+  "services-koofr",
 ]
 
 # Default services provided by opendal.
@@ -122,6 +123,7 @@ services-gridfs = ["opendal/services-gridfs"]
 services-hdfs = ["opendal/services-hdfs"]
 services-huggingface = ["opendal/services-huggingface"]
 services-ipfs = ["opendal/services-ipfs"]
+services-koofr = ["opendal/services-koofr"]
 services-libsql = ["opendal/services-libsql"]
 services-memcached = ["opendal/services-memcached"]
 services-mini-moka = ["opendal/services-mini-moka"]
@@ -161,4 +163,4 @@ features = [
   # Depend on "openssh" which depends on "tokio-pipe" that is unavailable on Windows.
   "services-sftp",
 ]
-workspace = true
+workspace = true

core/Cargo.toml

@@ -197,7 +197,7 @@ services-upyun = ["dep:hmac", "dep:sha1"]
 services-vercel-artifacts = []
 # Deprecated
 # wasabi services support has been removed.
-# We will remove this feature in next version.
+# We will remove this feature in the next version.
 services-wasabi = []
 services-webdav = []
 services-webhdfs = []

core/src/services/koofr/backend.rs

@@ -50,7 +50,7 @@ pub struct KoofrConfig {
     pub endpoint: String,
     /// Koofr email.
     pub email: String,
-    /// password of this backend.
+    /// password of this backend. (Must be the application password)
     pub password: Option<String>,
 }
 
@@ -115,10 +115,16 @@ impl KoofrBuilder {
         self
     }
 
-    /// Koofr app password.
+    /// Koofr application password.
     ///
     /// Go to https://app.koofr.net/app/admin/preferences/password.
-    /// Click "Generate Password" button to generate a new password.
+    /// Click "Generate Password" button to generate a new application password.
+    ///
+    /// # Notes
+    ///
+    /// This is not user's Koofr account password.
+    /// Please use the application password instead.
+    /// Please also remind users of this.
     pub fn password(&mut self, password: &str) -> &mut Self {
         self.config.password = if password.is_empty() {
             None
@@ -173,7 +179,6 @@ impl Builder for KoofrBuilder {
         let root = normalize_root(&self.config.root.clone().unwrap_or_default());
         debug!("backend use root {}", &root);
 
-        // Handle endpoint.
         if self.config.endpoint.is_empty() {
             return Err(Error::new(ErrorKind::ConfigInvalid, "endpoint is empty")
                 .with_operation("Builder::build")
@@ -182,7 +187,6 @@ impl Builder for KoofrBuilder {
 
         debug!("backend use endpoint {}", &self.config.endpoint);
 
-        // Handle email.
         if self.config.email.is_empty() {
             return Err(Error::new(ErrorKind::ConfigInvalid, "email is empty")
                 .with_operation("Builder::build")
@@ -253,7 +257,9 @@ impl Accessor for KoofrBackend {
                 write_can_empty: true,
 
                 delete: true,
+
                 rename: true,
+
                 copy: true,
 
                 list: true,
@@ -348,6 +354,11 @@ impl Accessor for KoofrBackend {
 
     async fn copy(&self, from: &str, to: &str, _args: OpCopy) -> Result<RpCopy> {
         self.core.ensure_dir_exists(to).await?;
+
+        if from == to {
+            return Ok(RpCopy::default());
+        }
+
         let resp = self.core.remove(to).await?;
 
         let status = resp.status();
@@ -372,6 +383,11 @@ impl Accessor for KoofrBackend {
 
     async fn rename(&self, from: &str, to: &str, _args: OpRename) -> Result<RpRename> {
         self.core.ensure_dir_exists(to).await?;
+
+        if from == to {
+            return Ok(RpRename::default());
+        }
+
         let resp = self.core.remove(to).await?;
 
         let status = resp.status();

core/tests/behavior/async_copy.rs

@@ -63,6 +63,11 @@ pub async fn test_copy_file_with_ascii_name(op: Operator) -> Result<()> {
 
 /// Copy a file with non ascii name and test contents.
 pub async fn test_copy_file_with_non_ascii_name(op: Operator) -> Result<()> {
+    // Koofr does not support non-ascii name.(https://github.com/apache/opendal/issues/4051)
+    if op.info().scheme() == Scheme::Koofr {
+        return Ok(());
+    }
+
     let source_path = "🐂🍺中文.docx";
     let target_path = "😈🐅Français.docx";
     let (source_content, _) = gen_bytes(op.info().full_capability());