/ - Diff - Metacat - Ecoinformatics Redmine

     import junit.framework.TestSuite;
     import org.apache.commons.io.IOUtils;
     import org.dataone.client.v2.CNode;
     import org.dataone.client.v2.itk.D1Client;
     import org.dataone.service.exceptions.BaseException;
     import org.dataone.service.exceptions.InvalidRequest;
-...
     			Identifier retGuid = CNodeService.getInstance(request).registerSystemMetadata(session, guid, sysmeta);
     			assertEquals(guid.getValue(), retGuid.getValue());
     			// set it
     			ReplicationStatus status = ReplicationStatus.COMPLETED;
     			ReplicationStatus status = ReplicationStatus.QUEUED;
     			BaseException failure = new NotAuthorized("000", "Mock exception for " + this.getClass().getName());
     			//Test the failure of setReplicationStatus by a non-cn subject
     			Session testSession = getTestSession();
-...
     			// check it
     			assertEquals(status, sysmeta.getReplica(0).getReplicationStatus());
     			//Test the success of setReplicationStatus by a register mn subject
     			Session mnSession = getMNSessionFromCN();
     			status = ReplicationStatus.COMPLETED;
     			result = CNodeService.getInstance(request).setReplicationStatus(mnSession, guid, replicaMemberNode, status, failure);
     			sysmeta = CNodeService.getInstance(request).getSystemMetadata(session, guid);
                 assertNotNull(sysmeta);
                 // check it
                 assertEquals(status, sysmeta.getReplica(0).getReplicationStatus());
             } catch(Exception e) {
                 fail("Unexpected error: " + e.getMessage());
+            }
-...
                   assertTrue(e instanceof InvalidRequest);
+              }
+      }
       public Session getMNSessionFromCN() throws NotImplemented, ServiceFailure {
           Session session = new Session();
           Subject subject = null;
           CNode cn = D1Client.getCN();
           System.out.println("the cn is "+cn.getNodeBaseServiceUrl());
           List<Node> nodes = cn.listNodes().getNodeList();
           System.out.println("the size of the list is "+nodes.size());
           // find the first CN in the node list
           for (Node node : nodes) {
               if (node.getType().equals(NodeType.MN)) {
                   subject = node.getSubject(0);
                   break;
+              }
+          }
           session.setSubject(subject);
           return session;
+      }
+    }

     		// find the first CN in the node list
     		for (Node node : nodes) {
     			if (node.getType() == NodeType.CN) {
     			if (node.getType().equals(NodeType.CN)) {
     				subject = node.getSubject(0);
     				break;
+    			}

     	public NodeList listNodes() throws NotImplemented, ServiceFailure {
     		NodeList list = new NodeList();
     		list.addNode(getCapabilities());
     		list.addNode(getTestMN());
     		return list;
+    	}
-...
             return true;
+        }
         /*
          * Create a test mn in this env.
          */
         private Node getTestMN() {
             Node node = new Node();
             NodeReference nodeRef = new NodeReference();
             nodeRef.setValue("urn:node:test_MN-12346");
             node.setIdentifier(nodeRef);
             Subject subject = new Subject();
             subject.setValue("cn=" + getNodeId() + ",dc=dataone,dc=org");
             node.addSubject(subject );
             node.setType(NodeType.MN);
             return node;
+        }
+    }

Project

General

Profile

Metacat

Revision 9273

Added by Jing Tao almost 9 years ago