115 lines
4.9 KiB
Java
115 lines
4.9 KiB
Java
package org.gcube.dataanalysis.wps.mapper;
|
|
|
|
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.clientFor;
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.queryFor;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
|
|
import org.gcube.common.encryption.StringEncrypter;
|
|
import org.gcube.common.resources.gcore.GenericResource;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.AccessPoint;
|
|
import org.gcube.common.scope.api.ScopeProvider;
|
|
import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
|
|
import org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration;
|
|
import org.gcube.dataanalysis.wps.statisticalmanager.synchserver.infrastructure.DatabaseInfo;
|
|
import org.gcube.informationsystem.publisher.RegistryPublisher;
|
|
import org.gcube.informationsystem.publisher.RegistryPublisherFactory;
|
|
import org.gcube.resources.discovery.client.api.DiscoveryClient;
|
|
import org.gcube.resources.discovery.client.queries.api.SimpleQuery;
|
|
|
|
public class InfrastructureDialoguer {
|
|
public String scope;
|
|
|
|
public InfrastructureDialoguer(String scope){
|
|
|
|
this.scope = scope;
|
|
}
|
|
|
|
public DatabaseInfo getDatabaseInfo(String resourceName) throws Exception{
|
|
DatabaseInfo dbi = new DatabaseInfo();
|
|
AnalysisLogger.getLogger().debug("Searching for Database "+resourceName+" in scope "+scope);
|
|
SimpleQuery query = queryFor(ServiceEndpoint.class);
|
|
// query.addCondition("$resource/Profile/Category/text() eq 'Database' and $resource/Profile/Name eq 'StatisticalManagerDataBase' ");
|
|
// query.addCondition("$resource/Profile/Category/text() eq 'Database' and $resource/Profile/Name eq '"+resourceName+"' ");
|
|
query.addCondition("$resource/Profile/Name eq '"+resourceName+"' ");
|
|
DiscoveryClient<ServiceEndpoint> client = clientFor(ServiceEndpoint.class);
|
|
List<ServiceEndpoint> resources = client.submit(query);
|
|
if (resources==null || resources.size()==0){
|
|
throw new Exception("No resource named "+resourceName+" available in scope "+scope);
|
|
}
|
|
else{
|
|
AccessPoint ap = resources.get(0).profile().accessPoints().iterator().next();
|
|
dbi.url = ap.address();
|
|
dbi.username = ap.username();
|
|
dbi.password = StringEncrypter.getEncrypter().decrypt(ap.password().trim());
|
|
|
|
for (ServiceEndpoint.Property property:ap.properties()){
|
|
if (property.name().equalsIgnoreCase("driver"))
|
|
dbi.driver = property.value();
|
|
}
|
|
|
|
AnalysisLogger.getLogger().debug("Found Database : "+dbi);
|
|
}
|
|
|
|
if (dbi.url == null)
|
|
throw new Exception("No database URL for resource "+resourceName+" available in scope "+scope);
|
|
return dbi;
|
|
|
|
}
|
|
|
|
public void deleteAlgorithmInScope(String algorithmName, String secondaryType) throws Exception{
|
|
System.out.println("Searching for Algorithms in scope "+scope);
|
|
SimpleQuery query = queryFor(GenericResource.class);
|
|
query.addCondition("$resource/Profile/SecondaryType eq '"+secondaryType+"' ");
|
|
|
|
DiscoveryClient<GenericResource> client = clientFor(GenericResource.class);
|
|
List<GenericResource> resources = client.submit(query);
|
|
if (resources==null || resources.size()==0){
|
|
System.out.println("No resource named "+secondaryType+"/"+algorithmName+" available in scope "+scope);
|
|
return;
|
|
}
|
|
System.out.println("Found "+resources.size()+" resources");
|
|
for (GenericResource resource: resources){
|
|
if (resource.profile().name().equals(algorithmName)){
|
|
System.out.println("Removing Algorithm "+algorithmName);
|
|
RegistryPublisher rp = RegistryPublisherFactory.create();
|
|
rp.remove(resource);
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
public List<String> getAlgorithmsInScope(String secondaryType) throws Exception{
|
|
AnalysisLogger.getLogger().debug("Searching for Algorithms in scope "+scope);
|
|
SimpleQuery query = queryFor(GenericResource.class);
|
|
query.addCondition("$resource/Profile/SecondaryType eq '"+secondaryType+"' ");
|
|
|
|
DiscoveryClient<GenericResource> client = clientFor(GenericResource.class);
|
|
List<GenericResource> resources = client.submit(query);
|
|
if (resources==null || resources.size()==0){
|
|
System.out.println("WARNING: No resource named StatisticalManagerAlgorithm available in scope "+scope);
|
|
return new ArrayList<String>();
|
|
}
|
|
List<String> resourcesNames = new ArrayList<String>();
|
|
AnalysisLogger.getLogger().debug("Found "+resources.size()+" resources");
|
|
for (GenericResource resource: resources){
|
|
resourcesNames.add(resource.profile().name());
|
|
}
|
|
return resourcesNames;
|
|
|
|
}
|
|
|
|
public static void main(String[] args) throws Exception{
|
|
AnalysisLogger.setLogger("cfg/"
|
|
+ AlgorithmConfiguration.defaultLoggerFile);
|
|
InfrastructureDialoguer dialoguer = new InfrastructureDialoguer("/gcube/devsec/devVRE");
|
|
// dialoguer.getDatabaseInfo("StatisticalManagerDataBase");
|
|
dialoguer.getDatabaseInfo("FishBase");
|
|
|
|
}
|
|
|
|
}
|