From ccf80164cba0377610f358e4940d2aa8a68623e6 Mon Sep 17 00:00:00 2001 From: Kamil Koczurek Date: Wed, 29 May 2024 13:41:29 +0200 Subject: [PATCH] payment: fix allocation released filter payment: fix again --- core/payment/src/dao/allocation.rs | 2 +- core/payment/src/processor.rs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/core/payment/src/dao/allocation.rs b/core/payment/src/dao/allocation.rs index 1a31ff48d5..baf40d8e10 100644 --- 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 index 52b58d9ef0..1b5229b37e 100644 --- a/core/payment/src/processor.rs +++ b/core/payment/src/processor.rs @@ -805,10 +805,10 @@ impl PaymentProcessor { let dao = db.as_dao::(); 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)