* temporary solution to our ser_readln migration: have a buffer on the session, read...
[citadel.git] / webcit / webcit.c
1 /*
2  * $Id$
3  *
4  * This is the main transaction loop of the web service.  It maintains a
5  * persistent session to the Citadel server, handling HTTP WebCit requests as
6  * they arrive and presenting a user interface.
7  */
8 #define SHOW_ME_VAPPEND_PRINTF
9 #include <stdio.h>
10 #include <stdarg.h>
11 #include "webcit.h"
12 #include "groupdav.h"
13 #include "webserver.h"
14
15
16 /*
17  * String to unset the cookie.
18  * Any date "in the past" will work, so I chose my birthday, right down to
19  * the exact minute.  :)
20  */
21 static char *unset = "; expires=28-May-1971 18:10:00 GMT";
22
23 HashList *HandlerHash = NULL;
24
25 void WebcitAddUrlHandler(const char * UrlString, 
26                          long UrlSLen, 
27                          WebcitHandlerFunc F, 
28                          long Flags)
29 {
30         WebcitHandler *NewHandler;
31
32         if (HandlerHash == NULL)
33                 HandlerHash = NewHash(1, NULL);
34         
35         NewHandler = (WebcitHandler*) malloc(sizeof(WebcitHandler));
36         NewHandler->F = F;
37         NewHandler->Flags = Flags;
38         Put(HandlerHash, UrlString, UrlSLen, NewHandler, NULL);
39 }
40
41
42 /*
43  * web-printing funcion. uses our vsnprintf wrapper
44  */
45 void wprintf(const char *format,...)
46 {
47         wcsession *WCC = WC;
48         va_list arg_ptr;
49
50         if (WCC->WBuf == NULL)
51                 WCC->WBuf = NewStrBuf();
52
53         va_start(arg_ptr, format);
54         StrBufVAppendPrintf(WCC->WBuf, format, arg_ptr);
55         va_end(arg_ptr);
56 }
57
58 /*
59  * http-header-printing funcion. uses our vsnprintf wrapper
60  */
61 void hprintf(const char *format,...)
62 {
63         wcsession *WCC = WC;
64         va_list arg_ptr;
65
66         va_start(arg_ptr, format);
67         StrBufVAppendPrintf(WCC->HBuf, format, arg_ptr);
68         va_end(arg_ptr);
69 }
70
71
72
73 /*
74  * wrap up an HTTP session, closes tags, etc.
75  *
76  * print_standard_html_footer should be set to:
77  * 0            - to transmit only,
78  * nonzero      - to append the closing tags
79  */
80 void wDumpContent(int print_standard_html_footer)
81 {
82         if (print_standard_html_footer) {
83                 wprintf("</div> <!-- end of 'content' div -->\n");
84                 do_template("trailing", NULL);
85         }
86
87         /* If we've been saving it all up for one big output burst,
88          * go ahead and do that now.
89          */
90         end_burst();
91 }
92
93
94  
95
96 /*
97  * Output HTTP headers and leading HTML for a page
98  */
99 void output_headers(    int do_httpheaders,     /* 1 = output HTTP headers                          */
100                         int do_htmlhead,        /* 1 = output HTML <head> section and <body> opener */
101
102                         int do_room_banner,     /* 0=no, 1=yes,                                     
103                                                  * 2 = I'm going to embed my own, so don't open the 
104                                                  *     <div id="content"> either.                   
105                                                  */
106
107                         int unset_cookies,      /* 1 = session is terminating, so unset the cookies */
108                         int suppress_check,     /* 1 = suppress check for instant messages          */
109                         int cache               /* 1 = allow browser to cache this page             */
110 ) {
111         wcsession *WCC = WC;
112         char cookie[1024];
113         char httpnow[128];
114
115         hprintf("HTTP/1.1 200 OK\n");
116         http_datestring(httpnow, sizeof httpnow, time(NULL));
117
118         if (do_httpheaders) {
119                 if (WCC->serv_info != NULL)
120                         hprintf("Content-type: text/html; charset=utf-8\r\n"
121                                 "Server: %s / %s\n"
122                                 "Connection: close\r\n",
123                                 PACKAGE_STRING, 
124                                 ChrPtr(WCC->serv_info->serv_software));
125                 else
126                         hprintf("Content-type: text/html; charset=utf-8\r\n"
127                                 "Server: %s / [n/a]\n"
128                                 "Connection: close\r\n",
129                                 PACKAGE_STRING);
130         }
131
132         if (cache) {
133                 char httpTomorow[128];
134
135                 http_datestring(httpTomorow, sizeof httpTomorow, 
136                                 time(NULL) + 60 * 60 * 24 * 2);
137
138                 hprintf("Pragma: public\r\n"
139                         "Cache-Control: max-age=3600, must-revalidate\r\n"
140                         "Last-modified: %s\r\n"
141                         "Expires: %s\r\n",
142                         httpnow,
143                         httpTomorow
144                 );
145         }
146         else {
147                 hprintf("Pragma: no-cache\r\n"
148                         "Cache-Control: no-store\r\n"
149                         "Expires: -1\r\n"
150                 );
151         }
152
153         stuff_to_cookie(cookie, 1024, 
154                         WCC->wc_session, WCC->wc_username,
155                         WCC->wc_password, WCC->wc_roomname);
156
157         if (unset_cookies) {
158                 hprintf("Set-cookie: webcit=%s; path=/\r\n", unset);
159         } else {
160                 hprintf("Set-cookie: webcit=%s; path=/\r\n", cookie);
161                 if (server_cookie != NULL) {
162                         hprintf("%s\n", server_cookie);
163                 }
164         }
165
166         if (do_htmlhead) {
167                 begin_burst();
168                 do_template("head", NULL);
169
170                 /* check for ImportantMessages (these display in a div overlaying the main screen) */
171                 if (!IsEmptyStr(WCC->ImportantMessage)) {
172                         wprintf("<div id=\"important_message\">\n"
173                                 "<span class=\"imsg\">");
174                         StrEscAppend(WCC->WBuf, NULL, WCC->ImportantMessage, 0, 0);
175                         wprintf("</span><br />\n"
176                                 "</div>\n"
177                         );
178                         StrBufAppendBufPlain(WCC->trailing_javascript,
179                                              HKEY("setTimeout('hide_imsg_popup()', 5000);       \n"), 
180                                              0
181                         );
182                         WCC->ImportantMessage[0] = 0;
183                 }
184                 else if (StrLength(WCC->ImportantMsg) > 0) {
185                         wprintf("<div id=\"important_message\">\n"
186                                 "<span class=\"imsg\">");
187                         StrEscAppend(WCC->WBuf, WCC->ImportantMsg, NULL, 0, 0);
188                         wprintf("</span><br />\n"
189                                 "</div>\n"
190                         );
191                         StrBufAppendBufPlain(WCC->trailing_javascript,
192                                              HKEY("setTimeout('hide_imsg_popup()', 5000);       \n"),
193                                              0
194                         );
195                         FlushStrBuf(WCC->ImportantMsg);
196                 }
197                 if ( (WCC->logged_in) && (!unset_cookies) ) {
198                         /*DoTemplate(HKEY("iconbar"), NULL, &NoCtx);*/
199                         page_popup();
200                 }
201
202                 if (do_room_banner == 1) {
203                         wprintf("<div id=\"banner\">\n");
204                         embed_room_banner(NULL, navbar_default);
205                         wprintf("</div>\n");
206                 }
207         }
208
209         if (do_room_banner == 1) {
210                 wprintf("<div id=\"content\">\n");
211         }
212 }
213
214 void output_custom_content_header(const char *ctype) {
215   hprintf("HTTP/1.1 200 OK\r\n");
216   hprintf("Content-type: %s; charset=utf-8\r\n",ctype);
217   hprintf("Server: %s / %s\r\n", PACKAGE_STRING, ChrPtr(WC->serv_info->serv_software));
218   hprintf("Connection: close\r\n");
219 }
220
221
222 /*
223  * Generic function to do an HTTP redirect.  Easy and fun.
224  */
225 void http_redirect(const char *whichpage) {
226         hprintf("HTTP/1.1 302 Moved Temporarily\n");
227         hprintf("Location: %s\r\n", whichpage);
228         hprintf("URI: %s\r\n", whichpage);
229         hprintf("Content-type: text/html; charset=utf-8\r\n");
230         wprintf("<html><body>");
231         wprintf("Go <a href=\"%s\">here</A>.", whichpage);
232         wprintf("</body></html>\n");
233         end_burst();
234 }
235
236
237
238 /*
239  * Output a piece of content to the web browser using conformant HTTP and MIME semantics
240  */
241 void http_transmit_thing(const char *content_type,
242                          int is_static) {
243
244 #ifndef TECH_PREVIEW
245         lprintf(9, "http_transmit_thing(%s)%s\n",
246                 content_type,
247                 (is_static ? " (static)" : "")
248         );
249 #endif
250         output_headers(0, 0, 0, 0, 0, is_static);
251
252         hprintf("Content-type: %s\r\n"
253                 "Server: %s\r\n"
254                 "Connection: close\r\n",
255                 content_type,
256                 PACKAGE_STRING);
257
258         end_burst();
259 }
260
261 /*
262  * print menu box like used in the floor view or admin interface.
263  * This function takes pair of strings as va_args, 
264  * Title        Title string of the box
265  * Class        CSS Class for the box
266  * nLines       How many string pairs should we print? (URL, UrlText)
267  * ...          Pairs of URL Strings and their Names
268  */
269 void print_menu_box(char* Title, char *Class, int nLines, ...)
270 {
271         va_list arg_list;
272         long i;
273         
274         svput("BOXTITLE", WCS_STRING, Title);
275         do_template("beginboxx", NULL);
276         
277         wprintf("<ul class=\"%s\">", Class);
278         
279         va_start(arg_list, nLines);
280         for (i = 0; i < nLines; ++i)
281         { 
282                 wprintf("<li><a href=\"%s\">", va_arg(arg_list, char *));
283                 wprintf((char *) va_arg(arg_list, char *));
284                 wprintf("</a></li>\n");
285         }
286         va_end (arg_list);
287         
288         wprintf("</a></li>\n");
289         
290         wprintf("</ul>");
291         
292         do_template("endbox", NULL);
293 }
294
295
296 /*
297  * dump out static pages from disk
298  */
299 void output_static(const char *what)
300 {
301         int fd;
302         struct stat statbuf;
303         off_t bytes;
304         off_t count = 0;
305         const char *content_type;
306         int len;
307         const char *Err;
308
309         fd = open(what, O_RDONLY);
310         if (fd <= 0) {
311                 lprintf(9, "output_static('%s')  -- NOT FOUND --\n", what);
312                 hprintf("HTTP/1.1 404 %s\r\n", strerror(errno));
313                 hprintf("Content-Type: text/plain\r\n");
314                 wprintf("Cannot open %s: %s\r\n", what, strerror(errno));
315                 end_burst();
316         } else {
317                 len = strlen (what);
318                 content_type = GuessMimeByFilename(what, len);
319
320                 if (fstat(fd, &statbuf) == -1) {
321                         lprintf(9, "output_static('%s')  -- FSTAT FAILED --\n", what);
322                         hprintf("HTTP/1.1 404 %s\r\n", strerror(errno));
323                         hprintf("Content-Type: text/plain\r\n");
324                         wprintf("Cannot fstat %s: %s\n", what, strerror(errno));
325                         end_burst();
326                         return;
327                 }
328
329                 count = 0;
330                 bytes = statbuf.st_size;
331
332                 if (StrBufReadBLOB(WC->WBuf, &fd, 1, bytes, &Err) < 0)
333                 {
334                         if (fd > 0) close(fd);
335                         lprintf(9, "output_static('%s')  -- FREAD FAILED (%s) --\n", what, strerror(errno));
336                                 hprintf("HTTP/1.1 500 internal server error \r\n");
337                                 hprintf("Content-Type: text/plain\r\n");
338                                 end_burst();
339                                 return;
340                 }
341
342
343                 close(fd);
344 #ifndef TECH_PREVIEW
345                 lprintf(9, "output_static('%s')  %s\n", what, content_type);
346 #endif
347                 http_transmit_thing(content_type, 1);
348         }
349         if (yesbstr("force_close_session")) {
350                 end_webcit_session();
351         }
352 }
353
354
355 /*
356  * Convenience functions to display a page containing only a string
357  *
358  * titlebarcolor        color of the titlebar of the frame
359  * titlebarmsg          text to display in the title bar
360  * messagetext          body of the box
361  */
362 void convenience_page(const char *titlebarcolor, const char *titlebarmsg, const char *messagetext)
363 {
364         hprintf("HTTP/1.1 200 OK\n");
365         output_headers(1, 1, 2, 0, 0, 0);
366         wprintf("<div id=\"banner\">\n");
367         wprintf("<table width=100%% border=0 bgcolor=\"#%s\"><tr><td>", titlebarcolor);
368         wprintf("<span class=\"titlebar\">%s</span>\n", titlebarmsg);
369         wprintf("</td></tr></table>\n");
370         wprintf("</div>\n<div id=\"content\">\n");
371         escputs(messagetext);
372
373         wprintf("<hr />\n");
374         wDumpContent(1);
375 }
376
377
378 /*
379  * Display a blank page.
380  */
381 void blank_page(void) {
382         output_headers(1, 1, 0, 0, 0, 0);
383         wDumpContent(2);
384 }
385
386
387 /*
388  * A template has been requested
389  */
390 void url_do_template(void) {
391         const StrBuf *MimeType;
392         const StrBuf *Tmpl = sbstr("template");
393         begin_burst();
394         MimeType = DoTemplate(SKEY(Tmpl), NULL, &NoCtx);
395         http_transmit_thing(ChrPtr(MimeType), 0);
396 }
397
398
399
400 /*
401  * convenience function to indicate success
402  */
403 void display_success(char *successmessage)
404 {
405         convenience_page("007700", "OK", successmessage);
406 }
407
408
409 /*
410  * Authorization required page 
411  * This is probably temporary and should be revisited 
412  */
413 void authorization_required(const char *message)
414 {
415         hprintf("HTTP/1.1 401 Authorization Required\r\n");
416         hprintf("WWW-Authenticate: Basic realm=\"%s\"\r\n", ChrPtr(WC->serv_info->serv_humannode));
417         hprintf("Content-Type: text/html\r\n");
418         wprintf("<h1>");
419         wprintf(_("Authorization Required"));
420         wprintf("</h1>\r\n");
421         wprintf(_("The resource you requested requires a valid username and password. "
422                 "You could not be logged in: %s\n"), message);
423         wDumpContent(0);
424         
425 }
426
427 /*
428  * Convenience functions to wrap around asynchronous ajax responses
429  */
430 void begin_ajax_response(void) {
431         wcsession *WCC = WC;
432
433         FlushStrBuf(WCC->HBuf);
434         output_headers(0, 0, 0, 0, 0, 0);
435
436         hprintf("Content-type: text/html; charset=UTF-8\r\n"
437                 "Server: %s\r\n"
438                 "Connection: close\r\n"
439                 ,
440                 PACKAGE_STRING);
441         begin_burst();
442 }
443
444 /*
445  * print ajax response footer 
446  */
447 void end_ajax_response(void) {
448         wDumpContent(0);
449 }
450
451 /*
452  * Wraps a Citadel server command in an AJAX transaction.
453  */
454 void ajax_servcmd(void)
455 {
456         wcsession *WCC = WC;
457         int Done = 0;
458         StrBuf *Buf;
459         char *junk;
460         size_t len;
461
462         begin_ajax_response();
463         Buf = NewStrBuf();
464         serv_puts(bstr("g_cmd"));
465         StrBuf_ServGetln(Buf);
466         StrBufAppendBuf(WCC->WBuf, Buf, 0);
467         StrBufAppendBufPlain(WCC->WBuf, HKEY("\n"), 0);
468         
469         switch (GetServerStatus(Buf, NULL)) {
470         case 8:
471                 serv_puts("\n\n000");
472                 if ( (StrLength(Buf)==3) && 
473                      !strcmp(ChrPtr(Buf), "000")) {
474                         StrBufAppendBufPlain(WCC->WBuf, HKEY("\000"), 0);
475                         break;
476                 }
477         case 1:
478                 while (!Done) {
479                         StrBuf_ServGetlnBuffered(Buf);
480                         if ( (StrLength(Buf)==3) && 
481                              !strcmp(ChrPtr(Buf), "000")) {
482                                 Done = 1;
483                         }
484                         StrBufAppendBuf(WCC->WBuf, Buf, 0);
485                         StrBufAppendBufPlain(WCC->WBuf, HKEY("\n"), 0);
486                 }
487                 break;
488         case 4:
489                 text_to_server(bstr("g_input"));
490                 serv_puts("000");
491                 break;
492         case 6:
493                 len = atol(&ChrPtr(Buf)[4]);
494                 StrBuf_ServGetBLOBBuffered(Buf, len);
495                 break;
496         case 7:
497                 len = atol(&ChrPtr(Buf)[4]);
498                 junk = malloc(len);
499                 memset(junk, 0, len);
500                 serv_write(junk, len);
501                 free(junk);
502         }
503         
504         end_ajax_response();
505         
506         /*
507          * This is kind of an ugly hack, but this is the only place it can go.
508          * If the command was GEXP, then the instant messenger window must be
509          * running, so reset the "last_pager_check" watchdog timer so
510          * that page_popup() doesn't try to open it a second time.
511          */
512         if (!strncasecmp(bstr("g_cmd"), "GEXP", 4)) {
513                 WCC->last_pager_check = time(NULL);
514         }
515         FreeStrBuf(&Buf);
516 }
517
518
519 /*
520  * Helper function for the asynchronous check to see if we need
521  * to open the instant messenger window.
522  */
523 void seconds_since_last_gexp(void)
524 {
525         char buf[256];
526
527         if ( (time(NULL) - WC->last_pager_check) < 30) {
528                 wprintf("NO\n");
529         }
530         else {
531                 memset(buf, 0, 5);
532                 serv_puts("NOOP");
533                 serv_getln(buf, sizeof buf);
534                 if (buf[3] == '*') {
535                         wprintf("YES");
536                 }
537                 else {
538                         wprintf("NO");
539                 }
540         }
541 }
542
543 /**
544  * \brief Detects a 'mobile' user agent 
545  */
546 int is_mobile_ua(char *user_agent) {
547       if (strstr(user_agent,"iPhone OS") != NULL) {
548         return 1;
549       } else if (strstr(user_agent,"Windows CE") != NULL) {
550         return 1;
551       } else if (strstr(user_agent,"SymbianOS") != NULL) {
552         return 1;
553       } else if (strstr(user_agent, "Opera Mobi") != NULL) {
554         return 1;
555       } else if (strstr(user_agent, "Firefox/2.0.0 Opera 9.51 Beta") != NULL) {
556               /*  For some reason a new install of Opera 9.51beta decided to spoof. */
557           return 1;
558           }
559       return 0;
560 }
561
562
563 /*
564  * Entry point for WebCit transaction
565  */
566 void session_loop(HashList *HTTPHeaders, 
567                   StrBuf *ReqLine, 
568                   StrBuf *request_method, 
569                   StrBuf *ReadBuf,
570                   const char **Pos)
571 {
572         StrBuf *Buf;
573         const char *pch, *pchs, *pche;
574         void *vLine;
575         char action[1024];
576         char arg[8][128];
577         size_t sizes[10];
578         char *index[10];
579         char buf[SIZ];
580         int a, nBackDots, nEmpty;
581         int ContentLength = 0;
582         StrBuf *ContentType = NULL;
583         StrBuf *UrlLine = NULL;
584         StrBuf *content = NULL;
585         const char *content_end = NULL;
586         StrBuf *browser_host = NULL;
587         char user_agent[256];
588         int body_start = 0;
589         int is_static = 0;
590         int n_static = 0;
591         int len = 0;
592         void *vHandler;
593         WebcitHandler *Handler;
594         struct timeval tx_start;
595         struct timeval tx_finish;
596
597         /*
598          * We stuff these with the values coming from the client cookies,
599          * so we can use them to reconnect a timed out session if we have to.
600          */
601         StrBuf *c_username;
602         StrBuf *c_password;
603         StrBuf *c_roomname;
604         char c_httpauth_string[SIZ];
605         StrBuf *c_httpauth_user;
606         StrBuf *c_httpauth_pass;
607         wcsession *WCC;
608
609         gettimeofday(&tx_start, NULL);          /* start a stopwatch for performance timing */
610         
611         Buf = NewStrBuf();
612         c_username = NewStrBuf();
613         c_password = NewStrBuf();
614         c_roomname = NewStrBuf();
615         safestrncpy(c_httpauth_string, "", sizeof c_httpauth_string);
616         c_httpauth_user = NewStrBufPlain(HKEY(DEFAULT_HTTPAUTH_USER));
617         c_httpauth_pass = NewStrBufPlain(HKEY(DEFAULT_HTTPAUTH_PASS));
618
619         WCC= WC;
620         if (WCC->WBuf == NULL)
621                 WC->WBuf = NewStrBufPlain(NULL, 32768);
622         FlushStrBuf(WCC->WBuf);
623
624         if (WCC->HBuf == NULL)
625                 WCC->HBuf = NewStrBuf();
626         FlushStrBuf(WCC->HBuf);
627
628         WCC->upload_length = 0;
629         WCC->upload = NULL;
630         WCC->is_mobile = 0;
631         WCC->trailing_javascript = NewStrBuf();
632         WCC->nWildfireHeaders = 0;
633
634         /** Figure out the action */
635         index[0] = action;
636         sizes[0] = sizeof action;
637         for (a=1; a<9; a++)
638         {
639                 index[a] = arg[a-1];
640                 sizes[a] = sizeof arg[a-1];
641         }
642         nBackDots = 0;
643         nEmpty = 0;
644         for ( a = 0; a < 9; ++a)
645         {
646                 extract_token(index[a], ChrPtr(ReqLine), a + 1, '/', sizes[a]);
647                 if (strstr(index[a], "?")) *strstr(index[a], "?") = 0;
648                 if (strstr(index[a], "&")) *strstr(index[a], "&") = 0;
649                 if (strstr(index[a], " ")) *strstr(index[a], " ") = 0;
650                 if ((index[a][0] == '.') && (index[a][1] == '.'))
651                         nBackDots++;
652                 if (index[a][0] == '\0')
653                         nEmpty++;
654         }
655
656
657         if (GetHash(HTTPHeaders, HKEY("COOKIE"), &vLine) && 
658             (vLine != NULL)){
659                 cookie_to_stuff((StrBuf *)vLine, NULL,
660                                 c_username,
661                                 c_password,
662                                 c_roomname);
663         }
664         if (GetHash(HTTPHeaders, HKEY("AUTHORIZATION"), &vLine) &&
665             (vLine!=NULL)) {
666                 StrBufDecodeBase64((StrBuf*)vLine);
667                 StrBufExtract_token(c_httpauth_user, (StrBuf*)vLine, 0, ':');
668                 StrBufExtract_token(c_httpauth_pass, (StrBuf*)vLine, 1, ':');
669         }
670         if (GetHash(HTTPHeaders, HKEY("CONTENT-LENGTH"), &vLine) &&
671             (vLine!=NULL)) {
672                 ContentLength = StrToi((StrBuf*)vLine);
673         }
674         if (GetHash(HTTPHeaders, HKEY("CONTENT-TYPE"), &vLine) &&
675             (vLine!=NULL)) {
676                 ContentType = (StrBuf*)vLine;
677         }
678         if (GetHash(HTTPHeaders, HKEY("USER-AGENT"), &vLine) &&
679             (vLine!=NULL)) {
680                 safestrncpy(user_agent, ChrPtr((StrBuf*)vLine), sizeof user_agent);
681 #ifdef TECH_PREVIEW
682                 if ((WCC->is_mobile < 0) && is_mobile_ua(&buf[12])) {                   
683                         WCC->is_mobile = 1;
684                 }
685                 else {
686                         WCC->is_mobile = 0;
687                 }
688 #endif
689         }
690         if ((follow_xff) &&
691             GetHash(HTTPHeaders, HKEY("X-FORWARDED-HOST"), &vLine) &&
692             (vLine != NULL)) {
693                 WCC->http_host = (StrBuf*)vLine;
694         }
695         if ((StrLength(WCC->http_host) == 0) && 
696             GetHash(HTTPHeaders, HKEY("HOST"), &vLine) &&
697             (vLine!=NULL)) {
698                 WCC->http_host = (StrBuf*)vLine;
699         }
700
701         if (GetHash(HTTPHeaders, HKEY("X-FORWARDED-FOR"), &vLine) &&
702             (vLine!=NULL)) {
703                 browser_host = (StrBuf*) vLine;
704
705                 while (StrBufNum_tokens(browser_host, ',') > 1) {
706                         StrBufRemove_token(browser_host, 0, ',');
707                 }
708                 StrBufTrim(browser_host);
709         }
710
711         if (ContentLength > 0) {
712                 content = NewStrBuf();
713                 StrBufPrintf(content, "Content-type: %s\n"
714                          "Content-length: %d\n\n",
715                          ChrPtr(ContentType), ContentLength);
716 /*
717                 hprintf("Content-type: %s\n"
718                         "Content-length: %d\n\n",
719                         ContentType, ContentLength);
720 */
721                 body_start = StrLength(content);
722
723                 /** Read the entire input data at once. */
724                 client_read_to(&WCC->http_sock, 
725                                content, 
726                                ReadBuf, Pos,
727                                ContentLength,
728                                SLEEPING);
729
730                 if (!strncasecmp(ChrPtr(ContentType), "application/x-www-form-urlencoded", 33)) {
731                         StrBufCutLeft(content, body_start);
732                         ParseURLParams(content);
733                 } else if (!strncasecmp(ChrPtr(ContentType), "multipart", 9)) {
734                         content_end = ChrPtr(content) + ContentLength + body_start;
735                         mime_parser(ChrPtr(content), content_end, *upload_handler, NULL, NULL, NULL, 0);
736                 }
737         } else {
738                 content = NULL;
739         }
740
741         /* make a note of where we are in case the user wants to save it */
742         WCC->this_page = NewStrBufDup(ReqLine);
743         StrBufRemove_token(WCC->this_page, 2, ' ');
744         StrBufRemove_token(WCC->this_page, 0, ' ');
745
746         /* If there are variables in the URL, we must grab them now */
747         UrlLine = NewStrBufDup(ReqLine);
748         len = StrLength(UrlLine);
749         pch = pchs = ChrPtr(UrlLine);
750         pche = pchs + len;
751         while (pch < pche) {
752                 if ((*pch == '?') || (*pch == '&')) {
753                         StrBufCutLeft(UrlLine, pch - pchs + 1);
754                         ParseURLParams(UrlLine);
755                         break;
756                 }
757                 pch ++;
758         }
759         FreeStrBuf(&UrlLine);
760
761         /* If it's a "force 404" situation then display the error and bail. */
762         if (!strcmp(action, "404")) {
763                 hprintf("HTTP/1.1 404 Not found\r\n");
764                 hprintf("Content-Type: text/plain\r\n");
765                 wprintf("Not found\r\n");
766                 end_burst();
767                 goto SKIP_ALL_THIS_CRAP;
768         }
769
770         /* Static content can be sent without connecting to Citadel. */
771         is_static = 0;
772         for (a=0; a<ndirs && ! is_static; ++a) {
773                 if (!strcasecmp(action, (char*)static_content_dirs[a])) { /* map web to disk location */
774                         is_static = 1;
775                         n_static = a;
776                 }
777         }
778         if (is_static) {
779                 if (nBackDots < 2)
780                 {
781                         snprintf(buf, sizeof buf, "%s/%s/%s/%s/%s/%s/%s/%s",
782                                  static_dirs[n_static], 
783                                  index[1], index[2], index[3], index[4], index[5], index[6], index[7]);
784                         for (a=0; a<8; ++a) {
785                                 if (buf[strlen(buf)-1] == '/') {
786                                         buf[strlen(buf)-1] = 0;
787                                 }
788                         }
789                         for (a = 0; a < strlen(buf); ++a) {
790                                 if (isspace(buf[a])) {
791                                         buf[a] = 0;
792                                 }
793                         }
794                         output_static(buf);
795                 }
796                 else 
797                 {
798                         lprintf(9, "Suspicious request. Ignoring.");
799                         hprintf("HTTP/1.1 404 Security check failed\r\n");
800                         hprintf("Content-Type: text/plain\r\n\r\n");
801                         wprintf("You have sent a malformed or invalid request.\r\n");
802                         end_burst();
803                 }
804                 goto SKIP_ALL_THIS_CRAP;        /* Don't try to connect */
805         }
806
807         /* If the client sent a nonce that is incorrect, kill the request. */
808         if (havebstr("nonce")) {
809                 lprintf(9, "Comparing supplied nonce %s to session nonce %ld\n", 
810                         bstr("nonce"), WCC->nonce);
811                 if (ibstr("nonce") != WCC->nonce) {
812                         lprintf(9, "Ignoring request with mismatched nonce.\n");
813                         hprintf("HTTP/1.1 404 Security check failed\r\n");
814                         hprintf("Content-Type: text/plain\r\n\r\n");
815                         wprintf("Security check failed.\r\n");
816                         end_burst();
817                         goto SKIP_ALL_THIS_CRAP;
818                 }
819         }
820
821         /*
822          * If we're not connected to a Citadel server, try to hook up the
823          * connection now.
824          */
825         if (!WCC->connected) {
826                 if (WCC->ReadBuf == NULL)
827                         WCC->ReadBuf = NewStrBuf();
828                 if (!strcasecmp(ctdlhost, "uds")) {
829                         /* unix domain socket */
830                         snprintf(buf, SIZ, "%s/citadel.socket", ctdlport);
831                         WCC->serv_sock = uds_connectsock(buf);
832                 }
833                 else {
834                         /* tcp socket */
835                         WCC->serv_sock = tcp_connectsock(ctdlhost, ctdlport);
836                 }
837
838                 if (WCC->serv_sock < 0) {
839                         do_logout();
840                         FreeStrBuf(&WCC->ReadBuf);
841                         goto SKIP_ALL_THIS_CRAP;
842                 }
843                 else {
844                         WCC->connected = 1;
845                         serv_getln(buf, sizeof buf);    /* get the server greeting */
846
847                         /* Are there too many users already logged in? */
848                         if (!strncmp(buf, "571", 3)) {
849                                 wprintf(_("This server is already serving its maximum number of users and cannot accept any additional logins at this time.  Please try again later or contact your system administrator."));
850                                 end_burst();
851                                 end_webcit_session();
852                                 goto SKIP_ALL_THIS_CRAP;
853                         }
854
855                         /*
856                          * From what host is our user connecting?  Go with
857                          * the host at the other end of the HTTP socket,
858                          * unless we are following X-Forwarded-For: headers
859                          * and such a header has already turned up something.
860                          */
861                         if ( (!follow_xff) || (StrLength(browser_host) == 0) ) {
862                                 if (browser_host == NULL) {
863                                         browser_host = NewStrBuf();
864                                         Put(HTTPHeaders, HKEY("FreeMeWithTheOtherHeaders"), 
865                                             browser_host, HFreeStrBuf);
866                                 }
867                                 locate_host(browser_host, WCC->http_sock);
868                         }
869                         if (WCC->serv_info == NULL)
870                                 WCC->serv_info = get_serv_info(browser_host, user_agent);
871                         if (WCC->serv_info == NULL){
872                                 begin_burst();
873                                 wprintf(_("Received unexpected answer from Citadel "
874                                           "server; bailing out."));
875                                 hprintf("HTTP/1.1 200 OK\r\n");
876                                 hprintf("Content-type: text/plain; charset=utf-8\r\n");
877                                 end_burst();
878                                 end_webcit_session();
879                                 goto SKIP_ALL_THIS_CRAP;
880                         }
881                         if (WCC->serv_info->serv_rev_level < MINIMUM_CIT_VERSION) {
882                                 begin_burst();
883                                 wprintf(_("You are connected to a Citadel "
884                                         "server running Citadel %d.%02d. \n"
885                                         "In order to run this version of WebCit "
886                                         "you must also have Citadel %d.%02d or"
887                                         " newer.\n\n\n"),
888                                                 WCC->serv_info->serv_rev_level / 100,
889                                                 WCC->serv_info->serv_rev_level % 100,
890                                                 MINIMUM_CIT_VERSION / 100,
891                                                 MINIMUM_CIT_VERSION % 100
892                                         );
893                                 hprintf("HTTP/1.1 200 OK\r\n");
894                                 hprintf("Content-type: text/plain; charset=utf-8\r\n");
895                                 end_burst();
896                                 end_webcit_session();
897                                 goto SKIP_ALL_THIS_CRAP;
898                         }
899                 }
900         }
901
902         /*
903          * Functions which can be performed without logging in
904          */
905         if (!strcasecmp(action, "listsub")) {
906                 do_listsub();
907                 goto SKIP_ALL_THIS_CRAP;
908         }
909         if (!strcasecmp(action, "freebusy")) {
910                 do_freebusy(ChrPtr(ReqLine));
911                 goto SKIP_ALL_THIS_CRAP;
912         }
913
914         /*
915          * If we're not logged in, but we have HTTP Authentication data,
916          * try logging in to Citadel using that.
917          */
918         if ((!WCC->logged_in)
919             && (StrLength(c_httpauth_user) > 0)
920             && (StrLength(c_httpauth_pass) > 0))
921         {
922                 FlushStrBuf(Buf);
923                 serv_printf("USER %s", ChrPtr(c_httpauth_user));
924                 StrBuf_ServGetln(Buf);
925                 if (GetServerStatus(Buf, NULL) == 3) {
926                         serv_printf("PASS %s", ChrPtr(c_httpauth_pass));
927                         StrBuf_ServGetln(Buf);
928                         if (GetServerStatus(Buf, NULL) == 2) {
929                                 become_logged_in(c_httpauth_user,
930                                                 c_httpauth_pass, Buf);
931                                 if (WCC->httpauth_user == NULL)
932                                         WCC->httpauth_user = NewStrBufDup(c_httpauth_user);
933                                 else {
934                                         FlushStrBuf(WCC->httpauth_user);
935                                         StrBufAppendBuf(WCC->httpauth_user, c_httpauth_user, 0);
936                                 }
937                                 if (WCC->httpauth_pass == NULL)
938                                         WCC->httpauth_pass = NewStrBufDup(c_httpauth_pass);
939                                 else {
940                                         FlushStrBuf(WCC->httpauth_pass);
941                                         StrBufAppendBuf(WCC->httpauth_pass, c_httpauth_pass, 0);
942                                 }
943                         } else {
944                                 /* Should only display when password is wrong */
945                                 authorization_required(&buf[4]);
946                                 FreeStrBuf(&Buf);
947                                 goto SKIP_ALL_THIS_CRAP;
948                         }
949                 }
950         }
951
952         /* This needs to run early */
953 #ifdef TECH_PREVIEW
954         if (!strcasecmp(action, "rss")) {
955                 display_rss(sbstr("room"), request_method);
956                 goto SKIP_ALL_THIS_CRAP;
957         }
958 #endif
959
960         /* 
961          * The GroupDAV stuff relies on HTTP authentication instead of
962          * our session's authentication.
963          */
964         if (!strncasecmp(action, "groupdav", 8)) {
965                 groupdav_main(HTTPHeaders, 
966                               ReqLine, request_method,
967                               ContentType, /* do GroupDAV methods */
968                               ContentLength, content, body_start);
969                 if (!WCC->logged_in) {
970                         WCC->killthis = 1;      /* If not logged in, don't */
971                 }                               /* keep the session active */
972                 goto SKIP_ALL_THIS_CRAP;
973         }
974
975
976         /*
977          * Automatically send requests with any method other than GET or
978          * POST to the GroupDAV code as well.
979          */
980         if ((strcasecmp(ChrPtr(request_method), "GET")) && (strcasecmp(ChrPtr(request_method), "POST"))) {
981                 groupdav_main(HTTPHeaders, ReqLine, 
982                               request_method, ContentType, /** do GroupDAV methods */
983                               ContentLength, content, body_start);
984                 if (!WCC->logged_in) {
985                         WCC->killthis = 1;      /** If not logged in, don't */
986                 }                               /** keep the session active */
987                 goto SKIP_ALL_THIS_CRAP;
988         }
989
990         /*
991          * If we're not logged in, but we have username and password cookies
992          * supplied by the browser, try using them to log in.
993          */
994         if ((!WCC->logged_in)
995            && (StrLength(c_username)>0)
996            && (StrLength(c_password)>0)) {
997                 serv_printf("USER %s", ChrPtr(c_username));
998                 StrBuf_ServGetln(Buf);
999                 if (GetServerStatus(Buf, NULL) == 3) {
1000                         serv_printf("PASS %s", ChrPtr(c_password));
1001                         StrBuf_ServGetln(Buf);
1002                         if (GetServerStatus(Buf, NULL) == 2) {
1003                                 become_logged_in(c_username, c_password, Buf);
1004                                 get_preference("default_header_charset", &WCC->DefaultCharset);
1005                         }
1006                 }
1007         }
1008
1009         /*
1010          * If a 'gotofirst' parameter has been specified, attempt to goto that room
1011          * prior to doing anything else.
1012          */
1013         if (havebstr("gotofirst")) {
1014                 gotoroom(sbstr("gotofirst"));   /* do this quietly to avoid session output! */
1015         }
1016
1017         /*
1018          * If we don't have a current room, but a cookie specifying the
1019          * current room is supplied, make an effort to go there.
1020          */
1021         if ((StrLength(WCC->wc_roomname) == 0) && (StrLength(c_roomname) > 0)) {
1022                 serv_printf("GOTO %s", ChrPtr(c_roomname));
1023                 StrBuf_ServGetln(Buf);
1024                 if (GetServerStatus(Buf, NULL) == 2) {
1025                         if (WCC->wc_roomname == NULL) {
1026                                 WCC->wc_roomname = NewStrBufDup(c_roomname);
1027                         }
1028                         else {
1029                                 FlushStrBuf(WCC->wc_roomname);
1030                                 StrBufAppendBuf(WCC->wc_roomname, c_roomname, 0);
1031                         }
1032                 }
1033         }
1034         
1035         GetHash(HandlerHash, action, strlen(action) /* TODO*/, &vHandler),
1036                 Handler = (WebcitHandler*) vHandler;
1037         if (Handler != NULL) {
1038                 if (!WCC->logged_in && ((Handler->Flags & ANONYMOUS) == 0)) {
1039                         display_login(NULL);
1040                 }
1041                 else {
1042                         if((Handler->Flags & NEED_URL)) {
1043                                 if (WCC->UrlFragment1 == NULL)
1044                                         WCC->UrlFragment1 = NewStrBuf();
1045                                 if (WCC->UrlFragment2 == NULL)
1046                                         WCC->UrlFragment2 = NewStrBuf();
1047                                 if (WCC->UrlFragment3 == NULL)
1048                                         WCC->UrlFragment3 = NewStrBuf();
1049                                 if (WCC->UrlFragment4 == NULL)
1050                                         WCC->UrlFragment4 = NewStrBuf();
1051                                 StrBufPlain(WCC->UrlFragment1, index[0], -1);
1052                                 StrBufPlain(WCC->UrlFragment2, index[1], -1);
1053                                 StrBufPlain(WCC->UrlFragment3, index[2], -1);
1054                                 StrBufPlain(WCC->UrlFragment4, index[3], -1);
1055                         }
1056                         if ((Handler->Flags & AJAX) != 0)
1057                                 begin_ajax_response();
1058                         Handler->F();
1059                         if ((Handler->Flags & AJAX) != 0)
1060                                 end_ajax_response();
1061                 }
1062         }
1063         /* When all else fais, display the main menu. */
1064         else {
1065                 if (!WCC->logged_in) 
1066                         display_login(NULL);
1067                 else
1068                         display_main_menu();
1069         }
1070
1071 SKIP_ALL_THIS_CRAP:
1072         if (WCC->SavePrefsToServer) {
1073                 save_preferences();
1074                 WCC->SavePrefsToServer = 0;
1075         }
1076         FreeStrBuf(&Buf);
1077         FreeStrBuf(&c_username);
1078         FreeStrBuf(&c_password);
1079         FreeStrBuf(&c_roomname);
1080         FreeStrBuf(&c_httpauth_user);
1081         FreeStrBuf(&c_httpauth_pass);
1082         FreeStrBuf(&WCC->this_page);
1083         fflush(stdout);
1084         if (content != NULL) {
1085                 FreeStrBuf(&content);
1086                 content = NULL;
1087         }
1088         DeleteHash(&WCC->urlstrings);
1089         if (WCC->upload_length > 0) {
1090                 free(WCC->upload);
1091                 WCC->upload_length = 0;
1092         }
1093         FreeStrBuf(&WCC->trailing_javascript);
1094         WCC->http_host = NULL;
1095
1096         /* How long did this transaction take? */
1097         gettimeofday(&tx_finish, NULL);
1098         
1099         lprintf(9, "Transaction completed in %ld.%06ld seconds.\n",
1100                 ((tx_finish.tv_sec*1000000 + tx_finish.tv_usec) - (tx_start.tv_sec*1000000 + tx_start.tv_usec)) / 1000000,
1101                 ((tx_finish.tv_sec*1000000 + tx_finish.tv_usec) - (tx_start.tv_sec*1000000 + tx_start.tv_usec)) % 1000000
1102         );
1103 }
1104
1105
1106 /*
1107  * Replacement for sleep() that uses select() in order to avoid SIGALRM
1108  */
1109 void sleeeeeeeeeep(int seconds)
1110 {
1111         struct timeval tv;
1112
1113         tv.tv_sec = seconds;
1114         tv.tv_usec = 0;
1115         select(0, NULL, NULL, NULL, &tv);
1116 }
1117
1118
1119 int ConditionalImportantMesage(StrBuf *Target, WCTemplputParams *TP)
1120 {
1121         wcsession *WCC = WC;
1122         if (WCC != NULL)
1123                 return ((!IsEmptyStr(WCC->ImportantMessage)) || 
1124                         (StrLength(WCC->ImportantMsg) > 0));
1125         else
1126                 return 0;
1127 }
1128
1129 void tmplput_importantmessage(StrBuf *Target, WCTemplputParams *TP)
1130 {
1131         wcsession *WCC = WC;
1132         
1133         if (WCC != NULL) {
1134                 if (!IsEmptyStr(WCC->ImportantMessage)) {
1135                         StrEscAppend(Target, NULL, WCC->ImportantMessage, 0, 0);
1136                         WCC->ImportantMessage[0] = '\0';
1137                 }
1138                 else if (StrLength(WCC->ImportantMsg) > 0) {
1139                         StrEscAppend(Target, WCC->ImportantMsg, NULL, 0, 0);
1140                         FlushStrBuf(WCC->ImportantMsg);
1141                 }
1142         }
1143 }
1144
1145 void tmplput_trailing_javascript(StrBuf *Target, WCTemplputParams *TP)
1146 {
1147         wcsession *WCC = WC;
1148
1149         if (WCC != NULL)
1150                 StrBufAppendTemplate(Target, TP, WCC->trailing_javascript, 0);
1151 }
1152
1153 void tmplput_csslocal(StrBuf *Target, WCTemplputParams *TP)
1154 {
1155         extern StrBuf *csslocal;
1156         StrBufAppendBuf(Target, 
1157                         csslocal, 0);
1158 }
1159
1160
1161
1162
1163 void 
1164 InitModule_WEBCIT
1165 (void)
1166 {
1167         WebcitAddUrlHandler(HKEY("blank"), blank_page, ANONYMOUS);
1168         WebcitAddUrlHandler(HKEY("do_template"), url_do_template, ANONYMOUS);
1169         WebcitAddUrlHandler(HKEY("sslg"), seconds_since_last_gexp, AJAX);
1170         WebcitAddUrlHandler(HKEY("ajax_servcmd"), ajax_servcmd, 0);
1171
1172         RegisterConditional(HKEY("COND:IMPMSG"), 0, ConditionalImportantMesage, CTX_NONE);
1173         RegisterNamespace("CSSLOCAL", 0, 0, tmplput_csslocal, CTX_NONE);
1174         RegisterNamespace("IMPORTANTMESSAGE", 0, 0, tmplput_importantmessage, CTX_NONE);
1175         RegisterNamespace("TRAILING_JAVASCRIPT", 0, 0, tmplput_trailing_javascript, CTX_NONE);
1176 }