Function getClient

test/unit/insights-client-tests.js:445–484

* Gets a fake client instance. * @param {{rpcCallback, errorGetter, hostVersions, clientOptions}} [options]

(options)

 * @param {{rpcCallback, errorGetter, hostVersions, clientOptions}} [options]
 */
function getClient(options) {
  options = options || {};

  const rpcCallback = options.rpcCallback || utils.noop;
  const errorGetter = options.errorGetter || utils.noop;

  const clientOptions = Object.assign(
    { pooling: { coreConnectionsPerHost: coreConnectionsPerHostV3 }, applicationName: 'My Test Application' },
    options.clientOptions);

  const client = new Client(helper.getOptions(clientOptions));

  // Provide a fake control connection
  client.controlConnection.query = (request, w) => {
    rpcCallback(request.params[0]);
    const err = errorGetter();

    if (err) {
      return Promise.reject(err);
    }

    return Promise.resolve();
  };
  client.controlConnection.protocolVersion = 4;
  client.controlConnection.getLocalAddress = () => '10.10.10.1:9042';

  client.getState = () => new ClientState([{ address: '1.2.3.4:9042'}], { '1.2.3.4:9042': 2 }, { '1.2.3.4:9042': 123 });

  const hostVersions = options.hostVersions || [ '6.7.0' ];

  hostVersions.forEach((v, i) => {
    client.hosts.set(`10.10.10.${i}`, {
      getDseVersion: () => (v === '{empty}' ? utils.emptyArray : v.split('.')),
      datacenter: 'dc' + (i % 2),
      setDistance: () => {}
    });
  });

  return client;
}

/**
 * @param {{hostVersions, clientOptions}} [options]