aboutsummaryrefslogtreecommitdiffstats
path: root/src/contract_wrappers/exchange_wrapper.ts
diff options
context:
space:
mode:
authorLeonid Logvinov <logvinov.leon@gmail.com>2017-06-07 18:39:44 +0800
committerLeonid Logvinov <logvinov.leon@gmail.com>2017-06-07 18:39:44 +0800
commit9325bd8cb4d3b0f3bbf241a52bd60cda77972236 (patch)
treee2f31862725a5d8a8ba205edb83927127a63be78 /src/contract_wrappers/exchange_wrapper.ts
parent28d3528e42563f95255cee3bd7f85cc03141522e (diff)
downloaddexon-sol-tools-9325bd8cb4d3b0f3bbf241a52bd60cda77972236.tar
dexon-sol-tools-9325bd8cb4d3b0f3bbf241a52bd60cda77972236.tar.gz
dexon-sol-tools-9325bd8cb4d3b0f3bbf241a52bd60cda77972236.tar.bz2
dexon-sol-tools-9325bd8cb4d3b0f3bbf241a52bd60cda77972236.tar.lz
dexon-sol-tools-9325bd8cb4d3b0f3bbf241a52bd60cda77972236.tar.xz
dexon-sol-tools-9325bd8cb4d3b0f3bbf241a52bd60cda77972236.tar.zst
dexon-sol-tools-9325bd8cb4d3b0f3bbf241a52bd60cda77972236.zip
Add initial batchCancelAsync implementation
Diffstat (limited to 'src/contract_wrappers/exchange_wrapper.ts')
-rw-r--r--src/contract_wrappers/exchange_wrapper.ts45
1 files changed, 45 insertions, 0 deletions
diff --git a/src/contract_wrappers/exchange_wrapper.ts b/src/contract_wrappers/exchange_wrapper.ts
index 6f62934dc..b0c4295f1 100644
--- a/src/contract_wrappers/exchange_wrapper.ts
+++ b/src/contract_wrappers/exchange_wrapper.ts
@@ -206,6 +206,51 @@ export class ExchangeWrapper extends ContractWrapper {
this.throwErrorLogsAsErrors(response.logs);
}
/**
+ * Batch version of cancelOrderAsync. Atomically cancels multiple orders in a single transaction.
+ */
+ public async batchCancelOrderAsync(
+ orders: Array<Order|SignedOrder>, takerTokenCancelAmounts: BigNumber.BigNumber[]): Promise<void> {
+ const makers = _.map(orders, order => order.maker);
+ assert.isSameLength('orders', orders, 'takerTokenCancelAmounts', takerTokenCancelAmounts);
+ assert.assert(_.isEmpty(orders), 'Can not cancel an empty batch');
+ assert.assert(_.uniq(makers).length === 1, 'Can not cancel orders from multiple makers in a single batch');
+ const maker = makers[0];
+ // _.zip doesn't type check if values have different types :'(
+ const ordersAndTakerTokenCancelAmounts = _.zip<any>(orders, takerTokenCancelAmounts);
+ _.forEach(ordersAndTakerTokenCancelAmounts,
+ async ([order, takerTokenCancelAmount]: [Order|SignedOrder, BigNumber.BigNumber]) => {
+ assert.doesConformToSchema('order',
+ SchemaValidator.convertToJSONSchemaCompatibleObject(order as object), orderSchema);
+ assert.isBigNumber('takerTokenCancelAmount', takerTokenCancelAmount);
+ await assert.isSenderAddressAvailableAsync(this.web3Wrapper, 'order.maker', order.maker);
+ await this.validateCancelOrderAndThrowIfInvalidAsync(order, takerTokenCancelAmount);
+ });
+ const exchangeInstance = await this.getExchangeContractAsync();
+ const orderAddressesAndValues = _.map(orders, order => {
+ return ExchangeWrapper.getOrderAddressesAndValues(order);
+ });
+ // _.unzip doesn't type check if values have different types :'(
+ const [orderAddresses, orderValues] = _.unzip<any>(orderAddressesAndValues);
+ const gas = await exchangeInstance.batchCancel.estimateGas(
+ orderAddresses,
+ orderValues,
+ takerTokenCancelAmounts,
+ {
+ from: maker,
+ },
+ );
+ const response: ContractResponse = await exchangeInstance.batchCancel(
+ orderAddresses,
+ orderValues,
+ takerTokenCancelAmounts,
+ {
+ from: maker,
+ gas,
+ },
+ );
+ this.throwErrorLogsAsErrors(response.logs);
+ }
+ /**
* Subscribe to an event type emitted by the Exchange smart contract
*/
public async subscribeAsync(eventName: ExchangeEvents, subscriptionOpts: SubscriptionOpts,