Metacat

import org.dataone.service.exceptions.NotFound;

            System.out.println("adding param: " + name + " = " + value);

        System.out.println("entering putObject.  Action is " + action);

            // Read the incoming data from its Mime Multipart encoding

            logMetacat.debug("Disassembling MIME multipart form");

            InputStream object = null;

            InputStream sysmeta = null;

            MimeMultipart mmp = new MimeMultipart(new InputStreamDataSource("message", request.getInputStream()));

            logMetacat.debug("MMP created.");

            mmp.writeTo(System.out);

            for (int i = 0; i < mmp.getCount(); i++) {

                logMetacat.debug("Looping over MMP parts: " + i);

                BodyPart part = mmp.getBodyPart(i);

                String name = part.getFileName();

                logMetacat.debug("Part name is: " + name);

                System.out.println("part name: " + name);

                logMetacat.debug("Part has class name: " + part.getClass().getName());

                if (name.equals("object")) {

                    object = part.getInputStream();

                    logMetacat.debug("Found object part, size is: " + part.getSize());

                } else if (name.equals("systemmetadata")) {

                    sysmeta = part.getInputStream();

                    logMetacat.debug("Found sysmeta part, size is: " + part.getSize());

                } else {

                    throw new InvalidRequest(1000, "Request had malformed MIME part with name: " + name);

                }

            }

            if ( action.equals(FUNCTION_NAME_INSERT)) { //handle inserts

            } else if (action.equals(FUNCTION_NAME_UPDATE)) { //handle updates

                IdentifierManager im = IdentifierManager.getInstance();

                CrudService cs = CrudService.getInstance();

                Identifier obsoletedGuid = new Identifier();

                Identifier id = new Identifier();

                id.setValue(guid);

                AuthToken token = null;

                //do some checks

                if(params.get("obsoletedGuid") == null)

                {

                    throw new InvalidRequest(1202, "obsoletedGuid must be contained in the request parameters.");

                }

                //get the obsoletedGuid

                String[] obsGuidS = params.get("obsoletedGuid");

                obsoletedGuid.setValue(obsGuidS[0]);

                if (!im.identifierExists(obsoletedGuid.getValue())) 

                {

                    throw new InvalidRequest(1202, "The guid you are trying to update does not exist.");

                }

                logMetacat.debug("Commence update...");

                //get the systemmetadata

                IBindingFactory bfact =

                        BindingDirectory.getFactory(SystemMetadata.class);

                    IUnmarshallingContext uctx = bfact.createUnmarshallingContext();

                    SystemMetadata m = (SystemMetadata) uctx.unmarshalDocument(sysmeta, null);

                //do the update

                try

                {

                    cs.setParamsFromRequest(request);

                    Identifier rId = cs.update(token, id, object, obsoletedGuid, m);

                    System.out.println("id returned from update " + rId.getValue());

                }

                catch(NotFound e)

                {

                    throw new InvalidRequest(1202, "The guid you are trying to update does not exist.");

                }

    /**

     * update an existing object with a new object.  Change the system metadata

     * to reflect the changes and update it as well.

     */

    public Identifier update(AuthToken token, Identifier guid, 

            InputStream object, Identifier obsoletedGuid, SystemMetadata sysmeta) 

            throws InvalidToken, ServiceFailure, NotAuthorized, IdentifierNotUnique, 

            UnsupportedType, InsufficientResources, NotFound, InvalidSystemMetadata, 

            NotImplemented {

        try

        {

            SessionData sessionData = getSessionData(token);

            //find the old systemmetadata (sm.old) document id (the one linked to obsoletedGuid)

            SystemMetadata sm = getSystemMetadata(token, obsoletedGuid);

            //change sm.old's obsoletedBy field 

            List l = sm.getObsoletedByList();

            l.add(guid);

            sm.setObsoletedByList(l);

            //update sm.old

            updateSystemMetadata(sm, sessionData);

            //change the obsoletes field of the new systemMetadata (sm.new) to point to the id of the old one

            sysmeta.addObsolete(obsoletedGuid);

            //insert sm.new

            insertSystemMetadata(sysmeta, sessionData);

            boolean isScienceMetadata = isScienceMetadata(sysmeta);

            if(isScienceMetadata)

            {

                //update the doc

                updateDocument(object, obsoletedGuid, guid, sessionData);

            }

            else

            {

                //update a data file, not xml

                insertDataObject(object, guid, sessionData);

            }

            return guid;

        }

        catch(Exception e)

        {

            throw new ServiceFailure(1030, "Error updating document in CrudService: " + e.getMessage());

        }

    }

                        System.out.println("inserting data object: localId: " + localId);