/*
-** $Id: pz2.js,v 1.70 2008-03-12 11:36:57 jakub Exp $
+ * Mine
** pz2.js - pazpar2's javascript client library.
*/
}
this.errorHandler = paramArray.errorhandler || null;
+ this.showResponseType = paramArray.showResponseType || "xml";
// function callbacks
this.initCallback = paramArray.oninit || null;
this.keepAlive = paramArray.keepAlive;
this.sessionID = null;
+ this.serviceId = paramArray.serviceId || null;
this.initStatusOK = false;
this.pingStatusOK = false;
this.searchStatusOK = false;
}
// else, auto init session or wait for a user init?
if (this.useSessions && paramArray.autoInit !== false) {
- this.init();
+ this.init(this.sessionId, this.serviceId);
}
};
this.resetCallback();
},
- init: function ( sessionId )
+ init: function (sessionId, serviceId)
{
this.reset();
// session id as a param
- if ( sessionId != undefined && this.useSessions ) {
+ if (sessionId && this.useSessions ) {
this.initStatusOK = true;
this.sessionID = sessionId;
this.ping();
} else if (this.useSessions) {
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
+ var opts = {'command' : 'init'};
+ if (serviceId) opts.service = serviceId;
request.safeGet(
- { "command": "init" },
+ opts,
function(data) {
if ( data.getElementsByTagName("status")[0]
.childNodes[0].nodeValue == "OK" ) {
this.termCounter = 0;
this.bytargetCounter = 0;
this.statCounter = 0;
+ this.activeClients = 1;
// no proxy mode
if( !this.initStatusOK )
context.searchStatusOK = true;
//piggyback search
context.show(start, num, sort);
- if ( context.statCallback )
+ if (context.statCallback)
context.stat();
- if ( context.termlistCallback )
+ if (context.termlistCallback)
context.termlist();
- if ( context.bytargetCallback )
+ if (context.bytargetCallback)
context.bytarget();
}
else
Number( data.getElementsByTagName("activeclients")[0]
.childNodes[0].nodeValue );
context.activeClients = activeClients;
- var stat = {
- "activeclients": activeClients,
- "hits":
- Number( data.getElementsByTagName("hits")[0]
- .childNodes[0].nodeValue ),
- "records":
- Number( data.getElementsByTagName("records")[0]
- .childNodes[0].nodeValue ),
- "clients":
- Number( data.getElementsByTagName("clients")[0]
- .childNodes[0].nodeValue ),
- "initializing":
- Number( data.getElementsByTagName("initializing")[0]
- .childNodes[0].nodeValue ),
- "searching":
- Number( data.getElementsByTagName("searching")[0]
- .childNodes[0].nodeValue ),
- "presenting":
- Number( data.getElementsByTagName("presenting")[0]
- .childNodes[0].nodeValue ),
- "idle":
- Number( data.getElementsByTagName("idle")[0]
- .childNodes[0].nodeValue ),
- "failed":
- Number( data.getElementsByTagName("failed")[0]
- .childNodes[0].nodeValue ),
- "error":
- Number( data.getElementsByTagName("error")[0]
- .childNodes[0].nodeValue )
- };
-
+
+ var stat = Element_parseChildNodes(data.documentElement);
+
context.statCounter++;
var delay = context.statTime
+ context.statCounter * context.dumpFactor;
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
request.safeGet(
- {
- "command": "show",
- "session": this.sessionID,
- "start": this.currentStart,
- "num": this.currentNum,
- "sort": this.currentSort,
- "block": 1
- },
- function(data) {
- if ( data.getElementsByTagName("status")[0]
- .childNodes[0].nodeValue == "OK" ) {
- // first parse the status data send along with records
- // this is strictly bound to the format
- var activeClients =
- Number( data.getElementsByTagName("activeclients")[0]
- .childNodes[0].nodeValue );
- context.activeClients = activeClients;
- var show = {
- "activeclients": activeClients,
- "merged":
- Number( data.getElementsByTagName("merged")[0]
- .childNodes[0].nodeValue ),
- "total":
- Number( data.getElementsByTagName("total")[0]
- .childNodes[0].nodeValue ),
- "start":
- Number( data.getElementsByTagName("start")[0]
- .childNodes[0].nodeValue ),
- "num":
- Number( data.getElementsByTagName("num")[0]
- .childNodes[0].nodeValue ),
- "hits": []
- };
- // parse all the first-level nodes for all <hit> tags
- var hits = data.getElementsByTagName("hit");
- for (i = 0; i < hits.length; i++)
- show.hits[i] = Element_parseChildNodes(hits[i]);
-
- context.showCounter++;
- var delay = context.showTime;
- if (context.showCounter > context.showFastCount)
- delay += context.showCounter * context.dumpFactor;
- if ( activeClients > 0 )
- context.showTimer = setTimeout(
- function () {
- context.show();
- },
- delay);
- global_show = show;
- context.showCallback(show);
- }
- else
- context.throwError('Show failed. Malformed WS resonse.',
- 114);
+ {
+ "command": "show",
+ "session": this.sessionID,
+ "start": this.currentStart,
+ "num": this.currentNum,
+ "sort": this.currentSort,
+ "block": 1,
+ "type": this.showResponseType
+ },
+ function(data, type) {
+ var show = null;
+ var activeClients = 0;
+ if (type === "json") {
+ show = {};
+ activeClients = Number(data.activeclients[0]);
+ show.activeclients = activeClients;
+ show.merged = Number(data.merged[0]);
+ show.total = Number(data.total[0]);
+ show.start = Number(data.start[0]);
+ show.num = Number(data.num[0]);
+ show.hits = data.hit;
+ } else if (data.getElementsByTagName("status")[0]
+ .childNodes[0].nodeValue == "OK") {
+ // first parse the status data send along with records
+ // this is strictly bound to the format
+ activeClients =
+ Number(data.getElementsByTagName("activeclients")[0]
+ .childNodes[0].nodeValue);
+ show = {
+ "activeclients": activeClients,
+ "merged":
+ Number( data.getElementsByTagName("merged")[0]
+ .childNodes[0].nodeValue ),
+ "total":
+ Number( data.getElementsByTagName("total")[0]
+ .childNodes[0].nodeValue ),
+ "start":
+ Number( data.getElementsByTagName("start")[0]
+ .childNodes[0].nodeValue ),
+ "num":
+ Number( data.getElementsByTagName("num")[0]
+ .childNodes[0].nodeValue ),
+ "hits": []
+ };
+ // parse all the first-level nodes for all <hit> tags
+ var hits = data.getElementsByTagName("hit");
+ for (i = 0; i < hits.length; i++)
+ show.hits[i] = Element_parseChildNodes(hits[i]);
+ } else {
+ context.throwError('Show failed. Malformed WS resonse.',
+ 114);
}
+ context.activeClients = activeClients;
+ context.showCounter++;
+ var delay = context.showTime;
+ if (context.showCounter > context.showFastCount)
+ delay += context.showCounter * context.dumpFactor;
+ if ( activeClients > 0 )
+ context.showTimer = setTimeout(
+ function () {
+ context.show();
+ },
+ delay);
+ context.showCallback(show);
+ }
);
},
record: function(id, offset, syntax, handler)
bytarget[i][nodeName] = nodeText;
}
}
+ if (bytarget[i]["state"]=="Client_Disconnected") {
+ bytarget[i]["hits"] = "Error";
+ } else if (bytarget[i]["state"]=="Client_Error") {
+ bytarget[i]["hits"] = "Error";
+ } else if (bytarget[i]["state"]=="Client_Working") {
+ bytarget[i]["hits"] = "...";
+ }
}
context.bytargetCounter++;
}
};
+
pzHttpRequest.prototype =
{
safeGet: function ( params, callback )
for (var key in this.requestHeaders)
this.request.setRequestHeader(key, this.requestHeaders[key]);
this.request.onreadystatechange = function () {
- context._handleResponse();
+ context._handleResponse(url); /// url used ONLY for error reporting
}
this.request.send(data);
},
return this.url;
},
- _handleResponse: function ()
+ _handleResponse: function (savedUrlForErrorReporting)
{
if ( this.request.readyState == 4 ) {
// pick up appplication errors first
else {
throw err;
}
+ } else if (this.request.status == 200 &&
+ this.request.responseXML == null) {
+ if (this.request.responseText != null) {
+ //assume JSON
+
+ var json = null;
+ var text = this.request.responseText;
+ if (typeof window.JSON == "undefined")
+ json = eval("(" + text + ")");
+ else {
+ try {
+ json = JSON.parse(text);
+ }
+ catch (e) {
+ // Safari: eval will fail as well. Considering trying JSON2 (non-native implementation) instead
+ /* DEBUG only works in mk2-mobile
+ if (document.getElementById("log"))
+ document.getElementById("log").innerHTML = "" + e + " " + length + ": " + text;
+ */
+ try {
+ json = eval("(" + text + ")");
+ }
+ catch (e) {
+ /* DEBUG only works in mk2-mobile
+ if (document.getElementById("log"))
+ document.getElementById("log").innerHTML = "" + e + " " + length + ": " + text;
+ */
+ }
+ }
+ }
+ this.callback(json, "json");
+ } else {
+ var err = new Error("XML response is empty but no error " +
+ "for " + savedUrlForErrorReporting);
+ err.code = -1;
+ if (this.errorHandler) {
+ this.errorHandler(err);
+ } else {
+ throw err;
+ }
+ }
} else if (this.request.status == 200) {
this.callback(this.request.responseXML);
} else {
var err = new Error("HTTP response not OK: "
+ this.request.status + " - "
+ this.request.statusText );
- err.code = '00' + this.request.status;
-
+ err.code = '00' + this.request.status;
if (this.errorHandler) {
this.errorHandler(err);
}
// if no nested elements, get text content
if (node.hasChildNodes() && !hasChildElems) {
if (node.attributes.length)
- parsed['textContent'] = node.firstChild.nodeValue;
+ parsed['#text'] = node.firstChild.nodeValue;
else
parsed = node.firstChild.nodeValue;
}
projects / pazpar2-moved-to-github.git / blobdiff