import test = require('tape');
import ProviderEngine from '../src/index';
import FixtureProvider from '../src/subproviders/fixture';
import { createPayload } from '../src/util/create-payload';
import TestBlockProvider from './util/block';
import injectMetrics from './util/inject-metrics';
import PassthroughProvider from './util/passthrough';

test('fallthrough test', (t) => {
  t.plan(8);

  // handle nothing
  const providerA = injectMetrics(new PassthroughProvider());
  // handle "test_rpc"
  const providerB = injectMetrics(new FixtureProvider({
    test_rpc: true,
  }));
  // handle block requests
  const providerC = injectMetrics(new TestBlockProvider());

  const engine = new ProviderEngine();
  engine.addProvider(providerA);
  engine.addProvider(providerB);
  engine.addProvider(providerC);

  engine.start();
  engine.sendAsync(createPayload({ method: 'test_rpc' }), (err, response) => {
    t.ifError(err, 'did not error');
    t.ok(response, 'has response');

    t.equal(providerA.getWitnessed('test_rpc').length, 1, 'providerA did see "test_rpc"');
    t.equal(providerA.getHandled('test_rpc').length, 0, 'providerA did NOT handle "test_rpc"');

    t.equal(providerB.getWitnessed('test_rpc').length, 1, 'providerB did see "test_rpc"');
    t.equal(providerB.getHandled('test_rpc').length, 1, 'providerB did handle "test_rpc"');

    t.equal(providerC.getWitnessed('test_rpc').length, 0, 'providerC did NOT see "test_rpc"');
    t.equal(providerC.getHandled('test_rpc').length, 0, 'providerC did NOT handle "test_rpc"');

    engine.stop();
    t.end();
  });

});

test('add provider at index', (t) => {
  const providerA = new PassthroughProvider();
  const providerB = new PassthroughProvider();
  const providerC = new PassthroughProvider();
  const engine = new ProviderEngine();
  engine.addProvider(providerA);
  engine.addProvider(providerB);
  engine.addProvider(providerC, 1);

  t.deepEqual((engine as any)._providers, [providerA, providerC, providerB]);
  t.end();
});

test('remove provider', (t) => {
  const providerA = new PassthroughProvider();
  const providerB = new PassthroughProvider();
  const providerC = new PassthroughProvider();
  const engine = new ProviderEngine();
  engine.addProvider(providerA);
  engine.addProvider(providerB);
  engine.addProvider(providerC);
  engine.removeProvider(providerB);

  t.deepEqual((engine as any)._providers, [providerA, providerC]);
  t.end();
});