self.execute_cdp_command("Page.addScriptToEvaluateOnNewDocument", {"source": js_code, })

    async def http_filter(self):
        """ http 处理器，包括拦截与记录的功能
        """
        async with self.driver.bidi_connection() as connection:
            session, devtools = connection.session, connection.devtools
            pattern = [
                {"urlPattern": f"*baidu.com"},
                {"urlPattern": f"*qiandu.com"},
            ]
            pattern = map(devtools.fetch.RequestPattern.from_json, pattern)
            await session.execute(devtools.fetch.enable(patterns=pattern))  # 设置网络事件过滤
            await session.execute(devtools.network.enable())    # 开启网络追踪，所有期待的网络事件都会发送到客户端
            listener = session.listen(devtools.fetch.RequestPaused, devtools.network.ResponseReceived)
            async for event in listener:
                if isinstance(event, devtools.fetch.RequestPaused):
                    url = event.request.url
                    if 'qiandu.com' in url:
                        try:
                            await session.execute(
                                devtools.fetch.fail_request(
                                    event.request_id,
                                    error_reason=devtools.network.ErrorReason.CONNECTION_REFUSED
                                )
                            )
                        except Exception as e:
                            logger.warning(f"丢弃千度出错 - {e}")
                elif isinstance(event, devtools.network.ResponseReceived):
                    _type = event.type_
                    request_id = event.request_id
                    req_url = event.response.url
                    resp_code = event.response.status
                    rt = devtools.network.ResourceType
                    # 只关心需要的
                    if _type not in [rt.XHR, rt.DOCUMENT, rt.FETCH, rt.PREFETCH]:
                        continue

                    # 获取请求和响应体
                    try:
                        cdp_resp = await session.execute(devtools.network.get_request_post_data(request_id))
                        req_body = cdp_resp
                    except Exception as e:
                        req_body = None
                    try:
                        cdp_resp = await session.execute(devtools.network.get_response_body(request_id))
                        if cdp_resp[1]:  # base64Encoded
                            resp_body = base64.b64decode(cdp_resp[0]).decode(errors='ignore')
                        else:
                            resp_body = cdp_resp[0]
                    except Exception as e:
                        resp_body = None

# 提取
npx asar extract app.asar ./unpacked

# 修改
# ...

# 安装为开发依赖
npm install --save-dev electron@20.0.0

# 调试启动
npx electron --inspect-brk=9229 .

options = Options()
options.add_experimental_option("androidPackage", "com.tencent.mm")
options.add_experimental_option("androidUseRunningApp", True)
options.add_experimental_option("androidActivity", ".plugin.webview.ui.tools.WebViewUI") # 或 .plugin.webview.ui.tools.MMWebViewUI
options.add_experimental_option("androidProcess", "com.tencent.mm")
options.add_experimental_option("androidDeviceSerial", "932AY05YGZ") # 设备序号，adb devices可见
options.add_argument('--no-sandbox')
driver = webdriver.Chrome('/path/to/chromedriver', options=options)

# add 设置立即生效
adb shell settings put global http_proxy 127.0.0.1:8888
# delete 删除重启生效 adb shell reboot    必须三条全部执行哦！
adb shell settings delete global http_proxy
adb shell settings delete global global_http_proxy_host
adb shell settings delete global global_http_proxy_port
 # 或 它不必重启
adb shell settings put global http_proxy :0

adb tcpip 5555 # 重启设备的adbd并将其绑定到5555端口，若存在多个设备可使用-s serial指定，下文同
adb shell ip addr show wlan0 # 查看ip地址
adb connect ip-address-of-device:5555 # 让adbs连接到adbd
adb devices # 验证
adb disconnect <device-ip-address> # 断开连接

option = UiAutomator2Options()
option.app_activity = 'com.google.android.apps.chrome.Main' 
option.browser_name = 'chrome'  # appium默认上下文为native，这会自动切到chrome的第一个window上
option.platform_name = 'Android'
option.udid = self.device_serial    # 序列号
option.new_command_timeout = 0  # 防止超时退出
option.chromedriver_executable = # 可设置chromedriver的路径

option.chrome_options = {'args': [
    '--disable-popup-blocking', # 可设置各种启动参数，详见chrome文档，不过大部分都不会生效
]}
self.driver = webdriver.Remote('http://localhost:4723', options=option) # 连接到appium server
self.driver.implicitly_wait(self.WAIT_TIME)

remote_commands = {
  "executeCdpCommand": ("POST", f"/session/$sessionId/goog/cdp/execute"),
}
# 赋值给 AppiumConnection._commands

def find_element(self, element_location_str: Union[Template, str]) -> Optional[tuple[int, int]]:
    if isinstance(element_location_str, Template):
        return exists(element_location_str)
    else:
        snap = self._airtest_dev.snapshot()
        ocr = CnOcr()
        out = ocr.ocr(snap)
        for line in out:
            if element_location_str in line['text']:
                position = line['position']
                x_coordinates = position[:, 0]
                y_coordinates = position[:, 1]
                center_x = (np.max(x_coordinates) + np.min(x_coordinates)) // 2
                center_y = (np.max(y_coordinates) + np.min(y_coordinates)) // 2
                return center_x, center_y
        return None