Update Bubble_API_Calls.py

Bubble_API_Calls.py

@@ -88,7 +88,40 @@ 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_posts(org_urn: 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."
+        print(error_msg)
+        return None, error_msg
 
+    base_url = "https://app.ingaze.ai/version-test/api/1.1/obj/LI_posts"
+    constraints = [{"key": "author_urn", "constraint_type": "equals", "value": org_urn}]
+    params = {'constraints': json.dumps(constraints)}
+    headers = {"Authorization": f"Bearer {bubble_api_key}"}
+
+    status_message = f"Attempting to fetch posts from Bubble for urn: {org_urn}..."
+    print(status_message)
+
+    try:
+        response = requests.get(base_url, params=params, headers=headers, timeout=15)
+        response.raise_for_status()
+
+        data = response.json()
+        results = data.get("response", {}).get("results", [])
+
+        if results:
+            df = pd.DataFrame(results)
+            print(f"Successfully retrieved {len(df)} posts.")
+            return df, None
+        else:
+            print("No posts found for the given org_urn.")
+            return pd.DataFrame(), None
+
+    except requests.exceptions.RequestException as e:
+        error_msg = f"❌ Bubble API Error: {str(e)}"
+        print(error_msg)
+        return None, error_msg
 
 
 def bulk_upload_to_bubble(data, data_type):