Log more details about created invoices

estuary · Oct 2, 2024 · e516a9f · e516a9f
1 parent b562e71
commit e516a9f
Showing 1 changed file with 19 additions and 13 deletions.
diff --git a/crates/billing-integrations/src/stripe.rs b/crates/billing-integrations/src/stripe.rs
@@ -716,21 +716,27 @@ pub async fn do_publish_invoices(cmd: &PublishInvoice) -> anyhow::Result<()> {
             status.message(),
             *subtotal_agg as f64 / 100.0
         );
-        for (tenant, subtotal) in
-            tenants
-                .iter()
-                .sorted_by(|(_, a), (_, b)| b.cmp(a))
-                .take(match status {
-                    InvoiceResult::Created(_) | InvoiceResult::Updated => 8,
-                    InvoiceResult::NoDataMoved
-                    | InvoiceResult::NoFullPipeline
-                    | InvoiceResult::LessThanMinimum
-                    | InvoiceResult::FreeTier => 0,
-                    _ => 4,
-                })
-        {
+        let limit = match status {
+            InvoiceResult::Created(_) | InvoiceResult::Updated => 30,
+            InvoiceResult::NoDataMoved
+            | InvoiceResult::NoFullPipeline
+            | InvoiceResult::LessThanMinimum
+            | InvoiceResult::FreeTier => 0,
+            _ => 4,
+        };
+        let sorted_tenants = tenants
+            .iter()
+            .sorted_by(|(_, a), (_, b)| b.cmp(a))
+            .collect_vec();
+
+        let (displayed_tenants, remainder_tenants) =
+            sorted_tenants.split_at(limit.min(tenants.len()));
+        for (tenant, subtotal) in displayed_tenants {
             tracing::info!(" - {:} ${:.2}", tenant, *subtotal as f64 / 100.0);
         }
+        if limit > 0 && remainder_tenants.len() > 0 {
+            tracing::info!(" - ... {} Others", remainder_tenants.len(),);
+        }
     }
 
     Ok(())