CR-682 - LDIFReaderTestCase & LDIFChangeRecordReaderTestCase

Violette Roche-Montane

01.58.2012 c30dbe3bfa321c86a44fa734f3588ca074784f6e

CR-682 - LDIFReaderTestCase & LDIFChangeRecordReaderTestCase

 opendj-sdk/opendj3/opendj-ldap-sdk/src/test/java/org/forgerock/opendj/ldif/LDIFChangeRecordReaderTestCase.java

@@ -22,6 +22,7 @@
 *
 *
 *      Copyright 2011 ForgeRock AS
 *      Portions copyright 2012 ForgeRock AS.
 */

package org.forgerock.opendj.ldif;
@@ -30,14 +31,24 @@
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.anyListOf;
import static org.mockito.Matchers.eq;
import static org.mockito.Mockito.doThrow;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.NoSuchElementException;

import org.forgerock.i18n.LocalizableMessage;
import org.forgerock.i18n.LocalizedIllegalArgumentException;
import org.forgerock.opendj.ldap.AttributeDescription;
import org.forgerock.opendj.ldap.DN;
import org.forgerock.opendj.ldap.DecodeException;
import org.forgerock.opendj.ldap.LinkedAttribute;
import org.forgerock.opendj.ldap.Modification;
import org.forgerock.opendj.ldap.ModificationType;
@@ -46,6 +57,8 @@
import org.forgerock.opendj.ldap.requests.DeleteRequest;
import org.forgerock.opendj.ldap.requests.ModifyDNRequest;
import org.forgerock.opendj.ldap.requests.ModifyRequest;
import org.forgerock.opendj.ldap.schema.Schema;
import org.forgerock.opendj.ldap.schema.SchemaBuilder;
import org.forgerock.opendj.ldap.schema.SchemaValidationPolicy;
import org.forgerock.opendj.ldap.schema.SchemaValidationPolicy.Policy;
import org.testng.annotations.Test;
@@ -54,13 +67,544 @@
 * This class tests the LDIFChangeRecordReader functionality.
 */
public final class LDIFChangeRecordReaderTestCase extends LDIFTestCase {

    /**
     * Provide a standard LDIF Change Record, valid, for tests below.
     *
     * @return a string containing a standard LDIF Change Record.
     */
    public final String[] getStandardLDIFChangeRecord() {

        // @formatter:off
        final String[] cr = {
            "version: 1",
            "dn: uid=scarter,ou=People,dc=example,dc=com",
            "changetype: add",
            "sn: Carter",
            "cn: Samnatha Carter",
            "givenName: Sam",
            "objectClass: inetOrgPerson",
            "telephoneNumber: 555 555-5555",
            "mail: scarter@mail.org",
            "entryDN: uid=scarter,ou=people,dc=example,dc=org",
            "entryUUID: ad55a34a-763f-358f-93f9-da86f9ecd9e4",
            "modifyTimestamp: 20120903142126Z",
            "modifiersName: cn=Internal Client,cn=Root DNs,cn=config"
        };
        // @formatter:on
        return cr;
    }

    /**
     * Test to read an LDIFChangeRecord excluding all operational attributes. In
     * this case, force to false, all attributes must be read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAllOperationalAttributesFalse() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setExcludeAllOperationalAttributes(false);
        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("entryUUID")).isTrue();
        assertThat(addRequest.containsAttribute("entryDN")).isTrue();
        assertThat(addRequest.containsAttribute("modifyTimestamp")).isTrue();
        assertThat(addRequest.containsAttribute("modifiersName")).isTrue();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.getAttributeCount()).isEqualTo(10);
    }

    /**
     * All operational attributes are excluded (true). Therefore, they musn't
     * appear in the request.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAllOperationalAttributesTrue() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setExcludeAllOperationalAttributes(true);
        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        // Operational attributes are successfully excluded:
        assertThat(addRequest.containsAttribute("entryUUID")).isFalse();
        assertThat(addRequest.containsAttribute("entryDN")).isFalse();
        assertThat(addRequest.containsAttribute("modifyTimestamp")).isFalse();
        assertThat(addRequest.containsAttribute("modifiersName")).isFalse();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        // - 4 operational
        assertThat(addRequest.getAttributeCount()).isEqualTo(6);
    }

    /**
     * All user attributes are excluded (false). The reader must fully return
     * the ldif-changes. The changetype line doesn't appear.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAllUserAttributesFalse() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setExcludeAllUserAttributes(false);
        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("sn")).isTrue();
        assertThat(addRequest.containsAttribute("givenName")).isTrue();
        assertThat(addRequest.containsAttribute("mail")).isTrue();
        assertThat(addRequest.containsAttribute("entryDN")).isTrue();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.getAttributeCount()).isEqualTo(10);
    }

    /**
     * All user attributes are excluded (true). The reader must return the
     * ldif-changes without the user attributes. The changetype line doesn't
     * appear.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAllUserAttributesTrue() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setExcludeAllUserAttributes(true);
        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("sn")).isFalse();
        assertThat(addRequest.containsAttribute("givenName")).isFalse();
        assertThat(addRequest.containsAttribute("mail")).isFalse();
        assertThat(addRequest.containsAttribute("entryDN")).isTrue();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.getAttributeCount()).isEqualTo(4);
    }

    /**
     * Test to read an entry with attribute exclusions. Three attributes
     * excluded, entry must contain the others.
     *
     * @throws Exception
     */
    @Test
    public void testSetExcludeAttributeWithMatch() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setExcludeAttribute(AttributeDescription.valueOf("cn"));
        reader.setExcludeAttribute(AttributeDescription.valueOf("cn"));
        reader.setExcludeAttribute(AttributeDescription.valueOf("sn"));
        reader.setExcludeAttribute(AttributeDescription.valueOf("entryDN"));

        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("entryDN")).isFalse();
        assertThat(addRequest.containsAttribute("sn")).isFalse();
        assertThat(addRequest.containsAttribute("cn")).isFalse();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.containsAttribute("mail")).isTrue();
        assertThat(addRequest.getAttributeCount()).isEqualTo(7);
    }

    /**
     * Test to read an entry with attribute exclusions. One non-existent
     * attribute is defined. Record must be complete.
     *
     * @throws Exception
     */
    @Test
    public void testSetExcludeAttributeWithNoMatch() throws Exception {
        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setExcludeAttribute(AttributeDescription.valueOf("vip"));

        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("entryDN")).isTrue();
        assertThat(addRequest.containsAttribute("sn")).isTrue();
        assertThat(addRequest.containsAttribute("cn")).isTrue();
        assertThat(addRequest.containsAttribute("mail")).isTrue();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.getAttribute("vip")).isNull();
        assertThat(addRequest.getAttributeCount()).isEqualTo(10);
    }

    /**
     * SetExcludeAttribute doesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetExcludeAttributeDoesntAllowNull() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setExcludeAttribute(null);
    }

    /**
     * Test to read an entry with attribute including.
     *
     * @throws Exception
     */
    @Test()
    public void testSetIncludeAttributeWithMatch() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setIncludeAttribute(AttributeDescription.valueOf("cn"));
        reader.setIncludeAttribute(AttributeDescription.valueOf("cn"));
        reader.setIncludeAttribute(AttributeDescription.valueOf("sn"));
        reader.setIncludeAttribute(AttributeDescription.valueOf("entryDN"));

        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("entryDN")).isTrue();
        assertThat(addRequest.containsAttribute("sn")).isTrue();
        assertThat(addRequest.containsAttribute("cn")).isTrue();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.containsAttribute("mail")).isFalse();
        assertThat(addRequest.getAttributeCount()).isEqualTo(3);
    }

    /**
     * Test to read an ldifChangeRecord with attribute including.
     *
     * @throws Exception
     */
    @Test()
    public void testSetIncludeAttributeWithNoMatch() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());

        reader.setIncludeAttribute(AttributeDescription.valueOf("manager"));

        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("entryDN")).isFalse();
        assertThat(addRequest.containsAttribute("sn")).isFalse();
        assertThat(addRequest.containsAttribute("cn")).isFalse();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.containsAttribute("mail")).isFalse();
        assertThat(addRequest.getAttributeCount()).isEqualTo(0);
    }

    /**
     * SetIncludeAttribute doesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetIncludeAttributeDoesntAllowNull() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader("version: 1",
                        "dn: uid=scarter,ou=People,dc=example,dc=com");
        reader.setIncludeAttribute(null);
    }

    /**
     * Test SetIncludeBranch method of LDIFChangeRecordReader.
     *
     * @throws Exception
     */
    @Test()
    public void testSetIncludeBranchWithMatch() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());
        reader.setIncludeBranch(DN.valueOf("dc=example,dc=com"));

        final ChangeRecord cr = reader.readChangeRecord();
        reader.close();

        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("entryDN")).isTrue();
        assertThat(addRequest.containsAttribute("sn")).isTrue();
        assertThat(addRequest.containsAttribute("cn")).isTrue();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.containsAttribute("mail")).isTrue();
        assertThat(addRequest.getAttributeCount()).isEqualTo(10);
    }

    /**
     * Test SetIncludeBranch method of LDIFChangeRecordReader. The branch is not
     * included, throw an NoSuchElementException.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testSetIncludeBranchWithNoMatch() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());
        reader.setIncludeBranch(DN.valueOf("dc=example,dc=org"));
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * SetIncludeBranch doesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetIncludeBranchDoesntAllowNull() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader("version: 1",
                        "dn: uid=scarter,ou=People,dc=example,dc=com");
        reader.setIncludeBranch(null);
    }

    /**
     * Test SetExcludeBranch method of LDIFChangeRecordReader.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeBranchWithMatch() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());
        reader.setExcludeBranch(DN.valueOf("dc=example,dc=org"));
        ChangeRecord cr = null;

        cr = reader.readChangeRecord();

        AddRequest addRequest = (AddRequest) cr;
        assertThat(addRequest.containsAttribute("entryDN")).isTrue();
        assertThat(addRequest.containsAttribute("sn")).isTrue();
        assertThat(addRequest.containsAttribute("cn")).isTrue();
        assertThat(addRequest.containsAttribute("changetype")).isFalse();
        assertThat(addRequest.containsAttribute("mail")).isTrue();
        assertThat(addRequest.getAttributeCount()).isEqualTo(10);
        reader.close();
    }

    /**
     * Test SetExcludeBranch method of LDIFChangeRecordReader.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testSetExcludeBranchWithNoMatch() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader(getStandardLDIFChangeRecord());
        reader.setExcludeBranch(DN.valueOf("dc=example,dc=com"));

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * SetExcludeBranch doesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetExcludeBranchDoesntAllowNull() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader("version: 1",
                        "dn: uid=scarter,ou=People,dc=example,dc=com");
        reader.setExcludeBranch(null);
    }

    /**
     * SetSchema doesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetSchemaDoesntAllowNull() throws Exception {

        final LDIFChangeRecordReader reader =
                new LDIFChangeRecordReader("version: 1",
                        "dn: uid=scarter,ou=People,dc=example,dc=com");
        reader.setSchema(null);
    }

    /**
     * LDIFChangeRecordReader setSchemaValidationPolicy. Validate the
     * ChangeRecord depending of the selected policy. ChangeRecord is here
     * allowed because it fills the case of validation.
     *
     * @throws Exception
     */
    @Test()
    public void testSetSchemaValidationPolicyDefaultAllowsEntry() throws Exception {

        // @formatter:off
        final String[] strChangeRecord = {
            "dn: uid=user.0,ou=People,dc=example,dc=com",
            "changetype: add",
            "sn: Carter",
            "objectClass: person",
            "objectClass: top",
            "cn: Aaccf Amar",
            "sn: Amar"
        };
        // @formatter:on

        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(strChangeRecord);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        final ChangeRecord cr = reader.readChangeRecord();

        AddRequest addRequest = (AddRequest) cr;
        assertThat(cr.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(addRequest.containsAttribute("sn")).isTrue();
        assertThat(addRequest.containsAttribute("cn")).isTrue();
        assertThat(addRequest.getAttributeCount()).isEqualTo(3);

        reader.close();

    }

    /**
     * LDIFChangeRecordReader setSchemaValidationPolicy. Validate the Change
     * Record depending of the selected policy. ChangeRecord is here NOT allowed
     * because it contains a uid attribute which is not allowed by the
     * SchemaValidationPolicy.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testSetSchemaValidationPolicyDefaultRejectsEntry() throws Exception {
        // @formatter:off
        String[] strChangeRecord = {
            "dn: uid=user.0,ou=People,dc=example,dc=com",
            "changetype: add",
            "sn: Carter",
            "objectClass: person",
            "objectClass: top",
            "cn: Aaccf Amar",
            "sn: Amar",
            "uid: user.0"
        };
        // @formatter:on

        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(strChangeRecord);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Test an LDIFRecordChange with an empty pair key. Must throw an exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testReadAddRecordWithEmptyPairKeyChangeType() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "dn: dc=example,dc=com",
            ":add" // if empty spaces, ko.
        );
        // @formatter:on

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFChangeRecordReader used with a wrong changetype. Must return an
     * exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testReadAddRecordWithWrongChangeType() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "dn: dc=example,dc=com",
            "changetype: oops", // wrong
            "objectClass: top",
            "objectClass: domainComponent",
            "dc: example"
        );
        // @formatter:on
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Tests reading a valid add change record with a changetype.
     *
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testReadAddRecordWithChangeType() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
@@ -80,6 +624,8 @@
        assertThat(addRequest.containsAttribute("objectClass", "top", "domainComponent")).isTrue();
        assertThat(addRequest.containsAttribute("dc", "example")).isTrue();
        assertThat(addRequest.getAttributeCount()).isEqualTo(2);
        assertThat(reader.hasNext()).isFalse();
        reader.close();
    }

    /**
@@ -88,7 +634,7 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testReadAddRecordWithoutChangeType() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
@@ -107,6 +653,7 @@
        assertThat(addRequest.containsAttribute("objectClass", "top", "domainComponent")).isTrue();
        assertThat(addRequest.containsAttribute("dc", "example")).isTrue();
        assertThat(addRequest.getAttributeCount()).isEqualTo(2);
        reader.close();
    }

    /**
@@ -115,7 +662,7 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testReadModifyRecord() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
@@ -209,28 +756,7 @@
        assertThat(modification.getAttribute()).isEqualTo(new LinkedAttribute("description", "1"));

        assertThat(changes.hasNext()).isFalse();
    }

    /**
     * Tests reading a valid delete change record.
     *
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    public void testReadDeleteRecord() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "dn: dc=example,dc=com",
            "changetype: delete"
        );
        // @formatter:on

        assertThat(reader.hasNext()).isTrue();
        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(DeleteRequest.class);
        DeleteRequest deleteRequest = (DeleteRequest) record;
        assertThat((Object) deleteRequest.getName()).isEqualTo(DN.valueOf("dc=example,dc=com"));
        reader.close();
    }

    /**
@@ -239,7 +765,7 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testReadModdnRecordWithoutNewSuperior() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
@@ -258,6 +784,7 @@
        assertThat((Object) modifyDNRequest.getNewRDN()).isEqualTo(RDN.valueOf("dc=eggsample"));
        assertThat(modifyDNRequest.isDeleteOldRDN()).isTrue();
        assertThat(modifyDNRequest.getNewSuperior()).isNull();
        reader.close();
    }

    /**
@@ -266,7 +793,7 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testReadModdnRecordWithNewSuperior() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
@@ -286,6 +813,7 @@
        assertThat((Object) modifyDNRequest.getNewRDN()).isEqualTo(RDN.valueOf("dc=eggsample"));
        assertThat(modifyDNRequest.isDeleteOldRDN()).isTrue();
        assertThat((Object) modifyDNRequest.getNewSuperior()).isEqualTo(DN.valueOf("dc=org"));
        reader.close();
    }

    /**
@@ -294,8 +822,9 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testRejectedRecordListenerMalformedFirstRecord() throws Exception {

        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

        // @formatter:off
@@ -305,9 +834,9 @@
            "objectClass: top",
            "objectClass: domainComponent",
            "dc: example"
        ).setRejectedLDIFListener(listener);
        );
        // @formatter:on

        reader.setRejectedLDIFListener(listener);
        assertThat(reader.hasNext()).isFalse();

        verify(listener).handleMalformedRecord(
@@ -315,6 +844,7 @@
                eq(Arrays.asList("dn: baddn", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example")),
                any(LocalizableMessage.class));
        reader.close();
    }

    /**
@@ -323,8 +853,9 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testRejectedRecordListenerMalformedSecondRecord() throws Exception {

        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

        // @formatter:off
@@ -340,9 +871,9 @@
            "objectClass: top",
            "objectClass: domainComponent",
            "dc: example"
        ).setRejectedLDIFListener(listener);
        );
        // @formatter:on

        reader.setRejectedLDIFListener(listener);
        reader.readChangeRecord(); // Skip good record.
        assertThat(reader.hasNext()).isFalse();

@@ -351,6 +882,7 @@
                eq(Arrays.asList("dn: baddn", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example")),
                any(LocalizableMessage.class));
        reader.close();
    }

    /**
@@ -359,7 +891,7 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testRejectedRecordListenerSkipsRecord() throws Exception {
        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

@@ -370,9 +902,9 @@
            "objectClass: top",
            "objectClass: domainComponent",
            "dc: example"
        ).setRejectedLDIFListener(listener).setExcludeBranch(DN.valueOf("dc=com"));
        );
        // @formatter:on

        reader.setRejectedLDIFListener(listener).setExcludeBranch(DN.valueOf("dc=com"));
        assertThat(reader.hasNext()).isFalse();

        verify(listener).handleSkippedRecord(
@@ -380,6 +912,7 @@
                eq(Arrays.asList("dn: dc=example,dc=com", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example")),
                any(LocalizableMessage.class));
        reader.close();
    }

    /**
@@ -389,7 +922,7 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testRejectedRecordListenerRejectsBadSchemaRecord() throws Exception {
        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

@@ -401,7 +934,8 @@
            "objectClass: domainComponent",
            "dc: example",
            "xxx: unknown attribute"
        ).setRejectedLDIFListener(listener)
        );
        reader.setRejectedLDIFListener(listener)
             .setSchemaValidationPolicy(
                 SchemaValidationPolicy.ignoreAll()
                     .checkAttributesAndObjectClasses(Policy.REJECT));
@@ -414,6 +948,7 @@
                eq(Arrays.asList("dn: dc=example,dc=com", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example", "xxx: unknown attribute")),
                anyListOf(LocalizableMessage.class));
        reader.close();
    }

    /**
@@ -423,7 +958,7 @@
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test
    @Test()
    public void testRejectedRecordListenerWarnsBadSchemaRecord() throws Exception {
        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

@@ -435,7 +970,8 @@
            "objectClass: domainComponent",
            "dc: example",
            "xxx: unknown attribute"
        ).setRejectedLDIFListener(listener)
        );
        reader.setRejectedLDIFListener(listener)
             .setSchemaValidationPolicy(
                 SchemaValidationPolicy.ignoreAll()
                     .checkAttributesAndObjectClasses(Policy.WARN));
@@ -456,5 +992,1113 @@
                eq(Arrays.asList("dn: dc=example,dc=com", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example", "xxx: unknown attribute")),
                anyListOf(LocalizableMessage.class));
        reader.close();
    }

    /**
     * Read an example containing an invalid url. Must throw an exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testReadFileContainingInvalidURLThrowsError() throws Exception {

        // @formatter:off
        final  LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "version: 1",
            "# Add a new entry",
            "dn: cn=Fiona Jensen, ou=Marketing, dc=airius, dc=com",
            "changetype: add",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Fiona Jensen",
            "sn: Jensen",
            "uid: fiona",
            "telephonenumber: +1 408 555 1212",
            "jpegphoto:< http://www.FionaJensen.www"
        );
        // @formatter:on

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Read a complete LDIFChangeRecord containing serie of changes.
     *
     * @throws Exception
     */
    @Test()
    public void testReadFileContainingSerieOfChanges() throws Exception {
        // @formatter:off
        final  LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
                "version: 1",
                "# Add a new entry",
                "dn: cn=Fiona Jensen, ou=Marketing, dc=airius, dc=com",
                "changetype: add",
                "objectclass: top",
                "objectclass: person",
                "objectclass: organizationalPerson",
                "cn: Fiona Jensen",
                "sn: Jensen",
                "uid: fiona",
                "telephonenumber: +1 408 555 1212",
                "jpegphoto:< http://www.forgerock.com/sites/default/files/forgerock_logo.png",
                "",
                "# Delete an existing entry",
                "dn: cn=Robert Jensen, ou=Marketing, dc=airius, dc=com",
                "changetype: delete",
                "",
                "# Modify an entry's relative distinguished name",
                "dn: cn=Paul Jensen, ou=Product Development, dc=airius, dc=com",
                "changetype: modrdn",
                "newrdn: cn=Paula Jensen",
                "deleteoldrdn: 1",
                "",
                "# Rename an entry and move all of its children to a new location in",
                "# the directory tree (only implemented by LDAPv3 servers).",
                "dn: ou=PD Accountants, ou=Product Development, dc=airius, dc=com",
                "changetype: modrdn",
                "newrdn: ou=Product Development Accountants",
                "deleteoldrdn: 0",
                "newsuperior: ou=Accounting, dc=airius, dc=com",
                ""
        );
        // @formatter:on
        assertThat(reader.hasNext()).isTrue();
        // 1st record
        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(AddRequest.class);
        AddRequest addReq = (AddRequest) record;
        assertThat((Object) addReq.getName()).isEqualTo(
                DN.valueOf("cn=Fiona Jensen, ou=Marketing, dc=airius, dc=com"));
        // 2nd record
        record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(DeleteRequest.class);
        DeleteRequest delReq = (DeleteRequest) record;
        assertThat((Object) delReq.getName()).isEqualTo(
                DN.valueOf("cn=Robert Jensen, ou=Marketing, dc=airius, dc=com"));
        assertThat(reader.hasNext()).isTrue();
        // 3rd record
        record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(ModifyDNRequest.class);
        ModifyDNRequest modDNReq = (ModifyDNRequest) record;

        assertThat((Object) modDNReq.getNewRDN()).isEqualTo(RDN.valueOf("cn=Paula Jensen"));
        assertThat((Object) modDNReq.getName()).isEqualTo(
                DN.valueOf("cn=Paul Jensen, ou=Product Development, dc=airius, dc=com"));
        assertThat(reader.hasNext()).isTrue();
        // 4th record
        record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(ModifyDNRequest.class);
        modDNReq = (ModifyDNRequest) record;
        assertThat((Object) modDNReq.getName()).isEqualTo(
                DN.valueOf("ou=PD Accountants, ou=Product Development, dc=airius, dc=com"));
        assertThat(reader.hasNext()).isFalse();

        reader.close();
    }

    /**
     * Test to read an entry containing a control. Not Yet implemented. TODO
     * OPENDJ-185 Add support for controls in SDK LDIFReader.
     *
     * @throws Exception
     */
    @Test(enabled = false)
    public void testLDIFCRRParseAddChangeRecordEntryWithAControl() throws Exception {
        // @formatter:off
        final  LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
                    "# Delete an entry. The operation will attach the LDAPv3",
                    "# Tree Delete Control defined in [9]. The criticality",
                    "# field is \"true\" and the controlValue field is",
                    "# absent, as required by [9].",
                    "dn: ou=Product Development, dc=airius, dc=com",
                    "control: 1.2.840.113556.1.4.805 true",
                    "changetype: delete"
        );
        // @formatter:on

        assertThat(reader.hasNext()).isTrue();

        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());
        // Read the entry
        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(AddRequest.class);
        AddRequest request = (AddRequest) record;
        assertThat((Object) request.getName()).isEqualTo(
                DN.valueOf("ou=Product Development, dc=airius, dc=com"));
        assertThat(request.getControls()).isNotEmpty();
        reader.close();
    }

    /**
     * Test an add request malformed, changetype is erroneous (wrongchangetype)
     * Must throw an exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseAddChangeRecordEntryLastLDIFLineIsNull() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
                "dn: uid=scarter,ou=People,dc=example,dc=com",
                "wrongchangetype: add", // wrong
                "uid:Carter"
        );
        // @formatter:on

        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Tests reading a valid delete change record.
     *
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test()
    public void testLDIFCRRparseDeleteChangeRecordEntry() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "dn: dc=example,dc=com",
            "changetype: delete"
        );
        // @formatter:on

        assertThat(reader.hasNext()).isTrue();
        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(DeleteRequest.class);
        DeleteRequest deleteRequest = (DeleteRequest) record;
        assertThat((Object) deleteRequest.getName()).isEqualTo(DN.valueOf("dc=example,dc=com"));
        reader.close();
    }

    /**
     * Testing a valid LDIFChangeRecord with the delete type. The LDIF is
     * containing additional lines after the 'changetype' when none were
     * expected. Exception must be throw.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseDeleteChangeRecordEntryMalformedDelete() throws Exception {

        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
                "# Delete an existing entry",
                "dn: cn=Robert Jensen, ou=Marketing, dc=airius, dc=com",
                "changetype: delete",
                "-",
                "add: telephonenumber",
                "telephonenumber: 555-4321"
        );
        // @formatter:on
        reader.readChangeRecord();
    }

    /**
     * Read an LDIFChangeRecord for deleting selected values of a multi-valued
     * attribute.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFCRRParseModifyChangeRecordEntryDeleteMultipleValuableAttributes()
            throws Exception {
        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
                "# Add new entry containing multiple attributes",
                "dn: cn=Fiona Jensen, ou=Marketing, dc=airius, dc=com",
                "changetype: modify",
                "delete: telephonenumber",
                "telephonenumber: +1 408 555 1212",
                "telephonenumber: +1 408 555 1213",
                "telephonenumber: +1 408 555 1214"
        );
        // @formatter:on
        assertThat(reader.hasNext()).isTrue();

        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(ModifyRequest.class);
        ModifyRequest req = (ModifyRequest) record;
        assertThat((Object) req.getName()).isEqualTo(
                DN.valueOf("cn=Fiona Jensen, ou=Marketing, dc=airius, dc=com"));
        assertThat(reader.hasNext()).isFalse();
    }

    /**
     * Read an LDIFChangeRecord for deleting selected values of a multi-valued
     * attribute. The 2nd attribute is malformed : Schema validation failure.
     * ERR_LDIF_MALFORMED_ATTRIBUTE_NAME : The provided value is not a valid
     * telephone number because it is empty or null
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyChangeRecordEntryDeleteMultipleValuableAttributesMalformedLDIF()
            throws Exception {
        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
                "# Add new entry containing multiple attributes",
                "dn: cn=Fiona Jensen, ou=Marketing, dc=airius, dc=com",
                "changetype: modify",
                "delete: telephonenumber",
                "telephonenumber: +1 408 555 1212",
                "telephonenumber:", // wrong!
                "telephonenumber: +1 408 555 1214",
                "-"
        );
        // @formatter:on

        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * BER encoding is required for this LDIFChangeRecord. After adding the user
     * certificate to the core schema, LDIFCRR is correctly read.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFCRRParseModifyChangeRecordBEREncodingRequired() throws Exception {
        // @formatter:off
        String validcert1 = // a valid certificate but wrong can be used => no errors
                "MIICpTCCAg6gAwIBAgIJALeoA6I3ZC/cMA0GCSqGSIb3DQEBBQUAMFYxCzAJBgNV"
                + "BAYTAlVTMRMwEQYDVQQHEwpDdXBlcnRpb25lMRwwGgYDVQQLExNQcm9kdWN0IERl"
                + "dmVsb3BtZW50MRQwEgYDVQQDEwtCYWJzIEplbnNlbjAeFw0xMjA1MDIxNjM0MzVa"
                + "Fw0xMjEyMjExNjM0MzVaMFYxCzAJBgNVBAYTAlVTMRMwEQYDVQQHEwpDdXBlcnRp"
                + "b25lMRwwGgYDVQQLExNQcm9kdWN0IERldmVsb3BtZW50MRQwEgYDVQQDEwtCYWJz"
                + "IEplbnNlbjCBnzANBgkqhkiG9w0BAQEFAAOBjQAwgYkCgYEApysa0c9qc8FB8gIJ"
                + "8zAb1pbJ4HzC7iRlVGhRJjFORkGhyvU4P5o2wL0iz/uko6rL9/pFhIlIMbwbV8sm"
                + "mKeNUPitwiKOjoFDmtimcZ4bx5UTAYLbbHMpEdwSpMC5iF2UioM7qdiwpAfZBd6Z"
                + "69vqNxuUJ6tP+hxtr/aSgMH2i8ECAwEAAaN7MHkwCQYDVR0TBAIwADAsBglghkgB"
                + "hvhCAQ0EHxYdT3BlblNTTCBHZW5lcmF0ZWQgQ2VydGlmaWNhdGUwHQYDVR0OBBYE"
                + "FLlZD3aKDa8jdhzoByOFMAJDs2osMB8GA1UdIwQYMBaAFLlZD3aKDa8jdhzoByOF"
                + "MAJDs2osMA0GCSqGSIb3DQEBBQUAA4GBAE5vccY8Ydd7by2bbwiDKgQqVyoKrkUg"
                + "6CD0WRmc2pBeYX2z94/PWO5L3Fx+eIZh2wTxScF+FdRWJzLbUaBuClrxuy0Y5ifj"
                + "axuJ8LFNbZtsp1ldW3i84+F5+SYT+xI67ZcoAtwx/VFVI9s5I/Gkmu9f9nxjPpK7"
                + "1AIUXiE3Qcck";

        final String[] strChangeRecord = {
            "version: 1",
            "dn:uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            "add: userCertificate;binary", // with or without the binary its working
            String.format("userCertificate;binary::%s", validcert1)
        };
        // @formatter:on

        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(strChangeRecord);

        final SchemaBuilder scBuild = new SchemaBuilder();
        // Adding the new schema containing the userCertificate
        scBuild.addObjectClass("( 2.5.6.15 NAME 'strongAuthenticationUser"
                + "' SUP top AUXILIARY MUST userCertificate )", false);
        scBuild.addAttributeType(
                "( 2.5.4.36 NAME 'userCertificate' SYNTAX 1.3.6.1.4.1.1466.115.121.1.8 )", false);
        // Adding to default core schema
        scBuild.addSchema(Schema.getCoreSchema(), false);
        Schema schema = scBuild.toSchema();
        reader.setSchema(schema);
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        ModifyRequest modifyRequest = (ModifyRequest) reader.readChangeRecord();
        assertThat(modifyRequest.getName().toString()).isEqualTo(
                "uid=scarter,ou=People,dc=example,dc=com");
        assertThat(modifyRequest.getModifications().get(0).getModificationType().toString())
                .isEqualTo("add");
        assertThat(modifyRequest.getModifications().get(0).getAttribute().firstValueAsString())
                .contains("OpenSSL Generated Certificate");
        reader.close();
    }

    /**
     * LDIFChangeREcord reader try to add an unexpected binary option to the sn.
     * sn is a included in the core schema. Must throw an exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyChangeRecordBEREncodingNotRequired() throws Exception {
        // @formatter:off
        final String[] strChangeRecord = {
            "version: 1",
            "dn:uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            "add: sn;binary",
            "sn;binary:: 5bCP56yg5Y6f"
        };
        // @formatter:on

        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(strChangeRecord);

        Schema schema = Schema.getCoreSchema();
        reader.setSchema(schema);
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Test a 'modify' change record, respecting the default schema.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFCRRParseModifyChangeRecordEntryReplaceOk() throws Exception {

        // @formatter:off
        final String[] strChangeRecord = {
            "version: 1",
            "dn: uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            "replace: uid",
            "uid: Samantha Carter"
        };
        // @formatter:on

        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(strChangeRecord);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(ModifyRequest.class);

        ModifyRequest modifyRequest = (ModifyRequest) record;
        assertThat(modifyRequest.getName().toString()).isEqualTo(
                "uid=scarter,ou=People,dc=example,dc=com");
        assertThat(modifyRequest.getModifications().get(0).getModificationType().toString())
                .isEqualTo("replace");
        assertThat(modifyRequest.getModifications().get(0).getAttribute().firstValueAsString())
                .isEqualTo("Samantha Carter");
        reader.close();
    }

    /**
     * Test a 'modify' change record, without respecting the default schema. The
     * 'badAttribute' is not recognized by the schema. Must throw an exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyChangeRecordEntryReplaceKOPolicyReject() throws Exception {

        // @formatter:off
        final String[] strChangeRecord = {
            "version: 1",
            "dn: uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            "replace: badAttribute",
            "badAttribute: scarter"
        };
        // @formatter:on

        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(strChangeRecord);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Change Record throw an exception because the added attribute is not valid
     * ('badAttribute') relative to the default schema. Here, we use a
     * Policy.warn instead of a Policy.REJECT (default)
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyChangeRecordEntryReplaceKOPolicyWarn() throws Exception {

        // @formatter:off
        final String[] strChangeRecord = {
            "version: 1",
            "dn: uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            "replace: badAttribute",
            "badAttribute: scarter"
        };
        // @formatter:on

        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(strChangeRecord);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy()
                .checkAttributesAndObjectClasses(Policy.WARN));

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Change Record throw an exception because the space added just before uid
     * provokes an LocalizedIllegalArgumentException.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyChangeRecordEntryReplaceLocalizedIllegalArgumentException()
            throws Exception {

        // @formatter:off
        final String[] strChangeRecord = {
            "version: 1",
            "dn: uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            "replace: uid",
            " uid:Samantha Carter" // the space before provokes an LocalizedIllegalArgumentException
        };
        // @formatter:on

        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(strChangeRecord);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }

    }

    /**
     * Read a malformed Change Record : changetype is wrong.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testLDIFCRRParseModifyChangeRecordEntryWithWrongChangetype() {
        // @formatter:off
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord(
            "version: 1",
            "dn: uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            "oops:uidNumber" // wrong
        );
        // @formatter:on
    }

    /**
     * Read a malformed Change Record. 'pair.key' is null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testLDIFCRRParseModifyChangeRecordEntryWithNullPairKey() {
        // @formatter:off
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord(
            "version: 1",
            "dn: uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            ":uidNumber" // wrong
        );
        // @formatter:on
    }

    /**
     * Read a well formed Change Record.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFCRRParseModifyChangeRecordEntryIncrement() throws Exception {
        // @formatter:off
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord(
            "version: 1",
            "dn: uid=scarter,ou=People,dc=example,dc=com",
            "changetype: modify",
            "increment:uidNumber",
            "uidNumber: 1"
        );
        // @formatter:on

        assertThat(cr).isInstanceOf(ModifyRequest.class);
        ModifyRequest modifyRequest = (ModifyRequest) cr;

        assertThat(modifyRequest.getName().toString()).isEqualTo(
                "uid=scarter,ou=People,dc=example,dc=com");

        assertThat(modifyRequest.getModifications().get(0).getModificationType().toString())
                .isEqualTo("increment");
    }

    /**
     * Read an LDIF Record changes. Trying to modify DN using base64 newrdn.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFCRRparseModifyDNChangeRecordEntryRecordBase64NewRDN() throws Exception {

        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
                "dn::ZGM9cGVvcGxlLGRjPWV4YW1wbGUsZGM9b3Jn",
                "changetype: modrdn",
                "newrdn::ZGM9cGVvcGxlLGRjPWV4YW1wbGUsZGM9Y29t",
                "deleteoldrdn: 1"
        );
        // @formatter:on

        assertThat(reader.hasNext()).isTrue();
        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(ModifyDNRequest.class);
        ModifyDNRequest modifyDNRequest = (ModifyDNRequest) record;
        assertThat((Object) modifyDNRequest.getName()).isEqualTo(
                DN.valueOf("dc=people,dc=example,dc=org"));
        assertThat((Object) modifyDNRequest.getNewRDN()).isEqualTo(
                RDN.valueOf("dc=people,dc=example,dc=com"));
        assertThat(modifyDNRequest.isDeleteOldRDN()).isTrue();
        reader.close();
    }

    /**
     * Modifying a DN and delete the old one.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFCRRParseModifyDNChangeRecordEntry() throws Exception {
        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "version: 1",
            "dn: cn=scarter,dc=example,dc=com",
            "changetype: modrdn",
            "newrdn: cn=Susan Jacobs",
            "deleteoldrdn: 1"
        );
        // @formatter:on

        assertThat(reader.hasNext()).isTrue();
        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(ModifyDNRequest.class);
        ModifyDNRequest modifyDNRequest = (ModifyDNRequest) record;
        assertThat((Object) modifyDNRequest.getName()).isEqualTo(
                DN.valueOf("cn=scarter,dc=example,dc=com"));
        assertThat((Object) modifyDNRequest.getNewRDN()).isEqualTo(RDN.valueOf("cn=Susan Jacobs"));
        assertThat(modifyDNRequest.isDeleteOldRDN()).isTrue();
        assertThat((Object) modifyDNRequest.getNewSuperior()).isEqualTo(null);
        reader.close();
    }

    /**
     * Try to change the dn, but the new rdn is missing. Unable to parse LDIF
     * modify DN record starting at line 1 with distinguished name
     * "cn=scarter,dc=example,dc=com" because there was no new RDN.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyDNChangeRecordEntryMalformedMissedNewRDN() throws Exception {
        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "version: 1",
            "dn: cn=scarter,dc=example,dc=com",
            "changetype: modrdn"
        );
        // @formatter:on

        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFChangeRecord.parseModifyDNChangeRecordEntry and try to add an empty
     * new rdn throw an error.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyDNChangeRecordEntryKeyMalformedEmptyNewRDN() throws Exception {

        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "version: 1",
            "dn: cn=scarter,dc=example,dc=com",
            "changetype: modrdn",
            "newrdn:",
            "deleteoldrdn: 1"
        );
        // @formatter:on
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFChangeRecord.parseModifyDNChangeRecordEntry and try to add a
     * malformed rdn throw an error.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyDNChangeRecordEntryKeyValueMalformedRDN() throws Exception {
        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "version: 1",
            "dn: cn=scarter,dc=example,dc=com",
            "changetype: modrdn",
            "newrdn:oops", // wrong
            "deleteoldrdn: 1"
        );
        // @formatter:on
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFChangeRecord.parseModifyDNChangeRecordEntry and try to add a
     * malformed rdn throw an error. (deleteoldrdn value is wrong).
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyDNChangeRecordEntryKeyValueMalformedDeleteOldRDN()
            throws Exception {

        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "version: 1",
            "dn: cn=scarter,dc=example,dc=com",
            "changetype: modrdn",
            "newrdn:cn=Susan Jacobs",
            "deleteoldrdn: cn=scarter,dc=example,dc=com" // wrong
        );
        // @formatter:on
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFChangeRecord.parseModifyDNChangeRecordEntry and try to add a
     * malformed rdn throw an error. (pair.key != deleteoldrdn)
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyDNChangeRecordEntryKeyValueMalformedDeleteOldRDN2()
            throws Exception {
        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "version: 1",
            "dn: cn=scarter,dc=example,dc=com",
            "changetype: modrdn",
            "newrdn:cn=Susan Jacobs",
            "deleteold: 1" // wrong
        );
        // @formatter:on
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Try to change the DN but deleteoldrdn is missing. Must throw an exception
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRParseModifyDNChangeRecordEntryKeyValueMalformedDeleteOldRDN3()
            throws Exception {

        // @formatter:off
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "version: 1",
            "dn: cn=scarter,dc=example,dc=com",
            "changetype: modrdn",
            "newrdn:cn=Susan Jacobs"
            // missing deleteoldrn: 1/0||true/false||yes/no
        );
        // @formatter:on
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFCRR delete old rdn and add a new superior to the new one.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFCRRparseModifyRecordEntryDeleteOldRDNFalse() throws Exception {

        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "dn: cn=scarter,ou=People,dc=example,dc=com",
            "changeType: modrdn",
            "newrdn: cn=Susan Jacobs",
            "deleteOldRdn: 0",
            "newSuperior:ou=Manager,dc=example,dc=org"
        );
        // @formatter:on
        assertThat(reader.hasNext()).isTrue();
        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(ModifyDNRequest.class);
        ModifyDNRequest modifyDNRequest = (ModifyDNRequest) record;

        assertThat((Object) modifyDNRequest.getName()).isEqualTo(
                DN.valueOf("cn=scarter,ou=People,dc=example,dc=com"));
        assertThat((Object) modifyDNRequest.getNewRDN()).isEqualTo(RDN.valueOf("cn=Susan Jacobs"));
        assertThat(modifyDNRequest.isDeleteOldRDN()).isFalse();
        assertThat((Object) modifyDNRequest.getNewSuperior().toString()).isEqualTo(
                "ou=Manager,dc=example,dc=org");
        reader.close();
    }

    /**
     * LDIFCRR delete old rdn and add a new superior.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFCRRparseModifyRecordEntryNewSuperior() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "dn: cn=scarter,ou=People,dc=example,dc=com",
            "changeType: modrdn",
            "newrdn: cn=Susan Jacobs",
            "deleteOldRdn: 1",
            "newSuperior:ou=Manager,dc=example,dc=org"
        );
        // @formatter:on
        assertThat(reader.hasNext()).isTrue();
        ChangeRecord record = reader.readChangeRecord();
        assertThat(record).isInstanceOf(ModifyDNRequest.class);
        ModifyDNRequest modifyDNRequest = (ModifyDNRequest) record;

        assertThat((Object) modifyDNRequest.getName()).isEqualTo(
                DN.valueOf("cn=scarter,ou=People,dc=example,dc=com"));
        assertThat((Object) modifyDNRequest.getNewRDN()).isEqualTo(RDN.valueOf("cn=Susan Jacobs"));
        assertThat(modifyDNRequest.isDeleteOldRDN()).isTrue();
        assertThat((Object) modifyDNRequest.getNewSuperior().toString()).isEqualTo(
                "ou=Manager,dc=example,dc=org");
        reader.close();
    }

    /**
     * LDIFCRR delete old rdn and add a new superior willingly malformed. Syntax
     * is wrong "newSuperior:". Must throw an exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRparseModifyRecordEntryNewSuperiorMalformed() throws Exception {
        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "dn: cn=scarter,ou=People,dc=example,dc=com",
            "changeType: modrdn",
            "newrdn: cn=Susan Jacobs",
            "deleteOldRdn: 1",
            "newSuperior:" // wrong
        );
        // @formatter:on
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFCRR delete old rdn and add a new superior willingly malformed. Syntax
     * is wrong "newSuperior: Susan Jacobs". Must throw an exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFCRRparseModifyRecordEntryNewSuperiorMalformed2() throws Exception {

        // @formatter:off
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(
            "dn: cn=scarter,ou=People,dc=example,dc=com",
            "changeType: modrdn",
            "newrdn: cn=Susan Jacobs",
            "deleteOldRdn: 1",
            "newSuperior: Susan Jacobs" // wrong
        );
        // @formatter:on
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Mock an inputstream for verifying LDIFChangeRecordReader close().
     *
     * @throws Exception
     */
    @Test(expectedExceptions = IOException.class)
    public void testChangeRecordReaderClosesAfterReading() throws Exception {

        final FileInputStream mockIn = mock(FileInputStream.class);
        final LDIFChangeRecordReader reader = new LDIFChangeRecordReader(mockIn);

        doThrow(new IOException()).when(mockIn).read();
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
            verify(mockIn, times(1)).close();
        }
    }

    /**
     * Read an ldif-changes using a List<String>.
     *
     * @throws Exception
     */
    @Test()
    public void testChangeRecordReaderUseListConstructor() throws Exception {
        // @formatter:off
        List<String> cr = Arrays.asList(
            "dn: dc=example,dc=com",
            "changetype: add",
            "objectClass: top",
            "objectClass: domainComponent",
            "dc: example"
        );
        // @formatter:on

        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(cr);
        ChangeRecord rc = reader.readChangeRecord();
        assertThat(rc).isNotNull();
        assertThat(rc.getName().toString()).isEqualTo("dc=example,dc=com");
        reader.close();
    }

    /**
     * Try to read an LDIFChangeREcord without changetype. Must throw an
     * exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testChangeRecordReaderHasNoChange() throws Exception {

        // @formatter:off
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord(
            "version: 1",
            "# Add a new entry without changes !",
            "dn: dc=example,dc=com"
        );
        // @formatter:on
    }

    /**
     * Try to read a null ldif-changes using a List<String>. Exception expected.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testChangeRecordReaderDoesntAllowNull() throws Exception {
        List<String> cr = Arrays.asList();
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(cr);
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * Try to read a null ldif-changes using an empty String. Exception
     * expected.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testChangeRecordReaderLDIFLineDoesntAllowNull() throws Exception {
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(new String());
        try {
            reader.readChangeRecord();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFChangeRecordReader cause NullPointerException when InputStream is
     * null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testChangeRecordReaderInpuStreamDoesntAllowNull() throws Exception {
        final InputStream is = null;
        @SuppressWarnings({ "unused", "resource" })
        LDIFChangeRecordReader reader = new LDIFChangeRecordReader(is);
    }

    /**
     * LDIFChangeRecordReader cause NullPointerException when
     * valueOfLDIFChangeRecord is null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testValueOfLDIFChangeRecordDoesntAllowNull() throws Exception {
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord("");
    }

    /**
     * valueOfLDIFChangeRecord cause an exception due to the presence of
     * multiple change record.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testValueOfLDIFChangeRecordDoesntAllowMultipleChangeRecords() throws Exception {
        // @formatter:off
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord(
            "version: 1",
            "# Add a new entry",
            "dn: cn=Fiona Jensen, ou=Marketing, dc=airius, dc=com",
            "changetype: add",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Fiona Jensen",
            "sn: Jensen",
            "uid: fiona",
            "telephonenumber: +1 408 555 1212",
            "jpegphotojpegphoto:< http://www.forgerock.com/sites/default/files/forgerock_logo.png",
            "",
            "# Delete an existing entry",
            "dn: cn=Robert Jensen, ou=Marketing, dc=airius, dc=com",
            "changetype: delete"
        );
        // @formatter:on
    }

    /**
     * valueOfLDIFChangeRecord cause an exception due to badly formed ldif. In
     * this case, DN is missing.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testValueOfLDIFChangeRecordMalformedLDIFDNIsMissing() throws Exception {
        // @formatter:off
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord(
            "version: 1",
            "# Add a new entry",
            "changetype: add",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Fiona Jensen",
            "sn: Jensen",
            "uid: fiona",
            "telephonenumber: +1 408 555 1212"
        );
        // @formatter:on
        // DN is missing above.
    }

    /**
     * Try to read a malformed LDIF : The provided LDIF content did not contain
     * any LDIF change records. Coverage on AbstractLDIFReader -
     * readLDIFRecordDN.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testValueOfLDIFChangeRecordMalformedLDIFContainingOnlyVersion() throws Exception {

        // @formatter:off
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord(
                "version: 1"
        );
        // @formatter:on
    }

    /**
     * Try to read a malformed LDIF : Unable to parse LDIF entry starting at
     * line 1 because the line ":wrong" does not include an attribute name.
     * Coverage on AbstractLDIFReader - readLDIFRecordDN.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testValueOfLDIFChangeRecordMalformedLDIFContainingVersionAndWrongLine()
            throws Exception {

        // @formatter:off
        final ChangeRecord cr = LDIFChangeRecordReader.valueOfLDIFChangeRecord(
                "version: 1",
                ":wrong"
        );
        // @formatter:on
    }

    /**
     * Try to read a standard Change Record LDIF.
     *
     * @throws Exception
     */
    @Test()
    public void testValueOfLDIFChangeRecordStandardLDIF() throws Exception {

        // @formatter:off
        final ChangeRecord cr =
                LDIFChangeRecordReader.valueOfLDIFChangeRecord(getStandardLDIFChangeRecord());
        // @formatter:on

        AddRequest addRequest = (AddRequest) cr;
        assertThat(cr.getName().toString()).isEqualTo("uid=scarter,ou=People,dc=example,dc=com");
        assertThat(addRequest.containsAttribute("sn")).isTrue();
        assertThat(addRequest.containsAttribute("cn")).isTrue();
        assertThat(addRequest.getAttributeCount()).isEqualTo(10);
    }

}

 opendj-sdk/opendj3/opendj-ldap-sdk/src/test/java/org/forgerock/opendj/ldif/LDIFEntryReaderTestCase.java

@@ -22,6 +22,7 @@
 *
 *
 *      Copyright 2009-2010 Sun Microsystems, Inc.
 *      Portions copyright 2012 ForgeRock AS.
 */

package org.forgerock.opendj.ldif;
@@ -29,26 +30,873 @@
import static org.testng.Assert.assertNotNull;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Arrays;
import java.util.NoSuchElementException;

import org.forgerock.i18n.LocalizableMessage;
import org.forgerock.i18n.LocalizedIllegalArgumentException;
import org.forgerock.opendj.ldap.AttributeDescription;
import org.forgerock.opendj.ldap.DN;
import org.forgerock.opendj.ldap.DecodeException;
import org.forgerock.opendj.ldap.Entry;
import org.forgerock.opendj.ldap.Filter;
import org.forgerock.opendj.ldap.LinkedHashMapEntry;
import org.forgerock.opendj.ldap.Matcher;
import org.forgerock.opendj.ldap.TestCaseUtils;
import org.forgerock.opendj.ldap.schema.Schema;
import org.forgerock.opendj.ldap.schema.SchemaBuilder;
import org.forgerock.opendj.ldap.schema.SchemaValidationPolicy;
import org.forgerock.opendj.ldap.schema.SchemaValidationPolicy.Policy;
import org.testng.Assert;
import org.testng.annotations.Test;
import static org.fest.assertions.Assertions.assertThat;
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.anyListOf;
import static org.mockito.Matchers.eq;
import static org.mockito.Mockito.*;

/**
 * This class tests the LDIFEntryReader functionality.
 */
public final class LDIFEntryReaderTestCase extends LDIFTestCase {
    /**
     * Provide a standard entry for the tests below.
     *
     * @return well formed LDIF entry
     */
    public final String[] getStandardEntry() {
        // @formatter:off
        final String[] entry = {
            "dn: uid=user.0,ou=People,dc=example,dc=com",
            "objectClass: person",
            "objectClass: inetorgperson",
            "objectClass: organizationalperson",
            "objectClass: top",
            "postalAddress: Aaccf Amar$01251 Chestnut Street$Panama City, DE  50369",
            "postalCode: 50369",
            "uid: user.0",
            "description: This is the description for Aaccf Amar.",
            "userPassword: {SSHA}hpbT8dLi8xgYy2kl4aP6QKGzsFdhESWpPmDTEw==",
            "employeeNumber: 0",
            "initials: ASA",
            "givenName: Aaccf",
            "pager: +1 779 041 6341",
            "mobile: +1 010 154 3228",
            "cn: Aaccf Amar",
            "telephoneNumber: +1 685 622 6202",
            "sn: Amar",
            "street: 01251 Chestnut Street",
            "homePhone: +1 225 216 5900",
            "mail: user.0@maildomain.net",
            "l: Panama City", "st: DE",
            "pwdChangedTime: 20120903142126.219Z",
            "entryDN: uid=user.0,ou=people,dc=example,dc=org",
            "entryUUID: ad55a34a-763f-358f-93f9-da86f9ecd9e4",
            "modifyTimestamp: 20120903142126Z",
            "modifiersName: cn=Internal Client,cn=Root DNs,cn=config"
        };
        // @formatter:on
        return entry;
    }

    /**
     * Number of attributes of the standard entry.
     */
    public final int nbStandardEntryAttributes = new LinkedHashMapEntry(getStandardEntry())
            .getAttributeCount();

    /**
     * Test SetExcludeBranch method of LDIFEntryReader. Excluding the
     * "dc=example,dc=com" Entry is not read and function return a
     * NoSuchElementException exception.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testSetExcludeBranchWithNoMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setExcludeBranch(DN.valueOf("dc=example,dc=com"));

        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * Test SetExcludeBranch method of LDIFEntryReader. Excluding the
     * "dc=example,dc=org", which is not in the standard ldif entry. Entry must
     * be fully read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeBranchWithMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setExcludeBranch(DN.valueOf("dc=example,dc=org"));
        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
    }

    /**
     * Test the setExcludeBranch with a null parameter.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetExcludeBranchDoesntAllowNull() throws Exception {
        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setExcludeBranch(null);
    }

    /**
     * Test to read an entry excluding user attributes. Default case - all the
     * lines must be read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAllUserAttributesFalse() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setExcludeAllUserAttributes(false);
        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
        assertThat(entry.getAttribute("entryDN")).isNotNull();
        assertThat(entry.getAttribute("description")).isNotNull();
    }

    /**
     * Test to read an entry excluding user attributes Only the operational
     * attributes must be read (entryDN, entryUUID, modifyTimestamp,
     * modifiersName...) (e.g : 4 in the standard entry)
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAllUserAttributesTrue() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());

        reader.setExcludeAllUserAttributes(true);
        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getAttribute("dn")).isNull();
        assertThat(entry.getAttribute("sn")).isNull();
        assertThat(entry.getAttribute("uid")).isNull();
        assertThat(entry.getAttribute("description")).isNull();

        assertThat(entry.getAttribute("entryDN")).isNotEmpty();
        assertThat(entry.getAttribute("entryUUID")).isNotEmpty();
        assertThat(entry.getAttribute("modifyTimestamp")).isNotNull();
        assertThat(entry.getAttributeCount()).isEqualTo(4);
    }

    /**
     * Test to read an entry with attribute exclusions. In this test, the
     * attribute description 'vip' doesn't exist... the entry must be fully
     * read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAttributeWithNoMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setExcludeAttribute(AttributeDescription.valueOf("vip"));

        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
        // no attribute 'vip'
        assertThat(entry.getAttribute("vip")).isNull();
    }

    /**
     * Test to read an entry with attribute exclusions. Three attributes
     * excluded, entry must contain the others.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAttributeWithMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());

        reader.setExcludeAttribute(AttributeDescription.valueOf("cn"));
        reader.setExcludeAttribute(AttributeDescription.valueOf("cn"));
        reader.setExcludeAttribute(AttributeDescription.valueOf("sn"));
        reader.setExcludeAttribute(AttributeDescription.valueOf("entryDN"));

        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getAttribute("entryDN")).isNull();
        assertThat(entry.getAttribute("sn")).isNull();
        assertThat(entry.getAttribute("cn")).isNull();

        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes - 3);
        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
    }

    /**
     * setExcludeAttributeDoesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetExcludeAttributeDoesntAllowNull() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setExcludeAttribute(null);
    }

    /**
     * Test to read an entry excluding all operational attributes
     * setExcludeAllOperationalAttributes to false (default case) All attributes
     * must be read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAllOperationalAttributesFalse() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());

        reader.setExcludeAllOperationalAttributes(false);
        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
        assertThat(entry.getAttribute("entryDN")).isNotNull();
        assertThat(entry.getAttribute("entryUUID")).isNotNull();
        assertThat(entry.getAttribute("modifyTimestamp")).isNotNull();
    }

    /**
     * Test to read an entry excluding all operational attributes
     * setExcludeAllOperationalAttributes is forced to true
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeAllOperationalAttributesTrue() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());

        reader.setExcludeAllOperationalAttributes(true);
        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getAttribute("entryDN")).isNull();
        assertThat(entry.getAttribute("entryUUID")).isNull();
        assertThat(entry.getAttribute("modifyTimestamp")).isNull();

        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isLessThan(nbStandardEntryAttributes);
    }

    /**
     * Test SetExcludeFilter method of LDIFEntryReader. Throws a
     * NullPointerException if the excludeFilter is null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testsetExcludeFilterDoesntAllowNull() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());

        reader.setExcludeFilter(null);
        reader.close();
    }

    /**
     * Test testSetExcludeFilter method of LDIFEntryReader. StandardEntry has an
     * objectclass : person, not vip. The filter must exclude all entries with
     * an objectclass = vip. In this case, entry must be fully read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetExcludeFilterWithMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        final Filter filter = Filter.equality("objectclass", "vip");
        final Matcher excludeFilter = filter.matcher();

        reader.setExcludeFilter(excludeFilter);
        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttribute("objectclass").toString()).isNotEqualTo("vip");
    }

    /**
     * Test testSetExcludeFilter method of LDIFEntryReader. StandardEntry has an
     * objectclass : person. The filter must exclude all entries with an
     * objectclass = person. Entry musn't be read.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testSetExcludeFilterWithNoMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        final Filter filter = Filter.equality("objectclass", "person");
        final Matcher excludeFilter = filter.matcher();

        reader.setExcludeFilter(excludeFilter);
        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * Test the setIncludeAttribute Attributes included must be the only ones
     * present in the entry. First line dn must be present.
     *
     * @throws Exception
     */
    @Test()
    public void testSetIncludeAttributeWithMatch() throws Exception {
        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setIncludeAttribute(AttributeDescription.valueOf("cn"));
        reader.setIncludeAttribute(AttributeDescription.valueOf("sn"));
        reader.setIncludeAttribute(AttributeDescription.valueOf("sn"));
        final Entry entry = reader.readEntry();

        assertThat(entry).isNotNull();
        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isEqualTo(2);
        assertThat(entry.getAttribute("cn")).isNotNull();
        assertThat(entry.getAttribute("sn")).isNotNull();
        assertThat(entry.getAttribute("description")).isNull();

        reader.close();
    }

    /**
     * Test the setIncludeAttribute Attributes included must be the only ones
     * present in the entry. In this case, the attribute "manager" doesn't
     * exist. Only dn line must be read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetIncludeAttributeWithNoMatch() throws Exception {
        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setIncludeAttribute(AttributeDescription.valueOf("manager"));
        final Entry entry = reader.readEntry();

        assertThat(entry).isNotNull();
        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isEqualTo(0);
        assertThat(entry.getAttribute("description")).isNull();

        reader.close();
    }

    /**
     * Test SetIncludeAttribute method of LDIFEntryReader Throws a
     * NullPointerException if the includeAttribute is null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetIncludeAttributeDoesntAllowNull() throws Exception {
        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setIncludeAttribute(null);
        reader.close();
    }

    /**
     * Test SetIncludeBranch method of LDIFEntryReader. "dc=example,dc=org" not
     * existing in the standard ldif entry. Entry must not be read.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testSetIncludeBranchWithNoMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setIncludeBranch(DN.valueOf("dc=example,dc=org"));

        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * Test SetIncludeBranch method of LDIFEntryReader. "dc=example,dc=com" is
     * the branch of the standard entry. Entry must be fully read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetIncludeBranchWithMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setIncludeBranch(DN.valueOf("dc=example,dc=com"));
        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry).isNotNull();
        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
    }

    /**
     * Test SetIncludeBranch method of LDIFEntryReader. Throws a
     * NullPointerException if the includeBranch is null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetIncludeBranchDoesntAllowNull() throws Exception {
        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setIncludeBranch(null);
    }

    /**
     * LDIFEntryReader setIncludeFilter with an equality filter on the
     * objectclass: vip, Entry musn't be read.
     *
     * @throws Exception
     *             NoSuchElementException launched if entry is not read
     */
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testSetIncludeFilterWithNoMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        final Filter filter = Filter.equality("objectclass", "vip");
        final Matcher includeFilter = filter.matcher();
        reader.setIncludeFilter(includeFilter);
        Entry entry = null;
        try {
            entry = reader.readEntry();
        } finally {
            reader.close();
        }
        assertThat(entry).isNull();

    }

    /**
     * LDIFEntryReader setIncludeFilter with an equality filter on the
     * objectclass: person, Entry must be read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetIncludeFilterWithMatch() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        final Filter filter = Filter.equality("objectclass", "person");
        final Matcher includeFilter = filter.matcher();
        reader.setIncludeFilter(includeFilter);
        Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttribute("cn")).isNotNull();
        assertThat(entry.getAttribute("sn")).isNotNull();

    }

    /**
     * LDIFEntryReader setIncludeFilter doesn't allow null.
     *
     * @throws Exception
     *             NullPointerException expected
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetIncludeFilterDoesntAllowNull() throws Exception {
        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setIncludeFilter(null);
    }

    /**
     * Tests reading a malformed record invokes the rejected record listener.
     *
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test()
    public void testRejectedLDIFListenerMalformedFirstRecord() throws Exception {
        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

        LDIFEntryReader reader =
                new LDIFEntryReader("dn: baddn", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example");

        reader.setRejectedLDIFListener(listener);

        assertThat(reader.hasNext()).isFalse();

        verify(listener).handleMalformedRecord(
                eq(1L),
                eq(Arrays.asList("dn: baddn", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example")),
                any(LocalizableMessage.class));
        reader.close();
    }

    /**
     * Tests reading a malformed LDIF invokes the rejected LDIF listener.
     *
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test()
    public void testRejectedLDIFListenerMalformedSecondRecord() throws Exception {
        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

        // @formatter:off
        LDIFEntryReader reader = new LDIFEntryReader(
                "dn: dc=example,dc=com",
                "changetype: add",
                "objectClass: top",
                "objectClass: domainComponent",
                "dc: example",
                "",
                "dn: baddn",
                "changetype: add",
                "objectClass: top",
                "objectClass: domainComponent",
                "dc: example"
        );
        // @formatter:on

        reader.setRejectedLDIFListener(listener);

        reader.readEntry(); // Skip good record.
        assertThat(reader.hasNext()).isFalse();

        verify(listener).handleMalformedRecord(
                eq(7L),
                eq(Arrays.asList("dn: baddn", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example")),
                any(LocalizableMessage.class));
        reader.close();
    }

    /**
     * Tests reading a LDIF which does not conform to the schema invokes the
     * rejected LDIF listener.
     *
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test()
    public void testRejectedRecordListenerRejectsBadSchemaRecord() throws Exception {
        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

        // @formatter:off
        LDIFEntryReader reader = new LDIFEntryReader(
            "dn: dc=example,dc=com",
            "changetype: add",
            "objectClass: top",
            "objectClass: domainComponent",
            "dc: example",
            "xxx: unknown attribute");
        reader.setRejectedLDIFListener(listener)
             .setSchemaValidationPolicy(
                 SchemaValidationPolicy.ignoreAll()
                     .checkAttributesAndObjectClasses(Policy.REJECT));
        // @formatter:on

        assertThat(reader.hasNext()).isFalse();

        verify(listener).handleSchemaValidationFailure(
                eq(1L),
                eq(Arrays.asList("dn: dc=example,dc=com", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example", "xxx: unknown attribute")),
                anyListOf(LocalizableMessage.class));
        reader.close();
    }

    /**
     * Tests reading a LDIF which does not conform to the schema invokes the
     * rejected LDIF listener.
     *
     * @throws Exception
     *             if an unexpected error occurred.
     */
    @Test()
    public void testRejectedLDIFListenerWarnsBadSchemaRecord() throws Exception {

        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

        LDIFEntryReader reader =
                new LDIFEntryReader("dn: dc=example,dc=com", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example", "xxx: unknown attribute");
        reader.setRejectedLDIFListener(listener).setSchemaValidationPolicy(
                SchemaValidationPolicy.ignoreAll().checkAttributesAndObjectClasses(Policy.WARN));

        assertThat(reader.hasNext()).isTrue();

        Entry entry = reader.readEntry();

        assertThat(entry.getName().toString()).isEqualTo("dc=example,dc=com");
        assertThat(entry.containsAttribute("objectClass", "top", "domainComponent")).isTrue();
        assertThat(entry.containsAttribute("dc", "example")).isTrue();
        assertThat(entry.getAttributeCount()).isEqualTo(2);

        verify(listener).handleSchemaValidationWarning(
                eq(1L),
                eq(Arrays.asList("dn: dc=example,dc=com", "changetype: add", "objectClass: top",
                        "objectClass: domainComponent", "dc: example", "xxx: unknown attribute")),
                anyListOf(LocalizableMessage.class));
        reader.close();
    }

    /**
     * LDIFEntryReader setRejectedLDIFListener skips the record.
     *
     * @throws Exception
     */
    @Test()
    public void testRejectedLDIFListenerSkipsRecord() throws Exception {

        RejectedLDIFListener listener = mock(RejectedLDIFListener.class);

        LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setRejectedLDIFListener(listener).setExcludeBranch(DN.valueOf("dc=com"));

        assertThat(reader.hasNext()).isFalse();

        verify(listener).handleSkippedRecord(eq(1L), eq(Arrays.asList(getStandardEntry())),
                any(LocalizableMessage.class));
        reader.close();
    }

    /**
     * LDIFEntryReader setIncludeFilter allows null.
     *
     * @throws Exception
     */
    @Test()
    public void testSetRejectedLDIFListenerDoesAllowNull() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setRejectedLDIFListener(null);
        Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");

    }

    /**
     * LDIFEntryReader setSchemaValidationPolicy. Validate the entry depending
     * of the selected policy. Entry is here NOT allowed because it contains a
     * uid attribute which is not allowed by the SchemaValidationPolicy.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testSetSchemaValidationPolicyDefaultRejectsEntry() throws Exception {
        // @formatter:off
        String[] strEntry = {
            "dn: uid=user.0,ou=People,dc=example,dc=com", "objectClass: person",
            "objectClass: top", "cn: Aaccf Amar", "sn: Amar", "uid: user.0"
        };
        // @formatter:on
        final LDIFEntryReader reader = new LDIFEntryReader(strEntry);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFEntryReader setSchemaValidationPolicy. Validate the entry depending
     * of the selected policy. Entry is here allowed because it fills the case
     * of the validation.
     *
     * @throws Exception
     */
    @Test()
    public void testSetSchemaValidationPolicyDefaultAllowsEntry() throws Exception {

        // @formatter:off
        String[] strEntry = {
            "dn: uid=user.0,ou=People,dc=example,dc=com", "objectClass: person",
            "objectClass: top", "cn: Aaccf Amar", "sn: Amar"
        };
        // @formatter:on

        final LDIFEntryReader reader = new LDIFEntryReader(strEntry);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());
        final Entry entry = reader.readEntry();
        reader.close();

        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isEqualTo(3);
    }

    /**
     * LDIFEntryReader SetValidationPolicy doesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetSchemaValidationPolicyDoesntAllowNull() throws Exception {

        // @formatter:off
        String[] strEntry = {
            "dn: uid=user.0,ou=People,dc=example,dc=com", "objectClass: person",
            "objectClass: top", "cn: Aaccf Amar", "sn: Amar", "uid: user.0"
        };
        // @formatter:on

        final LDIFEntryReader reader = new LDIFEntryReader(strEntry);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(null);

    }

    /**
     * Test the setSchemaSetValidationPolicy. Adding a new schema and insuring
     * the validationPolicy allows the new attribute/class Adding a new schema
     * explained in the admin-guide (chapter 15. Managing Schema). The new
     * attribute is accepted by the policy schema. Entry must be read.
     *
     * @throws Exception
     */
    @Test()
    public void testSetSchemaSetSchemaValidationPolicyDefaultAllowsEntryWithNewAttribute()
            throws Exception {

        // @formatter:off
        final String[] strEntry = {
            "dn: uid=user.0,ou=People,dc=example,dc=com",
            "objectClass: person",
            "objectClass: organizationalperson",
            "objectClass: top", "cn: Aaccf Amar",
            "sn: Amar",
            "objectClass: myCustomObjClass",
            "myCustomAttribute: Testing..."
        };
        // @formatter:on

        final SchemaBuilder scBuild = new SchemaBuilder();
        // Adding the new schema containing the customclass
        scBuild.addObjectClass("( temporary-fake-oc-id NAME 'myCustomObjClass"
                + "' SUP top AUXILIARY MAY myCustomAttribute )", false);
        scBuild.addAttributeType("( temporary-fake-attr-id NAME 'myCustomAttribute' EQUALITY case"
                + "IgnoreMatch ORDERING caseIgnoreOrderingMatch SUBSTR caseIgnoreSubstrings"
                + "Match SYNTAX 1.3.6.1.4.1.1466.115.121.1.15 USAGE userApplications )", false);
        // Adding default core schema
        scBuild.addSchema(Schema.getCoreSchema(), false);
        Schema schema = scBuild.toSchema();
        final LDIFEntryReader reader = new LDIFEntryReader(strEntry);
        reader.setSchema(schema);
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        Entry entry = null;
        try {
            entry = reader.readEntry();
            // cn + sn + myCustomAttribute + objectClass
            assertThat(entry.getAttributeCount()).isEqualTo(4);
            assertThat(entry.getName().toString()).isEqualTo(
                    "uid=user.0,ou=People,dc=example,dc=com");
            assertThat(entry.getAttribute("sn").firstValue().toString()).isEqualTo("Amar");
            assertThat(entry.getAttribute("cn").firstValueAsString()).isEqualTo("Aaccf Amar");
            // entry.getAttribute("new attribute") : access by that way doesn't work...
            // TODO BUG jira/browse/OPENDJ-157
            assertThat(
                    entry.getAttribute(AttributeDescription.valueOf("myCustomAttribute", schema))
                            .firstValueAsString()).isEqualTo("Testing...");
        } finally {
            reader.close();
        }
    }

    /**
     * Test the setSchemaSetValidationPolicy : throw an exception if
     * unrecognized attributes are found. ex. Entry
     * "uid=user.0,ou=People,dc=example,dc=com" doesn't respect the schema
     * because it contains an unrecognized object class "myCustomObjClass".
     * Entry musn't be read.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testSetSchemaSetSchemaValidationPolicyDefaultDoesntAllowEntryWithNewAttribute()
            throws Exception {

        // @formatter:off
        String[] strEntry = {
            "dn: uid=user.0,ou=People,dc=example,dc=com", "objectClass: person",
            "objectClass: organizationalperson", "objectClass: top", "cn: Aaccf Amar",
            "sn: Amar", "objectClass: myCustomObjClass", "myCustomAttribute: Testing..."
        };
        // @formatter:on

        final LDIFEntryReader reader = new LDIFEntryReader(strEntry);

        final SchemaBuilder scBuild = new SchemaBuilder();
        scBuild.addSchema(Schema.getCoreSchema(), false);

        reader.setSchema(scBuild.toSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFEntryReader setSchema doesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testSetSchemaDoesntAllowNull() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(getStandardEntry());
        reader.setSchema(null); // must throw a NullPointerException
    }

    /**
     * Tests readEntry method of LDIFEntryReader class.See
     * https://opends.dev.java.net/issues/show_bug.cgi?id=4545 for more details.
     *
     * @throws Exception
     *             If the test failed unexpectedly.
     */
    @Test()
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testEmpty() throws Exception {
        final String path = TestCaseUtils.createTempFile("");
        final FileInputStream in = new FileInputStream(path);
@@ -56,13 +904,124 @@
        try {
            Assert.assertFalse(reader.hasNext());
            Assert.assertFalse(reader.hasNext());
            try {
                reader.readEntry();
                Assert.fail("reader.readEntry() should have thrown NoSuchElementException");
            } catch (NoSuchElementException e) {
                // This is expected.
            }
        } finally {
            Assert.assertFalse(reader.hasNext());
            reader.close();
        }
    }

    /**
     * Test to read an entry with no empty spaces.
     *
     * @throws Exception
     */
    @Test()
    public void testReadEntryWithNoSpaces() throws Exception {
        // @formatter:off
        final String[] strEntry = {
            "# Entry of SCarter",
            "dn:uid=scarter,ou=People,dc=example,dc=com",
            "objectClass:person",
            "objectClass:inetorgperson",
            "objectClass:organizationalperson",
            "objectClass:top",
            "postalAddress:Aaccf Amar$01251 Chestnut Street$Panama City, DE  50369",
            "postalCode:50369",
            "uid:scarter",
            "description::U2hvcnQgZGVzY3JpcHRpb24gb2YgU2NhcnRlcg=="
        };
        // @formatter:on
        final String path = TestCaseUtils.createTempFile(strEntry);
        final FileInputStream in = new FileInputStream(path);
        final LDIFEntryReader reader = new LDIFEntryReader(in);
        Entry entry = null;
        try {
            assertThat(reader.hasNext());
            entry = reader.readEntry();
            assertThat(entry.getName().toString()).isEqualTo(
                    "uid=scarter,ou=People,dc=example,dc=com");
            assertThat(entry.getAttribute("uid").firstValueAsString()).isEqualTo("scarter");
            assertThat(entry.getAttribute("description").firstValueAsString()).isEqualTo(
                    "Short description of Scarter");
        } finally {
            reader.close();
        }

    }

    /**
     * Test to read an entry containing spaces before the attribute
     *
     * @throws Exception
     */
    @Test()
    public void testReadEntryWithAttributesSpacesAtStart() throws Exception {
        // @formatter:off
        final String[] strEntry = {
            "#   Entry of SCarter",
            "dn:   uid=scarter,ou=People,dc=example,dc=com",
            "objectClass:   person",
            "objectClass:   inetorgperson",
            "objectClass:   organizationalperson",
            "objectClass:   top",
            "postalAddress:   Aaccf Amar$01251 Chestnut Street$Panama City, DE  50369",
            "postalCode:   50369",
            "uid:    scarter",
            "description::    U2hvcnQgZGVzY3JpcHRpb24gb2YgU2NhcnRlcg==",
        };
        // @formatter:on
        final String path = TestCaseUtils.createTempFile(strEntry);
        final FileInputStream in = new FileInputStream(path);
        final LDIFEntryReader reader = new LDIFEntryReader(in);
        Entry entry = null;
        try {
            assertThat(reader.hasNext());
            entry = reader.readEntry();
            assertThat(entry.getName().toString()).isEqualTo(
                    "uid=scarter,ou=People,dc=example,dc=com");
            assertThat(entry.getAttribute("uid").firstValueAsString()).isEqualTo("scarter");
            assertThat(entry.getAttribute("description").firstValueAsString()).isEqualTo(
                    "Short description of Scarter");
        } finally {
            reader.close();
        }
    }

    /**
     * Test to read an entry containing spaces at the end of the attribute. ldif
     * do not admit spaces at end ;)
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testReadEntryWithAttributesSpacesAtEnd() throws Exception {
        // @formatter:off
        final String[] strEntry = {
            "#   Entry of SCarter   ",
            "dn:   uid=scarter,ou=People,dc=example,dc=com    ",
            "objectClass:   person    ",
            "objectClass:   inetorgperson    ",
            "objectClass:   organizationalperson    ",
            "objectClass:   top  ",
            "postalAddress:   Aaccf Amar$01251 Chestnut Street$Panama City, DE  50369  ",
            "postalCode:   50369 ",
            "uid:    scarter  ",
            "description::    U2hvcnQgZGVzY3JpcHRpb24gb2YgU2NhcnRlcg==   ",
        };
        // @formatter:on
        final String path = TestCaseUtils.createTempFile(strEntry);
        final FileInputStream in = new FileInputStream(path);
        final LDIFEntryReader reader = new LDIFEntryReader(in);
        Entry entry = null;
        try {
            assertThat(reader.hasNext());
            entry = reader.readEntry();
            assertThat(entry.getName().toString()).isEqualTo(
                    "uid=scarter,ou=People,dc=example,dc=com");
            assertThat(entry.getAttribute("uid").firstValueAsString()).isEqualTo("scarter");
            assertThat(entry.getAttribute("description").firstValueAsString()).isEqualTo(
                    "Short description of Scarter");
        } finally {
            reader.close();
        }
@@ -75,34 +1034,614 @@
     * @throws Exception
     *             If the test failed unexpectedly.
     */
    @Test()
    @Test(expectedExceptions = NoSuchElementException.class)
    public void testReadEntry() throws Exception {
        final String path =
                TestCaseUtils.createTempFile("dn: uid=1,ou=people,dc=ucsf,dc=edu",
                        "objectClass: top", "objectClass: person",
                        "objectClass: organizationalperson", "objectClass: inetorgperson",
                        "givenName: Aaccf", "sn: Amar", "cn: Aaccf Amar", "initials: ASA",
                        "employeeNumber: 020000001", "uid: 1", "mail: Aaccf.Amar@ucsf.edu",
                        "userPassword: password", "telephoneNumber: +1 685 622 6202",
                        "homePhone: +1 225 216 5900", "pager: +1 779 041 6341",
                        "mobile: +1 010 154 3228", "street: 01251 Chestnut Street",
                        "l: Panama City", "st: DE", "postalCode: 50369",
                        "postalAddress: Aaccf Amar$01251 Chestnut Street$Panama City, DE  50369",
                        "description: This is the description for Aaccf Amar.");
        final String path = TestCaseUtils.createTempFile(getStandardEntry());
        final FileInputStream in = new FileInputStream(path);
        final LDIFEntryReader reader = new LDIFEntryReader(in);
        try {
            Assert.assertTrue(reader.hasNext());
            final Entry entry = reader.readEntry();
            assertNotNull(entry);
            Assert.assertEquals(entry.getName(), DN.valueOf("uid=1,ou=people,dc=ucsf,dc=edu"));
            Assert.assertEquals(entry.getName(), DN
                    .valueOf("uid=user.0,ou=People,dc=example,dc=com"));
            Assert.assertFalse(reader.hasNext());
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * Test to read an entry containing duplicates values
     * ERR_LDIF_MULTI_VALUED_SINGLE_VALUED_ATTRIBUTE &&
     * WARN_LDIF_DUPLICATE_ATTRIBUTE_VALUE
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testLDIFEntryReaderEntryWithDuplicateAttributes() throws Exception {
        // @formatter:off
        final String[] strEntry = {
            "dn: cn=user.0,ou=People,dc=example,dc=com",
            "objectClass: organizationalperson",
            "objectClass: top",
            "postalAddress: Aaccf Amar$01251 Chestnut Street$Panama City, DE  50369",
            "postalCode: 50369",
            "description: This is the description for Aaccf Amar.",
            "userPassword: ;", // empty value allowed
            "telephoneNumber: +1 685 622 6202", "sn: Amar",
            // entryUUID : ERR_LDIF_MULTI_VALUED_SINGLE_VALUED_ATTRIBUTE
            "entryUUID: ad55a34a-763f-358f-93f9-da86f9ecd9e4",
            "entryUUID: ad55a34a-763f-358f-93f9-da45f9ecd9e4",
            // WARN_LDIF_DUPLICATE_ATTRIBUTE_VALUE :
            "objectClass: person",
            "objectClass: person"
        };
        // @formatter:on
        final String path = TestCaseUtils.createTempFile(strEntry);
        final FileInputStream in = new FileInputStream(path);
        final LDIFEntryReader reader = new LDIFEntryReader(in);
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

            try {
                reader.readEntry();
                Assert.fail("reader.readEntry() should have thrown NoSuchElementException");
            } catch (NoSuchElementException e) {
                // This is expected.
        } finally {
            reader.close();
            }
    }

    /**
     * LDIFEntryReader - Try to read a full example of entry.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFEntryReaderFullEntry() throws Exception {

        // @formatter:off
        final String[] strEntry = {
            "version: 1",
            "dn: cn=Barbara Jensen, ou=Product Development, dc=airius, dc=com",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Barbara Jensen",
            "cn: Barbara J Jensen",
            "cn: Babs Jensen",
            "sn: Jensen",
            "uid: bjensen",
            "telephonenumber: +1 408 555 1212",
            "description: A big sailing fan.",
            "", // if a space here, second entry is not read
            "dn: cn=Bjorn Jensen, ou=Accounting, dc=airius, dc=com",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Bjorn Jensen",
            "sn: Jensen",
            "telephonenumber: +1 408 555 1212"
        };
        // @formatter:on
        final String path = TestCaseUtils.createTempFile(strEntry);
        final FileInputStream in = new FileInputStream(path);
        final LDIFEntryReader reader = new LDIFEntryReader(in);

        Entry entry = null;
        try {
            assertThat(reader.hasNext());
            // 1st entry
            entry = reader.readEntry();
            assertThat(entry.getName().toString()).isEqualTo(
                    "cn=Barbara Jensen, ou=Product Development, dc=airius, dc=com");
            assertThat(entry.getAttributeCount()).isEqualTo(6);
            // 2nd
            entry = reader.readEntry();
            assertThat(entry.getName().toString()).isEqualTo(
                    "cn=Bjorn Jensen, ou=Accounting, dc=airius, dc=com");
            assertThat(entry.getAttributeCount()).isEqualTo(4);

            assertThat(reader.hasNext()).isFalse();
        } finally {
            reader.close();
        }
    }

    /**
     * Testing to read an entry which containing empty required attributes.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testValueOfLDIFEntryReadStandardEntryMissingValues() throws Exception {

        // @formatter:off
        final String[] strEntry = {
            "dn: uid=user.0,ou=People,dc=example,dc=com",
            "objectClass: person",
            "objectClass: organizationalperson",
            "objectClass: top",
            "cn: Aaccf Amar",
            "sn:"
        };
        // @formatter:on
        final LDIFEntryReader reader = new LDIFEntryReader(strEntry);
        reader.setSchema(Schema.getDefaultSchema());
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());
        try {
            reader.readEntry();
        } finally {
            reader.close();
        }

    }

    /**
     * Testing to read an entry containing BER value
     * schemaValidationPolicy.checkAttributeValues().needsChecking() &&
     * attributeDescription.containsOption("binary") reply 'because it has an
     * unexpected binary option for attribute sn : 'sn;binary'.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testValueOfLDIFEntryBERUnexpectedBinaryOption() throws Exception {

        // @formatter:off
        final String[] strEntry = {
            "version: 1",
            "dn:: b3U95Za25qWt6YOoLG89QWlyaXVz",
            "# dn:: ou=<JapaneseOU>,o=Airius",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Horatio Jensen",
            "cn: Horatio N Jensen",
            "sn: Jensen",
            "uid: hjensen",
            "sn;binary:: 5bCP56yg5Y6f"
        };
        // @formatter:on

        final LDIFEntryReader reader = new LDIFEntryReader(strEntry);
        Schema schema = Schema.getCoreSchema();
        reader.setSchema(schema);
        reader.setSchemaValidationPolicy(SchemaValidationPolicy.defaultPolicy());

        try {
            reader.readEntry();
        } finally {
            reader.close();
        }

    }

    /**
     * Testing to read an entry containing a fatal continuation line at start.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testValueOfLDIFEntryFatalContinuationLineAtStart() throws Exception {

        // @formatter:off
        final String[] strEntry = {
            " This is a fatal continuation line at start",
            "dn:: b3U95Za25qWt6YOoLG89QWlyaXVz",
            "# dn:: ou=<JapaneseOU>,o=Airius",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Horatio Jensen",
            "cn: Horatio N Jensen",
            "sn: Jensen",
            "uid: hjensen"
        };
        // @formatter:on

        final LDIFEntryReader reader = new LDIFEntryReader(strEntry);
        try {
            reader.readEntry();
        } finally {
            reader.close();
        }

    }

    /**
     * LDIFEntryReader entry containing a reference to an external file.
     *
     * @throws Exception
     */
    @Test()
    public void testValueOfLDIFEntryReadEntryContainingURL() throws Exception {
        // @formatter:off
        final LDIFEntryReader reader = new LDIFEntryReader(
                "#A single comment",
                " continued in the second line",
                "version: 1",
                "dn:: b3U95Za25qWt6YOoLG89QWlyaXVz",
                "# dn:: ou=<JapaneseOU>,o=Airius",
                "objectclass: top",
                "objectclass: person",
                "objectclass: organizationalPerson",
                "cn: Horatio Jensen",
                "cn: Horatio N Jensen",
                "sn: Jensen",
                "uid: hjensen",
                "telephonenumber: +1 408 555 1212",
                "jpegphoto:< http://www.forgerock.com/sites/default/files/forgerock_logo.png",
                "#This is a end line comment", "# Followed by another"
        );
        // @formatter:on

        try {
            Entry entry = reader.readEntry();
            assertThat(entry.getName().toString()).isNotEqualTo("b3U95Za25qWt6YOoLG89QWlyaXVz");
            assertThat(entry.getAttributeCount()).isEqualTo(6);
            assertThat(entry.getAttribute("jpegphoto")).isNotEmpty();
            assertThat(entry.getAttribute("cn").firstValueAsString()).isEqualTo("Horatio Jensen");
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFEntryReader entry containing a reference to an external file & an
     * invalid protocol.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testValueOfLDIFEntryReadEntryContainingURLInvalidProtocol() throws Exception {

        // @formatter:off
        final LDIFEntryReader reader = new LDIFEntryReader(
                "version: 1",
                "dn:: b3U95Za25qWt6YOoLG89QWlyaXVz",
                "# dn:: ou=<JapaneseOU>,o=Airius",
                "objectclass: top",
                "objectclass: person",
                "objectclass: organizationalPerson",
                "cn: Horatio Jensen",
                "cn: Horatio N Jensen",
                "sn: Jensen",
                "uid: hjensen",
                "telephonenumber: +1 408 555 1212",
                "jpegphoto:< invalidProtocol",
                " ",
                " ");
        // @formatter:on

        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * Test to read an entry missing key value.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testReadEntryParseColonPositionThrowException() throws Exception {

        // @formatter:off
        final String path = TestCaseUtils.createTempFile(
                "#Entry made for testing",
                ": cn=Gern Jensen, ou=Product Testing, dc=airius, dc=com",
                "objectclass: top",
                "objectclass: person",
                "objectclass: organizationalPerson"
        );
        // @formatter:on

        final FileInputStream in = new FileInputStream(path);
        final LDIFEntryReader reader = new LDIFEntryReader(in);
        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * Test to read an entry containing base64 encoded attribute.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testReadEntryBase64EncodedMalformedBase64Attribute() throws Exception {

        // @formatter:off
        final LDIFEntryReader reader = new LDIFEntryReader(Arrays.asList(
            "version: 1",
            "dn: cn=Gern Jensen, ou=Product Testing, dc=airius, dc=com",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Gern Jensen",
            "cn: Gern O Jensen",
            "sn: Jensen",
            "uid: gernj",
            "telephonenumber: +1 408 555 1212",
            "description:: V2hhdCBhIGNhcmVmdWwgcmVhZGVyIHlvdSBhcmUhICBUaGlzIHZhbHVl"
            + "IGlzIGJhc2UtNjQtZW5aaaaaaaaaaajb2RlZCBiZWNhdXNlIGl0IGhhcyBhIGNvbnRyb2wgY2hhcmFjdG"
            + "VyIGluIGl0IChhIENSKS4NICBCeSB0aGUgd2F5LCB5b3Ugc2hvdWxkIHJlYWxseSBnZXQg"
            + "b3V0IG1vcmUu"
        ));
        // @formatter:on
        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * Test to read an entry containing base64 encoded attribute.
     *
     * @throws Exception
     */
    @Test()
    public void testReadEntryBase64Encoded() throws Exception {

        // @formatter:off
        final LDIFEntryReader reader = new LDIFEntryReader(Arrays.asList(
            "version: 1",
            "dn: cn=Gern Jensen, ou=Product Testing, dc=airius, dc=com",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Gern Jensen",
            "cn: Gern O Jensen",
            "sn: Jensen",
            "uid: gernj",
            "telephonenumber: +1 408 555 1212",
            "description:: V2hhdCBhIGNhcmVmdWwgcmVhZGVyIHlvdSBhcmUhICBUaGlzIHZhbHVl"
            + "IGlzIGJhc2UtNjQtZW5jb2RlZCBiZWNhdXNlIGl0IGhhcyBhIGNvbnRyb2wgY2hhcmFjdG"
            + "VyIGluIGl0IChhIENSKS4NICBCeSB0aGUgd2F5LCB5b3Ugc2hvdWxkIHJlYWxseSBnZXQg"
            + "b3V0IG1vcmUu")
        );
        // @formatter:on

        try {
            assertThat(reader.hasNext());
            final Entry entry = reader.readEntry();
            assertThat(entry).isNotNull();
            assertThat(entry.getAttributeCount()).isEqualTo(6);
            // Verifying second occurrence of is not taken into account
            assertThat(entry.getAttribute("cn").firstValueAsString()).isEqualTo("Gern Jensen");
            // Verifying decoding is enabled on description attribute
            assertThat(entry.getAttribute("description").firstValueAsString())
                    .isNotSameAs(
                            "V2hhdCBhIGNhcmVmdWwgcmVhZGVyIHlvdSBhcmUhICBUaGlzIHZhbHVl"
                                    + "IGlzIGJhc2UtNjQtZW5jb2RlZCBiZWNhdXNlIGl0IGhhcyBhIGNvbnRyb2wgY2hhcmFjdG"
                                    + "VyIGluIGl0IChhIENSKS4NICBCeSB0aGUgd2F5LCB5b3Ugc2hvdWxkIHJlYWxseSBnZXQg"
                                    + "b3V0IG1vcmUu");
            assertThat(entry.getAttribute("description").firstValueAsString()).contains(
                    "What a careful reader you are!");
        } finally {
            reader.close();
        }
    }

    /**
     * Test to read an entry containing base64 encoded attribute.
     *
     * @throws Exception
     */
    @Test()
    public void testReadEntryBase64EncodedDN() throws Exception {

        // @formatter:off
        final LDIFEntryReader reader = new LDIFEntryReader(Arrays.asList(
            "dn::  dWlkPXJvZ2FzYXdhcmEsb3U95Za25qWt6YOoLG89QWlyaXVz", // adding space before ok, after : ko
            "# dn:: uid=<uid>,ou=<JapaneseOU>,o=Airius",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Gern Jensen",
            "cn: Gern O Jensen",
            "sn: Jensen",
            "uid: gernj"
        ));
        // @formatter:on
        try {
            assertThat(reader.hasNext());
            final Entry entry = reader.readEntry();
            assertThat(reader.hasNext()).isFalse();
            assertThat(entry.getName().toString()).isEqualTo("uid=rogasawara,ou=営業部,o=Airius");
        } finally {
            reader.close();
        }
    }

    /**
     * Test to read an entry containing base64 encoded DN. DN base64 encoded is
     * malformed. Must throw an error.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = DecodeException.class)
    public void testReadEntryBase64EncodedDNMalformedThrowsError() throws Exception {

        // @formatter:off
        final LDIFEntryReader reader = new LDIFEntryReader(Arrays.asList(
            "dn:: dWlkPXJvZ2FzYXdh!!!OOOpppps!!!25qWt6YOoLG89QWlyaXVz",
            "# dn:: uid=<uid>,ou=<JapaneseOU>,o=Airius",
            "objectclass: top",
            "objectclass: person",
            "objectclass: organizationalPerson",
            "cn: Gern Jensen",
            "cn: Gern O Jensen",
            "sn: Jensen",
            "uid: gernj"
        ));
        // @formatter:on

        try {
            reader.readEntry();
        } finally {
            reader.close();
        }
    }

    /**
     * Test LDIFEntryReader reading a LDIF entry via EntryAsArray.
     *
     * @throws Exception
     */
    @Test()
    public void testLDIFEntryReaderEntryAsArray() throws Exception {

        final LDIFEntryReader reader = new LDIFEntryReader(Arrays.asList(getStandardEntry()));

        try {
            assertThat(reader.hasNext());
            assertThat(reader.readEntry().getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
        } finally {
            reader.close();
        }
    }

    /**
     * LDIFEntryReader cause NullPointerException when InputStream is null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testLDIFEntryReaderInpuStreamDoesntAllowNull() throws Exception {
        final InputStream is = null;
        LDIFEntryReader reader = new LDIFEntryReader(is);
    }

    /**
     * LDIFEntryReader read cause IOException.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = IOException.class)
    public void testReadEntryThrowsIOException() throws Exception {

        final FileInputStream mockIn = mock(FileInputStream.class);
        final LDIFEntryReader reader = new LDIFEntryReader(mockIn);

        doThrow(new IOException()).when(mockIn).read();
        try {
            reader.readEntry();
        } finally {
            reader.close();
            verify(mockIn, times(1)).close();
        }
    }

    /**
     * LDIFEntryReader ValueOfLDIFEntry - Multiple change records found.
     * Exception LocalizedIllegalArgumentException expected.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testValueOfLDIFEntryMultipleChangeRecordFound() throws Exception {

        // @formatter:off
        final Entry entry = LDIFEntryReader.valueOfLDIFEntry(
            "#This is an example test",
            "dn: CN=John Smith,OU=Legal,DC=example,DC=com",
            "changetype: modify",
            "replace:employeeID",
            "employeeID: 1234",
            "",
            "dn: CN=Jane Smith,OU=Accounting,DC=example,DC=com",
            "changetype: modify",
            "replace:employeeID",
            "employeeID: 5678"
        );
        // @formatter:on
    }

    /**
     * LDIFEntryReader ValueOfLDIFEntry throws exception when a single comment
     * inserted.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testValueOfLDIFEntryThrowsExceptionIfOnlyAComment() throws Exception {
        LDIFEntryReader.valueOfLDIFEntry("#This is an example test");
    }

    /**
     * Test of valueOfLDIFEntry using malformed LDIF. Must return an
     * LocalizedIllegalArgumentException In this case, dn is missing.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = LocalizedIllegalArgumentException.class)
    public void testValueOfLDIFEntryMalformedEntry() throws Exception {

        // @formatter:off
        LDIFEntryReader.valueOfLDIFEntry(
                "objectClass: top",
                "objectClass: person",
                "objectClass: organizationalperson",
                "objectClass: inetorgperson"
        );
        // @formatter:on
    }

    /**
     * Test of valueOfLDIFEntry using well formed entry.
     *
     * @throws Exception
     */
    @Test()
    public void testValueOfLDIFEntryWellFormedEntry() throws Exception {
        // @formatter:off
        final Entry entry = LDIFEntryReader.valueOfLDIFEntry(
                "dn: uid=user.0,ou=People,dc=example,dc=com",
                "objectClass: top",
                "objectClass: person",
                "objectClass: organizationalperson",
                "objectClass: inetorgperson"
        );
        // @formatter:on

        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttributeCount()).isEqualTo(1);
    }

    /**
     * Test LDIFEntryReader valueOfLDIFEntry on the standard entry and verify if
     * all the attributes are well read.
     *
     * @throws Exception
     */
    @Test()
    public void testValueOfLDIFEntryReadStandardEntry() throws Exception {

        final Entry entry = LDIFEntryReader.valueOfLDIFEntry(getStandardEntry());

        assertThat(entry).isNotNull();
        assertThat(entry.getName()).isNotNull();
        assertThat(entry.getName().toString()).isEqualTo("uid=user.0,ou=People,dc=example,dc=com");
        assertThat(entry.getAttribute("sn").firstValue().toString()).isEqualTo("Amar");
        assertThat(entry.getAttributeCount()).isEqualTo(nbStandardEntryAttributes);
    }

    /**
     * LDIFReader valueOfLDIFEntry doesn't allow null.
     *
     * @throws Exception
     */
    @Test(expectedExceptions = NullPointerException.class)
    public void testValueOfLDIFEntryDoesntAllowNull() throws Exception {
        LDIFEntryReader reader = new LDIFEntryReader();
        try {
            reader.valueOfLDIFEntry(null);
        } finally {
            reader.close();
        }