add ability to place and cancel orders in bulk

Author: localhuman

src/client/client.ts

@@ -183,7 +183,8 @@ import {
   AssetData,
   Asset,
   MissingNonceError,
-  InsufficientFundsError
+  InsufficientFundsError,
+  PlaceLimitOrderParams
 } from '../types'
 import {
   ClientMode,
@@ -192,6 +193,8 @@ import {
   GQLResp,
   PayloadSignature
 } from '../types/client'
+import { default as gqlstring } from 'graphql-tag'
+
 import { BlockchainError } from './movements'
 import { gqlToString } from './queryPrinter'
 import { CryptoCurrency } from '../constants/currency'
@@ -3854,4 +3857,140 @@ export class Client {
   public getBtcAddress(): string {
     return this.apiKey.child_keys[BIP44.BTC].address
   }
+
+  /*
+    Updates for placing or cancelling multiple orders in same request
+  */
+
+  /**
+   * Cancel a list of orders by ID.
+   *
+   * @param orderID[]
+   * @returns
+   *
+   * Example
+   * ```
+   * const cancelledOrders = await nash.cancelOrder(['11','12'])
+   * console.log(cancelledOrders)
+   * ```
+   */
+  public async cancelOrders(
+    orderIDs: string[],
+    marketName: string
+  ): Promise<CancelledOrder[]> {
+    const [a, b] = marketName.split('_')
+    await this.prefillRPoolIfNeededForAssets(
+      a as CryptoCurrency,
+      b as CryptoCurrency
+    )
+
+    const cancelOrdersPayloads = await Promise.all(
+      orderIDs.map(async id => {
+        const cancelOrderParams = createCancelOrderParams(id, marketName)
+        const signedPayload = await this.signPayload(cancelOrderParams)
+        return signedPayload
+      })
+    )
+
+    const names = ['A', 'B', 'C', 'D', 'E', 'F'].slice(
+      0,
+      cancelOrdersPayloads.length
+    )
+    const params = names
+      .map(name => `$p${name}:CancelOrderParams!, $s${name}:Signature!`)
+      .join(',')
+    const aliases = names
+      .map(
+        name =>
+          `  ${name}: cancelOrder(payload: $p${name}, signature: $s${name}) { orderId }`
+      )
+      .join('\n')
+    const mutationStr = `mutation cancelOrders(${params}) {\n${aliases}\n}`
+    const mutation = gqlstring(mutationStr)
+    const variables = {}
+    cancelOrdersPayloads.forEach((item, index) => {
+      variables[`p${names[index]}`] = item.payload
+      variables[`s${names[index]}`] = item.signature
+    })
+    const result = await this.gql.mutate({
+      mutation,
+      variables
+    })
+    const cancelledOrders = Object.keys(result.data).map(
+      k => result.data[k]
+    ) as CancelledOrder[]
+    return cancelledOrders
+  }
+
+  public async placeLimitOrders(
+    params: PlaceLimitOrderParams[]
+  ): Promise<OrderPlaced[]> {
+    await this.prefillRPoolIfNeededForAssets(
+      params[0].limitPrice.currencyA,
+      params[0].limitPrice.currencyB
+    )
+
+    const placeLimitOrderPayloads = await Promise.all(
+      params.map(async param => {
+        const { nonceOrder, noncesFrom, noncesTo } = this.getNoncesForTrade(
+          param.marketName,
+          param.buyOrSell
+        )
+        const normalizedAmount = normalizeAmountForMarket(
+          param.amount,
+          this.marketData[param.marketName]
+        )
+        const normalizedLimitPrice = normalizePriceForMarket(
+          param.limitPrice,
+          this.marketData[param.marketName]
+        )
+        const placeLimitOrderParams = createPlaceLimitOrderParams(
+          param.allowTaker,
+          normalizedAmount,
+          param.buyOrSell,
+          param.cancellationPolicy,
+          normalizedLimitPrice,
+          param.marketName,
+          noncesFrom,
+          noncesTo,
+          nonceOrder,
+          param.cancelAt
+        )
+        const signedPayload = await this.signPayload(placeLimitOrderParams)
+        return signedPayload
+      })
+    )
+
+    const names = ['A', 'B', 'C', 'D', 'E', 'F'].slice(
+      0,
+      placeLimitOrderPayloads.length
+    )
+    const paramNames = names
+      .map(name => `$p${name}:PlaceLimitOrderParams!, $s${name}:Signature!`)
+      .join(',')
+    const aliases = names
+      .map(
+        name =>
+          `  ${name}: placeLimitOrder(affiliateDeveloperCode: $affiliateDeveloperCode, payload: $p${name}, signature: $s${name}) {\n  id\n  status\n  ordersTillSignState\n }`
+      )
+      .join('\n')
+    const mutationStr = `mutation placeLimitOrders($affiliateDeveloperCode: AffiliateDeveloperCode, ${paramNames}) {\n${aliases}\n}`
+    const mutation = gqlstring(mutationStr)
+
+    const variables = {
+      affiliateDeveloperCode: this.affiliateDeveloperCode
+    }
+
+    placeLimitOrderPayloads.forEach((item, index) => {
+      variables[`p${names[index]}`] = item.signedPayload
+      variables[`s${names[index]}`] = item.signature
+    })
+
+    const result = await this.gql.mutate({
+      mutation,
+      variables
+    })
+
+    return Object.keys(result.data).map(k => result.data[k]) as OrderPlaced[]
+  }
 }

src/client/networks.ts

@@ -47,7 +47,11 @@ export const ETH_NETWORK: NetworkSettingsRecord = {
         contract: '0x00F2B67B5A5EC2FF88B2BE7D5A8D1A39D5929237'
       }
     },
-    nodes: ['https://consensus1.eth.nash.io','https://consensus2.eth.nash.io','https://consensus3.eth.nash.io']
+    nodes: [
+      'https://consensus1.eth.nash.io',
+      'https://consensus2.eth.nash.io',
+      'https://consensus3.eth.nash.io'
+    ]
   },
   [Networks.TestNet]: {
     contracts: {},

src/mutations/orders/cancelOrder.ts

@@ -10,3 +10,19 @@ export const CANCEL_ORDER_MUTATION = gql`
   }
   ${CANCELED_ORDER_FRAGMENT}
 `
+
+export const CANCEL_ORDERS_MUTATION = gql`
+  mutation cancelOrders(
+    $pA: CancelOrderParams!
+    $pB: CancelOrderParams!
+    $sA: Signature!
+    $sB: Signature!
+  ) {
+    a: cancelOrder(payload: $pA, signature: $sA) {
+      orderId
+    }
+    b: cancelOrder(payload: $pB, signature: $sB) {
+      orderId
+    }
+  }
+`

src/types/order.ts

@@ -60,3 +60,13 @@ export interface OrderPlaced {
   status: OrderStatus
   ordersTillSignState: number
 }
+
+export interface PlaceLimitOrderParams {
+  allowTaker: boolean
+  amount: CurrencyAmount
+  buyOrSell: OrderBuyOrSell
+  cancellationPolicy: OrderCancellationPolicy
+  limitPrice: CurrencyPrice
+  marketName: string
+  cancelAt?: DateTime
+}