From 2f0ef07944d11463b46b194119e895d591c79dd3 Mon Sep 17 00:00:00 2001
From: aecsocket <aecsocket@tutanota.com>
Date: Wed, 19 Nov 2025 12:38:30 +0000
Subject: [PATCH] Add logging and change limit of Mural payouts task (#4798)

---
 apps/labrinth/src/background_task.rs     |  3 ++-
 apps/labrinth/src/lib.rs                 |  6 +++---
 apps/labrinth/src/queue/payouts/mural.rs | 18 +++++++++++++++++-
 3 files changed, 22 insertions(+), 5 deletions(-)

diff --git a/apps/labrinth/src/background_task.rs b/apps/labrinth/src/background_task.rs
index 3e1a8a33..ee60a987 100644
--- a/apps/labrinth/src/background_task.rs
+++ b/apps/labrinth/src/background_task.rs
@@ -197,7 +197,8 @@ pub async fn payouts(
 }
 
 pub async fn sync_payout_statuses(pool: sqlx::Pool<Postgres>, mural: MuralPay) {
-    const LIMIT: u32 = 1000;
+    // Mural sets a max limit of 100 for search payouts endpoint
+    const LIMIT: u32 = 100;
 
     info!("Started syncing payout statuses");
 
diff --git a/apps/labrinth/src/lib.rs b/apps/labrinth/src/lib.rs
index a66e1426..9f7c0107 100644
--- a/apps/labrinth/src/lib.rs
+++ b/apps/labrinth/src/lib.rs
@@ -9,7 +9,7 @@ use queue::{
     session::AuthQueue, socket::ActiveSockets,
 };
 use sqlx::Postgres;
-use tracing::{info, warn};
+use tracing::{debug, info, warn};
 
 extern crate clickhouse as clickhouse_crate;
 use clickhouse_crate::Client;
@@ -240,14 +240,14 @@ pub fn app_setup(
             let redis_ref = redis_ref.clone();
 
             async move {
-                info!("Indexing analytics queue");
+                debug!("Indexing analytics queue");
                 let result = analytics_queue_ref
                     .index(client_ref, &redis_ref, &pool_ref)
                     .await;
                 if let Err(e) = result {
                     warn!("Indexing analytics queue failed: {:?}", e);
                 }
-                info!("Done indexing analytics queue");
+                debug!("Done indexing analytics queue");
             }
         });
     }
diff --git a/apps/labrinth/src/queue/payouts/mural.rs b/apps/labrinth/src/queue/payouts/mural.rs
index a5f44d7c..6d1cb3da 100644
--- a/apps/labrinth/src/queue/payouts/mural.rs
+++ b/apps/labrinth/src/queue/payouts/mural.rs
@@ -6,7 +6,7 @@ use muralpay::{MuralError, MuralPay, TokenFeeRequest};
 use rust_decimal::{Decimal, prelude::ToPrimitive};
 use serde::{Deserialize, Serialize};
 use sqlx::PgPool;
-use tracing::warn;
+use tracing::{info, warn};
 
 use crate::{
     database::models::DBPayoutId,
@@ -271,6 +271,8 @@ pub async fn sync_pending_payouts_from_mural(
         status: PayoutStatus,
     }
 
+    info!("Syncing pending payouts from Mural");
+
     let mut txn = db
         .begin()
         .await
@@ -299,6 +301,8 @@ pub async fn sync_pending_payouts_from_mural(
     .await
     .wrap_internal_err("failed to fetch incomplete Mural payouts")?;
 
+    info!("Found {} incomplete Mural payouts", rows.len());
+
     let futs = rows.into_iter().map(|row| async move {
         let platform_id = row.platform_id.wrap_err("no platform ID")?;
         let payout_request_id = platform_id.parse::<muralpay::PayoutRequestId>()
@@ -369,6 +373,8 @@ pub async fn sync_failed_mural_payouts_to_labrinth(
     mural: &MuralPay,
     limit: u32,
 ) -> eyre::Result<()> {
+    info!("Syncing failed Mural payouts to Labrinth");
+
     let mut next_id = None;
     loop {
         let search_resp = mural
@@ -393,6 +399,11 @@ pub async fn sync_failed_mural_payouts_to_labrinth(
             break;
         }
 
+        info!(
+            "Found {} canceled or failed Mural payouts",
+            search_resp.results.len()
+        );
+
         let mut payout_platform_id = Vec::<String>::new();
         let mut payout_new_status = Vec::<String>::new();
 
@@ -430,6 +441,11 @@ pub async fn sync_failed_mural_payouts_to_labrinth(
         .await
         .wrap_internal_err("failed to update payout statuses")?;
 
+        info!(
+            "Updated {} payouts in database from Mural info",
+            payout_platform_id.len()
+        );
+
         if next_id.is_none() {
             break;
         }