/* * 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 * trunk/opends/resource/legal-notices/OpenDS.LICENSE * or https://OpenDS.dev.java.net/OpenDS.LICENSE. * 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 * trunk/opends/resource/legal-notices/OpenDS.LICENSE. 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 * * * Portions Copyright 2006 Sun Microsystems, Inc. */ package org.opends.server.schema; import java.util.Arrays; import org.opends.server.api.EqualityMatchingRule; import org.opends.server.config.ConfigEntry; import org.opends.server.config.ConfigException; import org.opends.server.core.DirectoryServer; import org.opends.server.protocols.asn1.ASN1OctetString; import org.opends.server.types.ByteString; import org.opends.server.types.DirectoryException; import org.opends.server.types.DN; import org.opends.server.types.ErrorLogCategory; import org.opends.server.types.ErrorLogSeverity; import org.opends.server.types.InitializationException; import org.opends.server.types.ResultCode; import static org.opends.server.loggers.Debug.*; import static org.opends.server.loggers.Error.*; import static org.opends.server.messages.MessageHandler.*; import static org.opends.server.messages.SchemaMessages.*; import static org.opends.server.schema.SchemaConstants.*; import static org.opends.server.util.StaticUtils.*; /** * This class implements the uniqueMemberMatch matching rule defined in X.520 * and referenced in RFC 2252. It is based on the name and optional UID syntax, * and will compare values with a distinguished name and optional bit string * suffix. */ public class UniqueMemberEqualityMatchingRule extends EqualityMatchingRule { /** * The fully-qualified name of this class for debugging purposes. */ private static final String CLASS_NAME = "org.opends.server.schema.UniqueMemberEqualityMatchingRule"; /** * Creates a new instance of this uniqueMemberMatch matching rule. */ public UniqueMemberEqualityMatchingRule() { super(); assert debugConstructor(CLASS_NAME); } /** * Initializes this matching rule based on the information in the provided * configuration entry. * * @param configEntry The configuration entry that contains the information * to use to initialize this matching rule. * * @throws ConfigException If an unrecoverable problem arises in the * process of performing the initialization. * * @throws InitializationException If a problem that is not * configuration-related occurs during * initialization. */ public void initializeMatchingRule(ConfigEntry configEntry) throws ConfigException, InitializationException { assert debugEnter(CLASS_NAME, "initializeMatchingRule", String.valueOf(configEntry)); // No initialization is required. } /** * Retrieves the common name for this matching rule. * * @return The common name for this matching rule, or null if * it does not have a name. */ public String getName() { assert debugEnter(CLASS_NAME, "getName"); return EMR_UNIQUE_MEMBER_NAME; } /** * Retrieves the OID for this matching rule. * * @return The OID for this matching rule. */ public String getOID() { assert debugEnter(CLASS_NAME, "getOID"); return EMR_UNIQUE_MEMBER_OID; } /** * Retrieves the description for this matching rule. * * @return The description for this matching rule, or null if * there is none. */ public String getDescription() { assert debugEnter(CLASS_NAME, "getDescription"); // There is no standard description for this matching rule. return null; } /** * Retrieves the OID of the syntax with which this matching rule is * associated. * * @return The OID of the syntax with which this matching rule is associated. */ public String getSyntaxOID() { assert debugEnter(CLASS_NAME, "getSyntaxOID"); return SYNTAX_NAME_AND_OPTIONAL_UID_OID; } /** * Retrieves the normalized form of the provided value, which is best suited * for efficiently performing matching operations on that value. * * @param value The value to be normalized. * * @return The normalized version of the provided value. * * @throws DirectoryException If the provided value is invalid according to * the associated attribute syntax. */ public ByteString normalizeValue(ByteString value) throws DirectoryException { assert debugEnter(CLASS_NAME, "normalizeValue", String.valueOf(value)); String valueString = value.stringValue().trim(); int valueLength = valueString.length(); // See if the value contains the "optional uid" portion. If we think it // does, then mark its location. int dnEndPos = valueLength; int sharpPos = -1; if (valueString.endsWith("'B") || valueString.endsWith("'b")) { sharpPos = valueString.lastIndexOf("#'"); if (sharpPos > 0) { dnEndPos = sharpPos; } } // Take the DN portion of the string and try to normalize it. If it fails, // then this will throw an exception. StringBuilder valueBuffer = new StringBuilder(valueLength); try { DN dn = DN.decode(valueString.substring(0, dnEndPos)); dn.toNormalizedString(valueBuffer); } catch (Exception e) { assert debugException(CLASS_NAME, "normalizeValue", e); // We couldn't normalize the DN for some reason. If we're supposed to use // strict syntax enforcement, then throw an exception. Otherwise, log a // message and just try our best. int msgID = MSGID_ATTR_SYNTAX_NAMEANDUID_INVALID_DN; String message = getMessage(msgID, valueString, stackTraceToSingleLineString(e)); switch (DirectoryServer.getSyntaxEnforcementPolicy()) { case REJECT: throw new DirectoryException(ResultCode.INVALID_ATTRIBUTE_SYNTAX, message, msgID); case WARN: logError(ErrorLogCategory.SCHEMA, ErrorLogSeverity.MILD_ERROR, message, msgID); valueBuffer.append(toLowerCase(valueString).substring(0, dnEndPos)); break; default: valueBuffer.append(toLowerCase(valueString).substring(0, dnEndPos)); break; } } // If there is an "optional uid", then normalize it and make sure it only // contains valid binary digits. if (sharpPos > 0) { valueBuffer.append("#'"); int endPos = valueLength - 2; boolean logged = false; for (int i=sharpPos+2; i < endPos; i++) { char c = valueString.charAt(i); if ((c == '0') || (c == '1')) { valueBuffer.append(c); } else { // There was an invalid binary digit. We'll either throw an exception // or log a message and continue, based on the server's configuration. int msgID = MSGID_ATTR_SYNTAX_NAMEANDUID_ILLEGAL_BINARY_DIGIT; String message = getMessage(msgID, valueString, c, i); switch (DirectoryServer.getSyntaxEnforcementPolicy()) { case REJECT: throw new DirectoryException(ResultCode.INVALID_ATTRIBUTE_SYNTAX, message, msgID); case WARN: if (! logged) { logError(ErrorLogCategory.SCHEMA, ErrorLogSeverity.MILD_ERROR, message, msgID); logged = true; } break; } } } valueBuffer.append("'B"); } return new ASN1OctetString(valueBuffer.toString()); } /** * Indicates whether the two provided normalized values are equal to each * other. * * @param value1 The normalized form of the first value to compare. * @param value2 The normalized form of the second value to compare. * * @return true if the provided values are equal, or * false if not. */ public boolean areEqual(ByteString value1, ByteString value2) { assert debugEnter(CLASS_NAME, "areEqual", String.valueOf(value1), String.valueOf(value2)); // Since the values are already normalized, we just need to compare the // associated byte arrays. return Arrays.equals(value1.value(), value2.value()); } }