Metacat

import org.dataone.service.exceptions.NotFound;

            if (dataPackage.getEntityList() != null) {

	            for(int j=0; j < dataPackage.getEntityList().length; j++)

	            {

	                String dataDocUrl = dataPackage.getEntityList()[j].getURL();

	                String dataDocMimeType = 

	                	dataPackage.getEntityList()[j].getDataFormat();

	                if (dataDocMimeType == null) {

		                dataDocMimeType = 

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

	                }

	                String dataDocLocalId = "";

	                if(dataDocUrl.trim().startsWith("ecogrid://knb/"))

	                { //we only handle ecogrid urls right now

	                    dataDocLocalId = dataDocUrl.substring(dataDocUrl.indexOf("ecogrid://knb/") + 

	                            "ecogrid://knb/".length(), dataDocUrl.length());

	                    //get the file

	                    params = "action=read&qformat=xml&docid=" + dataDocLocalId;

	                    InputStream dataDocIs = getResponse(sourceUrl, "/metacat", params, "POST");

	                    String dataDocText = streamToString(dataDocIs);

	                    //set the id

	                    Identifier did = new Identifier();

	                    did.setValue(dataDocLocalId);

	                    //add the desribeby to the eml's sysmeta

	                    System.out.println("adding describe for doc " + 

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

	                    sysmeta.addDescribe(did);

	                    //create sysmeta for the data doc                    

	                    SystemMetadata dataDocSysMeta = generateSystemMetadata(doc);

	                    //overwrite the bogus values from the last call 

	                    dataDocSysMeta.setIdentifier(did);

	                    ObjectFormat format = null;

	                    try {

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

	                    } catch (NotFound e) {

							System.out.println(e.getMessage());

						}

						dataDocSysMeta.setObjectFormat(format);

	                    Checksum checksum = new Checksum();

	                    dataDocIs = stringToStream(dataDocText);

	                    ChecksumAlgorithm ca = ChecksumAlgorithm.convert("MD5");

	                    checksum.setAlgorithm(ca);

	                    checksum.setValue(checksum(dataDocIs));

	                    dataDocSysMeta.setChecksum(checksum);

	                    dataDocSysMeta.setSize(dataDocText.getBytes(MetaCatServlet.DEFAULT_ENCODING).length);

	                    dataDocSysMeta.addDescribedBy(sysmeta.getIdentifier());

	                    boolean error = false;

	                    // create access policy

	                    //"public", "read", "allow", "allowFirst"

	                    AccessPolicy accessPolicy = new AccessPolicy();

	                    AccessRule accessRule = new AccessRule();

						accessRule.addPermission(Permission.READ);

	                    Subject subject = new Subject();

	                    subject.setValue("public");

						accessRule.addSubject(subject );

						accessPolicy.addAllow(accessRule );

	                    //create the data doc on d1

	                    try

	                    {

	                        mn.create(session, dataDocSysMeta.getIdentifier(), IOUtils.toInputStream(dataDocText), dataDocSysMeta);

							mn.setAccessPolicy(session, dataDocSysMeta.getIdentifier(), accessPolicy);

	                    }

	                    catch(Exception e)

	                    {

	                        error = true;

	                        System.out.println("ERROR: Could not create data document with id " + 

	                                dataDocSysMeta.getIdentifier().getValue() + " : " + e.getMessage());

	                    }

	                    finally

	                    {

	                        if(error)

	                        {

	                            printHeader("Insertion of document " + dataDocSysMeta.getIdentifier().getValue() + 

	                                    "FAILED.");

	                        }

	                        else

	                        {

	                            printHeader("Done inserting document " + dataDocSysMeta.getIdentifier().getValue() +

	                                " which is described by " + sysmeta.getIdentifier().getValue());

	                        }

	                    }

	                }

	                else

	                {

	                    System.out.println("WARNING: Could not process describes url " +

	                            dataDocUrl + " for document " + doc.docid + 

	                    ".  Only ecogrid://knb/ urls are currently supported.");

	                }

	            }