fix: websockets 13.x uri attribute; test websockets 13.1; fork test over HTTP

- The sans-io ClientProtocol exposes the parsed URI as `wsuri` in
  websockets 13.x and `uri` in later releases; the new asyncio wrapper
  now falls back accordingly (it crashed stub creation on 13.x-16.x).
  websockets 13.1 added to the support matrix on all Python versions, so
  the new-API path is also exercised on Python 3.10 (websockets 17
  requires >= 3.11).
- sw_fork_support now reports over the HTTP protocol: forking with a
  live gRPC channel is subject to upstream at-fork races
  (grpc/grpc#43055) that can silently drop either side's segments (both
  directions were observed in CI). HTTP has no at-fork hazard, so the
  test deterministically validates the complete cross-fork trace again
  (parent entry/exit -> child entry with CrossProcess ref). The gRPC
  transport path remains covered by sw_gunicorn.

Locally validated: websockets 10.4 (legacy), 13.1 and 17.0.1 (new
asyncio path), and the fork case — full dataValidate pass each.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: wu-sheng

docs/en/setup/Plugins.md

@@ -51,7 +51,7 @@ or a limitation of SkyWalking auto-instrumentation (welcome to contribute!)
 | [urllib3](https://urllib3.readthedocs.io/en/latest/) | Python >=3.12 - NOT SUPPORTED YET; Python >=3.10 - ['1.26', '1.25'];  | `sw_urllib3` |
 | [urllib3](https://urllib3.readthedocs.io/en/latest/) | Python >=3.12 - ['2.3', '2.0'];  | `sw_urllib3_v2` |
 | [urllib_request](https://docs.python.org/3/library/urllib.request.html) | Python >=3.7 - ['*'];  | `sw_urllib_request` |
-| [websockets](https://websockets.readthedocs.io) | Python >=3.11 - ['10.3', '10.4', '17.0.1']; Python >=3.7 - ['10.3', '10.4'];  | `sw_websockets` |
+| [websockets](https://websockets.readthedocs.io) | Python >=3.11 - ['10.3', '10.4', '13.1', '17.0.1']; Python >=3.7 - ['10.3', '10.4', '13.1'];  | `sw_websockets` |
 ### Notes
 - The celery server running with "celery -A ..." should be run with the HTTP protocol
 as it uses multiprocessing by default which is not compatible with the gRPC protocol implementation

skywalking/plugins/sw_websockets.py

@@ -21,8 +21,8 @@
 link_vector = ['https://websockets.readthedocs.io']
 support_matrix = {
     'websockets': {
-        '>=3.11': ['10.3', '10.4', '17.0.1'],
-        '>=3.7': ['10.3', '10.4']  # websockets >= 14 requires Python >= 3.11
+        '>=3.11': ['10.3', '10.4', '13.1', '17.0.1'],
+        '>=3.7': ['10.3', '10.4', '13.1']  # websockets >= 14 requires Python >= 3.11
     }
 }
 note = """Both the legacy (websockets.legacy, websockets <= 13) and the new asyncio
@@ -99,7 +99,8 @@ def _install_new_client(ClientConnection):  # noqa
     _connection_handshake = ClientConnection.handshake
 
     async def _sw_connection_handshake(self, *args, **kwargs):
-        uri = self.protocol.uri
+        # the sans-io ClientProtocol renamed the attribute wsuri -> uri over time
+        uri = getattr(self.protocol, 'uri', None) or self.protocol.wsuri
         span = get_context().new_exit_span(op=uri.path or '/', peer=f'{uri.host}:{uri.port}',
                                            component=Component.Websockets)
         with span:

tests/plugin/web/sw_fork_support/docker-compose.yml

@@ -44,5 +44,10 @@ services:
       SW_AGENT_NAME: provider
       SW_AGENT_LOGGING_LEVEL: INFO
       SW_AGENT_EXPERIMENTAL_FORK_SUPPORT: 'true'
+      # HTTP reporter keeps this test deterministic: forking with a live gRPC channel
+      # is subject to upstream at-fork races (grpc/grpc#43055) that can silently drop
+      # either side's segments; the gRPC transport is covered by sw_gunicorn
+      SW_AGENT_PROTOCOL: http
+      SW_AGENT_COLLECTOR_BACKEND_SERVICES: collector:12800
 networks:
   beyond:

tests/plugin/web/sw_fork_support/expected.data.yml

@@ -15,14 +15,38 @@
 # limitations under the License.
 #
 
-# The forked child's own segment (entry span with a CrossProcess ref) is delivered
-# on a best-effort basis: reporting from a child forked while the parent's gRPC
-# channel is live can be broken by upstream at-fork races (grpc/grpc#43055), so
-# only the deterministic parent segment is asserted (segmentSize: ge 1).
 segmentItems:
   - serviceName: provider
-    segmentSize: ge 1
+    segmentSize: 2
     segments:
+      - segmentId: not null
+        spans:
+          - operationName: /users
+            parentSpanId: -1
+            spanId: 0
+            spanLayer: Http
+            tags:
+              - key: http.method
+                value: GET
+              - key: http.url
+                value: http://127.0.0.1:9091/users
+              - key: http.status_code
+                value: '200'
+            refs:
+              - parentEndpoint: /users
+                networkAddress: '127.0.0.1:9091'
+                refType: CrossProcess
+                parentSpanId: 1
+                parentTraceSegmentId: not null
+                parentServiceInstance: not null
+                parentService: provider
+                traceId: not null
+            startTime: gt 0
+            endTime: gt 0
+            componentId: 7001
+            spanType: Entry
+            peer: not null
+            skipAnalysis: false
       - segmentId: not null
         spans:
           - operationName: /users

tests/plugin/web/sw_fork_support/test_fork_support.py

@@ -31,11 +31,11 @@ def prepare():
 class TestPlugin(TestPluginBase):
     """
     Explicit os.fork() with SW_AGENT_EXPERIMENTAL_FORK_SUPPORT: the parent keeps its
-    agent and the forked child restarts one as a `-child(pid)` instance.
-    The child's own segment (entry with a CrossProcess ref) is best-effort — forking
-    with a live parent gRPC channel is subject to upstream at-fork races
-    (grpc/grpc#43055) — so only the parent's segment is asserted here; the fully
-    deterministic cross-process validation lives in the sw_gunicorn test.
+    agent, the forked child restarts one as a `-child(pid)` instance, and the trace
+    stays continuous across the fork (parent entry/exit -> child entry with ref).
+    Runs over the HTTP reporter: forking with a live gRPC channel is subject to
+    upstream at-fork races (grpc/grpc#43055) that can silently drop either side's
+    segments; the gRPC transport path is covered deterministically by sw_gunicorn.
     """
 
     @pytest.mark.parametrize('version', ['grpcio>=1.83'])