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.dataone.service.cn.CNAuthorization;

import org.dataone.service.cn.CNCore;

import org.dataone.service.cn.CNIdentity;

import org.dataone.service.cn.CNRead;

import org.dataone.service.cn.CNRegister;

import org.dataone.service.cn.CNReplication;

import org.dataone.service.exceptions.IdentifierNotUnique;

import org.dataone.service.exceptions.InsufficientResources;

import org.dataone.service.exceptions.InvalidCredentials;

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.types.AccessPolicy;

import org.dataone.service.types.Checksum;

import org.dataone.service.types.Event;

import org.dataone.service.types.Identifier;

import org.dataone.service.types.Log;

import org.dataone.service.types.Node;

import org.dataone.service.types.NodeList;

import org.dataone.service.types.NodeReference;

import org.dataone.service.types.ObjectFormat;

import org.dataone.service.types.ObjectFormatIdentifier;

import org.dataone.service.types.ObjectFormatList;

import org.dataone.service.types.ObjectList;

import org.dataone.service.types.ObjectLocationList;

import org.dataone.service.types.Person;

import org.dataone.service.types.QueryType;

import org.dataone.service.types.ReplicationPolicy;

import org.dataone.service.types.ReplicationStatus;

import org.dataone.service.types.Session;

import org.dataone.service.types.Subject;

import org.dataone.service.types.SubjectList;

import org.dataone.service.types.SystemMetadata;

/**

 * Represents Metacat's implementation of the DataONE Coordinating Node 

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

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

 * D1NodeService super class.

 *

 */

public class CNodeService extends D1NodeService implements CNAuthorization,

    CNCore, CNIdentity, CNRead, CNRegister, CNReplication {

	/**

	 * Constructor: create a CNodeService instance

	 * TODO: should we make this a singleton class like CNCoreImpl?

	 */

	public CNodeService() {

    super();

	}

	/**

	 * Set the replication policy for an object given the object identifier

	 * 

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

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

	 * @param policy - the replication policy to be applied

	 * 

	 * @return true or false

	 * 

	 * @throws NotImplemented

	 * @throws NotAuthorized

	 * @throws ServiceFailure

	 * @throws InvalidRequest

	 * 

	 */

	@Override

	public boolean setReplicationPolicy(Session session, Identifier pid,

	  ReplicationPolicy policy) 

	  throws NotImplemented, NotAuthorized, ServiceFailure, InvalidRequest {

		return false;

	}

	/**

	 * Set the replication status for an object given the object identifier

	 * 

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

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

	 * @param status - the replication status to be applied

	 * 

	 * @return true or false

	 * 

	 * @throws NotImplemented

	 * @throws NotAuthorized

	 * @throws ServiceFailure

	 * @throws InvalidRequest

	 * @throws InvalidToken

	 * @throws NotFound

	 * 

	 */

	@Override

	public boolean setReplicationStatus(Session session, Identifier pid,

	  ReplicationStatus status) 

	  throws ServiceFailure, NotImplemented, InvalidToken, NotAuthorized, 

	  InvalidRequest, NotFound {

		return false;

	}

	/**

	 * Add capabilities to the node description

	 * 

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

	 * @param nodeid - the node identifier for the given node be modified

	 * @param node - the node information to be added

	 * 

	 * @return true or false

	 * 

	 * @throws NotImplemented

	 * @throws NotAuthorized

	 * @throws ServiceFailure

	 * @throws InvalidRequest

	 * @throws NotFound

	 */

	@Override

	public boolean addNodeCapabilities(Session session, NodeReference nodeid, Node node)

	  throws NotImplemented, NotAuthorized, ServiceFailure, InvalidRequest,

	  NotFound {

		return false;

	}

	/**

	 * Register a Coordinating Node

	 * 

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

	 * @param node - the node information for the given node be modified

	 * 

	 * @return nodeid - the identifier of the node to be registered

	 * 

	 * @throws NotImplemented

	 * @throws NotAuthorized

	 * @throws ServiceFailure

	 * @throws InvalidRequest

	 * @throws IdentifierNotUnique

	 */

	@Override

	public Identifier register(Session session, Node node) 

	  throws NotImplemented, NotAuthorized, ServiceFailure, InvalidRequest, 

	  IdentifierNotUnique {

		return null;

	}

	/**

	 * Test that the specified relationship between pidOfSubject and pidOfObject exists

	 * 

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

	 * @param node - the node information for the given node be modified

	 * 

	 * @return true if the relationship exists

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotFound

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

	@Override

	public boolean assertRelation(Session session, Identifier pidofsubject, 

		String relationship, Identifier pidOfObject) 

	  throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, 

	  InvalidRequest, NotImplemented {

		return false;

	}

	/**

	 * 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 InvalidRequest, InvalidToken, ServiceFailure, NotAuthorized, 

	  NotFound, NotImplemented {

		return super.get(session, pid);

	}

	/**

	 * Return a checksum of the object given the object identifier and the name

	 * of the checksum algorithm (the default being SHA-1)

	 * 

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

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

	 * 

	 * @return checksum - the checksum of the object

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotFound

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

	@Override

	public Checksum getChecksum(Session session, Identifier pid)

	  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 InvalidRequest, InvalidToken, ServiceFailure, NotAuthorized,

	  NotFound, NotImplemented {

		return super.getSystemMetadata(session, pid);

	}

	/**

	 * Resolve the location of a given object

	 * 

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

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

	 * 

	 * @return objectLocationList - the list of nodes known to contain the object

	 * 

	 * @throws InvalidRequest

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotFound

	 * @throws NotImplemented

	 */

	@Override

	public ObjectLocationList resolve(Session session, Identifier pid)

	  throws InvalidRequest, InvalidToken, ServiceFailure, NotAuthorized,

	  NotFound, NotImplemented {

		return null;

	}

	/**

	 * Search the metadata catalog for identifiers that match the criteria

	 * 

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

	 * @param queryType - An identifier for the type of query expression 

	 *                    provided in the query

	 * @param query -  The criteria for matching the characteristics of the 

	 *                 metadata objects of interest

	 * 

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

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

	@Override

	public ObjectList search(Session session, QueryType queryType, String query)

	  throws InvalidToken, ServiceFailure, NotAuthorized, InvalidRequest,

	  NotImplemented {

		return null;

	}

	/**

	 * Add members to the named group

	 * 

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

	 * @param groupName - The identifier of the group to be modified

	 * @param members -  The list of members to be added to the group

	 * 

	 * @return true if the addition succeeds

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 * @throws NotFound

	 */

	@Override

	public boolean addGroupMembers(Session session, Subject groupName, SubjectList members)

	  throws ServiceFailure, InvalidToken, NotAuthorized, NotFound,

	  NotImplemented, InvalidRequest {

		return false;

	}

	/**

	 * Confirms a previously initiated identity mapping 

	 * 

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

	 * @param subject - The identifier of the subject to be used for the equivalent identity

	 * 

	 * @return true if the mapping succeeds

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 * @throws NotFound

	 */

	@Override

	public boolean confirmMapIdentity(Session session, Subject subject)

	  throws ServiceFailure, InvalidToken, NotAuthorized, NotFound,

	  NotImplemented, InvalidRequest {

		return false;

	}

	/**

	 * Create a group with the given name

	 * 

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

	 * @param groupName - The name of the group to be created

	 * 

	 * @return true if the creation succeeds

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 * @throws NotFound

	 * @throws IdentifierNotUnique

	 */

	@Override

	public boolean createGroup(Session session, Subject groupName) 

	  throws ServiceFailure, InvalidToken, NotAuthorized, NotFound, 

	  NotImplemented, InvalidRequest, IdentifierNotUnique {

		return false;

	}

	/**

	 * Get information about a Person (identities, groups, etc.)

	 * 

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

	 * @param subject - The name of the group to be created

	 * 

	 * @return true if the creation succeeds

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 */

	@Override

	public SubjectList getSubjectInfo(Session session, Subject subject)

	  throws ServiceFailure, InvalidRequest, NotAuthorized, NotImplemented {

		return null;

	}

	/**

	 * List subjects, including users, groups, and systems, that match search criteria

	 * 

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

	 * @param query -  A query string criteria to be matched

	 * @param start - The starting record number for the records to be returned

	 * @param count -  The number of records to be returned

	 * 

	 * @return subjectList - the list of subjects matching the criteria

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 */

	@Override

	public SubjectList listSubjects(Session session, String query, Integer start,

	  Integer count) 

	  throws ServiceFailure, InvalidToken, NotAuthorized, NotImplemented {

		// TODO Auto-generated method stub

		return null;

	}

	/**

	 * Map the two authenticated identities, asserting that they represent the same subject

	 * 

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

	 * @param subject - The Subject identifier to be used for the equivalent identity

	 * 

	 * @return true if the mapping initiation succeeds (still requires confirmation)

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws InvalidRequest

	 * @throws NotImplemented

	 * @throws NotFound

	 */

	@Override

	public boolean mapIdentity(Session session, Subject subject) 

	  throws ServiceFailure, InvalidToken, NotAuthorized, NotFound, 

	  NotImplemented, InvalidRequest {

		return false;

	}

	/**

	 * Create a new subject in the DataONE system

	 * 

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

	 * @param groupName - The name of the group to be created

	 * 

	 * @return subject - the identifier of the subject created

	 * 

	 * @throws ServiceFailure

	 * @throws IdentifierNotUnique

	 * @throws InvalidRequest

	 * @throws InvalidCredentials

	 * @throws NotImplemented

	 */

	@Override

	public Subject registerAccount(Session session, Person person)

	  throws ServiceFailure, IdentifierNotUnique, InvalidCredentials,

	  NotImplemented, InvalidRequest {

		return null;

	}

	/**

	 * Remove members from a named group

	 * 

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

	 * @param groupName - The name of the group to be modified

	 * @param members - The list of members to be removed

	 * 

	 * @return true if the removal succeeds

	 * 

	 * @throws ServiceFailure

	 * @throws InvalidToken

	 * @throws NotAuthorized

	 * @throws NotFound

	 * @throws NotImplemented

	 * @throws InvalidRequest

	 */

	@Override

	public boolean removeGroupMembers(Session session, Subject groupName, 

	  SubjectList members)

	  throws ServiceFailure, InvalidToken, NotAuthorized, NotFound,

	    NotImplemented, InvalidRequest {

		return false;

	}

	/**

	 * Update an existing subject in the DataONE system

	 * 

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

	 * @param person - The new information about the Subject

	 * 

	 * @return subject - The Subject in the DataONE system that was updated.

	 * 

	 * @throws ServiceFailure

	 * @throws IdentifierNotUnique

	 * @throws InvalidCredentials

	 * @throws NotImplemented

	 * @throws InvalidRequest

	 */

	@Override

	public Subject updateAccount(Session session, Person person)

	  throws ServiceFailure, IdentifierNotUnique, InvalidCredentials,

	  NotImplemented, InvalidRequest {

		return null;

	}

	/**

	 * Verify that the Person data associated with this Subject is a true 

	 * representation of the real world person.

	 * 

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

	 * @param person - The Subject identifier of the Person to be verified

	 * 

	 * @return true if the account verification succeeds

	 * 

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 * @throws InvalidToken

	 * @throws InvalidRequest

	 */

	@Override

	public boolean verifyAccount(Session session, Subject person)

	  throws ServiceFailure, NotAuthorized, NotImplemented, InvalidToken,

	  InvalidRequest {

		return false;

	}

	/**

	 * Used internally within a Coordinating Node to add a new object 

	 * to the object store

	 * 

	 * @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;

	}

	/**

	 * Returns the object format registered in the DataONE Object Format 

	 * Vocabulary for the given format identifier

	 * 

	 * @param fmtid - the identifier of the format requested

	 * 

	 * @return objectFormat - the object format requested

	 * 

	 * @throws InvalidRequest

	 * @throws ServiceFailure

	 * @throws NotFound

	 * @throws InsufficientResources

	 * @throws NotImplemented

	 */

	@Override

	public ObjectFormat getFormat(ObjectFormatIdentifier fmtid)

	  throws InvalidRequest, ServiceFailure, NotFound, InsufficientResources,

	  NotImplemented {

		return null;

	}

	/**

	 * Retrieves consolidated log information for the specified date range 

	 * (inclusive) for the entire DataONE infrastructure

	 * 

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

	 * @param fromDate - Starting time for records in response

	 * @param toDate - End time for records in response. If not specified, then defaults to now.

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

	 * 

	 * @return log - the log records requested

	 * 

	 * @throws InvalidRequest

	 * @throws ServiceFailure

	 * @throws InvalidToken

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 */

	@Override

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

	  throws InvalidToken, InvalidRequest, ServiceFailure, NotAuthorized,

	  NotImplemented {

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

	}

	/**

   * Returns a list of all object formats registered in the DataONE Object 

   * Format Vocabulary

 	 * 

	 * @return objectFormatList - The list of object formats registered in 

	 *                            the DataONE Object Format Vocabulary

	 * 

	 * @throws InvalidRequest

	 * @throws ServiceFailure

	 * @throws NotImplemented

	 * @throws NotFound

	 * @throws InsufficientResources

	 */

	@Override

	public ObjectFormatList listFormats() 

	  throws InvalidRequest, ServiceFailure, NotFound, InsufficientResources, 

	  NotImplemented {

		return null;

	}

	/**

   * Returns a list of nodes that have been registered with the DataONE infrastructure

 	 * 

	 * @return nodeList - List of nodes from the registry

	 * 

	 * @throws ServiceFailure

	 * @throws NotImplemented

	 */

	@Override

	public NodeList listNodes() 

	  throws NotImplemented, ServiceFailure {

		return null;

	}

	/**

   * Provides a mechanism for adding system metadata independently of its 

   * associated object, such as when adding system metadata for data objects.

 	 * 

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

	 * @param pid - The identifier of the object to register the system metadata against

	 * @param sysmeta - The system metadata to be registered

	 * 

	 * @return true if the registration succeeds

	 * 

	 * @throws NotImplemented

	 * @throws NotAuthorized

	 * @throws ServiceFailure

	 * @throws InvalidRequest

	 * @throws InvalidSystemMetadata

	 */

	@Override

	public boolean registerSystemMetadata(Session session, Identifier pid,

	  SystemMetadata sysmeta) 

	  throws NotImplemented, NotAuthorized, ServiceFailure, InvalidRequest, 

	  InvalidSystemMetadata {

		return false;

	}

	/**

   * Given an optional scope and format, reserves and returns an identifier 

   * within that scope and format that is unique and will not be 

   * used by any other sessions. 

 	 * 

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

	 * @param pid - The identifier of the object to register the system metadata against

	 * @param scope - An optional string to be used to qualify the scope of 

	 *                the identifier namespace, which is applied differently 

	 *                depending on the format requested. If scope is not 

	 *                supplied, a default scope will be used.

	 * @param format - The optional name of the identifier format to be used, 

	 * 								 drawn from a DataONE-specific vocabulary of identifier 

	 *                 format names, including several common syntaxes such 

	 *                 as DOI, LSID, UUID, and LSRN, among others. If the 

	 *                 format is not supplied by the caller, the CN service 

	 *                 will use a default identifier format, which may change 

	 *                 over time.

	 * 

	 * @return true if the registration succeeds

	 * 

	 * @throws InvalidToken

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws IdentifierNotUnique

	 * @throws NotImplemented

	 */

	@Override

	public Identifier reserveIdentifier(Session session, Identifier pid,

	  String scope, String format) 

	  throws InvalidToken, ServiceFailure, NotAuthorized, IdentifierNotUnique, 

	  NotImplemented, InvalidRequest {

		return null;

	}

	/**

   * 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 identifer of the resource for which access is being checked

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

	 *

	 * @return true if the operation is allowed

	 * 

	 * @throws ServiceFailure

	 * @throws InvalidToken

	 * @throws NotFound

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 * @throws InvalidRequest

	 */	

	@Override

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

	  throws ServiceFailure, InvalidToken, NotFound, NotAuthorized,

	  NotImplemented, InvalidRequest {

		return false;

	}

	/**

   * Sets the access permissions for an object identified by pid

 	 * 

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

	 * @param pid - The identifer of the resource to set access on

	 * @param accessPolicy - The access policy to be applied for the object

	 *

	 * @return true if the operation is allowed

	 * 

	 * @throws ServiceFailure

	 * @throws InvalidToken

	 * @throws NotFound

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 * @throws InvalidRequest

	 */	

	@Override

	public boolean setAccessPolicy(Session session, Identifier pid,

	    AccessPolicy accessPolicy) throws InvalidToken, NotFound, NotImplemented,

	    NotAuthorized, ServiceFailure, InvalidRequest {

		return super.setAccessPolicy(session, pid, accessPolicy);

	}

	/**

   * Changes ownership (RightsHolder) of the specified object to the 

   * subject specified by userId

 	 * 

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

	 * @param pid - Identifier of the object to be modified

	 * @param userId - The subject that will be taking ownership of the specified object.

	 *

	 * @return pid - the identifier of the modified object

	 * 

	 * @throws ServiceFailure

	 * @throws InvalidToken

	 * @throws NotFound

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 * @throws InvalidRequest

	 */	

	@Override

	public Identifier setOwner(Session session, Identifier pid, Subject userId)

	  throws InvalidToken, ServiceFailure, NotFound, NotAuthorized,

	  NotImplemented, InvalidRequest {

		return null;

	}

}