Update app.js

app.js

@@ -84,19 +84,20 @@ function startJobInternal(jobId, intervalMs, url, payload, initialDelay = 0) {
 app.get('/', (req, res) => res.send('Cron Registry Active'));
 
 app.post('/register', async (req, res) => {
-    const { secret, jobId, intervalMs, webhookUrl, payload, initialDelay } = req.body;
-
-    if (secret !== CRON_SECRET) return res.status(403).json({ error: "Unauthorized" });
-
-    // 1. Save to DB (Persistence)
-    const { error } = await supabase.from('system_jobs').upsert({
-        id: jobId,
-        interval_ms: intervalMs,
-        webhook_url: webhookUrl,
-        payload: payload,
-        updated_at: new Date()
-    });
-
+const { secret, jobId, intervalMs, webhookUrl, payload, initialDelay, leadId } = req.body;
+
+if (secret !== CRON_SECRET) return res.status(403).json({ error: "Unauthorized" });
+
+// Save to DB (Now including lead_id)
+const { error } = await supabase.from('system_jobs').upsert({
+    id: jobId,
+    lead_id: leadId, // <--- Save the UUID here
+    interval_ms: intervalMs,
+    webhook_url: webhookUrl,
+    payload: payload,
+    updated_at: new Date()
+});
+  
     if (error) return res.status(500).json({ error: error.message });
 
     // 2. Start in Memory