fix: persist node id of peer for swapped order

This fixes a bug where the node id of the peer with whom we swapped is
missing when persisting a swapped order to the database.

lib/orderbook/OrderBook.ts

@@ -546,7 +546,12 @@ class OrderBook extends EventEmitter {
    */
   public executeSwap = async (maker: PeerOrder, taker: OwnOrder): Promise<SwapSuccess> => {
     // make sure the order is in the database before we begin the swap
-    await this.repository.addOrderIfNotExists(maker);
+    if (!(await this.repository.getOrder(maker.id))) {
+      await this.repository.addOrderIfNotExists({
+        ...maker,
+        nodeId: this.pool.getNodeId(maker.peerPubKey),
+      });
+    }
     try {
       const swapResult = await this.swaps.executeSwap(maker, taker);
       this.emit('peerOrder.filled', maker);
@@ -583,6 +588,7 @@ class OrderBook extends EventEmitter {
     if (takerOrder) {
       addOrderPromises.push(this.repository.addOrderIfNotExists(takerOrder));
     }
+
     await Promise.all(addOrderPromises);
     await this.repository.addTrade({
       quantity,

lib/orderbook/OrderBookRepository.ts

@@ -48,6 +48,12 @@ class OrderbookRepository {
     }
   }
 
+  public getOrder = (id: string) => {
+    return this.models.Order.findOne({
+      where: { id },
+    });
+  }
+
   public addTrade = (trade: db.TradeFactory) => {
     return this.models.Trade.create(trade);
   }

lib/p2p/NodeList.ts

@@ -52,6 +52,10 @@ class NodeList extends EventEmitter {
     this.nodes.forEach(callback);
   }
 
+  public getId = (nodePubKey: string) => {
+    return this.nodes.get(nodePubKey)?.id;
+  }
+
   /**
    * Return list of public keys of all banned nodes with a given alias.
    */

lib/p2p/Pool.ts

@@ -153,6 +153,10 @@ class Pool extends EventEmitter {
     return this.nodeState.tokenIdentifiers[currency];
   }
 
+  public getNodeId = (nodePubKey: string) => {
+    return this.nodes.getId(nodePubKey);
+  }
+
   /**
    * Initialize the Pool by connecting to known nodes and listening to incoming peer connections, if configured to do so.
    */