"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.SEARCH_API_BASE_URL = void 0;
exports.registerSearchRoute = registerSearchRoute;
var _operators = require("rxjs/operators");
var _configSchema = require("@kbn/config-schema");
var _server = require("@kbn/kibana-utils-plugin/server");
var _lib = require("../../lib");
/*
 * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
 * or more contributor license agreements. Licensed under the Elastic License
 * 2.0 and the Server Side Public License, v 1; you may not use this file except
 * in compliance with, at your election, the Elastic License 2.0 or the Server
 * Side Public License, v 1.
 */

const SEARCH_API_BASE_URL = '/internal/search';
exports.SEARCH_API_BASE_URL = SEARCH_API_BASE_URL;
function registerSearchRoute(router) {
  router.versioned.post({
    path: `${SEARCH_API_BASE_URL}/{strategy}/{id?}`,
    access: 'internal'
  }).addVersion({
    version: '1',
    validate: {
      request: {
        params: _configSchema.schema.object({
          strategy: _configSchema.schema.string(),
          id: _configSchema.schema.maybe(_configSchema.schema.string())
        }),
        body: _configSchema.schema.object({
          legacyHitsTotal: _configSchema.schema.maybe(_configSchema.schema.boolean()),
          sessionId: _configSchema.schema.maybe(_configSchema.schema.string()),
          isStored: _configSchema.schema.maybe(_configSchema.schema.boolean()),
          isRestore: _configSchema.schema.maybe(_configSchema.schema.boolean())
        }, {
          unknowns: 'allow'
        })
      }
    }
  }, async (context, request, res) => {
    const {
      legacyHitsTotal = true,
      sessionId,
      isStored,
      isRestore,
      ...searchRequest
    } = request.body;
    const {
      strategy,
      id
    } = request.params;
    const abortSignal = (0, _lib.getRequestAbortedSignal)(request.events.aborted$);
    try {
      const search = await context.search;
      const response = await search.search({
        ...searchRequest,
        id
      }, {
        abortSignal,
        strategy,
        legacyHitsTotal,
        sessionId,
        isStored,
        isRestore
      }).pipe((0, _operators.first)()).toPromise();
      return res.ok({
        body: response
      });
    } catch (err) {
      return (0, _server.reportServerError)(res, err);
    }
  });
  router.versioned.delete({
    path: '/internal/search/{strategy}/{id}',
    access: 'internal'
  }).addVersion({
    version: '1',
    validate: {
      request: {
        params: _configSchema.schema.object({
          strategy: _configSchema.schema.string(),
          id: _configSchema.schema.string()
        })
      }
    }
  }, async (context, request, res) => {
    const {
      strategy,
      id
    } = request.params;
    try {
      const search = await context.search;
      await search.cancel(id, {
        strategy
      });
      return res.ok();
    } catch (err) {
      return (0, _server.reportServerError)(res, err);
    }
  });
}