Update apis/Bubble_API_Calls.py

apis/Bubble_API_Calls.py

@@ -126,25 +126,77 @@ def fetch_linkedin_posts_data_from_bubble(org_urn: str, data_type:str):
         return None, error_msg
 
 
+# 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": "text/plain"
+#     }
+
+#     # Convert list of dicts to newline-separated JSON strings
+#     payload = "\n".join(json.dumps(item) for item in data)
+#     response = requests.post(url, headers=headers, data=payload)
+
+#     print("Payload being sent:")
+#     print(payload)
+    
+#     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}")
+
+#versione f49ffdd ultima che funzionava per upload dati linkedin
 def bulk_upload_to_bubble(data, data_type):
+    """
+    Uploads a list of dictionaries to a specified Bubble data type using the bulk endpoint.
+
+    Args:
+        data (list): A list of dictionaries, where each dictionary represents a record.
+        data_type (str): The name of the Bubble data type (table) to upload to.
+
+    Returns:
+        list: A list of unique Bubble IDs for the created records if successful.
+        bool: False if the upload fails.
+    """
     api_token = os.environ.get("Bubble_API")
+    if not api_token:
+        logger.error("Bubble_API environment variable not set.")
+        return False
+
     url = f"https://app.ingaze.ai/version-test/api/1.1/obj/{data_type}/bulk"
     headers = {
         "Authorization": f"Bearer {api_token}",
-        "Content-Type": "text/plain"
+        # The bulk endpoint expects newline-delimited JSON objects with a text/plain Content-Type
+        "Content-Type": "text/plain" 
     }
 
-    # Convert list of dicts to newline-separated JSON strings
+    # Convert the list of dictionaries into a single string,
+    # with each JSON object separated by a newline character.
     payload = "\n".join(json.dumps(item) for item in data)
-    response = requests.post(url, headers=headers, data=payload)
 
-    print("Payload being sent:")
-    print(payload)
-    
-    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}")
+    logger.info(f"Sending bulk payload to Bubble data type: {data_type}")
+    # print("Payload being sent:\n" + payload) # Uncomment for deep debugging
+
+    try:
+        response = requests.post(url, headers=headers, data=payload.encode('utf-8'))
+        
+        # Raise an exception for bad status codes (4xx or 5xx)
+        response.raise_for_status()
+
+        # If the request was successful (200 OK), Bubble returns a JSON array of the new record IDs.
+        # We parse the JSON response to get this list.
+        created_ids = response.json()
+        logger.info(f"Successfully uploaded {len(data)} records to {data_type}.")
+        return created_ids
+
+    except requests.exceptions.HTTPError as http_err:
+        logger.error(f"HTTP error occurred: {http_err}")
+        logger.error(f"Failed to upload data to {data_type}. Status Code: {response.status_code}, Response: {response.text}")
+        return False
+    except Exception as err:
+        logger.error(f"An other error occurred: {err}")
+        return False
 
 def update_record_in_bubble(table_name, record_id, payload_to_update):
     """