/*
* Usage: bbsnnrp [options] nntpserver activefile -h|? (help) -v (verbose
* protocol transactions) -c (reset active files only; don't receive
* articles) -r remotehost(send articles to remotehost, default=local) -p
* port|(send articles to remotehost at port, default=7777) path(send
* articles to local at path, default=~bbs/innd/.innbbsd) -n (don't ask
* innbbsd server and stat articles) -w seconds (wait for seconds and run
* infinitely, default=once) -a max_art (maximum number of articles received
* for a group each time) -s max_stat(maximum number of articles stated for a
* group each time) -t stdin|nntp (default=nntp)
*/
#include "innbbsconf.h"
#include <sys/mman.h>
#ifndef AIX
#include <sys/fcntl.h>
#endif
#include "bbslib.h"
#include "daemon.h"
#include "nntp.h"
#ifndef MAX_ARTS
#define MAX_ARTS 100
#endif
#ifndef MAX_STATS
#define MAX_STATS 1000
#endif
#if defined(__linux)
#define NO_USE_MMAP
#else
#define USE_MMAP
#endif
int Max_Arts = MAX_ARTS;
int Max_Stats = MAX_STATS;
typedef struct NEWSRC_T {
char *nameptr, *lowptr, *highptr, *modeptr;
int namelen, lowlen, highlen;
ULONG low, high;
int mode, subscribe;
} newsrc_t;
typedef struct NNRP_T {
int nnrpfd;
int innbbsfd;
FILE *nnrpin, *nnrpout;
FILE *innbbsin, *innbbsout;
char activefile[MAXPATHLEN];
char rcfile[MAXPATHLEN];
newsrc_t *newsrc;
char *actpointer, *actend;
int actsize, actfd, actdirty;
} nnrp_t;
typedef struct XHDR_T {
char *header;
ULONG artno;
} xhdr_t;
xhdr_t XHDR[MAX_ARTS];
char LockFile[1024];
#define NNRPGroupOK NNTP_GROUPOK_VAL
#define NNRPXhdrOK NNTP_HEAD_FOLLOWS_VAL
#define NNRParticleOK NNTP_ARTICLE_FOLLOWS_VAL
#define INNBBSstatOK NNTP_NOTHING_FOLLOWS_VAL
#define INNBBSihaveOK NNTP_SENDIT_VAL
#define NNRPconnectOK NNTP_POSTOK_VAL
#define NNRPstatOK NNTP_NOTHING_FOLLOWS_VAL
#define INNBBSconnectOK NNTP_POSTOK_VAL
nnrp_t BBSNNRP;
void
doterm(s)
int s;
{
printf("bbsnnrp terminated. Signal %d\n", s);
writerc(&BBSNNRP);
if (isfile(LockFile))
unlink(LockFile);
exit(1);
}
extern char *optarg;
extern int opterr, optind;
#ifndef MIN_WAIT
#define MIN_WAIT 60
#endif
int ResetActive = 0;
int StatHistory = 1;
int AskLocal = 1;
int RunOnce = 1;
int DefaultWait = MIN_WAIT;
char *DefaultPort = DefaultINNBBSPort;
char *DefaultPath = LOCALDAEMON;
char *DefaultRemoteHost;
#ifndef MAXBUFLEN
#define MAXBUFLEN 256
#endif
char DefaultNewsgroups[MAXBUFLEN];
char DefaultOrganization[MAXBUFLEN];
char DefaultModerator[MAXBUFLEN];
char DefaultTrustfrom[MAXBUFLEN];
char DefaultTrustFrom[MAXBUFLEN];
usage(arg)
char *arg;
{
fprintf(stderr, "Usage: %s [options] nntpserver activefile\n", arg);
fprintf(stderr, " -h|? (help) \n");
fprintf(stderr, " -v (verbose protocol transactions)\n");
fprintf(stderr, " -c (reset active files only; don't receive articles)\n");
fprintf(stderr, " -r [proto:]remotehost\n");
fprintf(stderr, " (send articles to remotehost, default=ihave:local)\n");
fprintf(stderr, " -p port|(send articles to remotehost at port, default=%s)\n", DefaultINNBBSPort);
fprintf(stderr, " path(send articles to local at path, default=~bbs/innd/.innbbsd)\n");
fprintf(stderr, " -w seconds ( > 1 wait for seconds and run infinitely, default=once)\n");
fprintf(stderr, " -n (don't ask innbbsd server and stat articles)\n");
fprintf(stderr, " -a max_art(maximum number of articles received for a group each time)\n");
fprintf(stderr, " default=%d\n", MAX_ARTS);
fprintf(stderr, " -s max_stat(maximum number of articles stated for a group each time)\n");
fprintf(stderr, " default=%d\n", MAX_STATS);
fprintf(stderr, " -t stdin|nntp (default=nntp)\n");
fprintf(stderr, " -g newsgroups\n");
fprintf(stderr, " -m moderator\n");
fprintf(stderr, " -o organization\n");
fprintf(stderr, " -f trust_user (From: trust_user)\n");
fprintf(stderr, " -F trust_user (From trust_user)\n");
fprintf(stderr, " Please E-mail bug to skhuang@csie.nctu.edu.tw or\n");
fprintf(stderr, " post to tw.bbs.admin.installbbs\n");
}
static char *StdinInputType = "stdin";
static char *NntpInputType = "nntp";
static char *NntpIhaveProtocol = "ihave";
static char *NntpPostProtocol = "post";
static char *DefaultNntpProtocol;
main(argc, argv)
int argc;
char **argv;
{
char *ptr, *server, *active;
int c, errflag = 0;
int lockfd;
char *inputtype;
DefaultNntpProtocol = NntpIhaveProtocol;
*DefaultNewsgroups = '\0';
*DefaultModerator = '\0';
*DefaultOrganization = '\0';
*DefaultTrustFrom = '\0';
*DefaultTrustfrom = '\0';
inputtype = NntpInputType;
while ((c = getopt(argc, argv, "f:F:m:o:g:w:r:p:a:s:t:h?ncv")) != -1)
switch (c) {
case 'v':
verboseon("bbsnnrp.log");
break;
case 'c':
ResetActive = 1;
break;
case 'g':
strncpy(DefaultNewsgroups, optarg, sizeof DefaultNewsgroups);
break;
case 'm':
strncpy(DefaultModerator, optarg, sizeof DefaultModerator);
break;
case 'o':
strncpy(DefaultOrganization, optarg, sizeof DefaultOrganization);
break;
case 'f':
strncpy(DefaultTrustfrom, optarg, sizeof DefaultTrustfrom);
break;
case 'F':
strncpy(DefaultTrustFrom, optarg, sizeof DefaultTrustFrom);
break;
case 'r':{
char *hostptr;
AskLocal = 0;
DefaultRemoteHost = optarg;
if ((hostptr = strchr(optarg, ':')) != NULL) {
*hostptr = '\0';
DefaultRemoteHost = hostptr + 1;
if (strcasecmp(optarg, "post") == 0)
DefaultNntpProtocol = NntpPostProtocol;
*hostptr = ':';
}
break;
}
case 'w':
RunOnce = 0;
DefaultWait = atoi(optarg);
if (DefaultWait < MIN_WAIT)
DefaultWait = MIN_WAIT;
break;
case 'p':
if (AskLocal == 0) {
DefaultPort = optarg;
} else {
DefaultPath = optarg;
}
break;
case 'n':
StatHistory = 0;
break;
case 'a':
Max_Arts = atol(optarg);
if (Max_Arts < 0)
Max_Arts = 0;
break;
case 's':
Max_Stats = atol(optarg);
if (Max_Stats < 0)
Max_Stats = 0;
break;
case 't':
if (strcasecmp(optarg, StdinInputType) == 0) {
inputtype = StdinInputType;
}
break;
case 'h':
case '?':
default:
errflag++;
}
if (errflag > 0) {
usage(argv[0]);
return (1);
}
if (inputtype == NntpInputType && argc - optind < 2) {
usage(argv[0]);
exit(1);
}
if (inputtype == NntpInputType) {
server = argv[optind];
active = argv[optind + 1];
if (isfile(active)) {
strncpy(BBSNNRP.activefile, active, sizeof BBSNNRP.activefile);
} else if (strchr(active, '/') == NULL) {
sprintf(BBSNNRP.activefile, "%s/innd/%.*s", BBSHOME, sizeof BBSNNRP.activefile - 7 - strlen(BBSHOME), active);
} else {
strncpy(BBSNNRP.activefile, active, sizeof BBSNNRP.activefile);
}
strncpy(LockFile, (char *)fileglue("%s.lock", active), sizeof LockFile);
if ((lockfd = open(LockFile, O_RDONLY)) >= 0) {
char buf[10];
int pid;
if (read(lockfd, buf, sizeof buf) > 0 && (pid = atoi(buf)) > 0 && kill(pid, 0) == 0) {
fprintf(stderr, "another process [%d] running\n", pid);
exit(1);
} else {
fprintf(stderr, "no process [%d] running, but lock file existed, unlinked\n", pid);
unlink(LockFile);
}
close(lockfd);
}
if ((lockfd = open(LockFile, O_RDWR | O_CREAT | O_EXCL, 0644)) < 0) {
fprintf(stderr, "maybe another %s process running\n", argv[0]);
exit(1);
} else {
char buf[10];
int pid;
sprintf(buf, "%-.8d\n", getpid());
write(lockfd, buf, strlen(buf));
close(lockfd);
}
for (;;) {
if (!initial_bbs(NULL)) {
fprintf(stderr, "Initial BBS failed\n");
exit(1);
}
initsockets(server, &BBSNNRP, inputtype);
ptr = (char *)strrchr(active, '/');
if (ptr != NULL)
ptr++;
else
ptr = active;
sprintf(BBSNNRP.rcfile, "%s/.newsrc.%s.%s", INNDHOME, server, ptr);
initrcfiles(&BBSNNRP);
signal(SIGTERM, doterm);
signal(SIGKILL, doterm);
signal(SIGHUP, doterm);
signal(SIGPIPE, doterm);
readnews(server, &BBSNNRP);
writerc(&BBSNNRP);
closesockets();
if (RunOnce)
break;
sleep(DefaultWait);
}
unlink(LockFile);
}
/* NntpInputType */
else {
if (!initial_bbs(NULL)) {
fprintf(stderr, "Initial BBS failed\n");
exit(1);
}
initsockets(server, &BBSNNRP, inputtype);
signal(SIGTERM, doterm);
signal(SIGKILL, doterm);
signal(SIGHUP, doterm);
signal(SIGPIPE, doterm);
stdinreadnews(&BBSNNRP);
closesockets();
} /* stdin input type */
return 0;
}
headbegin(buffer)
char *buffer;
{
if (strncmp(buffer, "Path: ", 6) == 0) {
if (strchr(buffer + 6, '!') != NULL)
return 1;
}
if (strncmp(buffer, "From ", 5) == 0) {
if (strchr(buffer + 5, ':') != NULL)
return 1;
}
return 0;
}
stdinreadnews(bbsnnrp)
nnrp_t *bbsnnrp;
{
int i;
char buffer[4096];
ULONG low, high;
char tmpfilename[MAXPATHLEN];
FILE *tmpfp = NULL;
char mid[1024];
int pathagain;
int ngmet, submet, midmet, pathmet, orgmet, approvedmet;
int discard;
char sending_path[MAXPATHLEN];
int sending_path_len = 0;
strncpy(tmpfilename, (char *)fileglue("/tmp/bbsnnrp-stdin-%d-%d", getuid(), getpid()), sizeof tmpfilename);
fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
verboselog("innbbsGet: %s", buffer);
if (atoi(buffer) != INNBBSconnectOK) {
fprintf(stderr, "INNBBS server not OK\n");
return;
}
if (DefaultNntpProtocol == NntpPostProtocol) {
fputs("MODE READER\r\n", bbsnnrp->innbbsout);
fflush(bbsnnrp->innbbsout);
verboselog("innbbsPut: MODE READER\n");
fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
verboselog("innbbsGet: %s", buffer);
}
if (StatHistory == 0) {
fputs("MIDCHECK OFF\r\n", bbsnnrp->innbbsout);
fflush(bbsnnrp->innbbsout);
verboselog("innbbsPut: MIDCHECK OFF\n");
fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
verboselog("innbbsGet: %s", buffer);
}
tmpfp = fopen(tmpfilename, "w");
if (tmpfp == NULL)
return;
*mid = '\0';
for (;;) {
fprintf(stderr, "Try to read from stdin ...\n");
ngmet = 0, submet = 0, midmet = 0, pathmet = 0, orgmet = 0, approvedmet = 0;
discard = 0;
while (fgets(buffer, sizeof buffer, stdin) != NULL) {
char *tmpptr;
tmpptr = strchr(buffer, '\n');
if (tmpptr != NULL)
*tmpptr = '\0';
if (strncasecmp(buffer, "Message-ID: ", 12) == 0) {
strncpy(mid, buffer + 12, sizeof mid);
midmet = 1;
} else if (strncmp(buffer, "Subject: ", 9) == 0) {
submet = 1;
} else if (strncmp(buffer, "Path: ", 6) == 0) {
pathmet = 1;
} else if (strncmp(buffer, "Organization: ", 14) == 0) {
orgmet = 1;
} else if (strncmp(buffer, "Approved: ", 10) == 0) {
approvedmet = 1;
} else if (strncmp(buffer, "From: ", 6) == 0 && *DefaultTrustfrom) {
if (strstr(buffer + 6, DefaultTrustfrom) == NULL) {
discard = 1;
verboselog("Discard: %s for %s", buffer, DefaultTrustfrom);
}
} else if (strncmp(buffer, "From ", 5) == 0 && *DefaultTrustFrom) {
if (strstr(buffer + 5, DefaultTrustFrom) == NULL) {
discard = 1;
verboselog("Discard: %s for %s", buffer, DefaultTrustFrom);
}
} else if (strncmp(buffer, "Received: ", 10) == 0) {
char *rptr = buffer + 10, *rrptr;
int savech, len;
if (strncmp(buffer + 10, "from ", 5) == 0) {
rptr += 5;
rrptr = strchr(rptr, '(');
if (rrptr != NULL)
rptr = rrptr + 1;
rrptr = strchr(rptr, ' ');
savech = *rrptr;
if (rrptr != NULL)
*rrptr = '\0';
} else if (strncmp(buffer + 10, "(from ", 6) == 0) {
rptr += 6;
rrptr = strchr(rptr, ')');
savech = *rrptr;
if (rrptr != NULL)
*rrptr = '\0';
}
len = strlen(rptr) + 1;
if (*rptr && sending_path_len + len < sizeof(sending_path)) {
if (*sending_path)
strcat(sending_path, "!");
strcat(sending_path, rptr);
sending_path_len += len;
}
if (rrptr != NULL)
*rrptr = savech;
}
if (strncmp(buffer, "Newsgroups: ", 12) == 0) {
if (*DefaultNewsgroups) {
fprintf(tmpfp, "Newsgroups: %s\r\n", DefaultNewsgroups);
} else {
fprintf(tmpfp, "%s\r\n", buffer);
}
ngmet = 1;
} else {
if (buffer[0] == '\0') {
if (!ngmet && *DefaultNewsgroups) {
fprintf(tmpfp, "Newsgroups: %s\r\n", DefaultNewsgroups);
}
if (!submet) {
fprintf(tmpfp, "Subject: (no subject)\r\n");
}
if (!pathmet) {
fprintf(tmpfp, "Path: from-mail\r\n");
}
if (!midmet) {
static int seed;
time_t now;
time(&now);
fprintf(tmpfp, "Message-ID: <%d@%d.%d.%d>\r\n", now, getpid(), getuid(), seed);
sprintf(mid, "<%d@%d.%d.%d>", now, getpid(), getuid(), seed);
seed++;
}
if (!orgmet && *DefaultOrganization) {
fprintf(tmpfp, "Organization: %s\r\n", DefaultOrganization);
}
if (!approvedmet && *DefaultModerator) {
fprintf(tmpfp, "Approved: %s\r\n", DefaultModerator);
}
}
if (strncmp(buffer, "From ", 5) != 0 && strncmp(buffer, "To: ", 4) != 0) {
if (buffer[0] == '\0') {
if (*sending_path) {
fprintf(tmpfp, "X-Sending-Path: %s\r\n", sending_path);
}
}
fprintf(tmpfp, "%s\r\n", buffer);
}
}
if (buffer[0] == '\0')
break;
}
fprintf(stderr, "Article Body begin ...\n");
pathagain = 0;
while (fgets(buffer, sizeof buffer, stdin) != NULL) {
char *tmpptr;
tmpptr = strchr(buffer, '\n');
if (tmpptr != NULL)
*tmpptr = '\0';
if (headbegin(buffer)) {
FILE *oldfp = bbsnnrp->nnrpin;
pathagain = 1;
fputs(".\r\n", tmpfp);
fclose(tmpfp);
fprintf(stderr, "Try to post ...\n");
tmpfp = fopen(tmpfilename, "r");
bbsnnrp->nnrpin = tmpfp;
if (!discard)
if (INNBBSihave(bbsnnrp, -1, mid) == -1) {
fprintf(stderr, "post failed\n");
}
bbsnnrp->nnrpin = oldfp;
fclose(tmpfp);
*mid = '\0';
tmpfp = fopen(tmpfilename, "w");
fprintf(tmpfp, "%s\r\n", buffer);
break;
} else {
fprintf(tmpfp, "%s\r\n", buffer);
}
}
if (!pathagain)
break;
}
if (!pathagain && tmpfp) {
FILE *oldfp = bbsnnrp->nnrpin;
fputs(".\r\n", tmpfp);
fclose(tmpfp);
fprintf(stderr, "Try to post ...\n");
tmpfp = fopen(tmpfilename, "r");
bbsnnrp->nnrpin = tmpfp;
if (!discard)
if (INNBBSihave(bbsnnrp, -1, mid) == -1) {
fprintf(stderr, "post failed\n");
}
bbsnnrp->nnrpin = oldfp;
fclose(tmpfp);
}
if (isfile(tmpfilename)) {
unlink(tmpfilename);
}
}
static char *ACT_BUF, *RC_BUF;
int ACT_COUNT;
initrcfiles(bbsnnrp)
nnrp_t *bbsnnrp;
{
FILE *actfp, *rcfp;
char buff[1024];
int actfd, i, count, actcount = 0, rcount = 0, maxcount;
struct stat st;
char *actlistptr, *ptr;
actfd = open(bbsnnrp->activefile, O_RDWR);
if (actfd < 0) {
fprintf(stderr, "can't read/write %s\n", bbsnnrp->activefile);
exit(1);
}
if (fstat(actfd, &st) != 0) {
fprintf(stderr, "can't stat %s\n", bbsnnrp->activefile);
exit(1);
}
bbsnnrp->actfd = actfd;
bbsnnrp->actsize = st.st_size;
#ifdef USE_MMAP
bbsnnrp->actpointer = mmap(0, st.st_size, PROT_WRITE | PROT_READ,
MAP_SHARED, actfd, 0);
if (bbsnnrp->actpointer == (char *)-1) {
fprintf(stderr, "mmap error \n");
exit(1);
}
#else
if (bbsnnrp->actpointer == NULL) {
bbsnnrp->actpointer = (char *)mymalloc(st.st_size);
} else {
bbsnnrp->actpointer = (char *)myrealloc(bbsnnrp->actpointer, st.st_size);
}
if (bbsnnrp->actpointer == NULL || read(actfd, bbsnnrp->actpointer, st.st_size) <= 0) {
fprintf(stderr, "read act error \n");
exit(1);
}
#endif
bbsnnrp->actend = bbsnnrp->actpointer + st.st_size;
i = 0, count = 0;
for (ptr = bbsnnrp->actpointer; ptr < bbsnnrp->actend && (actlistptr = (char *)strchr(ptr, '\n')) != NULL; ptr = actlistptr + 1, ACT_COUNT++) {
if (*ptr == '\n')
continue;
if (*ptr == '#')
continue;
count++;
}
bbsnnrp->newsrc = (newsrc_t *) mymalloc(sizeof(newsrc_t) * count);
ACT_COUNT = 0;
for (ptr = bbsnnrp->actpointer; ptr < bbsnnrp->actend && (actlistptr = (char *)strchr(ptr, '\n')) != NULL; ptr = actlistptr + 1) {
register newsrc_t *rcptr;
char *nptr;
/**actlistptr = '\0';*/
if (*ptr == '\n')
continue;
if (*ptr == '#')
continue;
rcptr = &bbsnnrp->newsrc[ACT_COUNT];
rcptr->nameptr = NULL;
rcptr->namelen = 0;
rcptr->lowptr = NULL;
rcptr->lowlen = 0;
rcptr->highptr = NULL;
rcptr->highlen = 0;
rcptr->modeptr = NULL;
rcptr->low = 0;
rcptr->high = 0;
rcptr->mode = 'y';
for (nptr = ptr; *nptr && isspace(*nptr);)
nptr++;
if (nptr == actlistptr)
continue;
rcptr->nameptr = nptr;
for (nptr++; *nptr && !isspace(*nptr);)
nptr++;
rcptr->namelen = (int)(nptr - rcptr->nameptr);
if (nptr == actlistptr)
continue;
for (nptr++; *nptr && isspace(*nptr);)
nptr++;
if (nptr == actlistptr)
continue;
rcptr->highptr = nptr;
rcptr->high = atol(nptr);
for (nptr++; *nptr && !isspace(*nptr);)
nptr++;
rcptr->highlen = (int)(nptr - rcptr->highptr);
if (nptr == actlistptr)
continue;
for (nptr++; *nptr && isspace(*nptr);)
nptr++;
if (nptr == actlistptr)
continue;
rcptr->lowptr = nptr;
rcptr->low = atol(nptr);
for (nptr++; *nptr && !isspace(*nptr);)
nptr++;
rcptr->lowlen = (int)(nptr - rcptr->lowptr);
if (nptr == actlistptr)
continue;
for (nptr++; *nptr && isspace(*nptr);)
nptr++;
if (nptr == actlistptr)
continue;
rcptr->mode = *nptr;
rcptr->modeptr = nptr;
ACT_COUNT++;
}
}
initsockets(server, bbsnnrp, type)
char *server;
nnrp_t *bbsnnrp;
char *type;
{
int nnrpfd;
int innbbsfd;
if (AskLocal) {
innbbsfd = unixclient(DefaultPath, "tcp");
if (innbbsfd < 0) {
fprintf(stderr, "Connect to %s error. You may not run innbbsd\n", LOCALDAEMON);
/*
* unix connect fail, may run by inetd, try to connect to local
* once
*/
innbbsfd = inetclient("localhost", DefaultPort, "tcp");
if (innbbsfd < 0) {
exit(2);
}
close(innbbsfd);
/* try again */
innbbsfd = unixclient(DefaultPath, "tcp");
if (innbbsfd < 0) {
exit(3);
}
}
verboselog("INNBBS connect to %s\n", DefaultPath);
} else {
innbbsfd = inetclient(DefaultRemoteHost, DefaultPort, "tcp");
if (innbbsfd < 0) {
fprintf(stderr, "Connect to %s at %s error. Remote Server not Ready\n", DefaultRemoteHost, DefaultPort);
exit(2);
}
verboselog("INNBBS connect to %s\n", DefaultRemoteHost);
}
if (type == StdinInputType) {
bbsnnrp->nnrpfd = 0;
bbsnnrp->innbbsfd = innbbsfd;
if ((bbsnnrp->nnrpin = fdopen(0, "r")) == NULL ||
(bbsnnrp->nnrpout = fdopen(1, "w")) == NULL ||
(bbsnnrp->innbbsin = fdopen(innbbsfd, "r")) == NULL ||
(bbsnnrp->innbbsout = fdopen(innbbsfd, "w")) == NULL) {
fprintf(stderr, "fdopen error\n");
exit(3);
}
return;
}
nnrpfd = inetclient(server, "nntp", "tcp");
if (nnrpfd < 0) {
fprintf(stderr, " connect to %s error \n", server);
exit(2);
}
verboselog("NNRP connect to %s\n", server);
bbsnnrp->nnrpfd = nnrpfd;
bbsnnrp->innbbsfd = innbbsfd;
if ((bbsnnrp->nnrpin = fdopen(nnrpfd, "r")) == NULL ||
(bbsnnrp->nnrpout = fdopen(nnrpfd, "w")) == NULL ||
(bbsnnrp->innbbsin = fdopen(innbbsfd, "r")) == NULL ||
(bbsnnrp->innbbsout = fdopen(innbbsfd, "w")) == NULL) {
fprintf(stderr, "fdopen error\n");
exit(3);
}
}
closesockets()
{
fclose(BBSNNRP.nnrpin);
fclose(BBSNNRP.nnrpout);
fclose(BBSNNRP.innbbsin);
fclose(BBSNNRP.innbbsout);
close(BBSNNRP.nnrpfd);
close(BBSNNRP.innbbsfd);
}
updaterc(actptr, len, value)
char *actptr;
int len;
ULONG value;
{
for (actptr += len - 1; len-- > 0;) {
*actptr-- = value % 10 + '0';
value /= 10;
}
}
/*
* if old file is empty, don't need to update prevent from disk full
*/
int
myrename(old, new)
char *old, *new;
{
struct stat st;
if (stat(old, &st) != 0)
return -1;
if (st.st_size <= 0)
return -1;
return rename(old, new);
}
flushrc(bbsnnrp)
nnrp_t *bbsnnrp;
{
int backfd;
char *bak1;
if (bbsnnrp->actdirty == 0)
return;
bak1 = (char *)strdup((char *)fileglue("%s.BAK", bbsnnrp->activefile));
if (isfile(bak1)) {
myrename(bak1, (char *)fileglue("%s.BAK.OLD", bbsnnrp->activefile));
}
#ifdef USE_MMAP
if ((backfd = open((char *)fileglue("%s.BAK", bbsnnrp->activefile), O_WRONLY | O_TRUNC | O_CREAT, 0664)) < 0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize)
#else
myrename(bbsnnrp->activefile, bak1);
if ((backfd = open(bbsnnrp->activefile, O_WRONLY | O_TRUNC | O_CREAT, 0664)) < 0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize)
#endif
{
char emergent[128];
sprintf(emergent, "/tmp/bbsnnrp.%d.active", getpid());
fprintf(stderr, "write to backup active fail. Maybe disk full\n");
fprintf(stderr, "try to write in %s\n", emergent);
if ((backfd = open(emergent, O_WRONLY | O_TRUNC | O_CREAT, 0644)) < 0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize) {
fprintf(stderr, "write to %sfail.\n", emergent);
} else {
close(backfd);
}
/* if write fail, should leave */
/* exit(1); */
} else {
close(backfd);
}
free(bak1);
bbsnnrp->actdirty = 0;
}
writerc(bbsnnrp)
nnrp_t *bbsnnrp;
{
if (bbsnnrp->actpointer) {
flushrc(bbsnnrp);
#ifdef USE_MMAP
if (munmap(bbsnnrp->actpointer, bbsnnrp->actsize) < 0)
fprintf(stderr, "can't unmap\n");
/* free(bbsnnrp->actpointer); */
bbsnnrp->actpointer = NULL;
#endif
if (close(bbsnnrp->actfd) < 0)
fprintf(stderr, "can't close actfd\n");
}
}
static FILE *Xhdrfp;
static char NNRPbuffer[4096];
static char INNBBSbuffer[4096];
char *
NNRPgets(string, len, fp)
char *string;
int len;
FILE *fp;
{
char *re = fgets(string, len, fp);
char *ptr;
if (re != NULL) {
if ((ptr = (char *)strchr(string, '\r')) != NULL)
*ptr = '\0';
if ((ptr = (char *)strchr(string, '\n')) != NULL)
*ptr = '\0';
}
return re;
}
int
NNRPstat(bbsnnrp, artno, mid)
nnrp_t *bbsnnrp;
ULONG artno;
char **mid;
{
char *ptr;
int code;
*mid = NULL;
fprintf(bbsnnrp->nnrpout, "STAT %d\r\n", artno);
fflush(bbsnnrp->nnrpout);
verboselog("nnrpPut: STAT %d\n", artno);
NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
verboselog("nnrpGet: %s\n", NNRPbuffer);
ptr = (char *)strchr(NNRPbuffer, ' ');
if (ptr != NULL)
*ptr++ = '\0';
code = atoi(NNRPbuffer);
ptr = (char *)strchr(ptr, ' ');
if (ptr != NULL)
*ptr++ = '\0';
*mid = ptr;
ptr = (char *)strchr(ptr, ' ');
if (ptr != NULL)
*ptr++ = '\0';
return code;
}
int
NNRPxhdr(pattern, bbsnnrp, i, low, high)
char *pattern;
nnrp_t *bbsnnrp;
int i;
ULONG low, high;
{
newsrc_t *rcptr = &bbsnnrp->newsrc[i];
int size, code;
Xhdrfp = bbsnnrp->nnrpin;
fprintf(bbsnnrp->nnrpout, "XHDR %s %d-%d\r\n", pattern, low, high);
#ifdef BBSNNRPDEBUG
printf("XHDR %s %d-%d\r\n", pattern, low, high);
#endif
fflush(bbsnnrp->nnrpout);
verboselog("nnrpPut: XHDR %s %d-%d\n", pattern, low, high);
NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
verboselog("nnrpGet: %s\n", NNRPbuffer);
code = atoi(NNRPbuffer);
return code;
}
int
NNRPxhdrget(artno, mid, iscontrol)
int *artno;
char **mid;
int iscontrol;
{
*mid = NULL;
*artno = 0;
if (NNRPgets(NNRPbuffer, sizeof NNRPbuffer, Xhdrfp) == NULL)
return 0;
else {
char *ptr, *s;
if (strcmp(NNRPbuffer, ".") == 0)
return 0;
ptr = (char *)strchr(NNRPbuffer, ' ');
if (!ptr)
return 1;
*ptr++ = '\0';
*artno = atol(NNRPbuffer);
if (iscontrol) {
ptr = (char *)strchr(s = ptr, ' ');
if (!ptr)
return 1;
*ptr++ = '\0';
if (strcmp(s, "cancel") != 0)
return 1;
}
*mid = ptr;
return 1;
}
}
int
INNBBSstat(bbsnnrp, i, mid)
nnrp_t *bbsnnrp;
int i;
char *mid;
{
newsrc_t *rcptr = &bbsnnrp->newsrc[i];
int size, code;
fprintf(bbsnnrp->innbbsout, "STAT %s\r\n", mid);
fflush(bbsnnrp->innbbsout);
verboselog("innbbsPut: STAT %s\n", mid);
NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
verboselog("innbbsGet: %s\n", INNBBSbuffer);
return atol(INNBBSbuffer);
}
int
INNBBSihave(bbsnnrp, artno, mid)
nnrp_t *bbsnnrp;
ULONG artno;
char *mid;
{
int size, code;
int header = 1;
if (DefaultNntpProtocol == NntpPostProtocol) {
fprintf(bbsnnrp->innbbsout, "POST\r\n");
fflush(bbsnnrp->innbbsout);
verboselog("innbbsPut: POST %s\n", mid);
} else {
fprintf(bbsnnrp->innbbsout, "IHAVE %s\r\n", mid);
fflush(bbsnnrp->innbbsout);
verboselog("innbbsPut: IHAVE %s\n", mid);
}
if (NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin) == NULL) {
return -1;
}
verboselog("innbbsGet: %s\n", INNBBSbuffer);
#ifdef BBSNNRPDEBUG
printf("ihave got %s\n", INNBBSbuffer);
#endif
if (DefaultNntpProtocol == NntpPostProtocol) {
if ((code = atol(INNBBSbuffer)) != NNTP_START_POST_VAL) {
if (code == NNTP_POSTFAIL_VAL)
return 0;
else
return -1;
}
} else {
if ((code = atol(INNBBSbuffer)) != INNBBSihaveOK) {
if (code == 435 || code == 437)
return 0;
else
return -1;
}
}
if (artno != -1) {
fprintf(bbsnnrp->nnrpout, "ARTICLE %d\r\n", artno);
verboselog("nnrpPut: ARTICLE %d\n", artno);
#ifdef BBSNNRPDEBUG
printf("ARTICLE %d\r\n", artno);
#endif
fflush(bbsnnrp->nnrpout);
if (NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin) == NULL) {
return -1;
}
verboselog("nnrpGet: %s\n", NNRPbuffer);
#ifdef BBSNNRPDEBUG
printf("article got %s\n", NNRPbuffer);
#endif
if (atol(NNRPbuffer) != NNRParticleOK) {
fputs(".\r\n", bbsnnrp->innbbsout);
fflush(bbsnnrp->innbbsout);
NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
verboselog("innbbsGet: %s\n", INNBBSbuffer);
return 0;
}
}
header = 1;
while (fgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin) != NULL) {
if (strcmp(NNRPbuffer, "\r\n") == 0)
header = 0;
if (strcmp(NNRPbuffer, ".\r\n") == 0) {
verboselog("nnrpGet: .\n");
fputs(NNRPbuffer, bbsnnrp->innbbsout);
fflush(bbsnnrp->innbbsout);
verboselog("innbbsPut: .\n");
if (NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin) == NULL)
return -1;
verboselog("innbbsGet: %s\n", INNBBSbuffer);
#ifdef BBSNNRPDEBUG
printf("end ihave got %s\n", INNBBSbuffer);
#endif
code = atol(INNBBSbuffer);
if (DefaultNntpProtocol == NntpPostProtocol) {
if (code == NNTP_POSTEDOK_VAL)
return 1;
if (code == NNTP_POSTFAIL_VAL)
return 0;
} else {
if (code == 235)
return 1;
if (code == 437 || code == 435)
return 0;
}
break;
}
if (DefaultNntpProtocol == NntpPostProtocol &&
header && strncasecmp(NNRPbuffer, "NNTP-Posting-Host: ", 19) == 0) {
fprintf(bbsnnrp->innbbsout, "X-%s", NNRPbuffer);
} else {
fputs(NNRPbuffer, bbsnnrp->innbbsout);
}
}
fflush(bbsnnrp->innbbsout);
return -1;
}
int
NNRPgroup(bbsnnrp, i, low, high)
nnrp_t *bbsnnrp;
int i;
ULONG *low, *high;
{
newsrc_t *rcptr = &bbsnnrp->newsrc[i];
int size, code;
ULONG tmp;
fprintf(bbsnnrp->nnrpout, "GROUP %-.*s\r\n",
rcptr->namelen, rcptr->nameptr);
printf("GROUP %-.*s\r\n", rcptr->namelen, rcptr->nameptr);
verboselog("nnrpPut: GROUP %-.*s\n", rcptr->namelen, rcptr->nameptr);
fflush(bbsnnrp->nnrpout);
NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
verboselog("nnrpGet: %s\n", NNRPbuffer);
printf("%s\n", NNRPbuffer);
sscanf(NNRPbuffer, "%d %d %ld %ld", &code, &size, low, high);
if (*low > *high) {
tmp = *low;
*low = *high;
*high = tmp;
}
return code;
}
readnews(server, bbsnnrp)
char *server;
nnrp_t *bbsnnrp;
{
int i;
char buffer[4096];
ULONG low, high;
fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
verboselog("innbbsGet: %s", buffer);
if (atoi(buffer) != INNBBSconnectOK) {
fprintf(stderr, "INNBBS server not OK\n");
return;
}
#ifdef BBSNNRPDEBUG
printf("%s", buffer);
#endif
fgets(buffer, sizeof buffer, bbsnnrp->nnrpin);
verboselog("nnrpGet: %s", buffer);
if (buffer[0] != '2') {
/*
* if (atoi(buffer) != NNRPconnectOK && atoi(buffer) !=
* NNTP_NOPOSTOK_VAL) {
*/
fprintf(stderr, "NNRP server not OK\n");
return;
}
#ifdef BBSNNRPDEBUG
printf("%s", buffer);
#endif
fputs("MODE READER\r\n", bbsnnrp->nnrpout);
fflush(bbsnnrp->nnrpout);
verboselog("nnrpPut: MODE READER\n");
fgets(buffer, sizeof buffer, bbsnnrp->nnrpin);
verboselog("nnrpGet: %s", buffer);
if (DefaultNntpProtocol == NntpPostProtocol) {
fputs("MODE READER\r\n", bbsnnrp->innbbsout);
fflush(bbsnnrp->innbbsout);
verboselog("innbbsPut: MODE READER\n");
fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
verboselog("innbbsGet: %s", buffer);
}
#ifdef BBSNNRPDEBUG
printf("%s", buffer);
#endif
if (StatHistory == 0) {
fputs("MIDCHECK OFF\r\n", bbsnnrp->innbbsout);
fflush(bbsnnrp->innbbsout);
verboselog("innbbsPut: MIDCHECK OFF\n");
fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
verboselog("innbbsGet: %s", buffer);
}
bbsnnrp->actdirty = 0;
for (i = 0; i < ACT_COUNT; i++) {
int code = NNRPgroup(bbsnnrp, i, &low, &high);
newsrc_t *rcptr = &bbsnnrp->newsrc[i];
int j;
ULONG artno;
char *mid;
int artcount;
#ifdef BBSNNRPDEBUG
printf("got reply %d %ld %ld\n", code, low, high);
#endif
artcount = 0;
if (code == 411) {
FILE *ff = fopen(BBSHOME "/innd/log/badgroup.log", "a");
fprintf(ff, "%s\t%-.*s\r\n", server, rcptr->namelen, rcptr->nameptr);
fclose(ff);
} else if (code == NNRPGroupOK) {
int xcount;
ULONG maxartno = rcptr->high;
int isCancelControl = (strncmp(rcptr->nameptr, "control", rcptr->namelen) == 0)
||
(strncmp(rcptr->nameptr, "control.cancel", rcptr->namelen) == 0);
/* less than or equal to high, for server renumber */
if (rcptr->low != low) {
bbsnnrp->actdirty = 1;
rcptr->low = low;
updaterc(rcptr->lowptr, rcptr->lowlen, rcptr->low);
}
if (ResetActive) {
if (rcptr->high != high) {
bbsnnrp->actdirty = 1;
rcptr->high = high;
updaterc(rcptr->highptr, rcptr->highlen, rcptr->high);
}
} else if (rcptr->high < high) {
int xhdrcode;
ULONG maxget = high;
int exception = 0;
if (rcptr->high < low) {
bbsnnrp->actdirty = 1;
rcptr->high = low;
updaterc(rcptr->highptr, rcptr->highlen, low);
}
if (high > rcptr->high + Max_Stats) {
maxget = rcptr->high + Max_Stats;
}
if (isCancelControl)
xhdrcode = NNRPxhdr("Control", bbsnnrp, i, rcptr->high + 1, maxget);
else
xhdrcode = NNRPxhdr("Message-ID", bbsnnrp, i, rcptr->high + 1, maxget);
maxartno = maxget;
if (xhdrcode == NNRPXhdrOK) {
while (NNRPxhdrget(&artno, &mid, isCancelControl)) {
/* #define DEBUG */
#ifdef DEBUG
printf("no %d id %s\n", artno, mid);
#endif
if (artcount < Max_Arts) {
if (mid != NULL && !isCancelControl) {
if (!StatHistory || INNBBSstat(bbsnnrp, i, mid) != INNBBSstatOK) {
printf("** %d ** %d need it %s\n", artcount, artno, mid);
XHDR[artcount].artno = artno;
XHDR[artcount].header = restrdup(XHDR[artcount].header, mid);
/* INNBBSihave(bbsnnrp,i,artno,mid); */
/* to get it */
artcount++;
}
} else if (mid != NULL) {
if (INNBBSstat(bbsnnrp, i, mid) == INNBBSstatOK) {
printf("** %d ** %d need cancel %s\n", artcount, artno, mid);
XHDR[artcount].artno = artno;
XHDR[artcount].header = restrdup(XHDR[artcount].header, mid);
artcount++;
}
}
maxartno = artno;
}
}
} /* while xhdr OK */
exception = 0;
for (xcount = 0; xcount < artcount; xcount++) {
ULONG artno;
char *mid;
artno = XHDR[xcount].artno;
mid = XHDR[xcount].header;
if (isCancelControl) {
if (NNRPstat(bbsnnrp, artno, &mid) == NNRPstatOK) {
}
}
printf("** %d ** %d i have it %s\n", xcount, artno, mid);
if (!ResetActive && mid != NULL)
exception = INNBBSihave(bbsnnrp, artno, mid);
if (exception == -1)
break;
if (rcptr->high != artno) {
rcptr->high = artno;
updaterc(rcptr->highptr, rcptr->highlen, rcptr->high);
}
}
if (rcptr->high != maxartno && exception != -1) {
bbsnnrp->actdirty = 1;
rcptr->high = maxartno;
updaterc(rcptr->highptr, rcptr->highlen, maxartno);
}
}
}
/*
* flushrc(bbsnnrp);
*/
}
fprintf(bbsnnrp->innbbsout, "quit\r\n");
fprintf(bbsnnrp->nnrpout, "quit\r\n");
fflush(bbsnnrp->innbbsout);
fflush(bbsnnrp->nnrpout);
fgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
fgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
/*
* bbsnnrp->newsrc[0].high = 1900; updaterc(bbsnnrp->newsrc[0].highptr,
* bbsnnrp->newsrc[0].highlen, bbsnnrp->newsrc[0].high);
*/
}
INNBBSDhalt()
{
}
