7fe0013a29eb43ad0cfcd9a555fc1de62fc3e66a
[citadel.git] / citadel / imap_fetch.c
1 /*
2  * $Id$
3  *
4  * Implements the FETCH command in IMAP.
5  * This command is way too convoluted.  Marc Crispin is a fscking idiot.
6  *
7  */
8
9
10 #include "sysdep.h"
11 #include <stdlib.h>
12 #include <unistd.h>
13 #include <stdio.h>
14 #include <fcntl.h>
15 #include <signal.h>
16 #include <pwd.h>
17 #include <errno.h>
18 #include <sys/types.h>
19 #include <sys/time.h>
20 #include <sys/wait.h>
21 #include <ctype.h>
22 #include <string.h>
23 #include <limits.h>
24 #include "citadel.h"
25 #include "server.h"
26 #include <time.h>
27 #include "sysdep_decls.h"
28 #include "citserver.h"
29 #include "support.h"
30 #include "config.h"
31 #include "dynloader.h"
32 #include "room_ops.h"
33 #include "user_ops.h"
34 #include "policy.h"
35 #include "database.h"
36 #include "msgbase.h"
37 #include "tools.h"
38 #include "internet_addressing.h"
39 #include "mime_parser.h"
40 #include "serv_imap.h"
41 #include "imap_tools.h"
42 #include "imap_fetch.h"
43 #include "genstamp.h"
44
45
46
47 struct imap_fetch_part {
48         char desired_section[SIZ];
49         FILE *output_fp;
50 };
51
52 /*
53  * Individual field functions for imap_do_fetch_msg() ...
54  */
55
56
57
58 void imap_fetch_uid(int seq) {
59         cprintf("UID %ld", IMAP->msgids[seq-1]);
60 }
61
62 void imap_fetch_flags(struct CtdlMessage *msg) {
63         cprintf("FLAGS ()");    /* FIXME do something here */
64 }
65
66 void imap_fetch_internaldate(struct CtdlMessage *msg) {
67         char buf[SIZ];
68         time_t msgdate;
69
70         if (msg->cm_fields['T'] != NULL) {
71                 msgdate = atol(msg->cm_fields['T']);
72         }
73         else {
74                 msgdate = time(NULL);
75         }
76
77         datestring(buf, msgdate, DATESTRING_IMAP);
78         cprintf("INTERNALDATE \"%s\"", buf);
79 }
80
81
82 /*
83  * Fetch RFC822-formatted messages.
84  *
85  * 'whichfmt' should be set to one of:
86  *      "RFC822"        entire message
87  *      "RFC822.HEADER" headers only (with trailing blank line)
88  *      "RFC822.SIZE"   size of translated message
89  *      "RFC822.TEXT"   body only (without leading blank line)
90  */
91 void imap_fetch_rfc822(int msgnum, char *whichfmt, struct CtdlMessage *msg) {
92         FILE *tmp;
93         char buf[1024];
94         char *ptr;
95         long headers_size, text_size, total_size;
96         long bytes_remaining = 0;
97         long blocksize;
98
99         tmp = tmpfile();
100         if (tmp == NULL) {
101                 lprintf(1, "Cannot open temp file: %s\n", strerror(errno));
102                 return;
103         }
104
105         /*
106          * Load the message into a temp file for translation and measurement
107          */ 
108         CtdlRedirectOutput(tmp, -1);
109         CtdlOutputPreLoadedMsg(msg, msgnum, MT_RFC822, 0, 0, 1);
110         CtdlRedirectOutput(NULL, -1);
111         if (!is_valid_message(msg)) {
112                 lprintf(1, "WARNING: output clobbered the message!\n");
113         }
114
115         /*
116          * Now figure out where the headers/text break is.  IMAP considers the
117          * intervening blank line to be part of the headers, not the text.
118          */
119         rewind(tmp);
120         headers_size = 0L;
121         do {
122                 ptr = fgets(buf, sizeof buf, tmp);
123                 if (ptr != NULL) {
124                         striplt(buf);
125                         if (strlen(buf) == 0) headers_size = ftell(tmp);
126                 }
127         } while ( (headers_size == 0L) && (ptr != NULL) );
128         fseek(tmp, 0L, SEEK_END);
129         total_size = ftell(tmp);
130         text_size = total_size - headers_size;
131
132         if (!strcasecmp(whichfmt, "RFC822.SIZE")) {
133                 cprintf("RFC822.SIZE %ld", total_size);
134                 fclose(tmp);
135                 return;
136         }
137
138         else if (!strcasecmp(whichfmt, "RFC822")) {
139                 bytes_remaining = total_size;
140                 rewind(tmp);
141         }
142
143         else if (!strcasecmp(whichfmt, "RFC822.HEADER")) {
144                 bytes_remaining = headers_size;
145                 rewind(tmp);
146         }
147
148         else if (!strcasecmp(whichfmt, "RFC822.TEXT")) {
149                 bytes_remaining = text_size;
150                 fseek(tmp, headers_size, SEEK_SET);
151         }
152
153         cprintf("%s {%ld}\r\n", whichfmt, bytes_remaining);
154         blocksize = sizeof(buf);
155         while (bytes_remaining > 0L) {
156                 if (blocksize > bytes_remaining) blocksize = bytes_remaining;
157                 fread(buf, blocksize, 1, tmp);
158                 client_write(buf, blocksize);
159                 bytes_remaining = bytes_remaining - blocksize;
160         }
161
162         fclose(tmp);
163 }
164
165
166
167 /*
168  * Load a specific part of a message into the temp file to be output to a
169  * client.  FIXME we can handle parts like "2" and "2.1" and even "2.MIME"
170  * but we still can't handle "2.HEADER" (which might not be a problem, because
171  * we currently don't have the ability to break out nested RFC822's anyway).
172  *
173  * Note: mime_parser() was called with dont_decode set to 1, so we have the
174  * luxury of simply spewing without having to re-encode.
175  */
176 void imap_load_part(char *name, char *filename, char *partnum, char *disp,
177                     void *content, char *cbtype, size_t length, char *encoding,
178                     void *cbuserdata)
179 {
180         struct imap_fetch_part *imfp;
181         char mbuf2[1024];
182
183         imfp = (struct imap_fetch_part *)cbuserdata;
184
185         if (!strcasecmp(partnum, imfp->desired_section)) {
186                 fwrite(content, length, 1, imfp->output_fp);
187         }
188
189         sprintf(mbuf2, "%s.MIME", partnum);
190
191         if (!strcasecmp(imfp->desired_section, mbuf2)) {
192                 fprintf(imfp->output_fp, "Content-type: %s", cbtype);
193                 if (strlen(name) > 0)
194                         fprintf(imfp->output_fp, "; name=\"%s\"", name);
195                 fprintf(imfp->output_fp, "\r\n");
196                 if (strlen(encoding) > 0)
197                         fprintf(imfp->output_fp,
198                                 "Content-Transfer-Encoding: %s\r\n", encoding);
199                 if (strlen(encoding) > 0) {
200                         fprintf(imfp->output_fp, "Content-Disposition: %s",
201                                         disp);
202                         if (strlen(filename) > 0) {
203                                 fprintf(imfp->output_fp, "; filename=\"%s\"",
204                                         filename);
205                         }
206                         fprintf(imfp->output_fp, "\r\n");
207                 }
208                 fprintf(imfp->output_fp, "Content-Length: %d\r\n", length);
209                 fprintf(imfp->output_fp, "\r\n");
210         }
211                         
212
213 }
214
215
216 /* 
217  * Called by imap_fetch_envelope() to output the "From" field.
218  * This is in its own function because its logic is kind of complex.  We
219  * really need to make this suck less.
220  */
221 void imap_output_envelope_from(struct CtdlMessage *msg) {
222         char user[1024], node[1024], name[1024];
223
224         cprintf("((");                          /* open double-parens */
225         imap_strout(msg->cm_fields['A']);       /* personal name */
226         cprintf(" NIL ");                       /* source route (not used) */
227
228         if (msg->cm_fields['F'] != NULL) {
229                 process_rfc822_addr(msg->cm_fields['F'], user, node, name);
230                 imap_strout(user);              /* mailbox name (user id) */
231                 cprintf(" ");
232                 if (!strcasecmp(node, config.c_nodename)) {
233                         imap_strout(config.c_fqdn);
234                 }
235                 else {
236                         imap_strout(node);              /* host name */
237                 }
238         }
239         else {
240                 imap_strout(msg->cm_fields['A']); /* mailbox name (user id) */
241                 cprintf(" ");
242                 imap_strout(msg->cm_fields['N']);       /* host name */
243         }
244         
245         cprintf(")) ");                         /* close double-parens */
246 }
247
248
249 /*
250  * Implements the ENVELOPE fetch item
251  * 
252  * FIXME ... we only output some of the fields right now.  Definitely need
253  *           to do all of them.  Accurately, too.
254  *
255  * Note that the imap_strout() function can cleverly output NULL fields as NIL,
256  * so we don't have to check for that condition like we do elsewhere.
257  */
258 void imap_fetch_envelope(long msgnum, struct CtdlMessage *msg) {
259         char datestringbuf[SIZ];
260         time_t msgdate;
261         char *fieldptr = NULL;
262
263         /* Parse the message date into an IMAP-format date string */
264         if (msg->cm_fields['T'] != NULL) {
265                 msgdate = atol(msg->cm_fields['T']);
266         }
267         else {
268                 msgdate = time(NULL);
269         }
270         datestring(datestringbuf, msgdate, DATESTRING_IMAP);
271
272         /* Now start spewing data fields.  The order is important, as it is
273          * defined by the protocol specification.  Nonexistent fields must
274          * be output as NIL, existent fields must be quoted or literalled.
275          * The imap_strout() function conveniently does all this for us.
276          */
277         cprintf("ENVELOPE (");
278
279         /* Date */
280         imap_strout(datestringbuf);
281         cprintf(" ");
282
283         /* Subject */
284         imap_strout(msg->cm_fields['U']);
285         cprintf(" ");
286
287         /* From */
288         imap_output_envelope_from(msg);
289
290         /* Sender */
291         if (0) {
292                 /* FIXME ... check for a *real* Sender: field */
293         }
294         else {
295                 imap_output_envelope_from(msg);
296         }
297
298         /* Reply-to */
299         if (0) {
300                 /* FIXME ... check for a *real* Reply-to: field */
301         }
302         else {
303                 imap_output_envelope_from(msg);
304         }
305
306         cprintf("NIL ");        /* to */
307
308         cprintf("NIL ");        /* cc */
309
310         cprintf("NIL ");        /* bcc */
311
312         /* In-reply-to */
313         fieldptr = rfc822_fetch_field(msg->cm_fields['M'], "In-reply-to");
314         imap_strout(fieldptr);
315         cprintf(" ");
316         if (fieldptr != NULL) phree(fieldptr);
317
318         /* message ID */
319         imap_strout(msg->cm_fields['I']);
320
321         cprintf(") ");
322 }
323
324
325 /*
326  * Strip any non header information out of a chunk of RFC822 data on disk
327  */
328 void imap_strip_headers(FILE *fp) {
329         char buf[1024];
330
331         rewind(fp);
332         while (fgets(buf, sizeof buf, fp) != NULL) {
333                 striplt(buf);
334                 if (strlen(buf) == 0) {
335                         fflush(fp);
336                         ftruncate(fileno(fp), ftell(fp));
337                 }
338         }
339         fflush(fp);
340         fprintf(fp, "\r\n");    /* add the trailing newline */
341         rewind(fp);
342 }
343
344
345 /*
346  * Implements the BODY and BODY.PEEK fetch items
347  */
348 void imap_fetch_body(long msgnum, char *item, int is_peek,
349                 struct CtdlMessage *msg) {
350         char section[1024];
351         char partial[1024];
352         int is_partial = 0;
353         char buf[1024];
354         int i;
355         FILE *tmp;
356         long bytes_remaining = 0;
357         long blocksize;
358         long pstart, pbytes;
359         struct imap_fetch_part imfp;
360
361         /* extract section */
362         strcpy(section, item);
363         for (i=0; i<strlen(section); ++i) {
364                 if (section[i]=='[') strcpy(section, &section[i+1]);
365         }
366         for (i=0; i<strlen(section); ++i) {
367                 if (section[i]==']') section[i] = 0;
368         }
369         lprintf(9, "Section is %s\n", section);
370
371         /* extract partial */
372         strcpy(partial, item);
373         for (i=0; i<strlen(partial); ++i) {
374                 if (partial[i]=='<') {
375                         strcpy(partial, &partial[i+1]);
376                         is_partial = 1;
377                 }
378         }
379         for (i=0; i<strlen(partial); ++i) {
380                 if (partial[i]=='>') partial[i] = 0;
381         }
382         if (is_partial == 0) strcpy(partial, "");
383         lprintf(9, "Partial is %s\n", partial);
384
385         tmp = tmpfile();
386         if (tmp == NULL) {
387                 lprintf(1, "Cannot open temp file: %s\n", strerror(errno));
388                 return;
389         }
390
391         /* Now figure out what the client wants, and get it */
392
393         if (!strcmp(section, "")) {             /* the whole thing */
394                 CtdlRedirectOutput(tmp, -1);
395                 CtdlOutputPreLoadedMsg(msg, msgnum, MT_RFC822, 0, 0, 1);
396                 CtdlRedirectOutput(NULL, -1);
397         }
398
399         /*
400          * Be obnoxious and send the entire header, even if the client only
401          * asks for certain fields.  FIXME this shortcut later.
402          */
403         else if (!strncasecmp(section, "HEADER", 6)) {
404                 CtdlRedirectOutput(tmp, -1);
405                 CtdlOutputPreLoadedMsg(msg, msgnum, MT_RFC822, 1, 0, 1);
406                 CtdlRedirectOutput(NULL, -1);
407                 imap_strip_headers(tmp);
408         }
409
410         /*
411          * Anything else must be a part specifier.
412          * (Note value of 1 passed as 'dont_decode' so client gets it encoded)
413          */
414         else {
415                 safestrncpy(imfp.desired_section, section,
416                                 sizeof(imfp.desired_section));
417                 imfp.output_fp = tmp;
418
419                 mime_parser(msg->cm_fields['M'], NULL,
420                                 *imap_load_part, NULL, NULL,
421                                 (void *)&imfp,
422                                 1);
423         }
424
425
426         fseek(tmp, 0L, SEEK_END);
427         bytes_remaining = ftell(tmp);
428
429         if (is_partial == 0) {
430                 rewind(tmp);
431                 cprintf("BODY[%s] {%ld}\r\n", section, bytes_remaining);
432         }
433         else {
434                 sscanf(partial, "%ld.%ld", &pstart, &pbytes);
435                 if ((bytes_remaining - pstart) < pbytes) {
436                         pbytes = bytes_remaining - pstart;
437                 }
438                 fseek(tmp, pstart, SEEK_SET);
439                 bytes_remaining = pbytes;
440                 cprintf("BODY[%s] {%ld}<%ld>\r\n",
441                         section, bytes_remaining, pstart);
442         }
443
444         blocksize = sizeof(buf);
445         while (bytes_remaining > 0L) {
446                 if (blocksize > bytes_remaining) blocksize = bytes_remaining;
447                 fread(buf, blocksize, 1, tmp);
448                 client_write(buf, blocksize);
449                 bytes_remaining = bytes_remaining - blocksize;
450         }
451
452         fclose(tmp);
453
454         if (is_peek) {
455                 /* FIXME set the last read pointer or something */
456         }
457 }
458
459 /*
460  * Called immediately before outputting a multipart bodystructure
461  */
462 void imap_fetch_bodystructure_pre(
463                 char *name, char *filename, char *partnum, char *disp,
464                 void *content, char *cbtype, size_t length, char *encoding,
465                 void *cbuserdata
466                 ) {
467
468         cprintf("(");
469 }
470
471
472
473 /*
474  * Called immediately after outputting a multipart bodystructure
475  */
476 void imap_fetch_bodystructure_post(
477                 char *name, char *filename, char *partnum, char *disp,
478                 void *content, char *cbtype, size_t length, char *encoding,
479                 void *cbuserdata
480                 ) {
481
482         char subtype[SIZ];
483
484         extract_token(subtype, cbtype, 1, '/');
485         imap_strout(subtype);
486         cprintf(")");
487 }
488
489
490
491 /*
492  * Output the info for a MIME part in the format required by BODYSTRUCTURE.
493  *
494  * FIXME .... this needs oodles of work to get completed.
495  */
496 void imap_fetch_bodystructure_part(
497                 char *name, char *filename, char *partnum, char *disp,
498                 void *content, char *cbtype, size_t length, char *encoding,
499                 void *cbuserdata
500                 ) {
501
502         char buf[SIZ];
503
504         cprintf("(");
505
506         if (cbtype == NULL) {
507                 cprintf("\"TEXT\" \"PLAIN\" ");
508         }
509         else {
510                 extract_token(buf, cbtype, 0, '/');
511                 imap_strout(buf);
512                 cprintf(" ");
513                 extract_token(buf, cbtype, 1, '/');
514                 imap_strout(buf);
515                 cprintf(" ");
516         }
517
518         cprintf("(\"CHARSET\" \"US-ASCII\"");
519
520         if (name != NULL) {
521                 cprintf(" \"NAME\" ");
522                 imap_strout(name);
523         }
524
525         if (filename != NULL) {
526                 cprintf(" \"FILENAME\" ");
527                 imap_strout(name);
528         }
529
530         cprintf(") ");
531
532         cprintf("NIL NIL ");
533
534         if (encoding != NULL) {
535                 imap_strout(encoding);
536         }
537         else {
538                 imap_strout("7BIT");
539         }
540         cprintf(" ");
541
542         cprintf("%ld ", length);        /* bytes */
543         cprintf("NIL) ");               /* lines */
544
545 }
546
547
548
549 /*
550  * Spew the BODYSTRUCTURE data for a message.  (Do you need a silencer if
551  * you're going to shoot a MIME?  Do you need a reason to shoot Mark Crispin?
552  * No, and no.)
553  *
554  * FIXME finish the implementation
555  */
556 void imap_fetch_bodystructure (long msgnum, char *item,
557                 struct CtdlMessage *msg) {
558         FILE *tmp;
559         char buf[1024];
560         long lines = 0L;
561         long bytes = 0L;
562
563
564         /* For non-RFC822 (ordinary Citadel) messages, this is short and
565          * sweet...
566          */
567         if (msg->cm_format_type != FMT_RFC822) {
568
569                 /* *sigh* We have to RFC822-format the message just to be able
570                  * to measure it.
571                  */
572                 tmp = tmpfile();
573                 if (tmp == NULL) return;
574                 CtdlRedirectOutput(tmp, -1);
575                 CtdlOutputPreLoadedMsg(msg, msgnum, MT_RFC822, 0, 0, 1);
576                 CtdlRedirectOutput(NULL, -1);
577
578                 rewind(tmp);
579                 while (fgets(buf, sizeof buf, tmp) != NULL) ++lines;
580                 bytes = ftell(tmp);
581                 fclose(tmp);
582
583                 cprintf("BODYSTRUCTURE (\"TEXT\" \"PLAIN\" "
584                         "(\"CHARSET\" \"US-ASCII\") NIL NIL "
585                         "\"7BIT\" %ld %ld)", bytes, lines);
586
587                 return;
588         }
589
590         /* For messages already stored in RFC822 format, we have to parse. */
591         cprintf("BODYSTRUCTURE ");
592         mime_parser(msg->cm_fields['M'],
593                         NULL,
594                         *imap_fetch_bodystructure_part, /* part */
595                         *imap_fetch_bodystructure_pre,  /* pre-multi */
596                         *imap_fetch_bodystructure_post, /* post-multi */
597                         NULL,
598                         0);
599 }
600
601
602
603
604
605
606 /*
607  * imap_do_fetch() calls imap_do_fetch_msg() to output the deta of an
608  * individual message, once it has been successfully loaded from disk.
609  */
610 void imap_do_fetch_msg(int seq, struct CtdlMessage *msg,
611                         int num_items, char **itemlist) {
612         int i;
613
614         cprintf("* %d FETCH (", seq);
615
616         for (i=0; i<num_items; ++i) {
617
618                 if (!strncasecmp(itemlist[i], "BODY[", 5)) {
619                         imap_fetch_body(IMAP->msgids[seq-1], itemlist[i],
620                                         0, msg);
621                 }
622                 else if (!strncasecmp(itemlist[i], "BODY.PEEK[", 10)) {
623                         imap_fetch_body(IMAP->msgids[seq-1], itemlist[i],
624                                         1, msg);
625                 }
626                 else if (!strcasecmp(itemlist[i], "BODYSTRUCTURE")) {
627                         imap_fetch_bodystructure(IMAP->msgids[seq-1],
628                                         itemlist[i], msg);
629                 }
630                 else if (!strcasecmp(itemlist[i], "ENVELOPE")) {
631                         imap_fetch_envelope(IMAP->msgids[seq-1], msg);
632                 }
633                 else if (!strcasecmp(itemlist[i], "FLAGS")) {
634                         imap_fetch_flags(msg);
635                 }
636                 else if (!strcasecmp(itemlist[i], "INTERNALDATE")) {
637                         imap_fetch_internaldate(msg);
638                 }
639                 else if (!strcasecmp(itemlist[i], "RFC822")) {
640                         imap_fetch_rfc822(IMAP->msgids[seq-1], itemlist[i], msg);
641                 }
642                 else if (!strcasecmp(itemlist[i], "RFC822.HEADER")) {
643                         imap_fetch_rfc822(IMAP->msgids[seq-1], itemlist[i], msg);
644                 }
645                 else if (!strcasecmp(itemlist[i], "RFC822.SIZE")) {
646                         imap_fetch_rfc822(IMAP->msgids[seq-1], itemlist[i], msg);
647                 }
648                 else if (!strcasecmp(itemlist[i], "RFC822.TEXT")) {
649                         imap_fetch_rfc822(IMAP->msgids[seq-1], itemlist[i], msg);
650                 }
651                 else if (!strcasecmp(itemlist[i], "UID")) {
652                         imap_fetch_uid(seq);
653                 }
654
655                 if (i != num_items-1) cprintf(" ");
656         }
657
658         cprintf(")\r\n");
659 }
660
661
662
663 /*
664  * imap_fetch() calls imap_do_fetch() to do its actual work, once it's
665  * validated and boiled down the request a bit.
666  */
667 void imap_do_fetch(int num_items, char **itemlist) {
668         int i;
669         struct CtdlMessage *msg;
670
671         if (IMAP->num_msgs > 0)
672          for (i = 0; i < IMAP->num_msgs; ++i)
673           if (IMAP->flags[i] && IMAP_FETCHED) {
674                 msg = CtdlFetchMessage(IMAP->msgids[i]);
675                 if (msg != NULL) {
676                         imap_do_fetch_msg(i+1, msg, num_items, itemlist);
677                         CtdlFreeMessage(msg);
678                 }
679                 else {
680                         cprintf("* %d FETCH <internal error>\r\n", i+1);
681                 }
682         }
683 }
684
685
686
687 /*
688  * Back end for imap_handle_macros()
689  * Note that this function *only* looks at the beginning of the string.  It
690  * is not a generic search-and-replace function.
691  */
692 void imap_macro_replace(char *str, char *find, char *replace) {
693         char holdbuf[1024];
694
695         if (!strncasecmp(str, find, strlen(find))) {
696                 if (str[strlen(find)]==' ') {
697                         strcpy(holdbuf, &str[strlen(find)+1]);
698                         strcpy(str, replace);
699                         strcat(str, " ");
700                         strcat(str, holdbuf);
701                 }
702                 if (str[strlen(find)]==0) {
703                         strcpy(holdbuf, &str[strlen(find)+1]);
704                         strcpy(str, replace);
705                 }
706         }
707 }
708
709
710
711 /*
712  * Handle macros embedded in FETCH data items.
713  * (What the heck are macros doing in a wire protocol?  Are we trying to save
714  * the computer at the other end the trouble of typing a lot of characters?)
715  */
716 void imap_handle_macros(char *str) {
717         int i;
718         int nest = 0;
719
720         for (i=0; i<strlen(str); ++i) {
721                 if (str[i]=='(') ++nest;
722                 if (str[i]=='[') ++nest;
723                 if (str[i]=='<') ++nest;
724                 if (str[i]=='{') ++nest;
725                 if (str[i]==')') --nest;
726                 if (str[i]==']') --nest;
727                 if (str[i]=='>') --nest;
728                 if (str[i]=='}') --nest;
729
730                 if (nest <= 0) {
731                         imap_macro_replace(&str[i],
732                                 "ALL",
733                                 "FLAGS INTERNALDATE RFC822.SIZE ENVELOPE"
734                         );
735                         imap_macro_replace(&str[i],
736                                 "BODY",
737                                 "BODYSTRUCTURE"
738                         );
739                         imap_macro_replace(&str[i],
740                                 "FAST",
741                                 "FLAGS INTERNALDATE RFC822.SIZE"
742                         );
743                         imap_macro_replace(&str[i],
744                                 "FULL",
745                                 "FLAGS INTERNALDATE RFC822.SIZE ENVELOPE BODY"
746                         );
747                 }
748         }
749 }
750
751
752 /*
753  * Break out the data items requested, possibly a parenthesized list.
754  * Returns the number of data items, or -1 if the list is invalid.
755  * NOTE: this function alters the string it is fed, and uses it as a buffer
756  * to hold the data for the pointers it returns.
757  */
758 int imap_extract_data_items(char **argv, char *items) {
759         int num_items = 0;
760         int nest = 0;
761         int i, initial_len;
762         char *start;
763
764         /* Convert all whitespace to ordinary space characters. */
765         for (i=0; i<strlen(items); ++i) {
766                 if (isspace(items[i])) items[i]=' ';
767         }
768
769         /* Strip leading and trailing whitespace, then strip leading and
770          * trailing parentheses if it's a list
771          */
772         striplt(items);
773         if ( (items[0]=='(') && (items[strlen(items)-1]==')') ) {
774                 items[strlen(items)-1] = 0;
775                 strcpy(items, &items[1]);
776                 striplt(items);
777         }
778
779         /* Parse any macro data items */
780         imap_handle_macros(items);
781
782         /*
783          * Now break out the data items.  We throw in one trailing space in
784          * order to avoid having to break out the last one manually.
785          */
786         strcat(items, " ");
787         start = items;
788         initial_len = strlen(items);
789         for (i=0; i<initial_len; ++i) {
790                 if (items[i]=='(') ++nest;
791                 if (items[i]=='[') ++nest;
792                 if (items[i]=='<') ++nest;
793                 if (items[i]=='{') ++nest;
794                 if (items[i]==')') --nest;
795                 if (items[i]==']') --nest;
796                 if (items[i]=='>') --nest;
797                 if (items[i]=='}') --nest;
798
799                 if (nest <= 0) if (items[i]==' ') {
800                         items[i] = 0;
801                         argv[num_items++] = start;
802                         start = &items[i+1];
803                 }
804         }
805
806         return(num_items);
807
808 }
809
810
811 /*
812  * One particularly hideous aspect of IMAP is that we have to allow the client
813  * to specify arbitrary ranges and/or sets of messages to fetch.  Citadel IMAP
814  * handles this by setting the IMAP_FETCHED flag for each message specified in
815  * the ranges/sets, then looping through the message array, outputting messages
816  * with the flag set.  We don't bother returning an error if an out-of-range
817  * number is specified (we just return quietly) because any client braindead
818  * enough to request a bogus message number isn't going to notice the
819  * difference anyway.
820  *
821  * This function clears out the IMAP_FETCHED bits, then sets that bit for each
822  * message included in the specified range.
823  *
824  * Set is_uid to 1 to fetch by UID instead of sequence number.
825  */
826 void imap_pick_range(char *range, int is_uid) {
827         int i;
828         int num_sets;
829         int s;
830         char setstr[1024], lostr[1024], histr[1024];
831         int lo, hi;
832         char *actual_range;
833
834         actual_range = range;
835         if (!strcasecmp(range, "ALL")) actual_range = "1:*";
836
837         /*
838          * Clear out the IMAP_FETCHED flags for all messages.
839          */
840         for (i = 1; i <= IMAP->num_msgs; ++i) {
841                 IMAP->flags[i-1] = IMAP->flags[i-1] & ~IMAP_FETCHED;
842         }
843
844         /*
845          * Now set it for all specified messages.
846          */
847         num_sets = num_tokens(actual_range, ',');
848         for (s=0; s<num_sets; ++s) {
849                 extract_token(setstr, actual_range, s, ',');
850
851                 extract_token(lostr, setstr, 0, ':');
852                 if (num_tokens(setstr, ':') >= 2) {
853                         extract_token(histr, setstr, 1, ':');
854                         if (!strcmp(histr, "*")) sprintf(histr, "%d", INT_MAX);
855                 } 
856                 else {
857                         strcpy(histr, lostr);
858                 }
859                 lo = atoi(lostr);
860                 hi = atoi(histr);
861
862                 /* Loop through the array, flipping bits where appropriate */
863                 for (i = 1; i <= IMAP->num_msgs; ++i) {
864                         if (is_uid) {   /* fetch by sequence number */
865                                 if ( (IMAP->msgids[i-1]>=lo)
866                                    && (IMAP->msgids[i-1]<=hi)) {
867                                         IMAP->flags[i-1] =
868                                                 IMAP->flags[i-1] | IMAP_FETCHED;
869                                 }
870                         }
871                         else {          /* fetch by uid */
872                                 if ( (i>=lo) && (i<=hi)) {
873                                         IMAP->flags[i-1] =
874                                                 IMAP->flags[i-1] | IMAP_FETCHED;
875                                 }
876                         }
877                 }
878         }
879 }
880
881
882
883 /*
884  * This function is called by the main command loop.
885  */
886 void imap_fetch(int num_parms, char *parms[]) {
887         char items[1024];
888         char *itemlist[SIZ];
889         int num_items;
890         int i;
891
892         if (num_parms < 4) {
893                 cprintf("%s BAD invalid parameters\r\n", parms[0]);
894                 return;
895         }
896
897         imap_pick_range(parms[2], 0);
898
899         strcpy(items, "");
900         for (i=3; i<num_parms; ++i) {
901                 strcat(items, parms[i]);
902                 if (i < (num_parms-1)) strcat(items, " ");
903         }
904
905         num_items = imap_extract_data_items(itemlist, items);
906         if (num_items < 1) {
907                 cprintf("%s BAD invalid data item list\r\n", parms[0]);
908                 return;
909         }
910
911         imap_do_fetch(num_items, itemlist);
912         cprintf("%s OK FETCH completed\r\n", parms[0]);
913 }
914
915 /*
916  * This function is called by the main command loop.
917  */
918 void imap_uidfetch(int num_parms, char *parms[]) {
919         char items[1024];
920         char *itemlist[SIZ];
921         int num_items;
922         int i;
923         int have_uid_item = 0;
924
925         if (num_parms < 5) {
926                 cprintf("%s BAD invalid parameters\r\n", parms[0]);
927                 return;
928         }
929
930         imap_pick_range(parms[3], 1);
931
932         strcpy(items, "");
933         for (i=4; i<num_parms; ++i) {
934                 strcat(items, parms[i]);
935                 if (i < (num_parms-1)) strcat(items, " ");
936         }
937
938         num_items = imap_extract_data_items(itemlist, items);
939         if (num_items < 1) {
940                 cprintf("%s BAD invalid data item list\r\n", parms[0]);
941                 return;
942         }
943
944         /* If the "UID" item was not included, we include it implicitly
945          * because this is a UID FETCH command
946          */
947         for (i=0; i<num_items; ++i) {
948                 if (!strcasecmp(itemlist[i], "UID")) ++have_uid_item;
949         }
950         if (have_uid_item == 0) itemlist[num_items++] = "UID";
951
952         imap_do_fetch(num_items, itemlist);
953         cprintf("%s OK UID FETCH completed\r\n", parms[0]);
954 }
955
956