/*
 *  This part deals with the history database and had
 *  been originally written by
 *
 *  Kai Uwe Rommel <rommel@ars.muc.de>
 *
 *  Bug reports related to THIS heavily modified version
 *  should be sent to
 *
 *  harald@os2point.ping.de
 *  harald@haport.sesam.com
 *  Fido: 2:2448/434
 *
 */
#include <stdlib.h>
#include <stdio.h>
#include <io.h>
#include <string.h>
#include <time.h>

#include <fcntl.h>

#include <dbgheap.h>

#include <lprintf.h>
#include <dbm.h>
#include <datetime.h>
#include <active.h>
#include <history.h>

/************************************************************************/
/*                                                                      */
/* gethistart                                                           */
/*                                                                      */
/* Finds an article entry in the history file by it's id and            */
/* returns the path name of this article if found.                      */
/*                                                                      */
/* Parameter    Description                                             */
/* ------------ ------------------------------------------------------- */
/* historyfile  Points to a string that specifies the name of the       */
/*              history data base. Usually this will be "history".      */
/*                                                                      */
/* msg_id       Points to a string that specifies the id of the         */
/*              message to search for.                                  */
/*                                                                      */
/* artpath      Points to a buffer that receives the path to the        */
/*              message if found. This buffer must be preinitialized    */
/*              with the name of the newsgroup's home directory.        */
/*              If the caller doesn't need the path then this pointer   */
/*              may be NULL.                                            */
/* ------------ ------------------------------------------------------- */
/* Return value True if found, false otherwise.                         */
/*                                                                      */
/************************************************************************/
int gethistart(const char *historyfile, char *msg_id, char *artpath)
{
    register char  *cp;
    register char  *cp1;
    char  *line;
    DBM   *db;
    datum key, val;
    char  *histpag;
    int   isvirgin;

    /*
     * If no history file exists we assume that we were
     * started in a virgin environment. We check this first
     * to avoid an error message while opening the database.
     */
    histpag = malloc(strlen(historyfile) + 5);
    strcat(strcpy(histpag, historyfile), ".pag");
    isvirgin = access(histpag, 0);
    free(histpag);
    if(isvirgin)
        return(0);

    /*
     * Fetch the entry with the given message id
     */
    if((db = dbm_open(historyfile, O_RDONLY, 0)) != NULL) {
        key.dptr = msg_id;
        key.dsize = strlen(msg_id) + 1;
        val = dbm_fetch(db, key);

        if (val.dptr == NULL) {
            dbm_close(db);
            return(0);  /* article not found */
        }
        if(artpath == NULL) {
            dbm_close(db);
            return(1);  /* article found, caller doesn't need path */
        }

        /*
         * We need to copy the history line because dbm_close
         * will free the read buffer of the database.
         */
        line = strdup(val.dptr);
        dbm_close(db);
    }
    else {
        lprintf("Failed to open %s", historyfile);
        return(0);
    }

    /*
     * We assume this structure of our history line
     * <msg_id> <time> <size> <grp:num>[,<grp:num>]
     * Field separators may be space or tab. The last
     * field <grp:num> may be repeated and separated
     * by commas.
     */
    cp = line;
    while(*cp && *cp != ' ' && *cp != '\t')
        cp++;
    while(*cp == ' ' || *cp == '\t')
        cp++;
    while(*cp && *cp != ' ' && *cp != '\t')
        cp++;
    while(*cp == ' ' || *cp == '\t')
        cp++;

    if(*cp) {
        /*
         * Now cp points to the first <grp:num> item.
         * Append the path of this message to artpath.
         */
        cp1 = strchr(artpath, '\0');
        *cp1++ = '\\';
        while(*cp && *cp != ' ' && *cp != '\t' && *cp != ',') {
            if(*cp == '.' || *cp == ':')
                *cp1++ = '\\';
            else
                *cp1++ = *cp;
            cp++;
        }
        *cp1 = '\0';

        free(line);
        return(1);  /* article found, path supplied */
    }

    free(line);
    return (0);     /* article found, but could not supply path */
}

/************************************************************************/
/*                                                                      */
/*  addhistart                                                          */
/*                                                                      */
/*                                                                      */
/************************************************************************/
int addhistart(const char *historyfile, char *messageID,
               char **ngarray, long art_size)
{
    int groups_found = 0;
    char *hist_record = malloc(HISTRECSIZE);
    char snum[12];
    long himsg;
    datum key, val;
    void *hfp;
    int  i;

    /*
     * Create history record
     */
    sprintf(hist_record, "%ld %ld ", local_to_gmt(time(NULL)), art_size);
    for(i = 0; ngarray[i] != NULL; i++) {
        if(find_active(NULL, ngarray[i], NULL, &himsg)) {
            if (groups_found)
                strcat(hist_record, ",");
            strcat(hist_record, ngarray[i]);
            strcat(hist_record, ":");
            strcat(hist_record, ltoa(himsg, snum, 10));
            groups_found++;
        }
    }

    if(groups_found) {
        /*
         * Add history record to database
         */
        if((hfp = dbm_open(historyfile, O_RDWR | O_CREAT, 0666)) != NULL) {
            key.dptr = messageID;
            key.dsize = strlen(key.dptr) + 1;
            val.dptr = hist_record;
            val.dsize = strlen(val.dptr) + 1;
            if (dbm_store(hfp, key, val, DBM_REPLACE))
                lprintf("Failed to store history record");
            dbm_close(hfp);
        }
        else
            lprintf("Failed to open %s", historyfile);
    }

    free(hist_record);
    return(groups_found != 0);
}

/************************************************************************/
/*                                                                      */
/* delhistart                                                           */
/*                                                                      */
/* Finds an article entry in the history file by it's id and deletes    */
/* this entry if found.                                                 */
/*                                                                      */
/* Parameter    Description                                             */
/* ------------ ------------------------------------------------------- */
/* historyfile  Points to a string that specifies the name of the       */
/*              history data base. Usually this will be "history".      */
/*                                                                      */
/* msg_id       Points to a string that specifies the id of the         */
/*              message to search for.                                  */
/*                                                                      */
/* artlist      Points to a buffer that receives a list of messages     */
/*              in the format <grp:num>[,<grp:num>]. If no entry was    */
/*              found in historyfile, then this string will be empty.   */
/* ------------ ------------------------------------------------------- */
/* Return value Pointer to artlist.                                     */
/*                                                                      */
/************************************************************************/
char *delhistart(const char *historyfile, char *msg_id, char *artlist)
{
    datum key, val;
    void *hfp;
    char *line;
    char *cp;

    *artlist = '\0';

    /*
     * Search history file
     */
    if((hfp = dbm_open(historyfile, O_RDWR | O_CREAT, 0666)) == NULL) {
        lprintf("Failed to open %s", historyfile);
        return(artlist);
    }

    key.dptr = msg_id;
    key.dsize = strlen(key.dptr) + 1;
    val = dbm_fetch(hfp, key);
    if(val.dptr == NULL) {
        dbm_close(hfp);
        lprintf("Can't find %s to cancel", msg_id);
        return(artlist);
    }

    line = strdup(val.dptr);

    /*
     * Delete entry
     */
    key.dptr = msg_id; /* To check: Is this really needed? */
    key.dsize = strlen(key.dptr) + 1;

    if(dbm_cancel(hfp, key))
        lprintf("Failed to remove article(s) from history");

    dbm_close(hfp);

    /*
     * Copy result into buffer
     */
    cp = line;
    while(*cp && *cp != ' ' && *cp != '\t')
        cp++;
    while(*cp == ' ' || *cp == '\t')
        cp++;
    while(*cp && *cp != ' ' && *cp != '\t')
        cp++;
    while(*cp == ' ' || *cp == '\t')
        cp++;

    if(cp)
        strcpy(artlist, cp);

    free(line);

    return(artlist);
}