|
15 | 15 | import java.io.FileNotFoundException;
|
16 | 16 | import java.util.Iterator;
|
17 | 17 | import java.util.concurrent.atomic.AtomicReference;
|
| 18 | +import java.util.function.BiConsumer; |
18 | 19 | import java.util.logging.Level;
|
19 | 20 | import java.util.logging.Logger;
|
20 | 21 |
|
@@ -57,14 +58,20 @@ public void start(Future<Void> start) {
|
57 | 58 |
|
58 | 59 | // adds values used in the template to all routes.
|
59 | 60 | router.route("/*").handler(context -> {
|
| 61 | + BiConsumer<String, String> applyIfUnset = (key, value) -> { |
| 62 | + if (context.get(key) == null) { |
| 63 | + context.put(key, value); |
| 64 | + } |
| 65 | + }; |
60 | 66 | context.put("version", VERSION);
|
61 | 67 | context.put("esVersion", getElasticVersion());
|
62 | 68 | context.put("esURL", Configuration.getElasticURL());
|
63 | 69 | context.put("connected", ElasticWriter.isConnected());
|
64 | 70 | context.put("tls", Configuration.isElasticTLS());
|
65 |
| - context.put("index", Configuration.getDefaultIndex()); |
66 | 71 | context.put("indexLocked", Configuration.isIndexLocked());
|
67 | 72 | context.put("supportedFiles", String.join(", ", ParserFactory.getSupportedExtensions()));
|
| 73 | + applyIfUnset.accept("index", Configuration.getDefaultIndex()); |
| 74 | + |
68 | 75 | context.next();
|
69 | 76 | });
|
70 | 77 |
|
@@ -155,7 +162,6 @@ private Future<Integer> onComplete(RoutingContext context, String fileName) {
|
155 | 162 | return Future.<Integer>future().setHandler(result -> {
|
156 | 163 | if (result.succeeded()) {
|
157 | 164 | String index = getIndexFromRequest(context.request());
|
158 |
| - |
159 | 165 | logger.info(String.format("Imported file '%s' successfully into '%s'.", fileName, index));
|
160 | 166 |
|
161 | 167 | context.put(INDEX, index);
|
|
0 commit comments