}

    private int parseResponseCode() throws IOException {
        try {
            final String response = connection.getHeaderField(0);
            int index = response.indexOf(' ');
            while (response.charAt(index) == ' ') {
                index++;
            }
            return Integer.parseInt(response.substring(index, index + 3));
        } catch (final Exception ex) {

client = TestClient(app)


def test_security_api_key():
    response = client.get("/users/me", headers={"key": "secret"})
    assert response.status_code == 200, response.text
    assert response.json() == {"username": "secret"}


def test_security_api_key_no_key():
    response = client.get("/users/me")
    assert response.status_code == 200, response.text
    assert response.json() == {"msg": "Create an account first"}

        searchBody.put("size", 100);

        String response = checkMethodBase(searchBody).get(API_PATH + "/logs").asString();
        List<Map<String, Object>> logs = JsonPath.from(response).getList("response.logs");

        logger.info("Failure URL logs: {}", logs);
        assertTrue(logs.size() > 0, "Should have at least one failure URL log");

        // Verify response structure

        .post(RequestBody.create(file, MEDIA_TYPE_MARKDOWN))
        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

      System.out.println(response.body().string());
    }
  }

  public static void main(String... args) throws Exception {
    new PostFile().run();
  }

    Request request = new Request.Builder()
        .url("https://publicobject.com/secrets/hellosecret.txt")
        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

      System.out.println(response.body().string());
    }
  }

  public static void main(String... args) throws Exception {
    new PreemptiveAuth().run();
  }

        response.setContent("Response content");
        response.setFinishReason("stop");
        response.setPromptTokens(100);
        response.setCompletionTokens(50);
        response.setTotalTokens(150);
        response.setModel("gpt-4");

        assertEquals("Response content", response.getContent());
        assertEquals("stop", response.getFinishReason());

      }
  }

  override fun onResponse(
    call: Call,
    response: Response,
  ) {
    processResponse(response)
  }

  fun processResponse(response: Response) {
    response.use {
      if (!response.isSuccessful) {
        listener.onFailure(this, null, response)
        return
      }

      val body = response.body

      if (!body.isEventStream()) {
        listener.onFailure(

        }

        chain.doFilter(request, response);
    }

    /**
     * Send a 403 Forbidden response for blocked IPs.
     * @param response the HTTP response
     * @throws IOException if an I/O error occurs
     */
    protected void sendBlockedResponse(final HttpServletResponse response) throws IOException {
        response.setStatus(HttpServletResponse.SC_FORBIDDEN);
        response.setContentType("application/json;charset=UTF-8");

        assertTrue(jsonPath.getBoolean("response.created"));
        assertEquals(0, jsonPath.getInt("response.status"));
        return jsonPath.getString("response.id");
    }

    protected static List<String> getFileConfigIds(final String namePrefix) {
        final String response = getJsonResponse("/api/admin/fileconfig/settings");

        response.getServerData().securityMode = 1;
        response.getServerData().encryptedPasswords = true;
        response.getServerData().smaxMpxCount = 50;
        response.getServerData().maxNumberVcs = 1;
        response.getServerData().maxBufferSize = 16384;
        response.getServerData().maxRawSize = 4096;
        response.getServerData().sessKey = 0x12345678;
        response.getServerData().scapabilities = SmbConstants.CAP_UNICODE;