You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sa...@apache.org on 2014/04/14 20:30:11 UTC
[09/90] [abbrv] [partial] AIRAVATA-1124
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/ServiceDescriptionNode.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/ServiceDescriptionNode.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/ServiceDescriptionNode.java
deleted file mode 100644
index 81a5589..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/ServiceDescriptionNode.java
+++ /dev/null
@@ -1,142 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.registrybrowser.nodes;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-
-import javax.swing.Icon;
-import javax.swing.JTree;
-import javax.swing.tree.TreeNode;
-
-import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
-import org.apache.airavata.registry.api.exception.RegistryException;
-import org.apache.airavata.commons.gfac.type.ServiceDescription;
-import org.apache.airavata.xbaya.model.registrybrowser.ApplicationDeploymentDescriptions;
-import org.apache.airavata.xbaya.model.registrybrowser.InputParameters;
-import org.apache.airavata.xbaya.model.registrybrowser.OutputParameters;
-import org.apache.airavata.xbaya.ui.actions.AbstractBrowserActionItem;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.DeleteAction;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.EditAction;
-import org.apache.airavata.xbaya.ui.dialogs.descriptors.DeploymentDescriptionDialog;
-
-public class ServiceDescriptionNode extends AbstractAiravataTreeNode {
- private ServiceDescription serviceDescription;
-
- public ServiceDescriptionNode(ServiceDescription serviceDescription, TreeNode parent) {
- super(parent);
- setServiceDescription(serviceDescription);
- }
-
- @Override
- protected List<TreeNode> getChildren() {
- List<Object> parameterTypeList=new ArrayList<Object>();
- if (getServiceDescription().getType().getInputParametersArray().length>0){
- parameterTypeList.add(new InputParameters(getServiceDescription().getType().getInputParametersArray()));
- }
- if (getServiceDescription().getType().getOutputParametersArray().length>0){
- parameterTypeList.add(new OutputParameters(getServiceDescription().getType().getOutputParametersArray()));
- }
- parameterTypeList.add(new ApplicationDeploymentDescriptions(getRegistry(),getServiceDescription().getType().getName()));
- return getTreeNodeList(parameterTypeList.toArray(), this);
- }
-
- @Override
- public String getCaption(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return getServiceDescription().getType().getName();
- }
-
- @Override
- public Icon getIcon(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return JCRBrowserIcons.SERVICE_ICON;
- }
-
- public ServiceDescription getServiceDescription() {
- return serviceDescription;
- }
-
- public void setServiceDescription(ServiceDescription serviceDescription) {
- this.serviceDescription = serviceDescription;
- }
-
- @Override
- public List<String> getSupportedActions() {
- return Arrays.asList(EditAction.ID, DeleteAction.ID);
- }
-
- public boolean triggerAction(JTree tree, String action) throws Exception {
- if (action.equals(DeleteAction.ID)) {
- return deleteServiceDescription(tree);
- } else if (action.equals(EditAction.ID)) {
- return editServiceDescription(tree);
- }
- return super.triggerAction(tree, action);
- }
-
- private boolean editServiceDescription(JTree tree) {
- DeploymentDescriptionDialog serviceDescriptionDialog = new DeploymentDescriptionDialog(getRegistry(),false,getServiceDescription(), null);
- serviceDescriptionDialog.open();
-// ServiceDescriptionDialog serviceDescriptionDialog = new ServiceDescriptionDialog(getRegistry(),false,getServiceDescription());
-// serviceDescriptionDialog.open();
- if (serviceDescriptionDialog.isServiceCreated()) {
- refresh();
- reloadTreeNode(tree, this);
- }
- return true;
- }
-
- private boolean deleteServiceDescription(JTree tree) throws AiravataAPIInvocationException {
- if (askQuestion("Application", "Are you sure that you want to remove the applications associated with \""
- + getServiceDescription().getType().getName() + "\"?")) {
- getRegistry().getApplicationManager().deleteServiceDescription(getServiceDescription().getType().getName());
- ((AbstractAiravataTreeNode) getParent()).refresh();
- reloadTreeNode(tree, getParent());
- }
- return true;
- }
-
- @Override
- public String getActionCaption(AbstractBrowserActionItem action) {
- if (action.getID().equals(DeleteAction.ID)) {
- return "Remove";
- } else if (action.getID().equals(EditAction.ID)) {
- return "View/Edit";
- }
- return action.getDefaultCaption();
- }
-
- @Override
- public Icon getActionIcon(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getActionDescription(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getDefaultAction() {
- return EditAction.ID;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/ServiceDescriptionsNode.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/ServiceDescriptionsNode.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/ServiceDescriptionsNode.java
deleted file mode 100644
index dbfce2e..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/ServiceDescriptionsNode.java
+++ /dev/null
@@ -1,137 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.registrybrowser.nodes;
-
-import java.util.Arrays;
-import java.util.List;
-
-import javax.swing.Icon;
-import javax.swing.JTree;
-import javax.swing.tree.TreeNode;
-
-import org.apache.airavata.client.api.AiravataAPI;
-import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
-import org.apache.airavata.registry.api.exception.RegistryException;
-import org.apache.airavata.commons.gfac.type.ServiceDescription;
-//import org.apache.airavata.registry.api.AiravataRegistry2;
-import org.apache.airavata.xbaya.model.registrybrowser.ServiceDescriptions;
-import org.apache.airavata.xbaya.ui.actions.AbstractBrowserActionItem;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.AddAction;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.DeleteAction;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.RefreshAction;
-import org.apache.airavata.xbaya.ui.dialogs.descriptors.DeploymentDescriptionDialog;
-
-public class ServiceDescriptionsNode extends AbstractAiravataTreeNode {
- private ServiceDescriptions serviceDescriptions;
-
- public ServiceDescriptionsNode(ServiceDescriptions serviceDescriptions, TreeNode parent) {
- super(parent);
- setServiceDescriptions(serviceDescriptions);
- }
-
- @Override
- protected List<TreeNode> getChildren() {
- try {
- return getTreeNodeList(getServiceDescriptions().getDescriptions().toArray(), this);
- } catch (AiravataAPIInvocationException e) {
- e.printStackTrace();
- return emptyList();
- } catch (RegistryException e) {
- e.printStackTrace();
- return emptyList();
- }
- }
-
- @Override
- public String getCaption(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return "Applications";
- }
-
- @Override
- public Icon getIcon(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return JCRBrowserIcons.SERVICES_ICON;
- }
-
- public ServiceDescriptions getServiceDescriptions() {
- return serviceDescriptions;
- }
-
- public void setServiceDescriptions(ServiceDescriptions serviceDescriptions) {
- this.serviceDescriptions = serviceDescriptions;
- }
-
- @Override
- public List<String> getSupportedActions() {
- return Arrays.asList(AddAction.ID, RefreshAction.ID, DeleteAction.ID);
- }
-
- public boolean triggerAction(JTree tree, String action) throws Exception {
- if (action.equals(DeleteAction.ID)) {
- deleteServiceDescription(tree);
- return true;
- } else if (action.equals(AddAction.ID)) {
- DeploymentDescriptionDialog serviceDescriptionDialog = new DeploymentDescriptionDialog(null, getRegistry());
- serviceDescriptionDialog.open();
-// ServiceDescriptionDialog serviceDescriptionDialog = new ServiceDescriptionDialog(getRegistry());
-// serviceDescriptionDialog.open();
- if (serviceDescriptionDialog.isServiceCreated()) {
- refresh();
- reloadTreeNode(tree, this);
- }
- return true;
- }
- return super.triggerAction(tree, action);
- }
-
- private void deleteServiceDescription(JTree tree) throws Exception {
- if (askQuestion("Applications",
- "Are you sure that you want to remove all applications defined in this registry?")) {
- AiravataAPI registry = getRegistry();
- List<ServiceDescription> descriptions = getServiceDescriptions().getDescriptions();
- for (ServiceDescription descriptionWrap : descriptions) {
- registry.getApplicationManager().deleteServiceDescription(descriptionWrap.getType().getName());
- }
- refresh();
- reloadTreeNode(tree, this);
- }
- }
-
- @Override
- public String getActionCaption(AbstractBrowserActionItem action) {
- if (action.getID().equals(DeleteAction.ID)) {
- return "Remove all Applicatons";
- } else if (action.getID().equals(AddAction.ID)) {
- return "Register Application...";
- }
- return action.getDefaultCaption();
- }
-
- @Override
- public Icon getActionIcon(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getActionDescription(AbstractBrowserActionItem action) {
- return null;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowExperimentNode.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowExperimentNode.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowExperimentNode.java
deleted file mode 100644
index d7294db..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowExperimentNode.java
+++ /dev/null
@@ -1,141 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.registrybrowser.nodes;
-
-import java.awt.*;
-import java.awt.datatransfer.StringSelection;
-import java.util.Arrays;
-import java.util.List;
-
-import javax.swing.Icon;
-import javax.swing.JTree;
-import javax.swing.tree.TreeNode;
-
-import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
-import org.apache.airavata.registry.api.exception.RegistryException;
-import org.apache.airavata.registry.api.workflow.ExperimentName;
-import org.apache.airavata.registry.api.workflow.WorkflowExecutionStatus;
-import org.apache.airavata.xbaya.model.registrybrowser.XBayaWorkflowExperiment;
-import org.apache.airavata.xbaya.ui.actions.AbstractBrowserActionItem;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.CopyAction;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.DeleteAction;
-
-public class XBayaWorkflowExperimentNode extends AbstractAiravataTreeNode {
- private XBayaWorkflowExperiment experiment;
- private String workflowExecutionName;
-
- public XBayaWorkflowExperimentNode(XBayaWorkflowExperiment experiment, TreeNode parent) {
- super(parent);
- setExperiment(experiment);
- }
-
- @Override
- protected List<TreeNode> getChildren() {
- return getTreeNodeList(getExperiment().getWorkflows().toArray(), this);
- }
-
- @Override
- public String getCaption(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- if (workflowExecutionName==null) {
- try {
- workflowExecutionName = getRegistry().getProvenanceManager().getExperimentName(getExperiment().getExperimentId()).getInstanceName();
- } catch (AiravataAPIInvocationException e) {
- e.printStackTrace();
- }
- if (workflowExecutionName==null){
- workflowExecutionName="["+getExperiment().getExperimentId()+"]";
- }
- }
- String caption=workflowExecutionName;
- try {
- WorkflowExecutionStatus workflowExecutionStatus = getRegistry().getProvenanceManager().getWorkflowInstanceStatus(getExperiment().getExperimentId(), getExperiment().getExperimentId());
- if (workflowExecutionStatus!=null && workflowExecutionStatus.getExecutionStatus()!=null){
- caption += " - <i>" + workflowExecutionStatus.getExecutionStatus().toString()+"</i>";
- if (workflowExecutionStatus.getStatusUpdateTime()!=null) {
- caption += "<i> as of " + workflowExecutionStatus.getStatusUpdateTime().toString() + "</i>";
- }
- }
- } catch (AiravataAPIInvocationException e) {
- e.printStackTrace();
- }
- return wrapAsHtml(caption);
- }
-
- @Override
- public Icon getIcon(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return JCRBrowserIcons.WORKFLOW_EXPERIMENT_ICON;
- }
-
- @Override
- public List<String> getSupportedActions() {
- return Arrays.asList(CopyAction.ID);
- }
-
- public boolean triggerAction(JTree tree, String action) throws Exception {
- if (action.equals(CopyAction.ID)) {
- Toolkit.getDefaultToolkit().getSystemClipboard().setContents(new StringSelection(getExperimentInfo()), null);
- }
- return super.triggerAction(tree, action);
- }
-
- private String getExperimentName (){
- String experimentId = getExperiment().getExperimentId();
- try {
- ExperimentName experimentName = getExperiment().getAiravataAPI().getProvenanceManager().getExperimentName(experimentId);
- return experimentName.getInstanceName();
- } catch (AiravataAPIInvocationException e) {
- return null;
- }
- }
-
- private String getExperimentInfo (){
- String experimetName = getExperimentName();
- String experimetID = getExperiment().getExperimentId();
- return "[Experiment Name = " + experimetName + ", Experiment ID = " + experimetID + "]";
- }
-
- @Override
- public String getActionCaption(AbstractBrowserActionItem action) {
- if (action.getID().equals(CopyAction.ID)) {
- return "Copy Experiment Info to clipboard";
- }
- return action.getDefaultCaption();
- }
-
- @Override
- public Icon getActionIcon(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getActionDescription(AbstractBrowserActionItem action) {
- return null;
- }
-
- public XBayaWorkflowExperiment getExperiment() {
- return experiment;
- }
-
- public void setExperiment(XBayaWorkflowExperiment experiment) {
- this.experiment = experiment;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowExperimentsNode.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowExperimentsNode.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowExperimentsNode.java
deleted file mode 100644
index 420dea3..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowExperimentsNode.java
+++ /dev/null
@@ -1,89 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.registrybrowser.nodes;
-
-import java.util.Arrays;
-import java.util.List;
-
-import javax.swing.Icon;
-import javax.swing.JTree;
-import javax.swing.tree.TreeNode;
-
-import org.apache.airavata.xbaya.model.registrybrowser.XBayaWorkflowExperiments;
-import org.apache.airavata.xbaya.ui.actions.AbstractBrowserActionItem;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.RefreshAction;
-
-public class XBayaWorkflowExperimentsNode extends AbstractAiravataTreeNode {
- private XBayaWorkflowExperiments experiments;
-
- public XBayaWorkflowExperimentsNode(XBayaWorkflowExperiments experiments, TreeNode parent) {
- super(parent);
- setExperiments(experiments);
- }
-
- @Override
- protected List<TreeNode> getChildren() {
- return getTreeNodeList(getExperiments().getAllExperiments().toArray(), this);
- }
-
- @Override
- public String getCaption(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return "Experiments";
- }
-
- @Override
- public Icon getIcon(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return JCRBrowserIcons.WORKFLOW_EXPERIMENTS_ICON;
- }
-
- @Override
- public List<String> getSupportedActions() {
- return Arrays.asList(RefreshAction.ID);
- }
-
- public boolean triggerAction(JTree tree, String action) throws Exception {
- return super.triggerAction(tree, action);
- }
-
- @Override
- public String getActionCaption(AbstractBrowserActionItem action) {
- return action.getDefaultCaption();
- }
-
- @Override
- public Icon getActionIcon(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getActionDescription(AbstractBrowserActionItem action) {
- return null;
- }
-
- public XBayaWorkflowExperiments getExperiments() {
- return experiments;
- }
-
- public void setExperiments(XBayaWorkflowExperiments experiments) {
- this.experiments = experiments;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowNode.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowNode.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowNode.java
deleted file mode 100644
index 1d38b80..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowNode.java
+++ /dev/null
@@ -1,107 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.registrybrowser.nodes;
-
-import java.awt.*;
-import java.awt.datatransfer.StringSelection;
-import java.util.Arrays;
-import java.util.List;
-
-import javax.swing.Icon;
-import javax.swing.JTree;
-import javax.swing.tree.TreeNode;
-
-import org.apache.airavata.xbaya.model.registrybrowser.XBayaWorkflow;
-import org.apache.airavata.xbaya.ui.actions.AbstractBrowserActionItem;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.CopyAction;
-
-public class XBayaWorkflowNode extends AbstractAiravataTreeNode {
- private XBayaWorkflow xbayaWorkflow;
-
- public XBayaWorkflowNode(XBayaWorkflow xbayaWorkflow, TreeNode parent) {
- super(parent);
- setXbayaWorkflow(xbayaWorkflow);
- }
-
- @Override
- protected List<TreeNode> getChildren() {
- return getTreeNodeList(getXbayaWorkflow().getWorkflowServices().toArray(),this);
- }
-
- @Override
- public String getCaption(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- String caption=getXbayaWorkflow().getWorkflowId();
- if (getXbayaWorkflow().getWorkflowName()!=null){
- caption=getXbayaWorkflow().getWorkflowName()+" : "+caption;
- }
- return caption;
- }
-
- @Override
- public Icon getIcon(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return JCRBrowserIcons.WORKFLOW_ICON;
- }
-
- public XBayaWorkflow getXbayaWorkflow() {
- return xbayaWorkflow;
- }
-
- public void setXbayaWorkflow(XBayaWorkflow xbayaWorkflow) {
- this.xbayaWorkflow = xbayaWorkflow;
- }
-
- @Override
- public List<String> getSupportedActions() {
- return Arrays.asList(CopyAction.ID);
- }
-
- public boolean triggerAction(JTree tree, String action) throws Exception {
- if (action.equals(CopyAction.ID)) {
- Toolkit.getDefaultToolkit().getSystemClipboard().setContents(new StringSelection(getWorkflowInfo()), null);
- }
- return super.triggerAction(tree, action);
- }
-
- private String getWorkflowInfo (){
- String workflowName = getXbayaWorkflow().getWorkflowName();
- String workflowId = getXbayaWorkflow().getWorkflowId();
- return "[Worklfow Name = " + workflowName + ", Workflow Instance ID = " + workflowId + "]";
- }
-
- @Override
- public String getActionCaption(AbstractBrowserActionItem action) {
- if (action.getID().equals(CopyAction.ID)) {
- return "Copy Workflow Info to clipboard";
- }
- return action.getDefaultCaption();
- }
-
- @Override
- public Icon getActionIcon(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getActionDescription(AbstractBrowserActionItem action) {
- return null;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowNodeElementNode.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowNodeElementNode.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowNodeElementNode.java
deleted file mode 100644
index 5cf32de..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowNodeElementNode.java
+++ /dev/null
@@ -1,101 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.registrybrowser.nodes;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-
-import javax.swing.Icon;
-import javax.swing.JTree;
-import javax.swing.tree.TreeNode;
-
-import org.apache.airavata.xbaya.model.registrybrowser.ServiceParameters;
-import org.apache.airavata.xbaya.model.registrybrowser.XBayaWorkflowNodeElement;
-import org.apache.airavata.xbaya.ui.actions.AbstractBrowserActionItem;
-
-public class XBayaWorkflowNodeElementNode extends AbstractAiravataTreeNode {
- private XBayaWorkflowNodeElement xbayaWorkflowService;
-
- public XBayaWorkflowNodeElementNode(XBayaWorkflowNodeElement xbayaWorkflowNodeElement, TreeNode parent) {
- super(parent);
- setXbayaWorkflowNodeElement(xbayaWorkflowNodeElement);
- }
-
- @Override
- protected List<TreeNode> getChildren() {
- List<ServiceParameters> parameterTypeList=new ArrayList<ServiceParameters>();
- if (getXbayaWorkflowNodeElement().getInputParameters()!=null && getXbayaWorkflowNodeElement().getInputParameters().getParameters().size()>0){
- parameterTypeList.add(getXbayaWorkflowNodeElement().getInputParameters());
- }
- if (getXbayaWorkflowNodeElement().getOutputParameters()!=null && getXbayaWorkflowNodeElement().getOutputParameters().getParameters().size()>0){
- parameterTypeList.add(getXbayaWorkflowNodeElement().getOutputParameters());
- }
- return getTreeNodeList(parameterTypeList.toArray(), this);
- }
-
- @Override
- public String getCaption(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- String type = getXbayaWorkflowNodeElement().getNodeData().getType().toString();
-// if (selected) {
-// type = " <font color=\"#D3D3D3\">Service call</font>";
-// }
- return wrapAsHtml(getXbayaWorkflowNodeElement().getNodeId()," [", type, "]");
- }
-
- @Override
- public Icon getIcon(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return JCRBrowserIcons.WORKFLOW_SERVICE_ICON;
- }
-
- @Override
- public List<String> getSupportedActions() {
- return Arrays.asList();
- }
-
- public boolean triggerAction(JTree tree, String action) throws Exception {
- return super.triggerAction(tree, action);
- }
-
- @Override
- public String getActionCaption(AbstractBrowserActionItem action) {
- return action.getDefaultCaption();
- }
-
- @Override
- public Icon getActionIcon(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getActionDescription(AbstractBrowserActionItem action) {
- return null;
- }
-
- public XBayaWorkflowNodeElement getXbayaWorkflowNodeElement() {
- return xbayaWorkflowService;
- }
-
- public void setXbayaWorkflowNodeElement(XBayaWorkflowNodeElement xbayaWorkflowNodeElement) {
- this.xbayaWorkflowService = xbayaWorkflowNodeElement;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowTemplateNode.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowTemplateNode.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowTemplateNode.java
deleted file mode 100644
index 0edc847..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowTemplateNode.java
+++ /dev/null
@@ -1,130 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.registrybrowser.nodes;
-
-import java.util.Arrays;
-import java.util.List;
-
-import javax.jcr.PathNotFoundException;
-import javax.swing.Icon;
-import javax.swing.JTree;
-import javax.swing.tree.TreeNode;
-
-import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
-import org.apache.airavata.registry.api.exception.RegistryException;
-import org.apache.airavata.registry.api.exception.ServiceDescriptionRetrieveException;
-import org.apache.airavata.workflow.model.wf.Workflow;
-import org.apache.airavata.xbaya.model.registrybrowser.XBayaWorkflowTemplate;
-import org.apache.airavata.xbaya.registry.RegistryAccesser;
-import org.apache.airavata.xbaya.ui.actions.AbstractBrowserActionItem;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.DeleteAction;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.ImportAction;
-import org.apache.airavata.xbaya.ui.graph.GraphCanvas;
-
-public class XBayaWorkflowTemplateNode extends AbstractAiravataTreeNode {
- private XBayaWorkflowTemplate xbayaWorkflow;
-
- public XBayaWorkflowTemplateNode(XBayaWorkflowTemplate xbayaWorkflow, TreeNode parent) {
- super(parent);
- setXbayaWorkflow(xbayaWorkflow);
- }
-
- @Override
- protected List<TreeNode> getChildren() {
- return emptyList();
- }
-
- @Override
- public String getCaption(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return getXbayaWorkflow().getWorkflowName();
- }
-
- @Override
- public Icon getIcon(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return JCRBrowserIcons.WORKFLOW_TEMPLATE_ICON;
- }
-
- public XBayaWorkflowTemplate getXbayaWorkflow() {
- return xbayaWorkflow;
- }
-
- public void setXbayaWorkflow(XBayaWorkflowTemplate xbayaWorkflow) {
- this.xbayaWorkflow = xbayaWorkflow;
- }
-
- @Override
- public List<String> getSupportedActions() {
- return Arrays.asList(ImportAction.ID,DeleteAction.ID);
- }
-
- public boolean triggerAction(JTree tree, String action) throws Exception {
- if (action.equals(DeleteAction.ID)) {
- deleteHostDescription(tree);
- return true;
- } else if (action.equals(ImportAction.ID)) {
- Workflow workflow = new RegistryAccesser(getXBayaEngine()).getWorkflow(getXbayaWorkflow().getWorkflowName());
- GraphCanvas newGraphCanvas = getXBayaEngine().getGUI().newGraphCanvas(true);
- newGraphCanvas.setWorkflow(workflow);
- getXBayaEngine().getGUI().getGraphCanvas().setWorkflowFile(null);
- return true;
- }
- return super.triggerAction(tree, action);
- }
-
- private void deleteHostDescription(JTree tree) throws PathNotFoundException, ServiceDescriptionRetrieveException {
- if (askQuestion("XBaya Workflow", "Are you sure that you want to remove the workflow \""
- + getXbayaWorkflow().getWorkflowName() + "\"?")) {
- try {
- getRegistry().getWorkflowManager().removeWorkflow(getXbayaWorkflow().getWorkflowName());
- ((AbstractAiravataTreeNode) getParent()).refresh();
- reloadTreeNode(tree, getParent());
- } catch (AiravataAPIInvocationException e) {
- e.printStackTrace();
- }
- }
- }
-
- @Override
- public String getActionCaption(AbstractBrowserActionItem action) {
- if (action.getID().equals(DeleteAction.ID)) {
- return "Remove";
- } else if (action.getID().equals(ImportAction.ID)) {
- return "Import";
- }
- return action.getDefaultCaption();
- }
-
- @Override
- public Icon getActionIcon(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getActionDescription(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getDefaultAction() {
- return ImportAction.ID;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowTemplatesNode.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowTemplatesNode.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowTemplatesNode.java
deleted file mode 100644
index f3b0c43..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/registrybrowser/nodes/XBayaWorkflowTemplatesNode.java
+++ /dev/null
@@ -1,99 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.registrybrowser.nodes;
-
-import java.util.Arrays;
-import java.util.List;
-
-import javax.swing.Icon;
-import javax.swing.JOptionPane;
-import javax.swing.JTree;
-import javax.swing.tree.TreeNode;
-
-import org.apache.airavata.xbaya.model.registrybrowser.XBayaWorkflowTemplates;
-import org.apache.airavata.xbaya.ui.actions.AbstractBrowserActionItem;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.AddAction;
-import org.apache.airavata.xbaya.ui.actions.registry.browser.RefreshAction;
-
-public class XBayaWorkflowTemplatesNode extends AbstractAiravataTreeNode {
- private XBayaWorkflowTemplates xbayaWorkflows;
-
- public XBayaWorkflowTemplatesNode(XBayaWorkflowTemplates xbayaWorkflows, TreeNode parent) {
- super(parent);
- setXbayaWorkflows(xbayaWorkflows);
- }
-
- @Override
- protected List<TreeNode> getChildren() {
- return getTreeNodeList(getXbayaWorkflows().getWorkflows().toArray(), this);
- }
-
- @Override
- public String getCaption(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return "Workflow Templates";
- }
-
- @Override
- public Icon getIcon(boolean selected, boolean expanded, boolean leaf, boolean hasFocus) {
- return JCRBrowserIcons.WORKFLOW_TEMPLATES_ICON;
- }
-
- public XBayaWorkflowTemplates getXbayaWorkflows() {
- return xbayaWorkflows;
- }
-
- public void setXbayaWorkflows(XBayaWorkflowTemplates xbayaWorkflows) {
- this.xbayaWorkflows = xbayaWorkflows;
- }
-
- @Override
- public List<String> getSupportedActions() {
- return Arrays.asList(RefreshAction.ID);
- }
-
- public boolean triggerAction(JTree tree, String action) throws Exception {
- if (action.equals(AddAction.ID)) {
- JOptionPane.showMessageDialog(null, "TODO");
- // TODO
- return true;
- }
- return super.triggerAction(tree, action);
- }
-
- @Override
- public String getActionCaption(AbstractBrowserActionItem action) {
- if (action.getID().equals(AddAction.ID)) {
- return "New workflow...";
- }
- return action.getDefaultCaption();
- }
-
- @Override
- public Icon getActionIcon(AbstractBrowserActionItem action) {
- return null;
- }
-
- @Override
- public String getActionDescription(AbstractBrowserActionItem action) {
- return null;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/scufl/script/ScuflScript.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/scufl/script/ScuflScript.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/scufl/script/ScuflScript.java
deleted file mode 100644
index 27442e4..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/scufl/script/ScuflScript.java
+++ /dev/null
@@ -1,539 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.scufl.script;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.UUID;
-
-import javax.xml.namespace.QName;
-
-import org.apache.airavata.workflow.model.component.ws.WSComponent;
-import org.apache.airavata.workflow.model.graph.DataPort;
-import org.apache.airavata.workflow.model.graph.GraphException;
-import org.apache.airavata.workflow.model.graph.Node;
-import org.apache.airavata.workflow.model.graph.Port;
-import org.apache.airavata.workflow.model.graph.impl.NodeImpl;
-import org.apache.airavata.workflow.model.graph.system.ConstantNode;
-import org.apache.airavata.workflow.model.graph.system.EndifNode;
-import org.apache.airavata.workflow.model.graph.system.IfNode;
-import org.apache.airavata.workflow.model.graph.system.InputNode;
-import org.apache.airavata.workflow.model.graph.system.MemoNode;
-import org.apache.airavata.workflow.model.graph.system.OutputNode;
-import org.apache.airavata.workflow.model.graph.util.GraphUtil;
-import org.apache.airavata.workflow.model.graph.ws.WSGraph;
-import org.apache.airavata.workflow.model.graph.ws.WSNode;
-import org.apache.airavata.workflow.model.wf.Workflow;
-import org.apache.airavata.xbaya.XBayaConfiguration;
-import org.xmlpull.infoset.impl.XmlElementWithViewsImpl;
-import org.xmlpull.v1.builder.XmlBuilderException;
-import org.xmlpull.v1.builder.XmlDocument;
-import org.xmlpull.v1.builder.XmlElement;
-import org.xmlpull.v1.builder.XmlInfosetBuilder;
-import org.xmlpull.v1.builder.XmlNamespace;
-
-import xsul.XmlConstants;
-import xsul5.wsdl.WsdlMessage;
-import xsul5.wsdl.WsdlMessagePart;
-import xsul5.wsdl.WsdlPort;
-import xsul5.wsdl.WsdlPortType;
-import xsul5.wsdl.WsdlPortTypeOperation;
-import xsul5.wsdl.WsdlService;
-
-public class ScuflScript {
-
- private Workflow workflow;
-
- private XBayaConfiguration configuration;
-
- private WSGraph graph;
-
- private ArrayList<String> arguments;
-
- private List<InputNode> inputNodes;
-
- private List<OutputNode> outputNodes;
-
- private XmlInfosetBuilder builder = XmlConstants.BUILDER;
-
- private LinkedList<Node> notYetInvokedNodes;
-
- private LinkedList<Node> executingNodes;
-
- private XmlNamespace scuflNS = builder.newNamespace("s", "http://org.embl.ebi.escience/xscufl/0.1alpha");
-
- private Map<String, XmlElement> sources = new HashMap<String, XmlElement>();
-
- private List<XmlElement> links = new ArrayList<XmlElement>();
-
- private List<XmlElement> sinks = new ArrayList<XmlElement>();
-
- private XmlDocument script;
-
- public ScuflScript(Workflow workflow, XBayaConfiguration configuration) {
- this.workflow = workflow;
- this.configuration = configuration;
- this.graph = this.workflow.getGraph();
-
- this.arguments = new ArrayList<String>();
-
- this.notYetInvokedNodes = new LinkedList<Node>();
- for (Node node : this.graph.getNodes()) {
- if (!(node instanceof MemoNode)) {
- this.notYetInvokedNodes.add(node);
- }
- }
- this.executingNodes = new LinkedList<Node>();
- this.inputNodes = GraphUtil.getInputNodes(this.graph);
- this.outputNodes = GraphUtil.getOutputNodes(this.graph);
- }
-
- public void create() throws GraphException {
-
- XmlDocument doc = builder.newDocument();
-
- XmlElement scufl = doc.addDocumentElement(scuflNS, "scufl");
- scufl.addAttribute("version", "0.2");
- scufl.addAttribute("log", "0");
- XmlElement description = scufl.addElement(scuflNS, "workflowdescription");
- description.addAttribute("lsid", "urn:lsid:net.sf.taverna:wfDefinition:" + UUID.randomUUID());
- description.addAttribute("author", "");
- description.addAttribute("title", workflow.getName());
- writeServices(scufl);
-
- writeSplitors(scufl);
-
- // add links
- for (XmlElement link : this.links) {
- scufl.addElement(link);
- }
-
- // add source
- for (String key : this.sources.keySet()) {
- scufl.addElement(this.sources.get(key));
- }
-
- // add sinks
- for (XmlElement sink : this.sinks) {
- scufl.addElement(sink);
- }
-
- this.script = doc;
-
- }
-
- public String getScript() {
- return builder.serializeToString(this.script);
- }
-
- /**
- * @param scufl
- * @throws GraphException
- */
- private void writeSplitors(XmlElement scufl) throws GraphException {
-
- Collection<Node> nextNodes = getNextNodes();
- while (nextNodes.size() > 0) {
- for (Node node : nextNodes) {
-
- if (node instanceof WSNode) {
- WSNode wsNode = (WSNode) node;
- node.getInputPorts();
- writeSplitorPerService(scufl, wsNode);
-
- } else {
- // TODO conditions, loops might come here.
- }
- this.notYetInvokedNodes.remove(node);
- nextNodes = getNextNodes();
- }
- }
- }
-
- /**
- * @param scufl
- * @param node
- * @throws GraphException
- */
- private void writeSplitorPerService(XmlElement scufl, WSNode node) throws GraphException {
- List<DataPort> inputPorts = node.getInputPorts();
- XmlElement processor = scufl.addElement(scuflNS, "processor");
- processor.addAttribute("name", getValidName(node) + "InputMessagePartXML");
- XmlElement local = processor.addElement(scuflNS, "local");
- local.addChild(0, "org.embl.ebi.escience.scuflworkers.java.XMLInputSplitter");
- XmlElement extensions = local.addElement(scuflNS, "extensions");
-
- QName inputName = getInputElementName(node);
- if (null == inputName) {
- throw new GraphException("No Valid input type found for WS Node" + node.getName());
- }
- if (node.getOutputPorts().size() != 1) {
- throw new GraphException("Number of out ports in WS node " + node.getName() + "is invalid:"
- + node.getOutputPorts().size());
- }
- DataPort outputPort = node.getOutputPort(0);
-
- WSComponent component = node.getComponent();
- String inputPartName = component.getInputPartName();
- String inputTypeName = component.getInputTypeName();
-
- XmlElement complexType = extensions.addElement(scuflNS, "complextype");
- complexType.addAttribute("optional", "false");
- complexType.addAttribute("unbounded", "false");
- complexType.addAttribute("typename", inputTypeName);
-
- String spliterName = inputPartName;
- complexType.addAttribute("name", spliterName);
- complexType.addAttribute("qname", inputName.toString());
-
- XmlElement element = complexType.addElement(scuflNS, "elements");
- for (DataPort port : inputPorts) {
- if ("http://www.w3.org/2001/XMLSchema".equals(port.getType().getNamespaceURI())) {
- XmlElement baseType = element.addElement(scuflNS, "basetype");
- baseType.addAttribute("optional", "false");
- baseType.addAttribute("unbounded", "false");
- baseType.addAttribute("typename", port.getType().getLocalPart());
- baseType.addAttribute("name", port.getName());
- baseType.addAttribute("qname", inputTypeName + ">" + port.getName());
-
- }
- // all the sources are written here
- // the links from input nodes to the spiters are done here
- // links from the from node output splitter to the this service's
- // inputsplitter is done here
-
- if (port.getFromNode() instanceof InputNode) {
- XmlElement source = builder.newFragment(scuflNS, "source");
- source.addAttribute("name", port.getFromNode().getID());
- if (!sourceExist(port.getFromNode().getID())) {
- this.sources.put(port.getFromNode().getID(), source);
- }
- XmlElement link = builder.newFragment(scuflNS, "link");
- link.addAttribute("source", port.getFromNode().getID());
- link.addAttribute("sink", getValidName(node) + "InputMessagePartXML:" + port.getName());
- this.links.add(link);
-
- } else if (port.getFromNode() instanceof WSNode) {
- XmlElement link = builder.newFragment(scuflNS, "link");
- if (port.getFromNode().getOutputPorts().size() != 1) {
- throw new GraphException("Number of out ports in from WS node " + port.getFromNode().getName()
- + "is invalid:" + node.getOutputPorts().size());
- }
- link.addAttribute("source", getValidName((WSNode) port.getFromNode()) + "OutputMessagePartXML:"
- + port.getFromNode().getOutputPort(0).getName());
- link.addAttribute("sink", getValidName(node) + "InputMessagePartXML:" + port.getName());
- this.links.add(link);
- } else {
- throw new GraphException("Unhandled from node type:" + port.getFromNode() + " for node"
- + node.getName());
- }
- }
-
- // link from the spliter to the service
-
- XmlElement link = builder.newFragment(scuflNS, "link");
- link.addAttribute("source", getValidName(node) + "InputMessagePartXML:output");
- link.addAttribute("sink", getValidName(node) + ":" + spliterName);
- this.links.add(link);
-
- // link from service out to the ouput spliter
-
- link = builder.newFragment(scuflNS, "link");
- link.addAttribute("source", getValidName(node) + ":" + node.getComponent().getOutputPartName());
- link.addAttribute("sink", getValidName(node) + "OutputMessagePartXML:input");
- this.links.add(link);
-
- // /outspiltor
- XmlElement outProcessor = scufl.addElement(scuflNS, "processor");
- outProcessor.addAttribute("name", getValidName(node) + "OutputMessagePartXML");
- XmlElement outLocal = outProcessor.addElement(scuflNS, "local");
- outLocal.addChild(0, "org.embl.ebi.escience.scuflworkers.java.XMLOutputSplitter");
- XmlElement outExtensions = outLocal.addElement(scuflNS, "extensions");
- XmlElement outComplextype = outExtensions.addElement(scuflNS, "complextype");
- outComplextype.addAttribute("optional", "false");
- outComplextype.addAttribute("unbounded", "false");
- outComplextype.addAttribute("typename", component.getOutputTypeName());
- outComplextype.addAttribute("name", component.getOutputPartName());
- QName outputName = getOutputElementName(node);
- if (null == outputName) {
- throw new GraphException("No Valid output type found for WS Node" + node.getName());
- }
- outComplextype.addAttribute("qname", outputName.toString());
- XmlElement elements = outComplextype.addElement(scuflNS, "elements");
- XmlElement outBaseType = elements.addElement(scuflNS, "basetype");
- outBaseType.addAttribute("optional", "false");
- outBaseType.addAttribute("unbounded", "false");
-
- outBaseType.addAttribute("typename", outputPort.getType().getLocalPart());
- String Z = component.getOutputPort(0).getName();
- outBaseType.addAttribute("name", Z);
-
- outBaseType.addAttribute("qname", component.getOutputTypeName() + ">" + Z);
-
- List<DataPort> outputPorts = node.getOutputPorts();
- for (DataPort port : outputPorts) {
- List<Node> toNodes = port.getToNodes();
- for (Node toNode : toNodes) {
- if (toNode instanceof OutputNode) {
- if ("http://www.w3.org/2001/XMLSchema".equals(port.getType().getNamespaceURI())) {
- XmlElement sink = builder.newFragment(scuflNS, "sink");
- sink.addAttribute("name", toNode.getID());
- sinks.add(sink);
- link = builder.newFragment(scuflNS, "link");
- link.addAttribute("source", getValidName(node) + "OutputMessagePartXML:" + outputPort.getName());
- link.addAttribute("sink", toNode.getID());
- this.links.add(link);
- }
- }
- }
- }
-
- }
-
- private boolean sourceExist(String name) {
- Set<String> keys = this.sources.keySet();
- for (String string : keys) {
- if (name.equals(string))
- return true;
- }
- return false;
- }
-
- /**
- * @param node
- * @return
- * @throws GraphException
- */
- private QName getInputElementName(WSNode node) throws GraphException {
- WSComponent component = node.getComponent();
- String portTypeName = component.getPortTypeQName().getLocalPart();
- WsdlPortType portType = component.getWSDL().getPortType(portTypeName);
- WsdlPortTypeOperation operation = portType.getOperation(component.getOperationName());
- QName message = operation.getInput().getMessage();
- WsdlMessage wsdlMessage = component.getWSDL().getMessage(message.getLocalPart());
- Iterator<WsdlMessagePart> iterator = wsdlMessage.parts().iterator();
- QName inputName = null;
- if (iterator.hasNext()) {
- inputName = iterator.next().getElement();
- } else {
- throw new GraphException("No input part found for WS Node" + node.getName());
- }
- return inputName;
- }
-
- private QName getOutputElementName(WSNode node) throws GraphException {
- WSComponent component = node.getComponent();
- String portTypeName = component.getPortTypeQName().getLocalPart();
- WsdlPortType portType = component.getWSDL().getPortType(portTypeName);
- WsdlPortTypeOperation operation = portType.getOperation(component.getOperationName());
- QName message = operation.getOutput().getMessage();
- WsdlMessage wsdlMessage = component.getWSDL().getMessage(message.getLocalPart());
- Iterator<WsdlMessagePart> iterator = wsdlMessage.parts().iterator();
- QName inputName = null;
- if (iterator.hasNext()) {
- inputName = iterator.next().getElement();
- } else {
- throw new GraphException("No output part found for WS Node" + node.getName());
- }
- return inputName;
- }
-
- private void writeServices(XmlElement scufl) throws GraphException {
-
- Collection<NodeImpl> nextNodes = this.graph.getNodes();
- for (NodeImpl node : nextNodes) {
- if (node instanceof WSNode) {
- WSNode wsNode = (WSNode) node;
- createWSProcess(wsNode, scufl);
- }
- }
- }
-
- private XmlElement createWSProcess(WSNode node, XmlElement scufl) throws GraphException, XmlBuilderException {
-
- XmlElement processor = scufl.addElement(scuflNS, "processor");
- String name = getValidName(node);
- processor.addAttribute("name", name);
- XmlElement description = processor.addElement(scuflNS, "description");
- String txt = node.getComponent().getDescription();
- if (null == txt) {
- description.addChild(name);
- } else {
- description.addChild(txt);
- }
-
- XmlElement arbitrarywsdl = processor.addElement(scuflNS, "arbitrarywsdl");
- XmlElement wsdl = arbitrarywsdl.addElement(scuflNS, "wsdl");
-
- String epr = getEPR(node);
- if (null == epr) {
- throw new GraphException("EPR not found for the WS-node:" + builder.serializeToString(node));
- }
- wsdl.addChild(epr + "?wsdl");
-
- XmlElement operation = arbitrarywsdl.addElement(scuflNS, "operation");
- operation.addChild(node.getOperationName());
-
- return processor;
-
- }
-
- /**
- * @param node
- * @return
- */
- private String getValidName(WSNode node) {
- return node.getID();
- // String name = node.getName();
- // if (name.indexOf(":") != -1) {
- // name = name.substring(0, name.indexOf(":"));
- // }
- // return name;
- }
-
- /**
- * @param wsNode
- */
- private String getEPR(WSNode wsNode) {
- Iterable<WsdlService> services = wsNode.getComponent().getWSDL().services();
- Iterator<WsdlService> iterator = services.iterator();
- if (iterator.hasNext()) {
- Iterable<WsdlPort> ports = iterator.next().ports();
- Iterator<WsdlPort> portIterator = ports.iterator();
- if (portIterator.hasNext()) {
- WsdlPort port = portIterator.next();
- Iterable children = port.xml().children();
- Iterator childIterator = children.iterator();
- while (childIterator.hasNext()) {
- Object next = childIterator.next();
- if (next instanceof XmlElementWithViewsImpl) {
- org.xmlpull.infoset.XmlAttribute epr = ((XmlElementWithViewsImpl) next).attribute("location");
- return epr.getValue();
- }
- }
- }
- }
- return null;
- }
-
- public boolean validate(List<String> warnings) {
- // Empty
- if (this.graph.getNodes().size() == 0) {
- String message = "The workflow is empty.";
- warnings.add(message);
- }
-
- // Input ports need to be connected.
- Collection<Port> inputPorts = GraphUtil.getPorts(this.graph, Port.Kind.DATA_IN);
- for (Port inputPort : inputPorts) {
- Collection<Port> fromPorts = inputPort.getFromPorts();
- if (fromPorts.size() == 0) {
- Node node = inputPort.getNode();
- String message = node.getID() + " has an unconnected input " + inputPort.getName();
- warnings.add(message);
- }
- }
-
- // Input nodes need to be connected.
- for (InputNode inputNode : this.inputNodes) {
- if (inputNode.getPort().getToPorts().size() == 0) {
- String message = inputNode.getID() + " is not connected to any service.";
- warnings.add(message);
- }
- }
-
- // Cycle
- if (GraphUtil.containsCycle(this.graph)) {
- String message = "There is a cycle in the workflow.";
- warnings.add(message);
- }
-
- // Constants are not supported.
- List<ConstantNode> constantNodes = GraphUtil.getNodes(this.graph, ConstantNode.class);
- if (constantNodes.size() > 0) {
- String message = "Constants are not supported for Scufl scripts.";
- warnings.add(message);
- }
-
- // If/endif are not supported.
- List<IfNode> ifNodes = GraphUtil.getNodes(this.graph, IfNode.class);
- List<EndifNode> endifNodes = GraphUtil.getNodes(this.graph, EndifNode.class);
- if (ifNodes.size() > 0 || endifNodes.size() > 0) {
- String message = "If/endif are not supported for Scufl scripts.";
- warnings.add(message);
- }
-
- if (warnings.size() > 0) {
- return false;
- } else {
- // No error.
- return true;
- }
- }
-
- private Collection<Node> getNextNodes() throws GraphException {
- Collection<Node> nextNodes = new ArrayList<Node>();
- for (Node node : this.notYetInvokedNodes) {
- if (isNextNode(node)) {
- nextNodes.add(node);
- }
- }
- return nextNodes;
- }
-
- private boolean isNextNode(Node node) throws GraphException {
- if (node instanceof OutputNode) {
- return false;
- }
- for (Port port : node.getInputPorts()) {
- Collection<Node> fromNodes = port.getFromNodes();
- if (fromNodes.isEmpty()) {
- throw new GraphException("There is a port that is not connected to any.");
- } else {
- for (Node fromNode : fromNodes) {
- if (this.notYetInvokedNodes.contains(fromNode)) {
- // There is a node that should be executed before this
- // node.
- return false;
- }
- }
- }
- }
- Port port = node.getControlInPort();
- if (port != null) {
- Collection<Node> fromNodes = port.getFromNodes();
- for (Node fromNode : fromNodes) {
- if (this.notYetInvokedNodes.contains(fromNode)) {
- return false;
- }
- }
- }
- return true;
- }
-
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/BPELScriptTestCase.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/BPELScriptTestCase.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/BPELScriptTestCase.java
deleted file mode 100644
index bcfb604..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/BPELScriptTestCase.java
+++ /dev/null
@@ -1,209 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.test;
-
-import java.io.File;
-import java.io.IOException;
-
-import org.apache.airavata.common.utils.IOUtil;
-import org.apache.airavata.common.utils.XMLUtil;
-import org.apache.airavata.workflow.model.component.ComponentException;
-import org.apache.airavata.workflow.model.component.ComponentRegistryException;
-import org.apache.airavata.workflow.model.gpel.script.BPELScript;
-import org.apache.airavata.workflow.model.gpel.script.BPELScriptType;
-import org.apache.airavata.workflow.model.gpel.script.WorkflowWSDL;
-import org.apache.airavata.workflow.model.graph.GraphException;
-import org.apache.airavata.workflow.model.wf.Workflow;
-import org.apache.airavata.xbaya.XBayaConstants;
-import org.apache.airavata.xbaya.test.util.WorkflowCreator;
-import org.gpel.model.GpelProcess;
-import org.xmlpull.infoset.XmlElement;
-
-import xsul5.wsdl.WsdlDefinitions;
-
-public class BPELScriptTestCase extends XBayaTestCase {
-
- // private static final Logger logger = LoggerFactory.getLogger();
-
- private WorkflowCreator workflowCreator;
-
- @Override
- protected void setUp() throws Exception {
- super.setUp();
- this.workflowCreator = new WorkflowCreator();
- }
-
- /**
- * @throws ComponentException
- * @throws IOException
- * @throws GraphException
- * @throws ComponentRegistryException
- */
- public void testSimpleMath() throws ComponentException, IOException, GraphException, ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createSimpleMathWorkflow();
- testWrokflow(workflow, "simple-math");
- }
-
- /**
- * @throws ComponentException
- * @throws IOException
- * @throws GraphException
- * @throws ComponentRegistryException
- */
- public void testMath() throws ComponentException, IOException, GraphException, ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createMathWorkflow();
- testWrokflow(workflow, "math");
- }
-
- /**
- * @throws ComponentException
- * @throws IOException
- * @throws GraphException
- * @throws ComponentRegistryException
- */
- public void testComplexMath() throws ComponentException, IOException, GraphException, ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createComplexMathWorkflow();
- testWrokflow(workflow, "complex-math");
- }
-
- /**
- * @throws ComponentException
- * @throws IOException
- * @throws GraphException
- * @throws ComponentRegistryException
- */
- public void testMathWithConstant() throws ComponentException, IOException, GraphException,
- ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createMathWithConstWorkflow();
- testWrokflow(workflow, "constant-test");
- }
-
- /**
- * @throws ComponentException
- * @throws GraphException
- * @throws IOException
- * @throws ComponentRegistryException
- */
- public void testArray() throws ComponentException, GraphException, IOException, ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createArrayWorkflow();
- testWrokflow(workflow, "array-test");
- }
-
- /**
- * @throws ComponentException
- * @throws GraphException
- * @throws IOException
- * @throws ComponentRegistryException
- */
- public void testForEach() throws ComponentException, GraphException, IOException, ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createForEachWorkflow();
- testWrokflow(workflow, "foreach-test");
- }
-
- /**
- * @throws ComponentException
- * @throws GraphException
- * @throws IOException
- * @throws ComponentRegistryException
- */
- public void testIf() throws ComponentException, GraphException, IOException, ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createIfWorkflow();
- testWrokflow(workflow, "if-test");
- }
-
- /**
- * @throws GraphException
- * @throws ComponentException
- * @throws IOException
- * @throws ComponentRegistryException
- */
- public void testReceive() throws GraphException, ComponentException, IOException, ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createReceiveWorkflow();
- testWrokflow(workflow, "receive-test");
- }
-
- /**
- * @throws GraphException
- * @throws ComponentException
- * @throws IOException
- * @throws ComponentRegistryException
- */
- public void testLoan() throws GraphException, ComponentException, IOException, ComponentRegistryException {
- Workflow workflow = this.workflowCreator.createLoanWorkflow();
- testWrokflow(workflow, "loan");
- }
-
- private void testWrokflow(Workflow workflow, String filename) throws GraphException, IOException,
- ComponentException {
-
- // This one is for debuggin in case something below fails.
- XMLUtil.saveXML(workflow.toXML(), new File(this.temporalDirectory, filename + "-0.xwf"));
-
- // Create BPEL
- BPELScript bpel = new BPELScript(workflow);
- bpel.create(BPELScriptType.GPEL);
- GpelProcess gpelProcess = bpel.getGpelProcess();
- WorkflowWSDL workflowWSDL = bpel.getWorkflowWSDL();
- WsdlDefinitions definitions = workflowWSDL.getWsdlDefinitions();
-
- File bpelFile = new File(this.temporalDirectory, filename + XBayaConstants.BPEL_SUFFIX);
- File wsdlFile = new File(this.temporalDirectory, filename + XBayaConstants.WSDL_SUFFIX);
- XMLUtil.saveXML(gpelProcess.xml(), bpelFile);
- XMLUtil.saveXML(definitions.xml(), wsdlFile);
-
- // Save the workflow
- File workflowFile = new File(this.temporalDirectory, filename + XBayaConstants.WORKFLOW_FILE_SUFFIX);
- XMLUtil.saveXML(workflow.toXML(), workflowFile);
-
- // Read the workflow
- XmlElement workflowElement = XMLUtil.loadXML(workflowFile);
- workflow = new Workflow(workflowElement);
-
- // Create BPEL again
- bpel = new BPELScript(workflow);
- bpel.create(BPELScriptType.GPEL);
- gpelProcess = bpel.getGpelProcess();
- workflowWSDL = bpel.getWorkflowWSDL();
- definitions = workflowWSDL.getWsdlDefinitions();
-
- File bpelFile2 = new File(this.temporalDirectory, filename + "-2" + XBayaConstants.BPEL_SUFFIX);
- File wsdlFile2 = new File(this.temporalDirectory, filename + "-2" + XBayaConstants.WSDL_SUFFIX);
- XMLUtil.saveXML(gpelProcess.xml(), bpelFile2);
- XMLUtil.saveXML(definitions.xml(), wsdlFile2);
-
- File workflowFile2 = new File(this.temporalDirectory, filename + "-2" + XBayaConstants.WORKFLOW_FILE_SUFFIX);
- XMLUtil.saveXML(workflow.toXML(), workflowFile2);
-
- // Compare
- String workflowString = IOUtil.readFileToString(workflowFile);
- String workflowString2 = IOUtil.readFileToString(workflowFile2);
- assertEquals(workflowString, workflowString2);
-
- String bpelString = IOUtil.readFileToString(bpelFile);
- String bpelString2 = IOUtil.readFileToString(bpelFile2);
- assertEquals(bpelString, bpelString2);
-
- String wsdlString = IOUtil.readFileToString(wsdlFile);
- String wsdlString2 = IOUtil.readFileToString(wsdlFile2);
- assertEquals(wsdlString, wsdlString2);
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/BrowserTestCase.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/BrowserTestCase.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/BrowserTestCase.java
deleted file mode 100644
index 3d68557..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/BrowserTestCase.java
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.test;
-
-import junit.framework.TestCase;
-
-import org.apache.airavata.common.utils.BrowserLauncher;
-import org.apache.airavata.workflow.model.exceptions.WorkflowException;
-
-public class BrowserTestCase extends TestCase {
-
- /**
- * @throws WorkflowException
- *
- */
- public void testBrowserLauncher() throws Exception {
- BrowserLauncher.openURL("http://www.google.com");
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/DSCTestCase.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/DSCTestCase.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/DSCTestCase.java
deleted file mode 100644
index e6ae107..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/DSCTestCase.java
+++ /dev/null
@@ -1,131 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.test;
-
-import java.io.File;
-import java.net.URI;
-
-import junit.framework.TestSuite;
-
-import org.apache.airavata.common.utils.XMLUtil;
-import org.apache.airavata.workflow.model.gpel.DSCUtil;
-import org.apache.airavata.xbaya.file.XBayaPathConstants;
-import org.apache.airavata.xbaya.lead.LeadContextHeaderHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.xmlpull.v1.builder.XmlElement;
-
-import xsul.lead.LeadContextHeader;
-import xsul.util.XsulUtil;
-import xsul.wsif.WSIFMessage;
-import xsul.wsif.WSIFOperation;
-import xsul.wsif.WSIFPort;
-import xsul.xhandler_soap_sticky_header.StickySoapHeaderHandler;
-import xsul.xwsif_runtime.WSIFClient;
-import xsul.xwsif_runtime.WSIFRuntime;
-import xsul.xwsif_runtime_async.WSIFAsyncResponsesCorrelator;
-import xsul.xwsif_runtime_async_http.XsulSoapHttpWsaResponsesCorrelator;
-import xsul5.wsdl.WsdlDefinitions;
-import xsul5.wsdl.WsdlException;
-import xsul5.wsdl.WsdlResolver;
-
-public class DSCTestCase extends XBayaTestCase {
-
- private static final String SAMPLE_AWSDL = XBayaPathConstants.WSDL_DIRECTORY + "/test/TestCMD_Example1_AWSDL.xml";
-
- private static final Logger logger = LoggerFactory.getLogger(DSCTestCase.class);
-
- /**
- * @param args
- */
- public static void main(String[] args) {
- junit.textui.TestRunner.run(new TestSuite(DSCTestCase.class));
- }
-
- /**
- * @see org.apache.airavata.xbaya.test.XBayaTestCase#setUp()
- */
- @Override
- protected void setUp() throws Exception {
- super.setUp();
- }
-
- /**
- * @throws WsdlException
- */
- public void test() throws WsdlException {
- WsdlDefinitions definitions = WsdlResolver.getInstance().loadWsdl(new File(".").toURI(),
- new File(SAMPLE_AWSDL).toURI());
- URI dscURL = this.configuration.getDSCURL();
- logger.info("dscURL: " + dscURL);
- DSCUtil.convertToCWSDL(definitions, dscURL);
-
- logger.info(definitions.xmlStringPretty());
-
- // client
- int clientPort = 0;
- WSIFAsyncResponsesCorrelator correlator = new XsulSoapHttpWsaResponsesCorrelator(clientPort);
- String serverLoc = ((XsulSoapHttpWsaResponsesCorrelator) correlator).getServerLocation();
- logger.info("client is waiting at " + serverLoc);
-
- // LEAD Context Header
- // Create lead context.
- LeadContextHeaderHelper leadContextHelper = new LeadContextHeaderHelper();
- leadContextHelper.setXBayaConfiguration(this.configuration);
- LeadContextHeader leadContext = leadContextHelper.getLeadContextHeader();
- leadContext.setWorkflowId(URI.create("http://host/2005/11/09/workflowinstace"));
- leadContext.setNodeId("decoder1");
- leadContext.setTimeStep("5");
- leadContext.setServiceInstanceId(URI.create("decoder-instance-10"));
-
- XmlElement element3 = XMLUtil.xmlElement5ToXmlElement3(definitions.xml());
- xsul.wsdl.WsdlDefinitions definitions3 = new xsul.wsdl.WsdlDefinitions(element3);
-
- WSIFClient wclient = WSIFRuntime.getDefault().newClientFor(definitions3, "TestCMD_Example1SoapPort");
- StickySoapHeaderHandler handler = new StickySoapHeaderHandler("use-lead-header", leadContext);
-
- wclient.addHandler(handler);
- wclient.useAsyncMessaging(correlator);
- wclient.setAsyncResponseTimeoutInMs(33000L);
-
- WSIFPort port = wclient.getPort();
- WSIFOperation operation = port.createOperation("Run");
- WSIFMessage inputMessage = operation.createInputMessage();
- WSIFMessage outputMessage = operation.createOutputMessage();
- WSIFMessage faultMessage = operation.createFaultMessage();
-
- // inputMessage.setObjectPart("InputParam1", "Hello");
- inputMessage.setObjectPart("InputParam1", "100");
-
- logger.info("inputMessage: " + XsulUtil.safeXmlToString((XmlElement) inputMessage));
- boolean success = operation.executeRequestResponseOperation(inputMessage, outputMessage, faultMessage);
-
- XmlElement result;
- if (success) {
- result = (XmlElement) outputMessage;
- } else {
- result = (XmlElement) faultMessage;
- }
- logger.info("result:\n" + XsulUtil.safeXmlToString(result));
-
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/airavata/blob/0e2c10f5/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/DSCUtilTestCase.java
----------------------------------------------------------------------
diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/DSCUtilTestCase.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/DSCUtilTestCase.java
deleted file mode 100644
index 866aa6a..0000000
--- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/test/DSCUtilTestCase.java
+++ /dev/null
@@ -1,79 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.xbaya.test;
-
-import java.io.File;
-
-import org.apache.airavata.workflow.model.component.ComponentException;
-import org.apache.airavata.workflow.model.component.ComponentRegistryException;
-import org.apache.airavata.workflow.model.gpel.DSCUtil;
-import org.apache.airavata.workflow.model.graph.GraphException;
-import org.apache.airavata.workflow.model.wf.Workflow;
-import org.apache.airavata.xbaya.file.XBayaPathConstants;
-import org.apache.airavata.xbaya.test.util.WorkflowCreator;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import xsul5.wsdl.WsdlDefinitions;
-import xsul5.wsdl.WsdlException;
-import xsul5.wsdl.WsdlResolver;
-
-public class DSCUtilTestCase extends XBayaTestCase {
-
- private static final String SAMPLE_AWSDL = XBayaPathConstants.WSDL_DIRECTORY + "/test/adder-awsdl.xml";
-
- private static final String WSDL_WITH_MULTIPLE_PORT_TYPES = XBayaPathConstants.BPEL_SCRIPT_DIRECTORY
- + File.separator + "receive-test-wsdl.xml";
-
- private static final Logger logger = LoggerFactory.getLogger(DSCUtilTestCase.class);
-
- /**
- * @throws WsdlException
- */
- public void testConvertToCWSDL() throws WsdlException {
- WsdlDefinitions definitions = WsdlResolver.getInstance().loadWsdl(new File(".").toURI(),
- new File(SAMPLE_AWSDL).toURI());
- DSCUtil.convertToCWSDL(definitions, this.configuration.getDSCURL());
- logger.info(definitions.xmlStringPretty());
- }
-
- /**
- *
- */
- public void testMultiplePortTypes() {
- WsdlDefinitions definitions = WsdlResolver.getInstance().loadWsdl(new File(".").toURI(),
- new File(WSDL_WITH_MULTIPLE_PORT_TYPES).toURI());
- DSCUtil.convertToCWSDL(definitions, this.configuration.getDSCURL());
- logger.info(definitions.xmlStringPretty());
- }
-
- /**
- * @throws ComponentException
- * @throws GraphException
- * @throws ComponentRegistryException
- */
- public void testConvertToCWSDLs() throws ComponentException, GraphException, ComponentRegistryException {
- WorkflowCreator creator = new WorkflowCreator();
- Workflow workflow = creator.createComplexMathWorkflow();
- DSCUtil.createCWSDLs(workflow, this.configuration.getDSCURL());
- }
-}
\ No newline at end of file