![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to burst.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 burst.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / mh / uip |
1.1 ! root 1: /* burst.c - explode digests into individual messages */ ! 2: ! 3: #include "../h/mh.h" ! 4: #include <stdio.h> ! 5: #include <sys/types.h> ! 6: #include <sys/stat.h> ! 7: ! 8: static void burst(), cpybrst(); ! 9: ! 10: /* */ ! 11: ! 12: static struct swit switches[] = { ! 13: #define INPLSW 0 ! 14: "inplace", 0, ! 15: #define NINPLSW 1 ! 16: "noinplace", 0, ! 17: ! 18: #define QIETSW 2 ! 19: "quiet", 0, ! 20: #define NQIETSW 3 ! 21: "noquiet", 0, ! 22: ! 23: #define VERBSW 4 ! 24: "verbose", 0, ! 25: #define NVERBSW 5 ! 26: "noverbose", 0, ! 27: ! 28: #define HELPSW 6 ! 29: "help", 4, ! 30: ! 31: NULL, NULL ! 32: }; ! 33: ! 34: /* */ ! 35: ! 36: static char delim3[] = "-------"; ! 37: ! 38: ! 39: static struct msgs *mp; ! 40: ! 41: struct smsg { ! 42: long s_start; ! 43: long s_stop; ! 44: }; ! 45: ! 46: /* */ ! 47: ! 48: /* ARGSUSED */ ! 49: ! 50: main(argc, argv) ! 51: int argc; ! 52: char **argv; ! 53: { ! 54: int inplace = 0, ! 55: quietsw = 0, ! 56: verbosw = 0, ! 57: msgp = 0, ! 58: hi, ! 59: msgnum; ! 60: char *cp, ! 61: *maildir, ! 62: *folder = NULL, ! 63: buf[100], ! 64: **ap, ! 65: **argp, ! 66: *arguments[MAXARGS], ! 67: *msgs[MAXARGS]; ! 68: struct smsg *smsgs; ! 69: ! 70: invo_name = r1bindex (argv[0], '/'); ! 71: if ((cp = m_find (invo_name)) != NULL) { ! 72: ap = brkstring (cp = getcpy (cp), " ", "\n"); ! 73: ap = copyip (ap, arguments); ! 74: } ! 75: else ! 76: ap = arguments; ! 77: (void) copyip (argv + 1, ap); ! 78: argp = arguments; ! 79: ! 80: /* */ ! 81: ! 82: while (cp = *argp++) { ! 83: if (*cp == '-') ! 84: switch (smatch (++cp, switches)) { ! 85: case AMBIGSW: ! 86: ambigsw (cp, switches); ! 87: done (1); ! 88: case UNKWNSW: ! 89: adios (NULLCP, "-%s unknown\n", cp); ! 90: case HELPSW: ! 91: (void) sprintf (buf, "%s [+folder] [msgs] [switches]", ! 92: invo_name); ! 93: help (buf, switches); ! 94: done (1); ! 95: ! 96: case INPLSW: ! 97: inplace++; ! 98: continue; ! 99: case NINPLSW: ! 100: inplace = 0; ! 101: continue; ! 102: ! 103: case QIETSW: ! 104: quietsw++; ! 105: continue; ! 106: case NQIETSW: ! 107: quietsw = 0; ! 108: continue; ! 109: ! 110: case VERBSW: ! 111: verbosw++; ! 112: continue; ! 113: case NVERBSW: ! 114: verbosw = 0; ! 115: continue; ! 116: } ! 117: if (*cp == '+' || *cp == '@') { ! 118: if (folder) ! 119: adios (NULLCP, "only one folder at a time!"); ! 120: else ! 121: folder = path (cp + 1, *cp == '+' ? TFOLDER : TSUBCWF); ! 122: } ! 123: else ! 124: msgs[msgp++] = cp; ! 125: } ! 126: ! 127: /* */ ! 128: ! 129: if (!m_find ("path")) ! 130: free (path ("./", TFOLDER)); ! 131: if (!msgp) ! 132: msgs[msgp++] = "cur"; ! 133: if (!folder) ! 134: folder = m_getfolder (); ! 135: maildir = m_maildir (folder); ! 136: ! 137: if (chdir (maildir) == NOTOK) ! 138: adios (maildir, "unable to change directory to"); ! 139: if (!(mp = m_gmsg (folder))) ! 140: adios (NULLCP, "unable to read folder %s", folder); ! 141: if (mp -> hghmsg == 0) ! 142: adios (NULLCP, "no messages in %s", folder); ! 143: ! 144: for (msgnum = 0; msgnum < msgp; msgnum++) ! 145: if (!m_convert (mp, msgs[msgnum])) ! 146: done (1); ! 147: m_setseq (mp); ! 148: ! 149: smsgs = (struct smsg *) ! 150: calloc ((unsigned) (MAXFOLDER + 2), sizeof *smsgs); ! 151: if (smsgs == NULL) ! 152: adios (NULLCP, "unable to allocate burst storage"); ! 153: ! 154: hi = mp -> hghmsg + 1; ! 155: for (msgnum = mp -> lowsel; msgnum <= mp -> hghsel; msgnum++) ! 156: if (mp -> msgstats[msgnum] & SELECTED) ! 157: burst (smsgs, msgnum, inplace, quietsw, verbosw); ! 158: ! 159: free ((char *) smsgs); ! 160: ! 161: m_replace (pfolder, folder); ! 162: if (inplace) { ! 163: if (mp -> lowsel != mp -> curmsg) ! 164: m_setcur (mp, mp -> lowsel); ! 165: } ! 166: else ! 167: if (hi <= mp -> hghmsg) ! 168: m_setcur (mp, hi); ! 169: m_sync (mp); ! 170: m_update (); ! 171: ! 172: done (0); ! 173: } ! 174: ! 175: /* */ ! 176: ! 177: static void ! 178: burst(smsgs, msgnum, inplace, quietsw, verbosw) ! 179: register struct smsg *smsgs; ! 180: int msgnum, inplace, quietsw, verbosw; ! 181: { ! 182: int i, ! 183: j, ! 184: ld3, ! 185: wasdlm, ! 186: mode, ! 187: msgp; ! 188: register long pos; ! 189: register char c, ! 190: *msgnam; ! 191: char buffer[BUFSIZ], ! 192: f1[BUFSIZ], ! 193: f2[BUFSIZ], ! 194: f3[BUFSIZ]; ! 195: struct stat st; ! 196: register FILE *in, ! 197: *out; ! 198: ! 199: ld3 = strlen (delim3); ! 200: ! 201: if ((in = fopen (msgnam = m_name (msgnum), "r")) == NULL) ! 202: adios (msgnam, "unable to read message"); ! 203: ! 204: mode = fstat (fileno (in), &st) != NOTOK ? (st.st_mode & 0777) ! 205: : m_gmprot (); ! 206: for (msgp = 1, pos = 0L; msgp <= MAXFOLDER;) { ! 207: while (fgets (buffer, sizeof buffer, in) != NULL ! 208: && buffer[0] == '\n') ! 209: pos += (long) strlen (buffer); ! 210: if (feof (in)) ! 211: break; ! 212: (void) fseek (in, pos, 0); ! 213: smsgs[msgp].s_start = pos; ! 214: ! 215: for (c = NULL; ! 216: fgets (buffer, sizeof buffer, in) != NULL; ! 217: c = buffer[0]) ! 218: if (strncmp (buffer, delim3, ld3) == 0 ! 219: && peekc (in) == '\n' ! 220: && (msgp == 1 || c == '\n')) ! 221: break; ! 222: else ! 223: pos += (long) strlen (buffer); ! 224: ! 225: wasdlm = strncmp (buffer, delim3, ld3) == 0; ! 226: if (smsgs[msgp].s_start != pos) ! 227: smsgs[msgp++].s_stop = c == '\n' && wasdlm ? pos - 1 : pos; ! 228: if (feof (in)) { ! 229: if (wasdlm) { ! 230: smsgs[msgp - 1].s_stop -= ((long) strlen (buffer) + 1); ! 231: msgp++; /* fake "End of XXX Digest" */ ! 232: } ! 233: break; ! 234: } ! 235: pos += (long) strlen (buffer); ! 236: } ! 237: ! 238: /* */ ! 239: ! 240: switch (--msgp) { /* toss "End of XXX Digest" */ ! 241: case 0: ! 242: adios (NULLCP, "burst() botch -- you lose big"); ! 243: ! 244: case 1: ! 245: if (!quietsw) ! 246: admonish (NULLCP, "message %d not in digest format", msgnum); ! 247: (void) fclose (in); ! 248: return; ! 249: ! 250: default: ! 251: if (verbosw) ! 252: printf ("%d message%s exploded from digest %d\n", ! 253: msgp - 1, msgp - 1 != 1 ? "s" : "", msgnum); ! 254: if (msgp == 2) /* XXX */ ! 255: msgp++; ! 256: break; ! 257: } ! 258: ! 259: if ((mp = m_remsg (mp, 0, mp -> hghmsg + msgp)) == NULL) ! 260: adios (NULLCP, "unable to allocate folder storage"); ! 261: ! 262: /* */ ! 263: ! 264: msgp--; ! 265: j = mp -> hghmsg; ! 266: mp -> hghmsg += msgp - 1; ! 267: mp -> nummsg += msgp - 1; ! 268: if (mp -> hghsel > msgnum) ! 269: mp -> hghsel += msgp - 1; ! 270: ! 271: if (inplace && msgp > 1) ! 272: for (i = mp -> hghmsg; j > msgnum; i--, j--) { ! 273: (void) strcpy (f1, m_name (i)); ! 274: (void) strcpy (f2, m_name (j)); ! 275: if (mp -> msgstats[j] & EXISTS) { ! 276: if (verbosw) ! 277: printf ("message %d becomes message %d\n", j, i); ! 278: ! 279: if (rename (f2, f1) == NOTOK) ! 280: admonish (f1, "unable to rename %s to", f2); ! 281: mp -> msgstats[i] = mp -> msgstats[j]; ! 282: mp -> msgstats[j] = NULL; ! 283: mp -> msgflags |= SEQMOD; ! 284: } ! 285: } ! 286: ! 287: mp -> msgstats[msgnum] &= ~SELECTED; ! 288: i = inplace ? msgnum + msgp - 1 : mp -> hghmsg; ! 289: for (j = msgp; j >= (inplace ? 1 : 2); i--, j--) { ! 290: (void) strcpy (f1, m_name (i)); ! 291: (void) strcpy (f2, m_scratch ("", invo_name)); ! 292: if (verbosw && i != msgnum) ! 293: printf ("message %d of digest %d becomes message %d\n", ! 294: j, msgnum, i); ! 295: ! 296: if ((out = fopen (f2, "w")) == NULL) ! 297: adios (f2, "unable to write message"); ! 298: (void) chmod (f2, mode); ! 299: (void) fseek (in, pos = smsgs[j].s_start, 0); ! 300: cpybrst (in, out, msgnam, f2, ! 301: (int) (smsgs[j].s_stop - smsgs[j].s_start)); ! 302: (void) fclose (out); ! 303: ! 304: if (i == msgnum) { ! 305: (void) strcpy (f3, m_backup (f1)); ! 306: if (rename (f1, f3) == NOTOK) ! 307: admonish (f3, "unable to rename %s to", f1); ! 308: } ! 309: if (rename (f2, f1) == NOTOK) ! 310: admonish (f1, "unable to rename %s to", f2); ! 311: mp -> msgstats[i] = mp -> msgstats[msgnum]; ! 312: mp -> msgflags |= SEQMOD; ! 313: } ! 314: ! 315: (void) fclose (in); ! 316: } ! 317: ! 318: ! 319: /* */ ! 320: ! 321: #define S1 0 ! 322: #define S2 1 ! 323: #define S3 2 ! 324: ! 325: static void ! 326: cpybrst(in, out, ifile, ofile, len) ! 327: register FILE *in, *out; ! 328: register char *ifile, *ofile; ! 329: register int len; ! 330: { ! 331: register int c, ! 332: state; ! 333: ! 334: for (state = S1; (c = fgetc (in)) != EOF && len > 0; len--) { ! 335: if (c == NULL) ! 336: continue; ! 337: switch (state) { ! 338: case S1: ! 339: switch (c) { ! 340: case '-': ! 341: state = S3; ! 342: break; ! 343: ! 344: default: ! 345: state = S2; ! 346: case '\n': ! 347: (void) fputc (c, out); ! 348: break; ! 349: } ! 350: break; ! 351: ! 352: case S2: ! 353: switch (c) { ! 354: case '\n': ! 355: state = S1; ! 356: default: ! 357: (void) fputc (c, out); ! 358: break; ! 359: } ! 360: break; ! 361: ! 362: case S3: ! 363: switch (c) { ! 364: case ' ': ! 365: state = S2; ! 366: break; ! 367: ! 368: default: ! 369: state = c == '\n' ? S1 : S2; ! 370: (void) fputc ('-', out); ! 371: (void) fputc (c, out); ! 372: break; ! 373: } ! 374: break; ! 375: } ! 376: } ! 377: ! 378: if (ferror (in)) ! 379: adios (ifile, "error reading"); ! 380: if (ferror (out)) ! 381: adios (ofile, "error writing"); ! 382: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.