diff --git a/data-access/servlet/src/main/java/cutout/Reproject.java b/data-access/servlet/src/main/java/cutout/Reproject.java index 03d757149922ff11a777c8255ebd58140170abb8..4245798092a8787a3f229fc4c9ecf68855475e0e 100644 --- a/data-access/servlet/src/main/java/cutout/Reproject.java +++ b/data-access/servlet/src/main/java/cutout/Reproject.java @@ -8,9 +8,9 @@ class Reproject implements Runnable String prefix; String fileName; String[] response; - DatasetsAmqp datasets; + VlkbAmqp datasets; - public Reproject(DatasetsAmqp datasets, String id, String prefix, String fileName) + public Reproject(VlkbAmqp datasets, String id, String prefix, String fileName) { this.datasets = datasets; this.id = id; @@ -23,9 +23,9 @@ class Reproject implements Runnable public void run() { String name = Thread.currentThread().getName(); - DatasetsAmqp.LOGGER.info("Start of " + name); + VlkbAmqp.LOGGER.info("Start of " + name); response = datasets.mergefiles_reproject(id, prefix, fileName); - DatasetsAmqp.LOGGER.info("End of " + name); + VlkbAmqp.LOGGER.info("End of " + name); } } diff --git a/data-access/servlet/src/main/java/cutout/Datasets.java b/data-access/servlet/src/main/java/cutout/Vlkb.java similarity index 97% rename from data-access/servlet/src/main/java/cutout/Datasets.java rename to data-access/servlet/src/main/java/cutout/Vlkb.java index 7df294e85db8b63afc52ee1390cfcf389009f792..a4f3488b1917049b06dd23ad4a37d2c006ddb223 100644 --- a/data-access/servlet/src/main/java/cutout/Datasets.java +++ b/data-access/servlet/src/main/java/cutout/Vlkb.java @@ -11,7 +11,7 @@ import java.time.Instant;//Timestamp in cut-filename import vo.parameter.*; -public interface Datasets +public interface Vlkb { public CutResult doFile(String relPathname, int hdunum, Pos pos, Band band, Time time, Pol pol, String pixels, diff --git a/data-access/servlet/src/main/java/cutout/DatasetsAmqp.java b/data-access/servlet/src/main/java/cutout/VlkbAmqp.java similarity index 96% rename from data-access/servlet/src/main/java/cutout/DatasetsAmqp.java rename to data-access/servlet/src/main/java/cutout/VlkbAmqp.java index 95501ef7906ddd9017f37c53fd469d27f39961cd..10dfbf22f60395ad7cfd0f9397b7617853724d46 100644 --- a/data-access/servlet/src/main/java/cutout/DatasetsAmqp.java +++ b/data-access/servlet/src/main/java/cutout/VlkbAmqp.java @@ -27,30 +27,30 @@ import java.io.ByteArrayOutputStream; // for SODA direct streaming doSubimgStrea import vo.parameter.*; -class DatasetsAmqp implements Datasets +class VlkbAmqp implements Vlkb { - static final Logger LOGGER = Logger.getLogger(DatasetsAmqp.class.getName()); + static final Logger LOGGER = Logger.getLogger("VlkbAmqp"); private Settings settings = null; private Subsurvey[] subsurveys = null; - public DatasetsAmqp() + public VlkbAmqp() { - LOGGER.info("trace DatasetsAmqp()"); + LOGGER.info("trace VlkbAmqp()"); this.settings = Settings.getInstance(); } - public DatasetsAmqp(Settings settings) + public VlkbAmqp(Settings settings) { - LOGGER.info("trace DatasetsAmqp(settings)"); + LOGGER.info("trace VlkbAmqp(settings)"); this.settings = settings; } - public DatasetsAmqp(Settings settings, Subsurvey[] subsurveys) + public VlkbAmqp(Settings settings, Subsurvey[] subsurveys) { - LOGGER.info("trace DatasetsAmqp(settings, subsurveys)"); + LOGGER.info("trace VlkbAmqp(settings, subsurveys)"); this.settings = settings; this.subsurveys = subsurveys; } @@ -345,7 +345,7 @@ class DatasetsAmqp implements Datasets LOGGER.info("mergefiles_parallel()"); String[] responseCH = mergefiles_common_header(jobId, logfilename, prefix, filestomerge); - for(String sentence : responseCH) DatasetsAmqp.LOGGER.info("responseCmnHdr: " + sentence); + for(String sentence : responseCH) VlkbAmqp.LOGGER.info("responseCmnHdr: " + sentence); // check if response errored -> abort with 500: Internal Server Error & log details int threadsCount = filestomerge.length; @@ -377,7 +377,7 @@ class DatasetsAmqp implements Datasets } - for(String sentence : reprojectArr[i].response) DatasetsAmqp.LOGGER.info("response[" + String.valueOf(i) + "]: " + sentence); + for(String sentence : reprojectArr[i].response) VlkbAmqp.LOGGER.info("response[" + String.valueOf(i) + "]: " + sentence); if(!isResponseOk(reprojectArr[i].response)) { ;// FIXME response incorrect -> abort merge-job, free resources diff --git a/data-access/servlet/src/main/java/cutout/DatasetsCli.java b/data-access/servlet/src/main/java/cutout/VlkbCli.java similarity index 97% rename from data-access/servlet/src/main/java/cutout/DatasetsCli.java rename to data-access/servlet/src/main/java/cutout/VlkbCli.java index a3eba9023b32cd892e095be7e4a206bfcf48f06d..f0099489951061f2dc7e09652162d6c368217dd2 100644 --- a/data-access/servlet/src/main/java/cutout/DatasetsCli.java +++ b/data-access/servlet/src/main/java/cutout/VlkbCli.java @@ -37,33 +37,33 @@ import org.json.simple.JSONArray; import vo.parameter.*; -class DatasetsCli implements Datasets +class VlkbCli implements Vlkb { - static final Logger LOGGER = Logger.getLogger("DatasetsCli"); + static final Logger LOGGER = Logger.getLogger("VlkbCli"); private Settings settings = null; private Subsurvey[] subsurveys = null; private Soda soda = null; - public DatasetsCli() + public VlkbCli() { - LOGGER.info("trace DatasetsCli()"); + LOGGER.info("trace VlkbCli()"); this.settings = Settings.getInstance(); soda = new SodaImpl(settings, subsurveys); } - public DatasetsCli(Settings settings) + public VlkbCli(Settings settings) { - LOGGER.info("trace DatasetsCli(settings)"); + LOGGER.info("trace VlkbCli(settings)"); this.settings = settings; this.soda = new SodaImpl(settings, subsurveys); } - public DatasetsCli(Settings settings, Subsurvey[] subsurveys) + public VlkbCli(Settings settings, Subsurvey[] subsurveys) { - LOGGER.info("trace DatasetsCli(settings, subsurveys)"); + LOGGER.info("trace VlkbCli(settings, subsurveys)"); this.settings = settings; this.subsurveys = subsurveys; this.soda = new SodaImpl(settings, subsurveys); diff --git a/data-access/servlet/src/main/java/webapi/ServletCutout.java b/data-access/servlet/src/main/java/webapi/ServletCutout.java index b0567ce4a24368f19142236eeddb63fdfad6100b..e484d4a012cc4f2130598519b79284a2b845bd2b 100644 --- a/data-access/servlet/src/main/java/webapi/ServletCutout.java +++ b/data-access/servlet/src/main/java/webapi/ServletCutout.java @@ -60,7 +60,7 @@ public class ServletCutout extends javax.servlet.http.HttpServlet private Subsurvey[] subsurveys = null; protected Soda soda = new SodaImpl(settings, subsurveys); - protected Datasets datasets = ( settings.amqpConn.isHostnameEmpty() ? new DatasetsCli(settings): new DatasetsAmqp(settings) ); + protected Vlkb vlkb = ( settings.amqpConn.isHostnameEmpty() ? new VlkbCli(settings): new VlkbAmqp(settings) ); public void init() throws ServletException { @@ -136,7 +136,7 @@ public class ServletCutout extends javax.servlet.http.HttpServlet { LOGGER.info("trace"); - return datasets.doFileById(id, pos, band, time, pol, pixels, countNullValues, subsurveys); + return vlkb.doFileById(id, pos, band, time, pol, pixels, countNullValues, subsurveys); } diff --git a/data-access/servlet/src/main/java/webapi/ServletMCutout.java b/data-access/servlet/src/main/java/webapi/ServletMCutout.java index 28c878910a11c23dafe89c13c8d89bea36c439de..63127de3c009042820c216b334060a17d4f26136 100644 --- a/data-access/servlet/src/main/java/webapi/ServletMCutout.java +++ b/data-access/servlet/src/main/java/webapi/ServletMCutout.java @@ -40,7 +40,7 @@ public class ServletMCutout extends javax.servlet.http.HttpServlet private static final Logger LOGGER = Logger.getLogger(ServletMCutout.class.getName()); private static final Settings settings = Settings.getInstance(); - protected Datasets datasets = ( settings.amqpConn.isHostnameEmpty() ? new DatasetsCli(settings): new DatasetsAmqp(settings) ); + protected Vlkb vlkb = ( settings.amqpConn.isHostnameEmpty() ? new VlkbCli(settings): new VlkbAmqp(settings) ); public void init() throws ServletException @@ -95,7 +95,7 @@ public class ServletMCutout extends javax.servlet.http.HttpServlet OutputStream respOutputStream = response.getOutputStream(); - MCutResult result = datasets.doMCutout(reqJsonString); + MCutResult result = vlkb.doMCutout(reqJsonString); final String contentType = "text/xml"; // FIXME final String respEncoding = "utf-8"; // FIXME diff --git a/data-access/servlet/src/main/java/webapi/ServletMerge.java b/data-access/servlet/src/main/java/webapi/ServletMerge.java index 7b430faa553667a45a920f1d52507caf676793d5..3c2a8e1f39c46505764c85b68341bab07219aa89 100644 --- a/data-access/servlet/src/main/java/webapi/ServletMerge.java +++ b/data-access/servlet/src/main/java/webapi/ServletMerge.java @@ -47,7 +47,7 @@ public class ServletMerge extends javax.servlet.http.HttpServlet final String DEFAULT_SPEC_SYSTEM = settings.defaults.specSystem; - protected Datasets datasets = ( settings.amqpConn.isHostnameEmpty() ? new DatasetsCli(settings): new DatasetsAmqp(settings) ); + protected Vlkb vlkb = ( settings.amqpConn.isHostnameEmpty() ? new VlkbCli(settings): new VlkbAmqp(settings) ); public void init() throws ServletException @@ -133,7 +133,7 @@ public class ServletMerge extends javax.servlet.http.HttpServlet response.setContentType(respContentType); - CutResult cutResult = datasets.doMerge(parseLegacyPubdidArr(id), coord, countNullValues); + CutResult cutResult = vlkb.doMerge(parseLegacyPubdidArr(id), coord, countNullValues); String contentType = respContentType; String respEncoding = RESPONSE_ENCODING; diff --git a/data-access/servlet/src/main/java/webapi/UWSMCutoutWork.java b/data-access/servlet/src/main/java/webapi/UWSMCutoutWork.java index 8a5de968068e5b5ad7b36fb4c274c1a78693375a..4fcfeeb82aecf3ca8f22d3118954912050aaf6a9 100644 --- a/data-access/servlet/src/main/java/webapi/UWSMCutoutWork.java +++ b/data-access/servlet/src/main/java/webapi/UWSMCutoutWork.java @@ -39,7 +39,7 @@ public class UWSMCutoutWork extends JobThread private Settings settings = UWSMCutout.settings; - protected Datasets datasets = ( settings.amqpConn.isHostnameEmpty() ? new DatasetsCli(settings): new DatasetsAmqp(settings) ); + protected Vlkb vlkb = ( settings.amqpConn.isHostnameEmpty() ? new VlkbCli(settings): new VlkbAmqp(settings) ); /* NOTE needed if cutouts dir served by vlkb-datasets */ private String webappRootRequestUrl = null; @@ -83,7 +83,7 @@ public class UWSMCutoutWork extends JobThread /* SODA -> Implementation */ - MCutResult mresult = datasets.doMCutout(reqJsonString); + MCutResult mresult = vlkb.doMCutout(reqJsonString); /* Implement -> SODA */ diff --git a/data-access/servlet/src/main/java/webapi/UWSMergeWork.java b/data-access/servlet/src/main/java/webapi/UWSMergeWork.java index 4883a6a9c7ef7578785dcd331bfc1591d4d1d12c..7d62fd8371472ce6ab89de841c993e4f241b75f7 100644 --- a/data-access/servlet/src/main/java/webapi/UWSMergeWork.java +++ b/data-access/servlet/src/main/java/webapi/UWSMergeWork.java @@ -35,7 +35,7 @@ public class UWSMergeWork extends JobThread final String DEFAULT_SPEC_SYSTEM = settings.defaults.specSystem; final String DEFAULT_TIME_SYSTEM = "MJD_UTC"; - protected Datasets datasets = ( settings.amqpConn.isHostnameEmpty() ? new DatasetsCli(settings): new DatasetsAmqp(settings) ); + protected Vlkb vlkb = ( settings.amqpConn.isHostnameEmpty() ? new VlkbCli(settings): new VlkbAmqp(settings) ); /* NOTE needed if cutouts dir served by vlkb-datasets */ private String webappRootRequestUrl = null; @@ -84,7 +84,7 @@ public class UWSMergeWork extends JobThread */ Coord coord = new Coord(pos, band, time, pol, pixels); - CutResult cutResult = datasets.doMerge(parseLegacyPubdidArr(id), coord, false);//countNullValues); + CutResult cutResult = vlkb.doMerge(parseLegacyPubdidArr(id), coord, false);//countNullValues); final String respFormat = "text/xml";// FIXME read from param RESPONSEFORMAT ? diff --git a/data-access/servlet/src/main/java/webapi/UWSSodaWork.java b/data-access/servlet/src/main/java/webapi/UWSSodaWork.java index 5195fa2eee8ae0db2951c3e8f785f9c0d73cd566..c79eac238be39f69bf56e9e41cef03ec239b511a 100644 --- a/data-access/servlet/src/main/java/webapi/UWSSodaWork.java +++ b/data-access/servlet/src/main/java/webapi/UWSSodaWork.java @@ -32,7 +32,7 @@ public class UWSSodaWork extends JobThread /* NOTE needed if cutouts dir served by vlkb-datasets */ private String webappRootRequestUrl = null; - protected Datasets datasets = ( settings.amqpConn.isHostnameEmpty() ? new DatasetsCli(settings): new DatasetsAmqp(settings) );$ + protected Vlkb vlkb = ( settings.amqpConn.isHostnameEmpty() ? new VlkbCli(settings): new VlkbAmqp(settings) );$ public UWSSodaWork(UWSJob j) throws UWSException @@ -100,7 +100,7 @@ public class UWSSodaWork extends JobThread if(band != null) band.setSystem(Band.System.valueOf(DEFAULT_SPEC_SYSTEM)); if(time != null) time.setSystem(Time.System.valueOf(DEFAULT_TIME_SYSTEM)); - CutResult cutResult = datasets.doCutoutFile(rsl.relPathname, rsl.hdunum, pos, band, time, pol, false, null); + CutResult cutResult = vlkb.doCutoutFile(rsl.relPathname, rsl.hdunum, pos, band, time, pol, false, null); /* send Results */