Implement getServices() filter.

Nathanael Jourdane
1 parent 4b3a296c
Showing 3 changed files with 35 additions and 11 deletions Show diff stats
src/main/java/eu/omp/irap/vespa/epntapclient/EpnTapFacade.java
src/main/java/eu/omp/irap/vespa/epntapclient/voresource/VOResourceCtrl.java
src/test/java/eu/omp/irap/vespa/epntapclient/TestEpnTapFacade.java
@@ -115,15 +115,43 @@ public class EpnTapFacade implements EpnTapInterface {
 	@Override
 	public List<VOTABLE> getEPNServices(List<String> attributes)
 			throws CantGetVOTableException, VOResourceException {
-		// TODO process attributes
-		return null;
+		List<VOTABLE> voTables = new ArrayList<>();
+		List<String> ivoids = VOResourceCtrl.getIvoidResources(ServiceCore.EPNCORE);
+		// TODO: optimiser le nombre de requêtes
+		for (String ivoid : ivoids) {
+			try {
+				String tableName = getEPNCoreTableName(ivoid);
+				String query = String.format(Queries.SELECT_FROM, StringJoiner.join(attributes),
+						tableName);
+				VOTableController ctrl = new VOTableController(getTAPURL(ivoid), query);
+				ctrl.readTable();
+				voTables.add(ctrl.getVOTable());
+			} catch (CantGetVOTableException e) {
+				logger.info("Can not get the service " + ivoid + ", skipping...");
+			}
+		}
+		return voTables;
 	}
 	@Override
 	public List<VOTABLE> getEPNServices(Map<String, String> keywords, List<String> attributes)
 			throws CantGetVOTableException, VOResourceException {
-		// TODO process attributes and keywords
-		return null;
+		List<VOTABLE> voTables = new ArrayList<>();
+		List<String> ivoids = VOResourceCtrl.getIvoidResources(ServiceCore.EPNCORE, keywords);
+		// TODO: optimiser le nombre de requêtes
+		for (String ivoid : ivoids) {
+			try {
+				String tableName = getEPNCoreTableName(ivoid);
+				String query = String.format(Queries.SELECT_FROM, StringJoiner.join(attributes),
+						tableName);
+				VOTableController ctrl = new VOTableController(getTAPURL(ivoid), query);
+				ctrl.readTable();
+				voTables.add(ctrl.getVOTable());
+			} catch (CantGetVOTableException e) {
+				logger.info("Can not get the service " + ivoid + ", skipping...");
+			}
+		}
+		return voTables;
 	}
 	// *** Getters ***
@@ -98,7 +98,6 @@ public class VOResourceCtrl {
 		parameters.put("keywords", keywordJoiner.toString());
 		parameters.put("max", String.valueOf(VOResourceCtrl.MAX_VORESOURCES));
 		String query = Network.buildQuery(GET_IVOID_RESOURCES_URL, parameters);
-		System.out.println(query);
 		try {
 			ivoidResources = parseIvoidResources(Network.readJson(query));
 		} catch (CantSendQueryException e) {
@@ -94,17 +94,14 @@ public class TestEpnTapFacade {
 			System.out.println("\n*** 4. Services ***\n");
 			List<VOTABLE> epnServices = facade.getEPNServices();
-			System.out.println("4.1 getEPNServices()\n\t"
-					+ Debug.toJson(epnServices));
+			System.out.println("4.1 getEPNServices()\n\t");
 			List<VOTABLE> epnServices2 = facade.getEPNServices(SERVICE_ATTRIBUTES);
-			System.out.println("4.2 getEPNServices(" + strServiceAttributes + ")\n\t"
-					+ Debug.toJson(epnServices2));
+			System.out.println("4.2 getEPNServices(" + strServiceAttributes + ")\n\t");
 			List<VOTABLE> epnServices3 = facade.getEPNServices(KEYWORDS, SERVICE_ATTRIBUTES);
 			System.out.println("4.3 getEPNServices(" + strKeywords + ", "
-					+ strServiceAttributes + ")\n\t"
-					+ Debug.toJson(epnServices3));
+					+ strServiceAttributes + ")\n\t");
 			System.out.println("\n*** 5. Getters***\n");