|
|
|
@ -12,9 +12,9 @@ import java.util.Iterator;
|
|
|
|
|
import java.util.concurrent.atomic.AtomicLong;
|
|
|
|
|
|
|
|
|
|
import org.bson.Document;
|
|
|
|
|
import org.gcube.application.cms.tests.model.TestFilters;
|
|
|
|
|
import org.gcube.application.cms.tests.model.TestModel;
|
|
|
|
|
import org.gcube.application.cms.tests.model.TestQueries;
|
|
|
|
|
import org.gcube.application.cms.tests.model.concessioni.TestConcessioniFilters;
|
|
|
|
|
import org.gcube.application.cms.tests.model.concessioni.TestConcessioniModel;
|
|
|
|
|
import org.gcube.application.cms.tests.model.concessioni.TestConcessioniQueries;
|
|
|
|
|
import org.gcube.application.geoportal.client.utils.Queries;
|
|
|
|
|
import org.gcube.application.geoportal.client.utils.Serialization;
|
|
|
|
|
import org.gcube.application.geoportal.common.model.legacy.*;
|
|
|
|
@ -40,7 +40,7 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
public void searches() throws Exception {
|
|
|
|
|
TestFilters.filters.forEach((k,v)->{
|
|
|
|
|
TestConcessioniFilters.filters.forEach((k, v)->{
|
|
|
|
|
try {
|
|
|
|
|
System.out.println("Count for " + k + "\t" + count(client.search(v)));
|
|
|
|
|
}catch (Exception e){
|
|
|
|
@ -62,7 +62,7 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
// No Transformation
|
|
|
|
|
System.out.print("First Registered \t");
|
|
|
|
|
Iterator<Concessione> queriedDocuments=client.query(
|
|
|
|
|
Queries.parse(TestQueries.queries.get("firstRegistered.json")));
|
|
|
|
|
Queries.parse(TestConcessioniQueries.queries.get("firstRegistered.json")));
|
|
|
|
|
// Expected one result
|
|
|
|
|
assertTrue(count(queriedDocuments)==1);
|
|
|
|
|
|
|
|
|
@ -71,7 +71,7 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
System.out.print("Last Registered \t");
|
|
|
|
|
// Expected one result
|
|
|
|
|
queriedDocuments=client.query(
|
|
|
|
|
Queries.parse(TestQueries.queries.get("lastRegistered.json")));
|
|
|
|
|
Queries.parse(TestConcessioniQueries.queries.get("lastRegistered.json")));
|
|
|
|
|
assertTrue(count(queriedDocuments)==1);
|
|
|
|
|
|
|
|
|
|
queriedDocuments.forEachRemaining((Concessione c)->{System.out.println(c.getNome());});
|
|
|
|
@ -80,11 +80,11 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
// Transformations
|
|
|
|
|
System.out.println(
|
|
|
|
|
client.queryForJSON(
|
|
|
|
|
Queries.parse(TestQueries.queries.get("lastNameRegisteredByFabio.json"))));
|
|
|
|
|
Queries.parse(TestConcessioniQueries.queries.get("lastNameRegisteredByFabio.json"))));
|
|
|
|
|
|
|
|
|
|
System.out.println(
|
|
|
|
|
client.queryForJSON(
|
|
|
|
|
Queries.parse(TestQueries.queries.get("publicationWarningMessages.json"))));
|
|
|
|
|
Queries.parse(TestConcessioniQueries.queries.get("publicationWarningMessages.json"))));
|
|
|
|
|
|
|
|
|
|
// String query=Files.readFileAsString(filterFile.getAbsolutePath(), Charset.defaultCharset());
|
|
|
|
|
// System.out.println("Count for "+filterFile.getName()+"\t"+ count(client.search(query)));
|
|
|
|
@ -101,14 +101,14 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
public void testCreateNew() throws Exception {
|
|
|
|
|
Concessione c= client.createNew(TestModel.prepareEmptyConcessione());
|
|
|
|
|
Concessione c= client.createNew(TestConcessioniModel.prepareEmptyConcessione());
|
|
|
|
|
assertNotNull(c);
|
|
|
|
|
assertNotNull(c.getMongo_id());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
public void testReplace() throws Exception {
|
|
|
|
|
Concessione testObject= client.createNew(TestModel.prepareEmptyConcessione());
|
|
|
|
|
Concessione testObject= client.createNew(TestConcessioniModel.prepareEmptyConcessione());
|
|
|
|
|
String title="My new shiny Title";
|
|
|
|
|
testObject.setNome(title);
|
|
|
|
|
Concessione c1=client.replace(testObject);
|
|
|
|
@ -117,11 +117,11 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
public void testUploadFileSet() throws Exception {
|
|
|
|
|
Concessione testObject= client.createNew(TestModel.prepareConcessione());
|
|
|
|
|
Concessione testObject= client.createNew(TestConcessioniModel.prepareConcessione());
|
|
|
|
|
AddSectionToConcessioneRequest request=
|
|
|
|
|
// FileSets.prepareRequest(new StorageUtils(),Paths.RELAZIONE,new File(TestModel.getBaseFolder(),"relazione.pdf"));
|
|
|
|
|
// FileSets.prepareRequest(new StorageUtils(),Paths.RELAZIONE,new File(TestConcessioniModel.getBaseFolder(),"relazione.pdf"));
|
|
|
|
|
FileSets.build(Paths.ABSTRACT_RELAZIONE).add(
|
|
|
|
|
new StorageUtils().putOntoStorage(new File(TestModel.getBaseFolder(),"relazione.pdf"),"San Mauro_drone totale.JPG"))
|
|
|
|
|
new StorageUtils().putOntoStorage(new File(TestConcessioniModel.getBaseFolder(),"relazione.pdf"),"San Mauro_drone totale.JPG"))
|
|
|
|
|
.getTheRequest();
|
|
|
|
|
|
|
|
|
|
testObject= client.registerFileSet(testObject.getMongo_id(), request);
|
|
|
|
@ -134,7 +134,7 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
public void testDeleteById() throws Exception {
|
|
|
|
|
Concessione c= client.createNew(TestModel.prepareEmptyConcessione());
|
|
|
|
|
Concessione c= client.createNew(TestConcessioniModel.prepareEmptyConcessione());
|
|
|
|
|
client.deleteById(c.getMongo_id());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -181,7 +181,7 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
|
|
|
|
|
private Concessione prepare() throws Exception {
|
|
|
|
|
int numImgs=1;
|
|
|
|
|
Concessione c= client.createNew(TestModel.prepareConcessione(1,numImgs));
|
|
|
|
|
Concessione c= client.createNew(TestConcessioniModel.prepareConcessione(1,numImgs));
|
|
|
|
|
StorageUtils storage = new StorageUtils();
|
|
|
|
|
|
|
|
|
|
c.getRelazioneScavo().setPolicy(AccessPolicy.EMBARGOED);
|
|
|
|
@ -191,30 +191,30 @@ public class StatelessClientTests extends BasicVreTests{
|
|
|
|
|
assertEquals(AccessPolicy.EMBARGOED,c.getRelazioneScavo().getPolicy());
|
|
|
|
|
|
|
|
|
|
c=client.registerFileSet(mongoId,
|
|
|
|
|
FileSets.prepareRequest(storage,Paths.RELAZIONE,new File(TestModel.getBaseFolder(),"relazione.pdf")));
|
|
|
|
|
FileSets.prepareRequest(storage,Paths.RELAZIONE,new File(TestConcessioniModel.getBaseFolder(),"relazione.pdf")));
|
|
|
|
|
|
|
|
|
|
assertEquals(AccessPolicy.EMBARGOED,c.getRelazioneScavo().getPolicy());
|
|
|
|
|
|
|
|
|
|
c=client.registerFileSet(mongoId,
|
|
|
|
|
FileSets.prepareRequest(storage,Paths.ABSTRACT_RELAZIONE,new File(TestModel.getBaseFolder(),"relazione.pdf")));
|
|
|
|
|
FileSets.prepareRequest(storage,Paths.ABSTRACT_RELAZIONE,new File(TestConcessioniModel.getBaseFolder(),"relazione.pdf")));
|
|
|
|
|
|
|
|
|
|
assertEquals(AccessPolicy.EMBARGOED,c.getRelazioneScavo().getPolicy());
|
|
|
|
|
|
|
|
|
|
for(int i=0;i<numImgs;i++)
|
|
|
|
|
c=client.registerFileSet(mongoId,
|
|
|
|
|
FileSets.build(Paths.imgByIndex(i)).
|
|
|
|
|
add(storage.putOntoStorage(new File(TestModel.getBaseFolder(),"immagine"+(i+1)+".png"),
|
|
|
|
|
add(storage.putOntoStorage(new File(TestConcessioniModel.getBaseFolder(),"immagine"+(i+1)+".png"),
|
|
|
|
|
i+"San Mauro_drone totale.JPG")).getTheRequest());
|
|
|
|
|
|
|
|
|
|
assertEquals(AccessPolicy.EMBARGOED,c.getRelazioneScavo().getPolicy());
|
|
|
|
|
|
|
|
|
|
c=client.registerFileSet(mongoId,
|
|
|
|
|
FileSets.prepareRequest(storage,Paths.POSIZIONAMENTO,new File(TestModel.getBaseFolder(),"pos.shp")));
|
|
|
|
|
FileSets.prepareRequest(storage,Paths.POSIZIONAMENTO,new File(TestConcessioniModel.getBaseFolder(),"pos.shp")));
|
|
|
|
|
|
|
|
|
|
assertEquals(AccessPolicy.EMBARGOED,c.getRelazioneScavo().getPolicy());
|
|
|
|
|
|
|
|
|
|
c=client.registerFileSet(mongoId,
|
|
|
|
|
FileSets.prepareRequest(storage,Paths.piantaByIndex(0),new File(TestModel.getBaseFolder(),"pianta.shp")));
|
|
|
|
|
FileSets.prepareRequest(storage,Paths.piantaByIndex(0),new File(TestConcessioniModel.getBaseFolder(),"pianta.shp")));
|
|
|
|
|
|
|
|
|
|
assertEquals(AccessPolicy.EMBARGOED,c.getRelazioneScavo().getPolicy());
|
|
|
|
|
|
|
|
|
|