add perp trades endpoint

Signed-off-by: microwavedcola1 <microwavedcola@gmail.com>

mango-service-v3/src/app.ts

@@ -9,6 +9,7 @@ import MarketsController from "./markets.controller";
 import OrdersController from "./orders.controller";
 import WalletController from "./wallet.controller";
 import { AccountController } from "./account.controller";
+import { FillsController } from "./fills";
 
 class App {
   public app: express.Application;
@@ -28,6 +29,7 @@ class App {
         new MarketsController(this.mangoSimpleClient),
         new PositionsController(this.mangoSimpleClient),
         new AccountController(this.mangoSimpleClient),
+        new FillsController(this.mangoSimpleClient),
       ]);
     });
   }

mango-service-v3/src/fills.ts

@@ -0,0 +1,69 @@
+import Controller from "./controller.interface";
+import { NextFunction, Request, Response, Router } from "express";
+import MangoSimpleClient from "./mango.simple.client";
+import { query, validationResult } from "express-validator";
+import { isValidPerpMarket, logger, patchExternalMarketName } from "./utils";
+import { BadRequestError, RequestErrorCustom } from "./dtos";
+import fetch from "node-fetch";
+
+export class FillsController implements Controller {
+  public path = "/api/fills";
+  public router = Router();
+
+  constructor(public mangoSimpleClient: MangoSimpleClient) {
+    this.initializeRoutes();
+  }
+
+  private initializeRoutes() {
+    // GET /fills?market={market_name}
+    this.router.get(
+      this.path,
+      query("market").custom(isValidPerpMarket).optional(),
+      query("page").isNumeric().optional(),
+      this.getPerpFills
+    );
+  }
+
+  private getPerpFills = async (
+    request: Request,
+    response: Response,
+    next: NextFunction
+  ) => {
+    const errors = validationResult(request);
+    if (!errors.isEmpty()) {
+      return response
+        .status(400)
+        .json({ errors: errors.array() as BadRequestError[] });
+    }
+
+    const marketName = request.query.market
+      ? patchExternalMarketName(String(request.query.market))
+      : undefined;
+    const page = request.query.page;
+
+    const allMarkets = await this.mangoSimpleClient.fetchAllMarkets(marketName);
+    const market = allMarkets[Object.keys(allMarkets)[0]];
+
+    // note: flip to example while developing
+    // let eventHistoryPerpTradesUrl = `https://event-history-api.herokuapp.com/perp_trades/CGp2BQS5vgySstS1LHQh46FmPVNZNv9EcgtaaJo7o1yB`;
+    let eventHistoryPerpTradesUrl = `https://event-history-api.herokuapp.com/perp_trades/${this.mangoSimpleClient.mangoAccount.publicKey.toBase58()}`;
+    if (page) {
+      eventHistoryPerpTradesUrl = eventHistoryPerpTradesUrl + `?page=${page}`;
+    }
+    fetch(eventHistoryPerpTradesUrl)
+      .then(async (tradesResponse) => {
+        const parsedTradesResponse = (await tradesResponse.json()) as any;
+        const tradesAcrossAllPerpMarkets = parsedTradesResponse["data"];
+        const tradesForMarket = tradesAcrossAllPerpMarkets.filter(
+          (trade: any) => trade.address === market.publicKey.toBase58()
+        );
+        return response.send({ success: true, result: tradesForMarket });
+      })
+      .catch((error) => {
+        logger.error(`message - ${error.message}, ${error.stack}`);
+        return response.status(500).send({
+          errors: [{ msg: error.message } as RequestErrorCustom],
+        });
+      });
+  };
+}

mango-service-v3/src/utils.ts

@@ -37,6 +37,10 @@ const allMarketNames = mangoGroupConfig.spotMarkets
     )
   );
 
+const allPerpMarketNames = mangoGroupConfig.perpMarkets.map(
+  (perpMarketConfig) => perpMarketConfig.name
+);
+
 const allCoins = mangoGroupConfig.tokens.map(
   (tokenConfig) => tokenConfig.symbol
 );
@@ -81,6 +85,13 @@ export const isValidMarket: CustomValidator = (marketName) => {
   return Promise.resolve();
 };
 
+export const isValidPerpMarket: CustomValidator = (marketName) => {
+  if (allPerpMarketNames.indexOf(marketName) === -1) {
+    return Promise.reject(`Perp Market ${marketName} not supported!`);
+  }
+  return Promise.resolve();
+};
+
 export const isValidCoin: CustomValidator = (coin) => {
   if (allCoins.indexOf(coin) === -1) {
     return Promise.reject(`Coin ${coin} not supported!`);