feat: listtrades grpc command #667

lib/cli/commands/listtrades.ts

@@ -0,0 +1,21 @@
+import { Arguments } from 'yargs';
+import { callback, loadXudClient } from '../command';
+import { ListTradesRequest } from '../../proto/xudrpc_pb';
+
+export const command = 'listtrades [all]';
+
+export const describe = 'list all trades';
+
+export const builder = {
+  existing: {
+    description: 'should return all trades',
+    type: 'boolean',
+    default: false,
+  },
+};
+
+export const handler = (argv: Arguments) => {
+  const request = new ListTradesRequest();
+  request.setAll(argv.all);
+  loadXudClient(argv).listTrades(request, callback(argv));
+};

lib/grpc/GrpcServer.ts

@@ -34,6 +34,7 @@ class GrpcServer {
       listCurrencies: grpcService.listCurrencies,
       listPairs: grpcService.listPairs,
       listPeers: grpcService.listPeers,
+      listTrades: grpcService.listTrades,
       placeOrder: grpcService.placeOrder,
       placeOrderSync: grpcService.placeOrderSync,
       removeCurrency: grpcService.removeCurrency,

lib/grpc/GrpcService.ts

@@ -413,6 +413,29 @@ class GrpcService {
     }
   }
 
+  /**
+   * See [[Service.listTrades]]
+   */
+  public listTrades: grpc.handleUnaryCall<xudrpc.ListTradesRequest, xudrpc.ListTradesResponse> = async (call, callback) => {
+    try {
+      const listTrades = await this.service.listTrades(call.request.toObject());
+      const response = new xudrpc.ListTradesResponse();
+      const trades: xudrpc.Trade[] = [];
+      listTrades.forEach((trade) => {
+        const grpcTrade = new xudrpc.Trade();
+        grpcTrade.setQuantity(trade.quantity);
+        grpcTrade.setRhash(trade.rHash ? trade.rHash : '');
+        grpcTrade.setMakerorderid(trade.makerOrderId);
+        grpcTrade.setTakerorderid(trade.takerOrderId ? trade.takerOrderId : '');
+        trades.push(grpcTrade);
+      });
+      response.setTradesList(trades);
+      callback(null, response);
+    } catch (err) {
+      callback(this.getGrpcError(err), null);
+    }
+  }
+
   /**
    * See [[Service.listPeers]]
    */

lib/orderbook/OrderBook.ts

@@ -132,6 +132,19 @@ class OrderBook extends EventEmitter {
     });
   }
 
+  /**
+   * Get all trades or a limit number of trades.
+   */
+  public getTrades = async (limit?: number) => {
+    if (limit) {
+      const response = await this.repository.getTradesLimit(limit);
+      return response;
+    } else {
+      const response = await this.repository.getTrades();
+      return response;
+    }
+  }
+
   /**
    * Get lists of buy and sell orders of peers.
    */

lib/orderbook/OrderBookRepository.ts

@@ -51,6 +51,14 @@ class OrderbookRepository {
   public addTrade = (trade: db.TradeFactory) => {
     return this.models.Trade.create(trade);
   }
+
+  public getTrades = (): Bluebird<db.TradeInstance[]> => {
+    return this.models.Trade.findAll();
+  }
+
+  public getTradesLimit = (limit: number): Bluebird<db.TradeInstance[]> => {
+    return this.models.Trade.findAll({ limit });
+  }
 }
 
 export default OrderbookRepository;