Blame


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"
9 9f1fdc12 2005-10-29 devnull
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 9f1fdc12 2005-10-29 devnull
17 9f1fdc12 2005-10-29 devnull Window *wbox;
18 9f1fdc12 2005-10-29 devnull Message mbox;
19 9f1fdc12 2005-10-29 devnull Message replies;
20 9f1fdc12 2005-10-29 devnull char *home;
21 00d75e0e 2006-02-11 devnull CFid *plumbsendfd;
22 00d75e0e 2006-02-11 devnull CFid *plumbseemailfd;
23 00d75e0e 2006-02-11 devnull CFid *plumbshowmailfd;
24 00d75e0e 2006-02-11 devnull CFid *plumbsendmailfd;
25 9f1fdc12 2005-10-29 devnull Channel *cplumb;
26 9f1fdc12 2005-10-29 devnull Channel *cplumbshow;
27 9f1fdc12 2005-10-29 devnull Channel *cplumbsend;
28 9f1fdc12 2005-10-29 devnull int wctlfd;
29 9f1fdc12 2005-10-29 devnull void mainctl(void*);
30 9f1fdc12 2005-10-29 devnull void plumbproc(void*);
31 9f1fdc12 2005-10-29 devnull void plumbshowproc(void*);
32 9f1fdc12 2005-10-29 devnull void plumbsendproc(void*);
33 9f1fdc12 2005-10-29 devnull void plumbthread(void);
34 9f1fdc12 2005-10-29 devnull void plumbshowthread(void*);
35 9f1fdc12 2005-10-29 devnull void plumbsendthread(void*);
36 9f1fdc12 2005-10-29 devnull
37 9f1fdc12 2005-10-29 devnull int shortmenu;
38 9f1fdc12 2005-10-29 devnull
39 3f8c36d6 2006-02-09 devnull CFsys *mailfs;
40 3f8c36d6 2006-02-09 devnull CFsys *acmefs;
41 9f1fdc12 2005-10-29 devnull
42 9f1fdc12 2005-10-29 devnull void
43 9f1fdc12 2005-10-29 devnull usage(void)
44 9f1fdc12 2005-10-29 devnull {
45 9f1fdc12 2005-10-29 devnull fprint(2, "usage: Mail [-sS] [-o outgoing] [mailboxname [directoryname]]\n");
46 9f1fdc12 2005-10-29 devnull threadexitsall("usage");
47 9f1fdc12 2005-10-29 devnull }
48 9f1fdc12 2005-10-29 devnull
49 9f1fdc12 2005-10-29 devnull void
50 9f1fdc12 2005-10-29 devnull removeupasfs(void)
51 9f1fdc12 2005-10-29 devnull {
52 9f1fdc12 2005-10-29 devnull char buf[256];
53 9f1fdc12 2005-10-29 devnull
54 9f1fdc12 2005-10-29 devnull if(strcmp(mboxname, "mbox") == 0)
55 9f1fdc12 2005-10-29 devnull return;
56 9f1fdc12 2005-10-29 devnull snprint(buf, sizeof buf, "close %s", mboxname);
57 3f8c36d6 2006-02-09 devnull fswrite(mbox.ctlfd, buf, strlen(buf));
58 9f1fdc12 2005-10-29 devnull }
59 9f1fdc12 2005-10-29 devnull
60 9f1fdc12 2005-10-29 devnull int
61 9f1fdc12 2005-10-29 devnull ismaildir(char *s)
62 9f1fdc12 2005-10-29 devnull {
63 9f1fdc12 2005-10-29 devnull char buf[256];
64 9f1fdc12 2005-10-29 devnull Dir *d;
65 9f1fdc12 2005-10-29 devnull int ret;
66 9f1fdc12 2005-10-29 devnull
67 9f1fdc12 2005-10-29 devnull snprint(buf, sizeof buf, "%s%s", maildir, s);
68 9f1fdc12 2005-10-29 devnull d = dirstat(buf);
69 9f1fdc12 2005-10-29 devnull if(d == nil)
70 9f1fdc12 2005-10-29 devnull return 0;
71 9f1fdc12 2005-10-29 devnull ret = d->qid.type & QTDIR;
72 9f1fdc12 2005-10-29 devnull free(d);
73 9f1fdc12 2005-10-29 devnull return ret;
74 9f1fdc12 2005-10-29 devnull }
75 9f1fdc12 2005-10-29 devnull
76 9f1fdc12 2005-10-29 devnull void
77 9f1fdc12 2005-10-29 devnull threadmain(int argc, char *argv[])
78 9f1fdc12 2005-10-29 devnull {
79 9f1fdc12 2005-10-29 devnull char *s, *name;
80 9f1fdc12 2005-10-29 devnull char err[ERRMAX], *cmd;
81 9f1fdc12 2005-10-29 devnull int i, newdir;
82 9f1fdc12 2005-10-29 devnull Fmt fmt;
83 9f1fdc12 2005-10-29 devnull
84 9f1fdc12 2005-10-29 devnull doquote = needsrcquote;
85 9f1fdc12 2005-10-29 devnull quotefmtinstall();
86 9f1fdc12 2005-10-29 devnull
87 9f1fdc12 2005-10-29 devnull /* open these early so we won't miss notification of new mail messages while we read mbox */
88 00d75e0e 2006-02-11 devnull plumbsendfd = plumbopenfid("send", OWRITE|OCEXEC);
89 00d75e0e 2006-02-11 devnull plumbseemailfd = plumbopenfid("seemail", OREAD|OCEXEC);
90 00d75e0e 2006-02-11 devnull plumbshowmailfd = plumbopenfid("showmail", OREAD|OCEXEC);
91 9f1fdc12 2005-10-29 devnull
92 9f1fdc12 2005-10-29 devnull shortmenu = 0;
93 9f1fdc12 2005-10-29 devnull ARGBEGIN{
94 9f1fdc12 2005-10-29 devnull case 's':
95 9f1fdc12 2005-10-29 devnull shortmenu = 1;
96 9f1fdc12 2005-10-29 devnull break;
97 9f1fdc12 2005-10-29 devnull case 'S':
98 9f1fdc12 2005-10-29 devnull shortmenu = 2;
99 9f1fdc12 2005-10-29 devnull break;
100 9f1fdc12 2005-10-29 devnull case 'o':
101 9f1fdc12 2005-10-29 devnull outgoing = EARGF(usage());
102 9f1fdc12 2005-10-29 devnull break;
103 9f1fdc12 2005-10-29 devnull case 'm':
104 9f1fdc12 2005-10-29 devnull smprint(maildir, "%s/", EARGF(usage()));
105 9f1fdc12 2005-10-29 devnull break;
106 9f1fdc12 2005-10-29 devnull default:
107 9f1fdc12 2005-10-29 devnull usage();
108 9f1fdc12 2005-10-29 devnull }ARGEND
109 9f1fdc12 2005-10-29 devnull
110 3f8c36d6 2006-02-09 devnull acmefs = nsmount("acme",nil);
111 3f8c36d6 2006-02-09 devnull if(acmefs == nil)
112 3f8c36d6 2006-02-09 devnull error("cannot mount acme: %r");
113 3f8c36d6 2006-02-09 devnull mailfs = nsmount("mail", nil);
114 3f8c36d6 2006-02-09 devnull if(mailfs == nil)
115 3f8c36d6 2006-02-09 devnull error("cannot mount mail: %r");
116 9f1fdc12 2005-10-29 devnull
117 00d75e0e 2006-02-11 devnull name = "mbox";
118 9f1fdc12 2005-10-29 devnull
119 9f1fdc12 2005-10-29 devnull newdir = 1;
120 9f1fdc12 2005-10-29 devnull if(argc > 0){
121 9f1fdc12 2005-10-29 devnull i = strlen(argv[0]);
122 9f1fdc12 2005-10-29 devnull if(argc>2 || i==0)
123 9f1fdc12 2005-10-29 devnull usage();
124 9f1fdc12 2005-10-29 devnull /* see if the name is that of an existing /mail/fs directory */
125 9f1fdc12 2005-10-29 devnull if(argc==1 && strchr(argv[0], '/')==0 && ismaildir(argv[0])){
126 9f1fdc12 2005-10-29 devnull name = argv[0];
127 9f1fdc12 2005-10-29 devnull mboxname = eappend(estrdup(maildir), "", name);
128 9f1fdc12 2005-10-29 devnull newdir = 0;
129 9f1fdc12 2005-10-29 devnull }else{
130 9f1fdc12 2005-10-29 devnull if(argv[0][i-1] == '/')
131 9f1fdc12 2005-10-29 devnull argv[0][i-1] = '\0';
132 9f1fdc12 2005-10-29 devnull s = strrchr(argv[0], '/');
133 9f1fdc12 2005-10-29 devnull if(s == nil)
134 9f1fdc12 2005-10-29 devnull mboxname = estrdup(argv[0]);
135 9f1fdc12 2005-10-29 devnull else{
136 9f1fdc12 2005-10-29 devnull *s++ = '\0';
137 9f1fdc12 2005-10-29 devnull if(*s == '\0')
138 9f1fdc12 2005-10-29 devnull usage();
139 9f1fdc12 2005-10-29 devnull mailboxdir = argv[0];
140 9f1fdc12 2005-10-29 devnull mboxname = estrdup(s);
141 9f1fdc12 2005-10-29 devnull }
142 9f1fdc12 2005-10-29 devnull if(argc > 1)
143 9f1fdc12 2005-10-29 devnull name = argv[1];
144 9f1fdc12 2005-10-29 devnull else
145 9f1fdc12 2005-10-29 devnull name = mboxname;
146 9f1fdc12 2005-10-29 devnull }
147 9f1fdc12 2005-10-29 devnull }
148 9f1fdc12 2005-10-29 devnull
149 9f1fdc12 2005-10-29 devnull user = getenv("user");
150 9f1fdc12 2005-10-29 devnull if(user == nil)
151 9f1fdc12 2005-10-29 devnull user = "none";
152 3f8c36d6 2006-02-09 devnull home = getenv("home");
153 3f8c36d6 2006-02-09 devnull if(home == nil)
154 3f8c36d6 2006-02-09 devnull home = getenv("HOME");
155 3f8c36d6 2006-02-09 devnull if(home == nil)
156 3f8c36d6 2006-02-09 devnull error("can't find $home");
157 9f1fdc12 2005-10-29 devnull if(mailboxdir == nil)
158 3f8c36d6 2006-02-09 devnull mailboxdir = estrstrdup(home, "/mail");
159 9f1fdc12 2005-10-29 devnull if(outgoing == nil)
160 9f1fdc12 2005-10-29 devnull outgoing = estrstrdup(mailboxdir, "/outgoing");
161 9f1fdc12 2005-10-29 devnull
162 00d75e0e 2006-02-11 devnull mbox.ctlfd = fsopen(mailfs, "mbox/ctl", OWRITE);
163 3f8c36d6 2006-02-09 devnull if(mbox.ctlfd == nil)
164 00d75e0e 2006-02-11 devnull error("can't open %s: %r", "mbox/ctl");
165 9f1fdc12 2005-10-29 devnull
166 9f1fdc12 2005-10-29 devnull fsname = estrdup(name);
167 9f1fdc12 2005-10-29 devnull if(newdir && argc > 0){
168 9f1fdc12 2005-10-29 devnull s = emalloc(5+strlen(mailboxdir)+strlen(mboxname)+strlen(name)+10+1);
169 9f1fdc12 2005-10-29 devnull for(i=0; i<10; i++){
170 9f1fdc12 2005-10-29 devnull sprint(s, "open %s/%s %s", mailboxdir, mboxname, fsname);
171 3f8c36d6 2006-02-09 devnull if(fswrite(mbox.ctlfd, s, strlen(s)) >= 0)
172 9f1fdc12 2005-10-29 devnull break;
173 9f1fdc12 2005-10-29 devnull err[0] = '\0';
174 9f1fdc12 2005-10-29 devnull errstr(err, sizeof err);
175 9f1fdc12 2005-10-29 devnull if(strstr(err, "mbox name in use") == nil)
176 3f8c36d6 2006-02-09 devnull error("can't create directory %s for mail: %s", name, err);
177 9f1fdc12 2005-10-29 devnull free(fsname);
178 9f1fdc12 2005-10-29 devnull fsname = emalloc(strlen(name)+10);
179 9f1fdc12 2005-10-29 devnull sprint(fsname, "%s-%d", name, i);
180 9f1fdc12 2005-10-29 devnull }
181 9f1fdc12 2005-10-29 devnull if(i == 10)
182 9f1fdc12 2005-10-29 devnull error("can't open %s/%s: %r", mailboxdir, mboxname);
183 9f1fdc12 2005-10-29 devnull free(s);
184 9f1fdc12 2005-10-29 devnull }
185 9f1fdc12 2005-10-29 devnull
186 9f1fdc12 2005-10-29 devnull s = estrstrdup(fsname, "/");
187 9f1fdc12 2005-10-29 devnull mbox.name = estrstrdup(maildir, s);
188 9f1fdc12 2005-10-29 devnull mbox.level= 0;
189 9f1fdc12 2005-10-29 devnull readmbox(&mbox, maildir, s);
190 9f1fdc12 2005-10-29 devnull home = getenv("home");
191 9f1fdc12 2005-10-29 devnull if(home == nil)
192 9f1fdc12 2005-10-29 devnull home = "/";
193 9f1fdc12 2005-10-29 devnull
194 9f1fdc12 2005-10-29 devnull wbox = newwindow();
195 9f1fdc12 2005-10-29 devnull winname(wbox, mbox.name);
196 9f1fdc12 2005-10-29 devnull wintagwrite(wbox, "Put Mail Delmesg ", 3+1+4+1+7+1);
197 9f1fdc12 2005-10-29 devnull threadcreate(mainctl, wbox, STACK);
198 9f1fdc12 2005-10-29 devnull
199 9f1fdc12 2005-10-29 devnull fmtstrinit(&fmt);
200 9f1fdc12 2005-10-29 devnull fmtprint(&fmt, "Mail");
201 9f1fdc12 2005-10-29 devnull if(shortmenu)
202 9f1fdc12 2005-10-29 devnull fmtprint(&fmt, " -%c", "sS"[shortmenu-1]);
203 9f1fdc12 2005-10-29 devnull if(outgoing)
204 9f1fdc12 2005-10-29 devnull fmtprint(&fmt, " -o %s", outgoing);
205 9f1fdc12 2005-10-29 devnull fmtprint(&fmt, " %s", name);
206 9f1fdc12 2005-10-29 devnull cmd = fmtstrflush(&fmt);
207 9f1fdc12 2005-10-29 devnull if(cmd == nil)
208 9f1fdc12 2005-10-29 devnull sysfatal("out of memory");
209 9f1fdc12 2005-10-29 devnull winsetdump(wbox, "/acme/mail", cmd);
210 9f1fdc12 2005-10-29 devnull mbox.w = wbox;
211 9f1fdc12 2005-10-29 devnull
212 9f1fdc12 2005-10-29 devnull mesgmenu(wbox, &mbox);
213 9f1fdc12 2005-10-29 devnull winclean(wbox);
214 9f1fdc12 2005-10-29 devnull
215 3f8c36d6 2006-02-09 devnull /* wctlfd = open("/dev/wctl", OWRITE|OCEXEC); /* for acme window */
216 3f8c36d6 2006-02-09 devnull wctlfd = -1;
217 9f1fdc12 2005-10-29 devnull cplumb = chancreate(sizeof(Plumbmsg*), 0);
218 9f1fdc12 2005-10-29 devnull cplumbshow = chancreate(sizeof(Plumbmsg*), 0);
219 00d75e0e 2006-02-11 devnull if(strcmp(name, "mbox") == 0){
220 9f1fdc12 2005-10-29 devnull /*
221 9f1fdc12 2005-10-29 devnull * Avoid creating multiple windows to send mail by only accepting
222 9f1fdc12 2005-10-29 devnull * sendmail plumb messages if we're reading the main mailbox.
223 9f1fdc12 2005-10-29 devnull */
224 00d75e0e 2006-02-11 devnull plumbsendmailfd = plumbopenfid("sendmail", OREAD|OCEXEC);
225 9f1fdc12 2005-10-29 devnull cplumbsend = chancreate(sizeof(Plumbmsg*), 0);
226 9f1fdc12 2005-10-29 devnull proccreate(plumbsendproc, nil, STACK);
227 9f1fdc12 2005-10-29 devnull threadcreate(plumbsendthread, nil, STACK);
228 9f1fdc12 2005-10-29 devnull }
229 9f1fdc12 2005-10-29 devnull /* start plumb reader as separate proc ... */
230 9f1fdc12 2005-10-29 devnull proccreate(plumbproc, nil, STACK);
231 9f1fdc12 2005-10-29 devnull proccreate(plumbshowproc, nil, STACK);
232 9f1fdc12 2005-10-29 devnull threadcreate(plumbshowthread, nil, STACK);
233 9f1fdc12 2005-10-29 devnull /* ... and use this thread to read the messages */
234 9f1fdc12 2005-10-29 devnull plumbthread();
235 9f1fdc12 2005-10-29 devnull }
236 9f1fdc12 2005-10-29 devnull
237 9f1fdc12 2005-10-29 devnull void
238 9f1fdc12 2005-10-29 devnull plumbproc(void* v)
239 9f1fdc12 2005-10-29 devnull {
240 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
241 9f1fdc12 2005-10-29 devnull
242 9f1fdc12 2005-10-29 devnull threadsetname("plumbproc");
243 9f1fdc12 2005-10-29 devnull for(;;){
244 00d75e0e 2006-02-11 devnull m = plumbrecvfid(plumbseemailfd);
245 9f1fdc12 2005-10-29 devnull sendp(cplumb, m);
246 9f1fdc12 2005-10-29 devnull if(m == nil)
247 9f1fdc12 2005-10-29 devnull threadexits(nil);
248 9f1fdc12 2005-10-29 devnull }
249 9f1fdc12 2005-10-29 devnull }
250 9f1fdc12 2005-10-29 devnull
251 9f1fdc12 2005-10-29 devnull void
252 9f1fdc12 2005-10-29 devnull plumbshowproc(void* v)
253 9f1fdc12 2005-10-29 devnull {
254 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
255 9f1fdc12 2005-10-29 devnull
256 9f1fdc12 2005-10-29 devnull threadsetname("plumbshowproc");
257 9f1fdc12 2005-10-29 devnull for(;;){
258 00d75e0e 2006-02-11 devnull m = plumbrecvfid(plumbshowmailfd);
259 9f1fdc12 2005-10-29 devnull sendp(cplumbshow, m);
260 9f1fdc12 2005-10-29 devnull if(m == nil)
261 9f1fdc12 2005-10-29 devnull threadexits(nil);
262 9f1fdc12 2005-10-29 devnull }
263 9f1fdc12 2005-10-29 devnull }
264 9f1fdc12 2005-10-29 devnull
265 9f1fdc12 2005-10-29 devnull void
266 9f1fdc12 2005-10-29 devnull plumbsendproc(void* v)
267 9f1fdc12 2005-10-29 devnull {
268 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
269 9f1fdc12 2005-10-29 devnull
270 9f1fdc12 2005-10-29 devnull threadsetname("plumbsendproc");
271 9f1fdc12 2005-10-29 devnull for(;;){
272 00d75e0e 2006-02-11 devnull m = plumbrecvfid(plumbsendmailfd);
273 9f1fdc12 2005-10-29 devnull sendp(cplumbsend, m);
274 9f1fdc12 2005-10-29 devnull if(m == nil)
275 9f1fdc12 2005-10-29 devnull threadexits(nil);
276 9f1fdc12 2005-10-29 devnull }
277 9f1fdc12 2005-10-29 devnull }
278 9f1fdc12 2005-10-29 devnull
279 9f1fdc12 2005-10-29 devnull void
280 9f1fdc12 2005-10-29 devnull newmesg(char *name, char *digest)
281 9f1fdc12 2005-10-29 devnull {
282 9f1fdc12 2005-10-29 devnull Dir *d;
283 9f1fdc12 2005-10-29 devnull
284 3f8c36d6 2006-02-09 devnull if(strncmp(name, mbox.name, strlen(mbox.name)) != 0)
285 9f1fdc12 2005-10-29 devnull return; /* message is about another mailbox */
286 3f8c36d6 2006-02-09 devnull if(mesglookupfile(&mbox, name, digest) != nil)
287 9f1fdc12 2005-10-29 devnull return;
288 00d75e0e 2006-02-11 devnull if(strncmp(name, "Mail/", 5) == 0)
289 00d75e0e 2006-02-11 devnull name += 5;
290 3f8c36d6 2006-02-09 devnull d = fsdirstat(mailfs, name);
291 3f8c36d6 2006-02-09 devnull if(d == nil)
292 9f1fdc12 2005-10-29 devnull return;
293 3f8c36d6 2006-02-09 devnull if(mesgadd(&mbox, mbox.name, d, digest))
294 9f1fdc12 2005-10-29 devnull mesgmenunew(wbox, &mbox);
295 9f1fdc12 2005-10-29 devnull free(d);
296 9f1fdc12 2005-10-29 devnull }
297 9f1fdc12 2005-10-29 devnull
298 9f1fdc12 2005-10-29 devnull void
299 9f1fdc12 2005-10-29 devnull showmesg(char *name, char *digest)
300 9f1fdc12 2005-10-29 devnull {
301 9f1fdc12 2005-10-29 devnull char *n;
302 3f8c36d6 2006-02-09 devnull char *mb;
303 00d75e0e 2006-02-11 devnull
304 3f8c36d6 2006-02-09 devnull mb = mbox.name;
305 3f8c36d6 2006-02-09 devnull if(strncmp(name, mb, strlen(mb)) != 0)
306 9f1fdc12 2005-10-29 devnull return; /* message is about another mailbox */
307 3f8c36d6 2006-02-09 devnull n = estrdup(name+strlen(mb));
308 9f1fdc12 2005-10-29 devnull if(n[strlen(n)-1] != '/')
309 9f1fdc12 2005-10-29 devnull n = egrow(n, "/", nil);
310 3f8c36d6 2006-02-09 devnull mesgopen(&mbox, mbox.name, name+strlen(mb), nil, 1, digest);
311 9f1fdc12 2005-10-29 devnull free(n);
312 9f1fdc12 2005-10-29 devnull }
313 9f1fdc12 2005-10-29 devnull
314 9f1fdc12 2005-10-29 devnull void
315 9f1fdc12 2005-10-29 devnull delmesg(char *name, char *digest, int dodel)
316 9f1fdc12 2005-10-29 devnull {
317 9f1fdc12 2005-10-29 devnull Message *m;
318 9f1fdc12 2005-10-29 devnull
319 9f1fdc12 2005-10-29 devnull m = mesglookupfile(&mbox, name, digest);
320 9f1fdc12 2005-10-29 devnull if(m != nil){
321 9f1fdc12 2005-10-29 devnull mesgmenumarkdel(wbox, &mbox, m, 0);
322 9f1fdc12 2005-10-29 devnull if(dodel)
323 9f1fdc12 2005-10-29 devnull m->writebackdel = 1;
324 9f1fdc12 2005-10-29 devnull }
325 9f1fdc12 2005-10-29 devnull }
326 9f1fdc12 2005-10-29 devnull
327 9f1fdc12 2005-10-29 devnull void
328 9f1fdc12 2005-10-29 devnull plumbthread(void)
329 9f1fdc12 2005-10-29 devnull {
330 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
331 9f1fdc12 2005-10-29 devnull Plumbattr *a;
332 9f1fdc12 2005-10-29 devnull char *type, *digest;
333 9f1fdc12 2005-10-29 devnull
334 9f1fdc12 2005-10-29 devnull threadsetname("plumbthread");
335 9f1fdc12 2005-10-29 devnull while((m = recvp(cplumb)) != nil){
336 9f1fdc12 2005-10-29 devnull a = m->attr;
337 9f1fdc12 2005-10-29 devnull digest = plumblookup(a, "digest");
338 9f1fdc12 2005-10-29 devnull type = plumblookup(a, "mailtype");
339 9f1fdc12 2005-10-29 devnull if(type == nil)
340 9f1fdc12 2005-10-29 devnull fprint(2, "Mail: plumb message with no mailtype attribute\n");
341 9f1fdc12 2005-10-29 devnull else if(strcmp(type, "new") == 0)
342 9f1fdc12 2005-10-29 devnull newmesg(m->data, digest);
343 9f1fdc12 2005-10-29 devnull else if(strcmp(type, "delete") == 0)
344 9f1fdc12 2005-10-29 devnull delmesg(m->data, digest, 0);
345 9f1fdc12 2005-10-29 devnull else
346 9f1fdc12 2005-10-29 devnull fprint(2, "Mail: unknown plumb attribute %s\n", type);
347 9f1fdc12 2005-10-29 devnull plumbfree(m);
348 9f1fdc12 2005-10-29 devnull }
349 9f1fdc12 2005-10-29 devnull threadexits(nil);
350 9f1fdc12 2005-10-29 devnull }
351 9f1fdc12 2005-10-29 devnull
352 9f1fdc12 2005-10-29 devnull void
353 3f8c36d6 2006-02-09 devnull plumbshowthread(void *v)
354 9f1fdc12 2005-10-29 devnull {
355 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
356 9f1fdc12 2005-10-29 devnull
357 3f8c36d6 2006-02-09 devnull USED(v);
358 9f1fdc12 2005-10-29 devnull threadsetname("plumbshowthread");
359 9f1fdc12 2005-10-29 devnull while((m = recvp(cplumbshow)) != nil){
360 9f1fdc12 2005-10-29 devnull showmesg(m->data, plumblookup(m->attr, "digest"));
361 9f1fdc12 2005-10-29 devnull plumbfree(m);
362 9f1fdc12 2005-10-29 devnull }
363 9f1fdc12 2005-10-29 devnull threadexits(nil);
364 9f1fdc12 2005-10-29 devnull }
365 9f1fdc12 2005-10-29 devnull
366 9f1fdc12 2005-10-29 devnull void
367 3f8c36d6 2006-02-09 devnull plumbsendthread(void *v)
368 9f1fdc12 2005-10-29 devnull {
369 9f1fdc12 2005-10-29 devnull Plumbmsg *m;
370 9f1fdc12 2005-10-29 devnull
371 3f8c36d6 2006-02-09 devnull USED(v);
372 9f1fdc12 2005-10-29 devnull threadsetname("plumbsendthread");
373 9f1fdc12 2005-10-29 devnull while((m = recvp(cplumbsend)) != nil){
374 9f1fdc12 2005-10-29 devnull mkreply(nil, "Mail", m->data, m->attr, nil);
375 9f1fdc12 2005-10-29 devnull plumbfree(m);
376 9f1fdc12 2005-10-29 devnull }
377 9f1fdc12 2005-10-29 devnull threadexits(nil);
378 9f1fdc12 2005-10-29 devnull }
379 9f1fdc12 2005-10-29 devnull
380 9f1fdc12 2005-10-29 devnull int
381 9f1fdc12 2005-10-29 devnull mboxcommand(Window *w, char *s)
382 9f1fdc12 2005-10-29 devnull {
383 9f1fdc12 2005-10-29 devnull char *args[10], **targs;
384 9f1fdc12 2005-10-29 devnull Message *m, *next;
385 9f1fdc12 2005-10-29 devnull int ok, nargs, i, j;
386 9f1fdc12 2005-10-29 devnull char buf[128];
387 9f1fdc12 2005-10-29 devnull
388 9f1fdc12 2005-10-29 devnull nargs = tokenize(s, args, nelem(args));
389 9f1fdc12 2005-10-29 devnull if(nargs == 0)
390 9f1fdc12 2005-10-29 devnull return 0;
391 9f1fdc12 2005-10-29 devnull if(strcmp(args[0], "Mail") == 0){
392 9f1fdc12 2005-10-29 devnull if(nargs == 1)
393 9f1fdc12 2005-10-29 devnull mkreply(nil, "Mail", "", nil, nil);
394 9f1fdc12 2005-10-29 devnull else
395 9f1fdc12 2005-10-29 devnull mkreply(nil, "Mail", args[1], nil, nil);
396 9f1fdc12 2005-10-29 devnull return 1;
397 9f1fdc12 2005-10-29 devnull }
398 9f1fdc12 2005-10-29 devnull if(strcmp(s, "Del") == 0){
399 9f1fdc12 2005-10-29 devnull if(mbox.dirty){
400 9f1fdc12 2005-10-29 devnull mbox.dirty = 0;
401 9f1fdc12 2005-10-29 devnull fprint(2, "mail: mailbox not written\n");
402 9f1fdc12 2005-10-29 devnull return 1;
403 9f1fdc12 2005-10-29 devnull }
404 9f1fdc12 2005-10-29 devnull ok = 1;
405 9f1fdc12 2005-10-29 devnull for(m=mbox.head; m!=nil; m=next){
406 9f1fdc12 2005-10-29 devnull next = m->next;
407 9f1fdc12 2005-10-29 devnull if(m->w){
408 9f1fdc12 2005-10-29 devnull if(windel(m->w, 0))
409 9f1fdc12 2005-10-29 devnull m->w = nil;
410 9f1fdc12 2005-10-29 devnull else
411 9f1fdc12 2005-10-29 devnull ok = 0;
412 9f1fdc12 2005-10-29 devnull }
413 9f1fdc12 2005-10-29 devnull }
414 9f1fdc12 2005-10-29 devnull for(m=replies.head; m!=nil; m=next){
415 9f1fdc12 2005-10-29 devnull next = m->next;
416 9f1fdc12 2005-10-29 devnull if(m->w){
417 9f1fdc12 2005-10-29 devnull if(windel(m->w, 0))
418 9f1fdc12 2005-10-29 devnull m->w = nil;
419 9f1fdc12 2005-10-29 devnull else
420 9f1fdc12 2005-10-29 devnull ok = 0;
421 9f1fdc12 2005-10-29 devnull }
422 9f1fdc12 2005-10-29 devnull }
423 9f1fdc12 2005-10-29 devnull if(ok){
424 9f1fdc12 2005-10-29 devnull windel(w, 1);
425 9f1fdc12 2005-10-29 devnull removeupasfs();
426 9f1fdc12 2005-10-29 devnull threadexitsall(nil);
427 9f1fdc12 2005-10-29 devnull }
428 9f1fdc12 2005-10-29 devnull return 1;
429 9f1fdc12 2005-10-29 devnull }
430 9f1fdc12 2005-10-29 devnull if(strcmp(s, "Put") == 0){
431 9f1fdc12 2005-10-29 devnull rewritembox(wbox, &mbox);
432 9f1fdc12 2005-10-29 devnull return 1;
433 9f1fdc12 2005-10-29 devnull }
434 9f1fdc12 2005-10-29 devnull if(strcmp(s, "Delmesg") == 0){
435 9f1fdc12 2005-10-29 devnull if(nargs > 1){
436 9f1fdc12 2005-10-29 devnull for(i=1; i<nargs; i++){
437 9f1fdc12 2005-10-29 devnull snprint(buf, sizeof buf, "%s%s", mbox.name, args[i]);
438 9f1fdc12 2005-10-29 devnull delmesg(buf, nil, 1);
439 9f1fdc12 2005-10-29 devnull }
440 9f1fdc12 2005-10-29 devnull }
441 9f1fdc12 2005-10-29 devnull s = winselection(w);
442 9f1fdc12 2005-10-29 devnull if(s == nil)
443 9f1fdc12 2005-10-29 devnull return 1;
444 9f1fdc12 2005-10-29 devnull nargs = 1;
445 9f1fdc12 2005-10-29 devnull for(i=0; s[i]; i++)
446 9f1fdc12 2005-10-29 devnull if(s[i] == '\n')
447 9f1fdc12 2005-10-29 devnull nargs++;
448 9f1fdc12 2005-10-29 devnull targs = emalloc(nargs*sizeof(char*)); /* could be too many for a local array */
449 9f1fdc12 2005-10-29 devnull nargs = getfields(s, targs, nargs, 1, "\n");
450 9f1fdc12 2005-10-29 devnull for(i=0; i<nargs; i++){
451 9f1fdc12 2005-10-29 devnull if(!isdigit(targs[i][0]))
452 9f1fdc12 2005-10-29 devnull continue;
453 9f1fdc12 2005-10-29 devnull j = atoi(targs[i]); /* easy way to parse the number! */
454 9f1fdc12 2005-10-29 devnull if(j == 0)
455 9f1fdc12 2005-10-29 devnull continue;
456 9f1fdc12 2005-10-29 devnull snprint(buf, sizeof buf, "%s%d", mbox.name, j);
457 9f1fdc12 2005-10-29 devnull delmesg(buf, nil, 1);
458 9f1fdc12 2005-10-29 devnull }
459 9f1fdc12 2005-10-29 devnull free(s);
460 9f1fdc12 2005-10-29 devnull free(targs);
461 9f1fdc12 2005-10-29 devnull return 1;
462 9f1fdc12 2005-10-29 devnull }
463 9f1fdc12 2005-10-29 devnull return 0;
464 9f1fdc12 2005-10-29 devnull }
465 9f1fdc12 2005-10-29 devnull
466 9f1fdc12 2005-10-29 devnull void
467 9f1fdc12 2005-10-29 devnull mainctl(void *v)
468 9f1fdc12 2005-10-29 devnull {
469 9f1fdc12 2005-10-29 devnull Window *w;
470 9f1fdc12 2005-10-29 devnull Event *e, *e2, *eq, *ea;
471 9f1fdc12 2005-10-29 devnull int na, nopen;
472 9f1fdc12 2005-10-29 devnull char *s, *t, *buf;
473 9f1fdc12 2005-10-29 devnull
474 9f1fdc12 2005-10-29 devnull w = v;
475 9f1fdc12 2005-10-29 devnull proccreate(wineventproc, w, STACK);
476 9f1fdc12 2005-10-29 devnull
477 9f1fdc12 2005-10-29 devnull for(;;){
478 9f1fdc12 2005-10-29 devnull e = recvp(w->cevent);
479 9f1fdc12 2005-10-29 devnull switch(e->c1){
480 9f1fdc12 2005-10-29 devnull default:
481 9f1fdc12 2005-10-29 devnull Unknown:
482 9f1fdc12 2005-10-29 devnull print("unknown message %c%c\n", e->c1, e->c2);
483 9f1fdc12 2005-10-29 devnull break;
484 9f1fdc12 2005-10-29 devnull
485 9f1fdc12 2005-10-29 devnull case 'E': /* write to body; can't affect us */
486 9f1fdc12 2005-10-29 devnull break;
487 9f1fdc12 2005-10-29 devnull
488 9f1fdc12 2005-10-29 devnull case 'F': /* generated by our actions; ignore */
489 9f1fdc12 2005-10-29 devnull break;
490 9f1fdc12 2005-10-29 devnull
491 9f1fdc12 2005-10-29 devnull case 'K': /* type away; we don't care */
492 9f1fdc12 2005-10-29 devnull break;
493 9f1fdc12 2005-10-29 devnull
494 9f1fdc12 2005-10-29 devnull case 'M':
495 9f1fdc12 2005-10-29 devnull switch(e->c2){
496 9f1fdc12 2005-10-29 devnull case 'x':
497 9f1fdc12 2005-10-29 devnull case 'X':
498 9f1fdc12 2005-10-29 devnull ea = nil;
499 9f1fdc12 2005-10-29 devnull e2 = nil;
500 9f1fdc12 2005-10-29 devnull if(e->flag & 2)
501 9f1fdc12 2005-10-29 devnull e2 = recvp(w->cevent);
502 9f1fdc12 2005-10-29 devnull if(e->flag & 8){
503 9f1fdc12 2005-10-29 devnull ea = recvp(w->cevent);
504 9f1fdc12 2005-10-29 devnull na = ea->nb;
505 9f1fdc12 2005-10-29 devnull recvp(w->cevent);
506 9f1fdc12 2005-10-29 devnull }else
507 9f1fdc12 2005-10-29 devnull na = 0;
508 9f1fdc12 2005-10-29 devnull s = e->b;
509 9f1fdc12 2005-10-29 devnull /* if it's a known command, do it */
510 9f1fdc12 2005-10-29 devnull if((e->flag&2) && e->nb==0)
511 9f1fdc12 2005-10-29 devnull s = e2->b;
512 9f1fdc12 2005-10-29 devnull if(na){
513 9f1fdc12 2005-10-29 devnull t = emalloc(strlen(s)+1+na+1);
514 9f1fdc12 2005-10-29 devnull sprint(t, "%s %s", s, ea->b);
515 9f1fdc12 2005-10-29 devnull s = t;
516 9f1fdc12 2005-10-29 devnull }
517 9f1fdc12 2005-10-29 devnull /* if it's a long message, it can't be for us anyway */
518 9f1fdc12 2005-10-29 devnull if(!mboxcommand(w, s)) /* send it back */
519 9f1fdc12 2005-10-29 devnull winwriteevent(w, e);
520 9f1fdc12 2005-10-29 devnull if(na)
521 9f1fdc12 2005-10-29 devnull free(s);
522 9f1fdc12 2005-10-29 devnull break;
523 9f1fdc12 2005-10-29 devnull
524 9f1fdc12 2005-10-29 devnull case 'l':
525 9f1fdc12 2005-10-29 devnull case 'L':
526 9f1fdc12 2005-10-29 devnull buf = nil;
527 9f1fdc12 2005-10-29 devnull eq = e;
528 9f1fdc12 2005-10-29 devnull if(e->flag & 2){
529 9f1fdc12 2005-10-29 devnull e2 = recvp(w->cevent);
530 9f1fdc12 2005-10-29 devnull eq = e2;
531 9f1fdc12 2005-10-29 devnull }
532 9f1fdc12 2005-10-29 devnull s = eq->b;
533 9f1fdc12 2005-10-29 devnull if(eq->q1>eq->q0 && eq->nb==0){
534 9f1fdc12 2005-10-29 devnull buf = emalloc((eq->q1-eq->q0)*UTFmax+1);
535 9f1fdc12 2005-10-29 devnull winread(w, eq->q0, eq->q1, buf);
536 9f1fdc12 2005-10-29 devnull s = buf;
537 9f1fdc12 2005-10-29 devnull }
538 9f1fdc12 2005-10-29 devnull nopen = 0;
539 9f1fdc12 2005-10-29 devnull do{
540 9f1fdc12 2005-10-29 devnull /* skip 'deleted' string if present' */
541 9f1fdc12 2005-10-29 devnull if(strncmp(s, deleted, strlen(deleted)) == 0)
542 9f1fdc12 2005-10-29 devnull s += strlen(deleted);
543 9f1fdc12 2005-10-29 devnull /* skip mail box name if present */
544 9f1fdc12 2005-10-29 devnull if(strncmp(s, mbox.name, strlen(mbox.name)) == 0)
545 9f1fdc12 2005-10-29 devnull s += strlen(mbox.name);
546 9f1fdc12 2005-10-29 devnull nopen += mesgopen(&mbox, mbox.name, s, nil, 0, nil);
547 9f1fdc12 2005-10-29 devnull while(*s!='\0' && *s++!='\n')
548 9f1fdc12 2005-10-29 devnull ;
549 9f1fdc12 2005-10-29 devnull }while(*s);
550 9f1fdc12 2005-10-29 devnull if(nopen == 0) /* send it back */
551 9f1fdc12 2005-10-29 devnull winwriteevent(w, e);
552 9f1fdc12 2005-10-29 devnull free(buf);
553 9f1fdc12 2005-10-29 devnull break;
554 9f1fdc12 2005-10-29 devnull
555 9f1fdc12 2005-10-29 devnull case 'I': /* modify away; we don't care */
556 9f1fdc12 2005-10-29 devnull case 'D':
557 9f1fdc12 2005-10-29 devnull case 'd':
558 9f1fdc12 2005-10-29 devnull case 'i':
559 9f1fdc12 2005-10-29 devnull break;
560 9f1fdc12 2005-10-29 devnull
561 9f1fdc12 2005-10-29 devnull default:
562 9f1fdc12 2005-10-29 devnull goto Unknown;
563 9f1fdc12 2005-10-29 devnull }
564 9f1fdc12 2005-10-29 devnull }
565 9f1fdc12 2005-10-29 devnull }
566 9f1fdc12 2005-10-29 devnull }
567 9f1fdc12 2005-10-29 devnull