Fetch connector for elasticsearch.js

FetchConnector.js

import 'abortcontroller-polyfill';
import ConnectionAbstract from 'elasticsearch/src/lib/connection';

/**
 * @example
 * const client = new elasticsearch.Client({
 *   connectionClass: FetchConnector
 * });
 */
class FetchConnector extends ConnectionAbstract {
  request(params, cb) {
    const host = this.host;
    const url = host.makeUrl(params);
    const method = params.method || 'GET'
    const headers = host.getHeaders(params.headers);
    const body = params.body;

    const controller = new window.AbortController();
    const signal = controller.signal;

    fetch(url, { body, headers, method, signal })
      .then(response => response.text())
      .then(response => cb(null, response));

    return () => controller.abort();
  }
}

export default FetchConnector;

package.json

{
  "dependencies": {
    "abortcontroller-polyfill": "^1.1.5",
    "elasticsearch": "^14.1.0"
  }
}