Initial revision

git-svn-id: http://opensvn.csie.org/pttbbs/pttbbs/trunk/pttbbs@1 63ad8ddf-47c3-0310-b6dd-a9e9d9715204

1 files changed, 657 insertions, 0 deletions

diff --git a/innbbsd/inndchannel.c b/innbbsd/inndchannel.c
new file mode 100644
index 00000000..439b2af0
--- /dev/null
+++ b/innbbsd/inndchannel.c
@@ -0,0 +1,657 @@
+#include "innbbsconf.h"
+#include "daemon.h"
+#include "bbslib.h"
+#include "config.h"
+
+#define DEBUG
+#undef DEBUG
+
+#ifndef MAXCLIENT
+#define MAXCLIENT 500
+#endif
+
+#ifndef ChannelSize
+#define ChannelSize 4096
+#endif
+
+#ifndef ReadSize
+#define ReadSize 1024
+#endif
+
+#ifndef DefaultINNBBSPort
+# define DefaultINNBBSPort "7777"
+#endif
+
+#ifndef HIS_MAINT
+# define HIS_MAINT
+# define HIS_MAINT_HOUR 5
+# define HIS_MAINT_MIN  30
+#endif
+
+int Maxclient=MAXCLIENT;
+ClientType *Channel=NULL;
+ClientType INNBBSD_STAT;
+
+int Max_Art_Size = MAX_ART_SIZE;
+
+int inetdstart = 0;
+
+int Junkhistory = 0;
+
+char *REMOTEUSERNAME, *REMOTEHOSTNAME;
+
+static fd_set rfd,wfd,efd,orfd,owfd,oefd;
+
+clearfdset(fd)
+int fd;
+{
+   FD_CLR(fd,&rfd);
+}
+
+static
+channelcreate(client)
+ClientType *client;
+{
+  buffer_t *in, *out;
+  in = &client->in;
+  out = &client->out;
+  if (in->data != NULL)
+    free(in->data);
+  in->data = (char*)mymalloc( ChannelSize );
+  in->left = ChannelSize;
+  in->used = 0;
+  if (out->data != NULL)
+    free(out->data);
+  out->data = (char*)mymalloc( ChannelSize );
+  out->used = 0;
+  out->left = ChannelSize;
+  client->ihavecount = 0;
+  client->ihaveduplicate = 0;
+  client->ihavefail = 0;
+  client->ihavesize = 0;
+  client->statcount = 0;
+  client->statfail = 0;
+  client->begin = time(NULL);
+}
+
+channeldestroy(client)
+ClientType *client;
+{
+   if (client->in.data != NULL) {
+     free(client->in.data);
+     client->in.data = NULL;
+   }
+   if (client->out.data != NULL) {
+     free(client->out.data);
+     client->out.data = NULL;
+   }
+#if !defined(PowerBBS) && !defined(DBZSERVER)
+   if (client->ihavecount >0 || client->statcount >0) {
+     bbslog("%s@%s rec: %d dup: %d fail: %d size: %d, stat rec: %d fail: %d, time sec: %d\n",
+    client->username, client->hostname, client->ihavecount,
+    client->ihaveduplicate, client->ihavefail, client->ihavesize,
+    client->statcount, client->statfail, time(NULL) - client->begin);
+    INNBBSD_STAT.ihavecount += client->ihavecount;
+    INNBBSD_STAT.ihaveduplicate += client->ihaveduplicate;
+    INNBBSD_STAT.ihavefail += client->ihavefail;
+    INNBBSD_STAT.ihavesize += client->ihavesize;
+    INNBBSD_STAT.statcount += client->statcount;
+    INNBBSD_STAT.statfail  += client->statfail;
+   }
+#endif
+}
+
+inndchannel(port, path)
+char *port, *path;
+{
+     time_t tvec;
+     int i;
+     int bbsinnd ;
+     int localbbsinnd;
+     char obuf[4096];
+     struct timeval tout;
+     ClientType *client = (ClientType *)mymalloc( sizeof(ClientType) * Maxclient);
+     int localdaemonready = 0;
+     Channel = client;
+
+     bbsinnd = pmain(port);
+     if (bbsinnd < 0) {
+        perror("pmain, existing");
+        docompletehalt();
+        return(-1);
+     }
+
+     FD_ZERO(&rfd); FD_ZERO(&wfd); FD_ZERO(&efd);
+
+     localbbsinnd = p_unix_main(path);
+     if (localbbsinnd < 0) {
+        perror("local pmain, existing");
+/* Kaede
+        if (!inetdstart)
+          fprintf(stderr, "if no other innbbsd running, try to remove %s\n",path);
+*/
+        close(bbsinnd);
+        return(-1);
+     } else {
+       FD_SET(localbbsinnd,&rfd);
+       localdaemonready = 1;
+     }
+
+     FD_SET(bbsinnd,&rfd);
+     tvec = time((time_t *)0);
+     for (i=0;i< Maxclient ;++i) {
+         client[i].fd = -1;
+         client[i].access=0;
+         client[i].buffer[0] = '\0';
+         client[i].mode = 0;
+         client[i].in.left = 0;
+         client[i].in.used = 0;
+         client[i].in.data = NULL;
+         client[i].out.left = 0;
+         client[i].out.used = 0;
+         client[i].out.data = NULL;
+         client[i].midcheck = 1;
+     }
+     for (;;) {
+        int nsel,i;
+
+/*
+          When to maintain history files.
+*/
+        time_t now;
+        static int maint = 0;
+        struct tm *local;
+
+        if (INNBBSDshutdown()) {
+           HISclose();
+           bbslog(" Shutdown Complete \n");
+           docompletehalt();
+           exit(0);
+        }
+
+        time(&now);
+        local = localtime(&now);
+        if (local != NULL & local->tm_hour == His_Maint_Hour &&
+            local->tm_min  >= His_Maint_Min ) {
+           if (!maint) {
+             bbslog(":Maint: start (%d:%d).\n",local->tm_hour,local->tm_min);
+             HISmaint();
+             time(&now);
+             local = localtime(&now);
+             if (local != NULL)
+               bbslog(":Maint: end (%d:%d).\n",local->tm_hour,local->tm_min);
+             maint = 1;
+           }
+        } else {
+           maint = 0;
+        }
+/*
+*/
+/*
+        in order to maintain history, timeout every 60 seconds in case
+        no connections
+*/
+        tout.tv_sec = 60;
+        tout.tv_usec = 0;
+        orfd = rfd;
+        if ((nsel=select(FD_SETSIZE,&orfd, NULL , NULL , &tout))<0){
+                 continue;
+        }
+        if (localdaemonready && FD_ISSET(localbbsinnd,&orfd)) {
+           int ns,length;
+           int cc;
+           ns=tryaccept(localbbsinnd);
+           if (ns < 0) continue;
+           for (i=0;i< Maxclient ;++i) {
+               if (client[i].fd==-1) break;
+           }
+           if (i== Maxclient) {
+              static char msg[]="502 no free descriptors\r\n";
+              printf("%s",msg);
+              write(ns, msg, sizeof(msg));
+              close(ns);
+              continue;
+           }
+           client[i].fd=ns;
+           client[i].buffer[0] = '\0';
+           client[i].mode = 0;
+           client[i].midcheck = 1;
+           channelcreate(&client[i]);
+           FD_SET(ns,&rfd); /*FD_SET(ns,&wfd);*/
+           {
+                strncpy(client[i].username,"localuser",20);
+                strncpy(client[i].hostname,"localhost",128);
+                client[i].Argv.in  =  fdopen( ns,"r");
+                client[i].Argv.out =  fdopen( ns,"w");
+#if !defined(PowerBBS) && !defined(DBZSERVER)
+                bbslog("connected from (%s@%s).\n",client[i].username, client[i].hostname);
+#endif
+#ifdef INNBBSDEBUG
+                printf("connected from (%s@%s).\n",client[i].username, client[i].hostname);
+#endif
+#ifdef DBZSERVER
+                fprintf(client[i].Argv.out,"200 %s InterNetNews DBZSERVER server %s (%s@%s).\r\n",MYBBSID, VERSION, client[i].username, client[i].hostname);
+#else
+                fprintf(client[i].Argv.out,"200 %s InterNetNews INNBBSD server %s (%s@%s).\r\n", MYBBSID, VERSION, client[i].username, client[i].hostname );
+#endif
+                fflush(client[i].Argv.out);
+                verboselog("UNIX Connect from %s@%s\n",client[i].username, client[i].hostname);
+           }
+        }
+
+        if (FD_ISSET(bbsinnd,&orfd)) {
+           int ns=tryaccept(bbsinnd), length;
+           struct sockaddr_in there;
+           char *name;
+           struct hostent *hp;
+           int cc;
+           if (ns < 0) continue;
+           for (i=0;i< Maxclient ;++i) {
+               if (client[i].fd==-1) break;
+           }
+           if (i== Maxclient) {
+              static char msg[]="502 no free descriptors\r\n";
+              printf("%s",msg);
+              write(ns, msg, sizeof(msg));
+              close(ns);
+              continue;
+           }
+           client[i].fd=ns;
+           client[i].buffer[0] = '\0';
+           client[i].mode = 0;
+           client[i].midcheck = 1;
+           channelcreate(&client[i]);
+           FD_SET(ns,&rfd); /*FD_SET(ns,&wfd);*/
+           length = sizeof(there);
+           if (getpeername(ns,(struct sockaddr *)&there,&length)>=0){
+                time_t now=time((time_t *)0);
+                name=(char*)my_rfc931_name(ns,&there);
+                strncpy(client[i].username,name,20);
+                hp = (struct hostent*)gethostbyaddr((char*)&there.sin_addr, sizeof (struct in_addr), there.sin_family);
+                if (hp)
+                   strncpy(client[i].hostname,hp->h_name,128);
+                else
+                   strncpy(client[i].hostname,(char*)inet_ntoa(there.sin_addr),128);
+
+                client[i].Argv.in  =  fdopen( ns,"r");
+                client[i].Argv.out =  fdopen( ns,"w");
+                if ((char*)search_nodelist(client[i].hostname,client[i].username) == NULL) {
+                  bbslog(":Err: invalid connection (%s@%s).\n",client[i].username, client[i].hostname);
+                  fprintf(client[i].Argv.out,"502 You are not in my access file. (%s@%s)\r\n", client[i].username, client[i].hostname);
+                  fflush(client[i].Argv.out);
+                  fclose(client[i].Argv.in);
+                  fclose(client[i].Argv.out);
+                  close(client[i].fd);
+                  FD_CLR(client[i].fd,&rfd);
+                  client[i].fd = -1;
+                  continue;
+                }
+                bbslog("connected from (%s@%s).\n",client[i].username, client[i].hostname);
+#ifdef INNBBSDEBUG
+                printf("connected from (%s@%s).\n",client[i].username, client[i].hostname);
+#endif
+#ifdef DBZSERVER
+                fprintf(client[i].Argv.out,"200 %s InterNetNews DBZSERVER server %s (%s@%s).\r\n",MYBBSID, VERSION, client[i].username, client[i].hostname );
+#else
+                fprintf(client[i].Argv.out,"200 %s InterNetNews INNBBSD server %s (%s@%s).\r\n",MYBBSID, VERSION, client[i].username, client[i].hostname );
+#endif
+                fflush(client[i].Argv.out);
+                verboselog("INET Connect from %s@%s\n",client[i].username, client[i].hostname);
+           } else {
+           }
+
+        }
+        for (i=0;i< Maxclient ;++i) {
+            int fd=client[i].fd;
+            if (fd < 0) {
+                    continue;
+            }
+            if (FD_ISSET(fd,&orfd)) {
+                int nr;
+#ifdef DEBUG
+                printf("before read i %d in.used %d in.left %d\n",i,client[i].in.used, client[i].in.left);
+#endif
+                nr=channelreader(client+i);
+#ifdef DEBUG
+                printf("after read i %d in.used %d in.left %d\n",i,client[i].in.used, client[i].in.left);
+#endif
+                /*int nr=read(fd,client[i].buffer,1024);*/
+                if (nr <= 0) {
+                    FD_CLR(fd,&rfd);
+                    fclose(client[i].Argv.in);
+                    fclose(client[i].Argv.out);
+                    close(fd);
+                    client[i].fd = -1;
+                    channeldestroy(client+i);
+                    continue;
+                }
+#ifdef DEBUG
+                printf("nr %d %.*s", nr, nr, client[i].buffer);
+#endif
+                if (client[i].access==0) {
+                   continue;
+                }
+            }
+        }
+     }
+}
+
+int channelreader(client)
+ClientType *client;
+{
+   int len, clientlen;
+   char buffer1[8192], buffer2[4096];
+   char *ptr;
+   buffer_t *in = &client->in;
+
+   if (in->left < ReadSize+3) {
+      int need = in->used + in->left + ReadSize + 3;
+      need += need/5 ;
+      in->data = (char*)myrealloc(in->data, need);
+      in->left = need - in->used;
+      verboselog("channelreader realloc %d\n",need);
+   }
+   len = read(client->fd, in->data+in->used, ReadSize);
+
+   if (len <=0) return len;
+
+   in->data[len+in->used] = '\0';
+   in->lastread = len;
+#ifdef DEBUG
+   printf("after read lastread %d\n", in->lastread);
+   printf("len %d client %d\n", len, strlen(in->data+in->used));
+#endif
+
+   REMOTEHOSTNAME = client->hostname;
+   REMOTEUSERNAME = client->username;
+   if (client->mode == 0) {
+     if ( (ptr=(char*)strchr(in->data,'\n')) != NULL) {
+      if (in->data[0] != '\r')
+        commandparse(client);
+     }
+   } else {
+     commandparse(client);
+   }
+   return len;
+}
+
+commandparse(client)
+ClientType *client;
+{
+     char *ptr, *lastend;
+     argv_t *Argv = &client->Argv;
+     int (*Main)();
+     char *buffer = client->in.data;
+     int fd = client->fd;
+     buffer_t *in = &client->in;
+     int dataused;
+     int dataleft;
+
+#ifdef DEBUG
+     printf("%s %s buffer %s",client->username, client->hostname, buffer);
+#endif
+     ptr= (char*) strchr(in->data+in->used,'\n');
+     if (client->mode == 0) {
+        if (ptr == NULL) {
+             in->used += in->lastread;
+             in->left -= in->lastread;
+             return;
+        } else {
+          dataused = ptr - (in->data + in->used) + 1;
+          dataleft = in->lastread - dataused;
+          lastend = ptr + 1;
+        }
+     } else {
+        if (in->used >= 5) {
+          ptr = (char*) strstr(in->data+in->used-5,"\r\n.\r\n");
+        } else if (strncmp(in->data,".\r\n",3)==0) {
+          ptr = in->data;
+        } else {
+          ptr = (char*) strstr(in->data+in->used,"\r\n.\r\n");
+        }
+        if (ptr == NULL) {
+             in->used += in->lastread;
+             in->left -= in->lastread;
+             return;
+        } else {
+          ptr[2]='\0';
+          if ( strncmp(in->data,".\r\n",3)==0)
+             dataused = 3;
+          else
+             dataused = ptr - (in->data + in->used) + 5;
+          dataleft = in->lastread - dataused;
+          lastend = ptr + 5;
+          verboselog("Get: %s@%s end of data . size %d\n", client->username, client->hostname, in->used + dataused);
+          client->ihavesize += in->used + dataused;
+        }
+     }
+     if (client->mode == 0) {
+        struct Daemoncmd * dp;
+        Argv->argc = 0, Argv->argv = NULL,
+        Argv->inputline= buffer;
+        if ( ptr != NULL) *ptr = '\0';
+        verboselog("Get: %s\n",Argv->inputline);
+        Argv->argc = argify( in->data + in->used,&Argv->argv);
+        if ( ptr != NULL) *ptr = '\n';
+        dp = (struct Daemoncmd *) searchcmd(Argv->argv[0]);
+        Argv->dc = dp;
+        if (Argv->dc) {
+#ifdef DEBUG
+          printf("enter command %s\n",Argv->argv[0]);
+#endif
+          if (Argv->argc < dp->argc) {
+           fprintf(Argv->out,"%d Usage: %s\r\n",dp->errorcode,dp->usage);
+           fflush(Argv->out);
+           verboselog("Put: %d Usage: %s\n",dp->errorcode,dp->usage);
+          } else if (dp->argno != 0 && Argv->argc > dp->argno) {
+           fprintf(Argv->out,"%d Usage: %s\r\n",dp->errorcode,dp->usage);
+           fflush(Argv->out);
+           verboselog("Put: %d Usage: %s\n",dp->errorcode,dp->usage);
+          } else {
+            Main=Argv->dc->main;
+            if (Main) {
+              fflush(stdout);
+              (*Main)(client);
+            }
+          }
+        } else {
+          fprintf(Argv->out,"500 Syntax error or bad command\r\n");
+          fflush(Argv->out);
+          verboselog("Put: 500 Syntax error or bad command\r\n");
+        }
+        deargify(&Argv->argv);
+     } else {
+        if (Argv->dc) {
+#ifdef DEBUG
+           printf("enter data mode\n");
+#endif
+           Main=Argv->dc->main;
+           if (Main) {
+              fflush(stdout);
+              (*Main)(client);
+           }
+        }
+     }
+     if (client->mode == 0) {
+      if (dataleft > 0) {
+          strncpy(in->data, lastend, dataleft);
+#ifdef INNBBSDEBUG
+          printf("***** try to copy %x %x %d bytes\n",in->data, lastend, dataleft);
+#endif
+      } else {
+          dataleft = 0;
+      }
+      in->left += in->used - dataleft;
+      in->used = dataleft;
+     }
+}
+
+do_command()
+{
+}
+
+void dopipesig(s)
+int s;
+{
+    printf("catch sigpipe\n");
+    signal(SIGPIPE, dopipesig);
+}
+
+int standaloneinit(port)
+char *port ;
+{
+       int ndescriptors;
+       FILE *pf;
+       char pidfile[24];
+       ndescriptors = getdtablesize();
+/*#ifndef NOFORK*/
+       if (!inetdstart)
+          if (fork())
+                exit(0);
+/*#endif*/
+
+       sprintf(pidfile,"/tmp/innbbsd-%s.pid",port);
+/* Kaede
+       if (!inetdstart)
+         fprintf(stderr, "PID file is in %s\n", pidfile);
+*/
+       {  int s;
+          for (s = 3; s < ndescriptors; s++)
+              (void) close(s);
+       }
+       pf=fopen(pidfile,"w");
+       if (pf != NULL) {
+               fprintf(pf,"%d\n",getpid());
+               fclose(pf);
+       }
+}
+
+extern char *optarg;
+extern int opterr, optind;
+
+innbbsusage(name)
+char *name;
+{
+   fprintf(stderr,"Usage: %s   [options] [port [path]]\n",name);
+   fprintf(stderr,"   -v   (verbose log)\n");
+   fprintf(stderr,"   -h|? (help)\n");
+   fprintf(stderr,"   -n   (not to use in core dbz)\n");
+   fprintf(stderr,"   -i   (start from inetd with wait option)\n");
+   fprintf(stderr,"   -c   connections  (maximum number of connections accepted)\n");
+   fprintf(stderr,"        default=%d\n",Maxclient);
+   fprintf(stderr,"   -j   (keep history of junk article, default=none)\n");
+}
+
+
+#ifdef DEBUGNGSPLIT
+main()
+{
+   char **ngptr ;
+   char buf[1024];
+   gets(buf);
+   ngptr = (char**)BNGsplit(buf);
+   printf("line %s\n",buf);
+   while ( *ngptr != NULL) {
+      printf("%s\n",*ngptr);
+      ngptr++;
+   }
+}
+#endif
+
+static time_t INNBBSDstartup;
+innbbsdstartup()
+{
+   return INNBBSDstartup;
+}
+
+main(argc,argv)
+int argc;
+char **argv;
+{
+
+    char *port, *path;
+    int c, errflag=0;
+    extern INNBBSDhalt();
+/*
+woju
+*/
+    setgid(BBSGID);
+    setuid(BBSUID);
+    chdir(BBSHOME);
+    resolve_boards();
+
+    port = DefaultINNBBSPort;
+    path = LOCALDAEMON;
+    Junkhistory = 0;
+
+    time(&INNBBSDstartup);
+    openlog("innbbsd", LOG_PID | LOG_ODELAY, LOG_DAEMON);
+    while ((c = getopt(argc,argv,"c:f:s:vhidn?j"))!= -1)
+      switch (c) {
+      case 'j':
+       Junkhistory = 1;
+       break;
+      case 'v':
+       verboseon("innbbsd.log");
+       break;
+      case 'n':
+       hisincore(0);
+       break;
+      case 'c':
+       Maxclient = atoi(optarg);
+       if (Maxclient < 0) Maxclient = 0;
+       break;
+      case 'i': {
+       struct sockaddr_in there;
+       int len = sizeof(there);
+       int rel;
+       if ((rel=getsockname(0,(struct sockaddr *)&there,&len))< 0){
+          fprintf(stdout,"You must run -i from inetd with inetd.conf line: \n");
+          fprintf(stdout,"service-port stream  tcp wait  bbs  /home/bbs/innbbsd innbbsd -i port\n");
+          fflush(stdout);
+          exit(5);
+       }
+       inetdstart  = 1;
+       startfrominetd(1);
+      }
+       break;
+      case 'd':
+       dbzdebug(1);
+       break;
+      case 's':
+       Max_Art_Size = atol(optarg);
+       if (Max_Art_Size < 0) Max_Art_Size = 0;
+       break;
+      case 'h':
+      case '?':
+      default:
+        errflag ++;
+      }
+    if (errflag > 0) {
+       innbbsusage(argv[0]);
+       return(1);
+    }
+    if (argc - optind >= 1) {
+      port = argv[optind];
+    }
+    if (argc - optind >= 2) {
+      path = argv[optind+1];
+    }
+
+    standaloneinit(port);
+
+    initial_bbs("feed");
+    
+/* Kaede
+    if (!inetdstart)
+      fprintf(stderr, "Try to listen in port %s and path %s\n", port, path);
+*/
+    HISmaint();
+    HISsetup();
+    installinnbbsd();
+    sethaltfunction(INNBBSDhalt);
+
+    signal(SIGPIPE, dopipesig);
+    inndchannel(port, path);
+    HISclose();
+}