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