update plugin and workflow

Author: wangenius

.gitignore

@@ -29,4 +29,5 @@ Cargo.lock
 *.key.pub
 .env
 *.css.map
-docs/.vitepress/cache
+docs/.vitepress/cache
+deno

deno.lock

@@ -1,7 +1,8 @@
+use crate::plugins::deno::error::{PluginError, Result};
+use crate::utils::gen::generate_id;
 use serde::{Deserialize, Serialize};
 use serde_json::Value;
-use crate::plugins::deno::error::{PluginError, Result};
-use base64::engine::{general_purpose::STANDARD, Engine};
+use std::fs::{create_dir_all, write};
 
 /// 插件信息结构
 #[derive(Debug, Serialize, Deserialize, Clone)]
@@ -47,48 +48,55 @@ impl PluginManager {
     /// 执行插件工具
     pub async fn execute(&self, content: &str, tool: &str, args: Value) -> Result<Value> {
         let runtime = crate::plugins::deno::DENO_RUNTIME.lock().await;
-        let runtime = runtime.as_ref().ok_or_else(|| PluginError::Plugin("Deno运行时未初始化".to_string()))?;
+        let runtime = runtime
+            .as_ref()
+            .ok_or_else(|| PluginError::Plugin("Deno运行时未初始化".to_string()))?;
 
         if !runtime.check_installed() {
             return Err(PluginError::DenoNotInstalled);
         }
 
-        // 使用 data URL 直接执行内容
+        // 获取插件目录
+        let config_dir = crate::utils::file::get_config_dir()
+            .ok_or_else(|| PluginError::Plugin("无法获取配置目录".to_string()))?;
+        let plugins_dir = config_dir.join("plugins");
+        create_dir_all(&plugins_dir)?;
+
+        // 创建唯一的插件文件
+        let plugin_path = plugins_dir.join(format!("plugin_{}.ts", generate_id()));
+        let plugin_path_str = plugin_path.to_str().unwrap();
+
+        // 写入插件内容
+        write(&plugin_path, content)?;
+
+        // 使用文件路径方式执行
         let script = format!(
             r#"
             (async () => {{
-                const plugin = await import('data:text/typescript;base64,{content}');
+                const plugin = await import('file://{plugin_path}');
                 const targetFunction = plugin['{tool}'];
                 if (typeof targetFunction !== 'function') {{
                     throw new Error(`插件中未找到函数 '{tool}' 或导出不是一个函数。`);
                 }}
-                // 从 Rust 传递过来的 JSON 字符串，需要解析
                 const parsedArgs = JSON.parse('{args_json}'); 
-                // 直接调用目标函数并传递解析后的参数对象
-                // TypeScript 函数内部负责处理参数结构
                 const result = await targetFunction(parsedArgs); 
-                // 将结果序列化为 JSON 字符串并打印到 stdout, 以便 Rust 捕获
                 console.log(JSON.stringify(result !== undefined ? result : null)); 
             }})();
             "#,
-            content = STANDARD.encode(content),
+            plugin_path = plugin_path_str.replace("\\", "/"), // 确保路径使用正斜杠
             tool = tool,
-            // 确保 args 被正确序列化为 JSON 字符串, 并进行 JS 字符串所需的基本转义
             args_json = serde_json::to_string(&args)?
-                            .replace("\\", "\\\\") // 必须先转义反斜杠本身
-                            .replace("'", "\\'")   // 转义单引号
-                            .replace("\"", "\\\"")  // 转义双引号
-                            .replace("\n", "\\n")   // 转义换行符
-                            .replace("\r", "\\r")   // 转义回车符
+                .replace("\\", "\\\\")
+                .replace("'", "\\'")
+                .replace("\"", "\\\"")
+                .replace("\n", "\\n")
+                .replace("\r", "\\r")
         );
 
-        println!("{}", script);
-
         let env_vars = self.env_manager.load().await?;
         let output = runtime.execute(&script, &env_vars).await?;
-        
+        // 清理插件文件
+        let _ = std::fs::remove_file(&plugin_path);
         serde_json::from_str(&output).map_err(|e| PluginError::Json(e.to_string()))
     }
-
-
-} 
+}

src-tauri/src/plugins/deno/plugin.rs

@@ -86,7 +86,7 @@ export const Textarea = forwardRef<CustomTextAreaRef, TextAreaProps>(
     );
 
     return (
-      <div className="relative h-full">
+      <div className="relative h-full p">
         <textarea
           ref={internalRef}
           value={value}

src/components/ui/textarea.tsx

@@ -46,19 +46,21 @@ export function TestDrawer({
           <div className="flex items-center justify-between w-full">
             <h3 className="text-lg font-semibold">{selectedPlugin?.name}</h3>{" "}
             <Button
-              disabled={!testTool}
+              disabled={!testTool || isSubmitting}
               onClick={() => onTest(testTool)}
               variant="default"
               size="sm"
             >
-              <TbPlayerPlay className="w-3.5 h-3.5" />
               {isSubmitting ? (
                 <span className="flex items-center gap-1.5">
                   <TbLoader2 className="w-3.5 h-3.5 animate-spin" />
                   Testing...
                 </span>
               ) : (
-                "Run Test"
+                <span className="flex items-center gap-1.5">
+                  <TbPlayerPlay className="w-3.5 h-3.5" />
+                  Run Test
+                </span>
               )}
             </Button>
           </div>

src/page/plugins/components/TestDrawer.tsx

@@ -50,6 +50,7 @@ export const WorkflowsMarket = () => {
   // 安装工作流
   const handleInstall = async (workflow: WorkflowMarketProps) => {
     try {
+      console.log(workflow);
       setInstalling(workflow.id);
 
       // 添加到工作流管理器
@@ -61,9 +62,11 @@ export const WorkflowsMarket = () => {
         description: workflow.description,
       });
 
+      console.log(workflow.data);
+
       // 更新工作流主体数据
-      if (workflow.data && workflow.data.body) {
-        new Echo(workflow.data.body)
+      if (workflow.data && workflow.data) {
+        new Echo(JSON.parse(workflow.data))
           .indexed({
             database: WORKFLOW_BODY_DATABASE,
             name: newWorkflow.meta.id,