Add encrypted file upload to test03AddVault.

Author: chenkins

hub/src/test/java/ch/iterate/hub/core/AbstractHubSynchronizeTest.java

@@ -4,35 +4,37 @@
 
 package ch.iterate.hub.core;
 
-import ch.cyberduck.core.AbstractPath;
-import ch.cyberduck.core.AttributedList;
-import ch.cyberduck.core.DisabledCancelCallback;
-import ch.cyberduck.core.DisabledHostKeyCallback;
-import ch.cyberduck.core.DisabledListProgressListener;
-import ch.cyberduck.core.DisabledLoginCallback;
-import ch.cyberduck.core.DisabledPasswordCallback;
-import ch.cyberduck.core.Host;
-import ch.cyberduck.core.ListService;
-import ch.cyberduck.core.Path;
-import ch.cyberduck.core.Protocol;
-import ch.cyberduck.core.ProtocolFactory;
-import ch.cyberduck.core.Session;
-import ch.cyberduck.core.SimplePathPredicate;
+import ch.cyberduck.core.*;
+import ch.cyberduck.core.features.Bulk;
 import ch.cyberduck.core.features.Home;
+import ch.cyberduck.core.features.Touch;
 import ch.cyberduck.core.features.Vault;
+import ch.cyberduck.core.features.Write;
+import ch.cyberduck.core.io.ChecksumComputeFactory;
+import ch.cyberduck.core.io.HashAlgorithm;
+import ch.cyberduck.core.io.StatusOutputStream;
 import ch.cyberduck.core.preferences.PreferencesFactory;
 import ch.cyberduck.core.proxy.DisabledProxyFinder;
 import ch.cyberduck.core.ssl.DefaultX509KeyManager;
 import ch.cyberduck.core.ssl.DisabledX509TrustManager;
+import ch.cyberduck.core.transfer.Transfer;
+import ch.cyberduck.core.transfer.TransferItem;
+import ch.cyberduck.core.transfer.TransferStatus;
 import ch.cyberduck.core.vault.DefaultVaultRegistry;
 
+import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang3.RandomUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.openapitools.jackson.nullable.JsonNullableModule;
 
+import java.io.ByteArrayInputStream;
+import java.util.Collections;
 import java.util.EnumSet;
 import java.util.List;
 import java.util.UUID;
@@ -58,12 +60,24 @@
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
+import org.testcontainers.shaded.org.apache.commons.io.input.NullInputStream;
+
 import static ch.iterate.hub.testsetup.HubTestUtilities.getAdminApiClient;
 import static org.junit.jupiter.api.Assertions.*;
 
 public abstract class AbstractHubSynchronizeTest extends AbstractHubTest {
     private static final Logger log = LogManager.getLogger(AbstractHubSynchronizeTest.class.getName());
 
+    /**
+     * Use to start unattended setup and then run
+     * @throws InterruptedException
+     */
+    @Test
+    @Disabled
+    public void runForever() throws InterruptedException {
+        Thread.sleep(924982347);
+    }
+
     /**
      * Verify storage profiles are synced from hub bookmark.
      */
@@ -249,6 +263,19 @@ public void test03AddVault(final HubTestConfig config) throws Exception {
                 final AttributedList<Path> list = session.getFeature(ListService.class).list(bucket, new DisabledListProgressListener());
                 assertTrue(list.isEmpty());
             }
+            {
+                final Path home = vaultRegistry.find(session, bucket).getHome();
+                Path file = new Path(home, "gugus.txt", EnumSet.of(AbstractPath.Type.file));
+                byte[] content = RandomUtils.nextBytes(234);
+                TransferStatus transferStatus = new TransferStatus().withLength(content.length);
+                transferStatus.setChecksum(session.getFeature(Write.class).checksum(file, transferStatus).compute(new ByteArrayInputStream(content), transferStatus));
+                session.getFeature(Bulk.class).pre(Transfer.Type.upload, Collections.singletonMap(new TransferItem(file), transferStatus), new DisabledConnectionCallback());
+                StatusOutputStream<?> out = session.getFeature(Write.class).write(file, transferStatus, new DisabledConnectionCallback());
+                IOUtils.copyLarge(new ByteArrayInputStream(content), out);
+                out.close();
+                final AttributedList<Path> list = session.getFeature(ListService.class).list(bucket, new DisabledListProgressListener());
+                assertFalse(list.isEmpty());
+            }
 
             // raw listing encrypted file names
             vaultRegistry.close(bucket);

hub/src/test/java/ch/iterate/hub/core/HubSynchronizeTest.java

@@ -31,6 +31,15 @@ private Stream<Arguments> arguments() {
         }
     }
 
+    @Nested
+    @TestInstance(PER_CLASS)
+    @Disabled("run standalone against already running hub started by runForever test.")
+    public class PUnattendedMinio extends AbstractHubSynchronizeTest {
+        private Stream<Arguments> arguments() {
+            return Stream.of(minioStaticUnattendedLocalOnly, minioSTSUnattendedLocalOnly);
+        }
+    }
+
     @Nested
     @ExtendWith({HubTestSetupDockerExtension.UnattendedLocalKeycloakDev.class})
     @TestInstance(PER_CLASS)