test: TransactionDirect status in sidecar

Author: jackstar12

boltzr/src/chain/mrh_watcher.rs

@@ -62,7 +62,6 @@ impl MrhWatcher {
             let update = SwapStatus {
                 id: routing_hint.swapId.clone(),
                 status: SwapUpdateStatus::TransactionDirect.to_string(),
-                zero_conf_rejected: None,
                 transaction: Some(TransactionInfo {
                     id: tx.txid_hex(),
                     hex: Some(tx.serialize().to_lower_hex_string()),
@@ -111,7 +110,6 @@ mod test {
 
     #[tokio::test]
     async fn test_listen() {
-        // Create broadcast channels
         let (swap_status_update_tx, mut swap_status_update_rx) = broadcast::channel(256);
         let (tx_sender, tx_receiver) = broadcast::channel(256);
 
@@ -145,7 +143,10 @@ mod test {
         let received_update = swap_status_update_rx.recv().await.unwrap();
 
         assert_eq!(received_update.id, "123");
-        assert_eq!(received_update.status, "transaction.direct");
+        assert_eq!(
+            received_update.status,
+            SwapUpdateStatus::TransactionDirect.to_string()
+        );
         assert!(received_update.transaction.is_some());
 
         let transaction_info = received_update.transaction.unwrap();

test/integration/sidecar/Sidecar.spec.ts

@@ -74,6 +74,30 @@ describe('Sidecar', () => {
       );
     });
 
+    test(`should handle status ${SwapUpdateEvent.TransactionDirect}`, async () => {
+      const update = new sidecarrpc.SwapUpdate();
+      update.setId('test-swap');
+      update.setStatus(SwapUpdateEvent.TransactionDirect);
+      const transactionInfo = new sidecarrpc.SwapUpdate.TransactionInfo();
+      transactionInfo.setId('txid');
+      transactionInfo.setHex('hex');
+      update.setTransactionInfo(transactionInfo as any);
+
+      await sidecar['handleSentSwapUpdate'](update);
+
+      expect(eventHandler.nursery.emit).toHaveBeenCalledTimes(1);
+      expect(eventHandler.nursery.emit).toHaveBeenCalledWith('swap.update', {
+        id: update.getId(),
+        status: {
+          status: SwapUpdateEvent.TransactionDirect,
+          transaction: {
+            id: transactionInfo.getId(),
+            hex: transactionInfo.getHex(),
+          },
+        },
+      });
+    });
+
     test.each`
       status
       ${SwapUpdateEvent.InvoicePaid}