Metacat

import org.dataone.client.v2.itk.D1Client;

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

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

import org.dataone.service.types.v2.Node;

import org.dataone.service.types.v2.NodeList;

import edu.ucsb.nceas.metacat.dataone.CNodeService;

import org.dataone.service.exceptions.InvalidSystemMetadata;

import org.dataone.service.exceptions.ServiceFailure;

            //case-2

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

            Identifier pid1_case2 = new Identifier();

            pid1_case2.setValue(generateDocumentId());

            String sid_case2_str= "sid."+System.nanoTime();

            Identifier sid_case2 = new Identifier();

            sid_case2.setValue(sid_case2_str);

            SystemMetadata sysmeta_case2 = createSystemMetadata(pid1_case2, session.getSubject(), object);

            sysmeta_case2.setSeriesId(sid_case2);

            CNodeService.getInstance(request).create(session, pid1_case2, object, sysmeta_case2);

            Thread.sleep(1000);

            Identifier pid2_case2 = new Identifier();

            pid2_case2.setValue(generateDocumentId());

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

            sysmeta.setSeriesId(sid_case2);

            try {

                CNodeService.getInstance(request).create(session, pid2_case2, object, sysmeta);

                fail("we shouldn't get here and an InvalidSystemMetacat exception should be thrown.");

            } catch (InvalidSystemMetadata e) {

                System.out.println("case 2======= Invalid system metadata");

            }

    /**

     * We want to act as the CN itself

     * @throws ServiceFailure 

     * @throws Exception 

     */

    @Override

    public Session getTestSession() throws Exception {

        Session session = super.getTestSession();

        // use the first CN we find in the nodelist

        NodeList nodeList = D1Client.getCN().listNodes();

        for (Node node : nodeList.getNodeList()) {

            if ( node.getType().equals(NodeType.CN) ) {

                List<Subject> subjects = node.getSubjectList();

                for (Subject subject : subjects) {

                   session.setSubject(subject);

                   // we are done here

                   return session;

                }

            }

        }

        // in case we didn't find it

        return session;

    }