gCubeSystem
/
data-transfer-library
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fixed tests

This commit is contained in:
Fabio Sinibaldi 2020-07-20 15:23:43 +02:00
parent e6c16252b9
commit 24765a9bee
2 changed files with 26 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/java/org/gcube/data/transfer/library/TestClientCalls.java
View File

@ -28,10 +28,10 @@ import org.junit.Test;
public class TestClientCalls {
static String hostname="http://thredds-pre-d4s.d4science.org:80";
static String hostname="http://thredds-d-d4s.d4science.org:80";
// static String hostname="https://geoserver1-spatial-dev.d4science.org";
// static String scope="/gcube/devNext/NextNext";
static String scope="/pred4s/preprod/preVRE";
static String scope="/gcube/devsec/devVRE";
// static String scope="/pred4s/preprod/preVRE";
static Client client;

30
src/test/java/org/gcube/data/transfer/library/TransfererTest.java
View File

@ -2,7 +2,13 @@ package org.gcube.data.transfer.library;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.StandardCopyOption;
import java.util.Collections;
import java.util.HashMap;
@ -26,23 +32,33 @@ import org.junit.Test;
public class TransfererTest {
static String hostname="http://node3-d-d4s.d4science.org:80";
static String hostname="http://thredds-d-d4s.d4science.org:80";
// static String nodeId="462b68c5-463f-4295-86da-37d6c0abc7ea";
static String scope="/gcube/devNext";
static String scope="/gcube/devsec/devVRE";
static DataTransferClient client;
static String link="http://maven.research-infrastructures.eu/nexus/content/groups/gcube-releases-all/org/gcube/data/transfer/data-transfer-model/1.0.0-3.11.0-128236/data-transfer-model-1.0.0-3.11.0-128236-javadoc.jar";
static File tempFile;
@BeforeClass
public static void init() throws UnreachableNodeException, ServiceNotFoundException, HostingNodeNotFoundException{
public static void init() throws UnreachableNodeException, ServiceNotFoundException, HostingNodeNotFoundException, IOException{
TokenSetter.set(scope);
client=DataTransferClient.getInstanceByEndpoint(hostname);
// client=DataTransferClient.getInstanceByNodeId(nodeId);
// Download file from mvn
InputStream in = new URL(link).openStream();
Path file=Files.createTempFile("test", ".jar");
Files.copy(in, file, StandardCopyOption.REPLACE_EXISTING);
tempFile=file.toFile();
}
@Test
public void localFile() throws InvalidSourceException, SourceNotSetException, FailedTransferException, InitializationException, InvalidDestinationException, DestinationNotSetException{
for(int i=0;i<3;i++){
String localFile="/home/fabio/Dropbox/Mindless/01- COMA - Mindless.mp3";
String localFile=tempFile.getAbsolutePath();
String transferredFileName="Mindless.mp3";
Destination dest=new Destination(transferredFileName);
dest.setOnExistingFileName(DestinationClashPolicy.REWRITE);
@ -56,7 +72,7 @@ public class TransfererTest {
@Test
public void httpUrl() throws MalformedURLException, InvalidSourceException, SourceNotSetException, FailedTransferException, InitializationException, InvalidDestinationException, DestinationNotSetException{
String link="http://maven.research-infrastructures.eu/nexus/service/local/artifact/maven/redirect?r=central&g=org.apache.commons&a=commons-io&v=1.3.2&e=jar&c=javadoc";
System.out.println(client.httpSource(link,new Destination("Some import")));
}
@ -64,7 +80,7 @@ public class TransfererTest {
@Test
public void storage() throws InvalidSourceException, SourceNotSetException, FailedTransferException, InitializationException, RemoteBackendException, FileNotFoundException, InvalidDestinationException, DestinationNotSetException{
TokenSetter.set(scope);
String toUpload="/home/fabio/Documents/Personal/DND/Incantesimi 3.5 - Mago e Stregone.pdf";
String toUpload=tempFile.getAbsolutePath();
String id=StorageUtils.putOntoStorage(new File(toUpload));
Destination dest=new Destination("some/where","My Pdf.pdf");
TransferResult res=client.storageId(id,dest);
@ -95,6 +111,6 @@ public class TransfererTest {
public void decompressPlugin() throws InvalidSourceException, SourceNotSetException, FailedTransferException, InitializationException, InvalidDestinationException, DestinationNotSetException{
HashMap<String,String> invocationParams=new HashMap<String,String>();
invocationParams.put("SOURCE_ARCHIVE", PluginInvocation.DESTINATION_FILE_PATH);
client.localFile(new File("/home/fabio/eclipse/Eclipse-mars/lombok.jar"), new Destination("MyJar"),Collections.singleton(new PluginInvocation("DECOMPRESS", invocationParams)));
client.localFile(tempFile, new Destination("MyJar"),Collections.singleton(new PluginInvocation("DECOMPRESS", invocationParams)));
}
}