[Transform] Refactor delete transform schema

elastic · Jun 5, 2020 · cd293f2 · cd293f2
1 parent d8f901c
commit cd293f2
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 9 deletions.
diff --git a/x-pack/plugins/transform/server/routes/api/schema.ts b/x-pack/plugins/transform/server/routes/api/schema.ts
@@ -14,3 +14,19 @@ export const schemaTransformId = {
 export interface SchemaTransformId {
   transformId: string;
 }
+
+export const deleteTransformSchema = schema.object({
+  /**
+   * Delete Transform & Destination Index
+   */
+  transformsInfo: schema.maybe(
+    schema.arrayOf(
+      schema.object({
+        id: schema.string(),
+        state: schema.maybe(schema.string()),
+      })
+    )
+  ),
+  deleteDestIndex: schema.maybe(schema.boolean()),
+  deleteDestIndexPattern: schema.maybe(schema.boolean()),
+});
diff --git a/x-pack/plugins/transform/server/routes/api/transforms.ts b/x-pack/plugins/transform/server/routes/api/transforms.ts
@@ -29,7 +29,7 @@ import { RouteDependencies } from '../../types';
 import { addBasePath } from '../index';
 
 import { isRequestTimeout, fillResultsWithTimeouts, wrapError } from './error_utils';
-import { schemaTransformId, SchemaTransformId } from './schema';
+import { deleteTransformSchema, schemaTransformId, SchemaTransformId } from './schema';
 import { registerTransformsAuditMessagesRoutes } from './transforms_audit_messages';
 import { IIndexPattern } from '../../../../../../src/plugins/data/common/index_patterns';
 
@@ -182,14 +182,7 @@ export function registerTransformsRoutes(routeDependencies: RouteDependencies) {
     {
       path: addBasePath('delete_transforms'),
       validate: {
-        body: schema.maybe(schema.any()),
-        query: schema.object({
-          /**
-           * Transform Destination Index
-           */
-          deleteDestIndex: schema.maybe(schema.boolean()),
-          deleteDestIndexPattern: schema.maybe(schema.boolean()),
-        }),
+        body: deleteTransformSchema,
       },
     },
     license.guardApiRoute(async (ctx, req, res) => {