postgresql: commit add_claim tx

breez · Jan 27, 2025 · d3154b0 · d3154b0
1 parent b1fb25b
commit d3154b0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/swapd/src/postgresql/claim_repository.rs b/swapd/src/postgresql/claim_repository.rs
@@ -70,6 +70,7 @@ impl claim::ClaimRepository for ClaimRepository {
         .execute(&mut *db_tx)
         .await?;
 
+        db_tx.commit().await?;
         Ok(())
     }
 
@@ -86,7 +87,7 @@ impl claim::ClaimRepository for ClaimRepository {
                ,      r.fee_per_kw
                ,      r.auto_bump
                FROM claims r
-               WHERE tx_id IN (
+               WHERE r.tx_id IN (
                    SELECT ri.claim_tx_id
                    FROM claim_inputs ri
                    WHERE ri.tx_id NOT IN (