You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2013/07/25 00:44:34 UTC
svn commit: r1506767 [2/3] - in /airavata/sandbox/gsoc2013: ./ app/
app/scripts/ app/scripts/controllers/ app/scripts/model/ app/styles/
app/views/ css/ js/ test/spec/ test/spec/controllers/
Added: airavata/sandbox/gsoc2013/app/scripts/registryAPI.js
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/scripts/registryAPI.js?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/scripts/registryAPI.js (added)
+++ airavata/sandbox/gsoc2013/app/scripts/registryAPI.js Wed Jul 24 22:44:33 2013
@@ -0,0 +1,1650 @@
+
+
+function test(){
+ alert("Test works and mount also works");
+}
+
+
+function GateWay(name) {
+ this.gatewayName = name;
+}
+
+function setHeaders(name, value, headers) {
+ headers.push = {name: value};
+}
+
+function AiravataUser() {
+ this.userName;
+}
+function HostDescriptor(hName, hAddress) {
+ this.hostname = hName;
+ this.hostAddress = hAddress;
+
+ this.hostType = []; // String array
+ this.gridFTPEndPoint = []; // String array
+ this.gateKeeperEndPoint = []; // String array
+ this.imageID = []; // String array
+ this.instanceID = []; // String array
+}
+
+function ServiceDescriptor(sName, desc) {
+ this.serviceName = sName;
+ this.description = desc;
+ this.inputParams = [];
+ this.outputParams = [];
+}
+
+function ApplicationDescriptor() {
+ this.name;
+ this.hostdescName;
+// serviceName;
+ this.executablePath;
+ this.workingDir;
+ this.jobType;
+ this.projectNumber;
+ this.projectDescription;
+ this.queueName;
+ this.applicationDescType;
+ this.inputDir;
+ this.outputDir;
+ this.stdIn;
+ this.stdOut;
+ this.stdError;
+ this.staticWorkigDir;
+ // int set
+ this.maxWallTime;
+ this.cpuCount;
+ this.nodeCount;
+ this.processorsPerNode;
+ this.minMemory;
+ this.maxMemory;
+
+ this.environmentVariables; // HashMap<String, String>
+ this.serviceDescriptor; // ServiceDescriptor
+
+}
+
+function WorkflowNodeGramData(nodeId, rsl, invockedHost, gramJobId, workflowInstanaceId) {
+ this.NodeID = nodeId;
+ this.rsl = rsl;
+ this.invokedHost = invockedHost;
+ this.gramJobID = gramJobId;
+ this.workflowInstanceId = workflowInstanaceId;
+}
+
+function ExecutionError() {
+ this.source; // ExecutionErrorSource
+ this.errorTime; // Date
+ this.errorCode;
+ this.errorMessage;
+ this.errorDescription;
+ this.errorLocation;
+ this.actionTaken;
+ this.errorReported;
+ this.errorReference; // int
+}
+
+var ExecutionErrorSource = {
+ ALL: 'ALL',
+ EXPERIMENT: 'EXPERIMENT',
+ WORKFLOW: 'WORKFLOW',
+ NODE: 'NODE',
+ APPLICATION: 'APPLICATION'
+};
+
+function ExperimentExecutionError() {
+ ExecutionError.call(this);
+ this.experimentId;
+}
+
+ExperimentExecutionError.prototype = Object.create(ExecutionError.prototype);
+
+function WorkflowExecutionError() {
+ ExecutionError.class(this);
+ this.experimentId;
+ this.workflowInstanceId;
+}
+
+WorkflowExecutionError.prototype = Object.create(ExecutionError.prototype);
+
+function NodeExecutionError() {
+ ExecutionError.call(this);
+ this.experimentId;
+ this.workflowInstanceId;
+ this.nodeId;
+}
+
+NodeExecutionError.prototype = Object.create(ExecutionError.prototype);
+
+function ApplicationJobExecutionError() {
+ ExecutionError.call(this);
+ this.experimentId;
+ this.workflowInstanceId;
+ this.nodeId;
+ this.jobId;
+}
+
+ApplicationJobExecutionError.prototype = Object.create(ApplicationJobExecutionError.prototype);
+
+
+var ApplicatonJobStatus = {
+ VALIDATE_INPUT: "VALIDATE_INPUT",
+ STAGING: "STAGING",
+ AUTHENTICATE: "AUTHENTICATE",
+ INITIALIZE: "INITIALIZE",
+ SUBMITTED: "SUBMITTED",
+ PENDING: "PENDING",
+ EXECUTING: "EXECUTING",
+ SUSPENDED: "SUSPENDED",
+ WAIT_FOR_DATA: "WAIT_FOR_DATA",
+ FINALIZE: "FINALIZE",
+ RESULTS_GEN: "RESULTS_GEN",
+ RESULTS_RETRIEVE: "RESULTS_RETRIEVE",
+ VALIDATE_OUTPUT: "VALIDATE_OUTPUT",
+ FINISHED: "FINISHED",
+ FAILED: "FAILED",
+ CANCELLED: "CANCELLED",
+ UNKNOWN: "UNKNOWN"
+}
+
+function ApplicationJob() {
+ this.experimentId;
+ this.workflowExecutionId;
+ this.nodeId;
+
+ this.serviceDescriptionId;
+ this.hostDescriptionId;
+ this.applicationDescriptionId;
+
+ this.jobId;
+ this.jobData;
+
+ this.submittedTime; // Date
+ this.statusUpdateTime; // Date
+ this.status; // ApplicationJobStatus
+
+ this.metadata;
+}
+
+var airavataBasicHeaders = {"Authorization": "Basic YWRtaW46YWRtaW4=",
+ "Accept": "application/json", "Content-Type": "application/json"};
+
+var optionalBasicHeaders = {"Authorization": "Basic YWRtaW46YWRtaW4=",
+ "Accept": "*/*", "Content-Type": "application/json"};
+
+var formBasicHeaders = {"Authorization": "Basic YWRtaW46YWRtaW4=",
+ "Accept": "*/*", "Content-Type": "application/x-www-form-urlencoded"};
+
+var baseURL = {"BASE_RES_PATH": "/airavata-registry/api"};
+
+var type = {get: "GET", post: "POST", delete: "DELETE"};
+
+var basicResourcePaths = { "REGISTRY_API_BASICREGISTRY": "/basicregistry/",
+ "GET_GATEWAY": "get/gateway",
+ "GET_USER": "get/user",
+ "SET_GATEWAY": "set/gateway",
+ "SET_USER": "set/user",
+ "VERSION": "get/version",
+ "GET_SERVICE_URL": "get/serviceURL",
+ "SET_SERVICE_URL": "set/serviceURL"};
+
+function sendAndReceive(url, headers, type, data, onSuccess) {
+ return $.ajax({
+ url: url,
+ headers: headers,
+ type: type,
+ data: data,
+ async: false,
+ success: onSuccess
+ });
+}
+
+function sendRobust(url, headers, type, data, onSuccess) {
+ return $.ajax({
+ url: url,
+ headers: headers,
+ type: type,
+ data: data,
+ success: onSuccess
+ });
+}
+
+
+// ====================================== Util functions =====================================================
+
+function createSampleHostDesc() {
+ this.hostDesc = new HostDescription();
+ this.hostDesc.hostName = "Remote host";
+ this.hostDesc.hostAddress = "100.10.2.233";
+ return this.hostDesc;
+}
+
+
+// ====================================== Exception functions =====================================================
+
+function Exception(msg) {
+ if (msg) {
+ this.message = msg;
+ } else {
+ this.message = "Exception thrown";
+ }
+}
+
+Exception.prototype.getMessage = function () {
+ return this.message;
+};
+
+Exception.prototype.setMessage = function (newMsg) {
+ this.message = newMsg;
+}
+
+// ######### Throw this exception if subclass doesn't implement abstract method ############
+function MethodNotImplementedException(msg) {
+ Exception.call(this, msg);
+ if (msg) {
+ this.message = msg;
+ }
+}
+
+MethodNotImplementedException.prototype = Object.create(Exception.prototype);
+
+
+// ====================================== Basic Registry Resource =====================================================
+function BasicRegistry() {
+ this.basicRegistryResourcePath = baseURL.BASE_RES_PATH + basicResourcePaths.REGISTRY_API_BASICREGISTRY;
+}
+
+BasicRegistry.prototype.getGateWay = function () {
+ var url, gWay;
+ url = this.basicRegistryResourcePath + basicResourcePaths.GET_GATEWAY;
+ gWay = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return gWay.responseJSON;
+
+}
+
+BasicRegistry.prototype.setGateway = function (gateway) {
+ var url, data, gway;
+ if (gateway instanceof GateWay) {
+ url = this.basicRegistryResourcePath + basicResourcePaths.SET_GATEWAY;
+ data = JSON.stringify(gateway);
+ gWay = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return gWay.responseText;
+ } else {
+ return new Exception("Expected instanceof GateWay");
+ }
+}
+
+BasicRegistry.prototype.getUserName = function () {
+ var url, user;
+ url = this.basicRegistryResourcePath + basicResourcePaths.GET_USER;
+ user = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ alert(user.responseText);
+ return user.responseJSON;
+};
+
+BasicRegistry.prototype.setAiravataUser = function (airavataUser) {
+ var url, res, data;
+ url = this.basicRegistryResourcePath + basicResourcePaths.SET_USER;
+ data = JSON.stringify(airavataUser);
+ res = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return res;
+}
+
+BasicRegistry.prototype.getVersion = function () {
+ var url , res;
+ url = this.basicRegistryResourcePath + basicResourcePaths.VERSION;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+BasicRegistry.prototype.getConnectionURL = function () {
+ var url, res;
+ url = this.basicRegistryResourcePath+ basicResourcePaths.GET_SERVICE_URL;
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, null, null);
+ return res;
+}
+
+BasicRegistry.prototype.setConnectionURL = function (connectionURL) {
+ var url,formParam, res;
+ formParam = "?connectionurl=" + connectionURL;
+ url = this.basicRegistryResourcePath + basicResourcePaths.SET_SERVICE_URL + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res;
+}
+
+// ========================================= Descriptor Registry Resource ==========================================
+
+var descResourcePaths = { "DESC_RESOURCE_PATH": "/descriptorsregistry/",
+ "HOST_DESC_EXISTS": "hostdescriptor/exist",
+ "HOST_DESC_SAVE": "hostdescriptor/save",
+ "HOST_DESC_UPDATE": "hostdescriptor/update",
+ "HOST_DESC": "host/description",
+ "HOST_DESC_DELETE": "hostdescriptor/delete",
+ "GET_HOST_DESCS": "get/hostdescriptors",
+ "GET_HOST_DESCS_NAMES": "get/hostdescriptor/names",
+ "SERVICE_DESC_EXISTS": "servicedescriptor/exist",
+ "SERVICE_DESC_SAVE": "servicedescriptor/save",
+ "SERVICE_DESC_UPDATE": "servicedescriptor/update",
+ "SERVICE_DESC": "servicedescriptor/description",
+ "SERVICE_DESC_DELETE": "servicedescriptor/delete",
+ "GET_SERVICE_DESCS": "get/servicedescriptors",
+ "APPL_DESC_EXIST": "applicationdescriptor/exist",
+ "APP_DESC_BUILD_SAVE": "applicationdescriptor/build/save",
+ "APP_DESC_UPDATE": "applicationdescriptor/update",
+ "APP_DESC_DESCRIPTION": "applicationdescriptor/description",
+ "APP_DESC_PER_HOST_SERVICE": "applicationdescriptors/alldescriptors/host/service",
+ "APP_DESC_ALL_DESCS_SERVICE": "applicationdescriptor/alldescriptors/service",
+ "APP_DESC_ALL_DESCRIPTORS": "applicationdescriptor/alldescriptors",
+ "APP_DESC_NAMES": "applicationdescriptor/names",
+ "APP_DESC_DELETE": "applicationdescriptor/delete"
+}
+
+function DescriptorRegistry() {
+ this.descRegistryResourcePath = baseURL.BASE_RES_PATH + descResourcePaths.DESC_RESOURCE_PATH;
+}
+
+DescriptorRegistry.prototype.isHostDescriptorExists = function (hostDescName) {
+ var url, data, res;
+ url = this.descRegistryResourcePath + descResourcePaths.HOST_DESC_EXISTS;
+ data = {hostDescriptorName: hostDescName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res;
+}
+
+DescriptorRegistry.prototype.addHostDescriptor = function (hostDescriptor) {
+ var url, data, res;
+ if (hostDescriptor instanceof HostDescriptor) {
+ url = this.descRegistryResourcePath + descResourcePaths.HOST_DESC_SAVE;
+ data = JSON.stringify(hostDescriptor);
+ res = sendAndReceive(url, airavataBasicHeaders, type.post, data, null);
+ return res.responseJSON;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+DescriptorRegistry.prototype.updateHostDescriptor = function (updatedHostDesc) {
+ var url, data, res;
+ if (updatedHostDesc instanceof hostDescriptor) {
+ url = this.descRegistryResourcePath + descResourcePaths.HOST_DESC_UPDATE;
+ data = JSON.stringify(updatedHostDesc);
+ res = sendAndReceive(url, airavataBasicHeaders, type.post, data, null);
+ return res.responseJSON;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+DescriptorRegistry.prototype.getHostDescriptor = function (hostName) {
+ var url , data, res;
+ url = this.descRegistryResourcePath + descResourcePaths.HOST_DESC;
+ data = {hostName: hostName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+DescriptorRegistry.prototype.removeHostDescriptor = function (hostName) {
+ var url,formParam, res;
+ formParam = "?hostName=" + hostName;
+ url = this.descRegistryResourcePath + descResourcePaths.HOST_DESC_DELETE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.delete, null, null);
+ return res.responseText;
+}
+
+DescriptorRegistry.prototype.getHostDescriptors = function () {
+ var url, res;
+ url = this.descRegistryResourcePath + descResourcePaths.GET_HOST_DESCS;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJOSN;
+}
+
+
+DescriptorRegistry.prototype.getHostDescriptorNames = function () {
+ var url, res;
+ url = this.descRegistryResourcePath + descResourcePaths.GET_HOST_DESCS_NAMES;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+DescriptorRegistry.prototype.isServiceDescriptorExists = function (serviceDescName) {
+ var url, data, res;
+ url = this.descRegistryResourcePath + descResourcePaths.SERVICE_DESC_EXISTS;
+ data = {serviceDescriptorName: serviceDescName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+DescriptorRegistry.prototype.addServiceDescriptor = function (serviceDescriptor) {
+ var url, data, res;
+ if (serviceDescriptor instanceof ServiceDescriptor) {
+ url = this.descRegistryResourcePath + descResourcePaths.SERVICE_DESC_SAVE;
+ data = JSON.stringify(serviceDescriptor);
+ res = sendAndReceive(url, airavataBasicHeaders, type.post, data, null);
+ } else {
+ // TODO throw an exception
+ }
+}
+
+DescriptorRegistry.prototype.updateServiceDescriptor = function (serviceDescriptor) {
+ var url, data, res;
+ if (serviceDescriptor instanceof ServiceDescriptor) {
+ url = this.descRegistryResourcePath + descResourcePaths.SERVICE_DESC_UPDATE;
+ data = JSON.stringify(serviceDescriptor);
+ res = sendAndReceive(url, airavataBasicHeaders, type.post, data, null);
+ return res.responseJSON;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+DescriptorRegistry.prototype.getServiceDescriptor = function (serviceDescName) {
+ var url, data, res;
+ if (serviceDescName) {
+ url = this.descRegistryResourcePath + descResourcePaths.SERVICE_DESC;
+ data = {serviceName: serviceDescName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+DescriptorRegistry.prototype.removeServiceDescriptor = function (serviceDescName) {
+ var url, data, res;
+ if (serviceDescName) {
+ url = this.descRegistryResourcePath + descResourcePaths.SERVICE_DESC_DELETE;
+ data = {serviceName: serviceDescName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.delete, data, null);
+ return res.responseJSON;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+DescriptorRegistry.prototype.getServiceDescriptors = function () {
+ var url, res;
+ url = this.descRegistryResourcePath + descResourcePaths.GET_SERVICE_DESCS;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+DescriptorRegistry.prototype.isApplicationDescriptorExists = function (appDesc, hostName, appDescName) {
+ var url, data, res;
+ url = this.descRegistryResourcePath + descResourcePaths.APPL_DESC_EXIST;
+ data = {serviceName: appDesc, hostName: hostName, appDescName: appDescName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseText;
+ // TODO check this function
+}
+
+DescriptorRegistry.prototype.addApplicationDescriptor = function (appDescriptor) {
+ var url, data, res;
+ if (appDescriptor instanceof ApplicationDescriptor) {
+ url = this.descRegistryResourcePath + descResourcePaths.APP_DESC_BUILD_SAVE;
+ data = JSON.stringify(appDescriptor);
+ res = sendAndReceive(url, airavataBasicHeaders, type.post, data, null);
+ return res.responseJSON;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+DescriptorRegistry.prototype.udpateApplicationDescriptor = function (appDescriptor) {
+ var url, data, res;
+ if (appDescriptor) {
+ url = this.descRegistryResourcePath + descResourcePaths.APP_DESC_UPDATE;
+ data = JSON.stringify(appDescriptor);
+ res = sendAndReceive(url, airavataBasicHeaders, type.post, data, null);
+ return res.responseJSON;
+ }
+}
+
+DescriptorRegistry.prototype.getApplicationDescriptor = function (serviceName, hostName, applicationName) {
+ var url, data, res;
+ url = this.descRegistryResourcePath + descResourcePaths.APP_DESC_DESCRIPTION;
+ data = {serviceName: serviceName, hostName: hostName, appDescName: applicationName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+};
+
+DescriptorRegistry.prototype.getApplicationDescriptorPerServiceHost = function (serviceName, hostName) {
+ var url, data, res;
+ url = this.descRegistryResourcePath + descResourcePaths.APP_DESC_PER_HOST_SERVICE;
+ data = {serviceName: serviceName, hostName: hostName };
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+DescriptorRegistry.prototype.getApplicationDescriptors = function (serviceName) {
+ var url, data, res;
+ if (serviceName) {
+ url = this.descRegistryResourcePath + descResourcePaths.APP_DESC_ALL_DESCS_SERVICE;
+ data = {serviceName: serviceName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+ }
+}
+
+DescriptorRegistry.prototype.getApplicationDescriptors = function () {
+ var url , res;
+ url = this.descRegistryResourcePath + descResourcePaths.APP_DESC_ALL_DESCRIPTORS;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+DescriptorRegistry.prototype.getApplicationDescriptorNames = function () {
+ var url , res;
+ url = this.descRegistryResourcePath + descResourcePaths.APP_DESC_NAMES;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+DescriptorRegistry.prototype.removeApplicationDescriptor = function (serviceName, hostName, appName) {
+ var url , data, res;
+ url = this.descRegistryResourcePath + descResourcePaths.APP_DESC_DELETE;
+ data = {serviceName: serviceName, hostName: hostName, appName: appName};
+ res = sendAndReceive(url, airavataBasicHeaders, type.delete, data, null);
+ return res.responseJSON;
+}
+
+// ========================================= Configuration Registry Resource ==========================================
+
+
+// Resource path constants
+var configResourcePathConstants = {
+ CONFIGURATION_REGISTRY_RESOURCE: "/congfigregistry/",
+ GET_CONFIGURATION: "get/configuration",
+ GET_CONFIGURATION_LIST: "get/configurationlist",
+ SAVE_CONFIGURATION: "save/configuration",
+ UPDATE_CONFIGURATION: "update/configuration",
+ DELETE_ALL_CONFIGURATION: "delete/allconfiguration",
+ DELETE_CONFIGURATION: "delete/configuration",
+ GET_GFAC_URI_LIST: "get/gfac/urilist",
+ GET_WFINTERPRETER_URI_LIST: "get/workflowinterpreter/urilist",
+ GET_EVENTING_URI: "get/eventingservice/uri",
+ GET_MESSAGE_BOX_URI: "get/messagebox/uri",
+ ADD_GFAC_URI: "add/gfacuri",
+ ADD_WFINTERPRETER_URI: "add/workflowinterpreteruri",
+ ADD_EVENTING_URI: "add/eventinguri",
+ ADD_MESSAGE_BOX_URI: "add/msgboxuri",
+ ADD_GFAC_URI_DATE: "add/gfacuri/date",
+ ADD_WFINTERPRETER_URI_DATE: "add/workflowinterpreteruri/date",
+ ADD_EVENTING_URI_DATE: "add/eventinguri/date",
+ ADD_MSG_BOX_URI_DATE: "add/msgboxuri/date",
+ DELETE_GFAC_URI: "delete/gfacuri",
+ DELETE_ALL_GFAC_URIS: "delete/allgfacuris",
+ DELETE_WFINTERPRETER_URI: "delete/workflowinterpreteruri",
+ DELETE_ALL_WFINTERPRETER_URIS: "delete/allworkflowinterpreteruris",
+ DELETE_EVENTING_URI: "delete/eventinguri",
+ DELETE_MSG_BOX_URI: "delete/msgboxuri"
+};
+
+
+function ConfigurationRegistry() {
+ this.configResorcePath = baseURL.BASE_RES_PATH + configResourcePathConstants.CONFIGURATION_REGISTRY_RESOURCE;
+}
+
+ConfigurationRegistry.prototype.getConfiguration = function (key) {
+ var url, data, res;
+ if (key) {
+ url = this.configResorcePath + configResourcePathConstants.GET_CONFIGURATION;
+ data = {key: key};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ConfigurationRegistry.prototype.getConfigurationList = function (key) {
+ var url , data , res;
+ if (key) {
+ url = this.configResorcePath + configResourcePathConstants.GET_CONFIGURATION_LIST;
+ data = {key: key};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ConfigurationRegistry.prototype.setConfiguration = function (key, value, date) {
+ var url,formParam, res;
+ formParam = "?key=" + key + "&value=" + value + "&date=" + date;
+ url = this.configResorcePath + configResourcePathConstants.SAVE_CONFIGURATION + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.updateConfiguration = function (key, value, date) {
+ var url,formParam, res;
+ formParam = "?key=" + key + "&value=" + value + "&date=" + date;
+ url = this.configResorcePath + configResourcePathConstants.UPDATE_CONFIGURATION + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.removeAllConfiguration = function (key) {
+ var url , res;
+ url = this.configResorcePath + configResourcePathConstants.DELETE_ALL_CONFIGURATION;
+ data = {key: key};
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, data, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.removeConfiguration = function (key, value) {
+ var url, data , res;
+ url = this.configResorcePath + configResourcePathConstants.DELETE_CONFIGURATION;
+ data = {key: key, value: value};
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, data, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.getGFacURIs = function () {
+ var url, res;
+ url = this.configResorcePath + configResourcePathConstants.GET_GFAC_URI_LIST;
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+ConfigurationRegistry.prototype.getWorkflowInterpreterURIs = function () {
+ var url, res;
+ url = this.configResorcePath + configResourcePathConstants.GET_WFINTERPRETER_URI_LIST;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+ConfigurationRegistry.prototype.getEventingServiceURI = function () {
+ var url, res;
+ url = this.configResorcePath + configResourcePathConstants.GET_EVENTING_URI;
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.getMessageBoxURI = function () {
+ var url, res;
+ url = this.configResorcePath + configResourcePathConstants.GET_MESSAGE_BOX_URI;
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.addGFacURI = function (uri) {
+ var url,formParam, res;
+ formParam = "?uri=" + uri;
+ url = this.configResorcePath + configResourcePathConstants.ADD_GFAC_URI + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.addWorkflowInterpreterURI = function (uri) {
+ var url,formParam, res;
+ formParam = "?uri=" + uri;
+ if (uri) {
+ url = this.configResorcePath + configResourcePathConstants.ADD_WFINTERPRETER_URI + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ConfigurationRegistry.prototype.setEventingURI = function (uri) {
+ var url,formParam, res;
+ formParam = "?uri=" + uri;
+ if (uri) {
+ url = this.configResorcePath + configResourcePathConstants.ADD_EVENTING_URI + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ConfigurationRegistry.prototype.setMessageBoxURI = function (uri) {
+ var url, formParam, res;
+ if (uri) {
+ formParam = "?uri=" + uri;
+ url = this.configResorcePath + configResourcePathConstants.ADD_MESSAGE_BOX_URI + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+
+ConfigurationRegistry.prototype.addGFacURIByDate = function (uri, date) {
+ var url, formParam, res;
+ formParam = "?uri=" + uri + "&date=" + date;
+ url = this.configResorcePath + configResourcePathConstants.ADD_GFAC_URI_DATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.addWorkflowInterpreterURI = function (uri, date) {
+ var url, formParam, res;
+ formParam = "?uri=" + uri + "&date=" + date;
+ url = this.configResorcePath + configResourcePathConstants.ADD_WFINTERPRETER_URI_DATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.setEventingURIByDate = function (uri, date) {
+ var url, formParam, res;
+ formParam = "?uri=" + uri + "&date=" + date;
+ url = this.configResorcePath + configResourcePathConstants.ADD_EVENTING_URI_DATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.setMessageBoxURIByDate = function (uri, date) {
+ var url, formParam, res;
+ formParam = "?uri=" + uri + "&date=" + date;
+ url = this.configResorcePath + configResourcePathConstants.ADD_MSG_BOX_URI_DATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.removeGFacURI = function (uri) {
+ var url, data, res;
+ if (uri) {
+ url = this.configResorcePath + configResourcePathConstants.DELETE_GFAC_URI;
+ data = {uri: uri};
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ConfigurationRegistry.prototype.removeAllGFacURI = function () {
+ var url, res;
+ url = this.configResorcePath + configResourcePathConstants.DELETE_ALL_GFAC_URIS;
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.removeWorkflowInterpreterURI = function (uri) {
+ var url, data, res;
+ url = this.configResorcePath + configResourcePathConstants.DELETE_WFINTERPRETER_URI;
+ data = {uri: uri};
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, data, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.removeAllWorkflowInterpreterURI = function () {
+ var url, res;
+ url = this.configResorcePath + configResourcePathConstants.DELETE_ALL_WFINTERPRETER_URIS;
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.unsetEventingURI = function () {
+ var url, res;
+ url = this.configResorcePath + configResourcePathConstants.DELETE_EVENTING_URI;
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, null, null);
+ return res.responseText;
+}
+
+ConfigurationRegistry.prototype.unsetMessageBoxUwRI = function () {
+ var url, res;
+ url = this.configResorcePath + configResourcePathConstants.DELETE_MSG_BOX_URI;
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, null, null);
+ return res.responseText;
+}
+
+
+// ========================================= Provenance Registry Resource ==========================================
+
+var provenanceResourcePathConstants = {
+
+ REGISTRY_API_PROVENANCEREGISTRY: "/provenanceregistry/",
+ UPDATE_EXPERIMENT_EXECUTIONUSER: "update/experiment/executionuser",
+ GET_EXPERIMENT_EXECUTIONUSER: "get/experiment/executionuser",
+ GET_EXPERIMENT_NAME: "get/experiment/name",
+ UPDATE_EXPERIMENTNAME: "update/experimentname",
+ GET_EXPERIMENTMETADATA: "get/experimentmetadata",
+ UPDATE_EXPERIMENTMETADATA: "update/experimentmetadata",
+ GET_WORKFLOWTEMPLATENAME: "get/workflowtemplatename",
+ UPDATE_WORKFLOWINSTANCETEMPLATENAME: "update/workflowinstancetemplatename",
+ GET_EXPERIMENTWORKFLOWINSTANCES: "get/experimentworkflowinstances",
+ WORKFLOWINSTANCE_EXIST_CHECK: "workflowinstance/exist/check",
+ WORKFLOWINSTANCE_EXIST_CREATE: "workflowinstance/exist/create",
+ UPDATE_WORKFLOWINSTANCESTATUS_INSTANCEID: "update/workflowinstancestatus/instanceid",
+ UPDATE_WORKFLOWINSTANCESTATUS: "update/workflowinstancestatus",
+ GET_WORKFLOWINSTANCESTATUS: "get/workflowinstancestatus",
+ UPDATE_WORKFLOWNODEINPUT: "update/workflownodeinput",
+ UPDATE_WORKFLOWNODEOUTPUT: "update/workflownodeoutput",
+ GET_EXPERIMENT: "get/experiment",
+ GET_EXPERIMENT_ID_USER: "get/experimentId/user",
+ GET_EXPERIMENT_USER: "get/experiment/user",
+ UPDATE_WORKFLOWNODE_STATUS: "update/workflownode/status",
+ GET_WORKFLOWNODE_STATUS: "get/workflownode/status",
+ GET_WORKFLOWNODE_STARTTIME: "get/workflownode/starttime",
+ GET_WORKFLOW_STARTTIME: "get/workflow/starttime",
+ UPDATE_WORKFLOWNODE_GRAMDATA: "update/workflownode/gramdata",
+ GET_WORKFLOWINSTANCEDATA: "get/workflowinstancedata",
+ WORKFLOWINSTANCE_NODE_EXIST: "wfnode/exist",
+ WORKFLOWINSTANCE_NODE_EXIST_CREATE: "wfnode/exist/create",
+ WORKFLOWINSTANCE_NODE_DATA: "workflowinstance/nodeData",
+ ADD_WORKFLOWINSTANCE: "add/workflowinstance",
+ UPDATE_WORKFLOWNODETYPE: "update/workflownodetype",
+ ADD_WORKFLOWINSTANCENODE: "add/workflowinstancenode",
+ EXPERIMENTNAME_EXISTS: "experimentname/exists",
+
+ GET_EXPERIMENT_METAINFORMATION: "get/experiment/metainformation",
+ GET_ALL_EXPERIMENT_METAINFORMATION: "get/all/experiment/metainformation",
+ SEARCH_EXPERIMENTS: "search/experiments",
+
+ GET_EXPERIMENT_ERRORS: "experiment/errors",
+ GET_WORKFLOW_ERRORS: "workflow/errors",
+ GET_NODE_ERRORS: "node/errors",
+ GET_GFAC_ERRORS: "gfac/errors",
+ GET_ALL_GFAC_ERRORS: "gfac/all/errors",
+ GET_EXECUTION_ERRORS: "execution/errors",
+ ADD_EXPERIMENT_ERROR: "add/experiment/errors",
+ ADD_WORKFLOW_ERROR: "add/workflow/errors",
+ ADD_NODE_ERROR: "add/node/errors",
+ ADD_GFAC_ERROR: "add/gfac/errors",
+ ADD_APPLICATION_JOB: "add/application/job",
+ UPDATE_APPLICATION_JOB: "update/application/job",
+ UPDATE_APPLICATION_JOB_STATUS: "update/application/jobstatus",
+ UPDATE_APPLICATION_JOB_DATA: "update/application/jobdata",
+ UPDATE_APPLICATION_JOB_SUBMITTED_TIME: "update/application/job/submit",
+ UPDATE_APPLICATION_JOB_COMPLETED_TIME: "update/application/job/complete",
+ UPDATE_APPLICATION_JOB_METADATA: "update/application/job/metadata",
+ GET_APPLICATION_JOB: "get/application/job",
+ GET_APPLICATION_JOBS_FOR_DESCRIPTORS: "get/application/jobs/descriptors",
+ GET_APPLICATION_JOBS: "get/application/jobs",
+ APPLICATION_JOB_EXIST: "application/job/exists",
+ GET_APPLICATION_JOBS_STATUS_HISTORY: "get/application/status/history"
+
+};
+
+function ProvenanceRegistry() {
+ this.provenanceResourcePath = baseURL.BASE_RES_PATH + provenanceResourcePathConstants.REGISTRY_API_PROVENANCEREGISTRY;
+}
+
+
+ProvenanceRegistry.prototype.updateExperimentExecutionUser = function (experimentId, user) {
+ var url, formParam, res;
+ formParam = "?experimentId=" + experimentId + "&user=" + user;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_EXPERIMENT_EXECUTIONUSER + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getExperimentExecutionUser = function (experimentId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENT_EXECUTIONUSER;
+ data = {experimentId: experimentId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getExperimentName = function (experimentId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENT_NAME;
+ data = {experimentId: experimentId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateExperimentName = function (experimentId, experimentName) {
+ var url, formParam, res;
+ formParam = "?experimentId=" + experimentId + "&experimentName=" + experimentName;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_EXPERIMENTNAME + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getExperimentMetadata = function (experimentId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENTMETADATA;
+ data = {experimentId: experimentId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+
+ProvenanceRegistry.prototype.updateExperimentMetadata = function (experimentId, metadata) {
+ var url, formParam, res;
+ formParam = "?experimentId=" + experimentId + "&metadata=" + metadata;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_EXPERIMENTMETADATA + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+
+ProvenanceRegistry.prototype.getWorkflowExecutionTemplateName = function (workflowInstanceId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_WORKFLOWTEMPLATENAME;
+ data = {workflowInstanceId: workflowInstanceId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+
+ProvenanceRegistry.prototype.setWorkflowInstanceTemplateName = function (workflowInstanceId, templateName) {
+ var url, formParam, res;
+ formParam = "?workflowInstanceId=" + workflowInstanceId + "&templateName=" + templateName;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_WORKFLOWINSTANCETEMPLATENAME + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getExperimentWorkflowInstances = function (experimentId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENTWORKFLOWINSTANCES;
+ data = {experimentId: experimentId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.isWorkflowInstanceExists = function (instanceId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.WORKFLOWINSTANCE_EXIST_CHECK;
+ data = {instanceId: instanceId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.isWorkflowInstanceExistsThenCreate = function (instanceId, createIfNotPresent) {
+ var url, formParam, res;
+ formParam = "?instanceId=" + instanceId + "&createIfNotPresent=" + createIfNotPresent;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.WORKFLOWINSTANCE_EXIST_CREATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateWorkflowInstanceStatusByInstance = function (instanceId, executionStatus) {
+ var url, formParam, res;
+ formParam = "?instanceId=" + instanceId + "&executionStatus=" + executionStatus;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_WORKFLOWINSTANCESTATUS_INSTANCEID + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateWorkflowInstanceStatus = function (workflowInstanceId, executionStatus, statusUpdateTime) {
+ var url, formParam, res;
+ formParam = "?workflowInstanceId=" + workflowInstanceId + "&executionStatus=" + executionStatus + "&statusUpdateTime=" + statusUpdateTime;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_WORKFLOWINSTANCESTATUS + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getWorkflowInstanceStatus = function (instanceId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_WORKFLOWINSTANCESTATUS;
+ data = {instanceId: instanceId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateWorkflowNodeInput = function (nodeId, workflowInstanceId, data) {
+ var url, formParam, res;
+ formParam = "?nodeId=" + nodeId + "&workflowInstanceId=" + workflowInstanceId + "&data=" + data;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_WORKFLOWNODEINPUT + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateWorkflowNodeOutput = function (nodeId, workflowInstanceId, data) {
+ var url, formParam, res;
+ formParam = "?nodeId=" + nodeId + "&workflowInstanceId=" + workflowInstanceId + "&data=" + data;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_WORKFLOWNODEOUTPUT + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getExperiment = function (experimentId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENT;
+ data = {experimentId: experimentId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getExperimentIdByUser = function (username) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENT_ID_USER;
+ data = {username: username};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getExperimentByUser = function (username) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENT_USER;
+ data = {username: username};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+
+ProvenanceRegistry.prototype.updateWorkflowNodeStatus = function (workflowInstanceId, nodeId, executionStatus) {
+ var url, formParam, res;
+ formParam = "?workflowInstanceId=" + workflowInstanceId + "&nodeId=" + nodeId + "&executionStatus=" + executionStatus;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_WORKFLOWNODEOUTPUT + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getExperimentByUser = function (workflowInstanceId, nodeId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_WORKFLOWNODE_STATUS;
+ data = {workflowInstanceId: workflowInstanceId, nodeId: nodeId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getWorkflowNodeStartTime = function (workflowInstanceId, nodeId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_WORKFLOWNODE_STARTTIME;
+ data = {workflowInstanceId: workflowInstanceId, nodeId: nodeId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getWorkflowStartTime = function (workflowInstanceId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_WORKFLOW_STARTTIME;
+ data = {workflowInstanceId: workflowInstanceId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateWorkflowNodeGramData = function (workflowNodeGramData) {
+ var url, data, res;
+ if (workflowNodeGramData instanceof WorkflowNodeGramData) {
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_WORKFLOWNODE_GRAMDATA;
+ data = workflowNodeGramData;
+ res = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ProvenanceRegistry.prototype.getWorkflowInstanceData = function (workflowInstanceId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_WORKFLOWINSTANCEDATA;
+ data = {workflowInstanceId: workflowInstanceId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.isWorkflowInstanceNodePresent = function (workflowInstanceId, nodeId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.WORKFLOWINSTANCE_NODE_EXIST;
+ data = {workflowInstanceId: workflowInstanceId, nodeId: nodeId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.isWorkflowInstanceNodePresentCreate = function (workflowInstanceId, nodeId, createIfNotPresent) {
+ var url, formParam, res;
+ formParam = "?workflowInstanceId=" + workflowInstanceId + "&nodeId=" + nodeId + "&createIfNotPresent=" + createIfNotPresent;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.WORKFLOWINSTANCE_NODE_EXIST_CREATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getWorkflowInstanceNodeData = function (workflowInstanceId, nodeId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.WORKFLOWINSTANCE_NODE_DATA;
+ data = {workflowInstanceId: workflowInstanceId, nodeId: nodeId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.addWorkflowInstance = function (experimentId, workflowInstanceId, templateName) {
+ var url, formParam, res;
+ formParam = "?experimentId=" + experimentId + "&workflowInstanceId=" + workflowInstanceId + "&templateName=" + templateName;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.ADD_WORKFLOWINSTANCE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.addWorkflowInstance = function (workflowInstanceId, nodeId, nodeType) {
+ var url, formParam, res;
+ formParam = "?workflowInstanceId=" + workflowInstanceId + "&nodeId=" + nodeId + "&nodeType=" + nodeType;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_WORKFLOWNODETYPE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.addWorkflowInstance = function (workflowInstanceId, nodeId) {
+ var url, formParam, res;
+ formParam = "?workflowInstanceId=" + workflowInstanceId + "&nodeId=" + nodeId;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.ADD_WORKFLOWINSTANCENODE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.isExperimentNameExist = function (experimentName) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.WORKFLOWINSTANCE_NODE_DATA;
+ data = {experimentName: experimentName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getExperimentMetaInformation = function (experimentId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENT_METAINFORMATION;
+ data = {experimentId: experimentId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getAllExperimentMetaInformation = function (user) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_ALL_EXPERIMENT_METAINFORMATION;
+ data = {user: user};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.searchExperiments = function (user, experimentNameRegex) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.SEARCH_EXPERIMENTS;
+ data = {user: user, experimentNameRegex: experimentNameRegex};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getExperimentExecutionErrors = function (experimentId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENT_ERRORS;
+ data = {experimentId: experimentId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getWorkflowExecutionErrors = function (experimentId, workflowInstanceId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXPERIMENT_ERRORS;
+ data = {experimentId: experimentId, workflowInstanceId: workflowInstanceId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getNodeExecutionErrors = function (experimentId, workflowInstanceId, nodeId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_NODE_ERRORS;
+ data = {experimentId: experimentId, workflowInstanceId: workflowInstanceId, nodeId: nodeId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getGFacJobErrors = function (experimentId, workflowInstanceId, nodeId, gfacJobId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_GFAC_ERRORS;
+ data = {experimentId: experimentId, workflowInstanceId: workflowInstanceId, nodeId: nodeId, gfacJobId: gfacJobId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getAllGFacJobErrors = function (gfacJobId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_ALL_GFAC_ERRORS;
+ data = {gfacJobId: gfacJobId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getGFacJobErrors = function (experimentId, workflowInstanceId, nodeId, gfacJobId, sourceFilter) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_EXECUTION_ERRORS;
+ data = {experimentId: experimentId, workflowInstanceId: workflowInstanceId, nodeId: nodeId, gfacJobId: gfacJobId, sourceFilter: sourceFilter};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.addExperimentError = function (experimentExecutionError) {
+ var url, data, res;
+ if (experimentExecutionError instanceof ExperimentExecutionError) {
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.ADD_EXPERIMENT_ERROR;
+ data = experimentExecutionError;
+ res = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ProvenanceRegistry.prototype.addWorkflowError = function (workflowExecutionError) {
+ var url, data, res;
+ if (workflowExecutionError instanceof WorkflowExecutionError) {
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.ADD_WORKFLOW_ERROR;
+ data = workflowExecutionError;
+ res = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ProvenanceRegistry.prototype.addNodeExecutionError = function (nodeExecutionError) {
+ var url, data, res;
+ if (nodeExecutionError instanceof NodeExecutionError) {
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.ADD_NODE_ERROR;
+ data = nodeExecutionError;
+ res = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ProvenanceRegistry.prototype.addGFacJobExecutionError = function (applicationJobExecutionError) {
+ var url, data, res;
+ if (applicationJobExecutionError instanceof ApplicationJobExecutionError) {
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.ADD_GFAC_ERROR;
+ data = applicationJobExecutionError;
+ res = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ProvenanceRegistry.prototype.addApplicationJob = function (applicationJob) {
+ var url, data, res;
+ if (applicationJob instanceof ApplicationJob) {
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.ADD_APPLICATION_JOB;
+ data = applicationJob;
+ res = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ProvenanceRegistry.prototype.addApplicationJob = function (applicationJob) {
+ var url, data, res;
+ if (applicationJob instanceof ApplicationJob) {
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_APPLICATION_JOB;
+ data = applicationJob;
+ res = sendAndReceive(url, optionalBasicHeaders, type.post, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ProvenanceRegistry.prototype.updateApplicationJobStatus = function (gfacJobID, gfacJobStatus, statusUpdateDate) {
+ var url, formParam, res;
+ formParam = "?gfacJobID=" + gfacJobIDd + "&gfacJobStatus=" + gfacJobStatus + "&statusUpdateDate=" + statusUpdateDate;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_APPLICATION_JOB_STATUS + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateApplicationJobData = function (gfacJobID, jobdata) {
+ var url, formParam, res;
+ formParam = "?gfacJobID=" + gfacJobIDd + "&jobdata=" + jobdata;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_APPLICATION_JOB_DATA + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateApplicationJobSubmittedTime = function (gfacJobID, submittedDate) {
+ var url, formParam, res;
+ formParam = "?gfacJobID=" + gfacJobIDd + "&submittedDate=" + submittedDate;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_APPLICATION_JOB_SUBMITTED_TIME + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.updateApplicationJobMetadata = function (gfacJobID, metadata) {
+ var url, formParam, res;
+ formParam = "?gfacJobID=" + gfacJobIDd + "&metadata=" + metadata;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.UPDATE_APPLICATION_JOB_METADATA + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getApplicationJob = function (gfacJobId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_APPLICATION_JOB;
+ data = {gfacJobId: gfacJobId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getApplicationJobsForDescriptors = function (serviceDescriptionId, hostDescriptionId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_APPLICATION_JOBS_FOR_DESCRIPTORS;
+ data = {serviceDescriptionId: serviceDescriptionId, hostDescriptionId: hostDescriptionId, applicationDescriptionId: applicationDescriptionId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.getApplicationJobs = function (experimentId, workflowExecutionId, nodeId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.GET_APPLICATION_JOBS;
+ data = {experimentId: experimentId, workflowExecutionId: workflowExecutionId, nodeId: nodeId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProvenanceRegistry.prototype.isApplicationJobExists = function (gfacJobId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.APPLICATION_JOB_EXIST;
+ data = {gfacJobId: gfacJobId};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProvenanceRegistry.prototype.getApplicationJobStatusHistory = function (gfacJobId) {
+ var url, data, res;
+ url = this.provenanceResourcePath + provenanceResourcePathConstants.APPLICATION_JOB_EXIST;
+ data = {gfacJobId: gfacJobId};
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+
+// ========================================= Experiment Registry Resource ==========================================
+
+var experimentResourcePathConstants = {
+ EXP_RESOURCE_PATH: "/experimentregistry/",
+ DELETE_EXP: "delete/experiment",
+ GET_ALL_EXPS: "get/experiments/all",
+ GET_EXPS_BY_PROJECT: "get/experiments/project",
+ GET_EXPS_BY_DATE: "get/experiments/date",
+ GET_EXPS_PER_PROJECT_BY_DATE: "get/experiments/project/date",
+ ADD_EXP: "add/experiment",
+ EXP_EXISTS: "experiment/exist",
+ EXP_EXISTS_CREATE: "experiment/notexist/create"
+}
+
+function ExperimentRegistry() {
+ this.experimentRegistryPath = baseURL.BASE_RES_PATH + experimentResourcePathConstants.EXP_RESOURCE_PATH;
+}
+
+ExperimentRegistry.prototype.removeExperiment = function (experimentId) {
+ var url , data, res;
+ if (experimentId) {
+ url = this.experimentRegistryPath + experimentResourcePathConstants.DELETE_EXP;
+ data = { experimentId: experimentId}
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, data, null);
+ return res.responseText;
+ } else {
+ // TODO throw an exception
+ }
+}
+
+ExperimentRegistry.prototype.getExperiments = function () {
+ var url , data, res;
+ url = this.experimentRegistryPath + experimentResourcePathConstants.GET_ALL_EXPS;
+ data = { experimentId: experimentId}
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ExperimentRegistry.prototype.getExperimentsByDate = function (projectName) {
+ var url , data, res;
+ url = this.experimentRegistryPath + experimentResourcePathConstants.GET_EXPS_BY_PROJECT;
+ data = {projectName: projectName}
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ExperimentRegistry.prototype.getExperimentsByDate = function (fromDate, toDate) {
+ var url , data, res;
+ url = this.experimentRegistryPath + experimentResourcePathConstants.GET_EXPS_BY_DATE;
+ data = {fromDate: fromDate, toDate: toDate}
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ExperimentRegistry.prototype.getExperimentsByProjectDate = function (projectName, fromDate, toDate) {
+ var url , data, res;
+ url = this.experimentRegistryPath + experimentResourcePathConstants.GET_EXPS_PER_PROJECT_BY_DATE;
+ data = {projectName: projectName, fromDate: fromDate, toDate: toDate}
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+
+ExperimentRegistry.prototype.addExperiment = function (projectName, experimentID, submittedDate) {
+ var url , formParam, res;
+ formParam = "?projectName=" + projectName + "&experimentID=" + experimentID + "&submittedDate=" + submittedDate;
+ url = this.experimentRegistryPath + experimentResourcePathConstants.GET_EXPS_PER_PROJECT_BY_DATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+
+ExperimentRegistry.prototype.isExperimentExists = function (experimentID) {
+ var url , data, res;
+ url = this.experimentRegistryPath + experimentResourcePathConstants.EXP_EXISTS;
+ data = {experimentID: experimentID}
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ExperimentRegistry.prototype.isExperimentExistsThenCreate = function (experimentID, createIfNotPresent) {
+ var url , formParam, res;
+ formParam = "?experimentID=" + experimentID + "&createIfNotPresent=" + createIfNotPresent;
+ url = this.experimentRegistryPath + experimentResourcePathConstants.EXP_EXISTS_CREATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+// ========================================= Project Registry Resource ==========================================
+
+
+var projectResourcePathConstant = {
+ REGISTRY_API_PROJECTREGISTRY: "/projectregistry/",
+ PROJECT_EXIST: "project/exist",
+ PROJECT_EXIST_CREATE: "project/exist",
+ ADD_PROJECT: "add/project",
+ UPDATE_PROJECT: "update/project",
+ DELETE_PROJECT: "delete/project",
+ GET_PROJECT: "get/project",
+ GET_PROJECTS: "get/projects"
+}
+
+function ProjectRegistry() {
+ this.projectRegistryPath = baseURL.BASE_RES_PATH + projectResourcePathConstant.REGISTRY_API_PROJECTREGISTRY;
+
+}
+
+ProjectRegistry.prototype.isWorkspaceProjectExists = function (projectName) {
+ var url, data, res;
+ url = this.projectRegistryPath + projectResourcePathConstant.PROJECT_EXIST;
+ data = {projectName: projectName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+ProjectRegistry.prototype.isWorkspaceProjectExistsCreate = function (projectName, createIfNotPresent) {
+ var url , formParam, res;
+ formParam = "?projectName=" + projectName + "&createIfNotPresent=" + createIfNotPresent;
+ url = this.projectRegistryPath + projectResourcePathConstant.PROJECT_EXIST_CREATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProjectRegistry.prototype.addWorkspaceProject = function (projectName) {
+ var url , formParam, res;
+ formParam = "?projectName=" + projectName;
+ url = this.projectRegistryPath + projectResourcePathConstant.PROJECT_EXIST_CREATE + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProjectRegistry.prototype.updateWorkspaceProject = function (projectName) {
+ var url , formParam, res;
+ formParam = "?projectName=" + projectName;
+ url = this.projectRegistryPath + projectResourcePathConstant.UPDATE_PROJECT + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+ProjectRegistry.prototype.deleteWorkspaceProject = function (projectName) {
+ var url, data, res;
+ url = this.projectRegistryPath + projectResourcePathConstant.DELETE_PROJECT;
+ data = {projectName: projectName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, data, null);
+ return res.responseText;
+}
+
+ProjectRegistry.prototype.getWorkspaceProject = function (projectName) {
+ var url, data, res;
+ url = this.projectRegistryPath + projectResourcePathConstant.GET_PROJECT;
+ data = {projectName: projectName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseJSON;
+}
+
+ProjectRegistry.prototype.getWorkspaceProjects = function () {
+ var url, data, res;
+ url = this.projectRegistryPath + projectResourcePathConstant.GET_PROJECTS;
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+
+// ========================================= PublishWorkflow Registry Resource ==========================================
+
+
+var publishedWFConstants = {
+
+ REGISTRY_API_PUBLISHWFREGISTRY: "/publishwfregistry/",
+ PUBLISHWF_EXIST: "publishwf/exist",
+ PUBLISH_WORKFLOW: "publish/workflow",
+ PUBLISH_DEFAULT_WORKFLOW: "publish/default/workflow",
+ GET_PUBLISHWORKFLOWGRAPH: "get/publishworkflowgraph",
+ GET_PUBLISHWORKFLOWNAMES: "get/publishworkflownames",
+ GET_PUBLISHWORKFLOWS: "get/publishworkflows",
+ REMOVE_PUBLISHWORKFLOW: "remove/publishworkflow"
+}
+
+function PublishWorkflowRegistry() {
+ this.publishWorkflowResourcePath = baseURL.BASE_RES_PATH + publishedWFConstants.REGISTRY_API_PUBLISHWFREGISTRY;
+}
+
+PublishWorkflowRegistry.prototype.isPublishedWorkflowExists = function (workflowName) {
+ var url, data, res;
+ url = this.publishWorkflowResourcePath + publishedWFConstants.PUBLISHWF_EXIST;
+ data = {workflowName: workflowName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+PublishWorkflowRegistry.prototype.publishWorkflow = function (workflowName, publishWorkflowName) {
+ var url , formParam, res;
+ formParam = "?workflowName=" + workflowName + "&publishWorkflowName=" + publishWorkflowName;
+ url = this.publishWorkflowResourcePath + publishedWFConstants.PUBLISH_WORKFLOW + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+PublishWorkflowRegistry.prototype.publishDefaultWorkflow = function (workflowName) {
+ var url , formParam, res;
+ formParam = "?workflowName=" + workflowName;
+ url = this.publishWorkflowResourcePath + publishedWFConstants.PUBLISH_DEFAULT_WORKFLOW + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+PublishWorkflowRegistry.prototype.getPublishedWorkflowGraphXML = function (workflowName) {
+ var url, data, res;
+ url = this.publishWorkflowResourcePath + publishedWFConstants.GET_PUBLISHWORKFLOWGRAPH;
+ data = {workflowName: workflowName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ // TODO this will return xml file, fix this to return JSON object
+ return res.responseText;
+}
+
+PublishWorkflowRegistry.prototype.getPublishedWorkflowNames = function () {
+ var url, res;
+ url = this.publishWorkflowResourcePath + publishedWFConstants.GET_PUBLISHWORKFLOWNAMES;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+PublishWorkflowRegistry.prototype.getPublishedWorkflows = function () {
+ var url, res;
+ url = this.publishWorkflowResourcePath + publishedWFConstants.GET_PUBLISHWORKFLOWS;
+ res = sendAndReceive(url, airavataBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+PublishWorkflowRegistry.prototype.removePublishedWorkflow = function (workflowName) {
+ var url, data, res;
+ url = this.publishWorkflowResourcePath + publishedWFConstants.REMOVE_PUBLISHWORKFLOW;
+ data = {workflowName: workflowName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, data, null);
+ return res.responseText;
+}
+
+// ========================================= PublishWorkflow Registry Resource ==========================================
+
+
+var userWFConstants = {
+
+ REGISTRY_API_USERWFREGISTRY: "/userwfregistry/",
+ WORKFLOW_EXIST: "workflow/exist",
+ ADD_WORKFLOW: "add/workflow",
+ UPDATE_WORKFLOW: "update/workflow",
+ GET_WORKFLOWGRAPH: "get/workflowgraph",
+ GET_WORKFLOWS: "get/workflows",
+ REMOVE_WORKFLOW: "remove/workflow"
+}
+
+function UserWorkflowRegistry() {
+ this.userWorkflowResourcePath = baseURL.BASE_RES_PATH + userWFConstants.REGISTRY_API_USERWFREGISTRY;
+}
+
+UserWorkflowRegistry.prototype.isWorkflowExists = function (workflowName) {
+ var url, data, res;
+ url = this.userWorkflowResourcePath + userWFConstants.WORKFLOW_EXIST;
+ data = {workflowName: workflowName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+UserWorkflowRegistry.prototype.addWorkflow = function (workflowName, workflowGraphXml) {
+ var url , formParam, res;
+ formParam = "?workflowName=" + workflowName + "&workflowGraphXml=" + workflowGraphXml;
+ url = this.userWorkflowResourcePath + userWFConstants.ADD_WORKFLOW + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+UserWorkflowRegistry.prototype.updateWorkflow = function (workflowName, workflowGraphXml) {
+ var url , formParam, res;
+ formParam = "?workflowName=" + workflowName + "&workflowGraphXml=" + workflowGraphXml;
+ url = this.userWorkflowResourcePath + userWFConstants.UPDATE_WORKFLOW + formParam;
+ res = sendAndReceive(url, formBasicHeaders, type.post, null, null);
+ return res.responseText;
+}
+
+UserWorkflowRegistry.prototype.getWorkflowGraphXML = function (workflowName) {
+ var url, data, res;
+ url = this.userWorkflowResourcePath + userWFConstants.GET_WORKFLOWGRAPH;
+ data = {workflowName: workflowName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, data, null);
+ return res.responseText;
+}
+
+UserWorkflowRegistry.prototype.getWorkflows = function () {
+ var url, res;
+ url = this.userWorkflowResourcePath + userWFConstants.GET_WORKFLOWS;
+ res = sendAndReceive(url, optionalBasicHeaders, type.get, null, null);
+ return res.responseJSON;
+}
+
+UserWorkflowRegistry.prototype.removeWorkflow = function (workflowName) {
+ var url, data, res;
+ url = this.userWorkflowResourcePath + userWFConstants.REMOVE_WORKFLOW;
+ data = {workflowName: workflowName};
+ res = sendAndReceive(url, optionalBasicHeaders, type.delete, data, null);
+ return res.responseText;
+}
Added: airavata/sandbox/gsoc2013/app/styles/main.scss
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/styles/main.scss?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/styles/main.scss (added)
+++ airavata/sandbox/gsoc2013/app/styles/main.scss Wed Jul 24 22:44:33 2013
@@ -0,0 +1,43 @@
+/*
+ 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.
+*/
+
+@import "bootstrap-sass/lib/bootstrap";
+@import "bootstrap-sass/lib/responsive";
+$FontAwesomePath: "/bower_components/font-awesome/font";
+@import "font-awesome/scss/font-awesome";
+
+/* Generic styles */
+body {
+ background: #fafafa;
+ color: #333;
+}
+
+/* Styles dealing with the side navigation bar */
+.sidebar-nav {
+ padding: 9px 0;
+}
+
+@media (max-width: 980px) {
+ /* Enable use of floated navbar text */
+ .navbar-text.pull-right {
+ float: none;
+ padding-left: 5px;
+ padding-right: 5px;
+ }
+}
Propchange: airavata/sandbox/gsoc2013/app/styles/main.scss
------------------------------------------------------------------------------
svn:executable = *
Added: airavata/sandbox/gsoc2013/app/views/addHost.html
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/views/addHost.html?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/views/addHost.html (added)
+++ airavata/sandbox/gsoc2013/app/views/addHost.html Wed Jul 24 22:44:33 2013
@@ -0,0 +1,45 @@
+<!--
+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.
+-->
+
+<div class="modal hide fade" id="addHostModal" aria-labelledby="addHostModal" tabindex="-1" role="dialog" aria-hidden="true">
+ <div class="modal-header">
+ <button type="button" class="close" data-dismiss="modal" aria-hidden="true">Ã</button>
+ <h3>Register Host</h3>
+ </div>
+ <div class="modal-body">
+ <form class="form-horizontal">
+ <div class="control-group">
+ <label class="control-label" for="inputHostId"><i class=" icon-pencil icon-white"></i></label>
+ <div class="controls">
+ <input type="text" id="inputHostId" placeholder="Host Id" ng-model="hostId">
+ </div>
+ </div>
+ <div class="control-group">
+ <label class="control-label" for="inputHostAddress"><i class=" icon-upload icon-white"></i></label>
+ <div class="controls">
+ <input type="url" id="inputHostAddress" placeholder="Host Address" ng-model="hostAddress">
+ </div>
+ </div>
+ </form>
+ </div>
+ <div class="modal-footer">
+ <a href="#" class="btn btn-primary">Save</a>
+ <a href="#" class="btn " data-dismiss="modal" aria-hidden="true">Cancel</a>
+ </div>
+</div>
\ No newline at end of file
Added: airavata/sandbox/gsoc2013/app/views/create.canvas.html
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/views/create.canvas.html?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/views/create.canvas.html (added)
+++ airavata/sandbox/gsoc2013/app/views/create.canvas.html Wed Jul 24 22:44:33 2013
@@ -0,0 +1 @@
+Hwldcjndvjd
\ No newline at end of file
Added: airavata/sandbox/gsoc2013/app/views/create.sidenavbar.html
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/views/create.sidenavbar.html?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/views/create.sidenavbar.html (added)
+++ airavata/sandbox/gsoc2013/app/views/create.sidenavbar.html Wed Jul 24 22:44:33 2013
@@ -0,0 +1,21 @@
+<ul class="nav nav-list">
+ <li class="nav-header">Sidebar</li>
+ <li class="active"><a href="#">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li class="nav-header">Sidebar</li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li class="nav-header">Sidebar</li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+ <li><a href="#/create">Link</a></li>
+</ul>
Added: airavata/sandbox/gsoc2013/app/views/index.canvas.html
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/views/index.canvas.html?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/views/index.canvas.html (added)
+++ airavata/sandbox/gsoc2013/app/views/index.canvas.html Wed Jul 24 22:44:33 2013
@@ -0,0 +1,43 @@
+<div class="hero-unit">
+ <h1>Apache Airavata WebUI</h1>
+ <p>Connect to a registry to begin.</p>
+ </div>
+ <div class="row-fluid">
+
+ <div class="span4">
+ <h2>Heading</h2>
+ <p>Donec id elit non mi porta gravida at eget metus. Fusce dapibus, tellus ac cursus commodo, tortor mauris condimentum nibh, ut fermentum massa justo sit amet risus. Etiam porta sem malesuada magna mollis euismod. Donec sed odio dui. </p>
+ <p><a class="btn" href="#">View details »</a></p>
+ </div><!--/span-->
+ <div class="span4">
+ <h2>Heading</h2>
+
+ <p>Donec id elit non mi porta gravida at eget metus. Fusce dapibus, tellus ac cursus commodo, tortor mauris condimentum nibh, ut fermentum massa justo sit amet risus. Etiam porta sem malesuada magna mollis euismod. Donec sed odio dui. </p>
+ <p><a class="btn" href="#">View details »</a></p>
+ </div><!--/span-->
+ <div class="span4">
+ <h2>Heading</h2>
+ <p>Donec id elit non mi porta gravida at eget metus. Fusce dapibus, tellus ac cursus commodo, tortor mauris condimentum nibh, ut fermentum massa justo sit amet risus. Etiam porta sem malesuada magna mollis euismod. Donec sed odio dui. </p>
+ <p><a class="btn" href="#">View details »</a></p>
+
+ </div><!--/span-->
+ </div><!--/row-->
+ <div class="row-fluid">
+ <div class="span4">
+ <h2>Heading</h2>
+ <p>Donec id elit non mi porta gravida at eget metus. Fusce dapibus, tellus ac cursus commodo, tortor mauris condimentum nibh, ut fermentum massa justo sit amet risus. Etiam porta sem malesuada magna mollis euismod. Donec sed odio dui. </p>
+ <p><a class="btn" href="#">View details »</a></p>
+
+ </div><!--/span-->
+ <div class="span4">
+ <h2>Heading</h2>
+ <p>Donec id elit non mi porta gravida at eget metus. Fusce dapibus, tellus ac cursus commodo, tortor mauris condimentum nibh, ut fermentum massa justo sit amet risus. Etiam porta sem malesuada magna mollis euismod. Donec sed odio dui. </p>
+ <p><a class="btn" href="#">View details »</a></p>
+ </div><!--/span-->
+ <div class="span4">
+
+ <h2>Heading</h2>
+ <p>Donec id elit non mi porta gravida at eget metus. Fusce dapibus, tellus ac cursus commodo, tortor mauris condimentum nibh, ut fermentum massa justo sit amet risus. Etiam porta sem malesuada magna mollis euismod. Donec sed odio dui. </p>
+ <p><a class="btn" href="#">View details »</a></p>
+ </div><!--/span-->
+ </div><!--/row-->
Added: airavata/sandbox/gsoc2013/app/views/index.navbar.html
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/views/index.navbar.html?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/views/index.navbar.html (added)
+++ airavata/sandbox/gsoc2013/app/views/index.navbar.html Wed Jul 24 22:44:33 2013
@@ -0,0 +1,7 @@
+<ul class="nav">
+ <li class="active"><a href="#"><i class="icon-home"></i> Home</a></li>
+ <li><a href="#"><i class="icon-question"></i> Help</a></li>
+</ul>
+<ul class="nav pull-right">
+ <li><a href="http://airavata.apache.org/"><i class="icon-globe"></i> Airavata</a></li>
+</ul>
Added: airavata/sandbox/gsoc2013/app/views/index.sidenavbar.html
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/views/index.sidenavbar.html?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/views/index.sidenavbar.html (added)
+++ airavata/sandbox/gsoc2013/app/views/index.sidenavbar.html Wed Jul 24 22:44:33 2013
@@ -0,0 +1,15 @@
+<form style="padding:10px;">
+ <fieldset>
+ <legend>Connect to Airavata</legend>
+ <label>Registry URL</label>
+ <input type="text" placeholder="http://localhost:8080/airavata-registry/api">
+ <label>Gateway</label>
+ <input type="text" placeholder="default">
+ <label>Username</label>
+ <input type="text" placeholder="admin">
+ <label>Password</label>
+ <input type="password" placeholder="Password">
+ <br>
+ <button type="submit" class="btn">Connect</button>
+ </fieldset>
+</form>
Added: airavata/sandbox/gsoc2013/app/views/launchWorkflow.html
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/app/views/launchWorkflow.html?rev=1506767&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/app/views/launchWorkflow.html (added)
+++ airavata/sandbox/gsoc2013/app/views/launchWorkflow.html Wed Jul 24 22:44:33 2013
@@ -0,0 +1,149 @@
+<!--
+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.
+-->
+<!--<form class="form-horizontal" name="launchWorkflowForm">
+ <div class="control-group" ng-class="{error: launchWorkflowForm.name.$invalid}">
+ <label>Name</label>
+ <input type="text" name="name" ng-model="project.name" required>
+ <span ng-show="myForm.name.$error.required" class="help-inline">
+ Required</span>
+ </div>
+
+ <div class="control-group" ng-class="{error: myForm.site.$invalid}">
+ <label>Website</label>
+ <input type="url" name="site" ng-model="project.site" required>
+ <span ng-show="myForm.site.$error.required" class="help-inline">
+ Required</span>
+ <span ng-show="myForm.site.$error.url" class="help-inline">
+ Not a URL</span>
+ </div>
+
+ <label>Description</label>
+ <textarea name="description" ng-model="project.description"></textarea>
+
+ <br>
+ <a href="#/" class="btn">Cancel</a>
+ <button ng-click="save()" ng-disabled="isClean() || myForm.$invalid"
+ class="btn btn-primary">Save</button>
+ <button ng-click="destroy()"
+ ng-show="project.$id" class="btn btn-danger">Delete</button>
+</form> -->
+
+
+<div class="modal hide fade" id="launchWorkflow" ui-if="isWorkflowOpen" aria-labelledby="runWorkflowModal" tabindex="-1" role="dialog" aria-hidden="true">
+ <div class="modal-header">
+ <button type="button" class="close" data-dismiss="modal" aria-hidden="true">Ã</button>
+ <h3>Launch Workflow</h3>
+ </div>
+ <div class="modal-body">
+ <form class="form-horizontal">
+ <div class="control-group" ng-repeat="input in workflowInputs">
+ <label class="control-label" for={{input.id}}>{{input.name}} {{input.datatype}}</label>
+ <div class="controls">
+ <input type="text" id={{input.id}} placeholder={{input.value}} ng-model={{input.name}} required>
+ </div>
+ </div>
+ <div class="control-group">
+ <label class="control-label" for="inputExperimentName"><i class=" icon-pencil icon-white"></i></label>
+ <div class="controls">
+ <input type="text" id="inputExperimentName" placeholder="Experiment Name" ng-model="experimentName" required>
+ </div>
+ </div>
+ <div class="control-group">
+ <label class="control-label" for="inputWorkflowInterpreterURL"><i class=" icon-upload icon-white"></i></label>
+ <div class="controls">
+ <input type="url" id="inputWorkflowInterpreterURL" placeholder="Workflow Interpreter URL" ng-model="workflowInterpreterURL" required>
+ </div>
+ </div>
+ <div class="control-group">
+ <label class="control-label" for="inputGFacURL"><i class=" icon-upload icon-white"></i></label>
+ <div class="controls">
+ <input type="url" id="inputGFacURL" placeholder="GFac URL" ng-model="gfacURL" required="">
+ </div>
+ </div>
+ </form>
+ </div>
+ <div class="modal-footer">
+ <a href="#" class="btn btn-primary">Run</a>
+ <a href="#" class="btn " data-dismiss="modal" aria-hidden="true">Cancel</a>
+ </div>
+</div>
+
+<div class="modal hide fade" id="addHost" aria-labelledby="addHostModal" tabindex="-1" role="dialog" aria-hidden="true">
+ <div class="modal-header">
+ <button type="button" class="close" data-dismiss="modal" aria-hidden="true">Ã</button>
+ <h3>Register Host</h3>
+ </div>
+ <div class="modal-body">
+ <form class="form-horizontal">
+ <div class="control-group">
+ <label class="control-label" for="inputHostId"><i class=" icon-pencil icon-white"></i></label>
+ <div class="controls">
+ <input type="text" id="inputHostId" placeholder="Host Id" ng-model="hostId">
+ </div>
+ </div>
+ <div class="control-group">
+ <label class="control-label" for="inputHostAddress"><i class=" icon-upload icon-white"></i></label>
+ <div class="controls">
+ <input type="url" id="inputHostAddress" placeholder="Host Address" ng-model="hostAddress">
+ </div>
+ </div>
+ </form>
+ </div>
+ <div class="modal-footer">
+ <a href="#" class="btn btn-primary">Save</a>
+ <a href="#" class="btn " data-dismiss="modal" aria-hidden="true">Cancel</a>
+ </div>
+</div>
+
+
+<div class="modal hide fade" id="newApplicationDeploy" aria-labelledby="addHostModal" tabindex="-1" role="dialog" aria-hidden="true">
+ <div class="modal-header">
+ <button type="button" class="close" data-dismiss="modal" aria-hidden="true">Ã</button>
+ <h3>New Application Deployment</h3>
+ </div>
+ <div class="modal-body">
+ <form class="form-horizontal">
+ <div class="control-group">
+ <label class="control-label" for="applicationHost">Application Host: </label>
+ <div class="controls">
+ <select id="applicationHost" ng-model="applicationHost" ng-options="host.name for host in hostList"></select> <a href="#addHost" role="button" data-toggle="modal" title="Create New Host"><i class="icon-plus-sign icon-white"></i></a>
+ </div>
+ </div>
+ <div class="control-group">
+ <label class="control-label" for="executablePath">Executable Path</label>
+ <div class="controls">
+ <input type="url" id="executablePath" placeholder="Executable Path" ng-model="executablePath" required> <i class=" icon-folder-open icon-white"></i>
+ </div>
+ </div>
+ <div class="control-group">
+ <label class="control-label" for="scratchWorkingDirectory">Scratch Working Directory</label>
+ <div class="controls">
+ <input type="url" id="scratchWorkingDirectory" placeholder="Scratch Working Directory" ng-model="scratchWorkingDirectory" required> <i class=" icon-folder-open icon-white"></i>
+ </div>
+ </div>
+ <div>
+ <a href="#" class="btn btn-primary">Advance Application Configuration</a>
+ </div>
+ </form>
+ </div>
+ <div class="modal-footer">
+ <a href="#" class="btn btn-primary">Add</a>
+ <a href="#" class="btn " data-dismiss="modal" aria-hidden="true">Cancel</a>
+ </div>
+</div>
\ No newline at end of file