objectiveai_cli/command/plugins/logs/
mod.rs

1//! `plugins logs` — CLI-side dispatch for the logs subtree. One leaf:
2//! `list` (stream captured plugin stderr lines). Mirrors
3//! `objectiveai-sdk-rs/src/cli/command/plugins/logs/mod.rs`.
4
5use std::pin::Pin;
6
7use futures::{Stream, StreamExt};
8use objectiveai_sdk::cli::command::plugins::logs::{Request, ResponseItem};
9
10use crate::context::Context;
11use crate::error::Error;
12
13pub mod list;
14
15type ItemStream = Pin<Box<dyn Stream<Item = Result<ResponseItem, Error>> + Send>>;
16
17fn once<T: Send + 'static>(
18    item: Result<T, Error>,
19) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> {
20    Box::pin(futures::stream::once(async move { item }))
21}
22
23pub async fn execute(ctx: &Context, request: Request) -> Result<ItemStream, Error> {
24    let stream: ItemStream = match request {
25        Request::List(req) => {
26            let inner = list::execute(ctx, req).await?;
27            Box::pin(inner.map(|r| r.map(ResponseItem::List)))
28        }
29        Request::ListRequestSchema(req) => {
30            let value = list::request_schema::execute(ctx, req).await?;
31            once(Ok(ResponseItem::ListRequestSchema(value)))
32        }
33        Request::ListResponseSchema(req) => {
34            let value = list::response_schema::execute(ctx, req).await?;
35            once(Ok(ResponseItem::ListResponseSchema(value)))
36        }
37    };
38    Ok(stream)
39}
objectiveai_cli/command/plugins/logs/mod.rs

objectiveai_cli/command/plugins/logs/
mod.rs
