use std::sync::Arc;
use serde_json::Value;
use crate::adapters::common::{json_request, segment};
use crate::error::TreeDxResult;
use crate::transport::{Transport, TreeDxHttpMethod};
#[derive(Clone)]
pub struct ExecAdapter {
transport: Arc<dyn Transport>,
}
impl ExecAdapter {
pub fn new(transport: Arc<dyn Transport>) -> Self {
Self { transport }
}
pub async fn run(&self, workspace_id: &str, body: Value) -> TreeDxResult<Value> {
json_request(
&self.transport,
TreeDxHttpMethod::Post,
format!("/api/v1/workspaces/{}/exec", segment(workspace_id)),
Some(body),
None,
)
.await
}
}