diff --git a/crates/schema/database/mysql_queries/src/queries/wallets/add_durable_banked_balance_to_wallet.rs b/crates/schema/database/mysql_queries/src/queries/wallets/add_durable_banked_balance_to_wallet.rs index 50fa7d4945..616ed2e58f 100644 --- a/crates/schema/database/mysql_queries/src/queries/wallets/add_durable_banked_balance_to_wallet.rs +++ b/crates/schema/database/mysql_queries/src/queries/wallets/add_durable_banked_balance_to_wallet.rs @@ -10,6 +10,7 @@ pub async fn add_durable_banked_balance_to_wallet( wallet_token: &WalletToken, amount_to_add: u64, maybe_ledger_ref: Option<&str>, + wallet_ledger_entry_type_override: Option, transaction: &mut sqlx::Transaction<'_, MySql>, ) -> anyhow::Result { @@ -38,7 +39,7 @@ pub async fn add_durable_banked_balance_to_wallet( let record = InsertWalletLedgerEntry { wallet_token, - entry_type: WalletLedgerEntryType::CreditBanked, + entry_type: wallet_ledger_entry_type_override.unwrap_or(WalletLedgerEntryType::CreditBanked), maybe_entity_ref: maybe_ledger_ref.map(|t| t.to_string()), credits_delta: amount_to_add.to_i64().unwrap_or(0), diff --git a/crates/service/plugins/billing_artcraft/src/billing_action_fulfillment/credits_pack/complete_credits_pack_purchase.rs b/crates/service/plugins/billing_artcraft/src/billing_action_fulfillment/credits_pack/complete_credits_pack_purchase.rs index 99ff45e260..061e665d4c 100644 --- a/crates/service/plugins/billing_artcraft/src/billing_action_fulfillment/credits_pack/complete_credits_pack_purchase.rs +++ b/crates/service/plugins/billing_artcraft/src/billing_action_fulfillment/credits_pack/complete_credits_pack_purchase.rs @@ -38,9 +38,10 @@ pub async fn complete_credits_pack_purchase( info!("Adding {} credits to wallet: {}", credits_purchased, wallet_token.as_str()); let _result = add_durable_banked_balance_to_wallet( - &wallet_token, - credits_purchased, + &wallet_token, + credits_purchased, maybe_ledger_ref, + None, transaction, ).await?;