fix: make stream lifecycle cancellation-safe

.gitattributes

@@ -0,0 +1 @@
+README.md -text whitespace=cr-at-eol

.github/workflows/publish.yml

@@ -1,18 +1,27 @@
-name: Build and Publish Package
-on:
-  release:
-    types: [published]
-jobs:
-  build-and-publish:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v2
-      - name: Build Package
-        run: |
-          python setup.py sdist bdist_wheel
-      - name: Publish Package
-        uses: pypa/gh-action-pypi-publish@master
-        with:
-          user: __token__
-          password: ${{ secrets.PYPI_API_TOKEN }}
+name: Build and Publish Package
+on:
+  release:
+    types: [published]
+jobs:
+  build-and-publish:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: '3.14'
+      - name: Install build tools
+        run: python -m pip install build
+      - name: Test
+        run: |
+          python -m pip install --editable .
+          python -m unittest discover -s tests -v
+      - name: Build Package
+        run: python -m build
+      - name: Publish Package
+        uses: pypa/gh-action-pypi-publish@release/v1
+        with:
+          user: __token__
+          password: ${{ secrets.PYPI_API_TOKEN }}

.github/workflows/test.yml

@@ -0,0 +1,52 @@
+name: Test
+
+on:
+  pull_request:
+  push:
+    branches:
+      - main
+
+permissions:
+  contents: read
+
+jobs:
+  test:
+    runs-on: ${{ matrix.os }}
+    strategy:
+      fail-fast: false
+      matrix:
+        os:
+          - ubuntu-latest
+        python:
+          - '3.8'
+          - '3.9'
+          - '3.10'
+          - '3.11'
+          - '3.12'
+          - '3.13'
+          - '3.14'
+        include:
+          - os: windows-latest
+            python: '3.10'
+          - os: windows-latest
+            python: '3.14'
+
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: ${{ matrix.python }}
+          cache: pip
+          cache-dependency-path: setup.py
+
+      - name: Install
+        run: python -m pip install --editable .
+
+      - name: Test
+        run: python -m unittest discover -s tests -v
+
+      - name: Compile package and examples
+        run: python -m compileall -q dingtalk_stream tests examples

README.md

@@ -68,7 +68,12 @@ class CalcBotHandler(dingtalk_stream.ChatbotHandler):
         incoming_message = dingtalk_stream.ChatbotMessage.from_dict(callback.data)
         expression = incoming_message.text.content.strip()
         try:
-            result = eval(expression)
+            operands = [float(part.strip()) for part in expression.split('+')]
+            if len(operands) < 2:
+                raise ValueError('only addition expressions are supported')
+            result = sum(operands)
+            if result.is_integer():
+                result = int(result)
         except Exception as e:
             result = 'Error: %s' % e
         self.logger.info('%s = %s' % (expression, result))
@@ -97,14 +102,29 @@ if __name__ == '__main__':
 
 有的时候，你需要在已有的 ioloop 中使用钉钉 Stream 模式，不使用 `start_forever` 方法。
 
-此时，可以使用 `client.start()` 代替 `client.start_forever()`。注意：需要在网络异常后重新启动
+此时，可以使用 `client.start()` 代替 `client.start_forever()`。`start()` 会在网络异常后自动重连，
+调用 `stop()` 可以中断重连等待并关闭当前连接：
 
 ```Python
+client_task = asyncio.create_task(client.start())
 try:
-    await client.start()
-except (asyncio.exceptions.CancelledError,
-        websockets.exceptions.ConnectionClosedError) as e:
-    ... # 处理网络断线异常
+    await run_application()
+finally:
+    await client.stop()
+    await client_task
+```
+
+可以通过 `websocket_connect_options` 透传 `websockets.connect()` 参数，例如调整握手和心跳超时：
+
+```Python
+client = dingtalk_stream.DingTalkStreamClient(
+    credential,
+    websocket_connect_options={
+        'open_timeout': 10,
+        'ping_interval': 20,
+        'ping_timeout': 20,
+    },
+)
 ```
 
 ## 开发教程

dingtalk_stream/frames.py

@@ -170,25 +170,6 @@ def __init__(self):
         self.data = {}
         self.extensions = {}
 
-        @classmethod
-        def from_dict(cls, d):
-            msg = SystemMessage()
-            data = ''
-            for name, value in d.items():
-                if name == 'specVersion':
-                    msg.spec_version = value
-                elif name == 'data':
-                    data = value
-                elif name == 'type':
-                    pass
-                elif name == 'headers':
-                    msg.headers = Headers.from_dict(value)
-                else:
-                    msg.extensions[name] = value
-            if data:
-                msg.data = json.loads(data)
-            return msg
-
     def __str__(self):
         return 'SystemMessage(spec_version=%s, type=%s, headers=%s, data=%s, extensions=%s)' % (
             self.spec_version,