objectiveai_sdk/cli/command/agents/queue/read/pending/request_schema/
mod.rs

1use crate::cli::command::CommandRequest;
2
3#[derive(Debug, Clone, PartialEq, serde::Serialize, serde::Deserialize, schemars::JsonSchema)]
4#[schemars(rename = "cli.command.agents.queue.read.pending.request_schema.Request")]
5pub struct Request {
6    pub path_type: Path,
7    #[serde(flatten)]
8    pub base: crate::cli::command::RequestBase,
9}
10
11#[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize, schemars::JsonSchema)]
12#[schemars(rename = "cli.command.agents.queue.read.pending.request_schema.Path")]
13pub enum Path {
14    #[serde(rename = "agents/queue/read/pending/request_schema")]
15    AgentsQueueReadPendingRequestSchema,
16}
17
18#[derive(clap::Args)]
19pub struct Args {
20    #[command(flatten)]
21    pub base: crate::cli::command::RequestBaseArgs,
22}
23
24impl CommandRequest for Request {
25    fn into_command(&self) -> Vec<String> {
26        let mut argv: Vec<String> = vec!["agents", "message-queue", "read", "pending", "request-schema"]
27            .into_iter()
28            .map(String::from)
29            .collect();
30        self.base.push_flags(&mut argv);
31        argv
32    }
33
34    fn request_base(&self) -> &crate::cli::command::RequestBase {
35        &self.base
36    }
37
38    fn request_base_mut(&mut self) -> Option<&mut crate::cli::command::RequestBase> {
39        Some(&mut self.base)
40    }
41}
42
43pub type Response = crate::cli::command::ResponseSchema;
44
45impl TryFrom<Args> for Request {
46    type Error = crate::cli::command::FromArgsError;
47    fn try_from(args: Args) -> Result<Self, Self::Error> {
48        Ok(Self {
49            path_type: Path::AgentsQueueReadPendingRequestSchema,
50            base: args.base.into(),
51        })
52    }
53}
54
55#[cfg(feature = "cli-executor")]
56pub async fn execute<E: crate::cli::command::CommandExecutor>(
57    executor: &E,
58    mut request: Request,
59    agent_arguments: Option<&crate::cli::command::AgentArguments>,
60) -> Result<Response, E::Error> {
61    request.base.clear_transform();
62    executor.execute_one(request, agent_arguments).await
63}
64
65#[cfg(feature = "cli-executor")]
66pub async fn execute_transform<E: crate::cli::command::CommandExecutor>(
67    executor: &E,
68    mut request: Request,
69    transform: crate::cli::command::Transform,
70    agent_arguments: Option<&crate::cli::command::AgentArguments>,
71) -> Result<serde_json::Value, E::Error> {
72    request.base.set_transform(transform);
73    executor.execute_one(request, agent_arguments).await
74}
objectiveai_sdk/cli/command/agents/queue/read/pending/request_schema/mod.rs

objectiveai_sdk/cli/command/agents/queue/read/pending/request_schema/
mod.rs
