ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/socket/request.C
(Generate patch)

Comparing deliantra/server/socket/request.C (file contents):
Revision 1.38 by root, Thu Dec 14 22:45:41 2006 UTC vs.
Revision 1.41 by root, Fri Dec 15 19:59:20 2006 UTC

46 */ 46 */
47 47
48#include <global.h> 48#include <global.h>
49#include <sproto.h> 49#include <sproto.h>
50 50
51#include <newclient.h>
52#include <newserver.h>
53#include <living.h> 51#include <living.h>
54#include <commands.h> 52#include <commands.h>
55 53
56/* This block is basically taken from socket.c - I assume if it works there, 54/* This block is basically taken from socket.c - I assume if it works there,
57 * it should work here. 55 * it should work here.
88 -1, /* life stealing */ 86 -1, /* life stealing */
89 -1 /* Disease - not fully done yet */ 87 -1 /* Disease - not fully done yet */
90}; 88};
91 89
92static void 90static void
93socket_map_scroll (client_socket * ns, int dx, int dy) 91socket_map_scroll (client * ns, int dx, int dy)
94{ 92{
95 struct Map newmap; 93 struct Map newmap;
96 int x, y, mx, my; 94 int x, y, mx, my;
97 95
98 { 96 {
148} 146}
149 147
150static void 148static void
151clear_map (player *pl) 149clear_map (player *pl)
152{ 150{
153 client_socket &socket = *pl->socket; 151 client &socket = *pl->socket;
154 152
155 memset (&socket.lastmap, 0, sizeof (socket.lastmap)); 153 memset (&socket.lastmap, 0, sizeof (socket.lastmap));
156 154
157 if (socket.newmapcmd == 1) 155 if (socket.newmapcmd == 1)
158 socket.send_packet ("newmap"); 156 socket.send_packet ("newmap");
163 161
164/** check for map change and send new map data */ 162/** check for map change and send new map data */
165static void 163static void
166check_map_change (player *pl) 164check_map_change (player *pl)
167{ 165{
168 client_socket &socket = *pl->socket; 166 client &socket = *pl->socket;
169 object *ob = pl->ob; 167 object *ob = pl->ob;
170 char buf[MAX_BUF]; /* eauugggh */ 168 char buf[MAX_BUF]; /* eauugggh */
171 169
172 if (socket.current_map != ob->map) 170 if (socket.current_map != ob->map)
173 { 171 {
214 } 212 }
215 } 213 }
216 214
217 socket.current_x = ob->x; 215 socket.current_x = ob->x;
218 socket.current_y = ob->y; 216 socket.current_y = ob->y;
217}
218
219/**
220 * RequestInfo is sort of a meta command. There is some specific
221 * request of information, but we call other functions to provide
222 * that information.
223 */
224void
225RequestInfo (char *buf, int len, client * ns)
226{
227 char *params = NULL, *cp;
228
229 /* No match */
230 char bigbuf[MAX_BUF];
231 int slen;
232
233 /* Set up replyinfo before we modify any of the buffers - this is used
234 * if we don't find a match.
235 */
236 strcpy (bigbuf, "replyinfo ");
237 slen = strlen (bigbuf);
238 safe_strcat (bigbuf, buf, &slen, MAX_BUF);
239
240 /* find the first space, make it null, and update the
241 * params pointer.
242 */
243 for (cp = buf; *cp != '\0'; cp++)
244 if (*cp == ' ')
245 {
246 *cp = '\0';
247 params = cp + 1;
248 break;
249 }
250
251 if (!strcmp (buf, "image_info"))
252 send_image_info (ns, params);
253 else if (!strcmp (buf, "image_sums"))
254 send_image_sums (ns, params);
255 else if (!strcmp (buf, "skill_info"))
256 send_skill_info (ns, params);
257 else if (!strcmp (buf, "spell_paths"))
258 send_spell_paths (ns, params);
259 else
260 ns->send_packet (bigbuf, len);
219} 261}
220 262
221void 263void
222ExtCmd (char *buf, int len, player *pl) 264ExtCmd (char *buf, int len, player *pl)
223{ 265{
311 pl->socket->send_packet (bigbuf); 353 pl->socket->send_packet (bigbuf);
312} 354}
313 355
314/** This is the Setup cmd - easy first implementation */ 356/** This is the Setup cmd - easy first implementation */
315void 357void
316SetUp (char *buf, int len, client_socket * ns) 358SetUp (char *buf, int len, client * ns)
317{ 359{
318 int s, slen; 360 int s, slen;
319 char *cmd, *param, cmdback[HUGE_BUF]; 361 char *cmd, *param, cmdback[HUGE_BUF];
320 362
321 /* run through the cmds of setup 363 /* run through the cmds of setup
531 * This is what takes care of it. We tell the client how things worked out. 573 * This is what takes care of it. We tell the client how things worked out.
532 * I am not sure if this file is the best place for this function. however, 574 * I am not sure if this file is the best place for this function. however,
533 * it either has to be here or init_sockets needs to be exported. 575 * it either has to be here or init_sockets needs to be exported.
534 */ 576 */
535void 577void
536AddMeCmd (char *buf, int len, client_socket * ns) 578AddMeCmd (char *buf, int len, client * ns)
537{ 579{
538 Settings oldsettings; 580 Settings oldsettings;
539 581
540 oldsettings = settings; 582 oldsettings = settings;
541 if (ns->status != Ns_Add || add_player (ns)) 583 if (ns->status != Ns_Add || add_player (ns))
546 settings = oldsettings; 588 settings = oldsettings;
547} 589}
548 590
549/** Reply to ExtendedInfos command */ 591/** Reply to ExtendedInfos command */
550void 592void
551ToggleExtendedInfos (char *buf, int len, client_socket * ns) 593ToggleExtendedInfos (char *buf, int len, client * ns)
552{ 594{
553 char cmdback[MAX_BUF]; 595 char cmdback[MAX_BUF];
554 char command[50]; 596 char command[50];
555 int info, nextinfo; 597 int info, nextinfo;
556 598
607#define MSG_TYPE_MONUMENT 5 649#define MSG_TYPE_MONUMENT 5
608#define MSG_TYPE_SCRIPTED_DIALOG 6*/ 650#define MSG_TYPE_SCRIPTED_DIALOG 6*/
609 651
610/** Reply to ExtendedInfos command */ 652/** Reply to ExtendedInfos command */
611void 653void
612ToggleExtendedText (char *buf, int len, client_socket * ns) 654ToggleExtendedText (char *buf, int len, client * ns)
613{ 655{
614 char cmdback[MAX_BUF]; 656 char cmdback[MAX_BUF];
615 char temp[10]; 657 char temp[10];
616 char command[50]; 658 char command[50];
617 int info, nextinfo, i, flag; 659 int info, nextinfo, i, flag;
668 * a piece of data from us that we know the client wants. So 710 * a piece of data from us that we know the client wants. So
669 * if we know the client wants it, might as well push it to the 711 * if we know the client wants it, might as well push it to the
670 * client. 712 * client.
671 */ 713 */
672static void 714static void
673SendSmooth (client_socket * ns, uint16 face) 715SendSmooth (client * ns, uint16 face)
674{ 716{
675 uint16 smoothface; 717 uint16 smoothface;
676 718
677 /* If we can't find a face, return and set it so we won't try to send this 719 /* If we can't find a face, return and set it so we won't try to send this
678 * again. 720 * again.
702 /** 744 /**
703 * Tells client the picture it has to use 745 * Tells client the picture it has to use
704 * to smooth a picture number given as argument. 746 * to smooth a picture number given as argument.
705 */ 747 */
706void 748void
707AskSmooth (char *buf, int len, client_socket * ns) 749AskSmooth (char *buf, int len, client * ns)
708{ 750{
709 uint16 facenbr; 751 uint16 facenbr;
710 752
711 facenbr = atoi (buf); 753 facenbr = atoi (buf);
712 SendSmooth (ns, facenbr); 754 SendSmooth (ns, facenbr);
769 * etc.). It is a lot like PlayerCmd above, but is called with the 811 * etc.). It is a lot like PlayerCmd above, but is called with the
770 * 'ncom' method which gives more information back to the client so it 812 * 'ncom' method which gives more information back to the client so it
771 * can throttle. 813 * can throttle.
772 */ 814 */
773void 815void
774NewPlayerCmd (uint8 * buf, int len, player *pl) 816NewPlayerCmd (char *buf, int len, player *pl)
775{ 817{
776 int time, repeat; 818 int time, repeat;
777 char command[MAX_BUF]; 819 char command[MAX_BUF];
778 int pktlen; 820 int pktlen;
779 821
781 { 823 {
782 LOG (llevDebug, "Corrupt ncom command <%s> not long enough - discarding\n", buf); 824 LOG (llevDebug, "Corrupt ncom command <%s> not long enough - discarding\n", buf);
783 return; 825 return;
784 } 826 }
785 827
786 pktlen = net_uint16 (buf); 828 pktlen = net_uint16 ((uint8 *)buf);
787 repeat = net_uint32 (buf + 2); 829 repeat = net_uint32 ((uint8 *)buf + 2);
788 830
789 /* -1 is special - no repeat, but don't update */ 831 /* -1 is special - no repeat, but don't update */
790 if (repeat != -1) 832 if (repeat != -1)
791 pl->count = repeat; 833 pl->count = repeat;
792 834
793 if ((len - 4) >= MAX_BUF) 835 if ((len - 4) >= MAX_BUF)
794 len = MAX_BUF - 5; 836 len = MAX_BUF - 5;
795 837
796 strncpy ((char *) command, (char *) buf + 6, len - 4); 838 strncpy ((char *) command, (char *) buf + 6, len - 4);
797 command[len - 4] = '\0'; 839 command[len - 4] = 0;
798
799 /* The following should never happen with a proper or honest client.
800 * Therefore, the error message doesn't have to be too clear - if
801 * someone is playing with a hacked/non working client, this gives them
802 * an idea of the problem, but they deserve what they get
803 */
804 if (pl->state != ST_PLAYING)
805 {
806 new_draw_info_format (NDI_UNIQUE, 0, pl->ob, "You can not issue commands - state is not ST_PLAYING (%s)", buf);
807 return;
808 }
809 840
810 /* This should not happen anymore. */ 841 /* This should not happen anymore. */
811 if (pl->ob->speed_left < -1.0) 842 if (pl->ob->speed_left < -1.0)
812 LOG (llevError, "Player has negative time - shouldn't do command.\n"); 843 LOG (llevError, "Player has negative time - shouldn't do command.\n");
813 844
904 * something older than the server. If we assume the client will be 935 * something older than the server. If we assume the client will be
905 * backwards compatible, having it be a later version should not be a 936 * backwards compatible, having it be a later version should not be a
906 * problem. 937 * problem.
907 */ 938 */
908void 939void
909VersionCmd (char *buf, int len, client_socket * ns) 940VersionCmd (char *buf, int len, client * ns)
910{ 941{
911 char *cp; 942 char *cp;
912 char version_warning[256]; 943 char version_warning[256];
913 944
914 if (!buf) 945 if (!buf)
938 cp = strchr (cp + 1, ' '); 969 cp = strchr (cp + 1, ' ');
939 if (cp) 970 if (cp)
940 { 971 {
941 LOG (llevDebug, "CS: connection from client of type <%s>, ip %s\n", cp, ns->host); 972 LOG (llevDebug, "CS: connection from client of type <%s>, ip %s\n", cp, ns->host);
942 973
943 snprintf (ns->client, sizeof (ns->client), "%s", cp + 1); 974 assign (ns->version, cp + 1);
944 975
945 /* This is first implementation - i skip all beta DX clients with it
946 * Add later stuff here for other clients
947 */
948
949 /* these are old dxclients */
950 /* Version 1024 added support for singular + plural name values -
951 * requiing this minimal value reduces complexity of that code, and it
952 * has been around for a long time.
953 */
954 if (ns->sc_version < 1026) 976 if (ns->sc_version < 1026)
955 { 977 {
956 sprintf (version_warning, "drawinfo %d %s", NDI_RED, 978 sprintf (version_warning, "drawinfo %d %s", NDI_RED,
957 "**** VERSION WARNING ****\n**** CLIENT IS TOO OLD!! UPDATE THE CLIENT!! ****"); 979 "**** VERSION WARNING ****\n**** CLIENT IS TOO OLD!! UPDATE THE CLIENT!! ****");
958 ns->send_packet (version_warning); 980 ns->send_packet (version_warning);
960 982
961 } 983 }
962} 984}
963 985
964/** sound related functions. */ 986/** sound related functions. */
965
966void 987void
967SetSound (char *buf, int len, client_socket * ns) 988SetSound (char *buf, int len, client * ns)
968{ 989{
969 ns->sound = atoi (buf); 990 ns->sound = atoi (buf);
970} 991}
971 992
972/** client wants the map resent */ 993/** client wants the map resent */
1030/** 1051/**
1031 * Asks the client to query the user. This way, the client knows 1052 * Asks the client to query the user. This way, the client knows
1032 * it needs to send something back (vs just printing out a message) 1053 * it needs to send something back (vs just printing out a message)
1033 */ 1054 */
1034void 1055void
1035send_query (client_socket * ns, uint8 flags, char *text) 1056send_query (client * ns, uint8 flags, char *text)
1036{ 1057{
1037 char buf[MAX_BUF]; 1058 char buf[MAX_BUF];
1038 1059
1039 sprintf (buf, "query %d %s", flags, text ? text : ""); 1060 sprintf (buf, "query %d %s", flags, text ? text : "");
1040 ns->send_packet (buf); 1061 ns->send_packet (buf);
1199 * sent them the face yet (this can become quite costly in terms of 1220 * sent them the face yet (this can become quite costly in terms of
1200 * how much we are sending - on the other hand, this should only happen 1221 * how much we are sending - on the other hand, this should only happen
1201 * when the player logs in and picks stuff up. 1222 * when the player logs in and picks stuff up.
1202 */ 1223 */
1203void 1224void
1204esrv_send_animation (client_socket * ns, short anim_num) 1225esrv_send_animation (client * ns, short anim_num)
1205{ 1226{
1206 int i; 1227 int i;
1207 1228
1208 /* Do some checking on the anim_num we got. Note that the animations 1229 /* Do some checking on the anim_num we got. Note that the animations
1209 * are added in contigous order, so if the number is in the valid 1230 * are added in contigous order, so if the number is in the valid
1246/** 1267/**
1247 * This adds face_num to a map cell at x,y. If the client doesn't have 1268 * This adds face_num to a map cell at x,y. If the client doesn't have
1248 * the face yet, we will also send it. 1269 * the face yet, we will also send it.
1249 */ 1270 */
1250static void 1271static void
1251esrv_map_setbelow (client_socket * ns, int x, int y, short face_num, struct Map *newmap) 1272esrv_map_setbelow (client * ns, int x, int y, short face_num, struct Map *newmap)
1252{ 1273{
1253 if (newmap->cells[x][y].count >= MAP_LAYERS) 1274 if (newmap->cells[x][y].count >= MAP_LAYERS)
1254 { 1275 {
1255 LOG (llevError, "Too many faces in map cell %d %d\n", x, y); 1276 LOG (llevError, "Too many faces in map cell %d %d\n", x, y);
1256 return; 1277 return;
1276 struct LayerCell lcells[MAP_CLIENT_X * MAP_CLIENT_Y]; 1297 struct LayerCell lcells[MAP_CLIENT_X * MAP_CLIENT_Y];
1277}; 1298};
1278 1299
1279/** Checkes if map cells have changed */ 1300/** Checkes if map cells have changed */
1280static int 1301static int
1281mapcellchanged (client_socket * ns, int i, int j, struct Map *newmap) 1302mapcellchanged (client * ns, int i, int j, struct Map *newmap)
1282{ 1303{
1283 int k; 1304 int k;
1284 1305
1285 if (ns->lastmap.cells[i][j].count != newmap->cells[i][j].count) 1306 if (ns->lastmap.cells[i][j].count != newmap->cells[i][j].count)
1286 return 1; 1307 return 1;
1299 * cnum is the client number, cur is the the buffer we put all of 1320 * cnum is the client number, cur is the the buffer we put all of
1300 * this data into. we return the end of the data. layers is 1321 * this data into. we return the end of the data. layers is
1301 * how many layers of data we should back. 1322 * how many layers of data we should back.
1302 */ 1323 */
1303static uint8 * 1324static uint8 *
1304compactlayer (client_socket * ns, unsigned char *cur, int numlayers, struct Map *newmap) 1325compactlayer (client * ns, unsigned char *cur, int numlayers, struct Map *newmap)
1305{ 1326{
1306 int x, y, k; 1327 int x, y, k;
1307 int face; 1328 int face;
1308 unsigned char *fcur; 1329 unsigned char *fcur;
1309 struct MapLayer layers[MAP_LAYERS]; 1330 struct MapLayer layers[MAP_LAYERS];
1417 * needs to get sent - if so, it adds the data, sending the head 1438 * needs to get sent - if so, it adds the data, sending the head
1418 * if needed, and returning 1. If this no data needs to get 1439 * if needed, and returning 1. If this no data needs to get
1419 * sent, it returns zero. 1440 * sent, it returns zero.
1420 */ 1441 */
1421static int 1442static int
1422check_head (packet &sl, client_socket &ns, int ax, int ay, int layer) 1443check_head (packet &sl, client &ns, int ax, int ay, int layer)
1423{ 1444{
1424 short face_num; 1445 short face_num;
1425 1446
1426 if (heads[(ay * MAX_HEAD_POS + ax) * MAX_LAYERS + layer]) 1447 if (heads[(ay * MAX_HEAD_POS + ax) * MAX_LAYERS + layer])
1427 face_num = heads[(ay * MAX_HEAD_POS + ax) * MAX_LAYERS + layer]->face->number; 1448 face_num = heads[(ay * MAX_HEAD_POS + ax) * MAX_LAYERS + layer]->face->number;
1461 * the case, it seems to make more sense to have these layer values 1482 * the case, it seems to make more sense to have these layer values
1462 * actually match. 1483 * actually match.
1463 */ 1484 */
1464 1485
1465static int 1486static int
1466update_space (packet &sl, client_socket &ns, maptile *mp, int mx, int my, int sx, int sy, int layer) 1487update_space (packet &sl, client &ns, maptile *mp, int mx, int my, int sx, int sy, int layer)
1467{ 1488{
1468 object *ob, *head; 1489 object *ob, *head;
1469 uint16 face_num; 1490 uint16 face_num;
1470 int bx, by, i; 1491 int bx, by, i;
1471 1492
1684 * top layer (this matches what the GET_MAP_FACE and GET_MAP_FACE_OBJ 1705 * top layer (this matches what the GET_MAP_FACE and GET_MAP_FACE_OBJ
1685 * take. 1706 * take.
1686 */ 1707 */
1687 1708
1688static inline int 1709static inline int
1689update_smooth (packet &sl, client_socket &ns, maptile *mp, int mx, int my, int sx, int sy, int layer) 1710update_smooth (packet &sl, client &ns, maptile *mp, int mx, int my, int sx, int sy, int layer)
1690{ 1711{
1691 object *ob; 1712 object *ob;
1692 int smoothlevel; /* old face_num; */ 1713 int smoothlevel; /* old face_num; */
1693 1714
1694 ob = GET_MAP_FACE_OBJ (mp, mx, my, layer); 1715 ob = GET_MAP_FACE_OBJ (mp, mx, my, layer);
1728 * Returns the size of a data for a map square as returned by 1749 * Returns the size of a data for a map square as returned by
1729 * mapextended. There are CLIENTMAPX*CLIENTMAPY*LAYERS entries 1750 * mapextended. There are CLIENTMAPX*CLIENTMAPY*LAYERS entries
1730 * available. 1751 * available.
1731 */ 1752 */
1732int 1753int
1733getExtendedMapInfoSize (client_socket * ns) 1754getExtendedMapInfoSize (client * ns)
1734{ 1755{
1735 int result = 0; 1756 int result = 0;
1736 1757
1737 if (ns->ext_mapinfos) 1758 if (ns->ext_mapinfos)
1738 { 1759 {
1774 uint8 eentrysize; 1795 uint8 eentrysize;
1775 uint16 ewhatstart, ewhatflag; 1796 uint16 ewhatstart, ewhatflag;
1776 uint8 extendedinfos; 1797 uint8 extendedinfos;
1777 maptile *m; 1798 maptile *m;
1778 1799
1779 client_socket &socket = *pl->contr->socket; 1800 client &socket = *pl->contr->socket;
1780 1801
1781 check_map_change (pl->contr); 1802 check_map_change (pl->contr);
1782 1803
1783 packet sl; 1804 packet sl;
1784 packet esl; 1805 packet esl;
2227/** 2248/**
2228 * This sends the skill number to name mapping. We ignore 2249 * This sends the skill number to name mapping. We ignore
2229 * the params - we always send the same info no matter what. 2250 * the params - we always send the same info no matter what.
2230 */ 2251 */
2231void 2252void
2232send_skill_info (client_socket *ns, char *params) 2253send_skill_info (client *ns, char *params)
2233{ 2254{
2234 packet sl; 2255 packet sl;
2235 sl << "replyinfo skill_info\n"; 2256 sl << "replyinfo skill_info\n";
2236 2257
2237 for (int i = 1; i < NUM_SKILLS; i++) 2258 for (int i = 1; i < NUM_SKILLS; i++)
2249/** 2270/**
2250 * This sends the spell path to name mapping. We ignore 2271 * This sends the spell path to name mapping. We ignore
2251 * the params - we always send the same info no matter what. 2272 * the params - we always send the same info no matter what.
2252 */ 2273 */
2253void 2274void
2254send_spell_paths (client_socket * ns, char *params) 2275send_spell_paths (client * ns, char *params)
2255{ 2276{
2256 packet sl; 2277 packet sl;
2257 2278
2258 sl << "replyinfo spell_paths\n"; 2279 sl << "replyinfo spell_paths\n";
2259 2280

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines