feat: move stacking dao query to API (#108)

.changeset/wet-trees-hug.md

@@ -0,0 +1,6 @@
+---
+"stackspulse": patch
+"@stackspulse/server": patch
+---
+
+Migrate `/api/protocols/stackingdao` route.

apps/server/src/api/protocols/stackingdao/index.get.ts

@@ -0,0 +1,78 @@
+import { sql } from "~/db/db";
+import { apiCacheConfig } from "~/lib/api";
+
+type StackingDAOProtocolStatsResponse = {
+  month: string;
+  deposits: number;
+  withdrawals: number;
+}[];
+
+export default defineCachedEventHandler(async (event) => {
+  const result = await sql`
+WITH monthly_blocks AS (
+    SELECT
+        DATE_TRUNC('month', TO_TIMESTAMP(burn_block_time)) AS month,
+        MIN(block_height) AS min_block_height,
+        MAX(block_height) AS max_block_height
+    FROM
+        blocks
+    GROUP BY
+        DATE_TRUNC('month', TO_TIMESTAMP(burn_block_time))
+),
+
+deposits AS (
+    SELECT
+        mb.month,
+        SUM(se.amount) AS deposits
+    FROM 
+        monthly_blocks mb
+    JOIN 
+        stx_events se ON se.block_height BETWEEN mb.min_block_height AND mb.max_block_height
+    WHERE
+        se.recipient = 'SP4SZE494VC2YC5JYG7AYFQ44F5Q4PYV7DVMDPBG.reserve-v1'
+        AND se.sender NOT LIKE 'SP4SZE494VC2YC5JYG7AYFQ44F5Q4PYV7DVMDPBG%'
+        AND canonical = TRUE
+        AND microblock_canonical = TRUE
+    GROUP BY 
+        mb.month
+),
+withdrawals AS (
+    SELECT
+        mb.month,
+        SUM(se.amount) AS withdrawals
+    FROM
+        monthly_blocks mb
+    JOIN
+        stx_events se ON se.block_height BETWEEN mb.min_block_height AND mb.max_block_height
+    WHERE
+        se.sender = 'SP4SZE494VC2YC5JYG7AYFQ44F5Q4PYV7DVMDPBG.reserve-v1'
+        AND se.recipient NOT LIKE 'SP4SZE494VC2YC5JYG7AYFQ44F5Q4PYV7DVMDPBG%'
+        AND canonical = TRUE
+        AND microblock_canonical = TRUE
+    GROUP BY
+        mb.month
+)
+SELECT
+    mb.month,
+    COALESCE(d.deposits, 0) AS deposits,
+    COALESCE(w.withdrawals, 0) AS withdrawals
+FROM
+    monthly_blocks mb
+LEFT JOIN
+    deposits d ON mb.month = d.month
+LEFT JOIN
+    withdrawals w ON mb.month = w.month
+ORDER BY
+    mb.month ASC
+  `;
+
+  const stats: StackingDAOProtocolStatsResponse = result.map((row) => ({
+    // format of the month is "2021-08-01 00:00:00+00"
+    // we want to output "2021-08"
+    month: row.month.slice(0, 7),
+    deposits: Number.parseInt(row.deposits),
+    withdrawals: Number.parseInt(row.withdrawals),
+  }));
+
+  return stats;
+}, apiCacheConfig);

apps/web/src/components/Stats/stackingdao/DepositsWithdrawBarChart/index.tsx

@@ -1,34 +1,20 @@
-import { db } from "@/db/db";
-import { transactionTable } from "@/db/schema";
-import { eq, sql } from "drizzle-orm";
+import { env } from "@/env";
+import type { StackingDAOProtocolStatsResponse } from "@/lib/api";
 import { DepositWithdrawBarChartClient } from "./DepositWithdrawBarChartClient";
 
-const getData = async () => {
-  const query = db
-    .select({
-      month: sql<string>`strftime('%Y-%m', timestamp, 'unixepoch') as month`,
-      depositsAmount: sql<number>`sum(case when action = 'stackingdao-deposit' then json->>'outAmount' else 0 end) as depositsAmount`,
-      withdrawalsAmount: sql<number>`sum(case when action = 'stackingdao-withdraw' then json->>'inAmount' else 0 end) as withdrawalsAmount`,
-    })
-    .from(transactionTable)
-    .where(eq(transactionTable.protocol, "stackingdao"))
-    .groupBy(sql`month`);
-
-  const stats = await query;
-  return stats;
-};
-
 export const DepositWithdrawBarChart = async () => {
-  const stats = await getData();
+  const stats: StackingDAOProtocolStatsResponse = await fetch(
+    `${env.NEXT_PUBLIC_API_URL}/api/protocols/stackingdao`,
+  ).then((res) => res.json());
 
   const formattedData: {
     date: string;
     withdrawals: number;
     deposits: number;
   }[] = stats.map((d) => ({
     date: d.month,
-    withdrawals: d.withdrawalsAmount,
-    deposits: d.depositsAmount,
+    withdrawals: d.withdrawals,
+    deposits: d.deposits,
   }));
 
   return <DepositWithdrawBarChartClient data={formattedData} />;

apps/web/src/lib/api.ts

@@ -43,3 +43,13 @@ export type TransactionStatsRouteResponse = {
 export type TransactionStatsRouteQuery = {
   protocol?: Protocol;
 };
+
+/**
+ * `/api/protocols/stackingdao`
+ */
+
+export type StackingDAOProtocolStatsResponse = {
+  month: string;
+  deposits: number;
+  withdrawals: number;
+}[];