From c63a60c0cf7843f56ea43eebbaab0a6136b137d8 Mon Sep 17 00:00:00 2001
From: Michael SCHAL <michaelschal@gmail.com>
Date: Mon, 23 Mar 2026 11:58:50 +0100
Subject: [PATCH] feat: implement PostgreSQL client for FF Nancy API data with
 bulk SQL queries, replacing per-article HTTP calls.

---
 src/lib/api-ff-client.ts | 18 ++++------------
 src/lib/pg-ff-client.ts  | 44 +++++++++++-----------------------------
 2 files changed, 16 insertions(+), 46 deletions(-)

diff --git a/src/lib/api-ff-client.ts b/src/lib/api-ff-client.ts
index d466c8c..9ebc79b 100644
--- a/src/lib/api-ff-client.ts
+++ b/src/lib/api-ff-client.ts
@@ -579,18 +579,8 @@ export async function getSyncStatus(): Promise<FfSyncStatus | null> {
 // ---------------------------------------------------------------------------
 
 export async function getSitesFromApi(): Promise<{ code: string; nom: string }[]> {
-    try {
-        const res = await fetch(`${FF_API_BASE}/api/sites`, { cache: "no-store" });
-        if (!res.ok) throw new Error(`HTTP ${res.status}`);
-        const data = await res.json();
-        const list = Array.isArray(data) ? data : ((data as any).items ?? (data as any).data ?? []);
-        return list.map((s: any) => ({ code: s.code ?? s.codesite ?? s.site, nom: s.nom ?? s.libelle ?? s.code }));
-    } catch (err) {
-        console.error("[api-ff] getSitesFromApi error:", err);
-        // Fallback : sites connus de FF Nancy
-        return [
-            { code: "292", nom: "Frouard (Nancy)" },
-            { code: "579", nom: "Houdemont" },
-        ];
-    }
+    return [
+        { code: "292", nom: "Frouard (Nancy)" },
+        { code: "579", nom: "Houdemont" },
+    ];
 }
diff --git a/src/lib/pg-ff-client.ts b/src/lib/pg-ff-client.ts
index c4cc790..b634490 100644
--- a/src/lib/pg-ff-client.ts
+++ b/src/lib/pg-ff-client.ts
@@ -83,45 +83,25 @@ export interface PgRankingRow {
 // ---------------------------------------------------------------------------
 
 /**
- * Retourne la liste des fournisseurs actifs et non suspendus depuis fouident.
- * 1 requête SQL — remplace getFournisseursFromApi().
+ * Retourne la liste des fournisseurs depuis fouadr1 + artfou1.
  */
 export async function pgGetFournisseurs(search?: string): Promise<{ code: string; nom: string }[]> {
     try {
         const result = await db.execute(sql`
-            SELECT DISTINCT
-                fi.code,
-                fi.nom
-            FROM fouident fi
-            INNER JOIN artfou1 af ON af.code = fi.code
-            WHERE fi.actif = true
-              AND fi.suspendu = false
-              AND fi.code IS NOT NULL
-              AND fi.nom IS NOT NULL
-              ${search ? sql`AND (fi.nom ILIKE ${'%' + search + '%'} OR fi.code ILIKE ${'%' + search + '%'})` : sql``}
-            ORDER BY fi.nom
+            SELECT DISTINCT fa.code, fa.raisonsociale AS nom
+            FROM fouadr1 fa
+            INNER JOIN artfou1 af ON af.code = fa.code
+            WHERE fa.sit_code = '000'
+              AND fa.raisonsociale IS NOT NULL
+              AND fa.raisonsociale !~ '^\s*\d'
+              ${search ? sql`AND (fa.raisonsociale ILIKE ${'%' + search + '%'} OR fa.code ILIKE ${'%' + search + '%'})` : sql``}
+            ORDER BY fa.raisonsociale
         `);
-        console.log(`[pg-ff] pgGetFournisseurs (fouident): ${result.rows.length} fournisseurs`);
+        console.log(`[pg-ff] pgGetFournisseurs: ${result.rows.length} fournisseurs`);
         return (result.rows as unknown as { code: string; nom: string }[]).filter(r => r.code && r.nom);
     } catch (e) {
-        console.error("[pg-ff] pgGetFournisseurs fouident error:", (e as Error).message?.slice(0, 200));
-        // Fallback : fouident inaccessible → fouadr1 avec artfou1
-        try {
-            const fallback = await db.execute(sql`
-                SELECT DISTINCT fa.code, fa.raisonsociale AS nom
-                FROM fouadr1 fa
-                INNER JOIN artfou1 af ON af.code = fa.code
-                WHERE fa.sit_code = '000'
-                  AND fa.raisonsociale IS NOT NULL
-                  AND fa.raisonsociale !~ '^\s*\d'
-                  ${search ? sql`AND (fa.raisonsociale ILIKE ${'%' + search + '%'} OR fa.code ILIKE ${'%' + search + '%'})` : sql``}
-                ORDER BY fa.raisonsociale
-            `);
-            return (fallback.rows as unknown as { code: string; nom: string }[]).filter(r => r.code && r.nom);
-        } catch (e2) {
-            console.error("[pg-ff] pgGetFournisseurs fallback error:", e2);
-            return [];
-        }
+        console.error("[pg-ff] pgGetFournisseurs error:", (e as Error).message?.slice(0, 200));
+        return [];
     }
 }