From 126a121056d76e14a0cf118aff8456f02c13b782 Mon Sep 17 00:00:00 2001 From: AI Assistant Date: Mon, 30 Mar 2026 09:04:22 +0300 Subject: [PATCH] feat(auto-refresh): trigger PMTiles rebuild via N8N after nightly sync Co-Authored-By: Claude Opus 4.6 (1M context) --- .../services/auto-refresh-scheduler.ts | 20 +++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/src/modules/parcel-sync/services/auto-refresh-scheduler.ts b/src/modules/parcel-sync/services/auto-refresh-scheduler.ts index 7687775..ebae73f 100644 --- a/src/modules/parcel-sync/services/auto-refresh-scheduler.ts +++ b/src/modules/parcel-sync/services/auto-refresh-scheduler.ts @@ -196,6 +196,26 @@ async function runAutoRefresh() { g.__autoRefreshLastRun = today; console.log("[auto-refresh] Run nocturn finalizat."); + + // Trigger PMTiles rebuild via N8N webhook + const webhookUrl = process.env.N8N_WEBHOOK_URL; + if (webhookUrl) { + try { + await fetch(webhookUrl, { + method: "POST", + headers: { "Content-Type": "application/json" }, + body: JSON.stringify({ + event: "auto-refresh-complete", + uats: batch.map((u) => u.name), + timestamp: new Date().toISOString(), + }), + }); + console.log("[auto-refresh] Webhook PMTiles rebuild trimis la N8N."); + } catch (err) { + const msg = err instanceof Error ? err.message : String(err); + console.warn(`[auto-refresh] Webhook N8N esuat: ${msg}`); + } + } } catch (err) { const msg = err instanceof Error ? err.message : String(err); console.error(`[auto-refresh] Eroare generala: ${msg}`);