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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 外挂编程 > 查看源码
functions.pl
资源名称：openkore-2.0.7.zip　[点击查看]
上传用户：market2
上传日期：2018-11-18
资源大小：18786k
文件大小：41k
源码类别：

外挂编程

开发平台：

Windows_Unix

functions.pl：源码内容
  1. #########################################################################
  2. # This software is open source, licensed under the GNU General Public
  3. # License, version 2.
  4. # Basically, this means that you're allowed to modify and distribute
  5. # this software. However, if you distribute modified versions, you MUST
  6. # also distribute the source code.
  7. # See http://www.gnu.org/licenses/gpl.html for the full license.
  8. #########################################################################
  10. package main;
  11. use strict;
  12. use Time::HiRes qw(time usleep);
  13. use IO::Socket;
  14. use Text::ParseWords;
  15. use Carp::Assert;
  16. use Data::YAML::Writer;
  17. use Config;
  18. use encoding 'utf8';
  20. use Globals;
  21. use Modules;
  22. use Settings qw(%sys);
  23. use Log qw(message warning error debug);
  24. use Interface;
  25. use Network::Receive;
  26. use Network::Send ();
  27. use Network::PaddedPackets;
  28. use Network::MessageTokenizer;
  29. use Commands;
  30. use Misc;
  31. use Plugins;
  32. use Utils;
  33. use ChatQueue;
  34. use I18N;
  35. use Utils::Benchmark;
  36. use Utils::HttpReader;
  39. #######################################
  40. # PROGRAM INITIALIZATION
  41. #######################################
  43. use constant {
  44. STATE_LOAD_PLUGINS          => 0,
  45. STATE_LOAD_DATA_FILES       => 1,
  46. STATE_INIT_NETWORKING       => 2,
  47. STATE_INIT_PORTALS_DATABASE => 3,
  48. STATE_PROMPT                => 4,
  49. STATE_FINAL_INIT            => 5,
  50. STATE_INITIALIZED           => 6
  51. };
  53. our $state;
  55. sub mainLoop {
  56. Benchmark::begin('mainLoop') if DEBUG;
  57. $state = STATE_LOAD_PLUGINS if (!defined $state);
  59. # Parse command input
  60. my $input;
  61. if (defined($input = $interface->getInput(0))) {
  62. Misc::checkValidity("parseInput (pre)");
  63. parseInput($input);
  64. Misc::checkValidity("parseInput");
  65. }
  68. if ($state == STATE_INITIALIZED) {
  69. Plugins::callHook('mainLoop_pre');
  70. mainLoop_initialized();
  71. Plugins::callHook('mainLoop_post');
  73. } elsif ($state == STATE_LOAD_PLUGINS) {
  74. Log::message("$Settings::versionTextn");
  75. loadPlugins();
  76. Log::message("n");
  77. Plugins::callHook('start');
  78. $state = STATE_LOAD_DATA_FILES;
  80. } elsif ($state == STATE_LOAD_DATA_FILES) {
  81. loadDataFiles();
  82. $state = STATE_INIT_NETWORKING;
  84. } elsif ($state == STATE_INIT_NETWORKING) {
  85. initNetworking();
  86. $state = STATE_INIT_PORTALS_DATABASE;
  88. } elsif ($state == STATE_INIT_PORTALS_DATABASE) {
  89. initPortalsDatabase();
  90. $state = STATE_PROMPT;
  92. } elsif ($state == STATE_PROMPT) {
  93. promptFirstTimeInformation();
  94. $state = STATE_FINAL_INIT;
  96. } elsif ($state == STATE_FINAL_INIT) {
  97. finalInitialization();
  98. $state = STATE_INITIALIZED;
  100. } else {
  101. die "Unknown state $state.";
  102. }
  104. Benchmark::end('mainLoop') if DEBUG;
  105. # Reload any modules that requested to be reloaded
  106. Modules::reloadAllInQueue();
  107. }
  109. sub loadPlugins {
  110. eval {
  111. Plugins::loadAll();
  112. };
  113. if (my $e = caught('Plugin::LoadException')) {
  114. $interface->errorDialog(TF("This plugin cannot be loaded because of a problem in the plugin. " .
  115. "Please notify the plugin's author about this problem, " .
  116. "or remove the plugin so %s can start.nn" .
  117. "The error message is:n" .
  118. "%s",
  119. $Settings::NAME, $e->message));
  120. exit 1;
  121. } elsif (my $e = caught('Plugin::DeniedException')) {
  122. $interface->errorDialog($e->message);
  123. exit 1;
  124. } elsif ($@) {
  125. die $@;
  126. }
  127. }
  129. sub loadDataFiles {
  130. # These pragmas are necessary in order to support non-ASCII filenames.
  131. # If we use UTF-8 strings then Perl will think the file doesn't exist,
  132. # if $Settings::control_folder or $Settings::tables_folder contains
  133. # non-ASCII characters.
  134. no encoding 'utf8';
  136. Settings::addControlFile(Settings::getConfigFilename(),
  137. loader => [&parseConfigFile, %config],
  138. autoSearch => 0);
  139. Settings::addControlFile(Settings::getMonControlFilename(),
  140. loader => [&parseMonControl, %mon_control],
  141. autoSearch => 0);
  142. Settings::addControlFile(Settings::getItemsControlFilename(),
  143. loader => [&parseItemsControl, %items_control],
  144. autoSearch => 0);
  145. Settings::addControlFile(Settings::getShopFilename(),
  146. loader => [&parseShopControl, %shop],
  147. autoSearch => 0);
  148. Settings::addControlFile('overallAuth.txt', loader => [&parseDataFile, %overallAuth]);
  149. Settings::addControlFile('pickupitems.txt', loader => [&parseDataFile_lc, %pickupitems]);
  150. Settings::addControlFile('responses.txt',   loader => [&parseResponses, %responses]);
  151. Settings::addControlFile('timeouts.txt',    loader => [&parseTimeouts, %timeout]);
  152. Settings::addControlFile('chat_resp.txt',   loader => [&parseChatResp, @chatResponses]);
  153. Settings::addControlFile('avoid.txt',       loader => [&parseAvoidControl, %avoid]);
  154. Settings::addControlFile('priority.txt',    loader => [&parsePriority, %priority]);
  155. Settings::addControlFile('consolecolors.txt', loader => [&parseSectionedFile, %consoleColors]);
  156. Settings::addControlFile('routeweights.txt',  loader => [&parseDataFile, %routeWeights]);
  157. Settings::addControlFile('arrowcraft.txt',  loader => [&parseDataFile_lc, %arrowcraft_items]);
  159. Settings::addTableFile(Settings::getRecvPacketsFilename(),
  160. loader => [&parseDataFile2, %rpackets],
  161. autoSearch => 0);
  162. Settings::addTableFile('cities.txt',      loader => [&parseROLUT, %cities_lut]);
  163. Settings::addTableFile('commanddescriptions.txt', loader => [&parseCommandsDescription, %descriptions]);
  164. Settings::addTableFile('directions.txt',  loader => [&parseDataFile2, %directions_lut]);
  165. Settings::addTableFile('elements.txt',    loader => [&parseROLUT, %elements_lut]);
  166. Settings::addTableFile('emotions.txt',    loader => [&parseEmotionsFile, %emotions_lut]);
  167. Settings::addTableFile('equiptypes.txt',  loader => [&parseDataFile2, %equipTypes_lut]);
  168. Settings::addTableFile('haircolors.txt',  loader => [&parseDataFile2, %haircolors]);
  169. Settings::addTableFile('headgears.txt',   loader => [&parseArrayFile, @headgears_lut]);
  170. Settings::addTableFile('items.txt',       loader => [&parseROLUT, %items_lut]);
  171. Settings::addTableFile('itemsdescriptions.txt',   loader => [&parseRODescLUT, %itemsDesc_lut]);
  172. Settings::addTableFile('itemslots.txt',   loader => [&parseROSlotsLUT, %itemSlots_lut]);
  173. Settings::addTableFile('itemslotcounttable.txt',  loader => [&parseROLUT, %itemSlotCount_lut]);
  174. Settings::addTableFile('itemtypes.txt',   loader => [&parseDataFile2, %itemTypes_lut]);
  175. Settings::addTableFile('maps.txt',        loader => [&parseROLUT, %maps_lut]);
  176. Settings::addTableFile('monsters.txt',    loader => [&parseDataFile2, %monsters_lut]);
  177. Settings::addTableFile('npcs.txt',        loader => [&parseNPCs, %npcs_lut]);
  178. Settings::addTableFile('packetdescriptions.txt',  loader => [&parseSectionedFile, %packetDescriptions]);
  179. Settings::addTableFile('portals.txt',     loader => [&parsePortals, %portals_lut]);
  180. Settings::addTableFile('portalsLOS.txt',  loader => [&parsePortalsLOS, %portals_los]);
  181. Settings::addTableFile('servers.txt',     loader => [&parseSectionedFile, %masterServers]);
  182. Settings::addTableFile('sex.txt',         loader => [&parseDataFile2, %sex_lut]);
  183. Settings::addTableFile('skills.txt',      loader => &Skill::StaticInfo::parseSkillsDatabase);
  184. Settings::addTableFile('spells.txt',      loader => [&parseDataFile2, %spells_lut]);
  185. Settings::addTableFile('skillsdescriptions.txt',  loader => [&parseRODescLUT, %skillsDesc_lut]);
  186. Settings::addTableFile('skillssp.txt',    loader => [&parseSkillsSPLUT, %skillsSP_lut]);
  187. Settings::addTableFile('skillssp.txt',    loader => &Skill::StaticInfo::parseSPDatabase);
  188. Settings::addTableFile('skillsstatus.txt',        loader => [&parseDataFile2, %skillsStatus]);
  189. Settings::addTableFile('skillsailments.txt',      loader => [&parseDataFile2, %skillsAilments]);
  190. Settings::addTableFile('skillsstate.txt', loader => [&parseDataFile2, %skillsState]);
  191. Settings::addTableFile('skillslooks.txt', loader => [&parseDataFile2, %skillsLooks]);
  192. Settings::addTableFile('skillsarea.txt',  loader => [&parseDataFile2, %skillsArea]);
  193. Settings::addTableFile('skillsencore.txt',        loader => [&parseList, %skillsEncore]);
  195. use encoding 'utf8';
  197. Plugins::callHook('start2');
  198. eval {
  199. my $progressHandler = sub {
  200. my ($filename) = @_;
  201. message TF("Loading %s...n", $filename);
  202. };
  203. Settings::loadAll($progressHandler);
  204. };
  205. if (my $e = caught('UTF8MalformedException')) {
  206. $interface->errorDialog(TF(
  207. "The file %s must be valid UTF-8 encoded, which it is n" .
  208. "currently not. To solve this prolem, please use Notepadn" .
  209. "to save that file as valid UTF-8.",
  210. $e->textfile));
  211. exit 1;
  212. } elsif (my $e = caught('FileNotFoundException')) {
  213. $interface->errorDialog(TF("Unable to load the file %s.", $e->filename));
  214. exit 1;
  215. } elsif ($@) {
  216. die $@;
  217. }
  218. Plugins::callHook('start3');
  220. if ($config{'adminPassword'} eq 'x' x 10) {
  221. Log::message(T("nAuto-generating Admin Password due to default...n"));
  222. configModify("adminPassword", vocalString(8));
  223. #} elsif ($config{'adminPassword'} eq '') {
  224. # # This is where we protect the stupid from having a blank admin password
  225. # Log::message(T("nAuto-generating Admin Password due to blank...n"));
  226. # configModify("adminPassword", vocalString(8));
  227. } elsif ($config{'secureAdminPassword'} eq '1') {
  228. # This is where we induldge the paranoid and let them have session generated admin passwords
  229. Log::message(T("nGenerating session Admin Password...n"));
  230. configModify("adminPassword", vocalString(8));
  231. }
  233. Log::message("n");
  234. }
  236. sub initNetworking {
  237. our $XKore_dontRedirect = 0;
  238. my $XKore_version = $config{XKore} ? $config{XKore} : $sys{XKore};
  239. eval {
  240. if ($XKore_version eq "1" || $XKore_version eq "inject") {
  241. # Inject DLL to running Ragnarok process
  242. require Network::XKore;
  243. $net = new Network::XKore;
  244. } elsif ($XKore_version eq "2") {
  245. # Run as a proxy bot, allowing Ragnarok to connect while botting
  246. require Network::DirectConnection;
  247. require Network::XKore2;
  248. $net = new Network::DirectConnection;
  249. Network::XKore2::start();
  250. } elsif ($XKore_version eq "3" || $XKore_version eq "proxy") {
  251. # Proxy Ragnarok client connection
  252. require Network::XKoreProxy;
  253. $net = new Network::XKoreProxy;
  254. } else {
  255. # Run as a standalone bot, with no interface to the official RO client
  256. require Network::DirectConnection;
  257. $net = new Network::DirectConnection;
  258. }
  259. };
  260. if ($@) {
  261. # Problem with networking.
  262. $interface->errorDialog($@);
  263. exit 1;
  264. }
  266. if ($sys{bus}) {
  267. require Bus::Client;
  268. require Bus::Handlers;
  269. my $host = $sys{bus_server_host};
  270. my $port = $sys{bus_server_port};
  271. $host = undef if ($host eq '');
  272. $port = undef if ($port eq '');
  273. $bus = new Bus::Client(host => $host, port => $port);
  274. our $busMessageHandler = new Bus::Handlers($bus);
  275. }
  277. Network::PaddedPackets::init();
  278. }
  280. sub initPortalsDatabase {
  281. Log::message(T("Checking for new portals... "));
  282. if (compilePortals_check()) {
  283. Log::message(T("found new portals!n"));
  284. my $choice = $interface->showMenu(
  285. T("New portals have been added to the portals database. " .
  286. "The portals database must be compiled before the new portals can be used. " .
  287. "Would you like to compile portals now?n"),
  288. [T("Yes, compile now."), T("No, don't compile it.")],
  289. title => T("Compile portals?"));
  290. if ($choice == 0) {
  291. Log::message(T("compiling portals") . "nn");
  292. compilePortals();
  293. } else {
  294. Log::message(T("skipping compile") . "nn");
  295. }
  296. } else {
  297. Log::message(T("none foundnn"));
  298. }
  299. }
  301. sub promptFirstTimeInformation {
  302. if ($net->version != 1) {
  303. my $msg;
  304. if (!$config{username}) {
  305. $msg = $interface->query(T("Please enter your Ragnarok Online username."));
  306. if (!defined($msg)) {
  307. exit;
  308. }
  309. configModify('username', $msg, 1);
  310. }
  311. if (!$config{password}) {
  312. $msg = $interface->query(T("Please enter your Ragnarok Online password."), isPassword => 1);
  313. if (!defined($msg)) {
  314. exit;
  315. }
  316. configModify('password', $msg, 1);
  317. }
  318. }
  320. if ($config{master} eq "" || $config{master} =~ /^d+$/ || !exists $masterServers{$config{master}}) {
  321. my @servers = sort { lc($a) cmp lc($b) } keys(%masterServers);
  322. my $choice = $interface->showMenu(
  323. T("Please choose a master server to connect to."),
  324. @servers,
  325. title => T("Master servers"));
  326. if ($choice == -1) {
  327. exit;
  328. } else {
  329. configModify('master', $servers[$choice], 1);
  330. }
  331. }
  332. }
  334. sub finalInitialization {
  335. $incomingMessages = new Network::MessageTokenizer(%rpackets);
  336. $outgoingClientMessages = new Network::MessageTokenizer(%rpackets);
  338. $KoreStartTime = time;
  339. $conState = 1;
  340. our $nextConfChangeTime;
  341. $bExpSwitch = 2;
  342. $jExpSwitch = 2;
  343. $totalBaseExp = 0;
  344. $totalJobExp = 0;
  345. $startTime_EXP = time;
  346. $taskManager = new TaskManager();
  348. $itemsList = new ActorList('Actor::Item');
  349. $monstersList = new ActorList('Actor::Monster');
  350. $playersList = new ActorList('Actor::Player');
  351. $petsList = new ActorList('Actor::Pet');
  352. $npcsList = new ActorList('Actor::NPC');
  353. $portalsList = new ActorList('Actor::Portal');
  354. $slavesList = new ActorList('Actor::Slave');
  355. foreach my $list ($itemsList, $monstersList, $playersList, $petsList, $npcsList, $portalsList, $slavesList) {
  356. $list->onAdd()->add(undef, &actorAdded);
  357. $list->onRemove()->add(undef, &actorRemoved);
  358. $list->onClearBegin()->add(undef, &actorListClearing);
  359. }
  361. StdHttpReader::init();
  362. initStatVars();
  363. initRandomRestart();
  364. initUserSeed();
  365. initConfChange();
  366. Log::initLogFiles();
  367. $timeout{'injectSync'}{'time'} = time;
  369. Log::message("n");
  371. Plugins::callHook('initialized');
  372. XSTools::initVersion();
  373. }
  376. #######################################
  377. # VARIABLE INITIALIZATION FUNCTIONS
  378. #######################################
  380. # Calculate next random restart time.
  381. # The restart time will be autoRestartMin + rand(autoRestartSeed)
  382. sub initRandomRestart {
  383. if ($config{'autoRestart'}) {
  384. my $autoRestart = $config{'autoRestartMin'} + int(rand $config{'autoRestartSeed'});
  385. message TF("Next restart in %sn", timeConvert($autoRestart)), "system";
  386. configModify("autoRestart", $autoRestart, 1);
  387. }
  388. }
  390. # Initialize random configuration switching time
  391. sub initConfChange {
  392. my $i = 0;
  393. while (exists $ai_v{"autoConfChange_${i}_timeout"}) {
  394. delete $ai_v{"autoConfChange_${i}_timeout"};
  395. $i++;
  396. }
  398. $i = 0;
  399. while (exists $config{"autoConfChange_$i"}) {
  400. $ai_v{"autoConfChange_${i}_timeout"} = $config{"autoConfChange_${i}_minTime"} +
  401. int(rand($config{"autoConfChange_${i}_varTime"}));
  402. $i++;
  403. }
  404. $lastConfChangeTime = time;
  405. }
  407. # Initialize variables when you start a connection to a map server
  408. sub initConnectVars {
  409. # we must use $chars[$config{char}] here because $char may not be set
  410. initMapChangeVars();
  411. if ($char) {
  412. $char->{skills} = {};
  413. delete $char->{mute_period};
  414. delete $char->{muted};
  415. }
  416. undef @skillsID;
  417. $useArrowCraft = 1;
  418. }
  420. # Initialize variables when you change map (after a teleport or after you walked into a portal)
  421. sub initMapChangeVars {
  422. # we must use $chars[$config{char}] here because $char may not be set
  423. @portalsID_old = @portalsID;
  424. %portals_old = %portals;
  425. foreach (@portalsID_old) {
  426. next if (!$_ || !$portals_old{$_});
  427. $portals_old{$_}{gone_time} = time if (!$portals_old{$_}{gone_time});
  428. }
  430. # this is just used for portalRecord (add opposite portal by guessing method)
  431. if ($char) {
  432. $char->{old_pos_to} = {%{$char->{pos_to}}} if ($char->{pos_to});
  433. delete $char->{sitting};
  434. delete $char->{dead};
  435. delete $char->{warp};
  436. delete $char->{casting};
  437. delete $char->{homunculus}{appear_time};
  438. $char->inventory->clear();
  439. }
  440. $timeout{play}{time} = time;
  441. $timeout{ai_sync}{time} = time;
  442. $timeout{ai_sit_idle}{time} = time;
  443. $timeout{ai_teleport}{time} = time;
  444. $timeout{ai_teleport_idle}{time} = time;
  445. $timeout{ai_teleport_safe_force}{time} = time;
  447. delete $timeout{ai_teleport_retry}{time};
  448. delete $timeout{ai_teleport_delay}{time};
  450. undef %incomingDeal;
  451. undef %outgoingDeal;
  452. undef %currentDeal;
  453. undef $currentChatRoom;
  454. undef @currentChatRoomUsers;
  455. undef @itemsID;
  456. undef @identifyID;
  457. undef %repairList;
  458. undef @spellsID;
  459. undef @arrowCraftID;
  460. undef %items;
  461. undef %spells;
  462. undef %incomingParty;
  463. undef %talk;
  464. $ai_v{cart_time} = time + 60;
  465. $ai_v{inventory_time} = time + 60;
  466. $ai_v{temp} = {};
  467. $cart{inventory} = [];
  468. undef @venderItemList;
  469. undef $venderID;
  470. undef @venderListsID;
  471. undef %venderLists;
  472. undef %incomingGuild;
  473. undef @chatRoomsID;
  474. undef %chatRooms;
  475. undef %createdChatRoom;
  476. undef @lastpm;
  477. undef %incomingFriend;
  479. $itemsList->clear();
  480. $monstersList->clear();
  481. $playersList->clear();
  482. $petsList->clear();
  483. $portalsList->clear();
  484. $npcsList->clear();
  485. $slavesList->clear();
  487. @unknownPlayers = ();
  488. @unknownNPCs = ();
  489. @sellList = ();
  491. $shopstarted = 0;
  492. $timeout{ai_shop}{time} = time;
  493. $timeout{ai_storageAuto}{time} = time + 5;
  494. $timeout{ai_buyAuto}{time} = time + 5;
  495. $timeout{ai_shop}{time} = time;
  497. AI::clear("attack", "move");
  498. AI::SlaveManager::clear("attack", "route", "move");
  499. ChatQueue::clear;
  501. Plugins::callHook('packet_mapChange');
  503. $logAppend = ($config{logAppendUsername}) ? "_$config{username}_$config{char}" : '';
  504. if ($config{logAppendUsername} && index($Settings::storage_log_file, $logAppend) == -1) {
  505. $Settings::chat_log_file     = substr($Settings::chat_log_file,    0, length($Settings::chat_log_file)    - 4) . "$logAppend.txt";
  506. $Settings::storage_log_file  = substr($Settings::storage_log_file, 0, length($Settings::storage_log_file) - 4) . "$logAppend.txt";
  507. $Settings::shop_log_file     = substr($Settings::shop_log_file,    0, length($Settings::shop_log_file)    - 4) . "$logAppend.txt";
  508. $Settings::monster_log_file  = substr($Settings::monster_log_file, 0, length($Settings::monster_log_log)  - 4) . "$logAppend.txt";
  509. $Settings::item_log_file     = substr($Settings::item_log_file,    0, length($Settings::item_log_file)    - 4) . "$logAppend.txt";
  510. }
  511. }
  513. # Initialize variables when your character logs in
  514. sub initStatVars {
  515. $totaldmg = 0;
  516. $dmgpsec = 0;
  517. $startedattack = 0;
  518. $monstarttime = 0;
  519. $monkilltime = 0;
  520. $elasped = 0;
  521. $totalelasped = 0;
  522. $statChanged = 0;
  523. $skillChanged = 0;
  524. }
  527. #####################################################
  528. # MISC. MAIN LOOP FUNCTIONS
  529. #####################################################
  532. # This function is called every time in the main loop, when OpenKore has been
  533. # fully initialized.
  534. sub mainLoop_initialized {
  535. Benchmark::begin("mainLoop_part1") if DEBUG;
  537. # Handle connection states
  538. $net->checkConnection();
  540. # Receive and handle data from the RO server
  541. my $data = $net->serverRecv;
  542. if (defined($data) && length($data) > 0) {
  543. Benchmark::begin("parseMsg") if DEBUG;
  545. my $type;
  546. $incomingMessages->add($data);
  547. while ($data = $incomingMessages->readNext($type)) {
  548. if ($type == Network::MessageTokenizer::KNOWN_MESSAGE) {
  549. parseIncomingMessage($data);
  550. } else {
  551. if ($type == Network::MessageTokenizer::UNKNOWN_MESSAGE) {
  552. # Unknown message - ignore it
  553. my $messageID = Network::MessageTokenizer::getMessageID($data);
  554. if (!existsInList($config{debugPacket_exclude}, $messageID)) {
  555. warning TF("Unknown packet - %sn", $messageID), "connection";
  556. visualDump($data, "<< Received unknown packet") if ($config{debugPacket_unparsed});
  557. }
  558. } elsif ($config{debugPacket_received}) {
  559. debug "Received account IDn", "parseMsg", 0 ;
  560. }
  561. # Pass it along to the client, whatever it is
  562. $net->clientSend($data);
  563. }
  564. }
  565. $net->clientFlush() if (UNIVERSAL::isa($net, 'Network::XKoreProxy'));
  566. Benchmark::end("parseMsg") if DEBUG;
  567. }
  569. # Receive and handle data from the RO client
  570. $data = $net->clientRecv;
  571. if (defined($data) && length($data) > 0) {
  572. my $type;
  573. $outgoingClientMessages->add($data);
  574. while ($data = $outgoingClientMessages->readNext($type)) {
  575. parseOutgoingClientMessage($data);
  576. }
  577. }
  579. # GameGuard support
  580. if ($config{gameGuard} && ($net->version != 1 || ($net->version == 1 && $config{gameGuard} eq '2'))) {
  581. my $result = Poseidon::Client::getInstance()->getResult();
  582. if (defined($result)) {
  583. debug "Received Poseidon result.n", "poseidon";
  584. $messageSender->encryptMessageID($result);
  585. $net->serverSend($result);
  586. }
  587. }
  589. Benchmark::end("mainLoop_part1") if DEBUG;
  590. Benchmark::begin("mainLoop_part2") if DEBUG;
  592. # Process AI
  593. if ($net->getState() == Network::IN_GAME && timeOut($timeout{ai}) && $net->serverAlive()) {
  594. Misc::checkValidity("AI (pre)");
  595. Benchmark::begin("ai") if DEBUG;
  596. AI::CoreLogic::iterate();
  597. Benchmark::end("ai") if DEBUG;
  598. Benchmark::begin("ai_homunculus") if DEBUG;
  599. AI::SlaveManager::iterate();
  600. Benchmark::end("ai_homunculus") if DEBUG;
  601. Misc::checkValidity("AI");
  602. return if $quit;
  603. }
  604. Misc::checkValidity("mainLoop_part2.1");
  605. $taskManager->iterate();
  607. Benchmark::end("mainLoop_part2") if DEBUG;
  608. Benchmark::begin("mainLoop_part3") if DEBUG;
  610. # Process bus events.
  611. $bus->iterate() if ($bus);
  612. Misc::checkValidity("mainLoop_part2.2");
  615. ###### Other stuff that's run in the main loop #####
  617. if ($config{'autoRestart'} && time - $KoreStartTime > $config{'autoRestart'}
  618.  && $net->getState() == Network::IN_GAME && !AI::inQueue(qw/attack take items_take/)) {
  619. message T("nAuto-restarting!!n"), "system";
  621. if ($config{'autoRestartSleep'}) {
  622. my $sleeptime = $config{'autoSleepMin'} + int(rand $config{'autoSleepSeed'});
  623. $timeout_ex{'master'}{'timeout'} = $sleeptime;
  624. $sleeptime = $timeout{'reconnect'}{'timeout'} if ($sleeptime < $timeout{'reconnect'}{'timeout'});
  625. message TF("Sleeping for %sn", timeConvert($sleeptime)), "system";
  626. } else {
  627. $timeout_ex{'master'}{'timeout'} = $timeout{'reconnect'}{'timeout'};
  628. }
  630. $timeout_ex{'master'}{'time'} = time;
  631. $KoreStartTime = time + $timeout_ex{'master'}{'timeout'};
  632. AI::clear();
  633. AI::SlaveManager::clear();
  634. undef %ai_v;
  635. $net->serverDisconnect;
  636. $net->setState(Network::NOT_CONNECTED);
  637. undef $conState_tries;
  638. initRandomRestart();
  639. }
  641. Misc::checkValidity("mainLoop_part2.3");
  643. # Automatically switch to a different config file
  644. # based on certain conditions
  645. if ($net->getState() == Network::IN_GAME && timeOut($AI::Timeouts::autoConfChangeTime, 0.5)
  646.  && !AI::inQueue(qw/attack take items_take/)) {
  647. my $selected;
  648. my $i = 0;
  649. while (exists $config{"autoConfChange_$i"}) {
  650. if ($config{"autoConfChange_$i"}
  651.  && ( !$config{"autoConfChange_${i}_minTime"} || timeOut($lastConfChangeTime, $ai_v{"autoConfChange_${i}_timeout"}) )
  652.  && inRange($char->{lv}, $config{"autoConfChange_${i}_lvl"})
  653.  && inRange($char->{lv_job}, $config{"autoConfChange_${i}_joblvl"})
  654.  && ( !$config{"autoConfChange_${i}_isJob"} || $jobs_lut{$char->{jobID}} eq $config{"autoConfChange_${i}_isJob"} )
  655. ) {
  656. $selected = $config{"autoConfChange_$i"};
  657. last;
  658. }
  659. $i++;
  660. }
  662. if ($selected) {
  663. # Choose a random configuration file
  664. my @files = split(/,+/, $selected);
  665. my $file = $files[rand(@files)];
  666. message TF("Changing configuration file (from "%s" to "%s")...n", $Settings::config_file, $file), "system";
  668. # A relogin is necessary if the server host/port, username
  669. # or char is different.
  670. my $oldMaster = $masterServer;
  671. my $oldUsername = $config{'username'};
  672. my $oldChar = $config{'char'};
  674. switchConfigFile($file);
  676. my $master = $masterServer = $masterServers{$config{'master'}};
  677. if ($net->version != 1
  678.  && $oldMaster->{ip} ne $master->{ip}
  679.  || $oldMaster->{port} ne $master->{port}
  680.  || $oldMaster->{master_version} ne $master->{master_version}
  681.  || $oldMaster->{version} ne $master->{version}
  682.  || $oldUsername ne $config{'username'}
  683.  || $oldChar ne $config{'char'}) {
  684. AI::clear;
  685. AI::SlaveManager::clear();
  686. relog();
  687. } else {
  688. AI::clear("move", "route", "mapRoute");
  689. AI::SlaveManager::clear("move", "route", "mapRoute");
  690. }
  692. initConfChange();
  693. }
  695. $AI::Timeouts::autoConfChangeTime = time;
  696. }
  698. processStatisticsReporting() unless ($sys{sendAnonymousStatisticReport} eq "0");
  700. # Update state.yml
  701. if (timeOut($AI::Timeouts::stateUpdate, 0.5)) {
  702. my %state;
  703. my $f;
  704. $AI::Timeouts::stateUpdate = time;
  706. if ($field{name} && $net->getState() == Network::IN_GAME) {
  707. my $pos = calcPosition($char);
  708. %state = (
  709. connectionState => 'in game',
  710. fieldName => $field{name},
  711. fieldBaseName => $field{baseName},
  712. charName => $char->{name},
  713. x => $pos->{x},
  714. y => $pos->{y}
  715. );
  716. $state{actors} = {};
  717. foreach my $actor (@{$npcsList->getItems()}, @{$playersList->getItems()}, @{$monstersList->getItems()}, @{$slavesList->getItems()}) {
  718. my $actorType = $actor->{actorType};
  719. $state{actors}{$actorType} ||= [];
  720. push @{$state{actors}{$actorType}}, {
  721. x => $actor->{pos_to}{x},
  722. y => $actor->{pos_to}{y}
  723. };
  724. }
  725. } else {
  726. %state = (
  727. connectionState => 'not logged in'
  728. );
  729. }
  730. if ($bus && $bus->getState() == Bus::Client::CONNECTED()) {
  731. $state{bus}{host} = $bus->serverHost();
  732. $state{bus}{port} = $bus->serverPort();
  733. $state{bus}{clientID} = $bus->ID();
  734. }
  736. if (open($f, ">:utf8", "$Settings::logs_folder/state_".$config{'username'}.".yml")) {
  737. my $writer = new Data::YAML::Writer();
  738. $writer->write(%state, $f);
  739. close $f;
  740. }
  741. }
  743. Misc::checkValidity("mainLoop_part2.4");
  745. # Set interface title
  746. my $charName;
  747. my $title;
  748. $charName = "$char->{name}: " if ($char);
  749. if ($net->getState() == Network::IN_GAME) {
  750. my ($basePercent, $jobPercent, $weight, $pos);
  752. assert(defined $char);
  753. $basePercent = sprintf("%.2f", $char->{exp} / $char->{exp_max} * 100) if ($char->{exp_max});
  754. $jobPercent = sprintf("%.2f", $char->{exp_job} / $char->{exp_job_max} * 100) if ($char->{exp_job_max});
  755. $weight = int($char->{weight} / $char->{weight_max} * 100) . "%" if ($char->{weight_max});
  756. $pos = " : $char->{pos_to}{x},$char->{pos_to}{y} " . $field->name() if ($char->{pos_to} && $field);
  758. # Translation Comment: Interface Title with character status
  759. $title = TF("%s B%s (%s), J%s (%s) : w%s%s - %s",
  760. $charName, $char->{lv}, $basePercent . '%',
  761. $char->{lv_job}, $jobPercent . '%',
  762. $weight, $pos, $Settings::NAME);
  764. } elsif ($net->getState() == Network::NOT_CONNECTED) {
  765. # Translation Comment: Interface Title
  766. $title = TF("%sNot connected - %s", $charName, $Settings::NAME);
  767. } else {
  768. # Translation Comment: Interface Title
  769. $title = TF("%sConnecting - %s", $charName, $Settings::NAME);
  770. }
  771. my %args = (return => $title);
  772. Plugins::callHook('mainLoop::setTitle',%args);
  773. $interface->title($args{return});
  775. Misc::checkValidity("mainLoop_part3");
  776. Benchmark::end("mainLoop_part3") if DEBUG;
  777. }
  779. # Anonymous statistics reporting. This gives us insight about
  780. # servers that our users bot on.
  781. sub processStatisticsReporting {
  782. our %statisticsReporting;
  783. if (!$statisticsReporting{reported} && $config{master} && $config{username}) {
  784. if (!$statisticsReporting{http}) {
  785. use Utils qw(urlencode);
  786. import Utils::Whirlpool qw(whirlpool_hex);
  788. # Note that ABSOLUTELY NO SENSITIVE INFORMATION about the
  789. # user is sent. The username is filtered through an
  790. # irreversible hashing algorithm before it is sent to the
  791. # server. It is impossible to deduce the user's username
  792. # from the data sent to the server.
  793. #
  794. # If you're still not convinced about the security of this,
  795. # please read the following web pages for more details and explanation:
  796. #   http://www.openkore.com/statistics.php
  797. # -and-
  798. #   http://forums.openkore.com/viewtopic.php?t=28044
  799. my $url = "http://www.openkore.com/statistics.php";
  800. my $post = "server=" . urlencode($config{master});
  801. $post .= "&product=" . urlencode($Settings::NAME);
  802. $post .= "&version=" . urlencode($Settings::VERSION);
  803. $post .= "&uid=" . urlencode(whirlpool_hex($config{master} . $config{username} . $userSeed));
  804. $statisticsReporting{http} = new StdHttpReader($url, $post);
  805. debug "Posting anonymous usage statistics to $urln", "statisticsReporting";
  806. }
  808. my $http = $statisticsReporting{http};
  809. if ($http->getStatus() == HttpReader::DONE) {
  810. $statisticsReporting{reported} = 1;
  811. delete $statisticsReporting{http};
  812. debug "Statistics posting completed.n", "statisticsReporting";
  814. } elsif ($http->getStatus() == HttpReader::ERROR) {
  815. $statisticsReporting{reported} = 1;
  816. delete $statisticsReporting{http};
  817. debug "Statistics posting failed: " . $http->getError() . "n", "statisticsReporting";
  818. }
  820. } elsif (!$statisticsReporting{infoPosted} && $masterServer && $masterServer->{ip}
  821.       && $config{master} && $net && $net->getState() == Network::IN_GAME && $monstarttime) {
  822. if (!$statisticsReporting{http}) {
  823. my $url = "http://www.openkore.com/server-info.php";
  824. my $serverData = "";
  825. foreach my $key (sort keys %{$masterServer}) {
  826. $serverData .= "$key $masterServer->{$key}n";
  827. }
  828. my $post = "server=" . urlencode($config{master}) . "&data=" . urlencode($serverData);
  829. $statisticsReporting{http} = new StdHttpReader($url, $post);
  830. debug "Posting server info to $urln", "statisticsReporting";
  831. }
  833. my $http = $statisticsReporting{http};
  834. if ($http->getStatus() == HttpReader::DONE) {
  835. $statisticsReporting{infoPosted} = 1;
  836. delete $statisticsReporting{http};
  837. debug "Server info posting completed.n", "statisticsReporting";
  839. } elsif ($http->getStatus() == HttpReader::ERROR) {
  840. $statisticsReporting{infoPosted} = 1;
  841. delete $statisticsReporting{http};
  842. debug "Server info posting failed: " . $http->getError() . "n", "statisticsReporting";
  843. }
  844. }
  845. }
  847. sub parseInput {
  848. my $input = shift;
  849. my $printType;
  850. my ($hook, $msg);
  851. $printType = shift if ($net && $net->clientAlive);
  853. debug("Input: $inputn", "parseInput", 2);
  855. if ($printType) {
  856. my $hookOutput = sub {
  857. my ($type, $domain, $level, $globalVerbosity, $message, $user_data) = @_;
  858. $msg .= $message if ($type ne 'debug' && $level <= $globalVerbosity);
  859. };
  860. $hook = Log::addHook($hookOutput);
  861. $interface->writeOutput("console", "$inputn");
  862. }
  863. $XKore_dontRedirect = 1;
  865. Commands::run($input);
  867. if ($printType) {
  868. Log::delHook($hook);
  869. if (defined $msg && $net->getState() == Network::IN_GAME && $config{XKore_silent}) {
  870. $msg =~ s/n*$//s;
  871. $msg =~ s/n/\n/g;
  872. sendMessage($messageSender, "k", $msg);
  873. }
  874. }
  875. $XKore_dontRedirect = 0;
  876. }
  879. #######################################
  880. #######################################
  881. # Parse RO Client Send Message
  882. #######################################
  883. #######################################
  885. sub parseOutgoingClientMessage {
  886. use bytes;
  887. no encoding 'utf8';
  888. my ($msg) = @_;
  890. my $sendMsg = $msg;
  891. if (length($msg) >= 4 && $net->getState() >= 4 && length($msg) >= unpack("v1", substr($msg, 0, 2))) {
  892. Network::Receive->decrypt($msg, $msg);
  893. }
  894. my $switch = Network::MessageTokenizer::getMessageID($msg);
  895. if ($config{'debugPacket_ro_sent'} && !existsInList($config{'debugPacket_exclude'}, $switch)
  896.    || $config{debugPacket_include_dumpMethod} && existsInList($config{'debugPacket_include'}, $switch)) {
  897. my $label = $packetDescriptions{Send}{$switch} ?
  898. " - $packetDescriptions{Send}{$switch}" : '';
  900. if ($config{debugPacket_ro_sent} == 1) {
  901. debug "Packet SENT_BY_CLIENT: $switch$labeln", "parseSendMsg", 0;
  902. } elsif ($config{debugPacket_ro_sent} == 2) {
  903. visualDump($sendMsg, $switch . $label);
  904. }
  905. if ($config{debugPacket_include_dumpMethod} == 1) {
  906. debug "Packet: $switch$labeln", "parseMsg", 0;
  907. } elsif ($config{debugPacket_include_dumpMethod} == 2) {
  908. visualDump($sendMsg, $switch . $label);
  909. } elsif ($config{debugPacket_include_dumpMethod} == 3) {
  910. dumpData($msg,1);
  911. } elsif ($config{debugPacket_include_dumpMethod} == 4) {
  912. open DUMP, ">> DUMP_lines.txt";
  913. print DUMP sprintf(unpack('H*', $msg) . "n");
  914. close DUMP;
  915. }
  916. }
  918. Plugins::callHook('RO_sendMsg_pre', {switch => $switch, msg => $msg, realMsg => $sendMsg});
  920. my $serverType = $masterServer->{serverType};
  922. # If the player tries to manually do something in the RO client, disable AI for a small period
  923. # of time using ai_clientSuspend().
  925. if ($masterServer->{syncID} && $switch eq sprintf('%04X', hex($masterServer->{syncID}))) {
  926. #syncSync support for XKore 1 mode
  927. $syncSync = substr($msg, $masterServer->{syncTickOffset}, 4);
  929. } elsif ($switch eq "0065") {
  930. # Login to character server
  931. $incomingMessages->nextMessageMightBeAccountID();
  933. } elsif ($switch eq "0066") {
  934. # Login character selected
  935. configModify("char", unpack("C*",substr($msg, 2, 1)));
  937. } elsif (
  938. ($switch eq "0072" && ($serverType == 0 || $serverType == 21 || $serverType == 22)) ||
  939. ($switch eq "00F3" && $serverType == 18)
  940. ) {
  941. # Map login
  942. $incomingMessages->nextMessageMightBeAccountID();
  943. if ($serverType == 0 && $config{sex} ne "") {
  944. $sendMsg = substr($sendMsg, 0, 18) . pack("C",$config{'sex'});
  945. }
  947. } elsif ($switch eq "00A7") {
  948. if($masterServer && $masterServer->{paddedPackets}) {
  949. $syncSync = substr($msg, 8, 4);
  950. }
  952. } elsif ($switch eq "007E") {
  953. if ($masterServer && $masterServer->{paddedPackets}) {
  954. $syncSync = substr($msg, 4, 4);
  955. }
  957. } elsif ($switch eq "007D") {
  958. # Map loaded
  959. $packetParser->changeToInGameState();
  960. AI::clear("clientSuspend");
  961. $timeout{ai}{time} = time;
  962. if ($firstLoginMap) {
  963. undef $sentWelcomeMessage;
  964. undef $firstLoginMap;
  965. }
  966. $timeout{'welcomeText'}{'time'} = time;
  967. $ai_v{portalTrace_mapChanged} = time;
  968. # syncSync support for XKore 1 mode
  969. if($masterServer->{serverType} == 11) {
  970. $syncSync = substr($msg, 8, 4);
  971. } else {
  972. # formula: MapLoaded_len + Sync_len - 4 - Sync_packet_last_junk
  973. $syncSync = substr($msg, $masterServer->{mapLoadedTickOffset}, 4);
  974. }
  975. message T("Map loadedn"), "connection";
  977. Plugins::callHook('map_loaded');
  979. } elsif ($switch eq "0085") {
  980. #if ($masterServer->{serverType} == 0 || $masterServer->{serverType} == 1 || $masterServer->{serverType} == 2) {
  981. # #Move
  982. # AI::clear("clientSuspend");
  983. # makeCoords(%coords, substr($msg, 2, 3));
  984. # ai_clientSuspend($switch, (distance($char->{'pos'}, %coords) * $char->{walk_speed}) + 4);
  985. #}
  987. } elsif ($switch eq "0089") {
  988. if ($masterServer->{serverType} == 0) {
  989. # Attack
  990. if (!$config{'tankMode'} && !AI::inQueue("attack")) {
  991. AI::clear("clientSuspend");
  992. ai_clientSuspend($switch, 2, unpack("C*",substr($msg,6,1)), substr($msg,2,4));
  993. } else {
  994. undef $sendMsg;
  995. }
  996. }
  997. #undef $sendMsg;
  999. } elsif (($switch eq "008C" && ($masterServer->{serverType} == 0 || $masterServer->{serverType} == 1 || $masterServer->{serverType} == 2 || $masterServer->{serverType} == 6 || $masterServer->{serverType} == 7 || $masterServer->{serverType} == 10 || $masterServer->{serverType} == 11 || $masterServer->{serverType} == 21 || $masterServer->{serverType} == 22)) ||
  1000. ($switch eq "00F3" && ($masterServer->{serverType} == 3 || $masterServer->{serverType} == 5 || $masterServer->{serverType} == 8 || $masterServer->{serverType} == 9 || $masterServer->{serverType} == 15)) ||
  1001. ($switch eq "009F" && $masterServer->{serverType} == 4) ||
  1002. ($switch eq "007E" && $masterServer->{serverType} == 12) ||
  1003. ($switch eq "0190" && ($masterServer->{serverType} == 13 || $masterServer->{serverType} == 18)) ||
  1004. ($switch eq "0085" && $masterServer->{serverType} == 14) || # Public chat
  1006. $switch eq "0108" || # Party chat
  1008. $switch eq "017E") { # Guild chat
  1010. my $length = unpack("v",substr($msg,2,2));
  1011. my $message = substr($msg, 4, $length - 4);
  1012. my ($chat) = $message =~ /^[sS]*? : ([sS]*)00?/;
  1013. $chat =~ s/^s*//;
  1015. stripLanguageCode($chat);
  1017. my $prefix = quotemeta $config{'commandPrefix'};
  1018. if ($chat =~ /^$prefix/) {
  1019. $chat =~ s/^$prefix//;
  1020. $chat =~ s/^s*//;
  1021. $chat =~ s/s*$//;
  1022. $chat =~ s/00*$//;
  1023. parseInput($chat, 1);
  1024. undef $sendMsg;
  1025. }
  1027. } elsif ($switch eq "0096") {
  1028. # Private message
  1029. my $length = unpack("v",substr($msg,2,2));
  1030. my ($user) = substr($msg, 4, 24) =~ /([sS]*?)00/;
  1031. my $chat = substr($msg, 28, $length - 29);
  1032. $chat =~ s/^s*//;
  1034. # Ensures: $user and $chat are String
  1035. $user = I18N::bytesToString($user);
  1036. $chat = I18N::bytesToString($chat);
  1037. stripLanguageCode($chat);
  1039. my $prefix = quotemeta $config{commandPrefix};
  1040. if ($chat =~ /^$prefix/) {
  1041. $chat =~ s/^$prefix//;
  1042. $chat =~ s/^s*//;
  1043. $chat =~ s/s*$//;
  1044. parseInput($chat, 1);
  1045. undef $sendMsg;
  1046. } else {
  1047. undef %lastpm;
  1048. $lastpm{msg} = $chat;
  1049. $lastpm{user} = $user;
  1050. push @lastpm, {%lastpm};
  1051. }
  1053. } elsif (($switch eq "009B" && $masterServer->{serverType} == 0) ||
  1054. ($switch eq "009B" && $masterServer->{serverType} == 1) ||
  1055. ($switch eq "009B" && $masterServer->{serverType} == 2) ||
  1056. ($switch eq "0085" && $masterServer->{serverType} == 3) ||
  1057. ($switch eq "00F3" && $masterServer->{serverType} == 4) ||
  1058. ($switch eq "0085" && $masterServer->{serverType} == 5) ||
  1059. #($switch eq "009B" && $masterServer->{serverType} == 6) || serverType 6 uses what?
  1060. ($switch eq "009B" && $masterServer->{serverType} == 7) ||
  1061. ($switch eq "0072" && $masterServer->{serverType} == 13)) { # rRO
  1062. # Look
  1064. if ($char) {
  1065. if ($masterServer->{serverType} == 0) {
  1066. $char->{look}{head} = unpack("C", substr($msg, 2, 1));
  1067. $char->{look}{body} = unpack("C", substr($msg, 4, 1));
  1068. } elsif ($masterServer->{serverType} == 1 ||
  1069. $masterServer->{serverType} == 2 ||
  1070. $masterServer->{serverType} == 4 ||
  1071. $masterServer->{serverType} == 7) {
  1072. $char->{look}{head} = unpack("C", substr($msg, 6, 1));
  1073. $char->{look}{body} = unpack("C", substr($msg, 14, 1));
  1074. } elsif ($masterServer->{serverType} == 3) {
  1075. $char->{look}{head} = unpack("C", substr($msg, 12, 1));
  1076. $char->{look}{body} = unpack("C", substr($msg, 22, 1));
  1077. } elsif ($masterServer->{serverType} == 5) {
  1078. $char->{look}{head} = unpack("C", substr($msg, 8, 1));
  1079. $char->{look}{body} = unpack("C", substr($msg, 16, 1));
  1080. } elsif ($masterServer->{serverType} == 13) { # rRO
  1081. $char->{look}{head} = unpack("C", substr($msg, 2, 1));
  1082. $char->{look}{body} = unpack("C", substr($msg, 4, 1));
  1083. }
  1084. }
  1086. } elsif ($switch eq "009F") {
  1087. if ($masterServer->{serverType} == 0) {
  1088. # Take
  1089. AI::clear("clientSuspend");
  1090. ai_clientSuspend($switch, 2, substr($msg,2,4));
  1091. }
  1093. } elsif ($switch eq "00B2") {
  1094. # Trying to exit (respawn)
  1095. AI::clear("clientSuspend");
  1096. ai_clientSuspend($switch, 10);
  1098. } elsif ($switch eq "018A") {
  1099. # Trying to exit
  1100. AI::clear("clientSuspend");
  1101. ai_clientSuspend($switch, 10);
  1103. } elsif ($switch eq "0149") {
  1104. # Chat/skill mute
  1105. undef $sendMsg;
  1107. } elsif ($switch eq "01B2") {
  1108. # client started a shop manually
  1109. $shopstarted = 1;
  1111. } elsif ($switch eq "012E") {
  1112. # client stopped shop manually
  1113. $shopstarted = 0;
  1114. }
  1116. if ($sendMsg ne "") {
  1117. $messageSender->encryptMessageID($sendMsg);
  1118. $net->serverSend($sendMsg);
  1119. }
  1121. # This should be changed to packets that haven't been parsed yet, in a similar manner
  1122. # as parseMsg
  1123. return "";
  1124. }
  1127. #######################################
  1128. #######################################
  1129. #Parse Message
  1130. #######################################
  1131. #######################################
  1134. ##
  1135. # void parseIncomingMessage(Bytes msg)
  1136. # msg: The data to parse, as received from the socket.
  1137. #
  1138. # Parse network data sent by the RO server.
  1139. sub parseIncomingMessage {
  1140. my ($msg) = @_;
  1142. # Determine packet switch
  1143. my $switch = Network::MessageTokenizer::getMessageID($msg);
  1144. if (length($msg) >= 4 && substr($msg, 0, 4) ne $accountID && $net->getState() >= Network::CONNECTED_TO_CHAR_SERVER
  1145.  && $lastswitch ne $switch && length($msg) >= unpack("v1", substr($msg, 0, 2))) {
  1146. # The decrypt below casued annoying unparsed errors (at least in serverType  2)
  1147. if ($masterServer->{serverType} != 2) {
  1148. Network::Receive->decrypt($msg, $msg);
  1149. $switch = Network::MessageTokenizer::getMessageID($msg);
  1150. }
  1151. }
  1153. # The user is running in X-Kore mode and wants to switch character or gameGuard type 2 after 0259 tag 02.
  1154. # We're now expecting an accountID, unless the server has replicated packet 0259 (server-side bug).
  1155. if ($net->getState() == 2.5 && (!$config{gameGuard} || ($switch ne '0259' && $config{gameGuard} eq "2"))) {
  1156. if (length($msg) >= 4) {
  1157. $net->setState(Network::CONNECTED_TO_MASTER_SERVER);
  1158. $accountID = substr($msg, 0, 4);
  1159. debug "Selecting character, new accountID: ".unpack("V", $accountID)."n", "connection";
  1160. $net->clientSend($accountID);
  1161. return substr($msg, 4);
  1162. } else {
  1163. return $msg;
  1164. }
  1165. }
  1167. $lastswitch = $switch;
  1168. if ($config{debugPacket_received} && !existsInList($config{'debugPacket_exclude'}, $switch)) {
  1169. my $label = $packetDescriptions{Recv}{$switch} ?
  1170. "[$packetDescriptions{Recv}{$switch}]" : '';
  1171. if ($config{debugPacket_received} == 1) {
  1172. debug sprintf("Received packet: %-4s    [%2d bytes]  %sn", $switch, length($msg), $label),
  1173. "parseMsg", 0;
  1174. } else {
  1175. visualDump($msg, "<< Received packet: $switch  $label");
  1176. }
  1177. }
  1179. if ($config{debugPacket_include_dumpMethod} && existsInList($config{'debugPacket_include'}, $switch)) {
  1180. my $label = $packetDescriptions{Recv}{$switch} ?
  1181. " ($packetDescriptions{Recv}{$switch})" : '';
  1182. if ($config{debugPacket_include_dumpMethod} == 1) {
  1183. debug "Packet: $switch$labeln", "parseMsg", 0;
  1184. } elsif ($config{debugPacket_include_dumpMethod} == 2) {
  1185. visualDump($msg, "$switch$label");
  1186. } elsif ($config{debugPacket_include_dumpMethod} == 3) {
  1187. dumpData($msg,1);
  1188. } elsif ($config{debugPacket_include_dumpMethod} == 4) {
  1189. open DUMP, ">> DUMP_lines.txt";
  1190. print DUMP sprintf(unpack('H*', $msg) . "n");
  1191. close DUMP;
  1192. }
  1193. }
  1195. Plugins::callHook('parseMsg/pre', {switch => $switch, msg => $msg, msg_size => length($msg)});
  1197. if (!$packetParser->willMangle($switch)) {
  1198. # If we're running in X-Kore mode, pass the message back to the RO client.
  1199. $net->clientSend($msg);
  1200. }
  1202. $lastPacketTime = time;
  1203. if ($packetParser &&
  1204. (my $args = $packetParser->parse($msg))) {
  1205. # Use the new object-oriented packet parser
  1206. if ($config{debugPacket_received} > 2 &&
  1207.     !existsInList($config{'debugPacket_exclude'}, $switch)) {
  1208. my $switch = $args->{switch};
  1209. my $packet = $packetParser->{packet_list}{$switch};
  1210. my ($name, $packString, $varNames) = @{$packet};
  1212. my @vars = ();
  1213. for my $varName (@{$varNames}) {
  1214. message "$varName = $args->{$varName}n";
  1215. }
  1216. }
  1218. if ($packetParser->willMangle($switch)) {
  1219. my $ret = $packetParser->mangle($args);
  1220. if (!$ret) {
  1221. # Packet was not mangled
  1222. $net->clientSend($args->{RAW_MSG});
  1223. } elsif ($ret == 1) {
  1224. # Packet was mangled
  1225. $net->clientSend($packetParser->reconstruct($args));
  1226. } else {
  1227. # Packet was suppressed
  1228. }
  1229. }
  1230. }
  1231. }
  1233. return 1;