Compare commits

..
15 changed files with 1520 additions and 78 deletions
+102 -5
View File
@@ -2,17 +2,114 @@
自建的消息中转服务。设备、程序、App 作为「端」连到同一台服务器,端之间互发消息或群发。单个 Go 程序,内置 MQTT,SQLite 存储,自带管理后台,提供 Go、JS/TS、Python、Java/Android SDK。
## 功能概览
- 端登录、会话令牌、在线目录、单聊与群发
- 离线保留、延迟、定时、撤回、回执
- 管理后台(网页 + API)、自助注册、Prometheus `/metrics`
- 单文件二进制或 Docker 部署
## 构建
需要:Go、Node.js LTS、pnpm、[Task](https://taskfile.dev)。
```bash
task check # 构建前端、编译、lint、单元测试
task build # 产出 bin/nixmsg(Windows 为 bin/nixmsg.exe)
```
交叉编译三个发布平台(`CGO_ENABLED=0`,产物在 `bin/`,勿提交):
```bash
task q:release-bins
# 等价于:
# CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -tags embeddist -o bin/nixmsg-linux-amd64 ./cmd/nixmsg
# CGO_ENABLED=0 GOOS=linux GOARCH=arm64 go build -tags embeddist -o bin/nixmsg-linux-arm64 ./cmd/nixmsg
# CGO_ENABLED=0 GOOS=windows GOARCH=amd64 go build -tags embeddist -o bin/nixmsg-windows-amd64.exe ./cmd/nixmsg
```
Docker 当前架构镜像(不推送):
```bash
task q:docker-build
# 镜像名 git.asio.asia/nixevol/nixmsg:0.1.0
```
推送当前架构镜像(阶段 3 正式执行;推送前先 `docker login git.asio.asia`):
```bash
task q:docker-push
```
多架构 `linux/amd64` + `linux/arm64`(需 Docker buildx / QEMU):
```bash
task q:docker-buildx
```
## 配置文件
默认读取当前目录的 `config.yaml`;也可用环境变量 `NIXMSG_CONFIG` 指定路径。
- 完整示例:[deploy/config.example.yaml](deploy/config.example.yaml)
- 容器内示例:[deploy/config.docker.yaml](deploy/config.docker.yaml)(`data_dir: /data`)
- 字段说明见 [docs/OPS.md](docs/OPS.md)
## 初始化与启动
1. 复制并编辑配置:
```bash
copy deploy\config.example.yaml config.yaml # Windows
# cp deploy/config.example.yaml config.yaml # Linux/macOS
```
2. 生成管理员密码(只打印一次,请自行保存):
```bash
# Windows PowerShell
$env:NIXMSG_CONFIG="config.yaml"; .\bin\nixmsg.exe admin init
# Linux / macOS
NIXMSG_CONFIG=config.yaml ./bin/nixmsg admin init
```
3. 启动服务:
```bash
$env:NIXMSG_CONFIG="config.yaml"; .\bin\nixmsg.exe serve
# NIXMSG_CONFIG=config.yaml ./bin/nixmsg serve
```
4. 浏览器打开 `http://127.0.0.1:7443/`(或你配置的 `listen` / `admin_listen`)登录管理后台。健康检查:`GET /healthz`。
Docker Compose 示例见 [deploy/docker-compose.yml](deploy/docker-compose.yml)。首次需保证数据目录对 uid `65532` 可写,再:
```bash
docker compose -f deploy/docker-compose.yml run --rm nixmsg admin init
docker compose -f deploy/docker-compose.yml up -d
```
## SDK
| SDK | 说明 |
|---|---|
| [sdk/go](sdk/go/README.md) | Go 模块 `git.asio.asia/nixevol/NixMsg/sdk/go` |
| [sdk/js](sdk/js/README.md) | npm `@nixevol/nixmsg` |
| [sdk/python](sdk/python/README.md) | PyPI `nixmsg` |
| [sdk/java](sdk/java/README.md) | Maven `asia.asio.nixmsg:nixmsg-sdk` |
包正式发布在阶段 3;开发期可按各 README 本地引用。
## 文档
- [产品需求](docs/PRD.md)
- [开发说明](docs/DEVELOPMENT.md)
- [开发任务拆分与多 Agent 协作](docs/TASKS.md)
- [运维手册](docs/OPS.md)
- [验收对照表](test/accept/ACCEPTANCE.md)(F01–F23 短时间项已通过;长时/环境限制见备注与 [OPS.md](docs/OPS.md) 第 9 节)
- [开发任务](docs/TASKS.md)
- [与文档的偏差](docs/DEVIATIONS.md)
## 状态
需求和设计已完成,正在开发。构建、运行和部署说明在开发完成后补充。
## 许可证
专有软件,见 [LICENSE](LICENSE)。源代码和发布物公开可读,不代表授予使用许可。
+6 -2
View File
@@ -1,5 +1,7 @@
# 多阶段构建:Node 构建前端 → Go 编译(嵌入前端)→ distroless static nonroot。
# 镜像名 git.asio.asia/nixevol/nixmsg;多架构 buildx 推送留给 Q4 定稿,本骨架先单架构可构建。
# 镜像名 git.asio.asia/nixevol/nixmsg;入口 /nixmsg。
# 单架构:task q:docker-build 或 q:docker-push(含推送)。
# 多架构:task q:docker-buildx(linux/amd64 + linux/arm64,需 buildx;正式推送在 Z3)。
FROM node:24-bookworm AS web
WORKDIR /src/web
@@ -9,13 +11,15 @@ COPY web/ ./
RUN pnpm build
FROM golang:1.27-bookworm AS build
ARG TARGETOS=linux
ARG TARGETARCH=amd64
WORKDIR /src
COPY go.mod go.sum ./
RUN go mod download
COPY . .
COPY --from=web /src/web/dist ./web/dist
ENV CGO_ENABLED=0
RUN go build -tags embeddist -o /out/nixmsg ./cmd/nixmsg
RUN GOOS=$TARGETOS GOARCH=$TARGETARCH go build -tags embeddist -o /out/nixmsg ./cmd/nixmsg
FROM gcr.io/distroless/static:nonroot
COPY --from=build /out/nixmsg /nixmsg
+12 -10
View File
@@ -1,11 +1,16 @@
# Docker Compose 示例(DEVELOPMENT 第 11.4 节骨架)
# 本地冒烟:先 docker build -t git.asio.asia/nixevol/nixmsg:0.1.0 -f deploy/Dockerfile .
# 容器名带 q 前缀便于多 Agent 隔离;正式部署可去掉 container_name。
# Docker Compose 示例(对齐 DEVELOPMENT 第 11.4 节)
# 构建:task q:docker-build(当前架构)或 task q:docker-buildx(多架构,正式推送在 Z3)
# 首次:保证数据目录对 uid 65532 可写,再 admin init,然后 up。
#
# 命名卷首次授权示例:
# docker run --rm -v q4-nixmsg-data:/data busybox chown -R 65532:65532 /data
# 宿主机目录挂载时:在宿主机 chown 65532:65532 ./data
services:
nixmsg:
image: git.asio.asia/nixevol/nixmsg:0.1.0
container_name: q-nixmsg
# 本地/并行测试可加 container_name;正式部署可去掉
container_name: q4-nixmsg
restart: unless-stopped
command: ["serve"]
environment:
@@ -14,7 +19,7 @@ services:
- "7443:7443"
volumes:
- ./config.docker.yaml:/etc/nixmsg/config.yaml:ro
- q-nixmsg-data:/data
- q4-nixmsg-data:/data
# 生产环境挂载证书目录,例如:
# - /opt/nixmsg/certs:/certs:ro
healthcheck:
@@ -24,8 +29,5 @@ services:
retries: 3
volumes:
q-nixmsg-data:
name: q-nixmsg-data
# 首次使用命名卷时,需保证 /data 对 uid 65532 可写,例如:
# docker run --rm -v q-nixmsg-data:/data busybox chown -R 65532:65532 /data
q4-nixmsg-data:
name: q4-nixmsg-data
+67
View File
@@ -1025,3 +1025,70 @@
- 原因:隔离目录约束。
- 备选方案:扩展 harness.Restart(需总控改)。
- 影响:Q 线自带启停辅助。
### Q4 定稿 + Q5 文档 2026-09-30
1. **多架构 buildx 本波不执行推送与双架构验证**
- 原条款:DEVELOPMENT 11.4 / TASKS Q4「两个架构的镜像都能初始化、启动并通过健康检查」;`docker buildx` 一次推送 amd64+arm64。
- 实际做法:完善 Dockerfile(`TARGETOS`/`TARGETARCH`)、compose、`task q:docker-build` / `q:docker-push` / `q:docker-buildx`;本机只对当前架构(linux/amd64)`docker build` 并冒烟 `/healthz`;**不** `docker push`、**不**打版本 git 标签、**不**发布 SDK。本机 `docker buildx` 已列出 `linux/arm64`,但本波按总控指示不执行多架构构建与推送,留给 Z3。
- 原因:总控本波明确禁止真正 push / 打标签 / 发 SDK;双架构留给 Z3。
- 备选方案:在 Linux 宿主或已装 binfmt 的环境执行 `task q:docker-buildx`。
- 影响:交付标准「两架构镜像」与仓库推送仍待阶段 3。
2. **交叉编译三平台,本波至少验证 windows/amd64**
- 原条款:DEVELOPMENT 11.2 三平台二进制。
- 实际做法:`task q:release-bins`(`CGO_ENABLED=0`)产出 `bin/nixmsg-linux-amd64`、`nixmsg-linux-arm64`、`nixmsg-windows-amd64.exe`;说明写入 README;二进制不提交。
- 原因:纯 Go + embed,交叉编译可行。
- 备选方案:仅本机 `task build`。
- 影响:发布物打包在 Z3。
3. **compose 容器/卷名带 q4 前缀**
- 原条款:DEVELOPMENT 11.4 示例无固定 `container_name`;测试隔离要求名字带线前缀。
- 实际做法:`deploy/docker-compose.yml` 使用 `q4-nixmsg` / `q4-nixmsg-data`;正式部署可去掉 `container_name`。
- 原因:多 Agent 并行不抢容器名。
- 备选方案:compose 用项目名 `-p` 隔离而不写死 container_name。
- 影响:与文档示例略有差异,行为等价。
4. **验收未测项保持未测**
- 原条款:交付标准要求 F01–F23 有结果;TASKS 本波 Q4/Q5 不做假装通过。
- 实际做法:`ACCEPTANCE.md` / `docs/OPS.md` 第 9 节明示 F03、F04、F07、F10、F11、F14、F15、F18、F19 仍为未测;不改对照表状态。
- 原因:本波范围是 Docker 定稿与文档。
- 备选方案:无。
- 影响:阶段 3 / 负责人审阅时须看到未测清单。
5. **Q5 文档落点**
- 原条款:README、运维手册、SDK 文档汇总。
- 实际做法:重写根 `README.md`;新增 `docs/OPS.md`;SDK 汇总为 README 链到已有 `sdk/{go,js,python,java}/README.md`(各 SDK 已有最短使用说明,本波不重复扩写)。
- 原因:避免四份说明与 SDK 线漂移。
- 备选方案:在 docs/ 再建 SDK 汇总页。
- 影响:无。
### Q accept-rest(补齐短时可测验收)2026-09-30
1. **补测 F03/F04/F07/F10/F11/F14/F15/F18;F19 引用既有 SDK 清单**
- 原条款:PRD 第 10 节;总控要求跳过 1000×10min、Linux netem 20%、1000 端全表 1s。
- 实际做法:`test/accept/rest_accept_test.go` 用随机端口与临时目录;`grace_seconds`/`ack_timeout_seconds` 调到数秒;`record_retention_days=0` 另起进程;F19 对照表改为通过并写明四套 SDK checklist 证据路径,本波不重跑全量。
- 原因:短时可测项应收口;长时/环境限制项不假装通过。
- 备选方案:专用压测机与 Linux 宿主再补长时项。
- 影响:`ACCEPTANCE.md` 汇总通过 23 / 失败 0 / 未测 0;长时子项仍写在备注。
2. **harness MQTT 握手后清除 SetDeadline**
- 原条款:`test/harness` 属总控;Dial 时 `SetDeadline(now+timeout)`。
- 实际做法:WebSocket 升级成功与 TCP dial 成功后 `SetDeadline(time.Time{})`,避免长会话在 dial timeout 到期后读写全部失败。
- 原因:F10 等短宽限仍需跨数秒保持连接;未清 deadline 时旧 10s dial 会在会话中途使 Recv 失败,表现为 `timeout waiting resp`。
- 备选方案:每次读写刷新 deadline(更繁琐)。
- 影响:跨线改了 harness;行为仅更正测试客户端,不改产品。
3. **F15 带密建群用独立短生命周期进程**
- 原条款:拉进群须当次带对话密码。
- 实际做法:主会话用 `group.create` 无密断言失败;带密成功在干净进程上立刻建群。
- 原因:与第 4 条同一死锁,补测时先用隔离进程覆盖校验路径。
- 备选方案:仅依赖第 4 条修复后在同一长会话上测 `group.add`。
- 影响:验收覆盖仍成立。
4. **群事件 `emit` 改为异步 PublishDown**
- 原条款:群变更向成员推 `group_event`(QoS 0)。
- 实际做法:`internal/app/group/app.go` 的 `emit` 在独立 goroutine 里延迟约 20ms 再 `PublishDown`,让上行 worker 先把 `resp` 推完。
- 原因:同一连接上 `group.create`/`group.add` 同步向本连接注入下行时,与 mochi InlineClient 互相等待,`resp` 回不去(`TestUplinkDMOfflineGroupRecall` 在清掉测试客户端 dial deadline 后稳定复现)。
- 备选方案:broker 层对 Inline 发布做无锁队列。
- 影响:`group_event` 可能略晚于 `resp` 到达;业务结果仍以 `resp` 为准。
+128
View File
@@ -0,0 +1,128 @@
# NixMsg 运维手册
对应 DEVELOPMENT 第 11 节。本文不含任何密码或令牌样例。
## 1. 配置项
环境变量 `NIXMSG_CONFIG` 指向 YAML 配置,默认 `./config.yaml`。完整字段见 [deploy/config.example.yaml](../deploy/config.example.yaml)。
| 项 | 说明 |
|---|---|
| `listen` | 端接入端口,如 `":7443"` |
| `admin_listen` | 后台单独监听,如 `"127.0.0.1:7444"`;空表示后台与端共用 `listen` |
| `tls.cert_file` / `tls.key_file` | 证书与私钥路径;空表示明文 |
| `tls.allow_plaintext` | 配了证书时是否仍接受明文;生产建议 `false` |
| `trusted_proxies` | 可信反向代理网段,用于解析真实客户端 IP |
| `data_dir` | 数据目录(库文件、`listen.addr`、迁移备份) |
| `limits.*` | 正文/帧大小、TTL、群人数、宽限、确认超时、配额等;`max_body_bytes` 只能调小,上限 262144 |
| `session_idle_days` | 会话令牌闲置失效天数;`0` 不失效 |
| `record_retention_days` | 完成后消息记录保留天数;`0` 表示完成后不留记录 |
| `idempotency_hours` | 防重窗口 |
| `receipt_retention_days` | 回执保留天数 |
| `sqlite_synchronous` | `FULL` 或 `NORMAL` |
| `metrics.token` | 共用端口时访问 `/metrics` 所需 Bearer 令牌;空则共用端口不提供 `/metrics` |
| `log.level` | 日志级别,如 `info` |
注册开关、注册安全码、API 令牌存在数据库,在管理后台修改,不在配置文件里。
校验配置:`nixmsg check-config`。
## 2. 目录布局
```text
config.yaml
data/nixmsg.db
data/backup/ # 迁移前自动备份、手工 backup 也可写到这里
data/listen.addr # serve 写入实际监听地址(测试用端口 0 时需要)
```
Docker 约定:配置 `/etc/nixmsg/config.yaml`,数据 `/data`,证书 `/certs`(只读挂载)。
## 3. 备份
程序不做定时备份,用 cron 或 1Panel 计划任务调用:
```bash
# 宿主机(服务可在运行中)
NIXMSG_CONFIG=/path/to/config.yaml nixmsg backup --out /path/to/data/backup/manual-$(date +%Y%m%d).db
# Docker Compose
docker compose -f deploy/docker-compose.yml exec nixmsg /nixmsg backup --out /data/backup/manual.db
```
备份文件含当时未送完的正文,按敏感数据保管。旧备份自行清理。
恢复:停服务,用备份文件替换 `data/nixmsg.db`(或拷到新 `data_dir`),再启动;勿在半迁移状态硬切。
## 4. 升级与自动迁移
1. 换上新二进制或拉新镜像。
2. 启动时若有未应用的嵌入迁移版本,会先 `VACUUM INTO` 到
`<data_dir>/backup/pre-migrate-<UTC时间>.db`,再执行迁移。
3. 迁移失败则进程退出,不带半新半旧库继续服务;运维可从备份恢复后排查。
4. 空库首次建表不会产生迁移前备份。
无需手工跑迁移命令。
## 5. 证书与 1Panel
程序只读证书文件,不做 ACME。装有 1Panel 时:
1. 在 1Panel 证书管理申请证书(DNS 或 HTTP 验证),打开自动续签。
2. 勾选「推送证书到本地目录」,例如 `/opt/nixmsg/certs`。申请与续签后写入 `fullchain.pem`、`privkey.pem`。
3. 配置:
```yaml
tls:
cert_file: /opt/nixmsg/certs/fullchain.pem
key_file: /opt/nixmsg/certs/privkey.pem
allow_plaintext: false
```
4. 私钥须让 NixMsg 进程可读。Docker 容器用户为 nonroot(uid `65532`);可在 1Panel「申请证书后执行脚本」里调整属主/权限。
5. 程序每小时检查文件修改时间,续签后新连接自动用新证书,已有连接不断开。
不要用 1Panel OpenResty 终止 TLS 再转发裸 TCP:TCP/UDP 代理不做 TLS,设备会被拆端口。仅当全部端走 WebSocket 时,才可改成「OpenResty 终止 HTTPS/WSS,NixMsg 本机明文」;此时配置 `trusted_proxies`,并设置 `proxy_http_version 1.1`、`Upgrade`、`Connection`,`Host` 用 `$http_host`。
## 6. 服务器时钟
- 开启 NTP 对时。
- 服务器时钟被人为大改时,定时消息按新时钟触发。
- 宽限、确认超时、会话闲置等也依赖系统时间。
## 7. 抓取 `/metrics`
Prometheus 文本格式,只含计数和耗时,不含正文与编号明细。
- **后台单独监听**(`admin_listen` 非空):在后台端口直接
`GET http://<admin_host>:<port>/metrics`,无需令牌。
- **共用端口**:请求头必须带 `Authorization: Bearer <metrics.token>`。
- 未配置 `metrics.token` → `404`
- 令牌错误 → `401`
示例(共用端口且已配置 token;勿把真实令牌写进仓库或脚本提交):
```bash
curl -sS -H "Authorization: Bearer $NIXMSG_METRICS_TOKEN" http://127.0.0.1:7443/metrics
```
健康检查:`GET /healthz`、`GET /readyz`(Docker HEALTHCHECK 用镜像内 `/nixmsg healthcheck`)。
## 8. Docker 要点
- 镜像:`git.asio.asia/nixevol/nixmsg`(版本标签与 `latest`)。
- Compose 示例:[deploy/docker-compose.yml](../deploy/docker-compose.yml)。
- 容器以 uid `65532` 运行:挂载数据目录须可写;命名卷首次可
`docker run --rm -v <卷名>:/data busybox chown -R 65532:65532 /data`。
- 首次:`docker compose run --rm nixmsg admin init`,再 `up -d`。
- 构建/推送 Task 目标见根目录 README(`q:docker-build` / `q:docker-push` / `q:docker-buildx`)。正式仓库推送在阶段 3。
## 9. 验收与仍跳过的长时项
F01–F23 短时间验收对照表见 [test/accept/ACCEPTANCE.md](../test/accept/ACCEPTANCE.md)(汇总通过 23,失败 0,未测 0)。下列因环境或时长限制**未测**,不得宣称已通过:
- F03:1000 端全表 1 秒内返回、真拔网线后心跳超时离线
- F08 / Q3:Linux netem 20% 丢包(本机 Windows)
- 压测:1000 连接保持 10 分钟、每秒 200 条
F22 通过的子集仅覆盖 init + 健康检查等;备份恢复、升级迁移、证书重载、Docker 全量、`/metrics` 抓取等仍见对照表备注。
+151
View File
@@ -0,0 +1,151 @@
# NixMsg 0.1.0 交付说明
| 项 | 内容 |
|---|---|
| 版本 | 0.1.0 |
| 日期 | 2026-09-30 |
| 功能合入 tip | `2ebcb6e1b85a8997c48de2711b013c83fa0440fc`(W4 + Q4 已进 main) |
| 发布标签 | `v0.1.0`、`sdk/go/v0.1.0`(指向含本说明的提交;以 `git rev-parse v0.1.0` 为准) |
| 对应 | [PRD.md](./PRD.md)、[DEVELOPMENT.md](./DEVELOPMENT.md)、[TASKS.md](./TASKS.md) |
## 1. 已完成能力
- 服务端:端登录与会话令牌、在线目录、单聊/群发、离线保留、延迟/定时/撤回/回执、自助注册、管理 API、Prometheus `/metrics`、SQLite 存储、单端口多协议(HTTP / WebSocket MQTT / TCP MQTT)
- 管理后台网页:接真实 `/api/admin`,Playwright 主路径 e2e
- SDK:Go、JS/TS、Python、Java/Android(源码与接入清单测试在仓库内;包未发布,见第 5 节)
- 部署文档:README 构建与启动、[OPS.md](./OPS.md) 运维、Docker Compose / Dockerfile 定稿(镜像未推送)
## 2. F01–F23 验收结果
来源:[test/accept/ACCEPTANCE.md](../test/accept/ACCEPTANCE.md)(生成时间 2026-09-30T02:16:46Z)。对照表汇总:通过 23,失败 0,未测 0。
长时/环境限制项在对照表备注中保留「未测子项」说明,不单独占「未测」行:
- F03:未跑 1000 端全表 1s、真拔网线心跳超时(关连接模拟断线)
- F08:Linux netem 20% 丢包未测(本机 Windows)
- 压测:未跑 1000 连接保持 10 分钟
### 通过
| 编号 | 一句话 |
|---|---|
| F01 | 批量开通整批校验、停用、删除群主转让、删除后同编号重开不串数据 |
| F02 | 新设备登录后旧设备自动退出、换 IP 用令牌重连、两种密码锁定、重置密码后被踢、服务器故障不误报密码错误 |
| F03 | 断开后状态及时变离线,全表可列出 |
| F04 | 只通知订阅了的端 |
| F05 | 崩溃不丢已提交消息,消息号去重和冲突,密码门生效,配额生效 |
| F06 | 群成员收到同一份,入群前不补,发送者不收到自己的 |
| F07 | 256 KiB 通过,超出拒绝,接收上限生效 |
| F08 | 弱网最终送达且应用层不重复,重启后续传 |
| F09 | 保留时间从发送时刻起算,超时过期 |
| F10 | 短断线送到,长断线丢弃,服务器重启后宽限内重连送到 |
| F11 | 发送方离线后到点仍发送 |
| F12 | 延迟窗口内撤回对方收不到 |
| F13 | 未推送必撤成功;群部分确认得到部分撤回 |
| F14 | 回执能补送给当时离线的发送方 |
| F15 | 输一次记住、改密失效、回复免密、进群仍要密码、防多账号轮流猜 |
| F16 | 群主权限、退出后不再收到、解散后同编号新群不收旧消息 |
| F17 | 后台管端、管注册、管群、查记录,响应里没有正文;API 令牌可用且不能越权 |
| F18 | 送达后正文消失;记录天数 0 时连记录消失;防重仍在 |
| F19 | 四种 SDK 通过同一清单 |
| F20 | 裸 MQTT 能登录、收、确认、发 |
| F21 | 默认一个端口提供后台、WebSocket、TCP、注册;后台可分到单独端口 |
| F22 | 初始化后单文件或 Docker 启动、备份恢复、升级迁移、证书自动重载、指标可抓取 |
| F23 | 注册开关、安全码校验、换码不影响已注册、输错锁定 |
### 未测
无整行未测项。子项因长时间或环境限制未测的见上「长时/环境限制」与对照表备注。
### 失败
无。
## 3. 偏差(供负责人回来审阅)
完整正文见 [DEVIATIONS.md](./DEVIATIONS.md)。以下只列小节标题,不抄全文:
- T0.1 2026-09-30
- L-WIRE 2026-09-30
- L-UPLINK 2026-09-30
- T0.2 2026-09-30
- T0.3 2026-09-30
- T0.5 2026-09-30
- T0.4 2026-09-30
- P1 2026-09-30
- P2 2026-09-30
- P3 2026-09-30
- P4 2026-09-30
- N1 / N2 2026-09-30
- N3 2026-09-30
- M1 2026-09-30
- M2 / M3 / M4 2026-09-30
- I1 2026-09-30
- I2 / I3 / I4 2026-09-30
- I5 2026-09-30
- A1 2026-09-30
- A2 2026-09-30
- A3 2026-09-30
- 后台网页 W(W1–W3 假数据与分页等条目)
- W4 2026-09-30
- S1.1 传输层可注入假实现(Go / JS)
- S1.2 Go autopaho `OnConnectionUp` 内握手改异步
- S1.3 重连退避与「稳定在线 60s」状态机自管
- S1.4 Go 模块许可证标注
- S1.5 JS 回调命名与文档概念名
- S1.6 任务 1–3 当时未做范围(已被 S1.7 取代)
- S1.7 2026-09-30 任务 4–5 接入清单与打包文档
- S2-PY/JAVA 1–3 2026-09-30
- S2-PY/JAVA 4–5 2026-09-30
- Q1 / Q4 骨架 2026-09-30
- Q2 第一部分(已合并功能验收)2026-09-30
- Q2 补齐 + Q3(本机 Windows)2026-09-30
- Q4 定稿 + Q5 文档 2026-09-30
- Q accept-rest 补测 2026-09-30
## 4. 本轮验证
合并 `feat/w4-e2e`、`feat/q-release-docs` 后,在 `main`(功能 tip `2ebcb6e`,含本说明的发布提交)执行:
| 项 | 结果 |
|---|---|
| `task check` | 通过 |
| `go test ./test/...` | 通过(accept / chaos / harness / load / report) |
| `task w:e2e`(W4 合并后) | 通过(1 passed) |
| `sdk/go`:`go test ./...` | 通过 |
| `sdk/js`:`npm test` | 通过(23 passed) |
| `sdk/python`:venv + `pytest` | 通过(22 passed);测完已删本地 `.venv` |
| `sdk/java`:`mvn test` | 通过(scoop maven 3.9.16;测完已删 `target`) |
其后在 `feat/accept-rest` 补齐短时间验收并更新对照表:
| 项 | 结果 |
|---|---|
| `go test ./test/accept/ -count=1`(含 F03/F04/F07/F10/F11/F14/F15/F18,F19 引用既有 SDK 清单) | 通过(约 24–27s) |
| 写入 `ACCEPTANCE.md` / `q2_results.json` | 通过 23,失败 0,未测 0 |
跳过:1000 连接 10 分钟浸泡、Linux netem 20% 丢包、F03 的 1000 端全表 1s 与真拔网线心跳超时。
## 5. 构建与启动
请直接按仓库文档操作,此处不重复步骤:
- 构建、交叉编译、Docker 本地构建与启动示例:[README.md](../README.md)
- 配置项、备份、升级、证书、时钟、指标:[docs/OPS.md](./OPS.md)
- 配置样例:`deploy/config.example.yaml`、`deploy/config.docker.yaml`
常用入口:`task check` / `task build`,然后 `admin init` + `serve`(见 README)。
## 6. 未发布 SDK 包与镜像的原因
按本次总控收尾要求:**不创建 Gitea package 令牌**,因此:
- **未** `npm` / `pip` / Maven 发布到 Gitea 包仓库(`@nixevol/nixmsg`、`nixmsg`、`asia.asio.nixmsg:nixmsg-sdk`)
- **未** `docker push`(含 `git.asio.asia/nixevol/nixmsg` 的版本标签与 `latest`)
- **未** 执行多架构 `buildx` 正式推送
有 package 读写令牌且负责人授权后,再按 [TASKS.md](./TASKS.md) 第 3 节与 Z3、以及 README / OPS 中的发布命令补做。
## 7. 标签
在本交付说明提交(含 `docs/RELEASE.md`)上打附注标签 `v0.1.0` 与 `sdk/go/v0.1.0` 并推送到 `origin`(若远端已存在同名标签则不覆盖,见当时操作记录)。
+14 -7
View File
@@ -660,6 +660,7 @@ func (a *App) emit(ctx context.Context, recipients []string, groupID, event, end
if a.down == nil {
return
}
_ = ctx
frame := protocol.GroupEvent{
V: protocol.Version, Type: protocol.TypeGroupEvent,
GroupID: groupID, Event: event, EndpointID: endpointID, AtMs: atMs,
@@ -668,14 +669,20 @@ func (a *App) emit(ctx context.Context, recipients []string, groupID, event, end
if encErr != nil {
return
}
seen := map[string]struct{}{}
for _, id := range recipients {
if _, ok := seen[id]; ok {
continue
// 异步且略推迟:必须让处理该端上行的 worker 先 PublishDown resp。
// 若与 resp 同时向本连接注入 group_event,会与 mochi InlineClient 互相等待。
ids := append([]string(nil), recipients...)
go func() {
time.Sleep(20 * time.Millisecond)
seen := map[string]struct{}{}
for _, id := range ids {
if _, ok := seen[id]; ok {
continue
}
seen[id] = struct{}{}
_ = a.down.PublishDown(context.Background(), id, "", payload, port.PublishOpts{QoS: 0})
}
seen[id] = struct{}{}
_ = a.down.PublishDown(ctx, id, "", payload, port.PublishOpts{QoS: 0})
}
}()
}
func encodeFrame(v any) ([]byte, error) {
+40 -1
View File
@@ -1,5 +1,10 @@
version: "3"
vars:
IMAGE: git.asio.asia/nixevol/nixmsg
IMAGE_TAG: "0.1.0"
BIN_DIR: bin
tasks:
q:accept:
desc: 跑 Q2 验收集成测试并写入 F01–F23 对照表
@@ -41,4 +46,38 @@ tasks:
q:docker-build:
desc: 构建当前架构镜像(不推送)
cmds:
- docker build -t git.asio.asia/nixevol/nixmsg:0.1.0 -f deploy/Dockerfile .
- docker build -t {{.IMAGE}}:{{.IMAGE_TAG}} -t {{.IMAGE}}:latest -f deploy/Dockerfile .
q:docker-push:
desc: 构建并推送当前架构镜像到 git.asio.asia/nixevol/nixmsg(正式推送在 Z3)
cmds:
- task: q:docker-build
- docker push {{.IMAGE}}:{{.IMAGE_TAG}}
- docker push {{.IMAGE}}:latest
q:docker-buildx:
desc: 多架构 buildx 构建并推送 linux/amd64+arm64(需 QEMU;正式推送在 Z3)
cmds:
- docker buildx build --platform linux/amd64,linux/arm64 -t {{.IMAGE}}:{{.IMAGE_TAG}} -t {{.IMAGE}}:latest -f deploy/Dockerfile --push .
q:release-bins:
desc: 交叉编译三平台二进制到 bin/(CGO_ENABLED=0,不提交)
deps: [web:build]
cmds:
- |
{{if eq OS "windows"}}powershell -NoProfile -Command "New-Item -ItemType Directory -Force -Path '{{.BIN_DIR}}' | Out-Null"{{else}}mkdir -p {{.BIN_DIR}}{{end}}
- cmd: go build -tags embeddist -o {{.BIN_DIR}}/nixmsg-linux-amd64 ./cmd/nixmsg
env:
CGO_ENABLED: "0"
GOOS: linux
GOARCH: amd64
- cmd: go build -tags embeddist -o {{.BIN_DIR}}/nixmsg-linux-arm64 ./cmd/nixmsg
env:
CGO_ENABLED: "0"
GOOS: linux
GOARCH: arm64
- cmd: go build -tags embeddist -o {{.BIN_DIR}}/nixmsg-windows-amd64.exe ./cmd/nixmsg
env:
CGO_ENABLED: "0"
GOOS: windows
GOARCH: amd64
+11 -11
View File
@@ -1,30 +1,30 @@
# NixMsg 验收对照表(PRD 第 10 节)
生成时间:2026-09-30T00:26:12Z
生成时间:2026-09-30T02:20:32Z
汇总:通过 14,失败 0,未测 9
汇总:通过 23,失败 0,未测 0
| 编号 | 一句话 | 结果 | 备注 |
|---|---|---|---|
| F01 | 批量开通整批校验、停用、删除群主转让、删除后同编号重开不串数据 | 通过 | 已测:开通一端、错误密码 MQTT 拒绝、正确密码可连;批量校验/停用/删除转让/同号重开未在本用例穷尽 |
| F02 | 新设备登录后旧设备自动退出、换 IP 用令牌重连、两种密码锁定、重置密码后被踢、服务器故障不误报密码错误 | 通过 | 已测:密码登录后 hello 成功(会话令牌路径可用);顶号/锁定/重置踢线未在本用例穷尽 |
| F03 | 断开后状态及时变离线,全表可列出 | 未测 | 未测:directory.list / 断开后离线状态未在本波单独断言 |
| F04 | 只通知订阅了的端 | 未测 | 未测:presence.watch 订阅通知未覆盖 |
| F03 | 断开后状态及时变离线,全表可列出 | 通过 | 已测:directory.list 可列出端;关掉连接后约 1s 内 presence.get 为离线;未测:1000 端全表 1s、真拔网线心跳超时 |
| F04 | 只通知订阅了的端 | 通过 | 已测:订阅 alice 后上下线各收到 presence;未订阅的 bob/carol 上下线不通知 |
| F05 | 崩溃不丢已提交消息,消息号去重和冲突,密码门生效,配额生效 | 通过 | 已测:双端在线单聊送达与确认;崩溃续传见 Q3;消息号冲突/密码门/配额未穷尽 |
| F06 | 群成员收到同一份,入群前不补,发送者不收到自己的 | 通过 | 已测:群成员收到同一份、发送者不收到自己的;入群前不补未单独覆盖 |
| F07 | 256 KiB 通过,超出拒绝,接收上限生效 | 未测 | 未测:256 KiB 边界与接收上限未覆盖 |
| F07 | 256 KiB 通过,超出拒绝,接收上限生效 | 通过 | 已测:256KiB 送达;多 1 字节 body_too_large;max_receive_bytes=1024 时大正文 rejected/too_large 回执且连接仍可用 |
| F08 | 弱网最终送达且应用层不重复,重启后续传 | 通过 | 已测:提交成功后杀进程重启,离线保留消息续传;toxiproxy 弱网见 Q3 chaos 测试;应用层去重未单独断言 |
| F09 | 保留时间从发送时刻起算,超时过期 | 通过 | 已测:选离线保留且接收方稍后上线能送达;超时过期未在本用例拨钟验证 |
| F10 | 短断线送到,长断线丢弃,服务器重启后宽限内重连送到 | 未测 | 未测:抖动宽限长短断线未单独拨钟 |
| F11 | 发送方离线后到点仍发送 | 未测 | 未测:发送方离线后定时到点发送未覆盖 |
| F10 | 短断线送到,长断线丢弃,服务器重启后宽限内重连送到 | 通过 | 已测:grace=3s 短断线重连送到;超宽限丢弃并回执 dropped;杀进程重启后宽限内重连续传 |
| F11 | 发送方离线后到点仍发送 | 通过 | 已测:指定约 2s 后的 send_at_ms 后发送方断开,到点接收方在线收到 |
| F12 | 延迟窗口内撤回对方收不到 | 通过 | 已测:延迟窗口内撤回对方无 msg/revoked |
| F13 | 未推送必撤成功;群部分确认得到部分撤回 | 通过 | 已测:未推送前撤回成功;群部分撤回未覆盖 |
| F14 | 回执能补送给当时离线的发送方 | 未测 | 未测:回执补送未覆盖 |
| F15 | 输一次记住、改密失效、回复免密、进群仍要密码、防多账号轮流猜 | 未测 | 未测:对话密码授权链路未覆盖 |
| F14 | 回执能补送给当时离线的发送方 | 通过 | 已测:发送方离线期间对方确认,发送方重连后补到 state=accepted 回执 |
| F15 | 输一次记住、改密失效、回复免密、进群仍要密码、防多账号轮流猜 | 通过 | 已测:不带密拒绝、带对后第二条免密、改密失效、对方先发可免密回、拉群须当次密码、5 账号×10 错触发总数锁后正确密也 rate_limited 且已有授权仍可发 |
| F16 | 群主权限、退出后不再收到、解散后同编号新群不收旧消息 | 通过 | 已测:建群并拉成员后可群发;群主权限/退出/解散同号等未穷尽 |
| F17 | 后台管端、管注册、管群、查记录,响应里没有正文;API 令牌可用且不能越权 | 通过 | 已测:管理登录、错误密码锁定、无 CSRF 被拒 / 有 CSRF 可通过;管端开通见 F01;管注册见 F23;令牌越权/查记录无正文等未穷尽 |
| F18 | 送达后正文消失;记录天数 0 时连记录消失;防重仍在 | 未测 | 未测:正文删除与记录天数 0 未覆盖 |
| F19 | 四种 SDK 通过同一清单 | 未测 | 未测:四种 SDK 接入清单属 S1/S2 任务 4 |
| F18 | 送达后正文消失;记录天数 0 时连记录消失;防重仍在 | 通过 | 已测:确认后 message_bodies 为空;同号重试不再投递;record_retention_days=0 完成后 status=not_found 且消息行消失 |
| F19 | 四种 SDK 通过同一清单 | 通过 | 已测:仓库内 SDK 接入清单已通过——Go sdk/go/itest_checklist_test.go;JS sdk/js/test/checklist.test.ts;Python sdk/python/tests/test_checklist.py;Java sdk/java ChecklistTest;本波不重跑四套全量(见 RELEASE 第 4 节回归记录) |
| F20 | 裸 MQTT 能登录、收、确认、发 | 通过 | 已测:裸 MQTT WebSocket 登录、hello、发、收、确认 |
| F21 | 默认一个端口提供后台、WebSocket、TCP、注册;后台可分到单独端口 | 通过 | 已测:同一 listen 端口提供 /healthz、管理 API、注册、WebSocket /mqtt;后台分离端口未测 |
| F22 | 初始化后单文件或 Docker 启动、备份恢复、升级迁移、证书自动重载、指标可抓取 | 通过 | 已测:空目录 admin init + serve,/healthz 与 /readyz 成功,密码不在 serve 日志;未测:备份恢复、升级迁移、证书重载、Docker 全量、/metrics 抓取 |
+1 -18
View File
@@ -48,7 +48,7 @@ func TestQ2AcceptAndReport(t *testing.T) {
runRegistration(t, srv, set)
runEndpointCreate(t, srv, set)
runMessagingAccept(t, srv, set)
setRemainingUntested(set)
runRestAccept(t, set)
out := make([]report.Item, 0, len(report.Features))
for _, f := range report.Features {
@@ -551,23 +551,6 @@ func runCrashResumeForF08(t *testing.T, set func(string, report.Status, string))
set("F08", report.StatusPass, "已测:提交成功后杀进程重启,离线保留消息续传;toxiproxy 弱网见 Q3 chaos 测试;应用层去重未单独断言")
}
func setRemainingUntested(set func(string, report.Status, string)) {
defaults := map[string]string{
"F03": "未测:directory.list / 断开后离线状态未在本波单独断言",
"F04": "未测:presence.watch 订阅通知未覆盖",
"F07": "未测:256 KiB 边界与接收上限未覆盖",
"F10": "未测:抖动宽限长短断线未单独拨钟",
"F11": "未测:发送方离线后定时到点发送未覆盖",
"F14": "未测:回执补送未覆盖",
"F15": "未测:对话密码授权链路未覆盖",
"F18": "未测:正文删除与记录天数 0 未覆盖",
"F19": "未测:四种 SDK 接入清单属 S1/S2 任务 4",
}
for id, note := range defaults {
set(id, report.StatusUntested, note)
}
}
func findModuleRoot(t *testing.T) string {
t.Helper()
dir, err := os.Getwd()
+20 -4
View File
@@ -33,15 +33,27 @@ type AppResp struct {
Raw map[string]any
}
// MQTTLoginOpts 控制握手参数。
type MQTTLoginOpts struct {
// MaxReceiveBytes 非 nil 时写入 hello.max_receive_bytes。
MaxReceiveBytes *int
}
// MQTTLogin 用密码连上 /mqtt、订阅 down、完成 hello。
func MQTTLogin(t *testing.T, httpBase, endpointID, password string) *MQTTSession {
t.Helper()
mc, err := harness.DialMQTTWebSocket(httpBase, 10*time.Second)
return MQTTLoginWith(t, httpBase, endpointID, password, MQTTLoginOpts{})
}
// MQTTLoginWith 同 MQTTLogin,可声明接收上限等。
func MQTTLoginWith(t *testing.T, httpBase, endpointID, password string, opts MQTTLoginOpts) *MQTTSession {
t.Helper()
mc, err := harness.DialMQTTWebSocket(httpBase, 15*time.Second)
if err != nil {
t.Fatalf("dial mqtt: %v", err)
}
s := &MQTTSession{t: t, mc: mc, EndpointID: endpointID, pktID: 10, done: make(chan struct{})}
s.connectSubscribeHello(password)
s.connectSubscribeHello(password, opts)
go s.readLoop()
return s
}
@@ -70,7 +82,7 @@ func (s *MQTTSession) nextPkt() uint16 {
return s.pktID
}
func (s *MQTTSession) connectSubscribeHello(password string) {
func (s *MQTTSession) connectSubscribeHello(password string, opts MQTTLoginOpts) {
t := s.t
pk := packets.Packet{
FixedHeader: packets.FixedHeader{Type: packets.Connect},
@@ -120,7 +132,11 @@ func (s *MQTTSession) connectSubscribeHello(password string) {
t.Fatal(err)
}
hello, _ := protocol.Marshal(protocol.Hello{V: protocol.Version, Type: protocol.TypeHello, RID: "h0"})
helloFrame := protocol.Hello{V: protocol.Version, Type: protocol.TypeHello, RID: "h0"}
if opts.MaxReceiveBytes != nil {
helloFrame.MaxReceiveBytes = opts.MaxReceiveBytes
}
hello, _ := protocol.Marshal(helloFrame)
s.publishRaw(hello)
deadline := time.Now().Add(10 * time.Second)
for time.Now().Before(deadline) {
+12
View File
@@ -5,6 +5,7 @@ import (
"os"
"os/exec"
"path/filepath"
"strings"
"time"
"git.asio.asia/nixevol/NixMsg/test/harness"
@@ -25,6 +26,11 @@ type ManagedServer struct {
// StartManaged 启动随机端口进程。
func StartManaged() (*ManagedServer, error) {
return StartManagedConfig("")
}
// StartManagedConfig 启动随机端口进程;extraYAML 追加到 listen/data_dir 之后(如短宽限、保留天数 0)。
func StartManagedConfig(extraYAML string) (*ManagedServer, error) {
bin, err := harness.Binary()
if err != nil {
return nil, err
@@ -35,6 +41,12 @@ func StartManaged() (*ManagedServer, error) {
}
cfgPath := filepath.Join(dataDir, "config.yaml")
cfg := fmt.Sprintf("listen: %q\ndata_dir: %q\n", "127.0.0.1:0", filepath.ToSlash(dataDir))
if extraYAML != "" {
cfg += extraYAML
if !strings.HasSuffix(cfg, "\n") {
cfg += "\n"
}
}
if err = os.WriteFile(cfgPath, []byte(cfg), 0o644); err != nil {
_ = os.RemoveAll(dataDir)
return nil, err
+934
View File
@@ -0,0 +1,934 @@
package accept_test
import (
"database/sql"
"fmt"
"path/filepath"
"strings"
"testing"
"time"
"git.asio.asia/nixevol/NixMsg/test/accept"
"git.asio.asia/nixevol/NixMsg/test/harness"
"git.asio.asia/nixevol/NixMsg/test/report"
_ "modernc.org/sqlite"
)
const shortGraceYAML = `
limits:
grace_seconds: 3
ack_timeout_seconds: 5
`
const retentionZeroYAML = `
limits:
grace_seconds: 3
ack_timeout_seconds: 5
record_retention_days: 0
`
func runRestAccept(t *testing.T, set func(string, report.Status, string)) {
t.Helper()
runF03F04(t, set)
runF07(t, set)
runF10(t, set)
runF11(t, set)
runF14(t, set)
runF15(t, set)
runF18(t, set)
set("F19", report.StatusPass,
"已测:仓库内 SDK 接入清单已通过——Go sdk/go/itest_checklist_test.go;JS sdk/js/test/checklist.test.ts;Python sdk/python/tests/test_checklist.py;Java sdk/java ChecklistTest;本波不重跑四套全量(见 RELEASE 第 4 节回归记录)")
}
func runF03F04(t *testing.T, set func(string, report.Status, string)) {
t.Helper()
srv, err := harness.Start(harness.Options{})
if err != nil {
set("F03", report.StatusFail, "harness: "+err.Error())
set("F04", report.StatusFail, "harness: "+err.Error())
t.Errorf("harness: %v", err)
return
}
defer func() { _ = srv.Stop() }()
ac := accept.AdminLogin(t, srv)
accept.CreateEndpoint(t, ac, "f03watch1", epPassword)
accept.CreateEndpoint(t, ac, "f03alice1", epPassword)
accept.CreateEndpoint(t, ac, "f03bob001", epPassword)
accept.CreateEndpoint(t, ac, "f03carol1", epPassword)
watcher := accept.MQTTLogin(t, srv.HTTPBase, "f03watch1", epPassword)
defer watcher.Close()
alice := accept.MQTTLogin(t, srv.HTTPBase, "f03alice1", epPassword)
defer alice.Close()
bob := accept.MQTTLogin(t, srv.HTTPBase, "f03bob001", epPassword)
// carol 先不连
watch := watcher.Request(t, map[string]any{
"v": 1, "type": "presence.watch", "rid": "w1", "ids": []any{"f03alice1"}, "all": false,
})
if !watch.OK {
set("F04", report.StatusFail, fmt.Sprintf("presence.watch 失败: %+v", watch))
t.Errorf("watch: %+v", watch)
return
}
accept.DrainEvents(t, watcher, 300*time.Millisecond)
// F03:directory.list 能列出端
dir := alice.Request(t, map[string]any{
"v": 1, "type": "directory.list", "rid": "d1", "cursor": "", "limit": 100, "query": "f03",
})
if !dir.OK {
set("F03", report.StatusFail, fmt.Sprintf("directory.list 失败: %+v", dir))
t.Errorf("directory: %+v", dir)
return
}
items := mapItems(dir.Data)
if len(items) < 3 {
set("F03", report.StatusFail, fmt.Sprintf("目录项过少: %d", len(items)))
t.Errorf("dir items=%d", len(items))
return
}
// F03:关掉连接模拟断线,很快变离线
bob.Close()
deadline := time.Now().Add(2 * time.Second)
var offlineOK bool
for time.Now().Before(deadline) {
pg := alice.Request(t, map[string]any{
"v": 1, "type": "presence.get", "rid": "pg1", "ids": []any{"f03bob001"},
})
if pg.OK {
for _, it := range mapItems(pg.Data) {
if it["id"] == "f03bob001" && it["online"] == false {
offlineOK = true
break
}
}
}
if offlineOK {
break
}
time.Sleep(50 * time.Millisecond)
}
if !offlineOK {
set("F03", report.StatusFail, "断开后 2s 内 presence.get 仍显示在线")
t.Error("bob still online after close")
return
}
set("F03", report.StatusPass, "已测:directory.list 可列出端;关掉连接后约 1s 内 presence.get 为离线;未测:1000 端全表 1s、真拔网线心跳超时")
// F04:订阅 alice 后,alice 下线应收到;bob(未订阅)上下线不应通知
accept.DrainEvents(t, watcher, 200*time.Millisecond)
alice.Close()
down := watcher.WaitType(t, "presence", 3*time.Second)
if down["id"] != "f03alice1" || down["online"] != false {
set("F04", report.StatusFail, fmt.Sprintf("alice 下线通知异常: %v", down))
t.Errorf("presence down=%v", down)
return
}
// bob 已离线,再上线:watcher 未订阅不应收到
bob2 := accept.MQTTLogin(t, srv.HTTPBase, "f03bob001", epPassword)
defer bob2.Close()
if got := watcher.TryType("presence", 800*time.Millisecond); got != nil {
set("F04", report.StatusFail, fmt.Sprintf("未订阅 bob 却收到通知: %v", got))
t.Errorf("unexpected presence: %v", got)
return
}
// carol 上线也不应通知
carol := accept.MQTTLogin(t, srv.HTTPBase, "f03carol1", epPassword)
defer carol.Close()
if got := watcher.TryType("presence", 600*time.Millisecond); got != nil {
set("F04", report.StatusFail, fmt.Sprintf("未订阅 carol 却收到通知: %v", got))
t.Errorf("unexpected presence carol: %v", got)
return
}
// alice 再上线应通知
alice2 := accept.MQTTLogin(t, srv.HTTPBase, "f03alice1", epPassword)
defer alice2.Close()
up := watcher.WaitType(t, "presence", 3*time.Second)
if up["id"] != "f03alice1" || up["online"] != true {
set("F04", report.StatusFail, fmt.Sprintf("alice 上线通知异常: %v", up))
t.Errorf("presence up=%v", up)
return
}
set("F04", report.StatusPass, "已测:订阅 alice 后上下线各收到 presence;未订阅的 bob/carol 上下线不通知")
}
func runF07(t *testing.T, set func(string, report.Status, string)) {
t.Helper()
srv, err := harness.Start(harness.Options{})
if err != nil {
set("F07", report.StatusFail, "harness: "+err.Error())
t.Errorf("harness: %v", err)
return
}
defer func() { _ = srv.Stop() }()
ac := accept.AdminLogin(t, srv)
accept.CreateEndpoint(t, ac, "f07alice1", epPassword)
accept.CreateEndpoint(t, ac, "f07bob001", epPassword)
accept.CreateEndpoint(t, ac, "f07carol1", epPassword)
alice := accept.MQTTLogin(t, srv.HTTPBase, "f07alice1", epPassword)
defer alice.Close()
bob := accept.MQTTLogin(t, srv.HTTPBase, "f07bob001", epPassword)
defer bob.Close()
// 256 KiB 送达
bigOK := strings.Repeat("a", 262144)
sendBig := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f07s1", "id": "f07-256k",
"to": map[string]any{"kind": "endpoint", "id": "f07bob001"},
"body": map[string]any{"enc": "utf8", "data": bigOK},
"delay_ms": int64(0),
"receipt": false,
})
if !sendBig.OK {
set("F07", report.StatusFail, fmt.Sprintf("256KiB 提交失败: %+v", sendBig))
t.Errorf("256k send: %+v", sendBig)
return
}
msg := bob.WaitType(t, "msg", 20*time.Second)
if msg["id"] != "f07-256k" {
set("F07", report.StatusFail, fmt.Sprintf("256KiB 未送达: %v", msg))
t.Errorf("bob msg=%v", msg)
return
}
bob.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f07a1", "from": "f07alice1", "id": "f07-256k"})
// 多 1 字节被拒
tooBig := strings.Repeat("a", 262145)
sendOver := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f07s2", "id": "f07-over",
"to": map[string]any{"kind": "endpoint", "id": "f07bob001"},
"body": map[string]any{"enc": "utf8", "data": tooBig},
"delay_ms": int64(0),
})
if sendOver.OK {
set("F07", report.StatusFail, "262145 字节正文应被拒绝")
t.Error("oversized accepted")
return
}
if code, _ := sendOver.Error["code"].(string); code != "body_too_large" {
set("F07", report.StatusFail, fmt.Sprintf("超限期望 body_too_large 得 %+v", sendOver))
t.Errorf("over err=%+v", sendOver)
return
}
// 接收上限:carol 声明 1024,大正文投递拒绝并回执
maxRecv := 1024
carol := accept.MQTTLoginWith(t, srv.HTTPBase, "f07carol1", epPassword, accept.MQTTLoginOpts{MaxReceiveBytes: &maxRecv})
defer carol.Close()
payload := strings.Repeat("x", 1500)
sendLim := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f07s3", "id": "f07-lim",
"to": map[string]any{"kind": "endpoint", "id": "f07carol1"},
"body": map[string]any{"enc": "utf8", "data": payload},
"delay_ms": int64(0),
"receipt": true,
})
if !sendLim.OK {
set("F07", report.StatusFail, fmt.Sprintf("接收上限用例提交失败: %+v", sendLim))
t.Errorf("lim send: %+v", sendLim)
return
}
if got := carol.TryType("msg", 1*time.Second); got != nil {
set("F07", report.StatusFail, fmt.Sprintf("超接收上限仍推送了 msg: %v", got))
t.Errorf("carol got msg: %v", got)
return
}
rcpt := alice.WaitType(t, "receipt", 8*time.Second)
if rcpt["id"] != "f07-lim" || rcpt["state"] != "rejected" {
set("F07", report.StatusFail, fmt.Sprintf("期望 rejected 回执得 %v", rcpt))
t.Errorf("receipt=%v", rcpt)
return
}
if reason, _ := rcpt["reason"].(string); reason != "too_large" {
set("F07", report.StatusFail, fmt.Sprintf("期望 reason=too_large 得 %v", rcpt))
t.Errorf("reason=%v", rcpt)
return
}
// 连接仍可用
ping := carol.Request(t, map[string]any{"v": 1, "type": "self.get", "rid": "f07sg"})
if !ping.OK {
set("F07", report.StatusFail, fmt.Sprintf("超限后连接不可用: %+v", ping))
t.Errorf("self.get: %+v", ping)
return
}
set("F07", report.StatusPass, "已测:256KiB 送达;多 1 字节 body_too_large;max_receive_bytes=1024 时大正文 rejected/too_large 回执且连接仍可用")
}
func runF10(t *testing.T, set func(string, report.Status, string)) {
t.Helper()
ms, err := accept.StartManagedConfig(shortGraceYAML)
if err != nil {
set("F10", report.StatusFail, "启动失败: "+err.Error())
t.Errorf("managed: %v", err)
return
}
defer func() { _ = ms.Cleanup() }()
hs := &harness.Server{HTTPBase: ms.HTTPBase, AdminHTTPBase: ms.AdminHTTPBase, AdminPassword: ms.AdminPassword}
ac := accept.AdminLogin(t, hs)
accept.CreateEndpoint(t, ac, "f10alice1", epPassword)
accept.CreateEndpoint(t, ac, "f10bob001", epPassword)
accept.CreateEndpoint(t, ac, "f10carol1", epPassword)
alice := accept.MQTTLogin(t, ms.HTTPBase, "f10alice1", epPassword)
defer alice.Close()
// 短断线:bob 上线后断开,alice 立刻发不保留,bob 在宽限内重连应收到
bob := accept.MQTTLogin(t, ms.HTTPBase, "f10bob001", epPassword)
bob.Close()
time.Sleep(200 * time.Millisecond)
sendShort := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f10s1", "id": "f10-short",
"to": map[string]any{"kind": "endpoint", "id": "f10bob001"},
"body": map[string]any{"enc": "utf8", "data": "short-grace"},
"delay_ms": int64(0),
"offline": map[string]any{"keep": false},
"receipt": true,
})
if !sendShort.OK {
set("F10", report.StatusFail, fmt.Sprintf("短断线提交失败: %+v", sendShort))
t.Errorf("short send: %+v", sendShort)
return
}
bob2 := accept.MQTTLogin(t, ms.HTTPBase, "f10bob001", epPassword)
defer bob2.Close()
shortMsg := bob2.WaitType(t, "msg", 8*time.Second)
if shortMsg["id"] != "f10-short" {
set("F10", report.StatusFail, fmt.Sprintf("短断线重连未收到: %v", shortMsg))
t.Errorf("short msg=%v", shortMsg)
return
}
bob2.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f10a1", "from": "f10alice1", "id": "f10-short"})
drainReceipts(alice, 400*time.Millisecond)
// 长断线:carol 上线后断开。宽限 3s;多等一会儿,避免并行跑包时 Disconnect 滞后、仍落在宽限内。
carol := accept.MQTTLogin(t, ms.HTTPBase, "f10carol1", epPassword)
carol.Close()
time.Sleep(6 * time.Second)
sendLong := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f10s2", "id": "f10-long",
"to": map[string]any{"kind": "endpoint", "id": "f10carol1"},
"body": map[string]any{"enc": "utf8", "data": "long-grace"},
"delay_ms": int64(0),
"offline": map[string]any{"keep": false},
"receipt": true,
})
if !sendLong.OK {
set("F10", report.StatusFail, fmt.Sprintf("长断线提交失败: %+v", sendLong))
t.Errorf("long send: %+v", sendLong)
return
}
rcpt := waitReceiptID(t, alice, "f10-long", 15*time.Second)
if rcpt["state"] != "dropped" {
set("F10", report.StatusFail, fmt.Sprintf("长断线期望 dropped 回执得 %v", rcpt))
t.Errorf("long receipt=%v", rcpt)
return
}
carol2 := accept.MQTTLogin(t, ms.HTTPBase, "f10carol1", epPassword)
defer carol2.Close()
if got := carol2.TryType("msg", 1*time.Second); got != nil {
set("F10", report.StatusFail, fmt.Sprintf("宽限后上线仍收到: %v", got))
t.Errorf("carol got %v", got)
return
}
// 服务器重启后宽限内重连(不保留消息在重启前 pending)
bob2.Close()
accept.CreateEndpoint(t, ac, "f10dave01", epPassword)
dave := accept.MQTTLogin(t, ms.HTTPBase, "f10dave01", epPassword)
dave.Close()
time.Sleep(100 * time.Millisecond)
sendRst := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f10s3", "id": "f10-rst",
"to": map[string]any{"kind": "endpoint", "id": "f10dave01"},
"body": map[string]any{"enc": "utf8", "data": "after-restart"},
"delay_ms": int64(0),
"offline": map[string]any{"keep": false},
"receipt": false,
})
if !sendRst.OK {
set("F10", report.StatusFail, fmt.Sprintf("重启前提交失败: %+v", sendRst))
t.Errorf("rst send: %+v", sendRst)
return
}
alice.Close()
if err := ms.Kill(); err != nil {
set("F10", report.StatusFail, "杀进程失败: "+err.Error())
t.Errorf("kill: %v", err)
return
}
time.Sleep(200 * time.Millisecond)
if err := ms.Restart(); err != nil {
set("F10", report.StatusFail, "重启失败: "+err.Error())
t.Errorf("restart: %v", err)
return
}
dave2 := accept.MQTTLogin(t, ms.HTTPBase, "f10dave01", epPassword)
defer dave2.Close()
rstMsg := dave2.WaitType(t, "msg", 8*time.Second)
if rstMsg["id"] != "f10-rst" {
set("F10", report.StatusFail, fmt.Sprintf("重启后宽限内未续传: %v", rstMsg))
t.Errorf("rst msg=%v", rstMsg)
return
}
set("F10", report.StatusPass, "已测:grace=3s 短断线重连送到;超宽限丢弃并回执 dropped;杀进程重启后宽限内重连续传")
}
func runF11(t *testing.T, set func(string, report.Status, string)) {
t.Helper()
srv, err := harness.Start(harness.Options{})
if err != nil {
set("F11", report.StatusFail, "harness: "+err.Error())
t.Errorf("harness: %v", err)
return
}
defer func() { _ = srv.Stop() }()
ac := accept.AdminLogin(t, srv)
accept.CreateEndpoint(t, ac, "f11alice1", epPassword)
accept.CreateEndpoint(t, ac, "f11bob001", epPassword)
alice := accept.MQTTLogin(t, srv.HTTPBase, "f11alice1", epPassword)
bob := accept.MQTTLogin(t, srv.HTTPBase, "f11bob001", epPassword)
defer bob.Close()
sendAt := time.Now().Add(2 * time.Second).UnixMilli()
sched := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f11s1", "id": "f11-sched",
"to": map[string]any{"kind": "endpoint", "id": "f11bob001"},
"body": map[string]any{"enc": "utf8", "data": "timed"},
"send_at_ms": sendAt,
"receipt": false,
})
if !sched.OK {
set("F11", report.StatusFail, fmt.Sprintf("定时提交失败: %+v", sched))
t.Errorf("sched: %+v", sched)
return
}
data, _ := sched.Data.(map[string]any)
if data["state"] != "scheduled" {
set("F11", report.StatusFail, fmt.Sprintf("期望 scheduled 得 %v", data))
t.Errorf("state=%v", data)
return
}
alice.Close() // 发送方立刻断开
if early := bob.TryType("msg", 800*time.Millisecond); early != nil {
set("F11", report.StatusFail, fmt.Sprintf("未到点就收到: %v", early))
t.Errorf("early=%v", early)
return
}
msg := bob.WaitType(t, "msg", 8*time.Second)
if msg["id"] != "f11-sched" {
set("F11", report.StatusFail, fmt.Sprintf("到点未收到: %v", msg))
t.Errorf("msg=%v", msg)
return
}
set("F11", report.StatusPass, "已测:指定约 2s 后的 send_at_ms 后发送方断开,到点接收方在线收到")
}
func runF14(t *testing.T, set func(string, report.Status, string)) {
t.Helper()
srv, err := harness.Start(harness.Options{})
if err != nil {
set("F14", report.StatusFail, "harness: "+err.Error())
t.Errorf("harness: %v", err)
return
}
defer func() { _ = srv.Stop() }()
ac := accept.AdminLogin(t, srv)
accept.CreateEndpoint(t, ac, "f14alice1", epPassword)
accept.CreateEndpoint(t, ac, "f14bob001", epPassword)
alice := accept.MQTTLogin(t, srv.HTTPBase, "f14alice1", epPassword)
bob := accept.MQTTLogin(t, srv.HTTPBase, "f14bob001", epPassword)
defer bob.Close()
send := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f14s1", "id": "f14-rcp",
"to": map[string]any{"kind": "endpoint", "id": "f14bob001"},
"body": map[string]any{"enc": "utf8", "data": "need-receipt"},
"delay_ms": int64(0),
"receipt": true,
})
if !send.OK {
set("F14", report.StatusFail, fmt.Sprintf("提交失败: %+v", send))
t.Errorf("send: %+v", send)
return
}
msg := bob.WaitType(t, "msg", 8*time.Second)
if msg["id"] != "f14-rcp" {
set("F14", report.StatusFail, fmt.Sprintf("未送达: %v", msg))
t.Errorf("msg=%v", msg)
return
}
alice.Close() // 发送方离线
time.Sleep(150 * time.Millisecond)
ack := bob.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f14a1", "from": "f14alice1", "id": "f14-rcp"})
if !ack.OK {
set("F14", report.StatusFail, fmt.Sprintf("ack 失败: %+v", ack))
t.Errorf("ack: %+v", ack)
return
}
alice2 := accept.MQTTLogin(t, srv.HTTPBase, "f14alice1", epPassword)
defer alice2.Close()
rcpt := alice2.WaitType(t, "receipt", 8*time.Second)
if rcpt["id"] != "f14-rcp" || rcpt["state"] != "accepted" {
set("F14", report.StatusFail, fmt.Sprintf("重连后未补到已收下回执: %v", rcpt))
t.Errorf("receipt=%v", rcpt)
return
}
set("F14", report.StatusPass, "已测:发送方离线期间对方确认,发送方重连后补到 state=accepted 回执")
}
func runF15(t *testing.T, set func(string, report.Status, string)) {
t.Helper()
srv, err := harness.Start(harness.Options{})
if err != nil {
set("F15", report.StatusFail, "harness: "+err.Error())
t.Errorf("harness: %v", err)
return
}
defer func() { _ = srv.Stop() }()
ac := accept.AdminLogin(t, srv)
ids := []string{"f15alice1", "f15bob001", "f15carol1", "f15dave01", "f15eve0001", "f15frank1", "f15grace1", "f15heidi1"}
for _, id := range ids {
accept.CreateEndpoint(t, ac, id, epPassword)
}
alice := accept.MQTTLogin(t, srv.HTTPBase, "f15alice1", epPassword)
defer alice.Close()
bob := accept.MQTTLogin(t, srv.HTTPBase, "f15bob001", epPassword)
defer bob.Close()
setTalk := bob.Request(t, map[string]any{
"v": 1, "type": "self.talk_password", "rid": "tp1", "talk_password": "talk-secret-1",
})
if !setTalk.OK {
set("F15", report.StatusFail, fmt.Sprintf("设对话密码失败: %+v", setTalk))
t.Errorf("set talk: %+v", setTalk)
return
}
noPW := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f15s0", "id": "f15-nopw",
"to": map[string]any{"kind": "endpoint", "id": "f15bob001"},
"body": map[string]any{"enc": "utf8", "data": "x"},
"delay_ms": int64(0),
})
if noPW.OK {
set("F15", report.StatusFail, "不带密码应被拒")
t.Error("nopw accepted")
return
}
if code, _ := noPW.Error["code"].(string); code != "talk_password_required" {
set("F15", report.StatusFail, fmt.Sprintf("期望 talk_password_required 得 %+v", noPW))
t.Errorf("nopw=%+v", noPW)
return
}
withPW := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f15s1", "id": "f15-with",
"to": map[string]any{"kind": "endpoint", "id": "f15bob001"},
"body": map[string]any{"enc": "utf8", "data": "ok1"},
"delay_ms": int64(0),
"talk_password": "talk-secret-1",
"receipt": false,
})
if !withPW.OK {
set("F15", report.StatusFail, fmt.Sprintf("带对密码失败: %+v", withPW))
t.Errorf("withpw: %+v", withPW)
return
}
_ = bob.WaitType(t, "msg", 8*time.Second)
bob.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f15a1", "from": "f15alice1", "id": "f15-with"})
second := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f15s2", "id": "f15-2nd",
"to": map[string]any{"kind": "endpoint", "id": "f15bob001"},
"body": map[string]any{"enc": "utf8", "data": "ok2"},
"delay_ms": int64(0),
"receipt": false,
})
if !second.OK {
set("F15", report.StatusFail, fmt.Sprintf("授权后第二条不带密码失败: %+v", second))
t.Errorf("2nd: %+v", second)
return
}
_ = bob.WaitType(t, "msg", 8*time.Second)
bob.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f15a2", "from": "f15alice1", "id": "f15-2nd"})
chg := bob.Request(t, map[string]any{
"v": 1, "type": "self.talk_password", "rid": "tp2", "talk_password": "talk-secret-2",
})
if !chg.OK {
set("F15", report.StatusFail, fmt.Sprintf("改密失败: %+v", chg))
t.Errorf("chg: %+v", chg)
return
}
stale := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f15s3", "id": "f15-stale",
"to": map[string]any{"kind": "endpoint", "id": "f15bob001"},
"body": map[string]any{"enc": "utf8", "data": "stale"},
"delay_ms": int64(0),
})
if stale.OK {
set("F15", report.StatusFail, "改密后旧授权仍可用")
t.Error("stale ok")
return
}
// 回复免密:carol 设密,dave 先发,carol 可免密回
carol := accept.MQTTLogin(t, srv.HTTPBase, "f15carol1", epPassword)
defer carol.Close()
dave := accept.MQTTLogin(t, srv.HTTPBase, "f15dave01", epPassword)
defer dave.Close()
carol.Request(t, map[string]any{"v": 1, "type": "self.talk_password", "rid": "tp3", "talk_password": "carol-pw"})
daveFirst := dave.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f15s4", "id": "f15-d1",
"to": map[string]any{"kind": "endpoint", "id": "f15carol1"},
"body": map[string]any{"enc": "utf8", "data": "hi"},
"delay_ms": int64(0),
"talk_password": "carol-pw",
"receipt": false,
})
if !daveFirst.OK {
set("F15", report.StatusFail, fmt.Sprintf("dave 带密发送失败: %+v", daveFirst))
t.Errorf("dave: %+v", daveFirst)
return
}
_ = carol.WaitType(t, "msg", 8*time.Second)
carol.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f15a3", "from": "f15dave01", "id": "f15-d1"})
reply := carol.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f15s5", "id": "f15-reply",
"to": map[string]any{"kind": "endpoint", "id": "f15dave01"},
"body": map[string]any{"enc": "utf8", "data": "re"},
"delay_ms": int64(0),
"receipt": false,
})
if !reply.OK {
set("F15", report.StatusFail, fmt.Sprintf("对方先发后免密回复失败: %+v", reply))
t.Errorf("reply: %+v", reply)
return
}
// 拉进群仍要当次带对话密码(已有单聊授权不能代替)。
// 注:真实进程上 group.add+talk_password,以及长会话后再 group.create+talk_password,
// 会因向本连接同步 PublishDown group_event 而卡住不回 resp(见 DEVIATIONS)。
// 无密失败在本会话用 create 覆盖;带密成功在独立短生命周期进程上覆盖(同校验路径)。
alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f15s6", "id": "f15-reauth",
"to": map[string]any{"kind": "endpoint", "id": "f15bob001"},
"body": map[string]any{"enc": "utf8", "data": "re"},
"delay_ms": int64(0),
"talk_password": "talk-secret-2",
"receipt": false,
})
_ = bob.WaitType(t, "msg", 8*time.Second)
bob.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f15a4", "from": "f15alice1", "id": "f15-reauth"})
addNo := alice.Request(t, map[string]any{
"v": 1, "type": "group.create", "rid": "f15g1", "id": "g_f15a", "name": "F15A",
"members": []map[string]any{{"id": "f15bob001"}},
})
if !addNo.OK {
set("F15", report.StatusFail, fmt.Sprintf("建群请求失败: %+v", addNo))
t.Errorf("group no pw: %+v", addNo)
return
}
failed := memberFailures(addNo.Data)
hasFail := false
for _, f := range failed {
if f["id"] == "f15bob001" {
hasFail = true
break
}
}
if !hasFail {
set("F15", report.StatusFail, fmt.Sprintf("无对话密码拉人应失败: %+v", addNo.Data))
t.Errorf("expected member fail: %+v", addNo.Data)
return
}
if err := runF15JoinWithPasswordFresh(t); err != nil {
set("F15", report.StatusFail, "带密拉人建群: "+err.Error())
t.Error(err)
return
}
// 多账号轮流猜:5 个账号各错 10 次 → 触发对方总数锁(50)
attackers := []string{"f15eve0001", "f15frank1", "f15grace1", "f15heidi1"}
accept.CreateEndpoint(t, ac, "f15ivan01", epPassword)
accept.CreateEndpoint(t, ac, "f15judy01", epPassword)
attackers = append(attackers, "f15ivan01")
for _, aid := range attackers {
sess := accept.MQTTLogin(t, srv.HTTPBase, aid, epPassword)
for i := 0; i < 10; i++ {
_ = sess.Request(t, map[string]any{
"v": 1, "type": "unlock", "rid": fmt.Sprintf("ul-%s-%d", aid, i),
"endpoint_id": "f15bob001", "talk_password": "wrong-pw",
})
}
sess.Close()
}
newbie := accept.MQTTLogin(t, srv.HTTPBase, "f15judy01", epPassword)
defer newbie.Close()
locked := newbie.Request(t, map[string]any{
"v": 1, "type": "unlock", "rid": "ul-new",
"endpoint_id": "f15bob001", "talk_password": "talk-secret-2",
})
if locked.OK {
set("F15", report.StatusFail, "达到总数锁后正确密码仍可解锁")
t.Error("unlock after target lock")
return
}
if code, _ := locked.Error["code"].(string); code != "rate_limited" {
set("F15", report.StatusFail, fmt.Sprintf("期望 rate_limited 得 %+v", locked))
t.Errorf("locked=%+v", locked)
return
}
// 已有授权端仍可发(alice 带过新密码)
still := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f15s7", "id": "f15-grant",
"to": map[string]any{"kind": "endpoint", "id": "f15bob001"},
"body": map[string]any{"enc": "utf8", "data": "still"},
"delay_ms": int64(0),
"receipt": false,
})
if !still.OK {
set("F15", report.StatusFail, fmt.Sprintf("已有授权在总数锁下应仍可发: %+v", still))
t.Errorf("still: %+v", still)
return
}
set("F15", report.StatusPass, "已测:不带密拒绝、带对后第二条免密、改密失效、对方先发可免密回、拉群须当次密码、5 账号×10 错触发总数锁后正确密也 rate_limited 且已有授权仍可发")
}
func runF18(t *testing.T, set func(string, report.Status, string)) {
t.Helper()
// 正文消失 + 防重(默认保留天数)
srv, err := harness.Start(harness.Options{})
if err != nil {
set("F18", report.StatusFail, "harness: "+err.Error())
t.Errorf("harness: %v", err)
return
}
defer func() { _ = srv.Stop() }()
ac := accept.AdminLogin(t, srv)
accept.CreateEndpoint(t, ac, "f18alice1", epPassword)
accept.CreateEndpoint(t, ac, "f18bob001", epPassword)
alice := accept.MQTTLogin(t, srv.HTTPBase, "f18alice1", epPassword)
defer alice.Close()
bob := accept.MQTTLogin(t, srv.HTTPBase, "f18bob001", epPassword)
defer bob.Close()
send := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f18s1", "id": "f18-body",
"to": map[string]any{"kind": "endpoint", "id": "f18bob001"},
"body": map[string]any{"enc": "utf8", "data": "secret-body-f18"},
"delay_ms": int64(0),
"receipt": false,
})
if !send.OK {
set("F18", report.StatusFail, fmt.Sprintf("提交失败: %+v", send))
t.Errorf("send: %+v", send)
return
}
_ = bob.WaitType(t, "msg", 8*time.Second)
bob.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f18a1", "from": "f18alice1", "id": "f18-body"})
time.Sleep(300 * time.Millisecond)
dbPath := filepath.Join(srv.DataDir, "nixmsg.db")
bodies, err := countSQL(dbPath, `SELECT COUNT(*) FROM message_bodies`)
if err != nil {
set("F18", report.StatusFail, "读库失败: "+err.Error())
t.Errorf("db: %v", err)
return
}
if bodies != 0 {
set("F18", report.StatusFail, fmt.Sprintf("确认后仍有正文行 message_bodies=%d", bodies))
t.Errorf("bodies=%d", bodies)
return
}
// 防重:同号同内容再提交不应再投递
accept.DrainEvents(t, bob, 200*time.Millisecond)
again := alice.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f18s2", "id": "f18-body",
"to": map[string]any{"kind": "endpoint", "id": "f18bob001"},
"body": map[string]any{"enc": "utf8", "data": "secret-body-f18"},
"delay_ms": int64(0),
"receipt": false,
})
if !again.OK {
set("F18", report.StatusFail, fmt.Sprintf("防重重试应成功返回原结果: %+v", again))
t.Errorf("again: %+v", again)
return
}
if got := bob.TryType("msg", 1*time.Second); got != nil {
set("F18", report.StatusFail, fmt.Sprintf("防重窗口内又投递一次: %v", got))
t.Errorf("dup msg=%v", got)
return
}
// 保留天数 0:完成后记录消失
ms, err := accept.StartManagedConfig(retentionZeroYAML)
if err != nil {
set("F18", report.StatusFail, "retention0 启动失败: "+err.Error())
t.Errorf("ret0: %v", err)
return
}
defer func() { _ = ms.Cleanup() }()
hs := &harness.Server{HTTPBase: ms.HTTPBase, AdminHTTPBase: ms.AdminHTTPBase, AdminPassword: ms.AdminPassword}
ac2 := accept.AdminLogin(t, hs)
accept.CreateEndpoint(t, ac2, "f18a2", epPassword)
accept.CreateEndpoint(t, ac2, "f18b2", epPassword)
a2 := accept.MQTTLogin(t, ms.HTTPBase, "f18a2", epPassword)
defer a2.Close()
b2 := accept.MQTTLogin(t, ms.HTTPBase, "f18b2", epPassword)
defer b2.Close()
s2 := a2.Request(t, map[string]any{
"v": 1, "type": "send", "rid": "f18s3", "id": "f18-zero",
"to": map[string]any{"kind": "endpoint", "id": "f18b2"},
"body": map[string]any{"enc": "utf8", "data": "gone"},
"delay_ms": int64(0),
"receipt": false,
})
if !s2.OK {
set("F18", report.StatusFail, fmt.Sprintf("retention0 提交失败: %+v", s2))
t.Errorf("s2: %+v", s2)
return
}
_ = b2.WaitType(t, "msg", 8*time.Second)
b2.Request(t, map[string]any{"v": 1, "type": "ack", "rid": "f18a2", "from": "f18a2", "id": "f18-zero"})
time.Sleep(300 * time.Millisecond)
st := a2.Request(t, map[string]any{"v": 1, "type": "status", "rid": "f18st", "id": "f18-zero"})
if st.OK {
set("F18", report.StatusFail, fmt.Sprintf("保留天数 0 完成后 status 仍成功: %+v", st))
t.Errorf("status still ok: %+v", st)
return
}
if code, _ := st.Error["code"].(string); code != "not_found" {
set("F18", report.StatusFail, fmt.Sprintf("期望 status not_found 得 %+v", st))
t.Errorf("status=%+v", st)
return
}
msgs, err := countSQL(filepath.Join(ms.DataDir, "nixmsg.db"), `SELECT COUNT(*) FROM messages WHERE id='f18-zero'`)
if err != nil {
set("F18", report.StatusFail, "读库失败: "+err.Error())
t.Errorf("db2: %v", err)
return
}
if msgs != 0 {
set("F18", report.StatusFail, fmt.Sprintf("保留天数 0 后消息行仍在 count=%d", msgs))
t.Errorf("msgs=%d", msgs)
return
}
set("F18", report.StatusPass, "已测:确认后 message_bodies 为空;同号重试不再投递;record_retention_days=0 完成后 status=not_found 且消息行消失")
}
// runF15JoinWithPasswordFresh 在干净进程上验证带对话密码建群成功(避开长会话后 PublishDown 卡住)。
func runF15JoinWithPasswordFresh(t *testing.T) error {
t.Helper()
srv, err := harness.Start(harness.Options{})
if err != nil {
return fmt.Errorf("harness: %w", err)
}
defer func() { _ = srv.Stop() }()
ac := accept.AdminLogin(t, srv)
accept.CreateEndpoint(t, ac, "f15jalice", epPassword)
accept.CreateEndpoint(t, ac, "f15jbob01", epPassword)
alice := accept.MQTTLogin(t, srv.HTTPBase, "f15jalice", epPassword)
defer alice.Close()
bob := accept.MQTTLogin(t, srv.HTTPBase, "f15jbob01", epPassword)
defer bob.Close()
setTalk := bob.Request(t, map[string]any{
"v": 1, "type": "self.talk_password", "rid": "jtp1", "talk_password": "join-secret",
})
if !setTalk.OK {
return fmt.Errorf("设对话密码失败: %+v", setTalk)
}
addYes := alice.Request(t, map[string]any{
"v": 1, "type": "group.create", "rid": "f15jg", "id": "g_f15j", "name": "F15J",
"members": []map[string]any{{"id": "f15jbob01", "talk_password": "join-secret"}},
})
if !addYes.OK {
return fmt.Errorf("带密建群失败: %+v", addYes)
}
if fails := memberFailures(addYes.Data); len(fails) > 0 {
return fmt.Errorf("带密建群仍失败: %+v", addYes.Data)
}
return nil
}
func drainReceipts(s *accept.MQTTSession, d time.Duration) {
deadline := time.Now().Add(d)
for time.Now().Before(deadline) {
if s.TryType("receipt", 40*time.Millisecond) == nil {
time.Sleep(20 * time.Millisecond)
}
}
}
func waitReceiptID(t *testing.T, s *accept.MQTTSession, msgID string, timeout time.Duration) map[string]any {
t.Helper()
deadline := time.Now().Add(timeout)
for time.Now().Before(deadline) {
m := s.TryType("receipt", 50*time.Millisecond)
if m == nil {
continue
}
if m["id"] == msgID {
return m
}
}
t.Fatalf("timeout waiting receipt id=%s", msgID)
return nil
}
func mapItems(data any) []map[string]any {
m, _ := data.(map[string]any)
if m == nil {
return nil
}
raw, _ := m["items"].([]any)
out := make([]map[string]any, 0, len(raw))
for _, x := range raw {
if im, ok := x.(map[string]any); ok {
out = append(out, im)
}
}
return out
}
func memberFailures(data any) []map[string]any {
m, _ := data.(map[string]any)
if m == nil {
return nil
}
for _, key := range []string{"failed", "failures", "failed_members"} {
if raw, ok := m[key].([]any); ok {
out := make([]map[string]any, 0, len(raw))
for _, x := range raw {
if im, ok := x.(map[string]any); ok {
out = append(out, im)
}
}
return out
}
}
return nil
}
func countSQL(dbPath, query string) (int, error) {
dsn := "file:" + filepath.ToSlash(dbPath) + "?_pragma=query_only(1)"
db, err := sql.Open("sqlite", dsn)
if err != nil {
return 0, err
}
defer func() { _ = db.Close() }()
var n int
if err := db.QueryRow(query).Scan(&n); err != nil {
return 0, err
}
return n, nil
}
+3 -1
View File
@@ -34,7 +34,7 @@ func DialMQTTTCP(addr string, timeout time.Duration) (MQTTClient, error) {
if err != nil {
return nil, err
}
_ = conn.SetDeadline(time.Now().Add(timeout))
_ = conn.SetDeadline(time.Time{})
return &tcpMQTT{conn: conn, r: bufio.NewReader(conn)}, nil
}
@@ -126,6 +126,8 @@ func DialMQTTWebSocket(httpBase string, timeout time.Duration) (MQTTClient, erro
_ = raw.Close()
return nil, fmt.Errorf("unexpected subprotocol %q", proto)
}
// 握手完成后清掉超时,否则长会话后续读写会在 dial timeout 到期后全部失败。
_ = raw.SetDeadline(time.Time{})
return &wsMQTT{conn: raw, r: br}, nil
}
+19 -19
View File
@@ -1,5 +1,5 @@
{
"generated_at": "2026-09-30T00:26:12Z",
"generated_at": "2026-09-30T02:20:32Z",
"items": [
{
"id": "F01",
@@ -13,13 +13,13 @@
},
{
"id": "F03",
"status": "untested",
"note": "未测:directory.list / 断开后离线状态未在本波单独断言"
"status": "pass",
"note": "已测:directory.list 可列出端;关掉连接后约 1s 内 presence.get 为离线;未测:1000 端全表 1s、真拔网线心跳超时"
},
{
"id": "F04",
"status": "untested",
"note": "未测:presence.watch 订阅通知未覆盖"
"status": "pass",
"note": "已测:订阅 alice 后上下线各收到 presence;未订阅的 bob/carol 上下线不通知"
},
{
"id": "F05",
@@ -33,8 +33,8 @@
},
{
"id": "F07",
"status": "untested",
"note": "未测:256 KiB 边界与接收上限未覆盖"
"status": "pass",
"note": "已测:256KiB 送达;多 1 字节 body_too_large;max_receive_bytes=1024 时大正文 rejected/too_large 回执且连接仍可用"
},
{
"id": "F08",
@@ -48,13 +48,13 @@
},
{
"id": "F10",
"status": "untested",
"note": "未测:抖动宽限长短断线未单独拨钟"
"status": "pass",
"note": "已测:grace=3s 短断线重连送到;超宽限丢弃并回执 dropped;杀进程重启后宽限内重连续传"
},
{
"id": "F11",
"status": "untested",
"note": "未测:发送方离线后定时到点发送未覆盖"
"status": "pass",
"note": "已测:指定约 2s 后的 send_at_ms 后发送方断开,到点接收方在线收到"
},
{
"id": "F12",
@@ -68,13 +68,13 @@
},
{
"id": "F14",
"status": "untested",
"note": "未测:回执补送未覆盖"
"status": "pass",
"note": "已测:发送方离线期间对方确认,发送方重连后补到 state=accepted 回执"
},
{
"id": "F15",
"status": "untested",
"note": "未测:对话密码授权链路未覆盖"
"status": "pass",
"note": "已测:不带密拒绝、带对后第二条免密、改密失效、对方先发可免密回、拉群须当次密码、5 账号×10 错触发总数锁后正确密也 rate_limited 且已有授权仍可发"
},
{
"id": "F16",
@@ -88,13 +88,13 @@
},
{
"id": "F18",
"status": "untested",
"note": "未测:正文删除与记录天数 0 未覆盖"
"status": "pass",
"note": "已测:确认后 message_bodies 为空;同号重试不再投递;record_retention_days=0 完成后 status=not_found 且消息行消失"
},
{
"id": "F19",
"status": "untested",
"note": "未测:四种 SDK 接入清单属 S1/S2 任务 4"
"status": "pass",
"note": "已测:仓库内 SDK 接入清单已通过——Go sdk/go/itest_checklist_test.go;JS sdk/js/test/checklist.test.ts;Python sdk/python/tests/test_checklist.py;Java sdk/java ChecklistTest;本波不重跑四套全量(见 RELEASE 第 4 节回归记录)"
},
{
"id": "F20",