/* * 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 2012-2015 ForgeRock AS. */ package org.forgerock.opendj.rest2ldap; import static javax.xml.bind.DatatypeConverter.parseDateTime; import static javax.xml.bind.DatatypeConverter.printDateTime; import static org.forgerock.opendj.ldap.Filter.alwaysFalse; import static org.forgerock.opendj.ldap.Functions.byteStringToBoolean; import static org.forgerock.opendj.ldap.Functions.byteStringToGeneralizedTime; import static org.forgerock.opendj.ldap.Functions.byteStringToLong; import static org.forgerock.opendj.ldap.Functions.byteStringToString; import static org.forgerock.opendj.ldap.schema.CoreSchema.getBooleanSyntax; import static org.forgerock.opendj.ldap.schema.CoreSchema.getGeneralizedTimeSyntax; import static org.forgerock.opendj.ldap.schema.CoreSchema.getIntegerSyntax; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.Locale; import org.forgerock.json.JsonValue; import org.forgerock.opendj.ldap.Attribute; import org.forgerock.opendj.ldap.AttributeDescription; import org.forgerock.opendj.ldap.ByteString; import org.forgerock.opendj.ldap.Filter; import org.forgerock.opendj.ldap.GeneralizedTime; import org.forgerock.opendj.ldap.LinkedAttribute; import org.forgerock.opendj.ldap.schema.Syntax; import org.forgerock.util.Function; import org.forgerock.util.promise.NeverThrowsException; /** * Internal utility methods. */ final class Utils { private static final Function BASE64_TO_BYTESTRING = new Function() { @Override public ByteString apply(final Object value) { return ByteString.valueOfBase64(String.valueOf(value)); } }; private static final Function BYTESTRING_TO_BASE64 = new Function() { @Override public String apply(final ByteString value) { return value.toBase64String(); } }; static Object attributeToJson(final Attribute a) { final Function f = byteStringToJson(a.getAttributeDescription()); final boolean isSingleValued = a.getAttributeDescription().getAttributeType().isSingleValue(); return isSingleValued ? a.parse().as(f) : asList(a.parse().asSetOf(f)); } static Function base64ToByteString() { return BASE64_TO_BYTESTRING; } static Function byteStringToBase64() { return BYTESTRING_TO_BASE64; } static Function byteStringToJson(final AttributeDescription ad) { return new Function() { @Override public Object apply(final ByteString value) { final Syntax syntax = ad.getAttributeType().getSyntax(); if (syntax.equals(getBooleanSyntax())) { return byteStringToBoolean().apply(value); } else if (syntax.equals(getIntegerSyntax())) { return byteStringToLong().apply(value); } else if (syntax.equals(getGeneralizedTimeSyntax())) { return printDateTime(byteStringToGeneralizedTime().apply(value) .toCalendar()); } else { return byteStringToString().apply(value); } } }; } static T ensureNotNull(final T object) { if (object == null) { throw new NullPointerException(); } return object; } static T ensureNotNull(final T object, final String message) { if (object == null) { throw new NullPointerException(message); } return object; } static String getAttributeName(final Attribute a) { return a.getAttributeDescription().withoutOption("binary").toString(); } /** * Stub formatter for i18n strings. * * @param format * The format string. * @param args * The string arguments. * @return The formatted string. */ static String i18n(final String format, final Object... args) { return String.format(format, args); } static boolean isJSONPrimitive(final Object value) { return value instanceof String || value instanceof Boolean || value instanceof Number; } static boolean isNullOrEmpty(final JsonValue v) { return v == null || v.isNull() || (v.isList() && v.size() == 0); } static Attribute jsonToAttribute(final Object value, final AttributeDescription ad) { return jsonToAttribute(value, ad, jsonToByteString(ad)); } static Attribute jsonToAttribute(final Object value, final AttributeDescription ad, final Function f) { if (isJSONPrimitive(value)) { return new LinkedAttribute(ad, f.apply(value)); } else if (value instanceof Collection) { final Attribute a = new LinkedAttribute(ad); for (final Object o : (Collection) value) { a.add(f.apply(o)); } return a; } else { throw new IllegalArgumentException("Unrecognized type of JSON value: " + value.getClass().getName()); } } static Function jsonToByteString(final AttributeDescription ad) { return new Function() { @Override public ByteString apply(final Object value) { if (isJSONPrimitive(value)) { final Syntax syntax = ad.getAttributeType().getSyntax(); if (syntax.equals(getGeneralizedTimeSyntax())) { return ByteString.valueOf(GeneralizedTime.valueOf(parseDateTime(value.toString()))); } else { return ByteString.valueOf(value); } } else { throw new IllegalArgumentException("Unrecognized type of JSON value: " + value.getClass().getName()); } } }; } static Filter toFilter(final boolean value) { return value ? Filter.alwaysTrue() : Filter.alwaysFalse(); } static Filter toFilter(final FilterType type, final String ldapAttribute, final ByteString valueAssertion) { switch (type) { case CONTAINS: return Filter.substrings(ldapAttribute, null, Collections.singleton(valueAssertion), null); case STARTS_WITH: return Filter.substrings(ldapAttribute, valueAssertion, null, null); case EQUAL_TO: return Filter.equality(ldapAttribute, valueAssertion); case GREATER_THAN: return Filter.greaterThan(ldapAttribute, valueAssertion); case GREATER_THAN_OR_EQUAL_TO: return Filter.greaterOrEqual(ldapAttribute, valueAssertion); case LESS_THAN: return Filter.lessThan(ldapAttribute, valueAssertion); case LESS_THAN_OR_EQUAL_TO: return Filter.lessOrEqual(ldapAttribute, valueAssertion); case PRESENT: return Filter.present(ldapAttribute); case EXTENDED: default: return alwaysFalse(); // Not supported. } } static String toLowerCase(final String s) { return s != null ? s.toLowerCase(Locale.ENGLISH) : null; } private static List asList(final Collection c) { if (c instanceof List) { return (List) c; } return new ArrayList<>(c); } /** Prevent instantiation. */ private Utils() { // No implementation required. } }