1 /* $NetBSD: msgs.c,v 1.25 2016/09/05 00:40:29 sevan Exp $ */ 2 3 /*- 4 * Copyright (c) 1980, 1993 5 * The Regents of the University of California. All rights reserved. 6 * 7 * Redistribution and use in source and binary forms, with or without 8 * modification, are permitted provided that the following conditions 9 * are met: 10 * 1. Redistributions of source code must retain the above copyright 11 * notice, this list of conditions and the following disclaimer. 12 * 2. Redistributions in binary form must reproduce the above copyright 13 * notice, this list of conditions and the following disclaimer in the 14 * documentation and/or other materials provided with the distribution. 15 * 3. Neither the name of the University nor the names of its contributors 16 * may be used to endorse or promote products derived from this software 17 * without specific prior written permission. 18 * 19 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 20 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 21 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 22 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 23 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 24 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 25 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 26 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 27 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 28 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 29 * SUCH DAMAGE. 30 */ 31 32 #include <sys/cdefs.h> 33 #ifndef lint 34 __COPYRIGHT("@(#) Copyright (c) 1980, 1993\ 35 The Regents of the University of California. All rights reserved."); 36 #endif /* not lint */ 37 38 #ifndef lint 39 #if 0 40 static char sccsid[] = "@(#)msgs.c 8.2 (Berkeley) 4/28/95"; 41 #else 42 __RCSID("$NetBSD: msgs.c,v 1.25 2016/09/05 00:40:29 sevan Exp $"); 43 #endif 44 #endif /* not lint */ 45 46 /* 47 * msgs - a user bulletin board program 48 * 49 * usage: 50 * msgs [fhlopqr] [[-]number] to read messages 51 * msgs -s to place messages 52 * msgs -c [-days] to clean up the bulletin board 53 * 54 * prompt commands are: 55 * y print message 56 * n flush message, go to next message 57 * q flush message, quit 58 * p print message, turn on 'pipe thru more' mode 59 * P print message, turn off 'pipe thru more' mode 60 * - reprint last message 61 * s[-][<num>] [<filename>] save message 62 * m[-][<num>] mail with message in temp mbox 63 * x exit without flushing this message 64 * <num> print message number <num> 65 */ 66 67 #define V7 /* will look for TERM in the environment */ 68 #define OBJECT /* will object to messages without Subjects */ 69 #define REJECT /* will reject messages without Subjects 70 (OBJECT must be defined also) */ 71 /*#define UNBUFFERED */ /* use unbuffered output */ 72 73 #include <sys/param.h> 74 #include <sys/ioctl.h> 75 #include <sys/stat.h> 76 77 #include <ctype.h> 78 #include <dirent.h> 79 #include <err.h> 80 #include <errno.h> 81 #include <pwd.h> 82 #include <setjmp.h> 83 #include <signal.h> 84 #include <stdio.h> 85 #include <stdlib.h> 86 #include <string.h> 87 #include <termcap.h> 88 #include <termios.h> 89 #include <time.h> 90 #include <unistd.h> 91 92 #include "pathnames.h" 93 94 #define CMODE 0664 /* bounds file creation mode */ 95 #define NO 0 96 #define YES 1 97 #define SUPERUSER 0 /* superuser uid */ 98 #define DAEMON 1 /* daemon uid */ 99 #define NLINES 24 /* default number of lines/crt screen */ 100 #define NDAYS 21 /* default keep time for messages */ 101 #define DAYS *24*60*60 /* seconds/day */ 102 #define MSGSRC ".msgsrc" /* user's rc file */ 103 #define BOUNDS "bounds" /* message bounds file */ 104 #define NEXT "Next message? [yq]" 105 #define MORE "More? [ynq]" 106 #define NOMORE "(No more) [q] ?" 107 108 typedef char bool; 109 110 FILE *msgsrc; 111 FILE *newmsg; 112 const char *sep = "-"; 113 char inbuf[BUFSIZ]; 114 char fname[MAXPATHLEN]; 115 char cmdbuf[MAXPATHLEN + 16]; 116 char subj[128]; 117 char from[128]; 118 char date[128]; 119 char *ptr; 120 char *in; 121 bool local; 122 bool ruptible; 123 bool totty; 124 bool seenfrom; 125 bool seensubj; 126 bool blankline; 127 bool printing = NO; 128 bool mailing = NO; 129 bool quitit = NO; 130 bool sending = NO; 131 bool intrpflg = NO; 132 bool restricted = NO; 133 int uid; 134 int msg; 135 int prevmsg; 136 int lct; 137 int nlines; 138 int Lpp = 0; 139 time_t t; 140 time_t keep; 141 142 void ask(const char *); 143 void gfrsub(FILE *); 144 int linecnt(FILE *); 145 int next(char *, size_t); 146 char *nxtfld(char *); 147 void onintr(int); 148 void onsusp(int); 149 void prmesg(int); 150 151 /* option initialization */ 152 bool hdrs = NO; 153 bool qopt = NO; 154 bool hush = NO; 155 bool send_msg = NO; 156 bool locomode = NO; 157 bool use_pager = NO; 158 bool clean = NO; 159 bool lastcmd = NO; 160 jmp_buf tstpbuf; 161 162 int 163 main(int argc, char *argv[]) 164 { 165 bool newrc, already; 166 int rcfirst = 0; /* first message to print (from .rc) */ 167 int rcback = 0; /* amount to back off of rcfirst */ 168 int firstmsg, nextmsg, lastmsg = 0; 169 int blast = 0; 170 FILE *bounds; 171 struct passwd *pw; 172 173 #ifdef UNBUFFERED 174 setbuf(stdout, NULL); 175 #endif 176 177 time(&t); 178 setuid(uid = getuid()); 179 ruptible = (signal(SIGINT, SIG_IGN) == SIG_DFL); 180 if (ruptible) 181 signal(SIGINT, SIG_DFL); 182 183 argc--, argv++; 184 while (argc > 0) { 185 if (isdigit((unsigned char)argv[0][0])) {/* starting message # */ 186 rcfirst = atoi(argv[0]); 187 } 188 else if (isdigit((unsigned char)argv[0][1])) {/* backward offset */ 189 rcback = atoi( &( argv[0][1] ) ); 190 } 191 else { 192 ptr = *argv; 193 while (*ptr) switch (*ptr++) { 194 195 case '-': 196 break; 197 198 case 'c': 199 if (uid != SUPERUSER && uid != DAEMON) { 200 fprintf(stderr, "Sorry\n"); 201 exit(1); 202 } 203 clean = YES; 204 break; 205 206 case 'f': /* silently */ 207 hush = YES; 208 break; 209 210 case 'h': /* headers only */ 211 hdrs = YES; 212 break; 213 214 case 'l': /* local msgs only */ 215 locomode = YES; 216 break; 217 218 case 'o': /* option to save last message */ 219 lastcmd = YES; 220 break; 221 222 case 'p': /* pipe thru 'more' during long msgs */ 223 use_pager = YES; 224 break; 225 226 case 'q': /* query only */ 227 qopt = YES; 228 break; 229 230 case 'r': /* restricted */ 231 restricted = YES; 232 break; 233 234 235 case 's': /* sending TO msgs */ 236 send_msg = YES; 237 break; 238 239 default: 240 fprintf(stderr, 241 "usage: msgs [cfhlopqrs] [[-]number]\n"); 242 exit(1); 243 } 244 } 245 argc--, argv++; 246 } 247 248 /* 249 * determine current message bounds 250 */ 251 snprintf(fname, sizeof (fname), "%s/%s", _PATH_MSGS, BOUNDS); 252 bounds = fopen(fname, "r"); 253 254 if (bounds != NULL) { 255 if (fscanf(bounds, "%d %d\n", &firstmsg, &lastmsg) < 2) 256 firstmsg = lastmsg = 0; 257 fclose(bounds); 258 blast = lastmsg; /* save upper bound */ 259 } 260 261 if (clean) 262 keep = t - (rcback? rcback : NDAYS) DAYS; 263 264 if (clean || bounds == NULL) { /* relocate message bounds */ 265 struct dirent *dp; 266 struct stat stbuf; 267 bool seenany = NO; 268 DIR *dirp; 269 270 dirp = opendir(_PATH_MSGS); 271 if (dirp == NULL) { 272 perror(_PATH_MSGS); 273 exit(errno); 274 } 275 chmod(fname, CMODE); 276 277 firstmsg = 32767; 278 lastmsg = 0; 279 280 for (dp = readdir(dirp); dp != NULL; dp = readdir(dirp)){ 281 char *cp = dp->d_name; 282 int i = 0; 283 284 if (dp->d_ino == 0) 285 continue; 286 #ifndef __SVR4 287 if (dp->d_namlen == 0) 288 continue; 289 #endif 290 291 if (clean) 292 snprintf(inbuf, sizeof (inbuf), "%s/%s", 293 _PATH_MSGS, cp); 294 295 while (isdigit((unsigned char)*cp)) 296 i = i * 10 + *cp++ - '0'; 297 if (*cp) 298 continue; /* not a message! */ 299 300 if (clean) { 301 if (stat(inbuf, &stbuf) != 0) 302 continue; 303 if (stbuf.st_mtime < keep 304 && stbuf.st_mode&S_IWRITE) { 305 unlink(inbuf); 306 continue; 307 } 308 } 309 310 if (i > lastmsg) 311 lastmsg = i; 312 if (i < firstmsg) 313 firstmsg = i; 314 seenany = YES; 315 } 316 closedir(dirp); 317 318 if (!seenany) { 319 if (blast != 0) /* never lower the upper bound! */ 320 lastmsg = blast; 321 firstmsg = lastmsg + 1; 322 } 323 else if (blast > lastmsg) 324 lastmsg = blast; 325 326 if (!send_msg) { 327 bounds = fopen(fname, "w"); 328 if (bounds == NULL) { 329 perror(fname); 330 exit(errno); 331 } 332 chmod(fname, CMODE); 333 fprintf(bounds, "%d %d\n", firstmsg, lastmsg); 334 fclose(bounds); 335 } 336 } 337 338 if (send_msg) { 339 /* 340 * Send mode - place msgs in _PATH_MSGS 341 */ 342 bounds = fopen(fname, "w"); 343 if (bounds == NULL) { 344 perror(fname); 345 exit(errno); 346 } 347 348 nextmsg = lastmsg + 1; 349 snprintf(fname, sizeof (fname), "%s/%d", _PATH_MSGS, nextmsg); 350 newmsg = fopen(fname, "w"); 351 if (newmsg == NULL) { 352 perror(fname); 353 exit(errno); 354 } 355 chmod(fname, 0644); 356 357 fprintf(bounds, "%d %d\n", firstmsg, nextmsg); 358 fclose(bounds); 359 360 sending = YES; 361 if (ruptible) 362 signal(SIGINT, onintr); 363 364 if (isatty(fileno(stdin))) { 365 pw = getpwuid(uid); 366 if (!pw) { 367 fprintf(stderr, "Who are you?\n"); 368 exit(1); 369 } 370 printf("Message %d:\nFrom %s %sSubject: ", 371 nextmsg, pw->pw_name, ctime(&t)); 372 fflush(stdout); 373 fgets(inbuf, sizeof inbuf, stdin); 374 putchar('\n'); 375 fflush(stdout); 376 fprintf(newmsg, "From %s %sSubject: %s\n", 377 ptr, ctime(&t), inbuf); 378 blankline = seensubj = YES; 379 } 380 else 381 blankline = seensubj = NO; 382 for (;;) { 383 fgets(inbuf, sizeof inbuf, stdin); 384 if (feof(stdin) || ferror(stdin)) 385 break; 386 blankline = (blankline || (inbuf[0] == '\n')); 387 seensubj = (seensubj || (!blankline && (strncmp(inbuf, "Subj", 4) == 0))); 388 fputs(inbuf, newmsg); 389 } 390 #ifdef OBJECT 391 if (!seensubj) { 392 printf("NOTICE: Messages should have a Subject field!\n"); 393 #ifdef REJECT 394 unlink(fname); 395 #endif 396 exit(1); 397 } 398 #endif 399 exit(ferror(stdin)); 400 } 401 if (clean) 402 exit(0); 403 404 /* 405 * prepare to display messages 406 */ 407 totty = (isatty(fileno(stdout)) != 0); 408 use_pager = use_pager && totty; 409 410 { 411 char *home = getenv("HOME"); 412 if(home == NULL || *home == '\0') 413 errx(1, "$HOME not set"); 414 snprintf(fname, sizeof (fname), "%s/%s", home, MSGSRC); 415 } 416 msgsrc = fopen(fname, "r"); 417 if (msgsrc) { 418 newrc = NO; 419 fscanf(msgsrc, "%d\n", &nextmsg); 420 fclose(msgsrc); 421 if (nextmsg > lastmsg+1) { 422 printf("Warning: bounds have been reset (%d, %d)\n", 423 firstmsg, lastmsg); 424 truncate(fname, (off_t)0); 425 newrc = YES; 426 } 427 else if (!rcfirst) 428 rcfirst = nextmsg - rcback; 429 } 430 else 431 newrc = YES; 432 msgsrc = fopen(fname, "r+"); 433 if (msgsrc == NULL) 434 msgsrc = fopen(fname, "w"); 435 if (msgsrc == NULL) { 436 perror(fname); 437 exit(errno); 438 } 439 if (rcfirst) { 440 if (rcfirst > lastmsg+1) { 441 printf("Warning: the last message is number %d.\n", 442 lastmsg); 443 rcfirst = nextmsg; 444 } 445 if (rcfirst > firstmsg) 446 firstmsg = rcfirst; /* don't set below first msg */ 447 } 448 if (newrc) { 449 nextmsg = firstmsg; 450 fseek(msgsrc, 0L, 0); 451 fprintf(msgsrc, "%d\n", nextmsg); 452 fflush(msgsrc); 453 } 454 455 #ifdef V7 456 if (totty) { 457 struct winsize win; 458 if (ioctl(fileno(stdout), TIOCGWINSZ, &win) != -1) 459 Lpp = win.ws_row; 460 if (Lpp <= 0) { 461 if (tgetent(inbuf, getenv("TERM")) <= 0 462 || (Lpp = tgetnum("li")) <= 0) { 463 Lpp = NLINES; 464 } 465 } 466 } 467 #endif 468 Lpp -= 6; /* for headers, etc. */ 469 470 already = NO; 471 prevmsg = firstmsg; 472 printing = YES; 473 if (ruptible) 474 signal(SIGINT, onintr); 475 476 /* 477 * Main program loop 478 */ 479 for (msg = firstmsg; msg <= lastmsg; msg++) { 480 481 snprintf(fname, sizeof (fname), "%s/%d", _PATH_MSGS, msg); 482 newmsg = fopen(fname, "r"); 483 if (newmsg == NULL) 484 continue; 485 486 gfrsub(newmsg); /* get From and Subject fields */ 487 if (locomode && !local) { 488 fclose(newmsg); 489 continue; 490 } 491 492 if (qopt) { /* This has to be located here */ 493 printf("There are new messages.\n"); 494 exit(0); 495 } 496 497 if (already && !hdrs) 498 putchar('\n'); 499 500 /* 501 * Print header 502 */ 503 if (totty) 504 signal(SIGTSTP, onsusp); 505 (void) setjmp(tstpbuf); 506 already = YES; 507 nlines = 2; 508 if (seenfrom) { 509 printf("Message %d:\nFrom %s %s", msg, from, date); 510 nlines++; 511 } 512 if (seensubj) { 513 printf("Subject: %s", subj); 514 nlines++; 515 } 516 else { 517 if (seenfrom) { 518 putchar('\n'); 519 nlines++; 520 } 521 while (nlines < 6 522 && fgets(inbuf, sizeof inbuf, newmsg) 523 && inbuf[0] != '\n') { 524 fputs(inbuf, stdout); 525 nlines++; 526 } 527 } 528 529 lct = linecnt(newmsg); 530 if (lct) 531 printf("(%d%slines) ", lct, seensubj? " " : " more "); 532 533 if (hdrs) { 534 printf("\n-----\n"); 535 fclose(newmsg); 536 continue; 537 } 538 539 /* 540 * Ask user for command 541 */ 542 if (totty) 543 ask(lct? MORE : (msg==lastmsg? NOMORE : NEXT)); 544 else 545 inbuf[0] = 'y'; 546 if (totty) 547 signal(SIGTSTP, SIG_DFL); 548 cmnd: 549 in = inbuf; 550 switch (*in) { 551 case 'x': 552 case 'X': 553 exit(0); 554 555 case 'q': 556 case 'Q': 557 quitit = YES; 558 printf("--Postponed--\n"); 559 exit(0); 560 /* intentional fall-thru */ 561 case 'n': 562 case 'N': 563 if (msg >= nextmsg) sep = "Flushed"; 564 prevmsg = msg; 565 break; 566 567 case 'p': 568 case 'P': 569 use_pager = (*in++ == 'p'); 570 /* intentional fallthru */ 571 case '\n': 572 case 'y': 573 default: 574 if (*in == '-') { 575 msg = prevmsg-1; 576 sep = "replay"; 577 break; 578 } 579 if (isdigit((unsigned char)*in)) { 580 msg = next(in, sizeof(inbuf) - 581 (in - inbuf)); 582 sep = in; 583 break; 584 } 585 586 prmesg(nlines + lct + (seensubj? 1 : 0)); 587 prevmsg = msg; 588 589 } 590 591 printf("--%s--\n", sep); 592 sep = "-"; 593 if (msg >= nextmsg) { 594 nextmsg = msg + 1; 595 fseek(msgsrc, 0L, 0); 596 fprintf(msgsrc, "%d\n", nextmsg); 597 fflush(msgsrc); 598 } 599 if (newmsg) 600 fclose(newmsg); 601 if (quitit) 602 break; 603 } 604 605 /* 606 * Make sure .rc file gets updated 607 */ 608 if (--msg >= nextmsg) { 609 nextmsg = msg + 1; 610 fseek(msgsrc, 0L, 0); 611 fprintf(msgsrc, "%d\n", nextmsg); 612 fflush(msgsrc); 613 } 614 if (already && !quitit && lastcmd && totty) { 615 /* 616 * save or reply to last message? 617 */ 618 msg = prevmsg; 619 ask(NOMORE); 620 if (inbuf[0] == '-' || isdigit((unsigned char)inbuf[0])) 621 goto cmnd; 622 } 623 if (!(already || hush || qopt)) 624 printf("No new messages.\n"); 625 exit(0); 626 } 627 628 void 629 prmesg(int length) 630 { 631 FILE *outf; 632 char *env_pager; 633 634 if (use_pager && length > Lpp) { 635 signal(SIGPIPE, SIG_IGN); 636 signal(SIGQUIT, SIG_IGN); 637 if ((env_pager = getenv("PAGER")) == NULL || 638 env_pager[0] == '\0') { 639 snprintf(cmdbuf, sizeof(cmdbuf), "%s -z%d", 640 _PATH_PAGER, Lpp); 641 } else { 642 strlcpy(cmdbuf, env_pager, sizeof (cmdbuf)); 643 } 644 outf = popen(cmdbuf, "w"); 645 if (!outf) 646 outf = stdout; 647 else 648 setbuf(outf, NULL); 649 } 650 else 651 outf = stdout; 652 653 if (seensubj) 654 putc('\n', outf); 655 656 while (fgets(inbuf, sizeof inbuf, newmsg)) { 657 fputs(inbuf, outf); 658 if (ferror(outf)) { 659 clearerr(outf); 660 break; 661 } 662 } 663 664 if (outf != stdout) { 665 pclose(outf); 666 signal(SIGPIPE, SIG_DFL); 667 signal(SIGQUIT, SIG_DFL); 668 } 669 else { 670 fflush(stdout); 671 } 672 673 /* trick to force wait on output */ 674 tcdrain(fileno(stdout)); 675 } 676 677 void 678 onintr(int dummy) 679 { 680 signal(SIGINT, onintr); 681 if (mailing) 682 unlink(fname); 683 if (sending) { 684 unlink(fname); 685 puts("--Killed--"); 686 exit(1); 687 } 688 if (printing) { 689 putchar('\n'); 690 if (hdrs) 691 exit(0); 692 sep = "Interrupt"; 693 if (newmsg) 694 fseek(newmsg, 0L, 2); 695 intrpflg = YES; 696 } 697 } 698 699 /* 700 * We have just gotten a susp. Suspend and prepare to resume. 701 */ 702 void 703 onsusp(int dummy) 704 { 705 706 signal(SIGTSTP, SIG_DFL); 707 sigsetmask(0); 708 kill(0, SIGTSTP); 709 signal(SIGTSTP, onsusp); 710 if (!mailing) 711 longjmp(tstpbuf, 0); 712 } 713 714 int 715 linecnt(FILE *f) 716 { 717 off_t oldpos = ftell(f); 718 int l = 0; 719 char lbuf[BUFSIZ]; 720 721 while (fgets(lbuf, sizeof lbuf, f)) 722 l++; 723 clearerr(f); 724 fseek(f, oldpos, 0); 725 return (l); 726 } 727 728 int 729 next(char *buf, size_t bufsiz) 730 { 731 int i; 732 sscanf(buf, "%d", &i); 733 snprintf(buf, bufsiz, "Goto %d", i); 734 return(--i); 735 } 736 737 void 738 ask(const char *prompt) 739 { 740 char inch; 741 int n, cmsg; 742 off_t oldpos; 743 FILE *cpfrom, *cpto; 744 745 printf("%s ", prompt); 746 fflush(stdout); 747 intrpflg = NO; 748 (void) fgets(inbuf, sizeof inbuf, stdin); 749 if ((n = strlen(inbuf)) > 0 && inbuf[n - 1] == '\n') 750 inbuf[n - 1] = '\0'; 751 if (intrpflg) 752 inbuf[0] = 'x'; 753 754 /* 755 * Handle 'mail' and 'save' here. 756 */ 757 if (((inch = inbuf[0]) == 's' || inch == 'm') && !restricted) { 758 if (inbuf[1] == '-') 759 cmsg = prevmsg; 760 else if (isdigit((unsigned char)inbuf[1])) 761 cmsg = atoi(&inbuf[1]); 762 else 763 cmsg = msg; 764 snprintf(fname, sizeof (fname), "%s/%d", _PATH_MSGS, cmsg); 765 766 oldpos = ftell(newmsg); 767 768 cpfrom = fopen(fname, "r"); 769 if (!cpfrom) { 770 printf("Message %d not found\n", cmsg); 771 ask (prompt); 772 return; 773 } 774 775 if (inch == 's') { 776 in = nxtfld(inbuf); 777 if (*in) { 778 for (n=0; in[n] > ' '; n++) { /* sizeof fname? */ 779 fname[n] = in[n]; 780 } 781 fname[n] = '\0'; 782 } 783 else 784 strlcpy(fname, "Messages", sizeof(fname)); 785 } 786 else { 787 int fd; 788 789 strlcpy(fname, _PATH_TMP, sizeof(fname)); 790 fd = mkstemp(fname); 791 if (fd == -1) 792 err(1, "mkstemp failed"); 793 close(fd); 794 snprintf(cmdbuf, sizeof (cmdbuf), _PATH_MAIL, fname); 795 mailing = YES; 796 } 797 cpto = fopen(fname, "a"); 798 if (!cpto) { 799 perror(fname); 800 mailing = NO; 801 fseek(newmsg, oldpos, 0); 802 fclose(cpfrom); 803 ask(prompt); 804 return; 805 } 806 807 while ((n = fread(inbuf, 1, sizeof inbuf, cpfrom)) != 0) 808 fwrite(inbuf, 1, n, cpto); 809 810 fclose(cpfrom); 811 fclose(cpto); 812 fseek(newmsg, oldpos, 0); /* reposition current message */ 813 if (inch == 's') 814 printf("Message %d saved in \"%s\"\n", cmsg, fname); 815 else { 816 system(cmdbuf); 817 unlink(fname); 818 mailing = NO; 819 } 820 ask(prompt); 821 } 822 } 823 824 void 825 gfrsub(FILE *infile) 826 { 827 off_t frompos; 828 829 seensubj = seenfrom = NO; 830 local = YES; 831 subj[0] = from[0] = date[0] = 0; 832 833 /* 834 * Is this a normal message? 835 */ 836 if (fgets(inbuf, sizeof inbuf, infile)) { 837 if (strncmp(inbuf, "From", 4)==0) { 838 /* 839 * expected form starts with From 840 */ 841 seenfrom = YES; 842 frompos = ftell(infile); 843 ptr = from; 844 in = nxtfld(inbuf); 845 if (*in) while (*in && *in > ' ') { 846 if (*in == ':' || *in == '@' || *in == '!') 847 local = NO; 848 *ptr++ = *in++; 849 /* what about sizeof from ? */ 850 } 851 *ptr = '\0'; 852 if (*(in = nxtfld(in))) 853 strncpy(date, in, sizeof date); 854 else { 855 date[0] = '\n'; 856 date[1] = '\0'; 857 } 858 } 859 else { 860 /* 861 * not the expected form 862 */ 863 fseek(infile, 0L, 0); 864 return; 865 } 866 } 867 else 868 /* 869 * empty file ? 870 */ 871 return; 872 873 /* 874 * look for Subject line until EOF or a blank line 875 */ 876 while (fgets(inbuf, sizeof inbuf, infile) 877 && !(blankline = (inbuf[0] == '\n'))) { 878 /* 879 * extract Subject line 880 */ 881 if (!seensubj && strncmp(inbuf, "Subj", 4)==0) { 882 seensubj = YES; 883 frompos = ftell(infile); 884 strncpy(subj, nxtfld(inbuf), sizeof subj); 885 } 886 } 887 if (!blankline) 888 /* 889 * ran into EOF 890 */ 891 fseek(infile, frompos, 0); 892 893 if (!seensubj) 894 /* 895 * for possible use with Mail 896 */ 897 strncpy(subj, "(No Subject)\n", sizeof subj); 898 } 899 900 char * 901 nxtfld(char *s) 902 { 903 if (*s) while (*s && *s > ' ') s++; /* skip over this field */ 904 if (*s) while (*s && *s <= ' ') s++; /* find start of next field */ 905 return (s); 906 } 907
Indexes created Sat Sep 20 22:09:52 GMT 2025