CI: 每日健康检查: 7am 运行 tqsdk 确定接口可用

.github/workflows/check-dependence-daily.yml

@@ -0,0 +1,70 @@
+name: check-dependence-daily
+
+on:
+  schedule:
+  - cron: "0 22 * * *"
+
+jobs:
+  test-and-check:
+    strategy:
+      matrix:
+        envinfo:
+          - { name: 'linux-3.6-x64', os: ubuntu-latest, python-version: 3.6.x, python-arch: x64, TZ: 'Asia/Shanghai', bdist-platform: 'manylinux1_x86_64'}
+          - { name: 'linux-3.7-x64', os: ubuntu-latest, python-version: 3.7.x, python-arch: x64, TZ: 'Asia/Shanghai', bdist-platform: 'manylinux1_x86_64'}
+          - { name: 'linux-3.8-x64', os: ubuntu-latest, python-version: 3.8.x, python-arch: x64, TZ: 'Asia/Shanghai', bdist-platform: 'manylinux1_x86_64'}
+          - { name: 'linux-3.9-x64', os: ubuntu-latest, python-version: 3.9.x, python-arch: x64, TZ: 'Asia/Shanghai', bdist-platform: 'manylinux1_x86_64'}
+          - { name: 'macos-3.6-x64', os: macos-latest, python-version: 3.6.x, python-arch: x64, TZ: 'Asia/Shanghai', bdist-platform: 'any'}
+          - { name: 'macos-3.7-x64', os: macos-latest, python-version: 3.7.x, python-arch: x64, TZ: 'Asia/Shanghai', bdist-platform: 'any'}
+          - { name: 'macos-3.8-x64', os: macos-latest, python-version: 3.8.x, python-arch: x64, TZ: 'Asia/Shanghai', bdist-platform: 'any'}
+          - { name: 'macos-3.9-x64', os: macos-latest, python-version: 3.9.x, python-arch: x64, TZ: 'Asia/Shanghai', bdist-platform: 'any'}
+          - { name: 'windows-3.6-x64', os: windows-latest, python-version: 3.6.x, python-arch: x64, TZ: 'CST-8', bdist-platform: 'win_amd64'}
+          - { name: 'windows-3.6-x86', os: windows-latest, python-version: 3.6.x, python-arch: x86, TZ: 'CST-8', bdist-platform: 'win32'}
+          - { name: 'windows-3.7-x64', os: windows-latest, python-version: 3.7.x, python-arch: x64, TZ: 'CST-8', bdist-platform: 'win_amd64'}
+          - { name: 'windows-3.7-x86', os: windows-latest, python-version: 3.7.x, python-arch: x86, TZ: 'CST-8', bdist-platform: 'win32'}
+          - { name: 'windows-3.8-x64', os: windows-latest, python-version: 3.8.x, python-arch: x64, TZ: 'CST-8', bdist-platform: 'win_amd64'}
+          - { name: 'windows-3.8-x86', os: windows-latest, python-version: 3.8.x, python-arch: x86, TZ: 'CST-8', bdist-platform: 'win32'}
+          - { name: 'windows-3.9-x64', os: windows-latest, python-version: 3.9.x, python-arch: x64, TZ: 'CST-8', bdist-platform: 'win_amd64'}
+          - { name: 'windows-3.9-x86', os: windows-latest, python-version: 3.9.x, python-arch: x86, TZ: 'CST-8', bdist-platform: 'win32'}
+
+    env:
+        PYTHONUNBUFFERED: 1
+        PYTHONIOENCODING: "utf-8"
+        PYTHONHASHSEED: 32
+        TZ: ${{ matrix.envinfo.TZ }}
+
+    runs-on: ${{ matrix.envinfo.os }}
+
+    steps:
+    - name: Checkout
+      uses: actions/checkout@v2
+
+    - name: Set up Python
+      uses: actions/setup-python@v2
+      with:
+        python-version: ${{matrix.envinfo.python-version}}
+        architecture: ${{matrix.envinfo.python-arch}}
+
+    - name: Install latest tqsdk
+      run: |
+        python -m pip install tqsdk pytest
+
+    - name: Run test case and check tqsdk
+      run: |
+        echo "tqsdk 运行失败" > error.log
+        echo "date: $(date -d today +%Y%m%d)" >> error.log
+        echo "env : python-${{matrix.envinfo.python-version}}-${{matrix.envinfo.python-arch}} ${{matrix.envinfo.name}}" >> error.log
+        pip list >> error.log
+        pytest -x test/api --show-capture=no >> error.log
+
+    - name: send email after CI failed
+      if: ${{ failure() }}
+      uses: dawidd6/action-send-mail@v2
+      with:
+        server_address: smtpdm.aliyun.com
+        server_port: 465
+        username: ${{secrets.MAIL_USERNAME}}
+        password: ${{secrets.MAIL_PASSWORD}}
+        subject: TqSDK 健康检查
+        body: file://error.log
+        to: ${{secrets.EMAIL_LIST}}
+        from: TqSDK CI for depence check # <[email protected]>

test/api/helper.py

@@ -0,0 +1,274 @@
+#!/usr/bin/env python
+#  -*- coding: utf-8 -*-
+
+
+import json
+import logging
+import lzma
+import os
+import socket
+import threading
+import asyncio
+import urllib
+
+import websockets
+from aiohttp import web
+
+logger = logging.getLogger('websockets.server')
+logger.setLevel(logging.ERROR)
+logger.addHandler(logging.StreamHandler())
+
+class MockInsServer():
+    def __init__(self):
+        self.loop = asyncio.new_event_loop()
+        self.symbols_dir = os.path.join(os.path.dirname(__file__), 'symbols')
+        self.stop_signal = self.loop.create_future()
+        self.semaphore = threading.Semaphore(value=0)
+        self.thread = threading.Thread(target=self._run)
+        self.thread.start()
+        self.semaphore.acquire()
+
+    def close(self):
+        self.loop.call_soon_threadsafe(lambda: self.stop_signal.set_result(0))
+        self.thread.join()
+
+    async def handle(self, request):
+        dir_path = os.path.dirname(os.path.realpath(__file__))
+        file_path = os.path.join(dir_path, "symbols", request.url.name + ".lzma")
+        file = lzma.open(file_path, "rt", encoding="utf-8")
+        return web.json_response(json.loads(file.read()))
+
+    async def auth_handle(self, request):
+        """
+        对于 mock auth 服务， 只有 auth="tianqin,tianqin" 是收费全功能用户，其他是免费用户
+        """
+        query_str = await request.text()
+        query = urllib.parse.parse_qs(query_str)
+        if query["username"][0] == "tianqin" and query["password"][0] == "tianqin":
+            s = '{"access_token":"eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJobi1MZ3ZwbWlFTTJHZHAtRmlScjV5MUF5MnZrQmpLSFFyQVlnQ0UwR1JjIn0.eyJqdGkiOiI4NTMxZTY5Zi03OGExLTQwNzktOTNkNy1jOTVlNDQ1ZWFlMzUiLCJleHAiOjE2MDQ4ODc2MTMsIm5iZiI6MCwiaWF0IjoxNjA0MjgyODEzLCJpc3MiOiJodHRwczovL2F1dGguc2hpbm55dGVjaC5jb20vYXV0aC9yZWFsbXMvc2hpbm55dGVjaCIsInN1YiI6IjBkZWRkNTFhLTI4MjYtNDZkMC1hZjgyLTBlMjZmZmNiNTYyNSIsInR5cCI6IkJlYXJlciIsImF6cCI6InNoaW5ueV90cSIsImF1dGhfdGltZSI6MCwic2Vzc2lvbl9zdGF0ZSI6IjVhNzNiY2JiLTg0MTUtNDYxOS05MzliLTBkNTI3ZGE3M2U5NCIsImFjciI6IjEiLCJzY29wZSI6ImF0dHJpYnV0ZXMtZ3JhbnQtdHEgcHJvZmlsZSB1c2VybmFtZSIsImdyYW50cyI6eyJmZWF0dXJlcyI6WyJvcHQiLCJzdXAiLCJtYyIsInNlYyIsImZ1dHIiLCJ0cV9kbCIsInRxX2J0IiwiY21iIiwibG10X2lkeCIsInRxX21hIiwiYWR2Il0sImV4cGlyeV9kYXRlIjoiMCIsImFjY291bnRzIjpbIjAwMDE5OSIsIjgzMDExMTE5IiwiMTIzNDU2IiwiMTcyMjg5IiwiOTAwODQzMjEiLCI5MDEwMTA4NyIsIjk5OTkiLCI5MDA5MjMwNyIsIjE0NzcxNiIsIjBkZWRkNTFhLTI4MjYtNDZkMC1hZjgyLTBlMjZmZmNiNTYyNSIsIjEwMzk4OCJdfSwic2V0bmFtZSI6dHJ1ZSwibmFtZSI6Ik5VTEwgTlVMTCIsInByZWZlcnJlZF91c2VybmFtZSI6Im1heWFucWlvbmcxIiwiaWQiOiIwZGVkZDUxYS0yODI2LTQ2ZDAtYWY4Mi0wZTI2ZmZjYjU2MjUiLCJnaXZlbl9uYW1lIjoiTlVMTCIsImZhbWlseV9uYW1lIjoiTlVMTCIsInVzZXJuYW1lIjoibWF5YW5xaW9uZzEifQ.en9vKhjS4FX1DG2r3sfA3I0a8NQsOrZl_dPqBSydw3SiEzwoN21T2FUfUz7BzJ1WXDIMauYWSvaLr0IVRSafC715B4gmQ_24iy7S2T7OD7MECsdnQq2jzynCEsIEe4jhfBtn5vOZeVV2q2woBmYFcpYbIQjr4F60o0I5vddd7lo1kFUfLi8AkPYRRUDZ0qG8dAYKIYvewq40OS_QbrHU4JJDkFIyFMqlCkhed2b0zZanaDILuvEc190WkFs8IuKeQklZ_ZcBDUVHDD3kgKk7yErxySnWIvc0PY9oSg0rEsXG_eAS0ksnBfYtnN_CFbOwM4S2xkpuZxlFzE-hEudezQ","expires_in":604800,"refresh_expires_in":2592000,"refresh_token":"eyJhbGciOiJIUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJmZDNjMjQwYS00ODcyLTRiYTAtODNlZC04OGRjNWU4ZDE2ODAifQ.eyJqdGkiOiI5Y2Y0YjlhYS1lOTMxLTQ5MzEtYTc4Yi0yMjgwZjBkZGY2YzEiLCJleHAiOjE2MDY4NzQ4MTMsIm5iZiI6MCwiaWF0IjoxNjA0MjgyODEzLCJpc3MiOiJodHRwczovL2F1dGguc2hpbm55dGVjaC5jb20vYXV0aC9yZWFsbXMvc2hpbm55dGVjaCIsImF1ZCI6Imh0dHBzOi8vYXV0aC5zaGlubnl0ZWNoLmNvbS9hdXRoL3JlYWxtcy9zaGlubnl0ZWNoIiwic3ViIjoiMGRlZGQ1MWEtMjgyNi00NmQwLWFmODItMGUyNmZmY2I1NjI1IiwidHlwIjoiUmVmcmVzaCIsImF6cCI6InNoaW5ueV90cSIsImF1dGhfdGltZSI6MCwic2Vzc2lvbl9zdGF0ZSI6IjVhNzNiY2JiLTg0MTUtNDYxOS05MzliLTBkNTI3ZGE3M2U5NCIsInNjb3BlIjoiYXR0cmlidXRlcy1ncmFudC10cSBwcm9maWxlIHVzZXJuYW1lIn0.3sco_1DI4d0fbTgi5gi56uE6K_MKrWIk8ta9_bc2agM","token_type":"bearer","not-before-policy":0,"session_state":"5a73bcbb-8415-4619-939b-0d527da73e94","scope":"attributes-grant-tq profile username"}'
+        else:
+            s = '{"access_token":"eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJobi1MZ3ZwbWlFTTJHZHAtRmlScjV5MUF5MnZrQmpLSFFyQVlnQ0UwR1JjIn0.eyJqdGkiOiI2YTFhZmE0MC1lMDczLTRhMmQtODljYy04MDFmZmRkMjgxM2YiLCJleHAiOjE2Mjk0MjQ3NDAsIm5iZiI6MCwiaWF0IjoxNTk3ODg4NzQwLCJpc3MiOiJodHRwczovL2F1dGguc2hpbm55dGVjaC5jb20vYXV0aC9yZWFsbXMvc2hpbm55dGVjaCIsInN1YiI6IjcwZTQ0YWU1LTY0YjgtNDdlMC1iYjU0LWE1ZWVkY2RjZDM3YyIsInR5cCI6IkJlYXJlciIsImF6cCI6InNoaW5ueV90cSIsImF1dGhfdGltZSI6MCwic2Vzc2lvbl9zdGF0ZSI6ImFmOWNjZDNhLTI1MDktNGUzOC04MTBiLThjNjE4YWQzNmFjYiIsImFjciI6IjEiLCJzY29wZSI6ImF0dHJpYnV0ZXMtZ3JhbnQtdHEgcHJvZmlsZSB1c2VybmFtZSIsImdyYW50cyI6eyJmZWF0dXJlcyI6WyJmdXRyIiwibG10X2lkeCJdLCJleHBpcnlfZGF0ZSI6IjAiLCJhY2NvdW50cyI6WyI3MGU0NGFlNS02NGI4LTQ3ZTAtYmI1NC1hNWVlZGNkY2QzN2MiLCIxMDM5ODgiLCIqIl19LCJzZXRuYW1lIjp0cnVlLCJuYW1lIjoieWFucWlvbmcgTWEiLCJwcmVmZXJyZWRfdXNlcm5hbWUiOiJlbGl6YWJldGhtYSIsImlkIjoiNzBlNDRhZTUtNjRiOC00N2UwLWJiNTQtYTVlZWRjZGNkMzdjIiwiZ2l2ZW5fbmFtZSI6InlhbnFpb25nIiwiZmFtaWx5X25hbWUiOiJNYSIsInVzZXJuYW1lIjoiZWxpemFiZXRobWEifQ.en9vKhjS4FX1DG2r3sfA3I0a8NQsOrZl_dPqBSydw3SiEzwoN21T2FUfUz7BzJ1WXDIMauYWSvaLr0IVRSafC715B4gmQ_24iy7S2T7OD7MECsdnQq2jzynCEsIEe4jhfBtn5vOZeVV2q2woBmYFcpYbIQjr4F60o0I5vddd7lo1kFUfLi8AkPYRRUDZ0qG8dAYKIYvewq40OS_QbrHU4JJDkFIyFMqlCkhed2b0zZanaDILuvEc190WkFs8IuKeQklZ_ZcBDUVHDD3kgKk7yErxySnWIvc0PY9oSg0rEsXG_eAS0ksnBfYtnN_CFbOwM4S2xkpuZxlFzE-hEudezQ","expires_in":31536000,"refresh_expires_in":7776000,"refresh_token":"eyJhbGciOiJIUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJmZDNjMjQwYS00ODcyLTRiYTAtODNlZC04OGRjNWU4ZDE2ODAifQ.eyJqdGkiOiIxNzMyYmU1ZS02ZmY2LTQ0NGQtOGIzMC0xNzFlODhmNTQyYjUiLCJleHAiOjE2MDU2NjQ3NDAsIm5iZiI6MCwiaWF0IjoxNTk3ODg4NzQwLCJpc3MiOiJodHRwczovL2F1dGguc2hpbm55dGVjaC5jb20vYXV0aC9yZWFsbXMvc2hpbm55dGVjaCIsImF1ZCI6Imh0dHBzOi8vYXV0aC5zaGlubnl0ZWNoLmNvbS9hdXRoL3JlYWxtcy9zaGlubnl0ZWNoIiwic3ViIjoiNzBlNDRhZTUtNjRiOC00N2UwLWJiNTQtYTVlZWRjZGNkMzdjIiwidHlwIjoiUmVmcmVzaCIsImF6cCI6InNoaW5ueV90cSIsImF1dGhfdGltZSI6MCwic2Vzc2lvbl9zdGF0ZSI6ImFmOWNjZDNhLTI1MDktNGUzOC04MTBiLThjNjE4YWQzNmFjYiIsInNjb3BlIjoiYXR0cmlidXRlcy1ncmFudC10cSBwcm9maWxlIHVzZXJuYW1lIn0.Zuq-TsXC0D_rtk07JR1Dhd_iYNLxd5xg1s4jSrEZLBw","token_type":"bearer","not-before-policy":0,"session_state":"af9ccd3a-2509-4e38-810b-8c618ad36acb","scope":"attributes-grant-tq profile username"}'
+        return web.json_response(text=s)
+
+    async def task_serve(self):
+        try:
+            app = web.Application()
+            app.add_routes([web.get('/t/md/symbols/{tail:.*}', self.handle)])
+            app.add_routes([web.post('/auth/realms/shinnytech/protocol/openid-connect/token', self.auth_handle)])
+            runner = web.AppRunner(app)
+            await runner.setup()
+            server_socket = socket.socket()
+            server_socket.bind(('127.0.0.1', 0))
+            site = web.SockSite(runner, server_socket)
+            await site.start()
+            self.port = server_socket.getsockname()[1]
+            self.semaphore.release()
+            await self.stop_signal
+        finally:
+            await runner.shutdown()
+            await runner.cleanup()
+
+    def _run(self):
+        asyncio.set_event_loop(self.loop)
+        self.loop.run_until_complete(self.task_serve())
+
+
+class MockWebsocketsServer():
+    """
+    MockWebsocketsServer ，一个实例只提供一个 websockets 的 Mock
+    """
+
+    def __init__(self, **kwargs):
+        self.loop = asyncio.new_event_loop()
+        self.connection = {}
+        self.port = None
+        self.kwargs = kwargs
+        self._expecting = None
+        self.stop_signal = self.loop.create_future()
+        self.semaphore = threading.Semaphore(value=0)
+
+    def close(self):
+        #assert not self._expecting
+        self.loop.call_soon_threadsafe(lambda: self.stop_signal.set_result(0))
+        self.thread.join()
+        self.script_file.close()
+
+    def run(self, script_file_name):
+        self.script_file_name = script_file_name
+        self.thread = threading.Thread(target=self._run)
+        self.thread.start()
+        self.semaphore.acquire()
+
+    def _run(self):
+        if str.endswith(self.script_file_name, "lzma"):
+            self.script_file = lzma.open(self.script_file_name, "rt", encoding="utf-8")
+        else:  # 用于本地script还未压缩成lzma文件时运行测试用例
+            self.script_file = open(self.script_file_name, "rt", encoding="utf-8")
+        asyncio.set_event_loop(self.loop)
+        self.loop.run_until_complete(self._server())
+
+    async def _server(self):
+        async with websockets.serve(self._handler, "127.0.0.1") as server:
+            self.port = server.sockets[0].getsockname()[1]
+            self.semaphore.release()
+            await self.stop_signal
+
+    async def _handler(self, connection, path):
+        self.connection = connection
+        try:
+            async for msg in connection:
+                pack = json.loads(msg)
+                await self.on_received(pack)
+        except websockets.exceptions.ConnectionClosedOK as e:
+            assert e.code == 1000
+
+    async def _process_script(self):
+        # 每次处理日志文件中的一行, 直至需要输入为止
+        self._expecting = None
+        for line in self.script_file:
+            item = json.loads(line)
+            if item["name"] != "TqApi.TqConnect":
+                continue
+            if item["msg"] != "websocket send data" and item["msg"] != "websocket received data":
+                continue
+            is_valid_line = True
+            for k, v in self.kwargs.items():
+                if item.get(k) != v:
+                    is_valid_line = False
+                    break
+            if not is_valid_line:
+                continue
+            pack = json.loads(item['pack'])
+            if item["msg"] == "websocket send data" and pack != {"aid": "peek_message"}:
+                self._expecting = pack
+                break
+            elif item["msg"] == "websocket received data":
+                assert self.connection
+                await self.connection.send(item['pack'])
+
+    async def on_received(self, pack):
+        if not self._expecting:
+            await self._process_script()
+        if pack["aid"] != "peek_message":
+            if self._expecting["aid"] == "req_login" and pack["aid"] == "req_login":
+                # 登录请求单独判断这几个字段，不同操作系统带的穿管信息的包内容不同
+                assert self._expecting["bid"] == pack["bid"]
+                assert self._expecting["user_name"] == pack["user_name"]
+                assert self._expecting["password"] == pack["password"]
+            else:
+                assert self._expecting == pack
+            await self._process_script()
+
+
+class MockServer():
+    def __init__(self, td_url_character="opentd", md_url_character="openmd"):
+        self.loop = asyncio.new_event_loop()
+        self.connections = {}
+        self.server_md = None
+        self.server_td = None
+        self.md_url_character = md_url_character
+        self.td_url_character = td_url_character
+        self._expecting = {}
+        self.stop_signal = self.loop.create_future()
+        self.semaphore = threading.Semaphore(value=0)
+
+    def close(self):
+        assert not self._expecting
+        self.loop.call_soon_threadsafe(lambda: self.stop_signal.set_result(0))
+        self.thread.join()
+        self.script_file.close()
+
+    async def _handler_md(self, connection, path):
+        await self.on_connected("md", connection)
+        try:
+            while True:
+                s = await self.connections["md"].recv()
+                pack = json.loads(s)
+                await self.on_received("md", pack)
+        except websockets.exceptions.ConnectionClosedOK as e:
+            assert e.code == 1000
+
+    async def _handler_td(self, connection, path):
+        await self.on_connected("td", connection)
+        try:
+            while True:
+                s = await self.connections["td"].recv()
+                pack = json.loads(s)
+                if pack["aid"] == "peek_message":
+                    continue
+                await self.on_received("td", pack)
+        except websockets.exceptions.ConnectionClosedOK as e:
+            assert e.code == 1000
+
+    def run(self, script_file_name):
+        self.script_file_name = script_file_name
+        self.thread = threading.Thread(target=self._run)
+        self.thread.start()
+        self.semaphore.acquire()
+
+    async def _server(self):
+        async with websockets.serve(self._handler_md, "127.0.0.1") as self.server_md:
+            async with websockets.serve(self._handler_td, "127.0.0.1") as self.server_td:
+                self.md_port = self.server_md.sockets[0].getsockname()[1]
+                self.td_port = self.server_td.sockets[0].getsockname()[1]
+                self.semaphore.release()
+                await self.stop_signal
+
+    def _run(self):
+        if str.endswith(self.script_file_name, "lzma"):
+            self.script_file = lzma.open(self.script_file_name, "rt", encoding="utf-8")
+        else:  # 用于本地script还未压缩成lzma文件时运行测试用例
+            self.script_file = open(self.script_file_name, "rt", encoding="utf-8")
+        asyncio.set_event_loop(self.loop)
+        self.loop.run_until_complete(self._server())
+
+    async def _process_script(self):
+        # 每次处理日志文件中的一行, 直至需要输入为止
+        self._expecting = {}
+        for line in self.script_file:
+            # 2019-09-09 16:22:40,652 - DEBUG - websocket message sent to wss://openmd.shinnytech.com/t/md/front/mobile: {"aid": "subscribe_quote",
+            item = {}
+            if "websocket message sent" in line and "peek_message" not in line:  # 在api角度的sent
+                item["type"] = "sent"
+            elif "websocket message received" in line:  # 在api角度的received
+                item["type"] = "received"
+            else:
+                continue
+            if self.md_url_character in line:
+                item["source"] = "md"
+            elif self.td_url_character in line:
+                item["source"] = "td"
+            else:
+                raise Exception()
+            content_start_pos = line.find("{")
+            content = line[content_start_pos:]
+            item["content"] = json.loads(content)
+            if item["type"] == "sent":
+                self._expecting = item
+                break
+            elif item["type"] == "received":
+                msg = json.dumps(item["content"])
+                assert self.connections[item["source"]]
+                await self.connections[item["source"]].send(msg)
+
+    async def on_connected(self, source, connection):
+        self.connections[source] = connection
+        # self._process_script()
+        # assert self._expecting["source"] == source
+        # assert self._expecting["action"] == "connected"
+
+    async def on_received(self, source, pack):
+        if not self._expecting:
+            await self._process_script()
+        if pack["aid"] != "peek_message":
+            assert self._expecting["source"] == source
+            if self._expecting["content"]["aid"] == "req_login" and pack["aid"] == "req_login":
+                # 登录请求单独判断这几个字段，不同操作系统带的穿管信息的包内容不同
+                assert self._expecting["content"]["bid"] == pack["bid"]
+                assert self._expecting["content"]["user_name"] == pack["user_name"]
+                assert self._expecting["content"]["password"] == pack["password"]
+            else:
+                # 兼容新旧版本测试框架合约服务
+                if pack["aid"] != "ins_query":
+                    assert self._expecting["content"] == pack
+            await self._process_script()