webglade

SearchController.js (11288B)

---

 /**
 *
 *
 * @FileName: SearchController.js
 * @$LastChangedDate: 2004-07-16 17:49:47 +0200 (Fri, 16 Jul 2004) $
 * @Author: Fabio Serra AKA Faser - faser@faser.net
 * @Copyright: Fabio Serra
 * @Licenze: MPL 1.1
 *
 */
 
 function SearchController(mabRequestType,requestPage) {
 	//Object to handle the progress meter
 	this.myProgressBar = new ProgressBar(guiMeter,true);
 	//More Products button
 	this.guiNext = document.getElementById("next-btn");
 	//Status Bar
 	this.guiRecordStatus = document.getElementById("record-status");
 	//Status Bar display total record found and total records retrived
 	this.guiOutStatus = document.getElementById("out-status");
 	//To enable stop button
 	this.elBroadcaster = document.getElementById('isSearchRunning');
 	this.guiAbort = document.getElementById("abort-icon");
 
 	//Track multiple connections when the user wants to receive more than 10 records at time.
 	this.myThread = new Array();
 	//How many Amazon results pages I have to fetch?
 	this.requestPageToFetch = requestPage;
 	//Mab Search type
 	this.mabRequestType = mabRequestType;
 	//Amazon Search Type
 	this.searchType = "";
 
 	//Fill in the array.
 	for(var i=0;i<requestPage;i++) {
 		this.myThread[i] = {};
 		this.myThread[i].connObj = "";
 		this.myThread[i].connectionID = "";
 		this.myThread[i].status = -1;
 		this.myThread[i].content = "";
 	}
 
 }
 
 //Start a search
 SearchController.prototype.search = function(qString,currentThread) {
 	var me = this;
 
 	//Get Properly search type
 	if(this.getQueryParam(qString,"AsinSearch")) {
 		this.searchType = "asin";
 	}else if (this.getQueryParam(qString,"BlendedSearch")){
 		this.searchType = "blended";
 	} else {
 		this.searchType = this.getQueryParam(qString,"type");
 	}
 
 
 	//Get ESC key to abort all active connections
 	var stopConnection = function(e) {
 		if(e.keyCode == e.DOM_VK_ESCAPE || e.target.id == me.guiAbort.id) {
 			window.removeEventListener('keypress',stopConnection,false);
 			me.guiAbort.removeEventListener('click',stopConnection,false);
 			//Aborted by user
 			me.abortThreads(30);
 			me.resetGUI();
 			me.parseResponse();
 		}
 
 	}
 
 	//If this is the first search (thread) start the Progress Meter
 	if(currentThread == 0) {
 		this.initGUI();
 		//Listener to abort the search
 		window.addEventListener('keypress',stopConnection,false);
 		this.guiAbort.addEventListener('click',stopConnection,false);
 	}
 
 	var url = qString.split("?");
 	var blPermission = false;
 	if(MAB_RUN == "local") {blPermission = true;}
 	var myConnection = new Connection(url[0],blPermission);
 	this.myThread[currentThread].connObj = myConnection;
 	this.myThread[currentThread].connectionID = myConnection.connectionID;
 
 
 	//Callback from connection
 	var callback = function(res) {
 		//Save all connection result waiting that every threads is properly returned
 		for(var i=0;i<me.myThread.length;i++) {
 			if(me.myThread[i].connectionID == res.connectionID) {
 				me.myThread[i].status = res.status;
 				me.myThread[i].content = res.content;
 				me.myThread[i].requestedURL = res.requestedURL;
 			}
 		}
 
 
 		//If this is the first thread check that the response from connection is Ok
 		if(me.myThread[0].connectionID == res.connectionID) {
 
 			if(res.status > 0) {
 				me.myThread.splice(0,me.myThread.length);
 				me.abortThreads();
 				me.resetGUI();
 				alert(res.message);
 				return true;
 
 			}
 
 			//Check Amazon Response
 			var responseXML = new DOMParser().parseFromString(res.content, 'text/xml');
 			var firstDoc = new AmazonParser(responseXML);
 
 			var error = firstDoc.hasError();
 			if(error) {
 				me.abortThreads();
 				me.resetGUI();
 				window.removeEventListener('keypress',stopConnection,true);
 				alert(firstDoc.getErrorMsg());
 
 				return true;
 			}
 
 			//Everything is ok so check if there are more result and that I can start
 			//new thread as requested. This is not applicable to BlendedSearch, or my refresh Asin search
 			//Because they don't have pages and limit records so only one connection is requested
 			if(me.searchType == "asin" || me.searchType == "blended"){
 				me.requestPageToFetch = 0;
 			}else{
 				var pagesAvailable = 0;
 				try {
 					pagesAvailable = firstDoc.getTotalPages();
 				}catch(e){
 					//pass
 				}
 				var currentPage = me.getCurrentPage(qString);
 				var pageRest = pagesAvailable - currentPage;
 				if(pageRest < me.requestPageToFetch) {me.requestPageToFetch = pageRest;}
 			}
 
 			if(me.requestPageToFetch > 1) {
 				//Ok there are more page so start the new thread
 				for(i=1;i<me.myThread.length;i++) {
 					currentPage++
 					var newQString = me.setCurrentPage(qString,currentPage);
 					me.search(newQString,i);
 					//Limit 1 request for second. License Agreement Limit
 					if(i != me.myThread.length) {
 						pause(CALL_INTERVAL); //Problem - the gui becomes unresponsive
 					}
 
 				}
 				return true;
 			}else{
 				//Remove array element and stop the execution
 				me.abortThreads();
 				me.resetGUI();
 				window.removeEventListener('keypress',stopConnection,true);
 				me.parseResponse();
 				return true;
 			}
 		}
 
 		//Check if there are more running thread
 
 		if(me.getRunningThread() == 0) {
 			me.abortThreads();
 			me.resetGUI();
 			window.removeEventListener('keypress',stopConnection,true);
 			me.parseResponse();
 			return true;
 		}
 
 		return false;
 	}
 
 	//Set the callback
 	myConnection.setCallback(callback);
 	myConnection.setErrorCallback(callback);
 
 	//Request a txt response to prevent permission problem
 	myConnection.send(url[1],"GET","txt");
 	return true;
 }
 
 
 //Pass all connection results to be parsed to the Amazon Parser and then to the
 //XMDManager
 SearchController.prototype.parseResponse = function() {
 	var myParser = new AmazonParser();
 	var responseXML, requestedURL, res, lastPage;
 	var validResponse = false;
 	for(var i=0;i<this.myThread.length;i++) {
 		if(this.myThread[i].status == 0) {
 			//needed to bypass permission problem
 			responseXML = new DOMParser().parseFromString(this.myThread[i].content, 'text/xml');
 			requestedURL = this.myThread[i].requestedURL;
 			res = myParser.mergeDocument(responseXML);
 			if(res) {validResponse = true;}
 		}
 
 	}
 
 	//There aren't any valid response, so exit;
 	if(validResponse == false) {return false;}
 
 	//If the search is a mabRequestType == "asin" doesn't modify the searchHistory
 	if(this.mabRequestType != "asin") {
 		//Not Applicable to AsinSearch and BlendedSearch - SearchHistory is not valid
 		if(this.searchType == "asin" || this.searchType == "blended"){
 			mySearchHistory.totalPages = 1;
 			mySearchHistory.totalResults = myParser.getNrDetails();
 		}else{
 			try {
 				mySearchHistory.totalPages = myParser.getTotalPages();
 				mySearchHistory.totalResults = myParser.getTotalResults();
 			}catch(e) {
 				mySearchHistory.totalPages = 0;
 				mySearchHistory.totalResults = 0;
 			}
 		}
 		//Modify the SearchHistory to save the last useful search only if the
 		//mabRequestType is not asin
 		mySearchHistory.lastURL = decodeURI(requestedURL);
 		lastPage = this.getCurrentPage(requestedURL);
 		mySearchHistory.lastPage = lastPage;
 		mySearchHistory.recordRetrieved = myParser.getNrDetails();
 	}
 
 
 	var pagesAvailable, totalResults;
 	if(this.mabRequestType == "asin") {
 		totalResults = myParser.getNrDetails();
 		productRetrieved = totalResults;
 		pagesAvailable = 0;
 	}else{
 		totalResults = mySearchHistory.totalResults;
 		productRetrieved = mySearchHistory.recordRetrieved;
 		pagesAvailable = mySearchHistory.getPagesAvailable();
 	}
 
 	//In case of heavy search check if reviews tags are present
 	//if not, insert empty tags
 	if(this.searchType == "heavy") {
 		myParser.setMissingReviews();
 	}
 
 	//Button More and status bar
 	if(this.mabRequestType == "asin") {
 		//do nothing
 	}else if(pagesAvailable > 0 ) {
 		this.guiNext.setAttribute("disabled","false");
 	} else {
 		this.guiNext.setAttribute("disabled","true");
 	}
 
 	var strProductsFound = "Products Found: " + totalResults;
 	strProductsFound += " - Products Retrieved: " + productRetrieved;
 	this.guiOutStatus.setAttribute("label",strProductsFound);
 
 	//Ok, now pass the merged Amazon results to the current XMABModel
 	//After the model has been created syncronize with the view
 	//This is the current loaded mab model form XMDManager
 	var myXMDManager = myDocOpened.getCurrentDocument();
 	if(!myXMDManager) {
 		myXMDManager = new XMDManager();
 		myDocOpened.addDoc(myXMDManager);
 	}
 
 	//AsinSearch request to overwrite old node because could be refresh or comment
 	var refresh = false;
 	var addItem = true;
 	if(this.searchType == "asin") {
 		refresh = true;
 		addItem = true;
 	}
 	var result = myXMDManager.merge(myParser.xmlDoc,refresh);
 	myDisplayController.buildTree(myXMDManager,addItem);
 
 	//Update record status
 	var oldStr = this.guiRecordStatus.getAttribute("label");
 	var newStr = oldStr + "("+ result.nrMergedNode + " new - " + result.nrDuplicatedNode + " duplicated - " + result.nrReloadedNode + " reloaded)";
 	this.guiRecordStatus.setAttribute("label",newStr);
 
 	showDetails();
 	return true;
 
 }
 
 //Check how many thread have not received an answer yet
 SearchController.prototype.getRunningThread = function() {
 	var runningThread = 0;
 	for(var i=0;i<this.myThread.length;i++) {
 		if(this.myThread[i].status < 0) {
 			runningThread ++;
 		}
 	}
 	return runningThread;
 }
 
 //Get the requested current page from the query string
 SearchController.prototype.getCurrentPage = function(qString) {
 	var res = this.getQueryParam(qString,"page");
 	if(res) {
 		return parseInt(res);
 	}else{
 		return false;
 	}
 }
 
 //Set the requested page in to the query string
 SearchController.prototype.setCurrentPage = function(qString,newPage) {
 	var newQString = this.setQueryParam(qString,"page",newPage);
 	return newQString;
 }
 
 SearchController.prototype.getQueryParam = function(qString,param) {
 	if(!qString || !param) {return false;}
 
 	var arString = qString.split("?");
 	var params = arString[1];
 	var vars = params.split("&");
   	for (var i=0;i<vars.length;i++) {
     	var pair = vars[i].split("=");
     	if (pair[0] == param) {
 			return pair[1];
 
     	}
   	}
 	return false;
 }
 
 SearchController.prototype.setQueryParam = function(qString,param,newValue) {
 	var oldValue = this.getQueryParam(qString,param)
 	if(!oldValue) {return false;}
 	var newQString = qString.replace('&'+param+'='+oldValue,'&'+ param +'='+newValue);
 	return newQString;
 }
 
 
 //Abort current and all running threads
 SearchController.prototype.abortThreads = function(errorCode) {
 	var error = 40;
 	if(errorCode) {error = errorCode;}
 	for(var i=0;i<this.myThread.length;i++) {
 		if(this.myThread[i].status < 0) {
 			if(this.myThread[i].connObj) {
 				this.myThread[i].connObj.abortConnection(error);
 			}
 		}
 	}
 }
 
 SearchController.prototype.initGUI = function() {
 	this.myProgressBar.start();
 	this.elBroadcaster.setAttribute("disabled","false");
 }
 
 //Stop the progress meter, reset the broadcatser
 SearchController.prototype.resetGUI = function() {
 	this.myProgressBar.stop();
 	this.elBroadcaster.setAttribute("disabled","true");
 }