fix(n8n): resolve duplicate key constraint on tag_entity during workflow import

n8n import:workflow --separate imports each JSON file independently. All 4
workflows shared the same tags (parapharmacy, scraper), so the second import
tried to INSERT duplicate tag names, hitting the unique index on
tag_entity.name.

- Remove tags field from all 4 workflow JSON files (cosmetic, re-add via UI)
- Add cleanup-db.js to wipe workflow data before import
- Add --overwrite flag to import command as safety net
- Add cleanup-db.js volume mount to n8n-init container

n8n/cleanup-db.js

@@ -0,0 +1,46 @@
+#!/usr/bin/env node
+/**
+ * Clean n8n workflow data before fresh import to avoid constraint violations.
+ */
+let Client;
+try {
+  Client = require('/usr/local/lib/node_modules/n8n/node_modules/pg').Client;
+} catch {
+  Client = require('pg').Client;
+}
+
+const client = new Client({
+  host: process.env.DB_POSTGRESDB_HOST || 'postgres',
+  port: parseInt(process.env.DB_POSTGRESDB_PORT || '5432', 10),
+  database: process.env.DB_POSTGRESDB_DATABASE || 'farmafinder',
+  user: process.env.DB_POSTGRESDB_USER || 'farmafinder',
+  password: process.env.DB_POSTGRESDB_PASSWORD,
+});
+
+async function run() {
+  await client.connect();
+  console.log('[cleanup-db] Connected to PostgreSQL');
+
+  try {
+    for (const table of [
+      'workflows_tags',
+      'webhook_entity',
+      'execution_entity',
+      'workflow_statistics',
+      'workflow_archive',
+      'workflow_entity',
+    ]) {
+      try {
+        const r = await client.query(`DELETE FROM ${table}`);
+        if (r.rowCount > 0) console.log(`[cleanup-db] Deleted ${r.rowCount} rows from ${table}`);
+      } catch (e) {
+        if (e.code !== '42P01') console.error(`[cleanup-db] ${table}:`, e.message);
+      }
+    }
+    console.log('[cleanup-db] Done');
+  } finally {
+    await client.end();
+  }
+}
+
+run();

n8n/init-import.sh

@@ -11,9 +11,13 @@ if [ -f "$FLAG" ]; then
   exit 0
 fi
 
+# ── 0. Clean existing workflow data to avoid constraint violations ────
+echo "[n8n-init] Cleaning existing workflow data..."
+node /home/node/cleanup-db.js 2>&1 || echo "[n8n-init] Cleanup skipped (first run or no existing data)."
+
 # ── 1. Import workflows via CLI (writes to DB) ───────────────────────
 echo "[n8n-init] Importing workflows..."
-n8n import:workflow --separate --input=/home/node/workflows/ 2>/dev/null
+n8n import:workflow --separate --overwrite --input=/home/node/workflows/ 2>/dev/null
 
 # ── 3. Activate all workflows via CLI ────────────────────────────────
 echo "[n8n-init] Activating workflows..."

n8n/workflows/parapharmacy-all-sources.json

@@ -129,6 +129,5 @@
     }
   },
   "active": false,
-  "settings": { "executionOrder": "v1" },
-  "tags": [{ "name": "parapharmacy" }, { "name": "scraper" }, { "name": "scheduled" }]
+  "settings": { "executionOrder": "v1" }
 }

n8n/workflows/parapharmacy-manual-scraper.json

@@ -166,16 +166,5 @@
   "settings": {
     "executionOrder": "v1"
   },
-  "versionId": "1",
-  "tags": [
-    {
-      "name": "parapharmacy"
-    },
-    {
-      "name": "scraper"
-    },
-    {
-      "name": "webhook"
-    }
-  ]
+  "versionId": "1"
 }

n8n/workflows/parapharmacy-scraper.json

@@ -170,13 +170,5 @@
   "settings": {
     "executionOrder": "v1"
   },
-  "versionId": "1",
-  "tags": [
-    {
-      "name": "parapharmacy"
-    },
-    {
-      "name": "scraper"
-    }
-  ]
+  "versionId": "1"
 }

n8n/workflows/parapharmacy-webhook-scraper.json

@@ -94,6 +94,5 @@
     "Send to API": { "main": [[{ "node": "Format Response", "type": "main", "index": 0 }]] }
   },
   "active": true,
-  "settings": { "executionOrder": "v1" },
-  "tags": [{ "name": "parapharmacy" }, { "name": "scraper" }]
+  "settings": { "executionOrder": "v1" }
 }