/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 10044

Added by Jing Tao about 8 years ago

Add code to testArchive, testSetAccessPolicy, testSetOwner and testSetReplicationPolicy on objects whose authoritative member node is v1 or v2 MNRead.

     	    printTestHeader("testSetOwner");
     	    try {
                 //v2 mn should fail
                 Session session = getCNSession();
                 Identifier guid = new Identifier();
                 guid.setValue("testSetOwner." + System.currentTimeMillis());
                 InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
                 SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
                 NodeReference nr = new NodeReference();
                 nr.setValue(MockCNode.V1MNNODEID);
                 sysmeta.setOriginMemberNode(nr);
                 sysmeta.setAuthoritativeMemberNode(nr);
                 long serialVersion = 1L;
                 // save it
                 Identifier retGuid = CNodeService.getInstance(request).registerSystemMetadata(session, guid, sysmeta);
                 assertEquals(guid.getValue(), retGuid.getValue());
                 Subject rightsHolder = new Subject();
                 rightsHolder.setValue("newUser");
                 // set it
                 Identifier retPid = CNodeService.getInstance(request).setRightsHolder(session, guid, rightsHolder, serialVersion);
                 assertEquals(guid, retPid);
                 // get it
                 sysmeta = CNodeService.getInstance(request).getSystemMetadata(session, guid);
                 assertNotNull(sysmeta);
                 // check it
                 assertTrue(rightsHolder.equals(sysmeta.getRightsHolder()));
             } catch(Exception e) {
                 e.printStackTrace();
                 fail("Unexpected error: " + e.getMessage());
+            }
     	    try {
     	        //v2 mn should fail
                 Session session = getCNSession();
     			Identifier guid = new Identifier();
     			guid.setValue("testSetOwner." + System.currentTimeMillis());
     			InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
     			SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
     			NodeReference nr = new NodeReference();
                 nr.setValue(MockCNode.V2MNNODEID);
                 sysmeta.setOriginMemberNode(nr);
                 sysmeta.setAuthoritativeMemberNode(nr);
     			long serialVersion = 1L;
     			// save it
     			Identifier retGuid = CNodeService.getInstance(request).registerSystemMetadata(session, guid, sysmeta);
-...
             } catch(Exception e) {
                 e.printStackTrace();
                 if(e instanceof ServiceFailure) {
                     assertTrue(e.getMessage().contains("Couldn't determine the authoritative member node"));
                 if(e instanceof NotAuthorized) {
                     assertTrue(e.getMessage().contains("The Coordinating Node is not authorized to make systemMetadata changes"));
                 } else {
                     fail("Unexpected error: " + e.getMessage());
+                }
-...
     	public void testSetAccessPolicy() {
     	    printTestHeader("testSetAccessPolicy");
     	    try {
                 // trys to set access policy on an object whose authortiative memeber node is MNRead v2. It should fail.
                 Session session = getCNSession();
                 Identifier guid = new Identifier();
                 guid.setValue("testSetAccessPolicy." + System.currentTimeMillis());
                 InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
                 SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
                 NodeReference nr = new NodeReference();
                 nr.setValue(MockCNode.V1MNNODEID);
                 sysmeta.setOriginMemberNode(nr);
                 sysmeta.setAuthoritativeMemberNode(nr);
                 long serialVersion = 1L;
                 // save it
                 Identifier retGuid = CNodeService.getInstance(request).registerSystemMetadata(session, guid, sysmeta);
                 assertEquals(guid.getValue(), retGuid.getValue());
                 AccessPolicy accessPolicy = new AccessPolicy();
                 AccessRule accessRule = new AccessRule();
                 accessRule.addPermission(Permission.WRITE);
                 Subject publicSubject = new Subject();
                 publicSubject.setValue(Constants.SUBJECT_PUBLIC);
                 accessRule.addSubject(publicSubject);
                 accessPolicy.addAllow(accessRule);
                 // set it
                 boolean result = CNodeService.getInstance(request).setAccessPolicy(session, guid, accessPolicy, serialVersion );
                 assertTrue(result);
                 // check it
                 result = CNodeService.getInstance(request).isAuthorized(session, guid, Permission.WRITE);
                 assertTrue(result);
             } catch(Exception e) {
                 fail("Unexpected error: " + e.getMessage());
+            }
     	    try {
     	        // trys to set access policy on an object whose authortiative memeber node is MNRead v2. It should fail.
                 Session session = getCNSession();
     			Identifier guid = new Identifier();
     			guid.setValue("testSetAccessPolicy." + System.currentTimeMillis());
     			InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
     			SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
     	    long serialVersion = 1L;
     			NodeReference nr = new NodeReference();
     	        nr.setValue(MockCNode.V2MNNODEID);
     	        sysmeta.setOriginMemberNode(nr);
     			sysmeta.setAuthoritativeMemberNode(nr);
     	        long serialVersion = 1L;
     			// save it
     			Identifier retGuid = CNodeService.getInstance(request).registerSystemMetadata(session, guid, sysmeta);
-...
     			assertTrue(result);
             } catch(Exception e) {
                 e.printStackTrace();
                 if(e instanceof ServiceFailure) {
                     assertTrue(e.getMessage().contains("Couldn't determine the authoritative member node"));
                 if(e instanceof NotAuthorized) {
                     assertTrue(e.getMessage().contains("The Coordinating Node is not authorized to make systemMetadata changes"));
                 } else {
                     fail("Unexpected error: " + e.getMessage());
+                }
-...
     	    printTestHeader("testReplicationPolicy");
     	    try {
                 //v2 mn should fail
                 Session session = getCNSession();
                 Identifier guid = new Identifier();
                 guid.setValue("testReplicationPolicy." + System.currentTimeMillis());
                 InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
                 SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
                 NodeReference nr = new NodeReference();
                 nr.setValue(MockCNode.V1MNNODEID);
                 sysmeta.setOriginMemberNode(nr);
                 sysmeta.setAuthoritativeMemberNode(nr);
                 long serialVersion = 1L;
                 // save it
                 Identifier retGuid = CNodeService.getInstance(request).registerSystemMetadata(session, guid, sysmeta);
                 assertEquals(guid.getValue(), retGuid.getValue());
                 ReplicationPolicy policy = new ReplicationPolicy();
                 NodeReference node = new NodeReference();
                 node.setValue("testNode");
                 policy.addPreferredMemberNode(node );
                 // set it
                 boolean result = CNodeService.getInstance(request).setReplicationPolicy(session, guid, policy, serialVersion);
                 assertTrue(result);
                 // get it
                 sysmeta = CNodeService.getInstance(request).getSystemMetadata(session, guid);
                 assertNotNull(sysmeta);
                 // check it
                 assertEquals(policy.getPreferredMemberNode(0).getValue(), sysmeta.getReplicationPolicy().getPreferredMemberNode(0).getValue());
             } catch(Exception e) {
                     fail("Unexpected error: " + e.getMessage());
+            }
     	    try {
     	        //v2 mn should fail
                 Session session = getCNSession();
     			Identifier guid = new Identifier();
     			guid.setValue("testReplicationPolicy." + System.currentTimeMillis());
     			InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
     			SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
     	    long serialVersion = 1L;
     			NodeReference nr = new NodeReference();
                 nr.setValue(MockCNode.V2MNNODEID);
                 sysmeta.setOriginMemberNode(nr);
                 sysmeta.setAuthoritativeMemberNode(nr);
     	        long serialVersion = 1L;
     			// save it
     			Identifier retGuid = CNodeService.getInstance(request).registerSystemMetadata(session, guid, sysmeta);
-...
             } catch(Exception e) {
                 e.printStackTrace();
                 if(e instanceof ServiceFailure) {
                     assertTrue(e.getMessage().contains("Couldn't determine the authoritative member node"));
                 if(e instanceof NotAuthorized) {
                     assertTrue(e.getMessage().contains("The Coordinating Node is not authorized to make systemMetadata changes"));
                 } else {
                     fail("Unexpected error: " + e.getMessage());
+                }
-...
+      }
       public void testArchive() throws Exception {
           Session session = getCNSession();
           Identifier guid = new Identifier();
           guid.setValue("testArchive." + System.currentTimeMillis());
           InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
           SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
           Identifier pid = CNodeService.getInstance(request).create(session, guid, object, sysmeta);
           try {
               Session session = getCNSession();
               Identifier guid = new Identifier();
               guid.setValue("testArchive." + System.currentTimeMillis());
               InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
               SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
               NodeReference nr = new NodeReference();
               nr.setValue(MockCNode.V1MNNODEID);
               sysmeta.setOriginMemberNode(nr);
               sysmeta.setAuthoritativeMemberNode(nr);
               Identifier pid = CNodeService.getInstance(request).create(session, guid, object, sysmeta);
               CNodeService.getInstance(request).archive(session, guid);
           } catch (Exception e) {
              e.printStackTrace();
              if(e instanceof ServiceFailure) {
               assertTrue(e.getMessage().contains("Couldn't determine the authoritative member node"));
             } else {
               fail("Unexpected error: " + e.getMessage());
+            }
              fail("Unexpected error: " + e.getMessage());
+         }
           try {
               //v2 mn should faile
               Session session = getCNSession();
               Identifier guid = new Identifier();
               guid.setValue("testArchive." + System.currentTimeMillis());
               InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));
               SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);
               NodeReference nr = new NodeReference();
               nr.setValue(MockCNode.V2MNNODEID);
               sysmeta.setOriginMemberNode(nr);
               sysmeta.setAuthoritativeMemberNode(nr);
               Identifier pid = CNodeService.getInstance(request).create(session, guid, object, sysmeta);
               CNodeService.getInstance(request).archive(session, guid);
           } catch (Exception e) {
              e.printStackTrace();
              if(e instanceof NotAuthorized) {
                  assertTrue(e.getMessage().contains("The Coordinating Node is not authorized to make systemMetadata changes"));
              } else {
                  fail("Unexpected error: " + e.getMessage());
+             }
+         }
+      }

     import org.dataone.service.types.v1.Identifier;
     import org.dataone.service.types.v1.NodeReference;
     import org.dataone.service.types.v1.NodeType;
     import org.dataone.service.types.v1.Service;
     import org.dataone.service.types.v1.Services;
     import org.dataone.service.types.v1.Session;
     import org.dataone.service.types.v1.Subject;
     import org.dataone.service.types.v1.SubjectInfo;
-...
      * when there is a dependency on CN services
      */
     public class MockCNode extends MultipartCNode {
         public final static String V1MNNODEID= "urn:node:test_MN-v1";
         public final static String V2MNNODEID= "urn:node:test_MN-v2";
         /**
          * See superclass for documentation
-...
     		NodeList list = new NodeList();
     		list.addNode(getCapabilities());
     		list.addNode(getTestMN());
     		list.addNode(getTestV1MN());
     		list.addNode(getTestV2MN());
     		return list;
+    	}
-...
             return null;
+        }
         @Override
         public Node getNodeCapabilities(NodeReference nodeId) throws NotImplemented, ServiceFailure {
             if(nodeId != null && nodeId.getValue().equals(V1MNNODEID)) {
                 return getTestV1MN();
             } else if (nodeId != null && nodeId.getValue().equals(V2MNNODEID)) {
                 return getTestV2MN();
             } else {
                 return getCapabilities();
+            }
+        }
         /*
          * Create a test mn in this env.
          */
-...
             return node;
+        }
         /*
          * Create a v1 mn in this env
          */
         private Node getTestV1MN() {
             Node node = new Node();
             NodeReference nodeRef = new NodeReference();
             nodeRef.setValue(V1MNNODEID);
             node.setIdentifier(nodeRef);
             Subject subject = new Subject();
             subject.setValue("cn=" + V1MNNODEID + ",dc=dataone,dc=org");
             node.addSubject(subject );
             node.setType(NodeType.MN);
             Service service = new Service();
             service.setName("MNRead");
             service.setVersion("V1");
             service.setAvailable(true);
             Services services = new Services();
             services.addService(service);
             node.setServices(services);
             return node;
+        }
         /*
          * Create a v2 mn in this env
          */
         private Node getTestV2MN() {
             Node node = new Node();
             NodeReference nodeRef = new NodeReference();
             nodeRef.setValue(V2MNNODEID);
             node.setIdentifier(nodeRef);
             Subject subject = new Subject();
             subject.setValue("cn=" + V2MNNODEID + ",dc=dataone,dc=org");
             node.addSubject(subject);
             node.setType(NodeType.MN);
             Service service = new Service();
             service.setName("MNRead");
             service.setVersion("V1");
             service.setAvailable(true);
             Service service2 = new Service();
             service2.setName("MNRead");
             service2.setVersion("V2");
             service2.setAvailable(true);
             Services services = new Services();
             services.addService(service);
             services.addService(service2);
             node.setServices(services);
             return node;
+        }
+    }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 10044

Added by Jing Tao about 8 years ago