Rebased

Author: rsercano

docs/api.md

@@ -0,0 +1,29 @@
+import { Arguments, Argv } from 'yargs';
+import { RemoveAllOrdersRequest, RemoveAllOrdersResponse } from '../../proto/xudrpc_pb';
+import { callback, loadXudClient } from '../command';
+
+export const command = 'removeallorders';
+
+export const describe = 'removes all orders';
+
+export const builder = (argv: Argv) => argv
+    .example('$0 removeallorders', describe);
+
+const formatOutput = (response: RemoveAllOrdersResponse.AsObject) => {
+  if (response.removedOrderIdsList.length <= 0 && response.onHoldOrderIdsList.length <= 0) {
+    console.log('No orders found');
+    return;
+  }
+
+  if (response.removedOrderIdsList.length) {
+    response.removedOrderIdsList.forEach((removedOrder => console.log(`Removed order with id ${removedOrder}`)));
+  }
+  if (response.onHoldOrderIdsList.length) {
+    response.onHoldOrderIdsList.forEach((id => console.log(`Order with id ${id} has a hold for a pending swap and will be removed afterwards`)));
+  }
+
+};
+
+export const handler = async (argv: Arguments<any>) => {
+  (await loadXudClient(argv)).removeAllOrders(new RemoveAllOrdersRequest(), callback(argv, formatOutput));
+};

lib/cli/commands/removeallorders.ts

@@ -288,6 +288,26 @@ class GrpcService {
     }
   }
 
+  /**
+   * See [[Service.removeAllOrders]]
+   */
+  public removeAllOrders: grpc.handleUnaryCall<xudrpc.RemoveAllOrdersRequest, xudrpc.RemoveAllOrdersResponse> = async (_, callback) => {
+    if (!this.isReady(this.service, callback)) {
+      return;
+    }
+    try {
+      const { removedOrderLocalIds, onHoldOrderLocalIds } = await this.service.removeAllOrders();
+
+      const response = new xudrpc.RemoveAllOrdersResponse();
+      response.setRemovedOrderIdsList(removedOrderLocalIds);
+      response.setOnHoldOrderIdsList(onHoldOrderLocalIds);
+
+      callback(null, response);
+    } catch (err) {
+      callback(getGrpcError(err), null);
+    }
+  }
+
   /**
    * See [[Service.getBalance]]
    */

lib/grpc/GrpcService.ts

@@ -841,6 +841,22 @@ class OrderBook extends EventEmitter {
     return order;
   }
 
+  public removeOwnOrders = () => {
+    const removedOrderLocalIds = [];
+    const onHoldOrderLocalIds = [];
+
+    for (const localId of this.localIdMap.keys()) {
+      const onHoldIndicator = this.removeOwnOrderByLocalId(localId, true);
+      if (onHoldIndicator === 0) {
+        removedOrderLocalIds.push(localId);
+      } else {
+        onHoldOrderLocalIds.push(localId);
+      }
+    }
+
+    return { removedOrderLocalIds, onHoldOrderLocalIds };
+  }
+
   /**
    * Removes all or part of an order from the order book by its local id. Throws an error if the
    * specified pairId is not supported or if the order to cancel could not be found.