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