}

        HandleInfo info = manager.getHandleForReconnect("/test/file.txt");
        assertNull(info);
    }

    @Test
    public void testCompleteReconnectSuccess() {
        HandleGuid guid = manager.requestDurableHandle("/test/file.txt", HandleType.DURABLE_V2, 120000, null);

        HandleInfo info = manager.getHandleForReconnect("/test/file.txt");
        assertTrue(info.isReconnecting());

    }

    /**
     * Get handle information for reconnection
     * @param path the file path
     * @return the handle info if available and not expired, null otherwise
     */
    public HandleInfo getHandleForReconnect(String path) {
        lock.readLock().lock();
        try {
            HandleInfo info = handles.get(path);
            if (info != null && !info.isExpired()) {
                info.setReconnecting(true);

        testHandle = new HandleInfo("/test/file.txt", guid, fileId, HandleType.DURABLE_V2, 120000, null);
    }

    @Test
    public void testReconnectHandleSuccess() throws Exception {
        when(mockManager.getHandleForReconnect("/test/file.txt")).thenReturn(testHandle);

        // Create a test reconnector that succeeds
        TestHandleReconnector testReconnector = new TestHandleReconnector(mockManager, true);

            if (info.type == HandleType.PERSISTENT) {
                persistHandle(info);
            }
        }
    }
    
    public HandleInfo getHandleForReconnect(String path) {
        HandleInfo info = handles.get(path);
        if (info != null && !info.isExpired()) {
            info.reconnecting = true;
            return info;
        }
        return null;

     * @return a future that completes with the reconnected handle info or fails
     */
    public CompletableFuture<HandleInfo> reconnectHandle(String path, Exception cause) {
        HandleInfo info = handleManager.getHandleForReconnect(path);

        if (info == null) {
            return CompletableFuture.failedFuture(new IOException("No durable handle available for reconnection: " + path));
        }