Update api_connector.py

api_connector.py

@@ -1,5 +1,5 @@
 import requests
-from utils import log
+from logger import log_info, log_error, log_warning, log_debug
 
 class APIConnector:
     def __init__(self, service_config):
@@ -58,7 +58,7 @@ class APIConnector:
         new_refresh_token = json_resp.get("refresh_token", session.auth_tokens[api_name].get("refresh_token"))
         session.auth_tokens[api_name] = {"token": token, "refresh_token": new_refresh_token}
 
-        log(f"🔁 Refreshed auth token for {api_name}")
+        log_info(f"🔁 Refreshed auth token for {api_name}")
         return token
 
     def call_api(self, intent_def, session):
@@ -83,17 +83,17 @@ class APIConnector:
             try:
                 response = requests.request(method, url, headers=headers, json=body, timeout=timeout)
                 if response.status_code == 401 and auth_config and attempt < retry_count:
-                    log(f"🔁 Token expired for {api_name}, refreshing...")
+                    log_info(f"🔁 Token expired for {api_name}, refreshing...")
                     self.refresh_auth_token(api_name, auth_config, session)
                     continue
                 response.raise_for_status()
-                log(f"✅ API call successful: {api_name}")
+                log_info(f"✅ API call successful: {api_name}")
                 return response.json()
             except requests.Timeout:
                 fallback = intent_def.get("fallback_timeout_message", "This operation is currently unavailable.")
-                log(f"⚠️ API timeout for {api_name} → {fallback}")
+                log_warning(f"⚠️ API timeout for {api_name} → {fallback}")
                 return {"fallback": fallback}
             except Exception as e:
-                log(f"❌ API call error for {api_name}: {e}")
+                log_error(f"❌ API call error for {api_name}", e)
                 fallback = intent_def.get("fallback_error_message", "An error occurred during the operation.")
                 return {"fallback": fallback}