assertEquals(TEST_DOMAIN.getBytes(Type2Message.UNI_ENCODING).length, Type2Message.readUShort(targetInfo, 2)); // Length
                assertEquals(TEST_DOMAIN,
                        new String(Arrays.copyOfRange(targetInfo, 4, 4 + TEST_DOMAIN.getBytes(Type2Message.UNI_ENCODING).length),
                                Type2Message.UNI_ENCODING));

        Method calcMethod = findMethod(transport.getClass(), "calculatePreauthHash", byte[].class, int.class, int.class, byte[].class);
        calcMethod.setAccessible(true);

        byte[] input = "test data".getBytes();
        byte[] oldHash = new byte[64];

        byte[] newHash = (byte[]) calcMethod.invoke(transport, input, 0, input.length, oldHash);

        assertNotNull(newHash);

        this.hashCode = this.content.hashCode();
    }

    @Override
    public InputStream getInputStream() throws IOException {
        return new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
    }

    @Override
    public String getLocation() {
        return location;
    }

    /**
     * Gets the content of this source.
     *

                flags |= NTLMSSP_NEGOTIATE_OEM_DOMAIN_SUPPLIED;
                domain = suppliedDomainString.toUpperCase().getBytes(getOEMEncoding());
                size += domain.length;
            } else {
                flags &= NTLMSSP_NEGOTIATE_OEM_DOMAIN_SUPPLIED ^ 0xffffffff;
            }

            byte[] workstation = {};

            domainBytes = unicode ? domainName.getBytes(UNI_ENCODING) : domainName.getBytes(oemCp);
            size += domainBytes.length;
        }

        final String userName = getUser();
        byte[] userBytes = null;
        if (userName != null && userName.length() != 0) {
            userBytes = unicode ? userName.getBytes(UNI_ENCODING) : userName.toUpperCase().getBytes(oemCp);
            size += userBytes.length;

    /**
     * Context name for lease response
     */
    public static final String CONTEXT_NAME = "RqLs";

    private static final byte[] CONTEXT_NAME_BYTES = CONTEXT_NAME.getBytes();

    private Smb2LeaseKey leaseKey;
    private int leaseState;
    private int leaseFlags;

    /**
     * Create a new lease V1 context response
     */
    public LeaseV1CreateContextResponse() {

        return 0;
    }

    @Override
    int writeParametersWireFormat(final byte[] dst, int dstIndex) {
        final int start = dstIndex;
        byte[] descr;

        try {
            descr = DESCR.getBytes("ASCII");
        } catch (final UnsupportedEncodingException uee) {
            return 0;
        }

        writeInt2(NET_SHARE_ENUM, dst, dstIndex);
        dstIndex += 2;

import java.io.IOException;
import java.io.PrintStream;
import java.util.function.Consumer;

public class LoggingOutputStream extends FilterOutputStream {

    static final byte[] LINE_SEP = System.lineSeparator().getBytes();

    final EolBaos buf;
    final Consumer<String> consumer;

    public LoggingOutputStream(Consumer<String> consumer) {
        this(new EolBaos(), consumer);
    }

    /**
     * Context name for lease V2 response
     */
    public static final String CONTEXT_NAME = "RqL2";

    private static final byte[] CONTEXT_NAME_BYTES = CONTEXT_NAME.getBytes();

    private Smb2LeaseKey leaseKey;
    private int leaseState;
    private int leaseFlags;
    private Smb2LeaseKey parentLeaseKey;
    private int epoch;

    /**

    }

    @Override
    protected int writeParametersWireFormat(final byte[] dst, int dstIndex) {
        final int start = dstIndex;
        byte[] descr;

        try {
            descr = DESCR.getBytes("ASCII");
        } catch (final UnsupportedEncodingException uee) {
            return 0;
        }

        SMBUtil.writeInt2(NET_SHARE_ENUM, dst, dstIndex);
        dstIndex += 2;