Timing & Delivery of Your Secure Note

export async function POST(request: Request) {
  try {
    console.log("Starting death note delivery cron job");

    // CRITICAL: Health check prevents processing if DB unavailable
    if (!(await isDatabaseHealthy())) {
      console.log("Database unhealthy - skipping cron run");
      return NextResponse.json({
        skipped: true,
        reason: "database_unavailable"
      });
    }

    const overdueUsers = await findOverdueUsersWithContacts();

    for (const user of overdueUsers) {
      // RACE CONDITION PROTECTION: Fresh verification check
      const { data: freshVerification } = await database
        .from("user_status")
        .select("timestamp")
        .eq("user_id", user.id)
        .single();

      if (!freshVerification || new Date(freshVerification.timestamp) > now) {
        console.log("User checked in during cron - skipping");
        continue;
      }

      // PROCEED ONLY AFTER ALL CHECKS PASS
      await processUserDelivery(user);
    }
  } catch (error) {
    // Enhanced error logging for audit trail
    console.error("Cron job error:", {
      error: error.message,
      timestamp: new Date().toISOString()
    });
  }
}

/**
 * Check if database is healthy before processing
 * Simple health check to prevent cron job failures when database is unavailable
 */
async function isDatabaseHealthy(): Promise<boolean> {
  try {
    await database.from("system_health").select("status").limit(1);
    return true;
  } catch (error) {
    console.error("Database health check failed:", error);
    return false;
  }
}

// Used in BOTH cron jobs for complete protection:
// - /api/cron/check-in-reminder
// - /api/cron/death-note-delivery