Metacat

import java.util.Date;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import edu.ucsb.nceas.metacat.AccessionNumberException;

import edu.ucsb.nceas.metacat.IdentifierManager;

import edu.ucsb.nceas.metacat.McdbDocNotFoundException;

import edu.ucsb.nceas.metacat.properties.PropertyService;

import edu.ucsb.nceas.metacat.shared.ServiceException;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

public class SyncAccessPolicy {

	private static Logger logMetacat = Logger.getLogger(SyncAccessPolicy.class);

	/**

	 * Synchronize access policy (from system metadata) of d1 member node with

	 * the corresponding controlling node.

		CNode cn = D1Client.getCN();

			objInfo = objList.getObjectInfo(i);

			pid = objInfo.getIdentifier();

			try {

				// Get sm, access policy for requested localId

				mnSysMeta = IdentifierManager.getInstance().getSystemMetadata(

						+ pid.getValue() + e.getMessage());

			}

			mnAccessPolicy = mnSysMeta.getAccessPolicy();

			// mnSysMeta.getIdentifier().toString());

			// Get sm, access policy for requested pid from the CN

			try {

				cnSysMeta = cn.getSystemMetadata(pid);

				logMetacat.error("Error getting system metadata for pid: "

						+ pid.getValue() + " from cn: " + e.getMessage());

			}

			cnAccessPolicy = cnSysMeta.getAccessPolicy();

			if (!isEqual(mnAccessPolicy, cnAccessPolicy)) {

				try {

					BigInteger serialVersion = cnSysMeta.getSerialVersion();

							serialVersion.longValue());

					syncedIds.add(pid);

				} catch (Exception e) {

					logMetacat.error("Error setting access policy of pid: "

				}

			}

		}

		return syncedIds;

		ObjectFormatIdentifier objectFormatId = null;

		Boolean replicaStatus = false; // return only pids for which this mn is

										// authoritative

		ObjectList objsToSync = IdentifierManager.getInstance()

				.querySystemMetadata(startTime, endTime, objectFormatId,

	 *            - first access policy in the comparison

	 * @param ap2

	 *            - second access policy in the comparison

	 */

	private boolean isEqual(AccessPolicy ap1, AccessPolicy ap2) {

		// Get the list of access rules for each access policy

		List<org.dataone.service.types.v1.AccessRule> allowList1 = ap1

				.getAllowList();

		// Load the permissions from the access rules into a hash of sets, i.e.,

		// so that we end up with this:

		// ----------------------------

		// user1: read, write

		// user2: read

		// With the permissions in this structure, they can be easily compared

		Set<Permission> perms = null;

		// Process first access policy

		for (org.dataone.service.types.v1.AccessRule accessRule : allowList1) {

			for (Subject s : accessRule.getSubjectList()) {

				if (userPerms1.containsKey(s)) {

				for (Permission p : accessRule.getPermissionList()) {

					perms.add(p);

				}

			}

		}

				for (Permission p : accessRule.getPermissionList()) {

					perms.add(p);

				}

			}

		}

		// Now perform the comparison. This test assumes that the mn perms are

		// more

		// complete than the cn perms.

		for (Map.Entry<Subject, Set<Permission>> entry : userPerms1.entrySet()) {

			// User name

			Subject s1 = entry.getKey();

			// Perms that the user holds

			if (userPerms2.containsKey(s1)) {

					return false;

				}

			} else {

				return false;

			}

		}

		// All comparisons have been passed, so the two access policies are

		// equivalent

		return true;

	}

			try {

				guids = new ArrayList<String>(Arrays.asList(args[0]

						.split("\\s*,\\s*")));

						+ args[0]);

				syncAP.sync(guids);

			} catch (Exception e) {

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Timestamp;

import java.util.Calendar;

import java.util.Date;

import java.util.Hashtable;

import java.util.Timer;

import java.util.Vector;

import org.apache.log4j.Logger;

import org.dataone.client.RestClient;

import org.dataone.client.auth.CertificateManager;

import org.dataone.service.types.v1.SystemMetadata;

import org.dataone.service.util.DateTimeMarshaller;

import org.dataone.service.util.TypeMarshaller;

import edu.ucsb.nceas.metacat.database.DBConnection;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.database.DatabaseService;

import edu.ucsb.nceas.metacat.dataone.hazelcast.HazelcastService;

import edu.ucsb.nceas.metacat.index.MetacatSolrIndex;

import edu.ucsb.nceas.metacat.properties.PropertyService;

				rir.upgrade();

				out.write("Removed invalid replicas for server " + serverid);

			} else {

				out.write("<error>Unkonwn subaction</error>");

				out.write("<td><b>ORE Maps</b></td>");

				out.write("<td><b>Invalid Replicas</b></td>");

			}

			out.write("</tr>");

			pstmt = dbConn.prepareStatement("SELECT serverid, server, last_checked, replicate, datareplicate, hub FROM xml_replication");

					out.write("<input type='submit' value='Remove Invalid Replicas' " + disabled + " />");

					out.write("</form></td>");

				}

				out.write("</tr>");

				tablehasrows = rs.next();