140 lines
5.2 KiB
Java
140 lines
5.2 KiB
Java
package org.gcube.application.geoportal.service.utils;
|
|
|
|
import org.gcube.application.geoportal.common.model.rest.DatabaseConnection;
|
|
import org.gcube.application.geoportal.service.ServiceConstants;
|
|
import org.gcube.application.geoportal.service.model.internal.db.MongoConnection;
|
|
import org.gcube.application.geoportal.service.model.internal.faults.ConfigurationException;
|
|
import org.gcube.common.encryption.encrypter.StringEncrypter;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.AccessPoint;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.Property;
|
|
import org.gcube.resources.discovery.client.api.DiscoveryClient;
|
|
import org.gcube.resources.discovery.client.queries.api.SimpleQuery;
|
|
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.clientFor;
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.queryFor;
|
|
|
|
public class ISUtils {
|
|
|
|
public DatabaseConnection queryForDB(String platform, String flag) throws ConfigurationException {
|
|
return ISUtils.performQueryForDB(platform,flag);
|
|
}
|
|
|
|
// public List<AccessPoint> GetAP(String platform,String flag) {
|
|
// return performGetAP(platform,flag);
|
|
// }
|
|
|
|
private static DatabaseConnection performQueryForDB(String platform, String flag) throws ConfigurationException {
|
|
|
|
List<AccessPoint> found=performGetAP(platform, flag);
|
|
if(found.size()>1) {
|
|
throw new ConfigurationException("Multiple SE found ["+found.size()+"] for platform : "+platform+" flag : "+flag);
|
|
}else if (found.isEmpty()){
|
|
throw new ConfigurationException("No SE found for platform : "+platform+" flag : "+flag);
|
|
}
|
|
AccessPoint point=found.get(0);
|
|
|
|
DatabaseConnection toReturn=new DatabaseConnection();
|
|
toReturn.setPwd(decryptString(point.password()));
|
|
toReturn.setUser(point.username());
|
|
toReturn.setUrl(point.address());
|
|
return toReturn;
|
|
|
|
}
|
|
|
|
|
|
private static List<AccessPoint> performGetAP(String platform,String flag) {
|
|
SimpleQuery query = queryFor(ServiceEndpoint.class);
|
|
|
|
query.addCondition("$resource/Profile/Category/text() eq '"+ServiceConstants.SE_GNA_DB_CATEGORY+"'")
|
|
.addCondition("$resource/Profile/Platform/Name/text() eq '"+platform+"'")
|
|
.addCondition("$resource/Profile/AccessPoint//Property[Name/text() eq '"+
|
|
ServiceConstants.SE_GNA_DB_FLAG+"'][Value/text() eq '"+flag+"']")
|
|
.setResult("$resource/Profile/AccessPoint");
|
|
|
|
DiscoveryClient<AccessPoint> client = clientFor(AccessPoint.class);
|
|
return client.submit(query);
|
|
}
|
|
|
|
public MongoConnection queryForMongoDB(String platform,String flag) throws ConfigurationException {
|
|
return performQueryForMongoDB(platform,flag);
|
|
}
|
|
|
|
private static MongoConnection performQueryForMongoDB(String platform,String flag) throws ConfigurationException {
|
|
|
|
List<AccessPoint> found=performGetAP(platform, flag);
|
|
if(found.size()>1) {
|
|
throw new ConfigurationException("Multiple SE found ["+found.size()+"] for platform : "+platform+" flag : "+flag);
|
|
}else if (found.isEmpty()){
|
|
throw new ConfigurationException("No SE found for platform : "+platform+" flag : "+flag);
|
|
}
|
|
AccessPoint point=found.get(0);
|
|
MongoConnection toReturn=new MongoConnection();
|
|
for(Property prop:point.properties()) {
|
|
switch(prop.name()) {
|
|
case "host" : {
|
|
toReturn.getHosts().add(prop.value());
|
|
break;}
|
|
}
|
|
}
|
|
toReturn.getHosts().add(point.address());
|
|
Map<String, Property> props=point.propertyMap();
|
|
toReturn.setDatabase(props.get("database").value());
|
|
toReturn.setPassword(decryptString(point.password()));
|
|
toReturn.setPort(Integer.parseInt(props.get("port").value()));
|
|
toReturn.setUser(point.username());
|
|
|
|
return toReturn;
|
|
}
|
|
//
|
|
//
|
|
//
|
|
// private static String getToken() throws ConfigurationException {
|
|
// SimpleQuery query = queryFor(ServiceEndpoint.class);
|
|
//
|
|
// query.addCondition("$resource/Profile/Category/text() eq 'Application'")
|
|
// .addCondition("$resource/Profile/Name/text() eq 'GNA-APP'")
|
|
// .setResult("$resource/Profile/AccessPoint");
|
|
//
|
|
// DiscoveryClient<AccessPoint> client = clientFor(AccessPoint.class);
|
|
//
|
|
// List<AccessPoint> found= client.submit(query);
|
|
// if(found.size()>1) {
|
|
// throw new ConfigurationException("Multiple Token SE found ["+found.size()+"] for Category : Application name : GNA-APP");
|
|
// }else if (found.isEmpty()){
|
|
// throw new ConfigurationException("No Token SE found ["+found.size()+"] for Category : Application name : GNA-APP");
|
|
// }
|
|
//
|
|
// AccessPoint point=found.get(0);
|
|
// return decryptString(point.password());
|
|
//
|
|
// }
|
|
//
|
|
//
|
|
private static String decryptString(String toDecrypt){
|
|
try{
|
|
return StringEncrypter.getEncrypter().decrypt(toDecrypt);
|
|
}catch(Exception e) {
|
|
throw new RuntimeException("Unable to decrypt : "+toDecrypt,e);
|
|
}
|
|
}
|
|
//
|
|
//
|
|
// private static String getgCubeBaseEndpoint(String category,String name) {
|
|
//
|
|
// SimpleQuery query = queryFor(ServiceEndpoint.class);
|
|
//
|
|
// query.addCondition("$resource/Profile/Category/text() eq '"+category+"'")
|
|
// .addCondition("$resource/Profile/Name/text() eq '"+name+"'");
|
|
// DiscoveryClient<ServiceEndpoint> client = clientFor(ServiceEndpoint.class);
|
|
//
|
|
// AccessPoint point=client.submit(query).get(0).profile().accessPoints().asCollection().iterator().next();
|
|
//
|
|
// return point.address();
|
|
// }
|
|
|
|
}
|