path: root/innbbsd/bbslib.c

#if defined( LINUX )
# include "innbbsconf.h"
# include "bbslib.h"
# include <stdarg.h>
#else
# include <stdarg.h>
# include "innbbsconf.h"
# include "bbslib.h"
#endif

char INNBBSCONF[MAXPATHLEN];
char INNDHOME[MAXPATHLEN];
char HISTORY[MAXPATHLEN];
char LOGFILE[MAXPATHLEN];
char MYBBSID[MAXPATHLEN];
char ECHOMAIL[MAXPATHLEN];
char BBSFEEDS[MAXPATHLEN];
char LOCALDAEMON[MAXPATHLEN];

int His_Maint_Min= HIS_MAINT_MIN;
int His_Maint_Hour= HIS_MAINT_HOUR;
int Expiredays  = EXPIREDAYS;

nodelist_t *NODELIST=NULL, **NODELIST_BYNODE=NULL;
newsfeeds_t *NEWSFEEDS=NULL, **NEWSFEEDS_BYBOARD=NULL;
static char *NODELIST_BUF, *NEWSFEEDS_BUF;
int NFCOUNT, NLCOUNT;
int LOCALNODELIST=0, NONENEWSFEEDS=0;

#ifndef _PATH_BBSHOME
# define _PATH_BBSHOME "/u/staff/bbsroot/csie_util/bntpd/home"
#endif

static FILE *bbslogfp;

static int 
verboseFlag=0;

static char*
verboseFilename=NULL;
static char verbosename[MAXPATHLEN];

verboseon(filename)
char *filename;
{
  verboseFlag = 1;
  if ( filename != NULL ) {
    if (strchr(filename,'/') == NULL) {
       sprintf(verbosename,"%s/innd/%s",BBSHOME,filename);
       filename = verbosename;
    } 
  } 
  verboseFilename = filename;
}
verboseoff()
{
  verboseFlag = 0;
}

setverboseon()
{
   verboseFlag = 1;
}

isverboselog()
{
  return verboseFlag;
}

setverboseoff()
{
  verboseoff();
  if (bbslogfp != NULL) {
    fclose(bbslogfp);
    bbslogfp = NULL;
  }
}

verboselog(char *fmt, ...)
{
    va_list ap;
    char datebuf[40];
    time_t now;

    if (verboseFlag == 0) return;

    va_start(ap, fmt);

    time(&now);
    strftime(datebuf, sizeof(datebuf), "%b %d %X ", localtime(&now));

    if (bbslogfp == NULL) {
       if (verboseFilename != NULL)
         bbslogfp = fopen(verboseFilename, "a");
       else
         bbslogfp = fdopen(1, "a");
    }
    if (bbslogfp == NULL) {
        va_end(ap);
        return;
    }
    fprintf(bbslogfp,"%s[%d] ",datebuf, getpid());
    vfprintf(bbslogfp, fmt, ap);
    fflush(bbslogfp);
    va_end(ap);
}

#ifdef PalmBBS
xbbslog(char *fmt, ...)
#else
bbslog(char *fmt, ...)
#endif
{
    va_list ap;
    char datebuf[40];
    time_t now;

    va_start(ap, fmt);

    time(&now);
    strftime(datebuf, sizeof(datebuf), "%b %d %X ", localtime(&now));

    if (bbslogfp == NULL) {
       bbslogfp = fopen(LOGFILE, "a");
    }
    if (bbslogfp == NULL) {
        va_end(ap);
        return;
    }
    fprintf(bbslogfp,"%s[%d] ",datebuf,getpid());
    vfprintf(bbslogfp, fmt, ap);
    fflush(bbslogfp);
    va_end(ap);
}

initial_bbs(outgoing)
char *outgoing;
{
   FILE* FN;
   struct stat st;
   int fd, i;
   char *bbsnameptr=NULL; 

/* reopen bbslog */
   if (bbslogfp != NULL) {
     fclose(bbslogfp);
     bbslogfp = NULL;
   }

#ifdef WITH_ECHOMAIL
   init_echomailfp();
   init_bbsfeedsfp();
#endif

   LOCALNODELIST=0, NONENEWSFEEDS =0;
   sprintf(INNDHOME,"%s/innd",BBSHOME);
   sprintf(HISTORY, "%s/history",INNDHOME);
   sprintf(LOGFILE, "%s/bbslog",INNDHOME);
   sprintf(ECHOMAIL,"%s/echomail.log",BBSHOME);
   sprintf(LOCALDAEMON,"%s/.innbbsd",INNDHOME);
   sprintf(INNBBSCONF,"%s/innbbs.conf",INNDHOME);
   sprintf(BBSFEEDS,"%s/bbsfeeds.log",INNDHOME);

   if (isfile(INNBBSCONF)) {
     FILE *conf;
     char buffer[MAXPATHLEN];
     conf = fopen(INNBBSCONF,"r");
     if (conf != NULL) {
       while (fgets( buffer, sizeof buffer, conf) != NULL) {
     char *ptr, *front=NULL, *value=NULL, *value2=NULL, *value3=NULL;
     if ( buffer[0] == '#' || buffer[0] == '\n') continue;
     for ( front = buffer; *front && isspace(*front); front++);
     for ( ptr = front; *ptr && !isspace(*ptr) ; ptr++) ;
     if (*ptr == '\0') continue;
     *ptr++ = '\0';
     for ( ; *ptr && isspace(*ptr) ; ptr++) ;
     if (*ptr == '\0') continue;
     value = ptr++;
     for ( ; *ptr && !isspace(*ptr) ; ptr++) ;
     if (*ptr) {
       *ptr++ = '\0';
       for ( ; *ptr && isspace(*ptr) ; ptr++) ;
       value2 = ptr++;
       for ( ; *ptr && !isspace(*ptr) ; ptr++) ;
       if (*ptr) {
         *ptr++ = '\0';
         for ( ; *ptr && isspace(*ptr) ; ptr++) ;
         value3 = ptr++;
         for ( ; *ptr && !isspace(*ptr) ; ptr++) ;
         if (*ptr) {
           *ptr++ = '\0';
         }
       }
     }
     if ( strcasecmp(front,"expiredays") == 0) {
        Expiredays = atoi(value);
        if (Expiredays < 0) {
           Expiredays = EXPIREDAYS;
        }
     } else if ( strcasecmp(front,"expiretime") == 0) {
        ptr = strchr(value,':');
        if (ptr == NULL) {
           fprintf(stderr, "Syntax error in innbbs.conf\n");
        } else {
           *ptr++ = '\0';
           His_Maint_Hour = atoi(value);
           His_Maint_Min  = atoi(ptr);
           if (His_Maint_Hour < 0)
              His_Maint_Hour = HIS_MAINT_HOUR;
           if (His_Maint_Min < 0)
              His_Maint_Min = HIS_MAINT_MIN;
        }
     } else if ( strcasecmp(front,"newsfeeds") == 0) {
       if (strcmp(value,"none")==0) 
          NONENEWSFEEDS = 1;
     } else if ( strcasecmp(front,"nodelist") == 0) {
       if (strcmp(value,"local")==0)
          LOCALNODELIST = 1;
     } /*else if ( strcasecmp(front,"newsfeeds") == 0) {
           printf("newsfeeds %s\n", value); 
     } else if ( strcasecmp(front,"nodelist") == 0) {
           printf("nodelist %s\n", value); 
     } else if ( strcasecmp(front,"bbsname") == 0) {
           printf("bbsname %s\n", value); 
     } */
       }
       fclose(conf);
     }
   }

#ifdef WITH_ECHOMAIL
   bbsnameptr = (char*) fileglue("%s/bbsname.bbs",INNDHOME);
   if ((FN = fopen( bbsnameptr ,"r" ))==NULL) {
     fprintf(stderr,"can't open file %s\n", bbsnameptr);
     return 0;
   }
   while ( fscanf(FN,"%s", MYBBSID) != EOF);
   fclose(FN);
   if( ! isdir(fileglue("%s/out.going",BBSHOME)) ) {
      mkdir( (char*)fileglue("%s/out.going",BBSHOME), 0750 );
   }
   if (NONENEWSFEEDS == 0)
     readnffile(INNDHOME);
   if (LOCALNODELIST == 0) {
     if (readnlfile(INNDHOME, outgoing) != 0) return 0;
   }

#endif
   return 1;
}

static int 
nf_byboardcmp(a,b)
newsfeeds_t **a, **b;
{
/*
   if (!a || !*a || !(*a)->board) return -1;
   if (!b || !*b || !(*b)->board) return 1;
*/
   return strcasecmp((*a)->board, (*b)->board);
}

static int 
nfcmp(a,b)
newsfeeds_t *a, *b;
{
/*
   if (!a || !a->newsgroups) return -1;
   if (!b || !b->newsgroups) return 1;
*/
   return strcasecmp(a->newsgroups, b->newsgroups);
}

static int 
nlcmp(a,b)
nodelist_t *a, *b;
{
/*
   if (!a || !a->host) return -1;
   if (!b || !b->host) return 1;
*/
   return strcasecmp(a->host, b->host);
}

static int 
nl_bynodecmp(a,b)
nodelist_t **a, **b;
{
/*
   if (!a || !*a || !(*a)->node) return -1;
   if (!b || !*b || !(*b)->node) return 1;
*/
   return strcasecmp((*a)->node, (*b)->node);
}

/* read in newsfeeds.bbs and nodelist.bbs */
readnlfile(inndhome, outgoing)
char *inndhome;
char *outgoing;
{
    FILE *fp;
    char buff[1024];
    struct stat st;
    int i, count, j; 
    char *ptr, *nodelistptr;
    static lastcount=0;

    sprintf(buff,"%s/nodelist.bbs", inndhome);
    fp = fopen(buff,"r");
    if (fp == NULL) {
       fprintf(stderr,"open fail %s",buff);
       return -1;
    }
    if (fstat(fileno(fp),&st) != 0) {
    fprintf(stderr,"stat fail %s", buff);
        return -1;
    }
    if (NODELIST_BUF == NULL) {
    NODELIST_BUF = (char*) mymalloc( st.st_size +1);
    } else {
    NODELIST_BUF = (char*) myrealloc( NODELIST_BUF, st.st_size +1);
    }
    i = 0, count =0;
    while (fgets(buff, sizeof buff, fp) != NULL) {
       if (buff[0] == '#') continue;
       if (buff[0] == '\n') continue;
       strcpy(NODELIST_BUF+i, buff);
       i += strlen(buff);
       count ++;
    }
    fclose(fp);
    if (NODELIST == NULL) {
       NODELIST = (nodelist_t*) mymalloc(sizeof(nodelist_t) * (count+1));
       NODELIST_BYNODE = (nodelist_t**) mymalloc(sizeof(nodelist_t*) * (count+1));
    } else {
       NODELIST = (nodelist_t*) myrealloc(NODELIST, sizeof(nodelist_t) * (count+1));
       NODELIST_BYNODE = (nodelist_t**) myrealloc(NODELIST_BYNODE, sizeof(nodelist_t*) * (count+1));
    }
    for (i=lastcount; i< count; i++) {
      NODELIST[i].feedfp = NULL;
    }
    lastcount = count;
    NLCOUNT = 0;
    for (ptr = NODELIST_BUF; (nodelistptr = (char*)strchr(ptr,'\n')) != NULL; ptr = nodelistptr +1, NLCOUNT++) {
    char *nptr , *bptr, *pptr, *tptr;
    *nodelistptr = '\0';
    NODELIST[NLCOUNT].host = "";
    NODELIST[NLCOUNT].exclusion = "";
    NODELIST[NLCOUNT].node = "";
    NODELIST[NLCOUNT].protocol = "IHAVE(119)";
    NODELIST[NLCOUNT].comments = "";
    NODELIST_BYNODE[NLCOUNT] = NODELIST+NLCOUNT;
        for (nptr= ptr ;*nptr && isspace(*nptr); ) nptr++;
    if (*nptr == '\0') {
      bbslog("nodelist.bbs %d entry read error\n", NLCOUNT);
      return -1;
        }
        /*NODELIST[NLCOUNT].id = nptr;*/
        NODELIST[NLCOUNT].node = nptr;
    for (nptr++; *nptr && !isspace(*nptr); ) nptr++;
    if (*nptr == '\0') {
      bbslog("nodelist.bbs node %d entry read error\n", NLCOUNT);
      return -1;
        }
        *nptr = '\0';
        if ((tptr = strchr(NODELIST[NLCOUNT].node,'/'))) {
       *tptr = '\0';
       NODELIST[NLCOUNT].exclusion = tptr + 1;
    } else {
       NODELIST[NLCOUNT].exclusion = "";
    }
        for (nptr++ ;*nptr && isspace(*nptr); ) nptr++;
    if (*nptr == '\0') continue;
    if (*nptr=='+' || *nptr=='-') {
       NODELIST[NLCOUNT].feedtype = *nptr;
       if (NODELIST[NLCOUNT].feedfp != NULL) {
         fclose(NODELIST[NLCOUNT].feedfp);
       }
       if ( NODELIST[NLCOUNT].feedtype == '+')
         if (outgoing != NULL) {
         NODELIST[NLCOUNT].feedfp = fopen((char*)fileglue("%s/out.going/%s.%s",BBSHOME, NODELIST[NLCOUNT].node, outgoing),"a");
         }
       nptr++;
    } else {
       NODELIST[NLCOUNT].feedtype = ' ';
    }
        NODELIST[NLCOUNT].host = nptr;
    for (nptr++; *nptr && !isspace(*nptr); ) nptr++;
    if (*nptr == '\0') {
       continue;
        }
        *nptr = '\0';
        for (nptr++;*nptr && isspace(*nptr); ) nptr++;
    if (*nptr == '\0') continue;
        NODELIST[NLCOUNT].protocol = nptr;
    for (nptr++; *nptr && !isspace(*nptr); ) nptr++;
    if (*nptr == '\0') continue;
        *nptr = '\0';
        for (nptr++;*nptr && strchr(" \t\r\n",*nptr); ) nptr++;
    if (*nptr == '\0') continue;
        NODELIST[NLCOUNT].comments = nptr;
    }
    qsort(NODELIST, NLCOUNT, sizeof(nodelist_t), nlcmp);
    qsort(NODELIST_BYNODE, NLCOUNT, sizeof(nodelist_t*), nl_bynodecmp);
    return 0;
}

readnffile(inndhome)
char *inndhome;
{
    FILE *fp;
    char buff[1024];
    struct stat st;
    int i, count; 
    char *ptr, *newsfeedsptr;

    sprintf(buff,"%s/newsfeeds.bbs", inndhome);
    fp = fopen(buff,"r");
    if (fp == NULL) {
       fprintf(stderr,"open fail %s",buff);
       return -1;
    }
    if (fstat(fileno(fp),&st) != 0) {
    fprintf(stderr,"stat fail %s", buff);
        return -1;
    }
    if (NEWSFEEDS_BUF == NULL) {
    NEWSFEEDS_BUF = (char*) mymalloc( st.st_size +1);
    } else {
    NEWSFEEDS_BUF = (char*) myrealloc( NEWSFEEDS_BUF, st.st_size +1);
    }
    i = 0, count =0;
    while (fgets(buff, sizeof buff, fp) != NULL) {
       if (buff[0] == '#') continue;
       if (buff[0] == '\n') continue;
       strcpy(NEWSFEEDS_BUF+i, buff);
       i += strlen(buff);
       count ++;
    }
    fclose(fp);
    if (NEWSFEEDS == NULL) {
       NEWSFEEDS = (newsfeeds_t*) mymalloc(sizeof(newsfeeds_t) * (count+1));
       NEWSFEEDS_BYBOARD = (newsfeeds_t**) mymalloc(sizeof(newsfeeds_t*) * (count+1));
    } else {
       NEWSFEEDS = (newsfeeds_t*) myrealloc(NEWSFEEDS, sizeof(newsfeeds_t) * (count+1));
       NEWSFEEDS_BYBOARD = (newsfeeds_t**) myrealloc(NEWSFEEDS_BYBOARD, sizeof(newsfeeds_t*) * (count+1));
    }
    NFCOUNT = 0; 
    for (ptr = NEWSFEEDS_BUF; (newsfeedsptr = (char*)strchr(ptr,'\n')) != NULL; ptr = newsfeedsptr +1, NFCOUNT++) {
    char *nptr , *bptr, *pptr;
    *newsfeedsptr = '\0';
    NEWSFEEDS[NFCOUNT].newsgroups = "";
    NEWSFEEDS[NFCOUNT].board = "";
    NEWSFEEDS[NFCOUNT].path = NULL;
    NEWSFEEDS_BYBOARD[NFCOUNT] = NEWSFEEDS+NFCOUNT;
        for (nptr= ptr ;*nptr && isspace(*nptr); ) nptr++;
    if (*nptr == '\0') continue;
        NEWSFEEDS[NFCOUNT].newsgroups = nptr;
    for (nptr++; *nptr && !isspace(*nptr); ) nptr++;
    if (*nptr == '\0') continue;
        *nptr = '\0';
        for (nptr++ ;*nptr && isspace(*nptr); ) nptr++;
    if (*nptr == '\0') continue;
        NEWSFEEDS[NFCOUNT].board = nptr;
    for (nptr++; *nptr && !isspace(*nptr); ) nptr++;
    if (*nptr == '\0') continue;
        *nptr = '\0';
        for (nptr++;*nptr && isspace(*nptr); ) nptr++;
    if (*nptr == '\0') continue;
        NEWSFEEDS[NFCOUNT].path = nptr;
    for (nptr++; *nptr && !strchr("\r\n",*nptr); ) nptr++;
        *nptr = '\0';
    }
    qsort(NEWSFEEDS, NFCOUNT, sizeof(newsfeeds_t), nfcmp);
    qsort(NEWSFEEDS_BYBOARD, NFCOUNT, sizeof(newsfeeds_t*), nf_byboardcmp);
}

newsfeeds_t *search_board(board)
char *board;
{
   newsfeeds_t nft, *nftptr, **find;
   if (NONENEWSFEEDS) return NULL;
   nft.board = board;
   nftptr = &nft;
   find = (newsfeeds_t**)bsearch((char*)&nftptr, NEWSFEEDS_BYBOARD, NFCOUNT, sizeof(newsfeeds_t*), nf_byboardcmp);
   if (find != NULL) return *find;
   return NULL;
}

nodelist_t *search_nodelist_bynode(node)
char *node;
{
   nodelist_t nlt, *nltptr, **find;
   if (LOCALNODELIST) return NULL;
   nlt.node = node;
   nltptr = &nlt;
   find = (nodelist_t**)bsearch((char*)&nltptr, NODELIST_BYNODE, NLCOUNT, sizeof(nodelist_t*), nl_bynodecmp);
   if (find != NULL) return *find;
   return NULL;
}


nodelist_t *search_nodelist(site, identuser)
char *site;
char *identuser;
{
   nodelist_t nlt, *find;
   char buffer[1024];
   if (LOCALNODELIST) return NULL;
   nlt.host = site;
   find = (nodelist_t*)bsearch((char*)&nlt, NODELIST, NLCOUNT, sizeof(nodelist_t), nlcmp);
   if (find == NULL && identuser != NULL) {
     sprintf(buffer,"%s@%s", identuser, site);
     nlt.host = buffer;
     find = (nodelist_t*)bsearch((char*)&nlt, NODELIST, NLCOUNT, sizeof(nodelist_t), nlcmp);
   }
   return find;
}

newsfeeds_t *search_group(newsgroup)
char *newsgroup;
{
   newsfeeds_t nft, *find;
   if (NONENEWSFEEDS) return NULL;
   nft.newsgroups = newsgroup;
   find = (newsfeeds_t*)bsearch((char*)&nft, NEWSFEEDS, NFCOUNT, sizeof(newsfeeds_t), nfcmp);
   return find;
}

char *ascii_date(now)
time_t now;
{
   static char datebuf[40];
   /*time_t now;
   time(&now);*/
   strftime(datebuf, sizeof(datebuf), "%d %b %Y %X GMT", gmtime(&now));
   return datebuf;
}

char *
restrdup(ptr, string)
char *ptr;
char *string;
{
   int len ;
   if (string == NULL) {
      if (ptr != NULL) *ptr = '\0';
      return ptr;
   }
   len = strlen(string) + 1;
   if (ptr != NULL) {
      ptr = (char*)myrealloc(ptr, len);
   } else
   ptr = (char*)mymalloc(len);
   strcpy(ptr, string);
   return ptr;
}



void *
mymalloc(size)
int size;
{
    char *ptr = (char*)malloc(size);
    if (ptr == NULL) {
       fprintf(stderr, "cant allocate memory\n");
       syslog(LOG_ERR, "cant allocate memory %m");
       exit(1);
    }
    return ptr;
}

void *
myrealloc(optr, size)
void *optr;
int size;
{
    char *ptr = (char*)realloc(optr, size);
    if (ptr == NULL) {
       fprintf(stderr, "cant allocate memory\n");
       syslog(LOG_ERR, "cant allocate memory %m");
       exit(1);
    }
    return ptr;
}

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;
}

#ifdef BBSLIB
main()
{
   initial_bbs("feed");
   printf("%s\n",ascii_date());
}
#endif