Inline Neon dynamic import in all Vercel serverless functions

Remove _db.ts shared helper — Vercel bundles each function separately
so shared imports can fail. Each endpoint now does its own dynamic
import('@neondatabase/serverless').

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

frontend/api/health.ts

@@ -1,27 +1,14 @@
 import type { VercelRequest, VercelResponse } from '@vercel/node'
-import { getDb } from './_db'
 
 export default async function handler(req: VercelRequest, res: VercelResponse) {
   try {
-    const sql = await getDb()
+    const dbUrl = process.env.DATABASE_URL
+    if (!dbUrl) return res.json({ status: 'ok', pipeline_data: false, error: 'no DATABASE_URL' })
+    const { neon } = await import('@neondatabase/serverless')
+    const sql = neon(dbUrl)
     const result = await sql`SELECT count(*) as n FROM pipeline_runs`
-    const hasData = Number(result[0]?.n) > 0
-
-    res.setHeader('Access-Control-Allow-Origin', '*')
-    res.json({
-      status: 'ok',
-      service: 'market-intelligence-agent',
-      version: '1.0.0',
-      pipeline_data: hasData,
-      source: 'neon',
-    })
+    res.json({ status: 'ok', pipeline_data: Number(result[0]?.n) > 0, runs: Number(result[0]?.n), source: 'neon' })
   } catch (e: any) {
-    res.json({
-      status: 'ok',
-      service: 'market-intelligence-agent',
-      version: '1.0.0',
-      pipeline_data: false,
-      source: 'neon-error',
-    })
+    res.json({ status: 'ok', pipeline_data: false, error: e.message })
   }
 }

frontend/api/market-prices.ts

@@ -1,9 +1,12 @@
 import type { VercelRequest, VercelResponse } from '@vercel/node'
-import { getDb } from './_db'
 
 export default async function handler(req: VercelRequest, res: VercelResponse) {
   try {
-    const sql = await getDb()
+    const dbUrl = process.env.DATABASE_URL
+    if (!dbUrl) return res.status(500).json({ error: 'DATABASE_URL not set' })
+    const { neon } = await import('@neondatabase/serverless')
+    const sql = neon(dbUrl)
+
     const prices = await sql`
       SELECT DISTINCT ON (mandi_id, commodity_id)
         run_id, mandi_id, commodity_id, date, source, price_rs,
@@ -12,10 +15,9 @@ export default async function handler(req: VercelRequest, res: VercelResponse) {
       ORDER BY mandi_id, commodity_id, created_at DESC
     `
 
-    // Enrich with mandi/commodity names from config
     const enriched = prices.map((p: any) => ({
       mandi_id: p.mandi_id,
-      mandi_name: p.mandi_id, // Frontend can map these via /api/mandis
+      mandi_name: p.mandi_id,
       commodity_id: p.commodity_id,
       commodity_name: p.commodity_id,
       price_rs: p.price_rs,

frontend/api/pipeline-runs.ts

@@ -1,9 +1,11 @@
 import type { VercelRequest, VercelResponse } from '@vercel/node'
-import { getDb } from './_db'
 
 export default async function handler(req: VercelRequest, res: VercelResponse) {
   try {
-    const sql = await getDb()
+    const dbUrl = process.env.DATABASE_URL
+    if (!dbUrl) return res.status(500).json({ error: 'DATABASE_URL not set' })
+    const { neon } = await import('@neondatabase/serverless')
+    const sql = neon(dbUrl)
     const runs = await sql`
       SELECT run_id, started_at, finished_at, status, duration_sec,
              total_cost_usd, mandis_count, commodities_count, step_results

frontend/api/pipeline-stats.ts

@@ -1,9 +1,11 @@
 import type { VercelRequest, VercelResponse } from '@vercel/node'
-import { getDb } from './_db'
 
 export default async function handler(req: VercelRequest, res: VercelResponse) {
   try {
-    const sql = await getDb()
+    const dbUrl = process.env.DATABASE_URL
+    if (!dbUrl) return res.status(500).json({ error: 'DATABASE_URL not set' })
+    const { neon } = await import('@neondatabase/serverless')
+    const sql = neon(dbUrl)
 
     const runs = await sql`
       SELECT run_id, started_at, status, duration_sec, total_cost_usd,

frontend/api/price-forecast.ts

@@ -1,9 +1,11 @@
 import type { VercelRequest, VercelResponse } from '@vercel/node'
-import { getDb } from './_db'
 
 export default async function handler(req: VercelRequest, res: VercelResponse) {
   try {
-    const sql = await getDb()
+    const dbUrl = process.env.DATABASE_URL
+    if (!dbUrl) return res.status(500).json({ error: 'DATABASE_URL not set' })
+    const { neon } = await import('@neondatabase/serverless')
+    const sql = neon(dbUrl)
     const forecasts = await sql`
       SELECT DISTINCT ON (mandi_id, commodity_id, horizon_days)
         run_id, mandi_id, commodity_id, forecast_date, horizon_days,

frontend/api/sell-recommendations.ts

@@ -1,9 +1,11 @@
 import type { VercelRequest, VercelResponse } from '@vercel/node'
-import { getDb } from './_db'
 
 export default async function handler(req: VercelRequest, res: VercelResponse) {
   try {
-    const sql = await getDb()
+    const dbUrl = process.env.DATABASE_URL
+    if (!dbUrl) return res.status(500).json({ error: 'DATABASE_URL not set' })
+    const { neon } = await import('@neondatabase/serverless')
+    const sql = neon(dbUrl)
     const recs = await sql`
       SELECT DISTINCT ON (farmer_id)
         run_id, farmer_id, commodity_id, best_mandi_id, best_timing,