From 910d52f717cc0b37021ea0de17e869ec2ecbf6dd Mon Sep 17 00:00:00 2001
From: 07akioni <07akioni2@gmail.com>
Date: Mon, 21 Sep 2026 16:28:18 +0800
Subject: [PATCH 1/3] feat(telemetry): add explicit product event OTLP exporter
---
THIRD_PARTY_NOTICES.md | 1 +
docs/capability-seams.i18n.yaml | 4 +-
docs/capability-seams.md | 4 +
docs/capability-seams.zh.md | 4 +
docs/config-catalog.i18n.yaml | 4 +-
docs/config-catalog.md | 34 ++++
docs/config-catalog.zh.md | 34 ++++
docs/module-graph.i18n.yaml | 4 +-
docs/module-graph.md | 2 +
docs/module-graph.zh.md | 2 +
docs/subsystems/README.i18n.yaml | 4 +-
docs/subsystems/README.md | 1 +
docs/subsystems/README.zh.md | 1 +
docs/subsystems/product-telemetry.i18n.yaml | 6 +
docs/subsystems/product-telemetry.md | 35 ++++
docs/subsystems/product-telemetry.zh.md | 35 ++++
.../extensions/tool-cordis/src/api-catalog.ts | 20 +++
packages/host/README.i18n.yaml | 4 +-
packages/host/README.md | 7 +-
packages/host/README.zh.md | 7 +-
.../product-telemetry-otel/README.i18n.yaml | 6 +
.../host/product-telemetry-otel/README.md | 104 ++++++++++++
.../host/product-telemetry-otel/README.zh.md | 104 ++++++++++++
.../host/product-telemetry-otel/package.json | 47 ++++++
.../host/product-telemetry-otel/src/index.ts | 154 +++++++++++++++++
.../tests/fixtures/driver.ts | 42 +++++
.../tests/fixtures/telemetry.patch.yml | 15 ++
.../tests/loader-composition.e2e.ts | 23 +++
.../tests/telemetry.spec.ts | 157 ++++++++++++++++++
.../host/product-telemetry-otel/tsconfig.json | 21 +++
pnpm-lock.yaml | 37 +++++
scripts/gen-cordis-catalog.ts | 3 +
scripts/gen-doc-graphs.ts | 7 +
.../verify-package-readme-model-experience.ts | 1 +
tsconfig.base.json | 1 +
tsconfig.host.json | 1 +
36 files changed, 922 insertions(+), 14 deletions(-)
create mode 100644 docs/subsystems/product-telemetry.i18n.yaml
create mode 100644 docs/subsystems/product-telemetry.md
create mode 100644 docs/subsystems/product-telemetry.zh.md
create mode 100644 packages/host/product-telemetry-otel/README.i18n.yaml
create mode 100644 packages/host/product-telemetry-otel/README.md
create mode 100644 packages/host/product-telemetry-otel/README.zh.md
create mode 100644 packages/host/product-telemetry-otel/package.json
create mode 100644 packages/host/product-telemetry-otel/src/index.ts
create mode 100644 packages/host/product-telemetry-otel/tests/fixtures/driver.ts
create mode 100644 packages/host/product-telemetry-otel/tests/fixtures/telemetry.patch.yml
create mode 100644 packages/host/product-telemetry-otel/tests/loader-composition.e2e.ts
create mode 100644 packages/host/product-telemetry-otel/tests/telemetry.spec.ts
create mode 100644 packages/host/product-telemetry-otel/tsconfig.json
diff --git a/THIRD_PARTY_NOTICES.md b/THIRD_PARTY_NOTICES.md
index 096d5ee117..6cd790f7c5 100644
--- a/THIRD_PARTY_NOTICES.md
+++ b/THIRD_PARTY_NOTICES.md
@@ -53,6 +53,7 @@ External packages installed for runtime use or distributed inside the prebuilt b
| [`@openai/codex`](https://github.com/openai/codex) | Apache-2.0 |
| [`@opentelemetry/api`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@opentelemetry/api-logs`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
+| [`@opentelemetry/core`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@opentelemetry/exporter-logs-otlp-http`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@opentelemetry/otlp-exporter-base`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@opentelemetry/resources`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
diff --git a/docs/capability-seams.i18n.yaml b/docs/capability-seams.i18n.yaml
index a1e749da0f..efedaef6c9 100644
--- a/docs/capability-seams.i18n.yaml
+++ b/docs/capability-seams.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/capability-seams.md
-capability-seams.md: bbd44bce011404ee476131b9f498618a8ef5c708
-capability-seams.zh.md: 4e9f826bc27420ba372ac6feb688cc23bc58e141
+capability-seams.md: f6482d487543a9b1b0d9251c1aa6089b7ca2c558
+capability-seams.zh.md: f9a9d2d92b9d4253bfc00ed4ebbb9433a78138e7
diff --git a/docs/capability-seams.md b/docs/capability-seams.md
index bbd44bce01..f6482d4875 100644
--- a/docs/capability-seams.md
+++ b/docs/capability-seams.md
@@ -7,6 +7,8 @@ A service can be a core spine service, a swappable capability seam, or a bundle/
```mermaid
flowchart LR
+ pkg_product_telemetry_otel["product-telemetry-otel"]
+ svc_productTelemetry["ctx.productTelemetry
Product usage event sender"]
pkg_hmr["hmr"]
svc_hmr["ctx.hmr
Serialized module and configuration reloads"]
pkg_app_boot["app-boot"]
@@ -337,6 +339,7 @@ flowchart LR
pkg_plan_mode --> svc_planMode
pkg_plugin_manager --> svc_pluginManager
pkg_plugin_package_inventory_deepseek --> svc_deepseekLlmApiExtensions
+ pkg_product_telemetry_otel --> svc_productTelemetry
pkg_ptc_runtime --> svc_ptcRuntime
pkg_ptc_runtime_node --> svc_ptcRuntime
pkg_pwsh_local --> svc_shell
@@ -551,6 +554,7 @@ flowchart LR
| ctx key | Role | Owner | Implementations | Direct consumers | Companion plugins | Note |
| --- | --- | --- | --- | --- | --- | --- |
+| `ctx.productTelemetry` | `core` | [`product-telemetry-otel`](../packages/host/product-telemetry-otel) | - | - | - | Exports explicitly submitted analytics events through OTLP/HTTP; mounting alone collects nothing. |
| `ctx.hmr` | `core` | [`hmr`](../packages/boot/hmr) | - | [`app-boot`](../packages/boot/app-boot) | - | Owns module and exact configuration watchers; application mutations share its queue and automatic reloads await the application file lock. |
| `ctx.pluginManager` | `core` | [`plugin-manager`](../packages/boot/plugin-manager) | - | [`plugin-manager`](../packages/boot/plugin-manager), `ui-settings-plugin-inventory` | - | Shares profile package operations with the CLI and reports persisted and running state to Web and agent callers. |
| `ctx.profileContext` | `core` | [`app-boot`](../packages/boot/app-boot) | - | [`plugin-manager`](../packages/boot/plugin-manager) | - | The dsh launcher supplies data-only profile locations and composition inputs; reload scheduling belongs to dsh-hmr. |
diff --git a/docs/capability-seams.zh.md b/docs/capability-seams.zh.md
index 4e9f826bc2..f9a9d2d92b 100644
--- a/docs/capability-seams.zh.md
+++ b/docs/capability-seams.zh.md
@@ -9,6 +9,8 @@
```mermaid
flowchart LR
+ pkg_product_telemetry_otel["product-telemetry-otel"]
+ svc_productTelemetry["ctx.productTelemetry
Product usage event sender"]
pkg_hmr["hmr"]
svc_hmr["ctx.hmr
Serialized module and configuration reloads"]
pkg_app_boot["app-boot"]
@@ -339,6 +341,7 @@ flowchart LR
pkg_plan_mode --> svc_planMode
pkg_plugin_manager --> svc_pluginManager
pkg_plugin_package_inventory_deepseek --> svc_deepseekLlmApiExtensions
+ pkg_product_telemetry_otel --> svc_productTelemetry
pkg_ptc_runtime --> svc_ptcRuntime
pkg_ptc_runtime_node --> svc_ptcRuntime
pkg_pwsh_local --> svc_shell
@@ -553,6 +556,7 @@ flowchart LR
| ctx 键 | 角色 | 所属包 | 实现 | 直接消费方 | 配套插件 | 说明 |
| --- | --- | --- | --- | --- | --- | --- |
+| `ctx.productTelemetry` | `core` | [`product-telemetry-otel`](../packages/host/product-telemetry-otel) | - | - | - | 通过 OTLP/HTTP 发送显式提交的分析事件；仅挂载插件不会采集信息。 |
| `ctx.hmr` | `core` | [`hmr`](../packages/boot/hmr) | - | [`app-boot`](../packages/boot/app-boot) | - | 负责模块和精确配置监听；应用修改共用其队列，自动重载等待应用文件锁。 |
| `ctx.pluginManager` | `core` | [`plugin-manager`](../packages/boot/plugin-manager) | - | [`plugin-manager`](../packages/boot/plugin-manager), `ui-settings-plugin-inventory` | - | 与 CLI 共享 profile 包操作，并向 Web 和 Agent 调用方分别报告持久状态与运行状态。 |
| `ctx.profileContext` | `core` | [`app-boot`](../packages/boot/app-boot) | - | [`plugin-manager`](../packages/boot/plugin-manager) | - | dsh launcher 提供纯数据形式的 profile 位置与组合输入；重载调度由 dsh-hmr 负责。 |
diff --git a/docs/config-catalog.i18n.yaml b/docs/config-catalog.i18n.yaml
index 7c73a927de..285f1d9a96 100644
--- a/docs/config-catalog.i18n.yaml
+++ b/docs/config-catalog.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/config-catalog.md
-config-catalog.md: d3d1b4fe47bf6dc745dc9a00ac6ef317ab0d3ca8
-config-catalog.zh.md: 3f204af30d5e973c03cd24c6c2873bb7756d334e
+config-catalog.md: fe9edd406fa6305494e0e1f6fc71725278716685
+config-catalog.zh.md: 0a45e6573a94e46fa8d615af8a1f6e459c9cb2d2
diff --git a/docs/config-catalog.md b/docs/config-catalog.md
index d3d1b4fe47..fe9edd406f 100644
--- a/docs/config-catalog.md
+++ b/docs/config-catalog.md
@@ -2064,6 +2064,40 @@ export interface Config {
Source: [`packages/llm/plugin-package-inventory-deepseek/src/index.ts:32`](../packages/llm/plugin-package-inventory-deepseek/src/index.ts)
+
+
+## `@deepseek-ai/dsh-product-telemetry-otel`
+
+```ts config-catalog
+/** Collector routing, application identity, and bounded in-memory batch settings. */
+export interface Config {
+ /** Full HTTP(S) logs URL. */
+ endpoint: string
+ /** Collector routing header. */
+ channel: string
+ /** Resource service.name supplied by the application composition. */
+ serviceName: string
+ /** Resource service.version supplied by the application composition. */
+ serviceVersion: string
+ /** Omit to honor OTEL_EXPORTER_OTLP_LOGS_COMPRESSION / OTEL_EXPORTER_OTLP_COMPRESSION. */
+ compression?: 'none' | 'gzip'
+ /** Maximum records per export; must not exceed maxQueueSize. */
+ maxExportBatchSize: number
+ /** Maximum queued records; the SDK drops new records when full. */
+ maxQueueSize: number
+ /** Delay before exporting a partial batch. */
+ scheduledDelayMillis: number
+ /** Exporter HTTP deadline, including SDK transient-error retries. */
+ timeoutMillis: number
+ /** Processor deadline for one batch export. */
+ exportTimeoutMillis: number
+ /** Outer shutdown wait; pending exports may be lost after this deadline. */
+ shutdownTimeoutMillis: number
+}
+```
+
+Source: [`packages/host/product-telemetry-otel/src/index.ts:35`](../packages/host/product-telemetry-otel/src/index.ts)
+
## `@deepseek-ai/dsh-ptc-runtime-node`
diff --git a/docs/config-catalog.zh.md b/docs/config-catalog.zh.md
index 3f204af30d..0a45e6573a 100644
--- a/docs/config-catalog.zh.md
+++ b/docs/config-catalog.zh.md
@@ -2068,6 +2068,40 @@ export interface Config {
来源：[`packages/llm/plugin-package-inventory-deepseek/src/index.ts:32`](../packages/llm/plugin-package-inventory-deepseek/src/index.ts)
+
+
+## `@deepseek-ai/dsh-product-telemetry-otel`
+
+```ts config-catalog
+/** Collector routing, application identity, and bounded in-memory batch settings. */
+export interface Config {
+ /** Full HTTP(S) logs URL. */
+ endpoint: string
+ /** Collector routing header. */
+ channel: string
+ /** Resource service.name supplied by the application composition. */
+ serviceName: string
+ /** Resource service.version supplied by the application composition. */
+ serviceVersion: string
+ /** Omit to honor OTEL_EXPORTER_OTLP_LOGS_COMPRESSION / OTEL_EXPORTER_OTLP_COMPRESSION. */
+ compression?: 'none' | 'gzip'
+ /** Maximum records per export; must not exceed maxQueueSize. */
+ maxExportBatchSize: number
+ /** Maximum queued records; the SDK drops new records when full. */
+ maxQueueSize: number
+ /** Delay before exporting a partial batch. */
+ scheduledDelayMillis: number
+ /** Exporter HTTP deadline, including SDK transient-error retries. */
+ timeoutMillis: number
+ /** Processor deadline for one batch export. */
+ exportTimeoutMillis: number
+ /** Outer shutdown wait; pending exports may be lost after this deadline. */
+ shutdownTimeoutMillis: number
+}
+```
+
+来源： [`packages/host/product-telemetry-otel/src/index.ts:35`](../packages/host/product-telemetry-otel/src/index.ts)
+
## `@deepseek-ai/dsh-ptc-runtime-node`
diff --git a/docs/module-graph.i18n.yaml b/docs/module-graph.i18n.yaml
index 9574d6c46b..a11b820d77 100644
--- a/docs/module-graph.i18n.yaml
+++ b/docs/module-graph.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/module-graph.md
-module-graph.md: 8511f674c84bcfa11fb9e2b137b12025ec540c3e
-module-graph.zh.md: 67ba8d7f6b2582200b8a2ecc2215f7b317880081
+module-graph.md: 8976efc78f5c6f10b27c7c20cd4b380821ce3d61
+module-graph.zh.md: d1f770ec1fdebfca93d7fb436d75bee8325633b2
diff --git a/docs/module-graph.md b/docs/module-graph.md
index 8511f674c8..8976efc78f 100644
--- a/docs/module-graph.md
+++ b/docs/module-graph.md
@@ -274,6 +274,7 @@ flowchart TD
pkg_host_open_in_app["host-open-in-app"]
pkg_host_plugin_inventory["host-plugin-inventory"]
pkg_host_webserver["host-webserver"]
+ pkg_product_telemetry_otel["product-telemetry-otel"]
end
subgraph group_identity["packages/identity"]
pkg_anonymous_user_id["anonymous-user-id"]
@@ -1419,6 +1420,7 @@ flowchart TD
| [`host-directory-picker-native`](../packages/host/directory-picker-native) | `host` | — |
| [`host-open-in-app`](../packages/host/open-in-app) | `host` | — |
| [`host-webserver`](../packages/host/webserver) | `host` | — |
+| [`product-telemetry-otel`](../packages/host/product-telemetry-otel) | `host` | — |
| [`invariants`](../packages/runtime-diagnostics/invariants) | `runtime-diagnostics` | — |
| [`session-format`](../packages/session/session-format) | `session` | — |
| [`session-format-v0-to-v1`](../packages/session/session-format-v0-to-v1) | `session` | — |
diff --git a/docs/module-graph.zh.md b/docs/module-graph.zh.md
index 67ba8d7f6b..d1f770ec1f 100644
--- a/docs/module-graph.zh.md
+++ b/docs/module-graph.zh.md
@@ -276,6 +276,7 @@ flowchart TD
pkg_host_open_in_app["host-open-in-app"]
pkg_host_plugin_inventory["host-plugin-inventory"]
pkg_host_webserver["host-webserver"]
+ pkg_product_telemetry_otel["product-telemetry-otel"]
end
subgraph group_identity["packages/identity"]
pkg_anonymous_user_id["anonymous-user-id"]
@@ -1421,6 +1422,7 @@ flowchart TD
| [`host-directory-picker-native`](../packages/host/directory-picker-native) | `host` | — |
| [`host-open-in-app`](../packages/host/open-in-app) | `host` | — |
| [`host-webserver`](../packages/host/webserver) | `host` | — |
+| [`product-telemetry-otel`](../packages/host/product-telemetry-otel) | `host` | — |
| [`invariants`](../packages/runtime-diagnostics/invariants) | `runtime-diagnostics` | — |
| [`session-format`](../packages/session/session-format) | `session` | — |
| [`session-format-v0-to-v1`](../packages/session/session-format-v0-to-v1) | `session` | — |
diff --git a/docs/subsystems/README.i18n.yaml b/docs/subsystems/README.i18n.yaml
index af12f99e97..49c88f8b26 100644
--- a/docs/subsystems/README.i18n.yaml
+++ b/docs/subsystems/README.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/subsystems/README.md
-README.md: db21e0fe6bea366c4d7efc1d96d247dd255f54da
-README.zh.md: 4b2b28dbf9a39da0c0ce3a062c4de3261501f7d9
+README.md: 7534586b4bd2686cd75da160fe044806afcff539
+README.zh.md: 1132d9a9e0c0bb945532020b314f87a08b84b933
diff --git a/docs/subsystems/README.md b/docs/subsystems/README.md
index db21e0fe6b..7534586b4b 100644
--- a/docs/subsystems/README.md
+++ b/docs/subsystems/README.md
@@ -6,6 +6,7 @@ One page per subsystem of the DeepSeek Harness: what it is, the data structures
| Page | Owns |
|---|---|
+| [product-telemetry.md](product-telemetry.md) | Explicit product analytics submission and OTLP/HTTP transport |
| [boot.md](boot.md) | Current-profile plugin management and launcher reload coordination |
| [core.md](core.md) | how `packages/core` controls the agent loop: the package-by-package loop description, agent creation and ownership (`AgentHandle`), the `Agent` handle's delivery/cancellation/interception contracts, and the repo-wide type patterns (`…Map → derived-union`, branded ids) |
| [llm-streaming.md](llm-streaming.md) | the `packages/llm` conversation types — `Message`/`ContentBlock`, the assembled model request, the `StreamChunk` wire protocol and adapter contract, `BlockAssembler`, and the `LlmAdapter` provider contract |
diff --git a/docs/subsystems/README.zh.md b/docs/subsystems/README.zh.md
index 4b2b28dbf9..1132d9a9e0 100644
--- a/docs/subsystems/README.zh.md
+++ b/docs/subsystems/README.zh.md
@@ -6,6 +6,7 @@
| 页面 | 负责内容 |
|---|---|
+| [product-telemetry.md](product-telemetry.zh.md) | 显式产品分析事件提交与 OTLP/HTTP 传输 |
| [boot.md](boot.zh.md) | 当前 profile 插件管理与 launcher 重载协调 |
| [core.md](core.zh.md) | `packages/core` 如何控制 agent loop（智能体循环）：逐包的循环说明、agent 创建与所有权（`AgentHandle`）、`Agent` 句柄的投递/取消/拦截约定，以及全仓通用类型模式（`…Map → derived-union`、品牌化 id） |
| [llm-streaming.md](llm-streaming.zh.md) | `packages/llm` 的对话类型——`Message`/`ContentBlock`、组装完成的模型请求、`StreamChunk` wire protocol 和适配器约定（adapter contract）、`BlockAssembler`，以及 `LlmAdapter` 提供方约定 |
diff --git a/docs/subsystems/product-telemetry.i18n.yaml b/docs/subsystems/product-telemetry.i18n.yaml
new file mode 100644
index 0000000000..326d675316
--- /dev/null
+++ b/docs/subsystems/product-telemetry.i18n.yaml
@@ -0,0 +1,6 @@
+# Bilingual-pair consistency record (docs/i18n/README.md): the git blob hash of each
+# side as of the last confirmed-consistent state. Both languages carry equal authority;
+# after editing either side, bring the other along and re-record with:
+# pnpm run verify-translation-pairing --write docs/subsystems/product-telemetry.md
+product-telemetry.md: b9abdfc3a781ce5dc6237c25f2f7e0b045776125
+product-telemetry.zh.md: de132fec7c7a2e394bb3ee7ab6e8d745c0912b66
diff --git a/docs/subsystems/product-telemetry.md b/docs/subsystems/product-telemetry.md
new file mode 100644
index 0000000000..b9abdfc3a7
--- /dev/null
+++ b/docs/subsystems/product-telemetry.md
@@ -0,0 +1,35 @@
+# Product telemetry
+
+English | [中文](product-telemetry.zh.md)
+
+The [product telemetry plugin](../../packages/host/product-telemetry-otel/README.md) sends explicitly selected analytics events through OTLP/HTTP. Its `productTelemetry` service owns submission only; product consumers own when an event occurs and which fields are approved. No Session data or identifiers are collected automatically.
+
+`ProductTelemetryRecord` requires an event name, string body, and Unix-millisecond timestamp. Attributes accept scalar strings, numbers, booleans, and one-level objects of those values (`ProductTelemetryScalar`). Optional severity uses OTel severity numbers and defaults to INFO. Observation time is assigned when the record is enqueued.
+
+Enqueue is synchronous and does not acknowledge delivery. The SDK owns batching and retry; local diagnostics report export failures. See the package README for configuration, shutdown, and loss limits.
+
+
+
+
+
+## Cordis API
+
+Generated from source by `scripts/gen-cordis-catalog.ts` (verified fresh by `pnpm run verify-cordis-catalog` in doc-sync; regenerate with `pnpm run gen-cordis-catalog`) — the language sides differ only in locale-specific paired document paths. Signature blocks use a `ts cordis-catalog` fence and keep the original source JSDoc; dispatch modes are defined in the [primer](../cordis-primer.md#dispatch-modes), and the framework-inherited `ctx` API lives in [cordis-api/inherited.md](../cordis-api/inherited.md).
+
+
+
+### `ctx.productTelemetry` — `ProductTelemetry`
+
+Host analytics sender. Mounting alone sends nothing; the owning fiber drains it on unload.
+
+```ts cordis-catalog
+/**
+ * Enqueue one selected product event without waiting for network delivery.
+ * Queue admission and shutdown completion are not collector or warehouse acknowledgements.
+ * @param record - caller-owned event containing only approved analytics fields.
+ */
+emit(record: ProductTelemetryRecord): void
+```
+
+Source: [`packages/host/product-telemetry-otel/src/index.ts`](../../packages/host/product-telemetry-otel/src/index.ts)
+
diff --git a/docs/subsystems/product-telemetry.zh.md b/docs/subsystems/product-telemetry.zh.md
new file mode 100644
index 0000000000..de132fec7c
--- /dev/null
+++ b/docs/subsystems/product-telemetry.zh.md
@@ -0,0 +1,35 @@
+# 产品埋点
+
+[English](product-telemetry.md) | 中文
+
+[产品埋点插件](../../packages/host/product-telemetry-otel/README.zh.md) 通过 OTLP/HTTP 发送明确选定的分析事件。`productTelemetry` 服务仅负责提交；产品消费方决定事件发生时机与获准采集的字段。不自动采集 Session 数据或标识。
+
+`ProductTelemetryRecord` 要求事件名称、字符串 body 和 Unix 毫秒时间戳。属性接受字符串、数字、布尔标量，以及这些值组成的单层对象（`ProductTelemetryScalar`）。可选的严重程度使用 OTel 严重程度数字，默认为 INFO。记录入队时填写观测时间。
+
+入队同步完成，不代表送达确认。SDK 负责批量发送与重试；发送失败会产生本地诊断。配置、退出和丢失限制见包 README。
+
+
+
+
+
+## Cordis API
+
+Generated from source by `scripts/gen-cordis-catalog.ts` (verified fresh by `pnpm run verify-cordis-catalog` in doc-sync; regenerate with `pnpm run gen-cordis-catalog`) — the language sides differ only in locale-specific paired document paths. Signature blocks use a `ts cordis-catalog` fence and keep the original source JSDoc; dispatch modes are defined in the [primer](../cordis-primer.zh.md#dispatch-modes), and the framework-inherited `ctx` API lives in [cordis-api/inherited.md](../cordis-api/inherited.md).
+
+
+
+### `ctx.productTelemetry` — `ProductTelemetry`
+
+Host analytics sender. Mounting alone sends nothing; the owning fiber drains it on unload.
+
+```ts cordis-catalog
+/**
+ * Enqueue one selected product event without waiting for network delivery.
+ * Queue admission and shutdown completion are not collector or warehouse acknowledgements.
+ * @param record - caller-owned event containing only approved analytics fields.
+ */
+emit(record: ProductTelemetryRecord): void
+```
+
+Source: [`packages/host/product-telemetry-otel/src/index.ts`](../../packages/host/product-telemetry-otel/src/index.ts)
+
diff --git a/packages/extensions/tool-cordis/src/api-catalog.ts b/packages/extensions/tool-cordis/src/api-catalog.ts
index 7d2f58ff7a..b7b2cdaac1 100644
--- a/packages/extensions/tool-cordis/src/api-catalog.ts
+++ b/packages/extensions/tool-cordis/src/api-catalog.ts
@@ -1596,6 +1596,18 @@ export const SERVICE_API: readonly ServiceApiEntry[] = [
},
],
},
+ {
+ key: 'productTelemetry',
+ summary: 'Host analytics sender.',
+ description: 'Host analytics sender. Mounting alone sends nothing; the owning fiber drains it on unload.',
+ methods: [
+ {
+ signature: 'emit(record: ProductTelemetryRecord): void',
+ description: 'Enqueue one selected product event without waiting for network delivery. Queue admission and shutdown completion are not collector or warehouse acknowledgements.',
+ parameters: [{ name: 'record', description: 'caller-owned event containing only approved analytics fields.' }],
+ },
+ ],
+ },
{
key: 'profileContext',
summary: 'Current profile facts; scheduling and mutation belong to their callers.',
@@ -5634,6 +5646,14 @@ export const TYPE_API: readonly TypeApiEntry[] = [
name: 'PreToolDecision',
declaration: 'export type PreToolDecision = {\n kind: \'allow\';\n} | {\n kind: \'deny\';\n reason: string;\n info?: ToolErrorInfo;\n} | {\n kind: \'cancel\';\n} | {\n kind: \'ask\';\n reason?: string;\n};',
},
+ {
+ name: 'ProductTelemetryRecord',
+ declaration: 'export interface ProductTelemetryRecord {\n eventName: string;\n body: string;\n timestamp: number;\n severityNumber?: SeverityNumber;\n attributes?: Record>;\n}',
+ },
+ {
+ name: 'ProductTelemetryScalar',
+ declaration: 'export type ProductTelemetryScalar = string | number | boolean;',
+ },
{
name: 'ProfilePnpmInvocation',
declaration: 'export interface ProfilePnpmInvocation {\n readonly command: string;\n readonly args: readonly string[];\n readonly env: Readonly>;\n}',
diff --git a/packages/host/README.i18n.yaml b/packages/host/README.i18n.yaml
index 0c7ec8a7e2..2bf03c1e34 100644
--- a/packages/host/README.i18n.yaml
+++ b/packages/host/README.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write packages/host/README.md
-README.md: 0b595eb7e63f33ed8e11ec0f39438f5d79b6ab33
-README.zh.md: 6a7507b7d8d2b2d791952783235a80280c8c0408
+README.md: 4de7a5fdd00be392d19a58f4bc424fce53c5e112
+README.zh.md: 80b74e0647c810b900f671d7d1256ab0d46107a9
diff --git a/packages/host/README.md b/packages/host/README.md
index 0b595eb7e6..4de7a5fdd0 100644
--- a/packages/host/README.md
+++ b/packages/host/README.md
@@ -9,7 +9,7 @@ English | [中文](README.zh.md)
## Summary
-The `host/` group provides the web GUI's plain HTTP server, the SPA dist server that serves the built Web shell, the workspace-directory picking seam with its native, browse, and adaptive composition packages, the open-in-app application probe and launch routes, and the read-only plugin inventory projection. All eight packages are product packages; the browser transport lives in [`client/`](../client/README.md), and the composed application is [`apps/cli`](../../apps/cli/README.md) booting the [`dsh-base` bundle](../bundle/base/cordis.patch.yml) that serves the web app under `apps/web/`. The picker backends replace one another behind the shared seam.
+The `host/` group provides the web GUI's plain HTTP server, the SPA dist server that serves the built Web shell, the workspace-directory picking seam with its native, browse, and adaptive composition packages, the open-in-app application probe and launch routes, and the read-only plugin inventory projection. These packages are product packages; the browser transport lives in [`client/`](../client/README.md), and the composed application is [`apps/cli`](../../apps/cli/README.md) booting the [`dsh-base` bundle](../bundle/base/cordis.patch.yml) that serves the web app under `apps/web/`. The picker backends replace one another behind the shared seam.
## Table of Contents
@@ -22,7 +22,7 @@ The `host/` group provides the web GUI's plain HTTP server, the SPA dist server
## Packages
-Eight packages play the host roles; each package README owns its contract and configuration.
+The packages play the host roles; each package README owns its contract and configuration.
| Package | Role | ctx key |
|---|---|---|
@@ -34,6 +34,7 @@ Eight packages play the host roles; each package README owns its contract and co
| [`directory-picker-auto/`](directory-picker-auto/README.md) | Host-adaptive chooser that mounts the matching backend at boot | mounts a backend |
| [`open-in-app/`](open-in-app/README.md) | Application probe, icon, and launch routes opening the workspace directory in an installed application | consumes `ctx.webServer` |
| [`plugin-inventory/`](plugin-inventory/README.md) | Read-only projection of current Loader entries | Remote `pluginInventory/list` |
+| [`product-telemetry-otel/`](product-telemetry-otel/README.md) | Explicit product usage events over OTLP/HTTP | `ctx.productTelemetry` |
-----
@@ -46,6 +47,8 @@ Start with the subsystem references for the transport and the workspace records,
- [Workspace subsystem](../../docs/subsystems/workspace.md) — the workspace records the directory picker feeds.
- [Web config-tree boot and transport layering](../../.agents/notes/implemented/architecture/2026-07-24-web-config-tree-boot-and-transport-layering.md) — ownership of the Web transport layers.
+- [Product telemetry](../../docs/subsystems/product-telemetry.md) — explicit analytics event submission.
+
## Dev Note
diff --git a/packages/host/README.zh.md b/packages/host/README.zh.md
index 6a7507b7d8..80b74e0647 100644
--- a/packages/host/README.zh.md
+++ b/packages/host/README.zh.md
@@ -9,7 +9,7 @@ kind: "package-group"
## 概述
-`host/` 组提供 Web GUI 的普通 HTTP 服务器、服务已构建 Web 壳的 SPA dist 服务器、带原生／浏览／自适应组合包的工作区目录选择 seam、open-in-app 的应用探测与启动路由，以及只读的插件清单投影。这八个包都是产品包；浏览器传输位于 [`client/`](../client/README.zh.md)，组合应用是 [`apps/cli`](../../apps/cli/README.zh.md)，它启动 [`dsh-base` 组合包](../bundle/base/cordis.patch.yml) 来提供 `apps/web/` 下的 Web 应用。选择器后端可在共享 seam 后互相替换。
+`host/` 组提供 Web GUI 的普通 HTTP 服务器、服务已构建 Web 壳的 SPA dist 服务器、带原生／浏览／自适应组合包的工作区目录选择 seam、open-in-app 的应用探测与启动路由，以及只读的插件清单投影。这些包都是产品包；浏览器传输位于 [`client/`](../client/README.zh.md)，组合应用是 [`apps/cli`](../../apps/cli/README.zh.md)，它启动 [`dsh-base` 组合包](../bundle/base/cordis.patch.yml) 来提供 `apps/web/` 下的 Web 应用。选择器后端可在共享 seam 后互相替换。
## 目录
@@ -22,7 +22,7 @@ kind: "package-group"
## 包
-八个包分别承担 Host 角色；各包的 README 拥有自己的约定与配置。
+各包分别承担 Host 角色；各包的 README 拥有自己的约定与配置。
| 包 | 职责 | ctx 键 |
|---|---|---|
@@ -34,6 +34,7 @@ kind: "package-group"
| [`directory-picker-auto/`](directory-picker-auto/README.zh.md) | 在启动时挂载匹配后端的宿主自适应选择器 | 挂载一个后端 |
| [`open-in-app/`](open-in-app/README.zh.md) | 在已安装应用中打开 workspace 目录的应用探测、图标与启动路由 | 消费 `ctx.webServer` |
| [`plugin-inventory/`](plugin-inventory/README.zh.md) | 当前 Loader 条目的只读投影 | Remote `pluginInventory/list` |
+| [`product-telemetry-otel/`](product-telemetry-otel/README.zh.md) | 通过 OTLP/HTTP 显式上报产品使用事件 | `ctx.productTelemetry` |
-----
@@ -46,6 +47,8 @@ kind: "package-group"
- [工作区子系统](../../docs/subsystems/workspace.zh.md)——目录选择器所喂给的工作区记录。
- [Web 配置树启动与传输分层](../../.agents/notes/implemented/architecture/2026-07-24-web-config-tree-boot-and-transport-layering.zh.md)——Web 传输各层的所有权。
+- [产品埋点](../../docs/subsystems/product-telemetry.zh.md)——显式提交分析事件。
+
## 开发备注
diff --git a/packages/host/product-telemetry-otel/README.i18n.yaml b/packages/host/product-telemetry-otel/README.i18n.yaml
new file mode 100644
index 0000000000..823dcfa244
--- /dev/null
+++ b/packages/host/product-telemetry-otel/README.i18n.yaml
@@ -0,0 +1,6 @@
+# Bilingual-pair consistency record (docs/i18n/README.md): the git blob hash of each
+# side as of the last confirmed-consistent state. Both languages carry equal authority;
+# after editing either side, bring the other along and re-record with:
+# pnpm run verify-translation-pairing --write packages/host/product-telemetry-otel/README.md
+README.md: 4ce0a8744b46391b8dbe3d7d6739f0e0e1d118c5
+README.zh.md: 34075efae80c2e5275fbb782c485bea1b2661745
diff --git a/packages/host/product-telemetry-otel/README.md b/packages/host/product-telemetry-otel/README.md
new file mode 100644
index 0000000000..4ce0a8744b
--- /dev/null
+++ b/packages/host/product-telemetry-otel/README.md
@@ -0,0 +1,104 @@
+---
+description: "Configure explicit product usage events, OTLP/HTTP routing, batching, and shutdown limits."
+kind: "package-reference"
+---
+
+# @deepseek-ai/dsh-product-telemetry-otel
+
+English | [中文](README.zh.md)
+
+## Summary
+
+Send selected product usage events to an OTLP/HTTP collector. Events carry a name, string summary, occurrence time, and scalar or one-level object attributes. Mounting the plugin collects nothing automatically; applications explicitly submit each event. Delivery is best effort and does not confirm warehouse ingestion.
+
+## Table of Contents
+
+- [Use this package](#use-this-package)
+- [Understand the implementation](#understand-the-implementation)
+- [Further Exploration](#further-exploration)
+- [Model Experience](#model-experience)
+- [Known Limitations and Deferred Work](#known-limitations-and-deferred-work)
+- [Dev Note](#dev-note)
+
+-----
+
+
+## Use this package
+
+Mount the plugin in a Cordis composition with the application identity; override the collector endpoint when needed. The shipped profiles do not mount it.
+
+```yaml
+- name: '@deepseek-ai/dsh-product-telemetry-otel'
+ config:
+ endpoint: https://dsh-otel-collector.deepseeksvc.com/v1/logs
+ serviceName: dsh-telemetry-test
+ serviceVersion: test
+ compression: gzip
+ scheduledDelayMillis: 30000
+```
+
+| Field | Default | Meaning |
+|---|---|---|
+| `endpoint` | `https://dsh-otel-collector.deepseeksvc.com/v1/logs` | Full HTTP(S) logs URL |
+| `serviceName`, `serviceVersion` | required | Application identity on the OTel resource |
+| `channel` | `dsh_otel_report` | Collector `x-channel` header |
+| `compression` | SDK environment | `gzip` or `none`; omission honors OTel compression environment variables |
+| `maxExportBatchSize`, `maxQueueSize` | `512`, `2048` | Record-count limits; batch size cannot exceed queue size |
+| `scheduledDelayMillis` | `30000` | Partial-batch export interval |
+| `timeoutMillis` | `15000` | Exporter HTTP and retry deadline |
+| `exportTimeoutMillis` | `20000` | Processor batch export deadline |
+| `shutdownTimeoutMillis` | `21000` | Outer wait for shutdown; expiry reports possible loss |
+
+Consumers inject `productTelemetry` and call `emit()` with explicitly selected analytics fields. Event names and field semantics belong to their product and analytics owners. The plugin reads no Session, account, credential, or device identifier. Callers must exclude prompts, responses, file contents, credentials, and other unapproved values.
+
+The collector expects a string body and attributes containing strings, numbers, booleans, or objects of those scalars. Callers supply occurrence time in milliseconds; the plugin assigns observation time and defaults severity to INFO. Invalid transport configuration fails at activation. Export failures produce local warnings without making event submission wait for the network.
+
+-----
+
+
+## Understand the implementation
+
+
+Implementation internals — click to expand
+
+A private OTel logger feeds `BatchLogRecordProcessor` and the HTTP JSON exporter. The SDK owns queueing, transient-error retries, and compression; plugin disposal drains pending records with a bounded wait. Export completion is observed separately because SDK shutdown can resolve after a rejected export. No global OTel provider is installed.
+
+[`src/index.ts`](src/index.ts) owns configuration and submission. No runtime invariant companion is published: delivery has no independent local acknowledgement to compare with the SDK's queue.
+
+
+
+-----
+
+
+## Further Exploration
+
+- [Product telemetry](../../../docs/subsystems/product-telemetry.md) — consumer types and service reference.
+- [Session telemetry](../../session/session-telemetry-otel/README.md) — separate feedback-authorized Session reporting.
+- [Testing policy](../../../docs/testing.md) — Loader composition and network fixtures.
+
+-----
+
+
+## Model Experience
+
+None, as the plugin exports explicit analytics records without contributing model context.
+
+#### KV Cache effect
+
+None; event submission does not change model requests.
+
+## Known Limitations and Deferred Work
+
+
+
+Delivery and collection remain limited to the following capabilities.
+
+- No business events, renderer transport, or account/device identity are wired automatically.
+- The queue is memory-only; overflow, network failure, and process exit can lose events. There is no durable outbox or warehouse acknowledgement.
+- The SDK batches by record count, not encoded bytes. Callers must keep records within the collector's 4 MB limit and choose batch sizes appropriate to the receiver.
+- Caller-selected strings are not redacted automatically. This package does not decide product disclosure or consent policy.
+
+
+### Dev Note
+
+None.
diff --git a/packages/host/product-telemetry-otel/README.zh.md b/packages/host/product-telemetry-otel/README.zh.md
new file mode 100644
index 0000000000..34075efae8
--- /dev/null
+++ b/packages/host/product-telemetry-otel/README.zh.md
@@ -0,0 +1,104 @@
+---
+description: "配置显式产品使用事件、OTLP/HTTP 路由、批量发送与退出等待上限。"
+kind: "package-reference"
+---
+
+# @deepseek-ai/dsh-product-telemetry-otel
+
+[English](README.md) | 中文
+
+## 概述
+
+将选定的产品使用事件发送到 OTLP/HTTP 接收服务。事件包含名称、字符串摘要、发生时间，以及标量或单层对象属性。挂载插件不会自动采集信息；应用需要显式提交每个事件。发送采用尽力而为方式，不代表数据已入仓。
+
+## 目录
+
+- [使用本包](#use-this-package)
+- [理解实现](#understand-the-implementation)
+- [延伸阅读](#further-exploration)
+- [模型体验](#model-experience)
+- [已知限制与待办工作](#known-limitations-and-deferred-work)
+- [开发备注](#dev-note)
+
+-----
+
+
+## 使用本包
+
+在 Cordis 组合中挂载插件并提供应用标识；需要时可覆盖接收地址。内置 profile 不挂载本插件。
+
+```yaml
+- name: '@deepseek-ai/dsh-product-telemetry-otel'
+ config:
+ endpoint: https://dsh-otel-collector.deepseeksvc.com/v1/logs
+ serviceName: dsh-telemetry-test
+ serviceVersion: test
+ compression: gzip
+ scheduledDelayMillis: 30000
+```
+
+| 字段 | 默认值 | 含义 |
+|---|---|---|
+| `endpoint` | `https://dsh-otel-collector.deepseeksvc.com/v1/logs` | 完整 HTTP(S) 日志地址 |
+| `serviceName`, `serviceVersion` | 必填 | OTel resource 中的应用标识 |
+| `channel` | `dsh_otel_report` | 接收服务的 `x-channel` 请求头 |
+| `compression` | SDK 环境变量 | `gzip` 或 `none`；省略时遵循 OTel 压缩环境变量 |
+| `maxExportBatchSize`, `maxQueueSize` | `512`, `2048` | 记录条数上限；批次大小不能超过队列大小 |
+| `scheduledDelayMillis` | `30000` | 不满批次时的发送间隔 |
+| `timeoutMillis` | `15000` | Exporter HTTP 发送与重试的超时时间 |
+| `exportTimeoutMillis` | `20000` | Processor 批次导出的超时时间 |
+| `shutdownTimeoutMillis` | `21000` | 退出时的等待上限；超时会提示可能丢失数据 |
+
+消费方注入 `productTelemetry`，调用 `emit()` 提交明确选定的分析字段。事件名称与字段含义由产品和数据分析负责人定义。插件不读取 Session、账号、凭证或设备标识。调用方必须排除提示词、回答、文件内容、凭证及其他未经批准的数据。
+
+接收服务要求 body 为字符串，attributes 的值为字符串、数字、布尔值或由这些标量组成的对象。调用方以毫秒提供发生时间；插件填写观测时间，默认严重程度为 INFO。无效传输配置在激活时报错。发送失败产生本地警告，事件提交不等待网络。
+
+-----
+
+
+## 理解实现
+
+
+实现细节——点击展开
+
+私有 OTel logger 将记录交给 `BatchLogRecordProcessor` 和 HTTP JSON exporter。SDK 负责队列、临时错误重试与压缩；插件卸载时在限定时间内发送剩余记录。发送完成结果单独观测，因为 SDK 在发送被拒绝后仍可能正常完成退出。不安装全局 OTel provider。
+
+[`src/index.ts`](src/index.ts) 负责配置与提交。不发布运行时不变量伴随模块：本地没有独立的送达确认可与 SDK 队列比较。
+
+
+
+-----
+
+
+## 延伸阅读
+
+- [产品埋点](../../../docs/subsystems/product-telemetry.zh.md)——消费方类型与服务参考。
+- [会话上报](../../session/session-telemetry-otel/README.zh.md)——独立的、由反馈授权的 Session 上报。
+- [测试策略](../../../docs/testing.zh.md)——Loader 组合与网络测试夹具。
+
+-----
+
+
+## 模型体验
+
+无，因为插件仅发送显式分析记录，不提供模型上下文。
+
+#### KV Cache 影响
+
+无；提交事件不会改变模型请求。
+
+## 已知限制与待办工作
+
+
+
+发送和采集受以下能力限制。
+
+- 不自动接入业务事件、渲染进程传输或账号与设备标识。
+- 队列仅存在于内存；队列溢出、网络故障和进程退出可能丢失事件。没有持久发件箱或入仓确认。
+- SDK 按记录条数而非编码字节数分批。调用方必须确保记录不超过接收服务的 4 MB 限制，并选择接收服务适用的批次大小。
+- 不自动脱敏调用方选择的字符串。本包不决定产品告知或同意策略。
+
+
+### 开发备注
+
+无。
diff --git a/packages/host/product-telemetry-otel/package.json b/packages/host/product-telemetry-otel/package.json
new file mode 100644
index 0000000000..24dff2ab6a
--- /dev/null
+++ b/packages/host/product-telemetry-otel/package.json
@@ -0,0 +1,47 @@
+{
+ "name": "@deepseek-ai/dsh-product-telemetry-otel",
+ "description": "Explicit product usage events exported through OpenTelemetry HTTP logs",
+ "version": "0.1.6-alpha.2",
+ "publishConfig": {
+ "access": "public"
+ },
+ "repository": {
+ "type": "git",
+ "url": "git+https://github.com/deepseek-ai/deepseek-harness.git",
+ "directory": "packages/host/product-telemetry-otel"
+ },
+ "type": "module",
+ "main": "lib/index.js",
+ "types": "lib/types/index.d.ts",
+ "exports": {
+ ".": {
+ "types": "./lib/types/index.d.ts",
+ "default": "./lib/index.js"
+ },
+ "./src/*": "./src/*",
+ "./package.json": "./package.json"
+ },
+ "files": [
+ "lib/index.js",
+ "lib/types/**/*.d.ts"
+ ],
+ "license": "MIT",
+ "dependencies": {
+ "@opentelemetry/api-logs": "^0.220.0",
+ "@opentelemetry/exporter-logs-otlp-http": "^0.220.0",
+ "@opentelemetry/otlp-exporter-base": "^0.220.0",
+ "@opentelemetry/resources": "^2.9.0",
+ "@opentelemetry/sdk-logs": "^0.220.0",
+ "@deepseek-ai/schemastery": "workspace:^",
+ "@opentelemetry/core": "2.9.0"
+ },
+ "peerDependencies": {
+ "@deepseek-ai/cordis": "workspace:^"
+ },
+ "devDependencies": {
+ "@deepseek-ai/cordis": "workspace:^",
+ "@deepseek-ai/cordis-plugin-loader": "workspace:^",
+ "@deepseek-ai/dsh-app-boot": "workspace:^",
+ "@deepseek-ai/dsh-loader-smoke": "workspace:^"
+ }
+}
diff --git a/packages/host/product-telemetry-otel/src/index.ts b/packages/host/product-telemetry-otel/src/index.ts
new file mode 100644
index 0000000000..b617702172
--- /dev/null
+++ b/packages/host/product-telemetry-otel/src/index.ts
@@ -0,0 +1,154 @@
+/** Explicit product usage events over OTLP/HTTP; no automatic collection or Session access. */
+import { Context, Service } from '@deepseek-ai/cordis'
+import z from '@deepseek-ai/schemastery'
+import { SeverityNumber, type Logger } from '@opentelemetry/api-logs'
+import { OTLPLogExporter } from '@opentelemetry/exporter-logs-otlp-http'
+import { CompressionAlgorithm } from '@opentelemetry/otlp-exporter-base'
+import { ExportResultCode } from '@opentelemetry/core'
+import { resourceFromAttributes } from '@opentelemetry/resources'
+import { BatchLogRecordProcessor, LoggerProvider } from '@opentelemetry/sdk-logs'
+
+declare module '@deepseek-ai/cordis' {
+ interface Context {
+ productTelemetry: ProductTelemetry
+ }
+}
+
+/** Scalar values accepted by the collector's Arrow attributes map. */
+export type ProductTelemetryScalar = string | number | boolean
+
+/** Explicitly selected analytics fields; object values may contain scalars only. */
+export interface ProductTelemetryRecord {
+ /** Product/DA-owned event name. */
+ eventName: string
+ /** Human-readable summary; never a prompt, response, credential, or file contents. */
+ body: string
+ /** Event occurrence time in Unix milliseconds. Observation time is assigned on enqueue. */
+ timestamp: number
+ /** OTel severity; omitted values use INFO. */
+ severityNumber?: SeverityNumber
+ /** Business fields selected by the caller; no automatic device or account identity. */
+ attributes?: Record>
+}
+
+/** Collector routing, application identity, and bounded in-memory batch settings. */
+export interface Config {
+ /** Full HTTP(S) logs URL. */
+ endpoint: string
+ /** Collector routing header. */
+ channel: string
+ /** Resource service.name supplied by the application composition. */
+ serviceName: string
+ /** Resource service.version supplied by the application composition. */
+ serviceVersion: string
+ /** Omit to honor OTEL_EXPORTER_OTLP_LOGS_COMPRESSION / OTEL_EXPORTER_OTLP_COMPRESSION. */
+ compression?: 'none' | 'gzip'
+ /** Maximum records per export; must not exceed maxQueueSize. */
+ maxExportBatchSize: number
+ /** Maximum queued records; the SDK drops new records when full. */
+ maxQueueSize: number
+ /** Delay before exporting a partial batch. */
+ scheduledDelayMillis: number
+ /** Exporter HTTP deadline, including SDK transient-error retries. */
+ timeoutMillis: number
+ /** Processor deadline for one batch export. */
+ exportTimeoutMillis: number
+ /** Outer shutdown wait; pending exports may be lost after this deadline. */
+ shutdownTimeoutMillis: number
+}
+
+const positiveInteger = () => z.number().step(1).min(1).max(2_147_483_647)
+
+/** Loader validation; the same schema resolves defaults for direct construction. */
+export const Config: z, Config> = z.object({
+ endpoint: z.string().default('https://dsh-otel-collector.deepseeksvc.com/v1/logs'),
+ channel: z.string().default('dsh_otel_report'),
+ serviceName: z.string().required(),
+ serviceVersion: z.string().required(),
+ compression: z.union(['none', 'gzip']),
+ maxExportBatchSize: positiveInteger().default(512),
+ maxQueueSize: positiveInteger().default(2048),
+ scheduledDelayMillis: positiveInteger().default(30000),
+ timeoutMillis: positiveInteger().default(15000),
+ exportTimeoutMillis: positiveInteger().default(20000),
+ shutdownTimeoutMillis: positiveInteger().default(21000),
+})
+
+/** Host analytics sender. Mounting alone sends nothing; the owning fiber drains it on unload. */
+export default class ProductTelemetry extends Service {
+ static Config = Config
+ private readonly logger: Logger
+
+ constructor(ctx: Context, input: Config) {
+ const config = Config(input)
+ const endpoint = new URL(config.endpoint)
+ if (!['http:', 'https:'].includes(endpoint.protocol)) {
+ throw new Error('product-telemetry-otel: endpoint must use HTTP or HTTPS')
+ }
+ if (config.maxExportBatchSize > config.maxQueueSize) {
+ throw new Error('product-telemetry-otel: maxExportBatchSize must not exceed maxQueueSize')
+ }
+ super(ctx, 'productTelemetry')
+ const exporter = new OTLPLogExporter({
+ url: config.endpoint,
+ headers: { 'x-channel': config.channel },
+ timeoutMillis: config.timeoutMillis,
+ ...(config.compression === undefined ? {} : {
+ compression: config.compression === 'gzip' ? CompressionAlgorithm.GZIP : CompressionAlgorithm.NONE,
+ }),
+ })
+ const provider = new LoggerProvider({
+ resource: resourceFromAttributes({
+ 'service.name': config.serviceName,
+ 'service.version': config.serviceVersion,
+ }),
+ processors: [new BatchLogRecordProcessor({
+ maxExportBatchSize: config.maxExportBatchSize,
+ maxQueueSize: config.maxQueueSize,
+ scheduledDelayMillis: config.scheduledDelayMillis,
+ exportTimeoutMillis: config.exportTimeoutMillis,
+ exporter: {
+ export: (records, callback) => {
+ exporter.export(records, (result) => {
+ // SDK flush/shutdown can resolve after export failure; observe the actual completion.
+ if (result.code !== ExportResultCode.SUCCESS) ctx.logger.warn('Product telemetry export failed')
+ callback(result)
+ })
+ },
+ forceFlush: () => exporter.forceFlush(),
+ shutdown: () => exporter.shutdown(),
+ },
+ })],
+ })
+ this.logger = provider.getLogger('@deepseek-ai/dsh-product-telemetry-otel')
+ ctx.effect(() => async () => {
+ let timer!: ReturnType
+ const deadline = new Promise((resolve) => {
+ timer = setTimeout(() => {
+ ctx.logger.warn('Product telemetry shutdown deadline exceeded; pending events may be lost')
+ resolve()
+ }, config.shutdownTimeoutMillis)
+ })
+ try {
+ await Promise.race([provider.shutdown(), deadline])
+ } finally {
+ clearTimeout(timer)
+ }
+ })
+ }
+
+ /**
+ * Enqueue one selected product event without waiting for network delivery.
+ * Queue admission and shutdown completion are not collector or warehouse acknowledgements.
+ * @param record - caller-owned event containing only approved analytics fields.
+ */
+ emit(record: ProductTelemetryRecord): void {
+ const severityNumber = record.severityNumber ?? SeverityNumber.INFO
+ this.logger.emit({
+ ...record,
+ observedTimestamp: Date.now(),
+ severityNumber,
+ severityText: SeverityNumber[severityNumber],
+ })
+ }
+}
diff --git a/packages/host/product-telemetry-otel/tests/fixtures/driver.ts b/packages/host/product-telemetry-otel/tests/fixtures/driver.ts
new file mode 100644
index 0000000000..4dfac67960
--- /dev/null
+++ b/packages/host/product-telemetry-otel/tests/fixtures/driver.ts
@@ -0,0 +1,42 @@
+/** Loader composition with a loopback collector and one explicit synthetic event. */
+import { createServer } from 'node:http'
+import { once } from 'node:events'
+import { gunzipSync } from 'node:zlib'
+import { writeFile } from 'node:fs/promises'
+import type {} from '@deepseek-ai/dsh-product-telemetry-otel'
+import { bootProductionProfile } from '../../../../test-support/loader-smoke/tests/fixtures/production-profile.ts'
+
+const configPath = process.argv[2]
+if (configPath === undefined) throw new Error('product telemetry fixture requires an overlay')
+const captures: unknown[] = []
+const server = createServer((req, res) => {
+ const chunks: Buffer[] = []
+ req.on('data', chunk => chunks.push(chunk as Buffer))
+ req.on('end', () => {
+ const bytes = Buffer.concat(chunks)
+ const body: unknown = JSON.parse(gunzipSync(bytes).toString())
+ captures.push({ channel: req.headers['x-channel'], compression: req.headers['content-encoding'], body })
+ res.writeHead(200, { 'content-type': 'application/json' }).end('{}')
+ })
+})
+try {
+ server.listen(0, '127.0.0.1')
+ await once(server, 'listening')
+ const address = server.address()
+ if (address === null || typeof address === 'string') throw new Error('collector has no port')
+ process.env.DSH_PRODUCT_TELEMETRY_TEST_ENDPOINT = `http://127.0.0.1:${address.port}/v1/logs`
+ const ctx = await bootProductionProfile({ binName: 'product-telemetry-test', profile: 'headless', overlayPaths: [configPath] })
+ try {
+ const telemetry = ctx.get('productTelemetry')
+ if (telemetry === undefined) throw new Error('product telemetry did not activate')
+ telemetry.emit({ eventName: 'telemetry.synthetic', timestamp: 1_800_000_000_000, body: 'Synthetic test', attributes: { synthetic: true } })
+ } finally {
+ await ctx.fiber.dispose()
+ }
+ await writeFile('captures.json', JSON.stringify(captures))
+} finally {
+ const closed = once(server, 'close')
+ server.close()
+ server.closeAllConnections()
+ await closed
+}
diff --git a/packages/host/product-telemetry-otel/tests/fixtures/telemetry.patch.yml b/packages/host/product-telemetry-otel/tests/fixtures/telemetry.patch.yml
new file mode 100644
index 0000000000..c876c3d646
--- /dev/null
+++ b/packages/host/product-telemetry-otel/tests/fixtures/telemetry.patch.yml
@@ -0,0 +1,15 @@
+- id: session-telemetry-otel
+ disabled: true
+- id: headless-startup
+ disabled: true
+- id: headless-runner
+ disabled: true
+- insert:
+ - id: product-telemetry-otel
+ name: '@deepseek-ai/dsh-product-telemetry-otel'
+ config:
+ endpoint: !!js process.env.DSH_PRODUCT_TELEMETRY_TEST_ENDPOINT
+ serviceName: dsh-telemetry-test
+ serviceVersion: test
+ compression: gzip
+ scheduledDelayMillis: 60000
diff --git a/packages/host/product-telemetry-otel/tests/loader-composition.e2e.ts b/packages/host/product-telemetry-otel/tests/loader-composition.e2e.ts
new file mode 100644
index 0000000000..13acb46e00
--- /dev/null
+++ b/packages/host/product-telemetry-otel/tests/loader-composition.e2e.ts
@@ -0,0 +1,23 @@
+import { readFile } from 'node:fs/promises'
+import { resolve } from 'node:path'
+import { expect, it } from 'vitest'
+import { runLoaderSmoke, LOADER_SMOKE_TEST_TIMEOUT_MS } from '@deepseek-ai/dsh-loader-smoke'
+
+it('exports the explicitly submitted event through the headless Loader composition', async () => {
+ let captures: unknown
+ const driver = resolve(import.meta.dirname, 'fixtures/driver.ts')
+ await runLoaderSmoke({
+ label: 'product telemetry composition',
+ tempDirPrefix: 'product-telemetry-',
+ binScript: driver,
+ libBinScript: driver,
+ configPath: resolve(import.meta.dirname, 'fixtures/telemetry.patch.yml'),
+ tsconfigPath: resolve(import.meta.dirname, '../../../../tsconfig.base.json'),
+ inspect: async (cwd) => { captures = JSON.parse(await readFile(resolve(cwd, 'captures.json'), 'utf8')) },
+ })
+ expect(captures).toMatchObject([{
+ channel: 'dsh_otel_report', compression: 'gzip',
+ body: { resourceLogs: [{ scopeLogs: [{ logRecords: [{ eventName: 'telemetry.synthetic', body: { stringValue: 'Synthetic test' } }] }] }] },
+ }])
+ expect(JSON.stringify(captures).match(/"eventName"/g)).toHaveLength(1)
+}, LOADER_SMOKE_TEST_TIMEOUT_MS)
diff --git a/packages/host/product-telemetry-otel/tests/telemetry.spec.ts b/packages/host/product-telemetry-otel/tests/telemetry.spec.ts
new file mode 100644
index 0000000000..424ec5917a
--- /dev/null
+++ b/packages/host/product-telemetry-otel/tests/telemetry.spec.ts
@@ -0,0 +1,157 @@
+import { createServer, type IncomingHttpHeaders } from 'node:http'
+import { once } from 'node:events'
+import { gunzipSync } from 'node:zlib'
+import { afterEach, describe, expect, it, vi } from 'vitest'
+import { Context } from '@deepseek-ai/cordis'
+import { LoggerProvider } from '@opentelemetry/sdk-logs'
+import { SeverityNumber } from '@opentelemetry/api-logs'
+import ProductTelemetry, { Config } from '../src/index.ts'
+
+interface Capture {
+ headers: IncomingHttpHeaders
+ body: { resourceLogs: { resource: unknown; scopeLogs: { logRecords: Record[] }[] }[] }
+}
+const cleanup: (() => Promise)[] = []
+afterEach(async () => {
+ try {
+ for (const dispose of cleanup.splice(0).reverse()) await dispose()
+ } finally {
+ vi.restoreAllMocks()
+ vi.useRealTimers()
+ }
+})
+
+async function collector(statuses = [200]) {
+ const captures: Capture[] = []
+ const server = createServer((req, res) => {
+ const chunks: Buffer[] = []
+ req.on('data', chunk => chunks.push(chunk as Buffer))
+ req.on('end', () => {
+ const raw = Buffer.concat(chunks)
+ const bytes = req.headers['content-encoding'] === 'gzip' ? gunzipSync(raw) : raw
+ captures.push({ headers: req.headers, body: JSON.parse(bytes.toString()) as Capture['body'] })
+ res.writeHead(statuses.shift() ?? 200, { 'content-type': 'application/json' }).end('{}')
+ })
+ })
+ cleanup.push(async () => {
+ const closed = once(server, 'close')
+ server.close()
+ server.closeAllConnections()
+ await closed
+ })
+ server.listen(0, '127.0.0.1')
+ await once(server, 'listening')
+ const address = server.address()
+ if (address === null || typeof address === 'string') throw new Error('collector has no port')
+ return { captures, endpoint: `http://127.0.0.1:${address.port}/v1/logs` }
+}
+
+function config(endpoint: string, overrides: Partial = {}): Config {
+ return Config({ endpoint, serviceName: 'synthetic-test', serviceVersion: '1', scheduledDelayMillis: 60_000, ...overrides })
+}
+
+function context() {
+ const ctx = new Context()
+ cleanup.push(() => ctx.fiber.dispose())
+ return ctx
+}
+
+const event = { eventName: 'telemetry.synthetic', body: 'Synthetic test', timestamp: 1_800_000_000_000 }
+
+describe('explicit product telemetry', () => {
+ it.each(['gzip', 'none', undefined] as const)('drains typed events with %s compression and removes the service', async (compression) => {
+ const target = await collector()
+ const ctx = context()
+ const fiber = await ctx.plugin(ProductTelemetry, config(target.endpoint, compression === undefined ? {} : { compression }))
+ const service = ctx.productTelemetry
+ expect(target.captures).toEqual([])
+ service.emit({ ...event, attributes: { text: 'test', count: 2, duration: 1.5, synthetic: true, model: { provider: 'test', count: 1, enabled: false } } })
+ service.emit({ ...event, severityNumber: SeverityNumber.ERROR })
+ await fiber.dispose()
+ expect(ctx.get('productTelemetry')).toBeUndefined()
+ service.emit(event)
+ expect(target.captures).toHaveLength(1)
+ const [capture] = target.captures
+ expect(capture?.headers['x-channel']).toBe('dsh_otel_report')
+ expect(capture?.headers['content-encoding']).toBe(compression === 'gzip' ? 'gzip' : undefined)
+ const logs = capture?.body.resourceLogs.flatMap(r => r.scopeLogs.flatMap(s => s.logRecords))
+ expect(logs).toHaveLength(2)
+ expect(logs?.[0]).toMatchObject({
+ eventName: event.eventName, body: { stringValue: event.body }, severityNumber: 9,
+ timeUnixNano: '1800000000000000000',
+ })
+ expect(logs?.[0]?.['attributes']).toEqual(expect.arrayContaining([
+ { key: 'text', value: { stringValue: 'test' } },
+ { key: 'count', value: { intValue: 2 } },
+ { key: 'duration', value: { doubleValue: 1.5 } },
+ { key: 'synthetic', value: { boolValue: true } },
+ { key: 'model', value: { kvlistValue: { values: [{ key: 'provider', value: { stringValue: 'test' } }, { key: 'count', value: { intValue: 1 } }, { key: 'enabled', value: { boolValue: false } }] } } },
+ ]))
+ expect(Number(logs?.[0]?.['observedTimeUnixNano'])).toBeGreaterThan(0)
+ expect(logs?.[1]?.['severityNumber']).toBe(17)
+ expect(JSON.stringify(capture)).not.toContain('user.id')
+ })
+
+ it('does not export on mount or empty shutdown', async () => {
+ const target = await collector()
+ const fiber = await context().plugin(ProductTelemetry, config(target.endpoint))
+ await fiber.dispose()
+ expect(target.captures).toEqual([])
+ })
+
+ it('exports at the batch threshold and retries a transient rejection', async () => {
+ const target = await collector([503, 200])
+ const ctx = context()
+ await ctx.plugin(ProductTelemetry, config(target.endpoint, { maxExportBatchSize: 1 }))
+ ctx.productTelemetry.emit(event)
+ await vi.waitFor(() => { expect(target.captures).toHaveLength(2) }, { timeout: 10_000 })
+ expect(target.captures[0]?.body).toEqual(target.captures[1]?.body)
+ })
+
+ it('exports a partial batch on its configured interval', async () => {
+ const target = await collector()
+ const ctx = context()
+ await ctx.plugin(ProductTelemetry, config(target.endpoint, { scheduledDelayMillis: 10 }))
+ ctx.productTelemetry.emit(event)
+ await vi.waitFor(() => { expect(target.captures).toHaveLength(1) })
+ })
+
+ it('reports a permanent export rejection without failing the caller', async () => {
+ const target = await collector([400])
+ const ctx = context()
+ const warn = vi.spyOn(ctx.logger, 'warn')
+ const fiber = await ctx.plugin(ProductTelemetry, config(target.endpoint))
+ expect(() => { ctx.productTelemetry.emit(event) }).not.toThrow()
+ await fiber.dispose()
+ expect(target.captures).toHaveLength(1)
+ expect(warn).toHaveBeenCalledWith('Product telemetry export failed')
+ })
+
+ it.each([
+ { endpoint: 'broken' }, { endpoint: 'ftp://collector.test/logs' },
+ { maxExportBatchSize: 0 }, { maxExportBatchSize: 2, maxQueueSize: 1 },
+ { maxQueueSize: -1 }, { scheduledDelayMillis: 0 }, { exportTimeoutMillis: Infinity },
+ { shutdownTimeoutMillis: 2_147_483_648 },
+ ])('rejects invalid configuration %j before exposing the service', (invalid) => {
+ const ctx = context()
+ expect(() => new ProductTelemetry(ctx, config('http://collector.test/v1/logs', invalid))).toThrow()
+ expect(ctx.get('productTelemetry')).toBeUndefined()
+ })
+
+ it('bounds a stalled shutdown and observes its later settlement', async () => {
+ const target = await collector()
+ const ctx = context()
+ const warn = vi.spyOn(ctx.logger, 'warn')
+ const fiber = await ctx.plugin(ProductTelemetry, config(target.endpoint, { shutdownTimeoutMillis: 20 }))
+ const pending = Promise.withResolvers()
+ vi.spyOn(LoggerProvider.prototype, 'shutdown').mockReturnValue(pending.promise)
+ vi.useFakeTimers()
+ const disposal = fiber.dispose()
+ await vi.advanceTimersByTimeAsync(20)
+ await disposal
+ expect(warn).toHaveBeenCalledWith('Product telemetry shutdown deadline exceeded; pending events may be lost')
+ pending.resolve(undefined)
+ await pending.promise
+ await vi.advanceTimersByTimeAsync(0)
+ })
+})
diff --git a/packages/host/product-telemetry-otel/tsconfig.json b/packages/host/product-telemetry-otel/tsconfig.json
new file mode 100644
index 0000000000..f0063ae28d
--- /dev/null
+++ b/packages/host/product-telemetry-otel/tsconfig.json
@@ -0,0 +1,21 @@
+{
+ "extends": "../../../tsconfig.base.json",
+ "compilerOptions": {
+ "rootDir": "src",
+ "outDir": "lib/types"
+ },
+ "include": [
+ "src"
+ ],
+ "references": [
+ {
+ "path": "../../../vendor/cosmokit"
+ },
+ {
+ "path": "../../../vendor/cordis"
+ },
+ {
+ "path": "../../../vendor/schemastery"
+ }
+ ]
+}
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
index eaec62559b..c90b706eec 100644
--- a/pnpm-lock.yaml
+++ b/pnpm-lock.yaml
@@ -8172,6 +8172,43 @@ importers:
specifier: workspace:^
version: link:../../typert/protocol
+ packages/host/product-telemetry-otel:
+ dependencies:
+ '@deepseek-ai/schemastery':
+ specifier: link:../../../vendor/schemastery
+ version: link:../../../vendor/schemastery
+ '@opentelemetry/api-logs':
+ specifier: ^0.220.0
+ version: 0.220.0
+ '@opentelemetry/core':
+ specifier: 2.9.0
+ version: 2.9.0(@opentelemetry/api@1.9.1)
+ '@opentelemetry/exporter-logs-otlp-http':
+ specifier: ^0.220.0
+ version: 0.220.0(@opentelemetry/api@1.9.1)
+ '@opentelemetry/otlp-exporter-base':
+ specifier: ^0.220.0
+ version: 0.220.0(@opentelemetry/api@1.9.1)
+ '@opentelemetry/resources':
+ specifier: ^2.9.0
+ version: 2.10.0(@opentelemetry/api@1.9.1)
+ '@opentelemetry/sdk-logs':
+ specifier: ^0.220.0
+ version: 0.220.0(@opentelemetry/api@1.9.1)
+ devDependencies:
+ '@deepseek-ai/cordis':
+ specifier: workspace:^
+ version: link:../../../vendor/cordis
+ '@deepseek-ai/cordis-plugin-loader':
+ specifier: workspace:^
+ version: link:../../../vendor/loader
+ '@deepseek-ai/dsh-app-boot':
+ specifier: workspace:^
+ version: link:../../boot/app-boot
+ '@deepseek-ai/dsh-loader-smoke':
+ specifier: workspace:^
+ version: link:../../test-support/loader-smoke
+
packages/host/webserver:
dependencies:
'@deepseek-ai/schemastery':
diff --git a/scripts/gen-cordis-catalog.ts b/scripts/gen-cordis-catalog.ts
index 3600155fcd..637a0c389f 100644
--- a/scripts/gen-cordis-catalog.ts
+++ b/scripts/gen-cordis-catalog.ts
@@ -56,6 +56,7 @@ export { REGION_BEGIN, REGION_END }
export const SERVICE_PAGE: Record = {
speechToText: 'voice-input.md',
speechController: 'voice-input.md',
+ productTelemetry: 'product-telemetry.md',
connection: 'web-server.md',
pluginManager: 'boot.md',
profileContext: 'boot.md',
@@ -266,6 +267,8 @@ export const EVENT_WALK_EXEMPTIONS: Record = {
* appear on more than one page.
*/
export const LINK_MAP: Readonly> = {
+ ProductTelemetryRecord: 'product-telemetry.md',
+ ProductTelemetryScalar: 'product-telemetry.md',
WorkspaceChangesSummary: 'deliverables.md',
WorkspaceFileDiff: 'deliverables.md',
Reload: 'boot.md',
diff --git a/scripts/gen-doc-graphs.ts b/scripts/gen-doc-graphs.ts
index 1c676c29d7..dd3d68126c 100644
--- a/scripts/gen-doc-graphs.ts
+++ b/scripts/gen-doc-graphs.ts
@@ -99,6 +99,13 @@ const GROUP_ORDER = [
]
const SERVICE_ROLES: ServiceRole[] = [
+ {
+ key: 'productTelemetry',
+ pkg: 'product-telemetry-otel',
+ title: 'Product usage event sender',
+ mode: 'core',
+ note: 'Exports explicitly submitted analytics events through OTLP/HTTP; mounting alone collects nothing.',
+ },
{
key: 'hmr',
pkg: 'hmr',
diff --git a/scripts/verify-package-readme-model-experience.ts b/scripts/verify-package-readme-model-experience.ts
index 5044b71f8b..c0d7106d42 100644
--- a/scripts/verify-package-readme-model-experience.ts
+++ b/scripts/verify-package-readme-model-experience.ts
@@ -49,6 +49,7 @@ const SENTENCE_MODEL_EXPERIENCE: Readonly> = {
'packages/experimental/speech-to-text-sensevoice': { kind: 'none', reason: 'Local recognition returns transient text without modifying model context.' },
'packages/experimental/client-ui-voice-input': { kind: 'none', reason: 'Inserts reviewable text into the unsent draft without submitting to the Agent.' },
'packages/experimental/voice-input-bundle': { kind: 'none', reason: 'Composes dictation and preparation plugins without adding any model-facing contribution.' },
+ 'packages/host/product-telemetry-otel': { kind: 'none', reason: 'The plugin exports explicit analytics records without contributing model context.' },
'packages/api/terminal-controller': { kind: 'none', reason: 'User-owned terminal processes and screen streams never enter model requests or Session events.' },
'packages/client/ui-sidebar-terminal': { kind: 'none', reason: 'The browser renders user terminal screens without exposing them to the model.' },
'packages/ssh/ssh': { kind: 'none', reason: 'The connection owner transports private provider operations; consumers own all model-facing content.' },
diff --git a/tsconfig.base.json b/tsconfig.base.json
index 6d331689a3..9709e7f5b9 100644
--- a/tsconfig.base.json
+++ b/tsconfig.base.json
@@ -396,6 +396,7 @@
"@deepseek-ai/dsh-plan-mode": ["./packages/plan/plan-mode/src"],
"@deepseek-ai/dsh-plan-mode/invariant": ["./packages/plan/plan-mode/src/invariant.ts"],
"@deepseek-ai/dsh-plugin-package-inventory-deepseek": ["./packages/llm/plugin-package-inventory-deepseek/src"],
+ "@deepseek-ai/dsh-product-telemetry-otel": ["./packages/host/product-telemetry-otel/src"],
"@deepseek-ai/dsh-ptc-runtime": ["./packages/ptc-runtime/ptc-runtime/src"],
"@deepseek-ai/dsh-ptc-runtime-node": ["./packages/ptc-runtime/ptc-runtime-node/src"],
"@deepseek-ai/dsh-pwsh-sandbox": ["./packages/shell/pwsh-sandbox/src"],
diff --git a/tsconfig.host.json b/tsconfig.host.json
index 0dd50f4d02..ef20adab36 100644
--- a/tsconfig.host.json
+++ b/tsconfig.host.json
@@ -177,6 +177,7 @@
{ "path": "./packages/experimental/api-speech-to-text" },
{ "path": "./packages/experimental/voice-input-bundle" },
+ { "path": "./packages/host/product-telemetry-otel" },
{ "path": "./packages/client/connection/tsconfig.host.json" },
{ "path": "./packages/skill/skill-office" },
{ "path": "./packages/skill/tool-workspace-dependencies" },
From 535cb4aae30cf276d32cb6ad051eb736aab98900 Mon Sep 17 00:00:00 2001
From: 07akioni <07akioni2@gmail.com>
Date: Mon, 21 Sep 2026 17:45:19 +0800
Subject: [PATCH 2/3] fix(telemetry): isolate collector transport and address
review
---
THIRD_PARTY_NOTICES.md | 1 +
docs/capability-seams.i18n.yaml | 4 +-
docs/capability-seams.md | 10 +--
docs/capability-seams.zh.md | 10 +--
docs/config-catalog.i18n.yaml | 4 +-
docs/config-catalog.md | 68 +++++++++----------
docs/config-catalog.zh.md | 68 +++++++++----------
docs/subsystems/README.i18n.yaml | 4 +-
docs/subsystems/README.md | 2 +-
docs/subsystems/README.zh.md | 2 +-
docs/subsystems/product-telemetry.i18n.yaml | 4 +-
docs/subsystems/product-telemetry.md | 25 +++++++
docs/subsystems/product-telemetry.zh.md | 25 +++++++
packages/README.i18n.yaml | 4 +-
packages/README.md | 2 +-
packages/README.zh.md | 2 +-
packages/host/README.i18n.yaml | 4 +-
packages/host/README.md | 5 +-
packages/host/README.zh.md | 5 +-
.../product-telemetry-otel/README.i18n.yaml | 4 +-
.../host/product-telemetry-otel/README.md | 18 +++--
.../host/product-telemetry-otel/README.zh.md | 18 +++--
.../host/product-telemetry-otel/package.json | 15 ++--
.../host/product-telemetry-otel/src/index.ts | 43 ++++++++----
.../tests/fixtures/driver.ts | 3 +-
.../tests/fixtures/telemetry.patch.yml | 4 +-
.../tests/telemetry.spec.ts | 50 +++++++++++++-
pnpm-lock.yaml | 7 +-
scripts/gen-doc-graphs.ts | 19 +++---
scripts/type-equiv.manifest.json | 10 +++
tsconfig.base.json | 2 +-
31 files changed, 289 insertions(+), 153 deletions(-)
diff --git a/THIRD_PARTY_NOTICES.md b/THIRD_PARTY_NOTICES.md
index e0e5b174eb..e44344f777 100644
--- a/THIRD_PARTY_NOTICES.md
+++ b/THIRD_PARTY_NOTICES.md
@@ -57,6 +57,7 @@ External packages installed for runtime use or distributed inside the prebuilt b
| [`@opentelemetry/core`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@opentelemetry/exporter-logs-otlp-http`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@opentelemetry/otlp-exporter-base`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
+| [`@opentelemetry/otlp-transformer`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@opentelemetry/resources`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@opentelemetry/sdk-logs`](https://github.com/open-telemetry/opentelemetry-js) | Apache-2.0 |
| [`@playwright/mcp`](https://github.com/microsoft/playwright-mcp) | Apache-2.0 |
diff --git a/docs/capability-seams.i18n.yaml b/docs/capability-seams.i18n.yaml
index 410b06d888..6a71bb9da7 100644
--- a/docs/capability-seams.i18n.yaml
+++ b/docs/capability-seams.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/capability-seams.md
-capability-seams.md: d9232c12528c274f48b85e725b944e565a5431de
-capability-seams.zh.md: 81e6aabc5351b9a0827fbd544e46d704688c9338
+capability-seams.md: 072cb47af420136a08ce182cfa341bb42fc068e0
+capability-seams.zh.md: 138fb3241a00cb2f6ab8853dd9cbf1440fe6d490
diff --git a/docs/capability-seams.md b/docs/capability-seams.md
index d9232c1252..072cb47af4 100644
--- a/docs/capability-seams.md
+++ b/docs/capability-seams.md
@@ -3,12 +3,10 @@
# Capability Seams And Core Services
-A service can be a core spine service, a swappable capability seam, or a bundle/composition point. The graph shows the package that owns the service declaration, known implementation packages, and packages that consume the service directly.
+A service can be a core spine service, a swappable capability seam, a bundle/composition point, or a standalone service. The graph shows the package that owns the service declaration, known implementation packages, and packages that consume the service directly.
```mermaid
flowchart LR
- pkg_product_telemetry_otel["product-telemetry-otel"]
- svc_productTelemetry["ctx.productTelemetry
Product usage event sender"]
pkg_hmr["hmr"]
svc_hmr["ctx.hmr
Serialized module and configuration reloads"]
pkg_app_boot["app-boot"]
@@ -106,6 +104,8 @@ flowchart LR
pkg_credentials_local["credentials-local"]
pkg_authorization["authorization"]
svc_authorization["ctx.authorization
Authorization flow registry"]
+ pkg_host_product_telemetry_otel["host-product-telemetry-otel"]
+ svc_productTelemetry["ctx.productTelemetry
Product usage event sender"]
pkg_session_telemetry["session-telemetry"]
svc_sessionTelemetry["ctx.sessionTelemetry
Session telemetry seam"]
pkg_session_telemetry_otel["session-telemetry-otel"]
@@ -320,6 +320,7 @@ flowchart LR
pkg_host_directory_picker --> svc_directoryPicker
pkg_host_directory_picker_browse --> svc_directoryPicker
pkg_host_directory_picker_native --> svc_directoryPicker
+ pkg_host_product_telemetry_otel --> svc_productTelemetry
pkg_host_webserver --> svc_webServer
pkg_inspector --> svc_inspector
pkg_invariants --> svc_invariants
@@ -339,7 +340,6 @@ flowchart LR
pkg_plan_mode --> svc_planMode
pkg_plugin_manager --> svc_pluginManager
pkg_plugin_package_inventory_deepseek --> svc_deepseekLlmApiExtensions
- pkg_product_telemetry_otel --> svc_productTelemetry
pkg_ptc_runtime --> svc_ptcRuntime
pkg_ptc_runtime_node --> svc_ptcRuntime
pkg_pwsh_local --> svc_shell
@@ -554,7 +554,6 @@ flowchart LR
| ctx key | Role | Owner | Implementations | Direct consumers | Companion plugins | Note |
| --- | --- | --- | --- | --- | --- | --- |
-| `ctx.productTelemetry` | `core` | [`product-telemetry-otel`](../packages/host/product-telemetry-otel) | - | - | - | Exports explicitly submitted analytics events through OTLP/HTTP; mounting alone collects nothing. |
| `ctx.hmr` | `core` | [`hmr`](../packages/boot/hmr) | - | [`app-boot`](../packages/boot/app-boot) | - | Owns module and exact configuration watchers; application mutations share its queue and automatic reloads await the application file lock. |
| `ctx.pluginManager` | `core` | [`plugin-manager`](../packages/boot/plugin-manager) | - | [`plugin-manager`](../packages/boot/plugin-manager), `ui-settings-plugin-inventory` | - | Shares profile package operations with the CLI and reports persisted and running state to Web and agent callers. |
| `ctx.profileContext` | `core` | [`app-boot`](../packages/boot/app-boot) | - | [`plugin-manager`](../packages/boot/plugin-manager) | - | The dsh launcher supplies data-only profile locations and composition inputs; reload scheduling belongs to dsh-hmr. |
@@ -590,6 +589,7 @@ flowchart LR
| `ctx.subagentModelSelection` | `core` | [`tool-subagent`](../packages/subagent/tool-subagent) | - | [`tool-subagent`](../packages/subagent/tool-subagent) | - | Owns the default-off settings namespace that Agent-scoped delegation tools sample when composing a new top-level Session. |
| `ctx.credentials` | `seam` | [`credentials`](../packages/credentials/credentials) | [`credentials-local`](../packages/credentials/credentials-local) | [`api-settings-controller`](../packages/api/settings-controller), [`llm-deepseek`](../packages/llm/llm-deepseek), [`llm-pi-ai`](../packages/llm/llm-pi-ai) | - | Configuration carries references to secrets; providers own the values. Consumers resolve per operation, so a rotated credential reaches the very next request; the settings controller exposes value-free views and write-only storage. |
| `ctx.authorization` | `seam` | [`authorization`](../packages/credentials/authorization) | - | [`llm-pi-ai`](../packages/llm/llm-pi-ai) | - | Flows are registered by the plugin that knows how to obtain one credential and keyed by the record they write; the seam owns the conversation and the one-attempt-per-key lifecycle, never the protocol. |
+| `ctx.productTelemetry` | `service` | [`host-product-telemetry-otel`](../packages/host/product-telemetry-otel) | - | - | - | Exports explicitly submitted analytics events through OTLP/HTTP; mounting alone collects nothing. |
| `ctx.sessionTelemetry` | `seam` | [`session-telemetry`](../packages/session/session-telemetry) | [`session-telemetry-otel`](../packages/session/session-telemetry-otel) | - | - | The seam captures, redacts, and hands session records to one backend; nothing else consumes the service — its output leaves the process. |
| `ctx.storage` | `seam` | [`storage`](../packages/storage/storage) | [`storage-json`](../packages/storage/storage-json), [`storage-sqlite`](../packages/storage/storage-sqlite) | [`storage-domain`](../packages/storage/storage-domain) | - | Backends register side by side under names; data forms (domain first) mount on the hub and translate typed operations into opaque KV-unit primitives. |
| `ctx.storageDomain` | `core` | [`storage-domain`](../packages/storage/storage-domain) | - | [`workspace`](../packages/workspace/workspace) | - | Waits for every configured backend, then publishes the domain form as one lifecycle-bound service for typed durable state. |
diff --git a/docs/capability-seams.zh.md b/docs/capability-seams.zh.md
index 81e6aabc53..138fb3241a 100644
--- a/docs/capability-seams.zh.md
+++ b/docs/capability-seams.zh.md
@@ -5,12 +5,10 @@
[English](capability-seams.md) | 中文
-服务可以是核心主干服务、可替换的能力 seam，也可以是组合包／组合点。下图展示了拥有服务声明的包、已知实现包，以及直接消费该服务的包。
+服务可以是核心主干服务、可替换的能力 seam、组合包／组合点或独立服务。下图展示了拥有服务声明的包、已知实现包，以及直接消费该服务的包。
```mermaid
flowchart LR
- pkg_product_telemetry_otel["product-telemetry-otel"]
- svc_productTelemetry["ctx.productTelemetry
Product usage event sender"]
pkg_hmr["hmr"]
svc_hmr["ctx.hmr
Serialized module and configuration reloads"]
pkg_app_boot["app-boot"]
@@ -108,6 +106,8 @@ flowchart LR
pkg_credentials_local["credentials-local"]
pkg_authorization["authorization"]
svc_authorization["ctx.authorization
Authorization flow registry"]
+ pkg_host_product_telemetry_otel["host-product-telemetry-otel"]
+ svc_productTelemetry["ctx.productTelemetry
Product usage event sender"]
pkg_session_telemetry["session-telemetry"]
svc_sessionTelemetry["ctx.sessionTelemetry
Session telemetry seam"]
pkg_session_telemetry_otel["session-telemetry-otel"]
@@ -322,6 +322,7 @@ flowchart LR
pkg_host_directory_picker --> svc_directoryPicker
pkg_host_directory_picker_browse --> svc_directoryPicker
pkg_host_directory_picker_native --> svc_directoryPicker
+ pkg_host_product_telemetry_otel --> svc_productTelemetry
pkg_host_webserver --> svc_webServer
pkg_inspector --> svc_inspector
pkg_invariants --> svc_invariants
@@ -341,7 +342,6 @@ flowchart LR
pkg_plan_mode --> svc_planMode
pkg_plugin_manager --> svc_pluginManager
pkg_plugin_package_inventory_deepseek --> svc_deepseekLlmApiExtensions
- pkg_product_telemetry_otel --> svc_productTelemetry
pkg_ptc_runtime --> svc_ptcRuntime
pkg_ptc_runtime_node --> svc_ptcRuntime
pkg_pwsh_local --> svc_shell
@@ -556,7 +556,6 @@ flowchart LR
| ctx 键 | 角色 | 所属包 | 实现 | 直接消费方 | 配套插件 | 说明 |
| --- | --- | --- | --- | --- | --- | --- |
-| `ctx.productTelemetry` | `core` | [`product-telemetry-otel`](../packages/host/product-telemetry-otel) | - | - | - | 通过 OTLP/HTTP 发送显式提交的分析事件；仅挂载插件不会采集信息。 |
| `ctx.hmr` | `core` | [`hmr`](../packages/boot/hmr) | - | [`app-boot`](../packages/boot/app-boot) | - | 负责模块和精确配置监听；应用修改共用其队列，自动重载等待应用文件锁。 |
| `ctx.pluginManager` | `core` | [`plugin-manager`](../packages/boot/plugin-manager) | - | [`plugin-manager`](../packages/boot/plugin-manager), `ui-settings-plugin-inventory` | - | 与 CLI 共享 profile 包操作，并向 Web 和 Agent 调用方分别报告持久状态与运行状态。 |
| `ctx.profileContext` | `core` | [`app-boot`](../packages/boot/app-boot) | - | [`plugin-manager`](../packages/boot/plugin-manager) | - | dsh launcher 提供纯数据形式的 profile 位置与组合输入；重载调度由 dsh-hmr 负责。 |
@@ -592,6 +591,7 @@ flowchart LR
| `ctx.subagentModelSelection` | `core` | [`tool-subagent`](../packages/subagent/tool-subagent) | - | [`tool-subagent`](../packages/subagent/tool-subagent) | - | 拥有默认关闭的设置命名空间；Agent 作用域的委派工具会在组合新顶层 Session 时读取它。 |
| `ctx.credentials` | `seam` | [`credentials`](../packages/credentials/credentials) | [`credentials-local`](../packages/credentials/credentials-local) | [`api-settings-controller`](../packages/api/settings-controller), [`llm-deepseek`](../packages/llm/llm-deepseek), [`llm-pi-ai`](../packages/llm/llm-pi-ai) | - | 配置携带对机密信息的引用；提供方拥有实际值。消费方按操作解析，因此轮换后的凭据会在紧接着的下一次请求中生效；settings controller 提供不含实际值的视图和只写存储。 |
| `ctx.authorization` | `seam` | [`authorization`](../packages/credentials/authorization) | - | [`llm-pi-ai`](../packages/llm/llm-pi-ai) | - | flow 由知道如何取得某份凭据的插件注册，并以其写入的记录为键；seam 拥有这段对话与"每个键同时只跑一次尝试"的生命周期，而非协议本身。 |
+| `ctx.productTelemetry` | `service` | [`host-product-telemetry-otel`](../packages/host/product-telemetry-otel) | - | - | - | 通过 OTLP/HTTP 发送显式提交的分析事件；仅挂载插件不会采集信息。 |
| `ctx.sessionTelemetry` | `seam` | [`session-telemetry`](../packages/session/session-telemetry) | [`session-telemetry-otel`](../packages/session/session-telemetry-otel) | - | - | 该 seam 捕获会话记录、进行脱敏并交给一个后端；没有其他组件消费该服务，其输出会离开当前进程。 |
| `ctx.storage` | `seam` | [`storage`](../packages/storage/storage) | [`storage-json`](../packages/storage/storage-json), [`storage-sqlite`](../packages/storage/storage-sqlite) | [`storage-domain`](../packages/storage/storage-domain) | - | 各后端以不同名称并列注册；数据形态（领域优先）挂载到枢纽上，并将类型化操作转换为不透明的 KV 单元原语。 |
| `ctx.storageDomain` | `core` | [`storage-domain`](../packages/storage/storage-domain) | - | [`workspace`](../packages/workspace/workspace) | - | 等待所有已配置后端就绪，然后将领域形态发布为一个受生命周期约束的服务，用于类型化持久状态。 |
diff --git a/docs/config-catalog.i18n.yaml b/docs/config-catalog.i18n.yaml
index de3cf15b46..4210a71a33 100644
--- a/docs/config-catalog.i18n.yaml
+++ b/docs/config-catalog.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/config-catalog.md
-config-catalog.md: 821605161613f620ca40e3a8733ee4a613fe3f95
-config-catalog.zh.md: ce811976fded14184f8edd5da5de8d70dbe71d24
+config-catalog.md: 2225721f4adf3e938da7fa74a3b1cb2b159b0ed4
+config-catalog.zh.md: 21e95ea2a3bbbcf3f4667dd3f26fc10e6f607d7b
diff --git a/docs/config-catalog.md b/docs/config-catalog.md
index 8216051616..2225721f4a 100644
--- a/docs/config-catalog.md
+++ b/docs/config-catalog.md
@@ -1208,6 +1208,40 @@ export interface Config {
Source: [`packages/host/open-in-app/src/index.ts:50`](../packages/host/open-in-app/src/index.ts)
+
+
+## `@deepseek-ai/dsh-host-product-telemetry-otel`
+
+```ts config-catalog
+/** Collector routing, application identity, and bounded in-memory batch settings. */
+export interface Config {
+ /** Full HTTP(S) logs URL. */
+ endpoint: string
+ /** Collector routing header. */
+ channel: string
+ /** Resource service.name supplied by the application composition. */
+ serviceName: string
+ /** Resource service.version supplied by the application composition. */
+ serviceVersion: string
+ /** Omit to honor OTEL_EXPORTER_OTLP_LOGS_COMPRESSION / OTEL_EXPORTER_OTLP_COMPRESSION. */
+ compression?: 'none' | 'gzip'
+ /** Maximum records per export; must not exceed maxQueueSize. */
+ maxExportBatchSize: number
+ /** Maximum queued records; the SDK drops new records when full. */
+ maxQueueSize: number
+ /** Delay before exporting a partial batch. */
+ scheduledDelayMillis: number
+ /** Exporter HTTP deadline, including SDK transient-error retries. */
+ timeoutMillis: number
+ /** Processor deadline for one batch export. */
+ exportTimeoutMillis: number
+ /** Outer shutdown wait; pending exports may be lost after this deadline. */
+ shutdownTimeoutMillis: number
+}
+```
+
+Source: [`packages/host/product-telemetry-otel/src/index.ts:37`](../packages/host/product-telemetry-otel/src/index.ts)
+
## `@deepseek-ai/dsh-host-webserver`
@@ -2049,40 +2083,6 @@ export interface Config {
Source: [`packages/llm/plugin-package-inventory-deepseek/src/index.ts:32`](../packages/llm/plugin-package-inventory-deepseek/src/index.ts)
-
-
-## `@deepseek-ai/dsh-product-telemetry-otel`
-
-```ts config-catalog
-/** Collector routing, application identity, and bounded in-memory batch settings. */
-export interface Config {
- /** Full HTTP(S) logs URL. */
- endpoint: string
- /** Collector routing header. */
- channel: string
- /** Resource service.name supplied by the application composition. */
- serviceName: string
- /** Resource service.version supplied by the application composition. */
- serviceVersion: string
- /** Omit to honor OTEL_EXPORTER_OTLP_LOGS_COMPRESSION / OTEL_EXPORTER_OTLP_COMPRESSION. */
- compression?: 'none' | 'gzip'
- /** Maximum records per export; must not exceed maxQueueSize. */
- maxExportBatchSize: number
- /** Maximum queued records; the SDK drops new records when full. */
- maxQueueSize: number
- /** Delay before exporting a partial batch. */
- scheduledDelayMillis: number
- /** Exporter HTTP deadline, including SDK transient-error retries. */
- timeoutMillis: number
- /** Processor deadline for one batch export. */
- exportTimeoutMillis: number
- /** Outer shutdown wait; pending exports may be lost after this deadline. */
- shutdownTimeoutMillis: number
-}
-```
-
-Source: [`packages/host/product-telemetry-otel/src/index.ts:35`](../packages/host/product-telemetry-otel/src/index.ts)
-
## `@deepseek-ai/dsh-ptc-runtime-node`
diff --git a/docs/config-catalog.zh.md b/docs/config-catalog.zh.md
index ce811976fd..21e95ea2a3 100644
--- a/docs/config-catalog.zh.md
+++ b/docs/config-catalog.zh.md
@@ -1212,6 +1212,40 @@ export interface Config {
来源：[`packages/host/open-in-app/src/index.ts:50`](../packages/host/open-in-app/src/index.ts)
+
+
+## `@deepseek-ai/dsh-host-product-telemetry-otel`
+
+```ts config-catalog
+/** Collector routing, application identity, and bounded in-memory batch settings. */
+export interface Config {
+ /** Full HTTP(S) logs URL. */
+ endpoint: string
+ /** Collector routing header. */
+ channel: string
+ /** Resource service.name supplied by the application composition. */
+ serviceName: string
+ /** Resource service.version supplied by the application composition. */
+ serviceVersion: string
+ /** Omit to honor OTEL_EXPORTER_OTLP_LOGS_COMPRESSION / OTEL_EXPORTER_OTLP_COMPRESSION. */
+ compression?: 'none' | 'gzip'
+ /** Maximum records per export; must not exceed maxQueueSize. */
+ maxExportBatchSize: number
+ /** Maximum queued records; the SDK drops new records when full. */
+ maxQueueSize: number
+ /** Delay before exporting a partial batch. */
+ scheduledDelayMillis: number
+ /** Exporter HTTP deadline, including SDK transient-error retries. */
+ timeoutMillis: number
+ /** Processor deadline for one batch export. */
+ exportTimeoutMillis: number
+ /** Outer shutdown wait; pending exports may be lost after this deadline. */
+ shutdownTimeoutMillis: number
+}
+```
+
+来源： [`packages/host/product-telemetry-otel/src/index.ts:37`](../packages/host/product-telemetry-otel/src/index.ts)
+
## `@deepseek-ai/dsh-host-webserver`
@@ -2053,40 +2087,6 @@ export interface Config {
来源：[`packages/llm/plugin-package-inventory-deepseek/src/index.ts:32`](../packages/llm/plugin-package-inventory-deepseek/src/index.ts)
-
-
-## `@deepseek-ai/dsh-product-telemetry-otel`
-
-```ts config-catalog
-/** Collector routing, application identity, and bounded in-memory batch settings. */
-export interface Config {
- /** Full HTTP(S) logs URL. */
- endpoint: string
- /** Collector routing header. */
- channel: string
- /** Resource service.name supplied by the application composition. */
- serviceName: string
- /** Resource service.version supplied by the application composition. */
- serviceVersion: string
- /** Omit to honor OTEL_EXPORTER_OTLP_LOGS_COMPRESSION / OTEL_EXPORTER_OTLP_COMPRESSION. */
- compression?: 'none' | 'gzip'
- /** Maximum records per export; must not exceed maxQueueSize. */
- maxExportBatchSize: number
- /** Maximum queued records; the SDK drops new records when full. */
- maxQueueSize: number
- /** Delay before exporting a partial batch. */
- scheduledDelayMillis: number
- /** Exporter HTTP deadline, including SDK transient-error retries. */
- timeoutMillis: number
- /** Processor deadline for one batch export. */
- exportTimeoutMillis: number
- /** Outer shutdown wait; pending exports may be lost after this deadline. */
- shutdownTimeoutMillis: number
-}
-```
-
-来源： [`packages/host/product-telemetry-otel/src/index.ts:35`](../packages/host/product-telemetry-otel/src/index.ts)
-
## `@deepseek-ai/dsh-ptc-runtime-node`
diff --git a/docs/subsystems/README.i18n.yaml b/docs/subsystems/README.i18n.yaml
index 49c88f8b26..fbe468ab96 100644
--- a/docs/subsystems/README.i18n.yaml
+++ b/docs/subsystems/README.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/subsystems/README.md
-README.md: 7534586b4bd2686cd75da160fe044806afcff539
-README.zh.md: 1132d9a9e0c0bb945532020b314f87a08b84b933
+README.md: d2e8dea206e24ae65676ae50596a3f559239cc21
+README.zh.md: 78c97a016a93415ac1fca1afb6658aa623a61f7a
diff --git a/docs/subsystems/README.md b/docs/subsystems/README.md
index 7534586b4b..d2e8dea206 100644
--- a/docs/subsystems/README.md
+++ b/docs/subsystems/README.md
@@ -6,7 +6,6 @@ One page per subsystem of the DeepSeek Harness: what it is, the data structures
| Page | Owns |
|---|---|
-| [product-telemetry.md](product-telemetry.md) | Explicit product analytics submission and OTLP/HTTP transport |
| [boot.md](boot.md) | Current-profile plugin management and launcher reload coordination |
| [core.md](core.md) | how `packages/core` controls the agent loop: the package-by-package loop description, agent creation and ownership (`AgentHandle`), the `Agent` handle's delivery/cancellation/interception contracts, and the repo-wide type patterns (`…Map → derived-union`, branded ids) |
| [llm-streaming.md](llm-streaming.md) | the `packages/llm` conversation types — `Message`/`ContentBlock`, the assembled model request, the `StreamChunk` wire protocol and adapter contract, `BlockAssembler`, and the `LlmAdapter` provider contract |
@@ -68,5 +67,6 @@ One page per subsystem of the DeepSeek Harness: what it is, the data structures
| [conversation.md](conversation.md) | target-neutral Session-event assembly: Context identity, Location data, replay paths, view builders, and target-owned render nodes |
| [session-projection.md](session-projection.md) | the projection seam: `SessionProjectionMap`, the pure `ProjectionDefinition` unit, `ProjectionSnapshot`'s consistent cut, the change feed |
| [session-telemetry.md](session-telemetry.md) | the outbound session-reporting capability seam: `SessionTelemetryRecord`/`SessionTelemetrySeverity`, the `SessionTelemetrySink` contract, and the `session-telemetry/record` redact waterfall |
+| [product-telemetry.md](product-telemetry.md) | Explicit product analytics submission and OTLP/HTTP transport |
> Type declarations and their JSDoc on these pages are source-equivalent and drift-checked by `pnpm run verify-type-equiv` (see [development.md](../development.md#documenting-types-verbatim-ts-type-equiv)). Ordinary blocks preserve complete declarations; `public-api` blocks preserve body-stripped public class declarations. Cordis services and events use each page's generated **Cordis API** section.
diff --git a/docs/subsystems/README.zh.md b/docs/subsystems/README.zh.md
index 1132d9a9e0..78c97a016a 100644
--- a/docs/subsystems/README.zh.md
+++ b/docs/subsystems/README.zh.md
@@ -6,7 +6,6 @@
| 页面 | 负责内容 |
|---|---|
-| [product-telemetry.md](product-telemetry.zh.md) | 显式产品分析事件提交与 OTLP/HTTP 传输 |
| [boot.md](boot.zh.md) | 当前 profile 插件管理与 launcher 重载协调 |
| [core.md](core.zh.md) | `packages/core` 如何控制 agent loop（智能体循环）：逐包的循环说明、agent 创建与所有权（`AgentHandle`）、`Agent` 句柄的投递/取消/拦截约定，以及全仓通用类型模式（`…Map → derived-union`、品牌化 id） |
| [llm-streaming.md](llm-streaming.zh.md) | `packages/llm` 的对话类型——`Message`/`ContentBlock`、组装完成的模型请求、`StreamChunk` wire protocol 和适配器约定（adapter contract）、`BlockAssembler`，以及 `LlmAdapter` 提供方约定 |
@@ -68,5 +67,6 @@
| [conversation.md](conversation.zh.md) | 目标无关的会话事件组装：上下文标识、位置数据、回放路径、视图构建器与目标自有的渲染节点 |
| [session-projection.md](session-projection.zh.md) | 投影 seam：`SessionProjectionMap`、纯函数 `ProjectionDefinition` 单元、`ProjectionSnapshot` 的一致切面、变更馈送 |
| [session-telemetry.md](session-telemetry.zh.md) | 对外会话上报能力 seam：`SessionTelemetryRecord`/`SessionTelemetrySeverity`、`SessionTelemetrySink` 约定和 `session-telemetry/record` 脱敏 waterfall（瀑布式事件） |
+| [product-telemetry.md](product-telemetry.zh.md) | 显式产品分析事件提交与 OTLP/HTTP 传输 |
> 这些页面上的类型声明及其 JSDoc 与源码等价，并由 `pnpm run verify-type-equiv` 检查漂移（见 [development.md](../development.zh.md#documenting-types-verbatim-ts-type-equiv)）。普通块保留完整声明；`public-api` 块保留去除实现体的公开 class 声明。Cordis 服务与事件使用每页生成的 **Cordis API** 小节。
diff --git a/docs/subsystems/product-telemetry.i18n.yaml b/docs/subsystems/product-telemetry.i18n.yaml
index 326d675316..e5e8b34aea 100644
--- a/docs/subsystems/product-telemetry.i18n.yaml
+++ b/docs/subsystems/product-telemetry.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/subsystems/product-telemetry.md
-product-telemetry.md: b9abdfc3a781ce5dc6237c25f2f7e0b045776125
-product-telemetry.zh.md: de132fec7c7a2e394bb3ee7ab6e8d745c0912b66
+product-telemetry.md: d86540d5a2b75d84f11120b80b7d107788799238
+product-telemetry.zh.md: 52ad1193630fc67f87c9c710027fc1ec5a5db98a
diff --git a/docs/subsystems/product-telemetry.md b/docs/subsystems/product-telemetry.md
index b9abdfc3a7..d86540d5a2 100644
--- a/docs/subsystems/product-telemetry.md
+++ b/docs/subsystems/product-telemetry.md
@@ -8,6 +8,31 @@ The [product telemetry plugin](../../packages/host/product-telemetry-otel/README
Enqueue is synchronous and does not acknowledge delivery. The SDK owns batching and retry; local diagnostics report export failures. See the package README for configuration, shutdown, and loss limits.
+## Record types
+
+```ts type-equiv
+/** Scalar values accepted by the collector's Arrow attributes map. */
+type ProductTelemetryScalar = string | number | boolean
+```
+
+```ts type-equiv
+/** Explicitly selected analytics fields; object values may contain scalars only. */
+interface ProductTelemetryRecord {
+ /** Product/DA-owned event name. */
+ eventName: string
+ /** Human-readable summary; never a prompt, response, credential, or file contents. */
+ body: string
+ /** Event occurrence time in Unix milliseconds. Observation time is assigned on enqueue. */
+ timestamp: number
+ /** OTel severity; omitted values use INFO. */
+ severityNumber?: SeverityNumber
+ /** Business fields selected by the caller; no automatic device or account identity. */
+ attributes?: Record>
+}
+```
+
+Source: [`packages/host/product-telemetry-otel/src/index.ts`](../../packages/host/product-telemetry-otel/src/index.ts)
+
diff --git a/docs/subsystems/product-telemetry.zh.md b/docs/subsystems/product-telemetry.zh.md
index de132fec7c..52ad119363 100644
--- a/docs/subsystems/product-telemetry.zh.md
+++ b/docs/subsystems/product-telemetry.zh.md
@@ -8,6 +8,31 @@
入队同步完成，不代表送达确认。SDK 负责批量发送与重试；发送失败会产生本地诊断。配置、退出和丢失限制见包 README。
+## 记录类型
+
+```ts type-equiv
+/** Scalar values accepted by the collector's Arrow attributes map. */
+type ProductTelemetryScalar = string | number | boolean
+```
+
+```ts type-equiv
+/** Explicitly selected analytics fields; object values may contain scalars only. */
+interface ProductTelemetryRecord {
+ /** Product/DA-owned event name. */
+ eventName: string
+ /** Human-readable summary; never a prompt, response, credential, or file contents. */
+ body: string
+ /** Event occurrence time in Unix milliseconds. Observation time is assigned on enqueue. */
+ timestamp: number
+ /** OTel severity; omitted values use INFO. */
+ severityNumber?: SeverityNumber
+ /** Business fields selected by the caller; no automatic device or account identity. */
+ attributes?: Record>
+}
+```
+
+Source: [`packages/host/product-telemetry-otel/src/index.ts`](../../packages/host/product-telemetry-otel/src/index.ts)
+
diff --git a/packages/README.i18n.yaml b/packages/README.i18n.yaml
index 5893d269ed..df718ac1e0 100644
--- a/packages/README.i18n.yaml
+++ b/packages/README.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write packages/README.md
-README.md: 5f759989eda6588e707a0c80c3035d0ba51ec950
-README.zh.md: 8a2784f5a3f99c9842b10d98d89b6d40936380b2
+README.md: 0ce8e9202763a2e974300b83239f02c256a2953e
+README.zh.md: 8e0650d8f6b00112c4fdb4a4dbc11671a2b3f394
diff --git a/packages/README.md b/packages/README.md
index 5f759989ed..0ce8e92027 100644
--- a/packages/README.md
+++ b/packages/README.md
@@ -77,7 +77,7 @@ Every package lives in exactly one group; new packages join existing groups, and
| [`acp/`](acp/README.md) | Automation-only Agent Client Protocol server |
| [`interaction/`](interaction/README.md) | Human-collaboration plane: approval/interaction seams, permission preset, commands, ask-user tool |
| [`boot/`](boot/README.md) | Shared app-bin boot glue |
-| [`host/`](host/README.md) | Web-GUI host half: API gateway + HTTP route server |
+| [`host/`](host/README.md) | Web GUI host services, directory picking, application launch, plugin inventory, and product telemetry |
| [`client/`](client/README.md) | Web-GUI browser half: shell, wire, object services, slots, `ui-*` plugins |
| [`test-support/`](test-support/README.md) | Test infrastructure (testkits, replay, Loader smokes) |
| [`runtime-diagnostics/`](runtime-diagnostics/README.md) | Runtime diagnostics: package-owned invariant checks and reports |
diff --git a/packages/README.zh.md b/packages/README.zh.md
index 8a2784f5a3..8e0650d8f6 100644
--- a/packages/README.zh.md
+++ b/packages/README.zh.md
@@ -77,7 +77,7 @@ harness 由 `packages/` 下的 npm 包组装而成，按能力系列分组：会
| [`acp/`](acp/README.zh.md) | 仅面向自动化的 ACP（Agent Client Protocol）服务器 |
| [`interaction/`](interaction/README.zh.md) | 人机协作平面：批准／交互 seam、权限预设、命令、询问用户的工具 |
| [`boot/`](boot/README.zh.md) | 共享的 app bin 启动粘合层 |
-| [`host/`](host/README.zh.md) | web GUI 宿主半侧：API 网关 + HTTP 路由服务器 |
+| [`host/`](host/README.zh.md) | Web GUI 宿主服务、目录选择、应用启动、插件清单和产品遥测 |
| [`client/`](client/README.zh.md) | web GUI 浏览器半侧：shell、协议层、对象服务、slot、`ui-*` 插件 |
| [`test-support/`](test-support/README.zh.md) | 测试基础设施（testkit、回放、Loader 冒烟测试） |
| [`runtime-diagnostics/`](runtime-diagnostics/README.zh.md) | 运行时诊断：按包归属的运行时不变式检查与报告 |
diff --git a/packages/host/README.i18n.yaml b/packages/host/README.i18n.yaml
index 2bf03c1e34..c45b78cfa1 100644
--- a/packages/host/README.i18n.yaml
+++ b/packages/host/README.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write packages/host/README.md
-README.md: 4de7a5fdd00be392d19a58f4bc424fce53c5e112
-README.zh.md: 80b74e0647c810b900f671d7d1256ab0d46107a9
+README.md: f5e7832539404b8fb1fb856973f08d5dd5c87eb5
+README.zh.md: 402358f4f4097630ba8deda4551d6bc52ff01b11
diff --git a/packages/host/README.md b/packages/host/README.md
index 4de7a5fdd0..f5e7832539 100644
--- a/packages/host/README.md
+++ b/packages/host/README.md
@@ -1,5 +1,5 @@
---
-description: "Package map for the web GUI host half: the HTTP and SPA servers, workspace-directory picking implementations, the open-in-app launch routes, and the plugin inventory projection."
+description: "Package map for the web GUI host half: the HTTP and SPA servers, workspace-directory picking implementations, the open-in-app launch routes, the plugin inventory projection, and explicit product event reporting."
kind: "package-group"
---
@@ -9,7 +9,7 @@ English | [中文](README.zh.md)
## Summary
-The `host/` group provides the web GUI's plain HTTP server, the SPA dist server that serves the built Web shell, the workspace-directory picking seam with its native, browse, and adaptive composition packages, the open-in-app application probe and launch routes, and the read-only plugin inventory projection. These packages are product packages; the browser transport lives in [`client/`](../client/README.md), and the composed application is [`apps/cli`](../../apps/cli/README.md) booting the [`dsh-base` bundle](../bundle/base/cordis.patch.yml) that serves the web app under `apps/web/`. The picker backends replace one another behind the shared seam.
+The `host/` group provides the web GUI's plain HTTP server, the SPA dist server that serves the built Web shell, the workspace-directory picking seam with its native, browse, and adaptive composition packages, the open-in-app application probe and launch routes, the read-only plugin inventory projection, and explicit product event reporting. These packages are product packages; the browser transport lives in [`client/`](../client/README.md), and the composed application is [`apps/cli`](../../apps/cli/README.md) booting the [`dsh-base` bundle](../bundle/base/cordis.patch.yml) that serves the web app under `apps/web/`. The picker backends replace one another behind the shared seam.
## Table of Contents
@@ -46,7 +46,6 @@ Start with the subsystem references for the transport and the workspace records,
- [HTTP server subsystem](../../docs/subsystems/web-server.md) — the webserver's routes, matching order, and config.
- [Workspace subsystem](../../docs/subsystems/workspace.md) — the workspace records the directory picker feeds.
- [Web config-tree boot and transport layering](../../.agents/notes/implemented/architecture/2026-07-24-web-config-tree-boot-and-transport-layering.md) — ownership of the Web transport layers.
-
- [Product telemetry](../../docs/subsystems/product-telemetry.md) — explicit analytics event submission.
diff --git a/packages/host/README.zh.md b/packages/host/README.zh.md
index 80b74e0647..402358f4f4 100644
--- a/packages/host/README.zh.md
+++ b/packages/host/README.zh.md
@@ -1,5 +1,5 @@
---
-description: "Web GUI Host 侧的包映射：HTTP 与 SPA 服务器、工作区目录选择实现、open-in-app 启动路由和插件清单投影。"
+description: "Web GUI Host 侧的包映射：HTTP 与 SPA 服务器、工作区目录选择实现、open-in-app 启动路由、插件清单投影和显式产品事件上报。"
kind: "package-group"
---
@@ -9,7 +9,7 @@ kind: "package-group"
## 概述
-`host/` 组提供 Web GUI 的普通 HTTP 服务器、服务已构建 Web 壳的 SPA dist 服务器、带原生／浏览／自适应组合包的工作区目录选择 seam、open-in-app 的应用探测与启动路由，以及只读的插件清单投影。这些包都是产品包；浏览器传输位于 [`client/`](../client/README.zh.md)，组合应用是 [`apps/cli`](../../apps/cli/README.zh.md)，它启动 [`dsh-base` 组合包](../bundle/base/cordis.patch.yml) 来提供 `apps/web/` 下的 Web 应用。选择器后端可在共享 seam 后互相替换。
+`host/` 组提供 Web GUI 的普通 HTTP 服务器、服务已构建 Web 壳的 SPA dist 服务器、带原生／浏览／自适应组合包的工作区目录选择 seam、open-in-app 的应用探测与启动路由，只读的插件清单投影以及显式产品事件上报。这些包都是产品包；浏览器传输位于 [`client/`](../client/README.zh.md)，组合应用是 [`apps/cli`](../../apps/cli/README.zh.md)，它启动 [`dsh-base` 组合包](../bundle/base/cordis.patch.yml) 来提供 `apps/web/` 下的 Web 应用。选择器后端可在共享 seam 后互相替换。
## 目录
@@ -46,7 +46,6 @@ kind: "package-group"
- [HTTP 服务器子系统](../../docs/subsystems/web-server.zh.md)——webserver 的路由、匹配顺序与配置。
- [工作区子系统](../../docs/subsystems/workspace.zh.md)——目录选择器所喂给的工作区记录。
- [Web 配置树启动与传输分层](../../.agents/notes/implemented/architecture/2026-07-24-web-config-tree-boot-and-transport-layering.zh.md)——Web 传输各层的所有权。
-
- [产品埋点](../../docs/subsystems/product-telemetry.zh.md)——显式提交分析事件。
diff --git a/packages/host/product-telemetry-otel/README.i18n.yaml b/packages/host/product-telemetry-otel/README.i18n.yaml
index 823dcfa244..ea4a841892 100644
--- a/packages/host/product-telemetry-otel/README.i18n.yaml
+++ b/packages/host/product-telemetry-otel/README.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write packages/host/product-telemetry-otel/README.md
-README.md: 4ce0a8744b46391b8dbe3d7d6739f0e0e1d118c5
-README.zh.md: 34075efae80c2e5275fbb782c485bea1b2661745
+README.md: af1f2c415fc21db874abc7bb0d9e25c7149fcabf
+README.zh.md: ffdb682d9a8a0a4bf406f71322e062f14b666cf2
diff --git a/packages/host/product-telemetry-otel/README.md b/packages/host/product-telemetry-otel/README.md
index 4ce0a8744b..af1f2c415f 100644
--- a/packages/host/product-telemetry-otel/README.md
+++ b/packages/host/product-telemetry-otel/README.md
@@ -3,7 +3,7 @@ description: "Configure explicit product usage events, OTLP/HTTP routing, batchi
kind: "package-reference"
---
-# @deepseek-ai/dsh-product-telemetry-otel
+# @deepseek-ai/dsh-host-product-telemetry-otel
English | [中文](README.zh.md)
@@ -25,14 +25,14 @@ Send selected product usage events to an OTLP/HTTP collector. Events carry a nam
## Use this package
-Mount the plugin in a Cordis composition with the application identity; override the collector endpoint when needed. The shipped profiles do not mount it.
+Mount the plugin in a Cordis composition with the application identity; override the collector endpoint when needed. The shipped profiles do not mount it. Set `DSH_APP_VERSION` to the running application release version in the launcher environment; the schema rejects an absent version.
```yaml
-- name: '@deepseek-ai/dsh-product-telemetry-otel'
+- name: '@deepseek-ai/dsh-host-product-telemetry-otel'
config:
endpoint: https://dsh-otel-collector.deepseeksvc.com/v1/logs
- serviceName: dsh-telemetry-test
- serviceVersion: test
+ serviceName: deepseek-harness
+ serviceVersion: !!js process.env.DSH_APP_VERSION
compression: gzip
scheduledDelayMillis: 30000
```
@@ -49,6 +49,10 @@ Mount the plugin in a Cordis composition with the application identity; override
| `exportTimeoutMillis` | `20000` | Processor batch export deadline |
| `shutdownTimeoutMillis` | `21000` | Outer wait for shutdown; expiry reports possible loss |
+The default endpoint routes explicitly submitted events to the production product collector. Test and custom deployments must override it. Only `x-channel` and SDK protocol headers reach the collector; ambient OTel headers and client certificates are not inherited.
+
+The 30-second interval batches product events; the exporter has a 15-second retry window inside the processor’s 20-second batch deadline. The outer 21-second wait bounds plugin disposal, including SDK `forceFlush()` work that the processor deadline does not cover. An unreachable collector can delay disposal for the full 21 seconds. A full 2,048-record queue requires four 512-record batches and may not drain before that deadline. Interactive compositions needing a shorter exit should override these budgets; neither configuration guarantees delivery.
+
Consumers inject `productTelemetry` and call `emit()` with explicitly selected analytics fields. Event names and field semantics belong to their product and analytics owners. The plugin reads no Session, account, credential, or device identifier. Callers must exclude prompts, responses, file contents, credentials, and other unapproved values.
The collector expects a string body and attributes containing strings, numbers, booleans, or objects of those scalars. Callers supply occurrence time in milliseconds; the plugin assigns observation time and defaults severity to INFO. Invalid transport configuration fails at activation. Export failures produce local warnings without making event submission wait for the network.
@@ -61,7 +65,7 @@ The collector expects a string body and attributes containing strings, numbers,
Implementation internals — click to expand
-A private OTel logger feeds `BatchLogRecordProcessor` and the HTTP JSON exporter. The SDK owns queueing, transient-error retries, and compression; plugin disposal drains pending records with a bounded wait. Export completion is observed separately because SDK shutdown can resolve after a rejected export. No global OTel provider is installed.
+A private OTel logger feeds `BatchLogRecordProcessor` and the SDK HTTP delegate with its JSON log serializer. The delegate receives explicit headers and an HTTP agent; only shared timeout and compression settings use SDK environment resolution. The direct `@opentelemetry/core` dependency matches `sdk-logs` at 2.9.0 so exporter result enums share one TypeScript identity. The SDK owns queueing, transient-error retries, and compression; plugin disposal drains pending records with a bounded wait. Export completion is observed separately because SDK shutdown can resolve after a rejected export. No global OTel provider is installed.
[`src/index.ts`](src/index.ts) owns configuration and submission. No runtime invariant companion is published: delivery has no independent local acknowledgement to compare with the SDK's queue.
@@ -93,7 +97,7 @@ None; event submission does not change model requests.
Delivery and collection remain limited to the following capabilities.
-- No business events, renderer transport, or account/device identity are wired automatically.
+- Callers own event selection, renderer-to-host transport, and any permitted identity attributes.
- The queue is memory-only; overflow, network failure, and process exit can lose events. There is no durable outbox or warehouse acknowledgement.
- The SDK batches by record count, not encoded bytes. Callers must keep records within the collector's 4 MB limit and choose batch sizes appropriate to the receiver.
- Caller-selected strings are not redacted automatically. This package does not decide product disclosure or consent policy.
diff --git a/packages/host/product-telemetry-otel/README.zh.md b/packages/host/product-telemetry-otel/README.zh.md
index 34075efae8..ffdb682d9a 100644
--- a/packages/host/product-telemetry-otel/README.zh.md
+++ b/packages/host/product-telemetry-otel/README.zh.md
@@ -3,7 +3,7 @@ description: "配置显式产品使用事件、OTLP/HTTP 路由、批量发送
kind: "package-reference"
---
-# @deepseek-ai/dsh-product-telemetry-otel
+# @deepseek-ai/dsh-host-product-telemetry-otel
[English](README.md) | 中文
@@ -25,14 +25,14 @@ kind: "package-reference"
## 使用本包
-在 Cordis 组合中挂载插件并提供应用标识；需要时可覆盖接收地址。内置 profile 不挂载本插件。
+在 Cordis 组合中挂载插件并提供应用标识；需要时可覆盖接收地址。内置 profile 不挂载本插件。启动器环境须将 `DSH_APP_VERSION` 设为运行中应用的发布版本；缺少版本时 schema 会拒绝配置。
```yaml
-- name: '@deepseek-ai/dsh-product-telemetry-otel'
+- name: '@deepseek-ai/dsh-host-product-telemetry-otel'
config:
endpoint: https://dsh-otel-collector.deepseeksvc.com/v1/logs
- serviceName: dsh-telemetry-test
- serviceVersion: test
+ serviceName: deepseek-harness
+ serviceVersion: !!js process.env.DSH_APP_VERSION
compression: gzip
scheduledDelayMillis: 30000
```
@@ -49,6 +49,10 @@ kind: "package-reference"
| `exportTimeoutMillis` | `20000` | Processor 批次导出的超时时间 |
| `shutdownTimeoutMillis` | `21000` | 退出时的等待上限；超时会提示可能丢失数据 |
+默认接收地址将显式提交的事件发送到生产产品 collector，测试和自定义部署必须覆盖该地址。只向 collector 发送 `x-channel` 和 SDK 协议请求头，不继承宿主 OTel 请求头或客户端证书。
+
+30 秒间隔用于批量发送产品事件；exporter 的 15 秒重试窗口位于 processor 的 20 秒批次期限内。外层 21 秒等待限制插件卸载时间，包括 processor 期限未覆盖的 SDK `forceFlush()`。collector 不可达时，卸载可能等待完整的 21 秒。2,048 条满队列需要四个 512 条批次，可能无法在期限前排空。要求更快退出的交互式应用组合应覆盖这些时间配置；两种配置都不保证送达。
+
消费方注入 `productTelemetry`，调用 `emit()` 提交明确选定的分析字段。事件名称与字段含义由产品和数据分析负责人定义。插件不读取 Session、账号、凭证或设备标识。调用方必须排除提示词、回答、文件内容、凭证及其他未经批准的数据。
接收服务要求 body 为字符串，attributes 的值为字符串、数字、布尔值或由这些标量组成的对象。调用方以毫秒提供发生时间；插件填写观测时间，默认严重程度为 INFO。无效传输配置在激活时报错。发送失败产生本地警告，事件提交不等待网络。
@@ -61,7 +65,7 @@ kind: "package-reference"
实现细节——点击展开
-私有 OTel logger 将记录交给 `BatchLogRecordProcessor` 和 HTTP JSON exporter。SDK 负责队列、临时错误重试与压缩；插件卸载时在限定时间内发送剩余记录。发送完成结果单独观测，因为 SDK 在发送被拒绝后仍可能正常完成退出。不安装全局 OTel provider。
+私有 OTel logger 将记录交给 `BatchLogRecordProcessor`，再由 SDK HTTP delegate 和 JSON 日志序列化器发送。delegate 使用显式请求头和 HTTP agent，只有共享的超时与压缩配置使用 SDK 环境变量解析。直接依赖的 `@opentelemetry/core` 与 `sdk-logs` 对齐为 2.9.0，使导出结果枚举共享同一个 TypeScript 类型身份。SDK 负责队列、临时错误重试与压缩；插件卸载时在限定时间内发送剩余记录。发送完成结果单独观测，因为 SDK 在发送被拒绝后仍可能正常完成退出。不安装全局 OTel provider。
[`src/index.ts`](src/index.ts) 负责配置与提交。不发布运行时不变量伴随模块：本地没有独立的送达确认可与 SDK 队列比较。
@@ -93,7 +97,7 @@ kind: "package-reference"
发送和采集受以下能力限制。
-- 不自动接入业务事件、渲染进程传输或账号与设备标识。
+- 调用方拥有事件选择、渲染进程到宿主的传输以及获准使用的标识属性。
- 队列仅存在于内存；队列溢出、网络故障和进程退出可能丢失事件。没有持久发件箱或入仓确认。
- SDK 按记录条数而非编码字节数分批。调用方必须确保记录不超过接收服务的 4 MB 限制，并选择接收服务适用的批次大小。
- 不自动脱敏调用方选择的字符串。本包不决定产品告知或同意策略。
diff --git a/packages/host/product-telemetry-otel/package.json b/packages/host/product-telemetry-otel/package.json
index 24dff2ab6a..2bcdeb691b 100644
--- a/packages/host/product-telemetry-otel/package.json
+++ b/packages/host/product-telemetry-otel/package.json
@@ -1,5 +1,5 @@
{
- "name": "@deepseek-ai/dsh-product-telemetry-otel",
+ "name": "@deepseek-ai/dsh-host-product-telemetry-otel",
"description": "Explicit product usage events exported through OpenTelemetry HTTP logs",
"version": "0.1.6-alpha.2",
"publishConfig": {
@@ -27,13 +27,14 @@
],
"license": "MIT",
"dependencies": {
- "@opentelemetry/api-logs": "^0.220.0",
- "@opentelemetry/exporter-logs-otlp-http": "^0.220.0",
- "@opentelemetry/otlp-exporter-base": "^0.220.0",
- "@opentelemetry/resources": "^2.9.0",
- "@opentelemetry/sdk-logs": "^0.220.0",
"@deepseek-ai/schemastery": "workspace:^",
- "@opentelemetry/core": "2.9.0"
+ "@opentelemetry/api": "^1.9.1",
+ "@opentelemetry/api-logs": "^0.220.0",
+ "@opentelemetry/core": "2.9.0",
+ "@opentelemetry/otlp-exporter-base": "^0.220.0",
+ "@opentelemetry/otlp-transformer": "^0.220.0",
+ "@opentelemetry/resources": "^2.9.0",
+ "@opentelemetry/sdk-logs": "^0.220.0"
},
"peerDependencies": {
"@deepseek-ai/cordis": "workspace:^"
diff --git a/packages/host/product-telemetry-otel/src/index.ts b/packages/host/product-telemetry-otel/src/index.ts
index b617702172..eef6ec5dce 100644
--- a/packages/host/product-telemetry-otel/src/index.ts
+++ b/packages/host/product-telemetry-otel/src/index.ts
@@ -2,8 +2,10 @@
import { Context, Service } from '@deepseek-ai/cordis'
import z from '@deepseek-ai/schemastery'
import { SeverityNumber, type Logger } from '@opentelemetry/api-logs'
-import { OTLPLogExporter } from '@opentelemetry/exporter-logs-otlp-http'
-import { CompressionAlgorithm } from '@opentelemetry/otlp-exporter-base'
+import { validateHeaderValue } from 'node:http'
+import { JsonLogsSerializer } from '@opentelemetry/otlp-transformer'
+import { createOtlpHttpExportDelegate, getSharedConfigurationFromEnvironment, httpAgentFactoryFromOptions } from '@opentelemetry/otlp-exporter-base/node-http'
+import { CompressionAlgorithm, getSharedConfigurationDefaults, mergeOtlpSharedConfigurationWithDefaults, OTLPExporterBase } from '@opentelemetry/otlp-exporter-base'
import { ExportResultCode } from '@opentelemetry/core'
import { resourceFromAttributes } from '@opentelemetry/resources'
import { BatchLogRecordProcessor, LoggerProvider } from '@opentelemetry/sdk-logs'
@@ -59,10 +61,10 @@ export interface Config {
const positiveInteger = () => z.number().step(1).min(1).max(2_147_483_647)
-/** Loader validation; the same schema resolves defaults for direct construction. */
+/** Loader validation and defaults for application compositions. */
export const Config: z, Config> = z.object({
endpoint: z.string().default('https://dsh-otel-collector.deepseeksvc.com/v1/logs'),
- channel: z.string().default('dsh_otel_report'),
+ channel: z.string().min(1).default('dsh_otel_report'),
serviceName: z.string().required(),
serviceVersion: z.string().required(),
compression: z.union(['none', 'gzip']),
@@ -79,9 +81,18 @@ export default class ProductTelemetry extends Service {
static Config = Config
private readonly logger: Logger
- constructor(ctx: Context, input: Config) {
- const config = Config(input)
- const endpoint = new URL(config.endpoint)
+ constructor(ctx: Context, config: Config) {
+ let endpoint: URL
+ try {
+ endpoint = new URL(config.endpoint)
+ } catch (cause) {
+ throw new Error('product-telemetry-otel: endpoint must be a valid HTTP(S) URL', { cause })
+ }
+ try {
+ validateHeaderValue('x-channel', config.channel)
+ } catch (cause) {
+ throw new Error('product-telemetry-otel: channel must be a valid HTTP header value', { cause })
+ }
if (!['http:', 'https:'].includes(endpoint.protocol)) {
throw new Error('product-telemetry-otel: endpoint must use HTTP or HTTPS')
}
@@ -89,14 +100,20 @@ export default class ProductTelemetry extends Service {
throw new Error('product-telemetry-otel: maxExportBatchSize must not exceed maxQueueSize')
}
super(ctx, 'productTelemetry')
- const exporter = new OTLPLogExporter({
- url: config.endpoint,
- headers: { 'x-channel': config.channel },
+ const shared = mergeOtlpSharedConfigurationWithDefaults({
timeoutMillis: config.timeoutMillis,
...(config.compression === undefined ? {} : {
compression: config.compression === 'gzip' ? CompressionAlgorithm.GZIP : CompressionAlgorithm.NONE,
}),
- })
+ }, getSharedConfigurationFromEnvironment('LOGS'), getSharedConfigurationDefaults())
+ const transport = {
+ ...shared,
+ url: config.endpoint,
+ // This collector must not inherit another endpoint's headers or TLS client identity.
+ headers: () => Promise.resolve({ 'Content-Type': 'application/json', 'x-channel': config.channel }),
+ agentFactory: httpAgentFactoryFromOptions({ keepAlive: true }),
+ }
+ const exporter = new OTLPExporterBase(createOtlpHttpExportDelegate(transport, JsonLogsSerializer))
const provider = new LoggerProvider({
resource: resourceFromAttributes({
'service.name': config.serviceName,
@@ -111,7 +128,7 @@ export default class ProductTelemetry extends Service {
export: (records, callback) => {
exporter.export(records, (result) => {
// SDK flush/shutdown can resolve after export failure; observe the actual completion.
- if (result.code !== ExportResultCode.SUCCESS) ctx.logger.warn('Product telemetry export failed')
+ if (result.code !== ExportResultCode.SUCCESS) ctx.logger.warn('Product telemetry export failed', result.error)
callback(result)
})
},
@@ -120,7 +137,7 @@ export default class ProductTelemetry extends Service {
},
})],
})
- this.logger = provider.getLogger('@deepseek-ai/dsh-product-telemetry-otel')
+ this.logger = provider.getLogger('@deepseek-ai/dsh-host-product-telemetry-otel')
ctx.effect(() => async () => {
let timer!: ReturnType
const deadline = new Promise((resolve) => {
diff --git a/packages/host/product-telemetry-otel/tests/fixtures/driver.ts b/packages/host/product-telemetry-otel/tests/fixtures/driver.ts
index 4dfac67960..a0ad9389d8 100644
--- a/packages/host/product-telemetry-otel/tests/fixtures/driver.ts
+++ b/packages/host/product-telemetry-otel/tests/fixtures/driver.ts
@@ -3,7 +3,7 @@ import { createServer } from 'node:http'
import { once } from 'node:events'
import { gunzipSync } from 'node:zlib'
import { writeFile } from 'node:fs/promises'
-import type {} from '@deepseek-ai/dsh-product-telemetry-otel'
+import type {} from '@deepseek-ai/dsh-host-product-telemetry-otel'
import { bootProductionProfile } from '../../../../test-support/loader-smoke/tests/fixtures/production-profile.ts'
const configPath = process.argv[2]
@@ -24,6 +24,7 @@ try {
await once(server, 'listening')
const address = server.address()
if (address === null || typeof address === 'string') throw new Error('collector has no port')
+ process.env.DSH_APP_VERSION = 'synthetic-release'
process.env.DSH_PRODUCT_TELEMETRY_TEST_ENDPOINT = `http://127.0.0.1:${address.port}/v1/logs`
const ctx = await bootProductionProfile({ binName: 'product-telemetry-test', profile: 'headless', overlayPaths: [configPath] })
try {
diff --git a/packages/host/product-telemetry-otel/tests/fixtures/telemetry.patch.yml b/packages/host/product-telemetry-otel/tests/fixtures/telemetry.patch.yml
index c876c3d646..d9104a0bfb 100644
--- a/packages/host/product-telemetry-otel/tests/fixtures/telemetry.patch.yml
+++ b/packages/host/product-telemetry-otel/tests/fixtures/telemetry.patch.yml
@@ -6,10 +6,10 @@
disabled: true
- insert:
- id: product-telemetry-otel
- name: '@deepseek-ai/dsh-product-telemetry-otel'
+ name: '@deepseek-ai/dsh-host-product-telemetry-otel'
config:
endpoint: !!js process.env.DSH_PRODUCT_TELEMETRY_TEST_ENDPOINT
serviceName: dsh-telemetry-test
- serviceVersion: test
+ serviceVersion: !!js process.env.DSH_APP_VERSION
compression: gzip
scheduledDelayMillis: 60000
diff --git a/packages/host/product-telemetry-otel/tests/telemetry.spec.ts b/packages/host/product-telemetry-otel/tests/telemetry.spec.ts
index 424ec5917a..22f7df5c30 100644
--- a/packages/host/product-telemetry-otel/tests/telemetry.spec.ts
+++ b/packages/host/product-telemetry-otel/tests/telemetry.spec.ts
@@ -1,7 +1,7 @@
import { createServer, type IncomingHttpHeaders } from 'node:http'
import { once } from 'node:events'
import { gunzipSync } from 'node:zlib'
-import { afterEach, describe, expect, it, vi } from 'vitest'
+import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest'
import { Context } from '@deepseek-ai/cordis'
import { LoggerProvider } from '@opentelemetry/sdk-logs'
import { SeverityNumber } from '@opentelemetry/api-logs'
@@ -16,11 +16,17 @@ afterEach(async () => {
try {
for (const dispose of cleanup.splice(0).reverse()) await dispose()
} finally {
+ vi.unstubAllEnvs()
vi.restoreAllMocks()
vi.useRealTimers()
}
})
+beforeEach(() => {
+ vi.stubEnv('OTEL_EXPORTER_OTLP_COMPRESSION', undefined)
+ vi.stubEnv('OTEL_EXPORTER_OTLP_LOGS_COMPRESSION', undefined)
+})
+
async function collector(statuses = [200]) {
const captures: Capture[] = []
const server = createServer((req, res) => {
@@ -92,6 +98,22 @@ describe('explicit product telemetry', () => {
expect(JSON.stringify(capture)).not.toContain('user.id')
})
+ it('isolates collector headers from ambient OpenTelemetry credentials', async () => {
+ vi.stubEnv('OTEL_EXPORTER_OTLP_HEADERS', 'Authorization=Bearer%20synthetic-secret,x-user-id=synthetic-user')
+ vi.stubEnv('OTEL_EXPORTER_OTLP_LOGS_HEADERS', 'x-log-token=synthetic-token,x-channel=other-collector')
+ const target = await collector()
+ const ctx = context()
+ const fiber = await ctx.plugin(ProductTelemetry, config(target.endpoint))
+ ctx.productTelemetry.emit(event)
+ await fiber.dispose()
+ expect(target.captures).toHaveLength(1)
+ expect(target.captures[0]?.headers).toMatchObject({ 'x-channel': 'dsh_otel_report' })
+ expect(target.captures[0]?.headers).not.toHaveProperty('authorization')
+ expect(target.captures[0]?.headers).not.toHaveProperty('x-user-id')
+ expect(target.captures[0]?.headers).not.toHaveProperty('x-log-token')
+ expect(process.env['OTEL_EXPORTER_OTLP_HEADERS']).toContain('synthetic-secret')
+ })
+
it('does not export on mount or empty shutdown', async () => {
const target = await collector()
const fiber = await context().plugin(ProductTelemetry, config(target.endpoint))
@@ -124,11 +146,12 @@ describe('explicit product telemetry', () => {
expect(() => { ctx.productTelemetry.emit(event) }).not.toThrow()
await fiber.dispose()
expect(target.captures).toHaveLength(1)
- expect(warn).toHaveBeenCalledWith('Product telemetry export failed')
+ expect(warn).toHaveBeenCalledWith('Product telemetry export failed', expect.any(Error))
})
it.each([
{ endpoint: 'broken' }, { endpoint: 'ftp://collector.test/logs' },
+ { channel: '' }, { channel: 'bad\nchannel' }, { channel: '中文' }, { timeoutMillis: 0 },
{ maxExportBatchSize: 0 }, { maxExportBatchSize: 2, maxQueueSize: 1 },
{ maxQueueSize: -1 }, { scheduledDelayMillis: 0 }, { exportTimeoutMillis: Infinity },
{ shutdownTimeoutMillis: 2_147_483_648 },
@@ -138,6 +161,29 @@ describe('explicit product telemetry', () => {
expect(ctx.get('productTelemetry')).toBeUndefined()
})
+ it.each([
+ [{ endpoint: 'broken' }, 'endpoint must be a valid HTTP(S) URL'],
+ [{ channel: 'bad\nchannel' }, 'channel must be a valid HTTP header value'],
+ ] as const)('names invalid transport fields before registering the service', (invalid, message) => {
+ const ctx = context()
+ expect(() => new ProductTelemetry(ctx, config('http://collector.test/v1/logs', invalid)))
+ .toThrow(`product-telemetry-otel: ${message}`)
+ expect(ctx.get('productTelemetry')).toBeUndefined()
+ })
+
+ it.each([
+ ['OTEL_EXPORTER_OTLP_COMPRESSION', 'gzip'],
+ ['OTEL_EXPORTER_OTLP_LOGS_COMPRESSION', 'gzip'],
+ ])('honors %s when compression is omitted', async (name, value) => {
+ vi.stubEnv(name, value)
+ const target = await collector()
+ const ctx = context()
+ const fiber = await ctx.plugin(ProductTelemetry, config(target.endpoint))
+ ctx.productTelemetry.emit(event)
+ await fiber.dispose()
+ expect(target.captures[0]?.headers['content-encoding']).toBe('gzip')
+ })
+
it('bounds a stalled shutdown and observes its later settlement', async () => {
const target = await collector()
const ctx = context()
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
index a4cc9868ac..4868184291 100644
--- a/pnpm-lock.yaml
+++ b/pnpm-lock.yaml
@@ -8441,16 +8441,19 @@ importers:
'@deepseek-ai/schemastery':
specifier: link:../../../vendor/schemastery
version: link:../../../vendor/schemastery
+ '@opentelemetry/api':
+ specifier: ^1.9.1
+ version: 1.9.1
'@opentelemetry/api-logs':
specifier: ^0.220.0
version: 0.220.0
'@opentelemetry/core':
specifier: 2.9.0
version: 2.9.0(@opentelemetry/api@1.9.1)
- '@opentelemetry/exporter-logs-otlp-http':
+ '@opentelemetry/otlp-exporter-base':
specifier: ^0.220.0
version: 0.220.0(@opentelemetry/api@1.9.1)
- '@opentelemetry/otlp-exporter-base':
+ '@opentelemetry/otlp-transformer':
specifier: ^0.220.0
version: 0.220.0(@opentelemetry/api@1.9.1)
'@opentelemetry/resources':
diff --git a/scripts/gen-doc-graphs.ts b/scripts/gen-doc-graphs.ts
index 2df51d9664..0890e45bd7 100644
--- a/scripts/gen-doc-graphs.ts
+++ b/scripts/gen-doc-graphs.ts
@@ -31,7 +31,7 @@ interface ServiceRole {
key: string
pkg: string
title: string
- mode: 'core' | 'seam' | 'bundle'
+ mode: 'core' | 'seam' | 'bundle' | 'service'
implementations?: string[]
consumers?: string[]
companions?: string[]
@@ -99,13 +99,6 @@ const GROUP_ORDER = [
]
const SERVICE_ROLES: ServiceRole[] = [
- {
- key: 'productTelemetry',
- pkg: 'product-telemetry-otel',
- title: 'Product usage event sender',
- mode: 'core',
- note: 'Exports explicitly submitted analytics events through OTLP/HTTP; mounting alone collects nothing.',
- },
{
key: 'hmr',
pkg: 'hmr',
@@ -380,6 +373,14 @@ const SERVICE_ROLES: ServiceRole[] = [
consumers: ['llm-pi-ai'],
note: 'Flows are registered by the plugin that knows how to obtain one credential and keyed by the record they write; the seam owns the conversation and the one-attempt-per-key lifecycle, never the protocol.',
},
+ {
+ key: 'productTelemetry',
+ pkg: 'host-product-telemetry-otel',
+ title: 'Product usage event sender',
+ mode: 'service',
+ note: 'Exports explicitly submitted analytics events through OTLP/HTTP; mounting alone collects nothing.',
+ },
+
{
key: 'sessionTelemetry',
pkg: 'session-telemetry',
@@ -870,7 +871,7 @@ function renderCapabilitySeams(pkgs: Pkg[], services: readonly ServiceEntry[]):
const addEdge = (from: string, to: string): void => { edges.add(` ${from} --> ${to}`) }
const lines = generatedHeader('Capability Seams And Core Services')
lines.push(
- 'A service can be a core spine service, a swappable capability seam, or a bundle/composition point. The graph shows the package that owns the service declaration, known implementation packages, and packages that consume the service directly.',
+ 'A service can be a core spine service, a swappable capability seam, a bundle/composition point, or a standalone service. The graph shows the package that owns the service declaration, known implementation packages, and packages that consume the service directly.',
'',
'```mermaid',
'flowchart LR',
diff --git a/scripts/type-equiv.manifest.json b/scripts/type-equiv.manifest.json
index e36b61fbf7..e1bf5ad4e9 100644
--- a/scripts/type-equiv.manifest.json
+++ b/scripts/type-equiv.manifest.json
@@ -2256,6 +2256,16 @@
"doc": "docs/subsystems/deliverables.md",
"symbol": "WorkspaceChanges",
"source": "packages/deliverables/workspace-changes/src/types.ts"
+ },
+ {
+ "doc": "docs/subsystems/product-telemetry.md",
+ "symbol": "ProductTelemetryScalar",
+ "source": "packages/host/product-telemetry-otel/src/index.ts"
+ },
+ {
+ "doc": "docs/subsystems/product-telemetry.md",
+ "symbol": "ProductTelemetryRecord",
+ "source": "packages/host/product-telemetry-otel/src/index.ts"
}
]
}
diff --git a/tsconfig.base.json b/tsconfig.base.json
index ff609f43e8..d39dff388c 100644
--- a/tsconfig.base.json
+++ b/tsconfig.base.json
@@ -187,6 +187,7 @@
"@deepseek-ai/dsh-host-directory-picker-native/*": ["./packages/host/directory-picker-native/src/*"],
"@deepseek-ai/dsh-host-directory-picker-auto": ["./packages/host/directory-picker-auto/src"],
"@deepseek-ai/dsh-host-directory-picker-auto/*": ["./packages/host/directory-picker-auto/src/*"],
+ "@deepseek-ai/dsh-host-product-telemetry-otel": ["./packages/host/product-telemetry-otel/src"],
"@deepseek-ai/dsh-host-open-in-app": ["./packages/host/open-in-app/src"],
"@deepseek-ai/dsh-host-open-in-app/shared": ["./packages/host/open-in-app/src/shared.ts"],
"@deepseek-ai/dsh-host-webserver": ["./packages/host/webserver/src"],
@@ -402,7 +403,6 @@
"@deepseek-ai/dsh-plan-mode": ["./packages/plan/plan-mode/src"],
"@deepseek-ai/dsh-plan-mode/invariant": ["./packages/plan/plan-mode/src/invariant.ts"],
"@deepseek-ai/dsh-plugin-package-inventory-deepseek": ["./packages/llm/plugin-package-inventory-deepseek/src"],
- "@deepseek-ai/dsh-product-telemetry-otel": ["./packages/host/product-telemetry-otel/src"],
"@deepseek-ai/dsh-ptc-runtime": ["./packages/ptc-runtime/ptc-runtime/src"],
"@deepseek-ai/dsh-ptc-runtime-node": ["./packages/ptc-runtime/ptc-runtime-node/src"],
"@deepseek-ai/dsh-pwsh-sandbox": ["./packages/shell/pwsh-sandbox/src"],
From 6d13819fbced0eb0c148624526d5c58182408714 Mon Sep 17 00:00:00 2001
From: 07akioni <07akioni2@gmail.com>
Date: Mon, 21 Sep 2026 17:50:32 +0800
Subject: [PATCH 3/3] docs(telemetry): regenerate module graph after package
rename
---
docs/module-graph.i18n.yaml | 4 ++--
docs/module-graph.md | 4 ++--
docs/module-graph.zh.md | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/docs/module-graph.i18n.yaml b/docs/module-graph.i18n.yaml
index c697f85817..b3adeb8c42 100644
--- a/docs/module-graph.i18n.yaml
+++ b/docs/module-graph.i18n.yaml
@@ -2,5 +2,5 @@
# side as of the last confirmed-consistent state. Both languages carry equal authority;
# after editing either side, bring the other along and re-record with:
# pnpm run verify-translation-pairing --write docs/module-graph.md
-module-graph.md: 9157fef798cd1884cd21cd9ce7788f3882ed2dad
-module-graph.zh.md: 06d6b1acb38fdd864e745a06fa6e40a018833d42
+module-graph.md: ae55f2bb2cf29f0f6f4ad3c16df9abb7a3511191
+module-graph.zh.md: cef0a09afb07c4f8ee5392899a1cee3f9cadf3ca
diff --git a/docs/module-graph.md b/docs/module-graph.md
index 9157fef798..ae55f2bb2c 100644
--- a/docs/module-graph.md
+++ b/docs/module-graph.md
@@ -277,8 +277,8 @@ flowchart TD
pkg_host_frontend_static["host-frontend-static"]
pkg_host_open_in_app["host-open-in-app"]
pkg_host_plugin_inventory["host-plugin-inventory"]
+ pkg_host_product_telemetry_otel["host-product-telemetry-otel"]
pkg_host_webserver["host-webserver"]
- pkg_product_telemetry_otel["product-telemetry-otel"]
end
subgraph group_identity["packages/identity"]
pkg_anonymous_user_id["anonymous-user-id"]
@@ -1428,8 +1428,8 @@ flowchart TD
| [`host-directory-picker-browse`](../packages/host/directory-picker-browse) | `host` | — |
| [`host-directory-picker-native`](../packages/host/directory-picker-native) | `host` | — |
| [`host-open-in-app`](../packages/host/open-in-app) | `host` | — |
+| [`host-product-telemetry-otel`](../packages/host/product-telemetry-otel) | `host` | — |
| [`host-webserver`](../packages/host/webserver) | `host` | — |
-| [`product-telemetry-otel`](../packages/host/product-telemetry-otel) | `host` | — |
| [`invariants`](../packages/runtime-diagnostics/invariants) | `runtime-diagnostics` | — |
| [`session-format`](../packages/session/session-format) | `session` | — |
| [`session-format-v0-to-v1`](../packages/session/session-format-v0-to-v1) | `session` | — |
diff --git a/docs/module-graph.zh.md b/docs/module-graph.zh.md
index 06d6b1acb3..cef0a09afb 100644
--- a/docs/module-graph.zh.md
+++ b/docs/module-graph.zh.md
@@ -279,8 +279,8 @@ flowchart TD
pkg_host_frontend_static["host-frontend-static"]
pkg_host_open_in_app["host-open-in-app"]
pkg_host_plugin_inventory["host-plugin-inventory"]
+ pkg_host_product_telemetry_otel["host-product-telemetry-otel"]
pkg_host_webserver["host-webserver"]
- pkg_product_telemetry_otel["product-telemetry-otel"]
end
subgraph group_identity["packages/identity"]
pkg_anonymous_user_id["anonymous-user-id"]
@@ -1430,8 +1430,8 @@ flowchart TD
| [`host-directory-picker-browse`](../packages/host/directory-picker-browse) | `host` | — |
| [`host-directory-picker-native`](../packages/host/directory-picker-native) | `host` | — |
| [`host-open-in-app`](../packages/host/open-in-app) | `host` | — |
+| [`host-product-telemetry-otel`](../packages/host/product-telemetry-otel) | `host` | — |
| [`host-webserver`](../packages/host/webserver) | `host` | — |
-| [`product-telemetry-otel`](../packages/host/product-telemetry-otel) | `host` | — |
| [`invariants`](../packages/runtime-diagnostics/invariants) | `runtime-diagnostics` | — |
| [`session-format`](../packages/session/session-format) | `session` | — |
| [`session-format-v0-to-v1`](../packages/session/session-format-v0-to-v1) | `session` | — |