eebb88da63b204255d3ec67df9229d7fd5523452
[mmh] / refile.c
1 /* refile.c - file messages away */
2 #ifndef lint
3 static char ident[] = "@(#)$Id: refile.c,v 1.10 1992/12/15 00:20:22 jromine Exp $";
4 #endif  /* lint */
5
6 #include "../h/mh.h"
7 #include <errno.h>
8 #include <stdio.h>
9 #include <sys/types.h>
10 #include <sys/stat.h>
11 #ifdef LOCALE
12 #include        <locale.h>
13 #endif
14
15 /* \f */
16
17 static struct swit switches[] = {
18 #define DRAFTSW 0
19     "draft", 0,
20
21 #define LINKSW  1
22     "link", 0,
23 #define NLINKSW 2
24     "nolink", 0,
25
26 #define PRESSW  3
27     "preserve", 0,
28 #define NPRESSW 4
29     "nopreserve", 0,
30
31 #define SRCSW   5
32     "src +folder", 0,
33
34 #define FILESW  6
35     "file file", 0,
36
37 #define RPROCSW 7
38     "rmmproc program", 0,
39 #define NRPRCSW 8
40     "normmproc", 0,
41
42 #define HELPSW  9
43     "help", 4,
44
45     NULL, 0
46 };
47
48 /* \f */
49
50 extern int  errno;
51
52
53 static char maildir[BUFSIZ];
54
55
56 struct st_fold {
57     char   *f_name;
58     struct msgs *f_mp;
59 };
60
61 static opnfolds(), clsfolds(), removeit();
62 /* \f */
63
64 /* ARGSUSED */
65
66 main (argc, argv)
67 int     argc;
68 char  **argv;
69 {
70     int     linkf = 0,
71             prsrvf = 0,
72             filep = 0,
73             foldp = 0,
74             msgp = 0,
75             isdf = 0,
76             i,
77             msgnum;
78     char   *cp,
79            *folder = NULL,
80             buf[100],
81           **ap,
82           **argp,
83            *arguments[MAXARGS],
84            *filevec[NFOLDERS + 2],
85           **files = &filevec[1],        /* leave room for removeit:vec[0] */
86            *msgs[MAXARGS];
87     struct st_fold   folders[NFOLDERS + 1];
88     struct msgs *mp;
89
90 #ifdef LOCALE
91         setlocale(LC_ALL, "");
92 #endif
93     invo_name = r1bindex (argv[0], '/');
94     if ((cp = m_find (invo_name)) != NULL) {
95         ap = brkstring (cp = getcpy (cp), " ", "\n");
96         ap = copyip (ap, arguments);
97     }
98     else
99         ap = arguments;
100     (void) copyip (argv + 1, ap);
101     argp = arguments;
102
103 /* \f */
104
105     while (cp = *argp++) {
106         if (*cp == '-')
107             switch (smatch (++cp, switches)) {
108                 case AMBIGSW: 
109                     ambigsw (cp, switches);
110                     done (1);
111                 case UNKWNSW: 
112                     adios (NULLCP, "-%s unknown\n", cp);
113                 case HELPSW: 
114                     (void) sprintf (buf, "%s [msgs] [switches] +folder ...",
115                             invo_name);
116                     help (buf, switches);
117                     done (1);
118
119                 case LINKSW: 
120                     linkf++;
121                     continue;
122                 case NLINKSW: 
123                     linkf = 0;
124                     continue;
125
126                 case PRESSW: 
127                     prsrvf++;
128                     continue;
129                 case NPRESSW: 
130                     prsrvf = 0;
131                     continue;
132
133                 case SRCSW: 
134                     if (folder)
135                         adios (NULLCP, "only one source folder at a time!");
136                     if (!(cp = *argp++) || *cp == '-')
137                         adios (NULLCP, "missing argument to %s", argp[-2]);
138                     folder = path (*cp == '+' || *cp == '@' ? cp + 1 : cp,
139                                    *cp != '@' ? TFOLDER : TSUBCWF);
140                     continue;
141                 case DRAFTSW:
142                     if (filep > NFOLDERS)
143                         adios (NULLCP, "only %d files allowed!", NFOLDERS);
144                     isdf = 0;
145                     files[filep++] = getcpy (m_draft (NULLCP, NULLCP, 1, &isdf));
146                     continue;
147                 case FILESW: 
148                     if (filep > NFOLDERS)
149                         adios (NULLCP, "only %d files allowed!", NFOLDERS);
150                     if (!(cp = *argp++) || *cp == '-')
151                         adios (NULLCP, "missing argument to %s", argp[-2]);
152                     files[filep++] = path (cp, TFILE);
153                     continue;
154
155                 case RPROCSW: 
156                     if (!(rmmproc = *argp++) || *rmmproc == '-')
157                         adios (NULLCP, "missing argument to %s", argp[-2]);
158                     continue;
159                 case NRPRCSW: 
160                     rmmproc = (char *)0;
161                     continue;
162             }
163         if (*cp == '+' || *cp == '@') {
164             if (foldp > NFOLDERS)
165                 adios (NULLCP, "only %d folders allowed!", NFOLDERS);
166             folders[foldp++].f_name =
167                     path (cp + 1, *cp == '+' ? TFOLDER : TSUBCWF);
168         }
169         else
170             msgs[msgp++] = cp;
171     }
172
173 /* \f */
174
175     if (!m_find ("path"))
176         free (path ("./", TFOLDER));
177     if (foldp == 0)
178         adios (NULLCP, "no folder specified");
179
180 #ifdef  WHATNOW
181     if (!msgp && !foldp && !filep && (cp = getenv ("mhdraft")) && *cp)
182         files[filep++] = cp;
183 #endif  /* WHATNOW */
184
185     if (filep > 0) {
186         if (folder || msgp)
187             adios (NULLCP, "use -file or some messages, not both");
188         opnfolds (folders, foldp);
189         for (i = 0; i < filep; i++)
190             if (m_file (files[i], folders, foldp, prsrvf))
191                 done (1);
192         if (!linkf)
193             removeit (NULLMP, filep, filevec);
194         done (0);
195     }
196
197     if (!msgp)
198         msgs[msgp++] = "cur";
199     if (!folder)
200         folder = m_getfolder ();
201     (void) strcpy (maildir, m_maildir (folder));
202
203     if (chdir (maildir) == NOTOK)
204         adios (maildir, "unable to change directory to");
205     if (!(mp = m_gmsg (folder)))
206         adios (NULLCP, "unable to read folder %s", folder);
207     if (mp -> hghmsg == 0)
208         adios (NULLCP, "no messages in %s", folder);
209
210     for (msgnum = 0; msgnum < msgp; msgnum++)
211         if (!m_convert (mp, msgs[msgnum]))
212             done (1);
213     m_setseq (mp);
214
215     opnfolds (folders, foldp);
216     for (msgnum = mp -> lowsel; msgnum <= mp -> hghsel; msgnum++)
217         if (mp -> msgstats[msgnum] & SELECTED) {
218             cp = getcpy (m_name (msgnum));
219             if (m_file (cp, folders, foldp, prsrvf))
220                 done (1);
221             free (cp);
222             if (!linkf) {
223 #ifdef  notdef
224                 mp -> msgstats[msgnum] |= DELETED;
225 #endif  /* notdef */
226                 mp -> msgstats[msgnum] &= ~EXISTS;
227             }
228         }
229     if (!linkf)
230         mp -> msgflags |= SEQMOD;
231     clsfolds (folders, foldp);
232
233     m_replace (pfolder, folder);
234     if (mp -> hghsel != mp -> curmsg
235             && (mp -> numsel != mp -> nummsg || linkf))
236         m_setcur (mp, mp -> hghsel);
237     m_sync (mp);
238     m_update ();
239
240     if (!linkf)
241         removeit (mp, filep, filevec);
242
243     done (0);
244 }
245
246 /* \f */
247
248 static  opnfolds (folders, nfolders)
249 register struct st_fold *folders;
250 int     nfolders;
251 {
252     register char  *cp;
253     char    nmaildir[BUFSIZ];
254     register struct st_fold *fp,
255                             *ep;
256     register struct msgs   *mp;
257     struct stat st;
258
259     for (ep = (fp = folders) + nfolders; fp < ep; fp++) {
260         (void) chdir (m_maildir (""));
261         (void) strcpy (nmaildir, m_maildir (fp -> f_name));
262
263         if (stat (nmaildir, &st) == NOTOK) {
264             if (errno != ENOENT)
265                 adios (nmaildir, "error on folder");
266             cp = concat ("Create folder \"", nmaildir, "\"? ", NULLCP);
267             if (!getanswer (cp))
268                 done (1);
269             free (cp);
270             if (!makedir (nmaildir))
271                 adios (NULLCP, "unable to create folder %s", nmaildir);
272         }
273
274         if (chdir (nmaildir) == NOTOK)
275             adios (nmaildir, "unable to change directory to");
276         if (!(mp = m_gmsg (fp -> f_name)))
277             adios (NULLCP, "unable to read folder %s", fp -> f_name);
278         mp -> curmsg = 0;
279
280         fp -> f_mp = mp;
281
282         (void) chdir (maildir);
283     }
284 }
285
286 /* \f */
287
288 static  clsfolds (folders, nfolders)
289 register struct st_fold *folders;
290 int     nfolders;
291 {
292     register struct st_fold *fp,
293                            *ep;
294     register struct msgs   *mp;
295
296     for (ep = (fp = folders) + nfolders; fp < ep; fp++) {
297         mp = fp -> f_mp;
298         m_setseq (mp);
299         m_sync (mp);
300     }
301 }
302
303 /* \f */
304
305 static  removeit (mp, filep, files)
306 register struct msgs *mp;
307 register int filep;
308 register char **files;
309 {
310     register int    i,
311                     vecp;
312     register char  *cp,
313                   **vec;
314
315     if (rmmproc) {
316         if (filep > 0) {
317             vec = files++;      /* filevec[1] */
318             files[filep] = NULL;
319         }
320         else {
321             if (mp -> numsel > MAXARGS - 2)
322                 adios (NULLCP, "more than %d messages for %s exec",
323                         MAXARGS - 2, rmmproc);
324             vec = (char **) calloc ((unsigned) (mp -> numsel + 2), sizeof *vec);
325             if (vec == NULL)
326                 adios (NULLCP, "unable to allocate exec vector");
327             vecp = 1;
328             for (i = mp -> lowsel; i <= mp -> hghsel; i++)
329                 if (mp -> msgstats[i] & SELECTED)
330                     vec[vecp++] = getcpy (m_name (i));
331             vec[vecp] = NULL;
332         }
333
334         (void) fflush (stdout);
335         vec[0] = r1bindex (rmmproc, '/');
336         execvp (rmmproc, vec);
337         adios (rmmproc, "unable to exec");
338     }
339
340     if (filep > 0) {
341         files++;        /* filevec[1] */
342         for (i = 0; i < filep; i++)
343             if (unlink (files[i]) == NOTOK)
344                 admonish (files[i], "unable to unlink");
345     }
346     else
347         for (i = mp -> lowsel; i <= mp -> hghsel; i++)
348             if (mp -> msgstats[i] & SELECTED)
349                 if (unlink (cp = m_name (i)) == NOTOK)
350                     admonish (cp, "unable to unlink");
351 }
352
353 /* \f */
354
355 m_file (msg, folders, nfolders, prsrvf)
356 register char  *msg;
357 struct st_fold  *folders;
358 int     nfolders,
359         prsrvf;
360 {
361     int     in,
362             out,
363             linkerr,
364             msgnum;
365     register char  *nmsg;
366     char    newmsg[BUFSIZ];
367     register struct st_fold *fp,
368                             *ep;
369     register struct msgs *mp;
370     struct stat st,
371                 s1;
372
373     for (ep = (fp = folders) + nfolders; fp < ep; fp++) {
374         mp = fp -> f_mp;
375         if (prsrvf && (msgnum = m_atoi (nmsg = msg)) > 0) {
376             if (msgnum >= mp -> hghoff)
377                 if (mp = m_remsg (mp, 0, msgnum + MAXFOLDER))
378                     fp -> f_mp = mp;
379                 else
380                     adios (NULLCP, "unable to allocate folder storage");
381             if (!(mp -> msgstats[msgnum] & EXISTS)) {
382                 mp -> msgstats[msgnum] |= EXISTS;
383 #ifdef  notdef
384                 mp -> msgstats[msgnum] &= ~DELETED;
385 #endif  /* notdef */
386                 mp -> nummsg++;
387             }
388             mp -> msgstats[msgnum] |= SELECTED;             
389             if (msgnum > mp -> hghmsg)
390                 mp -> hghmsg = msgnum;
391         }
392         else {
393             if (mp -> hghmsg >= mp -> hghoff)
394                 if (mp = m_remsg (mp, 0, mp -> hghoff + MAXFOLDER))
395                     fp -> f_mp = mp;
396                 else
397                     adios (NULLCP, "unable to allocate folder storage");
398
399             nmsg = m_name (msgnum = ++mp -> hghmsg);
400             mp -> nummsg++;
401             mp -> msgstats[msgnum] |= EXISTS | SELECTED;
402         }
403         if (mp -> lowmsg == 0)
404             mp -> lowmsg = msgnum;
405         if (mp -> lowsel == 0 || msgnum < mp -> lowsel)
406             mp -> lowsel = msgnum;
407         if (msgnum > mp -> hghsel)
408             mp -> hghsel = msgnum;
409
410 /* \f */
411
412         (void) sprintf (newmsg, "%s/%s", mp -> foldpath, nmsg);
413         if (link (msg, newmsg) == NOTOK) {
414 #ifndef EISREMOTE
415             linkerr = errno;
416 #else   /* EISREMOTE */
417             if ((linkerr = errno) == EISREMOTE)
418                 linkerr = EXDEV;
419 #endif  /* EISREMOTE */
420             if (linkerr == EEXIST
421                     || (linkerr == EXDEV && stat (newmsg, &st) != NOTOK)) {
422                 if (linkerr != EEXIST
423                         || stat (msg, &s1) == NOTOK
424                         || stat (newmsg, &st) == NOTOK
425                         || s1.st_ino != st.st_ino) {
426                     advise (NULLCP, "message %s:%s already exists",
427                             fp -> f_name, newmsg);
428                     return 1;
429                 }
430                 continue;
431             }
432             if (linkerr == EXDEV) {
433                 if ((in = open (msg, 0)) == NOTOK) {
434                     advise (msg, "unable to open message %s");
435                     return 1;
436                 }
437                 (void) fstat (in, &st);
438                 if ((out = creat (newmsg, (int) st.st_mode & 0777))
439                         == NOTOK) {
440                     advise (newmsg, "unable to create");
441                     (void) close (in);
442                     return 1;
443                 }
444                 cpydata (in, out, msg, newmsg);
445                 (void) close (in);
446                 (void) close (out);
447             }
448             else {
449                 advise (newmsg, "error linking %s to", msg);
450                 return 1;
451             }
452         }
453     }
454
455     return 0;
456 }