Revenue analyst

1import json
2import stripe_data
3 
4subs = stripe_data.subscriptions()
5 
6mrr_usd = 0.0
7customers = set()
8trialing_usd = 0.0
9canceled_count = 0
10mrr_count = 0
11 
12for s in subs:
13    status = s.get("status")
14    if status in ("active", "past_due"):
15        minor = stripe_data.monthly_amount(s)
16        usd = stripe_data.to_usd(minor, s["currency"])
17        mrr_usd += usd
18        customers.add(s["customer"])
19        mrr_count += 1
20    elif status == "trialing":
21        minor = stripe_data.monthly_amount(s)
22        trialing_usd += stripe_data.to_usd(minor, s["currency"])
23    elif status == "canceled":
24        canceled_count += 1
25 
26arr_usd = mrr_usd * 12
27logo_churn = canceled_count / (mrr_count + canceled_count) if (mrr_count + canceled_count) else 0
28 
29result = {
30    "answer": f"Current MRR is ${mrr_usd:,.2f} USD across {len(customers)} customers ({mrr_count} contributing subscriptions), with ARR of ${arr_usd:,.2f} and a trial pipeline of ${trialing_usd:,.2f}.",
31    "value": round(mrr_usd, 2),
32    "unit": "USD",
33    "table": [
34        {"metric": "MRR (USD)", "value": round(mrr_usd, 2)},
35        {"metric": "ARR (USD)", "value": round(arr_usd, 2)},
36        {"metric": "Customers (MRR)", "value": len(customers)},
37        {"metric": "MRR subscriptions", "value": mrr_count},
38        {"metric": "Trial pipeline (USD)", "value": round(trialing_usd, 2)},
39        {"metric": "Canceled subscriptions", "value": canceled_count},
40        {"metric": "Logo churn (current)", "value": round(logo_churn * 100, 2)},
41    ],
42    "method": "Summed monthly_amount (minor units, post-discount) over subscriptions with status active or past_due, converted each to USD via to_usd using the subscription currency, and aggregated.",
43}
44 
45print("RESULT: " + json.dumps(result))