1 #include <u.h>
2 #include <libc.h>
3 #include <bio.h>
4 #include <thread.h>
5 #include <ctype.h>
6 #include <plumb.h>
7 #include "dat.h"
8
9 static int replyid;
10
11 int
quote(Message * m,Biobuf * b,char * dir,char * quotetext)12 quote(Message *m, Biobuf *b, char *dir, char *quotetext)
13 {
14 char *body, *type;
15 int i, n, nlines;
16 char **lines;
17
18 if(quotetext){
19 body = quotetext;
20 n = strlen(body);
21 type = nil;
22 }else{
23 /* look for first textual component to quote */
24 type = readfile(dir, "type", &n);
25 if(type == nil){
26 print("no type in %s\n", dir);
27 return 0;
28 }
29 if(strncmp(type, "multipart/", 10)==0 || strncmp(type, "message/", 8)==0){
30 dir = estrstrdup(dir, "1/");
31 if(quote(m, b, dir, nil)){
32 free(type);
33 free(dir);
34 return 1;
35 }
36 free(dir);
37 }
38 if(strncmp(type, "text", 4) != 0){
39 free(type);
40 return 0;
41 }
42 body = readbody(m->type, dir, &n);
43 if(body == nil)
44 return 0;
45 }
46 nlines = 0;
47 for(i=0; i<n; i++)
48 if(body[i] == '\n')
49 nlines++;
50 nlines++;
51 lines = emalloc(nlines*sizeof(char*));
52 nlines = getfields(body, lines, nlines, 0, "\n");
53 /* delete leading and trailing blank lines */
54 i = 0;
55 while(i<nlines && lines[i][0]=='\0')
56 i++;
57 while(i<nlines && lines[nlines-1][0]=='\0')
58 nlines--;
59 while(i < nlines){
60 Bprint(b, ">%s%s\n", lines[i][0]=='>'? "" : " ", lines[i]);
61 i++;
62 }
63 free(lines);
64 free(body); /* will free quotetext if non-nil */
65 free(type);
66 return 1;
67 }
68
69 void
mkreply(Message * m,char * label,char * to,Plumbattr * attr,char * quotetext)70 mkreply(Message *m, char *label, char *to, Plumbattr *attr, char *quotetext)
71 {
72 Message *r;
73 char *dir, *t;
74 int quotereply;
75 Plumbattr *a;
76
77 quotereply = (label[0] == 'Q');
78 r = emalloc(sizeof(Message));
79 r->isreply = 1;
80 if(m != nil)
81 r->replyname = estrdup(m->name);
82 r->next = replies.head;
83 r->prev = nil;
84 if(replies.head != nil)
85 replies.head->prev = r;
86 replies.head = r;
87 if(replies.tail == nil)
88 replies.tail = r;
89 r->name = emalloc(strlen(mbox.name)+strlen(label)+10);
90 sprint(r->name, "%s%s%d", mbox.name, label, ++replyid);
91 r->w = newwindow();
92 winname(r->w, r->name);
93 ctlprint(r->w->ctl, "cleartag");
94 wintagwrite(r->w, "fmt Look Post Undo", 4+5+5+4);
95 r->tagposted = 1;
96 threadcreate(mesgctl, r, STACK);
97 winopenbody(r->w, OWRITE);
98 if(to!=nil && to[0]!='\0')
99 Bprint(r->w->body, "%s\n", to);
100 for(a=attr; a; a=a->next)
101 Bprint(r->w->body, "%s: %s\n", a->name, a->value);
102 dir = nil;
103 if(m != nil){
104 dir = estrstrdup(mbox.name, m->name);
105 if(to == nil && attr == nil){
106 /* Reply goes to replyto; Reply all goes to From and To and CC */
107 if(strstr(label, "all") == nil)
108 Bprint(r->w->body, "To: %s\n", m->replyto);
109 else{ /* Replyall */
110 if(strlen(m->from) > 0)
111 Bprint(r->w->body, "To: %s\n", m->from);
112 if(strlen(m->to) > 0)
113 Bprint(r->w->body, "To: %s\n", m->to);
114 if(strlen(m->cc) > 0)
115 Bprint(r->w->body, "CC: %s\n", m->cc);
116 }
117 }
118 if(strlen(m->subject) > 0){
119 t = "Subject: Re: ";
120 if(strlen(m->subject) >= 3)
121 if(tolower(m->subject[0])=='r' && tolower(m->subject[1])=='e' && m->subject[2]==':')
122 t = "Subject: ";
123 Bprint(r->w->body, "%s%s\n", t, m->subject);
124 }
125 if(!quotereply){
126 Bprint(r->w->body, "Include: %sraw\n", dir);
127 free(dir);
128 }
129 }
130 Bprint(r->w->body, "\n");
131 if(m == nil)
132 Bprint(r->w->body, "\n");
133 else if(quotereply){
134 quote(m, r->w->body, dir, quotetext);
135 free(dir);
136 }
137 winclosebody(r->w);
138 if(m==nil && (to==nil || to[0]=='\0'))
139 winselect(r->w, "0", 0);
140 else
141 winselect(r->w, "$", 0);
142 winclean(r->w);
143 windormant(r->w);
144 }
145
146 void
delreply(Message * m)147 delreply(Message *m)
148 {
149 if(m->next == nil)
150 replies.tail = m->prev;
151 else
152 m->next->prev = m->prev;
153 if(m->prev == nil)
154 replies.head = m->next;
155 else
156 m->prev->next = m->next;
157 mesgfreeparts(m);
158 free(m);
159 }
160
161 /* copy argv to stack and free the incoming strings, so we don't leak argument vectors */
162 void
buildargv(char ** inargv,char * argv[NARGS+1],char args[NARGCHAR])163 buildargv(char **inargv, char *argv[NARGS+1], char args[NARGCHAR])
164 {
165 int i, n;
166 char *s, *a;
167
168 s = args;
169 for(i=0; i<NARGS; i++){
170 a = inargv[i];
171 if(a == nil)
172 break;
173 n = strlen(a)+1;
174 if((s-args)+n >= NARGCHAR) /* too many characters */
175 break;
176 argv[i] = s;
177 memmove(s, a, n);
178 s += n;
179 free(a);
180 }
181 argv[i] = nil;
182 }
183
184 void
execproc(void * v)185 execproc(void *v)
186 {
187 struct Exec *e;
188 int p[2], q[2];
189 char *prog;
190 char *argv[NARGS+1], args[NARGCHAR];
191
192 e = v;
193 p[0] = e->p[0];
194 p[1] = e->p[1];
195 q[0] = e->q[0];
196 q[1] = e->q[1];
197 prog = e->prog; /* known not to be malloc'ed */
198 rfork(RFFDG);
199 sendul(e->sync, 1);
200 buildargv(e->argv, argv, args);
201 free(e->argv);
202 chanfree(e->sync);
203 free(e);
204 dup(p[0], 0);
205 close(p[0]);
206 close(p[1]);
207 if(q[0]){
208 dup(q[1], 1);
209 close(q[0]);
210 close(q[1]);
211 }
212 procexec(nil, prog, argv);
213 //fprint(2, "exec: %s", e->prog);
214 //{int i;
215 //for(i=0; argv[i]; i++) print(" '%s'", argv[i]);
216 //print("\n");
217 //}
218 //argv[0] = "cat";
219 //argv[1] = nil;
220 //procexec(nil, "/bin/cat", argv);
221 fprint(2, "Mail: can't exec %s: %r\n", prog);
222 threadexits("can't exec");
223 }
224
225 enum{
226 ATTACH,
227 BCC,
228 CC,
229 FROM,
230 INCLUDE,
231 TO,
232 };
233
234 char *headers[] = {
235 "attach:",
236 "bcc:",
237 "cc:",
238 "from:",
239 "include:",
240 "to:",
241 nil,
242 };
243
244 int
whichheader(char * h)245 whichheader(char *h)
246 {
247 int i;
248
249 for(i=0; headers[i]!=nil; i++)
250 if(cistrcmp(h, headers[i]) == 0)
251 return i;
252 return -1;
253 }
254
255 char *tolist[200];
256 char *cclist[200];
257 char *bcclist[200];
258 int ncc, nbcc, nto;
259 char *attlist[200];
260 char included[200];
261
262 int
addressed(char * name)263 addressed(char *name)
264 {
265 int i;
266
267 for(i=0; i<nto; i++)
268 if(strcmp(name, tolist[i]) == 0)
269 return 1;
270 for(i=0; i<ncc; i++)
271 if(strcmp(name, cclist[i]) == 0)
272 return 1;
273 for(i=0; i<nbcc; i++)
274 if(strcmp(name, bcclist[i]) == 0)
275 return 1;
276 return 0;
277 }
278
279 char*
skipbl(char * s,char * e)280 skipbl(char *s, char *e)
281 {
282 while(s < e){
283 if(*s!=' ' && *s!='\t' && *s!=',')
284 break;
285 s++;
286 }
287 return s;
288 }
289
290 char*
findbl(char * s,char * e)291 findbl(char *s, char *e)
292 {
293 while(s < e){
294 if(*s==' ' || *s=='\t' || *s==',')
295 break;
296 s++;
297 }
298 return s;
299 }
300
301 /*
302 * comma-separate possibly blank-separated strings in line; e points before newline
303 */
304 void
commas(char * s,char * e)305 commas(char *s, char *e)
306 {
307 char *t;
308
309 /* may have initial blanks */
310 s = skipbl(s, e);
311 while(s < e){
312 s = findbl(s, e);
313 if(s == e)
314 break;
315 t = skipbl(s, e);
316 if(t == e) /* no more words */
317 break;
318 /* patch comma */
319 *s++ = ',';
320 while(s < t)
321 *s++ = ' ';
322 }
323 }
324
325 int
print2(int fd,int ofd,char * fmt,...)326 print2(int fd, int ofd, char *fmt, ...)
327 {
328 int m, n;
329 char *s;
330 va_list arg;
331
332 va_start(arg, fmt);
333 s = vsmprint(fmt, arg);
334 va_end(arg);
335 if(s == nil)
336 return -1;
337 m = strlen(s);
338 n = write(fd, s, m);
339 if(ofd > 0)
340 write(ofd, s, m);
341 return n;
342 }
343
344 int
write2(int fd,int ofd,char * buf,int n,int nofrom)345 write2(int fd, int ofd, char *buf, int n, int nofrom)
346 {
347 char *from, *p;
348 int m = 0;
349
350 if(fd >= 0)
351 m = write(fd, buf, n);
352
353 if(ofd <= 0)
354 return m;
355
356 if(nofrom == 0)
357 return write(ofd, buf, n);
358
359 /* need to escape leading From lines to avoid corrupting 'outgoing' mailbox */
360 for(p=buf; *p; p+=m){
361 from = cistrstr(p, "from");
362 if(from == nil)
363 m = n;
364 else
365 m = from - p;
366 if(m > 0)
367 write(ofd, p, m);
368 if(from){
369 /* escape with space if From is at start of line */
370 if(p==buf || from[-1]=='\n')
371 write(ofd, " ", 1);
372 write(ofd, from, 4);
373 m += 4;
374 }
375 n -= m;
376 }
377 return p - buf;
378 }
379
380 void
mesgsend(Message * m)381 mesgsend(Message *m)
382 {
383 char *s, *body, *to;
384 int i, j, h, n, natt, p[2];
385 struct Exec *e;
386 Channel *sync;
387 int first, nfld, delit, ofd;
388 char *copy, *fld[100], *now;
389
390 body = winreadbody(m->w, &n);
391 /* assemble to: list from first line, to: line, and cc: line */
392 nto = 0;
393 natt = 0;
394 ncc = 0;
395 nbcc = 0;
396 first = 1;
397 to = body;
398 for(;;){
399 for(s=to; *s!='\n'; s++)
400 if(*s == '\0'){
401 free(body);
402 return;
403 }
404 if(s++ == to) /* blank line */
405 break;
406 /* make copy of line to tokenize */
407 copy = emalloc(s-to);
408 memmove(copy, to, s-to);
409 copy[s-to-1] = '\0';
410 nfld = tokenizec(copy, fld, nelem(fld), ", \t");
411 if(nfld == 0){
412 free(copy);
413 break;
414 }
415 n -= s-to;
416 switch(h = whichheader(fld[0])){
417 case TO:
418 case FROM:
419 delit = 1;
420 commas(to+strlen(fld[0]), s-1);
421 for(i=1; i<nfld && nto<nelem(tolist); i++)
422 if(!addressed(fld[i]))
423 tolist[nto++] = estrdup(fld[i]);
424 break;
425 case BCC:
426 delit = 1;
427 commas(to+strlen(fld[0]), s-1);
428 for(i=1; i<nfld && nbcc<nelem(bcclist); i++)
429 if(!addressed(fld[i]))
430 bcclist[nbcc++] = estrdup(fld[i]);
431 break;
432 case CC:
433 delit = 1;
434 commas(to+strlen(fld[0]), s-1);
435 for(i=1; i<nfld && ncc<nelem(cclist); i++)
436 if(!addressed(fld[i]))
437 cclist[ncc++] = estrdup(fld[i]);
438 break;
439 case ATTACH:
440 case INCLUDE:
441 delit = 1;
442 for(i=1; i<nfld && natt<nelem(attlist); i++){
443 attlist[natt] = estrdup(fld[i]);
444 included[natt++] = (h == INCLUDE);
445 }
446 break;
447 default:
448 if(first){
449 delit = 1;
450 for(i=0; i<nfld && nto<nelem(tolist); i++)
451 tolist[nto++] = estrdup(fld[i]);
452 }else /* ignore it */
453 delit = 0;
454 break;
455 }
456 if(delit){
457 /* delete line from body */
458 memmove(to, s, n+1);
459 }else
460 to = s;
461 free(copy);
462 first = 0;
463 }
464
465 ofd = open(outgoing, OWRITE|OCEXEC); /* no error check necessary */
466 if(ofd > 0){
467 /* From dhog Fri Aug 24 22:13:00 EDT 2001 */
468 now = ctime(time(0));
469 fprint(ofd, "From %s %s", user, now);
470 fprint(ofd, "From: %s\n", user);
471 fprint(ofd, "Date: %s", now);
472 for(i=0; i<natt; i++)
473 if(included[i])
474 fprint(ofd, "Include: %s\n", attlist[i]);
475 else
476 fprint(ofd, "Attach: %s\n", attlist[i]);
477 /* needed because mail is by default Latin-1 */
478 fprint(ofd, "Content-Type: text/plain; charset=\"UTF-8\"\n");
479 fprint(ofd, "Content-Transfer-Encoding: 8bit\n");
480 }
481
482 e = emalloc(sizeof(struct Exec));
483 if(pipe(p) < 0)
484 error("can't create pipe: %r");
485 e->p[0] = p[0];
486 e->p[1] = p[1];
487 e->prog = "/bin/upas/marshal";
488 e->argv = emalloc((1+1+2+4*natt+1)*sizeof(char*));
489 e->argv[0] = estrdup("marshal");
490 e->argv[1] = estrdup("-8");
491 j = 2;
492 if(m->replyname){
493 e->argv[j++] = estrdup("-R");
494 e->argv[j++] = estrstrdup(mbox.name, m->replyname);
495 }
496 for(i=0; i<natt; i++){
497 if(included[i])
498 e->argv[j++] = estrdup("-A");
499 else
500 e->argv[j++] = estrdup("-a");
501 e->argv[j++] = estrdup(attlist[i]);
502 }
503 sync = chancreate(sizeof(int), 0);
504 e->sync = sync;
505 proccreate(execproc, e, EXECSTACK);
506 recvul(sync);
507 close(p[0]);
508
509 /* using marshal -8, so generate rfc822 headers */
510 if(nto > 0){
511 print2(p[1], ofd, "To: ");
512 for(i=0; i<nto-1; i++)
513 print2(p[1], ofd, "%s, ", tolist[i]);
514 print2(p[1], ofd, "%s\n", tolist[i]);
515 }
516 if(ncc > 0){
517 print2(p[1], ofd, "CC: ");
518 for(i=0; i<ncc-1; i++)
519 print2(p[1], ofd, "%s, ", cclist[i]);
520 print2(p[1], ofd, "%s\n", cclist[i]);
521 }
522 if(nbcc > 0){
523 print2(p[1], ofd, "BCC: ");
524 for(i=0; i<nbcc-1; i++)
525 print2(p[1], ofd, "%s, ", bcclist[i]);
526 print2(p[1], ofd, "%s\n", bcclist[i]);
527 }
528
529 i = strlen(body);
530 if(i > 0)
531 write2(p[1], ofd, body, i, 1);
532
533 /* guarantee a blank line, to ensure attachments are separated from body */
534 if(i==0 || body[i-1]!='\n')
535 write2(p[1], ofd, "\n\n", 2, 0);
536 else if(i>1 && body[i-2]!='\n')
537 write2(p[1], ofd, "\n", 1, 0);
538
539 /* these look like pseudo-attachments in the "outgoing" box */
540 if(ofd>0 && natt>0){
541 for(i=0; i<natt; i++)
542 if(included[i])
543 fprint(ofd, "=====> Include: %s\n", attlist[i]);
544 else
545 fprint(ofd, "=====> Attach: %s\n", attlist[i]);
546 }
547 if(ofd > 0)
548 write(ofd, "\n", 1);
549
550 for(i=0; i<natt; i++)
551 free(attlist[i]);
552 close(ofd);
553 close(p[1]);
554 free(body);
555
556 if(m->replyname != nil)
557 mesgmenumark(mbox.w, m->replyname, "\t[replied]");
558 if(m->name[0] == '/')
559 s = estrdup(m->name);
560 else
561 s = estrstrdup(mbox.name, m->name);
562 s = egrow(s, "-R", nil);
563 winname(m->w, s);
564 free(s);
565 winclean(m->w);
566 /* mark message unopened because it's no longer the original message */
567 m->opened = 0;
568 }
569