wm: glendy

ref: e7d1c059532a72e73ddfcaf3e78167b819bf1abb
dir: /netclient.c/

#ifdef unix
#include "unix.h"
#else
#include <u.h>
#include <libc.h>
#include <draw.h>
#endif
#include "engine.h"
#include "netclient.h"
#include "util.h"

int waitbit = 1; /* 0 is go, 1 is wait */
int networked = 0; /* 0 is local, 1 is networked */
int pside; /* Trapper, Glenda */

int srvfd;

static char*
movemsg(int dir)
{
	char *d, *msg;

	d = dirtostr(dir);
	if(d == nil)
		return nil;
	
	msg = (char*)malloc(8);
	sprint(msg, "m %s\n", d);
	return msg;
}

static char*
putmsg(int x, int y)
{
	char *msg;

	if(x > SzX || x < 0 || y > SzY || y < 0)
		return nil;
	
	msg = (char*)malloc(10);
	sprint(msg, "p %d %d\n", x, y);
	return msg;
}

int
netmove(int dir)
{
	int len;
	char *msg;

	msg = movemsg(dir);

	if(msg == nil)
		return Err;
	
	len = strlen(msg);
	if(write(srvfd, msg, len) < len)
		sysfatal("netmove(): half written?");

	/* otherwise client wont read socket to confirm */
	waitbit = 1;
	free(msg);
	return Ok;
}

int
netput(int x, int y)
{
	int len;
	char *msg;

	msg = putmsg(x, y);
	
	if(msg == nil)
		return Err;
	
	len = strlen(msg);
	if(write(srvfd, msg, len) < len)
			sysfatal("netput(): half written?: %r");

	/* otherwise client wont read socket to confirm */
	waitbit = 1;
	free(msg);
	return Ok;
}

static void
netproc(Netmsg *msg, char *in)
{
	int i, dir;
	char *tmp, *xpos, *ypos;
	
	char **tokens = (char**)malloc(64 * sizeof(char*));;
	Point p;
	
	msg->omsg = strdup(in);
	dprint("msg->omsg: %s\n", in);
	
	tokens[0] = strtok(in, " ");
	for(i = 1 ; tokens[i-1] != nil ; i++)
	{
		tokens[i] = strtok(nil, " ");
		dprint("token[%d] = %s\n", i, tokens[i]);
	}
	
	msg->ntoken = i;
	msg->tokens = tokens;
	msg->err = Ok;
	if(!strcmp(tokens[0], "CONN"))
	{
		switch(*tokens[1])
		{
			case '0':
				pside = PTrapper;
				break;
			case '1':
				pside = PGlenda;
				break;
			default:
				sysfatal("invalid conn");
		}
	}
	else if(!strcmp(tokens[0], "WAIT"))
	{
		waitbit = 1;
	}
	else if(!strcmp(tokens[0], "INIT"))
	{
		state = Init;
		while(state == Init)
		{
			tmp = netread();
			/* lots of assuming goes here,
			 * messages are in the form of:
			 * {w,g} xx yy\n
			 */
			strtok(tmp, " ");
			switch(*tmp)
			{
				case 'w':
					xpos = strtok(nil, " ");
					ypos = strtok(nil, " ");
					if(xpos == nil || ypos == nil)
						sysfatal("netproc(): w xpos or ypos is nil?\n");
					p.x = atoi(xpos);
					p.y = atoi(ypos);
					
					grid[p.x][p.y] = Wall;
					break;
				case 'g':
					xpos = strtok(nil, " ");
					ypos = strtok(nil, " ");
					if(xpos == nil || ypos == nil)
						dprint("netproc(): g xpos or ypos is nil?\n");
					
					p.x = atoi(xpos);
					p.y = atoi(ypos);
					
					grid[p.x][p.y] = Glenda;
					break;
				default:
					if(!strcmp("SENT", tmp))
						state = Start;
					else
						dprint("netproc(): unknown command: %s\n", tmp);
				
			}
		}
	}
	else if(!strcmp(tokens[0], "SENT"))
	{
		/* sent is handled in INIT */
		dprint("SENT without INIT?\n");
	}
	else if(!strcmp(tokens[0], "TURN"))
	{
		waitbit = 0;
	}
	else if(!strcmp(tokens[0], "WALL"))
	{
		msg->err = Wall;
	}
	else if(!strcmp(tokens[0], "GLND"))
	{
		msg->err = Glenda;
	}
	else if(!strcmp(tokens[0], "SYNC"))
	{
		if(state == Start)
			state = Playing;
		if(msg->ntoken < 2)
			sysfatal("netproc(): not enough toknes?");
		
		/* TODO: very ugly hack, get rid of this */
		networked = 0;
		if(atoi(msg->tokens[1]) % 2 == 0)
		{
			/* glenda's turn is done */
			if(msg->ntoken < 3)
				sysfatal("netproc(): not enough tokens to SYNC glenda's move");
			dir = parsemove(tokens[2]);
			domove(dir);
			dprint("in glenda's turn\n");
		}
		else
		{
			/* trapper's turn is done */
			if(msg->ntoken < 4)
				sysfatal("netproc(): not enough tokens to SYNC trapper's move");
			
			p = parseput(tokens[2], tokens[3]);
			doput(p);
		}
		/* TODO: very ugly hack, get rid of this */
		networked = 1;
	}
	else if(!strcmp(tokens[0], "WON"))
		state = Won;
	else if(!strcmp(tokens[0], "LOST"))
		state = Lost;
	else 
	{
		sysfatal("netproc(): unkown message");
	}
}

char*
netread(void)
{
	char *s = malloc(1024);
	int n = 0;
	
	memset(s, 0, 1024);
	while(read(srvfd, s+n, 1) == 1 && n < 1023)
	{
		if(s[n] == '\n' || s[n] == '\0')
		{
			s[n] = '\0';
			break;
		}
		n++;
	}
	return s;
}

Netmsg*
netmain(void)
{
	Netmsg *msg;
	char *s;
	msg = malloc(sizeof(Netmsg));

	s = netread();
	netproc(msg, s);
	free(s);
	return msg;
}