| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| */ |
| |
| package org.apache.directory.studio.ldapbrowser.core.jobs; |
| |
| |
| import java.util.ArrayList; |
| import java.util.Arrays; |
| import java.util.HashSet; |
| import java.util.List; |
| import java.util.Set; |
| |
| import javax.naming.directory.SearchControls; |
| |
| import org.apache.directory.api.ldap.model.exception.LdapInvalidDnException; |
| import org.apache.directory.api.ldap.model.message.Control; |
| import org.apache.directory.api.ldap.model.name.Dn; |
| import org.apache.directory.studio.common.core.jobs.StudioProgressMonitor; |
| import org.apache.directory.studio.connection.core.Connection; |
| import org.apache.directory.studio.connection.core.Controls; |
| import org.apache.directory.studio.connection.core.io.StudioLdapException; |
| import org.apache.directory.studio.connection.core.jobs.StudioConnectionBulkRunnableWithProgress; |
| import org.apache.directory.studio.ldapbrowser.core.BrowserCoreMessages; |
| import org.apache.directory.studio.ldapbrowser.core.events.BulkModificationEvent; |
| import org.apache.directory.studio.ldapbrowser.core.events.EntryMovedEvent; |
| import org.apache.directory.studio.ldapbrowser.core.events.EventRegistry; |
| import org.apache.directory.studio.ldapbrowser.core.model.IBrowserConnection; |
| import org.apache.directory.studio.ldapbrowser.core.model.IEntry; |
| import org.apache.directory.studio.ldapbrowser.core.model.ISearch; |
| import org.apache.directory.studio.ldapbrowser.core.model.ISearchResult; |
| |
| |
| /** |
| * Runnable to move entries. |
| * |
| * First it tries to move an entry using an moddn operation. If |
| * that operation fails with an LDAP error 66 (ContextNotEmptyException) |
| * the use is asked if s/he wants to simulate such a move by recursively |
| * searching/creating/deleting entries. |
| * |
| * @author <a href="mailto:dev@directory.apache.org">Apache Directory Project</a> |
| */ |
| public class MoveEntriesRunnable implements StudioConnectionBulkRunnableWithProgress |
| { |
| /** The browser connection. */ |
| private IBrowserConnection browserConnection; |
| |
| /** The entries to move. */ |
| private IEntry[] oldEntries; |
| |
| /** The new parent. */ |
| private IEntry newParent; |
| |
| /** The moved entries. */ |
| private IEntry[] newEntries; |
| |
| /** The searches to update. */ |
| private Set<ISearch> searchesToUpdateSet = new HashSet<ISearch>(); |
| |
| /** The dialog to ask for simulated renaming */ |
| private SimulateRenameDialog dialog; |
| |
| |
| /** |
| * Creates a new instance of MoveEntriesRunnable. |
| * |
| * @param entries the entries to move |
| * @param newParent the new parent |
| * @param dialog the dialog |
| */ |
| public MoveEntriesRunnable( IEntry[] entries, IEntry newParent, SimulateRenameDialog dialog ) |
| { |
| this.browserConnection = newParent.getBrowserConnection(); |
| this.oldEntries = entries; |
| this.newParent = newParent; |
| this.dialog = dialog; |
| this.newEntries = new IEntry[oldEntries.length]; |
| } |
| |
| |
| /** |
| * {@inheritDoc} |
| */ |
| public Connection[] getConnections() |
| { |
| return new Connection[] |
| { browserConnection.getConnection() }; |
| } |
| |
| |
| /** |
| * {@inheritDoc} |
| */ |
| public String getName() |
| { |
| return oldEntries.length == 1 ? BrowserCoreMessages.jobs__move_entry_name_1 |
| : BrowserCoreMessages.jobs__move_entry_name_n; |
| } |
| |
| |
| /** |
| * {@inheritDoc} |
| */ |
| public Object[] getLockedObjects() |
| { |
| List<IEntry> l = new ArrayList<IEntry>(); |
| l.add( newParent ); |
| l.addAll( Arrays.asList( oldEntries ) ); |
| return l.toArray(); |
| } |
| |
| |
| /** |
| * {@inheritDoc} |
| */ |
| public String getErrorMessage() |
| { |
| return oldEntries.length == 1 ? BrowserCoreMessages.jobs__move_entry_error_1 |
| : BrowserCoreMessages.jobs__move_entry_error_n; |
| } |
| |
| |
| /** |
| * {@inheritDoc} |
| */ |
| public void run( StudioProgressMonitor monitor ) |
| { |
| monitor.beginTask( BrowserCoreMessages.bind( |
| oldEntries.length == 1 ? BrowserCoreMessages.jobs__move_entry_task_1 |
| : BrowserCoreMessages.jobs__move_entry_task_n, new String[] |
| {} ), 3 ); |
| monitor.reportProgress( " " ); //$NON-NLS-1$ |
| monitor.worked( 1 ); |
| |
| // use a dummy monitor to be able to handle exceptions |
| StudioProgressMonitor dummyMonitor = new StudioProgressMonitor( monitor ); |
| |
| int numAdd = 0; |
| int numDel = 0; |
| boolean isSimulatedRename = false; |
| Dn parentDn = newParent.getDn(); |
| |
| for ( int i = 0; i < oldEntries.length; i++ ) |
| { |
| dummyMonitor.reset(); |
| |
| IEntry oldEntry = oldEntries[i]; |
| Dn oldDn = oldEntry.getDn(); |
| |
| Dn newDn = null; |
| |
| try |
| { |
| newDn = parentDn.add( oldDn.getRdn() ); |
| } |
| catch ( LdapInvalidDnException lide ) |
| { |
| newDn = Dn.EMPTY_DN; |
| } |
| |
| // try to move entry |
| RenameEntryRunnable.renameEntry( browserConnection, oldEntry, newDn, dummyMonitor ); |
| |
| // do a simulated rename, if renaming of a non-leaf entry is not supported. |
| if ( dummyMonitor.errorsReported() ) |
| { |
| if ( dialog != null && StudioLdapException.isContextNotEmptyException( dummyMonitor.getException() ) ) |
| { |
| // open dialog |
| if ( numAdd == 0 ) |
| { |
| dialog.setEntryInfo( browserConnection, oldDn, newDn ); |
| dialog.open(); |
| isSimulatedRename = dialog.isSimulateRename(); |
| } |
| |
| if ( isSimulatedRename ) |
| { |
| // do simulated rename operation |
| dummyMonitor.reset(); |
| |
| numAdd = CopyEntriesRunnable.copyEntry( oldEntry, newParent, null, |
| SearchControls.SUBTREE_SCOPE, |
| numAdd, null, dummyMonitor, monitor ); |
| |
| if ( !dummyMonitor.errorsReported() ) |
| { |
| dummyMonitor.reset(); |
| numDel = DeleteEntriesRunnable.optimisticDeleteEntryRecursive( browserConnection, oldDn, |
| oldEntry.isReferral(), false, numDel, dummyMonitor, monitor ); |
| } |
| } |
| else |
| { |
| // no simulated rename operation |
| // report the exception to the real monitor |
| Exception exception = dummyMonitor.getException(); |
| monitor.reportError( exception ); |
| } |
| } |
| else |
| { |
| // we have another exception |
| // report it to the real monitor |
| Exception exception = dummyMonitor.getException(); |
| monitor.reportError( exception ); |
| } |
| } |
| |
| // update model |
| if ( !dummyMonitor.errorsReported() ) |
| { |
| // uncache old entry |
| browserConnection.uncacheEntryRecursive( oldEntry ); |
| |
| // remove old entry from old parent |
| oldEntry.getParententry().deleteChild( oldEntry ); |
| |
| // add new entry to new parent |
| boolean hasMoreChildren = newParent.hasMoreChildren() || !newParent.isChildrenInitialized(); |
| List<Control> controls = new ArrayList<>(); |
| if ( oldEntry.isReferral() ) |
| { |
| controls.add( Controls.MANAGEDSAIT_CONTROL ); |
| } |
| IEntry newEntry = ReadEntryRunnable.getEntry( browserConnection, newDn, controls, monitor ); |
| newEntries[i] = newEntry; |
| newParent.addChild( newEntry ); |
| newParent.setHasMoreChildren( hasMoreChildren ); |
| |
| // reset searches, if the moved entry is a result of a search |
| List<ISearch> searches = browserConnection.getSearchManager().getSearches(); |
| for ( ISearch search : searches ) |
| { |
| if ( search.getSearchResults() != null ) |
| { |
| ISearchResult[] searchResults = search.getSearchResults(); |
| for ( ISearchResult result : searchResults ) |
| { |
| if ( oldEntry.equals( result.getEntry() ) ) |
| { |
| search.setSearchResults( null ); |
| searchesToUpdateSet.add( search ); |
| break; |
| } |
| } |
| } |
| } |
| } |
| } |
| } |
| |
| |
| /** |
| * {@inheritDoc} |
| */ |
| public void runNotification( StudioProgressMonitor monitor ) |
| { |
| // notify the entries and their parents |
| if ( newEntries.length < 2 ) |
| { |
| // notify fore each moved entry |
| for ( int i = 0; i < newEntries.length; i++ ) |
| { |
| if ( oldEntries[i] != null && newEntries[i] != null ) |
| { |
| EventRegistry.fireEntryUpdated( new EntryMovedEvent( oldEntries[i], newEntries[i] ), this ); |
| } |
| } |
| } |
| else |
| { |
| // reset the old and new parents and send only a bulk update event |
| // notifying for each moved entry would cause lot of UI updates... |
| for ( IEntry oldEntry : oldEntries ) |
| { |
| oldEntry.getParententry().setChildrenInitialized( false ); |
| } |
| newParent.setChildrenInitialized( false ); |
| EventRegistry.fireEntryUpdated( new BulkModificationEvent( browserConnection ), this ); |
| } |
| } |
| } |
