/** * POST /api/geoportal/enrich * * Enriches parcels for a given SIRUTA. Skips already-enriched features. * Tries: 1) Active eTerra session, 2) Env credentials, 3) Returns clear error. * Enrichment data is PERSISTED in GisFeature.enrichment column. * * Body: { siruta: string } */ import { NextResponse } from "next/server"; import { EterraClient } from "@/modules/parcel-sync/services/eterra-client"; import { enrichFeatures } from "@/modules/parcel-sync/services/enrich-service"; import { getSessionCredentials } from "@/modules/parcel-sync/services/session-store"; export const runtime = "nodejs"; export const dynamic = "force-dynamic"; export async function POST(req: Request) { try { const body = (await req.json()) as { siruta?: string }; const siruta = String(body.siruta ?? "").trim(); if (!siruta) { return NextResponse.json({ error: "SIRUTA obligatoriu" }, { status: 400 }); } // Try multiple credential sources const session = getSessionCredentials(); const username = session?.username || process.env.ETERRA_USERNAME || ""; const password = session?.password || process.env.ETERRA_PASSWORD || ""; if (!username || !password) { return NextResponse.json( { error: "Credentiale eTerra indisponibile. Deschide eTerra Parcele si logheaza-te mai intai, apoi revino aici." }, { status: 401 } ); } let client: EterraClient; try { client = await EterraClient.create(username, password); } catch (loginErr) { const loginMsg = loginErr instanceof Error ? loginErr.message : "Login esuat"; return NextResponse.json( { error: `Login eTerra esuat: ${loginMsg}. Verifica credentialele in eTerra Parcele.` }, { status: 401 } ); } const result = await enrichFeatures(client, siruta); return NextResponse.json({ status: result.status, enrichedCount: result.enrichedCount, buildingCrossRefs: result.buildingCrossRefs, message: result.enrichedCount > 0 ? `${result.enrichedCount} parcele imbogatite cu succes` : "Toate parcelele au deja date de enrichment", }); } catch (error) { const msg = error instanceof Error ? error.message : "Eroare la enrichment"; // Provide actionable error messages if (msg.includes("timeout") || msg.includes("ETIMEDOUT")) { return NextResponse.json({ error: "eTerra nu raspunde (timeout). Incearca mai tarziu." }, { status: 504 }); } if (msg.includes("maintenance") || msg.includes("Mentenan")) { return NextResponse.json({ error: "eTerra este in mentenanta. Incearca mai tarziu." }, { status: 503 }); } return NextResponse.json({ error: msg }, { status: 500 }); } }