Metacat

	      format = ObjectFormatCache.getInstance().getFormat(doctype);

	        	format = ObjectFormatCache.getInstance().getFormat("application/octet-stream");

	        	format = ObjectFormatCache.getInstance().getFormat("text/plain");

      if ( format == ObjectFormatCache.getInstance().getFormat("eml://ecoinformatics.org/eml-2.0.0") ||

           format == ObjectFormatCache.getInstance().getFormat("eml://ecoinformatics.org/eml-2.0.1") ||

           format == ObjectFormatCache.getInstance().getFormat("eml://ecoinformatics.org/eml-2.1.0") ||

           format == ObjectFormatCache.getInstance().getFormat("eml://ecoinformatics.org/eml-2.1.1") ) {

                	ObjectFormatCache.getInstance().getFormat("application/octet-stream").getFmtid().getValue();

                      ObjectFormat f = ObjectFormatCache.getInstance().getFormat(dataDocMimeType);

                    	  f = ObjectFormatCache.getInstance().getFormat("application/octet-stream");

import java.io.ByteArrayInputStream;

import java.io.IOException;

import java.sql.SQLException;

import java.util.HashMap;

import org.dataone.cn.batch.utils.TypeMarshaller;

import org.jibx.runtime.JiBXException;

import edu.ucsb.nceas.metacat.DBUtil;

import edu.ucsb.nceas.metacat.DocumentImpl;

import edu.ucsb.nceas.metacat.McdbException;

import edu.ucsb.nceas.metacat.properties.PropertyService;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

  private static CNCoreImpl instance = null;

  private Logger logMetacat = null;

  /* The scope of the object formats docid used as the metacat identifier */

  private final String OBJECT_FORMAT_DOCID = "OBJECT_FORMAT_LIST.1";

  /* The revision of the object formats document */

  private int rev;

  /* The separator of the object formats document */

  private String separator = ".";

  /* The accession number of the object formats document */

  private String accNumber = null;

  /* The list of object formats */

  private ObjectFormatList objectFormatList = null;

  /* the searchable map of object formats */

  private static HashMap<String, ObjectFormat> objectFormatMap;

  /**

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

  }

	  @Override

    public boolean registerSystemMetadata(Session session, Identifier guid,

      SystemMetadata sysmeta) 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

          //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;

  }

  /**

   * Return the object format based on the given object format identifier

   * @param fmtid - the object format identifier to look up

   * @return objectFormat - the desired object format

   */

  @Override

	public ObjectFormat getFormat(ObjectFormatIdentifier fmtid) 

	  throws InvalidRequest, ServiceFailure, NotFound, InsufficientResources, 

	  NotImplemented {

  	logMetacat.debug("CNCoreImpl.getFormat() called.");

    ObjectFormat objectFormat = null;

    // look up the format in the object format map

	    objectFormat = getObjectFormatMap().get(fmtid.getValue());

	    // refresh the object format list if the format is null

	    if ( objectFormat == null ) {

	    	getCachedList();

	      objectFormat = getObjectFormatMap().get(fmtid.getValue());

	      // the object format isn't registered

	      if ( objectFormat == null ) {

		      throw new NotFound("4848", "The format specified by " + fmtid.getValue() + 

	        " does not exist at this node.");

	      }

	    }

  	return objectFormat;

	/**

	 * Return the list of object formats registered from the Coordinating Node.

	 * @return objectFormatList -  the list of object formats

	 */

		try {

	    objectFormatList = getInstance().getCachedList();

		} catch (ServiceFailure sfe) {

    	throw sfe;

		} catch (NotFound nfe) {

    	throw nfe;

		}

		return objectFormatList;

  /*

   * Return the hash containing the fmtid and format mapping

   * 

   * @return objectFormatMap - the hash of fmtid/format pairs

   */

  private HashMap<String, ObjectFormat> getObjectFormatMap() {

  	if ( objectFormatMap == null ) {

  		objectFormatMap = new HashMap<String, ObjectFormat>();

  	}

  	return objectFormatMap;

  }

  /**

   * Get the object format list cached in Metacat

   */

  private ObjectFormatList getCachedList()

    throws NotFound, ServiceFailure {

  	ObjectFormatList objectFormatList = null;

    try {

      // reset the accession number separator in case it is 

      // different than the default

      try {

        separator = PropertyService.getProperty("document.accNumSeparator");

      } catch ( PropertyNotFoundException pnfe ) {

        // use the default separator, but log the issue

        logMetacat.debug("There was a problem finding the document " +

          "separator property. The error message was: " + pnfe.getMessage());

      }

      // get the latest accession number if it is in Metacat

      this.rev = 

        DBUtil.getLatestRevisionInDocumentTable(this.OBJECT_FORMAT_DOCID);

      if ( this.rev != -1 ) {

        this.accNumber = this.OBJECT_FORMAT_DOCID + 

                         this.separator + 

                         this.rev;

        DocumentImpl objectFormatsDocument = new DocumentImpl(accNumber, false);

        ByteArrayInputStream bais = 

          new ByteArrayInputStream(objectFormatsDocument.toString().getBytes());

        // deserialize the object format list

        try {

        	objectFormatList = 

        		TypeMarshaller.unmarshalTypeFromStream(ObjectFormatList.class, bais);

        } catch (IOException e) {

        	throw new ServiceFailure("4841", "Unexpected exception from the service - " + 

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

        } catch (InstantiationException e) {

         	throw new ServiceFailure("4841", "Unexpected exception from the service - " + 

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

        } catch (IllegalAccessException e) {

         	throw new ServiceFailure("4841", "Unexpected exception from the service - " + 

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

        } catch (JiBXException e) {

         	throw new ServiceFailure("4841", "Unexpected exception from the service - " + 

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

        }

      } else {

        throw new NotFound("4843", "The object formats collection could not " +

        	"be found at this node.");

      }

    } catch ( SQLException sqle ) {      

     	throw new ServiceFailure("4841", "Unexpected exception from the service - " + 

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

    } catch (McdbException mcdbe) {      

     	throw new ServiceFailure("4841", "Unexpected exception from the service - " + 

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

    }

    // index the object format list based on the format identifier string

    int listSize = objectFormatList.sizeObjectFormats();

    for (int i = 0; i < listSize; i++ ) {

      ObjectFormat objectFormat = 

        objectFormatList.getObjectFormat(i);

      String identifier = objectFormat.getFmtid().getValue();

      getObjectFormatMap().put(identifier, objectFormat);

    }

    return objectFormatList;

  }

	        sysMeta.setObjectFormat(ObjectFormatCache.getInstance().getFormat(objectFormat));

        	        sysMeta.setObjectFormat(ObjectFormatCache.getInstance().getFormat(objectFormat));

                ObjectFormat oFormat = ObjectFormatCache.getInstance().getFormat(format);

                    oi.setObjectFormat(ObjectFormatCache.getInstance().getFormat("application/octet-stream"));