1105 lines
41 KiB
Rust
1105 lines
41 KiB
Rust
//! Convex workspace / control-plane / compat transport bridge.
|
|
//!
|
|
//! local-first 主链下，本地 Markdown 正文、附件和资源文件不以这里作为真源。
|
|
//! 这个 crate 只保留用于 Convex workspace、历史 documents.* 兼容命令、
|
|
//! control-plane 查询和迁移期执行计划映射。
|
|
|
|
pub mod context;
|
|
pub mod mapping;
|
|
pub mod read_path;
|
|
pub mod types;
|
|
pub mod validation;
|
|
pub mod write_path;
|
|
|
|
pub use context::BridgeContext;
|
|
pub use mapping::{
|
|
map_command_name_to_convex, map_query_name_to_convex, ConvexMutationRequest, ConvexQueryRequest,
|
|
};
|
|
pub use read_path::{build_query_request, QueryReadResult};
|
|
pub use types::{BridgeError, BridgeErrorKind, BridgeResult};
|
|
pub use validation::{validate_command_envelope, validate_query_envelope};
|
|
pub use write_path::{
|
|
build_command_log_record, build_domain_event_record, build_write_pipeline, build_write_request,
|
|
WritePipelineResult,
|
|
};
|
|
|
|
#[cfg(test)]
|
|
mod tests {
|
|
use super::*;
|
|
use core_protocol::{
|
|
command::{
|
|
CopyTreeDocumentPages, CreateDocumentPage, CreatePage, CreateWorkspace,
|
|
DeleteDocumentPage, DuplicateDocumentPage, MoveDocumentPage, PatchPageBlock,
|
|
PutMindmap, ReplaceMediaAssetStorage, RestoreDocumentPage, SavePageContent,
|
|
UpdatePageOptions, UpdatePageStats, UpdatePageTitle,
|
|
},
|
|
query::{
|
|
GetBlock, GetBridgeCommand, GetBridgeRequest, GetBridgeTrace, GetMindmap, GetPage,
|
|
GetPageContent, GetPageMeta, ListBridgeWorkspaceOverview, ListSidebarDataset,
|
|
SearchDocuments, SearchRecent,
|
|
},
|
|
ActorPayload, CommandEnvelope, QueryEnvelope, SourcePayload, TargetRef,
|
|
};
|
|
|
|
fn demo_context() -> BridgeContext {
|
|
BridgeContext {
|
|
deployment_id: Some("dep_1".into()),
|
|
project_id: Some("proj_1".into()),
|
|
request_id: "req_1".into(),
|
|
trace_id: "trace_1".into(),
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
workspace_id: Some("ws_1".into()),
|
|
tenant_id: Some("tenant_1".into()),
|
|
auth_token: Some("token_1".into()),
|
|
source_channel: "cli".into(),
|
|
source_client: "mnote-cli".into(),
|
|
idempotency_key: Some("idem_ctx".into()),
|
|
validate_only: false,
|
|
dry_run: false,
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn build_write_request_keeps_workspace_scope() {
|
|
let command = CommandEnvelope {
|
|
name: "create_page".into(),
|
|
command_id: "cmd_1".into(),
|
|
idempotency_key: Some("idem_cmd".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "cli".into(),
|
|
client: "mnote-cli".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: None,
|
|
block_id: None,
|
|
}),
|
|
payload: CreatePage {
|
|
title: "第一页".into(),
|
|
parent_page_id: None,
|
|
position: None,
|
|
},
|
|
reason: Some("初始化页面".into()),
|
|
refs: vec!["spec:phase1-f".into()],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "pages:create");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert_eq!(request.deployment_id.as_deref(), Some("dep_1"));
|
|
assert_eq!(request.project_id.as_deref(), Some("proj_1"));
|
|
assert_eq!(request.idempotency_key.as_deref(), Some("idem_cmd"));
|
|
assert!(request.payload_json.contains("\"kind\":\"command\""));
|
|
assert!(request.payload_json.contains("\"name\":\"create_page\""));
|
|
}
|
|
|
|
#[test]
|
|
fn build_query_request_includes_trace_and_workspace() {
|
|
let query = QueryEnvelope {
|
|
name: "get_page".into(),
|
|
payload: GetPage {
|
|
page_id: "page_1".into(),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "pages:get");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert_eq!(request.request_id, "req_1");
|
|
assert_eq!(request.trace_id, "trace_1");
|
|
assert!(request.payload_json.contains("\"kind\":\"query\""));
|
|
assert!(request.payload_json.contains("\"name\":\"get_page\""));
|
|
}
|
|
|
|
#[test]
|
|
fn build_write_pipeline_sets_trace_fields() {
|
|
let command = CommandEnvelope {
|
|
name: "create_workspace".into(),
|
|
command_id: "cmd_2".into(),
|
|
idempotency_key: None,
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "cli".into(),
|
|
client: "mnote-cli".into(),
|
|
},
|
|
target: None,
|
|
payload: CreateWorkspace {
|
|
name: "demo".into(),
|
|
slug: Some("demo".into()),
|
|
},
|
|
reason: Some("初始化工作区".into()),
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let pipeline =
|
|
build_write_pipeline(&demo_context(), &command).expect("pipeline should build");
|
|
assert_eq!(pipeline.command_log.command_name, "create_workspace");
|
|
assert!(pipeline
|
|
.command_log
|
|
.payload_summary
|
|
.contains("request_id=req_1"));
|
|
assert_eq!(pipeline.command_log.trace_id, "trace_1");
|
|
assert_eq!(pipeline.command_log.request_id, "req_1");
|
|
assert!(pipeline
|
|
.domain_event
|
|
.payload_json
|
|
.contains("\"trace_id\":\"trace_1\""));
|
|
assert_eq!(pipeline.result.event_ids, vec!["evt_cmd_2".to_string()]);
|
|
}
|
|
|
|
#[test]
|
|
fn document_title_command_maps_to_documents_update_title() {
|
|
let command = CommandEnvelope {
|
|
name: "documents.title.update".into(),
|
|
command_id: "cmd_title_1".into(),
|
|
idempotency_key: Some("idem_title".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: UpdatePageTitle {
|
|
page_id: "page_1".into(),
|
|
title: "新标题".into(),
|
|
},
|
|
reason: None,
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateTitle");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"documents.title.update\""));
|
|
}
|
|
|
|
#[test]
|
|
fn page_head_update_title_command_maps_to_documents_update_title() {
|
|
let command = CommandEnvelope {
|
|
name: "page.head.updateTitle".into(),
|
|
command_id: "cmd_page_title_1".into(),
|
|
idempotency_key: Some("idem_page_title".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: UpdatePageTitle {
|
|
page_id: "page_1".into(),
|
|
title: "新标题".into(),
|
|
},
|
|
reason: None,
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateTitle");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"page.head.updateTitle\""));
|
|
}
|
|
|
|
#[test]
|
|
fn tree_resource_lifecycle_commands_have_convex_mapping() {
|
|
let cases = [
|
|
("tree.resource.archive", "mediaAssets:patchById"),
|
|
("tree.resource.restore", "mediaAssets:patchById"),
|
|
("tree.resource.purge", "mediaAssets:purgeById"),
|
|
("tree.resource.rename", "mediaAssets:patchById"),
|
|
];
|
|
|
|
for (command_name, function_name) in cases {
|
|
let command = CommandEnvelope {
|
|
name: command_name.into(),
|
|
command_id: format!("cmd_{command_name}"),
|
|
idempotency_key: Some(format!("idem_{command_name}")),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("doc_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: 1,
|
|
reason: None,
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, function_name);
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains(&format!("\"name\":\"{command_name}\"")));
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn document_save_command_maps_to_documents_update_content() {
|
|
let command = CommandEnvelope {
|
|
name: "documents.save".into(),
|
|
command_id: "cmd_save_1".into(),
|
|
idempotency_key: Some("idem_save".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: SavePageContent {
|
|
page_id: "page_1".into(),
|
|
workspace_id: Some("ws_1".into()),
|
|
revision: Some(42),
|
|
content_json: "{\"type\":\"doc\"}".into(),
|
|
conflict_detection_key: Some("rev:42".into()),
|
|
},
|
|
reason: Some("保存正文".into()),
|
|
refs: vec!["checklist:c3".into()],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateContent");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request.payload_json.contains("\"name\":\"documents.save\""));
|
|
}
|
|
|
|
#[test]
|
|
fn page_body_save_command_maps_to_documents_update_content() {
|
|
let command = CommandEnvelope {
|
|
name: "page.body.save".into(),
|
|
command_id: "cmd_page_save_1".into(),
|
|
idempotency_key: Some("idem_page_save".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: SavePageContent {
|
|
page_id: "page_1".into(),
|
|
workspace_id: Some("ws_1".into()),
|
|
revision: Some(42),
|
|
content_json: "{\"type\":\"doc\"}".into(),
|
|
conflict_detection_key: Some("rev:42".into()),
|
|
},
|
|
reason: Some("保存正文".into()),
|
|
refs: vec!["checklist:c3".into()],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateContent");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request.payload_json.contains("\"name\":\"page.body.save\""));
|
|
}
|
|
|
|
#[test]
|
|
fn document_embed_command_maps_to_documents_update_content() {
|
|
let command = CommandEnvelope {
|
|
name: "documents.embed".into(),
|
|
command_id: "cmd_embed_1".into(),
|
|
idempotency_key: Some("idem_embed".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_2".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: SavePageContent {
|
|
page_id: "page_2".into(),
|
|
workspace_id: Some("ws_1".into()),
|
|
revision: Some(7),
|
|
content_json: "{\"blocks\":[{\"id\":\"block_1\",\"type\":\"pageReference\"}]}"
|
|
.into(),
|
|
conflict_detection_key: Some("rev:7".into()),
|
|
},
|
|
reason: Some("嵌入页面".into()),
|
|
refs: vec!["checklist:p1-3".into()],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateContent");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"documents.embed\""));
|
|
}
|
|
|
|
#[test]
|
|
fn page_lifecycle_commands_map_to_document_mutations() {
|
|
let base_actor = ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
};
|
|
let base_source = SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
};
|
|
|
|
let create_request = build_write_request(
|
|
&demo_context(),
|
|
&CommandEnvelope {
|
|
name: "documents.create".into(),
|
|
command_id: "cmd_create_1".into(),
|
|
idempotency_key: Some("idem_create".into()),
|
|
actor: base_actor.clone(),
|
|
source: base_source.clone(),
|
|
target: Some(TargetRef {
|
|
workspace_id: None,
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: CreateDocumentPage {
|
|
page_id: "page_1".into(),
|
|
parent_page_id: Some("parent_1".into()),
|
|
title: "无标题".into(),
|
|
workspace_seed_id: "ws_seed_1".into(),
|
|
},
|
|
reason: Some("创建页面".into()),
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
},
|
|
)
|
|
.expect("create request should build");
|
|
assert_eq!(
|
|
create_request.function_name,
|
|
"documents:createWithParentReference"
|
|
);
|
|
|
|
let move_request = build_write_request(
|
|
&demo_context(),
|
|
&CommandEnvelope {
|
|
name: "documents.move".into(),
|
|
command_id: "cmd_move_1".into(),
|
|
idempotency_key: Some("idem_move".into()),
|
|
actor: base_actor.clone(),
|
|
source: base_source.clone(),
|
|
target: Some(TargetRef {
|
|
workspace_id: None,
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: MoveDocumentPage {
|
|
page_id: "page_1".into(),
|
|
parent_page_id: Some("parent_2".into()),
|
|
sort_order: 3,
|
|
},
|
|
reason: Some("移动页面".into()),
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
},
|
|
)
|
|
.expect("move request should build");
|
|
assert_eq!(move_request.function_name, "documents:move");
|
|
|
|
let delete_request = build_write_request(
|
|
&demo_context(),
|
|
&CommandEnvelope {
|
|
name: "documents.delete".into(),
|
|
command_id: "cmd_delete_1".into(),
|
|
idempotency_key: Some("idem_delete".into()),
|
|
actor: base_actor.clone(),
|
|
source: base_source.clone(),
|
|
target: Some(TargetRef {
|
|
workspace_id: None,
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: DeleteDocumentPage {
|
|
page_id: "page_1".into(),
|
|
},
|
|
reason: Some("删除页面".into()),
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
},
|
|
)
|
|
.expect("delete request should build");
|
|
assert_eq!(delete_request.function_name, "documents:softDelete");
|
|
|
|
let restore_request = build_write_request(
|
|
&demo_context(),
|
|
&CommandEnvelope {
|
|
name: "documents.restore".into(),
|
|
command_id: "cmd_restore_1".into(),
|
|
idempotency_key: Some("idem_restore".into()),
|
|
actor: base_actor.clone(),
|
|
source: base_source.clone(),
|
|
target: Some(TargetRef {
|
|
workspace_id: None,
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: RestoreDocumentPage {
|
|
page_id: "page_1".into(),
|
|
},
|
|
reason: Some("恢复页面".into()),
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
},
|
|
)
|
|
.expect("restore request should build");
|
|
assert_eq!(restore_request.function_name, "documents:restore");
|
|
|
|
let duplicate_request = build_write_request(
|
|
&demo_context(),
|
|
&CommandEnvelope {
|
|
name: "documents.duplicate".into(),
|
|
command_id: "cmd_duplicate_1".into(),
|
|
idempotency_key: Some("idem_duplicate".into()),
|
|
actor: base_actor.clone(),
|
|
source: base_source.clone(),
|
|
target: Some(TargetRef {
|
|
workspace_id: None,
|
|
page_id: Some("page_copy_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: DuplicateDocumentPage {
|
|
source_page_id: "page_1".into(),
|
|
new_page_id: "page_copy_1".into(),
|
|
title: Some("无标题 副本".into()),
|
|
},
|
|
reason: Some("复制页面".into()),
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
},
|
|
)
|
|
.expect("duplicate request should build");
|
|
assert_eq!(
|
|
duplicate_request.function_name,
|
|
"documents:duplicateWithMindmaps"
|
|
);
|
|
|
|
let copy_tree_request = build_write_request(
|
|
&demo_context(),
|
|
&CommandEnvelope {
|
|
name: "documents.copy_tree".into(),
|
|
command_id: "cmd_copy_tree_1".into(),
|
|
idempotency_key: Some("idem_copy_tree".into()),
|
|
actor: base_actor,
|
|
source: base_source,
|
|
target: Some(TargetRef {
|
|
workspace_id: None,
|
|
page_id: Some("target_parent_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: CopyTreeDocumentPages {
|
|
items_json: "[{\"documentId\":\"page_1\",\"recursive\":true}]".into(),
|
|
target_parent_page_id: Some("target_parent_1".into()),
|
|
},
|
|
reason: Some("复制页面树".into()),
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
},
|
|
)
|
|
.expect("copy tree request should build");
|
|
assert_eq!(copy_tree_request.function_name, "documents:copyTree");
|
|
}
|
|
|
|
#[test]
|
|
fn block_patch_command_maps_to_documents_update_content() {
|
|
let command = CommandEnvelope {
|
|
name: "blocks.patch".into(),
|
|
command_id: "cmd_patch_1".into(),
|
|
idempotency_key: Some("idem_patch".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: Some("block_1".into()),
|
|
}),
|
|
payload: PatchPageBlock {
|
|
page_id: "page_1".into(),
|
|
block_id: "block_1".into(),
|
|
workspace_id: Some("ws_1".into()),
|
|
revision: Some(7),
|
|
block_snapshot_json: "{\"id\":\"block_1\",\"type\":\"paragraph\"}".into(),
|
|
conflict_detection_key: Some("page:1:block:1".into()),
|
|
},
|
|
reason: Some("替换块快照".into()),
|
|
refs: vec!["checklist:c3".into()],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateContent");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request.payload_json.contains("\"name\":\"blocks.patch\""));
|
|
}
|
|
|
|
#[test]
|
|
fn blocks_get_query_maps_to_blocks_get_by_id() {
|
|
let query = QueryEnvelope {
|
|
name: "blocks.get".into(),
|
|
payload: GetBlock {
|
|
block_id: "block_1".into(),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "blocks:getById");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request.payload_json.contains("\"name\":\"blocks.get\""));
|
|
}
|
|
|
|
#[test]
|
|
fn document_stats_command_maps_to_documents_update_stats() {
|
|
let command = CommandEnvelope {
|
|
name: "documents.stats.update".into(),
|
|
command_id: "cmd_stats_1".into(),
|
|
idempotency_key: Some("idem_stats".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: UpdatePageStats {
|
|
page_id: "page_1".into(),
|
|
word_count: 10,
|
|
character_count: 20,
|
|
block_count: 3,
|
|
todo_total: 4,
|
|
todo_done: 1,
|
|
},
|
|
reason: None,
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateStats");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"documents.stats.update\""));
|
|
}
|
|
|
|
#[test]
|
|
fn document_options_command_maps_to_documents_update_options() {
|
|
let command = CommandEnvelope {
|
|
name: "documents.options.update".into(),
|
|
command_id: "cmd_options_1".into(),
|
|
idempotency_key: Some("idem_options".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: UpdatePageOptions {
|
|
page_id: "page_1".into(),
|
|
wide_layout: None,
|
|
small_text: None,
|
|
show_heading_numbers: None,
|
|
show_toc: Some(true),
|
|
show_structure: None,
|
|
protect_editing: None,
|
|
show_word_count: None,
|
|
collapse_backlinks: None,
|
|
page_font: None,
|
|
layout_density: Some("compact".into()),
|
|
hide_child_pages: None,
|
|
show_block_ref_count: None,
|
|
embed_default_block_id: None,
|
|
},
|
|
reason: None,
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateOptions");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"documents.options.update\""));
|
|
}
|
|
|
|
#[test]
|
|
fn page_layout_update_options_command_maps_to_documents_update_options() {
|
|
let command = CommandEnvelope {
|
|
name: "page.layout.updateOptions".into(),
|
|
command_id: "cmd_page_options_1".into(),
|
|
idempotency_key: Some("idem_page_options".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "next-route".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: UpdatePageOptions {
|
|
page_id: "page_1".into(),
|
|
wide_layout: None,
|
|
small_text: None,
|
|
show_heading_numbers: None,
|
|
show_toc: Some(true),
|
|
show_structure: None,
|
|
protect_editing: None,
|
|
show_word_count: None,
|
|
collapse_backlinks: None,
|
|
page_font: None,
|
|
layout_density: Some("compact".into()),
|
|
hide_child_pages: None,
|
|
show_block_ref_count: None,
|
|
embed_default_block_id: None,
|
|
},
|
|
reason: None,
|
|
refs: vec![],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "documents:updateOptions");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"page.layout.updateOptions\""));
|
|
}
|
|
|
|
#[test]
|
|
fn media_asset_writeback_command_maps_to_replace_storage_from_upload() {
|
|
let command = CommandEnvelope {
|
|
name: "media.assets.replace_storage".into(),
|
|
command_id: "cmd_asset_1".into(),
|
|
idempotency_key: Some("idem_asset".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "service".into(),
|
|
actor_id: "onlyoffice-callback".into(),
|
|
session_id: Some("onlyoffice".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "onlyoffice-callback".into(),
|
|
client: "mnote-web".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: None,
|
|
}),
|
|
payload: ReplaceMediaAssetStorage {
|
|
asset_id: "asset_1".into(),
|
|
storage_id: "storage_1".into(),
|
|
},
|
|
reason: Some("ONLYOFFICE 回调写回附件".into()),
|
|
refs: vec!["checklist:d".into()],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(
|
|
request.function_name,
|
|
"mediaAssets:replaceStorageFromUpload"
|
|
);
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"media.assets.replace_storage\""));
|
|
}
|
|
|
|
#[test]
|
|
fn document_meta_query_maps_to_documents_get_meta() {
|
|
let query = QueryEnvelope {
|
|
name: "documents.meta.get".into(),
|
|
payload: GetPageMeta {
|
|
page_id: "page_1".into(),
|
|
workspace_id: Some("ws_1".into()),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "documents:getMeta");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"documents.meta.get\""));
|
|
}
|
|
|
|
#[test]
|
|
fn document_content_query_maps_to_documents_get_content() {
|
|
let query = QueryEnvelope {
|
|
name: "documents.content.get".into(),
|
|
payload: GetPageContent {
|
|
page_id: "page_1".into(),
|
|
workspace_id: Some("ws_1".into()),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "documents:getContent");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"documents.content.get\""));
|
|
}
|
|
|
|
#[test]
|
|
fn mindmap_get_query_maps_to_mindmaps_get() {
|
|
let query = QueryEnvelope {
|
|
name: "mindmaps.get".into(),
|
|
payload: GetMindmap {
|
|
document_id: "page_1".into(),
|
|
mindmap_id: "mind_1".into(),
|
|
workspace_id: Some("ws_1".into()),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "mindmaps:get");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request.payload_json.contains("\"name\":\"mindmaps.get\""));
|
|
}
|
|
|
|
#[test]
|
|
fn mindmap_editor_scene_query_maps_to_mindmaps_get_editor_scene() {
|
|
let query = QueryEnvelope {
|
|
name: "mindmap.editor_scene.get".into(),
|
|
payload: GetMindmap {
|
|
document_id: "page_1".into(),
|
|
mindmap_id: "mind_1".into(),
|
|
workspace_id: Some("ws_1".into()),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "mindmaps:getEditorScene");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"mindmap.editor_scene.get\""));
|
|
}
|
|
|
|
#[test]
|
|
fn sidebar_dataset_query_maps_to_sidebar_dataset_list() {
|
|
let query = QueryEnvelope {
|
|
name: "sidebar.dataset.list".into(),
|
|
payload: ListSidebarDataset {
|
|
workspace_id: "ws_1".into(),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "sidebar:datasetList");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"sidebar.dataset.list\""));
|
|
}
|
|
|
|
#[test]
|
|
fn search_documents_query_maps_to_search_documents() {
|
|
let query = QueryEnvelope {
|
|
name: "search.documents".into(),
|
|
payload: SearchDocuments {
|
|
query: "rust".into(),
|
|
workspace_id: "ws_1".into(),
|
|
page_id: Some("page_1".into()),
|
|
pagination: core_protocol::query::Pagination {
|
|
limit: 20,
|
|
cursor: None,
|
|
},
|
|
title_only: false,
|
|
exact: false,
|
|
include_ocr: true,
|
|
time_range: "any".into(),
|
|
time_field: "updated".into(),
|
|
custom_range_from: None,
|
|
custom_range_to: None,
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "search:documents");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"search.documents\""));
|
|
}
|
|
|
|
#[test]
|
|
fn search_recent_query_maps_to_search_recent() {
|
|
let query = QueryEnvelope {
|
|
name: "search.recent".into(),
|
|
payload: SearchRecent {
|
|
workspace_id: "ws_1".into(),
|
|
pagination: core_protocol::query::Pagination {
|
|
limit: 10,
|
|
cursor: None,
|
|
},
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "search:recent");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request.payload_json.contains("\"name\":\"search.recent\""));
|
|
}
|
|
|
|
#[test]
|
|
fn bridge_request_query_maps_to_bridge_logs_request() {
|
|
let query = QueryEnvelope {
|
|
name: "bridge.request.get".into(),
|
|
payload: GetBridgeRequest {
|
|
workspace_id: "ws_1".into(),
|
|
request_id: "req_1".into(),
|
|
command_id: Some("cmd_1".into()),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "bridgeLogs:listByRequest");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"bridge.request.get\""));
|
|
}
|
|
|
|
#[test]
|
|
fn bridge_trace_query_maps_to_bridge_logs_trace() {
|
|
let query = QueryEnvelope {
|
|
name: "bridge.trace.get".into(),
|
|
payload: GetBridgeTrace {
|
|
workspace_id: "ws_1".into(),
|
|
trace_id: "trace_1".into(),
|
|
command_id: None,
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "bridgeLogs:listByTrace");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"bridge.trace.get\""));
|
|
}
|
|
|
|
#[test]
|
|
fn bridge_command_query_maps_to_bridge_logs_command() {
|
|
let query = QueryEnvelope {
|
|
name: "bridge.command.get".into(),
|
|
payload: GetBridgeCommand {
|
|
workspace_id: "ws_1".into(),
|
|
command_id: "cmd_1".into(),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "bridgeLogs:listByCommand");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"bridge.command.get\""));
|
|
}
|
|
|
|
#[test]
|
|
fn bridge_workspace_overview_query_maps_to_bridge_logs_workspace_overview() {
|
|
let query = QueryEnvelope {
|
|
name: "bridge.workspace.overview".into(),
|
|
payload: ListBridgeWorkspaceOverview {
|
|
workspace_id: "ws_1".into(),
|
|
pagination: core_protocol::query::Pagination {
|
|
limit: 20,
|
|
cursor: Some("cursor_1".into()),
|
|
},
|
|
command_status: Some("failed".into()),
|
|
event_status: Some("failed".into()),
|
|
target_page_id: Some("page_1".into()),
|
|
target_block_id: None,
|
|
aggregate_type: Some("page".into()),
|
|
aggregate_id: Some("page_1".into()),
|
|
},
|
|
};
|
|
|
|
let request =
|
|
build_query_request(&demo_context(), &query).expect("query request should build");
|
|
assert_eq!(request.function_name, "bridgeLogs:listWorkspaceOverview");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request
|
|
.payload_json
|
|
.contains("\"name\":\"bridge.workspace.overview\""));
|
|
}
|
|
|
|
#[test]
|
|
fn mindmap_put_command_maps_to_mindmaps_put() {
|
|
let command = CommandEnvelope {
|
|
name: "mindmaps.put".into(),
|
|
command_id: "cmd_mindmap_put_1".into(),
|
|
idempotency_key: Some("idem_mindmap_put".into()),
|
|
actor: ActorPayload {
|
|
actor_type: "human".into(),
|
|
actor_id: "user_1".into(),
|
|
session_id: Some("session_1".into()),
|
|
},
|
|
source: SourcePayload {
|
|
channel: "cli".into(),
|
|
client: "mnote-cli".into(),
|
|
},
|
|
target: Some(TargetRef {
|
|
workspace_id: Some("ws_1".into()),
|
|
page_id: Some("page_1".into()),
|
|
block_id: Some("mind_1".into()),
|
|
}),
|
|
payload: PutMindmap {
|
|
document_id: "page_1".into(),
|
|
mindmap_id: "mind_1".into(),
|
|
data_json: r#"{"data":{"text":"中心主题"},"children":[]}"#.into(),
|
|
create_only: false,
|
|
},
|
|
reason: Some("保存导图".into()),
|
|
refs: vec!["task-032".into()],
|
|
dry_run: false,
|
|
validate_only: false,
|
|
};
|
|
|
|
let request =
|
|
build_write_request(&demo_context(), &command).expect("write request should build");
|
|
assert_eq!(request.function_name, "mindmaps:put");
|
|
assert_eq!(request.workspace_id.as_deref(), Some("ws_1"));
|
|
assert!(request.payload_json.contains("\"name\":\"mindmaps.put\""));
|
|
}
|
|
}
|