Deploy @dexon-foundation/0x.jsstable

3 files changed, 0 insertions, 171 deletions

diff --git a/packages/pipeline/src/data_sources/contract-wrappers/erc20_events.ts b/packages/pipeline/src/data_sources/contract-wrappers/erc20_events.ts
deleted file mode 100644
index e0098122f..000000000
--- a/packages/pipeline/src/data_sources/contract-wrappers/erc20_events.ts
+++ /dev/null
@@ -1,45 +0,0 @@
-import {
-    ContractWrappers,
-    ERC20TokenApprovalEventArgs,
-    ERC20TokenEvents,
-    ERC20TokenWrapper,
-} from '@0x/contract-wrappers';
-import { Web3ProviderEngine } from '@0x/subproviders';
-import { LogWithDecodedArgs } from 'ethereum-types';
-
-import { GetEventsFunc, getEventsWithPaginationAsync } from './utils';
-
-export class ERC20EventsSource {
-    private readonly _erc20Wrapper: ERC20TokenWrapper;
-    private readonly _tokenAddress: string;
-    constructor(provider: Web3ProviderEngine, networkId: number, tokenAddress: string) {
-        const contractWrappers = new ContractWrappers(provider, { networkId });
-        this._erc20Wrapper = contractWrappers.erc20Token;
-        this._tokenAddress = tokenAddress;
-    }
-
-    public async getApprovalEventsAsync(
-        startBlock: number,
-        endBlock: number,
-    ): Promise<Array<LogWithDecodedArgs<ERC20TokenApprovalEventArgs>>> {
-        return getEventsWithPaginationAsync(
-            this._getApprovalEventsForRangeAsync.bind(this) as GetEventsFunc<ERC20TokenApprovalEventArgs>,
-            startBlock,
-            endBlock,
-        );
-    }
-
-    // Gets all approval events of for a specific sub-range. This getter
-    // function will be called during each step of pagination.
-    private async _getApprovalEventsForRangeAsync(
-        fromBlock: number,
-        toBlock: number,
-    ): Promise<Array<LogWithDecodedArgs<ERC20TokenApprovalEventArgs>>> {
-        return this._erc20Wrapper.getLogsAsync<ERC20TokenApprovalEventArgs>(
-            this._tokenAddress,
-            ERC20TokenEvents.Approval,
-            { fromBlock, toBlock },
-            {},
-        );
-    }
-}
diff --git a/packages/pipeline/src/data_sources/contract-wrappers/exchange_events.ts b/packages/pipeline/src/data_sources/contract-wrappers/exchange_events.ts
deleted file mode 100644
index 58691e2ab..000000000
--- a/packages/pipeline/src/data_sources/contract-wrappers/exchange_events.ts
+++ /dev/null
@@ -1,59 +0,0 @@
-import {
-    ContractWrappers,
-    ExchangeCancelEventArgs,
-    ExchangeCancelUpToEventArgs,
-    ExchangeEventArgs,
-    ExchangeEvents,
-    ExchangeFillEventArgs,
-    ExchangeWrapper,
-} from '@0x/contract-wrappers';
-import { Web3ProviderEngine } from '@0x/subproviders';
-import { LogWithDecodedArgs } from 'ethereum-types';
-
-import { GetEventsFunc, getEventsWithPaginationAsync } from './utils';
-
-export class ExchangeEventsSource {
-    private readonly _exchangeWrapper: ExchangeWrapper;
-    constructor(provider: Web3ProviderEngine, networkId: number) {
-        const contractWrappers = new ContractWrappers(provider, { networkId });
-        this._exchangeWrapper = contractWrappers.exchange;
-    }
-
-    public async getFillEventsAsync(
-        startBlock: number,
-        endBlock: number,
-    ): Promise<Array<LogWithDecodedArgs<ExchangeFillEventArgs>>> {
-        const getFillEventsForRangeAsync = this._makeGetterFuncForEventType<ExchangeFillEventArgs>(ExchangeEvents.Fill);
-        return getEventsWithPaginationAsync(getFillEventsForRangeAsync, startBlock, endBlock);
-    }
-
-    public async getCancelEventsAsync(
-        startBlock: number,
-        endBlock: number,
-    ): Promise<Array<LogWithDecodedArgs<ExchangeCancelEventArgs>>> {
-        const getCancelEventsForRangeAsync = this._makeGetterFuncForEventType<ExchangeCancelEventArgs>(
-            ExchangeEvents.Cancel,
-        );
-        return getEventsWithPaginationAsync(getCancelEventsForRangeAsync, startBlock, endBlock);
-    }
-
-    public async getCancelUpToEventsAsync(
-        startBlock: number,
-        endBlock: number,
-    ): Promise<Array<LogWithDecodedArgs<ExchangeCancelUpToEventArgs>>> {
-        const getCancelUpToEventsForRangeAsync = this._makeGetterFuncForEventType<ExchangeCancelUpToEventArgs>(
-            ExchangeEvents.CancelUpTo,
-        );
-        return getEventsWithPaginationAsync(getCancelUpToEventsForRangeAsync, startBlock, endBlock);
-    }
-
-    // Returns a getter function which gets all events of a specific type for a
-    // specific sub-range. This getter function will be called during each step
-    // of pagination.
-    private _makeGetterFuncForEventType<ArgsType extends ExchangeEventArgs>(
-        eventType: ExchangeEvents,
-    ): GetEventsFunc<ArgsType> {
-        return async (fromBlock: number, toBlock: number) =>
-            this._exchangeWrapper.getLogsAsync<ArgsType>(eventType, { fromBlock, toBlock }, {});
-    }
-}
diff --git a/packages/pipeline/src/data_sources/contract-wrappers/utils.ts b/packages/pipeline/src/data_sources/contract-wrappers/utils.ts
deleted file mode 100644
index 67660a37e..000000000
--- a/packages/pipeline/src/data_sources/contract-wrappers/utils.ts
+++ /dev/null
@@ -1,67 +0,0 @@
-import { DecodedLogArgs, LogWithDecodedArgs } from 'ethereum-types';
-
-const NUM_BLOCKS_PER_QUERY = 10000; // Number of blocks to query for events at a time.
-const NUM_RETRIES = 3; // Number of retries if a request fails or times out.
-
-export type GetEventsFunc<ArgsType extends DecodedLogArgs> = (
-    fromBlock: number,
-    toBlock: number,
-) => Promise<Array<LogWithDecodedArgs<ArgsType>>>;
-
-/**
- * Gets all events between the given startBlock and endBlock by querying for
- * NUM_BLOCKS_PER_QUERY at a time. Accepts a getter function in order to
- * maximize code re-use and allow for getting different types of events for
- * different contracts. If the getter function throws with a retryable error,
- * it will automatically be retried up to NUM_RETRIES times.
- * @param getEventsAsync A getter function which will be called for each step during pagination.
- * @param startBlock The start of the entire block range to get events for.
- * @param endBlock The end of the entire block range to get events for.
- */
-export async function getEventsWithPaginationAsync<ArgsType extends DecodedLogArgs>(
-    getEventsAsync: GetEventsFunc<ArgsType>,
-    startBlock: number,
-    endBlock: number,
-): Promise<Array<LogWithDecodedArgs<ArgsType>>> {
-    let events: Array<LogWithDecodedArgs<ArgsType>> = [];
-    for (let fromBlock = startBlock; fromBlock <= endBlock; fromBlock += NUM_BLOCKS_PER_QUERY) {
-        const toBlock = Math.min(fromBlock + NUM_BLOCKS_PER_QUERY - 1, endBlock);
-        const eventsInRange = await _getEventsWithRetriesAsync(getEventsAsync, NUM_RETRIES, fromBlock, toBlock);
-        events = events.concat(eventsInRange);
-    }
-    return events;
-}
-
-/**
- * Calls the getEventsAsync function and retries up to numRetries times if it
- * throws with an error that is considered retryable.
- * @param getEventsAsync a function that will be called on each iteration.
- * @param numRetries the maximum number times to retry getEventsAsync if it fails with a retryable error.
- * @param fromBlock the start of the sub-range of blocks we are getting events for.
- * @param toBlock the end of the sub-range of blocks we are getting events for.
- */
-export async function _getEventsWithRetriesAsync<ArgsType extends DecodedLogArgs>(
-    getEventsAsync: GetEventsFunc<ArgsType>,
-    numRetries: number,
-    fromBlock: number,
-    toBlock: number,
-): Promise<Array<LogWithDecodedArgs<ArgsType>>> {
-    let eventsInRange: Array<LogWithDecodedArgs<ArgsType>> = [];
-    for (let i = 0; i <= numRetries; i++) {
-        try {
-            eventsInRange = await getEventsAsync(fromBlock, toBlock);
-        } catch (err) {
-            if (isErrorRetryable(err) && i < numRetries) {
-                continue;
-            } else {
-                throw err;
-            }
-        }
-        break;
-    }
-    return eventsInRange;
-}
-
-function isErrorRetryable(err: Error): boolean {
-    return err.message.includes('network timeout');
-}