# revival-ConnectHelper.py - one of the three game scripts the Super Mecha Crows Android kit adds.
# The installer puts it into the game's update file (patch_npk/p_script.npk on the phone) under the game's own name
# logic.gutils.ConnectHelper, next to the game's original module, which it copied out of YOUR phone's game under
# logic.gutils.ConnectHelper_original. This script loads that original unchanged, then runs the Crows part below inside it.
import sys
import logic.gutils.ConnectHelper_original as _revival_original
sys.modules['logic.gutils.ConnectHelper'] = _revival_original
_REVIVAL_PART = '\n# ---- [REVIVAL] override tail, generated by tools/override/build_override.py ----\n# Runs after the original logic/gutils/ConnectHelper module body (class ConnectHelper exists, LogManager is imported).\n# NO bare print(): this client redirects sys.stdout to a C_debug.logoutput object with no flush(), so print()\n# raises AttributeError during import and the process __fastfail(FATAL_APP_EXIT)s (crash confirmed 2026-09-22c,\n# client.exe+0x19d1155; matches HANDOVER 7 \'logoutput has no flush\'). The marker goes ONLY through the game\'s\n# LogManager (writes to package/log.txt as a <SCRIPT> line), and every step is guarded so nothing can propagate.\n_REVIVAL_GATE_PUB = \'ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQCxiQP7dp86S5kBjMhq5UUXEDclfLikyoNcWU4WK63xUNj4lZi0buzsYnuM7w+7g1JN5bnY54/CkPXzrQByaMoOa2RS81vdUQDPmd2HqPEd5c7qoRpd8yrYCiaBE1bEe0cPwLZeVGE9TxIW3/1FtxJiHYNxeqpdoIUPJSijlsGJMwChFhT+AOFvHFaZBgq4bfDR6Dp88c6JtU5b8Y5zzICp6ARxYsSaYuyWpWEtc+iGEfNi5k1gMWCqRsDm1xZw9zeRAnNnkCuyrQ5SWqJ8AVsdezAho56c90Z0E5GpK2L5iLhv37o6xFXAIEPeptMSnyJr9xoQ9GNMjrgdFDruI5mv\'\n_REVIVAL_MARKER = \'[REVIVAL] ConnectHelper override active, gate key swapped\'\ntry:\n    ConnectHelper.GATE_CLIENT_CONFIG[\'loginkeycontent\'] = _REVIVAL_GATE_PUB\n    ConnectHelper.BATTLE_CLIENT_CONFIG[\'key_content\'] = _REVIVAL_GATE_PUB\nexcept Exception:\n    pass\ntry:\n    LogManager.get_logger(\'ConnectHelper\').info(\'%s (fp=%s)\' % (_REVIVAL_MARKER, _REVIVAL_GATE_PUB.split(\' \')[1][:16]))\nexcept Exception:\n    pass\n\n# ---- 4. The current version of part 5, from the Crows server ------------------------------------------------\n# Once at every start this asks the Crows server for the current version of part 5 (two small files), accepts it\n# only when it is signed with the Crows key below and matches its description, keeps it in\n# package\\Documents\\crows\\, and runs it in place of the copy written further down. Nothing about you is sent.\nCROWS_UPDATE_URL = \'https://g93.update.netease.com/crows/\'\nCROWS_UPDATE_KEY_N = \'d3a1ef2cf446ae0dbb18468aed0201042b1a970e404f99ab6df2984063f6fcf36f6c4043c44d4f4198230b00f7d41a10f81a5a43ff8e002eb0283ad85ca18dbf81fb03c29f90547a3636fc4c770f4150caa961ac10f40fc2284c6901b0f1b90aaa9dd492201c884a093ac800ee49d914a640c75da9935f98a812bdb1d691fa7a650732a9ec9b5cdfa31f4b3823232cc61d7d0a54dcd6eb0b406292d0fb7df08df6eae6c4d39a82c92fc2184816ba31f79aa8babb869e8503447d3ba8c3381739cf87d11985b5f8b0fdfc387033a74826fab64693b4d70309b7865566258be77b691925c14b4da36e9b87fec73d4bb5b5431598e94f41e4ae2716bc7a8ff36713\'\nCROWS_UPDATE_KEY_E = 65537\n\n\ndef _crows_update():\n    """True when a delivered copy of part 5 ran. Never raises: any problem means the built-in part 5 runs."""\n    import os\n    import json\n    import base64\n    import hashlib\n    try:\n        _log = LogManager.get_logger(\'ConnectHelper\')\n    except Exception:\n        _log = None\n\n    def say(msg):\n        try:\n            _log.info(\'[CROWS] part 5: \' + msg)\n        except Exception:\n            pass\n\n    try:\n        import game3d\n        doc = game3d.get_doc_dir()                        # <game>\\package\\Documents\n        store = os.path.join(doc, \'crows\')\n        pem = os.path.join(doc, \'cacert.pem\')             # the game\'s certificate list + the Crows CA (Install-SMC)\n    except Exception as exc:\n        say(\'no document folder (%s)\' % str(exc)[:60])\n        return False\n\n    def canonical(m):\n        body = dict((k, v) for k, v in m.items() if k != \'sig\')\n        return json.dumps(body, sort_keys=True, separators=(\',\', \':\')).encode(\'utf-8\')\n\n    def signed(m):\n        # RSA PKCS#1 v1.5 over SHA-256, checked with integer math: no library, nothing that differs between builds\n        try:\n            if not isinstance(m, dict) or m.get(\'file\') != \'kit.py\':\n                return False\n            int(m[\'version\']); int(m[\'size\']); str(m[\'sha256\'])\n            sig = base64.b64decode(str(m.get(\'sig\') or \'\'))\n            n = int(CROWS_UPDATE_KEY_N, 16)\n            k = (n.bit_length() + 7) // 8\n            if len(sig) != k:\n                return False\n            em = pow(int.from_bytes(sig, \'big\'), CROWS_UPDATE_KEY_E, n).to_bytes(k, \'big\')\n            t = bytes.fromhex(\'3031300d060960864801650304020105000420\') + hashlib.sha256(canonical(m)).digest()\n            return em == b\'\\x00\\x01\' + b\'\\xff\' * (k - len(t) - 3) + b\'\\x00\' + t\n        except Exception:\n            return False\n\n    def matches(m, data):\n        return len(data) == int(m[\'size\']) and hashlib.sha256(data).hexdigest() == str(m[\'sha256\'])\n\n    def fetch(name, limit):\n        import ssl\n        import urllib.request\n        ctx = ssl.create_default_context(cafile=pem)      # our own context: the game\'s helper turns checking off\n        req = urllib.request.Request(CROWS_UPDATE_URL + name, headers={\'User-Agent\': \'crows-kit\'})\n        with urllib.request.urlopen(req, timeout=4, context=ctx) as r:\n            data = r.read(limit + 1)\n        if len(data) > limit:\n            raise ValueError(\'%s is larger than %d bytes\' % (name, limit))\n        return data\n\n    have, have_ver = None, -1\n    try:\n        with open(os.path.join(store, \'kit.json\'), \'rb\') as fh:\n            m = json.loads(fh.read().decode(\'utf-8\'))\n        with open(os.path.join(store, \'kit.py\'), \'rb\') as fh:\n            kept = fh.read()\n        if signed(m) and matches(m, kept):            # a damaged copy counts as none: the server\'s is taken again\n            have, have_ver = m, int(m[\'version\'])\n        else:\n            say(\'the kept copy is damaged or unsigned, not counted\')\n    except Exception:\n        pass\n    try:\n        m = json.loads(fetch(\'kit.json\', 4096).decode(\'utf-8\'))\n        if not signed(m):\n            say(\'the server copy is not signed with the Crows key, ignored\')\n        elif int(m[\'version\']) <= have_ver:\n            say(\'version %d kept (server: %d)\' % (have_ver, int(m[\'version\'])))\n        else:\n            data = fetch(\'kit.py\', 262144)\n            if not matches(m, data):\n                say(\'the server copy does not match its description, ignored\')\n            else:\n                if not os.path.isdir(store):\n                    os.makedirs(store)\n                tmp = os.path.join(store, \'kit.py.tmp\')\n                with open(tmp, \'wb\') as fh:\n                    fh.write(data)\n                os.replace(tmp, os.path.join(store, \'kit.py\'))\n                tmp = os.path.join(store, \'kit.json.tmp\')\n                with open(tmp, \'wb\') as fh:\n                    fh.write(json.dumps(m, sort_keys=True).encode(\'utf-8\'))\n                os.replace(tmp, os.path.join(store, \'kit.json\'))\n                have, have_ver = m, int(m[\'version\'])\n                say(\'version %d (kit %s) downloaded\' % (have_ver, m.get(\'kit\')))\n    except Exception as exc:\n        say(\'server not asked (%s)\' % str(exc)[:80])\n    if have is None:\n        return False\n    try:\n        with open(os.path.join(store, \'kit.py\'), \'rb\') as fh:\n            data = fh.read()\n        if not matches(have, data):\n            say(\'the kept copy is damaged, not used\')\n            return False\n        exec(compile(data.decode(\'utf-8\'), \'crows/kit.py\', \'exec\'), globals())\n        say(\'version %d (kit %s) active\' % (have_ver, have.get(\'kit\')))\n        return True\n    except Exception as exc:\n        say(\'the kept copy failed (%s), the built-in part runs\' % str(exc)[:80])\n        return False\n\n\n_crows_delivered = _crows_update()\nif not _crows_delivered:\n\n    # ---- 5. The kit number and the launch report ----------------------------------------------------------------\n    # The Crows server accepts a Steam login only from the current kit. This part adds the kit number to the version\n    # the game reports when it logs in, and tells the server how the game was started: through Steam, with the game\'s\n    # own Steam file, from the game folder. It looks at file names and sizes only. Nothing is written, no file content\n    # leaves your PC, and it takes a few milliseconds.\n    CROWS_KIT = 1\n    CROWS_BUILD = \'2026-10-03\'\n\n\n    def _crows_launch_report():\n        import os\n        import sys\n        import hashlib\n        import time as _time\n        r = {\'kit\': CROWS_KIT, \'build\': CROWS_BUILD}\n        try:\n            env = os.environ\n            # Steam sets these for every game it starts; they are missing when client.exe is started by hand\n            r[\'steam_env\'] = [k for k in (\'SteamClientLaunch\', \'SteamAppId\', \'SteamGameId\', \'SteamEnv\', \'SteamUser\')\n                              if env.get(k)]\n            r[\'steam_appid\'] = str(env.get(\'SteamAppId\') or \'\')[:12]\n        except Exception:\n            r[\'steam_env\'] = None\n        try:\n            import game3d\n            doc = game3d.get_doc_dir()                       # <game>\\package\\Documents\n            pkg = os.path.dirname(doc)                       # <game>\\package\n            game = os.path.dirname(pkg)                      # <game>\n            binp = os.path.join(game, \'bin\')\n            api = os.path.join(binp, \'steam_api64.dll\')      # the game\'s Steam file: 298,384 bytes in the last Steam build\n            if os.path.isfile(api):\n                size = os.path.getsize(api)\n                r[\'api_size\'] = size\n                if size <= 32 * 1024 * 1024:\n                    h = hashlib.sha1()\n                    with open(api, \'rb\') as fh:\n                        for chunk in iter(lambda: fh.read(1 << 20), b\'\'):\n                            h.update(chunk)\n                    r[\'api_sha1\'] = h.hexdigest()[:16]\n            else:\n                r[\'api_size\'] = -1\n            r[\'emu_dir\'] = os.path.isdir(os.path.join(binp, \'steam_settings\'))   # a Steam emulator\'s settings folder\n            r[\'api_orig\'] = os.path.isfile(api + \'.orig\')                         # a swapped Steam file keeps a backup\n            r[\'bats\'] = sorted(n for n in os.listdir(game) if n.lower().endswith((\'.bat\', \'.cmd\')))[:6]\n            lt = os.path.join(game, \'launcher.txt\')                               # launcher.exe writes it on every start\n            r[\'launcher_age\'] = int(_time.time() - os.path.getmtime(lt)) if os.path.isfile(lt) else -1\n            r[\'cwd_ok\'] = os.path.normcase(os.path.abspath(os.getcwd())) == os.path.normcase(os.path.abspath(pkg))\n            r[\'exe\'] = os.path.basename(str(getattr(sys, \'executable\', \'\') or \'\'))[:32]\n        except Exception as exc:\n            r[\'err\'] = str(exc)[:80]\n        return r\n\n\n    try:\n        import version as _crows_version\n        _crows_cur = _crows_version.get_cur_version_str\n        _crows_stock_version_str = getattr(_crows_cur, \'_crows_stock\', _crows_cur)   # the game\'s own, even on a re-run\n\n        def _crows_version_str():\n            s = _crows_stock_version_str()\n            try:\n                parts = str(s).split(\'.\')\n                parts[-1] = str(int(parts[-1]) + CROWS_KIT)\n                return \'.\'.join(parts)\n            except Exception:\n                return s\n        _crows_version_str._crows_stock = _crows_stock_version_str\n        _crows_version.get_cur_version_str = _crows_version_str\n    except Exception:\n        pass\n\n    try:\n        from common.platform.device_info import DeviceInfo as _CrowsDeviceInfo\n        _crows_cur = _CrowsDeviceInfo.get_device_info\n        _crows_stock_device_info = getattr(_crows_cur, \'_crows_stock\', _crows_cur)\n\n        def _crows_device_info(self, *a, **k):\n            info = _crows_stock_device_info(self, *a, **k)\n            try:\n                if isinstance(info, dict):\n                    info[\'crows\'] = _crows_launch_report()\n            except Exception:\n                pass\n            return info\n        _crows_device_info._crows_stock = _crows_stock_device_info\n        _CrowsDeviceInfo.get_device_info = _crows_device_info\n    except Exception:\n        pass\n\n    try:\n        _crows_r = _crows_launch_report()\n        LogManager.get_logger(\'ConnectHelper\').info(\'[CROWS] kit %s build %s: steam_env=%s api_size=%s emu_dir=%s \'\n                                                    \'launcher_age=%s cwd_ok=%s bats=%s\' % (\n            CROWS_KIT, CROWS_BUILD, _crows_r.get(\'steam_env\'), _crows_r.get(\'api_size\'), _crows_r.get(\'emu_dir\'),\n            _crows_r.get(\'launcher_age\'), _crows_r.get(\'cwd_ok\'), _crows_r.get(\'bats\')))\n    except Exception:\n        pass\n\n\n# ---- [REVIVAL] Android kit mark (docs/ANDROID_LOGIN.md "Public kit") ----\n# The server lets an Android kit in only while its mark is on the server\'s list; the token proves the server issued\n# the mark. Every copy of the public kit carries the same mark. Added to the launch report after part 5.\n_REVIVAL_APROTO = {\'id\': \'pub1\', \'tok\': \'8029b7245bc7521858b1bfaad66570c3\'}\ntry:\n    from common.platform.device_info import DeviceInfo as _RevivalApDev\n    _revival_ap_prev = _RevivalApDev.get_device_info\n\n    def _revival_ap_device_info(self, *a, **k):\n        info = _revival_ap_prev(self, *a, **k)\n        try:\n            if isinstance(info, dict):\n                cr = info.get(\'crows\')\n                if not isinstance(cr, dict):\n                    cr = {}\n                    info[\'crows\'] = cr\n                cr[\'aproto\'] = dict(_REVIVAL_APROTO)\n        except Exception:\n            pass\n        return info\n    _RevivalApDev.get_device_info = _revival_ap_device_info\n    LogManager.get_logger(\'ConnectHelper\').info(\'[CROWS] android kit %s\' % (_REVIVAL_APROTO[\'id\'],))\nexcept Exception:\n    pass\n'
exec(compile(_REVIVAL_PART, 'revival-ConnectHelper', 'exec'), vars(_revival_original))
globals().update({_k: _v for _k, _v in vars(_revival_original).items() if not _k.startswith('__')})