Agent System

export function getDefaultDigestType(agentName: string): string {
  const patterns = AGENT_DIGEST_PATTERNS[agentName];
  if (!patterns || patterns.length === 0) return agentName;
  const first = patterns[0];
  return first ?? agentName;
}

getDefaultDigestType("Inbox Manager")  // Returns: "Email Triage"
getDefaultDigestType("Docs Librarian") // Returns: "Docs Quick Scan"

const dbId = input.target_database === "home_docs" 
  ? getHomeDocsDatabaseId() 
  : getDocsDatabaseId();

import { VALID_AGENT_NAMES } from "../shared/agent-config.js";

if (!VALID_AGENT_NAMES.includes(input.agent_name)) {
  return { 
    success: false, 
    error: `Invalid agent_name: ${input.agent_name}` 
  };
}

export function isValidAgentName(name: string): boolean {
  return VALID_AGENT_NAMES.includes(name);
}

{emoji} {Digest Type} — {date}

{Digest Type} ERROR — {date}

function buildPageTitle(params: {
  emoji: string;
  digestType: string;
  date: string;
  isError: boolean;
}): string {
  const { emoji, digestType, date, isError } = params;
  if (isError) return `${digestType} ERROR — ${date}`;
  return `${emoji} ${digestType} — ${date}`;
}

const isErrorTitled = 
  input.status_value === "partial" || input.status_value === "failed";

function isHeartbeat(params: {
  status_type: string;
  flagged_items: FlaggedItem[];
  actions_taken: ActionsTaken;
}): boolean {
  if (params.status_type === "heartbeat") return true;
  
  const { flagged_items, actions_taken } = params;
  const hasTasks = 
    (actions_taken.created_tasks?.length ?? 0) > 0 || 
    (actions_taken.updated_tasks?.length ?? 0) > 0;
  
  return flagged_items.length === 0 && !hasTasks;
}

const upstreamStatus = await notion.checkUpstreamStatus({
  agent_name: "GitHub Insyncerator",
  max_age_hours: 24,
  require_current_cycle: true,
});

if (!upstreamStatus.found || upstreamStatus.is_stale) {
  // Handle missing or stale dependency
}

const handoff = await notion.createHandoffMarker({
  source_agent: "Inbox Manager",
  target_agent: "GitHub Insyncerator",
  escalation_reason: "Found GitHub notification requiring sync",
  source_digest_url: "https://notion.so/...",
  create_task: true,
  task_priority: "🔴 High",
});