#include "innbbsconf.h"
#include "daemon.h"
#include "innbbsd.h"
#include <dirent.h>
#include "bbslib.h"
#include "inntobbs.h"
#include "nntp.h"
#ifdef GETRUSAGE
#include <sys/time.h>
#include <sys/resource.h>
#endif
#ifdef STDC
# ifndef ARG
# define ARG(x) (x)
# else
# define ARG(x) ()
# endif
#endif
/*< add <mid> <recno> ...
> 200 OK
< quit
500 BYE
> 300 DBZ Server ...
< query <mid>
> 250 <recno> ...
> 450 NOT FOUND!
*/
static int CMDhelp ARG((ClientType*));
static int CMDquit ARG((ClientType*));
static int CMDihave ARG((ClientType*));
static int CMDstat ARG((ClientType*));
static int CMDaddhist ARG((ClientType*));
static int CMDgrephist ARG((ClientType*));
static int CMDmidcheck ARG((ClientType*));
static int CMDshutdown ARG((ClientType*));
static int CMDmode ARG((ClientType*));
static int CMDreload ARG((ClientType*));
static int CMDhismaint ARG((ClientType*));
static int CMDverboselog ARG((ClientType*));
static int CMDlistnodelist ARG((ClientType*));
static int CMDlistnewsfeeds ARG((ClientType*));
#ifdef GETRUSAGE
static int CMDgetrusage ARG((ClientType*));
static int CMDmallocmap ARG((ClientType*));
#endif
static daemoncmd_t cmds[]=
/* cmd-name, cmd-usage, min-argc, max-argc, errorcode, normalcode, cmd-func */
{ {"help","help [cmd]",1,2,99,100,CMDhelp},
{"quit","quit",1,0,99,100,CMDquit},
#ifndef DBZSERVER
{"ihave","ihave mid",2,2,435,335,CMDihave},
#endif
{"stat","stat mid",2,2,223,430,CMDstat},
{"addhist","addhist <mid> <path>",3,3, NNTP_ADDHIST_BAD, NNTP_ADDHIST_OK,CMDaddhist},
{"grephist","grephist <mid>",2,2, NNTP_GREPHIST_BAD, NNTP_GREPHIST_OK, CMDgrephist},
{"midcheck","midcheck [on|off]",1,2, NNTP_MIDCHECK_BAD, NNTP_MIDCHECK_OK, CMDmidcheck},
{"shutdown","shutdown (local)",1,1, NNTP_SHUTDOWN_BAD, NNTP_SHUTDOWN_OK, CMDshutdown},
{"mode","mode (local)",1,1, NNTP_MODE_BAD, NNTP_MODE_OK, CMDmode},
{"listnodelist","listnodelist (local)",1,1, NNTP_MODE_BAD, NNTP_MODE_OK, CMDlistnodelist},
{"listnewsfeeds","listnewsfeeds (local)",1,1, NNTP_MODE_BAD, NNTP_MODE_OK, CMDlistnewsfeeds},
{"reload","reload (local)",1,1, NNTP_RELOAD_BAD, NNTP_RELOAD_OK, CMDreload},
{"hismaint","hismaint (local)",1,1, NNTP_RELOAD_BAD, NNTP_RELOAD_OK, CMDhismaint},
{"verboselog","verboselog [on|off](local)",1,2, NNTP_VERBOSELOG_BAD, NNTP_VERBOSELOG_OK, CMDverboselog},
#ifdef GETRUSAGE
{"getrusage","getrusage (local)",1,1, NNTP_MODE_BAD, NNTP_MODE_OK, CMDgetrusage},
#endif
#ifdef MALLOCMAP
{"mallocmap","mallocmap (local)",1,1, NNTP_MODE_BAD, NNTP_MODE_OK, CMDmallocmap},
#endif
{NULL,NULL,0,0,99,100,NULL}
};
installinnbbsd()
{
installdaemon(cmds,100,NULL);
}
#ifdef OLDLIBINBBSINND
testandmkdir(dir)
char *dir;
{
if (!isdir(dir)) {
char path[MAXPATHLEN+12];
sprintf(path,"mkdir -p %s",dir);
system(path);
}
}
static char splitbuf[2048];
static char joinbuf[1024];
#define MAXTOK 50
static char* Splitptr[MAXTOK];
char **split(line,pat)
char *line,*pat;
{
char *p;
int i;
for (i=0;i<MAXTOK;++i) Splitptr[i] = NULL;
strncpy(splitbuf,line,sizeof splitbuf - 1 );
/*printf("%d %d\n",strlen(line),strlen(splitbuf));*/
splitbuf[sizeof splitbuf - 1] = '\0';
for (i=0,p=splitbuf;*p && i< MAXTOK -1 ;){
for (Splitptr[i++]=p;*p && !strchr(pat,*p);p++);
if (*p=='\0') break;
for (*p++='\0'; *p && strchr(pat,*p);p++);
}
return Splitptr;
}
char **BNGsplit(line)
char *line;
{
char **ptr = split(line,",");
newsfeeds_t *nf1, *nf2;
char *n11, *n12, *n21, *n22;
int i,j;
for (i=0; ptr[i] != NULL; i++) {
nf1 = (newsfeeds_t*)search_group(ptr[i]);
for (j=i+1; ptr[j] != NULL; j++) {
if (strcmp(ptr[i],ptr[j])==0) {
*ptr[j] = '\0';
continue;
}
nf2 = (newsfeeds_t*)search_group(ptr[j]);
if (nf1 && nf2) {
if (strcmp(nf1->board,nf2->board)==0) {
*ptr[j] = '\0';
continue;
}
for (n11 = nf1->board, n12 = (char*)strchr(n11,',');
n11 && *n11 ; n12 = (char*) strchr(n11,',')) {
if (n12) *n12 = '\0';
for (n21 = nf2->board, n22 = (char*)strchr(n21,',');
n21 && *n21 ; n22 = (char*) strchr(n21,',')) {
if (n22) *n22 = '\0';
if (strcmp(n11,n21)==0) {
*n21 = '\t';
}
if (n22) {
*n22 = ',';
n21 = n22 + 1;
} else
break;
}
if (n12) {
*n12 = ',';
n11 = n12 +1;
} else
break;
}
}
}
}
return ptr;
}
char **ssplit(line,pat)
char *line,*pat;
{
char *p;
int i;
for (i=0;i<MAXTOK;++i) Splitptr[i] = NULL;
strncpy(splitbuf,line,1024);
for (i=0,p=splitbuf;*p && i< MAXTOK;){
for (Splitptr[i++]=p;*p && !strchr(pat,*p);p++);
if (*p=='\0') break;
*p=0;p++;
/* for (*p='\0'; strchr(pat,*p);p++);*/
}
return Splitptr;
}
char *join(lineptr,pat,num)
char **lineptr,*pat;
int num;
{
int i;
joinbuf[0] = '\0';
if (lineptr[0] != NULL)
strncpy(joinbuf,lineptr[0],1024);
else {
joinbuf[0]='\0';
return joinbuf;
}
for (i=1;i<num;i++) {
strcat(joinbuf,pat);
if (lineptr[i] != NULL)
strcat(joinbuf,lineptr[i]);
else
break;
}
return joinbuf;
}
#endif
static int CMDtnrpd(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
fprintf(argv->out,"%d %s\n",argv->dc->usage);
return 0;
}
islocalconnect(client)
ClientType *client;
{
if (strcmp(client->username,"localuser") != 0 ||
strcmp(client->hostname,"localhost") != 0)
return 0;
return 1;
}
static shutdownflag = 0;
INNBBSDhalt()
{
shutdownflag = 1;
}
int INNBBSDshutdown()
{
return shutdownflag;
}
static int CMDshutdown(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d shutdown access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Shutdown Put: %d shutdown access denied\n", p->errorcode);
return 1;
}
shutdownflag = 1;
fprintf(argv->out,"%d shutdown starting\r\n", p->normalcode);
fflush(argv->out);
verboselog("Shutdown Put: %d shutdown starting\n", p->normalcode);
return 1;
}
static int CMDmode(client)
ClientType *client;
{
/*char cwdpath[MAXPATHLEN+1];*/
argv_t *argv = &client->Argv;
extern ClientType INNBBSD_STAT;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
time_t uptime, now;
int i,j;
time_t lasthist;
ClientType *client1 = &INNBBSD_STAT;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d mode access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Mode Put: %d mode access denied\n", p->errorcode);
return 1;
}
fprintf(argv->out,"%d mode\r\n", p->normalcode);
fflush(argv->out);
verboselog("Mode Put: %d mode\n", p->normalcode);
uptime = innbbsdstartup();
time(&now);
fprintf(argv->out,"up since %salive %.2f days\r\n", ctime(&uptime), (double)(now - innbbsdstartup())/86400);
fprintf(argv->out,"BBSHOME %s\r\n", BBSHOME);
fprintf(argv->out,"MYBBSID %s\r\n", MYBBSID);
fprintf(argv->out,"ECHOMAIL %s\r\n", ECHOMAIL);
fprintf(argv->out,"INNDHOME %s\r\n", INNDHOME);
fprintf(argv->out,"HISTORY %s\r\n", HISTORY);
fprintf(argv->out,"LOGFILE %s\r\n", LOGFILE);
fprintf(argv->out,"INNBBSCONF %s\r\n", INNBBSCONF);
fprintf(argv->out,"BBSFEEDS %s\r\n", BBSFEEDS);
fprintf(argv->out,"Verbose log: %s\r\n", isverboselog() ?"ON":"OFF");
fprintf(argv->out,"History Expire Days %d\r\n", Expiredays);
fprintf(argv->out,"History Expire Time %d:%d\r\n", His_Maint_Hour, His_Maint_Min);
lasthist = gethisinfo();
if (lasthist > 0) {
time_t keep = lasthist, keep1;
time(&now);
fprintf(argv->out,"Oldest history entry created: %s",(char*)ctime(&keep));
keep = Expiredays * 86400 * 2 + lasthist;
keep1 = keep - now ;
fprintf(argv->out,"Next time to maintain history: (%.2f days later) %s",(double)keep1/86400, (char*)ctime(&keep));
}
fprintf(argv->out,"PID is %d\r\n", getpid());
fprintf(argv->out,"LOCAL ONLY %d\r\n", LOCALNODELIST);
fprintf(argv->out,"NONE NEWSFEEDS %d\r\n", NONENEWSFEEDS);
fprintf(argv->out,"Max connections %d\r\n", Maxclient);
#ifdef DEBUGCWD
getwd(cwdpath);
fprintf(argv->out,"Working directory %s\r\n", cwdpath);
#endif
if (Channel)
for (i=0, j=0; i< Maxclient; ++i) {
if (Channel[i].fd == -1) continue;
if (Channel+i == client) continue;
j++;
fprintf(argv->out," %d) in->used %d, in->left %d %s@%s\r\n",i,
Channel[i].in.used, Channel[i].in.left,
Channel[i].username,Channel[i].hostname);
}
fprintf(argv->out,"Total connections %d\r\n", j);
fprintf(argv->out,"Total rec: %d dup: %d fail: %d size: %d, stat rec: %d fail: %d\n", client1->ihavecount, client1->ihaveduplicate, client1->ihavefail, client1->ihavesize, client1->statcount, client1->statfail);
fprintf(argv->out,".\r\n");
fflush(argv->out);
return 1;
}
static int
CMDlistnodelist(client)
ClientType *client;
{
int nlcount;
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d listnodelist access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Mallocmap Put: %d listnodelist access denied\n", p->errorcode);
return 1;
}
fprintf(argv->out,"%d listnodelist\r\n", p->normalcode);
for (nlcount =0; nlcount < NLCOUNT; nlcount++) {
nodelist_t *nl = NODELIST+nlcount;
fprintf(argv->out,"%2d %s /\\/\\ %s\r\n", nlcount+1, nl->node==NULL?"":nl->node, nl->exclusion==NULL?"":nl->exclusion);
fprintf(argv->out," %s:%s:%s\r\n",nl->host==NULL?"":nl->host, nl->protocol==NULL?"":nl->protocol, nl->comments == NULL ? "": nl->comments);
}
fprintf(argv->out,".\r\n");
fflush(argv->out);
verboselog("Listnodelist Put: %d listnodelist complete\n", p->normalcode);
return 1;
}
static int
CMDlistnewsfeeds(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
int nfcount;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d listnewsfeeds access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Mallocmap Put: %d listnewsfeeds access denied\n", p->errorcode);
return 1;
}
fprintf(argv->out,"%d listnewsfeeds\r\n", p->normalcode);
for (nfcount =0; nfcount < NFCOUNT; nfcount++) {
newsfeeds_t *nf = NEWSFEEDS + nfcount;
fprintf(argv->out,"%3d %s<=>%s\r\n",nfcount+1, nf->newsgroups, nf->board);
fprintf(argv->out," %s\r\n",nf->path==NULL?"(Null)":nf->path);
}
fprintf(argv->out,".\r\n");
fflush(argv->out);
verboselog("Listnewsfeeds Put: %d listnewsfeeds complete\n", p->normalcode);
return 1;
}
#ifdef MALLOCMAP
static int CMDmallocmap(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
struct rusage ru;
int savefd ;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d mallocmap access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Mallocmap Put: %d mallocmap access denied\n", p->errorcode);
return 1;
}
fprintf(argv->out,"%d mallocmap\r\n", p->normalcode);
savefd = dup(1);
dup2(client->fd, 1);
mallocmap();
dup2(savefd, 1);
close(savefd);
fprintf(argv->out,".\r\n");
fflush(argv->out);
verboselog("Mallocmap Put: %d mallocmap complete\n", p->normalcode);
return 1;
}
#endif
#ifdef GETRUSAGE
static int CMDgetrusage(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
struct rusage ru;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d getrusage access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Getrusage Put: %d getrusage access denied\n", p->errorcode);
return 1;
}
fprintf(argv->out,"%d getrusage\r\n", p->normalcode);
if (getrusage(RUSAGE_SELF,&ru) == 0) {
fprintf(argv->out,"user time used: %.6f\r\n",(double)ru.ru_utime.tv_sec + (double)ru.ru_utime.tv_usec/1000000.0);
fprintf(argv->out,"system time used: %.6f\r\n",(double)ru.ru_stime.tv_sec + (double)ru.ru_stime.tv_usec/1000000.0);
fprintf(argv->out,"maximum resident set size: %lu\r\n",ru.ru_maxrss * getpagesize());
fprintf(argv->out,"integral resident set size: %lu\r\n",ru.ru_idrss * getpagesize());
fprintf(argv->out,"page faults not requiring physical I/O: %d\r\n",ru.ru_minflt);
fprintf(argv->out,"page faults requiring physical I/O: %d\r\n",ru.ru_majflt);
fprintf(argv->out,"swaps: %d\r\n",ru.ru_nswap);
fprintf(argv->out,"block input operations: %d\r\n",ru.ru_inblock);
fprintf(argv->out,"block output operations: %d\r\n",ru.ru_oublock);
fprintf(argv->out,"messages sent: %d\r\n",ru.ru_msgsnd);
fprintf(argv->out,"messages received: %d\r\n",ru.ru_msgrcv);
fprintf(argv->out,"signals received: %d\r\n",ru.ru_nsignals);
fprintf(argv->out,"voluntary context switches: %d\r\n",ru.ru_nvcsw);
fprintf(argv->out,"involuntary context switches: %d\r\n",ru.ru_nivcsw);
}
fprintf(argv->out,".\r\n");
fflush(argv->out);
verboselog("Getrusage Put: %d getrusage complete\n", p->normalcode);
return 1;
}
#endif
static int CMDhismaint(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d hismaint access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Hismaint Put: %d hismaint access denied\n", p->errorcode);
return 1;
}
verboselog("Hismaint Put: %d hismaint start\n", p->normalcode);
HISmaint();
fprintf(argv->out,"%d hismaint complete\r\n", p->normalcode);
fflush(argv->out);
verboselog("Hismaint Put: %d hismaint complete\n", p->normalcode);
return 1;
}
static int CMDreload(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d reload access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Reload Put: %d reload access denied\n", p->errorcode);
return 1;
}
initial_bbs("feed");
fprintf(argv->out,"%d reload complete\r\n", p->normalcode);
fflush(argv->out);
verboselog("Reload Put: %d reload complete\n", p->normalcode);
return 1;
}
static int CMDverboselog(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
if (!islocalconnect(client)) {
fprintf(argv->out,"%d verboselog access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Reload Put: %d verboselog access denied\n", p->errorcode);
return 1;
}
if (client->mode == 0) {
if (argv->argc > 1) {
if (strcasecmp(argv->argv[1],"off")==0) {
setverboseoff();
} else {
setverboseon();
}
}
}
fprintf(argv->out,"%d verboselog %s\r\n",p->normalcode,
isverboselog() ?"ON":"OFF");
fflush(argv->out);
verboselog("%d verboselog %s\r\n",p->normalcode,
isverboselog()?"ON":"OFF");
}
static int CMDmidcheck(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
if (client->mode == 0) {
if (argv->argc > 1) {
if (strcasecmp(argv->argv[1],"off")==0) {
client->midcheck = 0;
} else {
client->midcheck = 1;
}
}
}
fprintf(argv->out,"%d mid check %s\r\n",p->normalcode,
client->midcheck == 1?"ON":"OFF");
fflush(argv->out);
verboselog("%d mid check %s\r\n",p->normalcode,
client->midcheck == 1?"ON":"OFF");
}
static int CMDgrephist(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
if (client->mode == 0) {
if (argv->argc > 1) {
char *ptr;
ptr = (char*)DBfetch(argv->argv[1]);
if (ptr != NULL) {
fprintf(argv->out,"%d %s OK\r\n", p->normalcode, ptr);
fflush(argv->out);
verboselog("Addhist Put: %d %s OK\n", p->normalcode, ptr);
return 0;
} else {
fprintf(argv->out,"%d %s not found\r\n", p->errorcode,argv->argv[1]);
fflush(argv->out);
verboselog("Addhist Put: %d %s not found\n", p->errorcode, argv->argv[1]);
return 1;
}
}
}
fprintf(argv->out,"%d grephist error\r\n", p->errorcode);
fflush(argv->out);
verboselog("Addhist Put: %d grephist error\n", p->errorcode);
return 1;
}
static int CMDaddhist(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
buffer_t *in = &client->in;
daemoncmd_t *p = argv->dc;
/*
if (strcmp(client->username,"localuser") != 0 ||
strcmp(client->hostname,"localhost") != 0) {
fprintf(argv->out,"%d add hist access denied\r\n", p->errorcode);
fflush(argv->out);
verboselog("Addhist Put: %d add hist access denied\n", p->errorcode);
return 1;
}
*/
if (client->mode == 0) {
if (argv->argc > 2) {
char *ptr;
ptr = (char*)DBfetch(argv->argv[1]);
if (ptr == NULL) {
if (storeDB(argv->argv[1], argv->argv[2]) < 0) {
fprintf(argv->out,"%d add hist store DB error\r\n", p->errorcode);
fflush(argv->out);
verboselog("Addhist Put: %d add hist store DB error\n", p->errorcode);
return 1;
} else {
fprintf(argv->out,"%d add hist OK\r\n", p->normalcode);
fflush(argv->out);
verboselog("Addhist Put: %d add hist OK\n", p->normalcode);
return 0;
}
} else {
fprintf(argv->out,"%d add hist duplicate error\r\n", p->errorcode);
fflush(argv->out);
verboselog("Addhist Put: %d add hist duplicate error\n", p->errorcode);
return 1;
}
}
}
fprintf(argv->out,"%d add hist error\r\n", p->errorcode);
fflush(argv->out);
verboselog("Addhist Put: %d add hist error\n", p->errorcode);
return 1;
}
static int CMDstat(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
char *ptr, *frontptr;
buffer_t *in = &client->in;
daemoncmd_t *p;
if (client->mode == 0) {
client->statcount++;
if (argv->argc > 1) {
if (argv->argv[1][0] != '<') {
fprintf(argv->out,"430 No such article\r\n");
fflush(argv->out);
verboselog("Stat Put: 430 No such article\n");
client->statfail++;
return 0;
}
ptr = (char*)DBfetch(argv->argv[1]);
if (ptr != NULL) {
fprintf(argv->out,"223 0 status %s\r\n",argv->argv[1]);
fflush(argv->out);
client->mode = 0;
verboselog("Stat Put: 223 0 status %s\n",argv->argv[1]);
return 1;
} else {
fprintf(argv->out,"430 No such article\r\n");
fflush(argv->out);
verboselog("Stat Put: 430 No such article\n");
client->mode = 0;
client->statfail++;
}
}
}
}
#ifndef DBZSERVER
static int CMDihave(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
char *ptr=NULL, *frontptr;
buffer_t *in = &client->in;
daemoncmd_t *p;
if (client->mode == 0) {
client->ihavecount++;
if (argv->argc > 1) {
if (argv->argv[1][0] != '<') {
fprintf(argv->out,"435 Bad Message-ID\r\n");
fflush(argv->out);
verboselog("Ihave Put: 435 Bad Message-ID\n");
client->ihavefail++;
return 0;
}
if (client->midcheck == 1)
ptr = (char*)DBfetch(argv->argv[1]);
if (ptr != NULL && client->midcheck == 1) {
fprintf(argv->out,"435 Duplicate\r\n");
fflush(argv->out);
client->mode = 0;
verboselog("Ihave Put: 435 Duplicate\n");
client->ihaveduplicate++;
client->ihavefail++;
return 1;
} else {
fprintf(argv->out,"335\r\n");
fflush(argv->out);
client->mode = 1;
verboselog("Ihave Put: 335\n");
}
}
} else {
client->mode = 0;
readlines(client);
if (HEADER[SUBJECT_H] && HEADER[FROM_H] && HEADER[DATE_H] &&
HEADER[MID_H] && HEADER[NEWSGROUPS_H] ) {
char *path1, *path2;
int rel ;
rel = 0;
path1 = (char*)mymalloc(strlen(HEADER[PATH_H]) + 3);
path2 = (char*)mymalloc(strlen(MYBBSID) + 3);
sprintf(path1, "!%s!",HEADER[PATH_H]);
sprintf(path2, "!%s!",MYBBSID);
if (HEADER[CONTROL_H]) {
bbslog( "Control: %s\n", HEADER[CONTROL_H] );
if (strncasecmp(HEADER[CONTROL_H],"cancel ",7)==0) {
rel = cancel_article_front(HEADER[CONTROL_H]+7);
} else {
rel = receive_control();
}
} else if ( (char*)strstr(path1, path2) != NULL) {
bbslog( ":Warn: Loop back article: %s!%s\n",MYBBSID,HEADER[PATH_H] );
} else {
rel = receive_article();
}
free(path1);
free(path2);
if (rel == -1) {
fprintf(argv->out,"400 server side failed\r\n");
fflush(argv->out);
verboselog("Ihave Put: 400\n");
clearfdset(client->fd);
fclose(client->Argv.in);
fclose(client->Argv.out);
close(client->fd);
client->fd = -1;
client->mode = 0;
client->ihavefail++;
return;
} else {
fprintf(argv->out,"235\r\n");
verboselog("Ihave Put: 235\n");
}
fflush(argv->out);
} else if (!HEADER[PATH_H]) {
fprintf(argv->out,"437 No Path in \"ihave %s\" header\r\n",HEADER[MID_H]);
fflush(argv->out);
verboselog("Put: 437 No Path in \"ihave %s\" header\n",HEADER[MID_H]);
client->ihavefail++;
} else {
fprintf(argv->out,"437 No colon-space in \"ihave %s\" header\r\n",HEADER[MID_H]);
fflush(argv->out);
verboselog("Ihave Put: 437 No colon-space in \"ihave %s\" header\n",HEADER[MID_H]);
client->ihavefail++;
}
#ifdef DEBUG
printf("subject is %s\n",HEADER[SUBJECT_H]);
printf("from is %s\n",HEADER[FROM_H]);
printf("Date is %s\n",HEADER[DATE_H]);
printf("Newsgroups is %s\n",HEADER[NEWSGROUPS_H]);
printf("mid is %s\n",HEADER[MID_H]);
printf("path is %s\n",HEADER[PATH_H]);
#endif
}
fflush(argv->out);
return 0;
}
#endif
static int CMDhelp(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
daemoncmd_t *p;
if (argv->argc>=1) {
fprintf(argv->out,"%d Available Commands\r\n",argv->dc->normalcode);
for (p=cmds;p->name !=NULL;p++) {
fprintf(argv->out," %s\r\n",p->usage);
}
fprintf(argv->out,"Report problems to %s\r\n",ADMINUSER);
}
fputs(".\r\n",argv->out);
fflush(argv->out);
client->mode = 0;
return 0;
}
static int CMDquit(client)
ClientType *client;
{
argv_t *argv = &client->Argv;
fprintf(argv->out,"205 quit\r\n");
fflush(argv->out);
verboselog("Quit Put: 205 quit\n");
clearfdset(client->fd);
fclose(client->Argv.in);
fclose(client->Argv.out);
close(client->fd);
client->fd = -1;
client->mode = 0;
channeldestroy(client);
/*exit(0);*/
}
