1 /* invoked from /netlib/pub/search.html */ 2 3 #include <u.h> 4 #include <libc.h> 5 #include <bio.h> 6 #include "httpd.h" 7 #include "httpsrv.h" 8 9 void bib_fmt(char*,char*); 10 void index_fmt(char*,char*); 11 void no_fmt(char*,char*); 12 int send(HConnect*); 13 14 Hio *hout; 15 16 /********** table of databases ************/ 17 18 typedef struct DB DB; 19 struct DB 20 { 21 int SELECT; /* value from search.html */ 22 char *log; /* abbreviation for logfile */ 23 int maxhit; /* maximum number of hits to return */ 24 char *file; /* searchfs database */ 25 void (*fmt)(char*,char*); /* convert one record to HTML */ 26 char *postlude; /* trailer text */ 27 }; 28 29 DB db[] = 30 { 31 {0, "netlib", 250, "/srv/netlib_DEFAULT", index_fmt, 32 "<HR><A HREF=\"/netlib/master\">browse netlib</A></BODY>\r\n"}, 33 {1, "BibNet", 250, "/srv/netlib_bibnet", bib_fmt, 34 "<HR><A HREF=\"/netlib/bibnet\">browse BibNet</A></BODY>\r\n"}, 35 {2, "compgeom", 250, "/srv/netlib_compgeom", no_fmt, "</BODY>\r\n"}, 36 {3, "approx", 250, "/srv/netlib_approximation", no_fmt, 37 "<HR><A HREF=\"/netlib/a/catalog.html.gz\">hierarchical catalog</A></BODY>\r\n"}, 38 {4, "siam", 50, "/srv/netlib_siam-Secret", no_fmt, "</BODY>\r\n"}, 39 {-1,"",0,"",no_fmt,""} 40 }; 41 42 43 44 /********** reformat database record as HTML ************/ 45 46 void /* tr '\015' '\012' ("uncombline") */ 47 no_fmt(char*s,char*e) 48 { 49 /* s = start, e = (one past) end of database record */ 50 char *p; 51 for(p = s; p<e; p++) 52 if(*p=='\r'){ 53 hwrite(hout, s,p-s); 54 hprint(hout, "\n"); 55 s = p+1; 56 } 57 } 58 59 int /* should the filename have .gz appended? */ 60 suffix(char*filename) 61 { 62 int n; 63 char *z; 64 65 if(!filename || *filename==0) 66 return(0); 67 n = strlen(filename); 68 if(strncmp(".html",filename+n-5,5)==0) 69 return(0); 70 z = malloc(n+50); 71 if(z == nil) 72 return(0); 73 strcpy(z,"/netlib/pub/"); 74 strcat(z,filename); 75 strcat(z,".gz"); 76 if(access(z,4)==0){ 77 free(z); 78 return(1); 79 } 80 free(z); 81 return(0); 82 } 83 84 void /* add HREF to "file:" lines */ 85 index_fmt(char*s,char*e) 86 { 87 char *p, *filename; 88 if(strncmp(s,"file",4)==0 && (s[4]==' '||s[4]=='\t')){ 89 for(filename = s+4; strchr(" \t",*filename); filename++){} 90 for(s = filename; *s && strchr("\r\n",*s)==nil; s++){} 91 *s++ = '\0'; 92 if(*s=='\n') s++; 93 hprint(hout, "file: <A HREF=\"/netlib/%s",filename); 94 if(suffix(filename)) 95 hprint(hout, ".gz"); 96 hprint(hout, "\">%s</A>\r\n",filename); 97 for(p = s; p<e; p++) 98 if(*p=='\r'){ 99 hwrite(hout, s,p-s); 100 hprint(hout, "\n"); 101 s = p+1; 102 } 103 }else if(strncmp(s,"lib",3)==0 && (s[3]==' '||s[3]=='\t')){ 104 for(filename = s+3; strchr(" \t",*filename); filename++){} 105 for(s = filename; *s && strchr("\r\n",*s)==nil; s++){} 106 *s++ = '\0'; 107 if(*s=='\n') s++; 108 hprint(hout, "lib: <A HREF=\"/netlib/%s",filename); 109 hprint(hout, "\">%s</A>\r\n",filename); 110 for(p = s; p<e; p++) 111 if(*p=='\r'){ 112 hwrite(hout, s,p-s); 113 hprint(hout, "\n"); 114 s = p+1; 115 } 116 }else{ 117 no_fmt(s,e); 118 } 119 } 120 121 void /* add HREF to "URL" lines */ 122 bib_fmt(char*s,char*e) 123 { 124 char *p, *filename; 125 for(p = s; p<e; p++) 126 if(*p=='\r'){ 127 hwrite(hout, s,p-s); 128 hprint(hout, "\n"); 129 s = p+1; 130 if(strncmp(s," URL =",6)==0 && 131 (filename = strchr(s+6,'"'))!=nil){ 132 filename++; 133 for(s = filename; *s && strchr("\"\r\n",*s)==nil; s++){} 134 *s++ = '\0'; 135 p = s; 136 hprint(hout, " URL =<A HREF=\"%s\">%s</A>", 137 filename,filename); 138 } 139 } 140 } 141 142 143 /********** main() calls httpheadget() calls send() ************/ 144 145 void 146 main(int argc, char **argv) 147 { 148 HConnect *c; 149 150 c = init(argc, argv); 151 hout = &c->hout; 152 if(hparseheaders(c, HSTIMEOUT) >= 0) 153 send(c); 154 exits(nil); 155 } 156 157 Biobuf Blist; 158 159 Biobuf* 160 init800fs(char*name,char*pat) 161 { 162 int fd800fs, n; 163 char*search; 164 165 fd800fs = open(name, ORDWR); 166 if(fd800fs < 0) 167 exits("can't connect to 800fs server"); 168 if(mount(fd800fs, -1, "/mnt", MREPL, "") < 0) 169 exits("can't mount /mnt"); 170 fd800fs = open("/mnt/search", ORDWR); 171 n = strlen("search=")+strlen(pat)+1; 172 search = ezalloc(n); 173 strcpy(search,"search="); 174 strcat(search,pat); 175 write(fd800fs,search,n); 176 free(search); 177 Binit(&Blist, fd800fs,OREAD); 178 return(&Blist); 179 } 180 181 182 static char * 183 hq(char *text) 184 { 185 int textlen = strlen(text), escapedlen = textlen; 186 char *escaped, *s, *w; 187 188 for(s = text; *s; s++) 189 if(*s=='<' || *s=='>' || *s=='&') 190 escapedlen += 4; 191 escaped = ezalloc(escapedlen+1); 192 for(s = text, w = escaped; *s; s++){ 193 if(*s == '<'){ 194 strcpy(w, "<"); 195 w += 4; 196 }else if(*s == '>'){ 197 strcpy(w, ">"); 198 w += 4; 199 }else if(*s == '&'){ 200 strcpy(w, "&"); 201 w += 5; 202 }else{ 203 *w++ = *s; 204 } 205 } 206 return escaped; 207 } 208 209 int 210 send(HConnect *c) 211 { 212 Biobuf*blist; 213 int m, n, dbi, nmatch; 214 char *pat, *s, *e; 215 HSPairs *q; 216 217 if(strcmp(c->req.meth, "GET") != 0 && strcmp(c->req.meth, "HEAD") != 0) 218 return hunallowed(c, "GET, HEAD"); 219 if(c->head.expectother || c->head.expectcont) 220 return hfail(c, HExpectFail, nil); 221 if(c->req.search == nil || !*c->req.search) 222 return hfail(c, HNoData, "netlib_find"); 223 s = c->req.search; 224 while((s = strchr(s, '+')) != nil) 225 *s++ = ' '; 226 dbi = -1; 227 pat = nil; 228 for(q = hparsequery(c, hstrdup(c, c->req.search)); q; q = q->next){ 229 if(strcmp(q->s, "db") == 0){ 230 m = atoi(q->t); 231 for(dbi = 0; m!=db[dbi].SELECT; dbi++) 232 if(db[dbi].SELECT<0) 233 exits("unrecognized db"); 234 }else if(strcmp(q->s, "pat") == 0){ 235 pat = q->t; 236 } 237 } 238 if(dbi < 0) 239 exits("missing db field in query"); 240 if(pat == nil) 241 exits("missing pat field in query"); 242 logit(c, "netlib_find %s %s", db[dbi].log,pat); 243 244 blist = init800fs(db[dbi].file,pat); 245 246 if(c->req.vermaj){ 247 hokheaders(c); 248 hprint(hout, "Content-type: text/html\r\n"); 249 hprint(hout, "\r\n"); 250 } 251 if(strcmp(c->req.meth, "HEAD") == 0){ 252 writelog(c, "Reply: 200 netlib_find 0\n"); 253 hflush(hout); 254 exits(nil); 255 } 256 257 hprint(hout, "<HEAD><TITLE>%s/%s</TITLE></HEAD>\r\n<BODY>\r\n", 258 db[dbi].log,hq(pat)); 259 nmatch = 0; 260 261 while(s = Brdline(blist, '\n')){ /* get next database record */ 262 n = Blinelen(blist); 263 e = s+n; 264 hprint(hout, "<PRE>"); 265 (*db[dbi].fmt)(s,e); 266 hprint(hout, "</PRE>\r\n"); 267 if(nmatch++>=db[dbi].maxhit){ 268 hprint(hout, "<H4>reached limit at %d hits</H4>\n\r",nmatch); 269 break; 270 } 271 } 272 if(nmatch==0) 273 hprint(hout, "<H4>Nothing Found.</H4>\r\n"); 274 hprint(hout, db[dbi].postlude); 275 hflush(hout); 276 writelog(c, "Reply: 200 netlib_find %ld %ld\n", hout->seek, hout->seek); 277 return 1; 278 } 279