Update Bubble_API_Calls.py

Bubble_API_Calls.py

@@ -3,6 +3,7 @@ import os
 import json
 import requests
 
+
 def fetch_linkedin_token_from_bubble(url_user_token_str: str):
     """
     Fetches LinkedIn access token from Bubble.io API using the state value (url_user_token_str).
@@ -86,3 +87,22 @@ def fetch_linkedin_token_from_bubble(url_user_token_str: str):
     
     print(status_message) # Log the final status message
     return parsed_token_dict
+
+
+
+
+def bulk_upload_to_bubble(data, data_type):
+    api_token = os.environ.get("Bubble_API")
+
+    url = f"https://app.ingaze.ai/version-test/api/1.1/obj/{data_type}/bulk"
+
+    headers = {
+        "Authorization": f"Bearer {api_token}",
+        "Content-Type": "application/json"
+    }
+
+    response = requests.post(url, headers=headers, json=data)
+    if response.status_code == 200:
+        print(f"Successfully uploaded {len(data)} records to {data_type}.")
+    else:
+        print(f"Failed to upload data to {data_type}. Status Code: {response.status_code}, Response: {response.text}")