开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
handle_d2gs.c
资源名称：pvpgn-1.6.2.rar　[点击查看]
上传用户：tany51
上传日期：2013-06-12
资源大小：1397k
文件大小：20k
源码类别：

MySQL数据库

开发平台：

Visual C++

handle_d2gs.c：源码内容
  1. /*
  2.  * Copyright (C) 2000,2001 Onlyer (onlyer@263.net)
  3.  *
  4.  * This program is free software; you can redistribute it and/or
  5.  * modify it under the terms of the GNU General Public License
  6.  * as published by the Free Software Foundation; either version 2
  7.  * of the License, or (at your option) any later version.
  8.  *
  9.  * This program is distributed in the hope that it will be useful,
  10.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12.  * GNU General Public License for more details.
  13.  *
  14.  * You should have received a copy of the GNU General Public License
  15.  * along with this program; if not, write to the Free Software
  16.  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  17.  */
  18. #include "common/setup_before.h"
  19. #include "setup.h"
  21. #ifdef STDC_HEADERS
  22. # include <stdlib.h>
  23. #else
  24. # ifdef HAVE_MALLOC_H
  25. #  include <malloc.h>
  26. # endif
  27. #endif
  28. #ifdef HAVE_SYS_TYPES_H
  29. # include <sys/types.h> /* needed to include netinet/in.h */
  30. #endif
  31. #ifdef HAVE_SYS_SOCKET_H
  32. # include <sys/socket.h>
  33. #endif
  34. #include "compat/socket.h"
  35. #ifdef HAVE_NETINET_IN_H
  36. # include <netinet/in.h>
  37. #endif
  38. #include "compat/netinet_in.h"
  39. #ifdef HAVE_ARPA_INET_H
  40. # include <arpa/inet.h> /* FIXME: probably not needed... do some systems put types in here or something? */
  41. #endif
  42. #include "compat/psock.h"
  44. #include "d2gs.h"
  45. #include "handle_d2gs.h"
  46. #include "serverqueue.h"
  47. #include "game.h"
  48. #include "connection.h"
  49. #include "prefs.h"
  50. #include "d2cs_d2gs_protocol.h"
  51. #include "d2gstrans.h"
  52. #include "common/addr.h"
  53. #include "common/eventlog.h"
  54. #include "common/queue.h"
  55. #include "common/bn_type.h"
  56. #include "common/packet.h"
  57. #include "common/setup_after.h"
  59. DECLARE_PACKET_HANDLER(on_d2gs_authreply)
  60. DECLARE_PACKET_HANDLER(on_d2gs_setgsinfo)
  61. DECLARE_PACKET_HANDLER(on_d2gs_echoreply)
  62. DECLARE_PACKET_HANDLER(on_d2gs_creategamereply)
  63. DECLARE_PACKET_HANDLER(on_d2gs_joingamereply)
  64. DECLARE_PACKET_HANDLER(on_d2gs_updategameinfo)
  65. DECLARE_PACKET_HANDLER(on_d2gs_closegame)
  67. static t_packet_handle_table d2gs_packet_handle_table[]={
  68. /* 0x00 */ { 0,                                  conn_state_none,       NULL                    },
  69. /* 0x01 */ { 0,                                  conn_state_none,       NULL                    },
  70. /* 0x02 */ { 0,                                  conn_state_none,       NULL                    },
  71. /* 0x03 */ { 0,                                  conn_state_none,       NULL                    },
  72. /* 0x04 */ { 0,                                  conn_state_none,       NULL                    },
  73. /* 0x05 */ { 0,                                  conn_state_none,       NULL                    },
  74. /* 0x06 */ { 0,                                  conn_state_none,       NULL                    },
  75. /* 0x07 */ { 0,                                  conn_state_none,       NULL                    },
  76. /* 0x08 */ { 0,                                  conn_state_none,       NULL                    },
  77. /* 0x09 */ { 0,                                  conn_state_none,       NULL                    },
  78. /* 0x0a */ { 0,                                  conn_state_none,       NULL                    },
  79. /* 0x0b */ { 0,                                  conn_state_none,       NULL                    },
  80. /* 0x0c */ { 0,                                  conn_state_none,       NULL                    },
  81. /* 0x0d */ { 0,                                  conn_state_none,       NULL                    },
  82. /* 0x0e */ { 0,                                  conn_state_none,       NULL                    },
  83. /* 0x0f */ { 0,                                  conn_state_none,       NULL                    },
  84. /* 0x10 */ { 0,                                  conn_state_none,       NULL                    },
  85. /* FIXME: shouldn't these three be at 0x10-0x12? (But I'm pretty sure I preserved the padding) */
  86. /* 0x11 */ { sizeof(t_d2gs_d2cs_authreply),      conn_state_connected,  on_d2gs_authreply       },
  87. /* 0x12 */ { sizeof(t_d2gs_d2cs_setgsinfo),      conn_state_authed,     on_d2gs_setgsinfo       },
  88. /* 0x13 */ { sizeof(t_d2gs_d2cs_echoreply),      conn_state_any,        on_d2gs_echoreply       },
  89. /* 0x14 */ { 0,                                  conn_state_none,       NULL                    },
  90. /* 0x15 */ { 0,                                  conn_state_none,       NULL                    },
  91. /* 0x16 */ { 0,                                  conn_state_none,       NULL                    },
  92. /* 0x17 */ { 0,                                  conn_state_none,       NULL                    },
  93. /* 0x18 */ { 0,                                  conn_state_none,       NULL                    },
  94. /* 0x19 */ { 0,                                  conn_state_none,       NULL                    },
  95. /* 0x1a */ { 0,                                  conn_state_none,       NULL                    },
  96. /* 0x1b */ { 0,                                  conn_state_none,       NULL                    },
  97. /* 0x1c */ { 0,                                  conn_state_none,       NULL                    },
  98. /* 0x1d */ { 0,                                  conn_state_none,       NULL                    },
  99. /* 0x1e */ { 0,                                  conn_state_none,       NULL                    },
  100. /* 0x1f */ { 0,                                  conn_state_none,       NULL                    },
  101. /* 0x20 */ { sizeof(t_d2gs_d2cs_creategamereply),conn_state_authed,     on_d2gs_creategamereply },
  102. /* 0x21 */ { sizeof(t_d2gs_d2cs_joingamereply),  conn_state_authed,     on_d2gs_joingamereply   },
  103. /* 0x22 */ { sizeof(t_d2gs_d2cs_updategameinfo), conn_state_authed,     on_d2gs_updategameinfo  },
  104. /* 0x23 */ { sizeof(t_d2gs_d2cs_closegame),      conn_state_authed,     on_d2gs_closegame       },
  105. };
  107. static void d2gs_send_init_info(t_d2gs * gs, t_connection * c)
  108. {
  109. t_packet * rpacket;
  111. if ((rpacket=packet_create(packet_class_d2gs))) {
  112. packet_set_size(rpacket,sizeof(t_d2cs_d2gs_setinitinfo));
  113. packet_set_type(rpacket,D2CS_D2GS_SETINITINFO);
  114. bn_int_set(&rpacket->u.d2cs_d2gs_setinitinfo.h.seqno,0);
  115. bn_int_set(&rpacket->u.d2cs_d2gs_setinitinfo.time, time(NULL));
  116. bn_int_set(&rpacket->u.d2cs_d2gs_setinitinfo.gs_id, d2gs_get_id(gs));
  117. bn_int_set(&rpacket->u.d2cs_d2gs_setinitinfo.ac_version, 0);
  118. // packet_append_string(rpacket,prefs_get_d2gs_ac_checksum());
  119. packet_append_string(rpacket,"bogus_ac_checksum");
  120. // packet_append_string(rpacket,prefs_get_d2gs_ac_string());
  121. packet_append_string(rpacket,"bogus_ac_string");
  122. conn_push_outqueue(c,rpacket);
  123. packet_del_ref(rpacket);
  124. }
  125. return;
  126. }
  128. static void d2gs_send_server_conffile(t_d2gs *gs, t_connection *c)
  129. {
  130. t_packet *rpacket;
  131. FILE *fp;
  132. char *confs;
  133. long size;
  135. /* open d2gs server config file */
  136. if ((fp=fopen(prefs_get_d2gsconffile(), "r"))==NULL)
  137. return;
  138. /* get file size */
  139. if (fseek(fp, 0L, SEEK_END)) {
  140. fclose(fp);
  141. eventlog(eventlog_level_debug,__FUNCTION__,"failed fseek()");
  142. return;
  143. }
  144. if ((size = ftell(fp)) <= 0) {
  145. fclose(fp);
  146. eventlog(eventlog_level_error,__FUNCTION__,"failed ftell()");
  147. return;
  148. }
  149. fseek(fp, 0L, SEEK_SET);
  150. /* read config file content */
  151. confs = malloc(size+8);
  152. if (confs==NULL) {
  153. fclose(fp);
  154. eventlog(eventlog_level_error,__FUNCTION__,"not enough memory");
  155. return;
  156. }
  157. if (fread(confs, size, 1, fp) != 1) {
  158. fclose(fp);
  159. free(confs);
  160. eventlog(eventlog_level_error,__FUNCTION__,"failed fread()");
  161. return;
  162. }
  163. confs[size]='';
  164. fclose(fp);
  165. /* send the config within a packet */
  166. if ((rpacket=packet_create(packet_class_d2gs))) {
  167. packet_set_size(rpacket,sizeof(t_d2cs_d2gs_setconffile));
  168. packet_set_type(rpacket,D2CS_D2GS_SETCONFFILE);
  169. bn_int_set(&rpacket->u.d2cs_d2gs_setconffile.h.seqno,0);
  170. bn_int_set(&rpacket->u.d2cs_d2gs_setconffile.size, size);
  171. bn_int_set(&rpacket->u.d2cs_d2gs_setconffile.reserved1, time(NULL));
  172. packet_append_string(rpacket,confs);
  173. queue_push_packet(d2cs_conn_get_out_queue(c),rpacket);
  174. packet_del_ref(rpacket);
  175. eventlog(eventlog_level_info,__FUNCTION__,"send config file to d2gs %s", addr_num_to_ip_str(d2cs_conn_get_addr(c)));
  176. }
  177. free(confs);
  178. return;
  179. }
  181. static int on_d2gs_authreply(t_connection * c, t_packet * packet)
  182. {
  183. t_d2gs * gs;
  184. t_packet * rpacket;
  185. unsigned int reply;
  186. unsigned int try_checksum, checksum;
  187. unsigned int version, conf_version;
  188. unsigned int randnum, signlen;
  189. unsigned char *sign;
  191. if (!(gs=d2gslist_find_gs(conn_get_d2gs_id(c)))) {
  192. eventlog(eventlog_level_error,__FUNCTION__,"game server %d not found",conn_get_d2gs_id(c));
  193. return -1;
  194. }
  196. version=bn_int_get(packet->u.d2gs_d2cs_authreply.version);
  197. try_checksum=bn_int_get(packet->u.d2gs_d2cs_authreply.checksum);
  198. checksum=d2gs_calc_checksum(c);
  200. conf_version = prefs_get_d2gs_version();
  201. randnum = bn_int_get(packet->u.d2gs_d2cs_authreply.randnum);
  202. signlen = bn_int_get(packet->u.d2gs_d2cs_authreply.signlen);
  203. sign    = packet->u.d2gs_d2cs_authreply.sign;
  204. if (conf_version && conf_version != version) {
  205. eventlog(eventlog_level_warn,__FUNCTION__,"game server %d version mismatch 0x%X - 0x%X",conn_get_d2gs_id(c),
  206. version,conf_version);
  207. }
  208. if (conf_version && !MAJOR_VERSION_EQUAL(version, conf_version, D2GS_MAJOR_VERSION_MASK)) {
  209. eventlog(eventlog_level_error,__FUNCTION__,"game server %d major version mismatch 0x%X - 0x%X",conn_get_d2gs_id(c),
  210. version,conf_version);
  211. reply=D2CS_D2GS_AUTHREPLY_BAD_VERSION;
  212. } else if (prefs_get_d2gs_checksum() && try_checksum != checksum) {
  213. eventlog(eventlog_level_error,__FUNCTION__,"game server %d checksum mismach 0x%X - 0x%X",conn_get_d2gs_id(c),try_checksum,checksum);
  214. reply=D2CS_D2GS_AUTHREPLY_BAD_CHECKSUM;
  215. // } else if (license_verify_reply(c, randnum, sign, signlen)) {
  216. // eventlog(eventlog_level_error,__FUNCTION__,"game server %d signal mismach", conn_get_d2gs_id(c));
  217. // reply=D2CS_D2GS_AUTHREPLY_BAD_CHECKSUM;
  218. } else {
  219. reply=D2CS_D2GS_AUTHREPLY_SUCCEED;
  220. }
  222. if (reply==D2CS_D2GS_AUTHREPLY_SUCCEED) {
  223. eventlog(eventlog_level_info,__FUNCTION__,"game server %s authed",addr_num_to_ip_str(d2cs_conn_get_addr(c)));
  224. d2cs_conn_set_state(c,conn_state_authed);
  225. d2gs_send_server_conffile(gs, c);
  226. d2gs_send_init_info(gs, c);
  227. d2gs_active(gs,c);
  228. } else {
  229. eventlog(eventlog_level_error,__FUNCTION__,"game server %s failed to auth",addr_num_to_ip_str(d2cs_conn_get_addr(c)));
  230. /* 
  231. d2cs_conn_set_state(c,conn_state_destroy); 
  232. */
  233. }
  234. if ((rpacket=packet_create(packet_class_d2gs))) {
  235. packet_set_size(rpacket,sizeof(t_d2cs_d2gs_authreply));
  236. packet_set_type(rpacket,D2CS_D2GS_AUTHREPLY);
  237. bn_int_set(&rpacket->u.d2cs_d2gs_authreply.h.seqno,0);
  238. bn_int_set(&rpacket->u.d2cs_d2gs_authreply.reply,reply);
  239. conn_push_outqueue(c,rpacket);
  240. packet_del_ref(rpacket);
  241. }
  243. return 0;
  244. }
  246. static int on_d2gs_setgsinfo(t_connection * c, t_packet * packet)
  247. {
  248. t_d2gs * gs;
  249. t_packet * rpacket;
  250. unsigned int maxgame, prev_maxgame;
  251. unsigned int currgame, gameflag;
  253. if (!(gs=d2gslist_find_gs(conn_get_d2gs_id(c)))) {
  254. eventlog(eventlog_level_error,__FUNCTION__,"game server %d not found",conn_get_d2gs_id(c));
  255. return -1;
  256. }
  257. maxgame=bn_int_get(packet->u.d2gs_d2cs_setgsinfo.maxgame);
  258. gameflag=bn_int_get(packet->u.d2gs_d2cs_setgsinfo.gameflag);
  259. prev_maxgame=d2gs_get_maxgame(gs);
  260. currgame = d2gs_get_gamenum(gs);
  261. eventlog(eventlog_level_info, __FUNCTION__, "change game server %s max game from %d to %d (%d current)",addr_num_to_ip_str(d2cs_conn_get_addr(c)),prev_maxgame, maxgame, currgame);
  262. d2gs_set_maxgame(gs,maxgame);
  264.         if ((rpacket=packet_create(packet_class_d2gs))) {
  265.     packet_set_size(rpacket,sizeof(t_d2cs_d2gs_setgsinfo));
  266.     packet_set_type(rpacket,D2CS_D2GS_SETGSINFO);
  267.     bn_int_set(&rpacket->u.d2cs_d2gs_setgsinfo.h.seqno,0);
  268.     bn_int_set(&rpacket->u.d2cs_d2gs_setgsinfo.maxgame,maxgame);
  269.     bn_int_set(&rpacket->u.d2cs_d2gs_setgsinfo.gameflag,gameflag);
  270.     conn_push_outqueue(c,rpacket);
  271.     packet_del_ref(rpacket);
  272.         }
  274. gqlist_check_creategame(maxgame - currgame);
  275. return 0;
  276. }
  278. static int on_d2gs_echoreply(t_connection * c, t_packet * packet)
  279. {
  280. if (!c || !packet)
  281.     return 0;
  282. return 0;
  283. }
  285. static int on_d2gs_creategamereply(t_connection * c, t_packet * packet)
  286. {
  287. t_packet * opacket, * rpacket;
  288. t_sq * sq;
  289. t_connection * client;
  290. t_game * game;
  291. int result;
  292. int reply;
  293. int seqno;
  295. seqno=bn_int_get(packet->u.d2cs_d2gs.h.seqno);
  296. if (!(sq=sqlist_find_sq(seqno))) {
  297. eventlog(eventlog_level_error,__FUNCTION__,"seqno %d not found",seqno);
  298. return 0;
  299. }
  300. if (!(client=d2cs_connlist_find_connection_by_sessionnum(sq_get_clientid(sq)))) {
  301. eventlog(eventlog_level_error,__FUNCTION__,"client %d not found",sq_get_clientid(sq));
  302. sq_destroy(sq);
  303. return 0;
  304. }
  305. if (!(game=gamelist_find_game_by_id(sq_get_gameid(sq)))) {
  306. eventlog(eventlog_level_error,__FUNCTION__,"game %d not found",sq_get_gameid(sq));
  307. sq_destroy(sq);
  308. return 0;
  309. }
  310. if (!(opacket=sq_get_packet(sq))) {
  311. eventlog(eventlog_level_error,__FUNCTION__,"previous packet not found (seqno: %d)",seqno);
  312. sq_destroy(sq);
  313. return 0;
  314. }
  316. result=bn_int_get(packet->u.d2gs_d2cs_creategamereply.result);
  317. if (result==D2GS_D2CS_CREATEGAME_SUCCEED) {
  318. game_set_d2gs_gameid(game,bn_int_get(packet->u.d2gs_d2cs_creategamereply.gameid));
  319. game_set_created(game,1);
  320. eventlog(eventlog_level_info,__FUNCTION__,"game %s created on gs %d",d2cs_game_get_name(game),conn_get_d2gs_id(c));
  321. reply=D2CS_CLIENT_CREATEGAMEREPLY_SUCCEED;
  322. } else {
  323. eventlog(eventlog_level_warn,__FUNCTION__,"failed to create game %s on gs %d",d2cs_game_get_name(game),conn_get_d2gs_id(c));
  324. game_destroy(game);
  325. reply=D2CS_CLIENT_CREATEGAMEREPLY_FAILED;
  326. }
  328. if ((rpacket=packet_create(packet_class_d2cs))) {
  329. packet_set_size(rpacket,sizeof(t_d2cs_client_creategamereply));
  330. packet_set_type(rpacket,D2CS_CLIENT_CREATEGAMEREPLY);
  331. bn_short_set(&rpacket->u.d2cs_client_creategamereply.seqno,
  332. bn_short_get(opacket->u.client_d2cs_creategamereq.seqno));
  333. bn_short_set(&rpacket->u.d2cs_client_creategamereply.gameid,1);
  334. bn_short_set(&rpacket->u.d2cs_client_creategamereply.u1,1);
  335. bn_int_set(&rpacket->u.d2cs_client_creategamereply.reply,reply);
  336. conn_push_outqueue(client,rpacket);
  337. packet_del_ref(rpacket);
  338. }
  339. sq_destroy(sq);
  340. return 0;
  341. }
  343. static int on_d2gs_joingamereply(t_connection * c, t_packet * packet)
  344. {
  345. t_sq * sq;
  346. t_d2gs * gs;
  347. t_connection * client;
  348. t_game * game;
  349. t_packet * opacket, * rpacket;
  350. int result;
  351. int reply;
  352. int seqno;
  353. unsigned int gsaddr;
  356. seqno=bn_int_get(packet->u.d2cs_d2gs.h.seqno);
  357. if (!(sq=sqlist_find_sq(seqno))) {
  358. eventlog(eventlog_level_error,__FUNCTION__,"seqno %d not found",seqno);
  359. return 0;
  360. }
  361. if (!(client=d2cs_connlist_find_connection_by_sessionnum(sq_get_clientid(sq)))) {
  362. eventlog(eventlog_level_error,__FUNCTION__,"client %d not found",sq_get_clientid(sq));
  363. sq_destroy(sq);
  364. return 0;
  365. }
  366. if (!(game=gamelist_find_game_by_id(sq_get_gameid(sq)))) {
  367. eventlog(eventlog_level_error,__FUNCTION__,"game %d not found",sq_get_gameid(sq));
  368. sq_destroy(sq);
  369. return 0;
  370. }
  371. if (!(gs=game_get_d2gs(game))) {
  372. eventlog(eventlog_level_error,__FUNCTION__,"try join game without game server set");
  373. sq_destroy(sq);
  374. return 0;
  375. }
  376. if (!(opacket=sq_get_packet(sq))) {
  377. eventlog(eventlog_level_error,__FUNCTION__,"previous packet not found (seqno: %d)",seqno);
  378. sq_destroy(sq);
  379. return 0;
  380. }
  382. result=bn_int_get(packet->u.d2gs_d2cs_joingamereply.result);
  383. switch (result) {
  384. case D2GS_D2CS_JOINGAME_SUCCEED:
  385. eventlog(eventlog_level_info,__FUNCTION__,"added %s to game %s on gs %d",d2cs_conn_get_charname(client),
  386. d2cs_game_get_name(game),conn_get_d2gs_id(c));
  387. reply=D2CS_CLIENT_JOINGAMEREPLY_SUCCEED;
  388. break;
  390. case D2GS_D2CS_JOINGAME_GAME_FULL:
  391. eventlog(eventlog_level_info,__FUNCTION__,"failed to add %s to game %s on gs %d (game full)",d2cs_conn_get_charname(client),
  392. d2cs_game_get_name(game),conn_get_d2gs_id(c));
  393. reply=D2CS_CLIENT_JOINGAMEREPLY_GAME_FULL;
  394. break;
  395. default:
  396. eventlog(eventlog_level_info,__FUNCTION__,"failed to add %s to game %s on gs %d",d2cs_conn_get_charname(client),
  397. d2cs_game_get_name(game),conn_get_d2gs_id(c));
  398. reply=D2CS_CLIENT_JOINGAMEREPLY_FAILED;
  399. }
  401. if ((rpacket=packet_create(packet_class_d2cs))) {
  402. packet_set_size(rpacket,sizeof(t_d2cs_client_joingamereply));
  403. packet_set_type(rpacket,D2CS_CLIENT_JOINGAMEREPLY);
  404. bn_short_set(&rpacket->u.d2cs_client_joingamereply.seqno,
  405. bn_short_get(opacket->u.client_d2cs_joingamereq.seqno));
  406. /* specific flag for anti-cheating support */
  407. /*
  408. bn_short_set(&rpacket->u.d2cs_client_joingamereply.gameid,(unsigned short)game_get_d2gs_gameid(game)|0x8000);
  409. */
  410. bn_short_set(&rpacket->u.d2cs_client_joingamereply.gameid,(unsigned short)game_get_d2gs_gameid(game));
  412. bn_short_set(&rpacket->u.d2cs_client_joingamereply.u1,0);
  413. bn_int_set(&rpacket->u.d2cs_client_joingamereply.reply,reply);
  414. // if (reply == SERVER_JOINGAMEREPLY2_REPLY_OK) {
  415. if (reply == D2CS_CLIENT_JOINGAMEREPLY_SUCCEED) {
  416. bn_int_set(&rpacket->u.d2cs_client_joingamereply.token,sq_get_gametoken(sq));
  418. gsaddr = d2gs_get_ip(gs);
  419. d2gstrans_net(d2cs_conn_get_addr(client),&gsaddr);
  421. if(d2gs_get_ip(gs)!=gsaddr)
  422. {
  423.     eventlog(eventlog_level_info,__FUNCTION__,"translated gameserver %s -> %s",addr_num_to_ip_str(d2gs_get_ip(gs)),addr_num_to_ip_str(gsaddr));
  424. } else {
  425.     eventlog(eventlog_level_info,__FUNCTION__,"no translation required for gamserver %s",addr_num_to_ip_str(gsaddr));
  426. }
  428. bn_int_nset(&rpacket->u.d2cs_client_joingamereply.addr,gsaddr);
  430. } else {
  431. bn_int_set(&rpacket->u.d2cs_client_joingamereply.token,0);
  432. bn_int_set(&rpacket->u.d2cs_client_joingamereply.addr,0);
  433. }
  434. conn_push_outqueue(client,rpacket);
  435. packet_del_ref(rpacket);
  436. }
  437. sq_destroy(sq);
  438. return 0;
  439. }
  441. static int on_d2gs_updategameinfo(t_connection * c, t_packet * packet)
  442. {
  443. unsigned int flag;
  444. char const * charname;
  445. t_game * game;
  446. unsigned int charclass;
  447. unsigned int charlevel;
  448. unsigned int d2gs_gameid;
  449. unsigned int d2gs_id;
  451. if (!(charname=packet_get_str_const(packet,sizeof(t_d2gs_d2cs_updategameinfo),MAX_CHARNAME_LEN))) {
  452. eventlog(eventlog_level_error,__FUNCTION__,"got bad charname");
  453. return 0;
  454. }
  455. d2gs_id=conn_get_d2gs_id(c);
  456. d2gs_gameid=bn_int_get(packet->u.d2gs_d2cs_updategameinfo.gameid);
  457. charclass=bn_int_get(packet->u.d2gs_d2cs_updategameinfo.charclass);
  458. charlevel=bn_int_get(packet->u.d2gs_d2cs_updategameinfo.charlevel);
  459. flag=bn_int_get(packet->u.d2gs_d2cs_updategameinfo.flag);
  460. if (!(game=gamelist_find_game_by_d2gs_and_id(d2gs_id,d2gs_gameid))) {
  461. eventlog(eventlog_level_error,__FUNCTION__,"game %d not found on gs %d",d2gs_gameid,d2gs_id);
  462. return -1;
  463. }
  464. if (flag==D2GS_D2CS_UPDATEGAMEINFO_FLAG_ENTER) {
  465. game_add_character(game,charname,charclass,charlevel);
  466. } else if (flag==D2GS_D2CS_UPDATEGAMEINFO_FLAG_LEAVE) {
  467. game_del_character(game,charname);
  468. } else if (flag==D2GS_D2CS_UPDATEGAMEINFO_FLAG_UPDATE) {
  469. game_add_character(game,charname,charclass,charlevel);
  470. } else {
  471. eventlog(eventlog_level_error,__FUNCTION__,"got bad updategameinfo flag %d",flag);
  472. }
  473. return 0;
  474. }
  476. static int on_d2gs_closegame(t_connection * c, t_packet * packet)
  477. {
  478. t_game * game;
  480. if (!(game=gamelist_find_game_by_d2gs_and_id(conn_get_d2gs_id(c),
  481. bn_int_get(packet->u.d2gs_d2cs_closegame.gameid)))) {
  482. return 0;
  483. }
  484. game_destroy(game);
  485. return 0;
  486. }
  488. extern int handle_d2gs_packet(t_connection * c, t_packet * packet)
  489. {
  490. conn_process_packet(c,packet,d2gs_packet_handle_table,NELEMS(d2gs_packet_handle_table));
  491. return 0;
  492. }
  494. extern int handle_d2gs_init(t_connection * c)
  495. {
  496. t_packet * packet;
  498. if ((packet=packet_create(packet_class_d2gs))) {
  499. packet_set_size(packet,sizeof(t_d2cs_d2gs_authreq));
  500. packet_set_type(packet,D2CS_D2GS_AUTHREQ);
  501. bn_int_set(&packet->u.d2cs_d2gs_authreq.h.seqno,0);
  502. bn_int_set(&packet->u.d2cs_d2gs_authreq.sessionnum,d2cs_conn_get_sessionnum(c));
  503. bn_int_set(&packet->u.d2cs_d2gs_authreq.signlen, 0);
  504. packet_append_string(packet,prefs_get_realmname());
  505. // packet_append_data(packet, sign, signlen);
  506. conn_push_outqueue(c,packet);
  507. packet_del_ref(packet);
  508. }
  509. eventlog(eventlog_level_info,__FUNCTION__,"sent init packet to d2gs %d (sessionnum=%d)",conn_get_d2gs_id(c),d2cs_conn_get_sessionnum(c));
  510. return 0;
  511. }