![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to newsinput.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDTahoe / new / notes / src|
Return to newsinput.c CVS log | Up to [CSRG BSD Unix] / 43BSDTahoe / new / notes / src |
1.1 ! root 1: #define MAINLINE ! 2: #include "parms.h" ! 3: #include "structs.h" ! 4: #include "newsgate.h" ! 5: ! 6: #ifdef RCSIDENT ! 7: static char rcsid[] = "$Header: newsinput.c,v 1.7.0.6 85/10/01 23:06:08 notes Rel $"; ! 8: #endif RCSIDENT ! 9: ! 10: /* ! 11: * newsinput ! 12: * ! 13: * A total re-coding of the original. Makes use of the ! 14: * work that Lou Salkind and Tw Cook have done. Lou rearranged ! 15: * a bunch of stuff and Tw put the notes headers into the ! 16: * news header. ! 17: */ ! 18: ! 19: static char title[TITLEN + 1]; /* hold titles */ ! 20: extern char fromsys[SYSSZ + 1]; /* gave it to us */ ! 21: static struct when_f entered; /* date written */ ! 22: extern char origsys[SYSSZ + 1]; /* originator */ ! 23: extern char authname[NAMESZ + 1]; /* author */ ! 24: static int has_suffix = 0; /* had -(nf) suffix */ ! 25: ! 26: #define dprintf if (0) printf ! 27: ! 28: ! 29: main (argc, argv) ! 30: int argc; ! 31: char **argv; ! 32: { ! 33: FILE * rawnews; ! 34: FILE * body; ! 35: char pathname[BUFSIZ]; ! 36: struct io_f io; ! 37: struct hbuf header; ! 38: char nf[WDLEN]; ! 39: struct nflist_f *nfptr; /* expand newsgroups */ ! 40: int c; ! 41: int onechar; ! 42: char *tail; ! 43: int fid; /* for close */ ! 44: ! 45: ! 46: setuid (geteuid ()); /* force to "notes" */ ! 47: startup (argc, argv); /* comon init */ ! 48: rawnews = stdin; /* usually here */ ! 49: for (fid = 3; fid < 20; fid++) /* close all extras */ ! 50: close (fid); ! 51: ! 52: /* ! 53: * Parse the Header. Follow all the USENET standards ! 54: * for doing this. Result is left in a fun little ! 55: * structure. ! 56: * Internalize some of the information to help us figure out ! 57: * some things quickly. ! 58: */ ! 59: ! 60: if (!newsheader (&header, rawnews, TRUE)) /* read the headers */ ! 61: { ! 62: printf ("Incoming News mangled more than usual\n"); ! 63: exit (BAD); ! 64: } ! 65: ! 66: /* ! 67: * Parse things like origsys, fromsys, author, date written ! 68: */ ! 69: parsepath (header.path, header.from); /* systems, authors */ ! 70: parsetime (header.subdate, &entered); /* submitted */ ! 71: sprintf (pathname, "/tmp/nfxx%d", getpid ()); ! 72: dprintf ("Origsys: %s\n", origsys); ! 73: dprintf ("fromsys: %s\n", fromsys); ! 74: dprintf ("Date Written:"); ! 75: #ifdef notdef ! 76: prdate (&entered); ! 77: #endif ! 78: dprintf ("\nauthor: %s\n", authname); ! 79: /* ! 80: * See if this might be a control message. Notes readers don't ! 81: * care to see these. ! 82: * ! 83: * News code also recognizes titles with first 5 characters set ! 84: * to "cmsg " as control messages. We should clean them up too. ! 85: */ ! 86: if (header.ctlmsg[0] != '\0') /* is control */ ! 87: { ! 88: printf ("Control message (ignored): %s\n", header.ctlmsg); ! 89: exit (0); /* "success" */ ! 90: } ! 91: /* ! 92: * Save the body of the article somewhere safe (like not in ! 93: * memory). ! 94: */ ! 95: if ((body = fopen (pathname, "w")) == NULL) /* failed */ ! 96: { ! 97: printf ("Had problems creating/opening file %s\n", pathname); ! 98: exit (BAD); /* die */ ! 99: } ! 100: while ((onechar = getc (rawnews)) != EOF) /* save it */ ! 101: putc (onechar, body); ! 102: fflush (body); /* make sure */ ! 103: fclose (body); /* and close it */ ! 104: ! 105: /* ! 106: * Now run through the specified list of newsgroups, ! 107: * re-scan the body and such each time. ! 108: */ ! 109: ! 110: expand (header.nbuf); /* expand groups */ ! 111: while ((nfptr = nextgroup ()) != (struct nflist_f *) NULL) ! 112: { ! 113: ! 114: newsgroup (nfptr -> nf_name, nf, NEWSNF); /* map it */ ! 115: dprintf ("Newsgroup %s maps to notesfile %s\n", nfptr -> nf_name, nf); ! 116: tail = rindex (nfptr -> nf_name, '.'); /* catch ctl msgs */ ! 117: if (tail != (char *) NULL && !strcmp (tail, CTL))/* it is one */ ! 118: { ! 119: char pbuf[256]; /* for title fixing */ ! 120: ! 121: strcpy (nf, NFMAINT); /* map it */ ! 122: dprintf ("Control newsgroup %s mapped to %s\n", ! 123: nfptr -> nf_name, nf); ! 124: sprintf (pbuf, "%s:%s", nfptr -> nf_name, header.title); ! 125: strncpy (header.title, pbuf, BUFLEN); /* prefix title */ ! 126: header.title[BUFLEN - 1] = '\0'; /* ensure terminater */ ! 127: } ! 128: ! 129: if ((body = fopen (pathname, "r")) == NULL) ! 130: { ! 131: goto failed; /* shit */ ! 132: } ! 133: if (init (&io, nf) < 0) /* open the nf */ ! 134: { ! 135: char pbuf[512]; ! 136: char tbuf[128]; ! 137: #ifdef AUTOCREATE ! 138: sprintf (pbuf, ! 139: "Notesfile: %s\nNewsgroup: %s\n\nCreated by newsinput\n", ! 140: nf, nfptr -> nf_name); ! 141: sprintf (tbuf, "New NF: %s", nf); ! 142: nfcomment (NFMAINT, pbuf, tbuf, TRUE, 0); ! 143: buildnf (nf, Mstdir, 0, 1, 1); /* open and networked */ ! 144: x (init (&io, nf) < 0, "newsinput: open newly created notesfile"); ! 145: #else ! 146: sprintf (pbuf, "Notesfile: %s, newsgroup %s\n", ! 147: nf, nfptr -> nf_name); ! 148: sprintf (tbuf, "New newsgroup %s", nfptr -> nf_name); ! 149: nfcomment (NFMAINT, pbuf, tbuf, 0, 0); ! 150: printf ("Inserting into %s\n", NEWNEWS); ! 151: strcpy (nf, NEWNEWS); /* Change newsgroup */ ! 152: if (init (&io, nf) < 0) ! 153: exit (BAD); /* Give up */ ! 154: printf ("Open of %s suceeded\n", nf); ! 155: #endif AUTOCREATE ! 156: } ! 157: ! 158: if (nfgen (&io, &header, body, pathname) < 0) /* not from notes */ ! 159: { ! 160: dprintf ("Nfgen returns failure\n"); ! 161: fclose (body); /* give bnewsgen */ ! 162: body = fopen (pathname, "r"); /* a clean copy */ ! 163: if (bnewsgen (&io, &header, body) < 0) /* or news */ ! 164: { ! 165: dprintf ("bnewsgen returns failure\n"); ! 166: goto failed; /* drop out */ ! 167: } ! 168: } ! 169: fclose (body); /* ready for loop */ ! 170: finish (&io); ! 171: } ! 172: ! 173: unlink (pathname); ! 174: exit (GOOD); ! 175: ! 176: /* ! 177: * jump here on totally screwed up article. ! 178: */ ! 179: failed: ! 180: dprintf ("Jumped to failed\n"); ! 181: unlink (pathname); /* body of article */ ! 182: exit (BAD); ! 183: } ! 184: ! 185: /* ! 186: * nfgen(&io,&header,&FILE,pathname) ! 187: * ! 188: * parse a notesfile-generated article. Check the fields of ! 189: * header and look for # lines in the body of the article to ! 190: * determine if it came from notes. ! 191: * ! 192: * returns: 0 no permission for author ! 193: * > 0 signifies note or response where it wound up ! 194: * -1 if the article wasn't generated by notes ! 195: */ ! 196: ! 197: nfgen (io, header, body, pathname) ! 198: struct io_f *io; ! 199: struct hbuf *header; ! 200: FILE * body; ! 201: char *pathname; ! 202: { ! 203: register int i; ! 204: register char *p; ! 205: struct note_f note; ! 206: struct note_f note2; ! 207: struct id_f respid; ! 208: struct daddr_f where; ! 209: struct when_f whentime; ! 210: struct auth_f auth; /* author */ ! 211: int oldstyle = 0; ! 212: int found; ! 213: char line[CMDLEN]; /* scratch */ ! 214: char *suffix; ! 215: int notenum; ! 216: int status; ! 217: int fosterstat; /* for foster parents */ ! 218: int count; ! 219: char hline1[BUFLEN]; /* in-text header */ ! 220: char hline2[BUFLEN]; /* in-text header 2 */ ! 221: int onechar; /* scratch character */ ! 222: char field1[100], /* scanf tmps */ ! 223: field2[100]; ! 224: ! 225: /* ! 226: * Check for titles ending in "- nf". ! 227: * We always remove these. ! 228: */ ! 229: suffix = rindex (header -> title, '-'); /* find last */ ! 230: if (!strcmp (suffix, NFSUFFIX) || !strcmp (suffix, OLDSUFFIX)) ! 231: { ! 232: if (--suffix > header -> title) /* if we can */ ! 233: *suffix = '\0'; /* strip "- (nf)" */ ! 234: has_suffix++; /* flag it */ ! 235: } ! 236: /* ! 237: * at this point we should check for embodied #N.... lines and ! 238: * remove them. This is conditional on having a "- (nf)" in the ! 239: * title of the note. ! 240: */ ! 241: ! 242: strcpy (hline1, ""); /* empty these */ ! 243: strcpy (hline2, ""); ! 244: if (has_suffix) /* look for embedded */ ! 245: { ! 246: long position, /* place marker */ ! 247: ftell (); /* for types */ ! 248: ! 249: position = ftell (body); /* save it */ ! 250: while (fgets (hline1, sizeof hline1, body) != NULL) ! 251: if (hline1[0] == '#') ! 252: break; /* found one */ ! 253: if (hline1[0] != '#') /* actually didn't */ ! 254: { ! 255: fseek (body, position, 0); /* rewind */ ! 256: strcpy (hline1, ""); /* empty it */ ! 257: } ! 258: else ! 259: { /* grab line 2 */ ! 260: fgets (hline2, sizeof hline2, body); ! 261: while ((onechar = getc (body)) != '\n' && onechar != EOF) ! 262: ; /* zap separator line */ ! 263: } ! 264: } ! 265: ! 266: if (strlen (header -> nline1) == 0) /* no new headers */ ! 267: { ! 268: /* ! 269: * No notes header in the B news article header... ! 270: * If title ends with "- nf", look for the ! 271: * header in the body of the text. ! 272: * (for backwards compatability) ! 273: */ ! 274: if (has_suffix == 0) /* not from notes */ ! 275: { ! 276: dprintf ("No NFSUFFIX and no header lines\n"); ! 277: return (-1); ! 278: } ! 279: oldstyle = 1; ! 280: found = 0; ! 281: if (hline1[0] == '#') /* got them earlier */ ! 282: { ! 283: strcpy (header -> nline1, hline1); /* first line */ ! 284: strcpy (header -> nline2, hline2); /* second line */ ! 285: found++; /* and mark it */ ! 286: } ! 287: while (!found && /* search body */ ! 288: fgets (header -> nline1, sizeof header -> nline1, body)) ! 289: { ! 290: if (header -> nline1[0] == '#') /* bingo */ ! 291: { ! 292: found++; ! 293: break; ! 294: } ! 295: } ! 296: if (!found || ! 297: fgets (header -> nline2, sizeof header -> nline2, body) == NULL) ! 298: { ! 299: dprintf ("no header lines in text body\n"); ! 300: return (-1); /* not from notes */ ! 301: } ! 302: } ! 303: ! 304: /* ! 305: * We now have the header lines. ! 306: * Check validity and do the appropriate action. ! 307: */ ! 308: if (header -> nline1[0] != '#') ! 309: { ! 310: dprintf ("Invalid first header line\n"); ! 311: return (-1); ! 312: } ! 313: dprintf ("First line is: %s\n", header -> nline1); ! 314: dprintf ("Second line is: %s\n", header -> nline2); ! 315: strncpy (title, header -> title, TITLEN); /* get title */ ! 316: title[TITLEN - 1] = '\0'; /* terminate for sure */ ! 317: ! 318: switch (header -> nline1[1]) /* parse it */ ! 319: { ! 320: case 'N': /* base note */ ! 321: if (sscanf (header -> nline1, "#N:%99[^:]:%ld:%o:%d", field1, ! 322: ¬e.n_id.uniqid, &status, &count) != 4) ! 323: { ! 324: return (-1); /* no good */ ! 325: } ! 326: strncpy (note.n_id.sys, field1, SYSSZ); /* copy */ ! 327: note.n_id.sys[SYSSZ - 1] = '\0'; /* and terminate */ ! 328: status |= FRMNEWS; /* it's been there */ ! 329: ! 330: /* ! 331: * parse the second header line ! 332: */ ! 333: ! 334: p = header -> nline2; ! 335: for (i = 0; (i < HOMESYSSZ - 1) && (*p != '!' && *p != '\0'); i++) ! 336: auth.asystem[i] = *p++; /* get the author */ ! 337: auth.asystem[i] = '\0'; /* terminate */ ! 338: while (*p != '!' && *p != '\0') ! 339: p++; /* skip to end of system */ ! 340: if (*p == '!') ! 341: p++; /* skip the ! */ ! 342: for (i = 0; (i < NAMESZ - 1) && (*p != ' ' && *p != '\0'); i++) ! 343: auth.aname[i] = *p++; /* get the author */ ! 344: auth.aname[i] = '\0'; /* terminate */ ! 345: auth.aid = Anonuid; ! 346: ! 347: while (*p != ' ' && *p) ! 348: p++; /* drop rest of author */ ! 349: while (*p == ' ') /* find the date */ ! 350: p++; ! 351: parsetime (p, ¬e.n_date); /* and parse it */ ! 352: ! 353: getperms (io, 1, note.n_id.sys); /* check permissions */ ! 354: if (allow (io, WRITOK) == 0) /* not a chance */ ! 355: return (0); /* sort of success */ ! 356: ! 357: locknf (io, DSCRLOCK); /* MUTEX */ ! 358: if ((notenum = chknote (io, ¬e.n_id, ¬e2)) == 0) ! 359: { /* not in data base */ ! 360: pagein (io, body, &where); /* grab text */ ! 361: status |= FRMNEWS; /* through news */ ! 362: strcpy (note.n_from, fromsys); /* who gave it to us */ ! 363: i = putnote (io, &where, title, status, ¬e, &auth, ! 364: NOPOLICY, NOLOCKIT, NOADDID, fromsys, ADDTIME); ! 365: io -> nnotrcvd++; /* count it */ ! 366: unlocknf (io, DSCRLOCK); /* MUTEX done */ ! 367: return (i); /* return notenum */ ! 368: } ! 369: if ((note2.n_stat & ORPHND) && (status & ORPHND) == 0) ! 370: { /* replace foster */ ! 371: /* with true parent */ ! 372: pagein (io, body, ¬e2.n_addr); /* the text */ ! 373: gettime (¬e2.n_rcvd); /* update timestamp */ ! 374: gettime (¬e2.n_lmod); /* time stamp it */ ! 375: copyauth (&auth, ¬e2.n_auth); /* correct author */ ! 376: note2.n_stat = status | FRMNEWS; /* and status bits */ ! 377: strncpy (note2.ntitle, title, TITLEN); ! 378: note2.n_date = entered; ! 379: strcpy (note2.n_from, fromsys); ! 380: putnrec (io, notenum, ¬e2); /* and replace */ ! 381: io -> adopted++; /* count adoption */ ! 382: io -> nnotrcvd++; /* count in */ ! 383: unlocknf (io, DSCRLOCK); ! 384: printf ("Orphaned response chain adopted\n"); ! 385: return (notenum); /* note number */ ! 386: } ! 387: else ! 388: printf ("Duplicate note handed back by news\n"); ! 389: unlocknf (io, DSCRLOCK); ! 390: return (0); /* mark resolved */ ! 391: ! 392: case 'R': /* response */ ! 393: if (sscanf (header -> nline1, "#R:%99[^:]:%ld:%99[^:]:%ld:%o:%d", ! 394: field1, ¬e.n_id.uniqid, field2, ! 395: &respid.uniqid, &status, &count) != 6) ! 396: { ! 397: return (-1); /* no good */ ! 398: } ! 399: strncpy (note.n_id.sys, field1, SYSSZ); /* copy them */ ! 400: strncpy (respid.sys, field2, SYSSZ); /* both and */ ! 401: note.n_id.sys[SYSSZ - 1] = respid.sys[SYSSZ - 1] = '\0';/* stop */ ! 402: status |= FRMNEWS; /* it's been there */ ! 403: ! 404: getperms (io, 1, respid.sys); /* check modes */ ! 405: if (allow (io, RESPOK) == 0) /* not a chance */ ! 406: return (0); /* resolved */ ! 407: ! 408: p = header -> nline2; /* second line */ ! 409: for (i = 0; (i < HOMESYSSZ - 1) && (*p != '!' && *p != '\0'); i++) ! 410: auth.asystem[i] = *p++; /* get the author */ ! 411: auth.asystem[i] = '\0'; /* terminate */ ! 412: while (*p != '!' && *p != '\0') ! 413: p++; /* skip to end of system */ ! 414: if (*p == '!') ! 415: p++; /* skip the ! */ ! 416: for (i = 0; (i < NAMESZ - 1) && (*p != ' ' && *p != '\0'); i++) ! 417: auth.aname[i] = *p++; /* parse author */ ! 418: auth.aname[i] = '\0'; /* terminate */ ! 419: auth.aid = Anonuid; /* default */ ! 420: while (*p != ' ' && *p) ! 421: p++; /* rest of author */ ! 422: while (*p == ' ') /* find the date */ ! 423: p++; ! 424: parsetime (p, &entered); /* and parse it */ ! 425: ! 426: locknf (io, DSCRLOCK); /* MUTEX */ ! 427: notenum = chknote (io, ¬e.n_id, ¬e2); ! 428: if (notenum == 0) /* found parent? */ ! 429: { /* build foster */ ! 430: printf ("Orphaned response handed in by news\n"); ! 431: strcpy (note.n_from, fromsys); /* make basic info */ ! 432: note.n_nresp = 0; ! 433: note.n_auth.aid = Anonuid; ! 434: strcpy (note.n_auth.aname, "Unknown"); ! 435: strcpy (note.n_auth.asystem, note.n_id.sys);/* system */ ! 436: note.n_date = entered; ! 437: gettime (&whentime); /* current time */ ! 438: fosterstat = ORPHND | FRMNEWS; /* combo there */ ! 439: #ifdef notdef ! 440: strcpy (note.ntitle, "(Orphan) "); /* prefix */ ! 441: #else ! 442: strcpy (note.ntitle, ""); /* empty */ ! 443: #endif ! 444: i = strlen (note.ntitle); /* index */ ! 445: for (p = header -> title; i < TITLEN && *p; i++, p++)/* rest of title */ ! 446: note.ntitle[i] = *p; /* basic title */ ! 447: if (i < TITLEN) ! 448: note.ntitle[i] = '\0'; /* null it */ ! 449: else ! 450: note.ntitle[TITLEN - 1] = '\0'; /* null */ ! 451: where.addr = 0; /* no text */ ! 452: where.textlen = 0; /* still no text */ ! 453: notenum = putnote (io, &where, note.ntitle, fosterstat, ! 454: ¬e, ¬e.n_auth, NOPOLICY, NOLOCKIT, NOADDID, ! 455: fromsys, ADDTIME); /* insert him */ ! 456: io -> norphans++; /* orphan census */ ! 457: getnrec (io, notenum, ¬e2); /* get good one */ ! 458: } ! 459: /* ! 460: * At this point we know we have a parent because if there wasn't ! 461: * one before, we built a foster parent. ! 462: */ ! 463: if (chkresp (io, &respid, ¬e2, notenum) == 0) ! 464: { /* none, insert it */ ! 465: status |= FRMNEWS; ! 466: pagein (io, body, &where); ! 467: i = putresp (io, &where, status, notenum, &entered, &auth, ! 468: ¬e, NOLOCKIT, &respid, NOADDID, fromsys, ! 469: ADDTIME, &whentime); ! 470: io -> nrsprcvd++; /* count him in */ ! 471: unlocknf (io, DSCRLOCK); /* UNMUTEX */ ! 472: return (i); /* resp number */ ! 473: } ! 474: else ! 475: printf ("Duplicate response handed back by news\n"); ! 476: unlocknf (io, DSCRLOCK); ! 477: return (0); /* resolved */ ! 478: ! 479: default: /* bad news */ ! 480: return (-1); ! 481: } /* NOTREACHED */ ! 482: return (0); ! 483: } ! 484: ! 485: /* ! 486: * bnewsgen(&io,&header,&FILE) ! 487: * ! 488: * parse an article that came through B-news. We've already ! 489: * checked to see if it was a notesfile generated article ! 490: * so all we have to do is decide if it's a note/response ! 491: * and put it in the appropriate place. ! 492: */ ! 493: ! 494: bnewsgen (io, header, body) ! 495: struct io_f *io; ! 496: struct hbuf *header; ! 497: FILE * body; ! 498: { ! 499: register int i; ! 500: char *p; ! 501: struct note_f note; ! 502: struct note_f note2; ! 503: struct when_f whentime; ! 504: struct daddr_f where; ! 505: int notenum; ! 506: int status; ! 507: char pbuf[BUFLEN]; /* scratch */ ! 508: long newsseq; ! 509: char newssys[SYSSZ]; ! 510: struct id_f newsid; ! 511: struct auth_f auth; ! 512: char *lead, ! 513: *trail; /* references */ ! 514: char basesys[SYSSZ]; /* references */ ! 515: long baseseq; /* ditto */ ! 516: struct id_f baseid; /* ditto ditto */ ! 517: char field1[100], /* scanf tmps */ ! 518: field2[100]; ! 519: ! 520: getperms (io, 1, origsys); ! 521: if (allow (io, WRITOK) == 0) /* let him* */ ! 522: { ! 523: printf ("System %s not allowed to write notes\n", origsys); ! 524: return (0); /* NO! */ ! 525: } ! 526: ! 527: i = sscanf (header -> ident, "<%ld@%99[^>]>", &newsseq, field1, pbuf); ! 528: if (i < 2) /* try old */ ! 529: { ! 530: i = sscanf (header -> ident, "%99[^.].%ld", field1, &newsseq); ! 531: } ! 532: if (i < 2) /* no id */ ! 533: { ! 534: #ifdef NFMAINT ! 535: char pbuf[BUFSIZ]; ! 536: ! 537: sprintf (pbuf, ! 538: "Message-ID: %s\nPath: %s\nFrom: %s\nNewsgroups: %s\n", ! 539: header -> ident, header -> path, ! 540: header -> from, header -> nbuf); ! 541: nfcomment (NFMAINT, pbuf, "Unfathomable Article ID", 0, 0); ! 542: #endif NFMAINT ! 543: dprintf ("can't fathom article ID: %s\n", header -> ident); ! 544: return (-1); /* mark bogus */ ! 545: } ! 546: strncpy (newssys, field1, SYSSZ); /* copy */ ! 547: newssys[SYSSZ - 1] = '\0'; /* and truncate */ ! 548: ! 549: note.n_date = entered; ! 550: strcpy (note.n_from, fromsys); ! 551: strncpy (auth.aname, authname, NAMESZ); /* fill in author */ ! 552: strncpy (auth.asystem, origsys, HOMESYSSZ); /* system */ ! 553: auth.asystem[HOMESYSSZ - 1] = auth.aname[NAMESZ - 1] = '\0'; ! 554: auth.aid = Anonuid; ! 555: status = FRMNEWS; /* came through news */ ! 556: strncpy (title, header -> title, TITLEN); /* move new title */ ! 557: title[TITLEN - 1] = '\0'; /* sure it stops */ ! 558: ! 559: locknf (io, DSCRLOCK); /* MUTEX */ ! 560: /* ! 561: * first thing is to see if it's a base note somewhere. ! 562: */ ! 563: strcpy (newsid.sys, newssys); /* build uniq id */ ! 564: strcpy (note.n_id.sys, newssys); /* build descriptor */ ! 565: note.n_id.uniqid = newsid.uniqid = newsseq; ! 566: notenum = chknote (io, ¬e.n_id, ¬e2); /* try normal */ ! 567: if (notenum == 0) /* try -100 trick */ ! 568: { ! 569: note.n_id.uniqid = newsid.uniqid = newsseq * -100; ! 570: notenum = chknote (io, ¬e.n_id, ¬e2); ! 571: } ! 572: if (notenum != 0) ! 573: { ! 574: if (!(note2.n_stat & ORPHND)) ! 575: { ! 576: printf ("Duplicate news article received\n"); ! 577: io -> nnotdrop++; /* count as dropped */ ! 578: unlocknf (io, DSCRLOCK); ! 579: return (0); /* done with it */ ! 580: } ! 581: /* ! 582: * replace foster parent ! 583: */ ! 584: pagein (io, body, ¬e2.n_addr); /* collect text */ ! 585: gettime (¬e2.n_rcvd); /* current tod */ ! 586: gettime (¬e2.n_lmod); /* last touched */ ! 587: copyauth (&auth, note2.n_auth); /* fill in author */ ! 588: note2.n_stat |= FRMNEWS; /* brand it */ ! 589: strncpy (note2.ntitle, title, TITLEN); /* move title */ ! 590: note2.n_date = entered; ! 591: strcpy (note2.n_from, fromsys); /* who sent it to us */ ! 592: putnrec (io, notenum, ¬e2); /* and replace */ ! 593: io -> adopted++; /* count it */ ! 594: io -> nnotrcvd++; /* count in */ ! 595: unlocknf (io, DSCRLOCK); ! 596: printf ("Orphaned Response Chain adopted\n"); ! 597: return (notenum); /* correctly placed */ ! 598: } ! 599: ! 600: /* ! 601: * See if we can turn this into a response to some base note. ! 602: * First priority is to match it to any of the articles listed ! 603: * in a References field if there is one. ! 604: */ ! 605: ! 606: notenum = 0; /* init to not found */ ! 607: if (header -> followid[0]) /* references */ ! 608: { ! 609: trail = header -> followid; ! 610: while ((lead = index (trail, '<')) && (trail = index (lead, '>'))) ! 611: { /* delimited id */ ! 612: i = sscanf (lead, "<%ld@%99[^>]>", &baseseq, field1, pbuf); ! 613: if (i < 2) /* try old format */ ! 614: i = sscanf (lead, "%99[^.].%ld", field1, &baseseq); ! 615: if (i < 2) ! 616: continue; /* try next one */ ! 617: strncpy (basesys, field1, SYSSZ); ! 618: basesys[SYSSZ - 1] = '\0'; /* and truncate */ ! 619: ! 620: strcpy (baseid.sys, basesys); /* build goal */ ! 621: baseid.uniqid = baseseq; /* try notes source */ ! 622: if ((notenum = chknote (io, &baseid, ¬e2)))/* WANT ASSIGN */ ! 623: break; /* yes! */ ! 624: ! 625: baseid.uniqid = baseseq * -100; /* try news source */ ! 626: if ((notenum = chknote (io, &baseid, ¬e2)))/* WANT ASSIGN */ ! 627: break; /* yes! */ ! 628: ! 629: notenum = 0; /* ensure "unfound" */ ! 630: } ! 631: } ! 632: ! 633: /* ! 634: * If References did any good, "notenum" is positive non-zero. ! 635: * Otherwise it didn't help out at all and we have to resort to ! 636: * parsing the title for "re:" prefixes ! 637: * If we can find a base title, use the title search code to ! 638: * scan for it. ! 639: */ ! 640: ! 641: if (notenum == 0 && /* not found */ ! 642: !strncmp (header -> title, "re: ", 4) || /* and looks like */ ! 643: !strncmp (header -> title, "Re: ", 4) || /* a response */ ! 644: !strncmp (header -> title, "RE: ", 4)) ! 645: { ! 646: dprintf ("Looking at titles\n"); ! 647: p = header -> title; ! 648: do ! 649: { ! 650: for (p += 3; *p == ' ' || *p == '\t'; p++); /* drop spaces */ ! 651: } while (!strncmp (p, "re: ", 4) || ! 652: !strncmp (p, "Re: ", 4) || ! 653: !strncmp (p, "RE: ", 4)); ! 654: strncpy (io -> xstring, p, TITLEN); /* load it */ ! 655: io -> xstring[TITLEN - 1] = '\0'; /* and terminate it */ ! 656: notenum = findtitle (io, io -> descr.d_nnote, FALSE);/* start at back */ ! 657: if (notenum > 0) /* found one */ ! 658: getnrec (io, notenum, ¬e2); /* get a ptr to it */ ! 659: } ! 660: ! 661: /* ! 662: * OK. By now, we have a "notenum" if the article can be pegged ! 663: * as a response to one of our notes. ! 664: * Otherwise, notenum==0 and we'll have to turn it into ! 665: * a base note. ! 666: */ ! 667: ! 668: if (notenum > 0) ! 669: { ! 670: dprintf ("Looking in response chain for note %d\n", notenum); ! 671: if (!chkresp (io, &newsid, ¬e2, notenum)) ! 672: { /* no copy here */ ! 673: pagein (io, body, &where); ! 674: gettime (&whentime); ! 675: i = putresp (io, &where, status, notenum, &entered, &auth, ¬e, ! 676: NOLOCKIT, &newsid, NOADDID, fromsys, ADDTIME, &whentime); ! 677: unlocknf (io, DSCRLOCK); /* un-MUTEX */ ! 678: return (i); ! 679: } ! 680: else ! 681: { /* copy there */ ! 682: unlocknf (io, DSCRLOCK); /* all done */ ! 683: printf ("Duplicate Response handed back by news\n"); ! 684: io -> nrspdrop++; /* bong it */ ! 685: return (0); /* count as done */ ! 686: } ! 687: } ! 688: /* ! 689: * If we are going to do things this way, here is the point ! 690: * where we should check about turning a news-generated ! 691: * article into an orphaned response. ! 692: * ! 693: * Basically, look for a non-empty references line and ! 694: * make a foster parent with the first article id on that ! 695: * line. ! 696: */ ! 697: ! 698: /* ! 699: * by this point, it's obvious that we can't turn the note into ! 700: * a response. We can skip the check to see if it is already ! 701: * there because we did that at the very top of this loop ! 702: * and since we've locked the notesfile up while we're doing this, ! 703: * we know that nobody added a note. ! 704: */ ! 705: dprintf ("Processing article as a base note\n"); ! 706: pagein (io, body, &where); ! 707: notenum = putnote (io, &where, title, status, ¬e, ! 708: &auth, NOPOLICY, NOLOCKIT, NOADDID, fromsys, ADDTIME); ! 709: io -> nnotrcvd++; /* count it */ ! 710: unlocknf (io, DSCRLOCK); ! 711: return (notenum); ! 712: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.