/* file_c.c -- File cache management */

#include "autoconf.h"
#include "copyright.h"
#ifndef	lint
static char RCSid[] = "$Id: file_c.c,v 1.7 1995/03/21 00:00:15 ambar Exp $";
USE(RCSid);
#endif

#include "config.h"
#include "interface.h"
#include "mudconf.h"
#include "command.h"
#include "file_c.h"
#include "alloc.h"

typedef struct filecache_hdr FCACHE;
typedef struct filecache_block_hdr FBLKHDR;
typedef struct filecache_block FBLOCK;

  struct filecache_hdr {
      char *filename;
      FBLOCK *fileblock;
      const char *desc;
  };

  struct filecache_block {
	struct filecache_block_hdr {
	    struct filecache_block *nxt;
	    int nchars;
	}
      hdr;
      char data[MBUF_SIZE - sizeof(FBLKHDR)];
  };

#define FBLOCK_SIZE (MBUF_SIZE - sizeof(FBLKHDR))

FCACHE fcache[] =
{
    {mudconf.conn_file, NULL, "Conn"},
    {mudconf.site_file, NULL, "Conn/Badsite"},
    {mudconf.down_file, NULL, "Conn/Down"},
    {mudconf.full_file, NULL, "Conn/Full"},
    {mudconf.guest_file, NULL, "Conn/Guest"},
    {mudconf.creg_file, NULL, "Conn/Reg"},
    {mudconf.crea_file, NULL, "Crea/Newuser"},
    {mudconf.regf_file, NULL, "Crea/RegFaill"},
    {mudconf.motd_file, NULL, "Motd"},
    {mudconf.wizmotd_file, NULL, "Wizmotd"},
    {mudconf.quit_file, NULL, "Quit"},
#ifdef PUEBLO_SUPPORT
    {mudconf.htmlconn_file, NULL, "Conn/Html"},
#endif /* PUEBLO_SUPPORT */
    {NULL, NULL, NULL}};

NAMETAB list_files[] =
{
    {(char *) "badsite_connect", 1, CA_WIZARD, FC_CONN_SITE},
    {(char *) "connect", 2, CA_WIZARD, FC_CONN},
    {(char *) "create_register", 2, CA_WIZARD, FC_CREA_REG},
    {(char *) "down", 1, CA_WIZARD, FC_CONN_DOWN},
    {(char *) "full", 1, CA_WIZARD, FC_CONN_FULL},
    {(char *) "guest_motd", 1, CA_WIZARD, FC_CONN_GUEST},
#ifdef PUEBLO_SUPPORT
    {(char *) "html_connect", 1, CA_WIZARD, FC_CONN_HTML},
#endif /* PUEBLO_SUPPORT */
    {(char *) "motd", 1, CA_WIZARD, FC_MOTD},
    {(char *) "newuser", 1, CA_WIZARD, FC_CREA_NEW},
    {(char *) "quit", 1, CA_WIZARD, FC_QUIT},
    {(char *) "register_connect", 1, CA_WIZARD, FC_CONN_REG},
    {(char *) "wizard_motd", 1, CA_WIZARD, FC_WIZMOTD},
    {NULL, 0, 0, 0}};

void 
do_list_file(player, cause, extra, arg)
    dbref player, cause;
    int extra;
    char *arg;
{
    int flagvalue;

    flagvalue = search_nametab(player, list_files, arg);
    if (flagvalue < 0) {
	display_nametab(player, list_files,
			(char *) "Unknown file.  Use one of:", 1);
	return;
    }
    fcache_send(player, flagvalue);
}

static FBLOCK *
fcache_fill(fp, ch)
    FBLOCK *fp;
    char ch;
{
    FBLOCK *tfp;

    if (fp->hdr.nchars >= (MBUF_SIZE - sizeof(FBLKHDR))) {

	/* We filled the current buffer.  Go get a new one. */

	tfp = fp;
	fp = (FBLOCK *) alloc_mbuf("fcache_fill");
	fp->hdr.nxt = NULL;
	fp->hdr.nchars = 0;
	tfp->hdr.nxt = fp;
    }
    fp->data[fp->hdr.nchars++] = ch;
    return fp;
}

static int 
fcache_read(cp, filename)
    FBLOCK **cp;
    char *filename;
{
    int n, nmax, tchars, fd;
    char *buff;
    FBLOCK *fp, *tfp;

    /* Free a prior buffer chain */

    fp = *cp;
    while (fp != NULL) {
	tfp = fp->hdr.nxt;
	free_mbuf(fp);
	fp = tfp;
    }
    *cp = NULL;

    /* Read the text file into a new chain */

    if ((fd = tf_open(filename, O_RDONLY)) == -1) {

	/* Failure: log the event */

	STARTLOG(LOG_PROBLEMS, "FIL", "OPEN")
	    buff = alloc_mbuf("fcache_read.LOG");
	sprintf(buff, "Couldn't open file '%s'.", filename);
	log_text(buff);
	free_mbuf(buff);
	ENDLOG
	    tf_close(fd);
	return -1;
    }
    buff = alloc_lbuf("fcache_read.temp");

    /* Set up the initial cache buffer to make things easier */

    fp = (FBLOCK *) alloc_mbuf("fcache_read.first");
    fp->hdr.nxt = NULL;
    fp->hdr.nchars = 0;
    *cp = fp;
    tchars = 0;

    /* Process the file, one lbuf at a time */

    nmax = read(fd, buff, LBUF_SIZE);
    while (nmax > 0) {

	for (n = 0; n < nmax; n++) {
	    switch (buff[n]) {
	    case '\n':
		fp = fcache_fill(fp, '\r');
		fp = fcache_fill(fp, '\n');
		tchars += 2;
	    case '\0':
	    case '\r':
		break;
	    default:
		fp = fcache_fill(fp, buff[n]);
		tchars++;
	    }
	}
	nmax = read(fd, buff, LBUF_SIZE);
    }
    free_lbuf(buff);
    tf_close(fd);

    /* If we didn't read anything in, toss the initial buffer */

    if (fp->hdr.nchars == 0) {
	*cp = NULL;
	free_mbuf(fp);
    }
    return tchars;
}

void 
fcache_rawdump(fd, num)
    int fd, num;
{
    int cnt, remaining;
    char *start;
    FBLOCK *fp;

    if ((num < 0) || (num > FC_LAST))
	return;
    fp = fcache[num].fileblock;

    while (fp != NULL) {
	start = fp->data;
	remaining = fp->hdr.nchars;
	while (remaining > 0) {

	    cnt = WRITE(fd, start, remaining);
	    if (cnt < 0)
		return;
	    remaining -= cnt;
	    start += cnt;
	}
	fp = fp->hdr.nxt;
    }
    return;
}

void 
fcache_dump(d, num)
    DESC *d;
    int num;
{
    FBLOCK *fp;

    if ((num < 0) || (num > FC_LAST))
	return;
    fp = fcache[num].fileblock;

    while (fp != NULL) {
	queue_write(d, fp->data, fp->hdr.nchars);
	fp = fp->hdr.nxt;
    }
}

void 
fcache_send(player, num)
    dbref player;
    int num;
{
    DESC *d;

    DESC_ITER_PLAYER(player, d) {
	fcache_dump(d, num);
    }
}

void 
fcache_load(player)
    dbref player;
{
    FCACHE *fp;
    char *buff, *bufc, *sbuf;
    int i;

    buff = bufc = alloc_lbuf("fcache_load.lbuf");
    sbuf = alloc_sbuf("fcache_load.sbuf");
    for (fp = fcache; fp->filename; fp++) {
	i = fcache_read(&fp->fileblock, fp->filename);
	if ((player != NOTHING) && !Quiet(player)) {
	    ltos(sbuf, i);
	    if (fp == fcache)
		safe_str((char *) "File sizes: ", buff, &bufc);
	    else
		safe_str((char *) "  ", buff, &bufc);
	    safe_str((char *) fp->desc, buff, &bufc);
	    safe_str((char *) "...", buff, &bufc);
	    safe_str(sbuf, buff, &bufc);
	}
    }
    *bufc = '\0';
    if ((player != NOTHING) && !Quiet(player)) {
	notify(player, buff);
    }
    free_lbuf(buff);
    free_sbuf(sbuf);
}

void 
NDECL(fcache_init)
{
    FCACHE *fp;

    for (fp = fcache; fp->filename; fp++) {
	fp->fileblock = NULL;
    }
    fcache_load(NOTHING);
}