feat: add support for loading built-in plugins and update command provider handling

Author: sophatvathana

docs/EMBEDDED_PLUGINS.md

@@ -22,8 +22,8 @@ enum Commands {
     Run {
         file: PathBuf,
 
-        #[arg(long, default_value = "openai")]
-        provider: String,
+        #[arg(long)]
+        provider: Option<String>,
 
         #[arg(long)]
         api_key: Option<String>,
@@ -75,37 +75,43 @@ fn main() -> anyhow::Result<()> {
 
             let mut optimizer = TokenSaver::new();
             optimizer.optimize(&mut program);
+            let mut executor: Executor;
+            if let Some(provider) = provider {
+                let provider_enum = match provider.to_string().as_str() {
+                    "openai" => LLMProvider::OpenAI,
+                    "anthropic" => LLMProvider::Anthropic,
+                    "local" => LLMProvider::Local,
+                    "ollama" => LLMProvider::Ollama,
+                    _ => return Err(anyhow::anyhow!("Unknown provider: {}", provider)),
+                };
+                let llm_config = ProviderConfig {
+                    provider: provider_enum,
+                    api_key,
+                    base_url,
+                    default_model: model,
+                };
+                executor = Executor::new(Some(llm_config))?;
+            } else {
+                executor = Executor::new(None)?;
+            }
 
-            let provider_enum = match provider.as_str() {
-                "openai" => LLMProvider::OpenAI,
-                "anthropic" => LLMProvider::Anthropic,
-                "local" => LLMProvider::Local,
-                "ollama" => LLMProvider::Ollama,
-                _ => return Err(anyhow::anyhow!("Unknown provider: {}", provider)),
-            };
-
-            let llm_config = ProviderConfig {
-                provider: provider_enum,
-                api_key,
-                base_url,
-                default_model: model,
-            };
-
-            let mut executor = Executor::new(Some(llm_config))?;
+            if let Err(e) = executor.load_builtin_plugins() {
+                eprintln!("Warning: Failed to load builtin plugins: {}", e);
+            }
 
             if let Err(e) = executor.scan_plugin_directory("plugins") {
                 eprintln!("Warning: Failed to scan plugins directory: {}", e);
             }
 
             if let Err(e) = executor.load_plugins_from_default_manifest() {
                 eprintln!("Warning: Failed to load plugins from manifest: {}", e);
-            }
+            }   
 
             let loaded_plugins = executor.list_plugins();
             if !loaded_plugins.is_empty() {
                 eprintln!("Loaded plugins: {}", loaded_plugins.join(", "));
             }
- 
+
             let flow_engine = FlowEngine::new(executor);
 
             let mut executor_guard = flow_engine.executor.lock().unwrap();

rohas-cli/src/main.rs

@@ -59,12 +59,12 @@ impl BuiltinFactory {
         version: String,
     ) -> Result<Box<dyn Plugin>> {
         let handler = match builtin_key {
-            "csv_loader" => csv::load_csv,
-            "excel_loader" | "xls_loader" => excel::load_excel,
-            "postgres_query" => postgres::query_postgres,
+            "csvLoader" => csv::load_csv,
+            "excelLoader" | "xlsLoader" => excel::load_excel,
+            "postgresQuery" => postgres::query_postgres,
             _ => {
                 return Err(anyhow!(
-                    "Unknown builtin plugin '{}'. Supported builtins: csv_loader, excel_loader, postgres_query",
+                    "Unknown builtin plugin '{}'. Supported builtins: csvLoader, excelLoader, postgresQuery",
                     builtin_key
                 ))
             }

rohas-plugins/src/builtin/mod.rs

@@ -114,6 +114,10 @@ impl Executor {
         ))
     }
 
+    pub fn load_builtin_plugins(&mut self) -> Result<()> {
+        self.plugins.load_builtin_plugins()
+    }
+
     pub fn load_plugins_from_manifest(&mut self, manifest_path: &std::path::Path) -> Result<()> {
         self.plugins.load_from_manifest(manifest_path)
     }

rohas-runtime/src/executor.rs

@@ -79,6 +79,64 @@ impl PluginRegistry {
         Ok(())
     }
 
+    pub fn load_builtin_plugins(&mut self) -> Result<()> {
+        // Load CSV loader plugin
+        self.load_plugin_from_entry("csvLoader", &PluginManifestEntry {
+            plugin_type: "builtin".to_string(),
+            description: "Load data from CSV files".to_string(),
+            version: "1.0.0".to_string(),
+            endpoint: None,
+            timeout: 5,
+            path: None,
+            args: vec![],
+            interpreter: None,
+            script: None,
+            language: None,
+            builtin: Some("csvLoader".to_string()),
+            library: None,
+            symbol: None,
+            wasm_path: None,
+        }, None)?;
+
+        // Load Excel loader plugin
+        self.load_plugin_from_entry("excelLoader", &PluginManifestEntry {
+            plugin_type: "builtin".to_string(),
+            description: "Load data from Excel files".to_string(),
+            version: "1.0.0".to_string(),
+            endpoint: None,
+            timeout: 5,
+            path: None,
+            args: vec![],
+            interpreter: None,
+            script: None,
+            language: None,
+            builtin: Some("excelLoader".to_string()),
+            library: None,
+            symbol: None,
+            wasm_path: None,
+        }, None)?;
+
+        // Load PostgreSQL query plugin
+        self.load_plugin_from_entry("postgresQuery", &PluginManifestEntry {
+            plugin_type: "builtin".to_string(),
+            description: "Query PostgreSQL databases".to_string(),
+            version: "1.0.0".to_string(),
+            endpoint: None,
+            timeout: 5,
+            path: None,
+            args: vec![],
+            interpreter: None,
+            script: None,
+            language: None,
+            builtin: Some("postgresQuery".to_string()),
+            library: None,
+            symbol: None,
+            wasm_path: None,
+        }, None)?;
+
+        Ok(())
+    }
+
     fn load_plugin_from_entry(
         &mut self,
         name: &str,