payment: fix allocation released filter

payment: fix again
golemfactory · Jul 9, 2024 · ccf8016 · ccf8016
1 parent e85ea62
commit ccf8016
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/core/payment/src/dao/allocation.rs b/core/payment/src/dao/allocation.rs
@@ -162,7 +162,7 @@ impl<'c> AllocationDao<'c> {
         readonly_transaction(self.pool, "allocation_dao_get_filtered", move |conn| {
             let mut query = dsl::pay_allocation.into_boxed();
             if let Some(released) = released {
-                query = query.filter(dsl::released.eq(false));
+                query = query.filter(dsl::released.eq(released));
             }
             if let Some(owner_id) = owner_id {
                 query = query.filter(dsl::owner_id.eq(owner_id))

diff --git a/core/payment/src/processor.rs b/core/payment/src/processor.rs
@@ -805,10 +805,10 @@ impl PaymentProcessor {
             let dao = db.as_dao::<AllocationDao>();
 
             let active = dao
-                .get_for_address(platform.clone(), address.clone(), None)
+                .get_for_address(platform.clone(), address.clone(), Some(false))
                 .await?;
             let past = dao
-                .get_for_address(platform.clone(), address.clone(), None)
+                .get_for_address(platform.clone(), address.clone(), Some(true))
                 .await?;
 
             (active, past)