Update app.py

app.py

@@ -51,113 +51,6 @@ def show_token(): # Shows access_token if available
 def show_client():
     return token_received["client_id"] if token_received["status"] and token_received["client_id"] else ""
 
-# --- Function to fetch LinkedIn Token from Bubble.io ---
-def fetch_linkedin_token_from_bubble(url_user_token_str):
-    """
-    Fetches LinkedIn access token from Bubble.io API using the state value (url_user_token_str).
-    The token is expected in a 'Raw_text' field as a JSON string, which is then parsed.
-    Updates the global token_received state if successful.
-    Returns status messages for UI update.
-    """
-    # Initial UI states (in case of early exit or error)
-    current_status = check_status()
-    current_token_display = show_token()
-    current_client_display = show_client()
-
-    bubble_api_key = os.environ.get("Bubble_API")
-    if not bubble_api_key:
-        error_msg = "❌ Bubble API Error: The 'Bubble_API' environment variable is not set."
-        print(error_msg)
-        return error_msg, current_status, current_token_display, current_client_display
-
-    if not url_user_token_str or "not found" in url_user_token_str or "Could not access" in url_user_token_str:
-        return f"ℹ️ No valid user token from URL to query Bubble. ({url_user_token_str})", current_status, current_token_display, current_client_display
-
-    base_url = "https://app.ingaze.ai/version-test/api/1.1/obj/Linkedin_access"
-    constraints = [{"key": "state", "constraint_type": "equals", "value": url_user_token_str}]
-    params = {'constraints': json.dumps(constraints)}
-    headers = {"Authorization": f"Bearer {bubble_api_key}"} 
-    
-    bubble_api_status_msg = f"Attempting to fetch token from Bubble for state: {url_user_token_str}..."
-    print(bubble_api_status_msg)
-
-    response = None 
-    try:
-        response = requests.get(base_url, params=params, headers=headers, timeout=15) # Increased timeout slightly
-        response.raise_for_status() 
-        
-        data = response.json()
-        results = data.get("response", {}).get("results", [])
-        
-        if results:
-            raw_text_from_bubble = results[0].get("Raw_text", None)
-            parsed_token_dict = None 
-
-            if raw_text_from_bubble and isinstance(raw_text_from_bubble, str):
-                try:
-                    parsed_token_dict = json.loads(raw_text_from_bubble)
-                    if not isinstance(parsed_token_dict, dict):
-                        bubble_api_status_msg = (f"⚠️ Bubble API: 'Raw_text' field did not contain a valid JSON dictionary string. "
-                                                 f"Content type: {type(raw_text_from_bubble)}, Value: {raw_text_from_bubble}")
-                        print(bubble_api_status_msg)
-                        parsed_token_dict = None 
-                    # If it is a dict, parsed_token_dict is now the token dictionary itself
-                except json.JSONDecodeError as e:
-                    bubble_api_status_msg = (f"⚠️ Bubble API: Error decoding 'Raw_text' JSON string: {e}. "
-                                             f"Content: {raw_text_from_bubble}")
-                    print(bubble_api_status_msg)
-                    parsed_token_dict = None 
-            elif raw_text_from_bubble: # It exists but is not a string
-                 bubble_api_status_msg = (f"⚠️ Bubble API: 'Raw_text' field was not a string. "
-                                         f"Type: {type(raw_text_from_bubble)}, Value: {raw_text_from_bubble}")
-                 print(bubble_api_status_msg)
-
-
-            if parsed_token_dict and "access_token" in parsed_token_dict:
-                token_received["status"] = True
-                token_received["token"] = parsed_token_dict # Store the entire parsed dictionary
-                token_received["client_id"] = f"Bubble (state: {url_user_token_str})"
-                bubble_api_status_msg = f"✅ LinkedIn Token successfully fetched and parsed from Bubble 'Raw_text' for state: {url_user_token_str}"
-                print(bubble_api_status_msg)
-            elif raw_text_from_bubble and not parsed_token_dict:
-                # Error message already set by parsing logic if raw_text_from_bubble existed but parsing failed.
-                # If bubble_api_status_msg wasn't set by specific parsing errors, use a general one.
-                if not bubble_api_status_msg.startswith("⚠️"): # Avoid overwriting specific parsing error
-                    bubble_api_status_msg = f"⚠️ Bubble API: 'Raw_text' found but could not be parsed into a valid token dictionary for state: {url_user_token_str}."
-                print(bubble_api_status_msg)
-            elif not raw_text_from_bubble:
-                 bubble_api_status_msg = (f"⚠️ Bubble API: Token field ('Raw_text') "
-                                         f"not found or is null in response for state: {url_user_token_str}. Result: {results[0]}")
-                 print(bubble_api_status_msg)
-            elif parsed_token_dict and "access_token" not in parsed_token_dict: # Parsed OK, but missing the crucial key
-                 bubble_api_status_msg = (f"⚠️ Bubble API: 'access_token' key missing in parsed 'Raw_text' dictionary for state: {url_user_token_str}. Parsed: {parsed_token_dict}")
-                 print(bubble_api_status_msg)
-            # If none of the above, the initial bubble_api_status_msg will be used or an error below will catch it.
-
-        else: # No results from Bubble for the given state
-            bubble_api_status_msg = f"❌ Bubble API: No results found for state: {url_user_token_str}"
-            print(bubble_api_status_msg)
-            
-    except requests.exceptions.HTTPError as http_err:
-        error_details = response.text if response else "No response content"
-        bubble_api_status_msg = f"❌ Bubble API HTTP error: {http_err} - Response: {error_details}"
-        print(bubble_api_status_msg)
-    except requests.exceptions.Timeout:
-        bubble_api_status_msg = "❌ Bubble API Request timed out."
-        print(bubble_api_status_msg)
-    except requests.exceptions.RequestException as req_err:
-        bubble_api_status_msg = f"❌ Bubble API Request error: {req_err}"
-        print(bubble_api_status_msg)
-    except json.JSONDecodeError as json_err: # Error decoding the main Bubble response, not Raw_text
-        error_details = response.text if response else "No response content"
-        bubble_api_status_msg = f"❌ Bubble API main response JSON decode error: {json_err}. Response: {error_details}"
-        print(bubble_api_status_msg)
-    except Exception as e:
-        bubble_api_status_msg = f"❌ An unexpected error occurred while fetching from Bubble: {str(e)}"
-        print(bubble_api_status_msg)
-
-    # Return values to update all relevant UI components
-    return bubble_api_status_msg, check_status(), show_token(), show_client()
 
 
 # --- Guarded fetch functions (using token from POST or Bubble) ---