objectiveai_cli/command/api/config/
mod.rs

1//! `config api` sub-tier.
2
3use std::pin::Pin;
4
5use futures::{Stream, StreamExt};
6use objectiveai_sdk::cli::command::api::config::{Request, Response};
7
8use crate::context::Context;
9use crate::error::Error;
10
11pub mod address;
12pub mod backoff_max_elapsed_time_ms;
13pub mod commit_author_email;
14pub mod commit_author_name;
15pub mod get;
16pub mod github_authorization;
17pub mod http_referer;
18pub mod mcp_authorization;
19pub mod mcp_timeout_ms;
20pub mod objectiveai_authorization;
21pub mod openrouter_authorization;
22pub mod user_agent;
23pub mod x_title;
24
25type ItemStream = Pin<Box<dyn Stream<Item = Result<Response, Error>> + Send>>;
26
27fn once<T: Send + 'static>(
28    item: Result<T, Error>,
29) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> {
30    Box::pin(futures::stream::once(async move { item }))
31}
32
33pub async fn execute(ctx: &Context, request: Request) -> Result<ItemStream, Error> {
34    let stream: ItemStream = match request {
35        Request::Get(req) => {
36            let value = get::execute(ctx, req).await?;
37            once(Ok(Response::Get(value)))
38        }
39        Request::GetRequestSchema(req) => {
40            let value = get::request_schema::execute(ctx, req).await?;
41            once(Ok(Response::GetRequestSchema(value)))
42        }
43        Request::GetResponseSchema(req) => {
44            let value = get::response_schema::execute(ctx, req).await?;
45            once(Ok(Response::GetResponseSchema(value)))
46        }
47        Request::Address(req) => {
48            let inner = address::execute(ctx, req).await?;
49            Box::pin(inner.map(|r| r.map(Response::Address)))
50        }
51        Request::ObjectiveaiAuthorization(req) => {
52            let inner = objectiveai_authorization::execute(ctx, req).await?;
53            Box::pin(inner.map(|r| r.map(Response::ObjectiveaiAuthorization)))
54        }
55        Request::OpenrouterAuthorization(req) => {
56            let inner = openrouter_authorization::execute(ctx, req).await?;
57            Box::pin(inner.map(|r| r.map(Response::OpenrouterAuthorization)))
58        }
59        Request::GithubAuthorization(req) => {
60            let inner = github_authorization::execute(ctx, req).await?;
61            Box::pin(inner.map(|r| r.map(Response::GithubAuthorization)))
62        }
63        Request::McpAuthorization(req) => {
64            let inner = mcp_authorization::execute(ctx, req).await?;
65            Box::pin(inner.map(|r| r.map(Response::McpAuthorization)))
66        }
67        Request::McpTimeoutMs(req) => {
68            let inner = mcp_timeout_ms::execute(ctx, req).await?;
69            Box::pin(inner.map(|r| r.map(Response::McpTimeoutMs)))
70        }
71        Request::BackoffMaxElapsedTimeMs(req) => {
72            let inner = backoff_max_elapsed_time_ms::execute(ctx, req).await?;
73            Box::pin(inner.map(|r| r.map(Response::BackoffMaxElapsedTimeMs)))
74        }
75        Request::UserAgent(req) => {
76            let inner = user_agent::execute(ctx, req).await?;
77            Box::pin(inner.map(|r| r.map(Response::UserAgent)))
78        }
79        Request::HttpReferer(req) => {
80            let inner = http_referer::execute(ctx, req).await?;
81            Box::pin(inner.map(|r| r.map(Response::HttpReferer)))
82        }
83        Request::XTitle(req) => {
84            let inner = x_title::execute(ctx, req).await?;
85            Box::pin(inner.map(|r| r.map(Response::XTitle)))
86        }
87        Request::CommitAuthorName(req) => {
88            let inner = commit_author_name::execute(ctx, req).await?;
89            Box::pin(inner.map(|r| r.map(Response::CommitAuthorName)))
90        }
91        Request::CommitAuthorEmail(req) => {
92            let inner = commit_author_email::execute(ctx, req).await?;
93            Box::pin(inner.map(|r| r.map(Response::CommitAuthorEmail)))
94        }
95    };
96    Ok(stream)
97}
objectiveai_cli/command/api/config/mod.rs

objectiveai_cli/command/api/config/
mod.rs
