This repository has been archived on 2024-04-08. You can view files and clone it, but cannot push or open issues or pull requests.
deb-mbse/mbfido/newspost.c
2003-08-16 20:45:01 +00:00

234 lines
5.7 KiB
C

/*****************************************************************************
*
* $Id$
* Purpose ...............: Post newsarticles in temp newsfile.
*
*****************************************************************************
* Copyright (C) 1997-2002
*
* Michiel Broek FIDO: 2:280/2802
* Beekmansbos 10 Internet: mbroek@users.sourceforge.net
* 1971 BV IJmuiden
* the Netherlands
*
* This file is part of MBSE BBS.
*
* This BBS is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by the
* Free Software Foundation; either version 2, or (at your option) any
* later version.
*
* MBSE BBS is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with MBSE BBS; see the file COPYING. If not, write to the Free
* Software Foundation, 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
*****************************************************************************/
#include "../config.h"
#include "../lib/libs.h"
#include "../lib/structs.h"
#include "../lib/users.h"
#include "../lib/records.h"
#include "../lib/common.h"
#include "../lib/clcomm.h"
#include "../lib/mbinet.h"
#include "newspost.h"
extern FILE *nfp;
extern int newsopen;
extern int news_out;
extern int news_bad;
int newspost(void)
{
int start = TRUE;
char *buf, *p;
long curpos, count, seqnr;
FILE *ofp = NULL, *nb;
struct utsname utsbuf;
if (newsopen)
fclose(nfp);
buf = calloc(10240, sizeof(char));
/*
* Now reopen the file for reading. If it fails and
* the file was original closed we leave quiet.
* If the file wasn't open previously but there is
* a file, try to post the articles. They may be
* still here if the newsserver wasn't available.
*/
sprintf(buf, "%s/tmp/newsout", getenv("MBSE_ROOT"));
if ((nfp = fopen(buf, "r")) == NULL) {
if (newsopen)
WriteError("$Can't reopen %s", buf);
free(buf);
return newsopen;
}
IsDoing("Post news");
if (CFG.newsfeed == FEEDINN) {
Syslog('+', "Posting news articles to the NNTP server");
if (nntp_connect() == -1) {
free(buf);
return TRUE;
}
while (fgets(buf, 10240, nfp)) {
if (start) {
if (nntp_cmd((char *)"POST\r\n", 340) != 0) {
WriteError("NNTP POST refused");
free(buf);
return TRUE;
}
}
start = FALSE;
if (!strcmp(buf, ".\n")) {
if (nntp_cmd((char *)".\r\n", 240) == 0) {
news_out++;
} else {
WriteError("NNTP: refused article %d", news_out+1);
news_bad++;
}
start = TRUE;
} else {
/*
* Most NNTP servers like cr/lf after each line.
*/
Striplf(buf);
p = buf+strlen(buf);
*p++ = '\r';
*p++ = '\n';
*p = '\0';
nntp_send(buf);
}
Nopper();
}
nntp_close();
}
/*
* Create newsbatch file.
*/
if ((CFG.newsfeed == FEEDUUCP) || (CFG.newsfeed == FEEDRNEWS)) {
Syslog('m', "Building uncompressed batchfile");
sprintf(buf, "%s/tmp/newsbatch", getenv("MBSE_ROOT"));
if ((ofp = fopen(buf, "w+")) == NULL) {
WriteError("$Can't create %s", buf);
free(buf);
fclose(nfp);
return TRUE;
}
buf = calloc(10240, sizeof(char));
count = curpos = 0;
while (feof(ofp) == 0) {
/*
* Count the total length of the message
*/
while (fgets(buf, 10240, nfp)) {
if (strcmp(buf, ".\n")) {
count += strlen(buf);
} else {
break;
}
}
if (!count)
break;
fseek(nfp, curpos, SEEK_SET);
fprintf(ofp, "#! rnews %ld\n", count);
while (fgets(buf, 10240, nfp)) {
if (strcmp(buf, ".\n")) {
fprintf(ofp, buf);
} else {
break;
}
}
news_out++;
curpos = ftell(nfp);
count = 0;
}
/*
* Rewind the newsbatch and leave it open.
*/
rewind(ofp);
}
fclose(nfp);
newsopen = FALSE;
/*
* Mode rnews, pipe just created newsbatch to rnews.
*/
if (CFG.newsfeed == FEEDRNEWS) {
if ((nb = (expipe(CFG.rnewspath, NULL, NULL))) == NULL) {
WriteError("Could not open (pip) output for %s", CFG.rnewspath);
newsopen = FALSE;
return TRUE;
}
while (fgets(buf, 10240, ofp)) {
fputs(buf, nb);
}
if (exclose(nb)) {
WriteError("Error closing pipe");
newsopen = FALSE;
return TRUE;
} else
Syslog('+', "Articles send through %s", CFG.rnewspath);
fclose(ofp);
sprintf(buf, "%s/tmp/newsbatch", getenv("MBSE_ROOT"));
unlink(buf);
}
/*
* Mode UUCP, create UUCP files.
*/
if (CFG.newsfeed == FEEDUUCP) {
seqnr = sequencer();
memset(&utsbuf, 0, sizeof(utsbuf));
if (uname(&utsbuf)) {
WriteError("Can't get system nodename");
newsopen = FALSE;
return TRUE;
}
sprintf(buf, "%s/C.%s%lx", CFG.rnewspath, CFG.nntpnode, seqnr);
if ((nb = fopen(buf, "a")) == NULL) {
WriteError("Can't create %s", buf);
newsopen = FALSE;
return TRUE;
}
seqnr = sequencer();
fprintf(nb, "E D.%s%lx D.%s%lx news -C D.%s%lx 0666 \"\" 0 rnews\n",
utsbuf.nodename, seqnr, utsbuf.nodename, seqnr, utsbuf.nodename, seqnr);
fclose(nb);
sprintf(buf, "%s/D.%s%lx", CFG.rnewspath, utsbuf.nodename, seqnr);
if ((nb = fopen(buf, "a")) == NULL) {
WriteError("Can't create %s", buf);
newsopen = FALSE;
return TRUE;
}
while (fgets(buf, 10240, ofp)) {
fputs(buf, nb);
}
Syslog('+', "Articles placed in %s", CFG.rnewspath);
fclose(ofp);
sprintf(buf, "%s/tmp/newsbatch", getenv("MBSE_ROOT"));
unlink(buf);
}
sprintf(buf, "%s/tmp/newsout", getenv("MBSE_ROOT"));
unlink(buf);
free(buf);
return FALSE;
}