Function notifyExtendedOutages

server/src/notifications/compliance.ts:201–245

()

 * Called separately from the heartbeat job (e.g., weekly check).
 */
export async function notifyExtendedOutages(): Promise<{ notified: number }> {
  let notified = 0;

  try {
    // Find production agents failing for 7+ days
    const result = await query(
      `SELECT s.agent_url, s.headline, s.status, s.status_changed_at
       FROM agent_compliance_status s
       LEFT JOIN agent_registry_metadata m ON m.agent_url = s.agent_url
       WHERE s.status IN ('failing', 'degraded')
         AND s.status_changed_at < NOW() - INTERVAL '7 days'
         AND COALESCE(m.lifecycle_stage, 'production') = 'production'
         AND COALESCE(m.compliance_opt_out, FALSE) = FALSE`,
    );

    for (const row of result.rows) {
      const userIds = await resolveAgentOwnerUserIds(row.agent_url);
      const name = agentDisplayName(row.agent_url);
      const days = Math.floor((Date.now() - new Date(row.status_changed_at).getTime()) / (1000 * 60 * 60 * 24));

      for (const userId of userIds) {
        try {
          const alreadySent = await notificationDb.exists(userId, 'compliance_extended_outage', row.agent_url);
          if (alreadySent) continue;

          await notifyUser({
            recipientUserId: userId,
            type: 'compliance_extended_outage',
            referenceId: row.agent_url,
            referenceType: 'agent',
            title: `Your agent ${name} has been ${row.status} for ${days} days. Buyers are seeing failures.`,
            url: '/registry?tab=agents',
          });
          notified++;
        } catch (error) {
          logger.error({ error, userId, agentUrl: row.agent_url }, 'Failed to send extended outage notification');
        }
      }
    }
  } catch (error) {
    logger.error({ error }, 'Failed to check for extended outages');
  }

  return { notified };
}