1 #include <u.h>
2 #include <libc.h>
3 #include <draw.h>
4 #include <plumb.h>
5 #include <regexp.h>
6 #include <bio.h>
7 #include <9pclient.h>
8 #include "faces.h"
9 
10 static int		showfd = -1;
11 static int		seefd = -1;
12 static int		logfd = -1;
13 static char	*user;
14 static char	*logtag;
15 
16 char		**maildirs;
17 int		nmaildirs;
18 
19 void
20 initplumb(void)
21 {
22 	showfd = plumbopen("send", OWRITE);
23 	seefd = plumbopen("seemail", OREAD);
24 
25 	if(seefd < 0){
26 		logfd = open(unsharp("#9/log/mail"), OREAD);
27 		seek(logfd, 0LL, 2);
28 		user = getenv("user");
29 		if(user == nil){
30 			fprint(2, "faces: can't find user name: %r\n");
31 			exits("$user");
32 		}
33 		logtag = emalloc(32+strlen(user)+1);
34 		sprint(logtag, " delivered %s From ", user);
35 	}
36 }
37 
38 void
39 addmaildir(char *dir)
40 {
41 	maildirs = erealloc(maildirs, (nmaildirs+1)*sizeof(char*));
42 	maildirs[nmaildirs++] = dir;
43 }
44 
45 char*
46 attr(Face *f)
47 {
48 	static char buf[128];
49 
50 	if(f->str[Sdigest]){
51 		snprint(buf, sizeof buf, "digest=%s", f->str[Sdigest]);
52 		return buf;
53 	}
54 	return nil;
55 }
56 
57 void
58 showmail(Face *f)
59 {
60 	Plumbmsg pm;
61 	Plumbattr a;
62 	char *s;
63 
64 	if(showfd<0 || f->str[Sshow]==nil || f->str[Sshow][0]=='\0')
65 		return;
66 	s = emalloc(strlen("/mail/fs")+1+strlen(f->str[Sshow]));
67 	sprint(s,"/mail/fs/%s",f->str[Sshow]);
68 	pm.src = "faces";
69 	pm.dst = "showmail";
70 	pm.wdir = "/mail/fs";
71 	pm.type = "text";
72 	a.name = "digest";
73 	a.value = f->str[Sdigest];
74 	a.next = nil;
75 	pm.attr = &a;
76 	pm.ndata = strlen(s);
77 	pm.data = s;
78 	plumbsend(showfd,&pm);
79 }
80 
81 char*
82 value(Plumbattr *attr, char *key, char *def)
83 {
84 	char *v;
85 
86 	v = plumblookup(attr, key);
87 	if(v)
88 		return v;
89 	return def;
90 }
91 
92 void
93 setname(Face *f, char *sender)
94 {
95 	char *at, *bang;
96 	char *p;
97 
98 	/* works with UTF-8, although it's written as ASCII */
99 	for(p=sender; *p!='\0'; p++)
100 		*p = tolower(*p);
101 	f->str[Suser] = sender;
102 	at = strchr(sender, '@');
103 	if(at){
104 		*at++ = '\0';
105 		f->str[Sdomain] = estrdup(at);
106 		return;
107 	}
108 	bang = strchr(sender, '!');
109 	if(bang){
110 		*bang++ = '\0';
111 		f->str[Suser] = estrdup(bang);
112 		f->str[Sdomain] = sender;
113 		return;
114 	}
115 }
116 
117 int
118 getc(void)
119 {
120 	static uchar buf[512];
121 	static int nbuf = 0;
122 	static int i = 0;
123 
124 	while(i == nbuf){
125 		i = 0;
126 		nbuf = read(logfd, buf, sizeof buf);
127 		if(nbuf == 0){
128 			sleep(15000);
129 			continue;
130 		}
131 		if(nbuf < 0)
132 			return -1;
133 	}
134 	return buf[i++];
135 }
136 
137 char*
138 getline(char *buf, int n)
139 {
140 	int i, c;
141 
142 	for(i=0; i<n-1; i++){
143 		c = getc();
144 		if(c <= 0)
145 			return nil;
146 		if(c == '\n')
147 			break;
148 		buf[i] = c;
149 	}
150 	buf[i] = '\0';
151 	return buf;
152 }
153 
154 static char* months[] = {
155 	"jan", "feb", "mar", "apr",
156 	"may", "jun", "jul", "aug", 
157 	"sep", "oct", "nov", "dec"
158 };
159 
160 static int
161 getmon(char *s)
162 {
163 	int i;
164 
165 	for(i=0; i<nelem(months); i++)
166 		if(cistrcmp(months[i], s) == 0)
167 			return i;
168 	return -1;
169 }
170 
171 /* Fri Jul 23 14:05:14 EDT 1999 */
172 ulong
173 parsedatev(char **a)
174 {
175 	char *p;
176 	Tm tm;
177 
178 	memset(&tm, 0, sizeof tm);
179 	if((tm.mon=getmon(a[1])) == -1)
180 		goto Err;
181 	tm.mday = strtol(a[2], &p, 10);
182 	if(*p != '\0')
183 		goto Err;
184 	tm.hour = strtol(a[3], &p, 10);
185 	if(*p != ':')
186 		goto Err;
187 	tm.min = strtol(p+1, &p, 10);
188 	if(*p != ':')
189 		goto Err;
190 	tm.sec = strtol(p+1, &p, 10);
191 	if(*p != '\0')
192 		goto Err;
193 	if(strlen(a[4]) != 3)
194 		goto Err;
195 	strcpy(tm.zone, a[4]);
196 	if(strlen(a[5]) != 4)
197 		goto Err;
198 	tm.year = strtol(a[5], &p, 10);
199 	if(*p != '\0')
200 		goto Err;
201 	tm.year -= 1900;
202 	return tm2sec(&tm);
203 Err:
204 	return time(0);
205 }
206 
207 ulong
208 parsedate(char *s)
209 {
210 	char *f[10];
211 	int nf;
212 
213 	nf = getfields(s, f, nelem(f), 1, " ");
214 	if(nf < 6)
215 		return time(0);
216 	return parsedatev(f);
217 }
218 
219 /* 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 */
220 /* achille Oct 26 13:45:42 remote local!rsc From rsc Sat Oct 26 13:45:41 EDT 2002 (rsc) 170 */
221 int
222 parselog(char *s, char **sender, ulong *xtime)
223 {
224 	char *f[20];
225 	int nf;
226 
227 	nf = getfields(s, f, nelem(f), 1, " ");
228 	if(nf < 14)
229 		return 0;
230 	if(strcmp(f[4], "delivered") == 0 && strcmp(f[5], user) == 0)
231 		goto Found;
232 	if(strcmp(f[4], "remote") == 0 && strncmp(f[5], "local!", 6) == 0 && strcmp(f[5]+6, user) == 0)
233 		goto Found;
234 	return 0;
235 
236 Found:
237 	*sender = estrdup(f[7]);
238 	*xtime = parsedatev(&f[8]);
239 	return 1;
240 }
241 
242 int
243 logrecv(char **sender, ulong *xtime)
244 {
245 	char buf[4096];
246 
247 	for(;;){
248 		if(getline(buf, sizeof buf) == nil)
249 			return 0;
250 		if(parselog(buf, sender, xtime))
251 			return 1;
252 	}
253 	return -1;
254 }
255 
256 char*
257 tweakdate(char *d)
258 {
259 	char e[8];
260 
261 	/* d, date = "Mon Aug  2 23:46:55 EDT 1999" */
262 
263 	if(strlen(d) < strlen("Mon Aug  2 23:46:55 EDT 1999"))
264 		return estrdup("");
265 	if(strncmp(date, d, 4+4+3) == 0)
266 		snprint(e, sizeof e, "%.5s", d+4+4+3);	/* 23:46 */
267 	else
268 		snprint(e, sizeof e, "%.6s", d+4);	/* Aug  2 */
269 	return estrdup(e);
270 }
271 
272 Face*
273 nextface(void)
274 {
275 	int i;
276 	Face *f;
277 	Plumbmsg *m;
278 	char *t, *senderp, *showmailp, *digestp;
279 	ulong xtime;
280 
281 	f = emalloc(sizeof(Face));
282 	for(;;){
283 		if(seefd >= 0){
284 			m = plumbrecv(seefd);
285 			if(m == nil)
286 				killall("error on seemail plumb port");
287 			t = value(m->attr, "mailtype", "");
288 			if(strcmp(t, "delete") == 0)
289 				delete(m->data, value(m->attr, "digest", nil));
290 			else if(strcmp(t, "new") != 0)
291 				fprint(2, "faces: unknown plumb message type %s\n", t);
292 			else for(i=0; i<nmaildirs; i++) {
293 				if(strncmp(m->data,"/mail/fs/",strlen("/mail/fs/")) == 0)
294 					m->data += strlen("/mail/fs/");
295 				if(strncmp(m->data, maildirs[i], strlen(maildirs[i])) == 0)
296 					goto Found;
297 			}
298 			plumbfree(m);
299 			continue;
300 
301 		Found:
302 			xtime = parsedate(value(m->attr, "date", date));
303 			digestp = value(m->attr, "digest", nil);
304 			if(alreadyseen(digestp)){
305 				/* duplicate upas/fs can send duplicate messages */
306 				plumbfree(m);
307 				continue;
308 			}
309 			senderp = estrdup(value(m->attr, "sender", "???"));
310 			showmailp = estrdup(m->data);
311 			if(digestp)
312 				digestp = estrdup(digestp);
313 			plumbfree(m);
314 		}else{
315 			if(logrecv(&senderp, &xtime) <= 0)
316 				killall("error reading log file");
317 			showmailp = estrdup("");
318 			digestp = nil;
319 		}
320 		setname(f, senderp);
321 		f->time = xtime;
322 		f->tm = *localtime(xtime);
323 		f->str[Sshow] = showmailp;
324 		f->str[Sdigest] = digestp;
325 		return f;
326 	}
327 	return nil;
328 }
329 
330 char*
331 iline(char *data, char **pp)
332 {
333 	char *p;
334 
335 	for(p=data; *p!='\0' && *p!='\n'; p++)
336 		;
337 	if(*p == '\n')
338 		*p++ = '\0';
339 	*pp = p;
340 	return data;
341 }
342 
343 Face*
344 dirface(char *dir, char *num)
345 {
346 	Face *f;
347 	char *from, *date;
348 	char buf[1024],  *info, *p, *digest;
349 	int n;
350 	ulong len;
351 	CFid *fid;
352 
353 #if 0
354 	/*
355 	 * loadmbox leaves us in maildir, so we needn't
356 	 * walk /mail/fs/mbox for each face; this makes startup
357 	 * a fair bit quicker.
358 	 */
359 	if(getwd(pwd, sizeof pwd) != nil && strcmp(pwd, dir) == 0)
360 		sprint(buf, "%s/info", num);
361 	else
362 		sprint(buf, "%s/%s/info", dir, num);
363 #endif
364 	sprint(buf, "%s/%s/info", dir, num);
365 	len = fsdirlen(upasfs, buf);
366 	if(len <= 0)
367 		return nil;
368 	fid = fsopen(upasfs,buf, OREAD);
369 	if(fid == nil)
370 		return nil;
371 	info = emalloc(len+1);
372 	n = fsreadn(fid, info, len);
373 	fsclose(fid);
374 	if(n < 0){
375 		free(info);
376 		return nil;
377 	}
378 	info[n] = '\0';
379 	f = emalloc(sizeof(Face));
380 	from = iline(info, &p);	/* from */
381 	iline(p, &p);	/* to */
382 	iline(p, &p);	/* cc */
383 	iline(p, &p);	/* replyto */
384 	date = iline(p, &p);	/* date */
385 	setname(f, estrdup(from));
386 	f->time = parsedate(date);
387 	f->tm = *localtime(f->time);
388 	sprint(buf, "%s/%s", dir, num);
389 	f->str[Sshow] = estrdup(buf);
390 	iline(p, &p);	/* subject */
391 	iline(p, &p);	/* mime content type */
392 	iline(p, &p);	/* mime disposition */
393 	iline(p, &p);	/* filename */
394 	digest = iline(p, &p);	/* digest */
395 	f->str[Sdigest] = estrdup(digest);
396 	free(info);
397 	return f;
398 }