chore(analytics): add daily wallet spent query (#895)

* feat(analytics): add daily wallet spent query

* feat(analytics): added query to fetch provider revenue over time

Author: baktun14

doc/Example_Queries.md

@@ -316,4 +316,145 @@ FROM daily_leases l
 GROUP BY date
 ORDER BY date DESC
 
+```
+
+## Query to fetch the daily spent for a wallet address (owner)
+
+```
+WITH daily_leases AS (
+    SELECT 
+        d.date,
+        l.owner,
+        l.denom,
+        l.price,
+        l."createdHeight",
+        CASE 
+            WHEN l.id IS NULL THEN 0
+            ELSE LEAST(d."lastBlockHeightYet", COALESCE(l."closedHeight", l."predictedClosedHeight")) - 
+                 GREATEST(d."firstBlockHeight", l."createdHeight")
+        END as blocks_in_day,
+        d."aktPrice"
+    FROM day d
+    LEFT JOIN lease l ON 
+        l.owner = 'akash120y4k8s9zlpwtkdj94n9mdnd7czt0xuu5yrzes' AND -- change the owner here
+        l."createdHeight" < d."lastBlockHeightYet" AND 
+        COALESCE(l."closedHeight", l."predictedClosedHeight") > d."firstBlockHeight"
+),
+daily_costs AS (
+    SELECT 
+        date,
+        ROUND(CAST(SUM(CASE 
+            WHEN denom = 'uakt' 
+            THEN blocks_in_day * price / 1000000.0
+            ELSE 0 
+        END) as numeric), 2) as daily_akt_spent,
+        ROUND(CAST(SUM(CASE 
+            WHEN denom = 'uusdc' 
+            THEN blocks_in_day * price / 1000000.0
+            ELSE 0 
+        END) as numeric), 2) as daily_usdc_spent,
+        ROUND(CAST(SUM(CASE 
+            WHEN denom = 'uakt' 
+            THEN blocks_in_day * price * "aktPrice" / 1000000.0
+            WHEN denom = 'uusdc' 
+            THEN blocks_in_day * price / 1000000.0
+            ELSE 0 
+        END) as numeric), 2) as daily_usd_spent
+    FROM daily_leases
+    GROUP BY date
+)
+SELECT 
+    d.date::DATE AS "Date",
+    COUNT(dl.owner) AS "Active Leases",
+    COALESCE(dc.daily_akt_spent, 0) as "Daily AKT Spent",
+    COALESCE(SUM(dc.daily_akt_spent) OVER (ORDER BY d.date), 0) as "Total AKT Spent",
+    COALESCE(dc.daily_usdc_spent, 0) as "Daily USDC Spent",
+    COALESCE(SUM(dc.daily_usdc_spent) OVER (ORDER BY d.date), 0) as "Total USDC Spent",
+    COALESCE(dc.daily_usd_spent, 0) as "Daily USD Spent",
+    COALESCE(SUM(dc.daily_usd_spent) OVER (ORDER BY d.date), 0) as "Total USD Spent"
+FROM day d
+LEFT JOIN daily_leases dl ON dl.date = d.date
+LEFT JOIN daily_costs dc ON dc.date = d.date
+GROUP BY 
+    d.date,
+    dc.daily_akt_spent,
+    dc.daily_usdc_spent,
+    dc.daily_usd_spent
+ORDER BY d.date DESC;
+```
+
+## Query to fetch provider revenue over time
+
+```
+WITH filtered_providers AS (
+    SELECT owner, "hostUri"
+    FROM provider
+    WHERE "hostUri" = 'https://provider.europlots.com:8443' -- change the condition to filter providers
+),
+daily_leases AS (
+    SELECT 
+        d.date,
+        p."hostUri",
+        l.id as lease_id,
+        l.denom,
+        l.price,
+        l."createdHeight",
+        CASE 
+            WHEN l.id IS NULL THEN 0
+            ELSE LEAST(d."lastBlockHeightYet", COALESCE(l."closedHeight", l."predictedClosedHeight")) - 
+                 GREATEST(d."firstBlockHeight", l."createdHeight")
+        END as blocks_in_day,
+        d."aktPrice"
+    FROM day d
+    CROSS JOIN filtered_providers p
+    LEFT JOIN lease l ON 
+        p.owner = l."providerAddress" AND
+        l."createdHeight" < d."lastBlockHeightYet" AND 
+        COALESCE(l."closedHeight", l."predictedClosedHeight") > d."firstBlockHeight"
+),
+daily_revenue AS (
+    SELECT 
+        date,
+        "hostUri",
+        ROUND(CAST(SUM(CASE 
+            WHEN denom = 'uakt' 
+            THEN blocks_in_day * price / 1000000.0
+            ELSE 0 
+        END) as numeric), 2) as daily_akt_revenue,
+        ROUND(CAST(SUM(CASE 
+            WHEN denom = 'uusdc' 
+            THEN blocks_in_day * price / 1000000.0
+            ELSE 0 
+        END) as numeric), 2) as daily_usdc_revenue,
+        ROUND(CAST(SUM(CASE 
+            WHEN denom = 'uakt' 
+            THEN blocks_in_day * price * "aktPrice" / 1000000.0
+            WHEN denom = 'uusdc' 
+            THEN blocks_in_day * price / 1000000.0
+            ELSE 0 
+        END) as numeric), 2) as daily_usd_revenue
+    FROM daily_leases
+    WHERE lease_id IS NOT NULL
+    GROUP BY date, "hostUri"
+)
+SELECT 
+    dl.date::DATE AS "Date",
+    dl."hostUri",
+    COUNT(DISTINCT dl.lease_id) AS "Active Leases",
+    COALESCE(dr.daily_akt_revenue, 0) as "Daily AKT Revenue",
+    COALESCE(SUM(dr.daily_akt_revenue) OVER (PARTITION BY dl."hostUri" ORDER BY dl.date), 0) as "Total AKT Revenue",
+    COALESCE(dr.daily_usdc_revenue, 0) as "Daily USDC Revenue",
+    COALESCE(SUM(dr.daily_usdc_revenue) OVER (PARTITION BY dl."hostUri" ORDER BY dl.date), 0) as "Total USDC Revenue",
+    COALESCE(dr.daily_usd_revenue, 0) as "Daily USD Revenue",
+    COALESCE(SUM(dr.daily_usd_revenue) OVER (PARTITION BY dl."hostUri" ORDER BY dl.date), 0) as "Total USD Revenue"
+FROM daily_leases dl
+LEFT JOIN daily_revenue dr ON dr.date = dl.date AND dr."hostUri" = dl."hostUri"
+WHERE dl.lease_id IS NOT NULL
+GROUP BY 
+    dl.date,
+    dl."hostUri",
+    dr.daily_akt_revenue,
+    dr.daily_usdc_revenue,
+    dr.daily_usd_revenue
+ORDER BY dl.date DESC, dl."hostUri";
 ```