diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/AlgorithmPackage.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/AlgorithmPackage.java index 07bb33a..d84f27c 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/AlgorithmPackage.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/AlgorithmPackage.java @@ -10,13 +10,19 @@ import java.util.Vector; import org.gcube.dataanalysis.dataminer.poolmanager.ansible.model.Role; import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Algorithm; import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Dependency; +***REMOVED*** +***REMOVED*** public class AlgorithmPackage { private Algorithm algorithm; private boolean includeAlgorithmDependencies; - public AlgorithmPackage(Algorithm a,boolean includeAlgorithmDependencies) { - this.algorithm = a; + private Logger logger; + + public AlgorithmPackage(Algorithm a,boolean includeAlgorithmDependencies) + { + this.logger = LoggerFactory.getLogger(AlgorithmPackage.class); + this.algorithm = a; this.includeAlgorithmDependencies = includeAlgorithmDependencies; ***REMOVED*** @@ -61,12 +67,13 @@ public class AlgorithmPackage { Role r = tm.fillRoleTemplate(template, dictionary); r.setName(roleName); out.add(r); - ***REMOVED*** else { - System.out.println("WARNING: template is null"); + ***REMOVED*** else + { + this.logger.warn("WARNING: template is null"); ***REMOVED*** ***REMOVED*** catch (NoSuchElementException e) { ***REMOVED*** e.printStackTrace(); - System.out.println("WARNING: no template found for " + roleName); + this.logger.warn("WARNING: no template found for " + roleName); ***REMOVED*** ***REMOVED*** return out; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/CustomDependencyPackage.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/CustomDependencyPackage.java index 466c688..3fe1c36 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/CustomDependencyPackage.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/CustomDependencyPackage.java @@ -6,16 +6,20 @@ import java.util.Vector; import org.gcube.dataanalysis.dataminer.poolmanager.ansible.model.Role; import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Dependency; +***REMOVED*** public class CustomDependencyPackage extends DependencyPackage { - public CustomDependencyPackage(Dependency d) { - super(d); +***REMOVED*** + + public CustomDependencyPackage(Dependency dependency) + { + super(dependency); ***REMOVED*** - private String getCustomRepositoryLocation(String ansibleRoot) { - return ansibleRoot+"/custom"; - ***REMOVED*** +***REMOVED*** private String getCustomRepositoryLocation(String ansibleRoot) { +***REMOVED*** return ansibleRoot+"/custom"; +***REMOVED*** ***REMOVED*** /* public void serializeTo(String ansibleRoot) { @@ -54,7 +58,7 @@ public class CustomDependencyPackage extends DependencyPackage { ***REMOVED*** ***REMOVED*** catch (NoSuchElementException e) { ***REMOVED*** e.printStackTrace(); - System.out.println("WARNING: no custom role found for " + roleName); + this.logger.warn("WARNING: no custom role found for " + roleName); ***REMOVED*** ***REMOVED*** return out; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/CustomRoleManager.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/CustomRoleManager.java index b16805f..80490ad 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/CustomRoleManager.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/CustomRoleManager.java @@ -10,11 +10,7 @@ import org.gcube.dataanalysis.dataminer.poolmanager.ansiblebridge.AnsibleSeriali public class CustomRoleManager { - private String root; - public CustomRoleManager() { - - ***REMOVED*** public String getRoot() { String input = AnsibleBridge.class.getClassLoader().getResource("custom").getPath(); diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/DependencyPackage.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/DependencyPackage.java index a4445cc..6bf00bf 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/DependencyPackage.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/DependencyPackage.java @@ -8,13 +8,18 @@ import java.util.Vector; import org.gcube.dataanalysis.dataminer.poolmanager.ansible.model.Role; import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Dependency; +***REMOVED*** +***REMOVED*** public class DependencyPackage { +***REMOVED*** + private Dependency dependency; - public DependencyPackage(Dependency d) { - this.dependency = d; + public DependencyPackage(Dependency dependency) { + this.dependency = dependency; + this.logger = LoggerFactory.getLogger(DependencyPackage.class); ***REMOVED*** protected Map getDictionary(Dependency d) { @@ -42,11 +47,11 @@ public class DependencyPackage { r.setName(roleName); out.add(r); ***REMOVED*** else { - System.out.println("WARNING: template is null"); + this.logger.warn("WARNING: template is null"); ***REMOVED*** ***REMOVED*** catch (NoSuchElementException e) { ***REMOVED*** e.printStackTrace(); - System.out.println("WARNING: no template found for " + roleName); + this.logger.warn("WARNING: no template found for " + roleName); ***REMOVED*** ***REMOVED*** return out; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/OSDependencyPackage.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/OSDependencyPackage.java index 6c93efd..e816641 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/OSDependencyPackage.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/OSDependencyPackage.java @@ -4,8 +4,8 @@ import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Dependency; public class OSDependencyPackage extends DependencyPackage { - public OSDependencyPackage(Dependency d) { - super(d); + public OSDependencyPackage(Dependency dependency) { + super(dependency); ***REMOVED*** ***REMOVED*** diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/StaticRoleManager.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/StaticRoleManager.java index ece553e..6f88500 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/StaticRoleManager.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/ansiblebridge/template/StaticRoleManager.java @@ -2,7 +2,6 @@ package org.gcube.dataanalysis.dataminer.poolmanager.ansiblebridge.template; import java.io.File; ***REMOVED*** -import java.io.InputStream; import java.util.Collection; import java.util.Vector; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/ISClient.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/ISClient.java index 9d79512..e413782 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/ISClient.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/ISClient.java @@ -4,28 +4,10 @@ import static org.gcube.resources.discovery.icclient.ICFactory.clientFor; import static org.gcube.resources.discovery.icclient.ICFactory.queryFor; ***REMOVED*** -import java.io.ByteArrayOutputStream; -import java.io.File; -***REMOVED*** -import java.io.InputStream; -***REMOVED*** -import java.io.PrintStream; import java.io.StringWriter; -import java.net.MalformedURLException; -***REMOVED*** -import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; -import java.util.Collections; -import java.util.HashSet; -import java.util.LinkedHashMap; ***REMOVED*** -***REMOVED*** -import java.util.Map; -import java.util.Scanner; -import java.util.Set; -import java.util.TreeMap; -import java.util.TreeSet; import java.util.Vector; ***REMOVED*** @@ -35,11 +17,6 @@ import org.gcube.common.resources.gcore.ServiceEndpoint; ***REMOVED*** import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Algorithm; ***REMOVED*** -import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Dependency; -import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Domain; -***REMOVED*** -import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.comparator.HostComparator; -import org.gcube.dataanalysis.dataminer.poolmanager.service.DataminerPoolManager; import org.gcube.informationsystem.publisher.AdvancedScopedPublisher; import org.gcube.informationsystem.publisher.RegistryPublisherFactory; import org.gcube.informationsystem.publisher.ScopedPublisher; @@ -48,24 +25,15 @@ import org.gcube.resources.discovery.client.api.DiscoveryClient; import org.gcube.resources.discovery.client.queries.api.SimpleQuery; ***REMOVED*** ***REMOVED*** -import org.tmatesoft.svn.core.SVNDepth; import org.tmatesoft.svn.core.SVNException; -import org.tmatesoft.svn.core.SVNURL; -import org.tmatesoft.svn.core.auth.ISVNAuthenticationManager; -import org.tmatesoft.svn.core.internal.io.dav.DAVRepositoryFactory; -import org.tmatesoft.svn.core.io.SVNRepository; -import org.tmatesoft.svn.core.io.SVNRepositoryFactory; -import org.tmatesoft.svn.core.wc.ISVNOptions; -import org.tmatesoft.svn.core.wc.SVNClientManager; -import org.tmatesoft.svn.core.wc.SVNRevision; -import org.tmatesoft.svn.core.wc.SVNUpdateClient; -import org.tmatesoft.svn.core.wc.SVNWCUtil; - -***REMOVED*** public class ISClient { - private static final Logger LOGGER = LoggerFactory.getLogger(ISClient.class); +***REMOVED*** + public ISClient() { + this.logger = LoggerFactory.getLogger(ISClient.class); +***REMOVED*** + public Host getDataminer(String hostname) { Host h = new Host(); @@ -196,11 +164,11 @@ public class ISClient { ScopedPublisher scopedPublisher = RegistryPublisherFactory.scopedPublisher(); AdvancedScopedPublisher advancedScopedPublisher = new AdvancedScopedPublisher(scopedPublisher); String id = resource.id(); - LOGGER.debug("Trying to remove {***REMOVED*** with ID {***REMOVED*** from {***REMOVED***", resource.getClass().getSimpleName(), id, + this.logger.info("Trying to remove {***REMOVED*** with ID {***REMOVED*** from {***REMOVED***", resource.getClass().getSimpleName(), id, ScopeProvider.instance.get()); ***REMOVED*** scopedPublisher.remove(resource, scopes); advancedScopedPublisher.forceRemove(resource); - LOGGER.debug("{***REMOVED*** with ID {***REMOVED*** removed successfully", resource.getClass().getSimpleName(), id); + this.logger.info("{***REMOVED*** with ID {***REMOVED*** removed successfully", resource.getClass().getSimpleName(), id); ***REMOVED*** public void publishScopedResource(GenericResource a, List scopes) @@ -210,11 +178,11 @@ public class ISClient { ScopedPublisher scopedPublisher = RegistryPublisherFactory.scopedPublisher(); try { - System.out.println(scopes); - System.out.println(stringWriter); + this.logger.debug(scopes.toString()); + this.logger.debug(stringWriter.toString()); scopedPublisher.create(a, scopes); ***REMOVED*** catch (RegistryNotFoundException e) { - System.out.println(e); + this.logger.error("Registry not found",e); throw e; ***REMOVED*** ***REMOVED*** diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/configuration/DMPMClientConfiguratorManager.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/configuration/DMPMClientConfiguratorManager.java index 1ad903e..f97a4a5 100755 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/configuration/DMPMClientConfiguratorManager.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/configuration/DMPMClientConfiguratorManager.java @@ -11,7 +11,8 @@ import org.gcube.dataanalysis.dataminer.poolmanager.clients.configuration.Config ***REMOVED*** import org.tmatesoft.svn.core.SVNException; -public class DMPMClientConfiguratorManager{ +public class DMPMClientConfiguratorManager +{ private final Logger logger; private Properties defaultAdmins; private String admins; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/configurations/AbstractConfiguration.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/configurations/AbstractConfiguration.java index 8ac90f4..7233e1b 100755 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/configurations/AbstractConfiguration.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/clients/configurations/AbstractConfiguration.java @@ -3,36 +3,21 @@ package org.gcube.dataanalysis.dataminer.poolmanager.clients.configurations; import javax.xml.bind.annotation.XmlElement; -public abstract class AbstractConfiguration { - - - - +public abstract class AbstractConfiguration +{ private String host; - private String algorithmsList; - private String softwareRepo; - private String ghostRepo; - private String depsLinuxCompiled; - private String depsPreInstalled; - private String depsRBlackbox; - private String depsR; - private String depsJava; - private String depsKnimeWorkflow; - private String depsOctave; - private String depsPython; - private String depsWindowsCompiled; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Action.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Action.java index 5c69bdf..c4ef421 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Action.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Action.java @@ -3,9 +3,7 @@ package org.gcube.dataanalysis.dataminer.poolmanager.datamodel; public class Action { private String name; - private String description; - private String script; public String getName() { diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Algorithm.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Algorithm.java index 1452949..a85f359 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Algorithm.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Algorithm.java @@ -9,36 +9,24 @@ import java.util.Vector; public class Algorithm { - private String username; - + private String username; private String fullname; - private String email; - private String language; - private String name; - private String description; - private String clazz; - private String category; - private String algorithmType; - private String skipJava; - private String packageURL; - private Collection actions; - private Collection dependencies; public Algorithm() { this.actions = new Vector<>(); this.dependencies = new Vector<>(); - Dependency p = new Dependency(); + ***REMOVED*** Dependency p = new Dependency(); ***REMOVED***init with default values this.skipJava = "N"; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/AlgorithmSet.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/AlgorithmSet.java index 4a5bf3f..f42c11c 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/AlgorithmSet.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/AlgorithmSet.java @@ -6,39 +6,46 @@ import java.util.Vector; public class AlgorithmSet { private String name; - private Collection algorithms; - public AlgorithmSet() { + public AlgorithmSet() + { this.algorithms = new Vector<>(); ***REMOVED*** - public String getName() { + public String getName() + { return name; ***REMOVED*** - public void setName(String name) { + public void setName(String name) + { this.name = name; ***REMOVED*** - public Collection getAlgorithms() { + public Collection getAlgorithms() + { return new Vector<>(algorithms); ***REMOVED*** - public void addAlgorithm(Algorithm algoritm) { + public void addAlgorithm(Algorithm algoritm) + { this.algorithms.add(algoritm); ***REMOVED*** - public Boolean hasAlgorithm(Algorithm algorithm) { + public Boolean hasAlgorithm(Algorithm algorithm) + { for (Algorithm a : this.algorithms) { - if (a.getName().equals(algorithm.getName())) { + if (a.getName().equals(algorithm.getName())) + { return true; ***REMOVED*** ***REMOVED*** return false; ***REMOVED*** - public String toString() { + public String toString() + { String out = "ALGOSET: " + this.name + "\n"; for(Algorithm a:this.algorithms) { out+=a+"\n"; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Cluster.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Cluster.java index 9a704d9..50e4039 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Cluster.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Cluster.java @@ -25,40 +25,49 @@ public class Cluster { */ private Collection algoSets; - public Cluster() { + public Cluster() + { this.hosts = new Vector<>(); this.algoSets = new Vector<>(); ***REMOVED*** - public void addAlgorithmSet(AlgorithmSet set) { + public void addAlgorithmSet(AlgorithmSet set) + { this.algoSets.add(set); ***REMOVED*** - public void addHost(Host host) { + public void addHost(Host host) + { this.hosts.add(host); ***REMOVED*** - public Collection getHosts() { + public Collection getHosts() + { return hosts; ***REMOVED*** - public String getName() { + public String getName() + { return name; ***REMOVED*** - public void setName(String name) { + public void setName(String name) + { this.name = name; ***REMOVED*** - public String getDescription() { + public String getDescription() + { return description; ***REMOVED*** - public void setDescription(String description) { + public void setDescription(String description) + { this.description = description; ***REMOVED*** - public Collection getAlgorithmSets() { + public Collection getAlgorithmSets() + { return algoSets; ***REMOVED*** diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Dependency.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Dependency.java index 7c083ab..d6f22ee 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Dependency.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Dependency.java @@ -3,10 +3,10 @@ package org.gcube.dataanalysis.dataminer.poolmanager.datamodel; public class Dependency { private String name; - private String type; - public String getName() { + public String getName() + { return name; ***REMOVED*** diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Host.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Host.java index c13b941..20ac71c 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Host.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/datamodel/Host.java @@ -11,7 +11,7 @@ public class Host { ***REMOVED*** public Host() { - ***REMOVED*** TODO Auto-generated constructor stub + ***REMOVED*** public String getFullyQualifiedName() { diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/process/AlgorithmPackageParser.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/process/AlgorithmPackageParser.java index 9c5da00..fd29714 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/process/AlgorithmPackageParser.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/process/AlgorithmPackageParser.java @@ -10,9 +10,10 @@ import java.util.Vector; import java.util.zip.ZipEntry; import java.util.zip.ZipInputStream; -import org.apache.commons.lang.StringEscapeUtils; import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Algorithm; import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Dependency; +***REMOVED*** +***REMOVED*** public class AlgorithmPackageParser { @@ -20,35 +21,32 @@ public class AlgorithmPackageParser { * The name of the file containing algorithm metadata. Expected in the root * directory of the package. */ - private static final String METADATA_FILE_NAME = "Info.txt"; + private final String METADATA_FILE_NAME = "Info.txt", + METADATA_USERNAME = "Username", + METADATA_FULLNAME = "Full Name", + METADATA_EMAIL = "Email", + METADATA_LANGUAGE = "Language", + METADATA_CATEGORY = "Algorithm Category", + METADATA_ALGORITHM_NAME = "Algorithm Name", + METADATA_ALGORITHM_DESCRIPTION = "Algorithm Description", + METADATA_CLASS_NAME = "Class Name", - private static final String METADATA_USERNAME = "Username"; + ***REMOVED*** private static final String METADATA_PACKAGES = "Packages"; - private static final String METADATA_FULLNAME = "Full Name"; + METADATA_KEY_VALUE_SEPARATOR = ":"; - private static final String METADATA_EMAIL = "Email"; + private final int BUFFER_SIZE = 4096; + + private Logger logger; - private static final String METADATA_LANGUAGE = "Language"; - - private static final String METADATA_CATEGORY = "Algorithm Category"; - - private static final String METADATA_ALGORITHM_NAME = "Algorithm Name"; - - private static final String METADATA_ALGORITHM_DESCRIPTION = "Algorithm Description"; - - private static final String METADATA_CLASS_NAME = "Class Name"; - - private static final String METADATA_PACKAGES = "Packages"; - - private static final String METADATA_KEY_VALUE_SEPARATOR = ":"; - - private static final int BUFFER_SIZE = 4096; - + public AlgorithmPackageParser() { + this.logger = LoggerFactory.getLogger(AlgorithmPackageParser.class); + ***REMOVED*** public Algorithm parsePackage(String url) throws IOException { String packageMetadata = this.getPackageMetadata(url); if (packageMetadata == null) { - System.out.println("WARNING: No metadata found for " + url); + this.logger.warn("WARNING: No metadata found for " + url); return null; ***REMOVED*** else { Map> parsedMetadata = this.parseMetadata(packageMetadata); @@ -125,7 +123,7 @@ public class AlgorithmPackageParser { out.put(key, values); ***REMOVED*** values.add(value); - System.out.println(key + METADATA_KEY_VALUE_SEPARATOR + " " + values); + this.logger.debug(key + METADATA_KEY_VALUE_SEPARATOR + " " + values); ***REMOVED*** ***REMOVED*** return out; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/rest/PoolManager.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/rest/PoolManager.java index dccb4f5..353f52a 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/rest/PoolManager.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/rest/PoolManager.java @@ -35,18 +35,17 @@ import java.net.UnknownHostException; import java.util.Set; import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Algorithm; -import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.AlgorithmSet; import org.tmatesoft.svn.core.SVNException; -public interface PoolManager { - - String addAlgorithmToVRE(Algorithm algo, String vre, boolean test ) throws IOException, InterruptedException; - String addAlgorithmToHost(Algorithm algo, String host,boolean test) throws IOException, InterruptedException; +public interface PoolManager +{ + String addAlgorithmToVRE(Algorithm algo, String vre, boolean test ) throws IOException, InterruptedException; + String addAlgorithmToHost(Algorithm algo, String host,boolean test) throws IOException, InterruptedException; String stageAlgorithm(String algorithmPackageURL) throws IOException, InterruptedException; - String publishAlgorithm(String algorithmPackageURL, String targetVREToken, String targetVRE) throws IOException, InterruptedException; + String publishAlgorithm(String algorithmPackageURL, String targetVREToken, String targetVRE) throws IOException, InterruptedException; Algorithm extractAlgorithm(String url) throws IOException; @@ -61,6 +60,7 @@ public interface PoolManager { void addAlgToIs(Algorithm algo); Set getAlgoFromIs(); + List updateSVN(String file, List ldep) throws SVNException, IOException; diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/rest/RestPoolManager.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/rest/RestPoolManager.java index 6ab95b7..64d57c1 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/rest/RestPoolManager.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/rest/RestPoolManager.java @@ -24,20 +24,18 @@ import org.gcube.dataanalysis.dataminer.poolmanager.util.AlgorithmBuilder; import org.tmatesoft.svn.core.SVNException; @Path("/") -public class RestPoolManager implements PoolManager { - - - +public class RestPoolManager implements PoolManager +{ ***REMOVED***@Context ServletContext context; private final Logger logger; - private DataminerPoolManager service; ***REMOVED***@Context ***REMOVED***private ApplicationContext context = ContextProvider.get(); - public RestPoolManager() { + public RestPoolManager() + { this.logger = LoggerFactory.getLogger(RestPoolManager.class); this.service = new DataminerPoolManager(); diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java index 1b005c5..3442b21 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java @@ -30,7 +30,7 @@ public class DataminerPoolManager { this.svnUpdaterStaging = new SVNUpdaterStaging(); this.svnUpdaterProduction = new SVNUpdaterProduction(); ***REMOVED*** catch (SVNException e) { - e.printStackTrace(); + this.logger.error("SVN Exception",e); ***REMOVED*** ***REMOVED*** diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckMethod.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckMethod.java index 0564cd6..864efde 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckMethod.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckMethod.java @@ -81,7 +81,6 @@ public abstract class CheckMethod { String operatorName = line.substring(line.indexOf(">") + 1); operatorName = operatorName.substring(0, operatorName.indexOf("<")); this.logger.debug("Operator "+operatorName); - System.out.println(" " + operatorName); URL innerRequestURL = new URL(baseDescriptionRequest + operatorName); BufferedReader innerBufferedReader = new BufferedReader( new InputStreamReader(innerRequestURL.openStream())); @@ -225,12 +224,9 @@ public abstract class CheckMethod { session.connect(); Channel channel = session.openChannel(SFTP_PROTOCOL); channel.connect(); - System.out.println("shell channel connected...."); - + this.logger.debug("shell channel connected...."); ChannelSftp c = (ChannelSftp) channel; - - - System.out.println(path); + this.logger.debug(path); try { c.lstat(path); diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckPermission.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckPermission.java index 23fddb9..b5a3bb0 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckPermission.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckPermission.java @@ -4,21 +4,24 @@ import static org.gcube.common.authorization.client.Constants.authorizationServi ***REMOVED*** import org.gcube.common.authorization.library.AuthorizationEntry; +***REMOVED*** +***REMOVED*** public class CheckPermission { - public CheckPermission() { -***REMOVED*** + private static final Logger logger = LoggerFactory.getLogger(CheckPermission.class); + - public static boolean apply(String VREToken, String vre) throws ObjectNotFound, Exception { - + + public static boolean apply(String VREToken, String vre) throws ObjectNotFound, Exception + { AuthorizationEntry entry = authorizationService().get(VREToken); if (entry.getContext().equals(vre)) { - System.out.println("Authorization OK!"); + logger.info("Authorization OK!"); return true; ***REMOVED*** - System.out.println("Not a valid token recognized for the VRE: "+vre); + logger.info("Not a valid token recognized for the VRE: "+vre); return false; ***REMOVED*** diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SVNUpdater.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SVNUpdater.java index 0d2c1fa..4ee7b43 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SVNUpdater.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SVNUpdater.java @@ -310,7 +310,7 @@ public abstract class SVNUpdater { sb.append("none | "); sb.append(this.getTimeZone() + " | "); - System.out.println("Algo details: "+sb.toString()); + this.logger.info("Algo details: "+sb.toString()); return sb.toString(); ***REMOVED*** @@ -419,7 +419,7 @@ public abstract class SVNUpdater { boolean check = false; try { - System.out.println("Checking dependencies list: " + file); + this.logger.info("Checking dependencies list: " + file); final ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); svnRepository.getFile(file, SVNRepository.INVALID_REVISION, null, byteArrayOutputStream); String lines[] = byteArrayOutputStream.toString().split("\\r?\\n"); @@ -448,8 +448,10 @@ public abstract class SVNUpdater { ***REMOVED*** ***REMOVED*** ***REMOVED*** ***REMOVED*** - ***REMOVED*** catch (Exception a) { - a.getMessage(); + ***REMOVED*** catch (Exception a) + { + this.logger.error(a.getMessage(),a); + ***REMOVED*** return check; @@ -458,7 +460,7 @@ public abstract class SVNUpdater { public void updateSVN(String file, Collection deps) { try { - System.out.println("Updating dependencies list: " + file); + this.logger.info("Updating dependencies list: " + file); final ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); svnRepository.getFile(file, SVNRepository.INVALID_REVISION, null, byteArrayOutputStream); @@ -537,7 +539,7 @@ public abstract class SVNUpdater { Date fromDate = formatter.parse(cal.getTime().toString()); TimeZone central = TimeZone.getTimeZone("UTC"); formatter.setTimeZone(central); - System.out.println(formatter.format(fromDate)); + this.logger.info(formatter.format(fromDate)); return formatter.format(fromDate); ***REMOVED*** diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SendMail.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SendMail.java index 4dc8400..9c933d3 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SendMail.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SendMail.java @@ -209,7 +209,7 @@ public class SendMail { HttpGet getReq = new HttpGet(serviceAddress); getReq.setHeader("accept", JSON_MIME_TYPE); getReq.setHeader("content-type", JSON_MIME_TYPE); - System.out.println(EntityUtils.toString(client.execute(getReq).getEntity())); + this.logger.info(EntityUtils.toString(client.execute(getReq).getEntity())); return EntityUtils.toString(client.execute(getReq).getEntity());