scheduler.js

let timer = null;
let schedulerCallback = null;
let schedulerOpts = null;

function randomDelay({ minMinutes, maxMinutes }) {
  return (minMinutes + Math.random() * (maxMinutes - minMinutes)) * 60_000;
}

function schedule() {
  if (timer) clearTimeout(timer);

  const delay = randomDelay(schedulerOpts);
  const mins = (delay / 60_000).toFixed(1);
  console.log(`  [next autonomous cycle in ~${mins} min]`);

  timer = setTimeout(async () => {
    timer = null;
    try {
      await schedulerCallback();
    } catch (err) {
      console.error('Autonomous cycle error:', err.message);
    }
    schedule();
  }, delay);
}

export function startScheduler(callback, opts) {
  schedulerCallback = callback;
  schedulerOpts = opts;
  schedule();
}

export function resetScheduler() {
  if (!schedulerCallback) return;
  console.log('  [resetting autonomous timer]');
  schedule();
}

export function stopScheduler() {
  if (timer) {
    clearTimeout(timer);
    timer = null;
  }
}