Update intent_api.py

intent_api.py

@@ -6,7 +6,7 @@ from core import llm_models
 
 def auth_token_handler(api_name, auth_config, session):
     try:
-        token_info = session.auth_tokens.get(api_name)
+        token_info = session.get("auth_tokens", {}).get(api_name)
         if token_info and "token" in token_info:
             return token_info["token"], session
 
@@ -18,7 +18,7 @@ def auth_token_handler(api_name, auth_config, session):
             raise Exception("auth_endpoint veya token_path tanımsız")
 
         resolved_body = {
-            k: intent.resolve_placeholders(str(v), session.__dict__, session.variables) for k, v in auth_body.items()
+            k: intent.resolve_placeholders(str(v), session, session.get("variables", {})) for k, v in auth_body.items()
         }
 
         response = requests.post(auth_endpoint, json=resolved_body, timeout=5)
@@ -33,7 +33,7 @@ def auth_token_handler(api_name, auth_config, session):
                 raise Exception(f"Token path çözülemedi: {token_path}")
 
         refresh_token = json_resp.get("refresh_token")
-        session.auth_tokens[api_name] = {
+        session.setdefault("auth_tokens", {})[api_name] = {
             "token": token,
             "refresh_token": refresh_token
         }
@@ -53,12 +53,12 @@ def refresh_auth_token(api_name, auth_config, session):
         if not refresh_endpoint or not token_path:
             raise Exception("Refresh yapılandırması eksik")
 
-        refresh_token = session.auth_tokens.get(api_name, {}).get("refresh_token")
+        refresh_token = session.get("auth_tokens", {}).get(api_name, {}).get("refresh_token")
         if not refresh_token:
             raise Exception("Mevcut refresh token bulunamadı")
 
         resolved_body = {
-            k: intent.resolve_placeholders(str(v), session.__dict__, session.variables) for k, v in refresh_body.items()
+            k: intent.resolve_placeholders(str(v), session, session.get("variables", {})) for k, v in refresh_body.items()
         }
 
         response = requests.post(refresh_endpoint, json=resolved_body, timeout=5)
@@ -74,7 +74,7 @@ def refresh_auth_token(api_name, auth_config, session):
 
         new_refresh_token = json_resp.get("refresh_token", refresh_token)
 
-        session.auth_tokens[api_name] = {
+        session.setdefault("auth_tokens", {})[api_name] = {
             "token": token,
             "refresh_token": new_refresh_token
         }
@@ -127,7 +127,7 @@ def execute_intent(intent_name, user_input, session_dict, intent_definitions, da
         verify_path = tls.get("ca_bundle") if verify and tls.get("ca_bundle") else verify
 
         if auth_config:
-            token, session = intent.auth_token_handler(action_api_name, auth_config, session)
+            token, session = auth_token_handler(action_api_name, auth_config, session)
 
         resolved_headers = {
             h["key"]: intent.resolve_placeholders(h["value"], session, variables)
@@ -150,7 +150,7 @@ def execute_intent(intent_name, user_input, session_dict, intent_definitions, da
                 )
                 if response.status_code == 401 and auth_config and attempt < retry_count:
                     log("🔁 Token expired. Yenileniyor...")
-                    token, session = intent.refresh_auth_token(action_api_name, auth_config, session)
+                    token, session = refresh_auth_token(action_api_name, auth_config, session)
                     continue
                 response.raise_for_status()
                 break