Update spark_startup.py

spark_startup.py

@@ -1,29 +1,25 @@
 """
 Flare – Spark startup notifier
 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-App lifecyle içinde Spark servisine /startup çağrısı yapar.
+Projeler açılırken Spark’a /startup çağrısı yapar.
 """
 
-import threading
-import time
+from __future__ import annotations
+import threading, time, requests
 from typing import Dict, Any
-
-import requests
 from utils import log
-from config_provider import ConfigProvider, VersionConfig, ProjectConfig
+from config_provider import ConfigProvider, ProjectConfig, VersionConfig
 
 cfg = ConfigProvider.get()
 
 
 def _select_live_version(p: ProjectConfig) -> VersionConfig | None:
     published = [v for v in p.versions if v.published]
-    if not published:
-        return None
-    return max(published, key=lambda v: v.id)
+    return max(published, key=lambda v: v.id) if published else None
 
 
 def notify_startup():
-    spark_url = cfg.global_config.spark_endpoint
+    spark_base = cfg.global_config.spark_endpoint.rstrip("/")  # ← 🟢 tek “/”
     for p in cfg.projects:
         if not p.enabled:
             continue
@@ -35,11 +31,13 @@ def notify_startup():
             "project_name": p.name,
             "version_id": v.id,
             "general_prompt": v.general_prompt,
+            "cloud_token": cfg.global_config.get_plain_token(),
             "llm": v.llm.model_dump(),
         }
+
         try:
             log(f"🚀 Notifying Spark /startup for project '{p.name}' …")
-            r = requests.post(f"{spark_url}/startup", json=body, timeout=10)
+            r = requests.post(f"{spark_base}/startup", json=body, timeout=10)
             r.raise_for_status()
             log(f"✅ Spark acknowledged startup ({r.status_code})")
         except Exception as e:
@@ -47,5 +45,4 @@ def notify_startup():
 
 
 def run_in_thread():
-    t = threading.Thread(target=notify_startup, daemon=True)
-    t.start()
+    threading.Thread(target=notify_startup, daemon=True).start()