when(mockPrincipal.getName()).thenReturn(expectedUserName);

        // Act: Call the method under test
        String actualUserName = ntlmRequest.getRemoteUser();

        // Assert: Verify that the returned user name is the expected one
        assertEquals(expectedUserName, actualUserName, "getRemoteUser should return the principal's name.");
    }

    /**

    }

    @Test
    void messageAndCauseConstructor_setsMessageAndCause_withoutInteractingWithCause() {
        // Arrange - mock cause to verify no interactions are needed to construct
        Throwable cause = Mockito.mock(Throwable.class);
        String message = "forced downgrade detected";

        // Act

```

## Verify the configuration and alerts
To verify the above sample alert follow below steps

1. Start a distributed MinIO instance (4 nodes setup)
2. Start Prometheus server and AlertManager
3. Bring down couple of MinIO instances to bring down the Erasure Set tolerance to -1 and verify the same with `mc admin prometheus metrics ALIAS | grep minio_cluster_health_erasure_set_status`

        assertEquals("keep1/", it.next().getName());
        assertTrue(it.hasNext());
        assertEquals("keep2/", it.next().getName());
        assertFalse(it.hasNext());

        // Verify filter called once per entry
        verify(filter, times(3)).accept(any());
    }

    @Test
    @DisplayName("Filter throws CIFSException: entry is skipped and iteration continues")

        when(cfg.getMaximumBufferSize()).thenReturn(5);

        BufferCacheImpl impl = new BufferCacheImpl(cfg);

        // Verify interactions happen exactly once during construction
        verify(cfg, times(1)).getBufferCacheSize();
        verify(cfg, times(1)).getMaximumBufferSize();
        verifyNoMoreInteractions(cfg);

        // When cache is empty, getBuffer allocates a new buffer with configured size

    void testFileEntryInterface() {
        // Verify that SmbShareInfo properly implements FileEntry interface
        SmbShareInfo info = new SmbShareInfo(TEST_NET_NAME, TEST_TYPE, TEST_REMARK);

        // Cast to FileEntry to ensure interface is properly implemented
        jcifs.smb.FileEntry fileEntry = info;

        // Verify all FileEntry methods work
        assertEquals(TEST_NET_NAME, fileEntry.getName());

        it.close();

        // Verify interactions: one create, two additional directory queries (for fetchMore), one close
        verify(tree, times(1)).send(argThat((Request<?> r) -> r instanceof Smb2CreateRequest));
        verify(tree, times(2)).send(argThat((Request<?> r) -> r instanceof Smb2QueryDirectoryRequest));
        verify(tree, times(1)).send(argThat((Request<?> r) -> r instanceof Smb2CloseRequest));

        generator = new TestThumbnailGenerator();
        Map<String, Object> docMap = new HashMap<>();

        // Note: isTarget requires FessConfig which needs container
        // We can only verify the method handles missing container gracefully
        try {
            generator.isTarget(docMap);
        } catch (IllegalStateException e) {
            // Expected when container is not initialized

        SmbComClose close = new SmbComClose(1, 12345L);
        assertEquals(SMB_COM_CLOSE, close.command, "command should be SMB_COM_CLOSE after construction");
    }

    /**
     * Verify that writeParameterWordsWireFormat writes the file id and the
     * unsigned time correctly.  The last write time is zero which should be
     * encoded as four 0xFF bytes by {@code writeUTime}.
     */

     * @param length
     *            The length of the data to verify
     * @param extraPad
     *            extra padding to include in signature
     * @param msg
     *            The message to verify
     * @return whether verification was unsuccessful
     */
    boolean verify(byte[] data, int offset, int length, int extraPad, CommonServerMessageBlock msg);