add transactions api endpoint

Author: karooolis

packages/explorer/package.json

@@ -69,6 +69,7 @@
     "next": "14.2.5",
     "node-sql-parser": "^5.3.3",
     "nuqs": "^1.19.2",
+    "pg": "^8.13.1",
     "query-string": "^9.1.0",
     "react": "^18",
     "react-dom": "^18",
@@ -85,6 +86,7 @@
     "@trivago/prettier-plugin-sort-imports": "^4.3.0",
     "@types/better-sqlite3": "^7.6.4",
     "@types/debug": "^4.1.7",
+    "@types/pg": "^8.11.10",
     "@types/react": "18.2.22",
     "@types/react-dom": "18.2.7",
     "@types/yargs": "^17.0.10",

packages/explorer/src/app/(explorer)/api/transactions/route.ts

@@ -0,0 +1,35 @@
+import { Client } from "pg";
+import { Hex } from "viem";
+
+const postgresConnectionUrl = process.env.DATABASE_URL;
+
+export async function GET(req: Request) {
+  const client = new Client({ connectionString: postgresConnectionUrl });
+  const { searchParams } = new URL(req.url);
+  const worldAddress = searchParams.get("worldAddress") as Hex;
+  const offset = Number(searchParams.get("offset")) || 0;
+  const limit = Number(searchParams.get("limit")) || 10;
+  const columns = searchParams.get("columns") || "*";
+
+  if (!worldAddress) {
+    return Response.json({ error: "Missing worldAddress" }, { status: 400 });
+  }
+
+  try {
+    await client.connect();
+
+    const transactions = await client.query(
+      `SELECT ${columns} FROM transactions WHERE tx_to = decode($1, 'hex') ORDER BY block_num DESC OFFSET $2 LIMIT $3`,
+      [worldAddress, offset, limit],
+    );
+
+    return Response.json({
+      transactions: transactions.rows,
+    });
+  } catch (error) {
+    console.error("Database error:", error);
+    return Response.json({ error: "Failed to fetch transactions" }, { status: 500 });
+  } finally {
+    await client.end();
+  }
+}