Metacat

   * Deletes an object from the Coordinating Node, where the object is a 

   * a science metadata object.

   * 

   * @param session - the Session object containing the credentials for the Subject

   * @param pid - The object identifier to be deleted

   * 

   * @return pid - the identifier of the object used for the deletion

   * 

   * @throws InvalidToken

   * @throws ServiceFailure

   * @throws NotAuthorized

   * @throws NotFound

   * @throws NotImplemented

   * @throws InvalidRequest

   */

  @Override

  public Identifier archive(Session session, Identifier pid) 

      throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, NotImplemented {

	  // check that it is CN/admin

	  boolean allowed = isAdminAuthorized(session);

	  if (!allowed) {

		  String msg = "The subject is not allowed to call delete() on a Coordinating Node.";

		  logMetacat.info(msg);

		  throw new NotAuthorized("1320", msg);

	  }

	  // defer to superclass implementation

	  Identifier retId =  super.archive(session, pid);

	  // notify the replicas

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

	  if (systemMetadata.getReplicaList() != null) {

		  for (Replica replica: systemMetadata.getReplicaList()) {

			  NodeReference replicaNode = replica.getReplicaMemberNode();

			  try {

				  // TODO: implement in the clients

				  //Identifier mnRetId = D1Client.getMN(replicaNode).archive(null, pid);

			  } catch (Exception e) {

				  // all we can really do is log errors and carry on with life

				  logMetacat.error("Error archiving pid: " +  pid.getValue() + " from replica MN: " + replicaNode.getValue(), e);

			}

		  }

	  }

	  return retId;

  }

  /**

/**

   * Archives an object, where the object is either a 

   * data object or a science metadata object.

   * 

   * @param session - the Session object containing the credentials for the Subject

   * @param pid - The object identifier to be archived

   * 

   * @return pid - the identifier of the object used for the archiving

   * 

   * @throws InvalidToken

   * @throws ServiceFailure

   * @throws NotAuthorized

   * @throws NotFound

   * @throws NotImplemented

   * @throws InvalidRequest

   */

  public Identifier archive(Session session, Identifier pid) 

      throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, NotImplemented {

      String localId = null;

      boolean allowed = false;

      String username = Constants.SUBJECT_PUBLIC;

      String[] groupnames = null;

      if (session == null) {

      	throw new InvalidToken("1330", "No session has been provided");

      } else {

          username = session.getSubject().getValue();

          if (session.getSubjectInfo() != null) {

              List<Group> groupList = session.getSubjectInfo().getGroupList();

              if (groupList != null) {

                  groupnames = new String[groupList.size()];

                  for (int i = 0; i > groupList.size(); i++) {

                      groupnames[i] = groupList.get(i).getGroupName();

                  }

              }

          }

      }

      // do we have a valid pid?

      if (pid == null || pid.getValue().trim().equals("")) {

          throw new ServiceFailure("1350", "The provided identifier was invalid.");

      }

      // check for the existing identifier

      try {

          localId = IdentifierManager.getInstance().getLocalId(pid.getValue());

      } catch (McdbDocNotFoundException e) {

          throw new NotFound("1340", "The object with the provided " + "identifier was not found.");

      }

      // does the subject have archive (a D1 CHANGE_PERMISSION level) privileges on the pid?

      try {

			allowed = isAuthorized(session, pid, Permission.CHANGE_PERMISSION);

		} catch (InvalidRequest e) {

          throw new ServiceFailure("1350", e.getDescription());

		}

      if (allowed) {

          try {

              // archive the document

        	  // this method just archives it in metacat

              DocumentImpl.delete(localId, username, groupnames, null);

              EventLog.getInstance().log(request.getRemoteAddr(), request.getHeader("User-Agent"), username, localId, Event.DELETE.xmlValue());

              // archive it

              SystemMetadata sysMeta = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

              sysMeta.setArchived(true);

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

          } catch (McdbDocNotFoundException e) {

              throw new NotFound("1340", "The provided identifier was invalid.");

          } catch (SQLException e) {

              throw new ServiceFailure("1350", "There was a problem archiving the object." + "The error message was: " + e.getMessage());

          } catch (InsufficientKarmaException e) {

              throw new NotAuthorized("1320", "The provided identity does not have " + "permission to archive this object.");

          } catch (Exception e) { // for some reason DocumentImpl throws a general Exception

              throw new ServiceFailure("1350", "There was a problem archiving the object." + "The error message was: " + e.getMessage());

          }

      } else {

          throw new NotAuthorized("1320", "The provided identity does not have " + "permission to archive the object on the Node.");

      }

      return pid;

  }