eightequal/AstralRinth
1
0
Fork 0
forked from didirus/AstralRinth
Code Pull Requests Activity

Automatically fail payments that are older than 30 days (#3697)

Browse Source
This commit is contained in:
Emma Alexia
2025-05-25 15:36:19 -04:00
committed by GitHub
parent 84adf79564
commit 74cf3f076e
2 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
apps/labrinth/.sqlx/query-33893ae0a7d244c33b489e4d4fa444fa17a6bb5b7a834794a5482f4dc85c6ce0.json generated Normal file
View File

@@ -0,0 +1,15 @@
{
"db_name": "PostgreSQL",
"query": "\n UPDATE payouts\n SET status = $1\n WHERE status = $2 AND created < NOW() - INTERVAL '30 days'\n ",
"describe": {
"columns": [],
"parameters": {
"Left": [
"Varchar",
"Text"
]
},
"nullable": []
},
"hash": "33893ae0a7d244c33b489e4d4fa444fa17a6bb5b7a834794a5482f4dc85c6ce0"
}

12
apps/labrinth/src/queue/payouts.rs
View File

@@ -735,6 +735,18 @@ pub async fn process_payout(
pool: &PgPool, pool: &PgPool,
client: &clickhouse::Client, client: &clickhouse::Client,
) -> Result<(), ApiError> { ) -> Result<(), ApiError> {
sqlx::query!(
"
UPDATE payouts
SET status = $1
WHERE status = $2 AND created < NOW() - INTERVAL '30 days'
",
crate::models::payouts::PayoutStatus::Failed.as_str(),
crate::models::payouts::PayoutStatus::InTransit.as_str(),
)
.execute(pool)
.await?;
let start: DateTime<Utc> = DateTime::from_naive_utc_and_offset( let start: DateTime<Utc> = DateTime::from_naive_utc_and_offset(
(Utc::now() - Duration::days(1)) (Utc::now() - Duration::days(1))
.date_naive() .date_naive()