cloudseeding / tasks / logTasks.ts

import {
  agentContext,
  claimTaskThread,
  releaseTaskThread,
} from "../utils/agentContext.ts";
import {
  formatUptime,
  msFrom,
  msRandomOffset,
  msUntilNextWakeWindow,
} from "../utils/time.ts";

// Capture server start time when module is loaded
const serverStartTime = Date.now();

export const logTasks = () => {
  if (!claimTaskThread()) {
    const newDelay = msFrom.minutes(2);
    console.log(
      `🔹 Task log attempt failed, ${agentContext.agentBskyName} is busy. Next attempt in ${
        (newDelay / 1000) / 60
      } minutes…`,
    );
    setTimeout(logTasks, newDelay);
    return;
  }

  const delay = msUntilNextWakeWindow(
    msFrom.minutes(30),
    msFrom.hours(1),
  );

  if (delay !== 0) {
    setTimeout(logTasks, delay);
    console.log(
      `🔹 ${agentContext.agentBskyName} is currently asleep. scheduling next task log for ${
        (delay / 1000 / 60 / 60).toFixed(2)
      } hours from now…`,
    );
    releaseTaskThread();
    return;
  }

  // Check if there's any activity
  const totalActivity = agentContext.reflectionCount +
    agentContext.checkCount +
    agentContext.processingCount +
    agentContext.proactiveCount;

  const uptime = Date.now() - serverStartTime;
  const uptimeFormatted = formatUptime(uptime);

  const nextCheckDelay = msFrom.minutes(30);
  const nextCheckMinutes = ((nextCheckDelay / 1000) / 60).toFixed(1);

  if (totalActivity <= 0) {
    console.log(
      `🔹 no activity yet... uptime: ${uptimeFormatted}. next log in ${nextCheckMinutes} minutes`,
    );
  } else {
    const actions = [];

    if (agentContext.reflectionCount > 0) {
      const times = agentContext.reflectionCount === 1
        ? "once"
        : `${agentContext.reflectionCount} times`;
      actions.push(`reflected ${times}`);
    }
    if (agentContext.checkCount > 0) {
      const times = agentContext.checkCount === 1
        ? "once"
        : `${agentContext.checkCount} times`;
      actions.push(`checked notifications ${times}`);
    }
    if (agentContext.processingCount > 0) {
      const times = agentContext.processingCount === 1
        ? "once"
        : `${agentContext.processingCount} times`;
      actions.push(`found and processed notifications ${times}`);
    }
    if (agentContext.proactiveCount > 0) {
      const times = agentContext.proactiveCount === 1
        ? "once"
        : `${agentContext.proactiveCount} times`;
      actions.push(`proactively used bluesky ${times}`);
    }

    const message = actions.join(", ");

    console.log(
      `🔹 ${message}. total notifications: ${agentContext.notifCount}. uptime: ${uptimeFormatted}. next log in ${nextCheckMinutes} minutes`,
    );
  }

  setTimeout(logTasks, nextCheckDelay);
  releaseTaskThread();
};