cloudseeding / tasks / sendWakeMessage.ts

import {
  agentContext,
  claimTaskThread,
  releaseTaskThread,
  isAgentAwake,
} from "../utils/agentContext.ts";
import { getNow, msFrom, msRandomOffset } from "../utils/time.ts";
import { messageAgent } from "../utils/messageAgent.ts";
import { wakePrompt } from "../prompts/wakePrompt.ts";
import { msUntilDailyWindow } from "../utils/time.ts";

export const sendWakeMessage = async () => {
  if (!claimTaskThread()) {
    const newDelay = msFrom.minutes(2);
    console.log(
      `🔹 ${agentContext.agentBskyName} is busy, sending wake message again in ${
        (newDelay / 1000) / 60
      } minutes…`,
    );
    // session is busy, try to check notifications in 2 minutes.
    setTimeout(sendWakeMessage, newDelay);
    return;
  }

  if (!agentContext.sleepEnabled) {
    console.log(
      `🔹 ${agentContext.agentBskyName} is not enabled for sleep mode. Opting out of wake messaging…`,
    );
    releaseTaskThread();
    return;
  }

  const now = getNow();

  if (isAgentAwake(now.hour)) {
    console.log(`🔹 attempting to wake up ${agentContext.agentBskyName}`);
  } else {
    const delay = msUntilDailyWindow(
      agentContext.wakeTime,
      0,
      msFrom.minutes(30),
    );
    setTimeout(sendWakeMessage, delay);
    console.log(
      `🔹 ${agentContext.agentBskyName} should still be asleep. Scheduling wake message for ${
        (delay / 1000 / 60 / 60).toFixed(2)
      } hours from now…`,
    );
    releaseTaskThread();
    return;
  }

  try {
    await messageAgent(wakePrompt);
  } catch (error) {
    console.error("error in sendWakeMessage: ", error);
  } finally {
    console.log("🔹 wake attempt processed, scheduling next wake prompt…");
    setTimeout(
      sendWakeMessage,
      msUntilDailyWindow(agentContext.wakeTime, 0, msFrom.minutes(30)),
    );
    console.log("🔹 exiting wake process");
    releaseTaskThread();
  }
};