+//
+// Copyright (C) 2000, 2001, 2002 Virtual Cowboys info@virtualcowboys.nl
+//
+// Author: Ruben Daniels <ruben@virtualcowboys.nl>
+// Version: 0.91
+// Date: 29-08-2001
+// Site: www.vcdn.org/Public/XMLRPC/
+//
+// This program is free software; you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation; either version 2 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program; if not, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+
+Object.prototype.toXMLRPC = function(){
+ var wo = this.valueOf();
+
+ if(wo.toXMLRPC == this.toXMLRPC){
+ retstr = "<struct>";
+
+ for(prop in this){
+ if(typeof wo[prop] != "function"){
+ retstr += "<member><name>" + prop + "</name><value>" + XMLRPC.getXML(wo[prop]) + "</value></member>";
+ }
+ }
+ retstr += "</struct>";
+
+ return retstr;
+ }
+ else{
+ return wo.toXMLRPC();
+ }
+}
+
+String.prototype.toXMLRPC = function(){
+ //<![CDATA[***your text here***]]>
+ return "<string><![CDATA[" + this.replace(/\]\]/g, "] ]") + "]]></string>";//.replace(/</g, "<").replace(/&/g, "&")
+}
+
+Number.prototype.toXMLRPC = function(){
+ if(this == parseInt(this)){
+ return "<int>" + this + "</int>";
+ }
+ else if(this == parseFloat(this)){
+ return "<double>" + this + "</double>";
+ }
+ else{
+ return false.toXMLRPC();
+ }
+}
+
+Boolean.prototype.toXMLRPC = function(){
+ if(this) return "<boolean>1</boolean>";
+ else return "<boolean>0</boolean>";
+}
+
+Date.prototype.toXMLRPC = function(){
+ //Could build in possibilities to express dates
+ //in weeks or other iso8601 possibillities
+ //hmmmm ????
+ //19980717T14:08:55
+ return "<dateTime.iso8601>" + doYear(this.getUTCYear()) + doZero(this.getMonth()) + doZero(this.getUTCDate()) + "T" + doZero(this.getHours()) + ":" + doZero(this.getMinutes()) + ":" + doZero(this.getSeconds()) + "</dateTime.iso8601>";
+
+ function doZero(nr) {
+ nr = String("0" + nr);
+ return nr.substr(nr.length-2, 2);
+ }
+
+ function doYear(year) {
+ if(year > 9999 || year < 0)
+ XMLRPC.handleError(new Error("Unsupported year: " + year));
+
+ year = String("0000" + year)
+ return year.substr(year.length-4, 4);
+ }
+}
+
+Array.prototype.toXMLRPC = function(){
+ var retstr = "<array><data>";
+ for(var i=0;i<this.length;i++){
+ retstr += "<value>" + XMLRPC.getXML(this[i]) + "</value>";
+ }
+ return retstr + "</data></array>";
+}
+
+function VirtualService(servername, oRPC){
+ this.version = '0.91';
+ this.URL = servername;
+ this.multicall = false;
+ this.autoroute = true;
+ this.onerror = null;
+
+ this.rpc = oRPC;
+ this.receive = {};
+
+ this.purge = function(receive){
+ return this.rpc.purge(this, receive);
+ }
+
+ this.revert = function(){
+ this.rpc.revert(this);
+ }
+
+ this.add = function(name, alias, receive){
+ this.rpc.validateMethodName();if(this.rpc.stop){this.rpc.stop = false;return false}
+ if(receive) this.receive[name] = receive;
+ this[(alias || name)] = new Function('var args = new Array(), i;for(i=0;i<arguments.length;i++){args.push(arguments[i]);};return this.call("' + name + '", args);');
+ return true;
+ }
+
+ //internal function for sending data
+ this.call = function(name, args){
+ var info = this.rpc.send(this.URL, name, args, this.receive[name], this.multicall, this.autoroute);
+
+ if(info){
+ if(!this.multicall) this.autoroute = info[0];
+ return info[1];
+ }
+ else{
+ if(this.onerror) this.onerror(XMLRPC.lastError);
+ return false;
+ }
+ }
+}
+
+
+XMLRPC = {
+ routeServer : "http://www.vcdn.org/cgi-bin/rpcproxy.cgi",
+ autoroute : true,
+ multicall : false,
+
+ services : {},
+ stack : {},
+ queue : new Array(),
+ timers : new Array(),
+ timeout : 30000,
+
+ ontimeout : null,
+
+ getService : function(serviceName){
+ //serviceNames cannot contain / or .
+ if(/[\/\.]/.test(serviceName)){
+ return new VirtualService(serviceName, this);
+ }
+ else if(this.services[serviceName]){
+ return this.services[serviceName];
+ }
+ else{
+ try{
+ var ct = eval(serviceName);
+ this.services[serviceName] = new ct(this);
+ }
+ catch(e){
+ return false;
+ }
+ }
+ },
+
+ purge : function(modConst, receive){
+ if(this.stack[modConst.URL].length){
+ var info = this.send(modConst.URL, "system.multicall", [this.stack[modConst.URL]], receive, false, modConst.autoroute);
+ modConst.autoroute = info[0];
+ this.revert(modConst);
+
+ if(info){
+ modConst.autoroute = info[0];
+ return info[1];
+ }
+ else{
+ if(modConst.onerror) modConst.onerror(this.lastError);
+ return false;
+ }
+ }
+ },
+
+ revert : function(modConst){
+ this.stack[modConst.URL] = new Array();
+ },
+
+ call : function(){
+ //[optional info || receive, servername,] functionname, args......
+ var args = new Array(), i, a = arguments;
+ var servername, methodname, receive, service, info, autoroute, multicall;
+
+ if(typeof a[0] == "object"){
+ receive = a[0][0];
+ servername = a[0][1].URL;
+ methodname = a[1];
+ multicall = (a[0][1].supportsMulticall && a[0][1].multicall);
+ autoroute = a[0][1].autoroute;
+ service = a[0][1];
+ }
+ else if(typeof a[0] == "function"){
+ i = 3;
+ receive = a[0];
+ servername = a[1];
+ methodname = a[2];
+ }
+ else{
+ i = 2;
+ servername = a[0];
+ methodname = a[1];
+ }
+
+ for(i=i;i<a.length;i++){
+ args.push(a[i]);
+ }
+
+ info = this.send(servername, methodname, args, receive, multicall, autoroute);
+ if(info){
+ (service || this).autoroute = info[0];
+ return info[1];
+ }
+ else{
+ if(service && service.onerror) service.onerror(this.lastError);
+ return false;
+ }
+
+ },
+
+ /***
+ * Perform typematching on 'vDunno' and return a boolean value corresponding
+ * to the result of the evaluation-match of the mask-value stated in the 2nd argument.
+ * The 2nd argument is optional (none will be treated as a 0-mask) or a sum of
+ * several masks as follows:
+ * type/s -> mask/s
+ * --------------------
+ * undefined -> 0/1 [default]
+ * number -> 2
+ * boolean -> 4
+ * string -> 8
+ * function -> 16
+ * object -> 32
+ * --------------------
+ * Examples:
+ * Want [String] only: (eqv. (typeof(vDunno) == 'string') )
+ * Soya.Common.typematch(unknown, 8)
+ * Anything else than 'undefined' acceptable:
+ * Soya.Common.typematch(unknown)
+ * Want [Number], [Boolean] or [Function]:
+ * Soya.Common.typematch(unknown, 2 + 4 + 16)
+ * Want [Number] only:
+ * Soya.Common.typematch(unknown, 2)
+ **/
+ typematch : function (vDunno, nCase){
+ var nMask;
+ switch(typeof(vDunno)){
+ case 'number' : nMask = 2; break;
+ case 'boolean' : nMask = 4; break;
+ case 'string' : nMask = 8; break;
+ case 'function': nMask = 16; break;
+ case 'object' : nMask = 32; break;
+ default : nMask = 1; break;
+ }
+ return Boolean(nMask & (nCase || 62));
+ },
+
+ getNode : function(data, tree){
+ var nc = 0;//nodeCount
+ //node = 1
+ if(data != null){
+ for(i=0;i<data.childNodes.length;i++){
+ if(data.childNodes[i].nodeType == 1){
+ if(nc == tree[0]){
+ data = data.childNodes[i];
+ if(tree.length > 1){
+ tree.shift();
+ data = this.getNode(data, tree);
+ }
+ return data;
+ }
+ nc++
+ }
+ }
+ }
+
+ return false;
+ },
+
+ toObject : function(data){
+ var ret, i;
+ switch(data.tagName){
+ case "string":
+ var s=""
+ //Mozilla has many textnodes with a size of 4096 chars each instead of one large one.
+ //They all need to be concatenated.
+ for(var j=0;j<data.childNodes.length;j++){
+ s+=new String(data.childNodes.item(j).nodeValue);
+ }
+ return s;
+ break;
+ case "int":
+ case "i4":
+ case "double":
+ return (data.firstChild) ? new Number(data.firstChild.nodeValue) : 0;
+ break;
+ case "dateTime.iso8601":
+ /*
+ Have to read the spec to be able to completely
+ parse all the possibilities in iso8601
+ 07-17-1998 14:08:55
+ 19980717T14:08:55
+ */
+
+ var sn = (isIE) ? "-" : "/";
+
+ if(/^(\d{4})(\d{2})(\d{2})T(\d{2}):(\d{2}):(\d{2})/.test(data.firstChild.nodeValue)){;//data.text)){
+ return new Date(RegExp.$2 + sn + RegExp.$3 + sn +
+ RegExp.$1 + " " + RegExp.$4 + ":" +
+ RegExp.$5 + ":" + RegExp.$6);
+ }
+ else{
+ return new Date();
+ }
+
+ break;
+ case "array":
+ data = this.getNode(data, [0]);
+
+ if(data && data.tagName == "data"){
+ ret = new Array();
+
+ var i = 0;
+ while(child = this.getNode(data, [i++])){
+ ret.push(this.toObject(child));
+ }
+
+ return ret;
+ }
+ else{
+ this.handleError(new Error("Malformed XMLRPC Message1"));
+ return false;
+ }
+ break;
+ case "struct":
+ ret = {};
+
+ var i = 0;
+ while(child = this.getNode(data, [i++])){
+ if(child.tagName == "member"){
+ ret[this.getNode(child, [0]).firstChild.nodeValue] = this.toObject(this.getNode(child, [1]));
+ }
+ else{
+ this.handleError(new Error("Malformed XMLRPC Message2"));
+ return false;
+ }
+ }
+
+ return ret;
+ break;
+ case "boolean":
+ return Boolean(isNaN(parseInt(data.firstChild.nodeValue)) ? (data.firstChild.nodeValue == "true") : parseInt(data.firstChild.nodeValue))
+
+ break;
+ case "base64":
+ return this.decodeBase64(data.firstChild.nodeValue);
+ break;
+ case "value":
+ child = this.getNode(data, [0]);
+ return (!child) ? ((data.firstChild) ? new String(data.firstChild.nodeValue) : "") : this.toObject(child);
+
+ break;
+ default:
+ this.handleError(new Error("Malformed XMLRPC Message: " + data.tagName));
+ return false;
+ break;
+ }
+ },
+
+ /*** Decode Base64 ******
+ * Original Idea & Code by thomas@saltstorm.net
+ * from Soya.Encode.Base64 [http://soya.saltstorm.net]
+ **/
+ decodeBase64 : function(sEncoded){
+ // Input must be dividable with 4.
+ if(!sEncoded || (sEncoded.length % 4) > 0)
+ return sEncoded;
+
+ /* Use NN's built-in base64 decoder if available.
+ This procedure is horribly slow running under NN4,
+ so the NN built-in equivalent comes in very handy. :) */
+
+ else if(typeof(atob) != 'undefined')
+ return atob(sEncoded);
+
+ var nBits, i, sDecoded = '';
+ var base64 = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=';
+ sEncoded = sEncoded.replace(/\W|=/g, '');
+
+ for(i=0; i < sEncoded.length; i += 4){
+ nBits =
+ (base64.indexOf(sEncoded.charAt(i)) & 0xff) << 18 |
+ (base64.indexOf(sEncoded.charAt(i+1)) & 0xff) << 12 |
+ (base64.indexOf(sEncoded.charAt(i+2)) & 0xff) << 6 |
+ base64.indexOf(sEncoded.charAt(i+3)) & 0xff;
+ sDecoded += String.fromCharCode(
+ (nBits & 0xff0000) >> 16, (nBits & 0xff00) >> 8, nBits & 0xff);
+ }
+
+ // not sure if the following statement behaves as supposed under
+ // all circumstances, but tests up til now says it does.
+
+ return sDecoded.substring(0, sDecoded.length -
+ ((sEncoded.charCodeAt(i - 2) == 61) ? 2 :
+ (sEncoded.charCodeAt(i - 1) == 61 ? 1 : 0)));
+ },
+
+ getObject : function(type, message){
+ if(type == "HTTP"){
+ if(isIE)
+ obj = new ActiveXObject("microsoft.XMLHTTP");
+ else if(isNS)
+ obj = new XMLHttpRequest();
+ }
+ else if(type == "XMLDOM"){
+ if(isIE){
+ obj = new ActiveXObject("microsoft.XMLDOM");
+ obj.loadXML(message)
+ }else if(isNS){
+ obj = new DOMParser();
+ obj = obj.parseFromString(message, "text/xml");
+ }
+
+ }
+ else{
+ this.handleError(new Error("Unknown Object"));
+ }
+
+ return obj;
+ },
+
+ validateMethodName : function(name){
+ /*do Checking:
+
+ The string may only contain identifier characters,
+ upper and lower-case A-Z, the numeric characters, 0-9,
+ underscore, dot, colon and slash.
+
+ */
+ if(/^[A-Za-z0-9\._\/:]+$/.test(name))
+ return true
+ else
+ this.handleError(new Error("Incorrect method name"));
+ },
+
+ getXML : function(obj){
+ if(typeof obj == "function"){
+ this.handleError(new Error("Cannot Parse functions"));
+ }else if(obj == null || obj == undefined || (typeof obj == "number" && !isFinite(obj)))
+ return false.toXMLRPC();
+ else
+ return obj.toXMLRPC();
+ },
+
+ handleError : function(e){
+ if(!this.onerror || !this.onerror(e)){
+ //alert("An error has occured: " + e.message);
+ throw e;
+ }
+ this.stop = true;
+ this.lastError = e;
+ },
+
+ cancel : function(id){
+ //You can only cancel a request when it was executed async (I think)
+ if(!this.queue[id]) return false;
+
+ this.queue[id][0].abort();
+ return true;
+ },
+
+ send : function(serverAddress, functionName, args, receive, multicall, autoroute){
+ var id, http;
+ //default is sync
+ this.validateMethodName();
+ if(this.stop){this.stop = false; return false;}
+
+ //setting up multicall
+ multicall = (multicall != null) ? multicall : this.multicall;
+
+ if(multicall){
+ if(!this.stack[serverAddress]) this.stack[serverAddress] = new Array();
+ this.stack[serverAddress].push({methodName : functionName, params : args});
+ return true;
+ }
+
+ //creating http object
+ var http = this.getObject("HTTP");
+
+ //setting some things for async/sync transfers
+ if(!receive || isNS){;
+ async = false;
+ }
+ else{
+ async = true;
+ /* The timer functionality is implemented instead of
+ the onreadystatechange event because somehow
+ the calling of this event crashed IE5.x
+ */
+ id = this.queue.push([http, receive, null, new Date()])-1;
+
+ this.queue[id][2] = new Function("var id='" + id + "';var dt = new Date(new Date().getTime() - XMLRPC.queue[id][3].getTime());diff = parseInt(dt.getSeconds()*1000 + dt.getMilliseconds());if(diff > XMLRPC.timeout){if(XMLRPC.ontimeout) XMLRPC.ontimeout(); clearInterval(XMLRPC.timers[id]);XMLRPC.cancel(id);return};if(XMLRPC.queue[id][0].readyState == 4){XMLRPC.queue[id][0].onreadystatechange = function(){};XMLRPC.receive(id);clearInterval(XMLRPC.timers[id])}");
+ this.timers[id] = setInterval("XMLRPC.queue[" + id + "][2]()", 20);
+ }
+
+ //setting up the routing
+ autoroute = (autoroute || this.autoroute);
+
+ //'active' is only set when direct sending the message has failed
+ var srv = (autoroute == "active") ? this.routeServer : serverAddress;
+
+ try{
+ http.open('POST', srv, async);
+ http.setRequestHeader("User-Agent", "vcXMLRPC v0.91 (" + navigator.userAgent + ")");
+ http.setRequestHeader("Host", srv.replace(/^https?:\/{2}([:\[\]\-\w\.]+)\/?.*/, '$1'));
+ http.setRequestHeader("Content-type", "text/xml");
+ if(autoroute == "active"){
+ http.setRequestHeader("X-Proxy-Request", serverAddress);
+ http.setRequestHeader("X-Compress-Response", "gzip");
+ }
+ }
+ catch(e){
+ if(autoroute == true){
+ //Access has been denied, Routing call.
+ autoroute = "active";
+ if(id){
+ delete this.queue[id];
+ clearInterval(this.timers[id]);
+ }
+ return this.send(serverAddress, functionName, args, receive, multicall, autoroute);
+ }
+
+ //Routing didn't work either..Throwing error
+ this.handleError(new Error("Could not sent XMLRPC Message (Reason: Access Denied on client)"));
+ if(this.stop){this.stop = false;return false}
+ }
+
+ //Construct the message
+ var message = '<?xml version="1.0"?><methodCall><methodName>' + functionName + '</methodName><params>';
+ for(i=0;i<args.length;i++){
+ message += '<param><value>' + this.getXML(args[i]) + '</value></param>';
+ }
+ message += '</params></methodCall>';
+
+ var xmldom = this.getObject('XMLDOM', message);
+ if(self.DEBUG) alert(message);
+
+ try{
+ //send message
+ http.send(xmldom);
+ }
+ catch(e){
+ //Most likely the message timed out(what happend to your internet connection?)
+ this.handleError(new Error("XMLRPC Message not Sent(Reason: " + e.message + ")"));
+ if(this.stop){this.stop = false;return false}
+ }
+
+ if(!async && receive)
+ return [autoroute, receive(this.processResult(http))];
+ else if(receive)
+ return [autoroute, id];
+ else
+ return [autoroute, this.processResult(http)];
+ },
+
+ receive : function(id){
+ //Function for handling async transfers..
+ if(this.queue[id]){
+ var data = this.processResult(this.queue[id][0]);
+ this.queue[id][1](data);
+ delete this.queue[id];
+ }
+ else{
+ this.handleError(new Error("Error while processing queue"));
+ }
+ },
+
+ processResult : function(http){
+ if(self.DEBUG) alert(http.responseText);
+ if(http.status == 200){
+ //getIncoming message
+ dom = http.responseXML;
+
+ if(dom){
+ var rpcErr, main;
+
+ //Check for XMLRPC Errors
+ rpcErr = dom.getElementsByTagName("fault");
+ if(rpcErr.length > 0){
+ rpcErr = this.toObject(rpcErr[0].firstChild);
+ this.handleError(new Error(rpcErr.faultCode, rpcErr.faultString));
+ return false
+ }
+
+ //handle method result
+ main = dom.getElementsByTagName("param");
+ if(main.length == 0) this.handleError(new Error("Malformed XMLRPC Message"));
+ data = this.toObject(this.getNode(main[0], [0]));
+
+ //handle receiving
+ if(this.onreceive) this.onreceive(data);
+ return data;
+ }
+ else{
+ this.handleError(new Error("Malformed XMLRPC Message"));
+ }
+ }
+ else{
+ this.handleError(new Error("HTTP Exception: (" + http.status + ") " + http.statusText + "\n\n" + http.responseText));
+ }
+ }
+}
+
+//Smell something
+ver = navigator.appVersion;
+app = navigator.appName;
+isNS = Boolean(navigator.productSub)
+//moz_can_do_http = (parseInt(navigator.productSub) >= 20010308)
+
+isIE = (ver.indexOf("MSIE 5") != -1 || ver.indexOf("MSIE 6") != -1) ? 1 : 0;
+isIE55 = (ver.indexOf("MSIE 5.5") != -1) ? 1 : 0;
+
+isOTHER = (!isNS && !isIE) ? 1 : 0;
+
projects / Epoz.git / commitdiff
