}

    @Override
    public String toString() {
        return "LlmMessage{role='" + role + "', content='"
                + (content != null && content.length() > 50 ? content.substring(0, 50) + "..." : content) + "'}";
    }

    serverSocket = serverSocketFactory.createServerSocket()
    val serverAddress = InetAddress.getByName("localhost")
    serverSocket!!.bind(InetSocketAddress(serverAddress, 0), 50)
    return InetSocketAddress(serverAddress, serverSocket!!.localPort)
  }

  private fun doServerHandshake(server: HandshakeCertificates): Future<Handshake> {
    return executorService.submit<Handshake> {

        byte[] buffer = new byte[100];

        assertThrows(NullPointerException.class, () -> nullBufferResponse.readDataWireFormat(buffer, 0, 50));
    }

    @Test
    void testReadDataWireFormatEmptyOutputBuffer() throws SMBProtocolDecodingException {
        // Test with empty outputBuffer

        // Fill test pattern
        for (int i = 0; i < buffer.length; i++) {
            buffer[i] = (byte) (i % 256);
        }

        int bytesConsumed = response.decode(buffer, 0, 50);

        assertEquals(28, bytesConsumed, "Should consume exactly 28 bytes regardless of extra length");

        byte[] resumeKey = response.getResumeKey();