/*
-** $Id: pz2.js,v 1.67 2007-11-13 13:07:28 jakub Exp $
+** $Id: pz2.js,v 1.70 2008-03-12 11:36:57 jakub Exp $
** pz2.js - pazpar2's javascript client library.
*/
// current query
this.currQuery = null;
+ //current raw record offset
+ this.currRecOffset = null;
+
//timers
this.statTime = paramArray.stattime || 1000;
this.statTimer = null;
this.showFastCount = 4;
this.bytargetTime = paramArray.bytargettime || 1000;
this.bytargetTimer = null;
+ this.recordTime = paramArray.recordtime || 500;
+ this.recordTimer = null;
// counters for each command and applied delay
this.dumpFactor = 500;
this.termCounter = 0;
this.statCounter = 0;
this.bytargetCounter = 0;
+ this.recordCounter = 0;
// active clients, updated by stat and show
// might be an issue since bytarget will poll accordingly
} else if (this.useSessions) {
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
- request.get(
+ request.safeGet(
{ "command": "init" },
function(data) {
if ( data.getElementsByTagName("status")[0]
);
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
- request.get(
+ request.safeGet(
{ "command": "ping", "session": this.sessionID },
function(data) {
if ( data.getElementsByTagName("status")[0]
}
);
},
- search: function (query, num, sort, filter, showfrom)
+ search: function (query, num, sort, filter, showfrom, addParamsArr)
{
clearTimeout(this.statTimer);
clearTimeout(this.showTimer);
if (filter !== undefined)
searchParams["filter"] = filter;
+
+ // copy additional parmeters, do not overwrite
+ if (addParamsArr != undefined) {
+ for (var prop in addParamsArr) {
+ if (!searchParams.hasOwnProperty(prop))
+ searchParams[prop] = addParamsArr[prop];
+ }
+ }
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
- request.get(
+ request.safeGet(
searchParams,
function(data) {
if ( data.getElementsByTagName("status")[0]
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
- request.get(
+ request.safeGet(
{ "command": "stat", "session": this.sessionID },
function(data) {
if ( data.getElementsByTagName("stat") ) {
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
- request.get(
+ request.safeGet(
{
"command": "show",
"session": this.sessionID,
};
// parse all the first-level nodes for all <hit> tags
var hits = data.getElementsByTagName("hit");
- var hit = new Array();
- for (i = 0; i < hits.length; i++) {
- show.hits[i] = new Array();
- show.hits[i]['location'] = new Array();
- var locCount = 0;
- for ( j = 0; j < hits[i].childNodes.length; j++) {
- if ( hits[i].childNodes[j].nodeType
- == Node.ELEMENT_NODE ) {
- if (hits[i].childNodes[j].nodeName
- == 'location') {
- var locNode = hits[i].childNodes[j];
- var id = locNode.getAttribute('id');
- show.hits[i]['location'][locCount] = {
- "id": locNode.getAttribute("id"),
- "name": locNode.getAttribute("name")
- };
- locCount++;
- }
- else {
- var nodeName =
- hits[i].childNodes[j].nodeName;
- var nodeText = 'ERROR'
- if ( hits[i].childNodes[j].firstChild )
- nodeText =
- hits[i].childNodes[j]
- .firstChild.nodeValue;
- show.hits[i][nodeName] = nodeText;
- }
- }
- }
- }
+ 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)
context.show();
},
delay);
-
+ global_show = show;
context.showCallback(show);
}
else
}
);
},
- record: function(id, offset, params)
+ record: function(id, offset, syntax, handler)
{
// we may call record with no previous search if in proxy mode
- if( !this.searchStatusOK && this.useSessions)
+ if(!this.searchStatusOK && this.useSessions)
throw new Error(
'Pz2.js: record command has to be preceded with a search command.'
- );
- if ( params == undefined )
- params = {};
-
- if ( params.callback != undefined ) {
- callback = params.callback;
- } else {
- callback = this.recordCallback;
- }
+ );
- // what is that?
- if ( params['handle'] == undefined )
- handle = {};
- else
- handle = params['handle'];
-
if( id !== undefined )
this.currRecID = id;
- var context = this;
- var request = new pzHttpRequest(this.pz2String, this.errorHandler);
-
- var recordParams = { "command": "record",
- "session": this.sessionID,
- "id": this.currRecID };
+ var recordParams = {
+ "command": "record",
+ "session": this.sessionID,
+ "id": this.currRecID
+ };
- if (offset !== undefined) {
+ this.currRecOffset = null;
+ if (offset != undefined) {
recordParams["offset"] = offset;
- }
-
- if (params.syntax != undefined) {
- recordParams['syntax'] = params.syntax;
+ this.currRecOffset = offset;
}
- this.currRecOffset = offset;
+ if (syntax != undefined)
+ recordParams['syntax'] = syntax;
- request.get(
+ //overwrite default callback id needed
+ var callback = this.recordCallback;
+ var args = undefined;
+ if (handler != undefined) {
+ callback = handler['callback'];
+ args = handler['args'];
+ }
+
+ var context = this;
+ var request = new pzHttpRequest(this.pz2String, this.errorHandler);
+
+ request.safeGet(
recordParams,
function(data) {
var recordNode;
- var record = new Array();
- record['xmlDoc'] = data;
- if (context.currRecOffset !== undefined) {
+ var record;
+ //raw record
+ if (context.currRecOffset !== null) {
+ record = new Array();
+ record['xmlDoc'] = data;
record['offset'] = context.currRecOffset;
- callback(record, handle);
+ callback(record, args);
+ //pz2 record
} else if ( recordNode =
data.getElementsByTagName("record")[0] ) {
// if stylesheet was fetched do not parse the response
if ( context.xslDoc ) {
+ record = new Array();
+ record['xmlDoc'] = data;
+ record['xslDoc'] = context.xslDoc;
record['recid'] =
recordNode.getElementsByTagName("recid")[0]
.firstChild.nodeValue;
- record['xslDoc'] =
- context.xslDoc;
+ //parse record
} else {
- for ( i = 0; i < recordNode.childNodes.length; i++) {
- if ( recordNode.childNodes[i].nodeType
- == Node.ELEMENT_NODE
- && recordNode.childNodes[i].nodeName
- != 'location' ) {
- var nodeName =
- recordNode.childNodes[i].nodeName;
- var nodeText = '';
- if (recordNode.childNodes[i].firstChild)
- nodeText = recordNode.childNodes[i]
- .firstChild.nodeValue;
- record[nodeName] = nodeText;
- }
- }
- // the location might be empty!!
- var locationNodes =
- recordNode.getElementsByTagName("location");
- record["location"] = new Array();
- for ( i = 0; i < locationNodes.length; i++ ) {
- record["location"][i] = {
- "id": locationNodes[i].getAttribute("id"),
- "name": locationNodes[i].getAttribute("name")
- };
-
- for (j = 0;
- j < locationNodes[i].childNodes.length;
- j++) {
- if ( locationNodes[i].childNodes[j].nodeType
- == Node.ELEMENT_NODE ) {
- var nodeName =
- locationNodes[i].childNodes[j].nodeName;
- var nodeText = '';
- if (locationNodes[i].childNodes[j]
- .firstChild)
- nodeText =
- locationNodes[i].childNodes[j]
- .firstChild.nodeValue;
- // this is stupid
- if (nodeName == 'md-subject') {
- if (record["location"][i][nodeName]) {
- record["location"][i][nodeName]
- .push(nodeText)
- } else {
- record["location"][i][nodeName]
- = new Array();
- record["location"][i][nodeName]
- .push(nodeText)
- }
- } else {
- record["location"][i][nodeName]
- = nodeText;
- }
- }
- }
- }
- }
-
- callback(record, handle);
+ record = Element_parseChildNodes(recordNode);
+ }
+ var activeClients =
+ Number( data.getElementsByTagName("activeclients")[0]
+ .childNodes[0].nodeValue );
+ context.activeClients = activeClients;
+ context.recordCounter++;
+ var delay = context.recordTime + context.recordCounter * context.dumpFactor;
+ if ( activeClients > 0 )
+ context.recordTimer =
+ setTimeout (
+ function() {
+ context.record(id, offset, syntax, handler);
+ },
+ delay
+ );
+ callback(record, args);
}
else
context.throwError('Record failed. Malformed WS resonse.',
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
- request.get(
+ request.safeGet(
{
"command": "termlist",
"session": this.sessionID,
var context = this;
var request = new pzHttpRequest(this.pz2String, this.errorHandler);
- request.get(
+ request.safeGet(
{ "command": "bytarget", "session": this.sessionID },
function(data) {
if ( data.getElementsByTagName("status")[0]
********************************************************************************
*/
var pzHttpRequest = function ( url, errorHandler ) {
+ this.maxUrlLength = 2048;
this.request = null;
this.url = url;
this.errorHandler = errorHandler || null;
this.async = true;
+ this.requestHeaders = {};
if ( window.XMLHttpRequest ) {
this.request = new XMLHttpRequest();
pzHttpRequest.prototype =
{
+ safeGet: function ( params, callback )
+ {
+ var encodedParams = this.encodeParams(params);
+ var url = this._urlAppendParams(encodedParams);
+ if (url.length >= this.maxUrlLength) {
+ this.requestHeaders["Content-Type"]
+ = "application/x-www-form-urlencoded";
+ this._send( 'POST', this.url, encodedParams, callback );
+ } else {
+ this._send( 'GET', url, '', callback );
+ }
+ },
+
get: function ( params, callback )
{
- this._send( 'GET', params, '', callback );
+ this._send( 'GET', this._urlAppendParams(this.encodeParams(params)),
+ '', callback );
},
post: function ( params, data, callback )
{
- this._send( 'POST', params, data, callback );
+ this._send( 'POST', this._urlAppendParams(this.encodeParams(params)),
+ data, callback );
},
load: function ()
return this.request.responseXML;
},
- _send: function ( type, params, data, callback )
+ encodeParams: function (params)
+ {
+ var sep = "";
+ var encoded = "";
+ for (var key in params) {
+ if (params[key] != null) {
+ encoded += sep + key + '=' + encodeURIComponent(params[key]);
+ sep = '&';
+ }
+ }
+ return encoded;
+ },
+
+ _send: function ( type, url, data, callback)
{
- this.callback = callback;
var context = this;
+ this.callback = callback;
this.async = true;
- this.request.open( type, this._urlAppendParams(params), this.async );
+ this.request.open( type, url, this.async );
+ for (var key in this.requestHeaders)
+ this.request.setRequestHeader(key, this.requestHeaders[key]);
this.request.onreadystatechange = function () {
context._handleResponse();
}
this.request.send(data);
},
- _urlAppendParams: function (params)
+ _urlAppendParams: function (encodedParams)
{
- var getUrl = this.url;
-
- var sep = '?';
- var el = params;
- for (var key in el) {
- if (el[key] != null) {
- getUrl += sep + key + '=' + encodeURIComponent(el[key]);
- sep = '&';
- }
- }
- return getUrl;
+ if (encodedParams)
+ return this.url + "?" + encodedParams;
+ else
+ return this.url;
},
_handleResponse: function ()
{
if ( this.request.readyState == 4 ) {
- // pick up pazpr2 errors first
- if ( this.request.responseXML
- && this.request.responseXML.documentElement.nodeName == 'error'
- && this.request.responseXML.getElementsByTagName("error")
- .length ) {
+ // pick up appplication errors first
+ var errNode = null;
+ if (this.request.responseXML &&
+ (errNode = this.request.responseXML.documentElement)
+ && errNode.nodeName == 'error') {
+ var errMsg = errNode.getAttribute("msg");
+ var errCode = errNode.getAttribute("code");
var errAddInfo = '';
- if ( this.request.responseXML.getElementsByTagName("error")[0]
- .childNodes.length )
- errAddInfo = ': ' +
- this.request.responseXML
- .getElementsByTagName("error")[0]
- .childNodes[0].nodeValue;
- var errMsg =
- this.request.responseXML.getElementsByTagName("error")[0]
- .getAttribute("msg");
- var errCode =
- this.request.responseXML.getElementsByTagName("error")[0]
- .getAttribute("code");
-
+ if (errNode.childNodes.length)
+ errAddInfo = ': ' + errNode.childNodes[0].nodeValue;
+
var err = new Error(errMsg + errAddInfo);
err.code = errCode;
else {
throw err;
}
- } else if ( this.request.status == 200 ) {
- this.callback( this.request.responseXML );
+ } else if (this.request.status == 200) {
+ this.callback(this.request.responseXML);
} else {
- var err = new Error("Pz2.js: HTTP request error (AJAX). Code: "
- + this.request.status + " Info: "
+ var err = new Error("HTTP response not OK: "
+ + this.request.status + " - "
+ this.request.statusText );
- err.code = 'HTTP';
+ err.code = '00' + this.request.status;
if (this.errorHandler) {
this.errorHandler(err);
}
}
+Element_parseChildNodes = function (node)
+{
+ var parsed = {};
+ var hasChildElems = false;
+
+ if (node.hasChildNodes()) {
+ var children = node.childNodes;
+ for (var i = 0; i < children.length; i++) {
+ var child = children[i];
+ if (child.nodeType == Node.ELEMENT_NODE) {
+ hasChildElems = true;
+ var nodeName = child.nodeName;
+ if (!(nodeName in parsed))
+ parsed[nodeName] = [];
+ parsed[nodeName].push(Element_parseChildNodes(child));
+ }
+ }
+ }
+
+ var attrs = node.attributes;
+ for (var i = 0; i < attrs.length; i++) {
+ var attrName = '@' + attrs[i].nodeName;
+ var attrValue = attrs[i].nodeValue;
+ parsed[attrName] = attrValue;
+ }
+
+ // if no nested elements, get text content
+ if (node.hasChildNodes() && !hasChildElems) {
+ if (node.attributes.length)
+ parsed['textContent'] = node.firstChild.nodeValue;
+ else
+ parsed = node.firstChild.nodeValue;
+ }
+
+ return parsed;
+}
+
/* do not remove trailing bracket */
}