4.3BSD/usr/contrib/spms/src/bin/plog/Plog.c
static char *rcsid = "$Header$";
/*
* plog - record, edit, print, sort progress of a project
*
* Author: Peter J. Nicklin
*/
#include <ctype.h>
#include <signal.h>
#include <stdio.h>
#include "bin.h"
#include "date.h"
#include "from.h"
#include "getarg.h"
#include "null.h"
#include "path.h"
#include "spms.h"
#include "system.h"
#include "yesno.h"
#define SUBJECT_MAX_FORWARD_LOOK 5 /* max no. of lines to read ahead */
/* for "Subject: " */
#define TITLELENGTH 72 /* length of subject title */
/*
* type of operation to be executed by plog
*/
#define APPENDLOG 1
#define EDITLOG 2
#define PRINTLOG 3
#define PRINTLOGTITLE 4
#define SORTLOG 5
char *PGN = "plog"; /* program name */
int PRINT_TITLE = YES; /* print message titles? */
main(argc, argv)
int argc;
char **argv;
{
extern int PPDEBUG; /* project pathname debug flag */
char command[PATHSIZE+8]; /* shell command buffer */
char *cwp; /* current working project */
char *getcwp(); /* get current working project */
char *pathcat(); /* pathname concatenation */
char *pathname; /* regular pathname */
char plog[PATHSIZE]; /* PROJECTLOG pathname */
char *strcpy(); /* string copy */
FILE *ifp; /* input file stream */
FILE *mustfopen(); /* must open file or die */
FILE *ofp; /* output file stream */
FILE *popen(); /* open pipe */
int action; /* what plog has to do */
int decoderange(); /* decode message range */
int naction = 0; /* number of non-default actions */
int range[2]; /* range of messages to print */
int sortlog(); /* sort project log by date */
int status = 0; /* exit status */
int xppath(); /* expand project pathname */
PATH pathbuf; /* pathname struct buffer */
void print(); /* print PROJECTLOG */
void print_head(); /* print PROJECTLOG message headings */
action = APPENDLOG;
range[0] = range[1] = 0;
{
register char *s; /* option pointer */
while (--argc > 0 && (**++argv == '-' || **argv == '+'))
{
if (**argv == '-')
{
for (s = argv[0]+1; *s != '\0'; s++)
switch (*s)
{
case 'D':
PPDEBUG = YES;
break;
case 'e':
action = EDITLOG;
naction++;
break;
case 'h':
PRINT_TITLE = NO;
break;
case 'p':
action = PRINTLOG;
naction++;
if (decoderange(++s, range) == NO)
status = 1;
goto endif;
case 's':
action = SORTLOG;
naction++;
break;
default:
warn("bad option -%c", *s);
status = 1;
goto endif;
}
}
else {
for (s = argv[0]+1; *s != '\0'; s++)
switch (*s)
{
case 'h':
action = PRINTLOGTITLE;
naction++;
break;
default:
warn("bad option +%c", *s);
status = 1;
goto endif;
}
}
endif: continue;
}
}
if (status == 1 || argc > 1)
{
fatal("usage: plog [-e] [{+-}h] [-p[low[-high]]] [-s] [projectname]");
}
if (naction > 1)
{
fatal("choose only one of -e, -p, -s, or +h options");
}
if (argc == 0)
{
if ((cwp = getcwp()) == NULL)
fatal("no project environment");
pathname = cwp;
}
else {
if (xppath(*argv, &pathbuf) == -1)
{
patherr(*argv);
exit(1);
}
switch (pathbuf.p_mode & P_IFMT)
{
case P_IFNEW:
case P_IFREG:
case P_IFPDIR:
fatal("%s: no such project", *argv);
case P_IFHOME:
case P_IFPROOT:
pathname = pathbuf.p_path;
break;
}
}
pathcat(plog, pathname, PROJECTLOG);
switch (action)
{
case APPENDLOG:
printf("Mailing to %s\n", plog);
sprintf(command, "Mail %s", plog);
status = system(command);
break;
case EDITLOG:
printf("Editing %s\n", plog);
sprintf(command, "Mail -f %s", plog);
status = system(command);
break;
case PRINTLOG:
ifp = mustfopen(plog, "r");
if (!isatty(fileno(stdout)) || (ofp = popen("more","w")) == NULL)
ofp = stdout;
print(ifp, ofp, range);
if (ofp != stdout)
pclose(ofp);
break;
case PRINTLOGTITLE:
ifp = mustfopen(plog, "r");
if (!isatty(fileno(stdout)) || (ofp = popen("more","w")) == NULL)
ofp = stdout;
print_head(ifp, ofp);
if (ofp != stdout)
pclose(ofp);
break;
case SORTLOG:
printf("Sorting %s\n", plog);
status = sortlog(plog);
break;
}
exit(status);
}
/*
* decoderange() determines the range of message numbers to be printed.
* Prints an error message and returns NO if syntax error, otherwise YES.
*/
decoderange(srange, range)
char *srange; /* range string to decode */
int range[]; /* decoded message range */
{
register char *s; /* range string pointer */
register int high = 0; /* high end of message range */
register int low = 0; /* low end of message range */
for (s = srange; isdigit(*s); s++)
low = 10*low + (*s - '0');
if (*s == '-')
for (s++; isdigit(*s); s++)
high = 10*high + (*s - '0');
if (*s != '\0')
{
warn("%s: bad message range", srange);
return(NO);
}
range[0] = low;
range[1] = high;
return(YES);
}
/*
* print() copies input stream to output stream, printing a title at
* the beginning of each log entry.
*/
void
print(ifp, ofp, range)
register FILE *ifp; /* input file stream */
register FILE *ofp; /* output file stream */
int range[]; /* range of messages to print */
{
register int high; /* top of range */
register int low; /* bottom of range */
register int msgno; /* current message number */
char *fgets(); /* get a line from input stream */
char linebuf[BUFSIZ]; /* input line buffer */
FROM *isfrom(); /* is line a "From " line? */
void print_title(); /* print message title */
msgno = 0;
low = range[0];
high = range[1];
while (fgets(linebuf, BUFSIZ, ifp) != NULL)
if (isfrom(linebuf) != NULL)
{
msgno++;
if (msgno < low)
continue;
else if (msgno > high && high != 0)
break;
if (PRINT_TITLE == YES)
{
print_title(linebuf, ifp, ofp);
}
else {
fputs(linebuf, ofp);
}
}
else {
if (msgno < low)
continue;
fputs(linebuf, ofp);
}
}
/*
* print_head() prints the log entry headings only.
*/
void
print_head(ifp, ofp)
register FILE *ifp; /* input file stream */
register FILE *ofp; /* output file stream */
{
register int msgno; /* current message number */
register char *sp; /* subject field pointer */
char *fgets(); /* get a line from input stream */
char linebuf[BUFSIZ]; /* input line buffer */
char *skipword(); /* skip to next word */
char *subject; /* beginning of subject field */
FROM *fromline; /* "From " line struct */
FROM *isfrom(); /* is line a "From " line? */
int i; /* read-ahead buffer counter */
int strlen(); /* string length */
int strncmp(); /* compare strings for n chars */
msgno = 0;
while (fgets(linebuf, BUFSIZ, ifp) != NULL)
if ((fromline = isfrom(linebuf)) != NULL)
{
msgno++;
fprintf(ofp, "%3d %-10s %s", msgno, fromline->from,
fromline->date);
for (i = 0; i < SUBJECT_MAX_FORWARD_LOOK; i++)
{
if (fgets(linebuf, BUFSIZ, ifp) == NULL)
break;
if (strncmp("Subject: ", linebuf, 9) == 0)
{
sp = subject = skipword(linebuf);
while (*sp != '\n' && *sp != '\0')
sp++;
*sp = '\0';
fprintf(ofp, " \"%s\"", subject);
}
else if (isfrom(linebuf) != NULL)
{
/* "From " line not welcome here */
fseek(ifp, (long) -strlen(linebuf), 1);
break;
}
}
putc('\n', ofp);
}
}
/*
* printsubject() pretty-prints a "Subject: " field.
*/
void
printsubject(linebuf, ofp)
char *linebuf; /* line containing subject */
register FILE *ofp; /* output file stream */
{
register int nblank; /* number of blanks to pad title */
char *skipword(); /* skip to next word */
int strlen(); /* string length */
nblank = (TITLELENGTH - (strlen(linebuf) - 9)) / 2;
/* length of "Subject: " = 9 chars */
while (nblank-- > 0)
putc(' ', ofp);
fputs(skipword(linebuf), ofp);
}
/*
* print_title() prints a subject title between two dashed lines.
* If a "Subject:" field cannot be found within SUBJECT_MAX_FORWARD_LOOK
* lines of the "From" line, then, a single dash line is printed.
*/
#define PUTDASHLINE(fp) {int i = TITLELENGTH; \
while (i-- > 0) putc('-', fp); putc('\n', fp);}
void
print_title(linebuf, ifp, ofp)
char linebuf[]; /* line buffer containing "From" */
register FILE *ifp; /* input file stream */
register FILE *ofp; /* output file stream */
{
char *fgets(); /* get a line from input stream */
char frombuf[BUFSIZ]; /* "From " line buffer */
char *strcpy(); /* string copy */
int i; /* read-ahead buffer counter */
int strncmp(); /* compare strings for n chars */
long ftell(); /* offset relative to file beginning */
long markifp; /* mark position of file */
void printsubject(); /* printprint "Subject: " field */
PUTDASHLINE(ofp);
markifp = ftell(ifp);
strcpy(frombuf, linebuf);
for (i = 0; i < SUBJECT_MAX_FORWARD_LOOK; i++)
{
if (fgets(linebuf, BUFSIZ, ifp) == NULL)
break;
if (strncmp("Subject: ", linebuf, 9) == 0)
{
printsubject(linebuf, ofp);
PUTDASHLINE(ofp);
break;
}
}
fputs(frombuf, ofp);
fseek(ifp, markifp, 0);
}
/*
* sortlog() sorts the project log by date. Returns status 0 if
* successful, otherwise 1.
*/
sortlog(logname)
char *logname; /* name of project log file */
{
register FILE *ifp; /* input file stream */
register int (*hstat)(); /* hangup status */
register int (*istat)(); /* interrupt status */
register int (*qstat)(); /* quit status */
register long nc = 0; /* number of characters read */
char *fgets(); /* get a line from input stream */
char linebuf[BUFSIZ]; /* input line buffer */
char *pathcat(); /* pathname concatenation */
char *pathhead(); /* remove pathname tail */
char *strcpy(); /* string copy */
FILE *mustfopen(); /* must open file or die */
FILE *ofp; /* output file stream */
FROM *from; /* broken down "From " line */
FROM *initfrom(); /* initialize "From " pointer array */
FROM *isfrom(); /* is line a "From " line? */
FROM *lastfrom; /* previous "From " line */
FROM *savefrom(); /* save "From " lines */
int len; /* length of input line */
int outfrom(); /* output "From " messages */
int parsedate(); /* parse ctime(3) generated date */
char sortlog[PATHSIZE]; /* temporary projectlog for sorting */
int status = 0; /* return status */
int strlen(); /* string length */
void sortfrom(); /* sort "From " lines */
ifp = mustfopen(logname, "r");
lastfrom = initfrom();
for (;;)
{
if (fgets(linebuf, BUFSIZ, ifp) == NULL)
break;
len = strlen(linebuf);
nc += len;
if ((from = isfrom(linebuf)) != NULL)
{
if (parsedate(from->date, &from->bdt) == NO)
{
warn("%s: bad date", from->date);
status = 1;
}
else {
from->m_seek = nc - len;
lastfrom->m_len = from->m_seek - lastfrom->m_seek;
if ((lastfrom = savefrom(from)) == NULL)
{
warn("out of memory");
return(1);
}
}
}
}
lastfrom->m_len = nc - lastfrom->m_seek;
if (status > 0)
return(status);
sortfrom();
pathcat(sortlog, pathhead(strcpy(sortlog, logname)), "temp_log");
if (FILEXIST(sortlog))
{
warn("%s sort in progress - try later", PROJECTLOG);
return(1);
}
hstat = signal(SIGHUP, SIG_IGN);
istat = signal(SIGINT, SIG_IGN);
qstat = signal(SIGQUIT, SIG_IGN);
ofp = mustfopen(sortlog, "w");
if (outfrom(ifp, ofp) == YES)
{
fclose(ifp);
fclose(ofp);
RENAME(sortlog, logname);
}
else {
warn("write error in %s: sort failed", sortlog);
fclose(ifp);
fclose(ofp);
unlink(sortlog);
status = 1;
}
signal(SIGINT, hstat);
signal(SIGINT, istat);
signal(SIGQUIT, qstat);
return(status);
}
/*
* skipword() skips a liberal (blank, tab delimited) word and returns a
* pointer to the next word.
*/
char *
skipword(bp)
register char *bp; /* buffer pointer */
{
for (; *bp != '\0' && isspace(*bp); bp++)
continue;
for (; *bp != '\0' && !isspace(*bp); bp++)
continue;
for (; *bp != '\0' && isspace(*bp); bp++)
continue;
return(bp);
}