void testClose_Successful() throws IOException {
        // Test case: close() when opened and successful MsrpcSamrCloseHandle
        String server = "testServer";
        int access = 123;

        // Setup for successful constructor
        doNothing().when(mockHandle).sendrecv(any(MsrpcSamrConnect4.class));

        // Setup for successful close

        RangeQueryBuilder rangeQuery = (RangeQueryBuilder) deleteQuery;
        assertEquals("expires", rangeQuery.fieldName());
        assertEquals("now", rangeQuery.to());

        // Assert result is empty when successful
        assertEquals("", result);
    }

    public void test_execute_withException() {
        // Create mock SearchEngineClient that throws exception
        searchEngineClient = new SearchEngineClient() {

/**
 * Tests for the {@link ASN1Util} class.
 */
class ASN1UtilTest {

    // --- as(Class, Object) ---

    @Test
    void testAs_Object_Success() throws PACDecodingException {
        // Test successful casting
        String expected = "test string";
        Object obj = expected;
        String result = ASN1Util.as(String.class, obj);
        assertSame(expected, result);
    }

    @Test

        HandleGuid guid = new HandleGuid();

        // Create handle info with empty file ID (will be populated after successful create response)
        HandleInfo info = new HandleInfo(path, guid, new byte[16], type, timeout, leaseKey);

        lock.writeLock().lock();
        try {
            handles.put(path, info);

    @Test
    void readRDataWireFormat_shouldSetNbtAddress_whenAddressIsNonZero_groupNameFalse_nodeTypeZero()
            throws NoSuchFieldException, IllegalAccessException {
        // Prepare superclass fields for successful parsing
        setSuperclassFieldsForSuccessfulParsing();

        byte[] src = new byte[10];
        int srcIndex = 0;

        // Simulate groupName = false (0x00), nodeType = 0 (0x00) -> src[srcIndex] = 0x00

        when(locator.getType()).thenReturn(SmbConstants.TYPE_WORKGROUP);
        when(locator.getURL()).thenReturn(createSmbURL("smb://"));

        // Mock successful but empty response
        when(treeHandle.send(any(), any(), (RequestParam[]) any())).thenAnswer(invocation -> {
            // The response is the second argument
            Object response = invocation.getArgument(1);

    }

    @Test
    void constructor_shouldOpenDomainSuccessfully() throws IOException {
        // Arrange
        int access = 0x01; // Example access value
        // Simulate successful RPC call
        doAnswer(invocation -> {
            MsrpcSamrOpenDomain rpc = invocation.getArgument(0);
            rpc.retval = 0; // Success
            return null;

    public WitnessUnregisterResponse() {
        // Default constructor
    }

    private int returnCode;
    private String error;

    /**
     * Checks if the unregistration was successful.
     *
     * @return true if successful
     */
    public boolean isSuccess() {
        return returnCode == 0;
    }

    /**
     * Gets a human-readable error description.
     *
     * @return the error description

    @Test
    void testUnregistration() throws Exception {
        // Setup successful registration
        WitnessRegisterResponse registerResponse = mock(WitnessRegisterResponse.class);
        lenient().when(registerResponse.isSuccess()).thenReturn(true);
        lenient().when(registerResponse.getRegistrationId()).thenReturn("test-reg-123");

        // Setup successful unregistration

     *
     * Current strategy is based on failure count. In the future, this could be enhanced to consider:
     * - Recent event frequency (successful notifications)
     * - Time since last successful notification
     * - Events per unit time for more adaptive behavior
     *
     * @param handle notification handle
     * @return polling interval in milliseconds
     */