#include <u.h>#include <libc.h>#include <draw.h>#include <plumb.h>#include <regexp.h>#include <bio.h>#include "faces.h" static int		showfd = -1;static int		seefd = -1;static int		logfd = -1;static char	*user;static char	*logtag; char		**maildirs;int		nmaildirs; Face		*pathface(char*, Face*); voidinitplumb(void){	showfd = plumbopen("send", OWRITE);	seefd = plumbopen("seemail", OREAD); 	if(seefd < 0){		logfd = open("/sys/log/mail", OREAD);		seek(logfd, 0LL, 2);		user = getenv("user");		if(user == nil){			fprint(2, "faces: can't find user name: %r\n");			exits("$user");		}		logtag = emalloc(32+strlen(user)+1);		sprint(logtag, " delivered %s From ", user);	}} voidaddmaildir(char *dir){	maildirs = erealloc(maildirs, (nmaildirs+1)*sizeof(char*));	maildirs[nmaildirs++] = dir;} char*attr(Face *f){	static char buf[128]; 	if(f->str[Sdigest]){		snprint(buf, sizeof buf, "digest=%s", f->str[Sdigest]);		return buf;	}	return nil;} voidshowmail(Face *f){	char *s;	int n; 	if(showfd<0 || f->str[Sshow]==nil || f->str[Sshow][0]=='\0')		return;	s = emalloc(128+strlen(f->str[Sshow])+1);	n = sprint(s, "faces\nshowmail\n/mail/fs/\ntext\n%s\n%ld\n%s", attr(f), strlen(f->str[Sshow]), f->str[Sshow]);	write(showfd, s, n);	free(s);} char*value(Plumbattr *attr, char *key, char *def){	char *v; 	v = plumblookup(attr, key);	if(v)		return v;	return def;} voidsetname(Face *f, char *sender){	char *at, *bang;	char *p; 	/* works with UTF-8, although it's written as ASCII */	for(p=sender; *p!='\0'; p++)		*p = tolower(*p);	f->str[Suser] = sender;	at = strchr(sender, '@');	if(at){		*at++ = '\0';		f->str[Sdomain] = estrdup(at);		return;	}	bang = strchr(sender, '!');	if(bang){		*bang++ = '\0';		f->str[Suser] = estrdup(bang);		f->str[Sdomain] = sender;		return;	}} intgetc(void){	static uchar buf[512];	static int nbuf = 0;	static int i = 0; 	while(i == nbuf){		i = 0;		nbuf = read(logfd, buf, sizeof buf);		if(nbuf == 0){			sleep(15000);			continue;		}		if(nbuf < 0)			return -1;	}	return buf[i++];} char*getline(char *buf, int n){	int i, c; 	for(i=0; i<n-1; i++){		c = getc();		if(c <= 0)			return nil;		if(c == '\n')			break;		buf[i] = c;	}	buf[i] = '\0';	return buf;} static char* months[] = {	"jan", "feb", "mar", "apr",	"may", "jun", "jul", "aug", 	"sep", "oct", "nov", "dec"}; static intgetmon(char *s){	int i; 	for(i=0; i<nelem(months); i++)		if(cistrcmp(months[i], s) == 0)			return i;	return -1;} /* Fri Jul 23 14:05:14 EDT 1999 */ulongparsedatev(char **a){	char *p;	Tm tm; 	memset(&tm, 0, sizeof tm);	if((tm.mon=getmon(a[1])) == -1)		goto Err;	tm.mday = strtol(a[2], &p, 10);	if(*p != '\0')		goto Err;	tm.hour = strtol(a[3], &p, 10);	if(*p != ':')		goto Err;	tm.min = strtol(p+1, &p, 10);	if(*p != ':')		goto Err;	tm.sec = strtol(p+1, &p, 10);	if(*p != '\0')		goto Err;	if(strlen(a[4]) != 3)		goto Err;	strcpy(tm.zone, a[4]);	if(strlen(a[5]) != 4)		goto Err;	tm.year = strtol(a[5], &p, 10);	if(*p != '\0')		goto Err;	tm.year -= 1900;	return tm2sec(&tm);Err:	return time(0);} ulongparsedate(char *s){	char *f[10];	int nf; 	nf = getfields(s, f, nelem(f), 1, " ");	if(nf < 6)		return time(0);	return parsedatev(f);} /* achille Jul 23 14:05:15 delivered jmk From ms.com!bub Fri Jul 23 14:05:14 EDT 1999 (plan9.bell-labs.com!jmk) 1352 *//* achille Oct 26 13:45:42 remote local!rsc From rsc Sat Oct 26 13:45:41 EDT 2002 (rsc) 170 */intparselog(char *s, char **sender, ulong *xtime){	char *f[20];	int nf; 	nf = getfields(s, f, nelem(f), 1, " ");	if(nf < 14)		return 0;	if(strcmp(f[4], "delivered") == 0 && strcmp(f[5], user) == 0)		goto Found;	if(strcmp(f[4], "remote") == 0 && strncmp(f[5], "local!", 6) == 0 && strcmp(f[5]+6, user) == 0)		goto Found;	return 0; Found:	*sender = estrdup(f[7]);	*xtime = parsedatev(&f[8]);	return 1;} intlogrecv(char **sender, ulong *xtime){	char buf[4096]; 	for(;;){		if(getline(buf, sizeof buf) == nil)			return 0;		if(parselog(buf, sender, xtime))			return 1;	}} char*tweakdate(char *d){	char e[8]; 	/* d, date = "Mon Aug  2 23:46:55 EDT 1999" */ 	if(strlen(d) < strlen("Mon Aug  2 23:46:55 EDT 1999"))		return estrdup("");	if(strncmp(date, d, 4+4+3) == 0)		snprint(e, sizeof e, "%.5s", d+4+4+3);	/* 23:46 */	else		snprint(e, sizeof e, "%.6s", d+4);	/* Aug  2 */	return estrdup(e);} Face*nextface(void){	int i;	Face *f;	Plumbmsg *m;	char *t, *senderp, *showmailp, *digestp;	ulong xtime; 	f = emalloc(sizeof(Face));	for(;;){		if(seefd >= 0){			m = plumbrecv(seefd);			if(m == nil)				killall("error on seemail plumb port");			t = value(m->attr, "mailtype", "");			if(strcmp(t, "delete") == 0)				delete(m->data, value(m->attr, "digest", nil));			else if(strcmp(t, "new") != 0)				fprint(2, "faces: unknown plumb message type %s\n", t);			else for(i=0; i<nmaildirs; i++)				if(strncmp(m->data, maildirs[i], strlen(maildirs[i])) == 0)					goto Found;			plumbfree(m);			continue; 		Found:			xtime = parsedate(value(m->attr, "date", date));			digestp = value(m->attr, "digest", nil);			if(alreadyseen(digestp)){				/* duplicate upas/fs can send duplicate messages */				plumbfree(m);				continue;			}			senderp = estrdup(value(m->attr, "sender", "???"));			showmailp = estrdup(m->data);			if(digestp)				digestp = estrdup(digestp);			plumbfree(m);		}else{			if(logrecv(&senderp, &xtime) <= 0)				killall("error reading log file");			showmailp = estrdup("");			digestp = nil;		}		setname(f, senderp);		f->time = xtime;		f->tm = *localtime(xtime);		f->str[Sshow] = showmailp;		f->str[Sdigest] = digestp;		f = pathface(showmailp, f);		return f;	}} char*iline(char *data, char **pp){	char *p; 	for(p=data; *p!='\0' && *p!='\n'; p++)		;	if(*p == '\n')		*p++ = '\0';	*pp = p;	return data;} Face*dirface0(char *dir, char *num, Face *f){	char *from, *date;	char buf[1024], pwd[1024], *info, *p, *digest;	int n, fd;	ulong len; 	/*	 * loadmbox leaves us in maildir, so we needn't	 * walk /mail/fs/mbox for each face; this makes startup	 * a fair bit quicker.	 */	if(getwd(pwd, sizeof pwd) != nil && strcmp(pwd, dir) == 0)		sprint(buf, "%s/info", num);	else		sprint(buf, "%s/%s/info", dir, num);	len = dirlen(buf);	if(len <= 0)		return nil;	fd = open(buf, OREAD);	if(fd < 0)		return nil;	info = emalloc(len+1);	n = readn(fd, info, len);	close(fd);	if(n < 0){		free(info);		return nil;	}	info[n] = '\0';	if(f == nil)		f = emalloc(sizeof(Face));	from = iline(info, &p);	/* from */	iline(p, &p);	/* to */	iline(p, &p);	/* cc */	iline(p, &p);	/* replyto */	date = iline(p, &p);	/* date */	if(f->str[Suser]  == nil)		setname(f, estrdup(from));	if(f->time == 0){		f->time = parsedate(date);		f->tm = *localtime(f->time);	}	sprint(buf, "%s/%s", dir, num);	if(f->str[Sshow] == nil)		f->str[Sshow] = estrdup(buf);	if(f->str[Ssubject] == nil)		f->str[Ssubject] = estrdup(iline(p, &p));	/* subject */	iline(p, &p);	/* mime content type */	iline(p, &p);	/* mime disposition */	iline(p, &p);	/* filename */	digest = iline(p, &p);	/* digest */	if(f->str[Sdigest] == nil)		f->str[Sdigest] = estrdup(digest);	free(info);	return f;} Face*dirface(char *dir, char *num){	return dirface0(dir, num, 0);} Face*pathface(char *path, Face *f){	char buf[1024], *t; 	strncpy(buf, path, 1024);	if((t = strrchr(buf, '/')) == 0)		return f;	*t = 0;	dirface0(buf, t+1, f);	return f;}