/*
        net_packetlog.c

        packet logging/parsing - for debugging and educational purposes

        Copyright (C) 2000 Jukka Sorjonen <jukka.sorjonen@asikkala.fi>
       
	This program is free software; you can redistribute it and/or
	modify it under the terms of the GNU General Public License
	as published by the Free Software Foundation; either version 2
	of the License, or (at your option) any later version.

	This program is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

	See the GNU General Public License for more details.

	You should have received a copy of the GNU General Public License
	along with this program; if not, write to:

		Free Software Foundation, Inc.
		59 Temple Place - Suite 330
		Boston, MA  02111-1307, USA

	$Id$


*/

// fixme: we did support Quake1 protocol too...
#define QUAKEWORLD

#ifdef HAVE_CONFIG_H
# include <config.h>
#endif

#include <ctype.h>
#include <stdarg.h>

#include "qtypes.h"
#include "quakeio.h"
#include "net.h"
#include "protocol.h"
#include "msg.h"

#include "server.h"

cvar_t *netlogger;
cvar_t *netloglevel;

extern server_t sv;
extern qboolean is_server(void);

//extern sizebuf_t net_message;
extern byte net_message_buffer[MAX_MSGLEN*2];

void Analyze_Server_Packet(byte *data,int len);
void Analyze_Client_Packet(byte *data,int len);

void Parse_Server_Packet(void);
void Parse_Client_Packet(void);

int Net_LogStart(char *fname);
void Net_LogStop(void);

// note: this is SUPPOSED to be duplicate, like many others
char *svc_string[] =
{
	"svc_bad",
	"svc_nop",
	"svc_disconnect",
	"svc_updatestat",
	"svc_version",		// [long] server version
	"svc_setview",		// [short] entity number
	"svc_sound",			// <see code>
	"svc_time",			// [float] server time
	"svc_print",			// [string] null terminated string
	"svc_stufftext",		// [string] stuffed into client's console buffer
						// the string should be \n terminated
	"svc_setangle",		// [vec3] set the view angle to this absolute value
	
	"svc_serverdata",		// [long] version ...
	"svc_lightstyle",		// [byte] [string]
	"svc_updatename",		// [byte] [string]
	"svc_updatefrags",	// [byte] [short]
	"svc_clientdata",		// <shortbits + data>
	"svc_stopsound",		// <see code>
	"svc_updatecolors",	// [byte] [byte]
	"svc_particle",		// [vec3] <variable>
	"svc_damage",			// [byte] impact [byte] blood [vec3] from
	
	"svc_spawnstatic",
	"svc_spawnbinary",
	"svc_spawnbaseline",
	
	"svc_temp_entity",		// <variable>
	"svc_setpause",
	"svc_signonnum",
	"svc_centerprint",
	"svc_killedmonster",
	"svc_foundsecret",
	"svc_spawnstaticsound",
	"svc_intermission",
	"svc_finale",			// [string] music [string] text
	"svc_cdtrack",			// [byte] track [byte] looptrack
	"svc_sellscreen",	

	"svc_smallkick",		// Quake svc_cutscene
	"svc_bigkick",

	"svc_updateping",
	"svc_updateentertime",

	"svc_updatestatlong",
	"svc_muzzleflash",
	"svc_updateuserinfo",
	"svc_download",
	"svc_playerinfo",
	"svc_nails",
	"svc_chokecount",
	"svc_modellist",
	"svc_soundlist",
	"svc_packetentities",
 	"svc_deltapacketentities",
	"svc_maxspeed",
	"svc_entgravity",

	"svc_setinfo",
	"svc_serverinfo",
	"svc_updatepl",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL",
	"NEW PROTOCOL"
};

char *clc_string[] = 
{
			"clc_bad",
			"clc_nop",
			"clc_disconnect",
			"clc_move",
			"clc_stringcmd",
			"clc_delta",
			"clc_tmove",
			"clc_upload"
};

#ifndef svc_spawnbinary
#define svc_spawnbinary 21
#endif

// Quake1, obsolete for QW
#define svc_time                        7       // [float] server time
#define svc_updatename          13      // [byte] [string]
#define svc_version                     4       // [long] server version
#define svc_clientdata          15      // <shortbits + data>
#define svc_updatecolors        17      // [byte] [byte]
#define svc_particle            18      // [vec3] <variable>
#define svc_signonnum           25      // [byte]  used for the signon sequence

QFile *Net_PacketLog;

/*
=================
NET_LogPrintf

Prints packet to logfile, adds time stamp etc.
=================
*/

void Net_LogPrintf (char *fmt, ...)
{
	va_list	argptr;
	char	text[2048];

	va_start(argptr, fmt);
	vsnprintf(text, sizeof(text), fmt, argptr);
	va_end(argptr);
        if (!Net_PacketLog) return;

        Qprintf(Net_PacketLog,"%s",text);
	Qflush(Net_PacketLog);
}

int Net_LogStart(char *fname)
{
        Con_Printf("Opening packet logfile: %s\n",fname);
	Net_PacketLog=Qopen(fname,"wt+");
	if(!Net_PacketLog) return -1;
	return 0;
}

void Net_LogStop(void)
{
	if (Net_PacketLog) Qclose(Net_PacketLog);
	Net_PacketLog=NULL;
}

void hex_dump_buf(unsigned char *buf, int len)
{
int pos = 0, llen, i;

	while(pos < len)
		{
		llen = (len - pos < 16 ? len - pos : 16);
		Net_LogPrintf("%08x: ", pos);
		for(i = 0; i < llen; i++) Net_LogPrintf("%02x ", buf[pos + i]);
		for(i = 0; i < 16 - llen; i++) Net_LogPrintf("   ");
		Net_LogPrintf(" | ");

		for(i = 0; i < llen; i++)
			Net_LogPrintf("%c", isprint(buf[pos + i]) ? buf[pos + i] : '.');
		for(i = 0; i < 16 - llen; i++) Net_LogPrintf(" ");
		Net_LogPrintf("\n");
		pos += llen;
		}
}

void ascii_dump_buf(unsigned char *buf, int len)
{
int pos = 0, llen, i;

	while(pos < len)
		{
		llen = (len - pos < 60 ? len - pos : 60);
		Net_LogPrintf("%08x: ", pos);
		for(i = 0; i < llen; i++)
			Net_LogPrintf("%c", isprint(buf[pos + i]) ? buf[pos + i] : '.');
		Net_LogPrintf("\n");
		pos += llen;
		}
}

void Log_Incoming_Packet(char *p, int len)
{
        if (!netloglevel->int_val) return;

        if (is_server) {
                Net_LogPrintf("\n<<<<<<<<<<<<<<<<<<<<< client to server %d bytes: <<<<<<<<<<<<<<<<<<<<<<<<\n", len);
                if (netloglevel->int_val!=3) hex_dump_buf((unsigned char *)p,len);
                if (netloglevel->int_val>1) Analyze_Client_Packet(p,len);
        }
        else {
                Net_LogPrintf("\n>>>>>>>>>>>>>>>>>>>>> server to client %d bytes: >>>>>>>>>>>>>>>>>>>>>>>>\n", len);
                if (netloglevel->int_val!=3) hex_dump_buf((unsigned char *)p,len);;
                if (netloglevel->int_val>1) Analyze_Server_Packet(p,len);
        }
        return;
}

void Log_Outgoing_Packet(char *p, int len)
{
        if (!netloglevel->int_val) return;

        if (is_server) {
                Net_LogPrintf("\n>>>>>>>>>>>>>>>>>>>>> server to client %d bytes: >>>>>>>>>>>>>>>>>>>>>>>>\n", len);
                if (netloglevel->int_val!=3) hex_dump_buf((unsigned char *)p,len);;
                if (netloglevel->int_val>1) Analyze_Server_Packet(p,len);
        }
        else {
                Net_LogPrintf("\n<<<<<<<<<<<<<<<<<<<<< client to server %d bytes: <<<<<<<<<<<<<<<<<<<<<<<<\n", len);
                if (netloglevel->int_val!=3) hex_dump_buf((unsigned char *)p,len);;
                if (netloglevel->int_val>1) Analyze_Client_Packet(p,len);
        }
        return;
}


void Analyze_Server_Packet(byte *data,int len)
{
        // Fixme: quick-hack
	net_message.data=data;
	net_message.cursize=len;
	MSG_BeginReading();
	Parse_Server_Packet();
	net_message.data=net_message_buffer;
}


void Parse_Server_Packet() 
{
	long seq1,seq2;
	int c,i,ii,iii,mask1,mask2;
        char *s;

	seq1 = MSG_ReadLong();
	if (msg_badread) return;

	if(seq1==-1) 
	{
		Net_LogPrintf("Special Packet");

	} else 
	{
		seq2=MSG_ReadLong();
		//fixme display seqs right when reliable
		Net_LogPrintf("\nSeq: %ld Ack: %ld ",seq1 & 0x7FFFFFFF,seq2 & 0x7FFFFFFF);
		
		if ((seq1 >>31) &0x01) Net_LogPrintf("SV_REL ");
		if ((seq2 >>31) &0x01) Net_LogPrintf("SV_RELACK");
                Net_LogPrintf("\n");
		
		while(1)
		{
			if (msg_badread) break;
			c = MSG_ReadByte();
			if (c == -1) break;
//                      Net_LogPrintf("\n<%ld,%ld> ",seq1 & 0x7FFFFFFF,seq2 & 0x7FFFFFFF);
                        Net_LogPrintf("<%06x> [0x%02x] ",MSG_GetReadCount(),c);

			if (c<53) Net_LogPrintf("%s: ",svc_string[c]);
//                        else Net_LogPrintf("(UNK: %d): ",c);
			
			if (MSG_GetReadCount()>net_message.cursize) return;
			
			switch (c)
			{
			case svc_bad:
				Net_LogPrintf(" - should not happen");
			case svc_nop:
				Net_LogPrintf(" No operation");
				break;
			case svc_disconnect:
				Net_LogPrintf(" <Quit>");
				break;
			case svc_updatestat:
                                i=MSG_ReadByte();
                                Net_LogPrintf(" index: %d value: %d",i,MSG_ReadByte ());
				break;
			case svc_version:
#ifdef QUAKEWORLD
                                Net_LogPrintf("**QW OBSOLETE**");
#endif			
				break;
			case svc_setview:
#ifdef QUAKEWORLD
                                Net_LogPrintf("**QW OBSOLETE**");
#else
				MSG_ReadShort();
#endif			
				break;	
			case svc_sound:
                                i = MSG_ReadShort ();
                                Net_LogPrintf(": (%d) ",i);
                                if (i & SND_VOLUME) Net_LogPrintf("Volume %d ", MSG_ReadByte());
                                if (i & SND_ATTENUATION) Net_LogPrintf("Ann: %f", (float)MSG_ReadByte () / 64.0);
                                ii = MSG_ReadByte ();

                                // fixme: well, cl. for client :-)
                                Net_LogPrintf("%d (%s) ",ii,sv.sound_precache[ii]);

                                Net_LogPrintf("Pos: ");
                                for (ii = 0; ii < 3; ii++)
                                        Net_LogPrintf("%f ",MSG_ReadCoord());
                                Net_LogPrintf("Ent: %d ",(i >> 3) & 1023);
                                Net_LogPrintf("Channel %d ",i & 7);                                
				break;
			case svc_time:
#ifdef QUAKEWORLD
                                Net_LogPrintf("**QW OBSOLETE**\n");
#else
				MSG_ReadFloat();
#endif			
				break;					
			case svc_print:
                                // fixme i==PRINT_CHAT
                                Net_LogPrintf(" %d",MSG_ReadByte());
                                Net_LogPrintf(" %s",MSG_ReadString());
				break;
			case svc_stufftext:
				Net_LogPrintf("%s",MSG_ReadString());
				break;
			case svc_setangle:
				for (i=0;i<3;i++) Net_LogPrintf("%f ",MSG_ReadAngle());
				break;
#ifdef QUAKEWORLD
			case svc_serverdata:
				Net_LogPrintf("Ver: %ld",MSG_ReadLong());
				Net_LogPrintf(" Client ID: %ld",MSG_ReadLong());
				Net_LogPrintf(" Dir: %s",MSG_ReadString());
				Net_LogPrintf(" User ID: %d",MSG_ReadByte());
				Net_LogPrintf(" Map: %s",MSG_ReadString());
				for(i=0;i<10;i++) MSG_ReadFloat();
				break;
#endif
				
			case svc_lightstyle:
                                i=MSG_ReadByte();
                                if (i >= MAX_LIGHTSTYLES) return;
                                Net_LogPrintf("%d %s",i,MSG_ReadString());
				break;
			case svc_updatename:
#ifdef QUAKEWORLD
                                Net_LogPrintf("**QW OBSOLETE**");
#else
				Net_LogPrintf("%d %s",MSG_ReadByte(),MSG_ReadString());
#endif			
				break;
			case svc_updatefrags:
				Net_LogPrintf("player: %d frags: %d",MSG_ReadByte(),MSG_ReadShort());
				break;			
			case svc_clientdata:
#ifdef QUAKEWORLD
                                Net_LogPrintf("**QW OBSOLETE**");
#endif			
				break;
			case svc_stopsound:
				Net_LogPrintf("%d",MSG_ReadShort());
				break;

			case svc_updatecolors:
#ifdef QUAKEWORLD
                                Net_LogPrintf("**QW OBSOLETE**"); 
#else
				Net_LogPrintf("%d %d",MSG_ReadByte(),MSG_ReadByte());				
#endif			
				break;
			case svc_particle:
#ifdef QUAKEWORLD
                                Net_LogPrintf("**QW OBSOLETE**");
#else
				for (i=0;i<3;i++) Net_LogPrintf(" %f",MSG_ReadCoord());
				for (i=0;i<3;i++) Net_LogPrintf(" %d",MSG_ReadChar());
				Net_LogPrintf(" Count: %d",MSG_ReadByte());
				Net_LogPrintf(" Color: %d",MSG_ReadByte());
#endif			
				break;

			case svc_damage:
				// fixme parse damage
				Net_LogPrintf("armor: %d health: %d",MSG_ReadByte(),MSG_ReadByte());
				Net_LogPrintf(" from %f,%f,%f",MSG_ReadCoord(),MSG_ReadCoord(),MSG_ReadCoord());
				break;
			case svc_spawnstatic:
				Net_LogPrintf("%d",MSG_ReadByte());
				Net_LogPrintf(" Frame: %d Color: %d Skin: %",MSG_ReadByte(),MSG_ReadByte(),MSG_ReadByte());
				for(i = 0; i < 3; i++) Net_LogPrintf("%d: %f %f", i+1, MSG_ReadCoord(), MSG_ReadAngle());
				break;			
			case svc_spawnbinary:
                                Net_LogPrintf("**OBSOLETE**");
				break;		
			case svc_spawnbaseline:
				Net_LogPrintf("%d",MSG_ReadShort());
				Net_LogPrintf(" idx: %d",MSG_ReadByte());
				Net_LogPrintf(" Frame: %d",MSG_ReadByte());
				Net_LogPrintf(" Colormap: %d",MSG_ReadByte());
				Net_LogPrintf(" Skin: %d",MSG_ReadByte());
				for (i=0;i<3;i++) {
					Net_LogPrintf(" %f",MSG_ReadCoord());
					Net_LogPrintf(" %d",MSG_ReadAngle());
				};
				break;
			case svc_temp_entity:
				i=MSG_ReadByte();
				switch(i)
				{
					case 0:
					case 1:
					case 3:
					case 4:
					case 7:
					case 8:
					case 10:
					case 11:
					case 13:
						Net_LogPrintf(" origin %f %f %f",MSG_ReadCoord(),MSG_ReadCoord(),MSG_ReadCoord());
						break;
					case 5:
					case 6:
					case 9:
						Net_LogPrintf(" created by %d",MSG_ReadShort());
						Net_LogPrintf(" origin: %f,%f,%f",MSG_ReadCoord(),MSG_ReadCoord(),MSG_ReadCoord());
						Net_LogPrintf(" trace endpos: %f,%f,%f", MSG_ReadCoord(), MSG_ReadCoord(), MSG_ReadCoord());
						break;
					case 2:
					case 12:
                                                Net_LogPrintf(" count: %d",MSG_ReadByte());
						printf(" origin: %f,%f,%f",MSG_ReadCoord(),MSG_ReadCoord(),MSG_ReadCoord());	
						break;
					default:
                                                Net_LogPrintf(" unknown value %d for tempentity",i); 
						break;
				}
				break;

			case svc_setpause:
                                Net_LogPrintf(" %d",MSG_ReadByte ());
				break;
			case svc_signonnum:
#ifdef QUAKEWORLD
                                Net_LogPrintf("**QW OBSOLETE**");
#else
				Net_LogPrintf("%d",MSG_ReadByte());
#endif		
				break;			
			case svc_centerprint:
				Net_LogPrintf(MSG_ReadString());
				break;
			case svc_killedmonster:
				break;
			case svc_foundsecret:
				break;
			case svc_spawnstaticsound:
				Net_LogPrintf("pos %f,%f,%f",MSG_ReadCoord(),MSG_ReadCoord(),MSG_ReadCoord());
				Net_LogPrintf("%d %d %d",MSG_ReadByte(),MSG_ReadByte(),MSG_ReadByte());
				break;
			case svc_intermission:
                                for (i=0 ; i<3 ; i++) Net_LogPrintf("%f ",MSG_ReadCoord());
                                Net_LogPrintf("\n");
                                for (i=0 ; i<3 ; i++) Net_LogPrintf("%f ",MSG_ReadAngle ());
				break; 
			case svc_finale:
				Net_LogPrintf("%s",MSG_ReadString());			
				break;
			case svc_cdtrack:
				Net_LogPrintf("%d",MSG_ReadByte());
				break;
			case svc_sellscreen:
				break;
			case svc_smallkick:
				break;
			case svc_bigkick:
				break;
			case svc_updateping:
                                Net_LogPrintf("Player: %d ",MSG_ReadByte());
                                Net_LogPrintf("Ping: %d",MSG_ReadShort());
				break;
			case svc_updateentertime:
                                Net_LogPrintf("Player: %d ",MSG_ReadByte());
                                Net_LogPrintf("Time: %f",MSG_ReadFloat());
				break;
				
			case svc_updatestatlong:
                                i=MSG_ReadByte();
                                Net_LogPrintf("%d value: %ld",i,MSG_ReadLong());
				break;
				
			case svc_muzzleflash:
				Net_LogPrintf("%d",MSG_ReadShort());
				break;

			case svc_updateuserinfo:
                                Net_LogPrintf("Player: %d ",MSG_ReadByte());
				Net_LogPrintf("ID: %ld ",MSG_ReadLong());
                                Net_LogPrintf("Info: %s",MSG_ReadString());
				break;
			case svc_download:
				ii=MSG_ReadShort();
				Net_LogPrintf("%d bytes at %d",ii,MSG_ReadByte());
				for (i=0;i<ii;i++) MSG_ReadByte();
				break;
			case svc_playerinfo:
                                Net_LogPrintf("\n\tPlayer: %d",MSG_ReadByte());
				mask1=MSG_ReadShort();
				Net_LogPrintf(" Mask1: %d",mask1);
				Net_LogPrintf(" Origin: %f,%f,%f",MSG_ReadCoord(),MSG_ReadCoord(),MSG_ReadCoord());
				Net_LogPrintf(" Frame: %d",MSG_ReadByte());
				
				if(mask1 & PF_MSEC) Net_LogPrintf(" Ping: %d",MSG_ReadByte());
	
				if(mask1 & PF_COMMAND)
				{
					mask2 = MSG_ReadByte(); // command
					if(mask2 & 0x01) Net_LogPrintf(" Pitch: %f", MSG_ReadAngle16());
					if(mask2 & 0x80) Net_LogPrintf(" Yaw: %f", MSG_ReadAngle16());
					if(mask2 & 0x02) Net_LogPrintf(" Roll: %f", MSG_ReadAngle16());
					if(mask2 & 0x04) Net_LogPrintf(" Speed1: %d", MSG_ReadShort());
					if(mask2 & 0x08) Net_LogPrintf(" Speed2: %d", MSG_ReadShort());
					if(mask2 & 0x10) Net_LogPrintf(" Speed3: %d", MSG_ReadShort());
					if(mask2 & 0x20) Net_LogPrintf(" Flag: %d", MSG_ReadByte());
					if(mask2 & 0x40) Net_LogPrintf(" Impulse: %d", MSG_ReadByte());
                                        Net_LogPrintf(" Msec: %d", MSG_ReadByte());
				}
				if(mask1 & PF_VELOCITY1) Net_LogPrintf(" Xspd: %f", MSG_ReadCoord());
				if(mask1 & PF_VELOCITY2) Net_LogPrintf(" Yspd: %f", MSG_ReadCoord());
				if(mask1 & PF_VELOCITY3) Net_LogPrintf(" ZSpd: %f", MSG_ReadCoord());
				if(mask1 & PF_MODEL) Net_LogPrintf(" Model: %d", MSG_ReadByte());
				if(mask1 & PF_SKINNUM) Net_LogPrintf(" Skin: %d", MSG_ReadByte());
				if(mask1 & PF_EFFECTS) Net_LogPrintf(" Effects: %d", MSG_ReadByte());

                                if(mask1 & PF_WEAPONFRAME) Net_LogPrintf(" Weapon frame: %d", MSG_ReadByte());
				break;
			case svc_nails:
				ii=MSG_ReadByte();
                                Net_LogPrintf(" %d (bits not parsed)",ii);
                                for(i=0;i<ii;i++) {
                                        for (iii=0;iii<6;iii++) MSG_ReadByte();
                                }
				break;	
                        case svc_chokecount: 
				Net_LogPrintf("%d",MSG_ReadByte());
				break;
			case svc_modellist:
				ii=MSG_ReadByte();
                                Net_LogPrintf("start %d",ii);
				for(i=ii;i<256;i++) {
                                        s=MSG_ReadString();
                                        if (msg_badread) break;
                                        if (!s) break;
                                        if (strlen(s)==0) break;
                                        Net_LogPrintf("\n\tModel %d: %s",i,s);
				}
                                i=MSG_ReadByte();
                                if (i) Net_LogPrintf("\n\tnext at %d",i);
                                else Net_LogPrintf("\n\t*End of modellist*");
				break;
			case svc_soundlist:
				ii=MSG_ReadByte();
				Net_LogPrintf("start %d",ii);
				for(i=ii;i<256;i++) {
                                        s=MSG_ReadString();
                                        if (msg_badread) break;
                                        if (!s) break;
                                        if (strlen(s)==0) break;
                                        Net_LogPrintf("\n\tSound %d: %s",i,s);
				}
                                i=MSG_ReadByte();

                                if (i) Net_LogPrintf("\n\tnext at %d",i);
                                else Net_LogPrintf("\n\t*End of sound list*");
				break;
			case svc_packetentities:
                                Net_LogPrintf("Not parsed (parser broken ;-)");
                                return;
				while ((mask1=MSG_ReadShort()))
				{
                                        if (msg_badread) break;
                                        Net_LogPrintf("\n\t");
					if(mask1 & 0x8000) mask1|=MSG_ReadByte();

					if(mask1 & U_MODEL) Net_LogPrintf(" Mdl: %d",MSG_ReadByte());
					if(mask1 & U_FRAME) Net_LogPrintf(" Frame: %d",MSG_ReadByte());
					if(mask1 & U_COLORMAP) Net_LogPrintf(" Colormap:%d",MSG_ReadByte());	
					if(mask1 & U_SKIN) Net_LogPrintf(" Skin: %d",MSG_ReadByte());
					if(mask1 & U_EFFECTS) Net_LogPrintf(" Effects: %d",MSG_ReadByte()); 
					if(mask1 & U_ORIGIN1) Net_LogPrintf(" X: %f",MSG_ReadCoord());	
					if(mask1 & U_ANGLE1) Net_LogPrintf(" Pitch: %d",MSG_ReadAngle());
					if(mask1 & U_ORIGIN2) Net_LogPrintf(" Y: %f",MSG_ReadCoord());	
					if(mask1 & U_ANGLE2) Net_LogPrintf(" Yaw: %d",MSG_ReadAngle());	
					if(mask1 & U_ORIGIN3) Net_LogPrintf(" Z: %f",MSG_ReadCoord());
					if(mask1 & U_ANGLE3) Net_LogPrintf(" Roll: %d",MSG_ReadAngle());
//					if(mask1 & U_SOLID) return;
				}
				break;
			case svc_deltapacketentities:
                                Net_LogPrintf("idx: %d",MSG_ReadByte());
                                return;
//                                break;
			case svc_maxspeed :
				Net_LogPrintf("%f",MSG_ReadFloat());
				break;
			case svc_entgravity :
				Net_LogPrintf("%f",MSG_ReadFloat());
				break;
			case svc_setinfo:
				Net_LogPrintf("Player: %d ",MSG_ReadByte());
				Net_LogPrintf("Keyname: %s ",MSG_ReadString());
                                Net_LogPrintf("Value: %s",MSG_ReadString());
				break;
			case svc_serverinfo:
				Net_LogPrintf("Name: %s Value: %s",MSG_ReadString(),MSG_ReadString());
				break;
			case svc_updatepl:
				Net_LogPrintf("Player: %d Ploss: %d",MSG_ReadByte(),MSG_ReadByte());
				break;
			default:
				Net_LogPrintf ("**UNKNOWN**: [%d]",c);
				break;
			}
			Net_LogPrintf("\n");
		}
	}
}

void Analyze_Client_Packet(byte *data,int len)
{
	// fixme quick-hack
	net_message.data=data;
	net_message.cursize=len;
	MSG_BeginReading();
	Parse_Client_Packet();
	net_message.data=net_message_buffer;
}

void Parse_Client_Packet(void)
{
	int i,c,ii;
	long seq1,seq2;
	int mask;
	
	seq1 = MSG_ReadLong();
	if(seq1==-1) 
	{
		Net_LogPrintf("Special: %s\n",MSG_ReadString());	
		return;
	} else 
	{
		//fixme display seqs right when reliable
		seq2 = MSG_ReadLong();

		Net_LogPrintf("\nSeq: %ld Ack: %ld ",seq1 & 0x7FFFFFFF,seq2 & 0x7FFFFFFF);
/*
		if ((seq1 >>31) &0x01) Net_LogPrintf("CL_REL ");
		if ((seq2 >>31) &0x01) Net_LogPrintf("CL_RELACK ");
*/
		
		Net_LogPrintf("QP: %u\n",MSG_ReadShort());

		while (1)
		{
			if (msg_badread) break;
			c = MSG_ReadByte();
			if (c == -1) break;
//			Net_LogPrintf("<%ld,%ld> ",seq1 & 0x7FFFFFFF,seq2 & 0x7FFFFFFF);
                        Net_LogPrintf("\n<%06x> [0x%02x] ",MSG_GetReadCount(),c);
			if (c<8) Net_LogPrintf("%s: ",clc_string[c]);
			
			switch(c)
			{
			case clc_nop:
				break;
			case clc_delta:
				Net_LogPrintf ("%d",MSG_ReadByte());
				break;
			case clc_move:
				Net_LogPrintf("checksum = %02x ",MSG_ReadByte());
                                Net_LogPrintf("PacketLoss: %d",MSG_ReadByte());
				
				for (i=0;i<3;i++) {
					mask=MSG_ReadByte();
                                        Net_LogPrintf("\n\t(%d) mask = %02x",i,mask);
					if(mask & 0x01) Net_LogPrintf(" Tilt: %f",MSG_ReadAngle16());
					if(mask & 0x80) Net_LogPrintf(" Yaw: %f",MSG_ReadAngle16());
					if(mask & 0x02) Net_LogPrintf(" Roll: %f",MSG_ReadAngle16());
					if(mask & 0x04) Net_LogPrintf(" Fwd: %d",MSG_ReadShort());
					if(mask & 0x08) Net_LogPrintf(" Right: %d",MSG_ReadShort());
					if(mask & 0x10) Net_LogPrintf(" Up: %d",MSG_ReadShort());
					if(mask & 0x20) Net_LogPrintf(" Flags: %d",MSG_ReadByte());
					if(mask & 0x40) Net_LogPrintf(" Impulse: %d",MSG_ReadByte());
					Net_LogPrintf(" Msec: %d",MSG_ReadByte());
				}
				break;
			case clc_stringcmd:
				Net_LogPrintf("%s",MSG_ReadString());
				break;	
			case clc_tmove:
                                for (i=0;i<3;i++) Net_LogPrintf("%f ",MSG_ReadCoord());
				break;
			case clc_upload:
				ii=MSG_ReadShort();
				Net_LogPrintf("%d bytes at %d",ii,MSG_ReadByte());
				for (i=0;i<ii;i++) MSG_ReadByte();
				break;
			default:
				Net_LogPrintf ("**UNKNOWN**: [%d]",c);
				break;
			}
			Net_LogPrintf("\n");
		}
		
	}
}

int Net_Log_Init(void)
{
        netlogger=Cvar_Get("net_logger","1",CVAR_NONE,"Packet logging/parsing");

// 0 = no logging
// 1 = hex dump only
// 2 = parse/hexdump
// 3 = just parse
// 4 = parse/hexdump, skip movement/empty messages

        netloglevel=Cvar_Get("net_loglevel","2",CVAR_NONE,"Packet logging/parsing");

        Net_LogStart("QFPACKET.LOG");
        return 0;
}