src/htparser.c

   1 /*
   2     ashd - A Sane HTTP Daemon
   3     Copyright (C) 2008  Fredrik Tolf <fredrik@dolda2000.com>
   4
   5     This program is free software: you can redistribute it and/or modify
   6     it under the terms of the GNU General Public License as published by
   7     the Free Software Foundation, either version 3 of the License, or
   8     (at your option) any later version.
   9
  10     This program is distributed in the hope that it will be useful,
  11     but WITHOUT ANY WARRANTY; without even the implied warranty of
  12     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13     GNU General Public License for more details.
  14
  15     You should have received a copy of the GNU General Public License
  16     along with this program.  If not, see <http://www.gnu.org/licenses/>.
  17 */
  18
  19 #include <stdlib.h>
  20 #include <unistd.h>
  21 #include <stdio.h>
  22 #include <string.h>
  23 #include <sys/socket.h>
  24 #include <pwd.h>
  25 #include <errno.h>
  26
  27 #ifdef HAVE_CONFIG_H
  28 #include <config.h>
  29 #endif
  30 #include <utils.h>
  31 #include <mt.h>
  32 #include <mtio.h>
  33 #include <log.h>
  34 #include <req.h>
  35 #include <proc.h>
  36
  37 #include "htparser.h"
  38
  39 static int plex;
  40 static char *pidfile = NULL;
  41
  42 static void trimx(struct hthead *req)
  43 {
  44     int i;
  45
  46     i = 0;
  47     while(i < req->noheaders) {
  48         if(!strncasecmp(req->headers[i][0], "x-ash-", 6)) {
  49             free(req->headers[i][0]);
  50             free(req->headers[i][1]);
  51             free(req->headers[i]);
  52             memmove(req->headers + i, req->headers + i + 1, sizeof(*req->headers) * (--req->noheaders - i));
  53         } else {
  54             i++;
  55         }
  56     }
  57 }
  58
  59 static struct hthead *parsereq(FILE *in)
  60 {
  61     struct hthead *req;
  62     struct charbuf method, url, ver;
  63     int c;
  64
  65     req = NULL;
  66     bufinit(method);
  67     bufinit(url);
  68     bufinit(ver);
  69     while(1) {
  70         c = getc(in);
  71         if(c == ' ') {
  72             break;
  73         } else if((c == EOF) || (c < 32) || (c >= 128)) {
  74             goto fail;
  75         } else {
  76             bufadd(method, c);
  77         }
  78     }
  79     while(1) {
  80         c = getc(in);
  81         if(c == ' ') {
  82             break;
  83         } else if((c == EOF) || (c < 32)) {
  84             goto fail;
  85         } else {
  86             bufadd(url, c);
  87         }
  88     }
  89     while(1) {
  90         c = getc(in);
  91         if(c == 10) {
  92             break;
  93         } else if(c == 13) {
  94         } else if((c == EOF) || (c < 32) || (c >= 128)) {
  95             goto fail;
  96         } else {
  97             bufadd(ver, c);
  98         }
  99     }
 100     bufadd(method, 0);
 101     bufadd(url, 0);
 102     bufadd(ver, 0);
 103     req = mkreq(method.b, url.b, ver.b);
 104     if(parseheaders(req, in))
 105         goto fail;
 106     trimx(req);
 107     goto out;
 108
 109 fail:
 110     if(req != NULL) {
 111         freehthead(req);
 112         req = NULL;
 113     }
 114 out:
 115     buffree(method);
 116     buffree(url);
 117     buffree(ver);
 118     return(req);
 119 }
 120
 121 static struct hthead *parseresp(FILE *in)
 122 {
 123     struct hthead *req;
 124     int code;
 125     struct charbuf ver, msg;
 126     int c;
 127
 128     req = NULL;
 129     bufinit(ver);
 130     bufinit(msg);
 131     code = 0;
 132     while(1) {
 133         c = getc(in);
 134         if(c == ' ') {
 135             break;
 136         } else if((c == EOF) || (c < 32) || (c >= 128)) {
 137             goto fail;
 138         } else {
 139             bufadd(ver, c);
 140         }
 141     }
 142     while(1) {
 143         c = getc(in);
 144         if(c == ' ') {
 145             break;
 146         } else if((c == EOF) || (c < '0') || (c > '9')) {
 147             goto fail;
 148         } else {
 149             code = (code * 10) + (c - '0');
 150         }
 151     }
 152     while(1) {
 153         c = getc(in);
 154         if(c == 10) {
 155             break;
 156         } else if(c == 13) {
 157         } else if((c == EOF) || (c < 32)) {
 158             goto fail;
 159         } else {
 160             bufadd(msg, c);
 161         }
 162     }
 163     bufadd(msg, 0);
 164     bufadd(ver, 0);
 165     req = mkresp(code, msg.b, ver.b);
 166     if(parseheaders(req, in))
 167         goto fail;
 168     goto out;
 169
 170 fail:
 171     if(req != NULL) {
 172         freehthead(req);
 173         req = NULL;
 174     }
 175 out:
 176     buffree(msg);
 177     buffree(ver);
 178     return(req);
 179 }
 180
 181 static off_t passdata(FILE *in, FILE *out, off_t max)
 182 {
 183     size_t read;
 184     off_t total;
 185     char buf[8192];
 186
 187     total = 0;
 188     while(!feof(in) && ((max < 0) || (total < max))) {
 189         read = sizeof(buf);
 190         if(max >= 0)
 191             read = min(max - total, read);
 192         read = fread(buf, 1, read, in);
 193         if(ferror(in))
 194             return(-1);
 195         if(fwrite(buf, 1, read, out) != read)
 196             return(-1);
 197         total += read;
 198     }
 199     return(total);
 200 }
 201
 202 static int passchunks(FILE *in, FILE *out)
 203 {
 204     char buf[8192];
 205     size_t read;
 206
 207     do {
 208         read = fread(buf, 1, sizeof(buf), in);
 209         if(ferror(in))
 210             return(-1);
 211         fprintf(out, "%zx\r\n", read);
 212         if(fwrite(buf, 1, read, out) != read)
 213             return(-1);
 214         fprintf(out, "\r\n");
 215     } while(read > 0);
 216     return(0);
 217 }
 218
 219 static int hasheader(struct hthead *head, char *name, char *val)
 220 {
 221     char *hd;
 222
 223     if((hd = getheader(head, name)) == NULL)
 224         return(0);
 225     return(!strcasecmp(hd, val));
 226 }
 227
 228 void serve(FILE *in, struct conn *conn)
 229 {
 230     int pfds[2];
 231     FILE *out;
 232     struct hthead *req, *resp;
 233     char *hd, *p;
 234     off_t dlen;
 235
 236     out = NULL;
 237     req = resp = NULL;
 238     while(1) {
 239         if((req = parsereq(in)) == NULL)
 240             break;
 241         replrest(req, req->url);
 242         if(req->rest[0] == '/')
 243             replrest(req, req->rest + 1);
 244         if((p = strchr(req->rest, '?')) != NULL)
 245             *p = 0;
 246
 247         if((conn->initreq != NULL) && conn->initreq(conn, req))
 248             break;
 249
 250         if(block(plex, EV_WRITE, 60) <= 0)
 251             break;
 252         if(socketpair(PF_UNIX, SOCK_STREAM, 0, pfds))
 253             break;
 254         if(sendreq(plex, req, pfds[0]))
 255             break;
 256         close(pfds[0]);
 257         out = mtstdopen(pfds[1], 1, 600, "r+");
 258
 259         if((hd = getheader(req, "content-length")) != NULL) {
 260             dlen = atoo(hd);
 261             if(dlen > 0) {
 262                 if(passdata(in, out, dlen) != dlen)
 263                     break;
 264             }
 265         }
 266         if(fflush(out))
 267             break;
 268         /* Make sure to send EOF */
 269         shutdown(pfds[1], SHUT_WR);
 270
 271         if((resp = parseresp(out)) == NULL)
 272             break;
 273         replstr(&resp->ver, req->ver);
 274
 275         if(!strcmp(req->ver, "HTTP/1.0")) {
 276             writeresp(in, resp);
 277             fprintf(in, "\r\n");
 278             if((hd = getheader(resp, "content-length")) != NULL) {
 279                 dlen = passdata(out, in, -1);
 280                 if(dlen != atoo(hd))
 281                     break;
 282                 if(!hasheader(req, "connection", "keep-alive"))
 283                     break;
 284             } else {
 285                 passdata(out, in, -1);
 286                 break;
 287             }
 288             if(hasheader(req, "connection", "close") || hasheader(resp, "connection", "close"))
 289                 break;
 290         } else if(!strcmp(req->ver, "HTTP/1.1")) {
 291             if((hd = getheader(resp, "content-length")) != NULL) {
 292                 writeresp(in, resp);
 293                 fprintf(in, "\r\n");
 294                 dlen = passdata(out, in, -1);
 295                 if(dlen != atoo(hd))
 296                     break;
 297             } else if(!getheader(resp, "transfer-encoding")) {
 298                 headappheader(resp, "Transfer-Encoding", "chunked");
 299                 writeresp(in, resp);
 300                 fprintf(in, "\r\n");
 301                 if(passchunks(out, in))
 302                     break;
 303             } else {
 304                 writeresp(in, resp);
 305                 fprintf(in, "\r\n");
 306                 passdata(out, in, -1);
 307                 break;
 308             }
 309             if(hasheader(req, "connection", "close") || hasheader(resp, "connection", "close"))
 310                 break;
 311         } else {
 312             break;
 313         }
 314
 315         fclose(out);
 316         out = NULL;
 317         freehthead(req);
 318         freehthead(resp);
 319         req = resp = NULL;
 320     }
 321
 322     if(out != NULL)
 323         fclose(out);
 324     if(req != NULL)
 325         freehthead(req);
 326     if(resp != NULL)
 327         freehthead(resp);
 328     fclose(in);
 329 }
 330
 331 static void plexwatch(struct muth *muth, va_list args)
 332 {
 333     vavar(int, fd);
 334     char *buf;
 335     int ret;
 336
 337     while(1) {
 338         block(fd, EV_READ, 0);
 339         buf = smalloc(65536);
 340         ret = recv(fd, buf, 65536, 0);
 341         if(ret < 0) {
 342             flog(LOG_WARNING, "received error on rootplex read channel: %s", strerror(errno));
 343             exit(1);
 344         } else if(ret == 0) {
 345             exit(0);
 346         }
 347         /* Maybe I'd like to implement some protocol in this direction
 348          * some day... */
 349         free(buf);
 350     }
 351 }
 352
 353 static void usage(FILE *out)
 354 {
 355     fprintf(out, "usage: htparser [-hSf] [-u USER] [-r ROOT] [-p PIDFILE] PORTSPEC... -- ROOT [ARGS...]\n");
 356     fprintf(out, "\twhere PORTSPEC is HANDLER[:PAR[=VAL][(,PAR[=VAL])...]] (try HANDLER:help)\n");
 357     fprintf(out, "\tavailable handlers are `plain' and `ssl'.\n");
 358 }
 359
 360 static void addport(char *spec)
 361 {
 362     char *nm, *p, *p2, *n;
 363     struct charvbuf pars, vals;
 364
 365     bufinit(pars);
 366     bufinit(vals);
 367     if((p = strchr(spec, ':')) == NULL) {
 368         nm = spec;
 369     } else {
 370         nm = spec;
 371         *(p++) = 0;
 372         do {
 373             if((n = strchr(p, ',')) != NULL)
 374                 *(n++) = 0;
 375             if((p2 = strchr(p, '=')) != NULL)
 376                 *(p2++) = 0;
 377             if(!*p) {
 378                 usage(stderr);
 379                 exit(1);
 380             }
 381             bufadd(pars, p);
 382             if(p2)
 383                 bufadd(vals, p2);
 384             else
 385                 bufadd(vals, "");
 386         } while((p = n) != NULL);
 387     }
 388
 389     /* XXX: It would be nice to decentralize this, but, meh... */
 390     if(!strcmp(nm, "plain")) {
 391         handleplain(pars.d, pars.b, vals.b);
 392 #ifdef HAVE_GNUTLS
 393     } else if(!strcmp(nm, "ssl")) {
 394         handlegnussl(pars.d, pars.b, vals.b);
 395 #endif
 396     } else {
 397         flog(LOG_ERR, "htparser: unknown port handler `%s'", nm);
 398         exit(1);
 399     }
 400
 401     buffree(pars);
 402     buffree(vals);
 403 }
 404
 405 int main(int argc, char **argv)
 406 {
 407     int c;
 408     int i, s1;
 409     int daemonize, logsys;
 410     char *root;
 411     FILE *pidout;
 412     struct passwd *pwent;
 413
 414     daemonize = logsys = 0;
 415     root = NULL;
 416     pwent = NULL;
 417     while((c = getopt(argc, argv, "+hSfu:r:p:")) >= 0) {
 418         switch(c) {
 419         case 'h':
 420             usage(stdout);
 421             exit(0);
 422         case 'f':
 423             daemonize = 1;
 424             break;
 425         case 'S':
 426             logsys = 1;
 427             break;
 428         case 'u':
 429             if((pwent = getpwnam(optarg)) == NULL) {
 430                 flog(LOG_ERR, "could not find user %s", optarg);
 431                 exit(1);
 432             }
 433             break;
 434         case 'r':
 435             root = optarg;
 436             break;
 437         case 'p':
 438             pidfile = optarg;
 439             break;
 440         default:
 441             usage(stderr);
 442             exit(1);
 443         }
 444     }
 445     s1 = 0;
 446     for(i = optind; i < argc; i++) {
 447         if(!strcmp(argv[i], "--"))
 448             break;
 449         s1 = 1;
 450         addport(argv[i]);
 451     }
 452     if(!s1 || (i == argc)) {
 453         usage(stderr);
 454         exit(1);
 455     }
 456     if((plex = stdmkchild(argv + ++i)) < 0) {
 457         flog(LOG_ERR, "could not spawn root multiplexer: %s", strerror(errno));
 458         return(1);
 459     }
 460     mustart(plexwatch, plex);
 461     pidout = NULL;
 462     if(pidfile != NULL) {
 463         if((pidout = fopen(pidfile, "w")) == NULL) {
 464             flog(LOG_ERR, "could not open %s for writing: %s", pidfile, strerror(errno));
 465             return(1);
 466         }
 467     }
 468     if(logsys)
 469         opensyslog();
 470     if(root) {
 471         if(chroot(root)) {
 472             flog(LOG_ERR, "could not chroot to %s: %s", root, strerror(errno));
 473             exit(1);
 474         }
 475     }
 476     if(pwent) {
 477         if(setgid(pwent->pw_gid)) {
 478             flog(LOG_ERR, "could not switch group to %i: %s", (int)pwent->pw_gid, strerror(errno));
 479             exit(1);
 480         }
 481         if(setuid(pwent->pw_uid)) {
 482             flog(LOG_ERR, "could not switch user to %i: %s", (int)pwent->pw_uid, strerror(errno));
 483             exit(1);
 484         }
 485     }
 486     if(daemonize) {
 487         daemon(0, 0);
 488     }
 489     if(pidout != NULL) {
 490         fprintf(pidout, "%i\n", getpid());
 491         fclose(pidout);
 492     }
 493     ioloop();
 494     return(0);
 495 }