DataMuseum.dk

top - metrics - download

    Length: 26698 (0x684a)
    Types: TextFile
    Names: »readr.c«

└─⟦9ae75bfbd⟧ Bits:30007242 EUUGD3: Starter Kit
    └─⟦373604645⟧ »EurOpenD3/news/bnews.2.11/src.tar.Z« 
        └─⟦3beb569ac⟧ 
            └─⟦this⟧ »src/readr.c« 

TextFile

/*
 * This software is Copyright 1986, 1989 by Rick Adams.
 *
 * Permission is hereby granted to copy, reproduce, redistribute or
 * otherwise use this software as long as: there is no monetary
 * profit gained specifically from the use or reproduction or this
 * software, it is not sold, rented, traded or otherwise marketed, and
 * this copyright notice is included prominently in any copy
 * made.
 *
 * The author make no claims as to the fitness or correctness of
 * this software for any use whatsoever, and it is provided as is. 
 * Any use of this software is at the user's own risk.
 *
 * readr - /bin/mail and msgs interface and associated functions.
 */

#ifdef SCCSID
static char	*SccsId = "@(#)readr.c	2.71	10/29/89";
#endif /* SCCSID */

#include "rparams.h"
#include <setjmp.h>
#include <errno.h>

extern int errno;

char *Progname = "readnews";	/* used by xerror to identify failing program */

static char	lbuf[BUFLEN*2];
long atol();

#define	saveart	oobit = bit;strcpy(ofilename1, filename);strcpy(ogroupdir, groupdir);hptr = h;h = hold;hold = hptr
#define NLINES(h, fp) (h->numlines[0] ? h->intnumlines : (h->intnumlines=linecnt(fp),sprintf(h->numlines, "%d", h->intnumlines), h->intnumlines))

char *tft = "/tmp/folXXXXXX";

/*
 * These were made static for u370 with its buggy cc.
 * I judged it better to have one copy with no ifdefs than
 * to conditionally compile them as automatic variables
 * in readr (which they originally were).  Performance
 * considerations might warrant moving some of the simple
 * things into register variables, but I don't know what
 * breaks the u370 cc.
 */
#ifndef SERVER
static char goodone[BUFLEN];		/* last decent article		*/
#endif	/* !SERVER */
static char ogroupdir[BUFLEN];		/* last groupdir		*/
static char address[PATHLEN];		/* for reply copy		*/
static char edcmdbuf[128];
static int rfq = 0;			/* for last article		*/
static long pngsize;			/* Printing ngsize		*/
static char *bptr;			/* temp pointer.		*/
static char *tfilename;			/* temporary file name 		*/
static char ofilename1[BUFLEN];		/* previous file name		*/
static struct hbuf hbuf1, hbuf2,	/* for minusing			*/
		*h = &hbuf1,		/* current header		*/
		*hold = &hbuf2,		/* previous header		*/
		*hptr;			/* temporary 			*/
static char *ptr1, *ptr2, *ptr3;	/* for reply manipulation	*/
static int  abs = FALSE;		/* TRUE if we asked absolutely	*/
static char tf[100];
static long oobit;			/* last bit, really		*/
static int dgest = 0;
static FILE *ofp;			/* Current output file to terminal*/
static FILE *fp;			/* current article to be printed*/
static int ignorenews;			/* 1 iff readnews -p > /dev/null*/
static time_t timelastsaved;		/* time newsrc last written out */
static jmp_buf sigjmpbuf;		/* for signal processing */
static int canlongjmp;			/* TRUE if setjmp on sigjmp valid */
short ospeed;				/* terminal speed NOT STATIC */
					/* used in readnews.c, declared here */
					/* to match declaration in visual.c */
#ifdef SERVER
static int clrtmp = 0;
#endif

int catchcont();
readr()
{
	register char *m = getenv("MORE");
	register char *m2, cc;

	/*
	 * Turn of more's 'l' option, so \f kludge will work.
	 * This is really revolting!
	 */
	if (m2 = m) {
		while (cc = *m++)
			if (cc != 'l')
				*m2++ = cc;
		*m2 = '\0';
	}

#ifdef DEBUG
	fprintf(stderr, "readr()\n");
#endif	/* DEBUG */
	if (aflag) {
		if (*datebuf) {
			if ((atime = cgtdate(datebuf)) == -1)
				xerror("Cannot parse date string");
		} else
			atime = 0;
	}

	if (pflag && ignoring())
		ignorenews = TRUE;

	if (xflag)
		uflag = 0;
	if (uflag)
		(void) time(&timelastsaved);

	ofp = stdout;
	if (cflag && coptbuf[0] != '\0') {
		(void) umask(022);
		MKTEMP(outfile);	/* get "unique" file name */
		(void) close(creat(outfile,0666));
		ofp = xfopen(outfile, "w");
		(void) umask(N_UMASK);
		cflag = FALSE;
		pflag = TRUE;
	}

	/* loop reading articles. */
	fp = NULL;
	obit = -1;
	nextng();
	for ( ;; ) {
		if (getnextart(FALSE))
			break;
#ifdef DEBUG
		fprintf(stderr,"after getnextart, fp %x, pos %ld, bit %ld, group '%s', filename '%s'\n",
			fp, ftell(fp), bit, groupdir, filename);
#endif	/* DEBUG */
#ifndef SERVER
		(void) strcpy(goodone, filename);
#endif	/* SERVER */
		if (pflag || lflag || eflag) {
			/* This code should be gotten rid of */
			if (SigTrap) {
				qfflush(ofp);
				fprintf(ofp, "\n");
				cdump(ofp);
				xxit(0); /* kludge! drop when qfflush works */
#ifdef SERVER
				if (clrtmp)
					(void) unlink(filename);
				clrtmp = 0;
#endif
				return;
			}
			clear(bit);
			nextbit();
			FCLOSE(fp);
			continue;
		}
		for ( ;; ) {
			char *pp;
			int nlines;
			SIGNAL_TYPE ointr;
#ifdef	SIGCONT
			SIGNAL_TYPE ocont;
#endif	/* SIGCONT */
			(void) setjmp(sigjmpbuf);
			canlongjmp = TRUE;

			SigTrap = FALSE;
			if (!cflag) {
				if (rfq)
					(void) sprintf(bfr, "Last article.  [qfr] ");
				else {
					nlines = NLINES(h, fp);
					if (nlines <= 0) {
						(void) sprintf(bfr, "(0 lines) Next? [nqfr] ");
						FCLOSE(fp);
					} else {
						(void) sprintf(bfr, "(%d lines) More? [ynq] ", nlines);
					}
				}
			} else
				(void) sprintf(bfr, "? ");
			fprintf(ofp, "%s", bfr);
			(void) fflush(ofp);
			bptr = lbuf;
			ointr = (int (*)())signal(SIGINT, catchcont);
#ifdef SIGCONT
			ocont = (int (*)())signal(SIGCONT, catchcont);
#endif	/* SIGCONT */
			pp = fgets(bptr, BUFLEN, stdin);
			canlongjmp = FALSE;
			(void) signal(SIGINT, ointr);
#ifdef SIGCONT
			(void) signal(SIGCONT, ocont);
#endif	/* SIGCONT */
			if (pp != NULL)
				break;
			if (!SigTrap) {
#ifdef SERVER
				if (clrtmp)
					(void) unlink(filename);
				clrtmp = 0;
#endif
				return;
			}
#ifdef SIGCONT
			if (SigTrap != SIGCONT)
#endif	/* SIGCONT */
				fprintf(ofp, "\n");
		}
		(void) nstrip(bptr);
		while (*bptr == ' ' || *bptr == '\t')
			bptr++;
		if (command())
			break;
	}

	if (!pflag && !news) {
		fprintf(stderr, "No news.\n");
	}
	cout(ofp);
#ifdef SERVER
	if (clrtmp)
		(void) unlink(filename);
	clrtmp = 0;
#endif
}

#define EOL() if (*bptr != '\0') { fprintf(ofp, "? for commands.\n"); return FALSE; }
/*
 * Process one command, which has already been typed in.
 */
command()
{
	char *findhist();
	long i;
#ifdef SERVER
	char workspace[256];
#endif	/* !SERVER */

	switch (*bptr++) {

	/* display list of articles in current group */
	case 'l':
	case 'L':
		list_group(groupdir, atoi(bptr),
			(*(bptr - 1) == 'l') ? FALSE : TRUE, pngsize);
		break;
	
	/* No.  Go on to next article. */
	case 'n':
		EOL();
		readmode = NEXT;
		if (!cflag)
			FCLOSE(fp);
		fprintf(ofp, "\n");
		clear(bit);
		saveart;
		nextbit();
		break;

	/* Undigestify the article. */
	case 'd':
		dgest = 1;
		/* fall through */

	/* yes: print this article, go on. */
	case 'y':
		EOL();
		/* fall through. */

	/* The user hit return.  Default is 'y' unless rfq, then it's 'q'. */
	case '\0':
		if (!bptr[-1] && rfq)
			return TRUE;
		readmode = NEXT;
		showtail(fp);
		clear(bit);
		saveart;
		nextbit();
		break;

	/*
	 * Unsubscribe to the newsgroup and go on to next group
	 */
	case 'u':
		fprintf(ofp, "To unsubscribe, use 'U'\n");
		break;

	case 'U':
		fprintf(ofp, "Unsubscribing to newsgroup: %s\n", groupdir);
		obit = -1;
		FCLOSE(fp);
		if (cflag)
			clear(bit);
		else
			putc('\n', ofp);
		rfq = 0;
		zapng = TRUE;
		saveart;
		if (nextng()) {
			if (actdirect == BACKWARD)
				fprintf(ofp, "Can't back up.\n");
			else
				return TRUE;
		}
		break;

		/* Print the current version of news */
	case 'v':
		fprintf(ofp, "News version: %s\n", news_version);
		break;

		/* reprint the article */
	case 'p':
		EOL();
		if (!cflag)
			goto minus;
		readmode = NEXT;
		if (!cflag) {
			FCLOSE(fp);
			bit = last;
			putc('\n', ofp);
		}
		obit = -1;
		break;

		/* decrypt joke */
	case 'D':
		caesar_command();
		readmode = NEXT;
		clear(bit);
		saveart;
		nextbit();
		break;

		/* write out the article someplace */
	case 's':
	case 'w':
		{
		char *grn = groupdir;
		tfilename = filename;
		if (*bptr == '-') {
			bptr++;
			grn = ogroupdir;
			if (*ofilename1)
				tfilename = ofilename1;
		}
		if (*bptr != '\0' && *bptr != ' ') {
			fprintf(ofp, "Bad file name.\n");
			break;
		}
		while (*bptr == ' ')
			bptr++;
		if (*bptr != '|' && *bptr != '/') {
			char	hetyped[BUFLEN];
			char	*boxptr;
			struct	stat stbf;
  			(void) strcpy(hetyped, bptr);
			if (hetyped[0] == '~' && hetyped[1] == '/') {
  				strcpy(hetyped, bptr+2);
  				strcpy(bptr, userhome);
			} else if (boxptr = getenv("NEWSBOX")) {
 				if (index(boxptr, '%')) {
 					sprintf(bptr, boxptr, grn);
 				    	if (stat(bptr, &stbf) < 0) {
						if (mkdir(bptr, 0777) < 0) {
							fprintf(ofp, "Cannot create directory %s", bptr);
							break;
						}
					} else if ((stbf.st_mode & S_IFMT) != S_IFDIR) {
						fprintf(ofp, "%s is not a directory", bptr);
						break;
					}
				} else
				    strcpy(bptr, boxptr);
			} else
				(void) strcpy(bptr, ".");
			(void) strcat(bptr, "/");
			if (hetyped[0] != '\0')
				(void) strcat(bptr, hetyped);
			else
				(void) strcat(bptr, "Articles");
		}
		fwait(fsubr(save, tfilename, bptr));
		}
		break;

		/* back up  */
	case '-':
minus:
		rfq = 0;
		abs = TRUE;
		if (!*ofilename1) {
			fprintf(ofp, "Can't back up.\n");
			break;
		}
		if (cflag)
			clear(bit);
		else {
			FCLOSE(fp);
			putc('\n', ofp);
		}
		hptr = h;
		h = hold;
		hold = hptr;
		(void) strcpy(bfr, filename);
		(void) strcpy(filename, ofilename1);
		(void) strcpy(ofilename1, bfr);
		obit = bit;
		if (STRCMP(groupdir, ogroupdir)) {
			(void) strcpy(bfr, groupdir);
			selectng(ogroupdir, FALSE, FALSE);
			(void) strcpy(groupdir, ogroupdir);
			(void) strcpy(ogroupdir, bfr);
			ngrp = 1;
			back();
		}
		bit = oobit;
		oobit = obit;
		obit = -1;
		(void) getnextart(TRUE);
		return FALSE;

		/* skip forwards */
	case '+':
caseplus:
		if (*bptr == '\0')
			(void) strcat(bptr, "1");
		rfq = 0;
		if (cflag)
			clear(bit);
		saveart;
		last = bit;
		for (i = 0; i < atol(bptr); i++) {
			nextbit();
			if ((bit > pngsize) || (rflag && bit < 1))
				break;
		}
		if (!cflag) {
			putc('\n', ofp);
			FCLOSE(fp);
		}
		obit = -1;
		break;

	/* exit - time updated to that of most recently read article */
	case 'q':
		EOL();
		return TRUE;

	/* exit - no time update. */
	case 'x':
		EOL();
		xxit(0);

	/* cancel the article. */
	case 'c':
		(void) cancel_command();
		break;
#ifndef NOSHELL
	/* escape to shell */
	case '!':
		fwait(fsubr(ushell, bptr, (char *)NULL));
		fprintf(ofp, "\n");
		hdr();
		break;

	/* mail reply */
#endif	/* !NOSHELL */
	case 'r':
		(void) reply_command();
		break;

	/* send to some system */
	case 'X':
		xmit_command();
		break;
	/* mark the rest of the articles in this group as read */
	case 'K':
		saveart;
		while (bit <= pngsize && bit >= minartno) {
			clear(bit);
			nextbit();
		}
		FCLOSE(fp);
		break;

	/* next newsgroup */
	case 'P':
		*bptr = '-';
	case 'N':
		FCLOSE(fp);
		if (next_ng_command())
			return TRUE;
		break;

	case 'b':	/* back up 1 article */
		i = bit - 1;
		goto tryartnum;
	case '0':	/* specific no. */
	case '1':
	case '2':
	case '3':
	case '4':
	case '5':
	case '6':
	case '7':
	case '8':
	case '9':
		(void) sscanf(--bptr, "%ld", &i);
		if (i == 0) {
			fprintf(ofp, "Bad article no.\n");
			break;
		}
		if (i > pngsize) {
			fprintf(ofp, "Not that many articles.\n");
			break;
		}
tryartnum:
		readmode = SPEC;
		abs = TRUE;
		bit = i;
		obit = -1;
		if (!cflag) {
			putc('\n', ofp);
			FCLOSE(fp);
		}
		rfq = 0;
		break;

	/* specific message ID. */
	case '<':
		ptr1 = findhist(--bptr);
		if (ptr1 == NULL) {
			fprintf(ofp, "No such article: %s.\n", bptr);
			break;
		}
		ptr2 = index(ptr1, '\t');
		ptr3 = index(++ptr2, '\t');
		ptr2 = index(++ptr3, ' ');
		if (ptr2)
			*ptr2 = '\0';
		ptr2 = index(ptr3, '/');
		if (!ptr2) {
			if (STRCMP(ptr3, "cancelled") == 0) {
				fprintf(ofp, "Article %s has been cancelled.\n",
					bptr);
				break;
			}
			fprintf(ofp, "Article %s (dated %s) has expired.\n",
				bptr, index(ptr1, '\t')+1);
			break;
		}
		*ptr2++ = '\0';
		abs = TRUE;
		if (cflag)
			clear(bit);
		else {
			FCLOSE(fp);
			putc('\n', ofp);
		}
		saveart;
		(void) strcpy(ogroupdir, ptr3);
		if (STRCMP(groupdir, ogroupdir)) {
			(void) strcpy(bfr, groupdir);
			selectng(ogroupdir, FALSE, PERHAPS);
			(void) strcpy(groupdir, ogroupdir);
			(void) strcpy(ogroupdir, bfr);
			ngrp = 1;
			back();
		}
		(void) sscanf(ptr2, "%ld", &bit);
		oobit = obit;
		obit = -1;
		i = bit;
		(void) getnextart(TRUE);
		if (bit != i || STRCMP(groupdir, ptr3) != 0) {
			(void) fprintf(ofp, "Can't read %s/%ld.\n", ptr3, i);
			goto minus;
		}
		rfq = 0;
		break;

	/* follow-up article */
	case 'f':
		if (STRCMP(h->followto, "poster") == 0) {
			(void) reply_command();
			break;
		}

		if (*bptr == '-')
			tfilename = ofilename1;
		else
			tfilename = filename;
#ifdef SERVER
		(void) sprintf(bfr,"%s/%s %s/%s/%ld", BIN, "postnews", 
				SPOOL,groupdir,bit);
#else	/* !SERVER */
		(void) sprintf(bfr,"%s/%s %s", BIN, "postnews", tfilename);
#endif	/* !SERVER */
		(void) system(bfr);
		break;

	/* erase - pretend we haven't seen this article. */
	case 'e':
		if (rfq || *bptr == '-') {
			if (STRCMP(groupdir, ogroupdir)) {
				i = bit;
				(void) strcpy(bfr, groupdir);
				selectng(ogroupdir, FALSE, PERHAPS);
				set(oobit);
				fprintf(ofp,"Holding article %ld newsgroup %s\n"
					,oobit, ogroupdir);
				(void) strcpy(groupdir, ogroupdir);
				selectng(bfr, FALSE, FALSE);
				bit = i;
			} else {
				fprintf(ofp,"Holding article %ld\n", oobit);
				set(oobit);
			}
		} else {
			fprintf(ofp,"Holding article %ld\n", bit);
			set(bit);
			goto caseplus;	/* skip this article for now */
		}
		break;

	case 'H':
	case 'h':
		if (!hflag)
			dash(8, ofp);
		if (*bptr == '-') {
			if (oobit > 0)
				fprintf(ofp, "Article %ld:\n", oobit);
			hprint(hold, ofp, 1 + (bptr[-1]=='H'));
		} else {
			fprintf(ofp, "Article %ld of %ld: %s\n",
				rfq ? oobit : bit, pngsize, h->ident);
			hprint(h, ofp, 1 + (bptr[-1]=='H'));
		}
		if (!hflag)
			dash(8, ofp);
		break;

	case '#':
		fprintf(ofp, "Article %ld of %ld: newsgroup %s\n",
			rfq ? oobit : bit, pngsize, rfq ? ogroupdir : groupdir);
		break;

		/* error */
	case '?':
		help(ofp);
		break;
	default:
		fprintf(ofp, "? for commands.\n");
		break;
	}

	return FALSE;
}

cancel_command()
{
	register char *poster;
	int notauthor;
	char *tailpath();

	tfilename = filename;
	hptr = h;
	if (*bptr == '-') {
		if (*ofilename1) {
			tfilename = ofilename1;
			hptr = hold;
		}
		bptr++;
	}
	EOL();
	readmode = SPEC;
	poster = tailpath(hptr);
	notauthor = STRCMP(username, poster);
	if (uid != ROOTID && uid && notauthor) {
		fprintf(ofp,
			"You (%s) can't cancel someone else's (%s) article.\n",
			username,poster);
		return FALSE;
	}
	if (!cancel(ofp, hptr, notauthor) && hptr == h) {
		clear(bit);
		saveart;
		nextbit();
		obit = -1;
		if (!cflag)
			putc('\n', ofp);
		FCLOSE(fp);
	}
	return TRUE;
}

reply_command()
{
	register char	*pathptr;
	int edit = 1;
	char *ed, *fbp;
	int idlen;
	FILE *tfp;
	char *replyname();
	char subj[BUFLEN];
	char folbuf[BUFLEN];
	struct stat statb;
	long creatm;

	hptr = h;
	while (*bptr && index("d-", *bptr)) {
		switch (*bptr) {
		/* Followup the previous article. */
		case '-':
			hptr = hold;
			break;

		/* Don't edit the headers */
		case 'd':
			edit = 0;
			break;
		}
		bptr++;
	}
	EOL();
	ptr1 = index(MAILPARSER, ' ');
	if (ptr1)
		*ptr1 = '\0';
	if (edit && access(MAILPARSER, 1)) {
#ifdef IHCC
		fprintf(stderr, "Can't edit headers, 'recmail' missing.\n");
#else
		fprintf(stderr, "Can't edit headers without %s\n", MAILPARSER);
#endif
		edit = 0;
	}
	if (ptr1)
		*ptr1 = ' ';

	*rcbuf = '\0';
	pathptr = replyname(hptr);;
	for (ptr1 = address, ptr2 = pathptr; *ptr2; ptr1++, ptr2++) {
		if (index("\"\\$", *ptr2))
			*ptr1++ = '\\';
		*ptr1 = *ptr2;
	}
	*ptr1 = '\0';

	folbuf[0] = '\0';		/* References */
	if (hptr->followid[0]) {
		fbp = hptr->followid;
		idlen = strlen(hptr->ident);

		/*
		 * If the references line is too long, truncate it.
		 * The "3" is for the comma, the space, and the '\0' at
		 * the end of the string.
		 */
		while (fbp && strlen(fbp) + idlen > BUFLEN - 3)
			fbp = index(fbp + 1, '<');
		if (fbp != NULL) {
			(void) strcpy(folbuf, fbp);
			(void) strcat(folbuf, " ");
		}
	}
	(void) strcat(folbuf, hptr->ident);

	(void) strcpy(subj, hptr->title);	/* Subject */
	while (isspace(*bptr))
		bptr++;
	if (*bptr != '\0')
		(void) strcpy(subj, bptr);
	if (!PREFIX(subj, "Re:")){
		(void) strcpy(bfr, subj);
		(void) sprintf(subj, "Re: %s", bfr);
	}
	if (!edit) {
		fprintf(ofp, "To: %s\n", pathptr);
		ed = index(MAILER, '%');
		if (ed && ed[1] == 's')
			fprintf(ofp, "Subject: %s\n", subj);
		(void) fflush(ofp);
	}

	/* Put the user in the editor to create the body of the followup. */
	if (edit) {
		int oumask;

		(void) strcpy(tf, tft);
		MKTEMP(tf);

		ed = getenv("EDITOR");
		if (ed == NULL)
			ed = DFTEDITOR;

		oumask = umask(077);
		if ((tfp = fopen(tf, "w")) == NULL) {
			perror(tf);
			creatm = 0L;
		} else {
			fprintf(tfp, "To: %s\n", pathptr);
			fprintf(tfp, "Subject: %s\n", subj);
#ifdef INTERNET
			fprintf(tfp, "News-Path: %s\n", hptr->path);
#endif /* INTERNET */
			fprintf(tfp, "References: %s\n\n", folbuf);
			fstat(fileno(tfp), &statb);
			creatm = statb.st_mtime;
			(void) fclose(tfp);
		}
		(void) umask(oumask);

		(void) sprintf(edcmdbuf, "%s %s", ed, tf);
		(void) system(edcmdbuf);
		(void) strcpy(rcbuf, MAILPARSER);
		(void) strcat(rcbuf, " -t");
		(void) strcat(rcbuf, " < ");
		(void) strcat(rcbuf, tf);
		if (access(tf, 4) || stat(tf, &statb)) {
			fprintf(stderr, "Reply not sent: no input file.\n");
			return FALSE;
		}
		if (statb.st_mtime == creatm) {
			fprintf(stderr, "Reply not sent: cancelled.\n");
			(void) unlink(tf);
			return FALSE;
		}
		fprintf(ofp,"Sending reply.\n");
		(void) fflush(stdout);
		if (vfork() == 0) {
			(void) system(rcbuf);
			(void) unlink(tf);
			_exit(0);
		}
	} else {
		(void) sprintf(rcbuf, MAILER, hptr->title);
		(void) sprintf(bfr, "%s %s", rcbuf, address);
		(void) system(bfr);
	}
	hdr();
	return TRUE;
}
xmit_command()
{
#ifdef u370
	static struct srec srec;	
#else	/* !u370 */
	struct srec srec;
#endif	/* !u370 */

	tfilename = filename;
	if (*bptr == '-') {
		if (*ofilename1)
			tfilename = ofilename1;
		bptr++;
	}
	if (*bptr != '\0' && *bptr != ' ') {
		fprintf(ofp, "Bad system name.\n");
		return;
	}
	while (*bptr == ' ')
		bptr++;
	if (*bptr == '\0') {
		fprintf(ofp, "Missing system name.\n");
		return;
	}
#ifndef SERVER
	if (s_find(&srec, bptr) == 0) {
		fprintf(ofp, "%s not in SYSFILE\n", bptr);
		return;
	}
#endif	/* !SERVER */
	(void) transmit(&srec, tfilename);
}

next_ng_command()
{
	obit = -1;
	if (!*bptr || *bptr == '-') {
		if (cflag)
			clear(bit);
		else
			putc('\n', ofp);
		if (*bptr)
			actdirect = BACKWARD;
		rfq = 0;
		saveart;
		if (nextng()) {
			if (actdirect == BACKWARD)
				fprintf(ofp, "Can't back up.\n");
			else
				return TRUE;
		}
		return FALSE;
	}
	while (isspace(*bptr))
		bptr++;
	if (!validng(bptr)) {
		fprintf(ofp, "No such group.\n");
		return FALSE;
	}
	if (cflag)
		clear(bit);
	else
		putc('\n', ofp);
	readmode = SPEC;
	rfq = 0;
	saveart;
	back();
	selectng(bptr, FALSE, TRUE);
	return FALSE;
}

caesar_command()
{
	char	temp[BUFLEN];
	FILE	*pfp, *popen();

	fprintf(stderr, "Caesar decoding:\n");
	(void) sprintf(temp, "%s/%s", LIB, "caesar");
	if (*bptr) {
		(void) strcat(temp, " ");
		(void) strcat(temp, bptr);
	}
	if (NLINES(h, fp) > LNCNT && *PAGER) {
		(void) strcat(temp, " | ");
		(void) strcat(temp, PAGER);
	}
	pfp = popen(temp, "w");
	tprint(fp, pfp, FALSE);
	FCLOSE(fp);
	(void) pclose(pfp);
}

/*
 * Show the user the tail, if any, of the message on file
 * descriptor fd, and close fd.  The digester is considered,
 * and the pager is used if appropriate.
 */
showtail(fd)
FILE *fd;
{
	if (fd == NULL)
		return;

	if (dgest) {
		digest(fd, ofp, h);
	} else if (!lflag && !pflag && !eflag) {
		pprint(fd);
	}
	(void) fclose(fd);
}

/*
 * Print out the rest of the article through the pager.
 */
pprint(fd)
FILE *fd;
{
#ifdef PAGE
	/* Filter the tail of long messages through PAGER. */
	if (NLINES(h, fd) > LNCNT && *PAGER) {
		if (!index(PAGER, FMETA)) {
			FILE *pfp, *popen();

			pfp = popen(PAGER, "w");
			if (pfp == NULL)
				pfp = ofp;
			/*
			 * What follows is an attempt to prevent the
			 * next message from scrolling part of this
			 * message off the top of the screen before
			 * the poor luser can read it.
			 */
			tprint(fd, pfp, FALSE);
			putc('\f', pfp);
			putc('\n', pfp);
			putc(' ', pfp);
			(void) pclose(pfp);
		}
		else
			pout(ofp);
	}
	else
#endif	/* PAGE */
		tprint(fd, ofp, FALSE);
}

/*
 * Find the next article we want to consider, if we're done with
 * the last one, and show the header.
 */
getnextart(minus)
int minus;
{
 	int noaccess;
#ifdef SERVER
	char workspace[256];
#else	/* !SERVER */
 	register DIR *dirp;
 	register DIRECTORY_STRUCT *dir;
#endif	/* !SERVER */
 	long nextnum, tnum;

 	noaccess = 0;

	if (minus)
		goto nextart2;	/* Kludge for "-" command. */

	if (bit == obit)	/* Return if still on same article as last time */
		return 0;

	SigTrap = FALSE;

nextart:
#ifdef DEBUG
	fprintf(stderr,"nextart:\n");
#endif /* DEBUG */
	dgest = 0;

	if (bit < minartno && !rflag)
		bit = minartno;

	/* If done with this newsgroup, find the next one. */
	while (ngsize <= 0 || (!rflag && ((long) bit > ngsize)) || (rflag && bit < minartno)) {
		if (nextng()) {
			if (actdirect == BACKWARD) {
				fprintf(ofp, "Can't back up.\n");
				actdirect = FORWARD;
				continue;
			} else
				if (rfq++ || pflag || cflag)
					return 1;
			break;
		}
		if (rflag)
			bit = ngsize + 1;
		else
			bit = minartno - 1;
		if (uflag && !xflag) {
			time_t now;
			(void) time(&now);
			if (now - timelastsaved > 5*60 /* 5 minutes */) {
				if (!xflag)
					fprintf(stderr,"[Saving .newsrc]\n");
				writeoutrc();
				timelastsaved = now;
			}
		}
		noaccess = 0;
	}

nextart2:
#ifdef DEBUG
	fprintf(stderr, "article: %s/%ld\n", groupdir, bit);
#endif	/* DEBUG */
	if (rcreadok)
		rcreadok = 2;	/* have seen >= 1 article */
#ifdef SERVER
	if (clrtmp)
		unlink(filename);
	clrtmp = 0;
	if (bit == 0 || (fp = getarticle(groupdir, bit, "ARTICLE")) == NULL)
		goto badart;
	clrtmp = 1;
	strcpy(filename, article_name());
	(void) fclose(fp);
	fp = NULL;
#else	/* !SERVER */
	(void) sprintf(filename, "%s/%ld", dirname(groupdir), bit);

	if (rfq && goodone[0])
		strcpy(filename, goodone);
#endif	/* !SERVER */
	if (SigTrap) {
		if (SigTrap == SIGHUP)
			return 1;
		if (!rcreadok)
			xxit(0);
		fprintf(ofp, "Abort (n)?  ");
		(void) fflush(ofp);
		(void) gets(bfr);
		if (*bfr == 'y' || *bfr == 'Y')
			xxit(0);
		SigTrap = FALSE;
	}
#ifdef DEBUG
	fprintf(stderr, "filename = '%s'\n", filename);
#endif	/* DEBUG */
	/* Decide if we want to show this article. */
 	if (bit <= 0 || (fp = art_open(filename, "r")) == NULL) {
		/* don't show the header if the article was specifically
		 * requested and it isn't there
		 */
		if (lbuf[0] == '<') {
			lbuf[0] = '\0';
			bit = -1;
			return 1;
		}
 		/* since there can be holes in legal article numbers, */
 		/* we wait till we hit 5 consecutive bad articles */
 		/* before we haul off and scan the directory */
 		if (++noaccess < 5)
 			goto badart;
		noaccess = 0;
#ifdef SERVER
		if (*groupdir == ' ' || *groupdir == '\0' || 
			set_group(groupdir) == NULL)
			goto badart;
#else	/* !SERVER */
 		dirp = opendir(dirname(groupdir));
 		if (dirp == NULL) {
			if (errno != EACCES)
				fprintf(stderr,"Can't open %s\n", dirname(groupdir));
 			goto badart;
 		}
#endif	/* !SERVER */
 		nextnum = rflag ? minartno - 1 : ngsize + 1;
#ifdef SERVER 
		tnum = nextnum;
		for(;;){
			(void) sprintf(bfr,"STAT %ld",tnum);
			put_server(bfr);
			(void) get_server(workspace,sizeof(workspace));
			if (*workspace != '2') {
				if (rflag)
					tnum++;
				else
					tnum--;
				continue;
			}
#else	/* !SERVER */
 		while ((dir = readdir(dirp)) != NULL) {
 			tnum = atol(dir->d_name);
 			if (tnum <= 0)
 				continue;
#endif	/* !SERVER */
 			if (rflag ? (tnum > nextnum && tnum < bit)
 				  : (tnum < nextnum && tnum > bit))
 				nextnum = tnum;
#ifdef SERVER
			break;		/* not exactly right */
#endif	/* !SERVER */
 		}
#ifndef SERVER
 		closedir(dirp);
#endif	/* SERVER */
 		if (rflag ? (nextnum >= bit) : (nextnum <= bit))
 			goto badart;
#ifdef DEBUG
		fprintf(stderr,"nextnum = %ld\n",nextnum);
#endif /* DEBUG */
 		do {
 			clear(bit);
 			nextbit();
 		} while (rflag ? (nextnum < bit) : (nextnum > bit));
 		obit = -1;
 		abs = FALSE;
		if (ignorenews) /* ignored news is still news */
			news = TRUE;
 		goto nextart;
 	} else
 		noaccess = 0;

 	if (ignorenews || hread(h, fp, TRUE) == NULL
		|| (!rfq && !aselect(h, abs))) {
		if (ignorenews)
			news = TRUE;
 badart:
#ifndef SERVER
#ifdef DEBUG
		fprintf(stderr, "Bad article '%s'\n", filename);
#endif	/* DEBUG */
#endif	/* !SERVER */
		FCLOSE(fp);
		clear(bit);
		obit = -1;
		nextbit();
		abs = FALSE;
		goto nextart;
	}
	abs = FALSE;
	actdirect = FORWARD;
	news = TRUE;
	hdr();
	if (pflag)
		tprint(fp, ofp, FALSE);
	else if (cflag && !lflag && !eflag) {
		(void) fflush(ofp);
		pprint(fp);
	}
	if (cflag || lflag || eflag || pflag) {
		SigTrap = FALSE;
		FCLOSE(fp);
	}
	obit = bit;
	return 0;
}

/*
 * Print out whatever the appropriate header is
 */
hdr()
{
	char *briefdate();

	if (rfq)
		return;

	if (lflag || eflag) {
		hprint(h, ofp, 0);
		return;
	}

	/* Print out a header */
	if (ngrp) {
		pngsize = ngsize;
		ngrp--;
		nghprint(groupdir);
	}
	if (!hflag)
		fprintf(ofp, "Article %ld of %ld, %s.\n",
			bit, pngsize, briefdate(h->subdate));
	hprint(h, ofp, pflag ? 1 : 0);
}

nghprint(title)
char *title;
{
	char *tstr = "Newsgroup ";
	int l = strlen(title) + strlen(tstr);

	fprintf(ofp, "\n");
	if (!hflag) {
		dash(l, ofp);
		fprintf(ofp, "%s%s\n", tstr, title);
		dash(l, ofp);
	} else {
		fprintf(ofp, "%s%s, ", tstr, title);
		if (bit == pngsize)
			fprintf(ofp, "%ld\n", pngsize);
		else
			fprintf(ofp, "%ld-%ld\n", bit, pngsize);
	}
	fprintf(ofp, "\n");
}

/*
 * Routine to catch a continue signal.
 */
catchcont(sig)
int sig;
{
	(void) signal(sig, catchcont);
	SigTrap = sig;
	(void) fflush(ofp);
#ifdef SIGCONT
	if (fp && sig == SIGCONT)
		hdr();
	if (sig != SIGCONT)
#endif /* SIGCONT */
		putc('\n', ofp);
	if (canlongjmp)
		longjmp(sigjmpbuf,1);
}

xxit(status)
int	status;
{
	(void) unlink(infile);
	(void) unlink(outfile);
#ifdef SORTACTIVE
	if (strncmp(ACTIVE,"/tmp/", 5) == 0)
		(void) unlink(ACTIVE);
#endif /* SORTACTIVE */
#ifdef SERVER
	if (active_name() != NULL) 
		(void) unlink(active_name());
	if (article_name() != NULL) 
		(void) unlink(article_name());
	close_server();	
#endif	/* SERVER */
	exit(status);
}