use std::pin::Pin;
use futures::{Stream, StreamExt};
use objectiveai_sdk::cli::command::{Request, ResponseItem};
use crate::context::Context;
use crate::error::Error;
type ItemStream =
Pin<Box<dyn Stream<Item = Result<ResponseItem, Error>> + Send>>;
fn once<T: Send + 'static>(
item: Result<T, Error>,
) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> {
Box::pin(futures::stream::once(async move { item }))
}
pub async fn execute(ctx: &Context, request: Request) -> Result<ItemStream, Error> {
let stream: ItemStream = match request {
Request::Agents(req) => {
let inner = super::agents::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Agents)))
}
Request::Api(req) => {
let inner = super::api::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Api)))
}
Request::Config(req) => {
let inner = super::config::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Config)))
}
Request::Db(req) => {
let inner = super::db::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Db)))
}
Request::Functions(req) => {
let inner = super::functions::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Functions)))
}
Request::Mcp(req) => {
let inner = super::mcp::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Mcp)))
}
Request::Plugins(req) => {
let inner = super::plugins::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Plugins)))
}
Request::Swarms(req) => {
let inner = super::swarms::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Swarms)))
}
Request::Tasks(req) => {
let inner = super::tasks::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Tasks)))
}
Request::Tools(req) => {
let inner = super::tools::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Tools)))
}
Request::Update(req) => {
let inner = super::update::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Update)))
}
Request::UpdateRequestSchema(req) => {
let value = super::update::request_schema::execute(ctx, req).await?;
once(Ok(ResponseItem::UpdateRequestSchema(value)))
}
Request::UpdateResponseSchema(req) => {
let value = super::update::response_schema::execute(ctx, req).await?;
once(Ok(ResponseItem::UpdateResponseSchema(value)))
}
Request::Viewer(req) => {
let inner = super::viewer::execute(ctx, req).await?;
Box::pin(inner.map(|r| r.map(ResponseItem::Viewer)))
}
};
Ok(stream)
}