Update Bubble_API_Calls.py

Bubble_API_Calls.py

@@ -145,3 +145,54 @@ def bulk_upload_to_bubble(data, data_type):
     else:
         print(f"Failed to upload data to {data_type}. Status Code: {response.status_code}, Response: {response.text}")
 
+def update_record_in_bubble(table_name, record_id, payload_to_update):
+    """
+    Updates an existing record in a Bubble.io table using a PATCH request.
+
+    Args:
+        table_name (str): The name of the Bubble table (e.g., "User", "Product").
+        record_id (str): The unique ID of the record to update.
+        payload_to_update (dict): A dictionary where keys are field names (slugs)
+                                  and values are the new values for those fields.
+    Returns:
+        bool: True if the update was successful, False otherwise.
+    """
+    bubble_api_key = os.environ.get("Bubble_API")
+    if not record_id:
+        logging.error(f"Record ID is missing. Cannot update record in Bubble table '{table_name}'.")
+        return False
+    if not payload_to_update:
+        logging.warning(f"Payload to update is empty for record_id '{record_id}' in Bubble table '{table_name}'. Nothing to update.")
+        # Consider this a success as there's no error, just no action.
+        # Depending on desired behavior, you might return False or raise an error.
+        return True
+
+    # Construct the API endpoint for a specific record
+    # Example: https://<app_name>.bubbleapps.io/api/1.1/obj/<table_name>/<record_id>
+    api_endpoint = f"https://app.ingaze.ai/version-test/api/1.1/obj/{table_name}/{record_id}"
+    headers = {
+        "Authorization": f"Bearer {bubble_api_key}",
+        "Content-Type": "application/json"
+    }
+
+    logging.debug(f"Attempting to update record '{record_id}' in table '{table_name}' at endpoint '{api_endpoint}' with payload: {payload_to_update}")
+
+    try:
+        response = requests.patch(api_endpoint, json=payload_to_update, headers=headers)
+        response.raise_for_status()  # Raises an HTTPError for bad responses (4XX or 5XX)
+        logging.info(f"Successfully updated record '{record_id}' in Bubble table '{table_name}'.")
+        return True
+    except requests.exceptions.HTTPError as http_err:
+        # Log more details from the response if available
+        error_details = ""
+        try:
+            error_details = response.json() # Bubble often returns JSON errors
+        except ValueError: # If response is not JSON
+            error_details = response.text
+        logging.error(f"HTTP error occurred while updating record '{record_id}' in '{table_name}': {http_err}. Response: {error_details}")
+    except requests.exceptions.RequestException as req_err:
+        logging.error(f"Request exception occurred while updating record '{record_id}' in '{table_name}': {req_err}")
+    except Exception as e:
+        logging.error(f"An unexpected error occurred while updating record '{record_id}' in '{table_name}': {e}", exc_info=True)
+    
+    return False