feat(OrderBook.ts) persist trades to DB

lib/orderbook/OrderBook.ts

@@ -300,6 +300,7 @@ class OrderBook extends EventEmitter {
         portion.localId = maker.localId;
         result.internalMatches.push(maker);
         this.emit('ownOrder.filled', portion);
+        await this.perssitTrade(portion.quantity, maker.id, taker.id);
         onUpdate && onUpdate({ case: PlaceOrderEventCase.InternalMatch, payload: maker });
       } else {
         if (!this.swaps) {
@@ -314,6 +315,7 @@ class OrderBook extends EventEmitter {
           await this.repository.addOrderIfNotExists(maker);
           const swapResult = await this.swaps.executeSwap(maker, taker);
           this.emit('peerOrder.filled', portion);
+          await this.perssitTrade(swapResult.quantity, maker.id, taker.id);
           result.swapResults.push(swapResult);
           onUpdate && onUpdate({ case: PlaceOrderEventCase.SwapResult, payload: swapResult });
         } catch (err) {
@@ -361,6 +363,7 @@ class OrderBook extends EventEmitter {
     try {
       const swapResult = await this.swaps!.executeSwap(maker, taker);
       this.emit('peerOrder.filled', maker);
+      await this.perssitTrade(swapResult.quantity, maker.id, taker.id);
       return swapResult;
     } catch (err) {
       this.emit('peerOrder.invalidation', maker);
@@ -387,6 +390,14 @@ class OrderBook extends EventEmitter {
     return true;
   }
 
+  private perssitTrade = async (quantity: number, makerOrderId: string, takerOrderId: string) => {
+    await this.repository.addTrade({
+      makerOrderId,
+      takerOrderId,
+      quantity,
+    });
+  }
+
   /**
    * Adds an incoming peer order to the local order book. It timestamps the order based on when it
    * enters the order book and also records its initial quantity upon being received.

lib/orderbook/OrderBookRepository.ts

@@ -40,6 +40,10 @@ class OrderbookRepository {
       await this.models.Order.create(order as OrderAttributes);
     }
   }
+
+  public addTrade = async (trade: db.TradeFactory) => {
+    await this.models.Trade.create(trade);
+  }
 }
 
 export default OrderbookRepository;