Method invoke_dsc_resource

dsc/src/mcp/invoke_dsc_resource.rs:71–116

(&self, Parameters(InvokeDscResourceRequest { operation, resource_type, properties_json }): Parameters<InvokeDscResourceRequest>)

        )
    )]
    pub async fn invoke_dsc_resource(&self, Parameters(InvokeDscResourceRequest { operation, resource_type, properties_json }): Parameters<InvokeDscResourceRequest>) -> Result<Json<InvokeDscResourceResponse>, McpError> {
        let result = task::spawn_blocking(move || {
            let mut dsc = DscManager::new();
            let Some(resource) = dsc.find_resource(&DiscoveryFilter::new(&resource_type, None, None)).unwrap_or(None) else {
                return Err(McpError::invalid_request(t!("mcp.invoke_dsc_resource.resourceNotFound", resource = resource_type), None));
            };
            match operation {
                DscOperation::Get => {
                    let result = match resource.get(&properties_json) {
                        Ok(res) => res,
                        Err(e) => return Err(McpError::internal_error(e.to_string(), None)),
                    };
                    Ok(ResourceOperationResult::GetResult(result))
                },
                DscOperation::Set => {
                    let result = match resource.set(&properties_json, false, &ExecutionKind::Actual) {
                        Ok(res) => res,
                        Err(e) => return Err(McpError::internal_error(e.to_string(), None)),
                    };
                    Ok(ResourceOperationResult::SetResult(result))
                },
                DscOperation::Test => {
                    let result = match resource.test(&properties_json) {
                        Ok(res) => res,
                        Err(e) => return Err(McpError::internal_error(e.to_string(), None)),
                    };
                    Ok(ResourceOperationResult::TestResult(result))
                },
                DscOperation::Delete => {
                    match resource.delete(&properties_json, &ExecutionKind::Actual) {
                        Ok(_) => Ok(ResourceOperationResult::DeleteResult { success: true }),
                        Err(e) => Err(McpError::internal_error(e.to_string(), None)),
                    }
                },
                DscOperation::Export => {
                    let result = match resource.export(&properties_json) {
                        Ok(res) => res,
                        Err(e) => return Err(McpError::internal_error(e.to_string(), None)),
                    };
                    Ok(ResourceOperationResult::ExportResult(result))
                }
            }
        }).await.map_err(|e| McpError::internal_error(e.to_string(), None))??;

        Ok(Json(InvokeDscResourceResponse { result }))
    }
}