Metacat

<eml:eml packageId="tao.14563.1" system="knb"

	xmlns:eml="eml://ecoinformatics.org/eml-2.1.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

	xsi:schemaLocation="eml://ecoinformatics.org/eml-2.1.0 eml.xsd">

	<access authSystem="knb" order="allowFirst">

		<allow>

			<principal>public</principal>

			<permission>read</permission>

		</allow>

	</access>

	<dataset>

		<title>Test EML package - public-readable from morpho</title>

		<creator id="1320966812705">

			<individualName>

				<surName>adfasd</surName>

			</individualName>

		</creator>

		<abstract>

			<para>adf</para>

		</abstract>

		<keywordSet>

			<keyword>SAEON, South Africa</keyword>

		</keywordSet>

		<contact id="1320966816821">

			<individualName>

				<surName>asdfdas</surName>

			</individualName>

		</contact>

	</dataset>

</eml:eml>

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import org.dataone.client.ObjectFormatCache;

import org.dataone.service.types.v1.Subject;

	/**

	 * Set up the test fixtures

	 * 

	 * @throws Exception

	 */

	@Before

	public void setUp() throws Exception {

		super.setUp();

		// set up the configuration for d1client

		Settings.getConfiguration().setProperty("D1Client.cnClassName",

				MockCNode.class.getName());

	}

	/**

	 * Remove the test fixtures

	 */

	@After

	public void tearDown() {

	}

	/**

	 * Build the test suite

	 * 

	 * @return

	 */

	public static Test suite() {

		TestSuite suite = new TestSuite();

		suite.addTest(new RegisterDOITest("initialize"));

		// DOI registration test

		suite.addTest(new RegisterDOITest("testCreateDOI"));

		suite.addTest(new RegisterDOITest("testMintAndCreateDOI"));

		suite.addTest(new RegisterDOITest("testMintAndCreateForEML"));

		return suite;

	}

	/**

	 * Constructor for the tests

	 * 

	 * @param name

	 *            - the name of the test

	 */

	public RegisterDOITest(String name) {

		super(name);

	}

	/**

	 * Initial blank test

	 */

	public void initialize() {

		assertTrue(1 == 1);

	}

	/**

	 * constructs a "fake" session with a test subject

	 * @return

	 */

	@Override

	public Session getTestSession() throws Exception {

		Session session = new Session();

        Subject subject = new Subject();

        subject.setValue("CN=Benjamin Leinfelder A515,O=University of Chicago,C=US,DC=cilogon,DC=org");

        session.setSubject(subject);

        return session;

	}

	public void testMintAndCreateDOI() {

		printTestHeader("testMintAndCreateDOI");

		testMintAndCreateDOI(null);

	}

	public void testMintAndCreateForEML() {

		printTestHeader("testMintAndCreateForEML");

		String emlFile = "test/tao.14563.1.xml";

		InputStream content = null;

		try {

			content = new FileInputStream(emlFile);

		} catch (FileNotFoundException e) {

			e.printStackTrace();

			fail(e.getMessage());

		}

		testMintAndCreateDOI(content);

	}

	/**

	private void testMintAndCreateDOI(InputStream inputStream) {

		printTestHeader("testMintAndCreateDOI - common");

			SystemMetadata sysmeta = null;

			InputStream object = null;

			if (inputStream != null) {

				sysmeta = createSystemMetadata(guid, session.getSubject(), null);

				object = inputStream;

		        sysmeta.setFormatId(ObjectFormatCache.getInstance().getFormat("eml://ecoinformatics.org/eml-2.1.0").getFormatId());

			} else {

				object = new ByteArrayInputStream("test".getBytes("UTF-8"));

				sysmeta = createSystemMetadata(guid, session.getSubject(), object);

			}

			System.out.println("tested with DOI: " + pid.getValue());

import java.io.InputStream;

import java.util.Arrays;

import java.util.Collections;

import org.apache.wicket.protocol.http.MockHttpServletRequest;

import org.dataone.client.D1Client;

import org.dataone.service.exceptions.InsufficientResources;

import org.dataone.service.exceptions.InvalidToken;

import org.dataone.service.exceptions.NotAuthorized;

import org.dataone.service.exceptions.NotFound;

import org.dataone.service.types.v1.Permission;

import org.dataone.service.types.v1.Person;

import org.dataone.service.types.v1.Session;

import org.dataone.service.types.v1.Subject;

import org.dataone.service.types.v1.SubjectInfo;

import org.dataone.service.types.v1.util.AuthUtils;

import org.dataone.service.util.Constants;

import org.ecoinformatics.datamanager.parser.DataPackage;

import org.ecoinformatics.datamanager.parser.generic.DataPackageParserInterface;

import org.ecoinformatics.datamanager.parser.generic.Eml200DataPackageParser;

				// title 

				String title = ErcMissingValueCode.UNKNOWN.toString();

				try {

					title = lookupTitle(sysMeta);

				} catch (Exception e) {

					e.printStackTrace();

					// ignore

				}

				// creator

				String creator = sysMeta.getRightsHolder().getValue();

				try {

					creator = lookupCreator(sysMeta.getRightsHolder());

				} catch (Exception e) {

					// ignore and use default

				}

				// publisher

				String publisher = ErcMissingValueCode.UNKNOWN.toString();

				publisher = node.getName();

				// publication year

				// type

				String resourceType = DataCiteProfileResourceTypeValues.DATASET.toString() + "/" + sysMeta.getFormatId().getValue();

				// target (URL)

				String target = node.getBaseURL() + "/v1/object/" + identifier;

				// status and export fields for public/protected data

				String status = InternalProfileValues.UNAVAILABLE.toString();

				String export = InternalProfileValues.NO.toString();

				Subject publicSubject = new Subject();

				publicSubject.setValue(Constants.SUBJECT_PUBLIC);

				if (AuthUtils.isAuthorized(Arrays.asList(new Subject[] {publicSubject}), Permission.READ, sysMeta)) {

					status = InternalProfileValues.PUBLIC.toString();

					export = InternalProfileValues.YES.toString();

				}

				// set the metadata fields

				metadata.put(DataCiteProfile.TITLE.toString(), title);

				metadata.put(DataCiteProfile.CREATOR.toString(), creator);

				metadata.put(DataCiteProfile.PUBLISHER.toString(), publisher);

				metadata.put(DataCiteProfile.RESOURCE_TYPE.toString(), resourceType);

				metadata.put(InternalProfile.TARGET.toString(), target);

				metadata.put(InternalProfile.STATUS.toString(), status);

				metadata.put(InternalProfile.EXPORT.toString(), export);

	/**

	 * Locates an appropriate title for the object identified by the given SystemMetadata.

	 * Different types of objects will be handled differently for titles:

	 * 1. EML formats - parsed by the Datamanager library to find dataset title 

	 * 2. Data objects - TODO: use title from EML file that describes that data

	 * 3. ORE objects - TODO: use title from EML file contained in that package

	 * @param sysMeta

	 * @return appropriate title if known, or the missing value code

	 * @throws Exception

	 */

	private String lookupTitle(SystemMetadata sysMeta) throws Exception {

		String title = ErcMissingValueCode.UNKNOWN.toString();

		if (sysMeta.getFormatId().getValue().startsWith("eml://")) {

			DataPackageParserInterface parser = new Eml200DataPackageParser();

			// for using the MN API as the MN itself

			MockHttpServletRequest request = new MockHttpServletRequest(null, null, null);

			Session session = new Session();

	        Subject subject = MNodeService.getInstance(request).getCapabilities().getSubject(0);

	        session.setSubject(subject);

			InputStream emlStream = MNodeService.getInstance(request).get(session, sysMeta.getIdentifier());

			parser.parse(emlStream);

			DataPackage dataPackage = parser.getDataPackage();

			title = dataPackage.getTitle();

		}

		return title;

	}

	/**

	 * Lookup the citable name for the given Subject

	 * Calls the configured CN to determine this information.

	 * If the person is not registered with the CN identity service, 

	 * a NotFound exception will be raised as expected from the service.

	 * @param subject

	 * @return fullName if found

	 * @throws ServiceFailure

	 * @throws NotAuthorized

	 * @throws NotImplemented

	 * @throws NotFound

	 * @throws InvalidToken

	 */

	private String lookupCreator(Subject subject) throws ServiceFailure, NotAuthorized, NotImplemented, NotFound, InvalidToken {

		// default to given DN

		String fullName = subject.getValue();

		SubjectInfo subjectInfo = D1Client.getCN().getSubjectInfo(subject);

		if (subjectInfo != null && subjectInfo.getPersonList() != null) {

			for (Person p: subjectInfo.getPersonList()) {

				if (p.getSubject().equals(subject)) {

					fullName = p.getFamilyName();

					if (p.getGivenNameList() != null && p.getGivenNameList().size() > 0) {

						fullName = fullName + ", " + p.getGivenName(0);

					}

					break;

				}

			}

		}

		return fullName;

	}