Update app.py

app.py

@@ -57,7 +57,8 @@ print("--- BOOT SEQUENCE INITIATED ---", flush=True)
 app = Flask(__name__)
 
 ALERT_EMAIL_SENDER = "gowreeshgowri50@gmail.com" 
-ALERT_EMAIL_PASSWORD = "oynu ulet pynk xsza" 
+# FIX: Automatically strip spaces from Google App Password
+ALERT_EMAIL_PASSWORD = "oynu ulet pynk xsza".replace(" ", "") 
 ALERT_EMAIL_RECEIVER = "mcblackdevil12342@gmail.com"
 ENABLE_EMAIL_ALERTS = True
 
@@ -154,13 +155,12 @@ def process_accident_async(stream_id, frame, location, confidence, severity):
                 except Exception as ve:
                     print(f"Failed to attach video: {ve}")
 
-            # Using Port 587 (TLS) which is much more reliable in cloud environments like HuggingFace
-            server = smtplib.SMTP('smtp.gmail.com', 587)
-            server.ehlo()
-            server.starttls()
-            server.login(ALERT_EMAIL_SENDER, ALERT_EMAIL_PASSWORD)
-            server.send_message(msg)
-            server.quit()
+            # FIX: Using Port 465 (Implicit SSL) with explicit timeout to prevent hanging in strict environments
+            context = ssl.create_default_context()
+            with smtplib.SMTP_SSL('smtp.gmail.com', 465, context=context, timeout=15) as server:
+                server.login(ALERT_EMAIL_SENDER, ALERT_EMAIL_PASSWORD)
+                server.send_message(msg)
+            
             print(f"📧 Dispatch Email Sent Successfully for Stream {stream_id}", flush=True)
         except Exception as e:
             print(f"📧 Email Failed to Send: {str(e)}", flush=True)
@@ -230,6 +230,18 @@ def init_upload():
 @app.route('/init_stream', methods=['POST'])
 def init_stream():
     url = request.json.get('url')
+    
+    # --- YouTube Live Stream Resolution ---
+    if 'youtube.com' in url or 'youtu.be' in url:
+        try:
+            ydl_opts = {'format': 'best', 'quiet': True, 'noplaylist': True}
+            with yt_dlp.YoutubeDL(ydl_opts) as ydl:
+                info = ydl.extract_info(url, download=False)
+                # Overwrite the YouTube link with the raw hidden media stream link
+                url = info.get('url', url)
+        except Exception as e:
+            print(f"yt-dlp extraction failed: {e}", flush=True)
+
     loc, wx = get_geo_info(url)
     v_time = datetime.datetime.now().strftime("%H:%M:%S")
     stream_id = f"live_{uuid.uuid4().hex}"