d

server.js

@@ -33,23 +33,23 @@ app.get("/hello", (req, res) => {
   res.send("hello world pal");
 });
 
+const log = (msg) => console.log(`[${new Date().toISOString()}] ${msg}`);
+const err = (msg) => console.error(`[${new Date().toISOString()}] ${msg}`);
+
 function fetchSecret(key) {
+  log(`Fetching secret: ${key}`);
   return new Promise((resolve, reject) => {
     const url = `${API_BASE}/${key}`;
-
-    https
+    const req = https
       .get(
         url,
         { headers: { accept: "application/json", "X-API-Key": API_KEY } },
         (res) => {
           let data = "";
-
-          res.on("data", (chunk) => {
-            data += chunk;
-          });
-
+          res.on("data", (chunk) => { data += chunk; });
           res.on("end", () => {
             try {
+              log(`Secret ${key} fetched OK`);
               resolve(JSON.parse(data).value);
             } catch (error) {
               reject(new Error(`Failed to parse response for ${key}: ${data}`));
@@ -57,7 +57,14 @@ function fetchSecret(key) {
           });
         },
       )
-      .on("error", reject);
+      .on("error", (e) => {
+        err(`Secret fetch failed for ${key}: ${e.message}`);
+        reject(e);
+      });
+    req.setTimeout(15000, () => {
+      req.destroy();
+      reject(new Error(`Timeout fetching secret ${key}`));
+    });
   });
 }
 
@@ -82,21 +89,29 @@ function writeState(state) {
 }
 
 async function sendEmail(subject, body) {
+  log("Fetching SMTP config...");
   const cfg = await getSmtpConfig();
+  log(`SMTP config loaded (host=${cfg.host}, port=${cfg.port}, from=${cfg.from}, to=${cfg.to})`);
 
   const transporter = nodemailer.createTransport({
     host: cfg.host,
     port: cfg.port,
     secure: cfg.port === 465,
     auth: { user: cfg.user, pass: cfg.pass },
+    connectionTimeout: 30000,
+    greetingTimeout: 30000,
+    socketTimeout: 60000,
   });
 
-  return transporter.sendMail({
+  log("Sending email...");
+  const result = await transporter.sendMail({
     from: cfg.from,
     to: cfg.to,
     subject,
     text: body,
   });
+  log(`Email sent (messageId=${result.messageId})`);
+  return result;
 }
 
 function valuesChanged(oldVals, newVals) {
@@ -108,7 +123,9 @@ function valuesChanged(oldVals, newVals) {
 }
 
 async function scrape() {
+  log("Launching Firefox browser...");
   const browser = await firefox.launch({ headless: true });
+  log("Browser launched");
 
   try {
     const context = await browser.newContext({
@@ -118,7 +135,9 @@ async function scrape() {
 
     const page = await context.newPage();
 
+    log(`Navigating to ${URL}...`);
     await page.goto(URL, { waitUntil: "domcontentloaded", timeout: 60000 });
+    log("Page loaded");
 
     const title = await page.title();
     if (title === "Access Denied") {
@@ -170,16 +189,17 @@ async function scrape() {
 }
 
 async function main() {
-  console.log(`[${new Date().toISOString()}] Checking visa ballot...`);
+  log("=== Starting visa ballot check ===");
 
   const current = await scrape();
   if (!current) {
-    console.log("Scrape failed, will retry next run");
+    log("Scrape failed (null returned), will retry next run");
     return;
   }
 
-  console.log("Current India values:", current);
+  log(`Scraped India values: ${JSON.stringify(current)}`);
 
+  log("Reading saved state...");
   const state = readState();
   const prevIndia = state.india || {
     selection1: "TBA",
@@ -191,8 +211,11 @@ async function main() {
 
   let emailSent = false;
 
+  log(`Prev India values: ${JSON.stringify(prevIndia)}`);
+  log(`Changed: ${changed}`);
+
   if (changed) {
-    console.log("Values changed! Sending alert email.");
+    log("Values changed! Sending alert email.");
 
     const subject = "[Visa Alert] India ballot values changed";
     const body = `India Work and Holiday ballot values have changed:
@@ -205,10 +228,10 @@ async function main() {
 
     try {
       await sendEmail(subject, body);
-      console.log("Change alert email sent");
+      log("Change alert email sent");
       emailSent = true;
     } catch (error) {
-      console.error("Failed to send change email:", error.message);
+      err(`Failed to send change email: ${error.message}`);
     }
 
     state.lastChangeTime = new Date().toISOString();
@@ -223,7 +246,7 @@ async function main() {
     const hoursSinceLastDaily = (now - lastDailyEmail) / 3600000;
 
     if (allStillTba && hoursSinceLastDaily >= 24) {
-      console.log("Still TBA - sending daily status email");
+      log("Still TBA and 24h since last daily email - sending daily status");
 
       try {
         await sendEmail(
@@ -236,11 +259,11 @@ async function main() {
 
   Check: ${URL}`,
         );
-        console.log("Daily status email sent");
+        log("Daily status email sent");
         emailSent = true;
         state.lastDailyEmailTime = new Date().toISOString();
       } catch (error) {
-        console.error("Failed to send daily email:", error.message);
+        err(`Failed to send daily email: ${error.message}`);
       }
     }
   }
@@ -248,9 +271,11 @@ async function main() {
   state.india = current;
   state.lastCheckTime = new Date().toISOString();
   if (emailSent) state.lastEmailTime = new Date().toISOString();
+  log("Writing state to disk...");
   writeState(state);
+  log("State saved");
 
-  console.log("Done");
+  log("=== Visa ballot check complete ===");
 }
 
 const isDirectRun =
@@ -263,7 +288,8 @@ if (isDirectRun) {
   });
 
   main().catch((error) => {
-    console.error("Fatal error:", error);
+    err(`Fatal error: ${error.message}`);
+    if (error.stack) err(error.stack);
     process.exit(1);
   });
 }