ref: 260d1eaaa73a377fb7b0cfc00707ddba35a54ccd
dir: /sys/src/cmd/upas/Mail/mesg.c/
#include <u.h>
#include <libc.h>
#include <bio.h>
#include <thread.h>
#include <ctype.h>
#include <plumb.h>
#include "dat.h"
enum
{
DIRCHUNK = 32*sizeof(Dir)
};
char regexchars[] = "\\/[].+?()*^$";
char deleted[] = "(deleted)-";
char deletedrx[] = "\\(deleted\\)-";
char deletedrx01[] = "(\\(deleted\\)-)?";
char deletedaddr[] = "-#0;/^\\(deleted\\)-/";
struct{
char *type;
char *port;
char *suffix;
} ports[] = {
"text/", "edit", ".txt", /* must be first for plumbport() */
/* text must be first for plumbport() */
"image/gif", "image", ".gif",
"image/jpeg", "image", ".jpg",
"image/jpeg", "image", ".jpeg",
"image/png", "image", ".png",
"image/tiff", "image", ".tif",
"application/postscript", "postscript", ".ps",
"application/pdf", "postscript", ".pdf",
"application/msword", "msword", ".doc",
"application/rtf", "msword", ".rtf",
"audio/x-wav", "wav", ".wav",
nil, nil
};
char *goodtypes[] = {
"text",
"text/plain",
"message/rfc822",
"text/richtext",
"text/tab-separated-values",
"application/octet-stream",
nil,
};
struct{
char *type;
char *ext;
} exts[] = {
"image/gif", ".gif",
"image/jpeg", ".jpg",
nil, nil
};
char *okheaders[] =
{
"From:",
"Date:",
"To:",
"CC:",
"Subject:",
nil
};
char *extraheaders[] =
{
"Resent-From:",
"Resent-To:",
"Sort:",
nil,
};
char*
line(char *data, char **pp)
{
char *p, *q;
for(p=data; *p!='\0' && *p!='\n'; p++)
;
if(*p == '\n')
*pp = p+1;
else
*pp = p;
q = emalloc(p-data + 1);
memmove(q, data, p-data);
return q;
}
char*
fc(Message *m, char *s)
{
char *r;
if(*s && *m->from){
r = smprint("%s <%s>", s, m->from);
free(s);
return r;
}else if(*s)
return s;
else if(*m->from)
return estrdup(m->from);
return estrdup("??");
}
int
loadinfo(Message *m, char *dir)
{
int n;
char *data, *p;
data = readfile(dir, "info", &n);
if(data == nil)
return 0;
m->from = line(data, &p);
m->to = line(p, &p);
m->cc = line(p, &p);
m->replyto = line(p, &p);
m->date = line(p, &p);
m->subject = line(p, &p);
m->type = line(p, &p);
m->disposition = line(p, &p);
m->filename = line(p, &p);
m->digest = line(p, &p);
/* m->bcc = */ free(line(p, &p));
/* m->inreplyto = */ free(line(p, &p));
/* m->date = */ free(line(p, &p));
/* m->sender = */ free(line(p, &p));
/* m->messageid = */ free(line(p, &p));
/* m->lines = */ free(line(p, &p));
/* m->size = */ free(line(p, &p));
m->flags = line(p, &p);
/* m->fileid = */ free(line(p, &p));
m->fromcolon = fc(m, line(p, &p));
free(data);
return 1;
}
int
isnumeric(char *s)
{
while(*s){
if(!isdigit(*s))
return 0;
s++;
}
return 1;
}
Dir*
loaddir(char *name, int *np)
{
int fd;
Dir *dp;
fd = open(name, OREAD);
if(fd < 0)
return nil;
*np = dirreadall(fd, &dp);
close(fd);
return dp;
}
void
readmbox(Message *mbox, char *dir, char *subdir)
{
char *name;
Dir *d, *dirp;
int i, n;
name = estrstrdup(dir, subdir);
dirp = loaddir(name, &n);
mbox->recursed = 1;
if(dirp)
for(i=0; i<n; i++){
d = &dirp[i];
if(isnumeric(d->name))
mesgadd(mbox, name, d, nil);
}
free(dirp);
free(name);
}
/* add message to box, in increasing numerical order */
int
mesgadd(Message *mbox, char *dir, Dir *d, char *digest)
{
Message *m;
char *name;
int loaded;
m = emalloc(sizeof(Message));
m->name = estrstrdup(d->name, "/");
m->next = nil;
m->prev = mbox->tail;
m->level= mbox->level+1;
m->recursed = 0;
name = estrstrdup(dir, m->name);
loaded = loadinfo(m, name);
free(name);
/* if two upas/fs are running, we can get misled, so check digest before accepting message */
if(loaded==0 || (digest!=nil && m->digest!=nil && strcmp(digest, m->digest)!=0)){
mesgfreeparts(m);
free(m);
return 0;
}
if(mbox->tail != nil)
mbox->tail->next = m;
mbox->tail = m;
if(mbox->head == nil)
mbox->head = m;
if (m->level != 1){
m->recursed = 1;
readmbox(m, dir, m->name);
}
return 1;
}
int
thisyear(char *year)
{
static char now[10];
char *s;
if(now[0] == '\0'){
s = ctime(time(nil));
strcpy(now, s+24);
}
return strncmp(year, now, 4) == 0;
}
char*
stripdate(char *as)
{
int n;
char *s, *fld[10];
as = estrdup(as);
s = estrdup(as);
n = tokenize(s, fld, 10);
if(n > 5){
sprint(as, "%.3s ", fld[0]); /* day */
/* some dates have 19 Apr, some Apr 19 */
if(strlen(fld[1])<4 && isnumeric(fld[1]))
sprint(as+strlen(as), "%.3s %.3s ", fld[1], fld[2]); /* date, month */
else
sprint(as+strlen(as), "%.3s %.3s ", fld[2], fld[1]); /* date, month */
/* do we use time or year? depends on whether year matches this one */
if(thisyear(fld[5])){
if(strchr(fld[3], ':') != nil)
sprint(as+strlen(as), "%.5s ", fld[3]); /* time */
else if(strchr(fld[4], ':') != nil)
sprint(as+strlen(as), "%.5s ", fld[4]); /* time */
}else
sprint(as+strlen(as), "%.4s ", fld[5]); /* year */
}
free(s);
return as;
}
char*
readfile(char *dir, char *name, int *np)
{
char *file, *data;
int fd, len;
Dir *d;
if(np != nil)
*np = 0;
file = estrstrdup(dir, name);
fd = open(file, OREAD);
if(fd < 0)
return nil;
d = dirfstat(fd);
free(file);
len = 0;
if(d != nil)
len = d->length;
free(d);
data = emalloc(len+1);
read(fd, data, len);
close(fd);
if(np != nil)
*np = len;
return data;
}
int
writefile(char *dir, char *name, char *s)
{
char *e, *file;
int fd, n;
file = estrstrdup(dir, name);
// fprint(2, "writefile %s [%s]\n", file, s);
fd = open(file, OWRITE);
if(fd < 0)
return -1;
for(e = s + strlen(s); e - s > 0; s += n)
if((n = write(fd, s, e - s)) <= 0)
break;
close(fd);
return s == e? 0: -1;
}
void
setflags(Message *m, char *f)
{
char *flgchar = "aDdfrsS";
char *t, *p;
int rm;
t = smprint("%s/%s", mbox.name, m->name);
writefile(t, "flags", f);
free(t);
for(; *f; f++){
rm = 0;
if(*f == '-'){
rm = 1;
f++;
}
if((p = strchr(flgchar, *f)) != nil)
m->flags[p - flgchar] = rm ? '-' : *f;
}
}
void
fmtflags(char *b, char *flg)
{
*b++ = '[';
*b++ = (strchr(flg, 's') == nil) ? '*' : ' '; /* unread */
*b++ = (strchr(flg, 'a') == nil) ? ' ' : 'R'; /* answered */
*b++ = ']';
*b = '\0';
}
char*
info(Message *m, int ind, int ogf)
{
char *i;
int j, len, lens;
char *p;
char fmt[80], s[80], flg[16];
if (ogf)
p=m->to;
else
p=m->fromcolon;
fmtflags(flg, m->flags);
if(ind==0 && altmenu){
len = 12;
lens = 20;
if(ind==0 && m->subject[0]=='\0'){
snprint(fmt, sizeof fmt,
"\t%%-%d.%ds\t%%-12.12s\t", len, len);
snprint(s, sizeof s, fmt, p, stripdate(m->date) + 4);
}else{
snprint(fmt, sizeof fmt,
"\t%%-%d.%ds\t%%-12.12s\t%%-%d.%ds", len, len, lens, lens);
snprint(s, sizeof s, fmt, p, stripdate(m->date) + 4, m->subject);
}
i = estrdup(s);
return i;
}
if(ind==0 && shortmenu){
len = 30;
lens = 30;
if(shortmenu > 1){
len = 10;
lens = 25;
}
if(ind==0 && m->subject[0]=='\0'){
snprint(fmt, sizeof fmt, " %%-%d.%ds", len, len);
snprint(s, sizeof s, fmt, p);
}else{
snprint(fmt, sizeof fmt, " %%-%d.%ds %%-%d.%ds", len, len, lens, lens);
snprint(s, sizeof s, fmt, p, m->subject);
}
i = estrdup(s);
return i;
}
i = estrdup("");
i = eappend(i, " ", flg);
i = eappend(i, "\t", p);
i = egrow(i, "\t", stripdate(m->date));
if(ind == 0){
if(strcmp(m->type, "text")!=0 && strncmp(m->type, "text/", 5)!=0 &&
strncmp(m->type, "multipart/", 10)!=0)
i = egrow(i, "\t(", estrstrdup(m->type, ")"));
}else if(strncmp(m->type, "multipart/", 10) != 0)
i = egrow(i, "\t(", estrstrdup(m->type, ")"));
if(m->subject[0] != '\0'){
i = eappend(i, "\n", nil);
for(j=0; j<ind; j++)
i = eappend(i, "\t", nil);
i = eappend(i, "\t", m->subject);
}
return i;
}
void
mesgmenu0(Window *w, Message *mbox, char *realdir, char *dir, int ind, Biobuf *fd, int onlyone, int dotail)
{
int i;
Message *m;
char *name, *tmp;
int ogf=0;
if(strstr(realdir, "outgoing") != nil)
ogf=1;
/* show mail box in reverse order, pieces in forward order */
if(ind > 0)
m = mbox->head;
else
m = mbox->tail;
while(m != nil){
for(i=0; i<ind; i++)
Bprint(fd, "\t");
if(ind != 0)
Bprint(fd, " ");
name = estrstrdup(dir, m->name);
tmp = info(m, ind, ogf);
Bprint(fd, "%s%s\n", name, tmp);
free(tmp);
if(dotail && m->tail)
mesgmenu0(w, m, realdir, name, ind+1, fd, 0, dotail);
free(name);
if(ind)
m = m->next;
else
m = m->prev;
if(onlyone)
m = nil;
}
}
void
mesgmenu(Window *w, Message *mbox)
{
winopenbody(w, OWRITE);
mesgmenu0(w, mbox, mbox->name, "", 0, w->body, 0, !shortmenu);
winclosebody(w);
}
/* one new message has arrived, as mbox->tail */
void
mesgmenunew(Window *w, Message *mbox)
{
Biobuf *b;
winselect(w, "0", 0);
w->data = winopenfile(w, "data");
b = emalloc(sizeof(Biobuf));
Binit(b, w->data, OWRITE);
mesgmenu0(w, mbox, mbox->name, "", 0, b, 1, !shortmenu);
Bterm(b);
free(b);
if(!mbox->dirty)
winclean(w);
/* select tag line plus following indented lines, but not final newline (it's distinctive) */
winselect(w, "0/.*\\n((\t.*\\n)*\t.*)?/", 1);
close(w->addr);
close(w->data);
w->addr = -1;
w->data = -1;
}
char*
name2regexp(char *prefix, char *s)
{
char *buf, *p, *q;
buf = emalloc(strlen(prefix)+2*strlen(s)+50); /* leave room to append more */
p = buf;
*p++ = '0';
*p++ = '/';
*p++ = '^';
strcpy(p, prefix);
p += strlen(prefix);
for(q=s; *q!='\0'; q++){
if(strchr(regexchars, *q) != nil)
*p++ = '\\';
*p++ = *q;
}
*p++ = '/';
*p = '\0';
return buf;
}
void
mesgmenumarkdel(Window *w, Message *mbox, Message *m, int writeback)
{
char *buf;
if(m->deleted)
return;
m->writebackdel = writeback;
if(w->data < 0)
w->data = winopenfile(w, "data");
buf = name2regexp("", m->name);
strcat(buf, "-#0");
if(winselect(w, buf, 1))
write(w->data, deleted, 10);
free(buf);
close(w->data);
close(w->addr);
w->addr = w->data = -1;
mbox->dirty = 1;
m->deleted = 1;
}
void
mesgmenumarkundel(Window *w, Message*, Message *m)
{
char *buf;
if(m->deleted == 0)
return;
if(w->data < 0)
w->data = winopenfile(w, "data");
buf = name2regexp(deletedrx, m->name);
if(winselect(w, buf, 1))
if(winsetaddr(w, deletedaddr, 1))
write(w->data, "", 0);
free(buf);
close(w->data);
close(w->addr);
w->addr = w->data = -1;
m->deleted = 0;
}
void
mesgmenudel(Window *w, Message *mbox, Message *m)
{
char *buf;
if(w->data < 0)
w->data = winopenfile(w, "data");
buf = name2regexp(deletedrx, m->name);
if(winsetaddr(w, buf, 1) && winsetaddr(w, ".,./.*\\n(\t.*\\n)*/", 1))
write(w->data, "", 0);
free(buf);
close(w->data);
close(w->addr);
w->addr = w->data = -1;
mbox->dirty = 1;
m->deleted = 1;
}
void
mesgmenureflag(Window *w, Message *m)
{
char *buf, flg[16];
fmtflags(flg, m->flags);
buf = name2regexp(deletedrx01, m->name);
strcat(buf, "+/\\[[^\\]]*\\]/");
if(w->data < 0)
w->data = winopenfile(w, "data");
if(winselect(w, buf, 1))
write(w->data, flg, strlen(flg));
free(buf);
close(w->data);
w->data = -1;
}
void
mesgmenumark(Window *w, char *which, char *mark)
{
char *buf;
if(w->data < 0)
w->data = winopenfile(w, "data");
buf = name2regexp(deletedrx01, which);
if(winsetaddr(w, buf, 1) && winsetaddr(w, "+0-#1", 1)) /* go to end of line */
write(w->data, mark, strlen(mark));
free(buf);
close(w->data);
close(w->addr);
w->addr = w->data = -1;
if(!mbox.dirty)
winclean(w);
}
void
mesgfreeparts(Message *m)
{
free(m->name);
free(m->replyname);
free(m->fromcolon);
free(m->from);
free(m->to);
free(m->cc);
free(m->replyto);
free(m->date);
free(m->subject);
free(m->type);
free(m->disposition);
free(m->filename);
free(m->flags);
free(m->digest);
}
void
mesgdel(Message *mbox, Message *m)
{
Message *n, *next;
if(m->opened)
error("internal error: deleted message still open in mesgdel");
/* delete subparts */
for(n=m->head; n!=nil; n=next){
next = n->next;
mesgdel(m, n);
}
/* remove this message from list */
if(m->next)
m->next->prev = m->prev;
else
mbox->tail = m->prev;
if(m->prev)
m->prev->next = m->next;
else
mbox->head = m->next;
mesgfreeparts(m);
}
int
deliver(char *folder, char *file)
{
char *av[4];
int pid, wpid, nz;
Waitmsg *w;
pid = fork();
switch(pid){
case -1:
return -1;
case 0:
av[0] = "mbappend";
av[1] = folder;
av[2] = file;
av[3] = 0;
exec("/bin/upas/mbappend", av);
_exits("b0rked");
return -1;
default:
while(w = wait()){
nz = !w->msg || !w->msg[0];
if(!nz)
werrstr("%s", w->msg);
wpid = w->pid;
free(w);
if(wpid == pid)
return nz? 0: -1;
}
return -1;
}
}
int
mesgsave(Message *m, char *s)
{
char *t;
int ret;
t = smprint("%s/%s/rawunix", mbox.name, m->name);
if(s[0] != '/')
s = estrdup(s);
else
s = smprint("%s/%s", mailboxdir, s);
ret = 1;
if(deliver(s, t) == -1){
fprint(2, "Mail: save failed: can't write %s: %r\n", s);
ret = 0;
}
setflags(m, "S");
free(s);
free(t);
return ret;
}
int
mesgcommand(Message *m, char *cmd)
{
char *s;
char *args[10];
int ok, ret, nargs;
s = cmd;
ret = 1;
nargs = tokenize(s, args, nelem(args));
if(nargs == 0)
return 0;
if(strcmp(args[0], "Post") == 0){
mesgsend(m);
goto Return;
}
if(strncmp(args[0], "Save", 4) == 0){
if(m->isreply)
goto Return;
s = estrdup("\t[saved");
if(nargs==1 || strcmp(args[1], "")==0){
ok = mesgsave(m, "stored");
}else{
ok = mesgsave(m, args[1]);
s = eappend(s, " ", args[1]);
}
if(ok){
s = egrow(s, "]", nil);
mesgmenumark(mbox.w, m->name, s);
}
free(s);
setflags(m, "S");
goto Return;
}
if(strcmp(args[0], "Reply")==0){
if(nargs>=2 && strcmp(args[1], "all")==0)
mkreply(m, "Replyall", nil, nil, nil);
else
mkreply(m, "Reply", nil, nil, nil);
goto Return;
}
if(strcmp(args[0], "Q") == 0){
s = winselection(m->w); /* will be freed by mkreply */
if(nargs>=3 && strcmp(args[1], "Reply")==0 && strcmp(args[2], "all")==0)
mkreply(m, "QReplyall", nil, nil, s);
else
mkreply(m, "QReply", nil, nil, s);
goto Return;
}
if(strcmp(args[0], "Del") == 0){
if(windel(m->w, 0)){
chanfree(m->w->cevent);
free(m->w);
m->w = nil;
if(m->isreply)
delreply(m);
else{
m->opened = 0;
m->tagposted = 0;
}
free(cmd);
threadexits(nil);
}
goto Return;
}
if(strcmp(args[0], "Delmesg") == 0){
if(!m->isreply){
mesgmenumarkdel(wbox, &mbox, m, 1);
free(cmd); /* mesgcommand might not return */
mesgcommand(m, estrdup("Del"));
return 1;
}
// setflags(m, "d");
goto Return;
}
if(strcmp(args[0], "UnDelmesg") == 0){
if(!m->isreply && m->deleted)
mesgmenumarkundel(wbox, &mbox, m);
// setflags(m, "-d");
goto Return;
}
// if(strcmp(args[0], "Headers") == 0){
// m->showheaders();
// return True;
// }
ret = 0;
Return:
free(cmd);
return ret;
}
void
mesgtagpost(Message *m)
{
if(m->tagposted)
return;
wintagwrite(m->w, " Post", 5);
m->tagposted = 1;
}
/* need to expand selection more than default word */
#pragma varargck argpos eval 2
long
eval(Window *w, char *s, ...)
{
char buf[64];
va_list arg;
va_start(arg, s);
vsnprint(buf, sizeof buf, s, arg);
va_end(arg);
if(winsetaddr(w, buf, 1)==0)
return -1;
if(pread(w->addr, buf, 24, 0) != 24)
return -1;
return strtol(buf, 0, 10);
}
int
isemail(char *s)
{
int nat;
nat = 0;
for(; *s; s++)
if(*s == '@')
nat++;
else if(!isalpha(*s) && !isdigit(*s) && !strchr("_.-+/", *s))
return 0;
return nat==1;
}
char addrdelim[] = "/[ \t\\n<>()\\[\\]]/";
char*
expandaddr(Window *w, Event *e)
{
char *s;
long q0, q1;
if(e->q0 != e->q1) /* cannot happen */
return nil;
q0 = eval(w, "#%d-%s", e->q0, addrdelim);
if(q0 == -1) /* bad char not found */
q0 = 0;
else /* increment past bad char */
q0++;
q1 = eval(w, "#%d+%s", e->q0, addrdelim);
if(q1 < 0){
q1 = eval(w, "$");
if(q1 < 0)
return nil;
}
if(q0 >= q1)
return nil;
s = emalloc((q1-q0)*UTFmax+1);
winread(w, q0, q1, s);
return s;
}
int
replytoaddr(Window *w, Message *m, Event *e, char *s)
{
int did;
char *buf;
Plumbmsg *pm;
buf = nil;
did = 0;
if(e->flag & 2){
/* autoexpanded; use our own bigger expansion */
buf = expandaddr(w, e);
if(buf == nil)
return 0;
s = buf;
}
if(isemail(s)){
did = 1;
pm = emalloc(sizeof(Plumbmsg));
pm->src = estrdup("Mail");
pm->dst = estrdup("sendmail");
pm->data = estrdup(s);
pm->ndata = -1;
if(m->subject && m->subject[0]){
pm->attr = emalloc(sizeof(Plumbattr));
pm->attr->name = estrdup("Subject");
if(tolower(m->subject[0]) != 'r' || tolower(m->subject[1]) != 'e' || m->subject[2] != ':')
pm->attr->value = estrstrdup("Re: ", m->subject);
else
pm->attr->value = estrdup(m->subject);
pm->attr->next = nil;
}
if(plumbsend(plumbsendfd, pm) < 0)
fprint(2, "error writing plumb message: %r\n");
plumbfree(pm);
}
free(buf);
return did;
}
void
mesgctl(void *v)
{
Message *m;
Window *w;
Event *e, *eq, *e2, *ea;
int na, nopen, i, j;
char *os, *s, *t, *buf;
m = v;
w = m->w;
threadsetname("mesgctl");
proccreate(wineventproc, w, STACK);
for(;;){
e = recvp(w->cevent);
switch(e->c1){
default:
Unk:
print("unknown message %c%c\n", e->c1, e->c2);
break;
case 'E': /* write to body; can't affect us */
break;
case 'F': /* generated by our actions; ignore */
break;
case 'K': /* type away; we don't care */
case 'M':
switch(e->c2){
case 'x': /* mouse only */
case 'X':
ea = nil;
eq = e;
if(e->flag & 2){
e2 = recvp(w->cevent);
eq = e2;
}
if(e->flag & 8){
ea = recvp(w->cevent);
recvp(w->cevent);
na = ea->nb;
}else
na = 0;
if(eq->q1>eq->q0 && eq->nb==0){
s = emalloc((eq->q1-eq->q0)*UTFmax+1);
winread(w, eq->q0, eq->q1, s);
}else
s = estrdup(eq->b);
if(na){
t = emalloc(strlen(s)+1+na+1);
sprint(t, "%s %s", s, ea->b);
free(s);
s = t;
}
if(!mesgcommand(m, s)) /* send it back */
winwriteevent(w, e);
break;
case 'l': /* mouse only */
case 'L':
buf = nil;
eq = e;
if(e->flag & 2){
e2 = recvp(w->cevent);
eq = e2;
}
s = eq->b;
if(eq->q1>eq->q0 && eq->nb==0){
buf = emalloc((eq->q1-eq->q0)*UTFmax+1);
winread(w, eq->q0, eq->q1, buf);
s = buf;
}
os = s;
nopen = 0;
do{
/* skip mail box name if present */
if(strncmp(s, mbox.name, strlen(mbox.name)) == 0)
s += strlen(mbox.name);
if(strstr(s, "body") != nil){
/* strip any known extensions */
for(i=0; exts[i].ext!=nil; i++){
j = strlen(exts[i].ext);
if(strlen(s)>j && strcmp(s+strlen(s)-j, exts[i].ext)==0){
s[strlen(s)-j] = '\0';
break;
}
}
if(strlen(s)>5 && strcmp(s+strlen(s)-5, "/body")==0)
s[strlen(s)-4] = '\0'; /* leave / in place */
}
nopen += mesgopen(&mbox, mbox.name, s, m, 0, nil);
while(*s!=0 && *s++!='\n')
;
}while(*s);
if(nopen == 0 && e->c1 == 'L')
nopen += replytoaddr(w, m, e, os);
if(nopen == 0)
winwriteevent(w, e);
free(buf);
break;
case 'I': /* modify away; we don't care */
case 'D':
mesgtagpost(m);
/* fall through */
case 'd':
case 'i':
break;
default:
goto Unk;
}
}
}
}
void
mesgline(Message *m, char *header, char *value)
{
if(strlen(value) > 0)
Bprint(m->w->body, "%s: %s\n", header, value);
}
int
isprintable(char *type)
{
int i;
for(i=0; goodtypes[i]!=nil; i++)
if(strcmp(type, goodtypes[i])==0)
return 1;
return 0;
}
char*
ext(char *type)
{
int i;
for(i=0; exts[i].type!=nil; i++)
if(strcmp(type, exts[i].type)==0)
return exts[i].ext;
return "";
}
void
mimedisplay(Message *m, char *name, char *rootdir, Window *w, int fileonly)
{
char *dest, *maildest;
if(strcmp(m->disposition, "file")==0 || strlen(m->filename)!=0){
if(strlen(m->filename) == 0){
dest = estrdup(m->name);
dest[strlen(dest)-1] = '\0';
}else
dest = estrdup(m->filename);
if(maildest = getenv("maildest")){
maildest = eappend(maildest, "/", dest);
Bprint(w->body, "\tcp %s%sbody%s %q\n", rootdir, name, ext(m->type), maildest);
free(maildest);
}
if(m->filename[0] != '/')
dest = egrow(estrdup(home), "/", dest);
Bprint(w->body, "\tcp %s%sbody%s %q\n", rootdir, name, ext(m->type), dest);
free(dest);
}else if(!fileonly)
Bprint(w->body, "\tfile is %s%sbody%s\n", rootdir, name, ext(m->type));
}
void
printheader(char *dir, Biobuf *b, char **okheaders)
{
char *s;
char *lines[100];
int i, j, n;
s = readfile(dir, "header", nil);
if(s == nil)
return;
n = getfields(s, lines, nelem(lines), 0, "\n");
for(i=0; i<n; i++)
for(j=0; okheaders[j]; j++)
if(cistrncmp(lines[i], okheaders[j], strlen(okheaders[j])) == 0)
Bprint(b, "%s\n", lines[i]);
free(s);
}
void
mesgload(Message *m, char *rootdir, char *file, Window *w)
{
char *s, *subdir, *name, *dir;
Message *mp, *thisone;
int n;
dir = estrstrdup(rootdir, file);
if(strcmp(m->type, "message/rfc822") != 0){ /* suppress headers of envelopes */
if(strlen(m->from) > 0){
Bprint(w->body, "From: %s\n", m->from);
mesgline(m, "Date", m->date);
mesgline(m, "To", m->to);
mesgline(m, "CC", m->cc);
mesgline(m, "Subject", m->subject);
printheader(dir, w->body, extraheaders);
}else{
printheader(dir, w->body, okheaders);
printheader(dir, w->body, extraheaders);
}
Bprint(w->body, "\n");
}
if(m->level == 1 && m->recursed == 0){
m->recursed = 1;
readmbox(m, rootdir, m->name);
}
if(m->head == nil){ /* single part message */
if(strcmp(m->type, "text")==0 || strncmp(m->type, "text/", 5)==0){
mimedisplay(m, m->name, rootdir, w, 1);
s = readbody(m->type, dir, &n);
winwritebody(w, s, n);
free(s);
}else
mimedisplay(m, m->name, rootdir, w, 0);
}else{
/* multi-part message, either multipart/* or message/rfc822 */
thisone = nil;
if(strcmp(m->type, "multipart/alternative") == 0){
thisone = m->head; /* in case we can't find a good one */
for(mp=m->head; mp!=nil; mp=mp->next)
if(isprintable(mp->type)){
thisone = mp;
break;
}
}
for(mp=m->head; mp!=nil; mp=mp->next){
if(thisone!=nil && mp!=thisone)
continue;
subdir = estrstrdup(dir, mp->name);
name = estrstrdup(file, mp->name);
/* skip first element in name because it's already in window name */
if(mp != m->head)
Bprint(w->body, "\n===> %s (%s) [%s]\n", strchr(name, '/')+1, mp->type, mp->disposition);
if(strcmp(mp->type, "text")==0 || strncmp(mp->type, "text/", 5)==0){
mimedisplay(mp, name, rootdir, w, 1);
printheader(subdir, w->body, okheaders);
printheader(subdir, w->body, extraheaders);
winwritebody(w, "\n", 1);
s = readbody(mp->type, subdir, &n);
winwritebody(w, s, n);
free(s);
}else{
if(strncmp(mp->type, "multipart/", 10)==0 || strcmp(mp->type, "message/rfc822")==0){
mp->w = w;
mesgload(mp, rootdir, name, w);
mp->w = nil;
}else
mimedisplay(mp, name, rootdir, w, 0);
}
free(name);
free(subdir);
}
}
free(dir);
}
int
tokenizec(char *str, char **args, int max, char *splitc)
{
int na;
int intok = 0;
if(max <= 0)
return 0;
for(na=0; *str != '\0';str++){
if(strchr(splitc, *str) == nil){
if(intok)
continue;
args[na++] = str;
intok = 1;
}else{
/* it's a separator/skip character */
*str = '\0';
if(intok){
intok = 0;
if(na >= max)
break;
}
}
}
return na;
}
Message*
mesglookup(Message *mbox, char *name, char *digest)
{
int n;
Message *m;
char *t;
if(digest){
/* can find exactly */
for(m=mbox->head; m!=nil; m=m->next)
if(strcmp(digest, m->digest) == 0)
break;
return m;
}
n = strlen(name);
if(n == 0)
return nil;
if(name[n-1] == '/')
t = estrdup(name);
else
t = estrstrdup(name, "/");
for(m=mbox->head; m!=nil; m=m->next)
if(strcmp(t, m->name) == 0)
break;
free(t);
return m;
}
/*
* Find plumb port, knowing type is text, given file name (by extension)
*/
int
plumbportbysuffix(char *file)
{
char *suf;
int i, nsuf, nfile;
nfile = strlen(file);
for(i=0; ports[i].type!=nil; i++){
suf = ports[i].suffix;
nsuf = strlen(suf);
if(nfile > nsuf)
if(cistrncmp(file+nfile-nsuf, suf, nsuf) == 0)
return i;
}
return 0;
}
/*
* Find plumb port using type and file name (by extension)
*/
int
plumbport(char *type, char *file)
{
int i;
for(i=0; ports[i].type!=nil; i++)
if(strncmp(type, ports[i].type, strlen(ports[i].type)) == 0)
return i;
/* see if it's a text type */
for(i=0; goodtypes[i]!=nil; i++)
if(strncmp(type, goodtypes[i], strlen(goodtypes[i])) == 0)
return plumbportbysuffix(file);
return -1;
}
void
plumb(Message *m, char *dir)
{
int i;
char *port;
Plumbmsg *pm;
if(strlen(m->type) == 0)
return;
i = plumbport(m->type, m->filename);
if(i < 0)
fprint(2, "can't find destination for message subpart\n");
else{
port = ports[i].port;
pm = emalloc(sizeof(Plumbmsg));
pm->src = estrdup("Mail");
if(port)
pm->dst = estrdup(port);
else
pm->dst = nil;
pm->wdir = nil;
pm->type = estrdup("text");
pm->ndata = -1;
pm->data = estrstrdup(dir, "body");
pm->data = eappend(pm->data, "", ports[i].suffix);
if(plumbsend(plumbsendfd, pm) < 0)
fprint(2, "error writing plumb message: %r\n");
plumbfree(pm);
}
}
int
mesgopen(Message *mbox, char *dir, char *s, Message *mesg, int plumbed, char *digest)
{
char *t, *u, *v;
Message *m;
char *direlem[10];
int i, ndirelem, reuse;
/* find white-space-delimited first word */
for(t=s; *t!='\0' && !isspace(*t); t++)
;
u = emalloc(t-s+1);
memmove(u, s, t-s);
/* separate it on slashes */
ndirelem = tokenizec(u, direlem, nelem(direlem), "/");
if(ndirelem <= 0){
Error:
free(u);
return 0;
}
if(plumbed){
write(wctlfd, "top", 3);
write(wctlfd, "current", 7);
}
/* open window for message */
m = mesglookup(mbox, direlem[0], digest);
if(m == nil)
goto Error;
if(mesg!=nil && m!=mesg) /* string looked like subpart but isn't part of this message */
goto Error;
if(m->opened == 0){
if(m->w == nil){
reuse = 0;
m->w = newwindow();
}else{
reuse = 1;
/* re-use existing window */
if(winsetaddr(m->w, "0,$", 1)){
if(m->w->data < 0)
m->w->data = winopenfile(m->w, "data");
write(m->w->data, "", 0);
}
}
v = estrstrdup(mbox->name, m->name);
winname(m->w, v);
free(v);
if(!reuse){
if(m->deleted)
wintagwrite(m->w, "Q Reply all UnDelmesg Save ", 2+6+4+10+5);
else
wintagwrite(m->w, "Q Reply all Delmesg Save ", 2+6+4+8+5);
}
threadcreate(mesgctl, m, STACK);
winopenbody(m->w, OWRITE);
mesgload(m, dir, m->name, m->w);
winclosebody(m->w);
winclean(m->w);
m->opened = 1;
setflags(m, "s");
mesgmenureflag(mbox->w, m);
if(ndirelem == 1){
free(u);
return 1;
}
}
if(ndirelem == 1 && plumbport(m->type, m->filename) <= 0){
/* make sure dot is visible */
ctlprint(m->w->ctl, "show\n");
return 0;
}
/* walk to subpart */
dir = estrstrdup(dir, m->name);
for(i=1; i<ndirelem; i++){
m = mesglookup(m, direlem[i], digest);
if(m == nil)
break;
dir = egrow(dir, m->name, nil);
}
if(m != nil && plumbport(m->type, m->filename) > 0)
plumb(m, dir);
free(dir);
free(u);
return 1;
}
void
rewritembox(Window *w, Message *mbox)
{
Message *m, *next;
char *deletestr, *t;
int nopen;
deletestr = estrstrdup("delete ", fsname);
nopen = 0;
for(m=mbox->head; m!=nil; m=next){
next = m->next;
if(m->deleted == 0)
continue;
if(m->opened){
nopen++;
continue;
}
if(m->writebackdel){
/* messages deleted by plumb message are not removed again */
t = estrdup(m->name);
if(strlen(t) > 0)
t[strlen(t)-1] = '\0';
deletestr = egrow(deletestr, " ", t);
}
mesgmenudel(w, mbox, m);
mesgdel(mbox, m);
}
if(write(mbox->ctlfd, deletestr, strlen(deletestr)) < 0)
fprint(2, "Mail: warning: error removing mail message files: %r\n");
free(deletestr);
winselect(w, "0", 0);
if(nopen == 0)
winclean(w);
mbox->dirty = 0;
}
/* name is a full file name, but it might not belong to us */
Message*
mesglookupfile(Message *mbox, char *name, char *digest)
{
int k, n;
k = strlen(name);
n = strlen(mbox->name);
if(k==0 || strncmp(name, mbox->name, n) != 0){
// fprint(2, "Mail: message %s not in this mailbox\n", name);
return nil;
}
return mesglookup(mbox, name+n, digest);
}