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}`);