1 9f1fdc12 2005-10-29 devnull #include <u.h>
2 9f1fdc12 2005-10-29 devnull #include <libc.h>
3 9f1fdc12 2005-10-29 devnull #include <bio.h>
4 9f1fdc12 2005-10-29 devnull #include <thread.h>
5 00d75e0e 2006-02-11 devnull #include <9pclient.h>
6 9f1fdc12 2005-10-29 devnull #include <plumb.h>
7 9f1fdc12 2005-10-29 devnull #include <ctype.h>
8 9f1fdc12 2005-10-29 devnull #include "dat.h"
10 00d75e0e 2006-02-11 devnull char *maildir = "Mail/"; /* mountpoint of mail file system */
11 00d75e0e 2006-02-11 devnull char *mboxname = "mbox"; /* mailboxdir/mboxname is mail spool file */
12 9f1fdc12 2005-10-29 devnull char *mailboxdir = nil; /* nil == /mail/box/$user */
13 9f1fdc12 2005-10-29 devnull char *fsname; /* filesystem for mailboxdir/mboxname is at maildir/fsname */
14 9f1fdc12 2005-10-29 devnull char *user;
15 9f1fdc12 2005-10-29 devnull char *outgoing;
16 dfbaaaa6 2006-05-27 devnull char *srvname;
18 9f1fdc12 2005-10-29 devnull Window *wbox;
19 9f1fdc12 2005-10-29 devnull Message mbox;
20 9f1fdc12 2005-10-29 devnull Message replies;
21 9f1fdc12 2005-10-29 devnull char *home;
22 00d75e0e 2006-02-11 devnull CFid *plumbsendfd;
23 00d75e0e 2006-02-11 devnull CFid *plumbseemailfd;
24 00d75e0e 2006-02-11 devnull CFid *plumbshowmailfd;
25 00d75e0e 2006-02-11 devnull CFid *plumbsendmailfd;
26 9f1fdc12 2005-10-29 devnull Channel *cplumb;
27 9f1fdc12 2005-10-29 devnull Channel *cplumbshow;
28 9f1fdc12 2005-10-29 devnull Channel *cplumbsend;
29 9f1fdc12 2005-10-29 devnull int wctlfd;
30 9f1fdc12 2005-10-29 devnull void mainctl(void*);
31 9f1fdc12 2005-10-29 devnull void plumbproc(void*);
32 9f1fdc12 2005-10-29 devnull void plumbshowproc(void*);
33 9f1fdc12 2005-10-29 devnull void plumbsendproc(void*);
34 9f1fdc12 2005-10-29 devnull void plumbthread(void);
35 9f1fdc12 2005-10-29 devnull void plumbshowthread(void*);
36 9f1fdc12 2005-10-29 devnull void plumbsendthread(void*);
38 9f1fdc12 2005-10-29 devnull int shortmenu;
40 3f8c36d6 2006-02-09 devnull CFsys *mailfs;
41 3f8c36d6 2006-02-09 devnull CFsys *acmefs;
44 9f1fdc12 2005-10-29 devnull usage(void)
46 44fc56d8 2006-05-21 devnull fprint(2, "usage: Mail [-sS] [-n srvname] [-o outgoing] [mailboxname [directoryname]]\n");
47 9f1fdc12 2005-10-29 devnull threadexitsall("usage");
51 9f1fdc12 2005-10-29 devnull removeupasfs(void)
53 9f1fdc12 2005-10-29 devnull char buf[256];
55 9f1fdc12 2005-10-29 devnull if(strcmp(mboxname, "mbox") == 0)
57 9f1fdc12 2005-10-29 devnull snprint(buf, sizeof buf, "close %s", mboxname);
58 3f8c36d6 2006-02-09 devnull fswrite(mbox.ctlfd, buf, strlen(buf));
62 9f1fdc12 2005-10-29 devnull ismaildir(char *s)
67 3b5862ee 2006-02-14 devnull d = fsdirstat(mailfs, s);
68 9f1fdc12 2005-10-29 devnull if(d == nil)
69 9f1fdc12 2005-10-29 devnull return 0;
70 9f1fdc12 2005-10-29 devnull ret = d->qid.type & QTDIR;
72 9f1fdc12 2005-10-29 devnull return ret;
76 9f1fdc12 2005-10-29 devnull threadmain(int argc, char *argv[])
78 dfbaaaa6 2006-05-27 devnull char *s, *name;
79 9f1fdc12 2005-10-29 devnull char err[ERRMAX], *cmd;
80 9f1fdc12 2005-10-29 devnull int i, newdir;
83 9f1fdc12 2005-10-29 devnull doquote = needsrcquote;
84 9f1fdc12 2005-10-29 devnull quotefmtinstall();
86 9f1fdc12 2005-10-29 devnull /* open these early so we won't miss notification of new mail messages while we read mbox */
87 00d75e0e 2006-02-11 devnull plumbsendfd = plumbopenfid("send", OWRITE|OCEXEC);
88 00d75e0e 2006-02-11 devnull plumbseemailfd = plumbopenfid("seemail", OREAD|OCEXEC);
89 00d75e0e 2006-02-11 devnull plumbshowmailfd = plumbopenfid("showmail", OREAD|OCEXEC);
91 9f1fdc12 2005-10-29 devnull shortmenu = 0;
92 44fc56d8 2006-05-21 devnull srvname = "mail";
93 9f1fdc12 2005-10-29 devnull ARGBEGIN{
94 9f1fdc12 2005-10-29 devnull case 's':
95 9f1fdc12 2005-10-29 devnull shortmenu = 1;
97 9f1fdc12 2005-10-29 devnull case 'S':
98 9f1fdc12 2005-10-29 devnull shortmenu = 2;
100 9f1fdc12 2005-10-29 devnull case 'o':
101 9f1fdc12 2005-10-29 devnull outgoing = EARGF(usage());
103 9f1fdc12 2005-10-29 devnull case 'm':
104 9f1fdc12 2005-10-29 devnull smprint(maildir, "%s/", EARGF(usage()));
106 44fc56d8 2006-05-21 devnull case 'n':
107 44fc56d8 2006-05-21 devnull srvname = EARGF(usage());
109 9f1fdc12 2005-10-29 devnull default:
110 9f1fdc12 2005-10-29 devnull usage();
113 3f8c36d6 2006-02-09 devnull acmefs = nsmount("acme",nil);
114 3f8c36d6 2006-02-09 devnull if(acmefs == nil)
115 3f8c36d6 2006-02-09 devnull error("cannot mount acme: %r");
116 44fc56d8 2006-05-21 devnull mailfs = nsmount(srvname, nil);
117 3f8c36d6 2006-02-09 devnull if(mailfs == nil)
118 44fc56d8 2006-05-21 devnull error("cannot mount %s: %r", srvname);
120 00d75e0e 2006-02-11 devnull name = "mbox";
122 9f1fdc12 2005-10-29 devnull newdir = 1;
123 9f1fdc12 2005-10-29 devnull if(argc > 0){
124 9f1fdc12 2005-10-29 devnull i = strlen(argv[0]);
125 9f1fdc12 2005-10-29 devnull if(argc>2 || i==0)
126 9f1fdc12 2005-10-29 devnull usage();
127 9f1fdc12 2005-10-29 devnull /* see if the name is that of an existing /mail/fs directory */
128 3b5862ee 2006-02-14 devnull if(argc==1 && argv[0][0] != '/' && ismaildir(argv[0])){
129 9f1fdc12 2005-10-29 devnull name = argv[0];
130 3b5862ee 2006-02-14 devnull mboxname = estrdup(name);
131 9f1fdc12 2005-10-29 devnull newdir = 0;
133 9f1fdc12 2005-10-29 devnull if(argv[0][i-1] == '/')
134 9f1fdc12 2005-10-29 devnull argv[0][i-1] = '\0';
135 9f1fdc12 2005-10-29 devnull s = strrchr(argv[0], '/');
136 9f1fdc12 2005-10-29 devnull if(s == nil)
137 9f1fdc12 2005-10-29 devnull mboxname = estrdup(argv[0]);
139 9f1fdc12 2005-10-29 devnull *s++ = '\0';
140 9f1fdc12 2005-10-29 devnull if(*s == '\0')
141 9f1fdc12 2005-10-29 devnull usage();
142 9f1fdc12 2005-10-29 devnull mailboxdir = argv[0];
143 9f1fdc12 2005-10-29 devnull mboxname = estrdup(s);
145 9f1fdc12 2005-10-29 devnull if(argc > 1)
146 9f1fdc12 2005-10-29 devnull name = argv[1];
148 9f1fdc12 2005-10-29 devnull name = mboxname;
152 9f1fdc12 2005-10-29 devnull user = getenv("user");
153 9f1fdc12 2005-10-29 devnull if(user == nil)
154 9f1fdc12 2005-10-29 devnull user = "none";
155 3f8c36d6 2006-02-09 devnull home = getenv("home");
156 3f8c36d6 2006-02-09 devnull if(home == nil)
157 3f8c36d6 2006-02-09 devnull home = getenv("HOME");
158 3f8c36d6 2006-02-09 devnull if(home == nil)
159 3f8c36d6 2006-02-09 devnull error("can't find $home");
160 9f1fdc12 2005-10-29 devnull if(mailboxdir == nil)
161 3f8c36d6 2006-02-09 devnull mailboxdir = estrstrdup(home, "/mail");
162 9f1fdc12 2005-10-29 devnull if(outgoing == nil)
163 9f1fdc12 2005-10-29 devnull outgoing = estrstrdup(mailboxdir, "/outgoing");
165 3b5862ee 2006-02-14 devnull mbox.ctlfd = fsopen(mailfs, estrstrdup(mboxname, "/ctl"), OWRITE);
166 3f8c36d6 2006-02-09 devnull if(mbox.ctlfd == nil)
167 3b5862ee 2006-02-14 devnull error("can't open %s: %r", estrstrdup(mboxname, "/ctl"));
169 9f1fdc12 2005-10-29 devnull fsname = estrdup(name);
170 9f1fdc12 2005-10-29 devnull if(newdir && argc > 0){
171 9f1fdc12 2005-10-29 devnull s = emalloc(5+strlen(mailboxdir)+strlen(mboxname)+strlen(name)+10+1);
172 9f1fdc12 2005-10-29 devnull for(i=0; i<10; i++){
173 9f1fdc12 2005-10-29 devnull sprint(s, "open %s/%s %s", mailboxdir, mboxname, fsname);
174 3f8c36d6 2006-02-09 devnull if(fswrite(mbox.ctlfd, s, strlen(s)) >= 0)
176 9f1fdc12 2005-10-29 devnull err[0] = '\0';
177 9f1fdc12 2005-10-29 devnull errstr(err, sizeof err);
178 9f1fdc12 2005-10-29 devnull if(strstr(err, "mbox name in use") == nil)
179 3f8c36d6 2006-02-09 devnull error("can't create directory %s for mail: %s", name, err);
180 9f1fdc12 2005-10-29 devnull free(fsname);
181 9f1fdc12 2005-10-29 devnull fsname = emalloc(strlen(name)+10);
182 9f1fdc12 2005-10-29 devnull sprint(fsname, "%s-%d", name, i);
184 9f1fdc12 2005-10-29 devnull if(i == 10)
185 9f1fdc12 2005-10-29 devnull error("can't open %s/%s: %r", mailboxdir, mboxname);
186 9f1fdc12 2005-10-29 devnull free(s);
189 9f1fdc12 2005-10-29 devnull s = estrstrdup(fsname, "/");
190 9f1fdc12 2005-10-29 devnull mbox.name = estrstrdup(maildir, s);
191 9f1fdc12 2005-10-29 devnull mbox.level= 0;
192 9f1fdc12 2005-10-29 devnull readmbox(&mbox, maildir, s);
193 9f1fdc12 2005-10-29 devnull home = getenv("home");
194 9f1fdc12 2005-10-29 devnull if(home == nil)
195 9f1fdc12 2005-10-29 devnull home = "/";
197 9f1fdc12 2005-10-29 devnull wbox = newwindow();
198 9f1fdc12 2005-10-29 devnull winname(wbox, mbox.name);
199 9f1fdc12 2005-10-29 devnull wintagwrite(wbox, "Put Mail Delmesg ", 3+1+4+1+7+1);
200 9f1fdc12 2005-10-29 devnull threadcreate(mainctl, wbox, STACK);
202 9f1fdc12 2005-10-29 devnull fmtstrinit(&fmt);
203 9f1fdc12 2005-10-29 devnull fmtprint(&fmt, "Mail");
204 9f1fdc12 2005-10-29 devnull if(shortmenu)
205 9f1fdc12 2005-10-29 devnull fmtprint(&fmt, " -%c", "sS"[shortmenu-1]);
206 9f1fdc12 2005-10-29 devnull if(outgoing)
207 9f1fdc12 2005-10-29 devnull fmtprint(&fmt, " -o %s", outgoing);
208 9f1fdc12 2005-10-29 devnull fmtprint(&fmt, " %s", name);
209 9f1fdc12 2005-10-29 devnull cmd = fmtstrflush(&fmt);
210 9f1fdc12 2005-10-29 devnull if(cmd == nil)
211 9f1fdc12 2005-10-29 devnull sysfatal("out of memory");
212 9f1fdc12 2005-10-29 devnull winsetdump(wbox, "/acme/mail", cmd);
213 9f1fdc12 2005-10-29 devnull mbox.w = wbox;
215 9f1fdc12 2005-10-29 devnull mesgmenu(wbox, &mbox);
216 9f1fdc12 2005-10-29 devnull winclean(wbox);
218 3f8c36d6 2006-02-09 devnull /* wctlfd = open("/dev/wctl", OWRITE|OCEXEC); /* for acme window */
219 3f8c36d6 2006-02-09 devnull wctlfd = -1;
220 9f1fdc12 2005-10-29 devnull cplumb = chancreate(sizeof(Plumbmsg*), 0);
221 9f1fdc12 2005-10-29 devnull cplumbshow = chancreate(sizeof(Plumbmsg*), 0);
222 00d75e0e 2006-02-11 devnull if(strcmp(name, "mbox") == 0){
224 9f1fdc12 2005-10-29 devnull * Avoid creating multiple windows to send mail by only accepting
225 9f1fdc12 2005-10-29 devnull * sendmail plumb messages if we're reading the main mailbox.
227 00d75e0e 2006-02-11 devnull plumbsendmailfd = plumbopenfid("sendmail", OREAD|OCEXEC);
228 9f1fdc12 2005-10-29 devnull cplumbsend = chancreate(sizeof(Plumbmsg*), 0);
229 9f1fdc12 2005-10-29 devnull proccreate(plumbsendproc, nil, STACK);
230 9f1fdc12 2005-10-29 devnull threadcreate(plumbsendthread, nil, STACK);
232 9f1fdc12 2005-10-29 devnull /* start plumb reader as separate proc ... */
233 9f1fdc12 2005-10-29 devnull proccreate(plumbproc, nil, STACK);
234 9f1fdc12 2005-10-29 devnull proccreate(plumbshowproc, nil, STACK);
235 9f1fdc12 2005-10-29 devnull threadcreate(plumbshowthread, nil, STACK);
236 7cc0e47f 2007-06-23 devnull fswrite(mbox.ctlfd, "refresh", 7);
237 9f1fdc12 2005-10-29 devnull /* ... and use this thread to read the messages */
238 9f1fdc12 2005-10-29 devnull plumbthread();
242 9f1fdc12 2005-10-29 devnull plumbproc(void* v)
244 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
246 9f1fdc12 2005-10-29 devnull threadsetname("plumbproc");
247 9f1fdc12 2005-10-29 devnull for(;;){
248 00d75e0e 2006-02-11 devnull m = plumbrecvfid(plumbseemailfd);
249 9f1fdc12 2005-10-29 devnull sendp(cplumb, m);
250 9f1fdc12 2005-10-29 devnull if(m == nil)
251 9f1fdc12 2005-10-29 devnull threadexits(nil);
256 9f1fdc12 2005-10-29 devnull plumbshowproc(void* v)
258 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
260 9f1fdc12 2005-10-29 devnull threadsetname("plumbshowproc");
261 9f1fdc12 2005-10-29 devnull for(;;){
262 00d75e0e 2006-02-11 devnull m = plumbrecvfid(plumbshowmailfd);
263 9f1fdc12 2005-10-29 devnull sendp(cplumbshow, m);
264 9f1fdc12 2005-10-29 devnull if(m == nil)
265 9f1fdc12 2005-10-29 devnull threadexits(nil);
270 9f1fdc12 2005-10-29 devnull plumbsendproc(void* v)
272 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
274 9f1fdc12 2005-10-29 devnull threadsetname("plumbsendproc");
275 9f1fdc12 2005-10-29 devnull for(;;){
276 00d75e0e 2006-02-11 devnull m = plumbrecvfid(plumbsendmailfd);
277 9f1fdc12 2005-10-29 devnull sendp(cplumbsend, m);
278 9f1fdc12 2005-10-29 devnull if(m == nil)
279 9f1fdc12 2005-10-29 devnull threadexits(nil);
284 9f1fdc12 2005-10-29 devnull newmesg(char *name, char *digest)
288 3f8c36d6 2006-02-09 devnull if(strncmp(name, mbox.name, strlen(mbox.name)) != 0)
289 9f1fdc12 2005-10-29 devnull return; /* message is about another mailbox */
290 3f8c36d6 2006-02-09 devnull if(mesglookupfile(&mbox, name, digest) != nil)
292 00d75e0e 2006-02-11 devnull if(strncmp(name, "Mail/", 5) == 0)
293 00d75e0e 2006-02-11 devnull name += 5;
294 3f8c36d6 2006-02-09 devnull d = fsdirstat(mailfs, name);
295 3f8c36d6 2006-02-09 devnull if(d == nil)
297 3f8c36d6 2006-02-09 devnull if(mesgadd(&mbox, mbox.name, d, digest))
298 9f1fdc12 2005-10-29 devnull mesgmenunew(wbox, &mbox);
299 9f1fdc12 2005-10-29 devnull free(d);
303 9f1fdc12 2005-10-29 devnull showmesg(char *name, char *digest)
305 9f1fdc12 2005-10-29 devnull char *n;
306 3f8c36d6 2006-02-09 devnull char *mb;
308 3f8c36d6 2006-02-09 devnull mb = mbox.name;
309 3f8c36d6 2006-02-09 devnull if(strncmp(name, mb, strlen(mb)) != 0)
310 9f1fdc12 2005-10-29 devnull return; /* message is about another mailbox */
311 3f8c36d6 2006-02-09 devnull n = estrdup(name+strlen(mb));
312 9f1fdc12 2005-10-29 devnull if(n[strlen(n)-1] != '/')
313 9f1fdc12 2005-10-29 devnull n = egrow(n, "/", nil);
314 3f8c36d6 2006-02-09 devnull mesgopen(&mbox, mbox.name, name+strlen(mb), nil, 1, digest);
315 9f1fdc12 2005-10-29 devnull free(n);
319 0d42cc9d 2006-02-28 devnull delmesg(char *name, char *digest, int dodel, char *save)
321 9f1fdc12 2005-10-29 devnull Message *m;
323 9f1fdc12 2005-10-29 devnull m = mesglookupfile(&mbox, name, digest);
324 9f1fdc12 2005-10-29 devnull if(m != nil){
325 0d42cc9d 2006-02-28 devnull if(save)
326 0d42cc9d 2006-02-28 devnull mesgcommand(m, estrstrdup("Save ", save));
327 9f1fdc12 2005-10-29 devnull if(dodel)
328 0d42cc9d 2006-02-28 devnull mesgmenumarkdel(wbox, &mbox, m, 1);
330 313c365a 2007-06-23 devnull fprint(2, "message is gone...\n");
331 0d42cc9d 2006-02-28 devnull /* notification came from plumber - message is gone */
332 0d42cc9d 2006-02-28 devnull mesgmenudel(wbox, &mbox, m);
333 0d42cc9d 2006-02-28 devnull if(!m->opened)
334 0d42cc9d 2006-02-28 devnull mesgdel(&mbox, m);
340 9f1fdc12 2005-10-29 devnull plumbthread(void)
342 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
343 9f1fdc12 2005-10-29 devnull Plumbattr *a;
344 9f1fdc12 2005-10-29 devnull char *type, *digest;
346 9f1fdc12 2005-10-29 devnull threadsetname("plumbthread");
347 9f1fdc12 2005-10-29 devnull while((m = recvp(cplumb)) != nil){
348 9f1fdc12 2005-10-29 devnull a = m->attr;
349 9f1fdc12 2005-10-29 devnull digest = plumblookup(a, "digest");
350 9f1fdc12 2005-10-29 devnull type = plumblookup(a, "mailtype");
351 9f1fdc12 2005-10-29 devnull if(type == nil)
352 9f1fdc12 2005-10-29 devnull fprint(2, "Mail: plumb message with no mailtype attribute\n");
353 9f1fdc12 2005-10-29 devnull else if(strcmp(type, "new") == 0)
354 9f1fdc12 2005-10-29 devnull newmesg(m->data, digest);
355 9f1fdc12 2005-10-29 devnull else if(strcmp(type, "delete") == 0)
356 0d42cc9d 2006-02-28 devnull delmesg(m->data, digest, 0, nil);
358 9f1fdc12 2005-10-29 devnull fprint(2, "Mail: unknown plumb attribute %s\n", type);
359 9f1fdc12 2005-10-29 devnull plumbfree(m);
361 9f1fdc12 2005-10-29 devnull threadexits(nil);
365 3f8c36d6 2006-02-09 devnull plumbshowthread(void *v)
367 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
369 3f8c36d6 2006-02-09 devnull USED(v);
370 9f1fdc12 2005-10-29 devnull threadsetname("plumbshowthread");
371 9f1fdc12 2005-10-29 devnull while((m = recvp(cplumbshow)) != nil){
372 9f1fdc12 2005-10-29 devnull showmesg(m->data, plumblookup(m->attr, "digest"));
373 9f1fdc12 2005-10-29 devnull plumbfree(m);
375 9f1fdc12 2005-10-29 devnull threadexits(nil);
379 3f8c36d6 2006-02-09 devnull plumbsendthread(void *v)
381 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
383 3f8c36d6 2006-02-09 devnull USED(v);
384 9f1fdc12 2005-10-29 devnull threadsetname("plumbsendthread");
385 9f1fdc12 2005-10-29 devnull while((m = recvp(cplumbsend)) != nil){
386 9f1fdc12 2005-10-29 devnull mkreply(nil, "Mail", m->data, m->attr, nil);
387 9f1fdc12 2005-10-29 devnull plumbfree(m);
389 9f1fdc12 2005-10-29 devnull threadexits(nil);
393 9f1fdc12 2005-10-29 devnull mboxcommand(Window *w, char *s)
395 0d42cc9d 2006-02-28 devnull char *args[10], **targs, *save;
396 9f1fdc12 2005-10-29 devnull Message *m, *next;
397 9f1fdc12 2005-10-29 devnull int ok, nargs, i, j;
398 9f1fdc12 2005-10-29 devnull char buf[128];
400 9f1fdc12 2005-10-29 devnull nargs = tokenize(s, args, nelem(args));
401 9f1fdc12 2005-10-29 devnull if(nargs == 0)
402 9f1fdc12 2005-10-29 devnull return 0;
403 9f1fdc12 2005-10-29 devnull if(strcmp(args[0], "Mail") == 0){
404 9f1fdc12 2005-10-29 devnull if(nargs == 1)
405 9f1fdc12 2005-10-29 devnull mkreply(nil, "Mail", "", nil, nil);
407 9f1fdc12 2005-10-29 devnull mkreply(nil, "Mail", args[1], nil, nil);
408 9f1fdc12 2005-10-29 devnull return 1;
410 9f1fdc12 2005-10-29 devnull if(strcmp(s, "Del") == 0){
411 9f1fdc12 2005-10-29 devnull if(mbox.dirty){
412 9f1fdc12 2005-10-29 devnull mbox.dirty = 0;
413 9f1fdc12 2005-10-29 devnull fprint(2, "mail: mailbox not written\n");
414 9f1fdc12 2005-10-29 devnull return 1;
417 9f1fdc12 2005-10-29 devnull for(m=mbox.head; m!=nil; m=next){
418 9f1fdc12 2005-10-29 devnull next = m->next;
419 9f1fdc12 2005-10-29 devnull if(m->w){
420 9f1fdc12 2005-10-29 devnull if(windel(m->w, 0))
421 9f1fdc12 2005-10-29 devnull m->w = nil;
426 9f1fdc12 2005-10-29 devnull for(m=replies.head; m!=nil; m=next){
427 9f1fdc12 2005-10-29 devnull next = m->next;
428 9f1fdc12 2005-10-29 devnull if(m->w){
429 9f1fdc12 2005-10-29 devnull if(windel(m->w, 0))
430 9f1fdc12 2005-10-29 devnull m->w = nil;
436 9f1fdc12 2005-10-29 devnull windel(w, 1);
437 9f1fdc12 2005-10-29 devnull removeupasfs();
438 9f1fdc12 2005-10-29 devnull threadexitsall(nil);
440 9f1fdc12 2005-10-29 devnull return 1;
442 9f1fdc12 2005-10-29 devnull if(strcmp(s, "Put") == 0){
443 9f1fdc12 2005-10-29 devnull rewritembox(wbox, &mbox);
444 7cc0e47f 2007-06-23 devnull return 1;
446 7cc0e47f 2007-06-23 devnull if(strcmp(s, "Get") == 0){
447 7cc0e47f 2007-06-23 devnull fswrite(mbox.ctlfd, "refresh", 7);
448 9f1fdc12 2005-10-29 devnull return 1;
450 9f1fdc12 2005-10-29 devnull if(strcmp(s, "Delmesg") == 0){
451 0d42cc9d 2006-02-28 devnull save = nil;
452 0d42cc9d 2006-02-28 devnull if(nargs > 1)
453 0d42cc9d 2006-02-28 devnull save = args[1];
454 9f1fdc12 2005-10-29 devnull s = winselection(w);
455 9f1fdc12 2005-10-29 devnull if(s == nil)
456 9f1fdc12 2005-10-29 devnull return 1;
457 9f1fdc12 2005-10-29 devnull nargs = 1;
458 9f1fdc12 2005-10-29 devnull for(i=0; s[i]; i++)
459 9f1fdc12 2005-10-29 devnull if(s[i] == '\n')
460 9f1fdc12 2005-10-29 devnull nargs++;
461 9f1fdc12 2005-10-29 devnull targs = emalloc(nargs*sizeof(char*)); /* could be too many for a local array */
462 9f1fdc12 2005-10-29 devnull nargs = getfields(s, targs, nargs, 1, "\n");
463 9f1fdc12 2005-10-29 devnull for(i=0; i<nargs; i++){
464 9f1fdc12 2005-10-29 devnull if(!isdigit(targs[i][0]))
465 9f1fdc12 2005-10-29 devnull continue;
466 9f1fdc12 2005-10-29 devnull j = atoi(targs[i]); /* easy way to parse the number! */
467 9f1fdc12 2005-10-29 devnull if(j == 0)
468 9f1fdc12 2005-10-29 devnull continue;
469 9f1fdc12 2005-10-29 devnull snprint(buf, sizeof buf, "%s%d", mbox.name, j);
470 0d42cc9d 2006-02-28 devnull delmesg(buf, nil, 1, save);
472 9f1fdc12 2005-10-29 devnull free(s);
473 9f1fdc12 2005-10-29 devnull free(targs);
474 9f1fdc12 2005-10-29 devnull return 1;
476 9f1fdc12 2005-10-29 devnull return 0;
480 9f1fdc12 2005-10-29 devnull mainctl(void *v)
482 9f1fdc12 2005-10-29 devnull Window *w;
483 9f1fdc12 2005-10-29 devnull Event *e, *e2, *eq, *ea;
484 9f1fdc12 2005-10-29 devnull int na, nopen;
485 9f1fdc12 2005-10-29 devnull char *s, *t, *buf;
488 880ab2f1 2006-02-15 devnull winincref(w);
489 9f1fdc12 2005-10-29 devnull proccreate(wineventproc, w, STACK);
491 9f1fdc12 2005-10-29 devnull for(;;){
492 9f1fdc12 2005-10-29 devnull e = recvp(w->cevent);
493 9f1fdc12 2005-10-29 devnull switch(e->c1){
494 9f1fdc12 2005-10-29 devnull default:
495 9f1fdc12 2005-10-29 devnull Unknown:
496 9f1fdc12 2005-10-29 devnull print("unknown message %c%c\n", e->c1, e->c2);
499 9f1fdc12 2005-10-29 devnull case 'E': /* write to body; can't affect us */
502 9f1fdc12 2005-10-29 devnull case 'F': /* generated by our actions; ignore */
505 9f1fdc12 2005-10-29 devnull case 'K': /* type away; we don't care */
508 9f1fdc12 2005-10-29 devnull case 'M':
509 9f1fdc12 2005-10-29 devnull switch(e->c2){
510 9f1fdc12 2005-10-29 devnull case 'x':
511 9f1fdc12 2005-10-29 devnull case 'X':
512 9f1fdc12 2005-10-29 devnull ea = nil;
513 9f1fdc12 2005-10-29 devnull e2 = nil;
514 9f1fdc12 2005-10-29 devnull if(e->flag & 2)
515 9f1fdc12 2005-10-29 devnull e2 = recvp(w->cevent);
516 9f1fdc12 2005-10-29 devnull if(e->flag & 8){
517 9f1fdc12 2005-10-29 devnull ea = recvp(w->cevent);
518 9f1fdc12 2005-10-29 devnull na = ea->nb;
519 9f1fdc12 2005-10-29 devnull recvp(w->cevent);
522 9f1fdc12 2005-10-29 devnull s = e->b;
523 9f1fdc12 2005-10-29 devnull /* if it's a known command, do it */
524 9f1fdc12 2005-10-29 devnull if((e->flag&2) && e->nb==0)
525 9f1fdc12 2005-10-29 devnull s = e2->b;
527 9f1fdc12 2005-10-29 devnull t = emalloc(strlen(s)+1+na+1);
528 9f1fdc12 2005-10-29 devnull sprint(t, "%s %s", s, ea->b);
531 9f1fdc12 2005-10-29 devnull /* if it's a long message, it can't be for us anyway */
532 9f1fdc12 2005-10-29 devnull if(!mboxcommand(w, s)) /* send it back */
533 9f1fdc12 2005-10-29 devnull winwriteevent(w, e);
535 9f1fdc12 2005-10-29 devnull free(s);
538 9f1fdc12 2005-10-29 devnull case 'l':
539 9f1fdc12 2005-10-29 devnull case 'L':
540 9f1fdc12 2005-10-29 devnull buf = nil;
542 9f1fdc12 2005-10-29 devnull if(e->flag & 2){
543 9f1fdc12 2005-10-29 devnull e2 = recvp(w->cevent);
544 9f1fdc12 2005-10-29 devnull eq = e2;
546 9f1fdc12 2005-10-29 devnull s = eq->b;
547 9f1fdc12 2005-10-29 devnull if(eq->q1>eq->q0 && eq->nb==0){
548 9f1fdc12 2005-10-29 devnull buf = emalloc((eq->q1-eq->q0)*UTFmax+1);
549 9f1fdc12 2005-10-29 devnull winread(w, eq->q0, eq->q1, buf);
550 9f1fdc12 2005-10-29 devnull s = buf;
552 9f1fdc12 2005-10-29 devnull nopen = 0;
554 9f1fdc12 2005-10-29 devnull /* skip 'deleted' string if present' */
555 9f1fdc12 2005-10-29 devnull if(strncmp(s, deleted, strlen(deleted)) == 0)
556 9f1fdc12 2005-10-29 devnull s += strlen(deleted);
557 9f1fdc12 2005-10-29 devnull /* skip mail box name if present */
558 9f1fdc12 2005-10-29 devnull if(strncmp(s, mbox.name, strlen(mbox.name)) == 0)
559 9f1fdc12 2005-10-29 devnull s += strlen(mbox.name);
560 9f1fdc12 2005-10-29 devnull nopen += mesgopen(&mbox, mbox.name, s, nil, 0, nil);
561 9f1fdc12 2005-10-29 devnull while(*s!='\0' && *s++!='\n')
563 9f1fdc12 2005-10-29 devnull }while(*s);
564 9f1fdc12 2005-10-29 devnull if(nopen == 0) /* send it back */
565 9f1fdc12 2005-10-29 devnull winwriteevent(w, e);
566 9f1fdc12 2005-10-29 devnull free(buf);
569 9f1fdc12 2005-10-29 devnull case 'I': /* modify away; we don't care */
570 9f1fdc12 2005-10-29 devnull case 'D':
571 9f1fdc12 2005-10-29 devnull case 'd':
572 9f1fdc12 2005-10-29 devnull case 'i':
575 9f1fdc12 2005-10-29 devnull default:
576 9f1fdc12 2005-10-29 devnull goto Unknown;
