Metacat

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

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

import edu.ucsb.nceas.metacat.EventLog;

import edu.ucsb.nceas.metacat.IdentifierManager;

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

      throws NotImplemented, NotFound, NotAuthorized, ServiceFailure, 

      InvalidRequest, InvalidToken {

      // get the subject

      Subject subject = session.getSubject();

      SystemMetadata systemMetadata = null;

      try {

          systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

        systemMetadata.setSerialVersion(systemMetadata.getSerialVersion().add(BigInteger.ONE));

        systemMetadata.setDateSysMetadataModified(Calendar.getInstance().getTime());

        HazelcastService.getInstance().getSystemMetadataMap().put(systemMetadata.getIdentifier(), systemMetadata);

      } catch (Exception e) {

          throw new ServiceFailure("4882", e.getMessage());

      } finally {

      }

      throws ServiceFailure, NotImplemented, InvalidToken, NotAuthorized, 

      InvalidRequest, NotFound {

      boolean allowed = false;

      int replicaEntryIndex = -1;

      List<Replica> replicas = null;

      SystemMetadata systemMetadata = null;

      try {      

          systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

          if ( systemMetadata == null ) {

          systemMetadata.setSerialVersion(systemMetadata.getSerialVersion().add(BigInteger.ONE));

          systemMetadata.setDateSysMetadataModified(Calendar.getInstance().getTime());

          HazelcastService.getInstance().getSystemMetadataMap().put(systemMetadata.getIdentifier(), systemMetadata);

      } catch (Exception e) {

          throw new ServiceFailure("4700", e.getMessage());

      } finally {

      }

    throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, 

    InvalidRequest, NotImplemented {

    boolean asserted = false;

    // are we allowed to do this?

    SystemMetadata systemMetadata = null;

    try {

        systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pidOfSubject);

        }

          //return systemMetadata.getObsoletedByList().contains(pidOfObject);

        }

    } catch (Exception e) {

        throw new ServiceFailure("4270", "Could not assert relation for: " + 

            pidOfSubject.getValue() +

            ". The error message was: " + e.getMessage());

    } finally {

    }

    throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, 

    NotImplemented {

    if (!isAuthorized(session, pid, Permission.READ)) {

        throw new NotAuthorized("1400", Permission.READ + " not allowed on " + pid.getValue());  

    }

    Checksum checksum = null;

    try {

        systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

        checksum = systemMetadata.getChecksum();

    } catch (Exception e) {

        throw new ServiceFailure("1410", "An error occurred getting the checksum for " + 

            pid.getValue() + ". The error message was: " + e.getMessage());

    } finally {

    }

      throws NotImplemented, NotAuthorized, ServiceFailure, InvalidRequest, 

      InvalidSystemMetadata {

      // TODO: control who can call this?

      if (session == null) {

          //TODO: many of the thrown exceptions do not use the correct error codes

      // insert the system metadata into the object store

      logMetacat.debug("Starting to insert SystemMetadata...");

      try {

          sysmeta.setSerialVersion(BigInteger.ONE);

          sysmeta.setDateSysMetadataModified(Calendar.getInstance().getTime());

          HazelcastService.getInstance().getSystemMetadataMap().put(sysmeta.getIdentifier(), sysmeta);

      } catch (Exception e) {

        logMetacat.error("Problem registering system metadata: " + pid.getValue(), e);

              e.getClass() + ": " + e.getMessage());

      } finally {

      }

      throws InvalidToken, ServiceFailure, NotFound, NotAuthorized,

      NotImplemented, InvalidRequest {

      // get the subject

      Subject subject = session.getSubject();

      SystemMetadata systemMetadata = null;

      try {

          systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

          // does the request have the most current system metadata?

          systemMetadata.setSerialVersion(systemMetadata.getSerialVersion().add(BigInteger.ONE));

          systemMetadata.setDateSysMetadataModified(Calendar.getInstance().getTime());

          HazelcastService.getInstance().getSystemMetadataMap().put(pid, systemMetadata);

      } catch (Exception e) {

      throw new ServiceFailure("4490", e.getMessage());

      } finally {

      }

      return pid;

    throws NotImplemented, NotAuthorized, InvalidToken, ServiceFailure, 

    NotFound, InvalidRequest {

    boolean isAllowed = false;

    SystemMetadata sysmeta = null;

    NodeReference targetNode = null;

      }

      //lock, get, and unlock the pid

      logMetacat.debug("Getting system metadata for identifier " + pid.getValue());

      sysmeta = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

          " is null.");          

      }

    } catch (RuntimeException e) {

    	  ServiceFailure sf = new ServiceFailure("4872", 

    } finally {

      // always unlock the pid

    }

    NotImplemented, InvalidRequest {

      try {

        // are we allowed?

          boolean isAllowed = false;

          // proceed if we're called by a CN

          if ( isAllowed ) {

              // create the coordinating node version of the document      

              sysmeta.setSerialVersion(BigInteger.ONE);

              sysmeta.setDateSysMetadataModified(Calendar.getInstance().getTime());

              pid = super.create(session, pid, object, sysmeta);

          } else {

              String msg = "The subject listed as " + session.getSubject().getValue() + 

          throw new ServiceFailure("4893", msg);

      } finally {

      }

      throws InvalidToken, ServiceFailure, NotFound, NotAuthorized, 

      NotImplemented, InvalidRequest {

      boolean success = false;

      // get the subject

      SystemMetadata systemMetadata = null;

      try {

          systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

          // does the request have the most current system metadata?

          systemMetadata.setSerialVersion(systemMetadata.getSerialVersion().add(BigInteger.ONE));

          systemMetadata.setDateSysMetadataModified(Calendar.getInstance().getTime());

          HazelcastService.getInstance().getSystemMetadataMap().put(systemMetadata.getIdentifier(), systemMetadata);

      } catch (Exception e) {

          // convert Hazelcast RuntimeException to ServiceFailure

          throw new ServiceFailure("4430", e.getMessage());

      } finally {

      }

      throws NotImplemented, NotAuthorized, ServiceFailure, InvalidRequest,

      NotFound {

      // get the subject

      Subject subject = session.getSubject();

      SystemMetadata systemMetadata = null;

      try {      

          systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

          // does the request have the most current system metadata?

          systemMetadata.setSerialVersion(systemMetadata.getSerialVersion().add(BigInteger.ONE));

          systemMetadata.setDateSysMetadataModified(Calendar.getInstance().getTime());

          HazelcastService.getInstance().getSystemMetadataMap().put(systemMetadata.getIdentifier(), systemMetadata);

      } catch (Exception e) {

          throw new ServiceFailure("4852", e.getMessage());

      } finally {

      }

import com.hazelcast.core.EntryEvent;

import com.hazelcast.core.EntryListener;

import com.hazelcast.core.Hazelcast;

import com.hazelcast.core.IMap;

import com.hazelcast.core.InstanceEvent;

import com.hazelcast.core.InstanceListener;

  /* The Hazelcast distributed system metadata map */

  private IMap<Identifier, SystemMetadata> systemMetadata;

  /*

   * Constructor: Creates an instance of the hazelcast service. Since

   * this uses a singleton pattern, use getInstance() to gain the instance.

  public IMap<Identifier,SystemMetadata> getSystemMetadataMap() {

	  return systemMetadata;

  }

  /**

   * Get the DataONE hazelcast node map