/*
|
* The contents of this file are subject to the terms of the Common Development and
|
* Distribution License (the License). You may not use this file except in compliance with the
|
* License.
|
*
|
* You can obtain a copy of the License at legal/CDDLv1.0.txt. See the License for the
|
* specific language governing permission and limitations under the License.
|
*
|
* When distributing Covered Software, include this CDDL Header Notice in each file and include
|
* the License file at legal/CDDLv1.0.txt. If applicable, add the following below the CDDL
|
* Header, with the fields enclosed by brackets [] replaced by your own identifying
|
* information: "Portions Copyright [year] [name of copyright owner]".
|
*
|
* Copyright 2008 Sun Microsystems, Inc.
|
* Portions copyright 2014-2015 ForgeRock AS.
|
*/
|
|
package org.forgerock.opendj.config.client.ldap;
|
|
import static org.forgerock.opendj.ldap.Connections.*;
|
|
import java.io.BufferedReader;
|
import java.io.BufferedWriter;
|
import java.io.File;
|
import java.io.FileReader;
|
import java.io.FileWriter;
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.SortedSet;
|
|
import org.forgerock.i18n.LocalizableMessage;
|
import org.forgerock.i18n.slf4j.LocalizedLogger;
|
import org.forgerock.opendj.config.AbstractManagedObjectDefinition;
|
import org.forgerock.opendj.config.Configuration;
|
import org.forgerock.opendj.config.ConfigurationClient;
|
import org.forgerock.opendj.config.DefinitionDecodingException;
|
import org.forgerock.opendj.config.InstantiableRelationDefinition;
|
import org.forgerock.opendj.config.LDAPProfile;
|
import org.forgerock.opendj.config.ManagedObjectNotFoundException;
|
import org.forgerock.opendj.config.ManagedObjectPath;
|
import org.forgerock.opendj.config.OptionalRelationDefinition;
|
import org.forgerock.opendj.config.PropertyDefinition;
|
import org.forgerock.opendj.config.SetRelationDefinition;
|
import org.forgerock.opendj.config.client.DriverBasedManagementContext;
|
import org.forgerock.opendj.config.client.ManagedObject;
|
import org.forgerock.opendj.config.client.ManagedObjectDecodingException;
|
import org.forgerock.opendj.config.client.ManagementContext;
|
import org.forgerock.opendj.config.client.OperationRejectedException;
|
import org.forgerock.opendj.config.client.spi.Driver;
|
import org.forgerock.opendj.ldap.AbstractConnectionWrapper;
|
import org.forgerock.opendj.ldap.Connection;
|
import org.forgerock.opendj.ldap.Entry;
|
import org.forgerock.opendj.ldap.LdapException;
|
import org.forgerock.opendj.ldap.MemoryBackend;
|
import org.forgerock.opendj.ldap.requests.UnbindRequest;
|
import org.forgerock.opendj.ldif.LDIF;
|
import org.forgerock.opendj.ldif.LDIFEntryReader;
|
import org.forgerock.opendj.ldif.LDIFEntryWriter;
|
import org.forgerock.opendj.server.config.client.RootCfgClient;
|
import org.forgerock.util.Reject;
|
|
/**
|
* An LDAP management connection context.
|
*/
|
public final class LDAPManagementContext extends DriverBasedManagementContext {
|
|
private static final class ManagementContextWrapper implements ManagementContext {
|
private final ManagementContext delegate;
|
private final List<IOException> exceptions;
|
|
private ManagementContextWrapper(ManagementContext result, List<IOException> exceptions) {
|
this.delegate = result;
|
this.exceptions = exceptions;
|
}
|
|
@Override
|
public boolean managedObjectExists(ManagedObjectPath<?, ?> path) throws ManagedObjectNotFoundException,
|
LdapException {
|
return delegate.managedObjectExists(path);
|
}
|
|
@Override
|
public <C extends ConfigurationClient, S extends Configuration> String[] listManagedObjects(
|
ManagedObjectPath<?, ?> parent, SetRelationDefinition<C, S> rd) throws ManagedObjectNotFoundException,
|
LdapException {
|
return delegate.listManagedObjects(parent, rd);
|
}
|
|
@Override
|
public <C extends ConfigurationClient, S extends Configuration> String[] listManagedObjects(
|
ManagedObjectPath<?, ?> parent, InstantiableRelationDefinition<C, S> rd,
|
AbstractManagedObjectDefinition<? extends C, ? extends S> d) throws ManagedObjectNotFoundException,
|
LdapException {
|
return delegate.listManagedObjects(parent, rd, d);
|
}
|
|
@Override
|
public <C extends ConfigurationClient, S extends Configuration> String[] listManagedObjects(
|
ManagedObjectPath<?, ?> parent, InstantiableRelationDefinition<C, S> rd)
|
throws ManagedObjectNotFoundException, LdapException {
|
return delegate.listManagedObjects(parent, rd);
|
}
|
|
@Override
|
public ManagedObject<RootCfgClient> getRootConfigurationManagedObject() {
|
return delegate.getRootConfigurationManagedObject();
|
}
|
|
@Override
|
public RootCfgClient getRootConfiguration() {
|
return delegate.getRootConfiguration();
|
}
|
|
@Override
|
public <P> SortedSet<P> getPropertyValues(ManagedObjectPath<?, ?> path, PropertyDefinition<P> pd)
|
throws DefinitionDecodingException, LdapException, ManagedObjectNotFoundException {
|
return delegate.getPropertyValues(path, pd);
|
}
|
|
@Override
|
public <P> P getPropertyValue(ManagedObjectPath<?, ?> path, PropertyDefinition<P> pd)
|
throws DefinitionDecodingException, LdapException, ManagedObjectNotFoundException {
|
return delegate.getPropertyValue(path, pd);
|
}
|
|
@Override
|
public <C extends ConfigurationClient, S extends Configuration> ManagedObject<? extends C> getManagedObject(
|
ManagedObjectPath<C, S> path) throws DefinitionDecodingException, ManagedObjectDecodingException,
|
ManagedObjectNotFoundException, LdapException {
|
return delegate.getManagedObject(path);
|
}
|
|
@Override
|
public <C extends ConfigurationClient, S extends Configuration> boolean deleteManagedObject(
|
ManagedObjectPath<?, ?> parent, SetRelationDefinition<C, S> rd, String name)
|
throws ManagedObjectNotFoundException, OperationRejectedException, LdapException {
|
return delegate.deleteManagedObject(parent, rd, name);
|
}
|
|
@Override
|
public <C extends ConfigurationClient, S extends Configuration> boolean deleteManagedObject(
|
ManagedObjectPath<?, ?> parent, OptionalRelationDefinition<C, S> rd)
|
throws ManagedObjectNotFoundException, OperationRejectedException, LdapException {
|
return delegate.deleteManagedObject(parent, rd);
|
}
|
|
@Override
|
public <C extends ConfigurationClient, S extends Configuration> boolean deleteManagedObject(
|
ManagedObjectPath<?, ?> parent, InstantiableRelationDefinition<C, S> rd, String name)
|
throws ManagedObjectNotFoundException, OperationRejectedException, LdapException {
|
return delegate.deleteManagedObject(parent, rd, name);
|
}
|
|
@Override
|
public void close() throws IOException {
|
delegate.close();
|
if (!exceptions.isEmpty()) {
|
throw exceptions.get(0);
|
}
|
}
|
}
|
|
private static final LocalizedLogger logger = LocalizedLogger.getLoggerForThisClass();
|
|
/**
|
* Create a new LDAP management context using the provided LDAP connection.
|
*
|
* @param connection
|
* The LDAP connection.
|
* @param profile
|
* The LDAP profile.
|
* @return Returns the new management context.
|
*/
|
public static ManagementContext newManagementContext(Connection connection, LDAPProfile profile) {
|
Reject.ifNull(connection, profile);
|
LDAPDriver driver = new LDAPDriver(connection, profile);
|
LDAPManagementContext context = new LDAPManagementContext(driver);
|
driver.setManagementContext(context);
|
return context;
|
}
|
|
private static ManagementContext newLDIFManagementContext(final File ldifFile, final LDAPProfile profile,
|
final List<IOException> exceptions) throws IOException {
|
final BufferedReader configReader = new BufferedReader(new FileReader(ldifFile));
|
try {
|
final MemoryBackend memoryBackend = new MemoryBackend(new LDIFEntryReader(configReader));
|
final Connection co = new AbstractConnectionWrapper<Connection>(newInternalConnection(memoryBackend)) {
|
@Override
|
public void close() {
|
try {
|
final BufferedWriter configWriter = new BufferedWriter(new FileWriter(ldifFile));
|
try {
|
final Iterator<Entry> entries = memoryBackend.getAll().iterator();
|
entries.next(); // skip RootDSE
|
LDIF.copyTo(LDIF.newEntryIteratorReader(entries), new LDIFEntryWriter(configWriter));
|
} finally {
|
configWriter.close();
|
}
|
} catch (IOException e) {
|
if (exceptions != null) {
|
exceptions.add(e);
|
} else {
|
logger.error(LocalizableMessage.raw(
|
"IOException occured during LDIF context management close:", e));
|
}
|
}
|
}
|
|
@Override
|
public void close(UnbindRequest request, String reason) {
|
close();
|
}
|
};
|
|
// We need to add the root dse entry to make the configuration framework work.
|
co.add(LDIFEntryReader.valueOfLDIFEntry("dn:", "objectClass:top", "objectClass:ds-root-dse"));
|
return LDAPManagementContext.newManagementContext(co, LDAPProfile.getInstance());
|
} finally {
|
configReader.close();
|
}
|
}
|
|
/**
|
* Returns a LDIF management context on the provided LDIF file.
|
*
|
* @param ldifFile
|
* The LDIF file to manage
|
* @param profile
|
* The LDAP profile
|
* @return A LDIF file management context
|
* @throws IOException
|
* If problems occurs while reading the file.
|
*/
|
public static ManagementContext newLDIFManagementContext(final File ldifFile, final LDAPProfile profile)
|
throws IOException {
|
final List<IOException> exceptions = new ArrayList<>();
|
return new ManagementContextWrapper(newLDIFManagementContext(ldifFile, profile, exceptions), exceptions);
|
}
|
|
/** The LDAP management context driver. */
|
private final LDAPDriver driver;
|
|
/** Private constructor. */
|
private LDAPManagementContext(LDAPDriver driver) {
|
this.driver = driver;
|
}
|
|
/** {@inheritDoc} */
|
@Override
|
protected Driver getDriver() {
|
return driver;
|
}
|
}
|
