Metacat

/**

 *  '$RCSfile$'

 *  Copyright: 2000-2011 Regents of the University of California and the

 *              National Center for Ecological Analysis and Synthesis

 *

 *   '$Author:  $'

 *     '$Date:  $'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

package edu.ucsb.nceas.metacat.dataone;

import java.io.InputStream;

import java.util.Date;

import org.apache.log4j.Logger;

import org.dataone.service.exceptions.IdentifierNotUnique;

import org.dataone.service.exceptions.InsufficientResources;

import org.dataone.service.exceptions.InvalidRequest;

import org.dataone.service.exceptions.InvalidSystemMetadata;

import org.dataone.service.exceptions.InvalidToken;

import org.dataone.service.exceptions.NotAuthorized;

import org.dataone.service.exceptions.NotFound;

import org.dataone.service.exceptions.NotImplemented;

import org.dataone.service.exceptions.ServiceFailure;

import org.dataone.service.exceptions.UnsupportedType;

import org.dataone.service.mn.tier1.MNCore;

import org.dataone.service.mn.tier1.MNRead;

import org.dataone.service.mn.tier2.MNAuthorization;

import org.dataone.service.mn.tier3.MNStorage;

import org.dataone.service.mn.tier4.MNReplication;

import org.dataone.service.types.AccessPolicy;

import org.dataone.service.types.Checksum;

import org.dataone.service.types.DescribeResponse;

import org.dataone.service.types.Event;

import org.dataone.service.types.Identifier;

import org.dataone.service.types.Log;

import org.dataone.service.types.MonitorList;

import org.dataone.service.types.Node;

import org.dataone.service.types.NodeReference;

import org.dataone.service.types.ObjectFormat;

import org.dataone.service.types.ObjectList;

import org.dataone.service.types.Permission;

import org.dataone.service.types.Session;

import org.dataone.service.types.Subject;

import org.dataone.service.types.SystemMetadata;

/**

 * Represents Metacat's implementation of the DataONE Member Node 

 * service API. Methods implement the various MN* interfaces, and methods common

 * to both Member Node and Coordinating Node interfaces are found in the

 * D1NodeService base class.

 */

public class MNodeService extends D1NodeService implements MNAuthorization,

  MNCore, MNRead, MNReplication, MNStorage {

	/* the instance of the MNodeService object */

  private static MNodeService instance = null;

  /* the logger instance */

  private Logger logMetacat = null;

  /**

   * singleton accessor

   */

  public static MNodeService getInstance() 

  {

    if (instance == null) {

      instance = new MNodeService();

    }

    return instance;

  }

  /**

   * Constructor, private for singleton access

   */

  private MNodeService() {

  	super();

    logMetacat = Logger.getLogger(MNodeService.class);

  }

	/**

	 * Adds a new object to the Member Node, where the object is either a data 

	 * object or a science metadata object. This method is called by clients 

	 * to create new data objects on Member Nodes

	 * 

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

	 * @param pid - The object identifier to be created

	 * @param object - the object bytes

	 * @param sysmeta - the system metadata that describes the object  

	 * 

	 * @return pid - the object identifier created

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws IdentifierNotUnique

	 * @throws UnsupportedType

	 * @throws InsufficientResources

	 * @throws InvalidSystemMetadata

	 * @throws NotImplemented

	 * @throws InvalidRequest

	 */

  @Override

	public Identifier create(Session session, Identifier pid, InputStream object,

	  SystemMetadata sysmeta) 

    throws InvalidToken, ServiceFailure, NotAuthorized, IdentifierNotUnique, 

    UnsupportedType, InsufficientResources, InvalidSystemMetadata, 

    NotImplemented, InvalidRequest {

		return null;

	}

	/**

	 * Deletes an object from the Member Node, 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 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 delete(Session session, Identifier pid) 

    throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, 

    NotImplemented, InvalidRequest {

		return null;

	}

  /**

   * Updates an existing object by creating a new object identified by 

   * newPid on the Member Node which explicitly obsoletes the object 

   * identified by pid through appropriate changes to the SystemMetadata 

   * of pid and newPid

   * 

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

	 * @param pid - The identifier of the object to be updated

	 * @param object - the new object bytes

	 * @param sysmeta - the new system metadata describing the object

	 * 

	 * @return newPid - the identifier of the new object

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotFound

	 * @throws NotImplemented

	 * @throws IdentifierNotUnique

	 * @throws UnsupportedType

	 * @throws InsufficientResources

	 * @throws InvalidSystemMetadata

	 * @throws InvalidRequest

   */

  @Override

	public Identifier update(Session session, Identifier pid, InputStream object,

	  Identifier newPid, SystemMetadata sysmeta) 

    throws InvalidToken, ServiceFailure, NotAuthorized, IdentifierNotUnique, 

    UnsupportedType, InsufficientResources, NotFound, InvalidSystemMetadata, 

    NotImplemented, InvalidRequest {

		return null;

	}

  /**

   * Called by a Coordinating Node to request that the Member Node create a 

   * copy of the specified object by retrieving it from another Member 

   * Node and storing it locally so that it can be made accessible to 

   * the DataONE system.

   * 

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

	 * @param sysmeta - Copy of the CN held system metadata for the object

	 * @param sourceNode - A reference to node from which the content should be 

	 *                     retrieved. The reference should be resolved by 

	 *                     checking the CN node registry.

	 * 

	 * @return true if the replication succeeds

	 * 

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 * @throws UnsupportedType

	 * @throws InsufficientResources

	 * @throws InvalidRequest

   */

  @Override

	public boolean replicate(Session session, SystemMetadata sysmeta, 

	  NodeReference sourceNode)

	  throws NotImplemented, ServiceFailure, NotAuthorized, InvalidRequest,

	  InsufficientResources, UnsupportedType {

		return false;

	}

  /**

   * This method provides a lighter weight mechanism than 

   * MN_read.getSystemMetadata() for a client to determine basic 

   * properties of the referenced object.

   * 

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

	 * @param pid - the identifier of the object to be described

	 * 

	 * @return describeResponse - A set of values providing a basic description 

	 *                            of the object.

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotFound

	 * @throws NotImplemented

	 * @throws InvalidRequest

   */

  @Override

	public DescribeResponse describe(Session session, Identifier pid)

	  throws InvalidToken, ServiceFailure, NotAuthorized, NotFound,

	  NotImplemented, InvalidRequest {

		return null;

	}

	/**

	 * Return the object identified by the given object identifier

	 * 

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

	 * @param pid - the object identifier for the given object

	 * 

	 * @return inputStream - the input stream of the given object

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

  @Override

	public InputStream get(Session session, Identifier pid) 

	  throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, 

	  NotImplemented, InvalidRequest {

		return super.get(session, pid);

	}

	/**

	 * Returns a Checksum for the specified object using an accepted hashing algorithm

	 * 

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

	 * @param pid - the object identifier for the given object

	 * @param algorithm -  the name of an algorithm that will be used to compute 

	 *                     a checksum of the bytes of the object

	 * 

	 * @return inputStream - the input stream of the given object

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotFound

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

  @Override

	public Checksum getChecksum(Session session, Identifier pid, String algorithm)

	  throws InvalidToken, ServiceFailure, NotAuthorized, NotFound,

	  InvalidRequest, NotImplemented {

		return null;

	}

	/**

	 * Return the system metadata for a given object

	 * 

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

	 * @param pid - the object identifier for the given object

	 * 

	 * @return inputStream - the input stream of the given system metadata object

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotFound

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

  @Override

	public SystemMetadata getSystemMetadata(Session session, Identifier pid)

	    throws InvalidToken, ServiceFailure, NotAuthorized, NotFound,

	    InvalidRequest, NotImplemented {

		return super.getSystemMetadata(session, pid);

	}

	/**

	 * Retrieve the list of objects present on the MN that match the calling parameters

	 * 

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

	 * @param startTime - Specifies the beginning of the time range from which 

	 *                    to return object (>=)

	 * @param endTime - Specifies the beginning of the time range from which 

	 *                  to return object (>=)

	 * @param objectFormat - Restrict results to the specified object format

	 * @param replicaStatus - Indicates if replicated objects should be returned in the list

	 * @param start - The zero-based index of the first value, relative to the 

	 *                first record of the resultset that matches the parameters.

	 * @param count - The maximum number of entries that should be returned in 

	 *                the response. The Member Node may return less entries 

	 *                than specified in this value.

	 * 

	 * @return objectList - the list of objects matching the criteria

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

  @Override

	public ObjectList listObjects(Session session, Date startTime, Date endTime,

	  ObjectFormat objectFormat, Boolean replicaStatus, Integer start, Integer count)

	  throws NotAuthorized, InvalidRequest, NotImplemented, ServiceFailure,

	  InvalidToken {

		return null;

	}

	/**

	 * Retrieve the list of objects present on the MN that match the calling parameters

	 * 

	 * @return node - the technical capabilities of the Member Node

	 * 

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

  @Override

	public Node getCapabilities() throws NotImplemented, NotAuthorized,

	    ServiceFailure, InvalidRequest {

		// TODO Auto-generated method stub

		return null;

	}

	/**

	 * Return the log records associated with a given event between the start and 

	 * end dates listed given a particular Subject listed in the Session

	 * 

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

	 * @param fromDate - the start date of the desired log records

	 * @param event - Return only log records for the specified type of event. Default is all.

	 * @param start - zero based offset from the first record in the 

	 *                set of matching log records. Used to assist with 

	 *                paging the response.

	 * @param count - maximum number of log records to return in the response. 

	 *                Used to assist with paging the response.

	 *                

	 * @return log - the log records requested

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

  @Override

	public Log getLogRecords(Session session, Date fromDate, Date toDate, Event event,

	  Integer start, Integer count)

    throws InvalidToken, ServiceFailure, NotAuthorized, InvalidRequest, 

    NotImplemented {

		return null;

	}

	/**

	 * Returns the number of operations that have been serviced by the node 

	 * over time periods of one and 24 hours.

	 * 

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

	 * @param period - An ISO8601 compatible DateTime range specifying the time 

	 *                 range for which to return operation statistics.

	 * @param requestor - Limit to operations performed by given requestor identity.

	 * @param event -  Enumerated value indicating the type of event being examined

	 * @param format - Limit to events involving objects of the specified format

	 * 

	 * @return the desired log records

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

  @Override

	public MonitorList getOperationStatistics(Session session, Integer period,

	  Subject requestor, Event event, ObjectFormat format) 

    throws NotImplemented, ServiceFailure, NotAuthorized, InvalidRequest, 

    InsufficientResources, UnsupportedType {

		return null;

	}

  /**

   * Low level “are you alive” operation. A valid ping response is 

   * indicated by a HTTP status of 200.

   * 

   * @return true if the service is alive

   * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

   */

	@Override

	public boolean ping() 

	  throws NotImplemented, ServiceFailure, NotAuthorized, InvalidRequest, 

	  InsufficientResources, UnsupportedType {

		return false;

	}

	/**

   * Test if the user identified by the provided token has authorization 

   * for operation on the specified object.

 	 * 

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

	 * @param pid - The identifier of the resource for which access is being checked

	 * @param action - The type of permission which is being requested for the given pid

	 *

	 * @return true if the action is allowed

	 * 

	 * @throws ServiceFailure

	 * @throws InvalidToken

	 * @throws NotFound

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 * @throws InvalidRequest

	 */	

	@Override

	public boolean isAuthorized(Session session, Identifier pid, Permission operation)

	  throws ServiceFailure, InvalidRequest, InvalidToken, NotFound,

	  NotAuthorized, NotImplemented {

		return false;

	}

	/**

	 * Set access for a given object using the object identifier and a Subject

	 * under a given Session.

	 * 

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

	 * @param pid - the object identifier for the given object to apply the policy

	 * @param policy - the access policy to be applied

	 * 

	 * @return true if the application of the policy succeeds

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotFound

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 * @throws InvalidRequest

	 */

	@Override

	public boolean setAccessPolicy(Session session, Identifier pid,

	  AccessPolicy accessPolicy) 

	  throws InvalidToken, ServiceFailure, NotFound, NotAuthorized, 

	  NotImplemented, InvalidRequest {

		return false;

	}

}

 * service API. Methods implement the various CN* interfaces, and methods common

	/*public boolean updateNodeCapabilities(Session session, NodeReference nodeid, Node node) */

	 * @param start - zero based offset from the first record in the 

	 *                set of matching log records. Used to assist with 

	 *                paging the response.

	 * @param count - maximum number of log records to return in the response. 

	 *                Used to assist with paging the response.

	 *                

	/* TODO: update this when the API in d1_common adds the arguments */

	/*public Log getLogRecords(Session session, Date fromDate, Date toDate, 

	 *  Event event, Integer start, Integer count) */

		/* return super.getLogRecords(session, fromDate, toDate, event, start, count); */

		return super.getLogRecords(session, fromDate, toDate, event, 0, 1000);

	public boolean isAuthorized(Session session, Identifier pid, Event action)

	 * @param event - restrict log records of a specific event type

	 * @param start - zero based offset from the first record in the 

	 *                set of matching log records. Used to assist with 

	 *                paging the response.

	 * @param count - maximum number of log records to return in the response. 

	 *                Used to assist with paging the response.

      Event event, Integer start, Integer count) throws InvalidToken, ServiceFailure,

	 * @return true if the application of the policy succeeds

    AccessPolicy accessPolicy)