arghd) { // only display some of them
numrecords = arghd;
}
historylist += "\n\n";
} // if get history info
else {
historylist += "_textnohistory_";
}
historylist += "\n";
} // else display list
disp.setmacro("searchhistorylist", "query", historylist);
} // define history macros
void queryaction::output_ccp (cgiargsclass &args, recptprotolistclass *protos,
displayclass &disp, outconvertclass &outconvert,
ostream &textout, ostream &logout) {
ColInfoResponse_t *cinfo = NULL;
comerror_t err;
InfoFilterOptionsResponse_t fresponse;
InfoFilterOptionsRequest_t frequest;
frequest.filterName = "QueryFilter";
text_t &index = args["h"];
text_t &subcollection = args["j"];
text_t &language = args["n"];
text_tset collections;
text_t arg_cc = args["cc"];
decode_cgi_arg (arg_cc);
splitchar (arg_cc.begin(), arg_cc.end(), ',', collections);
textout << outconvert << disp << "_query:header_\n"
<< "
_navigationbar_
\n"
<< "\n"
<< "_query:footer_\n";
}
bool queryaction::do_action (cgiargsclass &args, recptprotolistclass *protos,
browsermapclass *browsers, displayclass &disp,
outconvertclass &outconvert, ostream &textout,
ostream &logout) {
if (recpt == NULL) {
logout << "ERROR (queryaction::do_action): This action does not contain information\n"
<< " about any receptionists. The method set_receptionist was probably\n"
<< " not called from the module which instantiated this action.\n";
return true;
}
if (args["ccs"] == "1") {
if (!args["cc"].empty()) {
// query the selected collections
text_t::const_iterator b = args["cc"].begin();
text_t::const_iterator e = args["cc"].end();
if (findchar (b, e, ',') != e) {
if (!search_multiple_collections (args, protos, browsers, disp, outconvert,
textout, logout)) return false;
return true;
} else {
if (!search_single_collection (args, args["cc"], protos, browsers, disp,
outconvert, textout, logout)) return false;
return true;
}
}
}
// simply query the current collection
if (!search_single_collection (args, args["c"], protos, browsers, disp,
outconvert, textout, logout)) return false;
return true;
}
bool queryaction::search_multiple_collections (cgiargsclass &args, recptprotolistclass *protos,
browsermapclass *browsers, displayclass &disp,
outconvertclass &outconvert, ostream &textout,
ostream &logout) {
text_tarray collections;
text_t arg_cc = args["cc"];
decode_cgi_arg (arg_cc);
splitchar (arg_cc.begin(), arg_cc.end(), ',', collections);
if (collections.empty()) {
logout << "queryaction::search_multiple_collections: No collections "
<< "set for doing multiple query - will search current collection\n";
textout << outconvert << disp << "_query:textwarningnocollections_\n";
return search_single_collection (args, args["c"], protos, browsers, disp,
outconvert, textout, logout);
}
// queryaction uses "VList" browser to display results,
// a queries clasification is "Search"
text_t browsertype = "VList";
text_t classification = "Search";
QueryResult_tset results;
map colinfomap;
ColInfoResponse_t *cinfo = NULL;
recptproto *collectproto = NULL;
comerror_t err;
FilterRequest_t request;
FilterResponse_t response;
request.filterResultOptions = FROID | FRmetadata | FRtermFreq | FRranking;
text_t formattedstring = args["q"];
text_t freqmsg = "_textfreqmsg1_";
int numdocs = 0;
isapprox isApprox = Exact;
format_querystring (formattedstring, args.getintarg("b"));
set_queryfilter_options (request, formattedstring, args);
// need to retrieve maxdocs matches for each collection
// (will eventually want to tidy this up, do so caching etc.)
OptionValue_t option;
option.name = "StartResults";
option.value = "1";
request.filterOptions.push_back (option);
option.name = "EndResults";
option.value = args["m"];
request.filterOptions.push_back (option);
text_tarray::iterator col_here = collections.begin();
text_tarray::iterator col_end = collections.end();
map termfreqs;
while (col_here != col_end) {
request.fields.erase (request.fields.begin(), request.fields.end());
request.getParents = false;
collectproto = protos->getrecptproto (*col_here, logout);
if (collectproto == NULL) {
logout << outconvert << "queryaction::search_multiple_collections: " << *col_here
<< " collection has a NULL collectproto, ignoring\n";
col_here ++;
continue;
}
cinfo = recpt->get_collectinfo_ptr (collectproto, *col_here, logout);
if (cinfo == NULL) {
logout << "ERROR (query_action::search_multiple_collections): get_collectinfo_ptr returned NULL\n";
col_here ++;
continue;
}
browserclass *bptr = browsers->getbrowser (browsertype);
// get the formatstring if there is one
text_t formatstring;
if (!get_formatstring (classification, browsertype,
cinfo->format, formatstring))
formatstring = bptr->get_default_formatstring();
bptr->load_metadata_defaults (request.fields);
format_t *formatlistptr = new format_t();
parse_formatstring (formatstring, formatlistptr, request.fields, request.getParents);
colinfo_t thiscolinfo;
thiscolinfo.formatlistptr = formatlistptr;
thiscolinfo.browserptr = bptr;
colinfomap[*col_here] = thiscolinfo;
// do the query
collectproto->filter (*col_here, request, response, err, logout);
if (err != noError) {
outconvertclass text_t2ascii;
logout << text_t2ascii
<< "queryaction::search_multiple_collections: call to QueryFilter failed "
<< "for " << *col_here << " collection (" << get_comerror_string (err) << ")\n";
return false;
}
if (isApprox == Exact)
isApprox = response.isApprox;
else if (isApprox == MoreThan)
if (response.isApprox == Approximate)
isApprox = response.isApprox;
TermInfo_tarray::const_iterator this_term = response.termInfo.begin();
TermInfo_tarray::const_iterator end_term = response.termInfo.end();
while (this_term != end_term) {
termfreqs[(*this_term).term] += (*this_term).freq;
if ((col_here+1) == col_end) {
freqmsg += (*this_term).term + ": " + termfreqs[(*this_term).term];
if ((this_term+1) != end_term) freqmsg += ", ";
}
this_term ++;
}
if (response.numDocs > 0) {
numdocs += response.numDocs;
QueryResult_t thisresult;
thisresult.collection = *col_here;
ResultDocInfo_tarray::iterator doc_here = response.docInfo.begin();
ResultDocInfo_tarray::iterator doc_end = response.docInfo.end();
while (doc_here != doc_end) {
thisresult.doc = *doc_here;
results.insert (thisresult);
doc_here ++;
}
}
col_here ++;
}
disp.setmacro ("freqmsg", "query", freqmsg);
int maxdocs = args.getintarg("m");
int firstdoc = args.getintarg("r");
int hitsperpage = args.getintarg("o");
if (num_phrases > 0) isApprox = Exact;
if (maxdocs == -1) maxdocs = numdocs;
else if (numdocs > maxdocs) {
numdocs = maxdocs;
isApprox = MoreThan;
}
if (hitsperpage == -1) hitsperpage = numdocs;
text_t resline;
if (isApprox == Approximate) resline = "_textapprox_";
else if (isApprox == MoreThan) resline = "_textmorethan_";
if (numdocs == 0) resline = "_textnodocs_";
else if (numdocs == 1) resline += "_text1doc_";
else resline += text_t(numdocs) + " _textlotsdocs_";
disp.setmacro("resultline", "query", resline);
QueryResult_tset::iterator res_here = results.begin();
QueryResult_tset::iterator res_end = results.end();
text_tset metadata; // empty !!
bool getParents = false; // don't care !!
bool use_table;
ResultDocInfo_t thisdoc;
format_t *formatlistptr = NULL;
browserclass *browserptr = NULL;
// set up _thisfirst_ and _thislast_ macros
disp.setmacro ("thisfirst", "query", firstdoc);
int thislast = firstdoc + (hitsperpage - 1);
if (thislast > numdocs) thislast = numdocs;
disp.setmacro ("thislast", "query", thislast);
// set up _prevfirst_ and _prevlast_ macros
if (firstdoc > 1) {
disp.setmacro ("prevlast", "query", firstdoc - 1);
int prevfirst = firstdoc - hitsperpage;
if (prevfirst < 1) prevfirst = 1;
disp.setmacro ("prevfirst", "query", prevfirst);
}
// set up _nextfirst_ and _nextlast_ macros
if (thislast < numdocs) {
disp.setmacro ("nextfirst", "query", thislast + 1);
int nextlast = thislast + hitsperpage;
if (nextlast > numdocs) nextlast = numdocs;
disp.setmacro ("nextlast", "query", nextlast);
}
textout << outconvert << disp << "_query:header_\n"
<< "_query:content_";
int count = 1;
// output results
while (res_here != res_end) {
if (count < firstdoc) {count ++; res_here ++; continue;}
if (count > thislast) break;
formatlistptr = colinfomap[(*res_here).collection].formatlistptr;
browserptr = colinfomap[(*res_here).collection].browserptr;
thisdoc = (*res_here).doc;
use_table = is_table_content (formatlistptr);
collectproto = protos->getrecptproto ((*res_here).collection, logout);
if (collectproto == NULL) {
logout << outconvert << "queryaction::search_multiple_collections: " << (*res_here).collection
<< " collection has a NULL collectproto, ignoring results\n";
res_here ++;
continue;
}
browserptr->output_section_group (thisdoc, args, (*res_here).collection, 0,
formatlistptr, use_table, metadata, getParents,
collectproto, disp, outconvert, textout, logout);
// textout << outconvert << "(ranking: " << (*res_here).doc.ranking << ")\n";
res_here ++;
count ++;
}
textout << outconvert << disp << "_query:footer_";
// clean up the format_t pointers
map::iterator here = colinfomap.begin();
map::iterator end = colinfomap.end();
while (here != end) {
delete ((*here).second.formatlistptr);
here ++;
}
return true;
}
bool queryaction::search_single_collection (cgiargsclass &args, const text_t &collection,
recptprotolistclass *protos, browsermapclass *browsers,
displayclass &disp, outconvertclass &outconvert,
ostream &textout, ostream &logout) {
recptproto *collectproto = protos->getrecptproto (collection, logout);
if (collectproto == NULL) {
logout << outconvert << "queryaction::search_single_collection: " << collection
<< " collection has a NULL collectproto\n";
return false;
}
// queryaction uses "VList" browser to display results,
// a queries clasification is "Search"
text_t browsertype = "VList";
text_t classification = "Search";
comerror_t err;
ColInfoResponse_t *cinfo = recpt->get_collectinfo_ptr (collectproto, collection, logout);
if (cinfo == NULL) {
logout << "ERROR (query_action::search_single_collection): get_collectinfo_ptr returned NULL\n";
return false;
}
browserclass *bptr = browsers->getbrowser (browsertype);
// get the formatstring if there is one
text_t formatstring;
if (!get_formatstring (classification, browsertype,
cinfo->format, formatstring))
formatstring = bptr->get_default_formatstring();
FilterRequest_t request;
FilterResponse_t response;
bptr->set_filter_options (request, args);
bptr->load_metadata_defaults (request.fields);
format_t *formatlistptr = new format_t();
parse_formatstring (formatstring, formatlistptr, request.fields, request.getParents);
// do the query
request.filterResultOptions = FROID | FRmetadata | FRtermFreq;
text_t formattedstring = "";
if (args["qt"]=="0") { // normal text search
formattedstring = args["q"];
format_querystring (formattedstring, args.getintarg("b"));
add_dates(formattedstring, args.getintarg("ds"), args.getintarg("de"),
args.getintarg("dsbc"), args.getintarg("debc"));
}
else if (args["qt"]=="1" ){ // form search
if (args["b"]=="1" && args["fqa"]=="1") { // explicit query
formattedstring = args["q"];
}
else { // form search
if (args["b"]=="0") { // regular form
parse_reg_query_form(formattedstring, args);
}
else { // advanced form
parse_adv_query_form(formattedstring, args);
}
args["q"] = formattedstring;
// also reset the _cgiargq_ macro as it has changed now
disp.setmacro("cgiargq", "Global", html_safe(args["q"]));
// reset the compressed options to include the q arg
text_t compressedoptions = recpt->get_compressed_arg(args, logout);
if (!compressedoptions.empty()) {
disp.setmacro ("compressedoptions", "Global", dm_safe(compressedoptions));
// need a decoded version of compressedoptions for use within forms
// as browsers encode values from forms before sending to server
// (e.g. %25 becomes %2525)
decode_cgi_arg (compressedoptions);
disp.setmacro ("decodedcompressedoptions", "Global", dm_safe(compressedoptions));
}
} // form search
} // args["qt"]=1
else {
logout << "ERROR (query_action::search_single_collection): querytype not defined\n";
return false;
}
if (!formattedstring.empty()) { // do the query
set_queryfilter_options (request, formattedstring, args);
collectproto->filter (collection, request, response, err, logout);
if (err != noError) {
outconvertclass text_t2ascii;
logout << text_t2ascii
<< "queryaction::search_single_collections: call to QueryFilter failed "
<< "for " << collection << " collection (" << get_comerror_string (err) << ")\n";
return false;
}
define_query_macros (args, disp, response);
// save the query if appropriate
if (!save_search_history(args, response))
logout << "save failed";
}
define_history_macros (disp, args, protos, logout);
textout << outconvert << disp << "_query:header_\n"
<< "_query:content_";
// output the results
bool use_table = is_table_content (formatlistptr);
bptr->output_section_group (response, args, collection, 0, formatlistptr,
use_table, request.fields, request.getParents,
collectproto, disp, outconvert, textout, logout);
textout << outconvert << disp << "_query:footer_";
delete (formatlistptr);
return true;
}
// define_query_macros sets the macros that couldn't be set until the
// query had been done. Those macros are _freqmsg_, _quotedquery_,
// _resultline_, _nextfirst_, _nextlast_, _prevfirst_, _prevlast_,
// _thisfirst_, and _thislast_
void queryaction::define_query_macros (cgiargsclass &args, displayclass &disp,
const FilterResponse_t &response) {
// set up _freqmsg_ and _quotedquery_ macros
text_t freqmsg = "_textfreqmsg1_";
TermInfo_tarray::const_iterator this_term = response.termInfo.begin();
TermInfo_tarray::const_iterator end_term = response.termInfo.end();
while (this_term != end_term) {
char *term = (*this_term).term.getcstr();
if(term[0]<'0' || term[0] >'9'){
freqmsg += (*this_term).term + ": " + (*this_term).freq;
if ((this_term + 1) != end_term)
freqmsg += ", ";
}
delete term;
this_term ++;
}
disp.setmacro ("freqmsg", "query", freqmsg);
// set up _resultline_ macro
text_t resline;
int maxdocs = args.getintarg("m");
int numdocs = response.numDocs;
isapprox isApprox = response.isApprox;
if (num_phrases > 0) isApprox = Exact;
if (maxdocs == -1) maxdocs = numdocs;
else if (numdocs > maxdocs) {
numdocs = maxdocs;
isApprox = MoreThan;
}
if (isApprox == Approximate) resline = "_textapprox_";
else if (isApprox == MoreThan) resline = "_textmorethan_";
if (numdocs == 0) resline = "_textnodocs_";
else if (numdocs == 1) resline += "_text1doc_";
else resline += text_t(numdocs) + " _textlotsdocs_";
disp.setmacro("resultline", "query", resline);
int firstdoc = args.getintarg("r");
int hitsperpage = args.getintarg("o");
if (hitsperpage == -1) hitsperpage = numdocs;
// set up _thisfirst_ and _thislast_ macros
disp.setmacro ("thisfirst", "query", firstdoc);
int thislast = firstdoc + (hitsperpage - 1);
if (thislast > numdocs) thislast = numdocs;
disp.setmacro ("thislast", "query", thislast);
// set up _prevfirst_ and _prevlast_ macros
if (firstdoc > 1) {
disp.setmacro ("prevlast", "query", firstdoc - 1);
int prevfirst = firstdoc - hitsperpage;
if (prevfirst < 1) prevfirst = 1;
disp.setmacro ("prevfirst", "query", prevfirst);
}
// set up _nextfirst_ and _nextlast_ macros
if (thislast < numdocs) {
disp.setmacro ("nextfirst", "query", thislast + 1);
int nextlast = thislast + hitsperpage;
if (nextlast > numdocs) nextlast = numdocs;
disp.setmacro ("nextlast", "query", nextlast);
}
}
bool queryaction::save_search_history (cgiargsclass &args, const FilterResponse_t &response)
{
if (args["q"]=="") return true; // null query, dont save
if (args["hs"]=="0") return true; // only save when submit query
// displayed
// get userid
text_t userid = args["z"];
// the number of docs goes on the front of the query string
int numdocs= response.numDocs;
text_t query = text_t(numdocs);
if (response.isApprox==MoreThan) { // there were more docs found
query.push_back('+');
}
query += "c="+args["c"];
query += "&h="+args["h"];
query += "&t="+args["t"];
query += "&b="+args["b"];
query += "&j="+args["j"];
query += "&n="+args["n"];
query += "&s="+args["s"];
query += "&k="+args["k"];
query += "&g="+args["g"];
text_t qstring = args["q"];
text_t formattedquery =cgi_safe(qstring);
query += "&q="+formattedquery;
bool display=false;
int hd = args.getintarg("hd");
if (hd > 0) display=true;
if (set_history_info(userid, query, gdbmhome, display)) return true;
else return false;
}