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

objectiveai_cli/command/api/config/
mod.rs
