/*
cl_parse.c
parse a message received from the server
Copyright (C) 1996-1997 Id Software, Inc.
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
*/
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif
#ifdef HAVE_STRING_H
# include <string.h>
#endif
#ifdef HAVE_STRINGS_H
# include <strings.h>
#endif
#ifdef HAVE_ERRNO_H
# include <errno.h>
#endif
#ifdef HAVE_UNISTD_H
# include <unistd.h>
#endif
#include "QF/cbuf.h"
#include "QF/cdaudio.h"
#include "QF/cmd.h"
#include "QF/console.h"
#include "QF/cvar.h"
#include "QF/draw.h"
#include "QF/dstring.h"
#include "QF/gib.h"
#include "QF/idparse.h"
#include "QF/msg.h"
#include "QF/progs.h"
#include "QF/plist.h"
#include "QF/quakeio.h"
#include "QF/screen.h"
#include "QF/skin.h"
#include "QF/sound.h"
#include "QF/sys.h"
#include "QF/teamplay.h"
#include "QF/va.h"
#include "compat.h"
#include "sbar.h"
#include "client/effects.h"
#include "client/temp_entities.h"
#include "client/view.h"
#include "qw/bothdefs.h"
#include "qw/pmove.h"
#include "qw/protocol.h"
#include "qw/include/cl_cam.h"
#include "qw/include/cl_chat.h"
#include "qw/include/cl_ents.h"
#include "qw/include/cl_http.h"
#include "qw/include/cl_input.h"
#include "qw/include/cl_main.h"
#include "qw/include/cl_parse.h"
#include "qw/include/cl_skin.h"
#include "qw/include/client.h"
#include "qw/include/host.h"
#include "qw/include/map_cfg.h"
const char *svc_strings[] = {
"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 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",
"OBSOLETE 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] text
"svc_cdtrack", // [byte] track
"svc_sellscreen",
"svc_smallkick",
"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",
"svc_nails2", // FIXME from qwex
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL"
};
dstring_t *centerprint;
int oldparsecountmod;
int parsecountmod;
double parsecounttime;
int cl_playerindex, cl_flagindex;
int cl_h_playerindex, cl_gib1index, cl_gib2index, cl_gib3index;
int packet_latency[NET_TIMINGS];
extern cvar_t *hud_scoreboard_uid;
entitystateset_t cl_static_entities = DARRAY_STATIC_INIT (32);
static void
CL_LoadSky (void)
{
plitem_t *item;
const char *name = 0;
if (!cl.worldspawn) {
r_funcs->R_LoadSkys (0);
return;
}
if ((item = PL_ObjectForKey (cl.worldspawn, "sky")) // Q2/DarkPlaces
|| (item = PL_ObjectForKey (cl.worldspawn, "skyname")) // old QF
|| (item = PL_ObjectForKey (cl.worldspawn, "qlsky"))) /* QuakeLives */ {
name = PL_String (item);
}
r_funcs->R_LoadSkys (name);
}
int
CL_CalcNet (void)
{
int lost, a, i;
frame_t *frame;
for (i = cls.netchan.outgoing_sequence - UPDATE_BACKUP + 1;
i <= cls.netchan.outgoing_sequence; i++) {
frame = &cl.frames[i & UPDATE_MASK];
if (frame->receivedtime == -1)
packet_latency[i & NET_TIMINGSMASK] = 9999; // dropped
else if (frame->receivedtime == -2)
packet_latency[i & NET_TIMINGSMASK] = 10000; // choked
else if (frame->invalid)
packet_latency[i & NET_TIMINGSMASK] = 9998; // invalid delta
else
packet_latency[i & NET_TIMINGSMASK] =
(frame->receivedtime - frame->senttime) * 20;
}
lost = 0;
for (a = 0; a < NET_TIMINGS; a++) {
i = (cls.netchan.outgoing_sequence - a) & NET_TIMINGSMASK;
if (packet_latency[i] == 9999)
lost++;
}
return lost * 100 / NET_TIMINGS;
}
/*
CL_CheckOrDownloadFile
Returns true if the file exists, otherwise it attempts
to start a download from the server.
*/
qboolean
CL_CheckOrDownloadFile (const char *filename)
{
QFile *f;
if (strstr (filename, "..")) {
Sys_Printf ("Refusing to download a path with ..\n");
return true;
}
/*
if (!snd_initialized && strnequal ("sound/", filename, 6)) {
// don't bother downloading sounds if we can't play them
return true;
}
*/
f = QFS_FOpenFile (filename);
if (f) { // it exists, no need to download
Qclose (f);
return true;
}
// ZOID - can't download when recording
if (cls.demorecording) {
Sys_Printf ("Unable to download %s in record mode.\n",
cls.downloadname->str);
return true;
}
// ZOID - can't download when playback
if (cls.demoplayback)
return true;
dstring_copystr (cls.downloadname, filename);
dstring_copystr (cls.downloadtempname, filename);
Sys_Printf ("Downloading %s...\n", cls.downloadname->str);
// download to a temp name, and rename to the real name only when done,
// so if interrupted a runt file wont be left
QFS_StripExtension (cls.downloadname->str, cls.downloadtempname->str);
dstring_appendstr (cls.downloadtempname, ".tmp");
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
MSG_WriteString (&cls.netchan.message,
va (0, "download \"%s\"", cls.downloadname->str));
cls.downloadnumber++;
return false;
}
static plitem_t *
map_ent (const char *mapname)
{
static progs_t edpr;
char *name = malloc (strlen (mapname) + 4 + 1);
char *buf;
plitem_t *edicts = 0;
QFile *ent_file;
QFS_StripExtension (mapname, name);
strcat (name, ".ent");
ent_file = QFS_VOpenFile (name, 0, cl.model_precache[1]->vpath);
if ((buf = (char *) QFS_LoadFile (ent_file, 0))) {
edicts = ED_Parse (&edpr, buf);
free (buf);
} else {
edicts = ED_Parse (&edpr, cl.model_precache[1]->brush.entities);
}
free (name);
return edicts;
}
static void
CL_NewMap (const char *mapname)
{
cl_static_entities.size = 0;
r_funcs->R_NewMap (cl.worldmodel, cl.model_precache, cl.nummodels);
Team_NewMap ();
Con_NewMap ();
Hunk_Check (); // make sure nothing is hurt
Sbar_CenterPrint (0);
if (cl.model_precache[1] && cl.model_precache[1]->brush.entities) {
cl.edicts = map_ent (mapname);
if (cl.edicts) {
cl.worldspawn = PL_ObjectAtIndex (cl.edicts, 0);
CL_LoadSky ();
if (r_funcs->Fog_ParseWorldspawn)
r_funcs->Fog_ParseWorldspawn (cl.worldspawn);
}
}
map_cfg (mapname, 1);
}
static void
Model_NextDownload (void)
{
char *s;
int i;
if (cls.downloadnumber == 0) {
Sys_Printf ("Checking models...\n");
CL_UpdateScreen (realtime);
cls.downloadnumber = 1;
}
cls.downloadtype = dl_model;
for (; cl.model_name[cls.downloadnumber][0]; cls.downloadnumber++) {
s = cl.model_name[cls.downloadnumber];
if (s[0] == '*')
continue; // inline brush model
if (!CL_CheckOrDownloadFile (s))
return; // started a download
}
if (cl.model_name[1])
map_cfg (cl.model_name[1], 0);
for (i = 1; i < cl.nummodels; i++) {
char *info_key = 0;
if (!cl.model_name[i][0])
break;
cl.model_precache[i] = Mod_ForName (cl.model_name[i], false);
if (!cl.model_precache[i]) {
Sys_Printf ("\nThe required model file '%s' could not be found or "
"downloaded.\n\n", cl.model_name[i]);
Sys_Printf ("You may need to download or purchase a %s client "
"pack in order to play on this server.\n\n",
qfs_gamedir->gamedir);
CL_Disconnect ();
return;
}
if (strequal (cl.model_name[i], "progs/player.mdl")
&& cl.model_precache[i]->type == mod_alias) {
info_key = pmodel_name;
//XXX mod_funcs->Skin_Player_Model (cl.model_precache[i]);
}
if (strequal (cl.model_name[i], "progs/eyes.mdl")
&& cl.model_precache[i]->type == mod_alias)
info_key = emodel_name;
if (info_key && cl_model_crcs->int_val) {
aliashdr_t *ahdr = cl.model_precache[i]->aliashdr;
if (!ahdr)
ahdr = Cache_Get (&cl.model_precache[i]->cache);
Info_SetValueForKey (cls.userinfo, info_key, va (0, "%d",
ahdr->crc),
0);
if (!cls.demoplayback) {
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
SZ_Print (&cls.netchan.message, va (0, "setinfo %s %d",
info_key, ahdr->crc));
}
if (!cl.model_precache[i]->aliashdr)
Cache_Release (&cl.model_precache[i]->cache);
}
}
// Something went wrong (probably in the server, probably a TF server)
// We need to disconnect gracefully.
if (!cl.model_precache[1]) {
Sys_Printf ("\nThe server has failed to provide the map name.\n\n");
Sys_Printf ("Disconnecting to prevent a crash.\n\n");
CL_Disconnect ();
return;
}
// all done
cl.worldmodel = cl.model_precache[1];
CL_NewMap (cl.model_name[1]);
// done with modellist, request first of static signon messages
if (!cls.demoplayback) {
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
MSG_WriteString (&cls.netchan.message,
va (0, prespawn_name, cl.servercount,
cl.worldmodel->brush.checksum2));
}
}
static void
Sound_NextDownload (void)
{
char *s;
int i;
if (cls.downloadnumber == 0) {
Sys_Printf ("Checking sounds...\n");
CL_UpdateScreen (realtime);
cls.downloadnumber = 1;
}
cls.downloadtype = dl_sound;
for (; cl.sound_name[cls.downloadnumber][0];
cls.downloadnumber++) {
s = cl.sound_name[cls.downloadnumber];
if (!CL_CheckOrDownloadFile (va (0, "sound/%s", s)))
return; // started a download
}
for (i = 1; i < cl.numsounds; i++) {
if (!cl.sound_name[i][0])
break;
cl.sound_precache[i] = S_PrecacheSound (cl.sound_name[i]);
}
// done with sounds, request models now
memset (cl.model_precache, 0, sizeof (cl.model_precache));
cl_playerindex = -1;
cl_flagindex = -1;
cl_h_playerindex = -1;
cl_gib1index = cl_gib2index = cl_gib3index = -1;
if (!cls.demoplayback) {
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
MSG_WriteString (&cls.netchan.message,
va (0, modellist_name, cl.servercount, 0));
}
}
static void
CL_RequestNextDownload (void)
{
switch (cls.downloadtype) {
case dl_single:
break;
case dl_skin:
Skin_NextDownload ();
break;
case dl_model:
Model_NextDownload ();
break;
case dl_sound:
Sound_NextDownload ();
break;
case dl_none:
default:
Sys_MaskPrintf (SYS_DEV, "Unknown download type.\n");
}
}
void
CL_FinishDownload (void)
{
Qclose (cls.download);
VID_SetCaption (va (0, "Connecting to %s", cls.servername->str));
// rename the temp file to it's final name
if (strcmp (cls.downloadtempname->str, cls.downloadname->str)) {
dstring_t *oldn = dstring_new ();
dstring_t *newn = dstring_new ();
if (strncmp (cls.downloadtempname->str, "skins/", 6)) {
dsprintf (oldn, "%s/%s", qfs_gamedir->dir.def,
cls.downloadtempname->str);
dsprintf (newn, "%s/%s", qfs_gamedir->dir.def,
cls.downloadname->str);
} else {
dsprintf (oldn, "%s/%s", qfs_gamedir->dir.skins,
cls.downloadtempname->str + 6);
dsprintf (newn, "%s/%s", qfs_gamedir->dir.skins,
cls.downloadname->str + 6);
}
if (QFS_Rename (oldn->str, newn->str))
Sys_Printf ("failed to rename %s to %s, %s.\n", oldn->str,
newn->str, strerror (errno));
dstring_delete (oldn);
dstring_delete (newn);
}
cls.download = NULL;
dstring_clearstr (cls.downloadname);
dstring_clearstr (cls.downloadtempname);
dstring_clearstr (cls.downloadurl);
cls.downloadpercent = 0;
// get another file if needed
CL_RequestNextDownload ();
}
void
CL_FailDownload (void)
{
if (cls.download) {
Qclose (cls.download);
cls.download = NULL;
}
dstring_clearstr (cls.downloadname);
dstring_clearstr (cls.downloadtempname);
dstring_clearstr (cls.downloadurl);
CL_RequestNextDownload ();
}
static int
CL_OpenDownload (void)
{
dstring_t *name = dstring_newstr ();
const char *fname, *path;
if (strncmp (cls.downloadtempname->str, "skins/", 6) == 0) {
path = qfs_gamedir->dir.skins;
fname = cls.downloadtempname->str + 6;
} else if (strncmp (cls.downloadtempname->str, "progs/", 6) == 0) {
path = qfs_gamedir->dir.models;
fname = cls.downloadtempname->str + 6;
} else if (strncmp (cls.downloadtempname->str, "sound/", 6) == 0) {
path = qfs_gamedir->dir.sound;
fname = cls.downloadtempname->str + 6;
} else if (strncmp (cls.downloadtempname->str, "maps/", 5) == 0) {
path = qfs_gamedir->dir.maps;
fname = cls.downloadtempname->str + 5;
} else {
path = qfs_gamedir->dir.def;
fname = cls.downloadtempname->str;
}
dsprintf (name, "%s/%s", path, fname);
cls.download = QFS_WOpen (name->str, 0);
if (!cls.download) {
dstring_clearstr (cls.downloadname);
dstring_clearstr (cls.downloadurl);
Sys_Printf ("Failed to open %s\n", name->str);
CL_RequestNextDownload ();
return 0;
}
dstring_delete (name);
return 1;
}
/*
CL_ParseDownload
A download message has been received from the server
*/
static void
CL_ParseDownload (void)
{
int size, percent;
// read the data
size = (short) MSG_ReadShort (net_message);
percent = MSG_ReadByte (net_message);
if (cls.demoplayback) {
if (size > 0)
net_message->readcount += size;
dstring_clearstr (cls.downloadname);
dstring_clearstr (cls.downloadtempname);
dstring_clearstr (cls.downloadurl);
return; // not in demo playback
}
if (size == DL_NOFILE) {
Sys_Printf ("File not found.\n");
if (cls.download) {
Sys_Printf ("cls.download shouldn't have been set\n");
Qclose (cls.download);
cls.download = NULL;
}
dstring_clearstr (cls.downloadname);
dstring_clearstr (cls.downloadtempname);
dstring_clearstr (cls.downloadurl);
CL_RequestNextDownload ();
return;
}
if (size == DL_RENAME) {
const char *newname = MSG_ReadString (net_message);
if (strncmp (newname, cls.downloadname->str,
strlen (cls.downloadname->str))
|| strstr (newname + strlen (cls.downloadname->str), "/")) {
Sys_Printf
("WARNING: server tried to give a strange new name: %s\n",
newname);
CL_RequestNextDownload ();
return;
}
if (cls.download) {
Qclose (cls.download);
unlink (cls.downloadname->str);
}
dstring_copystr (cls.downloadname, newname);
Sys_Printf ("downloading to %s\n", cls.downloadname->str);
return;
}
if (size == DL_HTTP) {
#ifdef HAVE_LIBCURL
const char *url = MSG_ReadString (net_message);
const char *newname = MSG_ReadString (net_message);
if (*newname) {
if (strncmp (newname, cls.downloadname->str,
strlen (cls.downloadname->str))
|| strstr (newname + strlen (cls.downloadname->str), "/")) {
Sys_Printf
("WARNING: server tried to give a strange new name: %s\n",
newname);
CL_RequestNextDownload ();
return;
}
if (cls.download) {
Qclose (cls.download);
unlink (cls.downloadname->str);
}
dstring_copystr (cls.downloadname, newname);
}
dstring_copystr (cls.downloadurl, url);
Sys_Printf ("downloading %s to %s\n", cls.downloadurl->str,
cls.downloadname->str);
CL_HTTP_StartDownload ();
#else
MSG_ReadString (net_message);
MSG_ReadString (net_message);
Sys_Printf ("server sent http redirect but we don't know how to handle"
"it :(\n");
#endif
CL_OpenDownload ();
return;
}
// open the file if not opened yet
if (!cls.download) {
if (!CL_OpenDownload ()) {
return;
net_message->readcount += size;
}
}
Qwrite (cls.download, net_message->message->data + net_message->readcount,
size);
net_message->readcount += size;
if (percent != 100) {
// request next block
if (percent != cls.downloadpercent)
VID_SetCaption (va (0, "Downloading %s %d%%",
cls.downloadname->str, percent));
cls.downloadpercent = percent;
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
SZ_Print (&cls.netchan.message, "nextdl");
} else {
CL_FinishDownload ();
}
}
static byte *upload_data;
static int upload_pos, upload_size;
void
CL_NextUpload (void)
{
byte buffer[1024];
int percent, size, r;
if (!upload_data)
return;
r = upload_size - upload_pos;
if (r > 768)
r = 768;
memcpy (buffer, upload_data + upload_pos, r);
MSG_WriteByte (&cls.netchan.message, clc_upload);
MSG_WriteShort (&cls.netchan.message, r);
upload_pos += r;
size = upload_size;
if (!size)
size = 1;
percent = upload_pos * 100 / size;
MSG_WriteByte (&cls.netchan.message, percent);
SZ_Write (&cls.netchan.message, buffer, r);
Sys_MaskPrintf (SYS_DEV, "UPLOAD: %6d: %d written\n", upload_pos - r, r);
if (upload_pos != upload_size)
return;
Sys_Printf ("Upload completed\n");
free (upload_data);
upload_data = 0;
upload_pos = upload_size = 0;
}
void
CL_StartUpload (byte * data, int size)
{
if (cls.state < ca_onserver)
return; // must be connected
// override
if (upload_data)
free (upload_data);
Sys_MaskPrintf (SYS_DEV, "Upload starting of %d...\n", size);
upload_data = malloc (size);
memcpy (upload_data, data, size);
upload_size = size;
upload_pos = 0;
CL_NextUpload ();
}
qboolean
CL_IsUploading (void)
{
if (upload_data)
return true;
return false;
}
void
CL_StopUpload (void)
{
if (upload_data)
free (upload_data);
upload_data = NULL;
}
// SERVER CONNECTING MESSAGES =================================================
// LordHavoc: BIG BUG-FIX! Clear baselines each time it connects...
static void
CL_ClearBaselines (void)
{
int i;
i = qw_entstates.num_entities;
memset (qw_entstates.baseline, 0, i * sizeof (entity_state_t));
for (i = 0; i < MAX_EDICTS; i++) {
qw_entstates.baseline[i].colormod = 255;
qw_entstates.baseline[i].alpha = 255;
qw_entstates.baseline[i].scale = 16;
qw_entstates.baseline[i].glow_size = 0;
qw_entstates.baseline[i].glow_color = 254;
}
}
static void
CL_ParseServerData (void)
{
const char *str;
int protover;
//FIXME qboolean cflag = false;
Sys_MaskPrintf (SYS_DEV, "Serverdata packet received.\n");
// wipe the client_state_t struct
CL_ClearState ();
// parse protocol version number
// allow 2.2 and 2.29 demos to play
protover = MSG_ReadLong (net_message);
if (protover != PROTOCOL_VERSION
&& !(cls.demoplayback && (protover <= 26 || protover >= 28)))
Host_Error ("Server returned version %i, not %i\nYou probably "
"need to upgrade.\nCheck http://www.quakeworld.net/",
protover, PROTOCOL_VERSION);
cl.servercount = MSG_ReadLong (net_message);
// game directory
str = MSG_ReadString (net_message);
if (!strequal (qfs_gamedir->gamedir, str)) {
// save current config
Host_WriteConfiguration ();
//FIXME cflag = true;
QFS_Gamedir (str);
}
if (cls.demoplayback2) {
realtime = cls.basetime = MSG_ReadFloat (net_message);
cl.playernum = 31;
cl.spectator = true;
} else {
// parse player slot, high bit means spectator
cl.playernum = MSG_ReadByte (net_message);
if (cl.playernum & 128) {
cl.spectator = true;
cl.playernum &= ~128;
}
}
cl.viewentity = cl.playernum + 1;
// get the full level name
str = MSG_ReadString (net_message);
strncpy (cl.levelname, str, sizeof (cl.levelname) - 1);
// get the movevars
movevars.gravity = MSG_ReadFloat (net_message);
r_data->gravity = movevars.gravity; // Gravity for renderer effects
movevars.stopspeed = MSG_ReadFloat (net_message);
movevars.maxspeed = MSG_ReadFloat (net_message);
movevars.spectatormaxspeed = MSG_ReadFloat (net_message);
movevars.accelerate = MSG_ReadFloat (net_message);
movevars.airaccelerate = MSG_ReadFloat (net_message);
movevars.wateraccelerate = MSG_ReadFloat (net_message);
movevars.friction = MSG_ReadFloat (net_message);
movevars.waterfriction = MSG_ReadFloat (net_message);
movevars.entgravity = MSG_ReadFloat (net_message);
// separate the printfs so the server message can have a color
Sys_Printf ("\n\n\35\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36"
"\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\37\n\n");
Sys_Printf ("%c%s\n", 2, str);
// ask for the sound list next
memset (cl.sound_name, 0, sizeof (cl.sound_name));
if (!cls.demoplayback) {
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
MSG_WriteString (&cls.netchan.message,
va (0, soundlist_name, cl.servercount, 0));
}
// now waiting for downloads, etc
CL_SetState (ca_onserver);
CL_ClearBaselines ();
}
static void
CL_ParseSoundlist (void)
{
const char *str;
int n;
// precache sounds
// memset (cl.sound_precache, 0, sizeof (cl.sound_precache));
cl.numsounds = MSG_ReadByte (net_message);
for (;;) {
str = MSG_ReadString (net_message);
if (!str[0])
break;
cl.numsounds++;
if (cl.numsounds >= MAX_SOUNDS)
Host_Error ("Server sent too many sound_precache");
strcpy (cl.sound_name[cl.numsounds], str);
}
cl.numsounds++;
n = MSG_ReadByte (net_message);
if (n && !cls.demoplayback) {
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
MSG_WriteString (&cls.netchan.message,
va (0, soundlist_name, cl.servercount, n));
return;
}
cls.downloadnumber = 0;
cls.downloadtype = dl_sound;
Sound_NextDownload ();
}
static void
CL_ParseModellist (void)
{
int n;
const char *str;
// precache models and note certain default indexes
cl.nummodels = MSG_ReadByte (net_message);
for (;;) {
str = MSG_ReadString (net_message);
if (!str[0])
break;
cl.nummodels++;
if (cl.nummodels >= MAX_MODELS)
Host_Error ("Server sent too many model_precache");
strcpy (cl.model_name[cl.nummodels], str);
if (!strcmp (cl.model_name[cl.nummodels], "progs/player.mdl"))
cl_playerindex = cl.nummodels;
else if (!strcmp (cl.model_name[cl.nummodels], "progs/flag.mdl"))
cl_flagindex = cl.nummodels;
// for deadbodyfilter & gib filter
else if (!strcmp (cl.model_name[cl.nummodels], "progs/h_player.mdl"))
cl_h_playerindex = cl.nummodels;
else if (!strcmp (cl.model_name[cl.nummodels], "progs/gib1.mdl"))
cl_gib1index = cl.nummodels;
else if (!strcmp (cl.model_name[cl.nummodels], "progs/gib2.mdl"))
cl_gib2index = cl.nummodels;
else if (!strcmp (cl.model_name[cl.nummodels], "progs/gib3.mdl"))
cl_gib3index = cl.nummodels;
}
cl.nummodels++;
n = MSG_ReadByte (net_message);
if (n) {
if (!cls.demoplayback) {
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
MSG_WriteString (&cls.netchan.message,
va (0, modellist_name, cl.servercount, n));
}
return;
}
cls.downloadnumber = 0;
cls.downloadtype = dl_model;
Model_NextDownload ();
}
static void
CL_ParseBaseline (entity_state_t *es)
{
es->modelindex = MSG_ReadByte (net_message);
es->frame = MSG_ReadByte (net_message);
es->colormap = MSG_ReadByte (net_message);
es->skinnum = MSG_ReadByte (net_message);
MSG_ReadCoordAngleV (net_message, &es->origin[0], es->angles);//FIXME
es->origin[3] = 1;
// LordHavoc: set up baseline to for new effects (alpha, colormod, etc)
es->colormod = 255;
es->alpha = 255;
es->scale = 16;
es->glow_size = 0;
es->glow_color = 254;
}
/*
CL_ParseStatic
Static entities are non-interactive world objects
like torches
*/
static void
CL_ParseStatic (void)
{
entity_t *ent;
entity_state_t es;
CL_ParseBaseline (&es);
ent = r_funcs->R_AllocEntity ();
CL_Init_Entity (ent);
DARRAY_APPEND (&cl_static_entities, es);
// copy it to the current state
ent->renderer.model = cl.model_precache[es.modelindex];
ent->animation.frame = es.frame;
ent->renderer.skinnum = es.skinnum;
CL_TransformEntity (ent, es.scale / 16.0, es.angles, es.origin);
r_funcs->R_AddEfrags (&cl.worldmodel->brush, ent);
}
static void
CL_ParseStaticSound (void)
{
int sound_num, vol, atten;
vec3_t org;
MSG_ReadCoordV (net_message, org);
sound_num = MSG_ReadByte (net_message);
vol = MSG_ReadByte (net_message);
atten = MSG_ReadByte (net_message);
S_StaticSound (cl.sound_precache[sound_num], org, vol, atten);
}
// ACTION MESSAGES ============================================================
static void
CL_ParseStartSoundPacket (void)
{
float attenuation;
int bits, channel, ent, sound_num, volume;
vec3_t pos;
bits = MSG_ReadShort (net_message);
if (bits & SND_VOLUME)
volume = MSG_ReadByte (net_message);
else
volume = DEFAULT_SOUND_PACKET_VOLUME;
if (bits & SND_ATTENUATION)
attenuation = MSG_ReadByte (net_message) / 64.0;
else
attenuation = DEFAULT_SOUND_PACKET_ATTENUATION;
sound_num = MSG_ReadByte (net_message);
MSG_ReadCoordV (net_message, pos);
ent = (bits >> 3) & 1023;
channel = bits & 7;
if (ent > MAX_EDICTS)
Host_Error ("CL_ParseStartSoundPacket: ent = %i", ent);
S_StartSound (ent, channel, cl.sound_precache[sound_num], pos,
volume / 255.0, attenuation);
}
/*
CL_ParseClientdata
Server information pertaining to only this client, sent every frame
*/
void
CL_ParseClientdata (void)
{
float latency;
frame_t *frame;
int i;
// calculate simulated time of message
oldparsecountmod = parsecountmod;
i = cls.netchan.incoming_acknowledged;
cl.parsecount = i;
i &= UPDATE_MASK;
parsecountmod = i;
frame = &cl.frames[i];
if (cls.demoplayback2)
frame->senttime = realtime - host_frametime; //realtime;
parsecounttime = cl.frames[i].senttime;
frame->receivedtime = realtime;
// calculate latency
latency = frame->receivedtime - frame->senttime;
if (!(latency < 0 || latency > 1.0)) {
// drift the average latency towards the observed latency
if (latency < cls.latency)
cls.latency = latency;
else
cls.latency += 0.001; // drift up, so correction is needed
}
}
static void
CL_ProcessUserInfo (int slot, player_info_t *player)
{
char skin[MAX_SKIN_LENGTH] = { 0 };
const char *s;
s = Info_ValueForKey (player->userinfo, "skin");
if (strlen(s) < sizeof skin) {
QFS_StripExtension (s, skin);
if (!strequal (s, skin))
Info_SetValueForKey (player->userinfo, "skin", skin, 1);
} else {
Info_SetValueForKey (player->userinfo, "skin", skin, 1);
}
while (!(player->name = Info_Key (player->userinfo, "name"))) {
if (player->userid)
Info_SetValueForKey (player->userinfo, "name",
va (0, "user-%i [exploit]",
player->userid), 1);
else
Info_SetValueForKey (player->userinfo, "name", "", 1);
}
player->topcolor = atoi (Info_ValueForKey (player->userinfo, "topcolor"));
player->bottomcolor =
atoi (Info_ValueForKey (player->userinfo, "bottomcolor"));
while (!(player->team = Info_Key (player->userinfo, "team")))
Info_SetValueForKey (player->userinfo, "team", "", 1);
while (!(player->skinname = Info_Key (player->userinfo, "skin")))
Info_SetValueForKey (player->userinfo, "skin", "", 1);
while (!(player->chat = Info_Key (player->userinfo, "chat")))
Info_SetValueForKey (player->userinfo, "chat", "0", 1);
if (Info_ValueForKey (player->userinfo, "*spectator")[0])
player->spectator = true;
else
player->spectator = false;
mod_funcs->Skin_SetTranslation (slot + 1, player->topcolor,
player->bottomcolor);
player->skin = mod_funcs->Skin_SetSkin (player->skin, slot + 1,
player->skinname->value);
player->skin = mod_funcs->Skin_SetColormap (player->skin, slot + 1);
Sbar_Changed ();
}
static void
CL_UpdateUserinfo (void)
{
int slot, uid;
const char *info;
player_info_t *player;
slot = MSG_ReadByte (net_message);
if (slot >= MAX_CLIENTS)
Host_Error
("CL_ParseServerMessage: svc_updateuserinfo > MAX_SCOREBOARD");
player = &cl.players[slot];
uid = MSG_ReadLong (net_message);
info = MSG_ReadString (net_message);
if (*info) {
// a totally empty userinfo string should not be possible
player->userid = uid;
if (player->userinfo)
Info_Destroy (player->userinfo);
player->userinfo = Info_ParseString (info, MAX_INFO_STRING, 0);
CL_ProcessUserInfo (slot, player);
CL_Chat_Check_Name (Info_ValueForKey (player->userinfo, "name"), slot);
} else {
// the server dropped the client
CL_Chat_User_Disconnected (player->userid);
if (player->userinfo)
Info_Destroy (player->userinfo);
memset (player, 0, sizeof (*player));
}
}
static void
CL_SetInfo (void)
{
char key[MAX_MSGLEN], value[MAX_MSGLEN];
int flags, slot;
player_info_t *player;
slot = MSG_ReadByte (net_message);
if (slot >= MAX_CLIENTS)
Host_Error ("CL_ParseServerMessage: svc_setinfo > MAX_SCOREBOARD");
player = &cl.players[slot];
strncpy (key, MSG_ReadString (net_message), sizeof (key) - 1);
key[sizeof (key) - 1] = 0;
strncpy (value, MSG_ReadString (net_message), sizeof (value) - 1);
key[sizeof (value) - 1] = 0;
if (!player->userinfo)
player->userinfo = Info_ParseString ("", MAX_INFO_STRING, 0);
flags = !strequal (key, "name");
flags |= strequal (key, "team") << 1;
Info_SetValueForKey (player->userinfo, key, value, flags);
CL_ProcessUserInfo (slot, player);
Sys_MaskPrintf (SYS_DEV, "SETINFO %s: %s=%s\n", player->name->value, key,
value);
}
static void
CL_ServerInfo (void)
{
char key[MAX_MSGLEN], value[MAX_MSGLEN];
strncpy (key, MSG_ReadString (net_message), sizeof (key) - 1);
key[sizeof (key) - 1] = 0;
strncpy (value, MSG_ReadString (net_message), sizeof (value) - 1);
key[sizeof (value) - 1] = 0;
Sys_MaskPrintf (SYS_DEV, "SERVERINFO: %s=%s\n", key, value);
Info_SetValueForKey (cl.serverinfo, key, value, 0);
if (strequal (key, "chase")) {
cl.chase = atoi (value);
} else if (strequal (key, "cshifts")) {
cl.sv_cshifts = atoi (value);
} else if (strequal (key, "no_pogo_stick")) {
Cvar_Set (no_pogo_stick, value);
cl.no_pogo_stick = no_pogo_stick->int_val;
} else if (strequal (key, "teamplay")) {
cl.teamplay = atoi (value);
Sbar_DMO_Init_f (hud_scoreboard_uid); // HUD setup, cl.teamplay changed
} else if (strequal (key, "watervis")) {
cl.watervis = atoi (value);
} else if (strequal (key, "fpd")) {
cl.fpd = atoi (value);
} else if (strequal (key, "fbskins")) {
cl.fbskins = atoi (value);
// } else if (strequal (key, "*z_ext") {
// cl.z_ext = atoi (value);
// } else if (strequal (key, "pm_bunnyspeedcap") {
// cl.bunnyspeedcap = atof (value);
// } else if (strequal (key, "pm_slidefix") {
// movevars.slidefix = atoi (value);
// } else if (strequal (key, "pm_ktjump") {
// movevars.ktjump = atof (value);
// FIXME: need to set to 0.5 otherwise, outside of else structure
}
}
static void
CL_SetStat (int stat, int value)
{
if (stat < 0 || stat >= MAX_CL_STATS)
Host_Error ("CL_SetStat: %i is invalid", stat);
if (cls.demoplayback2) {
cl.players[cls.lastto].stats[stat] = value;
if (Cam_TrackNum () != cls.lastto)
return;
}
Sbar_Changed ();
switch (stat) {
case STAT_ITEMS:
Sbar_Changed ();
break;
case STAT_HEALTH:
if (cl_player_health_e->func)
GIB_Event_Callback (cl_player_health_e, 1,
va (0, "%i", value));
if (value <= 0)
Team_Dead ();
break;
}
cl.stats[stat] = value;
}
static void
CL_ParseMuzzleFlash (void)
{
//FIXME this should just enable the effect on the relevant entity and
//then automatic entity updates take care of the rest
int i;
player_state_t *pl;
vec3_t f, r, u;
vec4f_t position = { 0, 0, 0, 1}, fv = {};
i = MSG_ReadShort (net_message);
if ((unsigned int) (i - 1) >= MAX_CLIENTS)
return;
pl = &cl.frames[parsecountmod].playerstate[i - 1];
if (i - 1 == cl.playernum)
AngleVectors (cl.viewstate.angles, f, r, u);
else
AngleVectors (pl->viewangles, f, r, u);
VectorCopy (f, fv);
VectorCopy (pl->pls.es.origin, position);
CL_MuzzleFlash (position, fv, 0, i, cl.time);
}
#define SHOWNET(x) \
if (cl_shownet->int_val == 2) \
Sys_Printf ("%3i:%s\n", net_message->readcount - 1, x);
int received_framecount;
void
CL_ParseServerMessage (void)
{
int cmd = 0, i, j;
const char *str;
static dstring_t *stuffbuf;
TEntContext_t tentCtx = {
cl.viewstate.origin, cl.worldmodel, cl.viewentity
};
received_framecount = host_framecount;
cl.last_servermessage = realtime;
CL_ClearProjectiles ();
// if recording demos, copy the message out
if (cl_shownet->int_val == 1)
Sys_Printf ("%i ", net_message->message->cursize);
else if (cl_shownet->int_val == 2)
Sys_Printf ("------------------ %d\n",
cls.netchan.incoming_acknowledged);
CL_ParseClientdata ();
// parse the message
while (1) {
if (net_message->badread)
Host_Error ("CL_ParseServerMessage: Bad server message: %s\n",
svc_strings[cmd]);
cmd = MSG_ReadByte (net_message);
if (cmd == -1) {
net_message->readcount++; // so the EOM SHOWNET has the right
// value
SHOWNET ("END OF MESSAGE");
break; // end of message
}
SHOWNET (va (0, "%s(%d)", svc_strings[cmd], cmd));
// other commands
switch (cmd) {
default:
Host_Error ("CL_ParseServerMessage: Illegible server "
"message: %d\n", cmd);
break;
case svc_nop:
break;
case svc_disconnect:
if (cls.state == ca_connected)
Host_EndGame ("Server disconnected\n"
"Server version may not be compatible");
else
Host_EndGame ("Server disconnected\n");
case svc_updatestat:
i = MSG_ReadByte (net_message);
j = MSG_ReadByte (net_message);
CL_SetStat (i, j);
break;
// svc_version
// svc_setview
case svc_sound:
CL_ParseStartSoundPacket ();
break;
// svc_time
case svc_print:
{
dstring_t *p = 0;
i = MSG_ReadByte (net_message);
str = MSG_ReadString (net_message);
if (i == PRINT_CHAT) {
if (!CL_Chat_Allow_Message (str))
break;
// TODO: cl_nofake 2 -- accept fake messages from teammates
if (cl_nofake->int_val) {
char *c;
p = dstring_strdup (str);
for (c = p->str; *c; c++) {
if (*c == '\r')
*c = '#';
}
str = p->str;
}
Con_SetOrMask (128);
S_LocalSound ("misc/talk.wav");
if (cl_chat_e->func)
GIB_Event_Callback (cl_chat_e, 1, str);
Team_ParseChat (str);
}
Sys_Printf ("%s", str);
if (p)
dstring_delete (p);
Con_SetOrMask (0);
break;
}
case svc_stufftext:
str = MSG_ReadString (net_message);
if (str[strlen (str) - 1] == '\n') {
if (stuffbuf && stuffbuf->str[0]) {
Sys_MaskPrintf (SYS_DEV, "stufftext: %s%s\n",
stuffbuf->str, str);
Cbuf_AddText (cl_stbuf, stuffbuf->str);
dstring_clearstr (stuffbuf);
} else {
Sys_MaskPrintf (SYS_DEV, "stufftext: %s\n", str);
}
Cbuf_AddText (cl_stbuf, str);
} else {
Sys_MaskPrintf (SYS_DEV, "partial stufftext: %s\n", str);
if (!stuffbuf)
stuffbuf = dstring_newstr ();
dstring_appendstr (stuffbuf, str);
}
break;
case svc_setangle:
{
vec_t *dest = cl.viewstate.angles;
vec3_t dummy;
if (cls.demoplayback2) {
j = MSG_ReadByte (net_message);
// fixangle |= 1 << j;
if (j != Cam_TrackNum ())
dest = dummy;
}
MSG_ReadAngleV (net_message, dest);
break;
}
case svc_serverdata:
// make sure any stuffed commands are done
if (stuffbuf && stuffbuf->str[0]) {
Cbuf_AddText (cl_stbuf, stuffbuf->str);
dstring_clearstr (stuffbuf);
}
Cbuf_Execute_Stack (cl_stbuf);
CL_ParseServerData ();
// leave full screen intermission
r_data->vid->recalc_refdef = true;
break;
case svc_lightstyle:
i = MSG_ReadByte (net_message);
if (i >= MAX_LIGHTSTYLES)
Host_Error ("svc_lightstyle > MAX_LIGHTSTYLES");
strcpy (cl.lightstyle[i].map, MSG_ReadString (net_message));
cl.lightstyle[i].length = strlen (cl.lightstyle[i].map);
if (cl.lightstyle[i].length) {
int total = 0;
cl.lightstyle[i].peak = 'a';
for (j = 0; j < cl.lightstyle[i].length; j++) {
total += cl.lightstyle[i].map[j] - 'a';
cl.lightstyle[i].peak = max (cl.lightstyle[i].peak,
cl.lightstyle[i].map[j]);
}
total /= cl.lightstyle[i].length;
cl.lightstyle[i].average = total + 'a';
} else {
cl.lightstyle[i].average = 'm';
cl.lightstyle[i].peak = 'm';
}
break;
// svc_updatename
case svc_updatefrags:
Sbar_Changed ();
i = MSG_ReadByte (net_message);
if (i >= MAX_CLIENTS)
Host_Error ("CL_ParseServerMessage: svc_updatefrags > "
"MAX_SCOREBOARD");
cl.players[i].frags = (short) MSG_ReadShort (net_message);
break;
// svc_clientdata
case svc_stopsound:
i = MSG_ReadShort (net_message);
S_StopSound (i >> 3, i & 7);
break;
// svc_updatecolors
// svc_particle
case svc_damage:
V_ParseDamage ();
break;
case svc_spawnstatic:
CL_ParseStatic ();
break;
// svc_spawnbinary
case svc_spawnbaseline:
i = MSG_ReadShort (net_message);
CL_ParseBaseline (&qw_entstates.baseline[i]);
break;
case svc_temp_entity:
CL_ParseTEnt_qw (net_message, cl.time, &tentCtx);
break;
case svc_setpause:
r_data->paused = cl.paused = MSG_ReadByte (net_message);
if (cl.paused)
CDAudio_Pause ();
else
CDAudio_Resume ();
break;
// svc_signonnum
case svc_centerprint:
str = MSG_ReadString (net_message);
if (strcmp (str, centerprint->str)) {
dstring_copystr (centerprint, str);
//FIXME logging
}
Sbar_CenterPrint (str);
break;
case svc_killedmonster:
cl.stats[STAT_MONSTERS]++;
break;
case svc_foundsecret:
cl.stats[STAT_SECRETS]++;
break;
case svc_spawnstaticsound:
CL_ParseStaticSound ();
break;
case svc_intermission:
Sys_MaskPrintf (SYS_DEV, "svc_intermission\n");
cl.intermission = 1;
r_data->force_fullscreen = 1;
cl.completed_time = realtime;
r_data->vid->recalc_refdef = true; // go to full screen
Sys_MaskPrintf (SYS_DEV, "intermission simorg: ");
MSG_ReadCoordV (net_message, &cl.viewstate.origin[0]);//FIXME
cl.viewstate.origin[3] = 1;
Sys_MaskPrintf (SYS_DEV, VEC4F_FMT,
VEC4_EXP (cl.viewstate.origin));
Sys_MaskPrintf (SYS_DEV, "\nintermission simangles: ");
MSG_ReadAngleV (net_message, cl.viewstate.angles);
cl.viewstate.angles[ROLL] = 0; // FIXME @@@
Sys_MaskPrintf (SYS_DEV, "%f %f %f",
VectorExpand (cl.viewstate.angles));
Sys_MaskPrintf (SYS_DEV, "\n");
cl.viewstate.velocity = (vec4f_t) { };
// automatic fraglogging (by elmex)
// XXX: Should this _really_ called here?
if (!cls.demoplayback)
Sbar_LogFrags ();
break;
case svc_finale:
cl.intermission = 2;
r_data->force_fullscreen = 1;
cl.completed_time = realtime;
r_data->vid->recalc_refdef = true; // go to full screen
str = MSG_ReadString (net_message);
if (strcmp (str, centerprint->str)) {
dstring_copystr (centerprint, str);
//FIXME logging
}
Sbar_CenterPrint (str);
break;
case svc_cdtrack:
cl.cdtrack = MSG_ReadByte (net_message);
CDAudio_Play ((byte) cl.cdtrack, true);
break;
case svc_sellscreen:
Cmd_ExecuteString ("help", src_command);
break;
// svc_cutscene (same value as svc_smallkick)
case svc_smallkick:
cl.viewstate.punchangle = (vec4f_t) {
// -2 degrees pitch
0, -0.0174524064, 0, 0.999847695
};
break;
case svc_bigkick:
cl.viewstate.punchangle = (vec4f_t) {
// -4 degrees pitch
0, -0.0348994967, 0, 0.999390827
};
break;
case svc_updateping:
i = MSG_ReadByte (net_message);
if (i >= MAX_CLIENTS)
Host_Error ("CL_ParseServerMessage: svc_updateping > "
"MAX_SCOREBOARD");
cl.players[i].ping = MSG_ReadShort (net_message);
break;
case svc_updateentertime:
// time is sent over as seconds ago
i = MSG_ReadByte (net_message);
if (i >= MAX_CLIENTS)
Host_Error ("CL_ParseServerMessage: svc_updateentertime "
"> MAX_SCOREBOARD");
cl.players[i].entertime = realtime - MSG_ReadFloat
(net_message);
break;
case svc_updatestatlong:
i = MSG_ReadByte (net_message);
j = MSG_ReadLong (net_message);
CL_SetStat (i, j);
break;
case svc_muzzleflash:
CL_ParseMuzzleFlash ();
break;
case svc_updateuserinfo:
CL_UpdateUserinfo ();
break;
case svc_download:
CL_ParseDownload ();
break;
case svc_playerinfo:
CL_ParsePlayerinfo ();
break;
case svc_nails:
CL_ParseProjectiles (net_message, false, &tentCtx);
break;
case svc_chokecount: // some preceding packets were choked
i = MSG_ReadByte (net_message);
for (j = 0; j < i; j++)
cl.frames[(cls.netchan.incoming_acknowledged - 1 - j) &
UPDATE_MASK].receivedtime = -2;
break;
case svc_modellist:
CL_ParseModellist ();
break;
case svc_soundlist:
CL_ParseSoundlist ();
break;
case svc_packetentities:
CL_ParsePacketEntities (false);
break;
case svc_deltapacketentities:
CL_ParsePacketEntities (true);
break;
case svc_maxspeed:
movevars.maxspeed = MSG_ReadFloat (net_message);
break;
case svc_entgravity:
movevars.entgravity = MSG_ReadFloat (net_message);
break;
case svc_setinfo:
CL_SetInfo ();
break;
case svc_serverinfo:
CL_ServerInfo ();
break;
case svc_updatepl:
i = MSG_ReadByte (net_message);
if (i >= MAX_CLIENTS)
Host_Error ("CL_ParseServerMessage: svc_updatepl > "
"MAX_SCOREBOARD");
cl.players[i].pl = MSG_ReadByte (net_message);
break;
case svc_nails2: // FIXME from qwex
CL_ParseProjectiles (net_message, true, &tentCtx);
break;
}
}
CL_SetSolidEntities ();
}