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