@Test
        @DisplayName("Decode error handling should work correctly")
        void testDecodeErrorHandling() throws Exception {
            // Given
            when(mockHandle.getMaxXmit()).thenReturn(1024);
            when(mockHandle.getMaxRecv()).thenReturn(1024);
            DcerpcBind bindMessage = new DcerpcBind(mockBinding, mockHandle);

            // When - Decode with error response

            if (len++ > max) {
                throw new RuntimeException("zero termination not found: " + this);
            }
        }
        return len;
    }

    int encode(final byte[] dst, int dstIndex) {
        final int start = headerStart = dstIndex;

        dstIndex += writeHeaderWireFormat(dst, dstIndex);
        wordCount = writeParameterWordsWireFormat(dst, dstIndex + 1);

      .assertLogEqual("Content-Encoding: br")
      .assertLogEqual("Content-Type: text/plain; charset=utf-8")
      .assertLogMatch(Regex("""Content-Length: \d+"""))
      .assertLogEqual("<-- END HTTP (encoded body omitted)")
      .assertNoMoreLogs()
    applicationLogs
      .assertLogEqual("--> GET $url")
      .assertLogEqual("--> END GET")
      .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms\)"""))

import jcifs.util.Encdec;

@ExtendWith(MockitoExtension.class)
class NtlmUtilTest {

    @Mock
    CIFSContext cifsContext;

    @Mock
    Configuration configuration;

    // Helper: decode hex string to bytes
    private static byte[] hex(String s) {
        String clean = s.replaceAll("[^0-9A-Fa-f]", "");
        int len = clean.length();
        byte[] out = new byte[len / 2];

            byte[] buffer = new byte[0];
            int result = response.readParametersWireFormat(buffer, 0, 0);

            assertEquals(0, result);
        }

        @Test
        @DisplayName("Should decode DFS referral data correctly")
        void testReadDataWireFormat() {
            byte[] buffer = createValidDfsReferralBuffer();

            int bytesRead = response.readDataWireFormat(buffer, 0, buffer.length);

	}

	// Query IAM

	res, err := globalIAMSys.QueryLDAPPolicyEntities(r.Context(), q)
	if err != nil {
		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
		return
	}

	// Encode result and send response.

	data, err := json.Marshal(res)
	if err != nil {
		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
		return
	}
	password := cred.SecretKey

  }

  /**
   * Returns a serializable converter object that converts between strings and longs using {@link
   * Long#decode} and {@link Long#toString()}. The returned converter throws {@link
   * NumberFormatException} if the input string is invalid.
   *
   * <p><b>Warning:</b> please see {@link Long#decode} to understand exactly how strings are parsed.

			comment: "in the 世界",
			flags:   0x808,
		},
		{
			name:    "the replacement rune is �",
			comment: "the replacement rune is �",
			flags:   0x808,
		},
		{
			// Name is Japanese encoded in Shift JIS.
			name:    "\x93\xfa\x96{\x8c\xea.txt",
			comment: "in the 世界",
			flags:   0x008, // UTF-8 must not be set
		},
	}

	// write a zip file
	buf := new(bytes.Buffer)
	w := NewWriter(buf)

            writeInt2(buffer, dataOffset + 48, epoch);  // Epoch
            writeInt2(buffer, dataOffset + 50, 0);  // Reserved
        }
    }
    
    @Override
    public void decode(byte[] buffer, int offset, int length) {
        // Decode lease response
        byte[] keyBytes = new byte[16];
        System.arraycopy(buffer, offset, keyBytes, 0, 16);
        this.leaseKey = new Smb2LeaseKey(keyBytes);
        

                dstIndex += cnBytes.length;
                dstIndex += pad8(dstIndex);

                SMBUtil.writeInt2(dstIndex - structStart, dst, dataOffsetOffset);
                final int len = createContext.encode(dst, dstIndex);
                SMBUtil.writeInt4(len, dst, dataLengthOffset);
                dstIndex += len;

                final int pad = pad8(dstIndex);
                totalCreateContextLength += len + pad;