objectiveai_cli/command/api/config/commit_author_email/
mod.rs

1//! `config api commit-author-email` sub-tier.
2
3use std::pin::Pin;
4
5use futures::Stream;
6use objectiveai_sdk::cli::command::api::config::commit_author_email::{Request, Response};
7
8use crate::context::Context;
9use crate::error::Error;
10
11pub mod get;
12pub mod set;
13
14type ItemStream = Pin<Box<dyn Stream<Item = Result<Response, Error>> + Send>>;
15
16fn once<T: Send + 'static>(
17    item: Result<T, Error>,
18) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> {
19    Box::pin(futures::stream::once(async move { item }))
20}
21
22pub async fn execute(ctx: &Context, request: Request) -> Result<ItemStream, Error> {
23    let stream: ItemStream = match request {
24        Request::Get(req) => {
25            let value = get::execute(ctx, req).await?;
26            once(Ok(Response::Get(value)))
27        }
28        Request::GetRequestSchema(req) => {
29            let value = get::request_schema::execute(ctx, req).await?;
30            once(Ok(Response::GetRequestSchema(value)))
31        }
32        Request::GetResponseSchema(req) => {
33            let value = get::response_schema::execute(ctx, req).await?;
34            once(Ok(Response::GetResponseSchema(value)))
35        }
36        Request::Set(req) => {
37            let value = set::execute(ctx, req).await?;
38            once(Ok(Response::Set(value)))
39        }
40        Request::SetRequestSchema(req) => {
41            let value = set::request_schema::execute(ctx, req).await?;
42            once(Ok(Response::SetRequestSchema(value)))
43        }
44        Request::SetResponseSchema(req) => {
45            let value = set::response_schema::execute(ctx, req).await?;
46            once(Ok(Response::SetResponseSchema(value)))
47        }
48    };
49    Ok(stream)
50}
objectiveai_cli/command/api/config/commit_author_email/mod.rs

objectiveai_cli/command/api/config/commit_author_email/
mod.rs
