cloudseeding / tasks / sendWakeMessage.ts

import {
  agentContext,
  claimTaskThread,
  releaseTaskThread,
} 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 = msRandomOffset(msFrom.minutes(5), msFrom.minutes(10));
    console.log(
      `${agentContext.agentBskyName} is busy, sending wake message again in ${
        (newDelay / 1000) / 60
      } minutes…`,
    );
    // session is busy, try to check notifications in 5~10 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 (now.hour >= agentContext.wakeTime && now.hour < agentContext.sleepTime) {
    console.log(`attempting to wake up ${agentContext.agentBskyName}`);
  } else {
    const delay = msUntilDailyWindow(
      agentContext.wakeTime,
      0,
      msFrom.minutes(80),
    );
    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(80)),
    );
    console.log("exiting wake process");
    releaseTaskThread();
  }
};