Update main.py

main.py

@@ -10,7 +10,7 @@ from flask_apscheduler import APScheduler
 import firebase_admin
 from firebase_admin import credentials, db, auth as firebase_auth
 from resend import Emails
-from resend.exceptions import ResendError # <-- Keep this import
+from resend.exceptions import ResendError
 import logging
 from logging.handlers import RotatingFileHandler
 import time
@@ -36,7 +36,6 @@ root_logger.addHandler(file_handler)
 root_logger.addHandler(console_handler)
 
 # === ENV Config ===
-# CRITICAL: Double-check this list in your environment or code for hidden spaces!
 ADMIN_EMAILS = ["rairorr@gmail.com", "nharingosheperd@gmail.com"]
 RESEND_API_KEY = os.getenv("RESEND_API_KEY")
 FIREBASE_CRED_JSON = json.loads(os.getenv("FIREBASE"))
@@ -63,40 +62,32 @@ Emails.api_key = RESEND_API_KEY
 logger.info("Flask, APScheduler, and Resend initialized.")
 
 
-# === DEFINITIVELY FIXED FUNCTION (send_email) ===
 def send_email(to, subject, html):
-    """Sends an email with sanitized input and robust error logging."""
+    """Sends an email with robust error logging."""
     try:
-        # Sanitize the email address to remove leading/trailing whitespace
-        clean_to = to.strip()
-        if not clean_to:
-            logger.error("Attempted to send email to an empty address.")
-            return None
-
+        # Note: Sanitization is now handled by the caller function
         response = Emails.send({
             "from": "Admin <admin@resend.dev>",
-            "to": clean_to, # Use the cleaned email address
+            "to": to,
             "subject": subject,
             "html": html
         })
         if response is None:
-            logger.warning(f"Email API returned None for recipient {clean_to}. Check Resend dashboard for suppression list.")
+            logger.warning(f"Email API returned None for recipient {to}. Check Resend dashboard for suppression list.")
             return None
-        logger.info(f"Email sent successfully to {clean_to}. Response ID: {response.get('id')}")
+        logger.info(f"Email sent successfully to {to}. Response ID: {response.get('id')}")
         return response
     except ResendError as e:
-        # --- FIX: Convert the entire exception to a string. ---
-        # This is robust and will not crash even if attributes are missing.
         logger.error(f"A Resend API error occurred for recipient '{to}'. The error is: {str(e)}", exc_info=True)
         return None
     except Exception as e:
-        # Fallback for any other unexpected errors
         logger.error(f"An unexpected exception occurred while sending email to '{to}': {str(e)}", exc_info=True)
         return None
 
 
+# === DEFINITIVELY FIXED FUNCTION (send_rotation_notification) ===
 def send_rotation_notification(job_id, shift_record):
-    """Sends email notification for rotation to all admins."""
+    """Builds and sends email notifications with aggressive sanitization and debugging."""
     try:
         job_ref = db.reference(f"jobs/{job_id}")
         job_data = job_ref.get()
@@ -133,10 +124,22 @@ def send_rotation_notification(job_id, shift_record):
         html_content += "</tbody></table><p><em>This is an automated notification from the Guard Rotation System.</em></p>"
 
         subject = f"Guard Rotation - {job_name} (Shift {shift_number})"
+        
         for admin_email in ADMIN_EMAILS:
-            logger.info(f"Sending rotation notification to {admin_email}...")
-            send_email(admin_email, subject, html_content)
-            time.sleep(1) # Rate-limit prevention
+            # --- ULTIMATE DEBUGGING AND SANITIZATION ---
+            # 1. Log the raw state of the string
+            logger.debug(f"RAW email string | Length: {len(admin_email)} | Representation: {repr(admin_email)}")
+            
+            # 2. Aggressively sanitize the string by re-encoding it. This removes hidden characters.
+            sanitized_email = admin_email.encode('utf-8', 'ignore').decode('utf-8').strip()
+            
+            # 3. Log the sanitized state
+            logger.debug(f"SANITIZED email string | Length: {len(sanitized_email)} | Representation: {repr(sanitized_email)}")
+
+            logger.info(f"Sending rotation notification to {sanitized_email}...")
+            send_email(sanitized_email, subject, html_content) # Use the sanitized email
+            time.sleep(1)
+            
     except Exception as e:
         logger.error(f"Error building rotation notification for job {job_id}", exc_info=True)