You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2012/10/08 22:13:47 UTC

svn commit: r1395753 - in /airavata/trunk/modules: commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/ commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/ registry/airavata-jpa-registry/src/main/java/org/...

Author: lahiru
Date: Mon Oct  8 20:13:46 2012
New Revision: 1395753

URL: http://svn.apache.org/viewvc?rev=1395753&view=rev
Log:
fixing all nodes not being shown in monitoring panel

Modified:
    airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/ExperimentDataImpl.java
    airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/ExperimentData.java
    airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceData.java
    airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceNodeData.java
    airavata/trunk/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/ExperimentDataRetriever.java
    airavata/trunk/modules/registry/airavata-jpa-registry/src/test/java/org/apache/airavata/persistance/registry/jpa/GatewayResourceTest.java

Modified: airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/ExperimentDataImpl.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/ExperimentDataImpl.java?rev=1395753&r1=1395752&r2=1395753&view=diff
==============================================================================
--- airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/ExperimentDataImpl.java (original)
+++ airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/ExperimentDataImpl.java Mon Oct  8 20:13:46 2012
@@ -115,8 +115,18 @@ public class ExperimentDataImpl implemen
 		this.workflowInstanceName=workflowInstanceName;
 		
 	}
-	
-	@Override
+
+    @Override
+    public WorkflowInstanceData getWorkflowInstance(String workflowInstanceID) throws ExperimentLazyLoadedException {
+        for(WorkflowInstanceData workflowInstanceData : getWorkflowInstanceData()){
+            if(workflowInstanceData.getWorkflowInstanceId().equals(workflowInstanceID)){
+                return workflowInstanceData;
+            }
+        }
+        return null;
+    }
+
+    @Override
 	public List<WorkflowInstanceData> getWorkflowInstanceData() throws ExperimentLazyLoadedException{
 		if (isLazyLoaded()){
 			throw new ExperimentLazyLoadedException(getExperimentId());

Modified: airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/ExperimentData.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/ExperimentData.java?rev=1395753&r1=1395752&r2=1395753&view=diff
==============================================================================
--- airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/ExperimentData.java (original)
+++ airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/ExperimentData.java Mon Oct  8 20:13:46 2012
@@ -52,4 +52,5 @@ public interface ExperimentData {
 //	public void addOutput(WorkflowIOData output);
 	public void setMetadata(String metadata);
 	public void setExperimentName(String experimentName);
+    public WorkflowInstanceData getWorkflowInstance(String workflowInstanceID) throws ExperimentLazyLoadedException;
 }

Modified: airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceData.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceData.java?rev=1395753&r1=1395752&r2=1395753&view=diff
==============================================================================
--- airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceData.java (original)
+++ airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceData.java Mon Oct  8 20:13:46 2012
@@ -42,7 +42,11 @@ public class WorkflowInstanceData {
 		this.nodeDataList=nodeDataList;
 	}
 
-	public List<WorkflowInstanceNodeData> getNodeDataList() {
+    public WorkflowInstance getWorkflowInstance() {
+        return workflowInstance;
+    }
+
+    public List<WorkflowInstanceNodeData> getNodeDataList() {
 		if (nodeDataList==null){
 			nodeDataList=new ArrayList<WorkflowInstanceNodeData>();
 		}
@@ -56,10 +60,18 @@ public class WorkflowInstanceData {
 	public String getExperimentId(){
 		return workflowInstance.getExperimentId();
 	}
-	
+
+    /**
+     * @deprecated Use "getWorkflowInstanceID() instead
+     * @return
+     */
 	public String getTopicId(){
 		return workflowInstance.getWorkflowInstanceId();
 	}
+
+    public String getWorkflowInstanceId(){
+        return workflowInstance.getWorkflowInstanceId();
+    }
 	
 	/**
 	 * @deprecated Use "WorkflowInstanceData.getTemplateName()" instead

Modified: airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceNodeData.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceNodeData.java?rev=1395753&r1=1395752&r2=1395753&view=diff
==============================================================================
--- airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceNodeData.java (original)
+++ airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstanceNodeData.java Mon Oct  8 20:13:46 2012
@@ -22,6 +22,7 @@
 package org.apache.airavata.registry.api.workflow;
 
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 
 public class    WorkflowInstanceNodeData{
@@ -30,6 +31,7 @@ public class    WorkflowInstanceNodeData
 	private List<WorkflowInstanceNodePortData> outputData;
 	private String input;
 	private String output;
+    private WorkflowInstanceNodeStatus status;
 	
 	public WorkflowInstanceNodeData(WorkflowInstanceNode workflowInstanceNode) {
 		setWorkflowInstanceNode(workflowInstanceNode);
@@ -42,8 +44,21 @@ public class    WorkflowInstanceNodeData
 	public void setWorkflowInstanceNode(WorkflowInstanceNode workflowInstanceNode) {
 		this.workflowInstanceNode = workflowInstanceNode;
 	}
-	
-	private static class NameValue{
+
+    public WorkflowInstanceNodeStatus getStatus() {
+        return status;
+    }
+
+    public void setStatus(WorkflowInstanceNodeStatus status) {
+        this.status = status;
+    }
+
+    public void setStatus(WorkflowInstanceStatus.ExecutionStatus status, Date date) {
+        setStatus(new WorkflowInstanceNodeStatus(this.workflowInstanceNode, status, date));
+
+    }
+
+    private static class NameValue{
 		String name;
 		String value;
 		public NameValue(String name, String value) {

Modified: airavata/trunk/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/ExperimentDataRetriever.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/ExperimentDataRetriever.java?rev=1395753&r1=1395752&r2=1395753&view=diff
==============================================================================
--- airavata/trunk/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/ExperimentDataRetriever.java (original)
+++ airavata/trunk/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/ExperimentDataRetriever.java Mon Oct  8 20:13:46 2012
@@ -54,7 +54,7 @@ public class ExperimentDataRetriever {
                     "wd.workflow_instanceID, wd.template_name, wd.status, wd.start_time," +
                     "wd.last_update_time, nd.node_id, nd.inputs, nd.outputs, " +
                     "e.project_name, e.submitted_date, nd.node_type, nd.status," +
-                    "nd.start_time, nd.last_update_time " +
+                        "nd.start_time, nd.last_update_time " +
                     "FROM Experiment e " +
                     "LEFT JOIN Experiment_Data ed " +
                     "ON e.experiment_ID = ed.experiment_ID " +
@@ -66,41 +66,40 @@ public class ExperimentDataRetriever {
                     "ON wd.workflow_instanceID = nd.workflow_instanceID " +
                     "WHERE e.experiment_ID ='" + experimentId + "'";
 
+
             rs = statement.executeQuery(queryString);
             if (rs != null){
                 while (rs.next()) {
-                    experimentData = new ExperimentDataImpl();
-                    experimentData.setExperimentId(rs.getString(1));
-                    experimentData.setExperimentName(rs.getString(2));
-                    experimentData.setUser(rs.getString(3));
-                    experimentData.setMetadata(rs.getString(4));
-                    experimentData.setTopic(rs.getString(1));
-
-                    WorkflowInstance workflowInstance = new WorkflowInstance(experimentId, rs.getString(5));
-                    workflowInstance.setTemplateName(rs.getString(6));
-                    workflowInstance.setExperimentId(rs.getString(1));
-                    workflowInstance.setWorkflowInstanceId(rs.getString(5));
-                    experimentWorkflowInstances.add(workflowInstance);
-
-                    DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.S");
-                    Date lastUpdateDate = dateFormat.parse(rs.getString(9));
-                    WorkflowInstanceData workflowInstanceData = new WorkflowInstanceData(null,
-                            workflowInstance, new WorkflowInstanceStatus(workflowInstance,
-                            rs.getString(7)==null? null:ExecutionStatus.valueOf(rs.getString(7)),lastUpdateDate), null);
-                    workflowInstanceData.setExperimentData(experimentData);
-
-                    WorkflowInstanceNode workflowInstanceNode = new WorkflowInstanceNode(workflowInstance, rs.getString(10));
-
+                    if(experimentData == null){
+                        experimentData = new ExperimentDataImpl();
+                        experimentData.setExperimentId(rs.getString(1));
+                        experimentData.setExperimentName(rs.getString(2));
+                        experimentData.setUser(rs.getString(3));
+                        experimentData.setMetadata(rs.getString(4));
+                        experimentData.setTopic(rs.getString(1));
+                    }
+
+                    WorkflowInstanceData workflowInstanceData = experimentData.getWorkflowInstance(rs.getString(5));
+                    if(workflowInstanceData == null){
+                        WorkflowInstance workflowInstance = new WorkflowInstance(experimentId, rs.getString(5));
+                        workflowInstance.setTemplateName(rs.getString(6));
+                        workflowInstance.setExperimentId(rs.getString(1));
+                        workflowInstance.setWorkflowInstanceId(rs.getString(5));
+                        experimentWorkflowInstances.add(workflowInstance);
+                        Date lastUpdateDate = getTime(rs.getString(9));
+                        String wdStatus = rs.getString(7);
+                        workflowInstanceData = new WorkflowInstanceData(null,
+                                workflowInstance, new WorkflowInstanceStatus(workflowInstance,
+                                createExecutionStatus(wdStatus),lastUpdateDate), null);
+                        workflowInstanceData.setExperimentData(experimentData);
+                        experimentData.getWorkflowInstanceData().add(workflowInstanceData);
+                    }
+                    WorkflowInstanceNode workflowInstanceNode = new WorkflowInstanceNode(workflowInstanceData.getWorkflowInstance(), rs.getString(10));
                     WorkflowInstanceNodeData workflowInstanceNodeData = new WorkflowInstanceNodeData(workflowInstanceNode);
                     workflowInstanceNodeData.setInput(rs.getString(11));
                     workflowInstanceNodeData.setOutput(rs.getString(12));
-
+                    workflowInstanceNodeData.setStatus(createExecutionStatus(rs.getString(16)),getTime(rs.getString(18)));
                     workflowInstanceData.getNodeDataList().add(workflowInstanceNodeData);
-                    try {
-						experimentData.getWorkflowInstanceData().add(workflowInstanceData);
-					} catch (ExperimentLazyLoadedException e) {
-						e.printStackTrace();
-					}
                 }
             }
             if(rs != null){
@@ -117,10 +116,21 @@ public class ExperimentDataRetriever {
         } catch (SQLException e){
         }catch (ParseException e) {
             logger.error(e.getMessage(), e);
+        } catch (ExperimentLazyLoadedException e) {
+            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
         }
         return experimentData;
     }
 
+    private ExecutionStatus createExecutionStatus (String status){
+       return status == null ? ExecutionStatus.UNKNOWN : ExecutionStatus.valueOf(status);
+    }
+
+    private Date getTime (String date) throws ParseException {
+        DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.S");
+        return dateFormat.parse(date);
+    }
+
     public List<String> getExperimentIdByUser(String user){
         List<String> result=new ArrayList<String>();
         String connectionURL =  Utils.getJDBCURL();

Modified: airavata/trunk/modules/registry/airavata-jpa-registry/src/test/java/org/apache/airavata/persistance/registry/jpa/GatewayResourceTest.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/registry/airavata-jpa-registry/src/test/java/org/apache/airavata/persistance/registry/jpa/GatewayResourceTest.java?rev=1395753&r1=1395752&r2=1395753&view=diff
==============================================================================
--- airavata/trunk/modules/registry/airavata-jpa-registry/src/test/java/org/apache/airavata/persistance/registry/jpa/GatewayResourceTest.java (original)
+++ airavata/trunk/modules/registry/airavata-jpa-registry/src/test/java/org/apache/airavata/persistance/registry/jpa/GatewayResourceTest.java Mon Oct  8 20:13:46 2012
@@ -1,12 +1,8 @@
 package org.apache.airavata.persistance.registry.jpa;
 
 import junit.framework.TestCase;
-import org.apache.airavata.persistance.registry.jpa.model.Project;
 import org.apache.airavata.persistance.registry.jpa.resources.*;
 
-import java.sql.Timestamp;
-import java.util.Calendar;
-import java.util.List;
 
 public class GatewayResourceTest extends TestCase {
     private GatewayResource gatewayResource;
@@ -14,198 +10,40 @@ public class GatewayResourceTest extends
     @Override
     public void setUp() throws Exception {
         super.setUp();
-//        java.util.Date date= new java.util.Date();
-//        Timestamp time = new Timestamp(date.getTime());
-//        ExperimentResource experimentResource = new ExperimentResource();
-//        experimentResource.setExpID("Experiement_ID1");
-//        ExperimentDataResource experimentDataResource = (ExperimentDataResource)experimentResource.create(ResourceType.EXPERIMENT_DATA);
-//        experimentDataResource.setExpName("name1");
-//        experimentDataResource.setUserName("admin");
-//        experimentDataResource.save();
-
-//        ExperimentMetadataResource experimentMetadataResource = (ExperimentMetadataResource)experimentDataResource.create(ResourceType.EXPERIMENT_METADATA);
-
-//        experimentMetadataResource.setMetadata("test metadata");
-//        experimentMetadataResource.save();
-
-//        ExperimentDataResource experimentDataResource = (ExperimentDataResource)experimentResource.get(ResourceType.EXPERIMENT_DATA, "Experiement_ID1");
-//        WorkflowDataResource workflowDataResource = (WorkflowDataResource)experimentDataResource.get(ResourceType.WORKFLOW_DATA, "workflow1");
-//        NodeDataResource nodeDataResource = (NodeDataResource)workflowDataResource.create(ResourceType.NODE_DATA);
-//        GramDataResource gramDataResource = (GramDataResource)workflowDataResource.create(ResourceType.GRAM_DATA);
-
-//        NodeDataResource nodeDataResource = new NodeDataResource();
-
-//        nodeDataResource.setWorkflowDataResource(workflowDataResource);
-//        nodeDataResource.setLastUpdateTime(time);
-//        nodeDataResource.setStartTime(time);
-//        nodeDataResource.setInputs("inputs");
-//        nodeDataResource.setOutputs("outputs");
-//        nodeDataResource.setNodeID("node1");
-//        nodeDataResource.setNodeType("nodeType1");
-//        nodeDataResource.setStatus("OKState");
-//        nodeDataResource.save();
-
-//        GramDataResource gramDataResource = new GramDataResource();
-//        gramDataResource.setWorkflowDataResource(workflowDataResource);
-//        gramDataResource.setNodeID("node1");
-//        gramDataResource.setRsl("rsl");
-//        gramDataResource.setInvokedHost("host1");
-//        gramDataResource.setLocalJobID("job1");
-//        gramDataResource.save();
-//
-//        nodeDataResource = (NodeDataResource)workflowDataResource.get(ResourceType.NODE_DATA, "node1");
-//        System.out.println(nodeDataResource.getInputs());
-//        System.out.println(nodeDataResource.getOutputs());
-//        System.out.println(nodeDataResource.getLastUpdateTime());
-//        System.out.println(nodeDataResource.getNodeID());
-//        System.out.println(nodeDataResource.getNodeType());
-//        System.out.println(nodeDataResource.getStartTime());
-//        System.out.println(nodeDataResource.getStatus());
-//        System.out.println(nodeDataResource.getWorkflowDataResource().getWorkflowInstanceID());
-//
-//        gramDataResource = (GramDataResource)workflowDataResource.get(ResourceType.GRAM_DATA, "node1");
-//        System.out.println(gramDataResource.getWorkflowDataResource().getWorkflowInstanceID());
-//        System.out.println(gramDataResource.getInvokedHost());
-//        System.out.println(gramDataResource.getLocalJobID());
-//        System.out.println(gramDataResource.getNodeID());
-//        System.out.println(gramDataResource.getRsl());
-
-
-
-
-//        workflowDataResource.setWorkflowInstanceID("workflow1");
-//        workflowDataResource.setStatus("OKstatus");
-//        workflowDataResource.setTemplateName("workflow1");
-//        workflowDataResource.setLastUpdatedTime(time);
-//        workflowDataResource.setStartTime(time);
-//        workflowDataResource.save();
-
-
-//        System.out.println("Exp ID : " +workflowDataResource.getExperimentID());
-//        System.out.println("WF Name : " + workflowDataResource.getWorkflowInstanceID());
-//
-//        System.out.println("Status : " +workflowDataResource.getStatus());
-
-//        experimentMetadataResource = (ExperimentMetadataResource)experimentDataResource.get(ResourceType.EXPERIMENT_METADATA, "Experiement_ID1");
-//        System.out.println("exp metadata : " + experimentMetadataResource.getMetadata());
-
-
-
-//        gatewayResource = new GatewayResource();
-//        gatewayResource.setGatewayName("default");
-//        gatewayResource.setOwner("default");
-//        gatewayResource.save();
-//        UserResource userResource = (UserResource)gatewayResource.create(ResourceType.USER);
-//        userResource.setUserName("admin");
-//        userResource.setPassword("admin");
-//        userResource.save();
-//        WorkerResource workerResource = (WorkerResource)gatewayResource.create(ResourceType.GATEWAY_WORKER);
-//        workerResource.setUser(userResource.getUserName());
-//        workerResource.save();
-
+//        gatewayResource = (GatewayResource)ResourceUtils.createGateway("gateway1");
     }
 
-    public void testSave() throws Exception {
-//        ServiceDescriptorResource serviceDescriptorResource = gatewayResource.createServiceDescriptorResource("bb");
-//        serviceDescriptorResource.setUserName("admin");
-//        serviceDescriptorResource.setContent("ccccc");
-//        serviceDescriptorResource.save();
-//
-//        ApplicationDescriptorResource applicationDescriptorResource = gatewayResource.createApplicationDescriptorResource("test");
-//        applicationDescriptorResource.setUpdatedUser("admin");
-//        applicationDescriptorResource.setContent("abc");
-//        applicationDescriptorResource.setHostDescName("aa");
-//        applicationDescriptorResource.setServiceDescName("bb");
-//        applicationDescriptorResource.save();
-//        Calendar cal = Calendar.getInstance();
-//        cal.set( cal.YEAR, 1970 );
-//        cal.set( cal.MONTH, cal.JANUARY );
-//        cal.set( cal.DATE, 1 );
-//
-//        cal.set( cal.HOUR_OF_DAY, 0 );
-//        cal.set( cal.MINUTE, 0 );
-//        cal.set( cal.SECOND, 0 );
-//        cal.set( cal.MILLISECOND, 0 );
-//
-//        java.sql.Date jsqlD =
-//                new java.sql.Date( cal.getTime().getTime() );
-//
-//        ConfigurationResource config = ResourceUtils.createConfiguration("aa");
-//        config.setConfigVal("http://129.79.49.142:8080/axis2/services/WorkflowInterpretor/aaaa");
-//        config.setExpireDate(jsqlD);
-//        config.save();
-
-//        ConfigurationResource configurationResource = new ConfigurationResource();
-//        configurationResource.setConfigKey("cc");
-//        configurationResource.setConfigVal("http://129.79.49.142:8080/axis2/services/WorkflowInterpretor/aaaa");
-//        configurationResource.setExpireDate(jsqlD);
-//        configurationResource.save();
-//        List<HostDescriptorResource>  list = gatewayResource.getHostDescriptorResources();
-//        for(HostDescriptorResource resource : list) {
-//            System.out.println("Host Descriptor name :" +  resource.getHostDescName());
-//        }
-//        Thread t = new Thread(new Runnable() {
-//            @Override
-//            public void run() {
-//                while (true) {
-//                ResourceUtils.removeConfiguration("aa", "http://129.79.49.142:8080/axis2/services/WorkflowInterpretor");
-//                }
-//            }
-//        });
-//        Thread t2 = new Thread(new Runnable() {
-//            @Override
-//            public void run() {
-//                while (true) {
-//                    ConfigurationResource configurationResource = new ConfigurationResource();
-//                    configurationResource.setConfigKey("aa");
-//                    configurationResource.setConfigVal("http://129.79.49.142:8080/axis2/services/WorkflowInterpretor");
-//                    Calendar calendar = Calendar.getInstance();
-//                    //configurationResource.setExpireDate(calendar.);
-//                    configurationResource.save();
-//                }
-//            }
-//        });
-//        t.start();
-//        t2.start();
-//        while(true) {
-//            Thread.sleep(10000);
+//    public void testSave() throws Exception {
+//        gatewayResource.setOwner("owner1");
+//        gatewayResource.save();
+//
+//        boolean gatewayExist = ResourceUtils.isGatewayExist("gateway1");
+//        if(gatewayExist){
+//            assertTrue("The gateway exisits", gatewayExist);
 //        }
-
-    }
-
-    public void testCreate() throws Exception {
-//        boolean result;
-//        HostDescriptorResource hostDescriptorResource = gatewayResource.createHostDescriptorResource("Localhost");
-////        hostDescriptorResource.setHostDescName("Localhost");
-//        hostDescriptorResource.setUserName("admin");
-//        hostDescriptorResource.setContent("<hostDescription xmlns=\"http://schemas.airavata.apache.org/gfac/type\">\n" +
-//                " <hostName>LocalHost</hostName>\n" +
-//                " <hostAddress>127.0.0.1</hostAddress>\n" +
-//                "</hostDescription>");
-//        hostDescriptorResource.save();
-//        result = gatewayResource.isExists(ResourceType.HOST_DESCRIPTOR, "Localhost");
-//        assertTrue("The result doesn't exists", result == true);
-
-
+//
+//    }
+//
+//    public void testCreate() throws Exception {
 //        ProjectResource projectResource = (ProjectResource)gatewayResource.create(ResourceType.PROJECT);
-//        projectResource.setName("project1");
-//        WorkerResource workerResource = new WorkerResource();
-//        workerResource.setGateway(gatewayResource);
-//        workerResource.setUser("admin");
-//        projectResource.setWorker(workerResource);
-//        projectResource.save();
-//        result = workerResource.isProjectExists("project1");
-//        assertTrue("The result doesn't exists", result == true);
-
-    }
-
-    public void testIsExists() throws Exception {
-//        boolean result = gatewayResource.isExists(ResourceType.HOST_DESCRIPTOR, "Localhost");
+//        UserResource userResource = (UserResource)gatewayResource.create(ResourceType.USER);
+//        WorkerResource workerResource = (WorkerResource)gatewayResource.create(ResourceType.USER_WORKFLOW);
+//        PublishWorkflowResource publishWorkflowResource = (PublishWorkflowResource)gatewayResource.create(ResourceType.PUBLISHED_WORKFLOW);
+//        UserWorkflowResource userWorkflowResource = (UserWorkflowResource)gatewayResource.create(ResourceType.USER_WORKFLOW);
+//        HostDescriptorResource hostDescriptorResource = (HostDescriptorResource)gatewayResource.create(ResourceType.HOST_DESCRIPTOR);
 //
-//        assertTrue("The result doesn't exists", result == true);
-
-//        result = gatewayResource.isExists(ResourceType.USER, "admin");
 //
-//        assertTrue("The result exisits", result);
-    }
+//    }
+//
+//    public void testIsExists() throws Exception {
+//
+//    }
+//
+//    public void testGet() throws Exception {
+//
+//    }
+//
+//    public void testGetList() throws Exception {
+//
+//    }
 }