First iteration of PoC working

jloleysens · jloleysens · commit 97fc31f4e30e · 2019-11-11T19:22:09.000+01:00
diff --git a/src/legacy/core_plugins/console/index.ts b/src/legacy/core_plugins/console/index.ts
@@ -22,6 +22,7 @@ import { first } from 'rxjs/operators';
 import { resolve, join, sep } from 'path';
 import url from 'url';
 import { has, isEmpty, head, pick } from 'lodash';
+import { LiveHostsManager } from './server/live_hosts_manager';
 
 // @ts-ignore
 import { addProcessorDefinition } from './server/api_server/es_6_0/ingest';
@@ -142,7 +143,8 @@ export default function(kibana: any) {
 
       server.route(
         createProxyRoute({
-          baseUrl: head(legacyEsConfig.hosts),
+          // baseUrl: head(legacyEsConfig.hosts),
+          liveHostsManager: new LiveHostsManager(legacyEsConfig.hosts),
           pathFilters: proxyPathFilters,
           getConfigForReq(req: any, uri: any) {
             const filteredHeaders = filterHeaders(
diff --git a/src/legacy/core_plugins/console/server/proxy_route.js b/src/legacy/core_plugins/console/server/proxy_route.js
@@ -58,7 +58,7 @@ function getProxyHeaders(req) {
 }
 
 export const createProxyRoute = ({
-  baseUrl = '/',
+  liveHostsManager,
   pathFilters = [/.*/],
   getConfigForReq = () => ({}),
 }) => ({
@@ -100,6 +100,7 @@ export const createProxyRoute = ({
     handler: async (req, h) => {
       const { payload, query } = req;
       const { path, method } = query;
+      const baseUrl = await liveHostsManager.getLiveHost();
       const uri = toURL(baseUrl, path);
 
       // Because this can technically be provided by a settings-defined proxy config, we need to
