objectiveai_cli/command/swarms/
mod.rs1use std::pin::Pin;
7
8use futures::{Stream, StreamExt};
9use objectiveai_sdk::cli::command::swarms::{Request, ResponseItem};
10
11use crate::context::Context;
12use crate::error::Error;
13
14pub mod get;
15pub mod list;
16pub mod publish;
17
18type ItemStream = Pin<Box<dyn Stream<Item = Result<ResponseItem, Error>> + Send>>;
19
20fn once<T: Send + 'static>(
21 item: Result<T, Error>,
22) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> {
23 Box::pin(futures::stream::once(async move { item }))
24}
25
26pub async fn execute(ctx: &Context, request: Request) -> Result<ItemStream, Error> {
27 let stream: ItemStream = match request {
28 Request::Get(req) => {
29 let value = get::execute(ctx, req).await?;
30 once(Ok(ResponseItem::Get(value)))
31 }
32 Request::GetRequestSchema(req) => {
33 let value = get::request_schema::execute(ctx, req).await?;
34 once(Ok(ResponseItem::GetRequestSchema(value)))
35 }
36 Request::GetResponseSchema(req) => {
37 let value = get::response_schema::execute(ctx, req).await?;
38 once(Ok(ResponseItem::GetResponseSchema(value)))
39 }
40 Request::List(req) => {
41 let inner = list::execute(ctx, req).await?;
42 Box::pin(inner.map(|r| r.map(ResponseItem::List)))
43 }
44 Request::ListRequestSchema(req) => {
45 let value = list::request_schema::execute(ctx, req).await?;
46 once(Ok(ResponseItem::ListRequestSchema(value)))
47 }
48 Request::ListResponseSchema(req) => {
49 let value = list::response_schema::execute(ctx, req).await?;
50 once(Ok(ResponseItem::ListResponseSchema(value)))
51 }
52 Request::Publish(req) => {
53 let value = publish::execute(ctx, req).await?;
54 once(Ok(ResponseItem::Publish(value)))
55 }
56 Request::PublishRequestSchema(req) => {
57 let value = publish::request_schema::execute(ctx, req).await?;
58 once(Ok(ResponseItem::PublishRequestSchema(value)))
59 }
60 Request::PublishResponseSchema(req) => {
61 let value = publish::response_schema::execute(ctx, req).await?;
62 once(Ok(ResponseItem::PublishResponseSchema(value)))
63 }
64 };
65 Ok(stream)
66}