expand end to end integration test coverage

Author: purificant

src/bubble_data_api_client/client/raw_client.py

@@ -85,8 +85,12 @@ async def create(self, typename: str, data: typing.Any) -> httpx.Response:
         """Create a new thing with the given data."""
         return await self._transport.post(url=f"/{typename}", json=data)
 
+    # https://manual.bubble.io/core-resources/api/the-bubble-api/the-data-api/data-api-requests#bulk-create-things
     async def bulk_create(self, typename: str, data: list[typing.Any]) -> httpx.Response:
-        """Create multiple things in a single request using newline-delimited JSON."""
+        """Create multiple things in a single request using newline-delimited JSON.
+
+        Response is text/plain with one JSON object per line: {"status":"success","id":"..."}
+        """
         return await self._transport.post_text(
             url=f"/{typename}/bulk",
             content="\n".join(json.dumps(item) for item in data),

src/tests/integration/test_raw_client.py

@@ -1,4 +1,6 @@
 import http
+import json
+import warnings
 from collections.abc import AsyncGenerator
 
 import httpx
@@ -38,6 +40,56 @@ async def test_retrieve_success(typename: str, test_thing_id: str, bubble_raw_cl
     assert response_body["response"]["text"] == "integration test"
 
 
+async def test_bulk_create_success(typename: str, bubble_raw_client: raw_client.RawClient):
+    """Test that bulk_create creates multiple things and returns their IDs."""
+    created_ids: list[str] = []
+
+    try:
+        response = await bubble_raw_client.bulk_create(
+            typename=typename,
+            data=[{"text": "bulk test 1"}, {"text": "bulk test 2"}],
+        )
+
+        # bubble returns text/plain with newline-delimited JSON
+        assert response.status_code == http.HTTPStatus.OK
+        assert response.headers["content-type"] == "text/plain"
+        lines = response.text.strip().split("\n")
+        assert len(lines) == 2
+
+        # parse each line and extract IDs for cleanup
+        for line in lines:
+            result = json.loads(line)
+            assert result["status"] == "success"
+            assert "id" in result
+            created_ids.append(result["id"])
+
+        # verify both items exist with correct data
+        expected_texts = ["bulk test 1", "bulk test 2"]
+        for uid, expected_text in zip(created_ids, expected_texts, strict=True):
+            retrieve_response = await bubble_raw_client.retrieve(typename=typename, uid=uid)
+            assert retrieve_response.status_code == http.HTTPStatus.OK
+            assert retrieve_response.json()["response"]["text"] == expected_text
+
+    finally:
+        # cleanup all created items
+        for uid in created_ids:
+            try:
+                await bubble_raw_client.delete(typename=typename, uid=uid)
+            except Exception as e:
+                warnings.warn(f"cleanup failed for {uid}: {e}", stacklevel=2)
+
+
+async def test_update_success(typename: str, test_thing_id: str, bubble_raw_client: raw_client.RawClient):
+    """Test that we can update a thing."""
+    response = await bubble_raw_client.update(typename=typename, uid=test_thing_id, data={"text": "updated text"})
+    # 204 No Content = success
+    assert response.status_code == http.HTTPStatus.NO_CONTENT
+
+    # verify the update
+    response = await bubble_raw_client.retrieve(typename=typename, uid=test_thing_id)
+    assert response.json()["response"]["text"] == "updated text"
+
+
 async def test_delete_success(typename: str, bubble_raw_client: raw_client.RawClient):
     """Test that we can delete a thing."""
     response_create = await bubble_raw_client.create(typename, data={"text": "integration test delete success"})

src/tests/unit/client/test_raw_client.py

@@ -40,8 +40,10 @@ async def test_replace(configured_client: None) -> None:
 @respx.mock
 async def test_bulk_create(configured_client: None) -> None:
     """Test that bulk_create posts newline-delimited JSON."""
+    # bubble returns text/plain with one JSON object per line
+    mock_response_text = '{"status":"success","id":"1234x5678"}\n{"status":"success","id":"1234x5679"}'
     route = respx.post("https://example.com/customer/bulk").mock(
-        return_value=httpx.Response(200, json={"status": "success", "count": 2})
+        return_value=httpx.Response(200, text=mock_response_text, headers={"content-type": "text/plain"})
     )
 
     async with raw_client.RawClient() as client:
@@ -51,6 +53,7 @@ async def test_bulk_create(configured_client: None) -> None:
         )
 
     assert response.status_code == 200
+    assert response.headers["content-type"] == "text/plain"
     assert route.call_count == 1
     # verify it sent newline-delimited JSON
     request_content = route.calls[0].request.content.decode()