Project Uploaded

api_server.py

@@ -11,9 +11,9 @@ from dotenv import load_dotenv
 
 load_dotenv()
 
-# --- START: CRITICAL DEFINITIONS MOVED HERE ---
+# --- START: CRITICAL DEFINITIONS SECTION ---
+# This entire block is moved to the top to ensure 'log' is always available.
 
-# 1. Logging System Definition
 class LogBuffer:
     def __init__(self, max_items: int = 10000):
         self._buf: List[Dict[str, Any]] = []
@@ -40,7 +40,6 @@ def log(msg: str, level: str = "info", source: str = "server"):
     logs.append(msg, level, source)
     print(f"[{level.upper()}][{source}] {msg}", flush=True)
 
-# 2. Base64 Helper
 def decode_base64_with_padding(b64_string: str) -> bytes:
     """Decodes a Base64 string, adding missing padding if necessary."""
     missing_padding = len(b64_string) % 4
@@ -49,10 +48,11 @@ def decode_base64_with_padding(b64_string: str) -> bytes:
     try:
         return base64.b64decode(b64_string)
     except binascii.Error as e:
-        log(f"Error decoding base64 string: {e}", "error", "SERVER") # Now 'log' exists
+        log(f"Error decoding base64 string: {e}", "error", "SERVER")
         return b""
 
-# --- END: CRITICAL DEFINITIONS MOVED ---
+# --- END: CRITICAL DEFINITIONS SECTION ---
+
 
 # Define a writable directory for ALL runtime files
 WRITABLE_DIR = "/tmp"
@@ -72,6 +72,7 @@ if 'SERVICE_ACCOUNT_B64' in os.environ:
         with open(SERVICE_ACCOUNT_FILE, 'w') as f:
             f.write(decoded_service_account.decode('utf-8'))
 
+# Define global constants
 GROUPS_TXT   = os.environ.get("GROUPS_TXT", "groups.txt")
 FINAL5_PATH  = os.environ.get("FINAL5_PATH", "final5.py")
 PYTHON_BIN   = os.environ.get("PYTHON_BIN", "python")
@@ -90,7 +91,8 @@ GMAIL_SCOPES = [ "https://www.googleapis.com/auth/gmail.send" ]
 os.makedirs(SCRAPE_OUTDIR, exist_ok=True)
 os.makedirs(ANALYSIS_OUTDIR, exist_ok=True)
 
-# Use non-interactive, service-account based authentication
+
+# Define the Gmail service builder function
 def build_gmail_service():
     if not os.path.exists(SERVICE_ACCOUNT_FILE):
         log("Service account file not found, Gmail unavailable.", "error", "GMAIL")
@@ -107,9 +109,11 @@ def build_gmail_service():
         log(f"CRITICAL: Ensure your service account has Domain-Wide Delegation enabled for the user {SENDER_EMAIL}", "error", "GMAIL")
         return None
 
+# Now that all setup is done, build the service
 gmail_service = build_gmail_service()
 
 
+# --- The rest of the application code follows ---
 @dataclass
 class GroupRun:
     link: str
@@ -416,4 +420,4 @@ def api_get_recipients():
 
 if __name__ == "__main__":
     port = int(os.environ.get("PORT", 7860))
-    app.run(host="0.0.0.0", port=port)
+    app.run(host="0.0.0.0", port=port)```