"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.getPings = void 0;
var _client_defaults = require("../../../../common/constants/client_defaults");
/*
 * 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; you may not use this file except in compliance with the Elastic License
 * 2.0.
 */

const DEFAULT_PAGE_SIZE = 25;
function isStringArray(value) {
  if (!Array.isArray(value)) return false;
  // are all array items strings
  if (!value.some(s => typeof s !== 'string')) return true;
  throw Error('Excluded locations can only be strings');
}
const getPings = async ({
  uptimeEsClient,
  dateRange: {
    from,
    to
  },
  index,
  monitorId,
  status,
  sort,
  size: sizeParam,
  locations,
  excludedLocations
}) => {
  const size = sizeParam !== null && sizeParam !== void 0 ? sizeParam : DEFAULT_PAGE_SIZE;
  const searchBody = {
    size,
    ...(index ? {
      from: index * size
    } : {}),
    query: {
      bool: {
        filter: [_client_defaults.SUMMARY_FILTER, _client_defaults.EXCLUDE_RUN_ONCE_FILTER, {
          range: {
            '@timestamp': {
              gte: from,
              lte: to
            }
          }
        }, ...(monitorId ? [{
          term: {
            'monitor.id': monitorId
          }
        }] : []), ...(status ? [{
          term: {
            'monitor.status': status
          }
        }] : [])]
      }
    },
    sort: [{
      '@timestamp': {
        order: sort !== null && sort !== void 0 ? sort : 'desc'
      }
    }],
    ...((locations !== null && locations !== void 0 ? locations : []).length > 0 ? {
      post_filter: {
        terms: {
          'observer.geo.name': locations
        }
      }
    } : {})
  };

  // if there are excluded locations, add a clause to the query's filter
  const excludedLocationsArray = excludedLocations && JSON.parse(excludedLocations);
  if (isStringArray(excludedLocationsArray) && excludedLocationsArray.length > 0) {
    searchBody.query.bool.filter.push({
      bool: {
        must_not: [{
          terms: {
            'observer.geo.name': excludedLocationsArray
          }
        }]
      }
    });
  }
  const {
    body: {
      hits: {
        hits,
        total
      }
    }
  } = await uptimeEsClient.search({
    body: searchBody
  });
  const pings = hits.map(doc => {
    var _source$http, _source$http$response;
    const {
      _id,
      _source
    } = doc;
    // Calculate here the length of the content string in bytes, this is easier than in client JS, where
    // we don't have access to Buffer.byteLength. There are some hacky ways to do this in the
    // client but this is cleaner.
    const httpBody = _source === null || _source === void 0 ? void 0 : (_source$http = _source.http) === null || _source$http === void 0 ? void 0 : (_source$http$response = _source$http.response) === null || _source$http$response === void 0 ? void 0 : _source$http$response.body;
    if (httpBody && httpBody.content) {
      httpBody.content_bytes = Buffer.byteLength(httpBody.content);
    }
    return {
      ..._source,
      timestamp: _source['@timestamp'],
      docId: _id
    };
  });
  return {
    total: total.value,
    pings
  };
};
exports.getPings = getPings;