ethers.js/src.ts/providers/fallback-provider.ts

'use strict';

import { Provider } from './provider';

// Imported Types
import { Network } from '../utils/networks';

import * as errors from '../utils/errors';

// Returns:
//  - true is all networks match
//  - false if any network is null
//  - throws if any 2 networks do not match
function checkNetworks(networks: Array<Network>): boolean {
    var result = true;

    let check: Network = null;
    networks.forEach((network) => {

        // Null
        if (network == null) {
            result = false;
            return;
        }

        // Have nothing to compre to yet
        if (check == null) {
            check = network;
            return;
        }

        // Matches!
        if (check.name === network.name &&
            check.chainId === network.chainId &&
            check.ensAddress === network.ensAddress) { return; }

        errors.throwError(
            'provider mismatch',
            errors.INVALID_ARGUMENT,
            { arg: 'networks', value: networks }
        );
    });

    return result;
}

export class FallbackProvider extends Provider {
    private _providers: Array<Provider>;

    constructor(providers: Array<Provider>) {

        if (providers.length === 0) { throw new Error('no providers'); }

        // All networks are ready, we can know the network for certain
        let ready = checkNetworks(providers.map((p) => p.network));
        if (ready) {
            super(providers[0].network);

        } else {
            // The network won't be known until all child providers know
            let ready = Promise.all(providers.map((p) => p.getNetwork())).then((networks) => {
                if (!checkNetworks(networks)) {
                    errors.throwError('getNetwork returned null', errors.UNKNOWN_ERROR, { })
                }
                return networks[0];
            });

            super(ready);
        }
        errors.checkNew(this, FallbackProvider);

        // Preserve a copy, so we don't get mutated
        this._providers = providers.slice(0);
    }

    get providers(): Array<Provider> {
        // Return a copy, so we don't get mutated
        return this._providers.slice(0);
    }

    perform(method: string, params: any): any {
        // Creates a copy of the providers array
        var providers = this.providers;

        return new Promise((resolve, reject) => {
            var firstError: Error = null;
            function next() {
                if (!providers.length) {
                    reject(firstError);
                    return;
                }

                var provider = providers.shift();
                provider.perform(method, params).then((result) => {
                    return resolve(result);
                }).catch((error) => {
                    if (!firstError) { firstError = error; }
                    setTimeout(next, 0);
                });
            }
            next();
        });
    }
}