From 310b84d9650d81a24cb35ad5107166ac75c93fb0 Mon Sep 17 00:00:00 2001
From: Jean-Louis Leysens <jloleysens@gmail.com>
Date: Mon, 12 Apr 2021 16:20:04 +0200
Subject: [PATCH] refactor use of legacyEs

---
 .../management/ingest_pipelines/lib/elasticsearch.ts  | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/x-pack/test/api_integration/apis/management/ingest_pipelines/lib/elasticsearch.ts b/x-pack/test/api_integration/apis/management/ingest_pipelines/lib/elasticsearch.ts
index ce11707dbe32b9..5a4459fced6248 100644
--- a/x-pack/test/api_integration/apis/management/ingest_pipelines/lib/elasticsearch.ts
+++ b/x-pack/test/api_integration/apis/management/ingest_pipelines/lib/elasticsearch.ts
@@ -30,17 +30,18 @@ interface Pipeline {
 export const registerEsHelpers = (getService: FtrProviderContext['getService']) => {
   let pipelinesCreated: string[] = [];
 
-  const es = getService('legacyEs');
+  const es = getService('es');
 
   const createPipeline = (pipeline: Pipeline, cachePipeline?: boolean) => {
     if (cachePipeline) {
       pipelinesCreated.push(pipeline.id);
     }
 
-    return es.ingest.putPipeline(pipeline);
+    return es.ingest.putPipeline(pipeline).then(({ body }) => body);
   };
 
-  const deletePipeline = (pipelineId: string) => es.ingest.deletePipeline({ id: pipelineId });
+  const deletePipeline = (pipelineId: string) =>
+    es.ingest.deletePipeline({ id: pipelineId }).then(({ body }) => body);
 
   const cleanupPipelines = () =>
     Promise.all(pipelinesCreated.map(deletePipeline))
@@ -53,11 +54,11 @@ export const registerEsHelpers = (getService: FtrProviderContext['getService'])
       });
 
   const createIndex = (index: { index: string; id: string; body: object }) => {
-    return es.index(index);
+    return es.index(index).then(({ body }) => body);
   };
 
   const deleteIndex = (indexName: string) => {
-    return es.indices.delete({ index: indexName });
+    return es.indices.delete({ index: indexName }).then(({ body }) => body);
   };
 
   return {