rsnext/examples/with-elasticsearch/lib/elasticsearch.ts

import { Client } from "@elastic/elasticsearch";

export async function connectToElasticsearch() {
  const ESS_CLOUD_ID = process.env.ESS_CLOUD_ID;
  const ESS_CLOUD_USERNAME = process.env.ESS_CLOUD_USERNAME;
  const ESS_CLOUD_PASSWORD = process.env.ESS_CLOUD_PASSWORD;

  if (!ESS_CLOUD_ID || !ESS_CLOUD_USERNAME || !ESS_CLOUD_PASSWORD) {
    return "ERR_ENV_NOT_DEFINED";
  }

  return new Client({
    cloud: {
      id: ESS_CLOUD_ID,
    },
    auth: {
      username: ESS_CLOUD_USERNAME,
      password: ESS_CLOUD_PASSWORD,
    },
  });
}