shithub: ircd

ref: 4161df5fd7487feaf4758b93a8d8371bec433471
dir: /ircd.c/

#include <u.h>
#include <libc.h>
#include <auth.h>
#include <fcall.h>
#include <thread.h>
#include <9p.h>
#include <bio.h>
#include "dat.h"
#include "fns.h"
#include "version.h"

void
usage(void)
{
	fprint(2, "usage: %s\n", argv0);
	threadexitsall("usage");
}

static Biobuf *bio;
char *sysnameb = "nil";
static char *versionstring = nil;
int debug = 0;

char*
getversion()
{
	if (versionstring)
		return versionstring;
	
	versionstring = smprint("%s.%d %s :%s", Vversion, debug, Vname, Vcomment);
	return versionstring;
}

char *mtpt = "/mnt/ircd";
char *srvname = "ircd";
Reqqueue *reqqueue = nil;
User *ircuser = nil;

void
setuser(User *u)
{
	ircuser = u;
}

static void
readproc(Req *r)
{
	char *repl;
	
	threadsetname("readproc");
	
	if (!ircuser) {
		respond(r, nil);
		return;
	}
	
	while (1) {
		qlock(&ircuser->replies);
		repl = getreplies(ircuser);
		if (repl) {
			readstr(r, repl);
			qunlock(&ircuser->replies);
			respond(r, nil);
			return;
		}
		qunlock(&ircuser->replies);
	}
}

static void
fsread(Req *r)
{
	reqqueuepush(reqqueue, r, readproc);
}

static void
fswrite(Req *r)
{
	char line[512];
	char *c;
	Request parsed;
	
	if (r->ifcall.count > 512) {
		respond(r, "too many bytes");
		return;
	}
	memcpy(line, r->ifcall.data, r->ifcall.count);
	r->ofcall.count = r->ifcall.count;
	line[r->ifcall.count-1] = 0; /* last char is either \n or \r */
	
	c = strchr(line, '
');
	if (c)
		*c = 0;
	
	parsed = parseline(line);
	if (debug > 1)
		fprint(2, "request:%R", parsed);
	execrequest(ircuser, parsed);
	
	respond(r, nil);
}

static void
fsflush(Req *r)
{
	reqqueueflush(reqqueue, r->oldreq);
	respond(r, nil);
}

Srv fs = {
	.read = fsread,
	.write = fswrite,
	.flush = fsflush,
};

void
populatetree(File *root)
{
	File *f;
	
	if ((f = createfile(root, "irc", nil, 0666, nil)) != nil) {
		f->length = 0;
	}
}

void
threadmain(int argc, char **argv)
{
	ARGBEGIN{
	case 'h':
		usage();
		break;
	case 'v':
		fprint(2, "version: %s\n", getversion());
		threadexitsall(nil);
	case 's':
		srvname = EARGF(usage());
		break;
	case 'm':
		mtpt = EARGF(usage());
		break;
	case 'd':
		debug++;
		break;
	case 'D':
		chatty9p++;
		break;
	}ARGEND;
	
	fmtinstall('R', Rfmt);
	
	sysnameb = sysname();
	reqqueue = reqqueuecreate();
	
	fs.tree = alloctree(nil, nil, DMDIR|0777, nil);
	populatetree(fs.tree->root);
	threadpostmountsrv(&fs, srvname, mtpt, MREPL|MCREATE);
	//exits(nil);
}