123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577 |
- /*
- * This file is part of the UCB release of Plan 9. It is subject to the license
- * terms in the LICENSE file found in the top-level directory of this
- * distribution and at http://akaros.cs.berkeley.edu/files/Plan9License. No
- * part of the UCB release of Plan 9, including this file, may be copied,
- * modified, propagated, or distributed except according to the terms contained
- * in the LICENSE file.
- */
- #include <u.h>
- #include <libc.h>
- #include <bio.h>
- #include <thread.h>
- #include <ctype.h>
- #include <plumb.h>
- #include "dat.h"
- static int replyid;
- int
- quote(Message *m, Biobuf *b, char *dir, char *quotetext)
- {
- char *body, *type;
- int i, n, nlines;
- char **lines;
- if(quotetext){
- body = quotetext;
- n = strlen(body);
- type = nil;
- }else{
- /* look for first textual component to quote */
- type = readfile(dir, "type", &n);
- if(type == nil){
- print("no type in %s\n", dir);
- return 0;
- }
- if(strncmp(type, "multipart/", 10)==0 || strncmp(type, "message/", 8)==0){
- dir = estrstrdup(dir, "1/");
- if(quote(m, b, dir, nil)){
- free(type);
- free(dir);
- return 1;
- }
- free(dir);
- }
- if(strncmp(type, "text", 4) != 0){
- free(type);
- return 0;
- }
- body = readbody(m->type, dir, &n);
- if(body == nil)
- return 0;
- }
- nlines = 0;
- for(i=0; i<n; i++)
- if(body[i] == '\n')
- nlines++;
- nlines++;
- lines = emalloc(nlines*sizeof(char*));
- nlines = getfields(body, lines, nlines, 0, "\n");
- /* delete leading and trailing blank lines */
- i = 0;
- while(i<nlines && lines[i][0]=='\0')
- i++;
- while(i<nlines && lines[nlines-1][0]=='\0')
- nlines--;
- while(i < nlines){
- Bprint(b, ">%s%s\n", lines[i][0]=='>'? "" : " ", lines[i]);
- i++;
- }
- free(lines);
- free(body); /* will free quotetext if non-nil */
- free(type);
- return 1;
- }
- void
- mkreply(Message *m, char *label, char *to, Plumbattr *attr, char *quotetext)
- {
- Message *r;
- char *dir, *t;
- int quotereply;
- Plumbattr *a;
- quotereply = (label[0] == 'Q');
- r = emalloc(sizeof(Message));
- r->isreply = 1;
- if(m != nil)
- r->replyname = estrdup(m->name);
- r->next = replies.head;
- r->prev = nil;
- if(replies.head != nil)
- replies.head->prev = r;
- replies.head = r;
- if(replies.tail == nil)
- replies.tail = r;
- r->name = emalloc(strlen(mbox.name)+strlen(label)+10);
- sprint(r->name, "%s%s%d", mbox.name, label, ++replyid);
- r->w = newwindow();
- winname(r->w, r->name);
- ctlprint(r->w->ctl, "cleartag");
- wintagwrite(r->w, "fmt Look Post Undo", 4+5+5+4);
- r->tagposted = 1;
- threadcreate(mesgctl, r, STACK);
- winopenbody(r->w, OWRITE);
- if(to!=nil && to[0]!='\0')
- Bprint(r->w->body, "%s\n", to);
- for(a=attr; a; a=a->next)
- Bprint(r->w->body, "%s: %s\n", a->name, a->value);
- dir = nil;
- if(m != nil){
- dir = estrstrdup(mbox.name, m->name);
- if(to == nil && attr == nil){
- /* Reply goes to replyto; Reply all goes to From and To and CC */
- if(strstr(label, "all") == nil)
- Bprint(r->w->body, "To: %s\n", m->replyto);
- else{ /* Replyall */
- if(strlen(m->from) > 0)
- Bprint(r->w->body, "To: %s\n", m->from);
- if(strlen(m->to) > 0)
- Bprint(r->w->body, "To: %s\n", m->to);
- if(strlen(m->cc) > 0)
- Bprint(r->w->body, "CC: %s\n", m->cc);
- }
- }
- if(strlen(m->subject) > 0){
- t = "Subject: Re: ";
- if(strlen(m->subject) >= 3)
- if(tolower(m->subject[0])=='r' && tolower(m->subject[1])=='e' && m->subject[2]==':')
- t = "Subject: ";
- Bprint(r->w->body, "%s%s\n", t, m->subject);
- }
- if(!quotereply){
- Bprint(r->w->body, "Include: %sraw\n", dir);
- free(dir);
- }
- }
- Bprint(r->w->body, "\n");
- if(m == nil)
- Bprint(r->w->body, "\n");
- else if(quotereply){
- quote(m, r->w->body, dir, quotetext);
- free(dir);
- }
- winclosebody(r->w);
- if(m==nil && (to==nil || to[0]=='\0'))
- winselect(r->w, "0", 0);
- else
- winselect(r->w, "$", 0);
- winclean(r->w);
- windormant(r->w);
- }
- void
- delreply(Message *m)
- {
- if(m->next == nil)
- replies.tail = m->prev;
- else
- m->next->prev = m->prev;
- if(m->prev == nil)
- replies.head = m->next;
- else
- m->prev->next = m->next;
- mesgfreeparts(m);
- free(m);
- }
- /* copy argv to stack and free the incoming strings, so we don't leak argument vectors */
- void
- buildargv(char **inargv, char *argv[NARGS+1], char args[NARGCHAR])
- {
- int i, n;
- char *s, *a;
- s = args;
- for(i=0; i<NARGS; i++){
- a = inargv[i];
- if(a == nil)
- break;
- n = strlen(a)+1;
- if((s-args)+n >= NARGCHAR) /* too many characters */
- break;
- argv[i] = s;
- memmove(s, a, n);
- s += n;
- free(a);
- }
- argv[i] = nil;
- }
- void
- execproc(void *v)
- {
- struct Exec *e;
- int p[2], q[2];
- char *prog;
- char *argv[NARGS+1], args[NARGCHAR];
- e = v;
- p[0] = e->p[0];
- p[1] = e->p[1];
- q[0] = e->q[0];
- q[1] = e->q[1];
- prog = e->prog; /* known not to be malloc'ed */
- rfork(RFFDG);
- sendul(e->sync, 1);
- buildargv(e->argv, argv, args);
- free(e->argv);
- chanfree(e->sync);
- free(e);
- dup(p[0], 0);
- close(p[0]);
- close(p[1]);
- if(q[0]){
- dup(q[1], 1);
- close(q[0]);
- close(q[1]);
- }
- procexec(nil, prog, argv);
- //fprint(2, "exec: %s", e->prog);
- //{int i;
- //for(i=0; argv[i]; i++) print(" '%s'", argv[i]);
- //print("\n");
- //}
- //argv[0] = "cat";
- //argv[1] = nil;
- //procexec(nil, "/bin/cat", argv);
- fprint(2, "Mail: can't exec %s: %r\n", prog);
- threadexits("can't exec");
- }
- enum{
- ATTACH,
- BCC,
- CC,
- FROM,
- INCLUDE,
- TO,
- };
- char *headers[] = {
- "attach:",
- "bcc:",
- "cc:",
- "from:",
- "include:",
- "to:",
- nil,
- };
- int
- whichheader(char *h)
- {
- int i;
- for(i=0; headers[i]!=nil; i++)
- if(cistrcmp(h, headers[i]) == 0)
- return i;
- return -1;
- }
- char *tolist[200];
- char *cclist[200];
- char *bcclist[200];
- int ncc, nbcc, nto;
- char *attlist[200];
- char included[200];
- int
- addressed(char *name)
- {
- int i;
- for(i=0; i<nto; i++)
- if(strcmp(name, tolist[i]) == 0)
- return 1;
- for(i=0; i<ncc; i++)
- if(strcmp(name, cclist[i]) == 0)
- return 1;
- for(i=0; i<nbcc; i++)
- if(strcmp(name, bcclist[i]) == 0)
- return 1;
- return 0;
- }
- char*
- skipbl(char *s, char *e)
- {
- while(s < e){
- if(*s!=' ' && *s!='\t' && *s!=',')
- break;
- s++;
- }
- return s;
- }
- char*
- findbl(char *s, char *e)
- {
- while(s < e){
- if(*s==' ' || *s=='\t' || *s==',')
- break;
- s++;
- }
- return s;
- }
- /*
- * comma-separate possibly blank-separated strings in line; e points before newline
- */
- void
- commas(char *s, char *e)
- {
- char *t;
- /* may have initial blanks */
- s = skipbl(s, e);
- while(s < e){
- s = findbl(s, e);
- if(s == e)
- break;
- t = skipbl(s, e);
- if(t == e) /* no more words */
- break;
- /* patch comma */
- *s++ = ',';
- while(s < t)
- *s++ = ' ';
- }
- }
- int
- print2(int fd, int ofd, char *fmt, ...)
- {
- int m, n;
- char *s;
- va_list arg;
- va_start(arg, fmt);
- s = vsmprint(fmt, arg);
- va_end(arg);
- if(s == nil)
- return -1;
- m = strlen(s);
- n = write(fd, s, m);
- if(ofd > 0)
- write(ofd, s, m);
- return n;
- }
- int
- write2(int fd, int ofd, char *buf, int n, int nofrom)
- {
- char *from, *p;
- int m = 0;
- if(fd >= 0)
- m = write(fd, buf, n);
- if(ofd <= 0)
- return m;
- if(nofrom == 0)
- return write(ofd, buf, n);
- /* need to escape leading From lines to avoid corrupting 'outgoing' mailbox */
- for(p=buf; *p; p+=m){
- from = cistrstr(p, "from");
- if(from == nil)
- m = n;
- else
- m = from - p;
- if(m > 0)
- write(ofd, p, m);
- if(from){
- /* escape with space if From is at start of line */
- if(p==buf || from[-1]=='\n')
- write(ofd, " ", 1);
- write(ofd, from, 4);
- m += 4;
- }
- n -= m;
- }
- return p - buf;
- }
- void
- mesgsend(Message *m)
- {
- char *s, *body, *to;
- int i, j, h, n, natt, p[2];
- struct Exec *e;
- Channel *sync;
- int first, nfld, delit, ofd;
- char *copy, *fld[100], *now;
- body = winreadbody(m->w, &n);
- /* assemble to: list from first line, to: line, and cc: line */
- nto = 0;
- natt = 0;
- ncc = 0;
- nbcc = 0;
- first = 1;
- to = body;
- for(;;){
- for(s=to; *s!='\n'; s++)
- if(*s == '\0'){
- free(body);
- return;
- }
- if(s++ == to) /* blank line */
- break;
- /* make copy of line to tokenize */
- copy = emalloc(s-to);
- memmove(copy, to, s-to);
- copy[s-to-1] = '\0';
- nfld = tokenizec(copy, fld, nelem(fld), ", \t");
- if(nfld == 0){
- free(copy);
- break;
- }
- n -= s-to;
- switch(h = whichheader(fld[0])){
- case TO:
- case FROM:
- delit = 1;
- commas(to+strlen(fld[0]), s-1);
- for(i=1; i<nfld && nto<nelem(tolist); i++)
- if(!addressed(fld[i]))
- tolist[nto++] = estrdup(fld[i]);
- break;
- case BCC:
- delit = 1;
- commas(to+strlen(fld[0]), s-1);
- for(i=1; i<nfld && nbcc<nelem(bcclist); i++)
- if(!addressed(fld[i]))
- bcclist[nbcc++] = estrdup(fld[i]);
- break;
- case CC:
- delit = 1;
- commas(to+strlen(fld[0]), s-1);
- for(i=1; i<nfld && ncc<nelem(cclist); i++)
- if(!addressed(fld[i]))
- cclist[ncc++] = estrdup(fld[i]);
- break;
- case ATTACH:
- case INCLUDE:
- delit = 1;
- for(i=1; i<nfld && natt<nelem(attlist); i++){
- attlist[natt] = estrdup(fld[i]);
- included[natt++] = (h == INCLUDE);
- }
- break;
- default:
- if(first){
- delit = 1;
- for(i=0; i<nfld && nto<nelem(tolist); i++)
- tolist[nto++] = estrdup(fld[i]);
- }else /* ignore it */
- delit = 0;
- break;
- }
- if(delit){
- /* delete line from body */
- memmove(to, s, n+1);
- }else
- to = s;
- free(copy);
- first = 0;
- }
- ofd = open(outgoing, OWRITE|OCEXEC); /* no error check necessary */
- if(ofd > 0){
- /* From dhog Fri Aug 24 22:13:00 EDT 2001 */
- now = ctime(time(0));
- fprint(ofd, "From %s %s", user, now);
- fprint(ofd, "From: %s\n", user);
- fprint(ofd, "Date: %s", now);
- for(i=0; i<natt; i++)
- if(included[i])
- fprint(ofd, "Include: %s\n", attlist[i]);
- else
- fprint(ofd, "Attach: %s\n", attlist[i]);
- /* needed because mail is by default Latin-1 */
- fprint(ofd, "Content-Type: text/plain; charset=\"UTF-8\"\n");
- fprint(ofd, "Content-Transfer-Encoding: 8bit\n");
- }
- e = emalloc(sizeof(struct Exec));
- if(pipe(p) < 0)
- error("can't create pipe: %r");
- e->p[0] = p[0];
- e->p[1] = p[1];
- e->prog = "/bin/upas/marshal";
- e->argv = emalloc((1+1+2+4*natt+1)*sizeof(char*));
- e->argv[0] = estrdup("marshal");
- e->argv[1] = estrdup("-8");
- j = 2;
- if(m->replyname){
- e->argv[j++] = estrdup("-R");
- e->argv[j++] = estrstrdup(mbox.name, m->replyname);
- }
- for(i=0; i<natt; i++){
- if(included[i])
- e->argv[j++] = estrdup("-A");
- else
- e->argv[j++] = estrdup("-a");
- e->argv[j++] = estrdup(attlist[i]);
- }
- sync = chancreate(sizeof(int), 0);
- e->sync = sync;
- proccreate(execproc, e, EXECSTACK);
- recvul(sync);
- close(p[0]);
- /* using marshal -8, so generate rfc822 headers */
- if(nto > 0){
- print2(p[1], ofd, "To: ");
- for(i=0; i<nto-1; i++)
- print2(p[1], ofd, "%s, ", tolist[i]);
- print2(p[1], ofd, "%s\n", tolist[i]);
- }
- if(ncc > 0){
- print2(p[1], ofd, "CC: ");
- for(i=0; i<ncc-1; i++)
- print2(p[1], ofd, "%s, ", cclist[i]);
- print2(p[1], ofd, "%s\n", cclist[i]);
- }
- if(nbcc > 0){
- print2(p[1], ofd, "BCC: ");
- for(i=0; i<nbcc-1; i++)
- print2(p[1], ofd, "%s, ", bcclist[i]);
- print2(p[1], ofd, "%s\n", bcclist[i]);
- }
- i = strlen(body);
- if(i > 0)
- write2(p[1], ofd, body, i, 1);
- /* guarantee a blank line, to ensure attachments are separated from body */
- if(i==0 || body[i-1]!='\n')
- write2(p[1], ofd, "\n\n", 2, 0);
- else if(i>1 && body[i-2]!='\n')
- write2(p[1], ofd, "\n", 1, 0);
- /* these look like pseudo-attachments in the "outgoing" box */
- if(ofd>0 && natt>0){
- for(i=0; i<natt; i++)
- if(included[i])
- fprint(ofd, "=====> Include: %s\n", attlist[i]);
- else
- fprint(ofd, "=====> Attach: %s\n", attlist[i]);
- }
- if(ofd > 0)
- write(ofd, "\n", 1);
- for(i=0; i<natt; i++)
- free(attlist[i]);
- close(ofd);
- close(p[1]);
- free(body);
- if(m->replyname != nil)
- mesgmenumark(mbox.w, m->replyname, "\t[replied]");
- if(m->name[0] == '/')
- s = estrdup(m->name);
- else
- s = estrstrdup(mbox.name, m->name);
- s = egrow(s, "-R", nil);
- winname(m->w, s);
- free(s);
- winclean(m->w);
- /* mark message unopened because it's no longer the original message */
- m->opened = 0;
- }
|