* Supports Amazon S3, MinIO, and other S3-compatible storage systems.
 */
public class S3StorageClient implements StorageClient {

    private static final Logger logger = LogManager.getLogger(S3StorageClient.class);

    private final S3Client s3Client;
    private final String bucket;

    /**
     * Creates a new S3StorageClient instance.
     *
     * @param endpoint the S3 endpoint URL (null for AWS default)

    }

    /**
     * Test implementation of RequestWithPath interface for testing purposes
     */
    private static class TestRequestWithPath implements RequestWithPath {
        private String path;
        private String server;
        private String domain;
        private String fullUNCPath;
        private boolean resolveInDfs;

        @Override
        public String getPath() {
            return path;

@MockitoSettings(strictness = Strictness.LENIENT)
public class PreauthIntegrityTest {

    @Mock
    private CIFSContext context;

    @Mock
    private Configuration config;

    @Mock
    private Address address;

    @Mock
    private Smb2NegotiateResponse negotiateResponse;

    private SmbTransportImpl transport;

    @BeforeEach
    void setUp() throws Exception {

     * The size in bytes of the input block to the tranformation algorithm.
     */
    private static final int BLOCK_LENGTH = 64; //    = 512 / 8;

    /**
     * 4 32-bit words (interim result)
     */
    private int[] context = new int[4];

    /**
     * Number of bytes processed so far mod. 2 power of 64.
     */
    private long count;

    /**

 */
public class Type2Message extends NtlmMessage {

    private static final Logger log = LoggerFactory.getLogger(Type2Message.class);

    private byte[] challenge;
    private String target;
    private byte[] context;
    private byte[] targetInformation;

    private static final Map<String, byte[]> TARGET_INFO_CACHE = new HashMap<>();

    private static byte[] getDefaultTargetInfo(final CIFSContext tc) {

 */
public class EsPagingResultBean<ENTITY> extends PagingResultBean<ENTITY> {

    private static final long serialVersionUID = 1L;

    protected long took;
    private int totalShards;
    private int successfulShards;
    private int failedShards;
    private TotalHits totalHits;
    private Aggregations aggregations;

    private SearchRequestBuilder builder;

public class SmbRandomAccessFile implements SmbRandomAccess {

    private static final Logger log = LoggerFactory.getLogger(SmbRandomAccessFile.class);
    private static final int WRITE_OPTIONS = 0x0842;

    private final SmbFile file;
    private long fp;
    private int openFlags, access = 0, readSize, writeSize, options = 0;
    private final byte[] tmp = new byte[8];
    private SmbComWriteAndXResponse write_andx_resp = null;

 */
public class EsPagingResultBean<ENTITY> extends PagingResultBean<ENTITY> {

    private static final long serialVersionUID = 1L;

    protected long took;
    private int totalShards;
    private int successfulShards;
    private int failedShards;
    private TotalHits totalHits;
    private Aggregations aggregations;

    private SearchRequestBuilder builder;

import org.junit.jupiter.api.Test;

/**
 * Tests for the SmbComOpenAndX class.
 */
class SmbComOpenAndXTest {

    private SmbComOpenAndX smbComOpenAndX;
    private final String fileName = "testFile.txt";
    private final int access = SmbFile.GENERIC_READ | SmbFile.GENERIC_WRITE;
    private ServerMessageBlock andx;

    /**
     * Sets up the test environment before each test.
     */
    @BeforeEach

 *
 * @author mbechler
 */
public class DcerpcBind extends DcerpcMessage {

    private static final String[] result_message = { "0", "DCERPC_BIND_ERR_ABSTRACT_SYNTAX_NOT_SUPPORTED",
            "DCERPC_BIND_ERR_PROPOSED_TRANSFER_SYNTAXES_NOT_SUPPORTED", "DCERPC_BIND_ERR_LOCAL_LIMIT_EXCEEDED" };

    private static String getResultMessage(final int result) {