lee@unmvax.UUCP (10/29/84)
#ifndef lint
char *Rcsid = "$Header: getmaps.c,v 1.4 84/10/13 18:19:13 lee Exp $";
#endif
/*
* getmaps
*
* Get the net maps from USENET as published by Karen and Mark Horton, in
* "shar" format. Because of paranoia the sh is not used but instead a DFA
* recognizing the appropriate commands.
*
* lee Ward 10/13/84
*/
#include <stdio.h>
#include <ctype.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/dir.h>
char *mapgrp = "/usr/spool/news/net/news/map";
char *mapdir = "/usr/lee/netmap/maps";
char *seqfil = "/usr/lee/netmap/.seq";
char *logfil = "/usr/lee/netmap/log";
char *usestr = "[-l logfil] [-g group] [-s seqfile] [-a archiv-dir]";
FILE *logsd = NULL;
void domaps(), myabort(), log(), mkmaps(), getwrd(), logtime();
main(argc, argv)
int argc;
char *argv[];
{
int x;
FILE *seqsd;
char seqbuf[BUFSIZ];
for (x = 1; x < argc; x++) {
if (*argv[x]++ != '-') {
fprintf(stderr, "Bad usage\n");
fprintf(stderr, "Usage: %s %s\n", argv[0], usestr);
exit(-1);
}
switch (*argv[x]) {
case 'l':
logfil = argv[++x];
break;
case 'g':
mapgrp = argv[++x];
break;
case 's':
seqfil = argv[++x];
break;
case 'a':
mapdir = argv[++x];
break;
default:
fprintf(stderr, "Bad switch\n");
fprintf(stderr, "Usage: %s %s\n", argv[0], usestr);
exit(-1);
}
}
logsd = fopen(logfil, "a");
logtime("Start");
if (chdir(mapdir) != 0)
myabort("Could not change directory to %s", mapdir);
seqbuf[0] = NULL;
if ((seqsd = fopen(seqfil, "r")) != NULL) {
if ((x = fread(seqbuf, sizeof(char), sizeof(seqbuf),
seqsd)) != 0)
seqbuf[x - 1] = NULL;
(void )fclose(seqsd);
}
if ((seqsd = fopen(seqfil, "a")) == NULL)
myabort("Could not open seq file for writing");
(void )fseek(seqsd, 0L, 0);
domaps(mapgrp, seqbuf, seqsd);
(void )fclose(seqsd);
logtime("End");
}
void
domaps(grp, seqbuf, seqsd)
char *grp, *seqbuf;
FILE *seqsd;
{
char nbuf[BUFSIZ], *nptr, *tptr;
struct direct **filst;
int nfils, x;
struct stat stbuf;
extern int scandir(), alphasort();
extern char *strcpy(), *strncat();
if ((nfils = scandir(grp, &filst, (int (*)())NULL, alphasort)) == -1)
myabort("scandir failed");
(void )strcpy(nbuf, grp);
nptr = nbuf + strlen(nbuf);
*nptr++ = '/';
*nptr = NULL;
nbuf[BUFSIZ] = NULL;
for (x = 0; x < nfils; x++) {
if (strcmp(".", filst[x]->d_name) == 0 ||
strcmp("..", filst[x]->d_name) == 0)
continue;
tptr = filst[x]->d_name;
while(*tptr && isdigit(*tptr))
tptr++;
if (*tptr != NULL)
continue;
*nptr = NULL;
(void )strncat(nptr, filst[x]->d_name,
BUFSIZ - (nptr - nbuf) - 1);
if (stat(nbuf, &stbuf) != 0) {
log("Could not stat %s", nbuf);
continue;
}
if ((stbuf.st_mode & S_IFMT) == S_IFDIR)
continue;
if (strcmp(seqbuf, filst[x]->d_name) >= 0)
continue;
mkmaps(nbuf);
(void )fseek(seqsd, 0L, 0);
(void )fwrite(filst[x]->d_name, sizeof(char),
strlen(filst[x]->d_name), seqsd);
(void )fputc('\n', seqsd);
(void )fflush(seqsd);
}
}
void
mkmaps(file)
char *file;
{
char buf[BUFSIZ], tofil[BUFSIZ], delim[BUFSIZ];
int state, sizdel;
FILE *isd, *osd;
extern FILE *fopen();
#define SEARCH 1
#define INAMAP 2
#define SKIPPING 3
if ((isd = fopen(file, "r")) == NULL) {
log("Could not open %s. Skipping...", file);
return;
}
log("Unarchive %s", file);
state = SEARCH;
while (fgets(buf, sizeof(buf) - 1, isd) != NULL) {
buf[sizeof(buf)] = NULL;
if (state == SEARCH) {
if (gotcat(buf, tofil, BUFSIZ, delim, BUFSIZ)) {
state = INAMAP;
sizdel = strlen(delim);
if ((osd = fopen(tofil, "w")) == NULL) {
log("Could not open %s", tofil);
state = SKIPPING;
}
}
continue;
}
if (strncmp(buf, delim, sizdel) == 0) {
state = SEARCH;
if (osd != NULL)
(void )fclose(osd);
continue;
}
if (state == SKIPPING)
continue;
fputs(buf, osd);
}
if (state != SEARCH)
log("Read/sync error on %s", file);
(void )fclose(isd);
#undef SEARCH
#undef INAMAP
#undef SKIPPING
}
/*
* gotcat
*
* Use a DFA to recognize
* cat << DELIM > OUT
* or
* cat > OUT << DELIM
*
*/
/* Transition table for the DFA */
int ttbl[9][4] = {
1,-1,-1,-1,
-1,6,2,-1,
-1,-1,-1,3,
-1,4,-1,-1,
-1,-1,-1,5,
-1,-1,-1,-1,
-1,-1,-1,7,
-1,-1,8,-1,
-1,-1,-1,5,
};
gotcat(buf, tofil, tofilln, delim, delimln)
char *buf,
*tofil,
*delim;
int tofilln,
delimln;
{
int state;
char *ptr;
state = 0; /* Start state */
while (state != -1 && state != 5) {
/* Eat up white */
while (*buf != '\n' && (*buf == ' ' || *buf == '\t'))
buf++;
if (*buf == '>') {
buf++;
state = ttbl[state][1];
continue;
}
if (*buf == '<' && *(buf + 1) == '<') {
buf += 2;
state = ttbl[state][2];
continue;
}
if (*buf == 'c' && *(buf + 1) == 'a' && *(buf + 2) == 't') {
buf += 3;
state = ttbl[state][0];
continue;
}
ptr = buf;
while (*buf != '\n' && *buf != ' ' && *buf != '\t')
buf++;
if (state == 2 || state == 8)
getwrd(ptr, buf, delim, delimln);
else if (state == 6 || state == 4)
getwrd(ptr, buf, tofil, tofilln);
state = ttbl[state][3];
}
if (state == 5)
return(1);
return(0);
}
void
getwrd(fc, lc, buf, maxlen)
char *fc,
*lc,
*buf;
int maxlen;
{
char *ptr, *t1ptr, *t2ptr;
maxlen--;
maxlen = lc - fc > maxlen ? maxlen : lc - fc;
ptr = buf;
t1ptr = fc;
while (maxlen-- != 0)
*ptr++ = *t1ptr++;
*ptr = NULL;
/* Strip quotes */
ptr = buf;
while (*ptr != NULL) {
if (*ptr == '\\' && (*(ptr + 1) == '\'' || *(ptr + 1) == '"'))
ptr += 2;
else if (*ptr == '\'' || *ptr == '"') {
t1ptr = ptr;
t2ptr = ptr + 1;
while ((*t1ptr++ = *t2ptr++) != NULL)
;
} else
ptr++;
}
}
/*VARARGS1*/
void
myabort(s, a, b, c, d, e, f, g, h, i, j, k, l)
char *s;
{
if (logsd != NULL) {
fputs("ABORT - ", logsd);
fprintf(logsd, s, a, b, c, d, e, f, g, h, i, j, k, l);
(void )fputc('\n', logsd);
logtime("End");
}
exit(-1);
}
/*VARARGS1*/
void
log(s, a, b, c, d, e, f, g, h, i, j, k, l)
char *s;
{
if (logsd == NULL)
return;
fprintf(logsd, s, a, b, c, d, e, f, g, h, i, j, k, l);
(void )fputc('\n', logsd);
(void )fflush(logsd);
}
void
logtime(s)
char *s;
{
time_t clock;
extern char *ctime();
if (logsd == NULL)
return;
(void )time(&clock);
fprintf(logsd, "%s %s", s, ctime(&clock));
(void )fflush(logsd);
}
--
--Lee (Ward)
{ucbvax,convex,gatech,pur-ee}!unmvax!lee