@BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        testMacSigningKey = new byte[] { 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F, 0x10 };
    }

    @Test
    @DisplayName("Test constructor with MAC signing key and bypass flag")
    void testConstructorWithBypass() {

    assertThat(hpackWriter!!.headerCount).isEqualTo(1)
    hpackWriter!!.writeHeaders(headerEntries("foo", "bar1"))
    assertBytes(0x7e, 4, 'b'.code, 'a'.code, 'r'.code, '1'.code)
    assertThat(hpackWriter!!.headerCount).isEqualTo(2)
    hpackWriter!!.writeHeaders(headerEntries("foo", "bar1"))
    assertBytes(0xbe)
    assertThat(hpackWriter!!.headerCount).isEqualTo(2)
  }

            assertEquals((byte) 0x2B, ServerMessageBlock.SMB_COM_ECHO);
            assertEquals((byte) 0x2D, ServerMessageBlock.SMB_COM_OPEN_ANDX);
            assertEquals((byte) 0x2E, ServerMessageBlock.SMB_COM_READ_ANDX);
            assertEquals((byte) 0x2F, ServerMessageBlock.SMB_COM_WRITE_ANDX);
            assertEquals((byte) 0x32, ServerMessageBlock.SMB_COM_TRANSACTION2);

     * This is an enhanced version of Connect2 with additional parameters.
     */
    public static class SamrConnect4 extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x3e;
        }

        /** The return value of the operation */
        public int retval;
        /** The NetBIOS name of the server to connect to */
        public String system_name;

     * This is an enhanced version of Connect2 with additional parameters.
     */
    public static class SamrConnect4 extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x3e;
        }

        /** The return value of the operation */
        public int retval;
        /** The NetBIOS name of the server to connect to */
        public String system_name;

      // TODO(cpovirk): Use SourceCodeEscapers if it is added to Guava.
      StringBuilder escapedInput = new StringBuilder();
      for (char c : input.toCharArray()) {
        if (c >= 0x20 && c <= 0x7E) {
          escapedInput.append(c);
        } else {
          escapedInput.append(String.format("\\u%04x", (int) c));
        }
      }

     * LSA query information policy version 2 message.
     */
    public static class LsarQueryInformationPolicy2 extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x2e;
        }

        /** Return value from the RPC call. */
        public int retval;
        /** Policy handle for the query. */
        public rpc.policy_handle handle;

            // When: Creating connect4 message
            samr.SamrConnect4 message = new samr.SamrConnect4("system", 456, 123, mockPolicyHandle);

            // Then: Should have correct values
            assertEquals(0x3e, message.getOpnum());
            assertEquals("system", message.system_name);
            assertEquals(456, message.unknown);
            assertEquals(123, message.access_mask);

  }

  @Test
  fun responseBodyIsBinary() {
    setLevel(Level.BODY)
    val buffer = Buffer()
    buffer.writeUtf8CodePoint(0x89)
    buffer.writeUtf8CodePoint(0x50)
    buffer.writeUtf8CodePoint(0x4e)
    buffer.writeUtf8CodePoint(0x47)
    buffer.writeUtf8CodePoint(0x0d)
    buffer.writeUtf8CodePoint(0x0a)
    buffer.writeUtf8CodePoint(0x1a)
    buffer.writeUtf8CodePoint(0x0a)
    server.enqueue(

     * LSA query information policy version 2 message.
     */
    public static class LsarQueryInformationPolicy2 extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x2e;
        }

        /** Return value from the RPC call. */
        public int retval;
        /** Policy handle for the query. */
        public rpc.policy_handle handle;