![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to inews.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv10no / cmd / netnews / src|
Return to inews.c CVS log | Up to [Research Unix] / researchv10no / cmd / netnews / src |
1.1 ! root 1: /* ! 2: * inews - insert, receive, and transmit news articles. ! 3: */ ! 4: ! 5: static char *SccsId = "@(#)inews.c 2.30 6/24/83"; ! 6: ! 7: #include "iparams.h" ! 8: ! 9: /* local defines for inews */ ! 10: ! 11: #define OPTION 0 /* pick up an option string */ ! 12: #define STRING 1 /* pick up a string of arguments */ ! 13: ! 14: #define UNKNOWN 0001 /* possible modes for news program */ ! 15: #define UNPROC 0002 /* Unprocessed input */ ! 16: #define PROC 0004 /* Processed input */ ! 17: #define CANCEL 0010 /* Cancel an article */ ! 18: #define CREATENG 0020 /* Create a new newsgroup */ ! 19: ! 20: #ifndef SYSBUF ! 21: char SYSBUF[BUFSIZ]; /* to buffer std out */ ! 22: #endif ! 23: char forgedname[100]; /* A user specified -f option. */ ! 24: ! 25: struct { /* options table. */ ! 26: char optlet; /* option character. */ ! 27: char filchar; /* if to pickup string, fill character. */ ! 28: int flag; /* TRUE if have seen this opt. */ ! 29: int oldmode; /* OR of legal input modes. */ ! 30: int newmode; /* output mode. */ ! 31: char *buf; /* string buffer */ ! 32: } *optpt, options[] = { /* ! 33: optlet filchar flag oldmode newmode buf */ ! 34: 't', ' ', FALSE, UNPROC, UNKNOWN, header.title, ! 35: 'n', NGDELIM, FALSE, UNPROC, UNKNOWN, header.nbuf, ! 36: 'e', ' ', FALSE, UNPROC, UNKNOWN, header.expdate, ! 37: 'p', '\0', FALSE, UNKNOWN,PROC, filename, ! 38: 'f', '\0', FALSE, UNPROC, UNKNOWN, forgedname, ! 39: 'F', ' ', FALSE, UNPROC, UNKNOWN, header.followid, ! 40: 'c', '\0', FALSE, UNKNOWN,CANCEL, filename, ! 41: 'C', '\0', FALSE, UNKNOWN,CREATENG, header.nbuf, ! 42: #define Dflag options[8].flag ! 43: 'D', '\0', FALSE, UNPROC, UNKNOWN, filename, ! 44: #define hflag options[9].flag ! 45: 'h', '\0', FALSE, UNPROC, UNKNOWN, filename, ! 46: '\0', '\0', 0, 0, 0, (char *)NULL ! 47: }; ! 48: ! 49: FILE *mailhdr(); ! 50: ! 51: /* ! 52: * Authors: ! 53: * Matt Glickman [email protected] ! 54: * Mark Horton [email protected] ! 55: * Stephen Daniels [email protected] ! 56: * Tom Truscott [email protected] ! 57: * IHCC version adapted by: ! 58: * Larry Marek [email protected] ! 59: */ ! 60: main(argc, argv) ! 61: int argc; ! 62: register char **argv; ! 63: { ! 64: int state; /* which type of argument to pick up */ ! 65: int tlen, len; /* temps for string processing routine */ ! 66: register char *ptr; /* pointer to rest of buffer */ ! 67: int filchar; /* fill character (state = STRING) */ ! 68: char *user, *home; /* environment temps */ ! 69: struct passwd *pw; /* struct for pw lookup */ ! 70: struct group *gp; /* struct for group lookup */ ! 71: struct srec srec; /* struct for sys file lookup */ ! 72: struct utsname ubuf; ! 73: register int i; ! 74: FILE *mfd; /* mail file file-descriptor */ ! 75: char cbuf[BUFLEN]; /* command buffer */ ! 76: ! 77: /* uuxqt doesn't close all it's files */ ! 78: for (i = 3; !close(i); i++) ! 79: ; ! 80: /* set up defaults and initialize. */ ! 81: mode = UNKNOWN; ! 82: pathinit(); ! 83: ptr = rindex(*argv, '/'); ! 84: if (!ptr) ! 85: ptr = *argv - 1; ! 86: if (!strncmp(ptr+1, "rnews", 5)) ! 87: mode = PROC; ! 88: else if (argc < 2) ! 89: goto usage; ! 90: ! 91: state = OPTION; ! 92: header.title[0] = header.nbuf[0] = filename[0] = '\0'; ! 93: ! 94: /* check for existence of special files */ ! 95: if (!rwaccess(ARTFILE)) { ! 96: mfd = mailhdr(NULL, exists(ARTFILE) ? "Unwritable files!" : "Missing files!"); ! 97: if (mfd != NULL) { ! 98: fprintf(mfd,"System: %s\n\nThere was a problem with %s!!\n", SYSNAME, ARTFILE); ! 99: sprintf(cbuf, "touch %s;chmod 666 %s", ARTFILE, ARTFILE); ! 100: system(cbuf); ! 101: if (rwaccess(ARTFILE)) ! 102: fprintf(mfd, "The problem has been taken care of.\n"); ! 103: else ! 104: fprintf(mfd, "Corrective action failed - check suid bits.\n"); ! 105: mclose(mfd); ! 106: } ! 107: } ! 108: if (!rwaccess(ACTIVE)) { ! 109: mfd = mailhdr(NULL, exists(ACTIVE) ? "Unwritable files!" : "Missing files!"); ! 110: if (mfd != NULL) { ! 111: fprintf(mfd, "System: %s\n\nThere was a problem with %s!!\n", SYSNAME, ACTIVE); ! 112: sprintf(cbuf, "touch %s;chmod 666 %s", ACTIVE, ACTIVE); ! 113: system(cbuf); ! 114: if (rwaccess(ACTIVE)) ! 115: fprintf(mfd, "The problem has been taken care of.\n"); ! 116: else ! 117: fprintf(mfd, "Corrective action failed - check suid bits.\n"); ! 118: mclose(mfd); ! 119: } ! 120: } ! 121: setbuf(stdout, SYSBUF); ! 122: sigtrap = FALSE; /* true if a signal has been caught */ ! 123: /* ! 124: signal(SIGQUIT, SIG_IGN); ! 125: */ ! 126: if (mode != PROC) { ! 127: signal(SIGHUP, onsig); ! 128: signal(SIGINT, onsig); ! 129: } ! 130: savmask = umask(N_UMASK); /* set up mask */ ! 131: uid = (unsigned) getuid(); ! 132: gid = (unsigned) getgid(); ! 133: duid = geteuid(); ! 134: dgid = getegid(); ! 135: if (uid == 0 && geteuid() == 0) { ! 136: /* ! 137: * Must go through with this kludge since ! 138: * some systems do not honor the setuid bit ! 139: * when root invokes a setuid program. ! 140: */ ! 141: if ((pw = getpwnam(NEWSU)) == NULL) ! 142: xerror("Cannot get NEWSU pw entry"); ! 143: ! 144: duid = pw->pw_uid; ! 145: if ((gp = getgrnam(NEWSG)) == NULL) ! 146: xerror("Cannot get NEWSG gr entry"); ! 147: dgid = gp->gr_gid; ! 148: setuid(duid); ! 149: setgid(dgid); ! 150: } ! 151: ! 152: #ifndef IHCC ! 153: /* ! 154: * We force the use of 'getuser()' to prevent forgery of articles ! 155: * by just changing $LOGNAME ! 156: */ ! 157: if ((user = getenv("USER")) == NULL) ! 158: user = getenv("LOGNAME"); ! 159: if ((home = getenv("HOME")) == NULL) ! 160: home = getenv("LOGDIR"); ! 161: #endif ! 162: if (user == NULL || home == NULL) ! 163: getuser(); ! 164: else { ! 165: if (username[0] == 0) { ! 166: strcpy(username, user); ! 167: } ! 168: strcpy(userhome, home); ! 169: } ! 170: getuser(); ! 171: strcpy(whatever, username); ! 172: ! 173: /* loop once per arg. */ ! 174: ! 175: ++argv; /* skip first arg, which is prog name. */ ! 176: ! 177: while (--argc) { ! 178: if (state == OPTION) { ! 179: if (**argv != '-') { ! 180: sprintf(bfr, "Bad option string \"%s\"", *argv); ! 181: xerror(bfr); ! 182: } ! 183: while (*++*argv != '\0') { ! 184: for (optpt = options; optpt->optlet != '\0'; ++optpt) { ! 185: if (optpt->optlet == **argv) ! 186: goto found; ! 187: } ! 188: /* unknown option letter */ ! 189: usage: ! 190: fprintf(stderr, "usage: inews -t title"); ! 191: fprintf(stderr, " [ -n newsgroups ]"); ! 192: fprintf(stderr, " [ -e expiration date ]\n"); ! 193: fprintf(stderr, "\t[ -f sender]\n\n"); ! 194: fprintf(stderr, " inews -p [ filename ]\n"); ! 195: xxit(1); ! 196: ! 197: found:; ! 198: if (optpt->flag == TRUE || (mode != UNKNOWN && ! 199: (mode&optpt->oldmode) == 0)) { ! 200: sprintf(bfr, "Bad %c option", **argv); ! 201: xerror(bfr); ! 202: } ! 203: if (mode == UNKNOWN) ! 204: mode = optpt->newmode; ! 205: filchar = optpt->filchar; ! 206: optpt->flag = TRUE; ! 207: state = STRING; ! 208: ptr = optpt->buf; ! 209: len = BUFLEN; ! 210: } ! 211: ! 212: argv++; /* done with this option arg. */ ! 213: ! 214: } else { ! 215: ! 216: /* ! 217: * Pick up a piece of a string and put it into ! 218: * the appropriate buffer. ! 219: */ ! 220: if (**argv == '-') { ! 221: state = OPTION; ! 222: argc++; /* uncount this arg. */ ! 223: continue; ! 224: } ! 225: ! 226: if ((tlen = strlen(*argv)) >= len) ! 227: xerror("Argument string too long"); ! 228: strcpy(ptr, *argv++); ! 229: ptr += tlen; ! 230: if (*(ptr-1) != filchar) ! 231: *ptr++ = filchar; ! 232: len -= tlen + 1; ! 233: *ptr = '\0'; ! 234: } ! 235: } ! 236: ! 237: /* ! 238: * ALL of the command line has now been processed. (!) ! 239: */ ! 240: ! 241: tty = isatty(fileno(stdin)); ! 242: if (!Dflag && mode != PROC && mode != CREATENG) { ! 243: if (recording(header.nbuf)) { ! 244: if (!tty) ! 245: fwait(fsubr(newssave, stdin, NULL)); ! 246: xerror("aborted due to recording"); ! 247: } ! 248: } ! 249: ! 250: /* This code is really intended to be replaced by the control message. */ ! 251: if (mode == CANCEL) { ! 252: char *p; FILE *f; ! 253: f = xfopen(filename, "r"); ! 254: hread(&header, f, TRUE); ! 255: p = index(header.path, ' '); ! 256: if (p != NULL) ! 257: *p = 0; ! 258: p = header.path; ! 259: if (strncmp(whatever, p, strlen(whatever)) ! 260: && uid != ROOTID && uid != geteuid() && uid) ! 261: xerror("Not contributor"); ! 262: cancel(); ! 263: xxit(0); ! 264: } ! 265: ! 266: if (*header.nbuf) ! 267: lcase(header.nbuf); ! 268: if (mode != PROC) { ! 269: getident(&header); ! 270: #ifdef MYORG ! 271: strcpy(header.organization, MYORG); ! 272: if (strncmp(header.organization, "Frobozz", 7) == 0) ! 273: header.organization[0] = '\0'; ! 274: if (ptr = getenv("ORGANIZATION")) ! 275: strcpy(header.organization, ptr); ! 276: /* ! 277: * Note that the organization can also be turned off by ! 278: * setting it to the null string, either in MYORG or ! 279: * $ORGANIZATION in the environment. ! 280: */ ! 281: if (header.organization[0] == '/') { ! 282: mfd = fopen(header.organization, "r"); ! 283: if (mfd) { ! 284: fgets(header.organization, sizeof header.organization, mfd); ! 285: fclose(mfd); ! 286: } ! 287: ptr = index(header.organization, '\n'); ! 288: if (ptr) ! 289: *ptr = 0; ! 290: } ! 291: #endif ! 292: if (hflag) { ! 293: /* Fill in a few to make frmread return TRUE */ ! 294: strcpy(header.subdate, "today"); ! 295: strcpy(header.path, "me"); ! 296: strcpy(header.oident, "id"); ! 297: /* Allow the user to supply some headers. */ ! 298: hread(&header, stdin, FALSE); ! 299: /* But there are certain fields we won't let him specify. */ ! 300: if (header.from) ! 301: strcpy(forgedname, header.from); ! 302: header.from[0] = '\0'; ! 303: header.path[0] = '\0'; ! 304: header.subdate[0] = '\0'; ! 305: header.sender[0] = '\0'; ! 306: if (strcmp(header.oident, "id") == 0) ! 307: header.oident[0] = '\0'; ! 308: ngcat(header.nbuf); ! 309: } ! 310: if (forgedname[0]) { ! 311: strcpy(header.from, forgedname); ! 312: sprintf(header.sender, "%s@%s%s", ! 313: username, SYSNAME, MYDOMAIN); ! 314: } else { ! 315: gensender(&header, username); ! 316: } ! 317: strcpy(header.postversion, genversion()); ! 318: } ! 319: ! 320: /* Authorize newsgroups. */ ! 321: if (mode == PROC) { ! 322: checkbatch(); ! 323: signal(SIGHUP, SIG_IGN); ! 324: signal(SIGINT, SIG_IGN); ! 325: signal(SIGQUIT, SIG_IGN); ! 326: if (hread(&header, stdin, TRUE) == NULL) ! 327: xerror("Inbound news is garbled"); ! 328: input(); ! 329: if (history(&header)) { ! 330: fprintf(stderr, "Duplicate article %s rejected\n", header.ident); ! 331: log("Duplicate article %s rejected", header.ident); ! 332: xxit(0); ! 333: } ! 334: } ! 335: ngcat(header.nbuf); ! 336: ! 337: /* Easy way to make control messages, since all.all.ctl is unblessed */ ! 338: if (mode != PROC && prefix(header.title, "cmsg ") && header.ctlmsg[0] == 0) ! 339: strcpy(header.ctlmsg, &header.title[5]); ! 340: is_ctl = mode != CREATENG && ! 341: (ngmatch(header.nbuf, "all.all.ctl,") || header.ctlmsg[0]); ! 342: #ifdef DEBUG ! 343: fprintf(stderr,"is_ctl set to %d\n", is_ctl); ! 344: #endif ! 345: ! 346: /* Must end in comma (NGDELIM) */ ! 347: #define MODGROUPS "mod.all,all.mod,all.announce," ! 348: if (ngmatch(header.nbuf, MODGROUPS) && !header.approved[0]) { ! 349: mfd = mailhdr(&header, "Moderated newsgroup"); ! 350: if (mfd) { ! 351: fprintf(mfd, "This newsgroup is moderated, and cannot be posted to directly.\n"); ! 352: fprintf(mfd, "Please mail your article to the moderator for posting.\n"); ! 353: hwrite(&header, mfd); ! 354: if (infp) ! 355: while ((i = getc(infp)) != EOF) ! 356: putc(i, mfd); ! 357: mclose(mfd); ! 358: } ! 359: xerror("Unapproved moderated newsgroup\n"); ! 360: } ! 361: ! 362: if (mode == PROC) { ! 363: strcpy(nbuf, header.nbuf); ! 364: if (s_find(&srec, FULLSYSNAME) == FALSE) ! 365: xerror("Cannot find my name '%s' in %s", FULLSYSNAME, SUBFILE); ! 366: ngsquash(nbuf, srec.s_nbuf); ! 367: ! 368: } ! 369: else if (mode != CREATENG) { ! 370: if (!*header.title) ! 371: xerror("No title"); ! 372: if (!*header.nbuf) ! 373: strcpy(header.nbuf, DFLTNG); ! 374: else if (!is_ctl) ! 375: ngfcheck(FALSE); ! 376: ngcat(header.nbuf); ! 377: strcpy(nbuf, header.nbuf); ! 378: } ! 379: else { /* mode == CREATENG */ ! 380: ngcat(header.nbuf); ! 381: strcpy(nbuf, header.nbuf); ! 382: } ! 383: ! 384: for (ptr = nbuf; (ptr = index(ptr, NGDELIM)) != NULL; *ptr++ = '\0') ! 385: ; ! 386: if (!is_ctl && header.followid[0] == '\0') ! 387: for (ptr = nbuf; *ptr;) { ! 388: if (!exists(dirname(ptr))) ! 389: ngcheck(ptr); ! 390: while (*ptr++) ! 391: ; ! 392: } ! 393: else if (mode <= UNPROC) ! 394: ctlcheck(); ! 395: for (ptr = nbuf; *ptr;) { ! 396: if (*ptr != '-') ! 397: goto out; ! 398: while (*ptr++) ! 399: ; ! 400: } ! 401: xerror("No valid newsgroups in '%s'", header.nbuf); ! 402: out: ! 403: ! 404: /* Determine input. */ ! 405: if (mode != PROC) ! 406: input(); ! 407: ! 408: #ifndef VMS ! 409: /* Go into the background so the user can get on with his business. */ ! 410: if (mode != PROC) { ! 411: i = fork(); ! 412: if (i != 0) ! 413: exit(0); ! 414: } ! 415: #endif VMS ! 416: ! 417: /* Do the actual insertion. */ ! 418: insert(); ! 419: } ! 420: ! 421: /* ! 422: * Create directory named by bfr. ! 423: * Don't if user doesn't want to. ! 424: */ ! 425: ngcheck(ngname) ! 426: char *ngname; ! 427: { ! 428: char class[120]; ! 429: char dir[256]; ! 430: char *cp; ! 431: ! 432: strcpy(dir, dirname(ngname)); ! 433: if (mode == PROC) { ! 434: #ifdef AUTONEWNG ! 435: mknewsg(dir, ngname); ! 436: #endif ! 437: return 1; ! 438: } ! 439: ! 440: /* ! 441: * If a user is trying to input to a non-existent group complain. ! 442: * First check to see if the newsgroup ever existed. To do this, try ! 443: * to find the name in the "active" file. ! 444: */ ! 445: if (mode != CREATENG && !is_ctl) { ! 446: /* Ick! Figure out if the newsgroup is in the active file. */ ! 447: sprintf(dir, "grep -s '^%s ' %s", ngname, ACTIVE); ! 448: if ((system(dir) != 0)) ! 449: xerror("There is no such newsgroup as %s.", ngname); ! 450: else { ! 451: strcpy(dir, dirname(ngname)); ! 452: mknewsg(dir, ngname); ! 453: return 0; ! 454: } ! 455: } ! 456: /* ! 457: * Only certain users are allowed to create newsgroups ! 458: */ ! 459: if (uid != ROOTID && uid != geteuid() && uid) ! 460: xerror("Please contact one of the local netnews people\n\tto create this group for you"); ! 461: ! 462: /* Broadcast the new newsgroup */ ! 463: strcpy(class, ngname); ! 464: for (cp=class; *cp && *cp!='.'; cp++) ! 465: ; ! 466: if (*cp) ! 467: *cp = 0; ! 468: else { ! 469: mknewsg(dir, ngname); ! 470: exit(0); /* Local newsgroup */ ! 471: } ! 472: sprintf(bfr, "inews -D -n %s.ctl -t cmsg newgroup %s", ngname, ngname); ! 473: printf("Please type in a paragraph describing the new newsgroup.\n"); ! 474: printf("End with control D as usual.\n"); ! 475: printf("%s\n", bfr); ! 476: fflush(stdout); ! 477: system(bfr); ! 478: exit(0); ! 479: } ! 480: ! 481: #include <errno.h> ! 482: char firstbufname[100]; ! 483: /* ! 484: * Link ARTICLE into dir for ngname and update active file. ! 485: */ ! 486: localize(ngname) ! 487: char *ngname; ! 488: { ! 489: FILE *fp; ! 490: struct stat status; ! 491: char afline[BUFLEN]; ! 492: long ngsize; ! 493: long fpos; ! 494: int i, e; ! 495: extern int errno; ! 496: ! 497: lock(); ! 498: actfp = fopen(ACTIVE, "r+"); ! 499: for(;;) { ! 500: fpos = ftell(actfp); ! 501: if (fgets(afline, sizeof afline, actfp) == NULL) { ! 502: unlock(); ! 503: return FALSE; /* No such newsgroup locally */ ! 504: } ! 505: if (prefix(afline, ngname)) { ! 506: sscanf(afline, "%s %ld", bfr, &ngsize); ! 507: if (strcmp(bfr, ngname) == 0) { ! 508: break; ! 509: } ! 510: if (ngsize < 0 || ngsize > 99998) { ! 511: log("found bad ngsize %d ng %s, setting to 1", ngsize, bfr); ! 512: ngsize = 1; ! 513: } ! 514: } ! 515: } ! 516: for (;;) { ! 517: sprintf(bfr, "%s/%ld", dirname(ngname), ngsize+1); ! 518: if (link(ARTICLE, bfr) == 0) break; ! 519: e = errno; /* keep log from clobbering it */ ! 520: fprintf(stderr, "Cannot install article as %s\n", bfr); ! 521: log("Cannot install article as %s", bfr); ! 522: if (e != EEXIST) { ! 523: log("Link into %s failed, errno %d, check dir permissions.", bfr, e); ! 524: unlock(); ! 525: return FALSE; ! 526: } ! 527: ngsize++; ! 528: } ! 529: ! 530: /* Next two lines program around a bug in 4.1BSD stdio. */ ! 531: fclose(actfp); ! 532: actfp = fopen(ACTIVE, "r+"); ! 533: ! 534: fseek(actfp, fpos, 0); ! 535: /* Has to be same size as old because of %05d. ! 536: * This will overflow with 99999 articles. ! 537: */ ! 538: fprintf(actfp, "%s %05ld\n", ngname, ngsize+1); ! 539: fclose(actfp); ! 540: unlock(); ! 541: if (firstbufname[0] == '\0') ! 542: strcpy(firstbufname, bfr); ! 543: sprintf(bfr, "%s/%ld ", ngname, ngsize+1); ! 544: addhist(bfr); ! 545: return TRUE; ! 546: } ! 547: ! 548: /* ! 549: * Localize for each newsgroup and broadcast. ! 550: */ ! 551: insert() ! 552: { ! 553: register char *ptr; ! 554: register FILE *tfp; ! 555: int badgroup = 0, goodgroup = 0; ! 556: ! 557: /* Fill up the rest of header. */ ! 558: if (mode != PROC) { ! 559: history(&header); ! 560: } ! 561: dates(&header); ! 562: addhist(header.recdate); ! 563: addhist("\t"); ! 564: log("%s %s ng %s subj '%s'", mode==PROC ? "received" : "posted", header.ident, header.nbuf, header.title); ! 565: if (mode==PROC) ! 566: log("from %s relay %s", header.from, header.relayversion); ! 567: ! 568: /* Write article to temp file. */ ! 569: tfp = xfopen(mktemp(ARTICLE), "w"); ! 570: lhwrite(&header, tfp); ! 571: while (fgets(bfr, BUFLEN, infp) != NULL) { ! 572: /* ! 573: if (!strncmp(bfr, "From ", 5)) ! 574: putc('>', tfp); ! 575: */ ! 576: fputs(bfr, tfp); ! 577: } ! 578: fclose(tfp); ! 579: fclose(infp); ! 580: ! 581: if (is_ctl) { ! 582: control(&header); ! 583: goodgroup++; ! 584: if (!localize("control")) { ! 585: sprintf(bfr, "%s/%s", SPOOL, "control"); ! 586: mknewsg(bfr, "control"); ! 587: if (!localize("control")) { ! 588: tfp = mailhdr(NULL, "No control newsgroup"); ! 589: if (tfp) { ! 590: fprintf(tfp, "Can't create newsgroup 'control'.\n"); ! 591: mclose(tfp); ! 592: } ! 593: } ! 594: } ! 595: } else { ! 596: for (ptr = nbuf; *ptr;) { ! 597: if (*ptr == '-') { ! 598: while (*ptr++) ! 599: ; ! 600: continue; ! 601: } ! 602: strcpy(bfr, dirname(ptr)); ! 603: if (!exists(bfr)) { ! 604: #ifdef AUTONEWNG ! 605: mknewsg(bfr, ptr); ! 606: #else ! 607: getapproval(ptr); ! 608: badgroup++; ! 609: #endif ! 610: } ! 611: else ! 612: goodgroup++; ! 613: if (*nbuf) ! 614: localize(ptr); ! 615: while (*ptr++) ! 616: ; ! 617: } ! 618: } ! 619: ! 620: #ifdef NOFORWARD ! 621: if (*nbuf) ! 622: #endif ! 623: if (goodgroup) ! 624: broadcast(); ! 625: savehist(); ! 626: xxit(0); ! 627: } ! 628: ! 629: input() ! 630: { ! 631: register int empty = TRUE; ! 632: register char *cp; ! 633: int c; ! 634: long chcount = 0; ! 635: FILE *tmpfp; ! 636: int consec_newlines = 0; ! 637: int linecount = 0; ! 638: ! 639: tmpfp = xfopen(mktemp(INFILE), "w"); ! 640: if (*filename) { ! 641: tty = FALSE; ! 642: infp = xfopen(filename, "r"); ! 643: } else { ! 644: infp = stdin; ! 645: } ! 646: while (!sigtrap && fgets(bfr, BUFLEN, stdin) != NULL) { ! 647: if (mode == PROC) /* zap trailing empty lines */ ! 648: { ! 649: if (bfr[0] == '\n') /* 1 empty line, to go */ ! 650: { ! 651: consec_newlines++; /* count it, in case */ ! 652: continue; /* but don't write it*/ ! 653: } ! 654: /* foo! a non-empty line. write out all saved lines. */ ! 655: while (consec_newlines > 0) ! 656: { ! 657: putc('\n', tmpfp); ! 658: consec_newlines--; ! 659: linecount++; ! 660: } ! 661: } ! 662: if (mode != PROC && tty && strcmp(bfr, ".\n") == 0) ! 663: break; ! 664: for (cp = bfr; c = *cp; cp++) { ! 665: if (isprint(c) || isspace(c) || c=='\b') ! 666: putc(c, tmpfp); ! 667: if (isprint(c)) ! 668: chcount++; ! 669: if (c == '\n') ! 670: linecount++; ! 671: } ! 672: empty = FALSE; ! 673: } ! 674: if (*filename) ! 675: fclose(infp); ! 676: ! 677: sprintf(bfr, "%s/%s", getenv("HOME"), ".signature"); ! 678: if (mode != PROC && (infp = fopen(bfr, "r"))) { ! 679: fprintf(tmpfp, "-- \n"); /* To separate */ ! 680: linecount++; ! 681: while ((c = getc(infp)) != EOF) { ! 682: putc(c, tmpfp); ! 683: if (c == '\n') ! 684: linecount++; ! 685: } ! 686: fclose(infp); ! 687: } ! 688: ! 689: fclose(tmpfp); ! 690: if (sigtrap) { ! 691: if (tty) ! 692: printf("Interrupt\n"); ! 693: if (tty && !empty) ! 694: fwait(fsubr(newssave, (char *) NULL, (char *) NULL)); ! 695: if (!tty) ! 696: log("Blown away by an interrupt %d", sigtrap); ! 697: xxit(1); ! 698: } ! 699: if (tty) ! 700: printf("EOT\n"); ! 701: fflush(stdout); ! 702: infp = fopen(INFILE, "r"); ! 703: if (chcount < 5 && mode <= UNPROC && !is_ctl) ! 704: xerror("You didn't really want to post THAT!"); ! 705: if (header.numlines[0]) { ! 706: /* ! 707: * Check line count if there's already one attached to ! 708: * the article. Could make this a fatal error - ! 709: * throwing it away if it got chopped, in hopes that ! 710: * another copy will come in later with a correct ! 711: * line count. But that seems a bit much for now. ! 712: */ ! 713: if (linecount != header.intnumlines) ! 714: log("linecount expected %d, got %d\n", header.intnumlines, linecount); ! 715: } else { ! 716: /* Attach a line count to the article. */ ! 717: header.intnumlines = linecount; ! 718: sprintf(header.numlines, "%d", linecount); ! 719: } ! 720: } ! 721: ! 722: /* ! 723: * Make the directory for a new newsgroup. ngname should be the ! 724: * full pathname of the directory. Do the other stuff too. ! 725: * The various games with setuid and chown are to try to make sure ! 726: * the directory is owned by NEWSUSR and NEWSGRP, which is tough to ! 727: * do if you aren't root. This will work on a UCB system (which allows ! 728: * setuid(geteuid()) or a USG system (which allows you to give away files ! 729: * you own with chown), otherwise you have to change your kernel to allow ! 730: * one of these things or run with your dirs 777 so that it doesn't matter ! 731: * who owns them. ! 732: */ ! 733: mknewsg(fulldir, ngname) ! 734: char *fulldir; ! 735: char *ngname; ! 736: { ! 737: int pid; ! 738: register char *p; ! 739: char sysbuf[200]; ! 740: char parent[200]; ! 741: struct stat sbuf; ! 742: ! 743: if (ngname == NULL || !isalpha(ngname[0])) ! 744: xerror("Tried to make illegal newsgroup %s", ngname); ! 745: ! 746: /* ! 747: * If the parent is 755 and we're on a USG system, the setuid(getuid) ! 748: * will fail, and since mkdir is suid, and our real uid is random, ! 749: * the mkdir will fail. So we have to temporarily chmod it to 755. ! 750: */ ! 751: strcpy(parent, fulldir); ! 752: p = rindex(parent, '/'); ! 753: if (p) ! 754: *p = '\0'; ! 755: if (stat(parent, &sbuf) < 0) ! 756: sbuf.st_mode = 0777; ! 757: chmod(parent, 0777); ! 758: ! 759: if ((pid = fork()) <= 0) { ! 760: if (setuid(geteuid())) /* This fails on some systems, but ! 761: * works on 4BSD, and 2BSD. */ ! 762: #ifndef USG ! 763: umask(0) ! 764: #endif ! 765: ; ! 766: setgid(getegid()); ! 767: /* Create the directory */ ! 768: mkparents(fulldir); ! 769: sprintf(sysbuf, "mkdir %s", fulldir); ! 770: exit(system(sysbuf)); ! 771: } else if (fwait(pid)) { ! 772: sprintf(sysbuf, "Cannot mkdir %s", fulldir); ! 773: xerror(sysbuf); ! 774: } ! 775: ! 776: chmod(parent, sbuf.st_mode); /* put is back */ ! 777: ! 778: #ifdef USG ! 779: # ifndef CHEAP ! 780: /* ! 781: * Give away the files we just created, which were assigned to our ! 782: * REAL uid. This only works on USG systems. It is an alternative ! 783: * to the setuid call above. The directories we just made are owned ! 784: * by our real uid, so we have to temporarily set our effective uid ! 785: * the same to allow the chown. Fortunately, USG lets us setuid back. ! 786: */ ! 787: setuid(getuid()); ! 788: chown(fulldir, duid, dgid); ! 789: setuid(duid); ! 790: # endif ! 791: #endif ! 792: ! 793: /* Update the "active newsgroup" file. */ ! 794: if (ngname && *ngname) { ! 795: actfp = xfopen(ACTIVE, "a"); ! 796: fprintf(actfp, "%s 00000\n", ngname); ! 797: fclose(actfp); ! 798: } ! 799: ! 800: log("make newsgroup %s in dir %s", ngname, fulldir); ! 801: } ! 802: ! 803: /* ! 804: * If any parent directories of this dir don't exist, create them. ! 805: */ ! 806: mkparents(dirname) ! 807: char *dirname; ! 808: { ! 809: char buf[200], sysbuf[200]; ! 810: register char *p; ! 811: ! 812: strcpy(buf, dirname); ! 813: p = rindex(buf, '/'); ! 814: if (p) ! 815: *p = '\0'; ! 816: if (exists(buf)) ! 817: return; ! 818: mkparents(buf); ! 819: sprintf(sysbuf, "mkdir %s", buf); ! 820: system(sysbuf); ! 821: } ! 822: ! 823: cancel() ! 824: { ! 825: register FILE *fp; ! 826: ! 827: log("cancel article %s", filename); ! 828: fp = xfopen(filename, "r"); ! 829: if (hread(&header, fp, TRUE) == NULL) ! 830: xerror("Article is garbled.\n"); ! 831: fclose(fp); ! 832: unlink(filename); ! 833: } ! 834: ! 835: /* ! 836: * An article has come in that isn't in a newsgroup we know about. ! 837: * Stash it in the junk directory and notify the local contact person. ! 838: * Note that such articles are NOT broadcast to our neighbors, on the ! 839: * assumption that they are a typographical error. We only keep them ! 840: * here because we might be a new site. ! 841: */ ! 842: getapproval(ng) ! 843: char *ng; ! 844: { ! 845: FILE *fd; ! 846: ! 847: if (localize("junk")) ! 848: return; ! 849: ! 850: sprintf(bfr, "%s/%s", SPOOL, "junk"); ! 851: mknewsg(bfr, "junk"); ! 852: if (localize("junk")) ! 853: return; ! 854: ! 855: fd = mailhdr(NULL, "Strange Newsgroup Received"); ! 856: if (fd != NULL) { ! 857: fprintf(fd, "\nNewsgroup '%s' has been posted to\nby %s.\n\n", ! 858: ng, header.from[0] ? header.from : header.path); ! 859: fprintf(fd, "I was unable to save it in the newsgroup 'junk'\n"); ! 860: fprintf(fd, "I was also unable to create the newsgroup 'junk'\n"); ! 861: mclose(fd); ! 862: } ! 863: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.