Provide a portable Rust agent runtime mirroring Qwen-Agent behaviors.
Sign in to like and favorite skills
Provide a portable Rust agent runtime mirroring Qwen-Agent behaviors.
cargo fmtcargo clippyAskReplyProviderKindsandboxed_execStoreLimitsIntroduced universal provider API with
AskReplyProviderKindProviderAdded parity fixtures under
fixtures/Added synthetic reasoning trace fixture demonstrating the
reasoning_contentAdded custom image generation fixture demonstrating non-weather tool usage.
Introduced
AgentEmbedded
ReasoningPolicyAdded token budget guardrails that cap total tokens and downgrade reasoning near the limit.
Introduced tool routing allowing the agent to execute tool calls via registered providers.
Agent now processes
tool_callstokio::try_join!Agent now supports configurable retry limits and cancellation tokens with exponential backoff for provider and tool calls.
Added HTTP backend provider using
HttpConfig { base_url, model, api_key, timeout }tool_choicetoolsfunctionstool_choicefunction_callreasoningenable_chain_of_thoughtAdded
mcp_clientMcpProviderAgent::register_toolToolSpecuse soma_agent::{Ask, backends::http::{HttpConfig, HttpProvider}}; use serde_json::json; use std::time::Duration; let cfg = HttpConfig { base_url: "https://api.openai.com".into(), model: "gpt-4o".into(), api_key: std::env::var("OPENAI_API_KEY").unwrap(), timeout: Duration::from_secs(30), }; let provider = HttpProvider::new(cfg); let ask = Ask { op: "chat".into(), input: json!([{"role": "user", "content": "hi"}]), context: json!({ "tools": [{"name": "ping", "description": "", "parameters": {}}], "tool_choice": "auto", "reasoning": true }), }; let reply = provider.ask(ask);
Set
dialect"dashscope"functionsfunction_callenable_chain_of_thoughtCreate a JSON file mapping tool names to MCP server URLs:
{ "ping": "http://localhost:8080/" }
Register tools from the file:
use soma_agent::{Agent, ToolSpec}; use tokio_util::sync::CancellationToken; let mut agent = Agent::new(provider, 1, 1000, 1, CancellationToken::new()); agent.register_tool("cfg", ToolSpec::McpConfigFile("tools.json".into())).unwrap();