response = client.get("/items/", headers={"X-Token": "invalid"})
    assert response.status_code == 400, response.text
    assert response.json() == {"detail": "X-Token header invalid"}


def test_get_invalid_one_users(client: TestClient):
    response = client.get("/users/", headers={"X-Token": "invalid"})
    assert response.status_code == 400, response.text

        setTreeIdMethod.setAccessible(true);
        setTreeIdMethod.invoke(response, -1);
        assertFalse(response.isValidTid());

        // Test valid TID
        setTreeIdMethod.invoke(response, 100);
        assertTrue(response.isValidTid());

        // Test zero TID (valid)
        setTreeIdMethod.invoke(response, 0);
        assertTrue(response.isValidTid());
    }

    @Test

    response = client.post("/tuple-of-models/", json=data)
    assert response.status_code == 422, response.text

    data = [{"x": 1, "y": 2}]
    response = client.post("/tuple-of-models/", json=data)
    assert response.status_code == 422, response.text


def test_tuple_form_valid():
    response = client.post("/tuple-form/", data={"values": ("1", "2")})
    assert response.status_code == 200, response.text

    call.execute().use { response ->
      val source = response.body.source()
      assertThat(response.header("h1")).isEqualTo("v1")
      assertThat(response.peekTrailers()).isNull()
      assertThat(source.readUtf8()).isEqualTo(responseBody)
      assertThat(response.peekTrailers()).isEqualTo(headersOf("t1", "v2"))
      assertThat(response.peekTrailers()).isEqualTo(headersOf("t1", "v2")) // Idempotent.

client = TestClient(app)


def test_flask():
    response = client.get("/v1/")
    assert response.status_code == 200, response.text
    assert response.text == "Hello, World from Flask!"


def test_app():
    response = client.get("/v2")
    assert response.status_code == 200, response.text

        for (int i = 0; i < 10; i++) {
            assertEquals(0, response.writeSetupWireFormat(buffer, i * 10));
            assertEquals(0, response.writeParametersWireFormat(buffer, i * 10));
            assertEquals(0, response.writeDataWireFormat(buffer, i * 10));
            assertEquals(0, response.readSetupWireFormat(buffer, i * 10, 10));
            assertEquals(0, response.readParametersWireFormat(buffer, i * 10, 10));

                "input": None,
            },
        ]
    }


def test_openapi_schema(client: TestClient):
    response = client.get("/openapi.json")
    assert response.status_code == 200, response.text
    assert response.json() == {
        "openapi": "3.1.0",
        "info": {"title": "FastAPI", "version": "0.1.0"},
        "paths": {
            "/items/{item_id}": {

    cacheRequest: CacheRequest?,
    response: Response,
  ): Response {
    // Some apps return a null body; for compatibility we treat that like a null cache request.
    if (cacheRequest == null) return response
    val cacheBodyUnbuffered = cacheRequest.body()

    val source = response.body.source()
    val cacheBody = cacheBodyUnbuffered.buffer()

    val cacheWritingSource =
      object : Source {

    client = TestClient(app)
    response = client.post(path)
    assert response.status_code == 200, response.text
    assert response.json() == {"file_size": None}


@pytest.mark.parametrize(
    "path",
    [
        "/optional-bytes",
        "/optional-uploadfile",
    ],
)
def test_optional(path: str):
    client = TestClient(app)
    response = client.post(path, files=[("p", b"hello")])

            response.readBytesWireFormat(buffer1, 0);
            assertEquals(1024, response.getCount());
            assertEquals(512, response.getRemaining());

            // Second read - should update values
            byte[] buffer2 = createValidWriteResponse(2048, 1024);
            response.readBytesWireFormat(buffer2, 0);
            assertEquals(2048, response.getCount());