cleaned up get and search

Should have separated all of the get/search parts and everything that is es or os is now in registry-common.

src/main/java/gov/nasa/pds/harvest/HarvestMain.java

@@ -11,6 +11,8 @@ public class HarvestMain
     public static void main(String[] args)
     {
         System.setProperty("sun.stdout.encoding", "UTF-8");
+        System.setProperty("javax.net.ssl.trustStore", "/home/niessner/Projects/PDS/TestData/OSV2/default.certs");
+        System.setProperty("javax.net.ssl.trustStorePassword", "2Painful!");
         HarvestCli cli = new HarvestCli();
         cli.run(args);
     }

src/main/java/gov/nasa/pds/harvest/dao/RegistryDao.java

@@ -9,7 +9,6 @@
 import gov.nasa.pds.registry.common.Request;
 import gov.nasa.pds.registry.common.Response;
 import gov.nasa.pds.registry.common.RestClient;
-import gov.nasa.pds.registry.common.util.SearchResponseParser;
 
 
 /**
@@ -23,9 +22,6 @@ public class RegistryDao
     private String indexName;
     private boolean pretty;
 
-    private SearchResponseParser parser;
-
-
     /**
      * Constructor
      * @param client Elasticsearch client
@@ -48,7 +44,6 @@ public RegistryDao(RestClient client, String indexName, boolean pretty)
         this.client = client;
         this.indexName = indexName;
         this.pretty = pretty;
-        parser = new SearchResponseParser();
     }
 
 
@@ -78,16 +73,11 @@ public boolean idExists(String id) throws Exception
     public Set<String> getNonExistingIds(Collection<String> ids) throws Exception
     {
         if(ids == null || ids.isEmpty()) return new HashSet<>();
-        Response resp = searchIds(ids);
-
-        NonExistingIdsResponse idsResp = new NonExistingIdsResponse(ids);
-        parser.parseResponse(resp, idsResp);
-
-        return idsResp.getIds();
+        return searchIds(ids).nonExistingIds(ids);
     }
 
 
-    private Response searchIds(Collection<String> ids) throws Exception
+    private Response.Search searchIds(Collection<String> ids) throws Exception
     {
       if(ids == null || ids.isEmpty()) throw new InvalidPDS4ProductException("Error reading bundle/collection references. " +
           "Verify the bundle/collection is valid prior to loading the data.");
@@ -96,7 +86,7 @@ private Response searchIds(Collection<String> ids) throws Exception
             .buildTheseIds(ids)
             .setIndex(this.indexName)
             .setPretty(pretty);
-        Response resp = client.performRequest(req);
+        Response.Search resp = client.performRequest(req);
 
         return resp;
     }

src/main/java/gov/nasa/pds/harvest/dao/RegistryManager.java

@@ -53,22 +53,20 @@ private RegistryManager(ConnectionFactory conFact, boolean overwriteFlag) throws
         this.conFact = conFact;
         this.overwriteFlag = overwriteFlag;
         this.counter = new Counter();
-
         Logger log = LogManager.getLogger(this.getClass());
         log.log(LogUtils.LEVEL_SUMMARY, "Connection: " + conFact);
-
         client = conFact.createRestClient();
-
         registryDao = new RegistryDao(client, conFact.getIndexName());
         schemaDao = new SchemaDao(client, conFact.getIndexName());
         ddDao = new DataDictionaryDao(client, conFact.getIndexName());
-
         fieldNameCache = new FieldNameCache(ddDao, schemaDao);
-
         registryWriter = new MetadataWriter(conFact, registryDao, counter);
         registryWriter.setOverwriteExisting(overwriteFlag);
-
         invWriter = new CollectionInventoryWriter(conFact);
+
+        if (!this.client.exists(this.conFact.getIndexName())) {
+          throw new RuntimeException("The index '" + this.conFact.getIndexName() + "' does not exist. Please create it first.");
+        }
     }