path: root/util/expire.c

/* $Id: expire.c,v 1.6 2002/11/11 03:06:03 in2 Exp $ */
/* 自動砍信工具程式 */

#include "bbs.h"

#define QCAST int (*)(const void *, const void *)

#define DEF_DAYS    50
#define DEF_MAXP    2000
#define DEF_MINP    300

#define EXPIRE_CONF BBSHOME "/etc/expire.conf"
extern boardheader_t *bcache;
char bpath[256];

struct life
{
    char bname[16];     /* board ID */
    int days;           /* expired days */
    int maxp;           /* max post */
    int minp;           /* min post */
};
typedef struct life life;


void
 expire(brd)
life *brd;
{
    fileheader_t head;
    struct stat state;
    char lockfile[128], tmpfile[128], bakfile[128];
    char fpath[128], index[128], *fname;
    int total, bid;
    int fd, fdr, fdw, done, keep;
    int duetime, ftime;

    printf("%s\n", brd->bname);
    if((bid = getbnum(brd->bname)) == 0 || 
    strcmp(brd->bname, bcache[bid-1].brdname))
     {
     char    cmd[1024];
     printf("no such board?: %s\n", brd->bname);
     sprintf(cmd, "mv %s/boards/%c/%s %s/boards.error/%s",
         BBSHOME, brd->bname[0], brd->bname, BBSHOME, brd->bname);
     system(cmd);
        return;
     }
#ifdef  VERBOSE
    if (brd->days < 1)
    {
    printf(":Err: expire time must more than 1 day.\n");
    return;
    }
    else if (brd->maxp < 100)
    {
    printf(":Err: maxmum posts number must more than 100.\n");
    return;
    }
#endif

    sprintf(index, "%s/%s/.DIR", bpath, brd->bname);
    sprintf(lockfile, "%s.lock", index);
    if ((fd = open(lockfile, O_RDWR | O_CREAT | O_APPEND, 0644)) == -1)
    return;
    flock(fd, LOCK_EX);

    strcpy(fpath, index);
    fname = (char *) strrchr(fpath, '.');

    duetime = time(NULL) - brd->days * 24 * 60 * 60;
    done = 0;
    if ((fdr = open(index, O_RDONLY, 0)) > 0)
    {
    fstat(fdr, &state);
    total = state.st_size / sizeof(head);
    sprintf(tmpfile, "%s.new", index);
    unlink(tmpfile);
    if ((fdw = open(tmpfile, O_WRONLY | O_CREAT | O_EXCL, 0644)) > 0)
    {
        while (read(fdr, &head, sizeof head) == sizeof head)
        {
        done = 1;
        ftime = atoi(head.filename + 2);
        if (head.owner[0] == '-')
            keep = 0;
        else if (head.filemode & FILE_MARKED || total <= brd->minp)
            keep = 1;
        else if (ftime < duetime || total > brd->maxp)
            keep = 0;
        else
            keep = 1;

        if (keep)
        {
            if (write(fdw, (char *)&head, sizeof head) == -1)
            {
            done = 0;
            break;
            }
        }
        else
        {
            strcpy(fname, head.filename);
            unlink(fpath);
            printf("\t%s\n", fname);
            total--;
        }
        }
        close(fdw);
    }
    close(fdr);
    }

    if (done)
    {
    sprintf(bakfile, "%s.old", index);
    if (rename(index, bakfile) != -1)
         {
        rename(tmpfile, index);
        touchbtotal(bid);
         }
    }
    flock(fd, LOCK_UN);
    close(fd);
}


int main(argc, argv)
char *argv[];
{
    FILE *fin;
    int number, count;
    life db, table[MAX_BOARD], *key;
    struct dirent *de;
    DIR *dirp;
    int     i;
    char    *ptr, *bname, buf[256];
    char    dirs[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
              'q', 'w', 'e', 'r', 't', 'y', 'u', 'i', 'o', 'p',
              'a', 's', 'd', 'f', 'g', 'h', 'j', 'k', 'l',
              'z', 'x', 'c', 'v', 'b', 'n', 'm',
              'Q', 'W', 'E', 'R', 'T', 'Y', 'U', 'I', 'O', 'P',
              'A', 'S', 'D', 'F', 'G', 'H', 'J', 'K', 'L',
              'Z', 'X', 'C', 'V', 'B', 'N', 'M', NULL};

    resolve_boards();
    db.days = ((argc > 1) && (number = atoi(argv[1])) > 0) ? number : DEF_DAYS;
    db.maxp = ((argc > 2) && (number = atoi(argv[2])) > 0) ? number : DEF_MAXP;
    db.minp = ((argc > 3) && (number = atoi(argv[3])) > 0) ? number : DEF_MINP;

/* --------------- */
/* load expire.ctl */
/* --------------- */

    count = 0;
    if((fin = fopen(EXPIRE_CONF, "r")))
    {
    while (fgets(buf, 256, fin))
    {
        if (buf[0] == '#')
        continue;

        bname = (char *) strtok(buf, " \t\r\n");
        if (bname && *bname)
        {
        ptr = (char *) strtok(NULL, " \t\r\n");
        if (ptr && (number = atoi(ptr)) > 0)
        {
            key = &(table[count++]);
            strcpy(key->bname, bname);
            key->days = number;
            key->maxp = db.maxp;
            key->minp = db.minp;

            ptr = (char *) strtok(NULL, " \t\r\n");
            if (ptr && (number = atoi(ptr)) > 0)
            {
            key->maxp = number;

            ptr = (char *) strtok(NULL, " \t\r\n");
            if (ptr && (number = atoi(ptr)) > 0)
            {
                key->minp = number;
            }
            }
        }
        }
    }
    fclose(fin);
    }

    if (count > 1)
    {
    qsort(table, count, sizeof(life), (QCAST)strcasecmp);
    }

/* ---------------- */
/* visit all boards */
/* ---------------- */

    for( i = 0 ; dirs[i] != NULL ; ++i ){
    sprintf(bpath, BBSHOME "/boards/%c", dirs[i]);
    if (!(dirp = opendir(bpath))){
        printf(":Err: unable to open %s\n", bpath);
        continue;
    }
    while((de = readdir(dirp))){
        ptr = de->d_name;
        if (ptr[0] > ' ' && ptr[0] != '.'){
        if (count)
            key = (life *) bsearch(ptr, table, count, sizeof(life), (QCAST)strcasecmp);
        else
            key = NULL;
        if (!key)
            key = &db;
        strcpy(key->bname, ptr);
        expire(key);
        }
    }
    closedir(dirp);
    }
    return 0;
}