/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (the "License"). You may not use this file except in compliance
* with the License.
*
* You can obtain a copy of the license at
* trunk/opends/resource/legal-notices/OpenDS.LICENSE
* or https://OpenDS.dev.java.net/OpenDS.LICENSE.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at
* trunk/opends/resource/legal-notices/OpenDS.LICENSE. If applicable,
* add the following below this CDDL HEADER, with the fields enclosed
* by brackets "[]" replaced with your own identifying information:
* Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*
*
* Copyright 2010 Sun Microsystems, Inc.
*/
import netscape.ldap.*;
import netscape.ldap.util.*;
import java.util.ArrayList;
class Change {
int changeNumber = 0;
String changelogCookie = null;
CSN csn;
String type = "";
String dn = "";
ArrayList<String> changes = new ArrayList<String>(2);
String change = "";
String replicaIdentifier = null;
String changeNumberValue = null;
String nsUniqueId = "";
boolean deleteOldRDN = false;
String newRDN = null;
String newSuperior = null;
public Change(LDAPEntry entry) throws Exception {
LDAPAttribute attr = entry.getAttribute("replicaIdentifier");
if ( attr == null ) {
throw new Exception("No value found for replicaIdentifier");
}
replicaIdentifier = attr.getStringValueArray()[0];
attr = entry.getAttribute("changeNumber");
if ( attr == null ) {
throw new Exception("No value found for changeNumber");
}
changeNumberValue = attr.getStringValueArray()[0];
changeNumber = Integer.parseInt(changeNumberValue);
attr = entry.getAttribute("changelogCookie");
if ( attr != null ) {
changelogCookie = attr.getStringValueArray()[0];
}
attr = entry.getAttribute("replicationCSN");
if ( attr == null ) {
throw new Exception("No value found for replicationCSN");
}
csn = new CSN(attr.getStringValueArray()[0]);
attr = entry.getAttribute("targetDN");
if ( attr == null ) {
throw new Exception("No value found for targetDN");
}
dn = attr.getStringValueArray()[0];
attr = entry.getAttribute("changeType");
if ( attr == null ) {
throw new Exception("No value found for changeType");
}
type = attr.getStringValueArray()[0];
// attr = entry.getAttribute("targetUniqueId");
// if ( attr == null ) {
// throw new Exception("No value found for targetUniqueId");
// }
// nsUniqueId=attr.getStringValueArray()[0];
attr = entry.getAttribute("targetEntryUUID");
if ( attr == null ) {
throw new Exception("No value found for targetEntryUUID");
}
nsUniqueId = attr.getStringValueArray()[0];
// modrdn
if ( type.equals("modrdn") ) {
attr = entry.getAttribute("deleteOldRDN");
if ( attr == null ) {
throw new Exception("No value found for deleteOldRDN");
}
deleteOldRDN = Boolean.getBoolean(attr.getStringValueArray()[0]);
attr = entry.getAttribute("newRDN");
if ( attr == null ) {
throw new Exception("No value found for newRDN");
}
newRDN = attr.getStringValueArray()[0];
attr = entry.getAttribute("newSuperior");
if ( attr != null ) {
newSuperior=attr.getStringValueArray()[0];
}
}
// Conflict
attr = entry.getAttribute("changeHasReplFixupOp");
if ( attr != null ) {
change = attr.getStringValueArray()[0];
if ( change.trim().endsWith("-") ) {
change = change.substring(0, change.length()-3) + "\r\n";
}
String changeHasReplFixupOp=change.replaceFirst("targetDn", "dn") + "\r\n";
// println ("INFO", "FixupOp (csn="+ csn+"):\n" + changeHasReplFixupOp);
changes.add(changeHasReplFixupOp);
}
attr = entry.getAttribute("changes");
if ( attr != null ) {
change = attr.getStringValueArray()[0];
if ( change.trim().endsWith("-") ) {
change = change.substring(0, change.length()-3) + "\r\n";
}
}
if ( type.equals("modify") && ( change.equals("") ) ) {
throw new Exception("Attribute changes is empty - replicationCSN="+ csn);
//EclReadAndPlay.accessOut.println (getDate() + "- WARNING: Ignore change csn=" + csn );
}
String myChange = "dn: " + dn + "\n" +
"changetype: " + type + "\n" +
change +"\n";
changes.add(myChange);
changes.trimToSize();
}
public String toString() {
return ("change number " + changeNumber + " (csn="+csn +")");
}
}