Index: trunk/zoo-project/zoo-client/lib/js/wps-client/utils.js =================================================================== --- trunk/zoo-project/zoo-client/lib/js/wps-client/utils.js (revision 480) +++ trunk/zoo-project/zoo-client/lib/js/wps-client/utils.js (revision 480) @@ -0,0 +1,74 @@ +define([ +], function() { + + + // parseUri 1.2.2 + // (c) Steven Levithan + // MIT License + + function parseUri (str) { + var o = parseUri.options, + m = o.parser[o.strictMode ? "strict" : "loose"].exec(str), + uri = {}, + i = 14; + + while (i--) uri[o.key[i]] = m[i] || ""; + + uri[o.q.name] = {}; + uri[o.key[12]].replace(o.q.parser, function ($0, $1, $2) { + if ($1) uri[o.q.name][$1] = $2; + }); + + return uri; + }; + + parseUri.options = { + strictMode: false, + key: ["source","protocol","authority","userInfo","user","password","host","port","relative","path","directory","file","query","anchor"], + q: { + name: "queryKey", + parser: /(?:^|&)([^&=]*)=?([^&]*)/g + }, + parser: { + strict: /^(?:([^:\/?#]+):)?(?:\/\/((?:(([^:@]*)(?::([^:@]*))?)?@)?([^:\/?#]*)(?::(\d*))?))?((((?:[^?#\/]*\/)*)([^?#]*))(?:\?([^#]*))?(?:#(.*))?)/, + loose: /^(?:(?![^:@]+:[^:@\/]*@)([^:\/?#.]+):)?(?:\/\/)?((?:(([^:@]*)(?::([^:@]*))?)?@)?([^:\/?#]*)(?::(\d*))?)(((\/(?:[^?#](?![^?#\/]*\.[^?#\/.]+(?:[?#]|$)))*\/?)?([^?#\/]*))(?:\?([^#]*))?(?:#(.*))?)/ + } + }; + + + // + function xmlToString(data) { + //data.xml check for IE + var xmlstr = data.xml ? data.xml : (new XMLSerializer()).serializeToString(data); + return xmlstr; + } + + function equalsString(a, b) { + if (!a) { + return false; + } + + if (!b) { + return false; + } + + return jQuery.trim(a).localeCompare(jQuery.trim(b)) == 0; + } + + function encodeXML(str) { + return str.replace(/&/g, '&') + .replace(//g, '>') + .replace(/"/g, '"') + .replace(/'/g, '''); + }; + + return { + parseUri: parseUri, + xmlToString: xmlToString, + equalsString: equalsString, + encodeXML: encodeXML, + }; + + +}); Index: trunk/zoo-project/zoo-client/lib/js/wps-client/wps-payload.js =================================================================== --- trunk/zoo-project/zoo-client/lib/js/wps-client/wps-payload.js (revision 480) +++ trunk/zoo-project/zoo-client/lib/js/wps-client/wps-payload.js (revision 480) @@ -0,0 +1,138 @@ +// Filename: wps-payload.js +/** + * Author : Samuel Souk aloun + * + * Copyright (c) 2014 GeoLabs SARL + * + * Permission is hereby granted, free of charge, to any person obtaining a copy + * of this software and associated documentation files (the "Software"), to deal + * in the Software without restriction, including without limitation the rights + * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell + * copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN + * THE SOFTWARE. + */ + +define([ + 'jquery', 'utils', + 'hgn!tpl/payload_GetCapabilities', + 'hgn!tpl/payload_DescribeProcess', + 'hgn!tpl/payload_Execute', + + +], function($, utils, tplGetCapabilities, tplDescribeProcess, tplExecute) { + + // + return { + + // + getPayload: function(params) { + if (params.request == 'DescribeProcess') { + return this.getPayload_DescribeProcess(params); + } else if (params.request == 'GetCapabilities') { + return this.getPayload_GetCapabilities(params); + } else if (params.request == 'Execute') { + return this.getPayload_Execute(params); + } else { + console.log("#### UNKNOWN REQUEST ####"); + } + }, + + // + getPayload_DescribeProcess: function(params) { + if (params.Identifier) { + if ($.isArray(params.Identifier)) { + return tplDescribeProcess({identifiers: params.Identifier}); + } + else { + return tplDescribeProcess({identifiers: [params.Identifier]}); + } + } + // TODO: no Identifier + }, + + // + getPayload_GetCapabilities: function(params) { + return tplGetCapabilities(); + }, + + // + getPayload_Execute: function(params) { + //console.log(params); + //console.log("==== INPUTS ===="); + if (params.DataInputs) { + //console.log(params.DataInputs); + + for (var i = 0; i < params.DataInputs.length; i++) { + + /* + * Set some default values and flags. + */ + if (params.DataInputs[i].type == 'bbox') { + if (!params.DataInputs[i].crs) { + params.DataInputs[i].crs = "EPSG:4326"; + } + + if (!params.DataInputs[i].dimension) { + params.DataInputs[i].dimension = 2; + } + } + + if (params.DataInputs[i].type) { + params.DataInputs[i]['is_'+params.DataInputs[i].type] = true; + } + + // Complex data from payload callback. + if (params.DataInputs[i].complexPayload_callback) { + params.DataInputs[i].complexPayload = window[params.DataInputs[i].complexPayload_callback]; + } + + // Complex data from reference. + if (params.DataInputs[i].href) { + params.DataInputs[i].is_reference = true; + //params.DataInputs[i].href = utils.encodeXML(params.DataInputs[i].href); + if (params.DataInputs[i].method == 'POST') { + params.DataInputs[i].is_post = true; + } else { + params.DataInputs[i].is_get = true; + } + } + else { + // Complex data, embeded + } + } // for i loop + } + + //console.log("==== OUTPUTS ===="); + if (params.DataOutputs || params.storeExecuteResponse || params.status || params.lineage) { + console.log(params.DataOutputs); + + for (var i = 0; i < params.DataOutputs.length; i++) { + //console.log(params.DataOutputs[i]); + + if (params.DataOutputs[i].type) { + params.DataOutputs[i]['is_'+params.DataOutputs[i].type] = true; + } + } + } + + return tplExecute(params); + }, + + + }; + +}); + + + Index: trunk/zoo-project/zoo-client/lib/js/wps-client/zoo.js =================================================================== --- trunk/zoo-project/zoo-client/lib/js/wps-client/zoo.js (revision 480) +++ trunk/zoo-project/zoo-client/lib/js/wps-client/zoo.js (revision 480) @@ -0,0 +1,405 @@ +// Filename: zoo-process.js +/** + * Author : Samuel Souk aloun + * + * Copyright (c) 2014 GeoLabs SARL + * + * Permission is hereby granted, free of charge, to any person obtaining a copy + * of this software and associated documentation files (the "Software"), to deal + * in the Software without restriction, including without limitation the rights + * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell + * copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN + * THE SOFTWARE. + */ + +define([ + 'xml2json', 'queryString', 'wpsPayload', 'utils' +], function(X2JS, qs, wpsPayload, utils) { + + var ZooProcess = function(params) { + + /** + * Private + */ + + var _x2js = new X2JS({ + arrayAccessFormPaths: [ + 'ProcessDescriptions.ProcessDescription.DataInputs.Input', + 'ProcessDescriptions.ProcessDescription.DataInputs.Input.ComplexData.Supported.Format', + 'ProcessDescriptions.ProcessDescription.ProcessOutputs.Output', + 'ProcessDescriptions.ProcessDescription.ProcessOutputs.Output.ComplexOutput.Supported.Format', + 'Capabilities.ServiceIdentification.Keywords' + ], + }); + + + /** + * Public + */ + + this.url = params.url; + + this.statusLocation = {}; + this.launched = {}; + this.terminated = {}; + this.percent = {}; + this.delay = params.delay || 2000, + + // + this.describeProcess = function(params) { + var closure = this; + + if (!params.hasOwnProperty('type')) { + params.type = 'GET'; + } + + var zoo_request_params = { + Identifier: params.identifier, + metapath: params.metapath ? params.metapath : '', + request: 'DescribeProcess', + service: 'WPS', + version: '1.0.0', + } + + this.request(zoo_request_params, params.success, params.error, params.type); + }; + + // + this.getCapabilities = function(params) { + var closure = this; + + if (!params.hasOwnProperty('type')) { + params.type = 'GET'; + } + + // http://zoo-server/cgi-bin/zoo_loader.cgi?ServiceProvider=&metapath=&Service=WPS&Request=GetCapabilities&Version=1.0.0 + var zoo_request_params = { + ServiceProvider: '', + metapath: params.metapath ? params.metapath : '', + request: 'GetCapabilities', + service: 'WPS', + version: '1.0.0', + } + + this.request(zoo_request_params, params.success, params.error, params.type); + }; + + // + this.execute = function(params) { + var closure = this; + console.log("======== Execute "+params.identifier); + console.log(params); + + if (!params.hasOwnProperty('type')) { + params.type = 'GET'; + } + + var zoo_request_params = { + request: 'Execute', + service: 'WPS', + version: '1.0.0', + Identifier: params.identifier, + DataInputs: params.dataInputs ? params.dataInputs : '', + DataOutputs: params.dataOutputs ? params.dataOutputs : '', + + //storeExecuteResponse: params.storeExecuteResponse ? 'true' : 'false', + //status: params.status ? 'true' : 'false', + } + + + if (params.hasOwnProperty('responseDocument')) { + zoo_request_params.ResponseDocument = params.responseDocument; + } + if (params.hasOwnProperty('storeExecuteResponse') && params.storeExecuteResponse) { + zoo_request_params.storeExecuteResponse = 'true'; + } + if (params.hasOwnProperty('status') && params.status) { + zoo_request_params.status = 'true'; + } + if (params.hasOwnProperty('lineage') && params.lineage) { + zoo_request_params.lineage = 'true'; + } + + + this.request(zoo_request_params, params.success, params.error, params.type); + }; + + + // + this.request = function(params, onSuccess, onError, type) { + var closure = this; + console.log('======== REQUEST type='+type); + console.log(params); + + var url = this.url; + var payload; + var headers; + + if (type == 'GET') { + url += '?' + this.getQueryString(params); + } else if (type == 'POST') { + payload = wpsPayload.getPayload(params); + console.log("======== POST PAYLOAD ========"); + console.log(payload); + + headers = { + "Content-Type": "text/xml" + }; + } + + console.log("ajax url: "+url); + + $.ajax({ + type: type, + url: url, + dataType: "xml", + data: payload, + headers: headers + }) + .always( + function() { + //console.log("ALWAYS"); + } + ) + .fail( + function(jqXHR, textStatus, errorThrown) { + console.log("======== ERROR ========"); + onError(jqXHR); + } + ) + .done( + function(data, textStatus, jqXHR) { + console.log("======== SUCCESS ========"); + //console.log(data); + console.log(utils.xmlToString(data)); + + // TODO: move this transformation + data = _x2js.xml2json( data ); + + console.log(data); + //------ + + var launched; + + if (params.storeExecuteResponse == 'true' && params.status == 'true') { + launched = closure.parseStatusLocation(data); + console.log(launched); + closure.statusLocation[launched.sid] = launched.statusLocation; + + if (launched.hasOwnProperty('sid') && !closure.launched.hasOwnProperty(launched.sid)) { + closure.launched[launched.sid] = launched.params; + //closure.emit('launched', launched); + } + } + onSuccess(data, launched); + }); + }; + + // + this.watch = function(sid, handlers) { + //onPercentCompleted, onProcessSucceeded, onError + var closure = this; + + console.log("WATCH: "+sid); + + function onSuccess(data) { + console.log("++++ getStatus SUCCESS "+sid); + console.log(data); + + if (data.ExecuteResponse.Status.ProcessStarted) { + console.log("#### ProcessStarted"); + + var ret = { + sid: sid, + percentCompleted: data.ExecuteResponse.Status.ProcessStarted._percentCompleted, + text: data.ExecuteResponse.Status.ProcessStarted.__text, + creationTime: data.ExecuteResponse.Status.ProcessStarted._creationTime, + }; + + closure.percent[sid] = ret.percentCompleted; + //closure.emit('percent', ret); + + if (handlers.onPercentCompleted instanceof Function) { + handlers.onPercentCompleted(ret); + } + } + else if (data.ExecuteResponse.Status.ProcessSucceeded) { + console.log("#### ProcessSucceeded"); + + var text = data.ExecuteResponse.Status.ProcessSucceeded.__text; + closure.terminated[sid] = true; + + ret = { + sid: sid, + text: text, + result: data + }; + + //closure.emit('success', ret); + if (handlers.onProcessSucceeded instanceof Function) { + handlers.onProcessSucceeded(ret); + } + } + else { + console.log("#### UNHANDLED EXCEPTION"); + closure.terminated[sid] = true; + ret = { + sid: sid, + code: 'BAD', + text: 'UNHANDLED EXCEPTION' + }; + + //closure.emit('exception', ret); + if (handlers.onError instanceof Function) { + handlers.onError(ret); + } + } + } + + function onError(data) { + console.log("++++ getStatus ERROR "+sid); + console.log(data); + } + + function ping(sid) { + console.log("PING: "+sid); + closure.getStatus(sid, onSuccess, onError); + if (closure.terminated[sid]) { + console.log("++++ getStatus TERMINATED "+sid); + } + else if (!closure.percent.hasOwnProperty(sid) || closure.percent[sid]<100) { + setTimeout( function() { + ping(sid); + }, closure.delay); + } else { + console.log(closure.percent); + } + } + + ping(sid); + }; + + // + this.getStatus = function(sid, onSuccess, onError) { + var closure = this; + + console.log("GET STATUS: "+sid); + + if (closure.terminated[sid]) { + console.log("DEBUG TERMINATED"); + return; + } + if (!closure.launched[sid]) { + console.log("DEBUG LAUNCHED"); + return; + } + console.log("PARSE URI: "+closure.statusLocation[sid]); + var parsed_url = utils.parseUri(closure.statusLocation[sid]); + console.log(parsed_url); + zoo_request_params = parsed_url.queryKey; + + this.request(zoo_request_params, onSuccess, onError, 'GET'); + }; + + // + this.getQueryString = function(params) { + + var ret = ''; + + // TODO: serialize attributes + serializeInputs = function(obj) { + console.log("SERIALIZE dataInputs"); + console.log(obj); + if($.type(obj) === "string") { + return obj; + } + var str = []; + for(var p in obj){ + if (obj.hasOwnProperty(p)) { + //str.push(encodeURIComponent(p) + "=" + encodeURIComponent(obj[p])); + str.push(p + "=" + obj[p]); + } + } + return str.join(";"); + } + + var responseDocument = params.ResponseDocument; + var tmp_params = {}; + + var objectKeys = Object.keys || function (obj) { + var keys = []; + for (var key in obj) keys.push(key); + return keys; + }; + + var skip = { + 'DataInputs': true, + 'DataOuptputs': true, + 'ResponseDocument': true, + } + var keys = objectKeys(params); + for (var i = 0; i < keys.length; i++) { + var key = keys[i]; + if (skip.hasOwnProperty(key) && skip[key]) { + continue; + } + if (params.hasOwnProperty(key)) { + tmp_params[key] = params[key]; + } + } + + ret = qs.stringify(tmp_params); + + //req_options.path = req_options.path.replace("&DataInputs=sid%3D", "&DataInputs=sid=") + if (params.hasOwnProperty('DataInputs')) { + //var dataInputs = params.DataInputs; + var dataInputs = serializeInputs(params.DataInputs); + console.log("dataInputs: "+dataInputs); + ret += '&DataInputs=' + dataInputs; + } + /* + if (params.hasOwnProperty('DataOutputs')) { + var dataOutputs = serializeOutputs(params.DataOutputs); + console.log("dataOutputs: "+dataOutputs); + ret += '&DataOutputs=' + dataOutputs; + } + */ + //ResponseDocument=Result ou RawDataOutput=Result + + if (params.ResponseDocument) { + ret += '&ResponseDocument=' + params.ResponseDocument; + } + + return ret; + }; + + this.parseStatusLocation = function(data) { + var closure = this; + + if (statusLocation = data.ExecuteResponse._statusLocation) { + console.log("statusLocation: "+statusLocation); + + var parsed_url = utils.parseUri(statusLocation); + console.log(parsed_url); + var parsed_params = parsed_url.queryKey; + + return {sid: parsed_url.queryKey.DataInputs, params: parsed_params, statusLocation: statusLocation}; + } + }; + }; + + + return ZooProcess; + +}); Index: trunk/zoo-project/zoo-client/lib/tpl/payload_DescribeProcess.mustache =================================================================== --- trunk/zoo-project/zoo-client/lib/tpl/payload_DescribeProcess.mustache (revision 480) +++ trunk/zoo-project/zoo-client/lib/tpl/payload_DescribeProcess.mustache (revision 480) @@ -0,0 +1,5 @@ + +{{#identifiers}} + {{.}} +{{/identifiers}} + Index: trunk/zoo-project/zoo-client/lib/tpl/payload_Execute.mustache =================================================================== --- trunk/zoo-project/zoo-client/lib/tpl/payload_Execute.mustache (revision 480) +++ trunk/zoo-project/zoo-client/lib/tpl/payload_Execute.mustache (revision 480) @@ -0,0 +1,82 @@ + + + {{Identifier}} + +{{#DataInputs}} +{{#is_literal}} + + {{identifier}} + + {{value}} + + +{{/is_literal}} +{{#is_bbox}} + + {{identifier}} + + + {{lowerCorner}} + {{upperCorner}} + + + +{{/is_bbox}} +{{#is_complex}} +{{#is_reference}} +{{#is_get}} + + {{identifier}} + + +{{/is_get}} +{{#is_post}} + + {{identifier}} + +{{#mimeType}} + +{{/mimeType}} + {{{complexPayload}}} + + +{{/is_post}} +{{/is_reference}} +{{^is_reference}} + + {{identifier}} + + + {{{complexPayload}}} + + + +{{/is_reference}} +{{/is_complex}} +{{/DataInputs}} + + +{{#RawDataOutput}} + + {{identifier}} + +{{/RawDataOutput}} +{{^RawDataOutput}} + +{{#DataOutputs}} +{{#is_literal}} + + {{identifier}} + +{{/is_literal}} +{{^is_literal}} + + {{identifier}} + +{{/is_literal}} +{{/DataOutputs}} + +{{/RawDataOutput}} + + Index: trunk/zoo-project/zoo-client/lib/tpl/payload_GetCapabilities.mustache =================================================================== --- trunk/zoo-project/zoo-client/lib/tpl/payload_GetCapabilities.mustache (revision 480) +++ trunk/zoo-project/zoo-client/lib/tpl/payload_GetCapabilities.mustache (revision 480) @@ -0,0 +1,5 @@ + + + 1.0.0 + +