/*
   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()
{
}