directoryLeaseManager.handleDirectoryChange(directoryPath, "", DirectoryChangeNotifier.DirectoryChangeType.DIRECTORY_RENAMED);
        assertFalse(entry.isComplete());
        assertTrue(entry.getChildren().isEmpty());
    }

    @Test
    public void testHandleDirectoryLeaseBreak() {
        String directoryPath = "/test/dir";
        Smb2LeaseKey leaseKey = new Smb2LeaseKey();

        // Create cache entry

     * @param uri the URI to preprocess
     * @return the preprocessed URI
     * @throws CrawlerSystemException if the URI is empty
     */
    protected String preprocessUri(final String uri) {
        if (StringUtil.isEmpty(uri)) {
            throw new CrawlerSystemException("File system URI is empty. Please provide a valid file path or file:// URI.");
        }

        String filePath = uri;
        if (!filePath.startsWith("file:")) {

	QueueDir   string `json:"queueDir"`
	QueueLimit uint64 `json:"queueLimit"`
}

// Validate NSQArgs fields
func (n NSQArgs) Validate() error {
	if !n.Enable {
		return nil
	}

	if n.NSQDAddress.IsEmpty() {
		return errors.New("empty nsqdAddress")
	}

	if n.Topic == "" {
		return errors.New("empty topic")
	}
	if n.QueueDir != "" {
		if !filepath.IsAbs(n.QueueDir) {

        assertEquals(1, qrList.size());
        assertEquals(doc2, qrList.get(0));

        assertTrue(qrList.remove(doc2));
        assertEquals(0, qrList.size());
        assertTrue(qrList.isEmpty());
    }

    @Test
    public void test_listOperations_contains() {
        List<Map<String, Object>> documentList = new ArrayList<>();
        Map<String, Object> doc1 = new HashMap<>();

                return "testUserCode";
            }

            @Override
            protected void updateCookie(final String userCode, final int age) {
                assertTrue(userCode.isEmpty());
                assertEquals(0, age);
            }
        };
        MockletHttpServletRequest request = getMockRequest();

        userInfoHelper.deleteUserCodeFromCookie(request);
    }

        if (session != null) {
            request.setRepositorySession(session.getRepositorySession());
            request.setSystemProperties(session.getSystemProperties());
            if (request.getUserProperties().isEmpty()) {
                request.setUserProperties(session.getUserProperties());
            }

            MavenExecutionRequest req = session.getRequest();
            if (req != null) {

        return false;
    }

    @Override
    public boolean isAvailable() {
        if (available != null) {
            return available;
        }
        if (generatorList != null && !generatorList.isEmpty()) {
            String path = System.getenv("PATH");
            if (path == null) {
                path = System.getenv("Path");
            }
            if (path == null) {

        assertNull(session.getUserId());
        assertNotNull(session.getCreatedAt());
        assertNotNull(session.getLastAccessedAt());
        assertNotNull(session.getMessages());
        assertTrue(session.getMessages().isEmpty());
    }

    @Test
    public void test_constructorWithUserId() {
        final ChatSession session = new ChatSession("user-123");
        assertNotNull(session.getSessionId());

        }
    }
}

private fun prepareScenariosStep(
    testProject: String,
    scenarios: List<Scenario>,
    os: Os,
): BuildSteps.() -> Unit {
    if (scenarios.isEmpty()) {
        throw IllegalArgumentException("Scenarios list must not be empty for $testProject")
    }
    val csvLines = scenarios.map { "${it.className};${it.scenario}" }
    val action = "include"

        List<FileNotifyInformation> result = sut.watch();

        assertSame(info, result, "Should return same list instance");
        verify(info, times(1)).clear();
        assertTrue(result.isEmpty(), "List should be cleared");
    }

    // Parameterized test to exercise SMB2 with different recursive and filter values
    @ParameterizedTest(name = "SMB2 param: recursive={0}, filter={1}")