X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=webcit%2Fmessages.c;h=cd10b6a74091279cb7f603d78e7ad9b4f601b2ae;hb=63cbcbf7992bdf6e0b0eb04db4b92476a609d543;hp=fd9c6e8b075de8f5ad5cd96aeace44e3eb173310;hpb=f53035ceb017c0f02a978077bc1607e73a25068f;p=citadel.git diff --git a/webcit/messages.c b/webcit/messages.c index fd9c6e8b0..cd10b6a74 100644 --- a/webcit/messages.c +++ b/webcit/messages.c @@ -12,28 +12,22 @@ HashList *MsgHeaderHandler = NULL; HashList *MsgEvaluators = NULL; HashList *MimeRenderHandler = NULL; +HashList *ReadLoopHandler = NULL; int dbg_analyze_msg = 0; -#define SUBJ_COL_WIDTH_PCT 50 /**< Mailbox view column width */ -#define SENDER_COL_WIDTH_PCT 30 /**< Mailbox view column width */ -#define DATE_PLUS_BUTTONS_WIDTH_PCT 20 /**< Mailbox view column width */ +#define SUBJ_COL_WIDTH_PCT 50 /* Mailbox view column width */ +#define SENDER_COL_WIDTH_PCT 30 /* Mailbox view column width */ +#define DATE_PLUS_BUTTONS_WIDTH_PCT 20 /* Mailbox view column width */ void jsonMessageListHdr(void); void display_enter(void); -/*----------------------------------------------------------------------------*/ - - typedef void (*MsgPartEvaluatorFunc)(message_summary *Sum, StrBuf *Buf); typedef struct _MsgPartEvaluatorStruct { MsgPartEvaluatorFunc f; -}MsgPartEvaluatorStruct; - - -/*----------------------------------------------------------------------------*/ - +} MsgPartEvaluatorStruct; int load_message(message_summary *Msg, StrBuf *FoundCharset, @@ -49,11 +43,13 @@ int load_message(message_summary *Msg, int state=0; Buf = NewStrBuf(); - lprintf(1, "-------------------MSG4 %ld|%s--------------\n", Msg->msgnum, ChrPtr(Msg->PartNum)); - if (Msg->PartNum != NULL) + lprintf(9, "MSG4 %ld|%s\n", Msg->msgnum, ChrPtr(Msg->PartNum)); + if (Msg->PartNum != NULL) { serv_printf("MSG4 %ld|%s", Msg->msgnum, ChrPtr(Msg->PartNum)); - else + } + else { serv_printf("MSG4 %ld", Msg->msgnum); + } StrBuf_ServGetln(Buf); if (GetServerStatus(Buf, NULL) != 1) { @@ -65,9 +61,9 @@ int load_message(message_summary *Msg, return 0; } - /** begin everythingamundo table */ + /* begin everythingamundo table */ HdrToken = NewStrBuf(); - while ((StrBuf_ServGetln(Buf)>=0) && !Done) { + while (!Done && StrBuf_ServGetln(Buf)>=0) { if ( (StrLength(Buf)==3) && !strcmp(ChrPtr(Buf), "000")) { @@ -206,7 +202,7 @@ int load_message(message_summary *Msg, * printable_view Nonzero to display a printable view * section Optional for encapsulated message/rfc822 submessage */ -int read_message(StrBuf *Target, const char *tmpl, long tmpllen, long msgnum, const StrBuf *PartNum) +int read_message(StrBuf *Target, const char *tmpl, long tmpllen, long msgnum, const StrBuf *PartNum, const StrBuf **OutMime) { StrBuf *Buf; StrBuf *FoundCharset; @@ -234,10 +230,12 @@ int read_message(StrBuf *Target, const char *tmpl, long tmpllen, long msgnum, co FreeStrBuf(&Error); } - /* strip the bare contenttype, so we ommit charset etc. */ + /* Extract just the content-type (omit attributes such as "charset") */ StrBufExtract_token(Buf, Msg->MsgBody->ContentType, 0, ';'); StrBufTrim(Buf); - /* look up the renderer, that will convert this mimeitem into the htmlized form */ + StrBufLowerCase(Buf); + + /* Locate a renderer capable of converting this MIME part into HTML */ if (GetHash(MimeRenderHandler, SKEY(Buf), &vHdr) && (vHdr != NULL)) { RenderMimeFuncStruct *Render; @@ -267,7 +265,7 @@ int read_message(StrBuf *Target, const char *tmpl, long tmpllen, long msgnum, co memset(&SubTP, 0, sizeof(WCTemplputParams)); SubTP.Filter.ContextType = CTX_MAILSUM; SubTP.Context = Msg; - DoTemplate(tmpl, tmpllen, Target, &SubTP); + *OutMime = DoTemplate(tmpl, tmpllen, Target, &SubTP); DestroyMessageSummary(Msg); FreeStrBuf(&FoundCharset); @@ -276,38 +274,199 @@ int read_message(StrBuf *Target, const char *tmpl, long tmpllen, long msgnum, co } +void +HttpStatus(long CitadelStatus) +{ + long httpstatus = 502; + + switch (MAJORCODE(CitadelStatus)) + { + case LISTING_FOLLOWS: + case CIT_OK: + httpstatus = 201; + break; + case ERROR: + switch (MINORCODE(CitadelStatus)) + { + case INTERNAL_ERROR: + httpstatus = 403; + break; + + case TOO_BIG: + case ILLEGAL_VALUE: + case HIGHER_ACCESS_REQUIRED: + case MAX_SESSIONS_EXCEEDED: + case RESOURCE_BUSY: + case RESOURCE_NOT_OPEN: + case NOT_HERE: + case INVALID_FLOOR_OPERATION: + case FILE_NOT_FOUND: + case ROOM_NOT_FOUND: + httpstatus = 409; + break; + case MESSAGE_NOT_FOUND: + case ALREADY_EXISTS: + httpstatus = 403; + break; + case NO_SUCH_SYSTEM: + httpstatus = 502; + break; + + default: + case CMD_NOT_SUPPORTED: + case PASSWORD_REQUIRED: + case ALREADY_LOGGED_IN: + case USERNAME_REQUIRED: + case NOT_LOGGED_IN: + case SERVER_SHUTTING_DOWN: + case NO_SUCH_USER: + case ASYNC_GEXP: + httpstatus = 502; + break; + } + break; + + default: + case BINARY_FOLLOWS: + case SEND_BINARY: + case START_CHAT_MODE: + case ASYNC_MSG: + case MORE_DATA: + case SEND_LISTING: + httpstatus = 502; /* aeh... whut? */ + break; + } + + +} + +/* + * Unadorned HTML output of an individual message, suitable + * for placing in a hidden iframe, for printing, or whatever + */ +void handle_one_message(void) +{ + long CitStatus; + int CopyMessage = 0; + const StrBuf *Destination; + void *vLine; + const StrBuf *Mime; + long msgnum = 0L; + wcsession *WCC = WC; + const StrBuf *Tmpl; + StrBuf *CmdBuf = NULL; + const char *pMsg; + + + pMsg = strchr(ChrPtr(WCC->Hdr->HR.ReqLine), '/'); + if (pMsg == NULL) { + HttpStatus(CitStatus); + return; + } + + msgnum = atol(pMsg + 1); + StrBufCutAt(WCC->Hdr->HR.ReqLine, 0, pMsg); + gotoroom(WCC->Hdr->HR.ReqLine); + switch (WCC->Hdr->HR.eReqType) + { + case eGET: + case ePOST: + Tmpl = sbstr("template"); + if (StrLength(Tmpl) > 0) + read_message(WCC->WBuf, SKEY(Tmpl), msgnum, NULL, &Mime); + else + read_message(WCC->WBuf, HKEY("view_message"), msgnum, NULL, &Mime); + http_transmit_thing(ChrPtr(Mime), 0); + break; + case eDELETE: + CmdBuf = NewStrBuf (); + if (WCC->wc_is_trash) { /* Delete from Trash is a real delete */ + serv_printf("DELE %ld", msgnum); + } + else { /* Otherwise move it to Trash */ + serv_printf("MOVE %ld|_TRASH_|0", msgnum); + } + StrBuf_ServGetln(CmdBuf); + FlushStrBuf(WCC->ImportantMsg); + StrBufAppendBuf(WCC->ImportantMsg, CmdBuf, 4); + GetServerStatus(CmdBuf, &CitStatus); + HttpStatus(CitStatus); + break; + case eCOPY: + CopyMessage = 1; + case eMOVE: + if (GetHash(WCC->Hdr->HTTPHeaders, HKEY("DESTINATION"), &vLine) && + (vLine!=NULL)) { + Destination = (StrBuf*) vLine; + serv_printf("MOVE %ld|%s|%d", msgnum, ChrPtr(Destination), CopyMessage); + StrBuf_ServGetln(CmdBuf); + FlushStrBuf(WCC->ImportantMsg); + StrBufAppendBuf(WCC->ImportantMsg, CmdBuf, 4); + GetServerStatus(CmdBuf, &CitStatus); + HttpStatus(CitStatus); + } + else + HttpStatus(500); + break; + default: + break; + + } +} /* * Unadorned HTML output of an individual message, suitable * for placing in a hidden iframe, for printing, or whatever - * - * msgnum_as_string == Message number, as a string instead of as a long int */ void embed_message(void) { + const StrBuf *Mime; long msgnum = 0L; wcsession *WCC = WC; - const StrBuf *Tmpl = sbstr("template"); + const StrBuf *Tmpl; + StrBuf *CmdBuf = NULL; - msgnum = StrTol(WCC->UrlFragment2); - if (StrLength(Tmpl) > 0) - read_message(WCC->WBuf, SKEY(Tmpl), msgnum, NULL); - else - read_message(WCC->WBuf, HKEY("view_message"), msgnum, NULL); + msgnum = StrBufExtract_long(WCC->Hdr->HR.ReqLine, 0, '/'); + switch (WCC->Hdr->HR.eReqType) + { + case eGET: + case ePOST: + Tmpl = sbstr("template"); + if (StrLength(Tmpl) > 0) + read_message(WCC->WBuf, SKEY(Tmpl), msgnum, NULL, &Mime); + else + read_message(WCC->WBuf, HKEY("view_message"), msgnum, NULL, &Mime); + http_transmit_thing(ChrPtr(Mime), 0); + break; + case eDELETE: + CmdBuf = NewStrBuf (); + if (WCC->wc_is_trash) { /* Delete from Trash is a real delete */ + serv_printf("DELE %ld", msgnum); + } + else { /* Otherwise move it to Trash */ + serv_printf("MOVE %ld|_TRASH_|0", msgnum); + } + StrBuf_ServGetln(CmdBuf); + FlushStrBuf(WCC->ImportantMsg); + StrBufAppendBuf(WCC->ImportantMsg, CmdBuf, 4); + break; + default: + break; + + } } /* * Printable view of a message - * - * msgnum_as_string == Message number, as a string instead of as a long int */ void print_message(void) { long msgnum = 0L; + const StrBuf *Mime; - msgnum = StrTol(WC->UrlFragment2); + msgnum = StrBufExtract_long(WC->Hdr->HR.ReqLine, 0, '/'); output_headers(0, 0, 0, 0, 0, 0); hprintf("Content-type: text/html\r\n" @@ -316,36 +475,35 @@ void print_message(void) { begin_burst(); - read_message(WC->WBuf, HKEY("view_message_print"), msgnum, NULL); + read_message(WC->WBuf, HKEY("view_message_print"), msgnum, NULL, &Mime); wDumpContent(0); } /* * Mobile browser view of message - * - * @param msg_num_as_string Message number as a string instead of as a long int */ -void mobile_message_view(void) { - long msgnum = 0L; - msgnum = StrTol(WC->UrlFragment2); - output_headers(1, 0, 0, 0, 0, 1); - begin_burst(); - do_template("msgcontrols", NULL); - read_message(WC->WBuf, HKEY("view_message"), msgnum, NULL); - wDumpContent(0); +void mobile_message_view(void) +{ + long msgnum = 0L; + const StrBuf *Mime; + + msgnum = StrBufExtract_long(WC->Hdr->HR.ReqLine, 0, '/'); + output_headers(1, 0, 0, 0, 0, 1); + begin_burst(); + do_template("msgcontrols", NULL); + read_message(WC->WBuf, HKEY("view_message"), msgnum, NULL, &Mime); + wDumpContent(0); } -/** - * \brief Display a message's headers - * - * \param msgnum_as_string Message number, as a string instead of as a long int +/* + * Display a message's headers */ void display_headers(void) { long msgnum = 0L; char buf[1024]; - msgnum = StrTol(WC->UrlFragment2); + msgnum = StrBufExtract_long(WC->Hdr->HR.ReqLine, 0, '/'); output_headers(0, 0, 0, 0, 0, 0); hprintf("Content-type: text/plain\r\n" @@ -358,7 +516,7 @@ void display_headers(void) { serv_getln(buf, sizeof buf); if (buf[0] == '1') { while (serv_getln(buf, sizeof buf), strcmp(buf, "000")) { - wprintf("%s\n", buf); + wc_printf("%s\n", buf); } } @@ -413,40 +571,37 @@ message_summary *ReadOneMessageSummary(StrBuf *RawMessage, const char *DefaultSu * load message pointers from the server for a "read messages" operation * * servcmd: the citadel command to send to the citserver - * with_headers: also include some of the headers with the message numbers (more expensive) */ -int load_msg_ptrs(const char *servcmd, int with_headers) +int load_msg_ptrs(const char *servcmd, SharedMessageStatus *Stat) { StrBuf* FoundCharset = NULL; wcsession *WCC = WC; message_summary *Msg; StrBuf *Buf, *Buf2; - int nummsgs = 0; - int maxload = 0; long len; int n; int skipit; const char *Ptr = NULL; + Stat->lowest_found = LONG_MAX; + Stat->highest_found = LONG_MIN; + if (WCC->summ != NULL) { DeleteHash(&WCC->summ); } WCC->summ = NewHash(1, Flathash); - maxload = 10000; Buf = NewStrBuf(); serv_puts(servcmd); StrBuf_ServGetln(Buf); if (GetServerStatus(Buf, NULL) != 1) { FreeStrBuf(&Buf); - return (nummsgs); + return (Stat->nummsgs); } Buf2 = NewStrBuf(); - while (len = StrBuf_ServGetln(Buf), - ((len != 3) || - strcmp(ChrPtr(Buf), "000")!= 0)) + while (len = StrBuf_ServGetln(Buf), ((len != 3) || strcmp(ChrPtr(Buf), "000")!= 0)) { - if (nummsgs < maxload) { + if (Stat->nummsgs < Stat->maxload) { skipit = 0; Ptr = NULL; Msg = (message_summary*)malloc(sizeof(message_summary)); @@ -454,12 +609,27 @@ int load_msg_ptrs(const char *servcmd, int with_headers) Msg->msgnum = StrBufExtractNext_long(Buf, &Ptr, '|'); Msg->date = StrBufExtractNext_long(Buf, &Ptr, '|'); + + if (Stat->nummsgs == 0) { + if (Msg->msgnum < Stat->lowest_found) { + Stat->lowest_found = Msg->msgnum; + } + if (Msg->msgnum > Stat->highest_found) { + Stat->highest_found = Msg->msgnum; + } + } + + if ((Msg->msgnum == 0) && (StrLength(Buf) < 32)) { + free(Msg); + continue; + } + /* * as citserver probably gives us messages in forward date sorting * nummsgs should be the same order as the message date. */ if (Msg->date == 0) { - Msg->date = nummsgs; + Msg->date = Stat->nummsgs; if (StrLength(Buf) < 32) skipit = 1; } @@ -467,11 +637,11 @@ int load_msg_ptrs(const char *servcmd, int with_headers) Msg->from = NewStrBufPlain(NULL, StrLength(Buf)); StrBufExtract_NextToken(Buf2, Buf, &Ptr, '|'); if (StrLength(Buf2) != 0) { - /** Handle senders with RFC2047 encoding */ + /* Handle senders with RFC2047 encoding */ StrBuf_RFC822_to_Utf8(Msg->from, Buf2, WCC->DefaultCharset, FoundCharset); } - /** Nodename */ + /* node name */ StrBufExtract_NextToken(Buf2, Buf, &Ptr, '|'); if ((StrLength(Buf2) !=0 ) && ( ((WCC->room_flags & QR_NETWORK) @@ -482,9 +652,9 @@ int load_msg_ptrs(const char *servcmd, int with_headers) StrBufAppendBuf(Msg->from, Buf2, 0); } - /** Not used: - StrBufExtract_token(Msg->inetaddr, Buf, 4, '|'); - */ + /* Internet address (not used) + * StrBufExtract_token(Msg->inetaddr, Buf, 4, '|'); + */ StrBufSkip_NTokenS(Buf, &Ptr, '|', 1); Msg->subj = NewStrBufPlain(NULL, StrLength(Buf)); StrBufExtract_NextToken(Buf2, Buf, &Ptr, '|'); @@ -499,7 +669,6 @@ int load_msg_ptrs(const char *servcmd, int with_headers) } } - if ((StrLength(Msg->from) > 25) && (StrBuf_Utf8StrLen(Msg->from) > 25)) { StrBuf_Utf8StrCut(Msg->from, 23); @@ -509,11 +678,11 @@ int load_msg_ptrs(const char *servcmd, int with_headers) n = Msg->msgnum; Put(WCC->summ, (const char *)&n, sizeof(n), Msg, DestroyMessageSummary); } - nummsgs++; + Stat->nummsgs++; } FreeStrBuf(&Buf2); FreeStrBuf(&Buf); - return (nummsgs); + return (Stat->nummsgs); } @@ -530,93 +699,6 @@ inline message_summary* GetMessagePtrAt(int n, HashList *Summ) } -long DrawMessageDropdown(StrBuf *Selector, long maxmsgs, long startmsg, int nMessages) -{ - StrBuf *TmpBuf; - wcsession *WCC = WC; - void *vMsg; - int lo, hi; - long ret; - long hklen; - const char *key; - int done = 0; - int nItems; - HashPos *At; - long vector[16]; - WCTemplputParams SubTP; - - memset(&SubTP, 0, sizeof(WCTemplputParams)); - SubTP.Filter.ContextType = CTX_LONGVECTOR; - SubTP.Context = &vector; - TmpBuf = NewStrBuf(); - At = GetNewHashPos(WCC->summ, nMessages); - nItems = GetCount(WCC->summ); - ret = nMessages; - vector[0] = 7; - vector[2] = 1; - vector[1] = startmsg; - vector[3] = 0; - - while (!done) { - vector[3] = abs(nMessages); - lo = GetHashPosCounter(At); - if (nMessages > 0) { - if (lo + nMessages >= nItems) { - hi = nItems - 1; - vector[3] = nItems - lo; - if (startmsg == lo) - ret = vector[3]; - } - else { - hi = lo + nMessages - 1; - } - } else { - if (lo + nMessages < -1) { - hi = 0; - } - else { - if ((lo % abs(nMessages)) != 0) { - int offset = (lo % abs(nMessages) * - (nMessages / abs(nMessages))); - hi = lo + offset; - vector[3] = abs(offset); - if (startmsg == lo) - ret = offset; - } - else - hi = lo + nMessages; - } - } - done = !GetNextHashPos(WCC->summ, At, &hklen, &key, &vMsg); - - /** - * Bump these because although we're thinking in zero base, the user - * is a drooling idiot and is thinking in one base. - */ - vector[4] = lo + 1; - vector[5] = hi + 1; - vector[6] = lo; - FlushStrBuf(TmpBuf); - dbg_print_longvector(vector); - DoTemplate(HKEY("select_messageindex"), TmpBuf, &SubTP); - StrBufAppendBuf(Selector, TmpBuf, 0); - } - vector[6] = 0; - FlushStrBuf(TmpBuf); - if (maxmsgs == 9999999) { - vector[1] = 1; - ret = maxmsgs; - } - else - vector[1] = 0; - vector[2] = 0; - dbg_print_longvector(vector); - DoTemplate(HKEY("select_messageindex_all"), TmpBuf, &SubTP); - StrBufAppendBuf(Selector, TmpBuf, 0); - FreeStrBuf(&TmpBuf); - DeleteHashPos(&At); - return ret; -} void load_seen_flags(void) { @@ -640,7 +722,7 @@ void load_seen_flags(void) } at = GetNewHashPos(WCC->summ, 0); while (GetNextHashPos(WCC->summ, at, &HKLen, &HashKey, &vMsg)) { - /** Are you a new message, or an old message? */ + /* Are you a new message, or an old message? */ Msg = (message_summary*) vMsg; if (is_msg_in_mset(ChrPtr(OldMsg), Msg->msgnum)) { Msg->is_new = 0; @@ -655,334 +737,155 @@ void load_seen_flags(void) extern readloop_struct rlid[]; +typedef struct _RoomRenderer{ + int RoomType; + + GetParamsGetServerCall_func GetParamsGetServerCall; + PrintViewHeader_func PrintViewHeader; + LoadMsgFromServer_func LoadMsgFromServer; + RenderView_or_Tail_func RenderView_or_Tail; + View_Cleanup_func ViewCleanup; +} RoomRenderer; + + /* * command loop for reading messages * - * Set oper to "readnew" or "readold" or "readfwd" or "headers" + * Set oper to "readnew" or "readold" or "readfwd" or "headers" or "readgt" or "do_search" */ void readloop(long oper) { - StrBuf *MessageDropdown = NULL; - StrBuf *BBViewToolBar = NULL; + RoomRenderer *ViewMsg; + void *vViewMsg; void *vMsg; message_summary *Msg; char cmd[256] = ""; - char buf[SIZ]; - int a = 0; - int with_headers = 0; - int nummsgs; - long startmsg = 0; - int maxmsgs = 0; - long *displayed_msgs = NULL; - int num_displayed = 0; - int is_singlecard = 0; - struct calview calv; - int i; - int lowest_displayed = (-1); - int highest_displayed = 0; - addrbookent *addrbook = NULL; - int num_ab = 0; - int bbs_reverse = 0; + int i, r; wcsession *WCC = WC; HashPos *at; const char *HashKey; long HKLen; - int care_for_empty_list = 0; - int load_seen = 0; - int sortit = 0; - int defaultsortorder = 0; WCTemplputParams SubTP; - char *ab_name; + SharedMessageStatus Stat; + void *ViewSpecific; - if (havebstr("is_summary") && (1 == (ibstr("is_summary")))) + if (havebstr("is_summary") && (1 == (ibstr("is_summary")))) { WCC->wc_view = VIEW_MAILBOX; - - if (!WCC->is_ajax) { - output_headers(1, 1, 1, 0, 0, 0); - } else if (WCC->wc_view == VIEW_MAILBOX) { - jsonMessageListHdr(); } - switch (WCC->wc_view) { - case VIEW_WIKI: - sprintf(buf, "wiki?room=%s&page=home", ChrPtr(WCC->wc_roomname)); - http_redirect(buf); + if ((oper == do_search) && (WCC->wc_view == VIEW_WIKI)) { + display_wiki_pagelist(); return; - case VIEW_CALBRIEF: - case VIEW_CALENDAR: - load_seen = 1; - strcpy(cmd, "MSGS ALL"); - maxmsgs = 32767; - parse_calendar_view_request(&calv); - break; - case VIEW_TASKS: - strcpy(cmd, "MSGS ALL"); - maxmsgs = 32767; - break; - case VIEW_NOTES: - strcpy(cmd, "MSGS ALL"); - maxmsgs = 32767; - wprintf("
\n"); - break; - case VIEW_ADDRESSBOOK: - is_singlecard = ibstr("is_singlecard"); - if (is_singlecard != 1) { - if (oper == do_search) { - snprintf(cmd, sizeof(cmd), "MSGS SEARCH|%s", bstr("query")); - } - else { - strcpy(cmd, "MSGS ALL"); - } - maxmsgs = 9999999; - break; - } - break; - case VIEW_MAILBOX: - if (!WCC->is_ajax) { - new_summary_view(); - return; - } else { - defaultsortorder = 2; - sortit = 1; - load_seen = 1; - care_for_empty_list = 0; - with_headers = 1; - /* Generally using maxmsgs|startmsg is not required - in mailbox view, but we have a 'safemode' for clients - (*cough* Exploder) that simply can't handle too many */ - if (havebstr("maxmsgs")) maxmsgs = ibstr("maxmsgs"); - else maxmsgs = 9999999; - if (havebstr("startmsg")) startmsg = lbstr("startmsg"); - snprintf(cmd, sizeof(cmd), "MSGS %s|%s||1", - (oper == do_search) ? "SEARCH" : "ALL", - (oper == do_search) ? bstr("query") : "" - ); - } - break; - case VIEW_BBS: - default: - defaultsortorder = 1; - startmsg = -1; - sortit = 1; - care_for_empty_list = 1; - - rlid[oper].cmd(cmd, sizeof(cmd)); - SetAccessCommand(oper); + } - if (havebstr("maxmsgs")) - maxmsgs = ibstr("maxmsgs"); - if (maxmsgs == 0) maxmsgs = DEFAULT_MAXMSGS; + memset(&Stat, 0, sizeof(SharedMessageStatus)); + Stat.maxload = 10000; + Stat.lowest_found = (-1); + Stat.highest_found = (-1); + GetHash(ReadLoopHandler, IKEY(WCC->wc_view), &vViewMsg); + if (vViewMsg == NULL) { + WCC->wc_view = VIEW_BBS; + GetHash(ReadLoopHandler, IKEY(WCC->wc_view), &vViewMsg); + } + if (vViewMsg == NULL) { + return; // TODO: print message + } - if (havebstr("startmsg")) { - startmsg = lbstr("startmsg"); - } - + ViewMsg = (RoomRenderer*) vViewMsg; + if (!WCC->is_ajax) { + output_headers(1, 1, 1, 0, 0, 0); + } else if (WCC->wc_view == VIEW_MAILBOX) { + jsonMessageListHdr(); } - nummsgs = load_msg_ptrs(cmd, with_headers); - if (nummsgs == 0) { - if (care_for_empty_list) { - wprintf("

"); - switch (oper) { - case readnew: - wprintf(_("No new messages.")); - break; - case readold: - wprintf(_("No old messages.")); - break; - default: - wprintf(_("No messages here.")); - } - wprintf("
\n"); - goto DONE; - } + if (ViewMsg->GetParamsGetServerCall != NULL) { + r = ViewMsg->GetParamsGetServerCall( + &Stat, + &ViewSpecific, + oper, + cmd, sizeof(cmd) + ); + } else { + r = 0; + } + switch(r) + { + case 400: + case 404: + return; + case 300: /* the callback hook should do the work for us here, since he knows what to do. */ + return; + case 200: + default: + break; } + if (!IsEmptyStr(cmd)) + Stat.nummsgs = load_msg_ptrs(cmd, &Stat); - if (sortit) { + if (Stat.sortit) { CompareFunc SortIt; memset(&SubTP, 0, sizeof(WCTemplputParams)); - SubTP.Filter.ContextType = CTX_NONE; + SubTP.Filter.ContextType = CTX_MAILSUM; SubTP.Context = NULL; SortIt = RetrieveSort(&SubTP, NULL, 0, - HKEY("date"), defaultsortorder); + HKEY("date"), Stat.defaultsortorder); if (SortIt != NULL) SortByPayload(WCC->summ, SortIt); - if (WCC->wc_view == VIEW_BBS) { - if (lbstr("SortOrder") == 2) { - bbs_reverse = 1; - num_displayed = -DEFAULT_MAXMSGS; - } - else { - bbs_reverse = 0; - num_displayed = DEFAULT_MAXMSGS; - } - } } - if (startmsg < 0) startmsg = (bbs_reverse) ? nummsgs - 1 : 0; + if (Stat.startmsg < 0) + Stat.startmsg = (Stat.reverse) ? Stat.nummsgs - 1 : 0; - if (load_seen) load_seen_flags(); + if (Stat.load_seen) load_seen_flags(); - /** - * If we're to print s.th. above the message list... + /* + * Print any inforation above the message list... */ - switch (WCC->wc_view) { - case VIEW_BBS: - BBViewToolBar = NewStrBuf(); - MessageDropdown = NewStrBuf(); - - maxmsgs = DrawMessageDropdown(MessageDropdown, maxmsgs, startmsg, num_displayed); - if (num_displayed < 0) { - startmsg += maxmsgs; - if (num_displayed != maxmsgs) - maxmsgs = abs(maxmsgs) + 1; - else - maxmsgs = abs(maxmsgs); + if (ViewMsg->PrintViewHeader != NULL) + ViewMsg->PrintViewHeader(&Stat, &ViewSpecific); - } - memset(&SubTP, 0, sizeof(WCTemplputParams)); - SubTP.Filter.ContextType = CTX_STRBUF; - SubTP.Context = MessageDropdown; - DoTemplate(HKEY("msg_listselector_top"), BBViewToolBar, &SubTP); - StrBufAppendBuf(WCC->WBuf, BBViewToolBar, 0); - FlushStrBuf(BBViewToolBar); - break; - } - WCC->startmsg = startmsg; - WCC->maxmsgs = maxmsgs; + WCC->startmsg = Stat.startmsg; + WCC->maxmsgs = Stat.maxmsgs; WCC->num_displayed = 0; /* Put some helpful data in vars for mailsummary_json */ - svputlong("READLOOP:TOTALMSGS", nummsgs); - svputlong("READLOOP:STARTMSG", startmsg); + svputlong("READLOOP:TOTALMSGS", Stat.nummsgs); + svputlong("READLOOP:STARTMSG", Stat.startmsg); svputlong("WCVIEW", WCC->wc_view); + /* * iterate over each message. if we need to load an attachment, do it here. */ - if (WCC->wc_view == VIEW_MAILBOX) goto NO_MSG_LOOP; - /* - * iterate over each message. if we need to load an attachment, do it here. - */ - at = GetNewHashPos(WCC->summ, 0); - num_displayed = i = 0; - while (GetNextHashPos(WCC->summ, at, &HKLen, &HashKey, &vMsg)) { - Msg = (message_summary*) vMsg; - if ((Msg->msgnum >= startmsg) && (num_displayed <= maxmsgs)) { - switch (WCC->wc_view) { - case VIEW_WIKI: - break; - case VIEW_CALBRIEF: /* load the mime attachments for special tasks... */ - case VIEW_CALENDAR: - load_calendar_item(Msg, Msg->is_new, &calv); - break; - case VIEW_TASKS: - display_task(Msg, Msg->is_new); - break; - case VIEW_NOTES: - display_note(Msg, Msg->is_new); - break; - case VIEW_ADDRESSBOOK: - ab_name = NULL; - fetch_ab_name(Msg, &ab_name); - if (ab_name == NULL) - break; - ++num_ab; - addrbook = realloc(addrbook, - (sizeof(addrbookent) * num_ab) ); - safestrncpy(addrbook[num_ab-1].ab_name, ab_name, - sizeof(addrbook[num_ab-1].ab_name)); - addrbook[num_ab-1].ab_msgnum = Msg->msgnum; - free(ab_name); - break; - case VIEW_BBS: /* Tag the mails we want to show in bbview... */ - default: - if (displayed_msgs == NULL) { - displayed_msgs = malloc(sizeof(long) * - (maxmsgs= startmsg) && (i < startmsg + maxmsgs)) { - displayed_msgs[num_displayed] = Msg->msgnum; - if (lowest_displayed < 0) lowest_displayed = a; - highest_displayed = a; - - num_displayed++; - } - } - } - i++; + + if ((ViewMsg->LoadMsgFromServer != NULL) && + (!IsEmptyStr(cmd))) + { + at = GetNewHashPos(WCC->summ, 0); + Stat.num_displayed = i = 0; + while ( GetNextHashPos(WCC->summ, at, &HKLen, &HashKey, &vMsg)) { + Msg = (message_summary*) vMsg; + if ((Msg->msgnum >= Stat.startmsg) && (Stat.num_displayed <= Stat.maxmsgs)) { + ViewMsg->LoadMsgFromServer(&Stat, &ViewSpecific, Msg, Msg->is_new, i); + } + i++; + } + DeleteHashPos(&at); } - DeleteHashPos(&at); - NO_MSG_LOOP: /* * Done iterating the message list. now tasks we want to do after. */ - switch (WCC->wc_view) { - case VIEW_MAILBOX: - DoTemplate(HKEY("mailsummary_json"),NULL, &SubTP); - break; - case VIEW_BBS: - if (displayed_msgs != NULL) { - /** if we do a split bbview in the future, begin messages div here */ - - for (a=0; aWBuf, HKEY("view_message"), displayed_msgs[a], NULL); - } - - /** if we do a split bbview in the future, end messages div here */ - - free(displayed_msgs); - displayed_msgs = NULL; - } - memset(&SubTP, 0, sizeof(WCTemplputParams)); - SubTP.Filter.ContextType = CTX_STRBUF; - SubTP.Context = MessageDropdown; - DoTemplate(HKEY("msg_listselector_bottom"), BBViewToolBar, &SubTP); - StrBufAppendBuf(WCC->WBuf, BBViewToolBar, 0); + if (ViewMsg->RenderView_or_Tail != NULL) + ViewMsg->RenderView_or_Tail(&Stat, &ViewSpecific, oper); - FreeStrBuf(&BBViewToolBar); - FreeStrBuf(&MessageDropdown); - } + if (ViewMsg->ViewCleanup != NULL) + ViewMsg->ViewCleanup(&ViewSpecific); - -DONE: - switch (WCC->wc_view) { - case VIEW_WIKI: - break; - case VIEW_CALBRIEF: - case VIEW_CALENDAR: - render_calendar_view(&calv); - break; - case VIEW_TASKS: - do_tasks_view(); /** Render the task list */ - break; - case VIEW_NOTES: - break; - case VIEW_ADDRESSBOOK: - if (is_singlecard) - read_message(WC->WBuf, HKEY("view_message"), lbstr("startmsg"), NULL); - else - do_addrbook_view(addrbook, num_ab); /** Render the address book */ - break; - case VIEW_MAILBOX: - case VIEW_BBS: - default: - break; - } - /** Note: wDumpContent() will output one additional tag. */ - if (WCC->wc_view != VIEW_MAILBOX) { - /* We ought to move this out into template */ - wDumpContent(1); - } else { - end_burst(); - } WCC->startmsg = 0; WCC->maxmsgs = 0; if (WCC->summ != NULL) { DeleteHash(&WCC->summ); } - if (addrbook != NULL) free(addrbook); - FreeStrBuf(&BBViewToolBar); } @@ -1001,6 +904,7 @@ void post_mime_to_server(void) { size_t encoded_length; size_t encoded_strlen; char *txtmail = NULL; + int include_text_alt = 0; /* Set to nonzero to include multipart/alternative text/plain */ sprintf(top_boundary, "Citadel--Multipart--%s--%04x--%04x", ChrPtr(WCC->serv_info->serv_fqdn), @@ -1022,6 +926,11 @@ void post_mime_to_server(void) { is_multipart = 1; } + /* Only do multipart/alternative for mailboxes. BBS and Wiki rooms don't need it. */ + if (WC->wc_view == VIEW_MAILBOX) { + include_text_alt = 1; + } + if (is_multipart) { /* Remember, serv_printf() appends an extra newline */ serv_printf("Content-type: multipart/mixed; boundary=\"%s\"\n", top_boundary); @@ -1030,19 +939,21 @@ void post_mime_to_server(void) { } /* Remember, serv_printf() appends an extra newline */ - serv_printf("Content-type: multipart/alternative; " - "boundary=\"%s\"\n", alt_boundary); - serv_printf("This is a multipart message in MIME format.\n"); - serv_printf("--%s", alt_boundary); + if (include_text_alt) { + serv_printf("Content-type: multipart/alternative; " + "boundary=\"%s\"\n", alt_boundary); + serv_printf("This is a multipart message in MIME format.\n"); + serv_printf("--%s", alt_boundary); - serv_puts("Content-type: text/plain; charset=utf-8"); - serv_puts("Content-Transfer-Encoding: quoted-printable"); - serv_puts(""); - txtmail = html_to_ascii(bstr("msgtext"), 0, 80, 0); - text_to_server_qp(txtmail); /* Transmit message in quoted-printable encoding */ - free(txtmail); + serv_puts("Content-type: text/plain; charset=utf-8"); + serv_puts("Content-Transfer-Encoding: quoted-printable"); + serv_puts(""); + txtmail = html_to_ascii(bstr("msgtext"), 0, 80, 0); + text_to_server_qp(txtmail); /* Transmit message in quoted-printable encoding */ + free(txtmail); - serv_printf("--%s", alt_boundary); + serv_printf("--%s", alt_boundary); + } serv_puts("Content-type: text/html; charset=utf-8"); serv_puts("Content-Transfer-Encoding: quoted-printable"); @@ -1051,7 +962,9 @@ void post_mime_to_server(void) { text_to_server_qp(bstr("msgtext")); /* Transmit message in quoted-printable encoding */ serv_puts("\r\n"); - serv_printf("--%s--", alt_boundary); + if (include_text_alt) { + serv_printf("--%s--", alt_boundary); + } if (is_multipart) { long len; @@ -1063,6 +976,8 @@ void post_mime_to_server(void) { it = GetNewHashPos(WCC->attachments, 0); while (GetNextHashPos(WCC->attachments, it, &len, &Key, &vAtt)) { att = (wc_mime_attachment *)vAtt; + if (att->length == 0) + continue; encoded_length = ((att->length * 150) / 100); encoded = malloc(encoded_length); if (encoded == NULL) break; @@ -1106,6 +1021,7 @@ void post_message(void) int is_anonymous = 0; const StrBuf *display_name = NULL; wcsession *WCC = WC; + StrBuf *Buf; if (havebstr("force_room")) { gotoroom(sbstr("force_room")); @@ -1124,22 +1040,23 @@ void post_message(void) int n; char N[64]; - lprintf(9, "%s:%d: we are uploading %d bytes\n", __FILE__, __LINE__, WCC->upload_length); - /** There's an attachment. Save it to this struct... */ + /* There's an attachment. Save it to this struct... */ + lprintf(9, "Client is uploading %d bytes\n", WCC->upload_length); att = malloc(sizeof(wc_mime_attachment)); memset(att, 0, sizeof(wc_mime_attachment )); att->length = WCC->upload_length; att->ContentType = NewStrBufPlain(WCC->upload_content_type, -1); att->FileName = NewStrBufPlain(WCC->upload_filename, -1); - - if (WCC->attachments == NULL) + if (WCC->attachments == NULL) { WCC->attachments = NewHash(1, NULL); + } + /* And add it to the list. */ n = snprintf(N, sizeof N, "%d", GetCount(WCC->attachments) + 1); Put(WCC->attachments, N, n, att, DestroyMime); - /** + /* * Mozilla sends a simple filename, which is what we want, * but Satan's Browser sends an entire pathname. Reduce * the path to just a filename if we need to. @@ -1153,14 +1070,13 @@ void post_message(void) StrBufCutLeft(att->FileName, pch - ChrPtr(att->FileName) + 1); } - /** + /* * Transfer control of this memory from the upload struct * to the attachment struct. */ - att->Data = NewStrBufPlain(WCC->upload, WCC->upload_length); - free(WCC->upload); - WCC->upload_length = 0; + att->Data = WCC->upload; WCC->upload = NULL; + WCC->upload_length = 0; display_enter(); return; } @@ -1184,11 +1100,31 @@ void post_message(void) const StrBuf *my_email_addr = NULL; StrBuf *CmdBuf = NULL; StrBuf *references = NULL; + int save_to_drafts; + + save_to_drafts = havebstr("save_button"); + Buf = NewStrBuf(); + + if (save_to_drafts) { + /* temporarily change to the drafts room */ + serv_puts("GOTO _DRAFTS_"); + StrBuf_ServGetln(Buf); + if (GetServerStatus(Buf, NULL) != 2) { + /* You probably don't even have a dumb Drafts folder */ + StrBufCutLeft(Buf, 4); + lprintf(9, "%s:%d: server save to drafts error: %s\n", __FILE__, __LINE__, ChrPtr(Buf)); + StrBufAppendBufPlain(WCC->ImportantMsg, _("Saved to Drafts failed: "), -1, 0); + StrBufAppendBuf(WCC->ImportantMsg, Buf, 0); + display_enter(); + FreeStrBuf(&Buf); + return; + } + } if (havebstr("references")) { const StrBuf *ref = sbstr("references"); - references = NewStrBufPlain(ChrPtr(ref), StrLength(ref)); + references = NewStrBufDup(ref); if (*ChrPtr(references) == '|') { /* remove leading '|' if present */ StrBufCutLeft(references, 1); } @@ -1207,7 +1143,7 @@ void post_message(void) Recp = sbstr("recp"); Cc = sbstr("cc"); Bcc = sbstr("bcc"); - Wikipage = sbstr("wikipage"); + Wikipage = sbstr("page"); my_email_addr = sbstr("my_email_addr"); CmdBuf = NewStrBufPlain(NULL, @@ -1222,59 +1158,83 @@ void post_message(void) StrBufPrintf(CmdBuf, CMD, - ChrPtr(Recp), + save_to_drafts?"":ChrPtr(Recp), is_anonymous, ChrPtr(encoded_subject), ChrPtr(display_name), - ChrPtr(Cc), - ChrPtr(Bcc), + save_to_drafts?"":ChrPtr(Cc), + save_to_drafts?"":ChrPtr(Bcc), ChrPtr(Wikipage), ChrPtr(my_email_addr), ChrPtr(references)); FreeStrBuf(&references); + FreeStrBuf(&encoded_subject); lprintf(9, "%s\n", ChrPtr(CmdBuf)); serv_puts(ChrPtr(CmdBuf)); - serv_getln(buf, sizeof buf); FreeStrBuf(&CmdBuf); - FreeStrBuf(&encoded_subject); - if (buf[0] == '4') { + + StrBuf_ServGetln(Buf); + if (GetServerStatus(Buf, NULL) == 4) { + if (save_to_drafts) { + if ( (havebstr("recp")) + || (havebstr("cc" )) + || (havebstr("bcc" )) ) { + /* save recipient headers or room to post to */ + serv_printf("To: %s", ChrPtr(Recp)); + serv_printf("Cc: %s", ChrPtr(Cc)); + serv_printf("Bcc: %s", ChrPtr(Bcc)); + } else { + serv_printf("X-Citadel-Room: %s", ChrPtr(WC->wc_roomname)); + } + } post_mime_to_server(); - if ( (havebstr("recp")) + if (save_to_drafts) { + StrBufAppendBufPlain(WCC->ImportantMsg, _("Message has been saved to Drafts.\n"), -1, 0); + gotoroom(WCC->wc_roomname); + display_enter(); + FreeStrBuf(&Buf); + return; + } else if ( (havebstr("recp")) || (havebstr("cc" )) || (havebstr("bcc" )) ) { - sprintf(WCC->ImportantMessage, _("Message has been sent.\n")); + StrBufAppendBufPlain(WCC->ImportantMsg, _("Message has been sent.\n"), -1, 0); } else { - sprintf(WC->ImportantMessage, _("Message has been posted.\n")); + StrBufAppendBufPlain(WCC->ImportantMsg, _("Message has been posted.\n"), -1, 0); } dont_post = lbstr("postseq"); } else { - lprintf(9, "%s:%d: server post error: %s\n", __FILE__, __LINE__, buf); - sprintf(WC->ImportantMessage, "%s", &buf[4]); + StrBufCutLeft(Buf, 4); + + lprintf(9, "%s:%d: server post error: %s\n", __FILE__, __LINE__, ChrPtr(Buf)); + StrBufAppendBuf(WCC->ImportantMsg, Buf, 0); + if (save_to_drafts) gotoroom(WCC->wc_roomname); display_enter(); + FreeStrBuf(&Buf); return; } + FreeStrBuf(&Buf); } DeleteHash(&WCC->attachments); - /** + /* * We may have been supplied with instructions regarding the location * to which we must return after posting. If found, go there. */ if (havebstr("return_to")) { http_redirect(bstr("return_to")); } - /** + /* * If we were editing a page in a wiki room, go to that page now. */ - else if (havebstr("wikipage")) { - snprintf(buf, sizeof buf, "wiki?page=%s", bstr("wikipage")); + else if (havebstr("page")) { + snprintf(buf, sizeof buf, "wiki?page=%s", bstr("page")); http_redirect(buf); } - /** + /* * Otherwise, just go to the "read messages" loop. */ else { @@ -1285,8 +1245,8 @@ void post_message(void) -/** - * \brief display the message entry screen +/* + * display the message entry screen */ void display_enter(void) { @@ -1311,14 +1271,14 @@ void display_enter(void) is_anonymous = 1; } - /** First test to see whether this is a room that requires recipients to be entered */ + /* First test to see whether this is a room that requires recipients to be entered */ serv_puts("ENT0 0"); serv_getln(buf, sizeof buf); - if (!strncmp(buf, "570", 3)) { /** 570 means that we need a recipient here */ + if (!strncmp(buf, "570", 3)) { /* 570 means that we need a recipient here */ recipient_required = 1; } - else if (buf[0] != '2') { /** Any other error means that we cannot continue */ + else if (buf[0] != '2') { /* Any other error means that we cannot continue */ sprintf(WCC->ImportantMessage, "%s", &buf[4]); readloop(readnew); return; @@ -1329,7 +1289,7 @@ void display_enter(void) subject_required = extract_int(&buf[4], 1); } - /** + /* * Are we perhaps in an address book view? If so, then an "enter * message" command really means "add new entry." */ @@ -1372,7 +1332,7 @@ void display_enter(void) Recp = sbstr("recp"); Cc = sbstr("cc"); Bcc = sbstr("bcc"); - Wikipage = sbstr("wikipage"); + Wikipage = sbstr("page"); CmdBuf = NewStrBufPlain(NULL, sizeof (CMD) + @@ -1394,15 +1354,15 @@ void display_enter(void) serv_getln(buf, sizeof buf); FreeStrBuf(&CmdBuf); - if (!strncmp(buf, "570", 3)) { /** 570 means we have an invalid recipient listed */ + if (!strncmp(buf, "570", 3)) { /* 570 means we have an invalid recipient listed */ if (havebstr("recp") && havebstr("cc" ) && havebstr("bcc" )) { recipient_bad = 1; } } - else if (buf[0] != '2') { /** Any other error means that we cannot continue */ - wprintf("%s
\n", &buf[4]);/*TODO -> important message */ + else if (buf[0] != '2') { /* Any other error means that we cannot continue */ + wc_printf("%s
\n", &buf[4]); /* TODO -> important message */ return; } } @@ -1417,8 +1377,8 @@ void display_enter(void) return; } -/** - * \brief delete a message +/* + * delete a message */ void delete_msg(void) { @@ -1427,22 +1387,21 @@ void delete_msg(void) msgid = lbstr("msgid"); - if (WC->wc_is_trash) { /** Delete from Trash is a real delete */ + if (WC->wc_is_trash) { /* Delete from Trash is a real delete */ serv_printf("DELE %ld", msgid); } - else { /** Otherwise move it to Trash */ + else { /* Otherwise move it to Trash */ serv_printf("MOVE %ld|_TRASH_|0", msgid); } serv_getln(buf, sizeof buf); sprintf(WC->ImportantMessage, "%s", &buf[4]); - readloop(readnew); } -/** - * \brief move a message to another folder +/* + * move a message to another room */ void move_msg(void) { @@ -1464,9 +1423,6 @@ void move_msg(void) } - - - /* * Confirm move of a message */ @@ -1480,43 +1436,43 @@ void confirm_move_msg(void) output_headers(1, 1, 2, 0, 0, 0); - wprintf("
\n"); - wprintf("

"); - wprintf(_("Confirm move of message")); - wprintf("

"); - wprintf("
\n"); + wc_printf("
\n"); + wc_printf("

"); + wc_printf(_("Confirm move of message")); + wc_printf("

"); + wc_printf("
\n"); - wprintf("
\n"); + wc_printf("
\n"); - wprintf("
"); + wc_printf("
"); - wprintf(_("Move this message to:")); - wprintf("
\n"); + wc_printf(_("Move this message to:")); + wc_printf("
\n"); - wprintf("
\n"); - wprintf("\n", WC->nonce); - wprintf("\n", bstr("msgid")); + wc_printf("\n"); + wc_printf("\n", WC->nonce); + wc_printf("\n", bstr("msgid")); - wprintf("\n"); serv_puts("LKRA"); serv_getln(buf, sizeof buf); if (buf[0] == '1') { while (serv_getln(buf, sizeof buf), strcmp(buf, "000")) { extract_token(targ, buf, 0, '|', sizeof targ); - wprintf("
\n"); + wc_printf("", _("Move")); + wc_printf(" "); + wc_printf("", _("Cancel")); + wc_printf("
\n"); - wprintf("\n"); + wc_printf("\n"); wDumpContent(1); } @@ -1550,7 +1506,8 @@ void postpart(StrBuf *partnum, StrBuf *filename, int force_download) hprintf("HTTP/1.1 404 %s\n", ChrPtr(partnum)); output_headers(0, 0, 0, 0, 0, 0); hprintf("Content-Type: text/plain\r\n"); - wprintf(_("An error occurred while retrieving this part: %s/%s\n"), + begin_burst(); + wc_printf(_("An error occurred while retrieving this part: %s/%s\n"), ChrPtr(partnum), ChrPtr(filename)); end_burst(); } @@ -1568,14 +1525,19 @@ void postpart(StrBuf *partnum, StrBuf *filename, int force_download) */ void mimepart(int force_download) { + long msgnum; + StrBuf *att; wcsession *WCC = WC; StrBuf *Buf; off_t bytes; StrBuf *ContentType = NewStrBufPlain(HKEY("application/octet-stream")); const char *CT; - Buf = NewStrBuf(); - serv_printf("OPNA %s|%s", ChrPtr(WCC->UrlFragment2), ChrPtr(WCC->UrlFragment3)); + att = Buf = NewStrBuf(); + msgnum = StrBufExtract_long(WCC->Hdr->HR.ReqLine, 0, '/'); + StrBufExtract_token(att, WCC->Hdr->HR.ReqLine, 1, '/'); + + serv_printf("OPNA %ld|%s", msgnum, ChrPtr(att)); StrBuf_ServGetln(Buf); if (GetServerStatus(Buf, NULL) == 2) { StrBufCutLeft(Buf, 4); @@ -1591,7 +1553,8 @@ void mimepart(int force_download) if (!force_download) { if (!strcasecmp(ChrPtr(ContentType), "application/octet-stream")) { - CT = GuessMimeByFilename(SKEY(WCC->UrlFragment4)); + StrBufExtract_token(Buf, WCC->Hdr->HR.ReqLine, 2, '/'); + CT = GuessMimeByFilename(SKEY(Buf)); } if (!strcasecmp(ChrPtr(ContentType), "application/octet-stream")) { CT = GuessMimeType(SKEY(WCC->WBuf)); @@ -1603,7 +1566,8 @@ void mimepart(int force_download) hprintf("HTTP/1.1 404 %s\n", ChrPtr(Buf)); output_headers(0, 0, 0, 0, 0, 0); hprintf("Content-Type: text/plain\r\n"); - wprintf(_("An error occurred while retrieving this part: %s\n"), + begin_burst(); + wc_printf(_("An error occurred while retrieving this part: %s\n"), ChrPtr(Buf)); end_burst(); } @@ -1626,7 +1590,8 @@ StrBuf *load_mimepart(long msgnum, char *partnum) if (GetServerStatus(Buf, NULL) == 6) { StrBufCutLeft(Buf, 4); bytes = StrBufExtract_long(Buf, 0, '|'); - + FreeStrBuf(&Buf); + Buf = NewStrBuf(); StrBuf_ServGetBLOBBuffered(Buf, bytes); return(Buf); } @@ -1643,7 +1608,7 @@ void MimeLoadData(wc_mime_attachment *Mime) { StrBuf *Buf; off_t bytes; -/* TODO: is there a chance the contenttype is different to the one we know? */ + /* TODO: is there a chance the content type is different from the one we know? */ serv_printf("DLAT %ld|%s", Mime->msgnum, ChrPtr(Mime->PartNum)); Buf = NewStrBuf(); StrBuf_ServGetln(Buf); @@ -1673,15 +1638,29 @@ void download_mimepart(void) { } void view_postpart(void) { - postpart(WC->UrlFragment2, - WC->UrlFragment3, - 0); + StrBuf *filename = NewStrBuf(); + StrBuf *partnum = NewStrBuf(); + + StrBufExtract_token(partnum, WC->Hdr->HR.ReqLine, 0, '/'); + StrBufExtract_token(filename, WC->Hdr->HR.ReqLine, 1, '/'); + + postpart(partnum, filename, 0); + + FreeStrBuf(&filename); + FreeStrBuf(&partnum); } void download_postpart(void) { - postpart(WC->UrlFragment2, - WC->UrlFragment3, - 1); + StrBuf *filename = NewStrBuf(); + StrBuf *partnum = NewStrBuf(); + + StrBufExtract_token(partnum, WC->Hdr->HR.ReqLine, 0, '/'); + StrBufExtract_token(filename, WC->Hdr->HR.ReqLine, 1, '/'); + + postpart(partnum, filename, 1); + + FreeStrBuf(&filename); + FreeStrBuf(&partnum); } void h_readnew(void) { readloop(readnew);} @@ -1689,32 +1668,51 @@ void h_readold(void) { readloop(readold);} void h_readfwd(void) { readloop(readfwd);} void h_headers(void) { readloop(headers);} void h_do_search(void) { readloop(do_search);} +void h_readgt(void) { readloop(readgt);} void jsonMessageListHdr(void) { /* TODO: make a generic function */ - hprintf("HTTP/1.1 200 OK\r\n"); - hprintf("Content-type: application/json; charset=utf-8\r\n"); - hprintf("Server: %s / %s\r\n", PACKAGE_STRING, ChrPtr(WC->serv_info->serv_software)); - hprintf("Connection: close\r\n"); - hprintf("Pragma: no-cache\r\nCache-Control: no-store\r\nExpires:-1\r\n"); - begin_burst(); -} -/* Spit out the new summary view. This is basically a static page, so clients can cache the layout, all the dirty work is javascript :) */ -void new_summary_view(void) { - begin_burst(); - DoTemplate(HKEY("msg_listview"),NULL,&NoCtx); - DoTemplate(HKEY("trailing"),NULL,&NoCtx); - end_burst(); + hprintf("HTTP/1.1 200 OK\r\n"); + hprintf("Content-type: application/json; charset=utf-8\r\n"); + hprintf("Server: %s / %s\r\n", PACKAGE_STRING, ChrPtr(WC->serv_info->serv_software)); + hprintf("Connection: close\r\n"); + hprintf("Pragma: no-cache\r\nCache-Control: no-store\r\nExpires:-1\r\n"); + begin_burst(); } -/** Output message list in JSON-format */ + + +/* Output message list in JSON format */ void jsonMessageList(void) { - const StrBuf *room = sbstr("room"); - long oper = (havebstr("query")) ? do_search : readnew; - WC->is_ajax = 1; - gotoroom(room); - readloop(oper); - WC->is_ajax = 0; + const StrBuf *room = sbstr("room"); + long oper = (havebstr("query")) ? do_search : readnew; + WC->is_ajax = 1; + gotoroom(room); + readloop(oper); + WC->is_ajax = 0; +} + +void RegisterReadLoopHandlerset( + int RoomType, + GetParamsGetServerCall_func GetParamsGetServerCall, + PrintViewHeader_func PrintViewHeader, + LoadMsgFromServer_func LoadMsgFromServer, + RenderView_or_Tail_func RenderView_or_Tail, + View_Cleanup_func ViewCleanup + ) +{ + RoomRenderer *Handler; + + Handler = (RoomRenderer*) malloc(sizeof(RoomRenderer)); + + Handler->RoomType = RoomType; + Handler->GetParamsGetServerCall = GetParamsGetServerCall; + Handler->PrintViewHeader = PrintViewHeader; + Handler->LoadMsgFromServer = LoadMsgFromServer; + Handler->RenderView_or_Tail = RenderView_or_Tail; + Handler->ViewCleanup = ViewCleanup; + + Put(ReadLoopHandler, IKEY(RoomType), Handler, NULL); } void @@ -1741,28 +1739,30 @@ InitModule_MSG NULL); RegisterPreference("mailbox",_("Mailbox view mode"), PRF_STRING, NULL); - WebcitAddUrlHandler(HKEY("readnew"), h_readnew, NEED_URL); - WebcitAddUrlHandler(HKEY("readold"), h_readold, NEED_URL); - WebcitAddUrlHandler(HKEY("readfwd"), h_readfwd, NEED_URL); - WebcitAddUrlHandler(HKEY("headers"), h_headers, NEED_URL); - WebcitAddUrlHandler(HKEY("do_search"), h_do_search, 0); - WebcitAddUrlHandler(HKEY("display_enter"), display_enter, 0); - WebcitAddUrlHandler(HKEY("post"), post_message, 0); - WebcitAddUrlHandler(HKEY("move_msg"), move_msg, 0); - WebcitAddUrlHandler(HKEY("delete_msg"), delete_msg, 0); - WebcitAddUrlHandler(HKEY("confirm_move_msg"), confirm_move_msg, 0); - WebcitAddUrlHandler(HKEY("msg"), embed_message, NEED_URL|AJAX); - WebcitAddUrlHandler(HKEY("printmsg"), print_message, NEED_URL); - WebcitAddUrlHandler(HKEY("mobilemsg"), mobile_message_view, NEED_URL); - WebcitAddUrlHandler(HKEY("msgheaders"), display_headers, NEED_URL); - - WebcitAddUrlHandler(HKEY("mimepart"), view_mimepart, NEED_URL); - WebcitAddUrlHandler(HKEY("mimepart_download"), download_mimepart, NEED_URL); - WebcitAddUrlHandler(HKEY("postpart"), view_postpart, NEED_URL); - WebcitAddUrlHandler(HKEY("postpart_download"), download_postpart, NEED_URL); + WebcitAddUrlHandler(HKEY("readnew"), "", 0, h_readnew, NEED_URL); + WebcitAddUrlHandler(HKEY("readold"), "", 0, h_readold, NEED_URL); + WebcitAddUrlHandler(HKEY("readfwd"), "", 0, h_readfwd, NEED_URL); + WebcitAddUrlHandler(HKEY("headers"), "", 0, h_headers, NEED_URL); + WebcitAddUrlHandler(HKEY("readgt"), "", 0, h_readgt, NEED_URL); + WebcitAddUrlHandler(HKEY("do_search"), "", 0, h_do_search, 0); + WebcitAddUrlHandler(HKEY("display_enter"), "", 0, display_enter, 0); + WebcitAddUrlHandler(HKEY("post"), "", 0, post_message, 0); + WebcitAddUrlHandler(HKEY("move_msg"), "", 0, move_msg, 0); + WebcitAddUrlHandler(HKEY("delete_msg"), "", 0, delete_msg, 0); + WebcitAddUrlHandler(HKEY("confirm_move_msg"), "", 0, confirm_move_msg, 0); + WebcitAddUrlHandler(HKEY("msg"), "", 0, embed_message, NEED_URL); + WebcitAddUrlHandler(HKEY("message"), "", 0, handle_one_message, NEED_URL|XHTTP_COMMANDS|COOKIEUNNEEDED|FORCE_SESSIONCLOSE); + WebcitAddUrlHandler(HKEY("printmsg"), "", 0, print_message, NEED_URL); + WebcitAddUrlHandler(HKEY("mobilemsg"), "", 0, mobile_message_view, NEED_URL); + WebcitAddUrlHandler(HKEY("msgheaders"), "", 0, display_headers, NEED_URL); + + WebcitAddUrlHandler(HKEY("mimepart"), "", 0, view_mimepart, NEED_URL); + WebcitAddUrlHandler(HKEY("mimepart_download"), "", 0, download_mimepart, NEED_URL); + WebcitAddUrlHandler(HKEY("postpart"), "", 0, view_postpart, NEED_URL); + WebcitAddUrlHandler(HKEY("postpart_download"), "", 0, download_postpart, NEED_URL); /* json */ - WebcitAddUrlHandler(HKEY("roommsgs"), jsonMessageList,0); + WebcitAddUrlHandler(HKEY("roommsgs"), "", 0, jsonMessageList,0); return ; }