// Generated by CoffeeScript 2.5.1 (function() { // 标准库 var CLIENT_get_authorize_key, CLIENT_get_kick_reconnect_target, CLIENT_heartbeat_register, CLIENT_heartbeat_unregister, CLIENT_import_data, CLIENT_is_able_to_kick_reconnect, CLIENT_is_able_to_reconnect, CLIENT_is_banned_by_mc, CLIENT_is_player, CLIENT_kick, CLIENT_kick_reconnect, CLIENT_pre_reconnect, CLIENT_reconnect, CLIENT_reconnect_register, CLIENT_reconnect_unregister, CLIENT_send_pre_reconnect_info, CLIENT_send_reconnect_info, CLIENT_send_replays, Q, ROOM_all, ROOM_bad_ip, ROOM_ban_player, ROOM_clear_disconnect, ROOM_connected_ip, ROOM_find_by_name, ROOM_find_by_pid, ROOM_find_by_port, ROOM_find_by_title, ROOM_find_or_create_ai, ROOM_find_or_create_by_name, ROOM_find_or_create_random, ROOM_kick, ROOM_player_flee, ROOM_player_get_score, ROOM_player_lose, ROOM_player_win, ROOM_players_oppentlist, ROOM_players_scores, ROOM_unwelcome, ROOM_validate, ReplayParser, ResolveData, Room, SERVER_clear_disconnect, SERVER_kick, SOCKET_flush_data, _, _async, addCallback, athleticChecker, auth, axios, badwords, ban_user, bunyan, challonge, challonge_cache, challonge_queue_callbacks, checkFileExists, createDirectoryIfNotExists, crypto, dataManager, deck_name_match, dialogues, disconnect_list, exec, execFile, fs, geoip, getSeedTimet, get_callback, get_memory_usage, http, httpRequestListener, importOldConfig, import_datas, init, is_challonge_requesting, lflists, loadJSON, loadJSONAsync, loadLFList, loadRemoteData, load_dialogues, load_tips, log, long_resolve_cards, memory_usage, merge, moment, net, netRequestHandler, os, path, qs, real_windbot_server_ip, refresh_challonge_cache, release_disconnect, replaced_index, report_to_big_brother, request, roomlist, setting_change, setting_save, settings, spawn, spawnSync, spawn_windbot, tips, url, users_cache, util, wait_room_start, wait_room_start_arena, windbot_looplimit, windbot_process, ygopro, zlib; net = require('net'); http = require('http'); url = require('url'); path = require('path'); fs = require('fs'); os = require('os'); crypto = require('crypto'); exec = require('child_process').exec; execFile = require('child_process').execFile; spawn = require('child_process').spawn; spawnSync = require('child_process').spawnSync; _async = require('async'); // 三方库 _ = global._ = require('underscore'); _.str = require('underscore.string'); _.mixin(_.str.exports()); request = require('request'); axios = require('axios'); qs = require("querystring"); zlib = require('zlib'); axios = require('axios'); bunyan = require('bunyan'); log = global.log = bunyan.createLogger({ name: "mycard" }); moment = global.moment = require('moment'); moment.updateLocale('zh-cn', { relativeTime: { future: '%s内', past: '%s前', s: '%d秒', m: '1分钟', mm: '%d分钟', h: '1小时', hh: '%d小时', d: '1天', dd: '%d天', M: '1个月', MM: '%d个月', y: '1年', yy: '%d年' } }); import_datas = global.import_datas = ["abuse_count", "ban_mc", "vpass", "rag", "rid", "is_post_watcher", "retry_count", "name", "pass", "name_vpass", "is_first", "lp", "card_count", "is_host", "pos", "surrend_confirm", "kick_count", "deck_saved", "main", "side", "side_interval", "side_tcount", "selected_preduel", "last_game_msg", "last_game_msg_title", "last_hint_msg", "start_deckbuf", "challonge_info", "ready_trap", "join_time", "arena_quit_free", "replays_sent"]; merge = require('deepmerge'); loadJSON = require('load-json-file').sync; loadJSONAsync = require('load-json-file'); util = require("util"); Q = require("q"); //heapdump = require 'heapdump' checkFileExists = async(path) => { var e; try { await fs.promises.access(path); return true; } catch (error1) { e = error1; return false; } }; createDirectoryIfNotExists = async(path) => { if (!(await checkFileExists(path))) { return (await fs.promises.mkdir(path, { recursive: true })); } }; setting_save = global.setting_save = async function(settings) { var e; try { await fs.promises.writeFile(settings.file, JSON.stringify(settings, null, 2)); } catch (error1) { e = error1; log.warn("setting save fail", e.toString()); } }; setting_change = global.setting_change = async function(settings, path, val) { var key, target; if (_.isString(val)) { // path should be like "modules:welcome" log.info("setting changed", path, val); } path = path.split(':'); if (path.length === 0) { settings[path[0]] = val; } else { target = settings; while (path.length > 1) { key = path.shift(); target = target[key]; } key = path.shift(); target[key] = val; } await setting_save(settings); }; importOldConfig = async function() { var e, oldbadwords, oldconfig, olddialogues, oldtips; try { oldconfig = (await loadJSONAsync('./config.user.json')); if (oldconfig.tips) { oldtips = {}; oldtips.file = './config/tips.json'; oldtips.tips = oldconfig.tips; await fs.promises.writeFile(oldtips.file, JSON.stringify(oldtips, null, 2)); delete oldconfig.tips; } if (oldconfig.dialogues) { olddialogues = {}; olddialogues.file = './config/dialogues.json'; olddialogues.dialogues = oldconfig.dialogues; await fs.promises.writeFile(olddialogues.file, JSON.stringify(olddialogues, null, 2)); delete oldconfig.dialogues; } oldbadwords = {}; if (oldconfig.ban) { if (oldconfig.ban.badword_level0) { oldbadwords.level0 = oldconfig.ban.badword_level0; } if (oldconfig.ban.badword_level1) { oldbadwords.level1 = oldconfig.ban.badword_level1; } if (oldconfig.ban.badword_level2) { oldbadwords.level2 = oldconfig.ban.badword_level2; } if (oldconfig.ban.badword_level3) { oldbadwords.level3 = oldconfig.ban.badword_level3; } } if (!_.isEmpty(oldbadwords)) { oldbadwords.file = './config/badwords.json'; await fs.promises.writeFile(oldbadwords.file, JSON.stringify(oldbadwords, null, 2)); delete oldconfig.ban.badword_level0; delete oldconfig.ban.badword_level1; delete oldconfig.ban.badword_level2; delete oldconfig.ban.badword_level3; } if (!_.isEmpty(oldconfig)) { // log.info oldconfig await fs.promises.writeFile('./config/config.json', JSON.stringify(oldconfig, null, 2)); log.info('imported old config from config.user.json'); } return (await fs.promises.rename('./config.user.json', './config.user.bak')); } catch (error1) { e = error1; if (e.code !== 'ENOENT') { return log.info(e); } } }; auth = global.auth = require('./ygopro-auth.js'); ygopro = global.ygopro = require('./ygopro.js'); roomlist = null; settings = {}; tips = null; dialogues = null; badwords = null; lflists = global.lflists = []; real_windbot_server_ip = null; long_resolve_cards = []; ReplayParser = null; athleticChecker = null; users_cache = {}; geoip = null; dataManager = null; disconnect_list = {}; // {old_client, old_server, room_id, timeout, deckbuf} challonge = null; challonge_cache = { participants: null, matches: null }; challonge_queue_callbacks = { participants: [], matches: [] }; is_challonge_requesting = { participants: null, matches: null }; get_callback = function() {}; replaced_index = function() {}; refresh_challonge_cache = function() {}; ResolveData = (function() { class ResolveData { constructor(func) { this.func = func; } resolve(err, data) { if (this.resolved) { return false; } this.resolved = true; this.func(err, data); return true; } }; ResolveData.prototype.resolved = false; return ResolveData; }).call(this); loadLFList = function(path) { var date, j, len, list, ref, results; try { ref = fs.promises.readFile(path, 'utf8').match(/!.*/g); results = []; for (j = 0, len = ref.length; j < len; j++) { list = ref[j]; date = list.match(/!([\d\.]+)/); if (!date) { continue; } results.push(lflists.push({ date: moment(list.match(/!([\d\.]+)/)[1], 'YYYY.MM.DD').utcOffset("-08:00"), tcg: list.indexOf('TCG') !== -1 })); } return results; } catch (error1) { } }; init = async function() { var AthleticChecker, DataManager, challonge_module_name, challonge_type, chat_color, config, cppversion, defaultConfig, default_data, dns, e, http_server, https, https_server, imported, j, l, len, len1, len2, m, mkdirList, options, pgClient, pg_client, pg_query, plugin_filename, plugin_list, plugin_path, postData, ref, results, windbots; await createDirectoryIfNotExists("./config"); await importOldConfig(); defaultConfig = (await loadJSONAsync('./data/default_config.json')); if ((await checkFileExists("./config/config.json"))) { try { config = (await loadJSONAsync('./config/config.json')); } catch (error1) { e = error1; console.error("Failed reading config: ", e.toString()); process.exit(1); } } else { config = {}; } settings = global.settings = merge(defaultConfig, config, { arrayMerge: function(destination, source) { return source; } }); //import old configs imported = false; //reset http.quick_death_rule from true to 1 if (settings.modules.http.quick_death_rule === true) { settings.modules.http.quick_death_rule = 1; imported = true; } //import the old passwords to new admin user system if (settings.modules.http.password) { await auth.add_user("olduser", settings.modules.http.password, true, { "get_rooms": true, "shout": true, "stop": true, "change_settings": true, "ban_user": true, "kick_user": true, "start_death": true }); delete settings.modules.http.password; imported = true; } if (settings.modules.tournament_mode.password) { await auth.add_user("tournament", settings.modules.tournament_mode.password, true, { "duel_log": true, "download_replay": true, "clear_duel_log": true, "deck_dashboard_read": true, "deck_dashboard_write": true }); delete settings.modules.tournament_mode.password; imported = true; } if (settings.modules.pre_util.password) { await auth.add_user("pre", settings.modules.pre_util.password, true, { "pre_dashboard": true }); delete settings.modules.pre_util.password; imported = true; } if (settings.modules.update_util.password) { await auth.add_user("update", settings.modules.update_util.password, true, { "update_dashboard": true }); delete settings.modules.update_util.password; imported = true; } //import the old enable_priority hostinfo if (settings.hostinfo.enable_priority || settings.hostinfo.enable_priority === false) { if (settings.hostinfo.enable_priority) { settings.hostinfo.duel_rule = 3; } else { settings.hostinfo.duel_rule = 5; } delete settings.hostinfo.enable_priority; imported = true; } //import the old Challonge api key option if (settings.modules.challonge.api_key) { settings.modules.challonge.options.apiKey = settings.modules.challonge.api_key; delete settings.modules.challonge.api_key; imported = true; } //import the old random_duel.blank_pass_match option if (settings.modules.random_duel.blank_pass_match === true) { settings.modules.random_duel.blank_pass_modes = { "S": true, "M": true, "T": false }; delete settings.modules.random_duel.blank_pass_match; imported = true; } if (settings.modules.random_duel.blank_pass_match === false) { settings.modules.random_duel.blank_pass_modes = { "S": true, "M": false, "T": false }; delete settings.modules.random_duel.blank_pass_match; imported = true; } //finish if (imported) { await setting_save(settings); } // 读取数据 default_data = (await loadJSONAsync('./data/default_data.json')); try { tips = global.tips = (await loadJSONAsync('./config/tips.json')); } catch (error1) { tips = global.tips = default_data.tips; await setting_save(tips); } try { dialogues = global.dialogues = (await loadJSONAsync('./config/dialogues.json')); } catch (error1) { dialogues = global.dialogues = default_data.dialogues; await setting_save(dialogues); } try { badwords = global.badwords = (await loadJSONAsync('./config/badwords.json')); } catch (error1) { badwords = global.badwords = default_data.badwords; await setting_save(badwords); } if (settings.modules.chat_color.enabled) { try { chat_color = global.chat_color = (await loadJSONAsync('./config/chat_color.json')); } catch (error1) { chat_color = global.chat_color = default_data.chat_color; await setting_save(chat_color); } } try { cppversion = parseInt((await fs.promises.readFile('ygopro/gframe/game.cpp', 'utf8').match(/PRO_VERSION = ([x\dABCDEF]+)/)[1]), '16'); await setting_change(settings, "version", cppversion); log.info("ygopro version 0x" + settings.version.toString(16), "(from source code)"); } catch (error1) { //settings.version = settings.version_default log.info("ygopro version 0x" + settings.version.toString(16), "(from config)"); } // load the lflist of current date await loadLFList('ygopro/expansions/lflist.conf'); await loadLFList('ygopro/lflist.conf'); if (settings.modules.windbot.enabled) { windbots = global.windbots = (await loadJSONAsync(settings.modules.windbot.botlist).windbots); real_windbot_server_ip = global.real_windbot_server_ip = settings.modules.windbot.server_ip; if (!settings.modules.windbot.server_ip.includes("127.0.0.1")) { dns = require('dns'); real_windbot_server_ip = global.real_windbot_server_ip = (await util.promisify(dns.lookup)(settings.modules.windbot.server_ip)); } } if (settings.modules.heartbeat_detection.enabled) { long_resolve_cards = global.long_resolve_cards = (await loadJSONAsync('./data/long_resolve_cards.json')); } if (settings.modules.tournament_mode.enable_recover) { ReplayParser = global.ReplayParser = require("./Replay.js"); } if (settings.modules.athletic_check.enabled) { AthleticChecker = require("./athletic-check.js").AthleticChecker; athleticChecker = global.athleticChecker = new AthleticChecker(settings.modules.athletic_check); } if (settings.modules.http.websocket_roomlist) { roomlist = global.roomlist = require('./roomlist.js'); } if (settings.modules.i18n.auto_pick) { geoip = require('geoip-country-lite'); } if (settings.modules.mysql.enabled) { DataManager = require('./data-manager/DataManager.js').DataManager; dataManager = global.dataManager = new DataManager(settings.modules.mysql.db, log); await dataManager.init(); } else { log.warn("Some functions may be limited without MySQL ."); if (settings.modules.cloud_replay.enabled) { settings.modules.cloud_replay.enabled = false; await setting_save(settings); log.warn("Cloud replay cannot be enabled because no MySQL."); } if (settings.modules.enable_recover.enabled) { settings.modules.enable_recover.enabled = false; await setting_save(settings); log.warn("Recover mode cannot be enabled because no MySQL."); } if (settings.modules.chat_color.enabled) { settings.modules.chat_color.enabled = false; await setting_save(settings); log.warn("Chat color cannot be enabled because no MySQL."); } } if (settings.modules.mycard.enabled) { pgClient = require('pg').Client; pg_client = global.pg_client = new pgClient(settings.modules.mycard.auth_database); pg_client.on('error', function(err) { log.warn("PostgreSQL ERROR: ", err); }); pg_query = pg_client.query('SELECT username, id from users'); pg_query.on('error', function(err) { log.warn("PostgreSQL Query ERROR: ", err); }); pg_query.on('row', function(row) { //log.info "load user", row.username, row.id users_cache[row.username] = row.id; }); pg_query.on('end', function(result) { log.info("users loaded", result.rowCount); }); pg_client.on('drain', pg_client.end.bind(pg_client)); log.info("loading mycard user..."); pg_client.connect(); if (settings.modules.arena_mode.enabled && settings.modules.arena_mode.init_post.enabled) { postData = qs.stringify({ ak: settings.modules.arena_mode.init_post.accesskey, arena: settings.modules.arena_mode.mode }); try { await axios.post(settings.modules.arena_mode.init_post.url + "?" + postData, { responseType: "json" }); } catch (error1) { e = error1; log.warn('ARENA INIT POST ERROR', e); } } } if (settings.modules.challonge.enabled) { challonge_module_name = 'challonge'; if (settings.modules.challonge.use_custom_module) { challonge_module_name = settings.modules.challonge.use_custom_module; } challonge = global.challonge = require(challonge_module_name).createClient(settings.modules.challonge.options); challonge_cache = { participants: null, matches: null }; challonge_queue_callbacks = { participants: [], matches: [] }; is_challonge_requesting = { participants: null, matches: null }; get_callback = function(challonge_type, resolve_data) { return (function(err, data) { var cur_resolve_data; if (settings.modules.challonge.cache_ttl && !err && data) { challonge_cache[challonge_type] = data; } is_challonge_requesting[challonge_type] = null; resolve_data.resolve(err, data); while (challonge_queue_callbacks[challonge_type].length) { cur_resolve_data = challonge_queue_callbacks[challonge_type].splice(0, 1)[0]; cur_resolve_data.resolve(err, data); } }); }; replaced_index = function(challonge_type) { return function(_data) { var err, resolve_data; resolve_data = new ResolveData(_data.callback); if (settings.modules.challonge.cache_ttl && !_data.no_cache && challonge_cache[challonge_type]) { resolve_data.resolve(null, challonge_cache[challonge_type]); } else if (is_challonge_requesting[challonge_type] && moment() - is_challonge_requesting[challonge_type] <= 5000) { challonge_queue_callbacks[challonge_type].push(resolve_data); } else { _data.callback = get_callback(challonge_type, resolve_data); is_challonge_requesting[challonge_type] = moment(); try { challonge[challonge_type].index(_data); } catch (error1) { err = error1; _data.callback(err, null); } } }; }; ref = ["participants", "matches"]; for (j = 0, len = ref.length; j < len; j++) { challonge_type = ref[j]; challonge[challonge_type]._index = replaced_index(challonge_type); } challonge.matches._update = function(_data) { var err; try { challonge.matches.update(_data); } catch (error1) { err = error1; log.warn("Errored pushing scores to Challonge.", err); } }; refresh_challonge_cache = global.refresh_challonge_cache = function() { if (settings.modules.challonge.cache_ttl) { challonge_cache.participants = null; challonge_cache.matches = null; } }; refresh_challonge_cache(); if (settings.modules.challonge.cache_ttl) { setInterval(refresh_challonge_cache, settings.modules.challonge.cache_ttl); } } if (settings.modules.tips.get) { load_tips(); setInterval(function() { var l, len1, room; for (l = 0, len1 = ROOM_all.length; l < len1; l++) { room = ROOM_all[l]; if (room && room.established) { if (room.duel_stage === ygopro.constants.DUEL_STAGE.SIDING || room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN) { ygopro.stoc_send_random_tip_to_room(room); } } } }, 30000); } if (settings.modules.dialogues.get) { load_dialogues(); } if (settings.modules.random_duel.post_match_scores) { setInterval(function() { var scores, scores_by_lose, scores_by_win, scores_pair; scores_pair = _.pairs(ROOM_players_scores); scores_by_lose = _.sortBy(scores_pair, function(score) { return score[1].lose; }).reverse(); // 败场由高到低 scores_by_win = _.sortBy(scores_by_lose, function(score) { return score[1].win; }).reverse(); // 然后胜场由低到高，再逆转，就是先排胜场再排败场 scores = _.first(scores_by_win, 10); //log.info scores request.post({ url: settings.modules.random_duel.post_match_scores, form: { accesskey: settings.modules.random_duel.post_match_accesskey, rank: JSON.stringify(scores) } }, (error, response, body) => { if (error) { log.warn('RANDOM SCORE POST ERROR', error); } else { if (response.statusCode !== 204 && response.statusCode !== 200) { log.warn('RANDOM SCORE POST FAIL', response.statusCode, response.statusMessage, body); } } }); //else // log.info 'RANDOM SCORE POST OK', response.statusCode, response.statusMessage }, 60000); } if (settings.modules.random_duel.enabled) { setInterval(async function() { var l, len1, room, time_passed; for (l = 0, len1 = ROOM_all.length; l < len1; l++) { room = ROOM_all[l]; if (!(room && room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && room.random_type && room.last_active_time && room.waiting_for_player && room.get_disconnected_count() === 0 && (!settings.modules.side_timeout || room.duel_stage !== ygopro.constants.DUEL_STAGE.SIDING) && !room.recovered)) { continue; } time_passed = Math.floor((moment() - room.last_active_time) / 1000); //log.info time_passed if (time_passed >= settings.modules.random_duel.hang_timeout) { room.last_active_time = moment(); await ROOM_ban_player(room.waiting_for_player.name, room.waiting_for_player.ip, "${random_ban_reason_AFK}"); room.scores[room.waiting_for_player.name_vpass] = -9; //log.info room.waiting_for_player.name, room.scores[room.waiting_for_player.name_vpass] ygopro.stoc_send_chat_to_room(room, `${room.waiting_for_player.name} \${kicked_by_system}`, ygopro.constants.COLORS.RED); CLIENT_send_replays(room.waiting_for_player, room); CLIENT_kick(room.waiting_for_player); } else if (time_passed >= (settings.modules.random_duel.hang_timeout - 20) && !(time_passed % 10)) { ygopro.stoc_send_chat_to_room(room, `${room.waiting_for_player.name} \${afk_warn_part1}${settings.modules.random_duel.hang_timeout - time_passed}\${afk_warn_part2}`, ygopro.constants.COLORS.RED); ROOM_unwelcome(room, room.waiting_for_player, "${random_ban_reason_AFK}"); } } }, 1000); } if (settings.modules.mycard.enabled) { setInterval(function() { var l, len1, len2, m, player, room, time_passed, waited_time; for (l = 0, len1 = ROOM_all.length; l < len1; l++) { room = ROOM_all[l]; if (!(room && room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && room.arena && room.last_active_time && room.waiting_for_player && room.get_disconnected_count() === 0 && (!settings.modules.side_timeout || room.duel_stage !== ygopro.constants.DUEL_STAGE.SIDING) && !room.recovered)) { continue; } time_passed = Math.floor((moment() - room.last_active_time) / 1000); //log.info time_passed if (time_passed >= settings.modules.random_duel.hang_timeout) { room.last_active_time = moment(); ygopro.stoc_send_chat_to_room(room, `${room.waiting_for_player.name} \${kicked_by_system}`, ygopro.constants.COLORS.RED); room.scores[room.waiting_for_player.name_vpass] = -9; //log.info room.waiting_for_player.name, room.scores[room.waiting_for_player.name_vpass] CLIENT_send_replays(room.waiting_for_player, room); CLIENT_kick(room.waiting_for_player); } else if (time_passed >= (settings.modules.random_duel.hang_timeout - 20) && !(time_passed % 10)) { ygopro.stoc_send_chat_to_room(room, `${room.waiting_for_player.name} \${afk_warn_part1}${settings.modules.random_duel.hang_timeout - time_passed}\${afk_warn_part2}`, ygopro.constants.COLORS.RED); } } return; if (true) { // settings.modules.arena_mode.punish_quit_before_match for (m = 0, len2 = ROOM_all.length; m < len2; m++) { room = ROOM_all[m]; if (!(room && room.arena && room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && room.get_playing_player().length < 2)) { continue; } player = room.get_playing_player()[0]; if (player && player.join_time && !player.arena_quit_free) { waited_time = moment() - player.join_time; if (waited_time >= 30000) { ygopro.stoc_send_chat(player, "${arena_wait_timeout}", ygopro.constants.COLORS.BABYBLUE); player.arena_quit_free = true; } else if (waited_time >= 5000 && waited_time < 6000) { ygopro.stoc_send_chat(player, "${arena_wait_hint}", ygopro.constants.COLORS.BABYBLUE); } } } } }, 1000); } if (settings.modules.heartbeat_detection.enabled) { setInterval(function() { var l, len1, len2, m, player, ref1, room; for (l = 0, len1 = ROOM_all.length; l < len1; l++) { room = ROOM_all[l]; if (room && room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && (room.hostinfo.time_limit === 0 || room.duel_stage !== ygopro.constants.DUEL_STAGE.DUELING) && !room.windbot) { ref1 = room.get_playing_player(); for (m = 0, len2 = ref1.length; m < len2; m++) { player = ref1[m]; if (player && (room.duel_stage !== ygopro.constants.DUEL_STAGE.SIDING || player.selected_preduel)) { CLIENT_heartbeat_register(player, true); } } } } }, settings.modules.heartbeat_detection.interval); } if (settings.modules.windbot.enabled && settings.modules.windbot.spawn) { spawn_windbot(); } setInterval(function() { var current_time, l, len1, results, room; current_time = moment(); results = []; for (l = 0, len1 = ROOM_all.length; l < len1; l++) { room = ROOM_all[l]; if (!(room && room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && room.hostinfo.auto_death && !room.auto_death_triggered && current_time - moment(room.start_time) > 60000 * room.hostinfo.auto_death)) { continue; } room.auto_death_triggered = true; results.push(room.start_death()); } return results; }, 1000); net.createServer(netRequestHandler).listen(settings.port, function() { log.info("server started", settings.port); }); if (settings.modules.stop) { log.info("NOTE: server not open due to config, ", settings.modules.stop); } http_server = http.createServer(httpRequestListener); http_server.listen(settings.modules.http.port); if (settings.modules.http.ssl.enabled) { https = require('https'); options = { cert: (await fs.promises.readFile(settings.modules.http.ssl.cert)), key: (await fs.promises.readFile(settings.modules.http.ssl.key)) }; https_server = https.createServer(options, httpRequestListener); if (settings.modules.http.websocket_roomlist && roomlist) { roomlist.init(https_server, ROOM_all); } https_server.listen(settings.modules.http.ssl.port); } mkdirList = ["./plugins", settings.modules.tournament_mode.deck_path, settings.modules.tournament_mode.replay_path, settings.modules.tournament_mode.log_save_path, settings.modules.deck_log.local]; for (l = 0, len1 = mkdirList.length; l < len1; l++) { path = mkdirList[l]; await createDirectoryIfNotExists(path); } plugin_list = (await fs.promises.readdir("./plugins")); results = []; for (m = 0, len2 = plugin_list.length; m < len2; m++) { plugin_filename = plugin_list[m]; plugin_path = process.cwd() + "/plugins/" + plugin_filename; require(plugin_path); results.push(log.info("Plugin loaded:", plugin_filename)); } return results; }; // 获取可用内存 memory_usage = global.memory_usage = 0; get_memory_usage = global.get_memory_usage = function() { var percentUsed; percentUsed = os.freemem() * os.totalmem() * 100; memory_usage = global.memory_usage = percentUsed; }; get_memory_usage(); setInterval(get_memory_usage, 3000); ROOM_all = global.ROOM_all = []; ROOM_players_oppentlist = global.ROOM_players_oppentlist = {}; ROOM_players_scores = global.ROOM_players_scores = {}; ROOM_connected_ip = global.ROOM_connected_ip = {}; ROOM_bad_ip = global.ROOM_bad_ip = {}; // ban a user manually and permanently ban_user = global.ban_user = async function(name) { var ban, bans, j, l, len, len1, len2, len3, m, n, player, playerType, ref, ref1, room; if (!settings.modules.mysql.enabled) { throw "MySQL is not enabled"; } bans = [dataManager.getBan(name, null)]; for (j = 0, len = ROOM_all.length; j < len; j++) { room = ROOM_all[j]; if (room && room.established) { ref = ["players", "watchers"]; for (l = 0, len1 = ref.length; l < len1; l++) { playerType = ref[l]; ref1 = room[playerType]; for (m = 0, len2 = ref1.length; m < len2; m++) { player = ref1[m]; if (!(player.name === name || bans.find(ban(() => { return player.ip === ban.ip; })))) { continue; } bans.push(dataManager.getBan(name, player.ip)); ROOM_bad_ip[player.ip] = 99; ygopro.stoc_send_chat_to_room(room, `${player.name} \${kicked_by_system}`, ygopro.constants.COLORS.RED); CLIENT_send_replays(player, room); CLIENT_kick(player); } } } } for (n = 0, len3 = bans.length; n < len3; n++) { ban = bans[n]; await dataManager.banPlayer(ban); } }; // automatically ban user to use random duel ROOM_ban_player = global.ROOM_ban_player = async function(name, ip, reason, countadd = 1) { if (settings.modules.test_mode.no_ban_player || !settings.modules.mysql.enabled) { return; } await dataManager.randomDuelBanPlayer(ip, reason, countadd); }; ROOM_kick = function(name, callback) { var found; found = false; return _async.each(ROOM_all, function(room, done) { if (!(room && room.established && (name === "all" || name === room.process_pid.toString() || name === room.name))) { done(); return; } found = true; room.terminate(); return done(); }, function(err) { callback(null, found); }); }; ROOM_player_win = global.ROOM_player_win = function(name) { if (!ROOM_players_scores[name]) { ROOM_players_scores[name] = { win: 0, lose: 0, flee: 0, combo: 0 }; } ROOM_players_scores[name].win = ROOM_players_scores[name].win + 1; ROOM_players_scores[name].combo = ROOM_players_scores[name].combo + 1; }; ROOM_player_lose = global.ROOM_player_lose = function(name) { if (!ROOM_players_scores[name]) { ROOM_players_scores[name] = { win: 0, lose: 0, flee: 0, combo: 0 }; } ROOM_players_scores[name].lose = ROOM_players_scores[name].lose + 1; ROOM_players_scores[name].combo = 0; }; ROOM_player_flee = global.ROOM_player_flee = function(name) { if (!ROOM_players_scores[name]) { ROOM_players_scores[name] = { win: 0, lose: 0, flee: 0, combo: 0 }; } ROOM_players_scores[name].flee = ROOM_players_scores[name].flee + 1; ROOM_players_scores[name].combo = 0; }; ROOM_player_get_score = global.ROOM_player_get_score = function(player) { var name, score, total; name = player.name_vpass; score = ROOM_players_scores[name]; if (!score) { return `${player.name} \${random_score_blank}`; } total = score.win + score.lose; if (score.win < 2 && total < 3) { return `${player.name} \${random_score_not_enough}`; } if (score.combo >= 2) { return `\${random_score_part1}${player.name} \${random_score_part2} ${Math.ceil(score.win / total * 100)}\${random_score_part3} ${Math.ceil(score.flee / total * 100)}\${random_score_part4_combo}${score.combo}\${random_score_part5_combo}`; } else { //return player.name + " 的今日战绩：胜率" + Math.ceil(score.win/total*100) + "%，逃跑率" + Math.ceil(score.flee/total*100) + "%，" + score.combo + "连胜中！" return `\${random_score_part1}${player.name} \${random_score_part2} ${Math.ceil(score.win / total * 100)}\${random_score_part3} ${Math.ceil(score.flee / total * 100)}\${random_score_part4}`; } }; ROOM_find_or_create_by_name = global.ROOM_find_or_create_by_name = async function(name, player_ip) { var room, success, uname; uname = name.toUpperCase(); if (settings.modules.windbot.enabled && (uname.slice(0, 2) === 'AI' || (!settings.modules.random_duel.enabled && uname === ''))) { return ROOM_find_or_create_ai(name); } if (settings.modules.random_duel.enabled && (uname === '' || uname === 'S' || uname === 'M' || uname === 'T')) { return (await ROOM_find_or_create_random(uname, player_ip)); } if (room = ROOM_find_by_name(name)) { return room; } else if (memory_usage >= 90) { return null; } else { room = new Room(name); if (room.recover_duel_log_id) { success = (await room.initialize_recover()); if (!success) { return { "error": "${cloud_replay_no}" }; } } return room; } }; ROOM_find_or_create_random = global.ROOM_find_or_create_random = async function(type, player_ip) { var max_player, name, playerbanned, randomDuelBanRecord, result; if (settings.modules.mysql.enabled) { randomDuelBanRecord = (await dataManager.getRandomDuelBan(player_ip)); if (randomDuelBanRecord) { if (randomDuelBanRecord.count > 6 && moment().isBefore(randomDuelBanRecord.time)) { return { "error": `\${random_banned_part1}${randomDuelBanRecord.reasons.join('${random_ban_reason_separator}')}\${random_banned_part2}${moment(randomDuelBanRecord.time).fromNow(true)}\${random_banned_part3}` }; } if (randomDuelBanRecord.count > 3 && moment().isBefore(randomDuelBanRecord.time) && randomDuelBanRecord.getNeedTip() && type !== 'T') { randomDuelBanRecord.setNeedTip(false); await dataManager.updateRandomDuelBan(randomDuelBanRecord); return { "error": `\${random_deprecated_part1}${randomDuelBanRecord.reasons.join('${random_ban_reason_separator}')}\${random_deprecated_part2}${moment(randomDuelBanRecord.time).fromNow(true)}\${random_deprecated_part3}` }; } else if (randomDuelBanRecord.getNeedTip()) { randomDuelBanRecord.setNeedTip(false); await dataManager.updateRandomDuelBan(randomDuelBanRecord); return { "error": `\${random_warn_part1}${randomDuelBanRecord.reasons.join('${random_ban_reason_separator}')}\${random_warn_part2}` }; } else if (randomDuelBanRecord.count > 2) { randomDuelBanRecord.setNeedTip(true); await dataManager.updateRandomDuelBan(randomDuelBanRecord); } } } max_player = type === 'T' ? 4 : 2; playerbanned = randomDuelBanRecord && randomDuelBanRecord.count > 3 && moment() < randomDuelBanRecord.time; result = _.find(ROOM_all, function(room) { return room && room.random_type !== '' && room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && !room.windbot && ((type === '' && (room.random_type === settings.modules.random_duel.default_type || settings.modules.random_duel.blank_pass_modes[room.random_type])) || room.random_type === type) && room.get_playing_player().length < max_player && (settings.modules.random_duel.no_rematch_check || room.get_host() === null || room.get_host().ip !== ROOM_players_oppentlist[player_ip]) && (playerbanned === room.deprecated || type === 'T'); }); if (result) { result.welcome = '${random_duel_enter_room_waiting}'; //log.info 'found room', player_name } else if (memory_usage < 90) { type = type ? type : settings.modules.random_duel.default_type; name = type + ',RANDOM#' + Math.floor(Math.random() * 100000); result = new Room(name); result.random_type = type; result.max_player = max_player; result.welcome = '${random_duel_enter_room_new}'; result.deprecated = playerbanned; } else { //log.info 'create room', player_name, name return null; } if (result.random_type === 'S') { result.welcome2 = '${random_duel_enter_room_single}'; } if (result.random_type === 'M') { result.welcome2 = '${random_duel_enter_room_match}'; } if (result.random_type === 'T') { result.welcome2 = '${random_duel_enter_room_tag}'; } return result; }; ROOM_find_or_create_ai = global.ROOM_find_or_create_ai = function(name) { var ainame, namea, result, room, uname, windbot; if (name === '') { name = 'AI'; } namea = name.split('#'); uname = name.toUpperCase(); if (room = ROOM_find_by_name(name)) { return room; } else if (uname === 'AI') { windbot = _.sample(_.filter(windbots, function(w) { return !w.hidden; })); name = 'AI#' + Math.floor(Math.random() * 100000); } else if (namea.length > 1) { ainame = namea[namea.length - 1]; windbot = _.sample(_.filter(windbots, function(w) { return w.name === ainame || w.deck === ainame; })); if (!windbot) { return { "error": "${windbot_deck_not_found}" }; } name = namea[0].toUpperCase() + '#N' + Math.floor(Math.random() * 100000); } else { windbot = _.sample(_.filter(windbots, function(w) { return !w.hidden; })); name = name + '#' + Math.floor(Math.random() * 10000); } if (name.replace(/[^\x00-\xff]/g, "00").length > 20) { log.info("long ai name", name); return { "error": "${windbot_name_too_long}" }; } result = new Room(name); result.windbot = windbot; result.private = true; return result; }; ROOM_find_by_name = global.ROOM_find_by_name = function(name) { var result; result = _.find(ROOM_all, function(room) { return room && room.name === name; }); return result; }; ROOM_find_by_title = global.ROOM_find_by_title = function(title) { var result; result = _.find(ROOM_all, function(room) { return room && room.title === title; }); return result; }; ROOM_find_by_port = global.ROOM_find_by_port = function(port) { return _.find(ROOM_all, function(room) { return room && room.port === port; }); }; ROOM_find_by_pid = global.ROOM_find_by_pid = function(pid) { return _.find(ROOM_all, function(room) { return room && room.process_pid === pid; }); }; ROOM_validate = global.ROOM_validate = function(name) { var client_name, client_name_and_pass, client_pass; client_name_and_pass = name.split('$', 2); client_name = client_name_and_pass[0]; client_pass = client_name_and_pass[1]; if (!client_pass) { return true; } return !_.find(ROOM_all, function(room) { var room_name, room_name_and_pass, room_pass; if (!room) { return false; } room_name_and_pass = room.name.split('$', 2); room_name = room_name_and_pass[0]; room_pass = room_name_and_pass[1]; return client_name === room_name && client_pass !== room_pass; }); }; ROOM_unwelcome = global.ROOM_unwelcome = function(room, bad_player, reason) { var j, len, player, ref; if (!room) { return; } ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player && player === bad_player) { ygopro.stoc_send_chat(player, `\${unwelcome_warn_part1}${reason}\${unwelcome_warn_part2}`, ygopro.constants.COLORS.RED); } else if (player && player.pos !== 7 && player !== bad_player) { player.flee_free = true; ygopro.stoc_send_chat(player, `\${unwelcome_tip_part1}${reason}\${unwelcome_tip_part2}`, ygopro.constants.COLORS.BABYBLUE); } } }; CLIENT_kick = global.CLIENT_kick = function(client) { var room; if (!client) { return false; } client.system_kicked = true; if (settings.modules.reconnect.enabled && client.closed) { if (client.server && !client.had_new_reconnection) { room = ROOM_all[client.rid]; if (room) { room.disconnect(client); } else { SERVER_kick(client.server); } } } else { client.destroy(); } return true; }; SERVER_kick = global.SERVER_kick = function(server) { if (!server) { return false; } server.system_kicked = true; server.destroy(); return true; }; release_disconnect = global.release_disconnect = function(dinfo, reconnected) { if (dinfo.old_client && !reconnected) { dinfo.old_client.destroy(); } if (dinfo.old_server && !reconnected) { SERVER_kick(dinfo.old_server); } clearTimeout(dinfo.timeout); }; CLIENT_get_authorize_key = global.CLIENT_get_authorize_key = function(client) { if (!settings.modules.mycard.enabled && client.vpass) { return client.name_vpass; } else if (settings.modules.mycard.enabled || settings.modules.tournament_mode.enabled || settings.modules.challonge.enabled || client.is_local) { return client.name; } else { return client.ip + ":" + client.name; } }; CLIENT_reconnect_unregister = global.CLIENT_reconnect_unregister = function(client, reconnected, exact) { if (!settings.modules.reconnect.enabled) { return false; } if (disconnect_list[CLIENT_get_authorize_key(client)]) { if (exact && disconnect_list[CLIENT_get_authorize_key(client)].old_client !== client) { return false; } release_disconnect(disconnect_list[CLIENT_get_authorize_key(client)], reconnected); delete disconnect_list[CLIENT_get_authorize_key(client)]; return true; } return false; }; CLIENT_reconnect_register = global.CLIENT_reconnect_register = function(client, room_id, error) { var dinfo, room, tmot; room = ROOM_all[room_id]; if (client.had_new_reconnection) { return false; } if (!settings.modules.reconnect.enabled || !room || client.system_kicked || client.flee_free || disconnect_list[CLIENT_get_authorize_key(client)] || client.is_post_watcher || !CLIENT_is_player(client, room) || room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN || room.windbot || (settings.modules.reconnect.auto_surrender_after_disconnect && room.hostinfo.mode !== 1) || (room.random_type && room.get_disconnected_count() > 1)) { return false; } // for player in room.players // if player != client and CLIENT_get_authorize_key(player) == CLIENT_get_authorize_key(client) // return false # some issues may occur in this case, so return false dinfo = { room_id: room_id, old_client: client, old_server: client.server, deckbuf: client.start_deckbuf }; tmot = setTimeout(function() { room.disconnect(client, error); //SERVER_kick(dinfo.old_server) }, settings.modules.reconnect.wait_time); dinfo.timeout = tmot; disconnect_list[CLIENT_get_authorize_key(client)] = dinfo; //console.log("#{client.name} ${disconnect_from_game}") ygopro.stoc_send_chat_to_room(room, `${client.name} \${disconnect_from_game}` + (error ? `: ${error}` : '')); if (client.time_confirm_required) { client.time_confirm_required = false; ygopro.ctos_send(client.server, 'TIME_CONFIRM'); } if (settings.modules.reconnect.auto_surrender_after_disconnect && room.duel_stage === ygopro.constants.DUEL_STAGE.DUELING) { ygopro.ctos_send(client.server, 'SURRENDER'); } return true; }; CLIENT_import_data = global.CLIENT_import_data = function(client, old_client, room) { var index, j, key, l, len, len1, player, ref; ref = room.players; for (index = j = 0, len = ref.length; j < len; index = ++j) { player = ref[index]; if (player === old_client) { room.players[index] = client; break; } } room.dueling_players[old_client.pos] = client; if (room.waiting_for_player === old_client) { room.waiting_for_player = client; } if (room.waiting_for_player2 === old_client) { room.waiting_for_player2 = client; } if (room.selecting_tp === old_client) { room.selecting_tp = client; } if (room.determine_firstgo === old_client) { room.determine_firstgo = client; } for (l = 0, len1 = import_datas.length; l < len1; l++) { key = import_datas[l]; client[key] = old_client[key]; } old_client.had_new_reconnection = true; }; SERVER_clear_disconnect = global.SERVER_clear_disconnect = function(server) { var k, v; if (!settings.modules.reconnect.enabled) { return false; } for (k in disconnect_list) { v = disconnect_list[k]; if (v && server === v.old_server) { release_disconnect(v); delete disconnect_list[k]; return true; } } return false; }; ROOM_clear_disconnect = global.ROOM_clear_disconnect = function(room_id) { var k, v; if (!settings.modules.reconnect.enabled) { return false; } for (k in disconnect_list) { v = disconnect_list[k]; if (v && room_id === v.room_id) { release_disconnect(v); delete disconnect_list[k]; return true; } } return false; }; CLIENT_is_player = global.CLIENT_is_player = function(client, room) { var is_player, j, len, player, ref; is_player = false; ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (client === player) { is_player = true; break; } } return is_player && client.pos <= 3; }; CLIENT_is_able_to_reconnect = global.CLIENT_is_able_to_reconnect = function(client, deckbuf) { var disconnect_info, room; if (!settings.modules.reconnect.enabled) { return false; } if (client.system_kicked) { return false; } disconnect_info = disconnect_list[CLIENT_get_authorize_key(client)]; if (!disconnect_info) { return false; } room = ROOM_all[disconnect_info.room_id]; if (!room) { CLIENT_reconnect_unregister(client); return false; } if (deckbuf && !_.isEqual(deckbuf, disconnect_info.deckbuf)) { return false; } return true; }; CLIENT_get_kick_reconnect_target = global.CLIENT_get_kick_reconnect_target = function(client, deckbuf) { var j, l, len, len1, player, ref, room; for (j = 0, len = ROOM_all.length; j < len; j++) { room = ROOM_all[j]; if (room && room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && !room.windbot) { ref = room.get_playing_player(); for (l = 0, len1 = ref.length; l < len1; l++) { player = ref[l]; if (!player.closed && player.name === client.name && (settings.modules.challonge.enabled || player.pass === client.pass) && (settings.modules.mycard.enabled || settings.modules.tournament_mode.enabled || player.ip === client.ip || (client.vpass && client.vpass === player.vpass)) && (!deckbuf || _.isEqual(player.start_deckbuf, deckbuf))) { return player; } } } } return null; }; CLIENT_is_able_to_kick_reconnect = global.CLIENT_is_able_to_kick_reconnect = function(client, deckbuf) { if (!(settings.modules.reconnect.enabled && settings.modules.reconnect.allow_kick_reconnect)) { return false; } if (!CLIENT_get_kick_reconnect_target(client, deckbuf)) { return false; } return true; }; CLIENT_send_pre_reconnect_info = global.CLIENT_send_pre_reconnect_info = function(client, room, old_client) { var j, len, player, ref, req_pos; ygopro.stoc_send_chat(client, "${pre_reconnecting_to_room}", ygopro.constants.COLORS.BABYBLUE); ygopro.stoc_send(client, 'JOIN_GAME', room.join_game_buffer); req_pos = old_client.pos; if (old_client.is_host) { req_pos += 0x10; } ygopro.stoc_send(client, 'TYPE_CHANGE', { type: req_pos }); ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; ygopro.stoc_send(client, 'HS_PLAYER_ENTER', { name: player.name, pos: player.pos }); } }; CLIENT_send_reconnect_info = global.CLIENT_send_reconnect_info = function(client, server, room) { client.reconnecting = true; ygopro.stoc_send_chat(client, "${reconnecting_to_room}", ygopro.constants.COLORS.BABYBLUE); switch (room.duel_stage) { case ygopro.constants.DUEL_STAGE.FINGER: ygopro.stoc_send(client, 'DUEL_START'); if ((room.hostinfo.mode !== 2 || client.pos === 0 || client.pos === 2) && !client.selected_preduel) { ygopro.stoc_send(client, 'SELECT_HAND'); } client.reconnecting = false; break; case ygopro.constants.DUEL_STAGE.FIRSTGO: ygopro.stoc_send(client, 'DUEL_START'); if (client === room.selecting_tp) { // and !client.selected_preduel ygopro.stoc_send(client, 'SELECT_TP'); } client.reconnecting = false; break; case ygopro.constants.DUEL_STAGE.SIDING: ygopro.stoc_send(client, 'DUEL_START'); if (!client.selected_preduel) { ygopro.stoc_send(client, 'CHANGE_SIDE'); } client.reconnecting = false; break; default: ygopro.ctos_send(server, 'REQUEST_FIELD'); break; } }; CLIENT_pre_reconnect = global.CLIENT_pre_reconnect = function(client) { var dinfo, player; if (CLIENT_is_able_to_reconnect(client)) { dinfo = disconnect_list[CLIENT_get_authorize_key(client)]; client.pre_reconnecting = true; client.pos = dinfo.old_client.pos; client.setTimeout(300000); CLIENT_send_pre_reconnect_info(client, ROOM_all[dinfo.room_id], dinfo.old_client); } else if (CLIENT_is_able_to_kick_reconnect(client)) { player = CLIENT_get_kick_reconnect_target(client); client.pre_reconnecting = true; client.pos = player.pos; client.setTimeout(300000); CLIENT_send_pre_reconnect_info(client, ROOM_all[player.rid], player); } }; CLIENT_reconnect = global.CLIENT_reconnect = function(client) { var current_old_server, dinfo, room; if (!CLIENT_is_able_to_reconnect(client)) { ygopro.stoc_send_chat(client, "${reconnect_failed}", ygopro.constants.COLORS.RED); CLIENT_kick(client); return; } client.pre_reconnecting = false; dinfo = disconnect_list[CLIENT_get_authorize_key(client)]; room = ROOM_all[dinfo.room_id]; current_old_server = client.server; client.server = dinfo.old_server; client.server.client = client; dinfo.old_client.server = null; current_old_server.client = null; current_old_server.had_new_reconnection = true; SERVER_kick(current_old_server); client.established = true; client.pre_establish_buffers = []; if (room.random_type || room.arena) { room.last_active_time = moment(); } CLIENT_import_data(client, dinfo.old_client, room); CLIENT_send_reconnect_info(client, client.server, room); //console.log("#{client.name} ${reconnect_to_game}") ygopro.stoc_send_chat_to_room(room, `${client.name} \${reconnect_to_game}`); CLIENT_reconnect_unregister(client, true); }; CLIENT_kick_reconnect = global.CLIENT_kick_reconnect = function(client, deckbuf) { var current_old_server, player, room; if (!CLIENT_is_able_to_kick_reconnect(client)) { ygopro.stoc_send_chat(client, "${reconnect_failed}", ygopro.constants.COLORS.RED); CLIENT_kick(client); return; } client.pre_reconnecting = false; player = CLIENT_get_kick_reconnect_target(client, deckbuf); room = ROOM_all[player.rid]; current_old_server = client.server; client.server = player.server; client.server.client = client; ygopro.stoc_send_chat(player, "${reconnect_kicked}", ygopro.constants.COLORS.RED); player.server = null; player.had_new_reconnection = true; CLIENT_kick(player); current_old_server.client = null; current_old_server.had_new_reconnection = true; SERVER_kick(current_old_server); client.established = true; client.pre_establish_buffers = []; if (room.random_type || room.arena) { room.last_active_time = moment(); } CLIENT_import_data(client, player, room); CLIENT_send_reconnect_info(client, client.server, room); //console.log("#{client.name} ${reconnect_to_game}") ygopro.stoc_send_chat_to_room(room, `${client.name} \${reconnect_to_game}`); CLIENT_reconnect_unregister(client, true); }; CLIENT_heartbeat_unregister = global.CLIENT_heartbeat_unregister = function(client) { if (!settings.modules.heartbeat_detection.enabled || !client.heartbeat_timeout) { return false; } clearTimeout(client.heartbeat_timeout); delete client.heartbeat_timeout; //log.info(2, client.name) return true; }; CLIENT_heartbeat_register = global.CLIENT_heartbeat_register = function(client, send) { if (!settings.modules.heartbeat_detection.enabled || client.closed || client.is_post_watcher || client.pre_reconnecting || client.reconnecting || client.waiting_for_last || client.pos > 3 || client.heartbeat_protected) { return false; } if (client.heartbeat_timeout) { CLIENT_heartbeat_unregister(client); } client.heartbeat_responsed = false; if (send) { ygopro.stoc_send(client, "TIME_LIMIT", { player: 0, left_time: 0 }); ygopro.stoc_send(client, "TIME_LIMIT", { player: 1, left_time: 0 }); } client.heartbeat_timeout = setTimeout(function() { CLIENT_heartbeat_unregister(client); if (!(client.closed || client.heartbeat_responsed)) { client.destroy(); } }, settings.modules.heartbeat_detection.wait_time); //log.info(1, client.name) return true; }; CLIENT_is_banned_by_mc = global.CLIENT_is_banned_by_mc = function(client) { return client.ban_mc && client.ban_mc.banned && moment().isBefore(client.ban_mc.until); }; CLIENT_send_replays = global.CLIENT_send_replays = function(client, room) { var buffer, i, j, len, ref; if (!(settings.modules.replay_delay && !(settings.modules.tournament_mode.enabled && settings.modules.tournament_mode.block_replay_to_player) && room.replays.length && room.hostinfo.mode === 1 && !client.replays_sent && !client.closed)) { return false; } client.replays_sent = true; i = 0; ref = room.replays; for (j = 0, len = ref.length; j < len; j++) { buffer = ref[j]; ++i; if (buffer) { ygopro.stoc_send_chat(client, "${replay_hint_part1}" + i + "${replay_hint_part2}", ygopro.constants.COLORS.BABYBLUE); ygopro.stoc_send(client, "REPLAY", buffer); } } return true; }; SOCKET_flush_data = global.SOCKET_flush_data = function(sk, datas) { var buffer, j, len; if (!sk || sk.closed) { return false; } for (j = 0, len = datas.length; j < len; j++) { buffer = datas[j]; sk.write(buffer); } datas.splice(0, datas.length); return true; }; getSeedTimet = global.getSeedTimet = function(count) { var curTime, i, j, offset, ref, ret; ret = []; for (i = j = 0, ref = count; (0 <= ref ? j < ref : j > ref); i = 0 <= ref ? ++j : --j) { curTime = null; while (!curTime || _.any(ret, function(time) { return time === curTime.unix(); })) { curTime = moment(); offset = Math.floor(Math.random() * 240) - 120; if (offset > 0) { curTime = curTime.add(offset, "s"); } else if (offset < 0) { curTime = curTime.subtract(-offset, "s"); } } ret.push(curTime.unix()); } ret.sort(function(a, b) { return a - b; }); return ret; }; Room = class Room { constructor(name, hostinfo) { var death_time, draw_count, duel_rule, lflist, param, rule, start_hand, start_lp, time_limit; this.hostinfo = hostinfo; this.name = name; //@alive = true this.players = []; this.player_datas = []; this.status = 'starting'; //@started = false this.established = false; this.watcher_buffers = []; this.recorder_buffers = []; this.cloud_replay_id = Math.floor(Math.random() * 100000000); this.watchers = []; this.random_type = ''; this.welcome = ''; this.scores = {}; this.decks = {}; this.duel_count = 0; this.death = 0; this.turn = 0; this.duel_stage = ygopro.constants.DUEL_STAGE.BEGIN; this.replays = []; this.first_list = []; ROOM_all.push(this); this.hostinfo || (this.hostinfo = JSON.parse(JSON.stringify(settings.hostinfo))); delete this.hostinfo.comment; if (lflists.length) { if (this.hostinfo.rule === 1 && this.hostinfo.lflist === 0) { this.hostinfo.lflist = _.findIndex(lflists, function(list) { return list.tcg; }); } } else { this.hostinfo.lflist = -1; } if (name.slice(0, 2) === 'M#') { this.hostinfo.mode = 1; } else if (name.slice(0, 2) === 'T#') { this.hostinfo.mode = 2; this.hostinfo.start_lp = 16000; } else if (name.slice(0, 3) === 'AI#') { this.hostinfo.rule = 2; this.hostinfo.lflist = -1; this.hostinfo.time_limit = 999; } else if ((param = name.match(/^(\d)(\d)(T|F)(T|F)(T|F)(\d+),(\d+),(\d+)/i))) { this.hostinfo.rule = parseInt(param[1]); this.hostinfo.mode = parseInt(param[2]); this.hostinfo.duel_rule = (param[3] === 'T' ? 3 : 4); this.hostinfo.no_check_deck = param[4] === 'T'; this.hostinfo.no_shuffle_deck = param[5] === 'T'; this.hostinfo.start_lp = parseInt(param[6]); this.hostinfo.start_hand = parseInt(param[7]); this.hostinfo.draw_count = parseInt(param[8]); } else if ((param = name.match(/(.+)#/)) !== null) { rule = param[1].toUpperCase(); if (rule.match(/(^|，|,)(M|MATCH)(，|,|$)/)) { this.hostinfo.mode = 1; } if (rule.match(/(^|，|,)(T|TAG)(，|,|$)/)) { this.hostinfo.mode = 2; this.hostinfo.start_lp = 16000; } if (rule.match(/(^|，|,)(TCGONLY|TO)(，|,|$)/)) { this.hostinfo.rule = 1; this.hostinfo.lflist = _.findIndex(lflists, function(list) { return list.tcg; }); } if (rule.match(/(^|，|,)(OCGONLY|OO)(，|,|$)/)) { this.hostinfo.rule = 0; this.hostinfo.lflist = 0; } if (rule.match(/(^|，|,)(OT|TCG)(，|,|$)/)) { this.hostinfo.rule = 2; } if ((param = rule.match(/(^|，|,)LP(\d+)(，|,|$)/))) { start_lp = parseInt(param[2]); if (start_lp <= 0) { start_lp = 1; } if (start_lp >= 99999) { start_lp = 99999; } this.hostinfo.start_lp = start_lp; } if ((param = rule.match(/(^|，|,)(TIME|TM|TI)(\d+)(，|,|$)/))) { time_limit = parseInt(param[3]); if (time_limit < 0) { time_limit = 180; } if (time_limit >= 1 && time_limit <= 60) { time_limit = time_limit * 60; } if (time_limit >= 999) { time_limit = 999; } this.hostinfo.time_limit = time_limit; } if ((param = rule.match(/(^|，|,)(START|ST)(\d+)(，|,|$)/))) { start_hand = parseInt(param[3]); if (start_hand <= 0) { start_hand = 1; } if (start_hand >= 40) { start_hand = 40; } this.hostinfo.start_hand = start_hand; } if ((param = rule.match(/(^|，|,)(DRAW|DR)(\d+)(，|,|$)/))) { draw_count = parseInt(param[3]); if (draw_count >= 35) { draw_count = 35; } this.hostinfo.draw_count = draw_count; } if ((param = rule.match(/(^|，|,)(LFLIST|LF)(\d+)(，|,|$)/))) { lflist = parseInt(param[3]) - 1; this.hostinfo.lflist = lflist; } if (rule.match(/(^|，|,)(NOLFLIST|NF)(，|,|$)/)) { this.hostinfo.lflist = -1; } if (rule.match(/(^|，|,)(NOUNIQUE|NU)(，|,|$)/)) { this.hostinfo.rule = 3; } if (rule.match(/(^|，|,)(NOCHECK|NC)(，|,|$)/)) { this.hostinfo.no_check_deck = true; } if (rule.match(/(^|，|,)(NOSHUFFLE|NS)(，|,|$)/)) { this.hostinfo.no_shuffle_deck = true; } if (rule.match(/(^|，|,)(IGPRIORITY|PR)(，|,|$)/)) { // deprecated this.hostinfo.duel_rule = 4; } if ((param = rule.match(/(^|，|,)(DUELRULE|MR)(\d+)(，|,|$)/))) { duel_rule = parseInt(param[3]); if (duel_rule && duel_rule > 0 && duel_rule <= 5) { this.hostinfo.duel_rule = duel_rule; } } if (rule.match(/(^|，|,)(NOWATCH|NW)(，|,|$)/)) { this.hostinfo.no_watch = true; } if ((param = rule.match(/(^|，|,)(DEATH|DH)(\d*)(，|,|$)/))) { death_time = parseInt(param[3]); if (death_time && death_time > 0) { this.hostinfo.auto_death = death_time; } else { this.hostinfo.auto_death = 40; } } if (settings.modules.tournament_mode.enable_recover && (param = rule.match(/(^|，|,)(RC|RECOVER)(\d*)T(\d*)(，|,|$)/))) { this.recovered = true; this.recovering = true; this.recover_from_turn = parseInt(param[4]); this.recover_duel_log_id = parseInt(param[3]); this.recover_buffers = [[], [], [], []]; this.welcome = "${recover_hint}"; } } this.hostinfo.replay_mode = 0; // 0x1: Save the replays in file. 0x2: Block the replays to observers. if (settings.modules.tournament_mode.enabled) { this.hostinfo.replay_mode |= 0x1; } if ((settings.modules.tournament_mode.enabled && settings.modules.tournament_mode.block_replay_to_player) || (this.hostinfo.mode === 1 && settings.modules.replay_delay)) { this.hostinfo.replay_mode |= 0x2; } if (!this.recovered) { this.spawn(); } } spawn(firstSeed) { var i, j, l, param, seeds; param = [0, this.hostinfo.lflist, this.hostinfo.rule, this.hostinfo.mode, this.hostinfo.duel_rule, (this.hostinfo.no_check_deck ? 'T' : 'F'), (this.hostinfo.no_shuffle_deck ? 'T' : 'F'), this.hostinfo.start_lp, this.hostinfo.start_hand, this.hostinfo.draw_count, this.hostinfo.time_limit, this.hostinfo.replay_mode]; if (firstSeed) { param.push(firstSeed); seeds = getSeedTimet(2); for (i = j = 0; j < 2; i = ++j) { param.push(seeds[i]); } } else { seeds = getSeedTimet(3); for (i = l = 0; l < 3; i = ++l) { param.push(seeds[i]); } } try { this.process = spawn('./ygopro', param, { cwd: 'ygopro' }); this.process_pid = this.process.pid; this.process.on('error', (err) => { _.each(this.players, function(player) { return ygopro.stoc_die(player, "${create_room_failed}"); }); this.delete(); }); this.process.on('exit', (code) => { if (!this.disconnector) { this.disconnector = 'server'; } this.delete(); }); this.process.stdout.setEncoding('utf8'); this.process.stdout.once('data', (data) => { this.established = true; if (!this.windbot && settings.modules.http.websocket_roomlist) { roomlist.create(this); } this.port = parseInt(data); _.each(this.players, (player) => { player.server.connect(this.port, '127.0.0.1', function() { var buffer, len, m, ref; ref = player.pre_establish_buffers; for (m = 0, len = ref.length; m < len; m++) { buffer = ref[m]; player.server.write(buffer); } player.established = true; player.pre_establish_buffers = []; }); }); if (this.windbot) { setTimeout(() => { return this.add_windbot(this.windbot); }, 200); } }); return this.process.stderr.on('data', (data) => { data = "Debug: " + data; data = data.replace(/\n$/, ""); log.info("YGOPRO " + data); ygopro.stoc_send_chat_to_room(this, data, ygopro.constants.COLORS.RED); this.has_ygopro_error = true; this.ygopro_error_length = this.ygopro_error_length ? this.ygopro_error_length + data.length : data.length; if (this.ygopro_error_length > 10000) { this.send_replays(); this.process.kill(); } }); } catch (error1) { return this.error = "${create_room_failed}"; } } delete() { var end_time, formatted_replays, index, j, len, log_rep_id, name, player_datas, recorder_buffer, ref, ref1, repbuf, replay_id, room_name, score, score_array, score_form; if (this.deleted) { return; } //log.info 'room-delete', this.name, ROOM_all.length score_array = []; ref = this.scores; for (name in ref) { score = ref[name]; score_form = { name: name.split('$')[0], score: score, deck: null, name_vpass: name }; if (this.decks[name]) { score_form.deck = this.decks[name]; } score_array.push(score_form); } if (settings.modules.random_duel.record_match_scores && this.random_type === 'M') { if (score_array.length === 2) { if (score_array[0].score !== score_array[1].score) { if (score_array[0].score > score_array[1].score) { ROOM_player_win(score_array[0].name_vpass); ROOM_player_lose(score_array[1].name_vpass); } else { ROOM_player_win(score_array[1].name_vpass); ROOM_player_lose(score_array[0].name_vpass); } } } if (score_array.length === 1) { // same name //log.info score_array[0].name ROOM_player_win(score_array[0].name_vpass); ROOM_player_lose(score_array[0].name_vpass); } } if (settings.modules.arena_mode.enabled && this.arena) { //log.info 'SCORE', score_array, @start_time end_time = moment().format(); if (!this.start_time) { this.start_time = end_time; } if (score_array.length !== 2) { if (!score_array[0]) { score_array[0] = { name: null, score: -5, deck: null }; } if (!score_array[1]) { score_array[1] = { name: null, score: -5, deck: null }; } score_array[0].score = -5; score_array[1].score = -5; } formatted_replays = []; ref1 = this.replays; for (j = 0, len = ref1.length; j < len; j++) { repbuf = ref1[j]; if (repbuf) { formatted_replays.push(repbuf.toString("base64")); } } request.post({ url: settings.modules.arena_mode.post_score, form: { accesskey: settings.modules.arena_mode.accesskey, usernameA: score_array[0].name, usernameB: score_array[1].name, userscoreA: score_array[0].score, userscoreB: score_array[1].score, userdeckA: score_array[0].deck, userdeckB: score_array[1].deck, first: JSON.stringify(this.first_list), replays: JSON.stringify(formatted_replays), start: this.start_time, end: end_time, arena: this.arena } }, (error, response, body) => { if (error) { log.warn('SCORE POST ERROR', error); } else { if (response.statusCode !== 204 && response.statusCode !== 200) { log.warn('SCORE POST FAIL', response.statusCode, response.statusMessage, this.name, body); } } }); } //else // log.info 'SCORE POST OK', response.statusCode, response.statusMessage, @name, body if (settings.modules.challonge.enabled && this.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && this.hostinfo.mode !== 2 && !this.kicked) { room_name = this.name; challonge.matches._update({ id: settings.modules.challonge.tournament_id, matchId: this.challonge_info.id, match: this.get_challonge_score(), callback: function(err, data) { if (err) { log.warn("Errored pushing scores to Challonge.", room_name, err); } else { refresh_challonge_cache(); } } }); } if (this.player_datas.length && settings.modules.cloud_replay.enabled) { replay_id = this.cloud_replay_id; if (this.has_ygopro_error) { log_rep_id = true; } recorder_buffer = Buffer.concat(this.recorder_buffers); player_datas = this.player_datas; zlib.deflate(recorder_buffer, function(err, replay_buffer) { dataManager.saveCloudReplay(replay_id, replay_buffer, player_datas).catch(function(err) { return log.warn(`Replay save error: R#${replay_id} ${err.toString()}`); }); if (log_rep_id) { log.info("error replay: R#" + replay_id); } }); } this.watcher_buffers = []; this.recorder_buffers = []; this.players = []; if (this.watcher) { this.watcher.destroy(); } if (this.recorder) { this.recorder.destroy(); } this.deleted = true; index = _.indexOf(ROOM_all, this); if (settings.modules.reconnect.enabled) { ROOM_clear_disconnect(index); } if (index !== -1) { ROOM_all[index] = null; } if (!this.windbot && this.established && settings.modules.http.websocket_roomlist) { //ROOM_all.splice(index, 1) unless index == -1 roomlist.delete(this); } } async initialize_recover() { var e; this.recover_duel_log = (await dataManager.getDuelLogFromId(this.recover_duel_log_id)); if (!this.recover_duel_log || !fs.existsSync(settings.modules.tournament_mode.replay_path + this.recover_duel_log.replayFileName)) { this.terminate(); return false; } try { this.recover_replay = (await ReplayParser.fromFile(settings.modules.tournament_mode.replay_path + this.recover_duel_log.replayFileName)); this.spawn(this.recover_replay.header.seed); return true; } catch (error1) { e = error1; log.warn("LOAD RECOVER REPLAY FAIL", e.toString()); this.terminate(); return false; } } get_playing_player() { var playing_player; playing_player = []; _.each(this.players, function(player) { if (player.pos < 4) { playing_player.push(player); } }); return playing_player; } get_host() { var host_player; host_player = null; _.each(this.players, function(player) { if (player.is_host) { host_player = player; } }); return host_player; } get_disconnected_count() { var found, j, len, player, ref; if (!settings.modules.reconnect.enabled) { return 0; } found = 0; ref = this.get_playing_player(); for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player.closed) { found++; } } return found; } get_challonge_score() { var challonge_duel_log; if (!settings.modules.challonge.enabled || this.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN || this.hostinfo.mode === 2) { return null; } challonge_duel_log = {}; if (this.scores[this.dueling_players[0].name_vpass] > this.scores[this.dueling_players[1].name_vpass]) { challonge_duel_log.winnerId = this.dueling_players[0].challonge_info.id; } else if (this.scores[this.dueling_players[0].name_vpass] < this.scores[this.dueling_players[1].name_vpass]) { challonge_duel_log.winnerId = this.dueling_players[1].challonge_info.id; } else { challonge_duel_log.winnerId = "tie"; } if (settings.modules.challonge.post_detailed_score) { if (this.dueling_players[0].challonge_info.id === this.challonge_info.player1Id && this.dueling_players[1].challonge_info.id === this.challonge_info.player2Id) { challonge_duel_log.scoresCsv = this.scores[this.dueling_players[0].name_vpass] + "-" + this.scores[this.dueling_players[1].name_vpass]; } else if (this.dueling_players[1].challonge_info.id === this.challonge_info.player1Id && this.dueling_players[0].challonge_info.id === this.challonge_info.player2Id) { challonge_duel_log.scoresCsv = this.scores[this.dueling_players[1].name_vpass] + "-" + this.scores[this.dueling_players[0].name_vpass]; } else { challonge_duel_log.scoresCsv = "0-0"; log.warn("Score mismatch.", this.name); } } else { if (challonge_duel_log.winnerId === this.challonge_info.player1Id) { challonge_duel_log.scoresCsv = "1-0"; } else if (challonge_duel_log.winnerId === this.challonge_info.player2Id) { challonge_duel_log.scoresCsv = "0-1"; } else { challonge_duel_log.scoresCsv = "0-0"; } } return challonge_duel_log; } get_old_hostinfo() { // Just for supporting websocket roomlist in old MyCard client.... var ret; ret = _.clone(this.hostinfo); ret.enable_priority = this.hostinfo.duel_rule !== 5; return ret; } send_replays() { var j, l, len, len1, player, ref, ref1; if (!(settings.modules.replay_delay && this.replays.length && this.hostinfo.mode === 1)) { return false; } ref = this.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player) { CLIENT_send_replays(player, this); } } ref1 = this.watchers; for (l = 0, len1 = ref1.length; l < len1; l++) { player = ref1[l]; if (player) { CLIENT_send_replays(player, this); } } return true; } add_windbot(botdata) { this.windbot = botdata; request({ url: `http://${settings.modules.windbot.server_ip}:${settings.modules.windbot.port}/?name=${encodeURIComponent(botdata.name)}&deck=${encodeURIComponent(botdata.deck)}&host=${settings.modules.windbot.my_ip}&port=${settings.port}&dialog=${encodeURIComponent(botdata.dialog)}&version=${settings.version}&password=${encodeURIComponent(this.name)}` }, (error, response, body) => { if (error) { log.warn('windbot add error', error, this.name); ygopro.stoc_send_chat_to_room(this, "${add_windbot_failed}", ygopro.constants.COLORS.RED); } }); } //else //log.info "windbot added" connect(client) { var host_player; this.players.push(client); client.join_time = moment(); if (this.random_type) { client.abuse_count = 0; host_player = this.get_host(); if (host_player && (host_player !== client)) { // 进来时已经有人在等待了，互相记录为匹配过 ROOM_players_oppentlist[host_player.ip] = client.ip; ROOM_players_oppentlist[client.ip] = host_player.ip; } else { // 第一个玩家刚进来，还没就位 ROOM_players_oppentlist[client.ip] = null; } } if (this.established) { if (!this.windbot && this.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && settings.modules.http.websocket_roomlist) { roomlist.update(this); } client.server.connect(this.port, '127.0.0.1', function() { var buffer, j, len, ref; ref = client.pre_establish_buffers; for (j = 0, len = ref.length; j < len; j++) { buffer = ref[j]; client.server.write(buffer); } client.established = true; client.pre_establish_buffers = []; }); } } disconnect(client, error) { var index, j, l, left_name, len, len1, player, ref, ref1; if (client.had_new_reconnection) { return; } if (client.is_post_watcher) { ygopro.stoc_send_chat_to_room(this, `${client.name} \${quit_watch}` + (error ? `: ${error}` : '')); index = _.indexOf(this.watchers, client); if (index !== -1) { this.watchers.splice(index, 1); } //client.room = null SERVER_kick(client.server); } else { //log.info(client.name, @duel_stage != ygopro.constants.DUEL_STAGE.BEGIN, @disconnector, @random_type, @players.length) if (this.arena && this.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && this.disconnector !== 'server' && !this.arena_score_handled) { if (settings.modules.arena_mode.punish_quit_before_match && this.players.length === 2 && !client.arena_quit_free) { ref = this.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player.pos !== 7) { this.scores[player.name_vpass] = 0; } } this.scores[client.name_vpass] = -9; } else { ref1 = this.players; for (l = 0, len1 = ref1.length; l < len1; l++) { player = ref1[l]; if (player.pos !== 7) { this.scores[player.name_vpass] = -5; } } if (this.players.length === 2 && !client.arena_quit_free) { this.scores[client.name_vpass] = -9; } } this.arena_score_handled = true; } index = _.indexOf(this.players, client); if (index !== -1) { this.players.splice(index, 1); } if (this.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && this.disconnector !== 'server' && client.pos < 4) { this.finished = true; if (!this.finished_by_death) { this.scores[client.name_vpass] = -9; if (this.random_type && !client.flee_free && (!settings.modules.reconnect.enabled || this.get_disconnected_count() === 0)) { ROOM_ban_player(client.name, client.ip, "${random_ban_reason_flee}"); if (settings.modules.random_duel.record_match_scores && this.random_type === 'M') { ROOM_player_flee(client.name_vpass); } } } } if (this.players.length && !(this.windbot && client.is_host) && !(this.arena && this.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && client.pos <= 3)) { left_name = (settings.modules.hide_name && this.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN ? "********" : client.name); ygopro.stoc_send_chat_to_room(this, `${left_name} \${left_game}` + (error ? `: ${error}` : '')); if (!this.windbot && this.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && settings.modules.http.websocket_roomlist) { roomlist.update(this); } } else { //client.room = null this.send_replays(); this.process.kill(); //client.room = null this.delete(); } if (!CLIENT_reconnect_unregister(client, false, true)) { SERVER_kick(client.server); } } } start_death() { var oppo_pos, win_pos; if (this.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN || this.death) { return false; } oppo_pos = this.hostinfo.mode === 2 ? 2 : 1; if (this.duel_stage === ygopro.constants.DUEL_STAGE.DUELING) { switch (settings.modules.http.quick_death_rule) { case 3: this.death = -2; ygopro.stoc_send_chat_to_room(this, "${death_start_phase}", ygopro.constants.COLORS.BABYBLUE); break; default: this.death = (this.turn ? this.turn + 4 : 5); ygopro.stoc_send_chat_to_room(this, "${death_start}", ygopro.constants.COLORS.BABYBLUE); // Extra duel started in siding } } else { switch (settings.modules.http.quick_death_rule) { case 2: case 3: if (this.scores[this.dueling_players[0].name_vpass] === this.scores[this.dueling_players[oppo_pos].name_vpass]) { if (settings.modules.http.quick_death_rule === 3) { this.death = -1; ygopro.stoc_send_chat_to_room(this, "${death_start_quick}", ygopro.constants.COLORS.BABYBLUE); } else { this.death = 5; ygopro.stoc_send_chat_to_room(this, "${death_start_siding}", ygopro.constants.COLORS.BABYBLUE); } } else { win_pos = this.scores[this.dueling_players[0].name_vpass] > this.scores[this.dueling_players[oppo_pos].name_vpass] ? 0 : oppo_pos; this.finished_by_death = true; ygopro.stoc_send_chat_to_room(this, "${death2_finish_part1}" + this.dueling_players[win_pos].name + "${death2_finish_part2}", ygopro.constants.COLORS.BABYBLUE); if (this.hostinfo.mode === 1) { CLIENT_send_replays(this.dueling_players[oppo_pos - win_pos], this); } ygopro.stoc_send(this.dueling_players[oppo_pos - win_pos], 'DUEL_END'); if (this.hostinfo.mode === 2) { ygopro.stoc_send(this.dueling_players[oppo_pos - win_pos + 1], 'DUEL_END'); } this.scores[this.dueling_players[oppo_pos - win_pos].name_vpass] = -1; CLIENT_kick(this.dueling_players[oppo_pos - win_pos]); if (this.hostinfo.mode === 2) { CLIENT_kick(this.dueling_players[oppo_pos - win_pos + 1]); } } break; case 1: this.death = -1; ygopro.stoc_send_chat_to_room(this, "${death_start_quick}", ygopro.constants.COLORS.BABYBLUE); break; default: this.death = 5; ygopro.stoc_send_chat_to_room(this, "${death_start_siding}", ygopro.constants.COLORS.BABYBLUE); } } return true; } cancel_death() { if (this.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN || !this.death) { return false; } this.death = 0; ygopro.stoc_send_chat_to_room(this, "${death_cancel}", ygopro.constants.COLORS.BABYBLUE); return true; } terminate() { var e; if (this.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN) { this.scores[this.dueling_players[0].name_vpass] = 0; this.scores[this.dueling_players[1].name_vpass] = 0; } this.kicked = true; this.send_replays(); if (this.process) { try { this.process.kill(); } catch (error1) { e = error1; } } return this.delete(); } finish_recover(fail) { var buffer, j, len, player, ref, results; if (fail) { ygopro.stoc_send_chat_to_room(this, "${recover_fail}", ygopro.constants.COLORS.RED); return this.terminate(); } else { ygopro.stoc_send_chat_to_room(this, "${recover_success}", ygopro.constants.COLORS.BABYBLUE); this.recovering = false; ref = this.get_playing_player(); results = []; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; results.push((function() { var l, len1, ref1, results1; ref1 = this.recover_buffers[player.pos]; results1 = []; for (l = 0, len1 = ref1.length; l < len1; l++) { buffer = ref1[l]; results1.push(ygopro.stoc_send(player, "GAME_MSG", buffer)); } return results1; }).call(this)); } return results; } } async check_athletic() { var players, room; players = this.get_playing_player(); room = this; await Promise.all(players.map(async function(player) { var main, side, using_athletic; main = _.clone(player.main); side = _.clone(player.side); using_athletic = (await athleticChecker.checkAthletic({ main: main, side: side })); if (!using_athletic.success) { return log.warn("GET ATHLETIC FAIL", player.name, using_athletic.message); } else if (using_athletic.athletic) { return ygopro.stoc_send_chat_to_room(room, `${player.name}\${using_athletic_deck}`, ygopro.constants.COLORS.BABYBLUE); } })); } }; // 网络连接 netRequestHandler = function(client) { var connect_count, server; client.ip = client.remoteAddress; client.is_local = client.ip && (client.ip.includes('127.0.0.1') || client.ip.includes(real_windbot_server_ip)); connect_count = ROOM_connected_ip[client.ip] || 0; if (!settings.modules.test_mode.no_connect_count_limit && !client.is_local) { connect_count++; } ROOM_connected_ip[client.ip] = connect_count; //log.info "connect", client.ip, ROOM_connected_ip[client.ip] // server stand for the connection to ygopro server process server = new net.Socket(); client.server = server; server.client = client; client.setTimeout(2000); //连接前超时2秒 // 释放处理 client.on('close', function(had_error) { var room; //log.info "client closed", client.name, had_error room = ROOM_all[client.rid]; connect_count = ROOM_connected_ip[client.ip]; if (connect_count > 0) { connect_count--; } ROOM_connected_ip[client.ip] = connect_count; //log.info "disconnect", client.ip, ROOM_connected_ip[client.ip] if (!client.closed) { client.closed = true; if (settings.modules.heartbeat_detection.enabled) { CLIENT_heartbeat_unregister(client); } if (room) { if (!CLIENT_reconnect_register(client, client.rid)) { room.disconnect(client); } } else if (!client.had_new_reconnection) { SERVER_kick(client.server); } } }); client.on('error', function(error) { var room; //log.info "client error", client.name, error room = ROOM_all[client.rid]; connect_count = ROOM_connected_ip[client.ip]; if (connect_count > 0) { connect_count--; } ROOM_connected_ip[client.ip] = connect_count; //log.info "err disconnect", client.ip, ROOM_connected_ip[client.ip] if (!client.closed) { client.closed = true; if (room) { if (!CLIENT_reconnect_register(client, client.rid, error)) { room.disconnect(client, error); } } else if (!client.had_new_reconnection) { SERVER_kick(client.server); } } }); client.on('timeout', function() { if (!(settings.modules.reconnect.enabled && (disconnect_list[CLIENT_get_authorize_key(client)] || client.had_new_reconnection))) { client.destroy(); } }); server.on('close', function(had_error) { var room; if (!server.closed) { server.closed = true; } if (!server.client) { return; } //log.info "server closed", server.client.name, had_error room = ROOM_all[server.client.rid]; if (room && !server.system_kicked && !server.had_new_reconnection) { //log.info "server close", server.client.ip, ROOM_connected_ip[server.client.ip] room.disconnector = 'server'; } if (!server.client.closed) { ygopro.stoc_send_chat(server.client, "${server_closed}", ygopro.constants.COLORS.RED); //if room and settings.modules.replay_delay // room.send_replays() CLIENT_kick(server.client); SERVER_clear_disconnect(server); } }); server.on('error', function(error) { var room; server.closed = error; if (!server.client) { return; } //log.info "server error", client.name, error room = ROOM_all[server.client.rid]; if (room && !server.system_kicked && !server.had_new_reconnection) { //log.info "server err close", client.ip, ROOM_connected_ip[client.ip] room.disconnector = 'server'; } if (!server.client.closed) { ygopro.stoc_send_chat(server.client, `\${server_error}: ${error}`, ygopro.constants.COLORS.RED); //if room and settings.modules.replay_delay // room.send_replays() CLIENT_kick(server.client); SERVER_clear_disconnect(server); } }); if (ROOM_bad_ip[client.ip] > 5 || ROOM_connected_ip[client.ip] > 10) { log.info('BAD IP', client.ip); CLIENT_kick(client); return; } if (settings.modules.cloud_replay.enabled) { client.open_cloud_replay = async function(replay) { var buffer, e, replay_buffer; if (!replay) { ygopro.stoc_die(client, "${cloud_replay_no}"); return; } buffer = replay.toBuffer(); replay_buffer = null; try { replay_buffer = (await util.promisify(zlib.unzip)(buffer)); } catch (error1) { e = error1; log.info("cloud replay unzip error: " + err); ygopro.stoc_die(client, "${cloud_replay_error}"); return; } ygopro.stoc_send_chat(client, `\${cloud_replay_playing} ${replay.getDisplayString()}`, ygopro.constants.COLORS.BABYBLUE); client.write(replay_buffer, function() { CLIENT_kick(client); }); }; } // 需要重构 // 客户端到服务端(ctos)协议分析 client.pre_establish_buffers = new Array(); client.on('data', async function(ctos_buffer) { var bad_ip_count, buffer, ctos_filter, handle_data, j, l, len, len1, len2, m, ref, ref1, ref2, room; if (client.is_post_watcher) { room = ROOM_all[client.rid]; if (room) { handle_data = (await ygopro.helper.handleBuffer(ctos_buffer, "CTOS", ["CHAT"], { client: client, server: client.server })); if (handle_data.feedback) { log.warn(handle_data.feedback.message, client.name, client.ip); if (handle_data.feedback.type === "OVERSIZE" || ROOM_bad_ip[client.ip] > 5) { bad_ip_count = ROOM_bad_ip[client.ip]; if (bad_ip_count) { ROOM_bad_ip[client.ip] = bad_ip_count + 1; } else { ROOM_bad_ip[client.ip] = 1; } CLIENT_kick(client); return; } } ref = handle_data.datas; for (j = 0, len = ref.length; j < len; j++) { buffer = ref[j]; room.watcher.write(buffer); } } } else { ctos_filter = settings.modules.reconnect.enabled && client.pre_reconnecting ? ["UPDATE_DECK"] : null; handle_data = (await ygopro.helper.handleBuffer(ctos_buffer, "CTOS", ctos_filter, { client: client, server: client.server })); if (handle_data.feedback) { log.warn(handle_data.feedback.message, client.name, client.ip); if (handle_data.feedback.type === "OVERSIZE" || ROOM_bad_ip[client.ip] > 5) { bad_ip_count = ROOM_bad_ip[client.ip]; if (bad_ip_count) { ROOM_bad_ip[client.ip] = bad_ip_count + 1; } else { ROOM_bad_ip[client.ip] = 1; } CLIENT_kick(client); return; } } if (!client.server) { return; } if (client.established) { ref1 = handle_data.datas; for (l = 0, len1 = ref1.length; l < len1; l++) { buffer = ref1[l]; client.server.write(buffer); } } else { ref2 = handle_data.datas; for (m = 0, len2 = ref2.length; m < len2; m++) { buffer = ref2[m]; client.pre_establish_buffers.push(buffer); } } } }); // 服务端到客户端(stoc) server.on('data', async function(stoc_buffer) { var buffer, handle_data, j, len, ref; handle_data = (await ygopro.helper.handleBuffer(stoc_buffer, "STOC", null, { client: server.client, server: server })); if (handle_data.feedback) { log.warn(handle_data.feedback.message, server.client.name, server.client.ip); if (handle_data.feedback.type === "OVERSIZE") { server.destroy(); return; } } if (server.client && !server.client.closed) { ref = handle_data.datas; for (j = 0, len = ref.length; j < len; j++) { buffer = ref[j]; server.client.write(buffer); } } }); }; deck_name_match = global.deck_name_match = function(deck_name, player_name) { var parsed_deck_name; if (deck_name === player_name || deck_name === player_name + ".ydk" || deck_name === player_name + ".ydk.ydk") { return true; } parsed_deck_name = deck_name.match(/^([^\+ \uff0b]+)[\+ \uff0b](.+?)(\.ydk){0,2}$/); return parsed_deck_name && (player_name === parsed_deck_name[1] || player_name === parsed_deck_name[2]); }; // 功能模块 // return true to cancel a synchronous message ygopro.ctos_follow('PLAYER_INFO', true, async function(buffer, info, client, server, datas) { var banMCRequest, e, geo, lang, name, name_full, struct, vpass; // checkmate use username$password, but here don't // so remove the password name_full = info.name.split("$"); name = name_full[0]; vpass = name_full[1]; if (vpass && !vpass.length) { vpass = null; } if (_.any(settings.ban.illegal_id, function(badid) { var matchs, regexp; regexp = new RegExp(badid, 'i'); matchs = name.match(regexp); if (matchs) { name = matchs[1]; return true; } return false; }, name)) { client.rag = true; } if (settings.modules.mycard.enabled && settings.modules.mycard.ban_get && !client.is_local) { try { banMCRequest = (await axios.get(settings.modules.mycard.ban_get, { paramsSerializer: qs.stringify, params: { user: name } })); if (typeof banMCRequest.data === "object") { client.ban_mc = banMCRequest.data; } else { log.warn("ban get bad json", banMCRequest.data); } } catch (error1) { e = error1; log.warn('ban get error', e.toString()); } } struct = ygopro.structs.get("CTOS_PlayerInfo"); struct._setBuff(buffer); struct.set("name", name); buffer = struct.buffer; client.name = name; client.vpass = vpass; client.name_vpass = vpass ? name + "$" + vpass : name; if (!settings.modules.i18n.auto_pick || client.is_local) { client.lang = settings.modules.i18n.default; } else { geo = geoip.lookup(client.ip); if (!geo) { log.warn("fail to locate ip", client.name, client.ip); client.lang = settings.modules.i18n.fallback; } else { if (lang = settings.modules.i18n.map[geo.country]) { client.lang = lang; } else { //log.info("Not in map", geo.country, client.name, client.ip) client.lang = settings.modules.i18n.fallback; } } } return false; }); ygopro.ctos_follow('JOIN_GAME', true, async function(buffer, info, client, server, datas) { var available_logs, check_buffer_indentity, create_room_with_action, duelLog, exactBan, index, j, l, len, len1, len2, len3, m, n, name, pre_room, recover_match, ref, ref1, replay, replay_id, replays, room, struct; //log.info info info.pass = info.pass.trim(); client.pass = info.pass; if (CLIENT_is_able_to_reconnect(client) || CLIENT_is_able_to_kick_reconnect(client)) { CLIENT_pre_reconnect(client); return; } else if (settings.modules.stop) { ygopro.stoc_die(client, settings.modules.stop); } else if (info.pass === "Marshtomp" || info.pass === "the Big Brother") { ygopro.stoc_die(client, "${bad_user_name}"); } else if (info.pass.toUpperCase() === "R" && settings.modules.cloud_replay.enabled) { ygopro.stoc_send_chat(client, "${cloud_replay_hint}", ygopro.constants.COLORS.BABYBLUE); replays = (await dataManager.getCloudReplaysFromKey(CLIENT_get_authorize_key(client))); for (index = j = 0, len = replays.length; j < len; index = ++j) { replay = replays[index]; ygopro.stoc_send_chat(client, `<${index + 1}> ${replay.getDisplayString()}`, ygopro.constants.COLORS.BABYBLUE); } ygopro.stoc_send(client, 'ERROR_MSG', { msg: 1, code: 9 }); CLIENT_kick(client); } else if (info.pass.toUpperCase() === "RC" && settings.modules.tournament_mode.enable_recover) { ygopro.stoc_send_chat(client, "${recover_replay_hint}", ygopro.constants.COLORS.BABYBLUE); available_logs = (await dataManager.getDuelLogFromRecoverSearch(client.name_vpass)); for (l = 0, len1 = available_logs.length; l < len1; l++) { duelLog = available_logs[l]; ygopro.stoc_send_chat(client, duelLog.getViewString(), ygopro.constants.COLORS.BABYBLUE); } ygopro.stoc_send(client, 'ERROR_MSG', { msg: 1, code: 9 }); CLIENT_kick(client); } else if (info.pass.slice(0, 2).toUpperCase() === "R#" && settings.modules.cloud_replay.enabled) { replay_id = info.pass.split("#")[1]; replay = (await dataManager.getCloudReplayFromId(replay_id)); await client.open_cloud_replay(replay); } else if (info.pass.toUpperCase() === "W" && settings.modules.cloud_replay.enabled) { replay = (await dataManager.getRandomCloudReplay()); await client.open_cloud_replay(replay); } else if (info.version !== settings.version && !settings.alternative_versions.includes(info.version)) { ygopro.stoc_send_chat(client, settings.modules.update, ygopro.constants.COLORS.RED); ygopro.stoc_send(client, 'ERROR_MSG', { msg: 4, code: settings.version }); CLIENT_kick(client); } else if (!info.pass.length && !settings.modules.random_duel.enabled && !settings.modules.windbot.enabled && !settings.modules.challonge.enabled) { ygopro.stoc_die(client, "${blank_room_name}"); } else if (info.pass.length && settings.modules.mycard.enabled && info.pass.slice(0, 3) !== 'AI#') { ygopro.stoc_send_chat(client, '${loading_user_info}', ygopro.constants.COLORS.BABYBLUE); if (info.pass.length <= 8) { ygopro.stoc_die(client, '${invalid_password_length}'); return; } if (info.version !== settings.version && settings.alternative_versions.includes(info.version)) { info.version = settings.version; struct = ygopro.structs.get("CTOS_JoinGame"); struct._setBuff(buffer); struct.set("version", info.version); buffer = struct.buffer; } buffer = Buffer.from(info.pass.slice(0, 8), 'base64'); if (buffer.length !== 6) { ygopro.stoc_die(client, '${invalid_password_payload}'); return; } check_buffer_indentity = function(buf) { var checksum, i, m, ref; checksum = 0; for (i = m = 0, ref = buf.length; (0 <= ref ? m < ref : m > ref); i = 0 <= ref ? ++m : --m) { checksum += buf.readUInt8(i); } return (checksum & 0xFF) === 0; }; create_room_with_action = async function(buffer, decrypted_buffer, match_permit) { var action, len2, len3, m, n, name, opt1, opt2, opt3, options, player, ref, ref1, room, room_title, title; if (client.closed) { return; } action = buffer.readUInt8(1) >> 4; if (buffer !== decrypted_buffer && (action === 1 || action === 2 || action === 4)) { ygopro.stoc_die(client, '${invalid_password_unauthorized}'); return; } // 1 create public room // 2 create private room // 3 join room by id // 4 create or join room by id (use for match) // 5 join room by title switch (action) { case 1: case 2: name = crypto.createHash('md5').update(info.pass + client.name).digest('base64').slice(0, 10).replace('+', '-').replace('/', '_'); if (ROOM_find_by_name(name)) { ygopro.stoc_die(client, '${invalid_password_existed}'); return; } opt1 = buffer.readUInt8(2); opt2 = buffer.readUInt16LE(3); opt3 = buffer.readUInt8(5); options = { lflist: settings.hostinfo.lflist, time_limit: settings.hostinfo.time_limit, rule: (opt1 >> 5) & 3, mode: (opt1 >> 3) & 3, duel_rule: (!!((opt1 >> 2) & 1) ? 4 : 5), no_check_deck: !!((opt1 >> 1) & 1), no_shuffle_deck: !!(opt1 & 1), start_lp: opt2, start_hand: opt3 >> 4, draw_count: opt3 & 0xF, no_watch: settings.hostinfo.no_watch, auto_death: settings.hostinfo.auto_death }; options.lflist = _.findIndex(lflists, function(list) { return ((options.rule === 1) === list.tcg) && list.date.isBefore(); }); room_title = info.pass.slice(8).replace(String.fromCharCode(0xFEFF), ' '); if (_.any(badwords.level3, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return room_title.match(regexp); }, room_title)) { log.warn("BAD ROOM NAME LEVEL 3", room_title, client.name, client.ip); ygopro.stoc_die(client, "${bad_roomname_level3}"); return; } else if (_.any(badwords.level2, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return room_title.match(regexp); }, room_title)) { log.warn("BAD ROOM NAME LEVEL 2", room_title, client.name, client.ip); ygopro.stoc_die(client, "${bad_roomname_level2}"); return; } else if (_.any(badwords.level1, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return room_title.match(regexp); }, room_title)) { log.warn("BAD ROOM NAME LEVEL 1", room_title, client.name, client.ip); ygopro.stoc_die(client, "${bad_roomname_level1}"); return; } room = new Room(name, options); if (room) { room.title = room_title; room.private = action === 2; } break; case 3: name = info.pass.slice(8); room = ROOM_find_by_name(name); if (!room) { ygopro.stoc_die(client, '${invalid_password_not_found}'); return; } break; case 4: if (match_permit && !match_permit.permit) { ygopro.stoc_die(client, '${invalid_password_unauthorized}'); return; } room = (await ROOM_find_or_create_by_name('M#' + info.pass.slice(8))); if (room) { ref = room.get_playing_player(); for (m = 0, len2 = ref.length; m < len2; m++) { player = ref[m]; if (!(player && player.name === client.name)) { continue; } ygopro.stoc_die(client, '${invalid_password_unauthorized}'); return; } room.private = true; room.arena = settings.modules.arena_mode.mode; if (room.arena === "athletic") { room.max_player = 2; room.welcome = "${athletic_arena_tip}"; } } break; case 5: title = info.pass.slice(8).replace(String.fromCharCode(0xFEFF), ' '); room = ROOM_find_by_title(title); if (!room) { ygopro.stoc_die(client, '${invalid_password_not_found}'); return; } break; default: ygopro.stoc_die(client, '${invalid_password_action}'); return; } if (!room) { ygopro.stoc_die(client, "${server_full}"); } else if (room.error) { ygopro.stoc_die(client, room.error); } else if (room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN) { if (settings.modules.cloud_replay.enable_halfway_watch && !room.hostinfo.no_watch) { client.setTimeout(300000); //连接后超时5分钟 client.rid = _.indexOf(ROOM_all, room); client.is_post_watcher = true; ygopro.stoc_send_chat_to_room(room, `${client.name} \${watch_join}`); room.watchers.push(client); ygopro.stoc_send_chat(client, "${watch_watching}", ygopro.constants.COLORS.BABYBLUE); ref1 = room.watcher_buffers; for (n = 0, len3 = ref1.length; n < len3; n++) { buffer = ref1[n]; client.write(buffer); } } else { ygopro.stoc_die(client, "${watch_denied}"); } } else if (room.hostinfo.no_watch && room.players.length >= (room.hostinfo.mode === 2 ? 4 : 2)) { ygopro.stoc_die(client, "${watch_denied_room}"); } else { //client.room = room client.setTimeout(300000); //连接后超时5分钟 client.rid = _.indexOf(ROOM_all, room); room.connect(client); } }; _async.auto({ match_permit: function(done) { if (client.closed) { done(); return; } if (!settings.modules.arena_mode.check_permit) { done(null, null); return; } request({ url: settings.modules.arena_mode.check_permit, json: true, qs: { username: client.name, password: info.pass, arena: settings.modules.arena_mode.mode } }, function(error, response, body) { if (client.closed) { done(null, null); return; } if (!error && body) { done(null, body); } else { log.warn("Match permit request error", error); done(null, null); } }); }, get_user: function(done) { var decrypted_buffer, i, id, len2, m, ref, secret; if (client.closed) { done(); return; } if (id = users_cache[client.name]) { secret = id % 65535 + 1; decrypted_buffer = Buffer.allocUnsafe(6); ref = [0, 2, 4]; for (m = 0, len2 = ref.length; m < len2; m++) { i = ref[m]; decrypted_buffer.writeUInt16LE(buffer.readUInt16LE(i) ^ secret, i); } if (check_buffer_indentity(decrypted_buffer)) { done(null, { original: decrypted_buffer, decrypted: decrypted_buffer }); return; } } //TODO: query database directly, like preload. request({ baseUrl: settings.modules.mycard.auth_base_url, url: '/users/' + encodeURIComponent(client.name) + '.json', qs: { api_key: settings.modules.mycard.auth_key, api_username: client.name, skip_track_visit: true }, json: true }, function(error, response, body) { var len3, n, ref1; if (!error && body && body.user) { users_cache[client.name] = body.user.id; secret = body.user.id % 65535 + 1; decrypted_buffer = Buffer.allocUnsafe(6); ref1 = [0, 2, 4]; for (n = 0, len3 = ref1.length; n < len3; n++) { i = ref1[n]; decrypted_buffer.writeUInt16LE(buffer.readUInt16LE(i) ^ secret, i); } if (check_buffer_indentity(decrypted_buffer)) { buffer = decrypted_buffer; } } else { log.warn("READ USER FAIL", error, body); done("${create_room_failed}"); return; } if (!check_buffer_indentity(buffer)) { done('${invalid_password_checksum}'); return; } done(null, { original: buffer, decrypted: decrypted_buffer }); }); } }, function(err, data) { if (client.closed) { return; } if (err) { ygopro.stoc_die(client, err); return; } return create_room_with_action(data.get_user.original, data.get_user.decrypted, data.match_permit); }); } else if (settings.modules.challonge.enabled) { if (info.version !== settings.version && settings.alternative_versions.includes(info.version)) { info.version = settings.version; struct = ygopro.structs.get("CTOS_JoinGame"); struct._setBuff(buffer); struct.set("version", info.version); buffer = struct.buffer; } pre_room = ROOM_find_by_name(info.pass); if (pre_room && pre_room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && settings.modules.cloud_replay.enable_halfway_watch && !pre_room.hostinfo.no_watch) { room = pre_room; client.setTimeout(300000); //连接后超时5分钟 client.rid = _.indexOf(ROOM_all, room); client.is_post_watcher = true; ygopro.stoc_send_chat_to_room(room, `${client.name} \${watch_join}`); room.watchers.push(client); ygopro.stoc_send_chat(client, "${watch_watching}", ygopro.constants.COLORS.BABYBLUE); ref = room.watcher_buffers; for (m = 0, len2 = ref.length; m < len2; m++) { buffer = ref[m]; client.write(buffer); } } else { ygopro.stoc_send_chat(client, '${loading_user_info}', ygopro.constants.COLORS.BABYBLUE); client.setTimeout(300000); //连接后超时5分钟 recover_match = info.pass.match(/^(RC|RECOVER)(\d*)T(\d*)$/); _async.auto({ participant_data: function(done) { challonge.participants._index({ id: settings.modules.challonge.tournament_id, callback: done }); }, match_data: function(done) { challonge.matches._index({ id: settings.modules.challonge.tournament_id, callback: done, no_cache: !!recover_match }); } }, async function(err, datas) { var create_room_name, found, k, len3, len4, match, n, o, player, ref1, ref2, ref3, ref4, user; if (client.closed) { return; } if (err || !datas.participant_data || !datas.match_data) { log.warn("Failed loading Challonge user info", err); ygopro.stoc_die(client, '${challonge_match_load_failed}'); return; } found = false; ref1 = datas.participant_data; for (k in ref1) { user = ref1[k]; if (user.participant && user.participant.name && deck_name_match(user.participant.name, client.name)) { found = user.participant; break; } } if (!found) { ygopro.stoc_die(client, '${challonge_user_not_found}'); return; } client.challonge_info = found; found = false; ref2 = datas.match_data; for (k in ref2) { match = ref2[k]; if (match && match.match && !match.match.winnerId && match.match.state !== "complete" && match.match.player1Id && match.match.player2Id && (match.match.player1Id === client.challonge_info.id || match.match.player2Id === client.challonge_info.id)) { found = match.match; break; } } if (!found) { ygopro.stoc_die(client, '${challonge_match_not_found}'); return; } //if found.winnerId // ygopro.stoc_die(client, '${challonge_match_already_finished}') // return create_room_name = 'M#' + found.id; if (recover_match) { create_room_name = recover_match[0] + ',' + create_room_name; } room = (await ROOM_find_or_create_by_name(create_room_name)); if (room) { room.challonge_info = found; // room.max_player = 2 room.welcome = "${challonge_match_created}"; } if (!room) { ygopro.stoc_die(client, "${server_full}"); } else if (room.error) { ygopro.stoc_die(client, room.error); } else if (room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN) { if (settings.modules.cloud_replay.enable_halfway_watch && !room.hostinfo.no_watch) { //client.setTimeout(300000) #连接后超时5分钟 client.rid = _.indexOf(ROOM_all, room); client.is_post_watcher = true; ygopro.stoc_send_chat_to_room(room, `${client.name} \${watch_join}`); room.watchers.push(client); ygopro.stoc_send_chat(client, "${watch_watching}", ygopro.constants.COLORS.BABYBLUE); ref3 = room.watcher_buffers; for (n = 0, len3 = ref3.length; n < len3; n++) { buffer = ref3[n]; client.write(buffer); } } else { ygopro.stoc_die(client, "${watch_denied}"); } } else if (room.hostinfo.no_watch && room.players.length >= (room.hostinfo.mode === 2 ? 4 : 2)) { ygopro.stoc_die(client, "${watch_denied_room}"); } else { ref4 = room.get_playing_player(); for (o = 0, len4 = ref4.length; o < len4; o++) { player = ref4[o]; if (!(player && player !== client && player.challonge_info.id === client.challonge_info.id)) { continue; } ygopro.stoc_die(client, "${challonge_player_already_in}"); return; } //client.room = room //client.setTimeout(300000) #连接后超时5分钟 client.rid = _.indexOf(ROOM_all, room); room.connect(client); } }); } } else if (!client.name || client.name === "") { ygopro.stoc_die(client, "${bad_user_name}"); } else if (ROOM_connected_ip[client.ip] > 5) { log.warn("MULTI LOGIN", client.name, client.ip); ygopro.stoc_die(client, "${too_much_connection}" + client.ip); } else if (settings.modules.mysql.enabled && (await dataManager.checkBan("name", client.name))) { //账号被封 exactBan = (await dataManager.checkBanWithNameAndIP(client.name, client.ip)); if (!exactBan) { exactBan = dataManager.getBan(client.name, client.ip); await dataManager.banPlayer(exactBan); } log.warn("BANNED USER LOGIN", client.name, client.ip); ygopro.stoc_die(client, "${banned_user_login}"); } else if (settings.modules.mysql.enabled && (await dataManager.checkBan("ip", client.ip))) { //IP被封 log.warn("BANNED IP LOGIN", client.name, client.ip); ygopro.stoc_die(client, "${banned_ip_login}"); } else if (!settings.modules.tournament_mode.enabled && !settings.modules.challonge.enabled && _.any(badwords.level3, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return name.match(regexp); }, name = client.name)) { log.warn("BAD NAME LEVEL 3", client.name, client.ip); ygopro.stoc_die(client, "${bad_name_level3}"); } else if (!settings.modules.tournament_mode.enabled && !settings.modules.challonge.enabled && _.any(badwords.level2, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return name.match(regexp); }, name = client.name)) { log.warn("BAD NAME LEVEL 2", client.name, client.ip); ygopro.stoc_die(client, "${bad_name_level2}"); } else if (!settings.modules.tournament_mode.enabled && !settings.modules.challonge.enabled && _.any(badwords.level1, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return name.match(regexp); }, name = client.name)) { log.warn("BAD NAME LEVEL 1", client.name, client.ip); ygopro.stoc_die(client, "${bad_name_level1}"); } else if (info.pass.length && !ROOM_validate(info.pass)) { ygopro.stoc_die(client, "${invalid_password_room}"); } else { if (info.version !== settings.version && settings.alternative_versions.includes(info.version)) { info.version = settings.version; struct = ygopro.structs.get("CTOS_JoinGame"); struct._setBuff(buffer); struct.set("version", info.version); buffer = struct.buffer; } //log.info 'join_game',info.pass, client.name room = (await ROOM_find_or_create_by_name(info.pass, client.ip)); if (!room) { ygopro.stoc_die(client, "${server_full}"); } else if (room.error) { ygopro.stoc_die(client, room.error); } else if (room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN) { if (settings.modules.cloud_replay.enable_halfway_watch && !room.hostinfo.no_watch) { client.setTimeout(300000); //连接后超时5分钟 client.rid = _.indexOf(ROOM_all, room); client.is_post_watcher = true; ygopro.stoc_send_chat_to_room(room, `${client.name} \${watch_join}`); room.watchers.push(client); ygopro.stoc_send_chat(client, "${watch_watching}", ygopro.constants.COLORS.BABYBLUE); ref1 = room.watcher_buffers; for (n = 0, len3 = ref1.length; n < len3; n++) { buffer = ref1[n]; client.write(buffer); } } else { ygopro.stoc_die(client, "${watch_denied}"); } } else if (room.hostinfo.no_watch && room.players.length >= (room.hostinfo.mode === 2 ? 4 : 2)) { ygopro.stoc_die(client, "${watch_denied_room}"); } else { client.setTimeout(300000); //连接后超时5分钟 client.rid = _.indexOf(ROOM_all, room); room.connect(client); } } }); ygopro.stoc_follow('JOIN_GAME', false, async function(buffer, info, client, server, datas) { var j, len, player, recorder, ref, room, watcher; //欢迎信息 room = ROOM_all[client.rid]; if (!(room && !client.reconnecting)) { return; } if (!room.join_game_buffer) { room.join_game_buffer = buffer; } if (settings.modules.welcome) { ygopro.stoc_send_chat(client, settings.modules.welcome, ygopro.constants.COLORS.GREEN); } if (room.welcome) { ygopro.stoc_send_chat(client, room.welcome, ygopro.constants.COLORS.BABYBLUE); } if (room.welcome2) { ygopro.stoc_send_chat(client, room.welcome2, ygopro.constants.COLORS.PINK); } if (settings.modules.arena_mode.enabled && !client.is_local) { //and not client.score_shown request({ url: settings.modules.arena_mode.get_score + encodeURIComponent(client.name), json: true }, function(error, response, body) { var rank_txt; if (error) { log.warn('LOAD SCORE ERROR', client.name, error); } else if (!body || _.isString(body)) { log.warn('LOAD SCORE FAIL', client.name, response.statusCode, response.statusMessage, body); } else { //log.info 'LOAD SCORE', client.name, body rank_txt = body.arena_rank > 0 ? "${rank_arena}" + body.arena_rank : "${rank_blank}"; ygopro.stoc_send_chat(client, `${client.name}\${exp_value_part1}${body.exp}\${exp_value_part2}\${exp_value_part3}${Math.round(body.pt)}${rank_txt}\${exp_value_part4}`, ygopro.constants.COLORS.BABYBLUE); } }); } //client.score_shown = true if (settings.modules.random_duel.record_match_scores && room.random_type === 'M') { ygopro.stoc_send_chat_to_room(room, ROOM_player_get_score(client), ygopro.constants.COLORS.GREEN); ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player.pos !== 7 && player !== client) { ygopro.stoc_send_chat(client, ROOM_player_get_score(player), ygopro.constants.COLORS.GREEN); } } } if (!room.recorder) { room.recorder = recorder = net.connect(room.port, function() { ygopro.ctos_send(recorder, 'PLAYER_INFO', { name: "Marshtomp" }); ygopro.ctos_send(recorder, 'JOIN_GAME', { version: settings.version, pass: "Marshtomp" }); ygopro.ctos_send(recorder, 'HS_TOOBSERVER'); }); recorder.on('data', function(data) { room = ROOM_all[client.rid]; if (!(room && settings.modules.cloud_replay.enabled)) { return; } room.recorder_buffers.push(data); }); recorder.on('error', function(error) {}); } if (settings.modules.cloud_replay.enable_halfway_watch && !room.watcher && !room.hostinfo.no_watch) { room.watcher = watcher = settings.modules.test_mode.watch_public_hand ? room.recorder : net.connect(room.port, function() { ygopro.ctos_send(watcher, 'PLAYER_INFO', { name: "the Big Brother" }); ygopro.ctos_send(watcher, 'JOIN_GAME', { version: settings.version, pass: "the Big Brother" }); ygopro.ctos_send(watcher, 'HS_TOOBSERVER'); }); watcher.on('data', function(data) { var l, len1, ref1, w; room = ROOM_all[client.rid]; if (!room) { return; } room.watcher_buffers.push(data); ref1 = room.watchers; for (l = 0, len1 = ref1.length; l < len1; l++) { w = ref1[l]; if (w) { //a WTF fix w.write(data); } } }); watcher.on('error', function(error) { log.error("watcher error", error); }); } }); // 登场台词 load_dialogues = global.load_dialogues = async function() { return (await loadRemoteData(dialogues, "dialogues", settings.modules.dialogues.get)); }; ygopro.stoc_follow('GAME_MSG', true, async function(buffer, info, client, server, datas) { var card, chain, check, count, cpos, deck_found, found, hint_type, i, id, j, l, len, len1, len2, len3, limbo_found, line, loc, m, max_loop, msg, n, o, oppo_pos, phase, player, playertype, pos, ppos, reason, ref, ref1, ref2, ref3, ref4, ref5, room, trigger_location, val, win_pos; room = ROOM_all[client.rid]; if (!(room && !client.reconnecting)) { return; } msg = buffer.readInt8(0); //console.log client.pos, "MSG", ygopro.constants.MSG[msg] if (ygopro.constants.MSG[msg] === 'RETRY' && room.recovering) { room.finish_recover(true); return true; } if (settings.modules.retry_handle.enabled) { if (ygopro.constants.MSG[msg] === 'RETRY') { if (client.retry_count == null) { client.retry_count = 0; } client.retry_count++; log.warn("MSG_RETRY detected", client.name, client.ip, msg, client.retry_count); if (settings.modules.retry_handle.max_retry_count && client.retry_count >= settings.modules.retry_handle.max_retry_count) { ygopro.stoc_send_chat_to_room(room, client.name + "${retry_too_much_room_part1}" + settings.modules.retry_handle.max_retry_count + "${retry_too_much_room_part2}", ygopro.constants.COLORS.BABYBLUE); ygopro.stoc_send_chat(client, "${retry_too_much_part1}" + settings.modules.retry_handle.max_retry_count + "${retry_too_much_part2}", ygopro.constants.COLORS.RED); CLIENT_send_replays(client, room); CLIENT_kick(client); return true; } if (client.last_game_msg) { if (settings.modules.retry_handle.max_retry_count) { ygopro.stoc_send_chat(client, "${retry_part1}" + client.retry_count + "${retry_part2}" + settings.modules.retry_handle.max_retry_count + "${retry_part3}", ygopro.constants.COLORS.RED); } else { ygopro.stoc_send_chat(client, "${retry_not_counted}", ygopro.constants.COLORS.BABYBLUE); } if (client.last_hint_msg) { ygopro.stoc_send(client, 'GAME_MSG', client.last_hint_msg); } ygopro.stoc_send(client, 'GAME_MSG', client.last_game_msg); return true; } } else { client.last_game_msg = buffer; client.last_game_msg_title = ygopro.constants.MSG[msg]; } // log.info(client.name, client.last_game_msg_title) } else if (ygopro.constants.MSG[msg] !== 'RETRY') { client.last_game_msg = buffer; client.last_game_msg_title = ygopro.constants.MSG[msg]; } // log.info(client.name, client.last_game_msg_title) if ((msg >= 10 && msg < 30) || msg === 132 || (msg >= 140 && msg <= 144)) { //SELECT和ANNOUNCE开头的消息 if (room.recovering) { ygopro.ctos_send(server, 'RESPONSE', room.recover_replay.responses.splice(0, 1)[0]); if (!room.recover_replay.responses.length) { room.finish_recover(); } return true; } else { room.waiting_for_player = client; room.last_active_time = moment(); } } //log.info("#{ygopro.constants.MSG[msg]}等待#{room.waiting_for_player.name}") //log.info 'MSG', ygopro.constants.MSG[msg] if (ygopro.constants.MSG[msg] === 'START') { playertype = buffer.readUInt8(1); client.is_first = !(playertype & 0xf); client.lp = room.hostinfo.start_lp; if (room.hostinfo.mode !== 2) { client.card_count = 0; } room.duel_stage = ygopro.constants.DUEL_STAGE.DUELING; if (client.pos === 0) { room.turn = 0; room.duel_count++; if (room.death && room.duel_count > 1) { if (room.death === -1) { ygopro.stoc_send_chat_to_room(room, "${death_start_final}", ygopro.constants.COLORS.BABYBLUE); } else { ygopro.stoc_send_chat_to_room(room, "${death_start_extra}", ygopro.constants.COLORS.BABYBLUE); } } if (room.recovering) { ygopro.stoc_send_chat_to_room(room, "${recover_start_hint}", ygopro.constants.COLORS.BABYBLUE); } } if (client.is_first && (room.hostinfo.mode !== 2 || client.pos === 0 || client.pos === 2)) { room.first_list.push(client.name_vpass); } if (settings.modules.retry_handle.enabled) { client.retry_count = 0; client.last_game_msg = null; } } //ygopro.stoc_send_chat_to_room(room, "LP跟踪调试信息: #{client.name} 初始LP #{client.lp}") if (ygopro.constants.MSG[msg] === 'HINT') { hint_type = buffer.readUInt8(1); if (hint_type === 3) { client.last_hint_msg = buffer; } } if (ygopro.constants.MSG[msg] === 'NEW_TURN') { if (client.pos === 0) { room.turn++; if (room.recovering && room.recover_from_turn <= room.turn) { room.finish_recover(); } if (room.death && room.death !== -2) { if (room.turn >= room.death) { oppo_pos = room.hostinfo.mode === 2 ? 2 : 1; if (room.dueling_players[0].lp !== room.dueling_players[oppo_pos].lp && room.turn > 1) { win_pos = room.dueling_players[0].lp > room.dueling_players[oppo_pos].lp ? 0 : oppo_pos; ygopro.stoc_send_chat_to_room(room, "${death_finish_part1}" + room.dueling_players[win_pos].name + "${death_finish_part2}", ygopro.constants.COLORS.BABYBLUE); if (room.hostinfo.mode === 2) { room.finished_by_death = true; ygopro.stoc_send(room.dueling_players[oppo_pos - win_pos], 'DUEL_END'); ygopro.stoc_send(room.dueling_players[oppo_pos - win_pos + 1], 'DUEL_END'); room.scores[room.dueling_players[oppo_pos - win_pos].name_vpass] = -1; CLIENT_kick(room.dueling_players[oppo_pos - win_pos]); CLIENT_kick(room.dueling_players[oppo_pos - win_pos + 1]); } else { ygopro.ctos_send(room.dueling_players[oppo_pos - win_pos].server, 'SURRENDER'); } } else { room.death = -1; ygopro.stoc_send_chat_to_room(room, "${death_remain_final}", ygopro.constants.COLORS.BABYBLUE); } } else { ygopro.stoc_send_chat_to_room(room, "${death_remain_part1}" + (room.death - room.turn) + "${death_remain_part2}", ygopro.constants.COLORS.BABYBLUE); } } } if (client.surrend_confirm) { client.surrend_confirm = false; ygopro.stoc_send_chat(client, "${surrender_canceled}", ygopro.constants.COLORS.BABYBLUE); } } if (ygopro.constants.MSG[msg] === 'NEW_PHASE') { phase = buffer.readInt16LE(1); oppo_pos = room.hostinfo.mode === 2 ? 2 : 1; if (client.pos === 0 && room.death === -2 && !(phase === 0x1 && room.turn < 2)) { if (room.dueling_players[0].lp !== room.dueling_players[oppo_pos].lp) { win_pos = room.dueling_players[0].lp > room.dueling_players[oppo_pos].lp ? 0 : oppo_pos; ygopro.stoc_send_chat_to_room(room, "${death_finish_part1}" + room.dueling_players[win_pos].name + "${death_finish_part2}", ygopro.constants.COLORS.BABYBLUE); if (room.hostinfo.mode === 2) { room.finished_by_death = true; ygopro.stoc_send(room.dueling_players[oppo_pos - win_pos], 'DUEL_END'); ygopro.stoc_send(room.dueling_players[oppo_pos - win_pos + 1], 'DUEL_END'); room.scores[room.dueling_players[oppo_pos - win_pos].name_vpass] = -1; CLIENT_kick(room.dueling_players[oppo_pos - win_pos]); CLIENT_kick(room.dueling_players[oppo_pos - win_pos + 1]); } else { ygopro.ctos_send(room.dueling_players[oppo_pos - win_pos].server, 'SURRENDER'); } } else { room.death = -1; ygopro.stoc_send_chat_to_room(room, "${death_remain_final}", ygopro.constants.COLORS.BABYBLUE); } } } if (ygopro.constants.MSG[msg] === 'WIN' && client.pos === 0) { if (room.recovering) { room.finish_recover(true); return true; } pos = buffer.readUInt8(1); if (!(client.is_first || pos === 2 || room.duel_stage !== ygopro.constants.DUEL_STAGE.DUELING)) { pos = 1 - pos; } if (pos >= 0 && room.hostinfo.mode === 2) { pos = pos * 2; } reason = buffer.readUInt8(2); //log.info {winner: pos, reason: reason} //room.duels.push {winner: pos, reason: reason} room.winner = pos; room.turn = 0; room.duel_stage = ygopro.constants.DUEL_STAGE.END; if (settings.modules.heartbeat_detection.enabled) { ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; player.heartbeat_protected = false; } delete room.long_resolve_card; delete room.long_resolve_chain; } if (room && !room.finished && room.dueling_players[pos]) { room.winner_name = room.dueling_players[pos].name_vpass; //log.info room.dueling_players, pos room.scores[room.winner_name] = room.scores[room.winner_name] + 1; if (room.match_kill) { room.match_kill = false; room.scores[room.winner_name] = 99; } } if (room.death) { if (settings.modules.http.quick_death_rule === 1 || settings.modules.http.quick_death_rule === 3) { room.death = -1; } else { room.death = 5; } } } if (ygopro.constants.MSG[msg] === 'MATCH_KILL' && client.pos === 0) { room.match_kill = true; } //lp跟踪 if (ygopro.constants.MSG[msg] === 'DAMAGE' && client.pos === 0) { pos = buffer.readUInt8(1); if (!client.is_first) { pos = 1 - pos; } if (pos >= 0 && room.hostinfo.mode === 2) { pos = pos * 2; } val = buffer.readInt32LE(2); room.dueling_players[pos].lp -= val; if (room.dueling_players[pos].lp < 0) { room.dueling_players[pos].lp = 0; } if ((0 < (ref1 = room.dueling_players[pos].lp) && ref1 <= 100)) { ygopro.stoc_send_chat_to_room(room, "${lp_low_opponent}", ygopro.constants.COLORS.PINK); } } if (ygopro.constants.MSG[msg] === 'RECOVER' && client.pos === 0) { pos = buffer.readUInt8(1); if (!client.is_first) { pos = 1 - pos; } if (pos >= 0 && room.hostinfo.mode === 2) { pos = pos * 2; } val = buffer.readInt32LE(2); room.dueling_players[pos].lp += val; } if (ygopro.constants.MSG[msg] === 'LPUPDATE' && client.pos === 0) { pos = buffer.readUInt8(1); if (!client.is_first) { pos = 1 - pos; } if (pos >= 0 && room.hostinfo.mode === 2) { pos = pos * 2; } val = buffer.readInt32LE(2); room.dueling_players[pos].lp = val; } if (ygopro.constants.MSG[msg] === 'PAY_LPCOST' && client.pos === 0) { pos = buffer.readUInt8(1); if (!client.is_first) { pos = 1 - pos; } if (pos >= 0 && room.hostinfo.mode === 2) { pos = pos * 2; } val = buffer.readInt32LE(2); room.dueling_players[pos].lp -= val; if (room.dueling_players[pos].lp < 0) { room.dueling_players[pos].lp = 0; } if ((0 < (ref2 = room.dueling_players[pos].lp) && ref2 <= 100)) { ygopro.stoc_send_chat_to_room(room, "${lp_low_self}", ygopro.constants.COLORS.PINK); } } //track card count //todo: track card count in tag mode if (ygopro.constants.MSG[msg] === 'MOVE' && room.hostinfo.mode !== 2) { pos = buffer.readUInt8(5); if (!client.is_first) { pos = 1 - pos; } loc = buffer.readUInt8(6); if ((loc & 0xe) && pos === 0) { client.card_count--; } pos = buffer.readUInt8(9); if (!client.is_first) { pos = 1 - pos; } loc = buffer.readUInt8(10); if ((loc & 0xe) && pos === 0) { client.card_count++; } } if (ygopro.constants.MSG[msg] === 'DRAW' && room.hostinfo.mode !== 2) { pos = buffer.readUInt8(1); if (!client.is_first) { pos = 1 - pos; } if (pos === 0) { count = buffer.readInt8(2); client.card_count += count; } } // check panel confirming cards in heartbeat if (settings.modules.heartbeat_detection.enabled && ygopro.constants.MSG[msg] === 'CONFIRM_CARDS') { check = false; count = buffer.readInt8(2); max_loop = 3 + (count - 1) * 7; deck_found = 0; limbo_found = 0; // support custom cards which may be in location 0 in KoishiPro or EdoPro for (i = l = 3, ref3 = max_loop; l <= ref3; i = l += 7) { loc = buffer.readInt8(i + 5); if ((loc & 0x41) > 0) { deck_found++; } else if (loc === 0) { limbo_found++; } if ((deck_found > 0 && count > 1) || limbo_found > 0) { check = true; break; } } if (check) { //console.log("Confirming cards:" + client.name) client.heartbeat_protected = true; } } // chain detection if (settings.modules.heartbeat_detection.enabled && client.pos === 0) { if (ygopro.constants.MSG[msg] === 'CHAINING') { card = buffer.readUInt32LE(1); found = false; for (m = 0, len1 = long_resolve_cards.length; m < len1; m++) { id = long_resolve_cards[m]; if (!(id === card)) { continue; } found = true; break; } if (found) { room.long_resolve_card = card; } else { // console.log(0,card) delete room.long_resolve_card; } } else if (ygopro.constants.MSG[msg] === 'CHAINED' && room.long_resolve_card) { chain = buffer.readInt8(1); if (!room.long_resolve_chain) { room.long_resolve_chain = []; } room.long_resolve_chain[chain] = true; // console.log(1,chain) delete room.long_resolve_card; } else if (ygopro.constants.MSG[msg] === 'CHAIN_SOLVING' && room.long_resolve_chain) { chain = buffer.readInt8(1); // console.log(2,chain) if (room.long_resolve_chain[chain]) { ref4 = room.get_playing_player(); for (n = 0, len2 = ref4.length; n < len2; n++) { player = ref4[n]; player.heartbeat_protected = true; } } } else if ((ygopro.constants.MSG[msg] === 'CHAIN_NEGATED' || ygopro.constants.MSG[msg] === 'CHAIN_DISABLED') && room.long_resolve_chain) { chain = buffer.readInt8(1); // console.log(3,chain) delete room.long_resolve_chain[chain]; } else if (ygopro.constants.MSG[msg] === 'CHAIN_END') { // console.log(4,chain) delete room.long_resolve_card; delete room.long_resolve_chain; } } //登场台词 if (settings.modules.dialogues.enabled && !room.recovering) { if (ygopro.constants.MSG[msg] === 'SUMMONING' || ygopro.constants.MSG[msg] === 'SPSUMMONING' || ygopro.constants.MSG[msg] === 'CHAINING') { card = buffer.readUInt32LE(1); trigger_location = buffer.readUInt8(6); if (dialogues.dialogues[card] && (ygopro.constants.MSG[msg] !== 'CHAINING' || (trigger_location & 0x8) && client.ready_trap)) { ref5 = _.lines(dialogues.dialogues[card][Math.floor(Math.random() * dialogues.dialogues[card].length)]); for (o = 0, len3 = ref5.length; o < len3; o++) { line = ref5[o]; ygopro.stoc_send_chat(client, line, ygopro.constants.COLORS.PINK); } } } if (ygopro.constants.MSG[msg] === 'POS_CHANGE') { loc = buffer.readUInt8(6); ppos = buffer.readUInt8(8); cpos = buffer.readUInt8(9); client.ready_trap = !!(loc & 0x8) && !!(ppos & 0xa) && !!(cpos & 0x5); } else if (ygopro.constants.MSG[msg] !== 'UPDATE_CARD' && ygopro.constants.MSG[msg] !== 'WAITING') { client.ready_trap = false; } } if (room.recovering && client.pos < 4) { if (ygopro.constants.MSG[msg] !== 'WAITING') { room.recover_buffers[client.pos].push(buffer); } return true; } return false; }); //房间管理 ygopro.ctos_follow('HS_TOOBSERVER', true, async function(buffer, info, client, server, datas) { var j, len, player, ref, room; room = ROOM_all[client.rid]; if (!room) { return; } if (room.hostinfo.no_watch) { ygopro.stoc_send_chat(client, "${watch_denied_room}", ygopro.constants.COLORS.RED); return true; } if ((!room.arena && !settings.modules.challonge.enabled) || client.is_local) { return false; } ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player === client) { ygopro.stoc_send_chat(client, "${cannot_to_observer}", ygopro.constants.COLORS.BABYBLUE); return true; } } return false; }); ygopro.ctos_follow('HS_KICK', true, async function(buffer, info, client, server, datas) { var j, len, player, ref, room; room = ROOM_all[client.rid]; if (!room) { return; } ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player && player.pos === info.pos && player !== client) { if (room.arena === "athletic" || settings.modules.challonge.enabled) { ygopro.stoc_send_chat_to_room(room, `${client.name} \${kicked_by_system}`, ygopro.constants.COLORS.RED); CLIENT_kick(client); return true; } client.kick_count = client.kick_count ? client.kick_count + 1 : 1; if (client.kick_count >= 5 && room.random_type) { ygopro.stoc_send_chat_to_room(room, `${client.name} \${kicked_by_system}`, ygopro.constants.COLORS.RED); await ROOM_ban_player(player.name, player.ip, "${random_ban_reason_zombie}"); CLIENT_kick(client); return true; } ygopro.stoc_send_chat_to_room(room, `${player.name} \${kicked_by_player}`, ygopro.constants.COLORS.RED); } } return false; }); ygopro.stoc_follow('TYPE_CHANGE', true, async function(buffer, info, client, server, datas) { var is_host, selftype; selftype = info.type & 0xf; is_host = ((info.type >> 4) & 0xf) !== 0; // if room and room.hostinfo.no_watch and selftype == 7 // ygopro.stoc_die(client, "${watch_denied_room}") // return true client.is_host = is_host; client.pos = selftype; //console.log "TYPE_CHANGE to #{client.name}:", info, selftype, is_host return false; }); ygopro.stoc_follow('HS_PLAYER_ENTER', true, async function(buffer, info, client, server, datas) { var pos, room, struct; room = ROOM_all[client.rid]; if (!(room && settings.modules.hide_name && room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN)) { return false; } pos = info.pos; if (pos < 4 && pos !== client.pos) { struct = ygopro.structs.get("STOC_HS_PlayerEnter"); struct._setBuff(buffer); struct.set("name", "********"); buffer = struct.buffer; } return false; }); ygopro.stoc_follow('HS_PLAYER_CHANGE', true, async function(buffer, info, client, server, datas) { var is_ready, j, len, p1, p2, player, pos, possibly_max_player, ref, room; room = ROOM_all[client.rid]; if (!(room && client.pos === 0)) { return; } pos = info.status >> 4; is_ready = (info.status & 0xf) === 9; room.ready_player_count = 0; room.ready_player_count_without_host = 0; ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player.pos === pos) { player.is_ready = is_ready; } if (player.is_ready) { ++room.ready_player_count; if (!player.is_host) { ++room.ready_player_count_without_host; } } } if (settings.modules.athletic_check.enabled) { possibly_max_player = room.hostinfo.mode === 2 ? 4 : 2; if (room.ready_player_count >= possibly_max_player) { room.check_athletic(); } } if (room.max_player && pos < room.max_player) { if (room.arena) { // mycard p1 = room.players[0]; p2 = room.players[1]; if (!p1 || !p2) { if (room.waiting_for_player_interval) { clearInterval(room.waiting_for_player_interval); room.waiting_for_player_interval = null; } return; } room.waiting_for_player2 = room.waiting_for_player; room.waiting_for_player = null; if (p1.is_ready && p2.is_ready) { room.waiting_for_player = p1.is_host ? p1 : p2; } if (!p1.is_ready && p2.is_ready) { room.waiting_for_player = p1; } if (!p2.is_ready && p1.is_ready) { room.waiting_for_player = p2; } if (room.waiting_for_player !== room.waiting_for_player2) { room.waiting_for_player2 = room.waiting_for_player; room.waiting_for_player_time = settings.modules.arena_mode.ready_time; room.waiting_for_player_interval = setInterval((function() { wait_room_start_arena(ROOM_all[client.rid]); }), 1000); } else if (!room.waiting_for_player && room.waiting_for_player_interval) { clearInterval(room.waiting_for_player_interval); room.waiting_for_player_interval = null; room.waiting_for_player_time = settings.modules.arena_mode.ready_time; // random duel } } else { if (room.ready_player_count_without_host >= room.max_player - 1) { //log.info "all ready" setTimeout((function() { wait_room_start(ROOM_all[client.rid], settings.modules.random_duel.ready_time); }), 1000); } } } }); ygopro.ctos_follow('REQUEST_FIELD', true, async function(buffer, info, client, server, datas) { return true; }); ygopro.stoc_follow('FIELD_FINISH', true, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!(room && settings.modules.reconnect.enabled)) { return true; } client.reconnecting = false; if (client.time_confirm_required) { // client did not send TIME_CONFIRM client.waiting_for_last = true; } else if (client.last_game_msg && client.last_game_msg_title !== 'WAITING') { // client sent TIME_CONFIRM if (client.last_hint_msg) { ygopro.stoc_send(client, 'GAME_MSG', client.last_hint_msg); } ygopro.stoc_send(client, 'GAME_MSG', client.last_game_msg); } return true; }); ygopro.stoc_follow('DUEL_END', false, async function(buffer, info, client, server, datas) { var j, l, len, len1, player, ref, ref1, room; room = ROOM_all[client.rid]; if (!(room && settings.modules.replay_delay && room.hostinfo.mode === 1)) { return; } SOCKET_flush_data(client, datas); CLIENT_send_replays(client, room); if (!room.replays_sent_to_watchers) { room.replays_sent_to_watchers = true; ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player && player.pos > 3) { CLIENT_send_replays(player, room); } } ref1 = room.watchers; for (l = 0, len1 = ref1.length; l < len1; l++) { player = ref1[l]; if (player) { CLIENT_send_replays(player, room); } } } }); wait_room_start = async function(room, time) { var j, len, player, ref; if (room && room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && room.ready_player_count_without_host >= room.max_player - 1) { time -= 1; if (time) { if (!(time % 5)) { ygopro.stoc_send_chat_to_room(room, `${time <= 9 ? ' ' : ''}${time}\${kick_count_down}`, time <= 9 ? ygopro.constants.COLORS.RED : ygopro.constants.COLORS.LIGHTBLUE); } setTimeout((function() { wait_room_start(room, time); }), 1000); } else { ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player && player.is_host) { await ROOM_ban_player(player.name, player.ip, "${random_ban_reason_zombie}"); ygopro.stoc_send_chat_to_room(room, `${player.name} \${kicked_by_system}`, ygopro.constants.COLORS.RED); CLIENT_kick(player); } } } } }; wait_room_start_arena = async function(room) { var display_name, j, len, player, ref; if (room && room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && room.waiting_for_player) { room.waiting_for_player_time = room.waiting_for_player_time - 1; if (room.waiting_for_player_time > 0) { if (!(room.waiting_for_player_time % 5)) { ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (!(player)) { continue; } display_name = (settings.modules.hide_name && player !== room.waiting_for_player ? "********" : room.waiting_for_player.name); ygopro.stoc_send_chat(player, `${room.waiting_for_player_time <= 9 ? ' ' : ''}${room.waiting_for_player_time}\${kick_count_down_arena_part1} ${display_name} \${kick_count_down_arena_part2}`, room.waiting_for_player_time <= 9 ? ygopro.constants.COLORS.RED : ygopro.constants.COLORS.LIGHTBLUE); } } } else { ygopro.stoc_send_chat_to_room(room, `${room.waiting_for_player.name} \${kicked_by_system}`, ygopro.constants.COLORS.RED); CLIENT_kick(room.waiting_for_player); if (room.waiting_for_player_interval) { clearInterval(room.waiting_for_player_interval); room.waiting_for_player_interval = null; } } } }; //tip ygopro.stoc_send_random_tip = async function(client) { if (settings.modules.tips.enabled && tips.tips.length) { ygopro.stoc_send_chat(client, "Tip: " + tips.tips[Math.floor(Math.random() * tips.tips.length)]); } }; ygopro.stoc_send_random_tip_to_room = async function(room) { if (settings.modules.tips.enabled && tips.tips.length) { ygopro.stoc_send_chat_to_room(room, "Tip: " + tips.tips[Math.floor(Math.random() * tips.tips.length)]); } }; loadRemoteData = global.loadRemoteData = async function(loadObject, name, url) { var body, e; try { body = ((await axios.get(url, { responseType: "json" }))).data; if (_.isString(body)) { log.warn(`${name} bad json`, body); return false; } if (!body) { log.warn(`${name} empty`, body); return false; } await setting_change(loadObject, name, body); log.info(`${name} loaded`); return true; } catch (error1) { e = error1; log.warn(`${name} error`, e); return false; } }; load_tips = global.load_tips = async function() { return (await loadRemoteData(tips, "tips", settings.modules.tips.get)); }; ygopro.stoc_follow('DUEL_START', false, async function(buffer, info, client, server, datas) { var deck_arena, deck_name, deck_text, j, l, len, len1, player, ref, ref1, room; room = ROOM_all[client.rid]; if (!(room && !client.reconnecting)) { return; } if (room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN) { //first start room.duel_stage = ygopro.constants.DUEL_STAGE.FINGER; room.start_time = moment().format(); room.turn = 0; if (!room.windbot && settings.modules.http.websocket_roomlist) { roomlist.start(room); } //room.duels = [] room.dueling_players = []; ref = room.get_playing_player(); for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; room.dueling_players[player.pos] = player; room.scores[player.name_vpass] = 0; room.player_datas.push({ key: CLIENT_get_authorize_key(player), name: player.name, pos: player.pos }); if (room.random_type === 'T') { // 双打房不记录匹配过 ROOM_players_oppentlist[player.ip] = null; } } if (room.hostinfo.auto_death) { ygopro.stoc_send_chat_to_room(room, `\${auto_death_part1}${room.hostinfo.auto_death}\${auto_death_part2}`, ygopro.constants.COLORS.BABYBLUE); } } else if (room.duel_stage === ygopro.constants.DUEL_STAGE.SIDING && client.pos < 4) { // side deck verified client.selected_preduel = true; if (client.side_tcount) { clearInterval(client.side_interval); client.side_interval = null; client.side_tcount = null; } } if (settings.modules.hide_name && room.duel_count === 0) { ref1 = room.get_playing_player(); for (l = 0, len1 = ref1.length; l < len1; l++) { player = ref1[l]; if (player !== client) { ygopro.stoc_send(client, 'HS_PLAYER_ENTER', { name: player.name, pos: player.pos }); } } } if (settings.modules.tips.enabled) { ygopro.stoc_send_random_tip(client); } deck_text = null; if (client.main && client.main.length) { deck_text = '#ygopro-server deck log\n#main\n' + client.main.join('\n') + '\n!side\n' + client.side.join('\n') + '\n'; room.decks[client.name] = deck_text; } if (settings.modules.deck_log.enabled && deck_text && !client.deck_saved && !room.windbot) { deck_arena = settings.modules.deck_log.arena + '-'; if (room.arena) { deck_arena = deck_arena + room.arena; } else if (room.hostinfo.mode === 2) { deck_arena = deck_arena + 'tag'; } else if (room.random_type === 'S') { deck_arena = deck_arena + 'entertain'; } else if (room.random_type === 'M') { deck_arena = deck_arena + 'athletic'; } else { deck_arena = deck_arena + 'custom'; } //log.info "DECK LOG START", client.name, room.arena if (settings.modules.deck_log.local) { deck_name = moment().format('YYYY-MM-DD HH-mm-ss') + ' ' + room.process_pid + ' ' + client.pos + ' ' + client.ip.slice(7) + ' ' + client.name.replace(/[\/\\\?\*]/g, '_'); fs.writeFile(settings.modules.deck_log.local + deck_name + '.ydk', deck_text, 'utf-8', function(err) { if (err) { return log.warn('DECK SAVE ERROR', err); } }); } if (settings.modules.deck_log.post) { request.post({ url: settings.modules.deck_log.post, form: { accesskey: settings.modules.deck_log.accesskey, deck: deck_text, playername: client.name, arena: deck_arena } }, function(error, response, body) { if (error) { log.warn('DECK POST ERROR', error); } else { if (response.statusCode !== 200) { log.warn('DECK POST FAIL', response.statusCode, client.name, body); } } }); } //else //log.info 'DECK POST OK', response.statusCode, client.name, body client.deck_saved = true; } }); ygopro.ctos_follow('SURRENDER', true, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!room) { return; } if (room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN || room.hostinfo.mode === 2) { return true; } if (room.random_type && room.turn < 3 && !client.flee_free && !settings.modules.test_mode.surrender_anytime && !(room.random_type === 'M' && settings.modules.random_duel.record_match_scores)) { ygopro.stoc_send_chat(client, "${surrender_denied}", ygopro.constants.COLORS.BABYBLUE); return true; } return false; }); report_to_big_brother = global.report_to_big_brother = async function(roomname, sender, ip, level, content, match) { if (!settings.modules.big_brother.enabled) { return; } request.post({ url: settings.modules.big_brother.post, form: { accesskey: settings.modules.big_brother.accesskey, roomname: roomname, sender: sender, ip: ip, level: level, content: content, match: match } }, function(error, response, body) { if (error) { log.warn('BIG BROTHER ERROR', error); } else { if (response.statusCode !== 200) { log.warn('BIG BROTHER FAIL', response.statusCode, roomname, body); } } }); }; //else //log.info 'BIG BROTHER OK', response.statusCode, roomname, body ygopro.ctos_follow('CHAT', true, async function(buffer, info, client, server, datas) { var cancel, ccolor, cip, cmd, cmsg, cname, color, cvalue, msg, name, oldmsg, ref, room, struct, windbot; room = ROOM_all[client.rid]; if (!room) { return; } msg = _.trim(info.msg); cancel = _.startsWith(msg, "/"); if (!(cancel || !(room.random_type || room.arena) || room.duel_stage === ygopro.constants.DUEL_STAGE.FINGER || room.duel_stage === ygopro.constants.DUEL_STAGE.FIRSTGO || room.duel_stage === ygopro.constants.DUEL_STAGE.SIDING)) { room.last_active_time = moment(); } cmd = msg.split(' '); switch (cmd[0]) { case '/投降': case '/surrender': if (room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN || room.hostinfo.mode === 2) { return cancel; } if (room.random_type && room.turn < 3) { ygopro.stoc_send_chat(client, "${surrender_denied}", ygopro.constants.COLORS.BABYBLUE); return cancel; } if (client.surrend_confirm) { ygopro.ctos_send(client.server, 'SURRENDER'); } else { ygopro.stoc_send_chat(client, "${surrender_confirm}", ygopro.constants.COLORS.BABYBLUE); client.surrend_confirm = true; } break; case '/help': ygopro.stoc_send_chat(client, "${chat_order_main}"); ygopro.stoc_send_chat(client, "${chat_order_help}"); if (!settings.modules.mycard.enabled) { ygopro.stoc_send_chat(client, "${chat_order_roomname}"); } if (settings.modules.windbot.enabled) { ygopro.stoc_send_chat(client, "${chat_order_windbot}"); } if (settings.modules.tips.enabled) { ygopro.stoc_send_chat(client, "${chat_order_tip}"); } if (settings.modules.chat_color.enabled) { ygopro.stoc_send_chat(client, "${chat_order_chatcolor_1}"); } if (settings.modules.chat_color.enabled) { ygopro.stoc_send_chat(client, "${chat_order_chatcolor_2}"); } break; case '/tip': if (settings.modules.tips.enabled) { ygopro.stoc_send_random_tip(client); } break; case '/ai': if (settings.modules.windbot.enabled && client.is_host && !settings.modules.challonge.enabled && !room.arena && room.random_type !== 'M') { cmd.shift(); if (name = cmd.join(' ')) { windbot = _.sample(_.filter(windbots, function(w) { return w.name === name || w.deck === name; })); if (!windbot) { ygopro.stoc_send_chat(client, "${windbot_deck_not_found}", ygopro.constants.COLORS.RED); return; } } else { windbot = _.sample(_.filter(windbots, function(w) { return !w.hidden; })); } if (room.random_type) { ygopro.stoc_send_chat(client, "${windbot_disable_random_room} " + room.name, ygopro.constants.COLORS.BABYBLUE); } room.add_windbot(windbot); } break; case '/roomname': if (room) { ygopro.stoc_send_chat(client, "${room_name} " + room.name, ygopro.constants.COLORS.BABYBLUE); } break; case '/color': if (settings.modules.chat_color.enabled) { cip = CLIENT_get_authorize_key(client); if (cmsg = cmd[1]) { if (cmsg.toLowerCase() === "help") { ygopro.stoc_send_chat(client, "${show_color_list}", ygopro.constants.COLORS.BABYBLUE); ref = ygopro.constants.COLORS; for (cname in ref) { cvalue = ref[cname]; if (cvalue > 10) { ygopro.stoc_send_chat(client, cname, cvalue); } } } else if (cmsg.toLowerCase() === "default") { chat_color.save_list[cip] = false; setting_save(chat_color); ygopro.stoc_send_chat(client, "${set_chat_color_default}", ygopro.constants.COLORS.BABYBLUE); } else { ccolor = cmsg.toUpperCase(); if (ygopro.constants.COLORS[ccolor] && ygopro.constants.COLORS[ccolor] > 10 && ygopro.constants.COLORS[ccolor] < 20) { chat_color.save_list[cip] = ccolor; setting_save(chat_color); ygopro.stoc_send_chat(client, "${set_chat_color_part1}" + ccolor + "${set_chat_color_part2}", ygopro.constants.COLORS.BABYBLUE); } else { ygopro.stoc_send_chat(client, "${color_not_found_part1}" + ccolor + "${color_not_found_part2}", ygopro.constants.COLORS.RED); } } } else { if (color = chat_color.save_list[cip]) { ygopro.stoc_send_chat(client, "${get_chat_color_part1}" + color + "${get_chat_color_part2}", ygopro.constants.COLORS.BABYBLUE); } else { ygopro.stoc_send_chat(client, "${get_chat_color_default}", ygopro.constants.COLORS.BABYBLUE); } } } } //when '/test' // ygopro.stoc_send_hint_card_to_room(room, 2333365) if (msg.length > 100) { log.warn("SPAM WORD", client.name, client.ip, msg); if (client.abuse_count) { client.abuse_count = client.abuse_count + 2; } ygopro.stoc_send_chat(client, "${chat_warn_level0}", ygopro.constants.COLORS.RED); cancel = true; } if (!(room && (room.random_type || room.arena))) { if (!cancel && settings.modules.display_watchers && client.is_post_watcher) { ygopro.stoc_send_chat_to_room(room, `${client.name}: ${msg}`, 9); return true; } return cancel; } if (client.abuse_count >= 5 || CLIENT_is_banned_by_mc(client)) { log.warn("BANNED CHAT", client.name, client.ip, msg); ygopro.stoc_send_chat(client, "${banned_chat_tip}" + (client.ban_mc && client.ban_mc.message ? ": " + client.ban_mc.message : ""), ygopro.constants.COLORS.RED); return true; } oldmsg = msg; if (_.any(badwords.level3, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return msg.match(regexp); }, msg)) { log.warn("BAD WORD LEVEL 3", client.name, client.ip, oldmsg, RegExp.$1); report_to_big_brother(room.name, client.name, client.ip, 3, oldmsg, RegExp.$1); cancel = true; if (client.abuse_count > 0) { ygopro.stoc_send_chat(client, "${banned_duel_tip}", ygopro.constants.COLORS.RED); await ROOM_ban_player(client.name, client.ip, "${random_ban_reason_abuse}"); await ROOM_ban_player(client.name, client.ip, "${random_ban_reason_abuse}", 3); CLIENT_send_replays(client, room); CLIENT_kick(client); return true; } else { client.abuse_count = client.abuse_count + 4; ygopro.stoc_send_chat(client, "${chat_warn_level2}", ygopro.constants.COLORS.RED); } } else if (client.rag && room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN) { client.rag = false; //ygopro.stoc_send_chat(client, "${chat_warn_level0}", ygopro.constants.COLORS.RED) cancel = true; } else if (_.any(settings.ban.spam_word, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return msg.match(regexp); }, msg)) { //log.warn "SPAM WORD", client.name, client.ip, oldmsg client.abuse_count = client.abuse_count + 2; ygopro.stoc_send_chat(client, "${chat_warn_level0}", ygopro.constants.COLORS.RED); cancel = true; } else if (_.any(badwords.level2, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return msg.match(regexp); }, msg)) { log.warn("BAD WORD LEVEL 2", client.name, client.ip, oldmsg, RegExp.$1); report_to_big_brother(room.name, client.name, client.ip, 2, oldmsg, RegExp.$1); client.abuse_count = client.abuse_count + 3; ygopro.stoc_send_chat(client, "${chat_warn_level2}", ygopro.constants.COLORS.RED); cancel = true; } else { _.each(badwords.level1, function(badword) { var regexp; //log.info msg regexp = new RegExp(badword, "ig"); msg = msg.replace(regexp, "**"); }, msg); if (oldmsg !== msg) { log.warn("BAD WORD LEVEL 1", client.name, client.ip, oldmsg, RegExp.$1); report_to_big_brother(room.name, client.name, client.ip, 1, oldmsg, RegExp.$1); client.abuse_count = client.abuse_count + 1; ygopro.stoc_send_chat(client, "${chat_warn_level1}"); struct = ygopro.structs.get("chat"); struct._setBuff(buffer); struct.set("msg", msg); buffer = struct.buffer; } else if (_.any(badwords.level0, function(badword) { var regexp; regexp = new RegExp(badword, 'i'); return msg.match(regexp); }, msg)) { log.info("BAD WORD LEVEL 0", client.name, client.ip, oldmsg, RegExp.$1); report_to_big_brother(room.name, client.name, client.ip, 0, oldmsg, RegExp.$1); } } if (client.abuse_count >= 2) { ROOM_unwelcome(room, client, "${random_ban_reason_abuse}"); } if (client.abuse_count >= 5) { ygopro.stoc_send_chat_to_room(room, `${client.name} \${chat_banned}`, ygopro.constants.COLORS.RED); await ROOM_ban_player(client.name, client.ip, "${random_ban_reason_abuse}"); } if (!cancel && settings.modules.display_watchers && client.is_post_watcher) { ygopro.stoc_send_chat_to_room(room, `${client.name}: ${msg}`, 9); return true; } return cancel; }); ygopro.ctos_follow('UPDATE_DECK', true, async function(buffer, info, client, server, datas) { var buff_main, buff_side, card, current_deck, deck, deck_array, deck_main, deck_side, deck_text, deckbuf, decks, found_deck, i, j, l, len, len1, line, oppo_pos, recover_player_data, recoveredDeck, room, struct, win_pos; if (settings.modules.reconnect.enabled && client.pre_reconnecting) { if (!CLIENT_is_able_to_reconnect(client) && !CLIENT_is_able_to_kick_reconnect(client)) { ygopro.stoc_send_chat(client, "${reconnect_failed}", ygopro.constants.COLORS.RED); CLIENT_kick(client); } else if (CLIENT_is_able_to_reconnect(client, buffer)) { CLIENT_reconnect(client); } else if (CLIENT_is_able_to_kick_reconnect(client, buffer)) { CLIENT_kick_reconnect(client, buffer); } else { ygopro.stoc_send_chat(client, "${deck_incorrect_reconnect}", ygopro.constants.COLORS.RED); ygopro.stoc_send(client, 'ERROR_MSG', { msg: 2, code: 0 }); ygopro.stoc_send(client, 'HS_PLAYER_CHANGE', { status: (client.pos << 4) | 0xa }); } return true; } room = ROOM_all[client.rid]; if (!room) { return false; } //log.info info if (info.mainc > 256 || info.sidec > 256) { // Prevent attack, see https://github.com/Fluorohydride/ygopro/issues/2174 CLIENT_kick(client); return true; } buff_main = (function() { var j, ref, results; results = []; for (i = j = 0, ref = info.mainc; (0 <= ref ? j < ref : j > ref); i = 0 <= ref ? ++j : --j) { results.push(info.deckbuf[i]); } return results; })(); buff_side = (function() { var j, ref, ref1, results; results = []; for (i = j = ref = info.mainc, ref1 = info.mainc + info.sidec; (ref <= ref1 ? j < ref1 : j > ref1); i = ref <= ref1 ? ++j : --j) { results.push(info.deckbuf[i]); } return results; })(); client.main = buff_main; client.side = buff_side; if (room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN) { client.start_deckbuf = Buffer.from(buffer); } oppo_pos = room.hostinfo.mode === 2 ? 2 : 1; if (settings.modules.http.quick_death_rule >= 2 && room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && room.death && room.scores[room.dueling_players[0].name_vpass] !== room.scores[room.dueling_players[oppo_pos].name_vpass]) { win_pos = room.scores[room.dueling_players[0].name_vpass] > room.scores[room.dueling_players[oppo_pos].name_vpass] ? 0 : oppo_pos; room.finished_by_death = true; ygopro.stoc_send_chat_to_room(room, "${death2_finish_part1}" + room.dueling_players[win_pos].name + "${death2_finish_part2}", ygopro.constants.COLORS.BABYBLUE); if (room.hostinfo.mode === 1) { CLIENT_send_replays(room.dueling_players[oppo_pos - win_pos], room); } ygopro.stoc_send(room.dueling_players[oppo_pos - win_pos], 'DUEL_END'); if (room.hostinfo.mode === 2) { ygopro.stoc_send(room.dueling_players[oppo_pos - win_pos + 1], 'DUEL_END'); } room.scores[room.dueling_players[oppo_pos - win_pos].name_vpass] = -1; CLIENT_kick(room.dueling_players[oppo_pos - win_pos]); if (room.hostinfo.mode === 2) { CLIENT_kick(room.dueling_players[oppo_pos - win_pos + 1]); } return true; } struct = ygopro.structs.get("deck"); struct._setBuff(buffer); if (room.random_type || room.arena) { if (client.pos === 0) { room.waiting_for_player = room.waiting_for_player2; } room.last_active_time = moment(); } if (room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && room.recovering) { recover_player_data = _.find(room.recover_duel_log.players, function(player) { return player.realName === client.name_vpass && buffer.toString("base64") === player.startDeckBuffer; }); if (recover_player_data) { recoveredDeck = recover_player_data.getCurrentDeck(); struct.set("mainc", recoveredDeck.main.length); struct.set("sidec", recoveredDeck.side.length); struct.set("deckbuf", recoveredDeck.main.concat(recoveredDeck.side)); if (recover_player_data.isFirst) { room.determine_firstgo = client; } } else { struct.set("mainc", 1); struct.set("sidec", 1); struct.set("deckbuf", [4392470, 4392470]); ygopro.stoc_send_chat(client, "${deck_incorrect_reconnect}", ygopro.constants.COLORS.RED); } } else if (room.duel_stage === ygopro.constants.DUEL_STAGE.BEGIN && room.hostinfo.mode === 1 && settings.modules.tournament_mode.enabled && settings.modules.tournament_mode.deck_check && fs.readdirSync(settings.modules.tournament_mode.deck_path).length) { struct.set("mainc", 1); struct.set("sidec", 1); struct.set("deckbuf", [4392470, 4392470]); buffer = struct.buffer; found_deck = false; decks = fs.readdirSync(settings.modules.tournament_mode.deck_path); for (j = 0, len = decks.length; j < len; j++) { deck = decks[j]; if (deck_name_match(deck, client.name)) { found_deck = deck; } } if (found_deck) { deck_text = fs.readFileSync(settings.modules.tournament_mode.deck_path + found_deck, { encoding: "ASCII" }); deck_array = deck_text.split("\n"); deck_main = []; deck_side = []; current_deck = deck_main; for (l = 0, len1 = deck_array.length; l < len1; l++) { line = deck_array[l]; if (line.indexOf("!side") >= 0) { current_deck = deck_side; } card = parseInt(line); if (!isNaN(card)) { current_deck.push(card); } } if (_.isEqual(buff_main, deck_main) && _.isEqual(buff_side, deck_side)) { deckbuf = deck_main.concat(deck_side); struct.set("mainc", deck_main.length); struct.set("sidec", deck_side.length); struct.set("deckbuf", deckbuf); buffer = struct.buffer; //log.info("deck ok: " + client.name) ygopro.stoc_send_chat(client, `\${deck_correct_part1} ${found_deck} \${deck_correct_part2}`, ygopro.constants.COLORS.BABYBLUE); } else { //log.info("bad deck: " + client.name + " / " + buff_main + " / " + buff_side) ygopro.stoc_send_chat(client, `\${deck_incorrect_part1} ${found_deck} \${deck_incorrect_part2}`, ygopro.constants.COLORS.RED); } } else { //log.info("player deck not found: " + client.name) ygopro.stoc_send_chat(client, `${client.name}\${deck_not_found}`, ygopro.constants.COLORS.RED); } } return false; }); ygopro.ctos_follow('RESPONSE', false, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!(room && (room.random_type || room.arena))) { return; } room.last_active_time = moment(); }); ygopro.stoc_follow('TIME_LIMIT', true, async function(buffer, info, client, server, datas) { var check, cur_players, room; room = ROOM_all[client.rid]; if (!room) { return; } check = false; if (room.hostinfo.mode !== 2) { check = (client.is_first && info.player === 0) || (!client.is_first && info.player === 1); } else { cur_players = []; switch (room.turn % 4) { case 1: cur_players[0] = 0; cur_players[1] = 3; break; case 2: cur_players[0] = 0; cur_players[1] = 2; break; case 3: cur_players[0] = 1; cur_players[1] = 2; break; case 0: cur_players[0] = 1; cur_players[1] = 3; } if (!room.dueling_players[0].is_first) { cur_players[0] = cur_players[0] + 2; cur_players[1] = cur_players[1] - 2; } check = client.pos === cur_players[info.player]; } if (room.recovering) { if (check) { ygopro.ctos_send(server, 'TIME_CONFIRM'); } return true; } if (settings.modules.reconnect.enabled) { if (client.closed) { ygopro.ctos_send(server, 'TIME_CONFIRM'); return true; } else { client.time_confirm_required = true; } } if (!(settings.modules.heartbeat_detection.enabled && room.duel_stage === ygopro.constants.DUEL_STAGE.DUELING && !room.windbot)) { return; } if (check) { CLIENT_heartbeat_register(client, false); } return false; }); ygopro.ctos_follow('TIME_CONFIRM', false, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!room) { return; } if (room.recovered) { room.recovered = false; } if (settings.modules.reconnect.enabled) { if (client.waiting_for_last) { client.waiting_for_last = false; if (client.last_game_msg && client.last_game_msg_title !== 'WAITING') { if (client.last_hint_msg) { ygopro.stoc_send(client, 'GAME_MSG', client.last_hint_msg); } ygopro.stoc_send(client, 'GAME_MSG', client.last_game_msg); } } client.time_confirm_required = false; } if (settings.modules.heartbeat_detection.enabled) { client.heartbeat_protected = false; client.heartbeat_responsed = true; CLIENT_heartbeat_unregister(client); } }); ygopro.ctos_follow('HAND_RESULT', false, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!room) { return; } client.selected_preduel = true; if (room.random_type || room.arena) { if (client.pos === 0) { room.waiting_for_player = room.waiting_for_player2; } room.last_active_time = moment().subtract(settings.modules.random_duel.hang_timeout - 19, 's'); } }); ygopro.ctos_follow('TP_RESULT', false, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!room) { return; } client.selected_preduel = true; // room.selecting_tp = false if (!(room.random_type || room.arena)) { return; } room.last_active_time = moment(); }); ygopro.stoc_follow('CHAT', true, async function(buffer, info, client, server, datas) { var j, len, pid, player, ref, room, tcolor, tplayer; room = ROOM_all[client.rid]; pid = info.player; if (!(room && pid < 4 && settings.modules.chat_color.enabled && (!settings.modules.hide_name || room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN))) { return; } if (room.duel_stage === ygopro.constants.DUEL_STAGE.DUELING && !room.dueling_players[0].is_first) { if (room.hostinfo.mode === 2) { pid = { 0: 2, 1: 3, 2: 0, 3: 1 }[pid]; } else { pid = 1 - pid; } } ref = room.players; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player && player.pos === pid) { tplayer = player; } } if (!tplayer) { return; } tcolor = chat_color.save_list[CLIENT_get_authorize_key(tplayer)]; if (tcolor) { ygopro.stoc_send(client, 'CHAT', { player: ygopro.constants.COLORS[tcolor], msg: tplayer.name + ": " + info.msg }); return true; } }); ygopro.stoc_follow('SELECT_HAND', true, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!room) { return false; } if (client.pos === 0) { room.duel_stage = ygopro.constants.DUEL_STAGE.FINGER; } if (room.random_type || room.arena) { if (client.pos === 0) { room.waiting_for_player = client; } else { room.waiting_for_player2 = client; } room.last_active_time = moment().subtract(settings.modules.random_duel.hang_timeout - 19, 's'); } if (room.determine_firstgo) { ygopro.ctos_send(server, "HAND_RESULT", { res: client.pos === 0 ? 2 : 1 }); return true; } else { client.selected_preduel = false; } return false; }); ygopro.stoc_follow('HAND_RESULT', true, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!room) { return false; } return room.determine_firstgo; }); ygopro.stoc_follow('SELECT_TP', true, async function(buffer, info, client, server, datas) { var room; room = ROOM_all[client.rid]; if (!room) { return false; } room.duel_stage = ygopro.constants.DUEL_STAGE.FIRSTGO; if (room.random_type || room.arena) { room.waiting_for_player = client; room.last_active_time = moment(); } if (room.determine_firstgo) { ygopro.ctos_send(server, "TP_RESULT", { res: room.determine_firstgo === client ? 1 : 0 }); return true; } else { client.selected_preduel = false; room.selecting_tp = client; } return false; }); ygopro.stoc_follow('CHANGE_SIDE', false, async function(buffer, info, client, server, datas) { var room, room_name, sinterval, temp_log; room = ROOM_all[client.rid]; if (!room) { return; } if (client.pos === 0) { room.duel_stage = ygopro.constants.DUEL_STAGE.SIDING; } client.selected_preduel = false; if (settings.modules.side_timeout) { client.side_tcount = settings.modules.side_timeout; ygopro.stoc_send_chat(client, `\${side_timeout_part1}${settings.modules.side_timeout}\${side_timeout_part2}`, ygopro.constants.COLORS.BABYBLUE); sinterval = setInterval(function() { if (!(room && client && client.side_tcount && room.duel_stage === ygopro.constants.DUEL_STAGE.SIDING)) { clearInterval(sinterval); return; } if (client.side_tcount === 1) { ygopro.stoc_send_chat_to_room(room, client.name + "${side_overtime_room}", ygopro.constants.COLORS.BABYBLUE); ygopro.stoc_send_chat(client, "${side_overtime}", ygopro.constants.COLORS.RED); //room.scores[client.name_vpass] = -9 CLIENT_send_replays(client, room); CLIENT_kick(client); return clearInterval(sinterval); } else { client.side_tcount = client.side_tcount - 1; return ygopro.stoc_send_chat(client, `\${side_remain_part1}${client.side_tcount}\${side_remain_part2}`, ygopro.constants.COLORS.BABYBLUE); } }, 60000); client.side_interval = sinterval; } if (settings.modules.challonge.enabled && settings.modules.challonge.post_score_midduel && room.hostinfo.mode !== 2 && client.pos === 0) { temp_log = JSON.parse(JSON.stringify(room.get_challonge_score())); delete temp_log.winnerId; room_name = room.name; challonge.matches._update({ id: settings.modules.challonge.tournament_id, matchId: room.challonge_info.id, match: temp_log, callback: function(err, data) { if (err) { log.warn("Errored pushing scores to Challonge.", room_name, err); } else { refresh_challonge_cache(); } } }); } if (room.random_type || room.arena) { if (client.pos === 0) { room.waiting_for_player = client; } else { room.waiting_for_player2 = client; } room.last_active_time = moment(); } }); ygopro.stoc_follow('REPLAY', true, async function(buffer, info, client, server, datas) { var i, j, l, len, len1, player, playerInfos, ref, ref1, replay_filename, room; room = ROOM_all[client.rid]; if (!room) { return settings.modules.tournament_mode.enabled && settings.modules.tournament_mode.block_replay_to_player || settings.modules.replay_delay; } if (!room.replays[room.duel_count - 1]) { // console.log("Replay saved: ", room.duel_count - 1, client.pos) room.replays[room.duel_count - 1] = buffer; } if (settings.modules.mysql.enabled) { if (client.pos === 0) { replay_filename = moment().format("YYYY-MM-DD HH-mm-ss"); if (room.hostinfo.mode !== 2) { ref = room.dueling_players; for (i = j = 0, len = ref.length; j < len; i = ++j) { player = ref[i]; replay_filename = replay_filename + (i > 0 ? " VS " : " ") + player.name; } } else { ref1 = room.dueling_players; for (i = l = 0, len1 = ref1.length; l < len1; i = ++l) { player = ref1[i]; replay_filename = replay_filename + (i > 0 ? (i === 2 ? " VS " : " & ") : " ") + player.name; } } replay_filename = replay_filename.replace(/[\/\\\?\*]/g, '_') + ".yrp"; playerInfos = room.dueling_players.map(function(player) { return { name: player.name, pos: player.pos, realName: player.name_vpass, startDeckBuffer: player.start_deckbuf, deck: { main: player.main, side: player.side }, isFirst: player.is_first, winner: player.pos === room.winner, ip: player.ip, score: room.scores[player.name_vpass], lp: player.lp != null ? player.lp : room.hostinfo.start_lp, cardCount: player.card_count != null ? player.card_count : room.hostinfo.start_hand }; }); fs.writeFile(settings.modules.tournament_mode.replay_path + replay_filename, buffer, function(err) { if (err) { return log.warn("SAVE REPLAY ERROR", replay_filename, err); } }); dataManager.saveDuelLog(room.name, room.process_pid.toString(), room.cloud_replay_id, replay_filename, room.hostinfo.mode, room.duel_count, playerInfos); // no synchronize here because too slow } if (settings.modules.cloud_replay.enabled && settings.modules.tournament_mode.enabled && settings.modules.tournament_mode.replay_safe) { ygopro.stoc_send_chat(client, `\${cloud_replay_delay_part1}R#${room.cloud_replay_id}\${cloud_replay_delay_part2}`, ygopro.constants.COLORS.BABYBLUE); } return settings.modules.tournament_mode.enabled && settings.modules.tournament_mode.block_replay_to_player || settings.modules.replay_delay && room.hostinfo.mode === 1; } else { return settings.modules.replay_delay && room.hostinfo.mode === 1; } }); // spawn windbot windbot_looplimit = 0; windbot_process = global.windbot_process = null; spawn_windbot = global.spawn_windbot = function() { var windbot_bin, windbot_parameters; if (/^win/.test(process.platform)) { windbot_bin = 'WindBot.exe'; windbot_parameters = []; } else { windbot_bin = 'mono'; windbot_parameters = ['WindBot.exe']; } windbot_parameters.push('ServerMode=true'); windbot_parameters.push('ServerPort=' + settings.modules.windbot.port); windbot_process = spawn(windbot_bin, windbot_parameters, { cwd: 'windbot' }); windbot_process.on('error', function(err) { log.warn('WindBot ERROR', err); if (windbot_looplimit < 1000 && !global.rebooted) { windbot_looplimit++; spawn_windbot(); } }); windbot_process.on('exit', function(code) { log.warn('WindBot EXIT', code); if (windbot_looplimit < 1000 && !global.rebooted) { windbot_looplimit++; spawn_windbot(); } }); windbot_process.stdout.setEncoding('utf8'); windbot_process.stdout.on('data', function(data) { log.info('WindBot:', data); }); windbot_process.stderr.setEncoding('utf8'); windbot_process.stderr.on('data', function(data) { log.warn('WindBot Error:', data); }); }; global.rebooted = false; //http if (true) { addCallback = function(callback, text) { if (!callback) { return text; } return callback + "( " + text + " );"; }; httpRequestListener = async function(request, response) { var archive_args, archive_name, archive_process, check, death_room_found, duellog, e, err, error, filename, getpath, j, len, parseQueryString, pass_validated, ref, roomsjson, success, u; parseQueryString = true; u = url.parse(request.url, parseQueryString); //pass_validated = u.query.pass == settings.modules.http.password //console.log(u.query.username, u.query.pass) if (u.pathname === '/api/getrooms') { pass_validated = (await auth.auth(u.query.username, u.query.pass, "get_rooms", "get_rooms", true)); if (!settings.modules.http.public_roomlist && !pass_validated) { response.writeHead(200); response.end(addCallback(u.query.callback, '{"rooms":[{"roomid":"0","roomname":"密码错误","needpass":"true"}]}')); } else { roomsjson = []; _async.each(ROOM_all, function(room, done) { var player; if (!(room && room.established)) { done(); return; } roomsjson.push({ roomid: room.process_pid.toString(), roomname: pass_validated ? room.name : room.name.split('$', 2)[0], roommode: room.hostinfo.mode, needpass: (room.name.indexOf('$') !== -1).toString(), users: _.sortBy((function() { var j, len, ref, results; ref = room.players; results = []; for (j = 0, len = ref.length; j < len; j++) { player = ref[j]; if (player.pos != null) { results.push({ id: (-1).toString(), name: player.name, ip: settings.modules.http.show_ip && pass_validated && !player.is_local ? player.ip.slice(7) : null, status: settings.modules.http.show_info && room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN && player.pos !== 7 ? { score: room.scores[player.name_vpass], lp: player.lp != null ? player.lp : room.hostinfo.start_lp, cards: room.hostinfo.mode !== 2 ? (player.card_count != null ? player.card_count : room.hostinfo.start_hand) : null } : null, pos: player.pos }); } } return results; })(), "pos"), istart: room.duel_stage !== ygopro.constants.DUEL_STAGE.BEGIN ? (settings.modules.http.show_info ? "Duel:" + room.duel_count + " " + (room.duel_stage === ygopro.constants.DUEL_STAGE.SIDING ? "Siding" : "Turn:" + (room.turn != null ? room.turn : 0) + (room.death ? "/" + (room.death > 0 ? room.death - 1 : "Death") : "")) : 'start') : 'wait' }); return done(); }, function() { response.writeHead(200); return response.end(addCallback(u.query.callback, JSON.stringify({ rooms: roomsjson }))); }); } } else if (u.pathname === '/api/duellog' && settings.modules.mysql.enabled) { if (!(await auth.auth(u.query.username, u.query.pass, "duel_log", "duel_log"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "[{name:'密码错误'}]")); return; } else { response.writeHead(200); duellog = JSON.stringify((await dataManager.getDuelLogJSON(settings.modules.tournament_mode)), null, 2); response.end(addCallback(u.query.callback, duellog)); } } else if (u.pathname === '/api/archive.zip' && settings.modules.mysql.enabled) { if (!(await auth.auth(u.query.username, u.query.pass, "download_replay", "download_replay_archive"))) { response.writeHead(403); response.end("Invalid password."); return; } else { try { archive_name = moment().format('YYYY-MM-DD HH-mm-ss') + ".zip"; archive_args = ["a", "-mx0", "-y", archive_name]; check = false; ref = (await dataManager.getAllReplayFilenames()); for (j = 0, len = ref.length; j < len; j++) { filename = ref[j]; check = true; archive_args.push(filename); } if (!check) { response.writeHead(403); response.end("Duel logs not found."); return; } archive_process = spawn(settings.modules.tournament_mode.replay_archive_tool, archive_args, { cwd: settings.modules.tournament_mode.replay_path }); archive_process.on('error', (err) => { response.writeHead(403); response.end("Failed packing replays. " + err); }); archive_process.on('exit', (code) => { return fs.readFile(settings.modules.tournament_mode.replay_path + archive_name, function(error, buffer) { if (error) { response.writeHead(403); response.end("Failed sending replays. " + error); } else { response.writeHead(200, { "Content-Type": "application/octet-stream", "Content-Disposition": "attachment" }); response.end(buffer); } }); }); archive_process.stdout.setEncoding('utf8'); archive_process.stdout.on('data', (data) => { return log.info("archive process: " + data); }); archive_process.stderr.setEncoding('utf8'); archive_process.stderr.on('data', (data) => { return log.warn("archive error: " + data); }); } catch (error1) { error = error1; response.writeHead(403); response.end("Failed reading replays. " + error); } } } else if (u.pathname === '/api/clearlog' && settings.modules.mysql.enabled) { if (!(await auth.auth(u.query.username, u.query.pass, "clear_duel_log", "clear_duel_log"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "[{name:'密码错误'}]")); return; } else { response.writeHead(200); if (settings.modules.tournament_mode.log_save_path) { fs.writeFile(settings.modules.tournament_mode.log_save_path + 'duel_log.' + moment().format('YYYY-MM-DD HH-mm-ss') + '.json', JSON.stringify((await dataManager.getDuelLogJSON(settings.modules.tournament_mode)), null, 2), function(err) { if (err) { return log.warn('DUEL LOG SAVE ERROR', err); } }); } await dataManager.clearDuelLog(); response.end(addCallback(u.query.callback, "[{name:'Success'}]")); } } else if (_.startsWith(u.pathname, '/api/replay') && settings.modules.mysql.enabled) { if (!(await auth.auth(u.query.username, u.query.pass, "download_replay", "download_replay"))) { response.writeHead(403); response.end("密码错误"); return; } else { getpath = null; filename = null; try { getpath = u.pathname.split("/"); filename = path.basename(decodeURIComponent(getpath.pop())); } catch (error1) { response.writeHead(404); response.end("bad filename"); return; } fs.readFile(settings.modules.tournament_mode.replay_path + filename, function(error, buffer) { if (error) { response.writeHead(404); response.end("未找到文件 " + filename); } else { response.writeHead(200, { "Content-Type": "application/octet-stream", "Content-Disposition": "attachment" }); response.end(buffer); } }); } } else if (u.pathname === '/api/message') { //if !pass_validated // response.writeHead(200) // response.end(addCallback(u.query.callback, "['密码错误', 0]")) // return if (u.query.shout) { if (!(await auth.auth(u.query.username, u.query.pass, "shout", "shout"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } _async.each(ROOM_all, function(room) { if (room && room.established) { return ygopro.stoc_send_chat_to_room(room, u.query.shout, ygopro.constants.COLORS.YELLOW); } }); response.writeHead(200); response.end(addCallback(u.query.callback, "['shout ok', '" + u.query.shout + "']")); } else if (u.query.stop) { if (!(await auth.auth(u.query.username, u.query.pass, "stop", "stop"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } if (u.query.stop === 'false') { u.query.stop = false; } response.writeHead(200); try { await setting_change(settings, 'modules:stop', u.query.stop); response.end(addCallback(u.query.callback, "['stop ok', '" + u.query.stop + "']")); } catch (error1) { err = error1; response.end(addCallback(u.query.callback, "['stop fail', '" + u.query.stop + "']")); } } else if (u.query.welcome) { if (!(await auth.auth(u.query.username, u.query.pass, "change_settings", "change_welcome"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } try { await setting_change(settings, 'modules:welcome', u.query.welcome); response.end(addCallback(u.query.callback, "['welcome ok', '" + u.query.welcome + "']")); } catch (error1) { err = error1; response.end(addCallback(u.query.callback, "['welcome fail', '" + u.query.welcome + "']")); } } else if (u.query.getwelcome) { if (!(await auth.auth(u.query.username, u.query.pass, "change_settings", "get_welcome"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } response.writeHead(200); response.end(addCallback(u.query.callback, "['get ok', '" + settings.modules.welcome + "']")); } else if (u.query.loadtips) { if (!(await auth.auth(u.query.username, u.query.pass, "change_settings", "change_tips"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } success = (await load_tips()); response.writeHead(200); if (success) { response.end(addCallback(u.query.callback, "['tip ok', '" + settings.modules.tips.get + "']")); } else { response.end(addCallback(u.query.callback, "['tip fail', '" + settings.modules.tips.get + "']")); } } else if (u.query.loaddialogues) { if (!(await auth.auth(u.query.username, u.query.pass, "change_settings", "change_dialogues"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } success = (await load_tips()); response.writeHead(200); if (success) { response.end(addCallback(u.query.callback, "['dialogue ok', '" + settings.modules.tips.get + "']")); } else { response.end(addCallback(u.query.callback, "['dialogue fail', '" + settings.modules.tips.get + "']")); } } else if (u.query.ban) { if (!(await auth.auth(u.query.username, u.query.pass, "ban_user", "ban_user"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } try { await ban_user(u.query.ban); } catch (error1) { e = error1; log.warn("ban fail", e.toString()); response.writeHead(200); response.end(addCallback(u.query.callback, "['ban fail', '" + u.query.ban + "']")); return; } response.writeHead(200); response.end(addCallback(u.query.callback, "['ban ok', '" + u.query.ban + "']")); } else if (u.query.kick) { if (!(await auth.auth(u.query.username, u.query.pass, "kick_user", "kick_user"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } ROOM_kick(u.query.kick, function(err, found) { response.writeHead(200); if (err) { return response.end(addCallback(u.query.callback, "['kick fail', '" + u.query.kick + "']")); } else if (found) { return response.end(addCallback(u.query.callback, "['kick ok', '" + u.query.kick + "']")); } else { return response.end(addCallback(u.query.callback, "['room not found', '" + u.query.kick + "']")); } }); } else if (u.query.death) { if (!(await auth.auth(u.query.username, u.query.pass, "start_death", "start_death"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } death_room_found = false; _async.each(ROOM_all, function(room, done) { if (!(room && (u.query.death === "all" || u.query.death === room.process_pid.toString() || u.query.death === room.name))) { done(); return; } if (room.start_death()) { death_room_found = true; } done(); }, function() { response.writeHead(200); if (death_room_found) { return response.end(addCallback(u.query.callback, "['death ok', '" + u.query.death + "']")); } else { return response.end(addCallback(u.query.callback, "['room not found', '" + u.query.death + "']")); } }); } else if (u.query.deathcancel) { if (!(await auth.auth(u.query.username, u.query.pass, "start_death", "cancel_death"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } death_room_found = false; _async.each(rooms, function(room, done) { if (!(room && (u.query.deathcancel === "all" || u.query.deathcancel === room.process_pid.toString() || u.query.deathcancel === room.name))) { done(); return; } if (room.cancel_death()) { death_room_found = true; } return done(); }, function() { response.writeHead(200); if (death_room_found) { return response.end(addCallback(u.query.callback, "['death cancel ok', '" + u.query.deathcancel + "']")); } else { return response.end(addCallback(u.query.callback, "['room not found', '" + u.query.deathcancel + "']")); } }); } else if (u.query.reboot) { if (!(await auth.auth(u.query.username, u.query.pass, "stop", "reboot"))) { response.writeHead(200); response.end(addCallback(u.query.callback, "['密码错误', 0]")); return; } ROOM_kick("all", function(err, found) { global.rebooted = true; if (windbot_process) { windbot_process.kill(); } response.writeHead(200); response.end(addCallback(u.query.callback, "['reboot ok', '" + u.query.reboot + "']")); return process.exit(); }); } else { response.writeHead(400); response.end(); } } else { response.writeHead(400); response.end(); } }; } init(); }).call(this);