Metacat

import edu.ucsb.nceas.metacat.IdentifierManager;

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

    suite.addTest(new MNodeServiceTest("testMissMatchChecksumInCreate"));

  /**

   * Test object creation

   */

  public void testMissMatchChecksumInCreate() {

    printTestHeader("testMissMatchChecksumInCreate");

    Identifier guid = new Identifier();

    guid.setValue("testCreate." + System.currentTimeMillis());

    Session session = null;

    try {

      session = getTestSession();

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

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

      Node localNode = MNodeService.getInstance(request).getCapabilities();

      ReplicationPolicy rePolicy = new ReplicationPolicy();

      rePolicy.setReplicationAllowed(true);

      rePolicy.setNumberReplicas(new Integer(3));

      rePolicy.addPreferredMemberNode(localNode.getIdentifier());

      sysmeta.setReplicationPolicy(rePolicy);

      Checksum checksum = new Checksum();

      checksum.setAlgorithm("md5");

      checksum.setValue("098F6BCD4621D373CADE4E832627B4F9");

      sysmeta.setChecksum(checksum);

      Identifier pid = MNodeService.getInstance(request).create(session, guid, object, sysmeta);

      fail("It should fail since the checksum doesn't match.");

    } catch (InvalidSystemMetadata ee) {

      //ee.printStackTrace();

      try {

          Thread.sleep(5000);

          MNodeService.getInstance(request).getSystemMetadata(session, guid);

          fail("We shouldn't get here since the guid "+guid.getValue()+" was deleted.");

      } catch (NotFound e) {

         //here is okay.

      } catch (Exception e) {

          fail("Unexpected error: " + e.getMessage());

      }

      try {

          assertTrue(!IdentifierManager.getInstance().identifierExists(guid.getValue()));

      } catch (Exception e) {

          fail("Unexpected error: " + e.getMessage());

      }

    } catch (Exception e) {

        fail("Unexpected error: " + e.getMessage());

    }

  }