Update apis/Bubble_API_Calls.py

apis/Bubble_API_Calls.py

@@ -91,7 +91,7 @@ def fetch_linkedin_token_from_bubble(url_user_token_str: str):
     print(status_message) # Log the final status message
     return parsed_token_dict
 
-def fetch_linkedin_posts_data_from_bubble(org_urn: str, data_type:str):
+def fetch_linkedin_posts_data_from_bubble(org_urn: str, data_type:str, constraint_key:str):
     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."
@@ -99,7 +99,7 @@ def fetch_linkedin_posts_data_from_bubble(org_urn: str, data_type:str):
         return None, error_msg
 
     base_url = f"https://app.ingaze.ai/version-test/api/1.1/obj/{data_type}"
-    constraints = [{"key": "organization_urn", "constraint_type": "equals", "value": org_urn}]
+    constraints = [{"key": constraint_key, "constraint_type": "equals", "value": org_urn}]
     params = {'constraints': json.dumps(constraints)}
     headers = {"Authorization": f"Bearer {bubble_api_key}"}