recordNameField.setAccessible(true);
        recordNameField.set(response, new Name(mockConfig));

        Field questionNameField = NameServicePacket.class.getDeclaredField("questionName");
        questionNameField.setAccessible(true);
        questionNameField.set(response, new Name(mockConfig));

        int result = response.readBodyWireFormat(src, srcIndex);
        assertTrue(result > 0);
    }

    }
  }

  /**
   * Receives a response from this thread.
   *
   * @throws TimeoutException if this thread does not offer a response within a reasonable amount of
   *     time
   * @throws AssertionFailedError if the given method name does not match the name of the method
   *     this thread has called most recently
   */
  private Response getResponse(String methodName) throws Exception {

            public void process(String origin, ServletRequest request, ServletResponse response) {
                processCalled = true;
                processOrigin = origin;
                processRequest = request;
                processResponse = response;

                // Simulate adding headers for testing
                if (response instanceof HttpServletResponse) {

    val call =
      client.newCall(
        Request
          .Builder()
          .url(server.url("/"))
          .build(),
      )
    val response = call.execute()
    assertThat(response.code).isEqualTo(200)
    assertThat(response.body.string()).isEqualTo("abc")
    response.body.close()
    assertThat(listener.recordedEventTypes()).containsExactly(
      "ConnectStart",
      "ConnectEnd",
      "ConnectionAcquired",

    private Configuration mockConfig;
    private Smb2SetInfoResponse response;

    @BeforeEach
    void setUp() {
        mockConfig = mock(Configuration.class);
        response = new Smb2SetInfoResponse(mockConfig);
    }

    @Test
    @DisplayName("Test constructor initializes with config")
    void testConstructor() {
        assertNotNull(response);
        // Command is not set in constructor, only after decoding

        .url(url)
        .build();
    try (Response response = client.newCall(request).execute()) {
      String responseSource = response.networkResponse() != null ? ("(network: "
          + response.networkResponse().code()
          + " over "
          + response.protocol()
          + ")") : "(cache)";
      int responseCode = response.code();

            // Create response from RPC message results
            WitnessUnregisterResponse response = new WitnessUnregisterResponse();
            response.setReturnCode(message.getReturnCode());

            if (message.isSuccess()) {
                log.debug("Witness unregistration successful");
            } else {
                response.setError(message.getErrorMessage());

        list.setTook(response.getTook().getMillis());
        list.setTotalShards(response.getTotalShards());
        list.setSuccessfulShards(response.getSuccessfulShards());
        list.setFailedShards(response.getFailedShards());
        list.setTotalHits(searchHits.getTotalHits());

        list.setAggregation(response.getAggregations());

        // #pending others

def test_middleware():
    client = TestClient(app, base_url="https://testserver")
    response = client.get("/")
    assert response.status_code == 200, response.text

    client = TestClient(app)
    response = client.get("/", follow_redirects=False)
    assert response.status_code == 307, response.text

  override fun satisfactionFailure(
    call: Call,
    response: Response,
  ) = onEvent(SatisfactionFailure(System.nanoTime(), call))

  override fun cacheMiss(call: Call) = onEvent(CacheMiss(System.nanoTime(), call))

  override fun cacheHit(
    call: Call,
    response: Response,
  ) = onEvent(CacheHit(System.nanoTime(), call))

  override fun cacheConditionalHit(