[#963] Add txHash deduplication to indexer endpoints

package.json

@@ -1,6 +1,6 @@
 {
   "name": "plotlink",
-  "version": "0.1.50",
+  "version": "0.1.51",
   "private": true,
   "workspaces": [
     "packages/*"

src/app/api/index/donation/route.ts

@@ -1,6 +1,6 @@
 import { NextResponse } from "next/server";
 import { type Hex, decodeEventLog, encodeEventTopics } from "viem";
 import { publicClient, getReceiptWithRetry } from "../../../../../lib/rpc";
 import { createServerClient } from "../../../../../lib/supabase";
 import { validateRecentTx } from "../../../../../lib/index-auth";
 import {
@@ -28,6 +28,20 @@
     return error("Missing or invalid txHash");
   }
 
+  // 0. DB dedup — skip RPC/IPFS if already indexed
+  const supabaseDedup = createServerClient();
+  if (supabaseDedup) {
+    const { data: existing } = await supabaseDedup
+      .from("donations")
+      .select("id")
+      .eq("tx_hash", txHash)
+      .limit(1)
+      .maybeSingle();
+    if (existing) {
+      return NextResponse.json({ ok: true, cached: true });
+    }
+  }
+
   // 1. Validate tx exists and is recent (< 5 min) — prevents spam
   const receipt = await validateRecentTx(txHash);
   if (!receipt) {

src/app/api/index/plot/route.ts

@@ -1,6 +1,6 @@
 import { NextResponse } from "next/server";
 import { type Hex, decodeEventLog, encodeEventTopics } from "viem";
 import { publicClient, getReceiptWithRetry } from "../../../../../lib/rpc";
 import { createServerClient } from "../../../../../lib/supabase";
 import { validateRecentTx } from "../../../../../lib/index-auth";
 import {
@@ -34,6 +34,20 @@
     return error("Missing or invalid txHash");
   }
 
+  // 0. DB dedup — skip RPC/IPFS if already indexed
+  const supabaseDedup = createServerClient();
+  if (supabaseDedup) {
+    const { data: existing } = await supabaseDedup
+      .from("plots")
+      .select("id")
+      .eq("tx_hash", txHash)
+      .limit(1)
+      .maybeSingle();
+    if (existing) {
+      return NextResponse.json({ ok: true, cached: true });
+    }
+  }
+
   // 1. Validate tx exists and is recent (< 5 min) — prevents spam
   const receipt = await validateRecentTx(txHash);
   if (!receipt) {

src/app/api/index/storyline/route.ts

@@ -1,6 +1,6 @@
 import { NextResponse } from "next/server";
 import { type Hex, decodeEventLog, encodeEventTopics } from "viem";
 import { publicClient, getReceiptWithRetry } from "../../../../../lib/rpc";
 import { createServerClient } from "../../../../../lib/supabase";
 import { validateRecentTx } from "../../../../../lib/index-auth";
 import {
@@ -41,6 +41,20 @@
     return error("Missing or invalid txHash");
   }
 
+  // 0. DB dedup — skip RPC/IPFS if already indexed
+  const supabaseDedup = createServerClient();
+  if (supabaseDedup) {
+    const { data: existing } = await supabaseDedup
+      .from("storylines")
+      .select("id")
+      .eq("tx_hash", txHash)
+      .limit(1)
+      .maybeSingle();
+    if (existing) {
+      return NextResponse.json({ ok: true, cached: true });
+    }
+  }
+
   // 1. Validate tx exists and is recent (< 5 min) — prevents spam
   const receipt = await validateRecentTx(txHash);
   if (!receipt) {

src/app/api/index/trade/route.ts

@@ -1,6 +1,6 @@
 import { NextResponse } from "next/server";
 import { type Hex, decodeEventLog, formatUnits } from "viem";
 import { publicClient, getReceiptWithRetry } from "../../../../../lib/rpc";
 import { createServerClient } from "../../../../../lib/supabase";
 import { mcv2BondEventAbi } from "../../../../../lib/contracts/abi";
 import { MCV2_BOND, ZAP_PLOTLINK } from "../../../../../lib/contracts/constants";
@@ -23,6 +23,10 @@
   if (!txHash || !/^0x[0-9a-fA-F]{64}$/.test(txHash)) return error("Missing or invalid txHash");
   if (!tokenAddress) return error("tokenAddress required");
 
+  // Trade route skips early dedup: a single tx can produce multiple trade logs,
+  // and partial indexing on a previous attempt must not block retries.
+  // Per-log upserts handle duplicates safely without IPFS cost.
+
   // Validate tx exists and is recent (< 5 min) — prevents spam with fake hashes
   const validatedReceipt = await validateRecentTx(txHash);
   if (!validatedReceipt) return error("Transaction not found, failed, or too old", 400);