Compare commits
10
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
 CNWei
|
061ceff4b8 | ||
|
CNWei
|
9c1d0e16b4 | ||
 CNWeiandClaude Opus 4.6
|
b579a835de | ||
|
CNWei
|
e218ab04fe | ||
|
CNWei
|
18e0ccad58 | ||
|
CNWei
|
3097a16465 | ||
|
CNWei
|
5f3269bad5 | ||
|
CNWei
|
1775d3659d | ||
|
CNWei
|
748cfa8e7f | ||
|
CNWei
|
9a48c156c8 |
@@ -0,0 +1,76 @@
|
||||
# Mock Server 开发指南
|
||||
|
||||
## 构建与测试命令
|
||||
|
||||
```bash
|
||||
cargo build # 构建项目
|
||||
cargo run # 启动服务 http://127.0.0.1:8080
|
||||
cargo test # 运行所有测试
|
||||
cargo test <pattern> # 运行匹配的测试（如 `cargo test router`）
|
||||
cargo clippy # 代码检查
|
||||
cargo fmt # 格式化代码
|
||||
```
|
||||
|
||||
## 架构
|
||||
|
||||
```
|
||||
┌─────────────┐ ┌──────────────┐ ┌────────────────┐
|
||||
│ loader.rs │───▶│ router.rs │───▶│ handler.rs │
|
||||
│ YAML → 索引 │ │ HashMap 索引 │ │ 请求/响应处理 │
|
||||
└─────────────┘ └──────────────┘ └────────────────┘
|
||||
▲ │
|
||||
│ ┌──────────────────┐ │
|
||||
└─────────│ main.rs │◀─────────┘
|
||||
热重载 │ AppState(RwLock)│
|
||||
└──────────────────┘
|
||||
```
|
||||
|
||||
**数据流：**
|
||||
|
||||
1. `MockLoader` 扫描 `mocks/` 目录，解析 YAML 为 `MockRule` 结构体
|
||||
2. 规则按路径首段建立索引（如 `/api/users` → key: `api`）存储于 `MockRouter`
|
||||
3. 请求匹配顺序：method → path → query_params → headers → body
|
||||
4. `AppState` 使用 `RwLock` 包装 router，支持线程安全的热重载
|
||||
|
||||
## 核心类型 (config.rs)
|
||||
|
||||
- `MockRule`: 完整规则（id, request, response, settings）
|
||||
- `RequestMatcher`: 请求匹配条件（method, path, query_params, headers, body）
|
||||
- `MockResponse`: 响应配置（status, headers, body）
|
||||
- `MockSource`: 枚举类型，支持单接口/多接口 YAML 格式
|
||||
|
||||
## 请求匹配 (router.rs)
|
||||
|
||||
- 路径首段 HashMap 查找，O(1) 获取候选规则
|
||||
- 候选集内线性扫描进行精确匹配
|
||||
- Body 匹配：支持 JSON 对象和字符串两种比较方式
|
||||
|
||||
## 响应处理 (handler.rs)
|
||||
|
||||
- 内联 body：直接返回
|
||||
- `file://` 前缀：从磁盘流式读取文件（低内存占用）
|
||||
- `settings.delay_ms`：模拟网络延迟
|
||||
|
||||
## 文件结构
|
||||
|
||||
```
|
||||
src/
|
||||
├── main.rs # 入口，热重载监听，Axum 路由配置
|
||||
├── config.rs # 数据结构定义（MockRule, RequestMatcher 等）
|
||||
├── loader.rs # YAML 解析，目录扫描
|
||||
├── router.rs # 路径首段索引，匹配逻辑
|
||||
├── handler.rs # 统一请求处理器，文件流式响应
|
||||
└── upload.rs # Multipart 文件上传处理
|
||||
|
||||
tests/ # 集成测试（每个模块一个测试文件）
|
||||
mocks/ # YAML Mock 配置文件
|
||||
storage/ # 上传文件存储（按 YYYY-MM-DD 分目录）
|
||||
```
|
||||
|
||||
## 开发注意事项
|
||||
|
||||
- **Rust Edition 2024**，Axum 0.8.8
|
||||
- 测试使用 `tempfile` crate 处理临时文件
|
||||
- 请求体大小限制：10MB (handler.rs:30)
|
||||
- 热重载防抖时间：200ms (main.rs:46)
|
||||
- Header 匹配大小写不敏感 (router.rs:75)
|
||||
@@ -0,0 +1,89 @@
|
||||
---
|
||||
paths:
|
||||
- "**/*"
|
||||
---
|
||||
|
||||
## Git 提交消息规范
|
||||
|
||||
AI 在生成 commit 消息时必须遵循以下格式。
|
||||
|
||||
### 格式
|
||||
|
||||
```
|
||||
<类型>(<范围>): <描述>
|
||||
|
||||
[可选的详细说明]
|
||||
|
||||
[可选的脚注]
|
||||
```
|
||||
|
||||
### 类型（Type）
|
||||
|
||||
| 类型 | 说明 |
|
||||
|------|------|
|
||||
| feat | 新功能（feature） |
|
||||
| fix | 修复 bug |
|
||||
| docs | 文档更新 |
|
||||
| style | 代码格式（不影响功能的变动） |
|
||||
| refactor | 代码重构（既非新功能也非 bug 修复） |
|
||||
| test | 添加或修改测试 |
|
||||
| chore | 构建系统或辅助工具的变动 |
|
||||
| perf | 性能优化 |
|
||||
|
||||
### 范围（Scope）
|
||||
|
||||
描述提交影响的功能模块或组件（可选）。
|
||||
|
||||
### 描述（Description）
|
||||
|
||||
- 简明扼要描述变动内容
|
||||
- 首字母小写
|
||||
- 不超过 100 个字符
|
||||
- 使用祈使句（如 "add" 而非 "added"）
|
||||
|
||||
### 详细说明（Body）
|
||||
|
||||
- 提供更多上下文和详细说明（可选）
|
||||
- 每行不超过 72 个字符
|
||||
- 说明"做了什么"和"为什么"
|
||||
|
||||
### 脚注（Footer）
|
||||
|
||||
- 破坏性变动说明（如 `BREAKING CHANGE: ...`）
|
||||
- 关闭的 Issue（如 `Closes #123`）
|
||||
|
||||
### 示例
|
||||
|
||||
**新功能：**
|
||||
|
||||
```
|
||||
feat(api): 添加用户登录端点
|
||||
|
||||
- 实现 JWT 认证逻辑
|
||||
- 添加登录表单前端组件
|
||||
- 更新用户服务处理登录请求
|
||||
|
||||
Closes #45
|
||||
```
|
||||
|
||||
**Bug 修复：**
|
||||
|
||||
```
|
||||
fix(router): 修复路径匹配大小写问题
|
||||
|
||||
路径匹配在某些情况下区分大小写导致无法正确路由到处理器。
|
||||
```
|
||||
|
||||
**文档更新：**
|
||||
|
||||
```
|
||||
docs: 更新 README 中的安装说明
|
||||
```
|
||||
|
||||
**重构：**
|
||||
|
||||
```
|
||||
refactor(handler): 简化响应处理逻辑
|
||||
|
||||
将文件响应和内联响应的处理逻辑分离到独立函数中。
|
||||
```
|
||||
@@ -0,0 +1,89 @@
|
||||
---
|
||||
paths:
|
||||
- "mocks/**/*.{yml,yaml}"
|
||||
---
|
||||
|
||||
## YAML 配置规范
|
||||
|
||||
AI 在生成 Mock 规则时必须遵循以下格式。
|
||||
|
||||
### 字段说明
|
||||
|
||||
| 字段 | 类型 | 必填 | 说明 |
|
||||
|------|------|:----:|------|
|
||||
| id | string | 是 | 规则唯一标识 |
|
||||
| request.method | string | 是 | HTTP 方法 (GET/POST/PUT/DELETE...) |
|
||||
| request.path | string | 是 | 请求路径，精确匹配 |
|
||||
| request.query_params | object | 否 | 查询参数匹配 |
|
||||
| request.headers | object | 否 | 请求头匹配（大小写不敏感） |
|
||||
| request.body | any | 否 | 请求体匹配，支持 JSON 对象或字符串 |
|
||||
| response.status | number | 是 | HTTP 状态码 |
|
||||
| response.headers | object | 否 | 响应头 |
|
||||
| response.body | string | 是 | 响应体，支持 file:// 前缀 |
|
||||
| settings.delay_ms | number | 否 | 延迟响应（毫秒） |
|
||||
|
||||
### 匹配规则
|
||||
|
||||
1. **路径精确匹配**（非前缀匹配）
|
||||
2. **请求头匹配大小写不敏感**
|
||||
3. **Body 匹配**支持 JSON 对象或字符串比较
|
||||
|
||||
### 配置示例
|
||||
|
||||
**单接口模式：**
|
||||
|
||||
```yaml
|
||||
id: "login"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/login"
|
||||
body: { "username": "test" }
|
||||
response:
|
||||
status: 200
|
||||
body: '{"token": "xxx"}'
|
||||
settings:
|
||||
delay_ms: 100
|
||||
```
|
||||
|
||||
**多接口模式（数组）：**
|
||||
|
||||
```yaml
|
||||
- id: "get-users"
|
||||
request: { method: "GET", path: "/api/users" }
|
||||
response: { status: 200, body: '{"users": []}' }
|
||||
|
||||
- id: "create-user"
|
||||
request: { method: "POST", path: "/api/users" }
|
||||
response: { status: 201, body: '{"id": 1}' }
|
||||
```
|
||||
|
||||
**带查询参数和请求头：**
|
||||
|
||||
```yaml
|
||||
id: "search-users"
|
||||
request:
|
||||
method: "GET"
|
||||
path: "/api/users"
|
||||
query_params: { "role": "admin" }
|
||||
headers: { "Authorization": "Bearer token" }
|
||||
response:
|
||||
status: 200
|
||||
headers: { "X-Total-Count": "100" }
|
||||
body: '{"users": []}'
|
||||
```
|
||||
|
||||
**文件响应：**
|
||||
|
||||
```yaml
|
||||
id: "download-pdf"
|
||||
request:
|
||||
method: "GET"
|
||||
path: "/api/download"
|
||||
response:
|
||||
status: 200
|
||||
body: "file://./data/large-file.pdf"
|
||||
```
|
||||
|
||||
> `file://` 支持两种路径：
|
||||
> - 相对路径：`file://./data/file.pdf`（相对于项目根目录）
|
||||
> - 绝对路径：`file:///C:/path/to/file.pdf`
|
||||
@@ -0,0 +1,9 @@
|
||||
{
|
||||
"permissions": {
|
||||
"allow": [
|
||||
"Bash(find:*)",
|
||||
"Bash(cargo search:*)",
|
||||
"Bash(cd:*)"
|
||||
]
|
||||
}
|
||||
}
|
||||
Generated
+286
-2
@@ -60,6 +60,12 @@ dependencies = [
|
||||
"tracing",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "bitflags"
|
||||
version = "1.3.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
|
||||
|
||||
[[package]]
|
||||
name = "bitflags"
|
||||
version = "2.10.0"
|
||||
@@ -84,6 +90,22 @@ version = "1.0.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "877a4ace8713b0bcf2a4e7eec82529c029f1d0619886d18145fea96c3ffe5c0f"
|
||||
|
||||
[[package]]
|
||||
name = "errno"
|
||||
version = "0.3.14"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "39cab71617ae0d63f51a36d69f866391735b51691dbda63cf6f96d042b63efeb"
|
||||
dependencies = [
|
||||
"libc",
|
||||
"windows-sys 0.61.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "fastrand"
|
||||
version = "2.3.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "37909eebbb50d72f9059c3b6d82c0463f2ff062c9e95845c43a6c9c0355411be"
|
||||
|
||||
[[package]]
|
||||
name = "form_urlencoded"
|
||||
version = "1.2.2"
|
||||
@@ -93,6 +115,15 @@ dependencies = [
|
||||
"percent-encoding",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "fsevent-sys"
|
||||
version = "4.1.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "76ee7a02da4d231650c7cea31349b889be2f45ddb3ef3032d2ec8185f6313fd2"
|
||||
dependencies = [
|
||||
"libc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "futures-channel"
|
||||
version = "0.3.31"
|
||||
@@ -145,6 +176,18 @@ dependencies = [
|
||||
"slab",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "getrandom"
|
||||
version = "0.3.4"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "899def5c37c4fd7b2664648c28120ecec138e4d395b459e5ca34f9cce2dd77fd"
|
||||
dependencies = [
|
||||
"cfg-if",
|
||||
"libc",
|
||||
"r-efi",
|
||||
"wasip2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "hashbrown"
|
||||
version = "0.16.1"
|
||||
@@ -243,18 +286,70 @@ dependencies = [
|
||||
"hashbrown",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "inotify"
|
||||
version = "0.11.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "f37dccff2791ab604f9babef0ba14fbe0be30bd368dc541e2b08d07c8aa908f3"
|
||||
dependencies = [
|
||||
"bitflags 2.10.0",
|
||||
"inotify-sys",
|
||||
"libc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "inotify-sys"
|
||||
version = "0.1.5"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "e05c02b5e89bff3b946cedeca278abc628fe811e604f027c45a8aa3cf793d0eb"
|
||||
dependencies = [
|
||||
"libc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "itoa"
|
||||
version = "1.0.16"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "7ee5b5339afb4c41626dde77b7a611bd4f2c202b897852b4bcf5d03eddc61010"
|
||||
|
||||
[[package]]
|
||||
name = "kqueue"
|
||||
version = "1.1.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "eac30106d7dce88daf4a3fcb4879ea939476d5074a9b7ddd0fb97fa4bed5596a"
|
||||
dependencies = [
|
||||
"kqueue-sys",
|
||||
"libc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "kqueue-sys"
|
||||
version = "1.0.4"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ed9625ffda8729b85e45cf04090035ac368927b8cebc34898e7c120f52e4838b"
|
||||
dependencies = [
|
||||
"bitflags 1.3.2",
|
||||
"libc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "lazy_static"
|
||||
version = "1.5.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe"
|
||||
|
||||
[[package]]
|
||||
name = "libc"
|
||||
version = "0.2.178"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "37c93d8daa9d8a012fd8ab92f088405fb202ea0b6ab73ee2482ae66af4f42091"
|
||||
|
||||
[[package]]
|
||||
name = "linux-raw-sys"
|
||||
version = "0.11.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "df1d3c3b53da64cf5760482273a98e575c651a67eec7f77df96b5b642de8f039"
|
||||
|
||||
[[package]]
|
||||
name = "lock_api"
|
||||
version = "0.4.14"
|
||||
@@ -295,21 +390,73 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "a69bcab0ad47271a0234d9422b131806bf3968021e5dc9328caf2d4cd58557fc"
|
||||
dependencies = [
|
||||
"libc",
|
||||
"log",
|
||||
"wasi",
|
||||
"windows-sys 0.61.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "mock-server"
|
||||
name = "mock_server"
|
||||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"axum",
|
||||
"futures-util",
|
||||
"notify",
|
||||
"notify-debouncer-mini",
|
||||
"serde",
|
||||
"serde_json",
|
||||
"serde_yaml",
|
||||
"tempfile",
|
||||
"tokio",
|
||||
"tokio-util",
|
||||
"tracing",
|
||||
"tracing-subscriber",
|
||||
"walkdir",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "notify"
|
||||
version = "8.2.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "4d3d07927151ff8575b7087f245456e549fea62edf0ec4e565a5ee50c8402bc3"
|
||||
dependencies = [
|
||||
"bitflags 2.10.0",
|
||||
"fsevent-sys",
|
||||
"inotify",
|
||||
"kqueue",
|
||||
"libc",
|
||||
"log",
|
||||
"mio",
|
||||
"notify-types",
|
||||
"walkdir",
|
||||
"windows-sys 0.60.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "notify-debouncer-mini"
|
||||
version = "0.6.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "a689eb4262184d9a1727f9087cd03883ea716682ab03ed24efec57d7716dccb8"
|
||||
dependencies = [
|
||||
"log",
|
||||
"notify",
|
||||
"notify-types",
|
||||
"tempfile",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "notify-types"
|
||||
version = "2.0.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "5e0826a989adedc2a244799e823aece04662b66609d96af8dff7ac6df9a8925d"
|
||||
|
||||
[[package]]
|
||||
name = "nu-ansi-term"
|
||||
version = "0.50.3"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "7957b9740744892f114936ab4a57b3f487491bbeafaf8083688b16841a4240e5"
|
||||
dependencies = [
|
||||
"windows-sys 0.61.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -377,13 +524,32 @@ dependencies = [
|
||||
"proc-macro2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "r-efi"
|
||||
version = "5.3.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "69cdb34c158ceb288df11e18b4bd39de994f6657d83847bdffdbd7f346754b0f"
|
||||
|
||||
[[package]]
|
||||
name = "redox_syscall"
|
||||
version = "0.5.18"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ed2bf2547551a7053d6fdfafda3f938979645c44812fbfcda098faae3f1a362d"
|
||||
dependencies = [
|
||||
"bitflags",
|
||||
"bitflags 2.10.0",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "rustix"
|
||||
version = "1.1.3"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "146c9e247ccc180c1f61615433868c99f3de3ae256a30a43b49f67c2d9171f34"
|
||||
dependencies = [
|
||||
"bitflags 2.10.0",
|
||||
"errno",
|
||||
"libc",
|
||||
"linux-raw-sys",
|
||||
"windows-sys 0.61.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -392,6 +558,15 @@ version = "1.0.21"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "62049b2877bf12821e8f9ad256ee38fdc31db7387ec2d3b3f403024de2034aea"
|
||||
|
||||
[[package]]
|
||||
name = "same-file"
|
||||
version = "1.0.6"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "93fc1dc3aaa9bfed95e02e6eadabb4baf7e3078b0bd1b4d7b6b0b68378900502"
|
||||
dependencies = [
|
||||
"winapi-util",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "scopeguard"
|
||||
version = "1.2.0"
|
||||
@@ -477,6 +652,15 @@ dependencies = [
|
||||
"unsafe-libyaml",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "sharded-slab"
|
||||
version = "0.1.7"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "f40ca3c46823713e0d4209592e8d6e826aa57e928f09752619fc696c499637f6"
|
||||
dependencies = [
|
||||
"lazy_static",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "signal-hook-registry"
|
||||
version = "1.4.7"
|
||||
@@ -525,6 +709,28 @@ version = "1.0.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "0bf256ce5efdfa370213c1dabab5935a12e49f2c58d15e9eac2870d3b4f27263"
|
||||
|
||||
[[package]]
|
||||
name = "tempfile"
|
||||
version = "3.24.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "655da9c7eb6305c55742045d5a8d2037996d61d8de95806335c7c86ce0f82e9c"
|
||||
dependencies = [
|
||||
"fastrand",
|
||||
"getrandom",
|
||||
"once_cell",
|
||||
"rustix",
|
||||
"windows-sys 0.61.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "thread_local"
|
||||
version = "1.1.9"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "f60246a4944f24f6e018aa17cdeffb7818b76356965d03b07d6a9886e8962185"
|
||||
dependencies = [
|
||||
"cfg-if",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tokio"
|
||||
version = "1.48.0"
|
||||
@@ -602,9 +808,21 @@ checksum = "63e71662fa4b2a2c3a26f570f037eb95bb1f85397f3cd8076caed2f026a6d100"
|
||||
dependencies = [
|
||||
"log",
|
||||
"pin-project-lite",
|
||||
"tracing-attributes",
|
||||
"tracing-core",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tracing-attributes"
|
||||
version = "0.1.31"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "7490cfa5ec963746568740651ac6781f701c9c5ea257c58e057f3ba8cf69e8da"
|
||||
dependencies = [
|
||||
"proc-macro2",
|
||||
"quote",
|
||||
"syn",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tracing-core"
|
||||
version = "0.1.36"
|
||||
@@ -612,6 +830,32 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "db97caf9d906fbde555dd62fa95ddba9eecfd14cb388e4f491a66d74cd5fb79a"
|
||||
dependencies = [
|
||||
"once_cell",
|
||||
"valuable",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tracing-log"
|
||||
version = "0.2.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ee855f1f400bd0e5c02d150ae5de3840039a3f54b025156404e34c23c03f47c3"
|
||||
dependencies = [
|
||||
"log",
|
||||
"once_cell",
|
||||
"tracing-core",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tracing-subscriber"
|
||||
version = "0.3.22"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "2f30143827ddab0d256fd843b7a66d164e9f271cfa0dde49142c5ca0ca291f1e"
|
||||
dependencies = [
|
||||
"nu-ansi-term",
|
||||
"sharded-slab",
|
||||
"smallvec",
|
||||
"thread_local",
|
||||
"tracing-core",
|
||||
"tracing-log",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -626,12 +870,46 @@ version = "0.2.11"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "673aac59facbab8a9007c7f6108d11f63b603f7cabff99fabf650fea5c32b861"
|
||||
|
||||
[[package]]
|
||||
name = "valuable"
|
||||
version = "0.1.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ba73ea9cf16a25df0c8caa16c51acb937d5712a8429db78a3ee29d5dcacd3a65"
|
||||
|
||||
[[package]]
|
||||
name = "walkdir"
|
||||
version = "2.5.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "29790946404f91d9c5d06f9874efddea1dc06c5efe94541a7d6863108e3a5e4b"
|
||||
dependencies = [
|
||||
"same-file",
|
||||
"winapi-util",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "wasi"
|
||||
version = "0.11.1+wasi-snapshot-preview1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ccf3ec651a847eb01de73ccad15eb7d99f80485de043efb2f370cd654f4ea44b"
|
||||
|
||||
[[package]]
|
||||
name = "wasip2"
|
||||
version = "1.0.1+wasi-0.2.4"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "0562428422c63773dad2c345a1882263bbf4d65cf3f42e90921f787ef5ad58e7"
|
||||
dependencies = [
|
||||
"wit-bindgen",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "winapi-util"
|
||||
version = "0.1.11"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "c2a7b1c03c876122aa43f3020e6c3c3ee5c05081c9a00739faf7503aeba10d22"
|
||||
dependencies = [
|
||||
"windows-sys 0.61.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "windows-link"
|
||||
version = "0.2.1"
|
||||
@@ -721,6 +999,12 @@ version = "0.53.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "d6bbff5f0aada427a1e5a6da5f1f98158182f26556f345ac9e04d36d0ebed650"
|
||||
|
||||
[[package]]
|
||||
name = "wit-bindgen"
|
||||
version = "0.46.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "f17a85883d4e6d00e8a97c586de764dabcc06133f7f1d55dce5cdc070ad7fe59"
|
||||
|
||||
[[package]]
|
||||
name = "zmij"
|
||||
version = "0.1.8"
|
||||
|
||||
+10
-3
@@ -1,5 +1,5 @@
|
||||
[package]
|
||||
name = "mock-server"
|
||||
name = "mock_server"
|
||||
version = "0.1.0"
|
||||
edition = "2024"
|
||||
|
||||
@@ -18,11 +18,18 @@ serde_yaml = "0.9.34+deprecated"
|
||||
serde_json = "1.0.147"
|
||||
|
||||
# 物理目录递归扫描工具
|
||||
#walkdir = "2.5.0"
|
||||
walkdir = "2.5.0"
|
||||
|
||||
tracing="0.1.44"
|
||||
tracing-subscriber = "0.3.22"
|
||||
|
||||
# 性能优化：快速哈希（可选，用于路由匹配）
|
||||
#dashmap = "7.0.0-rc2"
|
||||
# 热加载支持（扩展功能）
|
||||
#notify = "8.2.0"
|
||||
notify = "8.2.0"
|
||||
notify-debouncer-mini = "0.6.0"
|
||||
# 路径处理
|
||||
#pathdiff = "0.2.3"
|
||||
|
||||
[dev-dependencies]
|
||||
tempfile = "3.24.0"
|
||||
@@ -1,21 +0,0 @@
|
||||
MIT License
|
||||
|
||||
Copyright (c) 2025 CNWei
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
in the Software without restriction, including without limitation the rights
|
||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
copies of the Software, and to permit persons to whom the Software is
|
||||
furnished to do so, subject to the following conditions:
|
||||
|
||||
The above copyright notice and this permission notice shall be included in all
|
||||
copies or substantial portions of the Software.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
||||
SOFTWARE.
|
||||
@@ -1,11 +1,76 @@
|
||||
# mock-server
|
||||
基于Rust/Axum的配置驱动型Mock服务，支持YAML配置、请求匹配、延迟响应、大文件流式返回等特性。
|
||||
|
||||
基于 Rust/Axum 的配置驱动型 Mock 服务，支持 YAML 配置、请求匹配、热重载、延迟响应、大文件流式返回等特性。
|
||||
|
||||
## 特性
|
||||
- 配置驱动：YAML定义API行为，无需修改代码
|
||||
- 高性能：基于Rust异步运行时，哈希索引匹配请求
|
||||
- 低内存：大响应体支持磁盘文件流式读取，不占用常驻内存
|
||||
- 易扩展：模块化设计，支持动态占位符、热加载（规划中）
|
||||
|
||||
- **配置驱动**：YAML 定义 API 行为，无需修改代码
|
||||
- **热重载**：`mocks/*.yaml` 变更自动生效，无需重启服务
|
||||
- **高性能**：基于 Rust 异步运行时，路径首段哈希索引 O(1) 匹配
|
||||
- **低内存**：大响应体支持 `file://` 协议从磁盘流式读取
|
||||
- **请求匹配**：支持 method、path、headers、query_params、body 多维度匹配
|
||||
|
||||
## 快速开始
|
||||
|
||||
### 1. 安装依赖
|
||||
|
||||
确保已安装 Rust 工具链：
|
||||
|
||||
```bash
|
||||
curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh
|
||||
```
|
||||
|
||||
### 2. 构建与运行
|
||||
|
||||
```bash
|
||||
cargo build # 构建项目
|
||||
cargo run # 启动服务 http://127.0.0.1:8080
|
||||
cargo test # 运行所有测试
|
||||
cargo test <pattern> # 运行匹配的测试（如 cargo test router）
|
||||
cargo clippy # 代码检查
|
||||
cargo fmt # 格式化代码
|
||||
```
|
||||
|
||||
## 文件结构
|
||||
|
||||
```
|
||||
src/
|
||||
├── main.rs # 入口，热重载监听，Axum 路由配置
|
||||
├── config.rs # 数据结构定义（MockRule, RequestMatcher 等）
|
||||
├── loader.rs # YAML 解析，目录扫描
|
||||
├── router.rs # 路径首段索引，匹配逻辑
|
||||
└── handler.rs # 统一请求处理器，文件流式响应
|
||||
|
||||
tests/ # 集成测试（每个模块一个测试文件）
|
||||
mocks/ # YAML Mock 配置文件
|
||||
```
|
||||
|
||||
## Mock 配置
|
||||
|
||||
详细配置规范请参考 [.claude/rules/mock-spec.md](.claude/rules/mock-spec.md)
|
||||
|
||||
## 未来计划
|
||||
|
||||
### 1. 动态参数与模板响应
|
||||
|
||||
支持路径参数捕获（如 `/api/users/{id}`）和响应模板，可在响应中引用请求参数：
|
||||
|
||||
```yaml
|
||||
# 请求: GET /api/users/123
|
||||
# 响应: { "id": "123", "name": "User 123" }
|
||||
```
|
||||
|
||||
### 2. HTTPS 支持
|
||||
|
||||
内置 TLS/SSL 支持，提供安全的 HTTPS 服务。
|
||||
|
||||
### 3. 可视化管理界面
|
||||
|
||||
- **TUI（终端界面）**：基于 Ratatui 的交互式终端管理
|
||||
- **GUI（图形界面）**：Web Dashboard 或桌面应用，可视化管理 Mock 规则
|
||||
|
||||
> 此功能需要深入讨论，欢迎提出建议和需求
|
||||
|
||||
## 许可证
|
||||
|
||||
MIT
|
||||
|
||||
@@ -0,0 +1,118 @@
|
||||
# 用户登录 - JSON 格式
|
||||
- name: "user_login_002"
|
||||
request:
|
||||
path: "/v1/auth/login"
|
||||
method: "POST"
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
Authorization: "eyJhbGciOiJIUzI1NiIsInR5cCI6"
|
||||
host: "127.0.0.1:8080"
|
||||
body: >
|
||||
{
|
||||
"username": "user002",
|
||||
"password": "password123"
|
||||
}
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "登录成功",
|
||||
"data": {
|
||||
"token": "eyJhbGciOiJIUzI1NiIsInR5cCI6",
|
||||
"userId": 10002,
|
||||
"username": "user002",
|
||||
"role": "administrator"
|
||||
}
|
||||
}
|
||||
settings:
|
||||
delay_ms: 2000 # 模拟真实网络延迟
|
||||
|
||||
- name: "user_login_003"
|
||||
request:
|
||||
path: "/v1/auth/login"
|
||||
method: "POST"
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
Authorization: "eyJhbGciOiJIUzI1NiIsInR5cCI6"
|
||||
host: "127.0.0.1:8080"
|
||||
body: |
|
||||
{
|
||||
"username": "user003",
|
||||
"password": "password123"
|
||||
}
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: >
|
||||
{
|
||||
"code": 0,
|
||||
"message": "登录成功",
|
||||
"data": {
|
||||
"token": "eyJhbGciOiJIUzI1NiIsInR5cCI6",
|
||||
"userId": 10003,
|
||||
"username": "user003",
|
||||
"role": "administrator"
|
||||
}
|
||||
}
|
||||
settings:
|
||||
delay_ms: 2000 # 模拟真实网络延迟
|
||||
|
||||
- name: "user_login_004"
|
||||
request:
|
||||
path: "/v1/auth/login"
|
||||
method: "POST"
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
Authorization: "eyJhbGciOiJIUzI1NiIsInR5cCI6"
|
||||
host: "127.0.0.1:8080"
|
||||
body: |
|
||||
{
|
||||
"username": "user004",
|
||||
"password": "password123"
|
||||
}
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "登录成功",
|
||||
"data": {
|
||||
"token": "eyJhbGciOiJIUzI1NiIsInR5cCI6",
|
||||
"userId": 10004,
|
||||
"username": "user004",
|
||||
"role": "administrator"
|
||||
}
|
||||
}
|
||||
|
||||
- name: "user_login_005"
|
||||
request:
|
||||
path: "/v1/auth/login"
|
||||
method: "POST"
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
Authorization: "eyJhbGciOiJIUzI1NiIsInR5cCI6"
|
||||
host: "127.0.0.1:8080"
|
||||
body:
|
||||
username: "user005"
|
||||
password: "password123"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "登录成功",
|
||||
"data": {
|
||||
"token": "eyJhbGciOiJIUzI1NiIsInR5cCI6",
|
||||
"userId": 10005,
|
||||
"username": "user005",
|
||||
"role": "administrator"
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,26 @@
|
||||
# 用户注册 - JSON 格式
|
||||
name: "user_register"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/v1/auth/register"
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body:
|
||||
username: "newuser"
|
||||
password: "newpass123"
|
||||
email: "[email protected]"
|
||||
response:
|
||||
status: 201
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "注册成功",
|
||||
"data": {
|
||||
"userId": 10002,
|
||||
"username": "newuser",
|
||||
"email": "[email protected]",
|
||||
"createdAt": "2026-03-27T10:00:00Z"
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,29 @@
|
||||
# 用户登录 - JSON 格式
|
||||
name: "user_login_001"
|
||||
request:
|
||||
path: "/v1/auth/login"
|
||||
method: "POST"
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
Authorization: "eyJhbGciOiJIUzI1NiIsInR5cCI6"
|
||||
host: "127.0.0.1:8080"
|
||||
body:
|
||||
username: "user001"
|
||||
password: "password123"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "登录成功",
|
||||
"data": {
|
||||
"token": "eyJhbGciOiJIUzI1NiIsInR5cCI6",
|
||||
"userId": 10001,
|
||||
"username": "user001",
|
||||
"role": "administrator"
|
||||
}
|
||||
}
|
||||
settings:
|
||||
delay_ms: 2000 # 模拟真实网络延迟
|
||||
@@ -0,0 +1,30 @@
|
||||
# XML 数据导出 - XML 格式
|
||||
name: "data_export"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/v1/data/export"
|
||||
headers:
|
||||
Content-Type: "application/xml"
|
||||
body: |
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<request>
|
||||
<userId>10001</userId>
|
||||
<format>xml</format>
|
||||
</request>
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/xml"
|
||||
body: |
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<response>
|
||||
<code>0</code>
|
||||
<message>导出成功</message>
|
||||
<data>
|
||||
<user>
|
||||
<id>10001</id>
|
||||
<name>管理员</name>
|
||||
<email>[email protected]</email>
|
||||
</user>
|
||||
</data>
|
||||
</response>
|
||||
@@ -0,0 +1,15 @@
|
||||
# 健康检查 - GET 无 Body
|
||||
name: "health_check"
|
||||
request:
|
||||
method: "GET"
|
||||
path: "/v1/health"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"status": "healthy",
|
||||
"version": "2.0.0",
|
||||
"timestamp": "2026-03-27T10:00:00Z"
|
||||
}
|
||||
@@ -0,0 +1,12 @@
|
||||
name: "prod_export_pdf"
|
||||
request:
|
||||
method: "GET"
|
||||
path: "/v1/products/report"
|
||||
body: '{"username":"user001","password":"password123"}'
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/pdf"
|
||||
Content-Disposition: "attachment; filename=report.pdf"
|
||||
# 智能协议：引擎会自动识别前缀并异步读取磁盘文件
|
||||
body: "file://./storage/v1/hello.pdf"
|
||||
@@ -0,0 +1,73 @@
|
||||
# 上传头像 - Multipart 格式（数组形式，只匹配字段名）
|
||||
- name: "user_upload_avatar_001"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/v1/user/avatar"
|
||||
headers:
|
||||
Content-Type: "multipart/form-data"
|
||||
body:
|
||||
- "avatar1"
|
||||
- "description1"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "头像上传成功",
|
||||
"data": {
|
||||
"url": "https://cdn.example.com/v1/avatars/10001.jpg",
|
||||
"size": 204800,
|
||||
"filename": "avatar.jpg"
|
||||
}
|
||||
}
|
||||
|
||||
- name: "user_upload_avatar_002"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/v1/user/avatar"
|
||||
headers:
|
||||
Content-Type: "multipart/form-data"
|
||||
body:
|
||||
avatar2: "avatar"
|
||||
description2: "description"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "头像上传成功",
|
||||
"data": {
|
||||
"url": "https://cdn.example.com/v1/avatars/10002.jpg",
|
||||
"size": 204800,
|
||||
"filename": "avatar.jpg"
|
||||
}
|
||||
}
|
||||
- name: "user_upload_avatar_003"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/v1/user/avatar"
|
||||
headers:
|
||||
Content-Type: "multipart/form-data"
|
||||
body: >
|
||||
{
|
||||
"avatar3": "avatar"
|
||||
"description3": "description"
|
||||
}
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "头像上传成功",
|
||||
"data": {
|
||||
"url": "https://cdn.example.com/v1/avatars/10003.jpg",
|
||||
"size": 204800,
|
||||
"filename": "avatar.jpg"
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,13 @@
|
||||
# 下载用户数据文件 - file:// 协议
|
||||
name: "user_download"
|
||||
request:
|
||||
method: "GET"
|
||||
path: "/v1/user/download"
|
||||
query_params:
|
||||
format: "json"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/octet-stream"
|
||||
Content-Disposition: "attachment; filename=user_data.json"
|
||||
body: "file://./storage/v1/user_data.json"
|
||||
@@ -0,0 +1,13 @@
|
||||
# 文本回显 - Text 格式
|
||||
name: "user_echo"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/v1/user/echo"
|
||||
headers:
|
||||
Content-Type: "text/plain"
|
||||
body: "Hello V1 Mock Server"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "text/plain"
|
||||
body: "Echo from V1: Hello V1 Mock Server"
|
||||
@@ -0,0 +1,24 @@
|
||||
# 表单登录 - Form 格式
|
||||
name: "_user_login_form"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/v1/user/login/form"
|
||||
headers:
|
||||
Content-Type: "application/x-www-form-urlencoded"
|
||||
body:
|
||||
username: "formuser"
|
||||
password: "formpass"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "表单登录成功",
|
||||
"data": {
|
||||
"token": "v2_form_token_xyz",
|
||||
"userId": 20001,
|
||||
"username": "formuser"
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,24 @@
|
||||
# 获取用户信息 - GET 无 Body，需要 Authorization Header
|
||||
name: "user_profile"
|
||||
request:
|
||||
method: "GET"
|
||||
path: "/v1/user/profile"
|
||||
headers:
|
||||
Authorization: "Bearer v1_test_token"
|
||||
response:
|
||||
status: 200
|
||||
headers:
|
||||
Content-Type: "application/json"
|
||||
body: |
|
||||
{
|
||||
"code": 0,
|
||||
"message": "获取成功",
|
||||
"data": {
|
||||
"userId": 10001,
|
||||
"username": "admin",
|
||||
"email": "[email protected]",
|
||||
"nickname": "管理员",
|
||||
"avatar": "https://example.com/avatars/admin.jpg",
|
||||
"createdAt": "2025-01-01T00:00:00Z"
|
||||
}
|
||||
}
|
||||
+235
@@ -0,0 +1,235 @@
|
||||
use axum::{
|
||||
body::Body,
|
||||
extract::{Query, State},
|
||||
http::{HeaderMap, Method, Request, StatusCode},
|
||||
response::{IntoResponse, Response},
|
||||
};
|
||||
use std::collections::HashMap;
|
||||
use std::sync::{Arc, RwLock}; // 必须引入 RwLock
|
||||
use tokio_util::io::ReaderStream;
|
||||
|
||||
use crate::models::Payload;
|
||||
use crate::router::MockRouter;
|
||||
|
||||
/// 共享的应用状态，router 现在由 RwLock 保护以支持热重载
|
||||
pub struct AppState {
|
||||
pub router: RwLock<MockRouter>,
|
||||
}
|
||||
|
||||
/// 提取请求的 Content-Type（去掉参数部分，如 boundary）
|
||||
fn extract_content_type(headers: &HeaderMap) -> Option<String> {
|
||||
headers
|
||||
.get(axum::http::header::CONTENT_TYPE)
|
||||
.and_then(|v| v.to_str().ok())
|
||||
.map(|s| s.split(';').next().unwrap_or(s).trim().to_lowercase())
|
||||
}
|
||||
|
||||
/// 根据 Content-Type 解析 Body（始终以请求的 Content-Type 为准）
|
||||
fn parse_body(content_type: Option<&str>, bytes: &[u8]) -> Payload {
|
||||
if bytes.is_empty() {
|
||||
return Payload::None;
|
||||
}
|
||||
|
||||
match content_type {
|
||||
Some(ct) if ct.contains("application/json") => {
|
||||
serde_json::from_slice(bytes)
|
||||
.map(Payload::Json)
|
||||
.unwrap_or_else(|_| {
|
||||
// JSON 解析失败，降级为文本
|
||||
Payload::Text(String::from_utf8_lossy(bytes).to_string())
|
||||
})
|
||||
}
|
||||
Some(ct) if ct.contains("xml") => {
|
||||
Payload::Xml(String::from_utf8_lossy(bytes).to_string())
|
||||
}
|
||||
Some(ct) if ct.contains("form-urlencoded") => {
|
||||
Payload::Form(parse_urlencoded(bytes))
|
||||
}
|
||||
Some(ct) if ct.contains("multipart/form-data") => {
|
||||
Payload::Multipart(extract_multipart_data(bytes))
|
||||
}
|
||||
_ => {
|
||||
Payload::Text(String::from_utf8_lossy(bytes).to_string())
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// 解析 urlencoded 格式
|
||||
fn parse_urlencoded(bytes: &[u8]) -> HashMap<String, String> {
|
||||
let body = String::from_utf8_lossy(bytes);
|
||||
let mut map = HashMap::new();
|
||||
for pair in body.split('&') {
|
||||
if let Some((key, value)) = pair.split_once('=') {
|
||||
let decoded_key = urlencoding_decode(key);
|
||||
let decoded_value = urlencoding_decode(value);
|
||||
map.insert(decoded_key, decoded_value);
|
||||
}
|
||||
}
|
||||
map
|
||||
}
|
||||
|
||||
/// URL 解码（简单实现）
|
||||
fn urlencoding_decode(s: &str) -> String {
|
||||
let mut result = String::new();
|
||||
let mut chars = s.chars().peekable();
|
||||
while let Some(c) = chars.next() {
|
||||
if c == '+' {
|
||||
result.push(' ');
|
||||
} else if c == '%' {
|
||||
let hex: String = chars.by_ref().take(2).collect();
|
||||
if let Ok(byte) = u8::from_str_radix(&hex, 16) {
|
||||
result.push(byte as char);
|
||||
} else {
|
||||
result.push('%');
|
||||
result.push_str(&hex);
|
||||
}
|
||||
} else {
|
||||
result.push(c);
|
||||
}
|
||||
}
|
||||
result
|
||||
}
|
||||
|
||||
/// 从 multipart body 中提取键值对
|
||||
fn extract_multipart_data(bytes: &[u8]) -> HashMap<String, String> {
|
||||
let body = String::from_utf8_lossy(bytes);
|
||||
let mut map = HashMap::new();
|
||||
|
||||
// 分割 boundary
|
||||
let lines: Vec<&str> = body.lines().collect();
|
||||
let mut current_name: Option<String> = None;
|
||||
let mut current_value = String::new();
|
||||
let mut in_value = false;
|
||||
|
||||
for line in &lines {
|
||||
// 检测 Content-Disposition 行，提取 name
|
||||
if line.contains("Content-Disposition") && line.contains("name=") {
|
||||
// 保存上一个字段的值
|
||||
if let Some(name) = current_name.take() {
|
||||
map.insert(name, current_value.trim().to_string());
|
||||
current_value.clear();
|
||||
}
|
||||
|
||||
// 提取 name 属性
|
||||
if let Some(start) = line.find("name=\"") {
|
||||
let start = start + 6;
|
||||
if let Some(end) = line[start..].find('"') {
|
||||
current_name = Some(line[start..start + end].to_string());
|
||||
in_value = false;
|
||||
}
|
||||
}
|
||||
} else if line.starts_with("Content-Type") {
|
||||
// 跳过 Content-Type 行
|
||||
continue;
|
||||
} else if line.is_empty() {
|
||||
// 空行后面是值
|
||||
in_value = true;
|
||||
} else if in_value {
|
||||
// 收集值内容
|
||||
if !current_value.is_empty() {
|
||||
current_value.push('\n');
|
||||
}
|
||||
current_value.push_str(line);
|
||||
}
|
||||
}
|
||||
|
||||
// 保存最后一个字段
|
||||
if let Some(name) = current_name {
|
||||
map.insert(name, current_value.trim().to_string());
|
||||
}
|
||||
|
||||
map
|
||||
}
|
||||
|
||||
/// 全局统一请求处理函数
|
||||
pub async fn mock_handler(
|
||||
State(state): State<Arc<AppState>>, // State 必须是第一个或靠前的参数
|
||||
method: Method,
|
||||
headers: HeaderMap,
|
||||
Query(params): Query<HashMap<String, String>>,
|
||||
req: Request<Body>, // Request<Body> 必须是最后一个参数
|
||||
) -> impl IntoResponse {
|
||||
// 1. 提取 path 和 method
|
||||
let path = req.uri().path().to_string();
|
||||
let method_str = method.as_str().to_string();
|
||||
|
||||
// 2. 提取请求的 Content-Type
|
||||
let req_content_type = extract_content_type(&headers);
|
||||
|
||||
// 3. 读取请求 body
|
||||
let body_bytes = match axum::body::to_bytes(req.into_body(), 10 * 1024 * 1024).await {
|
||||
Ok(bytes) => bytes,
|
||||
Err(_) => {
|
||||
return Response::builder()
|
||||
.status(StatusCode::BAD_REQUEST)
|
||||
.body(Body::from("Read body error"))
|
||||
.unwrap();
|
||||
}
|
||||
};
|
||||
|
||||
// 4. 根据【请求的 Content-Type】解析 body
|
||||
let parsed_body = parse_body(req_content_type.as_deref(), &body_bytes);
|
||||
|
||||
// 5. 将 Axum HeaderMap 转换为简单的 HashMap
|
||||
let mut req_headers = HashMap::new();
|
||||
for (name, value) in headers.iter() {
|
||||
if let Ok(v) = value.to_str() {
|
||||
req_headers.insert(name.as_str().to_string(), v.to_string());
|
||||
}
|
||||
}
|
||||
|
||||
// 6. 执行匹配逻辑：先获取读锁 (Read Lock)
|
||||
let maybe_rule = {
|
||||
let router = state.router.read().expect("Failed to acquire read lock");
|
||||
router.match_rule(&method_str, &path, ¶ms, &req_headers, &parsed_body).cloned()
|
||||
// 此处使用 .cloned() 以便尽早释放读锁，避免阻塞热重载写锁
|
||||
};
|
||||
|
||||
if let Some(rule) = maybe_rule {
|
||||
// 7. 处理模拟延迟
|
||||
if let Some(ref settings) = rule.settings {
|
||||
if let Some(delay) = settings.delay_ms {
|
||||
tokio::time::sleep(std::time::Duration::from_millis(delay)).await;
|
||||
}
|
||||
}
|
||||
|
||||
// 8. 构建响应
|
||||
let status = StatusCode::from_u16(rule.response.status).unwrap_or(StatusCode::OK);
|
||||
let mut response_builder = Response::builder().status(status);
|
||||
|
||||
if let Some(ref h) = rule.response.headers {
|
||||
for (k, v) in h {
|
||||
response_builder = response_builder.header(k, v);
|
||||
}
|
||||
}
|
||||
|
||||
// 9. Smart Body 逻辑
|
||||
if let Some(file_path) = rule.response.get_file_path() {
|
||||
match tokio::fs::File::open(file_path).await {
|
||||
Ok(file) => {
|
||||
let stream = ReaderStream::new(file);
|
||||
let body = Body::from_stream(stream);
|
||||
response_builder.body(body).unwrap()
|
||||
}
|
||||
Err(_) => Response::builder()
|
||||
.status(StatusCode::INTERNAL_SERVER_ERROR)
|
||||
.body(Body::from(format!(
|
||||
"Mock Error: File not found at {}",
|
||||
file_path
|
||||
)))
|
||||
.unwrap(),
|
||||
}
|
||||
} else {
|
||||
// 内联模式：直接返回字符串内容
|
||||
response_builder
|
||||
.body(Body::from(rule.response.body.clone()))
|
||||
.unwrap()
|
||||
}
|
||||
} else {
|
||||
// 匹配失败返回 404
|
||||
Response::builder()
|
||||
.status(StatusCode::NOT_FOUND)
|
||||
.body(Body::from("No mock rule matched this request"))
|
||||
.unwrap()
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,5 @@
|
||||
// 声明模块并设为 pub，这样 tests/ 目录才能看到它们
|
||||
pub mod models;
|
||||
pub mod loader;
|
||||
pub mod router;
|
||||
pub mod handler;
|
||||
@@ -0,0 +1,58 @@
|
||||
use std::collections::HashMap;
|
||||
use std::fs;
|
||||
use std::path::{Path, PathBuf};
|
||||
use walkdir::WalkDir; // 需在 Cargo.toml 添加 walkdir 依赖
|
||||
|
||||
use crate::models::{MockRule, MockSource};
|
||||
|
||||
pub struct MockLoader;
|
||||
|
||||
impl MockLoader {
|
||||
/// 递归扫描指定目录并构建索引表
|
||||
pub fn load_all_from_dir(dir: &Path) -> HashMap<String, Vec<MockRule>> {
|
||||
let mut index: HashMap<String, Vec<MockRule>> = HashMap::new();
|
||||
|
||||
// 1. 使用 walkdir 递归遍历目录，不限层级
|
||||
for entry in WalkDir::new(dir)
|
||||
.into_iter()
|
||||
.filter_map(|e| e.ok())
|
||||
.filter(|e| e.path().extension().map_or(false, |ext| ext == "yaml" || ext == "yml"))
|
||||
{
|
||||
if let Some(rules) = Self::parse_yaml_file(entry.path()) {
|
||||
for rule in rules {
|
||||
// 2. 提取路径首段作为索引 Key
|
||||
let key = Self::extract_first_segment(&rule.request.path);
|
||||
|
||||
// 3. 将规则插入到对应的索引桶中
|
||||
index.entry(key).or_insert_with(Vec::new).push(rule);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
println!("Successfully loaded {} segments from {:?}", index.len(), dir);
|
||||
index
|
||||
}
|
||||
|
||||
/// 解析单个 YAML 文件，支持单接口和多接口模式
|
||||
fn parse_yaml_file(path: &Path) -> Option<Vec<MockRule>> {
|
||||
let content = fs::read_to_string(path).ok()?;
|
||||
|
||||
// 利用 serde_yaml 的反序列化能力处理 MockSource 枚举
|
||||
match serde_yaml::from_str::<MockSource>(&content) {
|
||||
Ok(source) => Some(source.flatten()), // 统一打平为 Vec<MockRule>
|
||||
Err(e) => {
|
||||
eprintln!("Failed to parse YAML at {:?}: {}", path, e);
|
||||
None
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// 提取路径的第一级作为 Key（例如 "/api/v1/login" -> "api"）
|
||||
fn extract_first_segment(path: &str) -> String {
|
||||
path.trim_start_matches('/')
|
||||
.split('/')
|
||||
.next()
|
||||
.unwrap_or("root") // 如果是根路径 "/"，则归类到 "root"
|
||||
.to_string()
|
||||
}
|
||||
}
|
||||
+63
-2
@@ -1,3 +1,64 @@
|
||||
fn main() {
|
||||
println!("Hello, mock-server!");
|
||||
use std::net::SocketAddr;
|
||||
use std::path::Path;
|
||||
use std::sync::{Arc, RwLock};
|
||||
use std::time::Duration;
|
||||
use axum::{routing::any, Router};
|
||||
use notify_debouncer_mini::{new_debouncer, notify::*};
|
||||
|
||||
use mock_server::loader::MockLoader;
|
||||
use mock_server::router::MockRouter;
|
||||
use mock_server::handler::{mock_handler, AppState};
|
||||
|
||||
#[tokio::main]
|
||||
async fn main() {
|
||||
tracing_subscriber::fmt::init();
|
||||
|
||||
let mocks_dir = Path::new("./mocks");
|
||||
if !mocks_dir.exists() {
|
||||
std::fs::create_dir_all(mocks_dir).unwrap();
|
||||
}
|
||||
|
||||
// 1. 初始加载
|
||||
println!("Scanning mocks directory...");
|
||||
let index = MockLoader::load_all_from_dir(mocks_dir);
|
||||
let shared_state = Arc::new(AppState {
|
||||
router: RwLock::new(MockRouter::new(index)),
|
||||
});
|
||||
|
||||
// 2. 设置热加载监听器
|
||||
let state_for_watcher = shared_state.clone();
|
||||
let watch_path = mocks_dir.to_path_buf();
|
||||
let (tx, rx) = std::sync::mpsc::channel();
|
||||
|
||||
// 200ms 防抖，防止编辑器保存文件时产生多次干扰
|
||||
let mut debouncer = new_debouncer(Duration::from_millis(200), tx).unwrap();
|
||||
debouncer.watcher().watch(&watch_path, RecursiveMode::Recursive).unwrap();
|
||||
|
||||
// 启动异步任务监听文件变动
|
||||
tokio::spawn(async move {
|
||||
while let Ok(res) = rx.recv() {
|
||||
match res {
|
||||
Ok(_) => {
|
||||
println!("🔄 Detecting changes in mocks/, reloading...");
|
||||
let new_index = MockLoader::load_all_from_dir(&watch_path);
|
||||
// 获取写锁 (Write Lock) 更新索引
|
||||
let mut writer = state_for_watcher.router.write().expect("Failed to acquire write lock");
|
||||
*writer = MockRouter::new(new_index);
|
||||
println!("✅ Mocks reloaded successfully.");
|
||||
}
|
||||
Err(e) => eprintln!("Watcher error: {:?}", e),
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
// 3. 配置 Axum 路由
|
||||
let app = Router::new()
|
||||
.fallback(any(mock_handler))
|
||||
.with_state(shared_state);
|
||||
|
||||
let addr = SocketAddr::from(([127, 0, 0, 1], 8080));
|
||||
println!("🚀 Server running at http://{}", addr);
|
||||
|
||||
let listener = tokio::net::TcpListener::bind(addr).await.unwrap();
|
||||
axum::serve(listener, app).await.unwrap();
|
||||
}
|
||||
+121
@@ -0,0 +1,121 @@
|
||||
use serde::{Deserialize, Serialize};
|
||||
use std::collections::HashMap;
|
||||
|
||||
/// 解析后的请求 Body
|
||||
#[derive(Debug, Clone)]
|
||||
pub enum Payload {
|
||||
/// JSON 格式
|
||||
Json(serde_json::Value),
|
||||
/// XML 格式
|
||||
Xml(String),
|
||||
/// URL 编码表单
|
||||
Form(HashMap<String, String>),
|
||||
/// Multipart 表单（键值对）
|
||||
Multipart(HashMap<String, String>),
|
||||
/// 纯文本
|
||||
Text(String),
|
||||
/// 无 Body
|
||||
None,
|
||||
}
|
||||
|
||||
impl Payload {
|
||||
/// 转换为字符串（用于兜底比较）
|
||||
pub fn to_compare_string(&self) -> String {
|
||||
match self {
|
||||
Payload::Json(v) => v.to_string(),
|
||||
Payload::Xml(s) | Payload::Text(s) => s.clone(),
|
||||
Payload::Form(map) | Payload::Multipart(map) => {
|
||||
let mut pairs: Vec<_> = map.iter().collect();
|
||||
pairs.sort_by_key(|(k, _)| *k);
|
||||
pairs.iter().map(|(k, v)| format!("{}={}", k, v)).collect::<Vec<_>>().join("&")
|
||||
}
|
||||
Payload::None => String::new(),
|
||||
}
|
||||
}
|
||||
|
||||
/// 获取对应的 Content-Type 名称
|
||||
pub fn content_type_name(&self) -> &'static str {
|
||||
match self {
|
||||
Payload::Json(_) => "application/json",
|
||||
Payload::Xml(_) => "application/xml",
|
||||
Payload::Form(_) => "application/x-www-form-urlencoded",
|
||||
Payload::Multipart(_) => "multipart/form-data",
|
||||
Payload::Text(_) => "text/plain",
|
||||
Payload::None => "none",
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// 顶层包装：支持单对象或数组，自动打平
|
||||
#[derive(Debug, Deserialize)]
|
||||
#[serde(untagged)]
|
||||
pub enum MockSource {
|
||||
/// 对应"一个接口一个文件"模式
|
||||
Single(MockRule),
|
||||
/// 对应"一个文件多个接口"模式
|
||||
Multiple(Vec<MockRule>),
|
||||
}
|
||||
|
||||
impl MockSource {
|
||||
/// 将不同的解析模式统一转化为列表，供 Loader 构建索引
|
||||
pub fn flatten(self) -> Vec<MockRule> {
|
||||
match self {
|
||||
Self::Single(rule) => vec![rule],
|
||||
Self::Multiple(rules) => rules,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// 核心 Mock 规则定义
|
||||
#[derive(Debug, Deserialize, Serialize, Clone, PartialEq)]
|
||||
pub struct MockRule {
|
||||
pub name: String,
|
||||
pub request: RequestMatcher,
|
||||
pub response: MockResponse,
|
||||
pub settings: Option<MockSettings>,
|
||||
}
|
||||
|
||||
/// 请求匹配条件
|
||||
#[derive(Debug, Deserialize, Serialize, Clone, PartialEq)]
|
||||
pub struct RequestMatcher {
|
||||
pub method: String,
|
||||
pub path: String,
|
||||
/// 选填：只有请求包含这些参数时才匹配
|
||||
pub query_params: Option<HashMap<String, String>>,
|
||||
/// 选填：只有请求包含这些 Header 时才匹配
|
||||
pub headers: Option<HashMap<String, String>>,
|
||||
/// 选填：请求体匹配条件
|
||||
pub body: Option<serde_json::Value>,
|
||||
}
|
||||
|
||||
/// 响应内容定义
|
||||
#[derive(Debug, Deserialize, Serialize, Clone, PartialEq)]
|
||||
pub struct MockResponse {
|
||||
pub status: u16,
|
||||
pub headers: Option<HashMap<String, String>>,
|
||||
/// 统一字段：支持 Inline 文本或 file:// 前缀的路径
|
||||
pub body: String,
|
||||
}
|
||||
|
||||
/// 模拟器行为设置
|
||||
#[derive(Debug, Deserialize, Serialize, Clone, PartialEq)]
|
||||
pub struct MockSettings {
|
||||
/// 模拟网络延迟（毫秒）
|
||||
pub delay_ms: Option<u64>,
|
||||
}
|
||||
|
||||
impl MockResponse {
|
||||
/// 辅助方法：判断是否为文件协议
|
||||
pub fn is_file_protocol(&self) -> bool {
|
||||
self.body.starts_with("file://")
|
||||
}
|
||||
|
||||
/// 获取去掉协议前缀后的纯物理路径
|
||||
pub fn get_file_path(&self) -> Option<&str> {
|
||||
if self.is_file_protocol() {
|
||||
Some(&self.body[7..]) // 截取 "file://" 之后的内容
|
||||
} else {
|
||||
None
|
||||
}
|
||||
}
|
||||
}
|
||||
+225
@@ -0,0 +1,225 @@
|
||||
use std::collections::HashMap;
|
||||
use crate::models::{MockRule, Payload};
|
||||
|
||||
pub struct MockRouter {
|
||||
// 索引表：Key 是路径首段（如 "api"），Value 是该段下的所有 Mock 规则
|
||||
pub index: HashMap<String, Vec<MockRule>>,
|
||||
}
|
||||
|
||||
impl MockRouter {
|
||||
pub fn new(index: HashMap<String, Vec<MockRule>>) -> Self {
|
||||
Self { index }
|
||||
}
|
||||
|
||||
/// 核心匹配函数：根据请求信息寻找匹配的 Mock 规则
|
||||
pub fn match_rule(
|
||||
&self,
|
||||
method: &str,
|
||||
path: &str,
|
||||
queries: &HashMap<String, String>,
|
||||
headers: &HashMap<String, String>,
|
||||
payload: &Payload,
|
||||
) -> Option<&MockRule> {
|
||||
// 1. 提取请求路径的首段作为索引 Key
|
||||
let key = self.extract_first_segment(path);
|
||||
println!("DEBUG: Request Key: '{}', Available Keys: {:?}", key, self.index.keys());
|
||||
// 2. 从 HashMap 中快速定位候选规则列表 (O(k) 复杂度)
|
||||
if let Some(rules) = self.index.get(&key) {
|
||||
// 3. 在候选集中进行线性深度匹配
|
||||
for rule in rules {
|
||||
if self.is_match(rule, method, path, queries, headers, payload) {
|
||||
return Some(rule);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
None
|
||||
}
|
||||
|
||||
/// 细粒度匹配逻辑
|
||||
fn is_match(
|
||||
&self,
|
||||
rule: &MockRule,
|
||||
method: &str,
|
||||
path: &str,
|
||||
queries: &HashMap<String, String>,
|
||||
headers: &HashMap<String, String>,
|
||||
payload: &Payload,
|
||||
) -> bool {
|
||||
// A. 基础校验：Method 和 Path 必须完全一致 (忽略末尾斜杠)
|
||||
if rule.request.method.to_uppercase() != method.to_uppercase() {
|
||||
println!("DEBUG: [NAME:{}] Method Mismatch: YAML={}, Req={}", rule.name, rule.request.method, method);
|
||||
return false;
|
||||
}
|
||||
if rule.request.path.trim_end_matches('/') != path.trim_end_matches('/') {
|
||||
println!("DEBUG: [NAME:{}] Path Mismatch: YAML='{}', Req='{}'", rule.name, rule.request.path, path);
|
||||
return false;
|
||||
}
|
||||
println!("DEBUG: [NAME:{}] Method and Path matched! Checking headers...", rule.name);
|
||||
|
||||
// B. Query 参数校验 (子集匹配原则)
|
||||
if let Some(ref required_queries) = rule.request.query_params {
|
||||
for (key, val) in required_queries {
|
||||
if queries.get(key) != Some(val) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// C. Header 校验 (大小写不敏感，Content-Type 使用前缀匹配)
|
||||
if let Some(ref required_headers) = rule.request.headers {
|
||||
for (key, val) in required_headers {
|
||||
let key_lower = key.to_lowercase();
|
||||
let matched = headers.iter().any(|(k, v)| {
|
||||
if k.to_lowercase() != key_lower {
|
||||
return false;
|
||||
}
|
||||
// Content-Type 使用前缀匹配（因为可能包含 boundary 等参数）
|
||||
if key_lower == "content-type" {
|
||||
v.to_lowercase().starts_with(&val.to_lowercase())
|
||||
} else {
|
||||
v == val
|
||||
}
|
||||
});
|
||||
if !matched {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// D. Body 匹配（根据 Payload 类型智能比较）
|
||||
if let Some(ref yaml_body) = rule.request.body {
|
||||
return self.match_body(yaml_body, payload);
|
||||
}
|
||||
|
||||
true
|
||||
}
|
||||
|
||||
/// Body 匹配逻辑
|
||||
fn match_body(&self, yaml_body: &serde_json::Value, payload: &Payload) -> bool {
|
||||
// 将 YAML body 规范化：如果是字符串，尝试解析为 JSON
|
||||
let normalized_body = normalize_yaml_body(yaml_body);
|
||||
|
||||
match payload {
|
||||
Payload::Json(actual) => {
|
||||
// JSON 对象比较
|
||||
&normalized_body == actual
|
||||
}
|
||||
Payload::Xml(actual) => {
|
||||
// XML 字符串比较（规范化后比较）
|
||||
normalized_body.as_str()
|
||||
.map(|expected| normalize_xml(expected) == normalize_xml(actual))
|
||||
.unwrap_or(false)
|
||||
}
|
||||
Payload::Form(actual) => {
|
||||
// Form 键值对比较（子集匹配）
|
||||
compare_form_with_yaml(&normalized_body, actual)
|
||||
}
|
||||
Payload::Multipart(actual_data) => {
|
||||
// Multipart 匹配：支持键值对或字段名列表
|
||||
compare_multipart_with_yaml(&normalized_body, actual_data)
|
||||
}
|
||||
Payload::Text(actual) => {
|
||||
// 字符串比较（去掉首尾空白）
|
||||
normalized_body.as_str()
|
||||
.map(|expected| expected.trim() == actual.trim())
|
||||
.unwrap_or_else(|| normalized_body.to_string().trim() == actual.trim())
|
||||
}
|
||||
Payload::None => {
|
||||
false // YAML 配置了 body，但请求没有 body
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// 与 Loader 保持一致的 Key 提取算法
|
||||
fn extract_first_segment(&self, path: &str) -> String {
|
||||
path.trim_start_matches('/')
|
||||
.split('/')
|
||||
.next()
|
||||
.unwrap_or("root")
|
||||
.to_string()
|
||||
}
|
||||
}
|
||||
|
||||
/// 规范化 YAML body：如果是字符串，尝试解析为 JSON
|
||||
fn normalize_yaml_body(yaml_body: &serde_json::Value) -> serde_json::Value {
|
||||
if let Some(s) = yaml_body.as_str() {
|
||||
// 先 trim 去掉前导/尾随空格，再尝试解析为 JSON
|
||||
let trimmed = s.trim();
|
||||
if let Ok(parsed) = serde_json::from_str::<serde_json::Value>(trimmed) {
|
||||
return parsed;
|
||||
}
|
||||
}
|
||||
yaml_body.clone()
|
||||
}
|
||||
|
||||
/// 规范化 XML 字符串：去掉声明、多余空白、格式化为紧凑形式
|
||||
fn normalize_xml(xml: &str) -> String {
|
||||
let mut result = xml.to_string();
|
||||
|
||||
// 去掉 XML 声明
|
||||
if let Some(pos) = result.find("?>") {
|
||||
if result[..pos].contains("<?xml") {
|
||||
result = result[pos + 2..].to_string();
|
||||
}
|
||||
}
|
||||
|
||||
// 去掉多余空白字符
|
||||
result = result
|
||||
.chars()
|
||||
.collect::<Vec<_>>()
|
||||
.chunks(1)
|
||||
.map(|c| c[0])
|
||||
.collect::<String>();
|
||||
|
||||
// 分割成行，去掉每行首尾空白，过滤空行
|
||||
result = result
|
||||
.lines()
|
||||
.map(|line| line.trim())
|
||||
.filter(|line| !line.is_empty())
|
||||
.collect::<String>();
|
||||
|
||||
result
|
||||
}
|
||||
|
||||
/// Form 比较：YAML 中的键值对必须是请求的子集
|
||||
fn compare_form_with_yaml(yaml_body: &serde_json::Value, actual: &HashMap<String, String>) -> bool {
|
||||
let yaml_map = match yaml_body.as_object() {
|
||||
Some(obj) => obj,
|
||||
None => return false,
|
||||
};
|
||||
|
||||
for (key, yaml_val) in yaml_map {
|
||||
let expected = yaml_val.as_str().map(|s| s.to_string()).unwrap_or_else(|| yaml_val.to_string());
|
||||
if actual.get(key) != Some(&expected) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
true
|
||||
}
|
||||
|
||||
/// Multipart 比较：对象和数组形式都只匹配字段名是否存在
|
||||
fn compare_multipart_with_yaml(yaml_body: &serde_json::Value, actual: &HashMap<String, String>) -> bool {
|
||||
// 方式 1：对象形式 - 只匹配键名是否存在（忽略值）
|
||||
if let Some(yaml_map) = yaml_body.as_object() {
|
||||
for key in yaml_map.keys() {
|
||||
if !actual.contains_key(key) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
// 方式 2：数组形式 - 只匹配字段名是否存在
|
||||
if let Some(yaml_array) = yaml_body.as_array() {
|
||||
for yaml_field in yaml_array {
|
||||
let field_name = yaml_field.as_str().map(|s| s.to_string()).unwrap_or_else(|| yaml_field.to_string());
|
||||
if !actual.contains_key(&field_name) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
false
|
||||
}
|
||||
Binary file not shown.
@@ -0,0 +1,20 @@
|
||||
{
|
||||
"exportInfo": {
|
||||
"exportedAt": "2026-03-27T10:00:00Z",
|
||||
"version": "2.0.0"
|
||||
},
|
||||
"user": {
|
||||
"id": 10001,
|
||||
"username": "admin",
|
||||
"email": "[email protected]",
|
||||
"nickname": "管理员",
|
||||
"role": "administrator",
|
||||
"createdAt": "2025-01-01T00:00:00Z",
|
||||
"lastLoginAt": "2026-03-27T09:30:00Z"
|
||||
},
|
||||
"preferences": {
|
||||
"theme": "dark",
|
||||
"language": "zh-CN",
|
||||
"notifications": true
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,92 @@
|
||||
use std::fs::{self, File};
|
||||
use std::io::Write;
|
||||
use tempfile::tempdir;
|
||||
use mock_server::models::MockSource;
|
||||
use mock_server::loader::MockLoader;
|
||||
|
||||
#[test]
|
||||
fn test_config_deserialization() {
|
||||
// 测试 1：验证单接口 YAML 解析
|
||||
let single_yaml = r#"
|
||||
name: "auth_v1"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/v1/login"
|
||||
response:
|
||||
status: 200
|
||||
body: "inline_content"
|
||||
"#;
|
||||
let res: MockSource = serde_yaml::from_str(single_yaml).expect("应该成功解析单接口");
|
||||
assert_eq!(res.flatten().len(), 1);
|
||||
|
||||
// 测试 2：验证多接口 YAML 数组解析
|
||||
let multi_yaml = r#"
|
||||
- name: "api_1"
|
||||
request: { method: "GET", path: "/1" }
|
||||
response: { status: 200, body: "b1" }
|
||||
- name: "api_2"
|
||||
request: { method: "GET", path: "/2" }
|
||||
response: { status: 200, body: "b2" }
|
||||
"#;
|
||||
let res_multi: MockSource = serde_yaml::from_str(multi_yaml).expect("应该成功解析接口数组");
|
||||
assert_eq!(res_multi.flatten().len(), 2);
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn test_recursive_loading_logic() {
|
||||
// 创建临时 Mock 目录结构
|
||||
let root_dir = tempdir().expect("创建临时目录失败");
|
||||
let root_path = root_dir.path();
|
||||
|
||||
// 构造物理层级：mocks/v1/user/
|
||||
let user_dir = root_path.join("v1/user");
|
||||
fs::create_dir_all(&user_dir).unwrap();
|
||||
|
||||
// 在深层目录创建单接口文件
|
||||
let mut file1 = File::create(user_dir.join("get_profile.yaml")).unwrap();
|
||||
writeln!(
|
||||
file1,
|
||||
r#"
|
||||
name: "user_profile"
|
||||
request:
|
||||
method: "GET"
|
||||
path: "/api/v1/user/profile"
|
||||
response:
|
||||
status: 200
|
||||
body: "profile_data"
|
||||
"#
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
// 在根目录创建多接口文件
|
||||
let mut file2 = File::create(root_path.join("system.yaml")).unwrap();
|
||||
writeln!(
|
||||
file2,
|
||||
r#"
|
||||
- name: "sys_health"
|
||||
request: {{ method: "GET", path: "/health" }}
|
||||
response: {{ status: 200, body: "ok" }}
|
||||
- name: "sys_version"
|
||||
request: {{ method: "GET", path: "/version" }}
|
||||
response: {{ status: 200, body: "1.0.0" }}
|
||||
"#
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
// 执行加载
|
||||
let index = MockLoader::load_all_from_dir(root_path);
|
||||
|
||||
// 断言结果：
|
||||
// 1. 检查 Key 是否根据路径首段正确提取
|
||||
assert!(index.contains_key("api"), "索引应包含 'api' 键");
|
||||
assert!(index.contains_key("health"), "索引应包含 'health' 键");
|
||||
assert!(index.contains_key("version"), "索引应包含 'version' 键");
|
||||
|
||||
// 2. 检查规则总数
|
||||
let total_rules: usize = index.values().map(|v| v.len()).sum();
|
||||
assert_eq!(total_rules, 3, "总规则数应为 3");
|
||||
|
||||
// 3. 检查深层文件是否被正确读取
|
||||
let api_rules = &index["api"];
|
||||
assert_eq!(api_rules[0].name, "user_profile");
|
||||
}
|
||||
@@ -0,0 +1,425 @@
|
||||
use std::fs::{self, File};
|
||||
use std::io::Write;
|
||||
use tempfile::tempdir;
|
||||
use serde_json::json;
|
||||
use mock_server::models::{MockRule, MockSource, Payload};
|
||||
use mock_server::loader::MockLoader;
|
||||
use mock_server::router::MockRouter;
|
||||
use std::collections::HashMap;
|
||||
|
||||
/// 模块一：验证 Config 反序列化逻辑
|
||||
#[test]
|
||||
fn test_config_parsing_scenarios() {
|
||||
// 场景 A: 验证单接口配置 (增加 body 结构化校验)
|
||||
let yaml_single = r#"
|
||||
name: "auth_v1"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/v1/login"
|
||||
body: { "user": "admin" }
|
||||
response: { status: 200, body: "welcome" }
|
||||
"#;
|
||||
let source_s: MockSource = serde_yaml::from_str(yaml_single).expect("解析单接口失败");
|
||||
let rules = source_s.flatten();
|
||||
assert_eq!(rules.len(), 1);
|
||||
// 验证 body 是否被成功解析为 Value::Object
|
||||
assert!(rules[0].request.body.is_some());
|
||||
assert_eq!(rules[0].request.body.as_ref().unwrap()["user"], "admin");
|
||||
|
||||
// 场景 B: 验证多接口配置
|
||||
let yaml_multi = r#"
|
||||
- name: "api_1"
|
||||
request: { method: "GET", path: "/health" }
|
||||
response: { status: 200, body: "ok" }
|
||||
- name: "api_2"
|
||||
request: { method: "GET", path: "/version" }
|
||||
response: { status: 200, body: "1.0" }
|
||||
"#;
|
||||
let source_m: MockSource = serde_yaml::from_str(yaml_multi).expect("解析多接口失败");
|
||||
assert_eq!(source_m.flatten().len(), 2);
|
||||
|
||||
// 场景 C: 验证 Smart Body 的 file:// 协议字符串解析
|
||||
let yaml_file = r#"
|
||||
name: "export_api"
|
||||
request: { method: "GET", path: "/download" }
|
||||
response: { status: 200, body: "file://./storage/data.zip" }
|
||||
"#;
|
||||
let source_f: MockSource = serde_yaml::from_str(yaml_file).unwrap();
|
||||
let rule = &source_f.flatten()[0];
|
||||
assert!(rule.response.body.starts_with("file://"));
|
||||
}
|
||||
|
||||
/// 模块二：验证 Loader 递归扫描与索引构建
|
||||
#[test]
|
||||
fn test_loader_recursive_indexing() {
|
||||
let temp_root = tempdir().expect("无法创建临时目录");
|
||||
let root_path = temp_root.path();
|
||||
|
||||
let auth_path = root_path.join("v1/auth");
|
||||
fs::create_dir_all(&auth_path).unwrap();
|
||||
|
||||
let mut f1 = File::create(auth_path.join("single_login.yaml")).unwrap();
|
||||
writeln!(f1, "name: 'l1'\nrequest: {{ method: 'POST', path: '/api/v1/login' }}\nresponse: {{ status: 200, body: 'ok' }}").unwrap();
|
||||
|
||||
let mut f2 = File::create(root_path.join("sys.yaml")).unwrap();
|
||||
writeln!(f2, "- name: 's1'\n request: {{ method: 'GET', path: '/health' }}\n response: {{ status: 200, body: 'up' }}").unwrap();
|
||||
|
||||
let index = MockLoader::load_all_from_dir(root_path);
|
||||
|
||||
assert!(index.contains_key("api"));
|
||||
assert!(index.contains_key("health"));
|
||||
let total: usize = index.values().map(|v| v.len()).sum();
|
||||
assert_eq!(total, 2);
|
||||
}
|
||||
|
||||
/// 模块三：验证 Router 匹配逻辑（使用新的 Payload 类型）
|
||||
#[test]
|
||||
fn test_router_matching_logic() {
|
||||
let mut index = HashMap::new();
|
||||
|
||||
// 1. 准备带有 Body 的规则
|
||||
let rule_auth = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "auth_v1"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/v1/login"
|
||||
headers: { "Content-Type": "application/json" }
|
||||
body: { "code": 123 }
|
||||
response: { status: 200, body: "token_123" }
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
index.insert("api".to_string(), vec![rule_auth[0].clone()]);
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
// 2. 测试场景 A：JSON 完全匹配
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Content-Type".to_string(), "application/json".to_string());
|
||||
|
||||
let payload = Payload::Json(json!({ "code": 123 }));
|
||||
|
||||
let matched = router.match_rule(
|
||||
"POST",
|
||||
"/api/v1/login",
|
||||
&HashMap::new(),
|
||||
&headers,
|
||||
&payload,
|
||||
);
|
||||
assert!(matched.is_some());
|
||||
assert_eq!(matched.unwrap().name, "auth_v1");
|
||||
|
||||
// 3. 测试场景 B：Body 不匹配
|
||||
let wrong_payload = Payload::Json(json!({ "code": 456 }));
|
||||
let matched_fail = router.match_rule(
|
||||
"POST",
|
||||
"/api/v1/login",
|
||||
&HashMap::new(),
|
||||
&headers,
|
||||
&wrong_payload,
|
||||
);
|
||||
assert!(matched_fail.is_none(), "Body 不一致时不应匹配成功");
|
||||
|
||||
// 4. 测试场景 C：末尾斜杠兼容性测试
|
||||
let matched_slash = router.match_rule(
|
||||
"POST",
|
||||
"/api/v1/login/",
|
||||
&HashMap::new(),
|
||||
&headers,
|
||||
&payload,
|
||||
);
|
||||
assert!(matched_slash.is_some());
|
||||
}
|
||||
|
||||
/// 模块四：验证不同 Payload 类型的匹配
|
||||
#[test]
|
||||
fn test_payload_type_matching() {
|
||||
let mut index = HashMap::new();
|
||||
|
||||
// XML 规则
|
||||
let xml_rule = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "xml_api"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/xml"
|
||||
body: "<root><name>test</name></root>"
|
||||
response: { status: 200, body: "ok" }
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
// Form 规则
|
||||
let form_rule = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "form_api"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/form"
|
||||
body: { "username": "admin", "password": "123456" }
|
||||
response: { status: 200, body: "login_ok" }
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
// Text 规则
|
||||
let text_rule = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "text_api"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/text"
|
||||
body: "plain text content"
|
||||
response: { status: 200, body: "text_ok" }
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
index.insert("api".to_string(), vec![xml_rule[0].clone(), form_rule[0].clone(), text_rule[0].clone()]);
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
// 测试 XML 匹配
|
||||
let xml_payload = Payload::Xml("<root><name>test</name></root>".to_string());
|
||||
let xml_matched = router.match_rule("POST", "/api/xml", &HashMap::new(), &HashMap::new(), &xml_payload);
|
||||
assert!(xml_matched.is_some(), "XML 应该匹配");
|
||||
assert_eq!(xml_matched.unwrap().name, "xml_api");
|
||||
|
||||
// 测试 Form 匹配
|
||||
let mut form_data = HashMap::new();
|
||||
form_data.insert("username".to_string(), "admin".to_string());
|
||||
form_data.insert("password".to_string(), "123456".to_string());
|
||||
let form_payload = Payload::Form(form_data);
|
||||
let form_matched = router.match_rule("POST", "/api/form", &HashMap::new(), &HashMap::new(), &form_payload);
|
||||
assert!(form_matched.is_some(), "Form 应该匹配");
|
||||
assert_eq!(form_matched.unwrap().name, "form_api");
|
||||
|
||||
// 测试 Text 匹配
|
||||
let text_payload = Payload::Text("plain text content".to_string());
|
||||
let text_matched = router.match_rule("POST", "/api/text", &HashMap::new(), &HashMap::new(), &text_payload);
|
||||
assert!(text_matched.is_some(), "Text 应该匹配");
|
||||
assert_eq!(text_matched.unwrap().name, "text_api");
|
||||
|
||||
// 测试 None 不匹配
|
||||
let none_payload = Payload::None;
|
||||
let none_matched = router.match_rule("POST", "/api/text", &HashMap::new(), &HashMap::new(), &none_payload);
|
||||
assert!(none_matched.is_none(), "None 不应该匹配有 body 的规则");
|
||||
}
|
||||
|
||||
/// 模块五：验证 Payload 方法
|
||||
#[test]
|
||||
fn test_payload_methods() {
|
||||
// 测试 content_type_name
|
||||
assert_eq!(Payload::Json(json!({})).content_type_name(), "application/json");
|
||||
assert_eq!(Payload::Xml("".to_string()).content_type_name(), "application/xml");
|
||||
assert_eq!(Payload::Form(HashMap::new()).content_type_name(), "application/x-www-form-urlencoded");
|
||||
assert_eq!(Payload::Multipart(HashMap::new()).content_type_name(), "multipart/form-data");
|
||||
assert_eq!(Payload::Text("".to_string()).content_type_name(), "text/plain");
|
||||
assert_eq!(Payload::None.content_type_name(), "none");
|
||||
|
||||
// 测试 to_compare_string
|
||||
let json_payload = Payload::Json(json!({"a": 1, "b": 2}));
|
||||
assert!(json_payload.to_compare_string().contains("\"a\":1"));
|
||||
|
||||
let text_payload = Payload::Text("hello world".to_string());
|
||||
assert_eq!(text_payload.to_compare_string(), "hello world");
|
||||
|
||||
let none_payload = Payload::None;
|
||||
assert_eq!(none_payload.to_compare_string(), "");
|
||||
|
||||
// 测试 Form 排序后的字符串
|
||||
let mut form_map = HashMap::new();
|
||||
form_map.insert("b".to_string(), "2".to_string());
|
||||
form_map.insert("a".to_string(), "1".to_string());
|
||||
let form_payload = Payload::Form(form_map);
|
||||
assert_eq!(form_payload.to_compare_string(), "a=1&b=2");
|
||||
|
||||
// 测试 Multipart 排序后的字符串
|
||||
let mut multipart_map = HashMap::new();
|
||||
multipart_map.insert("b".to_string(), "2".to_string());
|
||||
multipart_map.insert("a".to_string(), "1".to_string());
|
||||
let multipart_payload = Payload::Multipart(multipart_map);
|
||||
assert_eq!(multipart_payload.to_compare_string(), "a=1&b=2");
|
||||
}
|
||||
|
||||
/// 模块六：验证 Multipart 匹配
|
||||
#[test]
|
||||
fn test_multipart_matching() {
|
||||
let mut index = HashMap::new();
|
||||
|
||||
// 数组形式：只匹配字段名
|
||||
let array_rule = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "upload_array"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/upload/array"
|
||||
body: ["file", "description"]
|
||||
response: { status: 200, body: "ok" }
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
// 对象形式：匹配键值对
|
||||
let object_rule = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "upload_object"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/upload/object"
|
||||
body: { "username": "admin", "role": "user" }
|
||||
response: { status: 200, body: "ok" }
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
index.insert("api".to_string(), vec![array_rule[0].clone(), object_rule[0].clone()]);
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
// 测试数组形式：匹配字段名
|
||||
let mut full_data = HashMap::new();
|
||||
full_data.insert("file".to_string(), "file_content".to_string());
|
||||
full_data.insert("description".to_string(), "test file".to_string());
|
||||
let full_payload = Payload::Multipart(full_data);
|
||||
let matched = router.match_rule("POST", "/api/upload/array", &HashMap::new(), &HashMap::new(), &full_payload);
|
||||
assert!(matched.is_some(), "包含所有字段应该匹配");
|
||||
|
||||
// 测试数组形式：缺少字段
|
||||
let mut partial_data = HashMap::new();
|
||||
partial_data.insert("file".to_string(), "file_content".to_string());
|
||||
let partial_payload = Payload::Multipart(partial_data);
|
||||
let not_matched = router.match_rule("POST", "/api/upload/array", &HashMap::new(), &HashMap::new(), &partial_payload);
|
||||
assert!(not_matched.is_none(), "缺少字段不应该匹配");
|
||||
|
||||
// 测试对象形式：键名匹配（值被忽略）
|
||||
let mut correct_data = HashMap::new();
|
||||
correct_data.insert("username".to_string(), "any_value".to_string()); // 值不重要
|
||||
correct_data.insert("role".to_string(), "any_role".to_string());
|
||||
let correct_payload = Payload::Multipart(correct_data);
|
||||
let object_matched = router.match_rule("POST", "/api/upload/object", &HashMap::new(), &HashMap::new(), &correct_payload);
|
||||
assert!(object_matched.is_some(), "键名匹配应该成功");
|
||||
|
||||
// 测试对象形式：键名不匹配
|
||||
let mut wrong_data = HashMap::new();
|
||||
wrong_data.insert("username".to_string(), "admin".to_string());
|
||||
wrong_data.insert("other_field".to_string(), "value".to_string()); // 缺少 role 字段
|
||||
let wrong_payload = Payload::Multipart(wrong_data);
|
||||
let wrong_matched = router.match_rule("POST", "/api/upload/object", &HashMap::new(), &HashMap::new(), &wrong_payload);
|
||||
assert!(wrong_matched.is_none(), "缺少键名不应该成功");
|
||||
}
|
||||
|
||||
/// 模块七：验证 YAML 块语法（折叠 `>` 和字面量 `|`）
|
||||
#[test]
|
||||
fn test_yaml_block_syntax() {
|
||||
let mut index = HashMap::new();
|
||||
|
||||
// 使用折叠语法 `>` 的规则
|
||||
let folded_rule = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "folded_api"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/folded"
|
||||
body: >
|
||||
{"username":"admin","password":"123456"}
|
||||
response:
|
||||
status: 200
|
||||
body: "ok"
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
// 使用字面量语法 `|` 的规则
|
||||
let literal_rule = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "literal_api"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/literal"
|
||||
body: |
|
||||
{"username":"test","password":"abcdef"}
|
||||
response:
|
||||
status: 200
|
||||
body: "ok"
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
index.insert("api".to_string(), vec![folded_rule[0].clone(), literal_rule[0].clone()]);
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
// 测试折叠语法：YAML 中 `>` 会把内容合并成一行，但仍是字符串
|
||||
// 程序应该能将字符串解析为 JSON 后匹配
|
||||
let folded_payload = Payload::Json(json!({"username":"admin","password":"123456"}));
|
||||
let folded_matched = router.match_rule("POST", "/api/folded", &HashMap::new(), &HashMap::new(), &folded_payload);
|
||||
assert!(folded_matched.is_some(), "折叠语法应该匹配 JSON 请求");
|
||||
assert_eq!(folded_matched.unwrap().name, "folded_api");
|
||||
|
||||
// 测试字面量语法：YAML 中 `|` 保留换行
|
||||
let literal_payload = Payload::Json(json!({"username":"test","password":"abcdef"}));
|
||||
let literal_matched = router.match_rule("POST", "/api/literal", &HashMap::new(), &HashMap::new(), &literal_payload);
|
||||
assert!(literal_matched.is_some(), "字面量语法应该匹配 JSON 请求");
|
||||
assert_eq!(literal_matched.unwrap().name, "literal_api");
|
||||
|
||||
// 测试不匹配的情况
|
||||
let wrong_payload = Payload::Json(json!({"username":"wrong","password":"wrong"}));
|
||||
let wrong_matched = router.match_rule("POST", "/api/folded", &HashMap::new(), &HashMap::new(), &wrong_payload);
|
||||
assert!(wrong_matched.is_none(), "错误的 body 不应该匹配");
|
||||
}
|
||||
|
||||
/// 模块八：验证 XML 格式化匹配
|
||||
#[test]
|
||||
fn test_xml_normalized_matching() {
|
||||
let mut index = HashMap::new();
|
||||
|
||||
// YAML 中的 XML（带格式化）
|
||||
let xml_rule = serde_yaml::from_str::<MockSource>(
|
||||
r#"
|
||||
name: "xml_api"
|
||||
request:
|
||||
method: "POST"
|
||||
path: "/api/xml"
|
||||
body: |
|
||||
<user>
|
||||
<id>1001</id>
|
||||
<name>张三</name>
|
||||
</user>
|
||||
response:
|
||||
status: 200
|
||||
body: "ok"
|
||||
"#,
|
||||
)
|
||||
.unwrap()
|
||||
.flatten();
|
||||
|
||||
index.insert("api".to_string(), vec![xml_rule[0].clone()]);
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
// 测试 1：完全相同的格式化 XML
|
||||
let formatted_xml = Payload::Xml("<user>\n <id>1001</id>\n <name>张三</name>\n</user>".to_string());
|
||||
let matched1 = router.match_rule("POST", "/api/xml", &HashMap::new(), &HashMap::new(), &formatted_xml);
|
||||
assert!(matched1.is_some(), "格式化 XML 应该匹配");
|
||||
|
||||
// 测试 2：紧凑格式的 XML
|
||||
let compact_xml = Payload::Xml("<user><id>1001</id><name>张三</name></user>".to_string());
|
||||
let matched2 = router.match_rule("POST", "/api/xml", &HashMap::new(), &HashMap::new(), &compact_xml);
|
||||
assert!(matched2.is_some(), "紧凑格式 XML 应该匹配");
|
||||
|
||||
// 测试 3：带 XML 声明的请求
|
||||
let xml_with_decl = Payload::Xml("<?xml version=\"1.0\" encoding=\"UTF-8\"?><user><id>1001</id><name>张三</name></user>".to_string());
|
||||
let matched3 = router.match_rule("POST", "/api/xml", &HashMap::new(), &HashMap::new(), &xml_with_decl);
|
||||
assert!(matched3.is_some(), "带声明的 XML 应该匹配");
|
||||
|
||||
// 测试 4：内容不同，不应该匹配
|
||||
let wrong_xml = Payload::Xml("<user><id>1002</id><name>李四</name></user>".to_string());
|
||||
let matched4 = router.match_rule("POST", "/api/xml", &HashMap::new(), &HashMap::new(), &wrong_xml);
|
||||
assert!(matched4.is_none(), "内容不同的 XML 不应该匹配");
|
||||
}
|
||||
@@ -0,0 +1,238 @@
|
||||
use std::path::Path;
|
||||
use std::collections::HashMap;
|
||||
use serde_json::json;
|
||||
use mock_server::models::Payload;
|
||||
use mock_server::loader::MockLoader;
|
||||
use mock_server::router::MockRouter;
|
||||
|
||||
/// 加载 v1 目录的 mock 规则
|
||||
fn load_v2_mocks() -> HashMap<String, Vec<mock_server::models::MockRule>> {
|
||||
let v2_path = Path::new("../mocks/v1");
|
||||
MockLoader::load_all_from_dir(v2_path)
|
||||
}
|
||||
|
||||
// ========== 模块一：验证所有 YAML 文件正确加载 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_load_all_mocks() {
|
||||
let index = load_v2_mocks();
|
||||
|
||||
// 验证索引键存在
|
||||
assert!(index.contains_key("v1"), "应包含 'v2' 索引键");
|
||||
|
||||
// 验证规则总数
|
||||
let total: usize = index.values().map(|v| v.len()).sum();
|
||||
assert_eq!(total, 9, "v2 目录应有 9 个 mock 规则");
|
||||
}
|
||||
|
||||
// ========== 模块二：JSON Payload 测试 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_json_login() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Content-Type".to_string(), "application/json".to_string());
|
||||
|
||||
let payload = Payload::Json(json!({
|
||||
"username": "admin",
|
||||
"password": "password123"
|
||||
}));
|
||||
|
||||
let matched = router.match_rule("POST", "/v1/auth/login", &HashMap::new(), &headers, &payload);
|
||||
|
||||
assert!(matched.is_some(), "JSON 登录应匹配成功");
|
||||
let rule = matched.unwrap();
|
||||
assert_eq!(rule.name, "v2_user_login");
|
||||
assert_eq!(rule.response.status, 200);
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn test_v2_json_register() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Content-Type".to_string(), "application/json".to_string());
|
||||
|
||||
let payload = Payload::Json(json!({
|
||||
"username": "newuser",
|
||||
"password": "newpass123",
|
||||
"email": "[email protected]"
|
||||
}));
|
||||
|
||||
let matched = router.match_rule("POST", "/v1/auth/register", &HashMap::new(), &headers, &payload);
|
||||
|
||||
assert!(matched.is_some(), "JSON 注册应匹配成功");
|
||||
let rule = matched.unwrap();
|
||||
assert_eq!(rule.name, "v2_user_register");
|
||||
assert_eq!(rule.response.status, 201);
|
||||
}
|
||||
|
||||
// ========== 模块三：Form Payload 测试 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_form_login() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Content-Type".to_string(), "application/x-www-form-urlencoded".to_string());
|
||||
|
||||
let mut form_data = HashMap::new();
|
||||
form_data.insert("username".to_string(), "formuser".to_string());
|
||||
form_data.insert("password".to_string(), "formpass".to_string());
|
||||
let payload = Payload::Form(form_data);
|
||||
|
||||
let matched = router.match_rule("POST", "/v1/user/login/form", &HashMap::new(), &headers, &payload);
|
||||
|
||||
assert!(matched.is_some(), "Form 登录应匹配成功");
|
||||
assert_eq!(matched.unwrap().name, "v2_user_login_form");
|
||||
}
|
||||
|
||||
// ========== 模块四：Text Payload 测试 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_text_echo() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Content-Type".to_string(), "text/plain".to_string());
|
||||
|
||||
let payload = Payload::Text("Hello V2 Mock Server".to_string());
|
||||
|
||||
let matched = router.match_rule("POST", "/v1/user/echo", &HashMap::new(), &headers, &payload);
|
||||
|
||||
assert!(matched.is_some(), "Text 回显应匹配成功");
|
||||
let rule = matched.unwrap();
|
||||
assert_eq!(rule.name, "v2_user_echo");
|
||||
assert!(rule.response.body.contains("Echo from V2"));
|
||||
}
|
||||
|
||||
// ========== 模块五：XML Payload 测试 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_xml_export() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Content-Type".to_string(), "application/xml".to_string());
|
||||
|
||||
let xml_body = r#"<request><userId>10001</userId><format>xml</format></request>"#;
|
||||
let payload = Payload::Xml(xml_body.to_string());
|
||||
|
||||
let matched = router.match_rule("POST", "/v1/data/export", &HashMap::new(), &headers, &payload);
|
||||
|
||||
assert!(matched.is_some(), "XML 导出应匹配成功");
|
||||
assert_eq!(matched.unwrap().name, "v2_data_export");
|
||||
}
|
||||
|
||||
// ========== 模块六：Multipart Payload 测试 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_multipart_upload() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Content-Type".to_string(), "multipart/form-data".to_string());
|
||||
|
||||
let mut multipart_data = HashMap::new();
|
||||
multipart_data.insert("avatar".to_string(), "file_content".to_string());
|
||||
multipart_data.insert("description".to_string(), "user avatar".to_string());
|
||||
let payload = Payload::Multipart(multipart_data);
|
||||
|
||||
let matched = router.match_rule("POST", "/v1/user/avatar", &HashMap::new(), &headers, &payload);
|
||||
|
||||
assert!(matched.is_some(), "Multipart 上传应匹配成功");
|
||||
assert_eq!(matched.unwrap().name, "v2_user_upload_avatar");
|
||||
}
|
||||
|
||||
// ========== 模块七：None Payload 测试 (GET 无 Body) ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_health_check() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let payload = Payload::None;
|
||||
|
||||
let matched = router.match_rule("GET", "/v1/health", &HashMap::new(), &HashMap::new(), &payload);
|
||||
|
||||
assert!(matched.is_some(), "健康检查应匹配成功");
|
||||
let rule = matched.unwrap();
|
||||
assert_eq!(rule.name, "v2_health_check");
|
||||
assert_eq!(rule.response.status, 200);
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn test_v2_get_profile() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Authorization".to_string(), "Bearer v2_test_token".to_string());
|
||||
|
||||
let payload = Payload::None;
|
||||
|
||||
let matched = router.match_rule("GET", "/v1/user/profile", &HashMap::new(), &headers, &payload);
|
||||
|
||||
assert!(matched.is_some(), "获取用户信息应匹配成功");
|
||||
assert_eq!(matched.unwrap().name, "v2_user_profile");
|
||||
}
|
||||
|
||||
// ========== 模块八：Query Params 测试 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_query_params() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
let mut query = HashMap::new();
|
||||
query.insert("format".to_string(), "json".to_string());
|
||||
|
||||
let payload = Payload::None;
|
||||
|
||||
let matched = router.match_rule("GET", "/v1/user/download", &query, &HashMap::new(), &payload);
|
||||
|
||||
assert!(matched.is_some(), "带 query params 的下载应匹配成功");
|
||||
let rule = matched.unwrap();
|
||||
assert_eq!(rule.name, "v2_user_download");
|
||||
assert!(rule.response.body.starts_with("file://"));
|
||||
}
|
||||
|
||||
// ========== 模块九：Header 匹配测试 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_header_required() {
|
||||
let index = load_v2_mocks();
|
||||
let router = MockRouter::new(index);
|
||||
|
||||
// 无 Authorization header 不应匹配
|
||||
let payload = Payload::None;
|
||||
let no_match = router.match_rule("GET", "/v1/user/profile", &HashMap::new(), &HashMap::new(), &payload);
|
||||
assert!(no_match.is_none(), "无 Authorization 不应匹配");
|
||||
|
||||
// 有正确的 Authorization header 应匹配
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("Authorization".to_string(), "Bearer v2_test_token".to_string());
|
||||
let matched = router.match_rule("GET", "/v1/user/profile", &HashMap::new(), &headers, &payload);
|
||||
assert!(matched.is_some(), "有 Authorization 应匹配");
|
||||
}
|
||||
|
||||
// ========== 模块十：name 字段验证 ==========
|
||||
|
||||
#[test]
|
||||
fn test_v2_all_rules_have_name() {
|
||||
let index = load_v2_mocks();
|
||||
|
||||
for (key, rules) in &index {
|
||||
for rule in rules {
|
||||
assert!(!rule.name.is_empty(), "规则 name 不能为空");
|
||||
assert!(rule.name.starts_with("v2_"), "v2 规则 name 应以 'v2_' 开头");
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user