Metacat

/**

 *  '$RCSfile$'

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

 *              National Center for Ecological Analysis and Synthesis

 *

 *   '$Author: leinfelder $'

 *     '$Date: 2011-06-07 12:08:45 -0700 (Tue, 07 Jun 2011) $'

 *

 * 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.cn.CNCore;

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

import org.dataone.service.types.Identifier;

import org.dataone.service.types.Log;

import org.dataone.service.types.NodeList;

import org.dataone.service.types.ObjectFormat;

import org.dataone.service.types.ObjectFormatIdentifier;

import org.dataone.service.types.ObjectFormatList;

import org.dataone.service.types.Session;

import org.dataone.service.types.SystemMetadata;

import edu.ucsb.nceas.metacat.EventLog;

import edu.ucsb.nceas.metacat.IdentifierManager;

import edu.ucsb.nceas.metacat.replication.ForceReplicationSystemMetadataHandler;

/**

 * 

 * Implements DataONE CNCore services for Metacat. 

 * 

 * @author leinfelder

 */

public class CNCoreImpl implements CNCore

{

    private static CNCoreImpl instance = null;

    private Logger logMetacat = null;

    /**

     * singleton accessor

     */

    public static CNCoreImpl getInstance() 

    {

      if (instance == null) {

        instance = new CNCoreImpl();

      }

      return instance;

    }

    /**

     * Constructor, private for singleton access

     */

    private CNCoreImpl() {

        logMetacat = Logger.getLogger(CNCoreImpl.class);

    }

    /**

     * register System Metadata without data/metadata object

     */

    @Override

    public boolean registerSystemMetaData(Session session, Identifier guid,

            SystemMetadata sysmeta) throws NotImplemented, NotAuthorized,

            ServiceFailure, InvalidRequest {

        logMetacat.debug("Starting CrudService.create()...");

        // TODO: control who can call this?

        if (session == null) {

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

            //check these against the docs and correct them

            throw new NotAuthorized("4861", "No Session - could not authorize to registration." +

                    "  If you are not logged in, please do so and retry the request.");

        }

        // verify that guid == SystemMetadata.getIdentifier()

        logMetacat.debug("Comparing guid|sysmeta_guid: " + guid.getValue() + "|" + sysmeta.getIdentifier().getValue());

        if (!guid.getValue().equals(sysmeta.getIdentifier().getValue())) {

            throw new InvalidRequest("4863", 

                "GUID in method call (" + guid.getValue() + ") does not match GUID in system metadata (" +

                sysmeta.getIdentifier().getValue() + ").");

        }

        logMetacat.debug("Checking if identifier exists...");

        // Check that the identifier does not already exist

        IdentifierManager im = IdentifierManager.getInstance();

        if (im.identifierExists(guid.getValue())) {

            throw new InvalidRequest("4863", 

                "GUID is already in use by an existing object.");

        }

        // insert the system metadata into the object store

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

        sysmeta.setDateSysMetadataModified(new Date());

        try {

			IdentifierManager.getInstance().createSystemMetadata(sysmeta);

			IdentifierManager.getInstance().updateSystemMetadata(sysmeta);

			// force replication of this record

			ForceReplicationSystemMetadataHandler forceReplication = new ForceReplicationSystemMetadataHandler(guid.getValue(), null);

		} catch (Exception e) {

            throw new ServiceFailure("4862", "Error inserting system metadata: " + e.getClass() + ": " + e.getMessage());

		}

        logMetacat.debug("Returning from registerSystemMetadata");

        EventLog.getInstance().log(null, session.getSubject().getValue(), guid.getValue(), "registerSystemMetadata");

        return true;

    }

  @Override

  public Log getLogRecords(Session arg0, Date arg1, Date arg2,

    Event arg3) throws InvalidToken, InvalidRequest, ServiceFailure,

    NotAuthorized, NotImplemented {

  	  // TODO Auto-generated method stub

  	  return null;

    }

   @Override

	 public ObjectFormat getFormat(ObjectFormatIdentifier arg0) 

	   throws InvalidRequest, ServiceFailure, NotFound, InsufficientResources, 

	   NotImplemented {

		 // TODO Auto-generated method stub

		 return null;

	}

	@Override

	public NodeList listNodes() throws NotImplemented, ServiceFailure {

		// TODO Auto-generated method stub

		return null;

	}

	@Override

  public ObjectFormatList listFormats() throws InvalidRequest, ServiceFailure,

    NotFound, InsufficientResources, NotImplemented {

	  // TODO Auto-generated method stub

	  return null;

  }

	@Override

	public Identifier create(Session arg0, Identifier arg1, InputStream arg2,

			SystemMetadata arg3) throws InvalidToken, ServiceFailure,

			NotAuthorized, IdentifierNotUnique, UnsupportedType,

			InsufficientResources, InvalidSystemMetadata, NotImplemented,

			InvalidRequest {

		// TODO Auto-generated method stub

		return null;

	}

	@Override

	public Identifier reserveIdentifier(Session arg0, Identifier arg1,

			String arg2, String arg3) throws InvalidToken, ServiceFailure,

			NotAuthorized, IdentifierNotUnique, NotImplemented, InvalidRequest {

		// TODO Auto-generated method stub

		return null;

	}

}