a4aab1b5b3
Implements the sentryagent-idp Rust SDK crate (sdk-rust/) with: - TokenManager with Arc<Mutex<TokenCache>> for thread-safe token caching - AgentIdPClient with full method coverage: agents, oauth2, credentials, audit, marketplace, delegation - Error hierarchy via thiserror (AgentIdPError enum) - All model types with serde derive - 429 RateLimited handling with Retry-After parsing; zero unwrap() calls - Unit tests (mockito), doc tests, and integration tests (#[ignore]) - quickstart example, full README, cargo doc clean Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
88 lines
2.7 KiB
Rust
88 lines
2.7 KiB
Rust
//! Public marketplace methods for `AgentIdPClient`.
|
|
//!
|
|
//! Covers `GET /marketplace/agents` and `GET /marketplace/agents/{id}`.
|
|
//! These endpoints are **unauthenticated** — no `Authorization` header is sent.
|
|
|
|
use crate::agents::parse_response;
|
|
use crate::client::AgentIdPClient;
|
|
use crate::error::AgentIdPError;
|
|
use crate::models::{MarketplaceAgent, MarketplaceAgentList, MarketplaceFilters};
|
|
|
|
impl AgentIdPClient {
|
|
/// Lists publicly available agents in the marketplace.
|
|
///
|
|
/// `GET /marketplace/agents` → `200 MarketplaceAgentList`
|
|
///
|
|
/// This endpoint does **not** require authentication. `None` filter fields
|
|
/// are omitted from the query string.
|
|
///
|
|
/// # Example
|
|
///
|
|
/// ```rust,no_run
|
|
/// use sentryagent_idp::{AgentIdPClient, MarketplaceFilters};
|
|
///
|
|
/// # async fn example(client: &AgentIdPClient) -> Result<(), sentryagent_idp::AgentIdPError> {
|
|
/// let results = client.list_public_agents(MarketplaceFilters {
|
|
/// q: Some("summarizer".to_owned()),
|
|
/// capability: None,
|
|
/// publisher: None,
|
|
/// page: 1,
|
|
/// per_page: 20,
|
|
/// }).await?;
|
|
/// println!("Found {} agents", results.total);
|
|
/// # Ok(())
|
|
/// # }
|
|
/// ```
|
|
pub async fn list_public_agents(
|
|
&self,
|
|
filters: MarketplaceFilters,
|
|
) -> Result<MarketplaceAgentList, AgentIdPError> {
|
|
let url = format!("{}/marketplace/agents", self.base_url);
|
|
|
|
let mut query: Vec<(&str, String)> = vec![
|
|
("page", filters.page.to_string()),
|
|
("per_page", filters.per_page.to_string()),
|
|
];
|
|
|
|
if let Some(ref q) = filters.q {
|
|
query.push(("q", q.clone()));
|
|
}
|
|
if let Some(ref capability) = filters.capability {
|
|
query.push(("capability", capability.clone()));
|
|
}
|
|
if let Some(ref publisher) = filters.publisher {
|
|
query.push(("publisher", publisher.clone()));
|
|
}
|
|
|
|
let resp = self
|
|
.http
|
|
.get(&url)
|
|
.query(&query)
|
|
.send()
|
|
.await?;
|
|
|
|
parse_response(resp).await
|
|
}
|
|
|
|
/// Retrieves a single publicly listed marketplace agent by ID.
|
|
///
|
|
/// `GET /marketplace/agents/{id}` → `200 MarketplaceAgent`
|
|
///
|
|
/// This endpoint does **not** require authentication.
|
|
///
|
|
/// # Errors
|
|
///
|
|
/// Returns [`crate::error::AgentIdPError::NotFound`] when no public agent
|
|
/// with the given ID exists.
|
|
pub async fn get_public_agent(
|
|
&self,
|
|
agent_id: &str,
|
|
) -> Result<MarketplaceAgent, AgentIdPError> {
|
|
let url = format!("{}/marketplace/agents/{}", self.base_url, agent_id);
|
|
|
|
let resp = self.http.get(&url).send().await?;
|
|
|
|
parse_response(resp).await
|
|
}
|
|
}
|