Metacat

import org.dataone.mimemultipart.MultipartResponseHandler;

                    if(httpVerb == POST)

                    {

                        InputStream is = request.getInputStream();

                        /*String input = IOUtils.toString(is);

                        System.out.println("input: " + input);

                        is = IOUtils.toInputStream(input);*/

                        File tmpDir = getTempDirectory();

                        File tmpSMFile = new File(tmpDir + 

                                ".sysmeta." + new Date().getTime() + ".tmp");

                        MultipartResponseHandler mpHandler = 

                            new MultipartResponseHandler(request, tmpSMFile);

                        Hashtable parts = mpHandler.getParts();

                        File f = (File)parts.get("sysmeta");

                        String sourceNode = (String)parts.get("sourceNode");

                        FileInputStream fis = new FileInputStream(f);

                        //lookup the id in the registry

                        URL url = new URL("http://cn.dataone.org/cn/node");

                        InputStream urlis = url.openStream();

                        Map<String,String> m = NodeListParser.parseNodeListFile(urlis);

                        String nodeUrl = m.get(sourceNode);

                        System.out.println("sourceNodeId: " + sourceNode);

                        System.out.println("resolved sourceNodeUrl: " + nodeUrl);

                        if(nodeUrl == null)

                        {

                            response.setStatus(500);

                            response.getOutputStream().write(("Member Node id " + 

                                    sourceNode + " not found in node registry.").getBytes());

                            response.getOutputStream().close();

                        }

                        //respond to cn with 200/OK

                        //String s;

                        //s = "sysmeta: " + IOUtils.toString(fis);

                        //s += "\n\n";

                        response.setStatus(200);

                        //response.getOutputStream().write(("sourceNode: " + sourceNode + "\n\n").getBytes());

                        //response.getOutputStream().write(("s: " + s).getBytes());

                        OutputStream out = response.getOutputStream();

                        out.write("OK\n".getBytes());

                        out.write(("sourceNodeId: " + sourceNode + "\n").getBytes());

                        out.write(("sourceNodeUrl: " + nodeUrl + "\n").getBytes());

                        out.close();

                        //parse the systemMetadata

                        SystemMetadata sm = (SystemMetadata)deserializeServiceType(SystemMetadata.class, fis);

                        NodeReference nr = sm.getOriginMemberNode();

                        nr.setValue(sourceNode);

                        sm.setOriginMemberNode(nr);

                        //get the document

                        AuthToken token = new AuthToken(sessionId);

                        MNode mnode = new MNode(nodeUrl);

                        //get the doc from the remote host

                        InputStream docStream = mnode.get(new AuthToken("public"), sm.getIdentifier());

                        File outputTmpFile = getTempFile();

                        FileOutputStream outputTmpFileStream = new FileOutputStream(outputTmpFile);

                        IOUtils.copy(docStream, outputTmpFileStream);

                        //verify checksum

                        System.out.println("verifying checksum");

                        String docChecksumStr = CrudService.checksum(

                                new FileInputStream(outputTmpFile), 

                                sm.getChecksum().getAlgorithm().name());

                        System.out.println("original checksum: " + sm.getChecksum().getValue());

                        System.out.println(" created checksum: " + docChecksumStr);

                        //insert the document in local db

                        System.out.println("creating new doc");

                        CrudService.getInstance().create(token, 

                                sm.getIdentifier(), new FileInputStream(outputTmpFile), sm);

                        //call cn.setReplicationStatus(guid, COMPLETE)

                        /*Questions:

                         * Call is now supposed to look like replicate(token, SystemMetadata, SourceNode)

                         * how is SystemMetadata encoded?  Multipart?

                         * 

                         * Is the token passed used to access MN_A?  How does MN_A

                         * know it's valid?

                         * 

                         * What exactly is happening when setReplicationStatus is called

                         * to the CN?  Which systemMetadata is being updated?  MN_A or MN_B or both?

                         * 

                         * 

                         * 

                         */

                    }

                    else if(name.equals("objectFormat") && value != null)