sepia-search-motore-di-ricerca-video/server/lib/elastic-search-instances.ts

import { elasticSearch } from '../helpers/elastic-search'
import { CONFIG } from '../initializers/constants'
import { getRemovedHosts, listIndexInstancesHost } from './instances-index'

async function listIndexInstances () {
  const res = await elasticSearch.search({
    index: CONFIG.ELASTIC_SEARCH.INDEXES.VIDEOS,
    body: {
      size: 0,
      aggs: {
        hosts: {
          terms: {
            size: 5000,
            field: 'host'
          }
        }
      }
    }
  })

  return res.body.aggregations.hosts.buckets.map(b => b.key)
}

async function buildInstanceHosts () {
  let indexHosts = await listIndexInstancesHost()

  if (CONFIG.INSTANCES_INDEX.WHITELIST.ENABLED) {
    const whitelistHosts = Array.isArray(CONFIG.INSTANCES_INDEX.WHITELIST.HOSTS) ? CONFIG.INSTANCES_INDEX.WHITELIST.HOSTS : []

    indexHosts = indexHosts.filter(h => whitelistHosts.includes(h))
  }

  const dbHosts = await listIndexInstances()
  const removedHosts = getRemovedHosts(dbHosts, indexHosts)

  return { indexHosts, removedHosts }
}

export {
  listIndexInstances,
  buildInstanceHosts
}