fix for delete not sending body from console

elastic · Mar 4, 2019 · 78f887f · 78f887f
1 parent 3b45c11
commit 78f887f
Showing 1 changed file with 34 additions and 21 deletions.
diff --git a/src/legacy/core_plugins/console/server/proxy_route.js b/src/legacy/core_plugins/console/server/proxy_route.js
@@ -54,7 +54,6 @@ function getProxyHeaders(req) {
   if (contentType) {
     headers['content-type'] = contentType;
   }
-
   return headers;
 }
 
@@ -107,30 +106,44 @@ export const createProxyRoute = ({
         agent,
         headers,
       } = getConfigForReq(req, uri);
+      const makeRequest = async (payloadToSend) => {
+        const wreckOptions = {
+          payload: payloadToSend,
+          timeout,
+          rejectUnauthorized,
+          agent,
+          headers: {
+            ...headers,
+            ...getProxyHeaders(req)
+          },
+        };
+
+        const esResponse = await Wreck.request(method, uri, wreckOptions);
+
+        if (method.toUpperCase() !== 'HEAD') {
+          return h.response(esResponse)
+            .code(esResponse.statusCode)
+            .header('warning', esResponse.headers.warning);
+        }
 
-      const wreckOptions = {
-        payload,
-        timeout,
-        rejectUnauthorized,
-        agent,
-        headers: {
-          ...headers,
-          ...getProxyHeaders(req)
-        },
-      };
-
-      const esResponse = await Wreck.request(method, uri, wreckOptions);
-
-      if (method.toUpperCase() !== 'HEAD') {
-        return h.response(esResponse)
+        return h.response(`${esResponse.statusCode} - ${esResponse.statusMessage}`)
           .code(esResponse.statusCode)
+          .type('text/plain')
           .header('warning', esResponse.headers.warning);
+      };
+      if (method === 'DELETE') {
+        let data = Buffer.alloc(0);
+        while (true) {
+          const datum = payload.read();
+          if (datum) {
+            data = Buffer.concat([data, datum]);
+          } else {
+            return await makeRequest(data);
+          }
+        }
+      } else {
+        return await makeRequest(payload);
       }
-
-      return h.response(`${esResponse.statusCode} - ${esResponse.statusMessage}`)
-        .code(esResponse.statusCode)
-        .type('text/plain')
-        .header('warning', esResponse.headers.warning);
     }
   }
 });