cloudseeding / tasks / sendSleepMessage.ts

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

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

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

  const now = getNow();

  if (now.hour >= agentContext.sleepTime) {
    console.log(`attempting to wind down ${agentContext.agentBskyName}`);
  } else {
    const delay = msUntilDailyWindow(
      agentContext.sleepTime,
      0,
      msFrom.minutes(20),
    );
    setTimeout(sendSleepMessage, delay);
    console.log(
      `It's too early to wind down ${agentContext.agentBskyName}. scheduling wind down for ${
        (delay / 1000 / 60 / 60).toFixed(2)
      } hours from now…`,
    );
    releaseTaskThread();
    return;
  }

  try {
    await messageAgent(sleepPrompt);
  } catch (error) {
    console.error("error in sendSleepMessage: ", error);
  } finally {
    console.log("wind down attempt processed, scheduling next wind down…");
    setTimeout(
      sendSleepMessage,
      msUntilDailyWindow(agentContext.sleepTime, 0, msFrom.minutes(20)),
    );
    console.log("exiting wind down process");
    releaseTaskThread();
  }
};