try {
            validator.validatePath("\\share\\forbidden\\file.txt");
            fail("Should block blacklisted path");
        } catch (SmbException e) {
            assertTrue(e.getMessage().contains("not allowed"));
        }

        // Should allow other paths
        String allowed = validator.validatePath("\\share\\allowed\\file.txt");
        assertEquals("\\share\\allowed\\file.txt", allowed);

        NullPointerException npe = assertThrows(NullPointerException.class, () -> locator.handleDFSReferral(referral, null));
        assertTrue(npe.getMessage() == null || npe.getMessage().contains("reqPath"));
        verify(locator).handleDFSReferral(referral, null);
        verifyNoMoreInteractions(locator);
    }

     * @param error error that caused failure
     */
    public void handleFailure(ChannelInfo failedChannel, Exception error) {
        log.warn("Channel {} failed: {}", failedChannel.getChannelId(), error.getMessage());

        // Mark channel as failed
        failedChannel.setState(ChannelState.FAILED);

        // Get or create failover state

        // When & Then: Constructor should throw SmbException
        SmbException exception = assertThrows(SmbException.class, () -> new NetServerEnumIterator(parent, treeHandle, "*", 0, null));

        assertTrue(exception.getMessage().contains("invalid"));
        verify(treeHandle, never()).acquire();
    }

    @Test
    @DisplayName("Constructor should handle null parent")
    void testConstructor_NullParent_ThrowsNPE() {

            } catch (final Exception e) {
                logger.warn("Failed to update scores: booster={}", b.getClass().getSimpleName(), e);
                resultBuf.append(e.getMessage()).append('\n');
            }
        });
        return resultBuf.toString();
    }

    /**
     * Adds a score booster.
     * @param scoreBooster The score booster.
     */

            dcerpcBinding.setOption("endpoint", endpoint);
        }, "Should throw DcerpcException for unknown pipe endpoint.");

        assertTrue(thrown.getMessage().contains("Bad endpoint"), "Exception message should indicate a bad endpoint.");
    }

    @Test
    void testSetOptionEndpointInvalidFormat() {

        // Act & Assert
        IOException thrown = assertThrows(IOException.class, () -> {
            new LsaPolicyHandle(mockDcerpcHandle, server, access);
        });

        assertEquals("Network error", thrown.getMessage());
        verify(mockDcerpcHandle, times(1)).sendrecv(any(MsrpcLsarOpenPolicy2.class));
    }

    @Test
    void close_shouldClosePolicySuccessfully() throws IOException {
        // Arrange

        return crawlingInfo;
    }

    public String getKeyMsg() {
        final Locale locale = ComponentUtil.getRequestManager().getUserLocale();
        final String message = ComponentUtil.getMessageManager().getMessage(locale, "labels.crawling_info_" + getKey());
        if (message == null || message.startsWith("???")) {
            return getKey();
        }
        return message;
    }

    @Override

                    () -> new Smb2SigningDigest(sessionKey, Smb2Constants.SMB2_DIALECT_0311, null));
            assertEquals("Missing preauthIntegrityHash for SMB 3.1.1", exception.getMessage());
        }

        @Test
        @DisplayName("Should throw exception for unknown dialect")
        void testConstructorUnknownDialect() {
            IllegalArgumentException exception =

        CIFSException ex1 = assertThrows(CIFSException.class, handle::getInput, "getInput after close must throw");
        assertTrue(ex1.getMessage().contains("Already closed"));
        CIFSException ex2 = assertThrows(CIFSException.class, handle::getOutput, "getOutput after close must throw");
        assertTrue(ex2.getMessage().contains("Already closed"));
    }

    @Test
    @DisplayName("ensureOpen opens SMB2 via UNC path and marks open")