123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278 |
- /* invoked from /netlib/pub/search.html */
- #include <u.h>
- #include <libc.h>
- #include <bio.h>
- #include "httpd.h"
- #include "httpsrv.h"
- void bib_fmt(char*,char*);
- void index_fmt(char*,char*);
- void no_fmt(char*,char*);
- int send(HConnect*);
- Hio *hout;
- /********** table of databases ************/
- typedef struct DB DB;
- struct DB
- {
- int SELECT; /* value from search.html */
- char *log; /* abbreviation for logfile */
- int maxhit; /* maximum number of hits to return */
- char *file; /* searchfs database */
- void (*fmt)(char*,char*); /* convert one record to HTML */
- char *postlude; /* trailer text */
- };
- DB db[] =
- {
- {0, "netlib", 250, "/srv/netlib_DEFAULT", index_fmt,
- "<HR><A HREF=\"/netlib/master\">browse netlib</A></BODY>\r\n"},
- {1, "BibNet", 250, "/srv/netlib_bibnet", bib_fmt,
- "<HR><A HREF=\"/netlib/bibnet\">browse BibNet</A></BODY>\r\n"},
- {2, "compgeom", 250, "/srv/netlib_compgeom", no_fmt, "</BODY>\r\n"},
- {3, "approx", 250, "/srv/netlib_approximation", no_fmt,
- "<HR><A HREF=\"/netlib/a/catalog.html.gz\">hierarchical catalog</A></BODY>\r\n"},
- {4, "siam", 50, "/srv/netlib_siam-Secret", no_fmt, "</BODY>\r\n"},
- {-1,"",0,"",no_fmt,""}
- };
- /********** reformat database record as HTML ************/
- void /* tr '\015' '\012' ("uncombline") */
- no_fmt(char*s,char*e)
- {
- /* s = start, e = (one past) end of database record */
- char *p;
- for(p = s; p<e; p++)
- if(*p=='\r'){
- hwrite(hout, s,p-s);
- hprint(hout, "\n");
- s = p+1;
- }
- }
- int /* should the filename have .gz appended? */
- suffix(char*filename)
- {
- int n;
- char *z;
- if(!filename || *filename==0)
- return(0);
- n = strlen(filename);
- if(strncmp(".html",filename+n-5,5)==0)
- return(0);
- z = malloc(n+50);
- if(z == nil)
- return(0);
- strcpy(z,"/netlib/pub/");
- strcat(z,filename);
- strcat(z,".gz");
- if(access(z,4)==0){
- free(z);
- return(1);
- }
- free(z);
- return(0);
- }
- void /* add HREF to "file:" lines */
- index_fmt(char*s,char*e)
- {
- char *p, *filename;
- if(strncmp(s,"file",4)==0 && (s[4]==' '||s[4]=='\t')){
- for(filename = s+4; strchr(" \t",*filename); filename++){}
- for(s = filename; *s && strchr("\r\n",*s)==nil; s++){}
- *s++ = '\0';
- if(*s=='\n') s++;
- hprint(hout, "file: <A HREF=\"/netlib/%s",filename);
- if(suffix(filename))
- hprint(hout, ".gz");
- hprint(hout, "\">%s</A>\r\n",filename);
- for(p = s; p<e; p++)
- if(*p=='\r'){
- hwrite(hout, s,p-s);
- hprint(hout, "\n");
- s = p+1;
- }
- }else if(strncmp(s,"lib",3)==0 && (s[3]==' '||s[3]=='\t')){
- for(filename = s+3; strchr(" \t",*filename); filename++){}
- for(s = filename; *s && strchr("\r\n",*s)==nil; s++){}
- *s++ = '\0';
- if(*s=='\n') s++;
- hprint(hout, "lib: <A HREF=\"/netlib/%s",filename);
- hprint(hout, "\">%s</A>\r\n",filename);
- for(p = s; p<e; p++)
- if(*p=='\r'){
- hwrite(hout, s,p-s);
- hprint(hout, "\n");
- s = p+1;
- }
- }else{
- no_fmt(s,e);
- }
- }
- void /* add HREF to "URL" lines */
- bib_fmt(char*s,char*e)
- {
- char *p, *filename;
- for(p = s; p<e; p++)
- if(*p=='\r'){
- hwrite(hout, s,p-s);
- hprint(hout, "\n");
- s = p+1;
- if(strncmp(s," URL =",6)==0 &&
- (filename = strchr(s+6,'"'))!=nil){
- filename++;
- for(s = filename; *s && strchr("\"\r\n",*s)==nil; s++){}
- *s++ = '\0';
- p = s;
- hprint(hout, " URL =<A HREF=\"%s\">%s</A>",
- filename,filename);
- }
- }
- }
- /********** main() calls httpheadget() calls send() ************/
- void
- main(int argc, char **argv)
- {
- HConnect *c;
- c = init(argc, argv);
- hout = &c->hout;
- if(hparseheaders(c, HSTIMEOUT) >= 0)
- send(c);
- exits(nil);
- }
- Biobuf Blist;
- Biobuf*
- init800fs(char*name,char*pat)
- {
- int fd800fs, n;
- char*search;
- fd800fs = open(name, ORDWR);
- if(fd800fs < 0)
- exits("can't connect to 800fs server");
- if(mount(fd800fs, -1, "/mnt", MREPL, "") < 0)
- exits("can't mount /mnt");
- fd800fs = open("/mnt/search", ORDWR);
- n = strlen("search=")+strlen(pat)+1;
- search = ezalloc(n);
- strcpy(search,"search=");
- strcat(search,pat);
- write(fd800fs,search,n);
- free(search);
- Binit(&Blist, fd800fs,OREAD);
- return(&Blist);
- }
- static char *
- hq(char *text)
- {
- int textlen = strlen(text), escapedlen = textlen;
- char *escaped, *s, *w;
- for(s = text; *s; s++)
- if(*s=='<' || *s=='>' || *s=='&')
- escapedlen += 4;
- escaped = ezalloc(escapedlen+1);
- for(s = text, w = escaped; *s; s++){
- if(*s == '<'){
- strcpy(w, "<");
- w += 4;
- }else if(*s == '>'){
- strcpy(w, ">");
- w += 4;
- }else if(*s == '&'){
- strcpy(w, "&");
- w += 5;
- }else{
- *w++ = *s;
- }
- }
- return escaped;
- }
- int
- send(HConnect *c)
- {
- Biobuf*blist;
- int m, n, dbi, nmatch;
- char *pat, *s, *e;
- HSPairs *q;
- if(strcmp(c->req.meth, "GET") != 0 && strcmp(c->req.meth, "HEAD") != 0)
- return hunallowed(c, "GET, HEAD");
- if(c->head.expectother || c->head.expectcont)
- return hfail(c, HExpectFail, nil);
- if(c->req.search == nil || !*c->req.search)
- return hfail(c, HNoData, "netlib_find");
- s = c->req.search;
- while((s = strchr(s, '+')) != nil)
- *s++ = ' ';
- dbi = -1;
- pat = nil;
- for(q = hparsequery(c, hstrdup(c, c->req.search)); q; q = q->next){
- if(strcmp(q->s, "db") == 0){
- m = atoi(q->t);
- for(dbi = 0; m!=db[dbi].SELECT; dbi++)
- if(db[dbi].SELECT<0)
- exits("unrecognized db");
- }else if(strcmp(q->s, "pat") == 0){
- pat = q->t;
- }
- }
- if(dbi < 0)
- exits("missing db field in query");
- if(pat == nil)
- exits("missing pat field in query");
- logit(c, "netlib_find %s %s", db[dbi].log,pat);
- blist = init800fs(db[dbi].file,pat);
- if(c->req.vermaj){
- hokheaders(c);
- hprint(hout, "Content-type: text/html\r\n");
- hprint(hout, "\r\n");
- }
- if(strcmp(c->req.meth, "HEAD") == 0){
- writelog(c, "Reply: 200 netlib_find 0\n");
- hflush(hout);
- exits(nil);
- }
- hprint(hout, "<HEAD><TITLE>%s/%s</TITLE></HEAD>\r\n<BODY>\r\n",
- db[dbi].log,hq(pat));
- nmatch = 0;
- while(s = Brdline(blist, '\n')){ /* get next database record */
- n = Blinelen(blist);
- e = s+n;
- hprint(hout, "<PRE>");
- (*db[dbi].fmt)(s,e);
- hprint(hout, "</PRE>\r\n");
- if(nmatch++>=db[dbi].maxhit){
- hprint(hout, "<H4>reached limit at %d hits</H4>\n\r",nmatch);
- break;
- }
- }
- if(nmatch==0)
- hprint(hout, "<H4>Nothing Found.</H4>\r\n");
- hprint(hout, db[dbi].postlude);
- hflush(hout);
- writelog(c, "Reply: 200 netlib_find %ld %ld\n", hout->seek, hout->seek);
- return 1;
- }
|