![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to forw.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 forw.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / mh / uip |
1.1 ! root 1: /* forw.c - forward messages */ ! 2: ! 3: #include "../h/mh.h" ! 4: #include "../h/formatsbr.h" ! 5: #include "../zotnet/tws.h" ! 6: #include <stdio.h> ! 7: #include <sys/types.h> ! 8: #include <sys/stat.h> ! 9: ! 10: ! 11: #define IFMT "digest-issue-%s" ! 12: #define VFMT "digest-volume-%s" ! 13: ! 14: /* */ ! 15: ! 16: static struct swit switches[] = { ! 17: #define ANNOSW 0 ! 18: "annotate", 0, ! 19: #define NANNOSW 1 ! 20: "noannotate", 0, ! 21: ! 22: #define DFOLDSW 2 ! 23: "draftfolder +folder", 0, ! 24: #define DMSGSW 3 ! 25: "draftmessage msg", 0, ! 26: #define NDFLDSW 4 ! 27: "nodraftfolder", 0, ! 28: ! 29: #define EDITRSW 5 ! 30: "editor editor", 0, ! 31: #define NEDITSW 6 ! 32: "noedit", 0, ! 33: ! 34: #define FILTSW 7 ! 35: "filter filterfile", 0, ! 36: #define FORMSW 8 ! 37: "form formfile", 0, ! 38: ! 39: #define FRMTSW 9 ! 40: "format", 5, ! 41: #define NFRMTSW 10 ! 42: "noformat", 7, ! 43: ! 44: #define INPLSW 11 ! 45: "inplace", 0, ! 46: #define NINPLSW 12 ! 47: "noinplace", 0, ! 48: ! 49: #define DGSTSW 13 ! 50: "digest list", 0, ! 51: #define ISSUESW 14 ! 52: "issue number", 0, ! 53: #define VOLUMSW 15 ! 54: "volume number", 0, ! 55: ! 56: #define WHATSW 16 ! 57: "whatnowproc program", 0, ! 58: #define NWHATSW 17 ! 59: "nowhatnowproc", 0, ! 60: ! 61: #define DASHSW 18 ! 62: "dashmunging", 4, ! 63: #define NDASHSW 19 ! 64: "nodashmunging", 6, ! 65: ! 66: #define HELPSW 20 ! 67: "help", 4, ! 68: ! 69: #define FILESW 21 ! 70: "file file", -4, /* interface from msh */ ! 71: ! 72: #ifdef MHE ! 73: #define BILDSW 22 ! 74: "build", -5, /* interface from mhe */ ! 75: #endif MHE ! 76: ! 77: NULL, NULL ! 78: }; ! 79: ! 80: /* */ ! 81: ! 82: static struct swit aqrnl[] = { ! 83: #define NOSW 0 ! 84: "quit", 0, ! 85: #define YESW 1 ! 86: "replace", 0, ! 87: #define LISTDSW 2 ! 88: "list", 0, ! 89: #define REFILSW 3 ! 90: "refile +folder", 0, ! 91: #define NEWSW 4 ! 92: "new", 0, ! 93: ! 94: NULL, NULL ! 95: }; ! 96: ! 97: ! 98: static struct swit aqrl[] = { ! 99: "quit", 0, ! 100: "replace", 0, ! 101: "list", 0, ! 102: "refile +folder", 0, ! 103: ! 104: NULL, NULL ! 105: }; ! 106: ! 107: /* */ ! 108: ! 109: static char drft[BUFSIZ]; ! 110: ! 111: static char delim3[] = ! 112: "\n------------------------------------------------------------\n\n"; ! 113: static char delim4[] = "\n------------------------------\n\n"; ! 114: ! 115: ! 116: static struct msgs *mp = NULL; /* used a lot */ ! 117: ! 118: ! 119: long lseek(), time(); ! 120: ! 121: static void mhl_draft(), copy_draft(); ! 122: static int build_form(); ! 123: ! 124: /* */ ! 125: ! 126: /* ARGSUSED */ ! 127: ! 128: main(argc, argv) ! 129: int argc; ! 130: char *argv[]; ! 131: { ! 132: int msgp = 0, ! 133: anot = 0, ! 134: inplace = 0, ! 135: issue = 0, ! 136: volume = 0, ! 137: dashflg = 1, ! 138: #ifdef MHE ! 139: buildsw = 0, ! 140: #endif MHE ! 141: nedit = 0, ! 142: nwhat = 0, ! 143: i, ! 144: in, ! 145: out, ! 146: isdf = 0, ! 147: msgnum; ! 148: char *cp, ! 149: *cwd, ! 150: *maildir, ! 151: *dfolder = NULL, ! 152: *dmsg = NULL, ! 153: *digest = NULL, ! 154: *ed = NULL, ! 155: *file = NULL, ! 156: *filter = NULL, ! 157: *folder = NULL, ! 158: *form = NULL, ! 159: buf[100], ! 160: value[10], ! 161: **ap, ! 162: **argp, ! 163: *arguments[MAXARGS], ! 164: *msgs[MAXARGS]; ! 165: struct stat st; ! 166: ! 167: invo_name = r1bindex (argv[0], '/'); ! 168: if ((cp = m_find (invo_name)) != NULL) { ! 169: ap = brkstring (cp = getcpy (cp), " ", "\n"); ! 170: ap = copyip (ap, arguments); ! 171: } ! 172: else ! 173: ap = arguments; ! 174: (void) copyip (argv + 1, ap); ! 175: argp = arguments; ! 176: ! 177: /* */ ! 178: ! 179: while (cp = *argp++) { ! 180: if (*cp == '-') ! 181: switch (smatch (++cp, switches)) { ! 182: case AMBIGSW: ! 183: ambigsw (cp, switches); ! 184: done (1); ! 185: case UNKWNSW: ! 186: adios (NULLCP, "-%s unknown", cp); ! 187: case HELPSW: ! 188: (void) sprintf (buf, "%s [+folder] [msgs] [switches]", ! 189: invo_name); ! 190: help (buf, switches); ! 191: done (1); ! 192: ! 193: case ANNOSW: ! 194: anot++; ! 195: continue; ! 196: case NANNOSW: ! 197: anot = 0; ! 198: continue; ! 199: ! 200: case EDITRSW: ! 201: if (!(ed = *argp++) || *ed == '-') ! 202: adios (NULLCP, "missing argument to %s", argp[-2]); ! 203: nedit = 0; ! 204: continue; ! 205: case NEDITSW: ! 206: nedit++; ! 207: continue; ! 208: ! 209: case WHATSW: ! 210: if (!(whatnowproc = *argp++) || *whatnowproc == '-') ! 211: adios (NULLCP, "missing argument to %s", argp[-2]); ! 212: nwhat = 0; ! 213: continue; ! 214: #ifdef MHE ! 215: case BILDSW: ! 216: buildsw++; /* fall... */ ! 217: #endif MHE ! 218: case NWHATSW: ! 219: nwhat++; ! 220: continue; ! 221: ! 222: case FILESW: ! 223: if (file) ! 224: adios (NULLCP, "only one file at a time!"); ! 225: if (!(cp = *argp++) || *cp == '-') ! 226: adios (NULLCP, "missing argument to %s", argp[-2]); ! 227: file = path (cp, TFILE); ! 228: continue; ! 229: case FILTSW: ! 230: if (!(cp = *argp++) || *cp == '-') ! 231: adios (NULLCP, "missing argument to %s", argp[-2]); ! 232: filter = getcpy (libpath (cp)); ! 233: continue; ! 234: case FORMSW: ! 235: if (!(form = *argp++) || *form == '-') ! 236: adios (NULLCP, "missing argument to %s", argp[-2]); ! 237: continue; ! 238: ! 239: case FRMTSW: ! 240: filter = getcpy (libpath (mhlforward)); ! 241: continue; ! 242: case NFRMTSW: ! 243: filter = NULL; ! 244: continue; ! 245: ! 246: case INPLSW: ! 247: inplace++; ! 248: continue; ! 249: case NINPLSW: ! 250: inplace = 0; ! 251: continue; ! 252: ! 253: case DGSTSW: ! 254: if (!(digest = *argp++) || *digest == '-') ! 255: adios (NULLCP, "missing argument to %s", argp[-2]); ! 256: continue; ! 257: case ISSUESW: ! 258: if (!(cp = *argp++) || *cp == '-') ! 259: adios (NULLCP, "missing argument to %s", argp[-2]); ! 260: if ((issue = atoi (cp)) < 1) ! 261: adios (NULLCP, "bad argument %s %s", argp[-2], cp); ! 262: continue; ! 263: case VOLUMSW: ! 264: if (!(cp = *argp++) || *cp == '-') ! 265: adios (NULLCP, "missing argument to %s", argp[-2]); ! 266: if ((volume = atoi (cp)) < 1) ! 267: adios (NULLCP, "bad argument %s %s", argp[-2], cp); ! 268: continue; ! 269: ! 270: case DFOLDSW: ! 271: if (dfolder) ! 272: adios (NULLCP, "only one draft folder at a time!"); ! 273: if (!(cp = *argp++) || *cp == '-') ! 274: adios (NULLCP, "missing argument to %s", argp[-2]); ! 275: dfolder = path (*cp == '+' || *cp == '@' ? cp + 1 : cp, ! 276: *cp != '@' ? TFOLDER : TSUBCWF); ! 277: continue; ! 278: case DMSGSW: ! 279: if (dmsg) ! 280: adios (NULLCP, "only one draft message at a time!"); ! 281: if (!(dmsg = *argp++) || *dmsg == '-') ! 282: adios (NULLCP, "missing argument to %s", argp[-2]); ! 283: continue; ! 284: case NDFLDSW: ! 285: dfolder = NULL; ! 286: isdf = NOTOK; ! 287: continue; ! 288: ! 289: case DASHSW: ! 290: dashflg++; ! 291: continue; ! 292: case NDASHSW: ! 293: dashflg = 0; ! 294: continue; ! 295: } ! 296: if (*cp == '+' || *cp == '@') { ! 297: if (folder) ! 298: adios (NULLCP, "only one folder at a time!"); ! 299: else ! 300: folder = path (cp + 1, *cp == '+' ? TFOLDER : TSUBCWF); ! 301: } ! 302: else ! 303: msgs[msgp++] = cp; ! 304: } ! 305: ! 306: /* */ ! 307: ! 308: cwd = getcpy (pwd ()); ! 309: ! 310: if (!m_find ("path")) ! 311: free (path ("./", TFOLDER)); ! 312: if (file && (msgp || folder)) ! 313: adios (NULLCP, "can't mix files and folders/msgs"); ! 314: ! 315: try_it_again: ; ! 316: #ifndef MHE ! 317: (void) strcpy (drft, m_draft (dfolder, dmsg, NOUSE, &isdf)); ! 318: if (stat (drft, &st) != NOTOK) ! 319: #else MHE ! 320: (void) strcpy (drft, buildsw ? m_maildir ("draft") ! 321: : m_draft (dfolder, NULLCP, NOUSE, &isdf)); ! 322: if (!buildsw && stat (drft, &st) != NOTOK) ! 323: #endif MHE ! 324: { ! 325: printf ("Draft \"%s\" exists (%ld bytes).", drft, st.st_size); ! 326: for (i = LISTDSW; i != YESW;) { ! 327: if (!(argp = getans ("\nDisposition? ", isdf ? aqrnl : aqrl))) ! 328: done (1); ! 329: switch (i = smatch (*argp, isdf ? aqrnl : aqrl)) { ! 330: case NOSW: ! 331: done (0); ! 332: case NEWSW: ! 333: dmsg = NULL; ! 334: goto try_it_again; ! 335: case YESW: ! 336: break; ! 337: case LISTDSW: ! 338: (void) showfile (++argp, drft); ! 339: break; ! 340: case REFILSW: ! 341: if (refile (++argp, drft) == 0) ! 342: i = YESW; ! 343: break; ! 344: default: ! 345: advise (NULLCP, "say what?"); ! 346: break; ! 347: } ! 348: } ! 349: } ! 350: ! 351: /* */ ! 352: ! 353: if (file) { ! 354: anot = 0; ! 355: goto go_to_it; ! 356: } ! 357: ! 358: if (!msgp) ! 359: msgs[msgp++] = "cur"; ! 360: if (!folder) ! 361: folder = m_getfolder (); ! 362: maildir = m_maildir (folder); ! 363: ! 364: if (chdir (maildir) == NOTOK) ! 365: adios (maildir, "unable to change directory to"); ! 366: if (!(mp = m_gmsg (folder))) ! 367: adios (NULLCP, "unable to read folder %s", folder); ! 368: if (mp -> hghmsg == 0) ! 369: adios (NULLCP, "no messages in %s", folder); ! 370: ! 371: for (msgnum = 0; msgnum < msgp; msgnum++) ! 372: if (!m_convert (mp, msgs[msgnum])) ! 373: done (1); ! 374: m_setseq (mp); ! 375: ! 376: /* */ ! 377: ! 378: go_to_it: ; ! 379: if (filter && access (filter, 04) == NOTOK) ! 380: adios (filter, "unable to read"); ! 381: ! 382: if (digest) { ! 383: if (issue == 0) { ! 384: (void) sprintf (buf, IFMT, digest); ! 385: if (volume == 0 ! 386: && (cp = m_find (buf)) ! 387: && ((issue = atoi (cp)) < 0)) ! 388: issue = 0; ! 389: issue++; ! 390: } ! 391: if (volume == 0) ! 392: (void) sprintf (buf, VFMT, digest); ! 393: if ((cp = m_find (buf)) == NULL || (volume = atoi (cp)) <= 0) ! 394: volume = 1; ! 395: if (!form) ! 396: form = digestcomps; ! 397: in = build_form (form, digest, volume, issue); ! 398: } ! 399: else ! 400: if (form) { ! 401: if ((in = open (libpath (form), 0)) == NOTOK) ! 402: adios (form, "unable to open form file"); ! 403: } ! 404: else { ! 405: if ((in = open (libpath (forwcomps), 0)) == NOTOK) ! 406: adios (forwcomps, "unable to open default components file"); ! 407: form = forwcomps; ! 408: } ! 409: ! 410: if ((out = creat (drft, m_gmprot ())) == NOTOK) ! 411: adios (drft, "unable to create"); ! 412: ! 413: cpydata (in, out, form, drft); ! 414: (void) close (in); ! 415: ! 416: /* */ ! 417: ! 418: if (file) { ! 419: if ((in = open (file, 0)) == NOTOK) ! 420: adios (file, "unable to open"); ! 421: cpydata (in, out, file, drft); ! 422: (void) close (in); ! 423: (void) close (out); ! 424: goto edit_it; ! 425: } ! 426: ! 427: if (filter) ! 428: mhl_draft (out, digest, drft, filter, dashflg); ! 429: else ! 430: copy_draft (out, digest, drft); ! 431: (void) close (out); ! 432: ! 433: if (digest) { ! 434: (void) sprintf (buf, IFMT, digest); ! 435: (void) sprintf (value, "%d", issue); ! 436: m_replace (buf, getcpy (value)); ! 437: (void) sprintf (buf, VFMT, digest); ! 438: (void) sprintf (value, "%d", volume); ! 439: m_replace (buf, getcpy (value)); ! 440: } ! 441: ! 442: m_replace (pfolder, folder); ! 443: if (mp -> lowsel != mp -> curmsg) ! 444: m_setcur (mp, mp -> lowsel); ! 445: m_sync (mp); ! 446: m_update (); ! 447: ! 448: edit_it: ; ! 449: if (nwhat) ! 450: done (0); ! 451: (void) m_whatnow (ed, nedit, NOUSE, drft, NULLCP, 0, mp, ! 452: anot ? "Forwarded" : NULLCP, inplace, cwd); ! 453: done (1); ! 454: } ! 455: ! 456: /* */ ! 457: ! 458: static void ! 459: mhl_draft(out, digest, file, filter, dashflg) ! 460: int out; ! 461: register char *digest, *file, *filter; ! 462: int dashflg; ! 463: { ! 464: int i, ! 465: child_id, ! 466: msgnum, ! 467: pd[2]; ! 468: char *vec[MAXARGS]; ! 469: ! 470: if (pipe (pd) == NOTOK) ! 471: adios ("pipe", "unable to create"); ! 472: ! 473: vec[0] = r1bindex (mhlproc, '/'); ! 474: ! 475: for (i = 0; (child_id = fork ()) == NOTOK && i < 5; i++) ! 476: sleep (5); ! 477: switch (child_id) { ! 478: case NOTOK: ! 479: adios ("fork", "unable to"); ! 480: ! 481: case OK: ! 482: (void) close (pd[0]); ! 483: (void) dup2 (pd[1], 1); ! 484: (void) close (pd[1]); ! 485: ! 486: i = 1; ! 487: vec[i++] = "-forwall"; ! 488: vec[i++] = "-form"; ! 489: vec[i++] = filter; ! 490: if (digest) { ! 491: vec[i++] = "-digest"; ! 492: vec[i++] = digest; ! 493: } ! 494: if (dashflg) ! 495: vec[i++] = "-dashmunging"; ! 496: else ! 497: vec[i++] = "-nodashmunging"; ! 498: if (mp -> numsel >= MAXARGS - i) ! 499: adios (NULLCP, "more than %d messages for %s exec", ! 500: vec[0], MAXARGS - i); ! 501: for (msgnum = mp -> lowsel; msgnum <= mp -> hghsel; msgnum++) ! 502: if (mp -> msgstats[msgnum] & SELECTED) ! 503: vec[i++] = getcpy (m_name (msgnum)); ! 504: vec[i] = NULL; ! 505: ! 506: execvp (mhlproc, vec); ! 507: fprintf (stderr, "unable to exec "); ! 508: perror (mhlproc); ! 509: _exit (-1); ! 510: ! 511: default: ! 512: (void) close (pd[1]); ! 513: cpydata (pd[0], out, vec[0], file); ! 514: (void) close (pd[0]); ! 515: (void) pidXwait (child_id, mhlproc); ! 516: break; ! 517: } ! 518: } ! 519: ! 520: /* */ ! 521: ! 522: static void ! 523: copy_draft(out, digest, file) ! 524: int out; ! 525: register char *digest, *file; ! 526: { ! 527: int fd,i, ! 528: msgcnt, ! 529: msgnum; ! 530: register char *bp, ! 531: *msgnam; ! 532: char buffer[BUFSIZ]; ! 533: ! 534: msgcnt = 1; ! 535: for (msgnum = mp -> lowsel; msgnum <= mp -> hghsel; msgnum++) ! 536: if (mp -> msgstats[msgnum] & SELECTED) { ! 537: if (digest) ! 538: (void) strcpy (buffer, ! 539: msgnum == mp -> lowsel ? delim3 : delim4); ! 540: else { ! 541: (void) strcpy (bp = buffer, "\n-------"), bp += strlen (bp); ! 542: if (msgnum == mp -> lowsel) ! 543: (void) sprintf (bp, " Forwarded Message%s", ! 544: mp -> numsel > 1 ? "s" : ""); ! 545: else ! 546: (void) sprintf (bp, " Message %d", msgcnt); ! 547: bp += strlen (bp); ! 548: (void) strcpy (bp, "\n\n"); ! 549: } ! 550: (void) write (out, buffer, strlen (buffer)); ! 551: ! 552: if ((fd = open (msgnam = m_name (msgnum), 0)) == NOTOK) { ! 553: admonish (msgnam, "unable to read message"); ! 554: continue; ! 555: } ! 556: cpydgst (fd, out, msgnam, file); ! 557: (void) close (fd); ! 558: ! 559: msgcnt++; ! 560: } ! 561: ! 562: if (digest) ! 563: (void) strcpy (buffer, delim4); ! 564: else ! 565: (void) sprintf (buffer, "\n------- End of Forwarded Message%s\n\n", ! 566: mp -> numsel > 1 ? "s" : ""); ! 567: (void) write (out, buffer, strlen (buffer)); ! 568: ! 569: if (digest) { ! 570: (void) sprintf (buffer, "End of %s Digest\n", digest); ! 571: i = strlen (buffer); ! 572: for (bp = buffer + i; i > 1; i--) ! 573: *bp++ = '*'; ! 574: *bp++ = '\n'; ! 575: *bp = NULL; ! 576: (void) write (out, buffer, strlen (buffer)); ! 577: } ! 578: } ! 579: ! 580: /* */ ! 581: ! 582: static int ! 583: build_form(form, digest, volume, issue) ! 584: register char *form, *digest; ! 585: int volume, issue; ! 586: { ! 587: int in; ! 588: int fmtsize; ! 589: register char *nfs; ! 590: char *line, ! 591: tmpfil[BUFSIZ]; ! 592: register FILE *tmp; ! 593: register struct comp *cptr; ! 594: struct format *fmt; ! 595: int dat[4]; ! 596: ! 597: nfs = new_fs (form, NULLCP, NULLCP); ! 598: fmtsize = strlen (nfs) + 256; ! 599: (void) fmt_compile (nfs, &fmt); ! 600: ! 601: FINDCOMP (cptr, "digest"); ! 602: if (cptr) ! 603: cptr->c_text = digest; ! 604: FINDCOMP (cptr, "date"); ! 605: if (cptr) ! 606: cptr->c_text = getcpy(dtimenow ()); ! 607: ! 608: dat[0] = issue; ! 609: dat[1] = volume; ! 610: dat[2] = 0; ! 611: dat[3] = fmtsize; ! 612: ! 613: (void) strcpy (tmpfil, m_tmpfil (invo_name)); ! 614: if ((tmp = fopen (tmpfil, "w+")) == NULL) ! 615: adios (tmpfil, "unable to create"); ! 616: (void) unlink (tmpfil); ! 617: if ((in = dup (fileno (tmp))) == NOTOK) ! 618: adios ("dup", "unable to"); ! 619: ! 620: if ((line = malloc ((unsigned) fmtsize)) == NULLCP) ! 621: adios (NULLCP, "unable to allocate format line storage"); ! 622: (void) fmtscan (fmt, line, fmtsize, dat); ! 623: (void) fputs (line, tmp); ! 624: (void) free (line); ! 625: if (fclose (tmp)) ! 626: adios (tmpfil, "error writing"); ! 627: ! 628: (void) lseek (in, 0L, 0); ! 629: return in; ! 630: } ! 631: ! 632: /* ! 633: * XXX We need to force WhatNow() to be linked in to get around ! 634: * library order problems ! 635: */ ! 636: /* XXX don't bother if linking with the shared library */ ! 637: #ifndef SHARED ! 638: static void ! 639: kludge() ! 640: { ! 641: WhatNow(0, (char **)0); ! 642: } ! 643: #endif
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.