airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ami...@apache.org
Subject svn commit: r1503233 - /airavata/sandbox/gsoc2013/js/registryAPI.js
Date Mon, 15 Jul 2013 13:19:09 GMT
Author: amilaj
Date: Mon Jul 15 13:19:09 2013
New Revision: 1503233

URL: http://svn.apache.org/r1503233
Log:
Fixing AIRAVATA-887. Commiting only the JS file. Thanks Shameera for contribution

Added:
    airavata/sandbox/gsoc2013/js/registryAPI.js

Added: airavata/sandbox/gsoc2013/js/registryAPI.js
URL: http://svn.apache.org/viewvc/airavata/sandbox/gsoc2013/js/registryAPI.js?rev=1503233&view=auto
==============================================================================
--- airavata/sandbox/gsoc2013/js/registryAPI.js (added)
+++ airavata/sandbox/gsoc2013/js/registryAPI.js Mon Jul 15 13:19:09 2013
@@ -0,0 +1,1658 @@
+
+
+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;
+}
+
+
+
+
+
+
+
+



Mime
View raw message