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