/* file_c.c - File cache management */
/* $Id: file_c.c,v 1.10 2000/11/30 08:21:16 rmg Exp $ */

#include "copyright.h"
#include "autoconf.h"
#include "config.h"

#include "alloc.h"	/* required by mudconf */
#include "flags.h"	/* required by mudconf */
#include "htab.h"	/* required by mudconf */
#include "mudconf.h"	/* required by code */

#include "db.h"		/* required by externs */
#include "externs.h"	/* required by interface */
#include "interface.h"	/* required by code */

#include "command.h"	/* required by code */
#include "file_c.h"	/* required by code */

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))
/* *INDENT-OFF* */

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/RegFail" },
	{ &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
    	{ 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
{(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}};

/* *INDENT-ON* */

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")
			log_printf("Couldn't open file '%s'.", filename);
		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)) {
			sprintf(sbuf, "%d", 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);
}