/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (the "License"). You may not use this file except in compliance
* with the License.
*
* You can obtain a copy of the license at legal-notices/CDDLv1_0.txt
* or http://forgerock.org/license/CDDLv1.0.html.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at legal-notices/CDDLv1_0.txt.
* If applicable, add the following below this CDDL HEADER, with the
* fields enclosed by brackets "[]" replaced with your own identifying
* information:
* Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*
*
* Copyright 2009 Sun Microsystems, Inc.
* Portions Copyright 2014 ForgeRock AS
*/
package org.opends.server.tools.dsconfig;
import static org.opends.messages.DSConfigMessages.*;
import java.util.List;
import java.util.SortedMap;
import org.forgerock.i18n.LocalizableMessage;
import org.opends.server.admin.DefinitionDecodingException;
import org.opends.server.admin.InstantiableRelationDefinition;
import org.opends.server.admin.ManagedObjectDefinition;
import org.opends.server.admin.ManagedObjectNotFoundException;
import org.opends.server.admin.ManagedObjectPath;
import org.opends.server.admin.OptionalRelationDefinition;
import org.opends.server.admin.RelationDefinition;
import org.opends.server.admin.SetRelationDefinition;
import org.opends.server.admin.client.AuthorizationException;
import org.opends.server.admin.client.CommunicationException;
import org.opends.server.admin.client.ConcurrentModificationException;
import org.opends.server.admin.client.ManagedObject;
import org.opends.server.admin.client.ManagedObjectDecodingException;
import org.opends.server.admin.client.ManagementContext;
import org.opends.server.admin.client.OperationRejectedException;
import com.forgerock.opendj.cli.ArgumentException;
import com.forgerock.opendj.cli.BooleanArgument;
import com.forgerock.opendj.cli.ClientException;
import com.forgerock.opendj.cli.ConsoleApplication;
import com.forgerock.opendj.cli.MenuResult;
import com.forgerock.opendj.cli.ReturnCode;
import com.forgerock.opendj.cli.StringArgument;
import com.forgerock.opendj.cli.SubCommand;
import com.forgerock.opendj.cli.SubCommandArgumentParser;
import com.forgerock.opendj.cli.TableBuilder;
import com.forgerock.opendj.cli.TextTablePrinter;
/**
* A sub-command handler which is used to delete existing managed
* objects.
*
* This sub-command implements the various delete-xxx sub-commands.
*/
final class DeleteSubCommandHandler extends SubCommandHandler {
/**
* The value for the long option force.
*/
private static final String OPTION_DSCFG_LONG_FORCE = "force";
/**
* The value for the short option force.
*/
private static final char OPTION_DSCFG_SHORT_FORCE = 'f';
/**
* Creates a new delete-xxx sub-command for an instantiable
* relation.
*
* @param parser
* The sub-command argument parser.
* @param p
* The parent managed object path.
* @param r
* The instantiable relation.
* @return Returns the new delete-xxx sub-command.
* @throws ArgumentException
* If the sub-command could not be created successfully.
*/
public static DeleteSubCommandHandler create(
SubCommandArgumentParser parser, ManagedObjectPath, ?> p,
InstantiableRelationDefinition, ?> r) throws ArgumentException {
return new DeleteSubCommandHandler(parser, p, r, p.child(r, "DUMMY"));
}
/**
* Creates a new delete-xxx sub-command for an optional relation.
*
* @param parser
* The sub-command argument parser.
* @param p
* The parent managed object path.
* @param r
* The optional relation.
* @return Returns the new delete-xxx sub-command.
* @throws ArgumentException
* If the sub-command could not be created successfully.
*/
public static DeleteSubCommandHandler create(
SubCommandArgumentParser parser, ManagedObjectPath, ?> p,
OptionalRelationDefinition, ?> r) throws ArgumentException {
return new DeleteSubCommandHandler(parser, p, r, p.child(r));
}
/**
* Creates a new delete-xxx sub-command for a set relation.
*
* @param parser
* The sub-command argument parser.
* @param p
* The parent managed object path.
* @param r
* The set relation.
* @return Returns the new delete-xxx sub-command.
* @throws ArgumentException
* If the sub-command could not be created successfully.
*/
public static DeleteSubCommandHandler create(
SubCommandArgumentParser parser, ManagedObjectPath, ?> p,
SetRelationDefinition, ?> r) throws ArgumentException {
return new DeleteSubCommandHandler(parser, p, r, p.child(r));
}
/** The argument which should be used to force deletion. */
private final BooleanArgument forceArgument;
/** The sub-commands naming arguments. */
private final List namingArgs;
/** The path of the managed object. */
private final ManagedObjectPath, ?> path;
/**
* The relation which references the managed object to be deleted.
*/
private final RelationDefinition, ?> relation;
/** The sub-command associated with this handler. */
private final SubCommand subCommand;
/** Private constructor. */
private DeleteSubCommandHandler(
SubCommandArgumentParser parser, ManagedObjectPath, ?> p,
RelationDefinition, ?> r, ManagedObjectPath, ?> c)
throws ArgumentException {
this.path = p;
this.relation = r;
// Create the sub-command.
String name = "delete-" + r.getName();
LocalizableMessage ufpn = r.getChildDefinition().getUserFriendlyPluralName();
LocalizableMessage description = INFO_DSCFG_DESCRIPTION_SUBCMD_DELETE.get(ufpn);
this.subCommand = new SubCommand(parser, name, false, 0, 0, null,
description);
// Create the naming arguments.
this.namingArgs = createNamingArgs(subCommand, c, false);
// Create the --force argument which is used to force deletion.
this.forceArgument = new BooleanArgument(OPTION_DSCFG_LONG_FORCE,
OPTION_DSCFG_SHORT_FORCE, OPTION_DSCFG_LONG_FORCE,
INFO_DSCFG_DESCRIPTION_FORCE.get(ufpn));
subCommand.addArgument(forceArgument);
// Register the tags associated with the child managed objects.
addTags(relation.getChildDefinition().getAllTags());
}
/**
* Gets the relation definition associated with the type of
* component that this sub-command handles.
*
* @return Returns the relation definition associated with the type
* of component that this sub-command handles.
*/
public RelationDefinition, ?> getRelationDefinition() {
return relation;
}
/** {@inheritDoc} */
@Override
public SubCommand getSubCommand() {
return subCommand;
}
/** {@inheritDoc} */
@Override
public MenuResult run(ConsoleApplication app,
ManagementContextFactory factory) throws ArgumentException,
ClientException {
// Get the naming argument values.
List names = getNamingArgValues(app, namingArgs);
// Reset the command builder
getCommandBuilder().clearArguments();
setCommandBuilderUseful(false);
// Delete the child managed object.
ManagementContext context = factory.getManagementContext(app);
MenuResult> result;
LocalizableMessage ufn = relation.getUserFriendlyName();
try {
result = getManagedObject(app, context, path, names);
} catch (AuthorizationException e) {
LocalizableMessage msg = ERR_DSCFG_ERROR_DELETE_AUTHZ.get(ufn);
throw new ClientException(ReturnCode.INSUFFICIENT_ACCESS_RIGHTS, msg);
} catch (DefinitionDecodingException e) {
LocalizableMessage pufn = path.getManagedObjectDefinition().getUserFriendlyName();
LocalizableMessage msg = ERR_DSCFG_ERROR_GET_PARENT_DDE.get(pufn, pufn, pufn);
throw new ClientException(ReturnCode.OTHER, msg);
} catch (ManagedObjectDecodingException e) {
LocalizableMessage pufn = path.getManagedObjectDefinition().getUserFriendlyName();
LocalizableMessage msg = ERR_DSCFG_ERROR_GET_PARENT_MODE.get(pufn);
throw new ClientException(ReturnCode.OTHER, msg, e);
} catch (CommunicationException e) {
LocalizableMessage msg = ERR_DSCFG_ERROR_DELETE_CE.get(ufn, e.getMessage());
throw new ClientException(ReturnCode.CLIENT_SIDE_SERVER_DOWN, msg);
} catch (ConcurrentModificationException e) {
LocalizableMessage msg = ERR_DSCFG_ERROR_DELETE_CME.get(ufn);
throw new ClientException(ReturnCode.CONSTRAINT_VIOLATION, msg);
} catch (ManagedObjectNotFoundException e) {
// Ignore the error if the deletion is being forced.
if (!forceArgument.isPresent()) {
LocalizableMessage pufn = path.getManagedObjectDefinition().getUserFriendlyName();
LocalizableMessage msg = ERR_DSCFG_ERROR_GET_PARENT_MONFE.get(pufn);
if (app.isInteractive()) {
app.println();
app.printVerboseMessage(msg);
return MenuResult.cancel();
} else {
throw new ClientException(ReturnCode.NO_SUCH_OBJECT, msg);
}
} else {
return MenuResult.success(0);
}
}
if (result.isQuit()) {
if (!app.isMenuDrivenMode()) {
// User chose to cancel deletion.
LocalizableMessage msg = INFO_DSCFG_CONFIRM_DELETE_FAIL.get(ufn);
app.printVerboseMessage(msg);
}
return MenuResult.quit();
} else if (result.isCancel()) {
// Must be menu driven, so no need for error message.
return MenuResult.cancel();
}
ManagedObject> parent = result.getValue();
try {
if (relation instanceof InstantiableRelationDefinition
|| relation instanceof SetRelationDefinition) {
String childName = names.get(names.size() - 1);
if (childName == null) {
MenuResult sresult =
readChildName(app, parent, relation, null);
if (sresult.isQuit()) {
if (!app.isMenuDrivenMode()) {
// User chose to cancel deletion.
LocalizableMessage msg = INFO_DSCFG_CONFIRM_DELETE_FAIL.get(ufn);
app.printVerboseMessage(msg);
}
return MenuResult.quit();
} else if (sresult.isCancel()) {
// Must be menu driven, so no need for error message.
return MenuResult.cancel();
} else {
childName = sresult.getValue();
}
} else if (relation instanceof SetRelationDefinition) {
// The provided type short name needs mapping to the full name.
String name = childName.trim();
SortedMap types = getSubTypes(relation.getChildDefinition());
ManagedObjectDefinition cd =
(ManagedObjectDefinition) types.get(name);
if (cd == null) {
// The name must be invalid.
String typeUsage = getSubTypesUsage(relation.getChildDefinition());
LocalizableMessage msg = ERR_DSCFG_ERROR_SUB_TYPE_UNRECOGNIZED.get(
name, relation.getUserFriendlyName(), typeUsage);
throw new ArgumentException(msg);
} else {
childName = cd.getName();
}
}
if (confirmDeletion(app)) {
setCommandBuilderUseful(true);
if (relation instanceof InstantiableRelationDefinition) {
parent.removeChild((InstantiableRelationDefinition,?>) relation,
childName);
} else {
parent.removeChild((SetRelationDefinition,?>) relation,
childName);
}
} else {
return MenuResult.cancel();
}
} else if (relation instanceof OptionalRelationDefinition) {
OptionalRelationDefinition, ?> orelation =
(OptionalRelationDefinition, ?>) relation;
if (confirmDeletion(app)) {
setCommandBuilderUseful(true);
parent.removeChild(orelation);
} else {
return MenuResult.cancel();
}
}
} catch (AuthorizationException e) {
LocalizableMessage msg = ERR_DSCFG_ERROR_DELETE_AUTHZ.get(ufn);
throw new ClientException(ReturnCode.INSUFFICIENT_ACCESS_RIGHTS, msg);
} catch (OperationRejectedException e) {
LocalizableMessage msg;
if (e.getMessages().size() == 1) {
msg = ERR_DSCFG_ERROR_DELETE_ORE_SINGLE.get(ufn);
} else {
msg = ERR_DSCFG_ERROR_DELETE_ORE_PLURAL.get(ufn);
}
if (app.isInteractive()) {
// If interactive, let the user go back to the main menu.
app.println();
app.println(msg);
app.println();
TableBuilder builder = new TableBuilder();
for (LocalizableMessage reason : e.getMessages()) {
builder.startRow();
builder.appendCell("*");
builder.appendCell(reason);
}
TextTablePrinter printer = new TextTablePrinter(app.getErrorStream());
printer.setDisplayHeadings(false);
printer.setColumnWidth(1, 0);
printer.setIndentWidth(4);
builder.print(printer);
return MenuResult.cancel();
} else {
throw new ClientException(ReturnCode.CONSTRAINT_VIOLATION,
msg, e);
}
} catch (ManagedObjectNotFoundException e) {
// Ignore the error if the deletion is being forced.
if (!forceArgument.isPresent()) {
LocalizableMessage msg = ERR_DSCFG_ERROR_DELETE_MONFE.get(ufn);
throw new ClientException(ReturnCode.NO_SUCH_OBJECT, msg);
}
} catch (ConcurrentModificationException e) {
LocalizableMessage msg = ERR_DSCFG_ERROR_DELETE_CME.get(ufn);
throw new ClientException(ReturnCode.CONSTRAINT_VIOLATION, msg);
} catch (CommunicationException e) {
LocalizableMessage msg = ERR_DSCFG_ERROR_DELETE_CE.get(ufn, e.getMessage());
throw new ClientException(ReturnCode.CLIENT_SIDE_SERVER_DOWN, msg);
}
// Add the naming arguments if they were provided.
for (StringArgument arg : namingArgs)
{
if (arg.isPresent())
{
getCommandBuilder().addArgument(arg);
}
}
// Output success message.
LocalizableMessage msg = INFO_DSCFG_CONFIRM_DELETE_SUCCESS.get(ufn);
app.printVerboseMessage(msg);
return MenuResult.success(0);
}
/** Confirm deletion. */
private boolean confirmDeletion(ConsoleApplication app) throws ClientException {
if (app.isInteractive()) {
LocalizableMessage prompt = INFO_DSCFG_CONFIRM_DELETE.get(relation
.getUserFriendlyName());
app.println();
if (!app.confirmAction(prompt, false)) {
// Output failure message.
LocalizableMessage msg = INFO_DSCFG_CONFIRM_DELETE_FAIL.get(relation
.getUserFriendlyName());
app.printVerboseMessage(msg);
return false;
}
}
return true;
}
}