fix(wallet): use subgraph for staking/orchestrators (Browse All root cause)

The staking/orchestrators route (used by Browse All via useOrchestratorCache)
was purely DB-based, returning only 7 records from the unpopulated production
DB. The Express backend calls getOrchestrators() (subgraph) directly.

Fixed to match Express: call getOrchestrators() from subgraph, returning
~100 active orchestrators. Also cleaned up diagnostic logging from
enhanced route and subgraph utility.

Made-with: Cursor

Author: seanhanca

apps/web-next/src/app/api/v1/wallet/orchestrators/enhanced/route.ts

@@ -26,14 +26,9 @@ export async function GET(request: NextRequest) {
           },
         },
       }),
-      getOrchestrators().catch((err) => {
-        console.error('[orchestrators/enhanced] subgraph failed, falling back to DB:', err?.message || err);
-        return [] as any[];
-      }),
+      getOrchestrators().catch(() => [] as any[]),
     ]);
 
-    console.log(`[orchestrators/enhanced] db=${dbOrchestrators.length} live=${liveOrchestrators.length}`);
-
     const dbMap = new Map(
       dbOrchestrators.map((o) => [o.address.toLowerCase(), o]),
     );
@@ -109,11 +104,7 @@ export async function GET(request: NextRequest) {
       }));
     }
 
-    return NextResponse.json({
-      data,
-      synced,
-      _debug: { dbCount: dbOrchestrators.length, liveCount: liveOrchestrators.length, source: liveOrchestrators.length > 0 ? 'subgraph' : 'db' },
-    });
+    return NextResponse.json({ data, synced });
   } catch (err) {
     console.error('[orchestrators/enhanced] Error:', err);
     return errors.internal('Failed to fetch enhanced orchestrators');

apps/web-next/src/app/api/v1/wallet/staking/orchestrators/route.ts

@@ -1,12 +1,14 @@
 /**
  * Wallet Staking Orchestrators API Routes
  * GET /api/v1/wallet/staking/orchestrators - List orchestrators
+ *
+ * Mirrors the Express backend: always fetches live data from the subgraph.
  */
 
-import {NextRequest, NextResponse } from 'next/server';
-import { prisma } from '@/lib/db';
+import { NextRequest, NextResponse } from 'next/server';
 import { validateSession } from '@/lib/api/auth';
-import { success, errors, getAuthToken } from '@/lib/api/response';
+import { errors, getAuthToken } from '@/lib/api/response';
+import { getOrchestrators } from '@/lib/wallet/subgraph';
 
 export async function GET(request: NextRequest): Promise<NextResponse> {
   try {
@@ -20,24 +22,9 @@ export async function GET(request: NextRequest): Promise<NextResponse> {
       return errors.unauthorized('Invalid or expired session');
     }
 
-    const searchParams = request.nextUrl.searchParams;
-    const chainId = searchParams.get('chainId');
-    const activeOnly = searchParams.get('activeOnly') !== 'false';
+    const orchestrators = await getOrchestrators();
 
-    const where: {
-      chainId?: number;
-      isActive?: boolean;
-    } = {};
-
-    if (chainId) where.chainId = parseInt(chainId, 10);
-    if (activeOnly) where.isActive = true;
-
-    const orchestrators = await prisma.walletOrchestrator.findMany({
-      where,
-      orderBy: { totalStake: 'desc' },
-    });
-
-    return success({ orchestrators });
+    return NextResponse.json({ data: { orchestrators } });
   } catch (err) {
     console.error('Error fetching orchestrators:', err);
     return errors.internal('Failed to fetch orchestrators');

apps/web-next/src/lib/wallet/subgraph.ts

@@ -26,15 +26,11 @@ export async function querySubgraph<T = any>(query: string): Promise<T> {
         body: JSON.stringify({ query }),
         signal: AbortSignal.timeout(15_000),
       });
-      if (!res.ok) {
-        const body = await res.text().catch(() => '');
-        throw new Error(`Subgraph ${res.status}: ${body.slice(0, 200)}`);
-      }
+      if (!res.ok) throw new Error(`Subgraph ${res.status}`);
       const json = await res.json();
       if (json.errors?.length) throw new Error(json.errors[0].message);
       return json.data as T;
     } catch (err) {
-      console.error(`[querySubgraph] URL ${url.slice(0, 60)}... failed:`, (err as Error).message);
       lastErr = err as Error;
     }
   }
@@ -44,8 +40,6 @@ export async function querySubgraph<T = any>(query: string): Promise<T> {
 export async function getOrchestrators() {
   const protocol = await getProtocol();
   const round = protocol.currentRound;
-  console.log(`[getOrchestrators] round=${round}, SUBGRAPH_API_KEY=${process.env.SUBGRAPH_API_KEY ? 'set' : 'MISSING'}`);
-
   const data = await querySubgraph<{ transcoders: any[] }>(`{
     transcoders(
       first: 100