[Bug] Python SDK accepts malformed initialize.serverInfo responses

[MicroMilo]

Summary

The Python SDK accepts malformed initialize results that violate the shared SDK runtime protocol.

Checked commit: 47f943859bef60e4160492346772ded9b24f765a.

Expected behavior

initialize.result.serverInfo must contain both name and version as strings. The TypeScript protocol declares both fields as required, and the TypeScript SDK rejects a malformed response with SdkProtocolError.

References:

• Protocol type:

  deepseek-harness/packages/sdk/protocol/src/types.ts

  Lines 27 to 31 in 47f9438

  	/** Wire-stable server identity returned by initialization. */
  	export interface InitializeResult {
  	/** Wire-stable server identity (`deepseek-harness-sdk-runtime`) and version. */
  	serverInfo: { name: string; version: string }
  	}

• TypeScript runtime validation:

  deepseek-harness/packages/sdk/client/src/client.ts

  Lines 268 to 275 in 47f9438

  	async initialize(params: InitializeParams): Promise<InitializeResult> {
  	const result = await this.request('initialize', { ...params })
  	if (!isRecord(result) || !isRecord(result.serverInfo)
  	|| typeof result.serverInfo.name !== 'string' || typeof result.serverInfo.version !== 'string') {
  	throw new SdkProtocolError(`initialize returned no server identity: ${JSON.stringify(result)}`)
  	}
  	return { serverInfo: { name: result.serverInfo.name, version: result.serverInfo.version } }
  	}

Actual behavior

The Python model makes serverInfo, name, and version optional:

deepseek-harness/python/sdk/src/deepseek_harness/models.py

Lines 26 to 32 in 47f9438

	class ServerInfo(BaseModel):
	name: str | None = None
	version: str | None = None
	class InitializeResponse(BaseModel):
	serverInfo: ServerInfo | None = None

Consequently, HarnessClient.initialize() accepts malformed runtime responses and returns successfully:

deepseek-harness/python/sdk/src/deepseek_harness/client.py

Lines 117 to 135 in 47f9438

	def initialize(
	self,
	*,
	cwd: str,
	provider: str,
	model: str,
	max_tokens: int | None = None,
	) -> InitializeResponse:
	payload: JsonObject = {
	"cwd": str(Path(cwd).resolve()),
	"provider": provider,
	"model": model,
	}
	if max_tokens is not None:
	payload["maxTokens"] = max_tokens
	try:
	return self.request("initialize", payload, response_model=InitializeResponse)
	except BaseException:
	self.close()

Minimal reproduction

from deepseek_harness.models import InitializeResponse

for payload in (
    {},
    {"serverInfo": {}},
    {"serverInfo": {"name": "fake"}},
):
    print(InitializeResponse.model_validate(payload).model_dump())

All three payloads are accepted. At the transport level, the same result objects returned by a fake JSON-RPC runtime also make HarnessClient.initialize() return normally.

The corresponding TypeScript client rejects these shapes because serverInfo.name and serverInfo.version are not strings.

Impact

A Python integration can mark an incompatible or malformed runtime as initialized, delaying the protocol error until a later request and producing behavior inconsistent with the TypeScript SDK.

Suggested fix

Make InitializeResponse.serverInfo, ServerInfo.name, and ServerInfo.version required strings, or add an equivalent explicit validation guard in HarnessClient.initialize(). Please also add regression tests for missing serverInfo, an empty identity object, and a missing/non-string version.

Would you consider this a bug in the Python SDK, and if so, would you prefer tightening the Pydantic model or adding an explicit guard at the client boundary?

[democard]

I checked the current repository HEAD (47f943859bef60e4160492346772ded9b24f765a, 2026-08-13) and this still appears reproducible in the source:

• python/sdk/src/deepseek_harness/models.py still declares ServerInfo.name and ServerInfo.version as optional.
• InitializeResponse.serverInfo is also optional.
• The TypeScript client validates both fields as required strings.

This leaves the Python SDK accepting {}, {"serverInfo": {}}, and partial serverInfo objects that the TypeScript SDK rejects. I suggest making all three fields required and adding parametrized regression tests for missing, partial, and non-string values, plus one valid response.

I did not find a fixing commit in the current HEAD, so this looks like a still-open protocol-consistency bug rather than a documentation issue.

[lilei0311]

I reproduced this against the current master (477b4f4205) and prepared a patch.

Root cause. python/sdk/src/deepseek_harness/models.py declares ServerInfo.name, ServerInfo.version, and InitializeResponse.serverInfo as optional, while the shared protocol requires both fields as strings (packages/sdk/protocol/src/types.ts:32) and the TypeScript client rejects the same responses with SdkProtocolError (packages/sdk/client/src/client.ts:276-283). So {}, {"serverInfo": {}}, and partial serverInfo objects all initialize successfully in Python.

Fix. Make the three fields required so validation happens at the wire boundary, then translate the resulting pydantic ValidationError into SdkProtocolError with the TypeScript client's wording (initialize returned no server identity: …). The failed handshake also reaps the runtime, matching the existing timeout path.

Evidence. Three tests lock the model contract, the accepted identity, and the client-level refusal. The client-level one is load-bearing: applied to unpatched master, it fails with DID NOT RAISE SdkProtocolError, which is the reported symptom; the model-level one fails too. On the patched tree, uv run --python 3.10 --group test --project python/sdk pytest reports 209 passed, 13 skipped on the pinned CI interpreter. Both READMEs document the requirement and the bilingual pairing record was re-recorded.

Patch

--- a/python/sdk/src/deepseek_harness/models.py
+++ b/python/sdk/src/deepseek_harness/models.py
@@ -24,9 +24,9 @@ class IncomingRequest:
 
 
 class ServerInfo(BaseModel):
-    name: str | None = None
-    version: str | None = None
+    name: str
+    version: str
 
 
 class InitializeResponse(BaseModel):
-    serverInfo: ServerInfo | None = None
+    serverInfo: ServerInfo

--- a/python/sdk/src/deepseek_harness/client.py
+++ b/python/sdk/src/deepseek_harness/client.py
@@ -12,9 +12,9 @@
-from pydantic import BaseModel
+from pydantic import BaseModel, ValidationError
 
-from .errors import JsonRpcError, TransportClosedError
+from .errors import JsonRpcError, SdkProtocolError, TransportClosedError
@@ -158,6 +158,12 @@ class HarnessClient:
         except TimeoutError as error:
             self.close()
             raise TimeoutError(f"{error}\nselected dsh profile {self.config.profile!r}") from error
+        except ValidationError as error:
+            # The handshake must carry both `serverInfo.name` and
+            # `serverInfo.version`; the TypeScript client refuses the same
+            # responses.
+            self.close()
+            raise SdkProtocolError(f"initialize returned no server identity: {error}") from error
         except BaseException as error:
             self.close()
             diagnostics = self._runtime_diagnostics()

The full patch, including tests and both READMEs, is attached below — I understand external PRs are not being accepted right now, so I am posting it here rather than opening a PR. Happy to adjust the shape or split it if that helps.

One adjacent gap I deliberately left out of scope: a non-object initialize result currently raises TypeError from request() rather than SdkProtocolError. It still fails loudly, so this issue's silent-acceptance impact is resolved, but full parity on that path would be a separate change.

Full patch (git am)

From df08976aa74d08d7bcb4bb12b6fe21a1aec7079b Mon Sep 17 00:00:00 2001
From: lilei0311 <lilei0311@users.noreply.github.com>
Date: Sat, 26 Sep 2026 21:06:02 +0800
Subject: [PATCH] fix(python-sdk): reject a handshake without a complete server
 identity

`ServerInfo.name`, `ServerInfo.version`, and `InitializeResponse.serverInfo`
were optional, so `initialize` accepted `{}`, `{"serverInfo": {}}`, and
partial `serverInfo` objects. A Python integration could therefore treat an
incompatible or malformed runtime as initialized and defer the protocol
error to a later request, unlike the TypeScript client, which requires both
fields as strings and rejects the same responses with `SdkProtocolError`.

Make all three fields required and translate the resulting wire validation
failure into `SdkProtocolError`, matching the TypeScript client's error type
and message. The bundled fake runtimes in the suite now answer with a
complete identity, and three tests pin the model contract, the accepted
identity, and the client-level refusal.

Also record the handshake identity requirement in both READMEs and re-record
their pairing entry.
---
 python/sdk/README.i18n.yaml               |  4 +-
 python/sdk/README.md                      |  2 +-
 python/sdk/README.zh.md                   |  2 +-
 python/sdk/src/deepseek_harness/client.py | 10 ++-
 python/sdk/src/deepseek_harness/models.py |  6 +-
 python/sdk/tests/test_client.py           | 83 +++++++++++++++++------
 6 files changed, 79 insertions(+), 28 deletions(-)

diff --git a/python/sdk/README.i18n.yaml b/python/sdk/README.i18n.yaml
index ddc16b98c6..1cc9c5098c 100644
--- a/python/sdk/README.i18n.yaml
+++ b/python/sdk/README.i18n.yaml
@@ -6,8 +6,8 @@
   en: 43f7de064985e731
   zh: 9ad59629660b1f13
 /deepseek-harness-python-sdk/start-a-runtime:
-  en: 9a069c1a7cbb0779
-  zh: 7f625a802cd1e9ea
+  en: 56adaf14c2ee1920
+  zh: 9ed7001d2036a76c
 /deepseek-harness-python-sdk/customize-plugins:
   en: d32ee602f121e6af
   zh: fdea4487688e5774
diff --git a/python/sdk/README.md b/python/sdk/README.md
index bfca3b0dda..9d9b7ea521 100644
--- a/python/sdk/README.md
+++ b/python/sdk/README.md
@@ -30,7 +30,7 @@ with DeepSeekHarness(
 print(result.final_response)

-DeepSeekHarness starts lazily and reuses its runtime until close() or context-manager exit. The initial profile handshake has an independent 30-second default bound through initialize_timeout_seconds; ordinary turns remain unbounded unless request_timeout_seconds is set. A timeout names the selected profile and includes retained runtime diagnostics. cwd is the agent workspace; runtime_cwd independently selects the subprocess working directory. Both become absolute before launch. provider, model, optional reasoning_effort, and optional positive max_tokens are sent during JSON-RPC initialization. base_url and api_key explicitly override DEEPSEEK_BASE_URL and DEEPSEEK_API_KEY in the child environment.
+DeepSeekHarness starts lazily and reuses its runtime until close() or context-manager exit. The initial profile handshake has an independent 30-second default bound through initialize_timeout_seconds; ordinary turns remain unbounded unless request_timeout_seconds is set. A timeout names the selected profile and includes retained runtime diagnostics. A handshake response that omits serverInfo.name or serverInfo.version violates the protocol and raises SdkProtocolError. cwd is the agent workspace; runtime_cwd independently selects the subprocess working directory. Both become absolute before launch. provider, model, optional reasoning_effort, and optional positive max_tokens are sent during JSON-RPC initialization. base_url and api_key explicitly override DEEPSEEK_BASE_URL and DEEPSEEK_API_KEY in the child environment.

Customize plugins

diff --git a/python/sdk/README.zh.md b/python/sdk/README.zh.md
index a10f1f5013..74c6b40fea 100644
--- a/python/sdk/README.zh.md
+++ b/python/sdk/README.zh.md
@@ -30,7 +30,7 @@ with DeepSeekHarness(
print(result.final_response)

-`DeepSeekHarness` 延迟启动运行时，并在调用 `close()` 或退出上下文管理器前复用该进程。首次 profile 握手通过 `initialize_timeout_seconds` 使用独立的 30 秒默认上限；普通轮次在未设置 `request_timeout_seconds` 时仍不设上限。超时诊断会指明所选 profile，并包含保留的运行时诊断。`cwd` 是 agent workspace；`runtime_cwd` 独立选择子进程工作目录。两者都会在启动前转成绝对路径。`provider`、`model`、可选的 `reasoning_effort` 和可选的正整数 `max_tokens` 通过 JSON-RPC 初始化发送。`base_url` 与 `api_key` 会显式覆盖子进程环境中的 `DEEPSEEK_BASE_URL` 与 `DEEPSEEK_API_KEY`。
+`DeepSeekHarness` 延迟启动运行时，并在调用 `close()` 或退出上下文管理器前复用该进程。首次 profile 握手通过 `initialize_timeout_seconds` 使用独立的 30 秒默认上限；普通轮次在未设置 `request_timeout_seconds` 时仍不设上限。超时诊断会指明所选 profile，并包含保留的运行时诊断。握手响应缺少 `serverInfo.name` 或 `serverInfo.version` 时违反协议，会抛出 `SdkProtocolError`。`cwd` 是 agent workspace；`runtime_cwd` 独立选择子进程工作目录。两者都会在启动前转成绝对路径。`provider`、`model`、可选的 `reasoning_effort` 和可选的正整数 `max_tokens` 通过 JSON-RPC 初始化发送。`base_url` 与 `api_key` 会显式覆盖子进程环境中的 `DEEPSEEK_BASE_URL` 与 `DEEPSEEK_API_KEY`。

## 自定义插件

diff --git a/python/sdk/src/deepseek_harness/client.py b/python/sdk/src/deepseek_harness/client.py
index faa42230e6..08fdcca9f7 100644
--- a/python/sdk/src/deepseek_harness/client.py
+++ b/python/sdk/src/deepseek_harness/client.py
@@ -12,9 +12,9 @@ from dataclasses import dataclass
from pathlib import Path
from typing import Callable, TypeAlias, TypeVar

-from pydantic import BaseModel
+from pydantic import BaseModel, ValidationError

-from .errors import JsonRpcError, TransportClosedError
+from .errors import JsonRpcError, SdkProtocolError, TransportClosedError
from .models import IncomingRequest, InitializeResponse, JsonObject, JsonValue, Notification

ModelT = TypeVar("ModelT", bound=BaseModel)
@@ -158,6 +158,12 @@ class HarnessClient:
        except TimeoutError as error:
            self.close()
            raise TimeoutError(f"{error}\nselected dsh profile {self.config.profile!r}") from error
+        except ValidationError as error:
+            # The handshake must carry both `serverInfo.name` and
+            # `serverInfo.version`; the TypeScript client refuses the same
+            # responses.
+            self.close()
+            raise SdkProtocolError(f"initialize returned no server identity: {error}") from error
        except BaseException as error:
            self.close()
            diagnostics = self._runtime_diagnostics()
diff --git a/python/sdk/src/deepseek_harness/models.py b/python/sdk/src/deepseek_harness/models.py
index f398bb422d..21e87acdd2 100644
--- a/python/sdk/src/deepseek_harness/models.py
+++ b/python/sdk/src/deepseek_harness/models.py
@@ -24,9 +24,9 @@ class IncomingRequest:


class ServerInfo(BaseModel):
-    name: str | None = None
-    version: str | None = None
+    name: str
+    version: str


class InitializeResponse(BaseModel):
-    serverInfo: ServerInfo | None = None
+    serverInfo: ServerInfo
diff --git a/python/sdk/tests/test_client.py b/python/sdk/tests/test_client.py
index 66b9b2665c..cf5d152c8f 100644
--- a/python/sdk/tests/test_client.py
+++ b/python/sdk/tests/test_client.py
@@ -8,9 +8,54 @@ import time
from pathlib import Path

import pytest
+from pydantic import ValidationError

from deepseek_harness import DeepSeekHarness, HarnessClient, HarnessConfig, Notification, RunResult, SdkProtocolError
from deepseek_harness.errors import JsonRpcError
+from deepseek_harness.models import InitializeResponse
+
+
+def test_initialize_rejects_malformed_server_info() -> None:
+    for payload in (
+        {},
+        {"serverInfo": {}},
+        {"serverInfo": {"name": "fake"}},
+        {"serverInfo": {"version": "1.0"}},
+        {"serverInfo": {"name": None, "version": "1.0"}},
+        {"serverInfo": {"name": "fake", "version": None}},
+    ):
+        with pytest.raises(ValidationError):
+            InitializeResponse.model_validate(payload)
+
+
+def test_initialize_accepts_valid_server_info() -> None:
+    response = InitializeResponse.model_validate(
+        {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}
+    )
+    assert response.serverInfo.name == "fake-runtime"
+    assert response.serverInfo.version == "1.0.0"
+
+
+def test_client_initialize_rejects_incomplete_server_identity(tmp_path: Path) -> None:
+    script = tmp_path / "fake_bridge.py"
+    script.write_text(
+        """
+import json
+import sys
+
+for line in sys.stdin:
+    msg = json.loads(line)
+    if msg.get("method") == "initialize":
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+    elif msg.get("method") == "shutdown":
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {}}), flush=True)
+        break
+""".strip()
+    )
+
+    with HarnessClient(_launch_args=(sys.executable, str(script))) as client:
+        with pytest.raises(SdkProtocolError, match="no server identity"):
+            client.initialize(provider="deepseek-official", cwd="/workspace", model="dsagent")


def test_high_level_sdk_runs_turn_and_preserves_auto_review_errors(tmp_path: Path) -> None:
@@ -37,7 +82,7 @@ for line in sys.stdin:
    method = msg.get("method")
    if method == "initialize":
        json.dump(msg.get("params"), open(os.environ["INIT_DUMP"], "w"))
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        params = msg.get("params") or {}
        print(json.dumps({"jsonrpc": "2.0", "method": "session.event", "params": {"sessionId": params["sessionId"], "event": {"type": "agent/inbox/spliced", "data": {"target": "next-turn", "start": 0, "inserted": [{"id": "message-1"}]}}}}), flush=True)
@@ -228,7 +273,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        print(json.dumps({"jsonrpc": "2.0", "method": "session.event", "params": {"sessionId": "main", "event": {"type": "agent/inbox/spliced", "data": {"target": "next-turn", "start": 0, "inserted": [{"id": "message-1"}]}}}}), flush=True)
        print(json.dumps({"jsonrpc": "2.0", "method": "session.status", "params": {"sessionId": "main", "status": "running"}}), flush=True)
@@ -267,7 +312,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        params = msg.get("params") or {}
        print(json.dumps({"jsonrpc": "2.0", "method": "session.event", "params": {"sessionId": params["sessionId"], "event": {"type": "agent/inbox/spliced", "data": {"target": "next-turn", "start": 0, "inserted": [{"id": "message-1"}]}}}}), flush=True)
@@ -306,7 +351,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    if msg.get("method") == "initialize":
        json.dump({"process": os.getcwd(), "environment": os.environ.get("DSH_CWD"), "wire": msg["params"]["cwd"]}, open(os.environ["CAPTURE"], "w"))
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif msg.get("method") == "shutdown":
        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {}}), flush=True)
        break
@@ -341,7 +386,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        print(json.dumps({"jsonrpc": "2.0", "method": "session.event", "params": {"sessionId": "main", "event": {"type": "agent/inbox/spliced", "data": {"target": "next-turn", "start": 0, "inserted": [{"id": "message-1"}]}}}}), flush=True)
        print(json.dumps({"jsonrpc": "2.0", "method": "session.status", "params": {"sessionId": "main", "status": "running"}}), flush=True)
@@ -383,7 +428,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        root = (msg.get("params") or {})["sessionId"]
        print(json.dumps({"jsonrpc": "2.0", "method": "session.event", "params": {"sessionId": root, "event": {"type": "agent/inbox/spliced", "data": {"target": "next-turn", "start": 0, "inserted": [{"id": "message-1"}]}}}}), flush=True)
@@ -443,7 +488,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        params = msg.get("params") or {}
        print(json.dumps({"jsonrpc": "2.0", "method": "session.event", "params": {"sessionId": "other", "event": {"type": "assistant/message", "data": {"content": [{"type": "text", "text": "wrong session"}]}}}}), flush=True)
@@ -480,7 +525,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        params = msg.get("params") or {}
        print(json.dumps({"jsonrpc": "2.0", "method": "session.event", "params": {"sessionId": params["sessionId"], "event": {"type": "agent/inbox/spliced", "data": {"target": "next-turn", "start": 0, "inserted": [{"id": "message-1"}]}}}}), flush=True)
@@ -512,7 +557,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-runtime", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        turn += 1
        params = msg.get("params") or {}
@@ -554,7 +599,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        params = msg.get("params") or {}
        print(json.dumps({"jsonrpc": "2.0", "method": "llm/request", "params": {"requestId": "req-1", "sessionId": params["sessionId"], "model": "dsagent", "messages": []}}), flush=True)
@@ -698,7 +743,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
    elif method in {"emit-first", "emit-second"}:
        print(json.dumps({"jsonrpc": "2.0", "method": "tick", "params": {"source": method}}), flush=True)
    elif method == "session/prompt":
@@ -740,7 +785,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
    elif method == "session/prompt":
        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"accepted": False}}), flush=True)
    elif method == "shutdown":
@@ -766,7 +811,7 @@ for line in sys.stdin:
    msg = json.loads(line)
    method = msg.get("method")
    if method == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
        print(json.dumps({"jsonrpc": "2.0", "id": "bridge-req-1", "method": "llm.request", "params": {"requestId": "req-1", "sessionId": "main", "model": "dsagent", "messages": []}}), flush=True)
    elif "id" in msg and "method" not in msg:
        print(json.dumps({"jsonrpc": "2.0", "method": "response/seen", "params": {"result": msg.get("result")}}), flush=True)
@@ -801,7 +846,7 @@ print("node warning: experimental loader", flush=True)
for line in sys.stdin:
    msg = json.loads(line)
    if msg.get("method") == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
    elif msg.get("method") == "shutdown":
        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {}}), flush=True)
        break
@@ -857,7 +902,7 @@ signal.signal(signal.SIGTERM, signal.SIG_IGN)
for line in sys.stdin:
    msg = json.loads(line)
    if msg.get("method") == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
    elif msg.get("method") == "shutdown":
        time.sleep(60)
""".strip()
@@ -894,7 +939,7 @@ import time
for line in sys.stdin:
    msg = json.loads(line)
    if msg.get("method") == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
    elif msg.get("method") == "shutdown":
        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {}}), flush=True)

@@ -993,7 +1038,7 @@ import sys
for line in sys.stdin:
    msg = json.loads(line)
    if msg.get("method") == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
    elif msg.get("method") == "shutdown":
        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {}}), flush=True)
        break
@@ -1043,7 +1088,7 @@ with open(os.environ["SEEN"], "w") as seen:
        seen.flush()
        msg = json.loads(line)
        if "id" in msg and msg.get("method") == "initialize":
-            print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh"}}}), flush=True)
+            print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "fake-dsh", "version": "1.0.0"}}}), flush=True)
        elif "id" in msg and msg.get("method") == "shutdown":
            print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {}}), flush=True)
            break
@@ -1089,7 +1134,7 @@ json.dump({
for line in sys.stdin:
    msg = json.loads(line)
    if msg.get("method") == "initialize":
-        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "bundled-runtime"}}}), flush=True)
+        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {"serverInfo": {"name": "bundled-runtime", "version": "1.0.0"}}}), flush=True)
    elif msg.get("method") == "shutdown":
        print(json.dumps({"jsonrpc": "2.0", "id": msg["id"], "result": {}}), flush=True)
        break
-- 
2.54.0 (Apple Git-157)