serverWriter.writeMessageFrame(OPCODE_TEXT, payload)
    assertData("8105")
    assertData(payload)
  }

  @Test fun serverLargeBufferedPayloadWrittenAsOneFrame() {
    val length = 12345
    val payload: ByteString = (binaryData(length))
    serverWriter.writeMessageFrame(OPCODE_TEXT, payload)
    assertData("817e")
    assertData(format("%04x", length))
    assertData(payload)
  }

        // Test with specific value
        FileEndOfFileInformation info = new FileEndOfFileInformation(12345L);
        String str2 = info.toString();
        assertEquals("EndOfFileInformation[endOfFile=12345]", str2);
    }

    @Test
    @DisplayName("Test toString with various values")
    void testToStringWithVariousValues() {
        // Test negative value

    }

    @Test
    @DisplayName("Should handle parsing invalid message bytes")
    void testInvalidMessageBytes() {
        // Given
        byte[] invalidBytes = { 1, 2, 3, 4, 5 }; // Too short and invalid

        // When/Then
        assertThrows(IOException.class, () -> {
            new Type1Message(invalidBytes);
        });
    }

    @Test

        when(nego.getServerData()).thenReturn(serverData);
        when(transport.getNegotiateResponse()).thenReturn(nego);

        // Mock config methods needed for SMB1
        when(config.getPid()).thenReturn(1234);

        SmbComTreeConnectAndXResponse response = mock(SmbComTreeConnectAndXResponse.class);
        when(response.getService()).thenReturn("A:");
        when(response.isValidTid()).thenReturn(true);

    // Now change the inputs and see result dynamically change as well

    list1.add(2);
    List<Integer> list3 = newArrayList(3);
    input.add(1, list3);

    assertEquals(asList(1, 2, 3, 4), newArrayList(result));
    assertEquals("[1, 2, 3, 4]", result.toString());
  }

  public void testConcatVarargs() {
    List<Integer> list1 = newArrayList(1);
    List<Integer> list2 = newArrayList(4);

    }

    @Test
    void constructor_shouldThrowSmbExceptionOnRpcError() throws IOException {
        // Arrange
        String server = "testServer";
        int access = 123;
        int errorCode = 12345;

        doAnswer(invocation -> {
            MsrpcLsarOpenPolicy2 rpc = invocation.getArgument(0);
            rpc.retval = errorCode; // Simulate RPC error
            return null;

    }

    @Test
    void constructor_shouldThrowSmbExceptionOnRpcError() throws IOException {
        // Arrange
        String server = "testServer";
        int access = 123;
        int errorCode = 12345;

        doAnswer(invocation -> {
            MsrpcLsarOpenPolicy2 rpc = invocation.getArgument(0);
            rpc.retval = errorCode; // Simulate RPC error
            return null;

            assertEquals(credits, testRequest.getCredit());
        }

        @Test
        @DisplayName("setTid should set tree ID")
        void testSetTid() {
            int tid = 12345;
            testRequest.setTid(tid);
            assertEquals(tid, testRequest.getTreeId());
        }
    }

    @Nested
    @DisplayName("Async Operation Tests")
    class AsyncOperationTests {

    }

    @Test
    @DisplayName("getPipeType and getPipe delegate to SmbNamedPipe")
    void pipeType_and_getPipe() {
        when(pipe.getPipeType()).thenReturn(12345);
        SmbPipeHandleImpl handle = new SmbPipeHandleImpl(pipe);
        assertEquals(12345, handle.getPipeType());
        assertSame(pipe, handle.getPipe());
    }

    @Test
    @DisplayName("isOpen/isStale reflect handle validity and lifecycle")

        authElementVector.add(new DERTaggedObject(0, new ASN1Integer(999))); // ad-type
        authElementVector.add(new DERTaggedObject(1, new DEROctetString(new byte[] { 1, 2, 3, 4 })));
        authDataVector.add(new DERSequence(authElementVector));
        vector.add(new DERTaggedObject(10, new DERSequence(authDataVector)));

        DERSequence sequence = new DERSequence(vector);