objectiveai_cli/command/db/
mod.rs1use std::pin::Pin;
5
6use futures::{Stream, StreamExt};
7use objectiveai_sdk::cli::command::db::{Request, ResponseItem};
8
9use crate::context::Context;
10use crate::error::Error;
11
12pub mod config;
13pub mod kill;
14pub mod query;
15pub mod spawn;
16
17type ItemStream = Pin<Box<dyn Stream<Item = Result<ResponseItem, Error>> + Send>>;
18
19fn once<T: Send + 'static>(
20 item: Result<T, Error>,
21) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> {
22 Box::pin(futures::stream::once(async move { item }))
23}
24
25pub async fn execute(ctx: &Context, request: Request) -> Result<ItemStream, Error> {
26 let stream: ItemStream = match request {
27 Request::Config(req) => {
28 let inner = config::execute(ctx, req).await?;
29 Box::pin(inner.map(|r| r.map(ResponseItem::Config)))
30 }
31 Request::Kill(req) => {
32 let value = kill::execute(ctx, req).await?;
33 once(Ok(ResponseItem::Kill(value)))
34 }
35 Request::KillRequestSchema(req) => {
36 let value = kill::request_schema::execute(ctx, req).await?;
37 once(Ok(ResponseItem::KillRequestSchema(value)))
38 }
39 Request::KillResponseSchema(req) => {
40 let value = kill::response_schema::execute(ctx, req).await?;
41 once(Ok(ResponseItem::KillResponseSchema(value)))
42 }
43 Request::Query(req) => {
44 let value = query::execute(ctx, req).await?;
45 once(Ok(ResponseItem::Query(value)))
46 }
47 Request::QueryRequestSchema(req) => {
48 let value = query::request_schema::execute(ctx, req).await?;
49 once(Ok(ResponseItem::QueryRequestSchema(value)))
50 }
51 Request::QueryResponseSchema(req) => {
52 let value = query::response_schema::execute(ctx, req).await?;
53 once(Ok(ResponseItem::QueryResponseSchema(value)))
54 }
55 Request::Spawn(req) => {
56 let value = spawn::execute(ctx, req).await?;
57 once(Ok(ResponseItem::Spawn(value)))
58 }
59 Request::SpawnRequestSchema(req) => {
60 let value = spawn::request_schema::execute(ctx, req).await?;
61 once(Ok(ResponseItem::SpawnRequestSchema(value)))
62 }
63 Request::SpawnResponseSchema(req) => {
64 let value = spawn::response_schema::execute(ctx, req).await?;
65 once(Ok(ResponseItem::SpawnResponseSchema(value)))
66 }
67 };
68 Ok(stream)
69}