support locking the target index in the web ui.

Author: Robin Duda

configuration.json

@@ -4,6 +4,7 @@
   "elastic_host": "localhost",
   "elastic_tls": false,
   "default_index": "excelastic",
+  "index_lock": false,
   "authentication": false,
   "basic": "username:password"
 }

src/main/java/com/codingchili/Controller/Website.java

@@ -6,6 +6,7 @@
 import io.vertx.core.eventbus.DeliveryOptions;
 import io.vertx.core.eventbus.MessageConsumer;
 import io.vertx.core.http.HttpServer;
+import io.vertx.core.http.HttpServerRequest;
 import io.vertx.core.json.JsonObject;
 import io.vertx.ext.web.*;
 import io.vertx.ext.web.handler.*;
@@ -62,6 +63,7 @@ public void start(Future<Void> start) {
             context.put("connected", ElasticWriter.isConnected());
             context.put("tls", Configuration.isElasticTLS());
             context.put("index", Configuration.getDefaultIndex());
+            context.put("indexLocked", Configuration.isIndexLocked());
             context.put("supportedFiles", String.join(", ", ParserFactory.getSupportedExtensions()));
             context.next();
         });
@@ -147,7 +149,9 @@ private Future<Integer> onComplete(RoutingContext context, String fileName) {
         // when the file has been read from disk, parsed and imported.
         return Future.<Integer>future().setHandler(result -> {
             if (result.succeeded()) {
-                String index = context.request().params().get(INDEX);
+                String index = getIndexFromRequest(context.request());
+
+
                 logger.info(String.format("Imported file '%s' successfully into '%s'.", fileName, index));
 
                 context.put(INDEX, index);
@@ -163,14 +167,20 @@ private Future<Integer> onComplete(RoutingContext context, String fileName) {
         });
     }
 
+    private String getIndexFromRequest(HttpServerRequest request) {
+        // only read the index from the request if the target index is not locked.
+        return (Configuration.isIndexLocked()) ?
+                Configuration.getDefaultIndex() : request.params().get(INDEX);
+    }
+
     /**
      * Parses a file upload request, converting the excel payload into json and waits
      * for elasticsearch to complete indexing.
      *
      * @param uploadedFileName the actual file on disk that contains the uploaded file.
-     * @param params   upload parameters
-     * @param fileName the name of the uploaded file
-     * @param future   callback on completed parse + indexing.
+     * @param params           upload parameters
+     * @param fileName         the name of the uploaded file
+     * @param future           callback on completed parse + indexing.
      */
     private void parse(String uploadedFileName, MultiMap params, String fileName, Future<Integer> future) {
         vertx.executeBlocking(blocking -> {

src/main/java/com/codingchili/Model/Configuration.java

@@ -26,6 +26,7 @@ public class Configuration {
     private static boolean SECURITY;
     private static String BASIC_AUTH;
     private static boolean ELASTIC_TLS;
+    private static boolean INDEX_LOCK;
 
     static {
         JsonObject configuration = getConfiguration();
@@ -36,6 +37,7 @@ public class Configuration {
         BASIC_AUTH = configuration.getString("basic", "username:password");
         ELASTIC_TLS = configuration.getBoolean("elastic_tls", false);
         DEFAULT_INDEX = configuration.getString("default_index", generateDefaultIndex());
+        INDEX_LOCK = configuration.getBoolean("index_lock", false);
     }
 
     private static JsonObject getConfiguration() {
@@ -118,7 +120,14 @@ public static String getElasticURL() {
     /**
      * @return the default index to use for importing.
      */
-    public static Object getDefaultIndex() {
+    public static String getDefaultIndex() {
         return DEFAULT_INDEX;
     }
+
+    /**
+     * @return true if the user should not be allowed to specify the import index.
+     */
+    public static boolean isIndexLocked() {
+        return INDEX_LOCK;
+    }
 }

src/main/resources/templates/index.jade

@@ -27,7 +27,7 @@ html(lang='en')
                             .form-group
                                 label.col-lg-3.control-label(for='index') Index
                                 .col-lg-9
-                                    input#index.form-control(type='text', name='index', placeholder='name of index', value='#{context.index}')
+                                    input#index.form-control(type='text', name='index', placeholder='name of index', value='#{context.index}' disabled=context.indexLocked)
                             .form-group
                                 label.col-lg-3.control-label(for='mapping') Mapping
                                 .col-lg-9