blob: e9b8626b6492dd00898fa610c68b3d1be28765ba (
plain) (
tree)
|
|
import { BlockParamLiteral, LogEntryEvent, OrderState } from '@0xproject/types';
export enum OrderWatcherError {
SubscriptionAlreadyPresent = 'SUBSCRIPTION_ALREADY_PRESENT',
SubscriptionNotFound = 'SUBSCRIPTION_NOT_FOUND',
}
export type EventWatcherCallback = (err: null | Error, log?: LogEntryEvent) => void;
/**
* orderExpirationCheckingIntervalMs: How often to check for expired orders. Default=50.
* eventPollingIntervalMs: How often to poll the Ethereum node for new events. Default=200.
* expirationMarginMs: Amount of time before order expiry that you'd like to be notified
* of an orders expiration. Default=0.
* cleanupJobIntervalMs: How often to run a cleanup job which revalidates all the orders. Default=1hr.
* stateLayer: Optional blockchain state layer OrderWatcher will monitor for new events. Default=latest.
* blockRetention: The numbers of blocks to retain in-memory, in order to handle block-reorgs. Default=100.
*/
export interface OrderWatcherConfig {
stateLayer: BlockParamLiteral;
orderExpirationCheckingIntervalMs?: number;
eventPollingIntervalMs?: number;
expirationMarginMs?: number;
cleanupJobIntervalMs?: number;
isVerbose?: boolean;
blockRetention?: number;
}
export type OnOrderStateChangeCallback = (err: Error | null, orderState?: OrderState) => void;
export enum InternalOrderWatcherError {
NoAbiDecoder = 'NO_ABI_DECODER',
ZrxNotInTokenRegistry = 'ZRX_NOT_IN_TOKEN_REGISTRY',
WethNotInTokenRegistry = 'WETH_NOT_IN_TOKEN_REGISTRY',
}
|