openlark-docs 0.19.0

//! 移动云空间文档至知识空间
//!
//! 该接口允许移动云空间文档至知识空间，并挂载在指定位置。
//!
//! docPath: <https://open.feishu.cn/document/server-docs/docs/wiki-v2/task/move_docs_to_wiki>

use openlark_core::{
    SDKResult,
    api::{ApiRequest, ApiResponseTrait, ResponseFormat},
    config::Config,
    http::Transport,
    validate_required,
};
use serde::{Deserialize, Serialize};

use crate::common::{api_endpoints::WikiApiV2, api_utils::*};

/// 移动云空间文档至知识空间请求（流式 Builder 模式）
///
/// 用于把云空间文档挂载到指定知识空间节点下。
pub struct MoveDocsToWikiRequest {
    config: Config,
    /// 知识空间ID
    space_id: String,
    /// 源文档 token
    obj_token: String,
    /// 源文档类型（例如 doc、docx 等）
    obj_type: String,
    /// 目标父节点 wiki token
    parent_wiki_token: String,
    /// 是否直接执行移动（可选，官方字段 `apply`）
    ///
    /// - `true`（默认）：同步执行移动
    /// - `false`：仅创建移动任务，返回 `task_id` 供后续查询
    apply: Option<bool>,
}

/// 移动云空间文档至知识空间请求体（内部使用）
#[derive(Debug, Clone, Serialize, Deserialize)]
struct MoveDocsToWikiRequestBody {
    obj_token: String,
    obj_type: String,
    parent_wiki_token: String,
    #[serde(skip_serializing_if = "Option::is_none")]
    apply: Option<bool>,
}

/// 移动云空间文档至知识空间响应
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct MoveDocsToWikiResponse {
    /// 操作已完成时返回的 wiki token
    pub wiki_token: Option<String>,
    /// 操作未完成时返回的异步任务 ID
    pub task_id: Option<String>,
    /// 是否已直接执行移动（官方字段 `applied`，仅 apply=true 时返回）
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub applied: Option<bool>,
}

impl ApiResponseTrait for MoveDocsToWikiResponse {
    fn data_format() -> ResponseFormat {
        ResponseFormat::Data
    }
}

impl MoveDocsToWikiRequest {
    /// 创建移动云空间文档至知识空间请求
    pub fn new(config: Config) -> Self {
        Self {
            config,
            space_id: String::new(),
            obj_token: String::new(),
            obj_type: String::new(),
            parent_wiki_token: String::new(),
            apply: None,
        }
    }

    /// 设置知识空间 ID
    pub fn space_id(mut self, space_id: impl Into<String>) -> Self {
        self.space_id = space_id.into();
        self
    }

    /// 设置源文档 token
    pub fn obj_token(mut self, obj_token: impl Into<String>) -> Self {
        self.obj_token = obj_token.into();
        self
    }

    /// 设置源文档类型（例如 doc、docx 等）
    pub fn obj_type(mut self, obj_type: impl Into<String>) -> Self {
        self.obj_type = obj_type.into();
        self
    }

    /// 设置目标父节点 wiki token
    pub fn parent_wiki_token(mut self, parent_wiki_token: impl Into<String>) -> Self {
        self.parent_wiki_token = parent_wiki_token.into();
        self
    }

    /// 设置是否直接执行移动（官方字段 `apply`）
    ///
    /// - `true`（默认）：同步执行移动
    /// - `false`：仅创建移动任务，返回 `task_id`
    pub fn apply(mut self, apply: bool) -> Self {
        self.apply = Some(apply);
        self
    }

    /// 执行请求
    pub async fn execute(self) -> SDKResult<MoveDocsToWikiResponse> {
        self.execute_with_options(openlark_core::req_option::RequestOption::default())
            .await
    }

    /// 使用指定请求选项执行请求。
    pub async fn execute_with_options(
        self,
        option: openlark_core::req_option::RequestOption,
    ) -> SDKResult<MoveDocsToWikiResponse> {
        validate_required!(self.space_id, "知识空间ID不能为空");
        validate_required!(self.obj_token, "源文档token不能为空");
        validate_required!(self.obj_type, "源文档类型不能为空");
        validate_required!(self.parent_wiki_token, "目标父节点wiki token不能为空");

        let api_endpoint = WikiApiV2::SpaceNodeMoveDocsToWiki(self.space_id);

        let request_body = MoveDocsToWikiRequestBody {
            obj_token: self.obj_token,
            obj_type: self.obj_type,
            parent_wiki_token: self.parent_wiki_token,
            apply: self.apply,
        };

        let api_request: ApiRequest<MoveDocsToWikiResponse> = api_endpoint
            .to_request()
            .body(serialize_params(&request_body, "移动云空间文档至知识空间")?);

        Transport::request_typed(api_request, &self.config, Some(option), "节点").await
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use serde_json::json;
    use wiremock::MockServer;
    use wiremock::matchers::{method, path};
    use wiremock::{Mock, ResponseTemplate};

    /// 端到端：POST .../nodes/move_docs_to_wiki → MoveDocsToWikiResponse。
    #[tokio::test]
    async fn test_move_docs_to_wiki_returns_data_on_success() {
        let server = MockServer::start().await;
        Mock::given(method("POST"))
            .and(path(
                "/open-apis/wiki/v2/spaces/sp001/nodes/move_docs_to_wiki",
            ))
            .respond_with(ResponseTemplate::new(200).set_body_json(json!({
                "code": 0, "msg": "success", "data": { "wiki_token": "wt001" }
            })))
            .mount(&server)
            .await;
        let config = Config::builder()
            .app_id("ci_app_id")
            .app_secret("ci_app_secret")
            .base_url(server.uri())
            .enable_token_cache(false)
            .build();
        let resp = MoveDocsToWikiRequest::new(config)
            .space_id("sp001")
            .obj_token("obj001")
            .obj_type("docx")
            .parent_wiki_token("pwt001")
            .execute()
            .await
            .expect("移动云文档至知识空间应成功");
        assert_eq!(resp.wiki_token.as_deref(), Some("wt001"));
        let received = server.received_requests().await.unwrap_or_default();
        assert_eq!(received.len(), 1);
        assert_eq!(
            received[0].url.path(),
            "/open-apis/wiki/v2/spaces/sp001/nodes/move_docs_to_wiki"
        );
    }
}