TASK-6442 - Add Resources Management functionality

opencga-analysis/src/main/java/org/opencb/opencga/analysis/AnalysisUtils.java

@@ -1,15 +1,21 @@
 package org.opencb.opencga.analysis;
 
+import org.apache.commons.collections4.CollectionUtils;
 import org.opencb.commons.datastore.core.Query;
 import org.opencb.commons.datastore.core.QueryOptions;
 import org.opencb.opencga.catalog.db.api.FileDBAdaptor;
+import org.opencb.opencga.catalog.db.api.ProjectDBAdaptor;
 import org.opencb.opencga.catalog.exceptions.CatalogException;
+import org.opencb.opencga.catalog.managers.CatalogManager;
 import org.opencb.opencga.catalog.managers.FileManager;
 import org.opencb.opencga.catalog.managers.JobManager;
+import org.opencb.opencga.catalog.utils.CatalogFqn;
 import org.opencb.opencga.core.exceptions.ToolException;
+import org.opencb.opencga.core.models.JwtPayload;
 import org.opencb.opencga.core.models.common.Enums;
 import org.opencb.opencga.core.models.file.File;
 import org.opencb.opencga.core.models.job.Job;
+import org.opencb.opencga.core.models.project.Project;
 import org.opencb.opencga.core.response.OpenCGAResult;
 
 import java.io.BufferedReader;
@@ -193,4 +199,22 @@ public static String getJobFileRelativePath(String path) {
         }
         return path.substring(index + 5);
     }
+
+    public static String getAssembly(CatalogManager catalogManager, String studyId, String sessionId) throws CatalogException {
+        String assembly = "";
+        OpenCGAResult<Project> projectQueryResult;
+
+        JwtPayload jwtPayload = catalogManager.getUserManager().validateToken(sessionId);
+        CatalogFqn studyFqn = CatalogFqn.extractFqnFromStudy(studyId, jwtPayload);
+        String organizationId = studyFqn.getOrganizationId();
+
+        projectQueryResult = catalogManager.getProjectManager().search(organizationId, new Query(ProjectDBAdaptor.QueryParams.STUDY.key(), studyId),
+                new QueryOptions(QueryOptions.INCLUDE, ProjectDBAdaptor.QueryParams.ORGANISM.key()), sessionId);
+        if (CollectionUtils.isNotEmpty(projectQueryResult.getResults())
+                && projectQueryResult.first().getOrganism() != null
+                && projectQueryResult.first().getOrganism().getAssembly() != null) {
+            assembly = projectQueryResult.first().getOrganism().getAssembly();
+        }
+        return assembly;
+    }
 }

opencga-analysis/src/main/java/org/opencb/opencga/analysis/ConfigurationUtils.java

@@ -121,4 +121,27 @@ public static String getToolDefaultVersion(String toolId, Configuration configur
         }
         return defaultVersion;
     }
+
+
+    public static AnalysisTool getAnalysisTool(String toolId, String version, Configuration configuration) throws ToolException {
+        for (AnalysisTool tool : configuration.getAnalysis().getTools()) {
+            if (toolId.equals(tool.getId())) {
+                if (StringUtils.isEmpty(version) || version.equals(tool.getVersion())) {
+                    return tool;
+                }
+            }
+        }
+        throw new ToolException("Missing analysis tool (ID = " + toolId + ", version = " + version + ") in configuration file");
+    }
+
+    public static String getToolResource(String toolId, String version, String resourceKey, Configuration configuration)
+            throws ToolException {
+        // Get resources from the configuration file
+        AnalysisTool tool = ConfigurationUtils.getAnalysisTool(toolId, version, configuration);
+        if (!tool.getResources().containsKey(resourceKey)) {
+            throw new ToolException("Error getting resource " + resourceKey + " of analysis tool (ID = " + toolId + ", version =  "
+                    + version + "): it does not exist in the configuration file");
+        }
+        return tool.getResources().get(resourceKey);
+    }
 }