10 static int showfd = -1;
11 static int seefd = -1;
12 static int logfd = -1;
22 showfd = plumbopen("send", OWRITE);
23 seefd = plumbopen("seemail", OREAD);
26 logfd = open(unsharp("#9/log/mail"), OREAD);
28 user = getenv("user");
30 fprint(2, "faces: can't find user name: %r\n");
33 logtag = emalloc(32+strlen(user)+1);
34 sprint(logtag, " delivered %s From ", user);
41 maildirs = erealloc(maildirs, (nmaildirs+1)*sizeof(char*));
42 maildirs[nmaildirs++] = dir;
51 snprint(buf, sizeof buf, "digest=%s", f->str[Sdigest]);
64 if(showfd<0 || f->str[Sshow]==nil || f->str[Sshow][0]=='\0')
66 s = emalloc(strlen("/mail/fs")+1+strlen(f->str[Sshow]));
67 sprint(s,"/mail/fs/%s",f->str[Sshow]);
73 a.value = f->str[Sdigest];
78 plumbsend(showfd,&pm);
82 value(Plumbattr *attr, char *key, char *def)
86 v = plumblookup(attr, key);
93 setname(Face *f, char *sender)
98 /* works with UTF-8, although it's written as ASCII */
99 for(p=sender; *p!='\0'; p++)
101 f->str[Suser] = sender;
102 at = strchr(sender, '@');
105 f->str[Sdomain] = estrdup(at);
108 bang = strchr(sender, '!');
111 f->str[Suser] = estrdup(bang);
112 f->str[Sdomain] = sender;
120 static uchar buf[512];
126 nbuf = read(logfd, buf, sizeof buf);
138 getline(char *buf, int n)
142 for(i=0; i<n-1; i++){
154 static char* months[] = {
155 "jan", "feb", "mar", "apr",
156 "may", "jun", "jul", "aug",
157 "sep", "oct", "nov", "dec"
165 for(i=0; i<nelem(months); i++)
166 if(cistrcmp(months[i], s) == 0)
171 /* Fri Jul 23 14:05:14 EDT 1999 */
178 memset(&tm, 0, sizeof tm);
179 if((tm.mon=getmon(a[1])) == -1)
181 tm.mday = strtol(a[2], &p, 10);
184 tm.hour = strtol(a[3], &p, 10);
187 tm.min = strtol(p+1, &p, 10);
190 tm.sec = strtol(p+1, &p, 10);
193 if(strlen(a[4]) != 3)
195 strcpy(tm.zone, a[4]);
196 if(strlen(a[5]) != 4)
198 tm.year = strtol(a[5], &p, 10);
213 nf = getfields(s, f, nelem(f), 1, " ");
216 return parsedatev(f);
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 */
222 parselog(char *s, char **sender, ulong *xtime)
227 nf = getfields(s, f, nelem(f), 1, " ");
230 if(strcmp(f[4], "delivered") == 0 && strcmp(f[5], user) == 0)
232 if(strcmp(f[4], "remote") == 0 && strncmp(f[5], "local!", 6) == 0 && strcmp(f[5]+6, user) == 0)
237 *sender = estrdup(f[7]);
238 *xtime = parsedatev(&f[8]);
243 logrecv(char **sender, ulong *xtime)
248 if(getline(buf, sizeof buf) == nil)
250 if(parselog(buf, sender, xtime))
261 /* d, date = "Mon Aug 2 23:46:55 EDT 1999" */
263 if(strlen(d) < strlen("Mon Aug 2 23:46:55 EDT 1999"))
265 if(strncmp(date, d, 4+4+3) == 0)
266 snprint(e, sizeof e, "%.5s", d+4+4+3); /* 23:46 */
268 snprint(e, sizeof e, "%.6s", d+4); /* Aug 2 */
278 char *t, *senderp, *showmailp, *digestp;
281 f = emalloc(sizeof(Face));
284 m = plumbrecv(seefd);
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)
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 */
309 senderp = estrdup(value(m->attr, "sender", "???"));
310 showmailp = estrdup(m->data);
312 digestp = estrdup(digestp);
315 if(logrecv(&senderp, &xtime) <= 0)
316 killall("error reading log file");
317 showmailp = estrdup("");
322 f->tm = *localtime(xtime);
323 f->str[Sshow] = showmailp;
324 f->str[Sdigest] = digestp;
331 iline(char *data, char **pp)
335 for(p=data; *p!='\0' && *p!='\n'; p++)
344 dirface(char *dir, char *num)
348 char buf[1024], *info, *p, *digest;
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.
359 if(getwd(pwd, sizeof pwd) != nil && strcmp(pwd, dir) == 0)
360 sprint(buf, "%s/info", num);
362 sprint(buf, "%s/%s/info", dir, num);
364 sprint(buf, "%s/%s/info", dir, num);
365 len = fsdirlen(upasfs, buf);
368 fid = fsopen(upasfs,buf, OREAD);
371 info = emalloc(len+1);
372 n = fsreadn(fid, info, len);
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);