sim-lib-agent-runner-process 0.1.3

use crate::{ProcessRunner, process::run_command};
use serde_json::Value as JsonValue;
use sim_codec::DecodeBudget;
use sim_codec_json::{expr_to_json, json_to_expr};
use sim_kernel::{CodecId, Error, Expr, Result};
use sim_lib_agent_runner_core::{ModelRequest, ModelResponse};

pub(crate) fn infer(runner: &ProcessRunner, request: ModelRequest) -> Result<ModelResponse> {
    let request_expr: Expr = request.into();
    let request_json = expr_to_json(&request_expr);
    let stdin =
        serde_json::to_vec(&request_json).map_err(|err| Error::HostError(err.to_string()))?;
    let stdout = run_command(
        &runner.command,
        stdin,
        "runner/process",
        runner.timeout,
        runner.max_output_bytes,
    )?;
    let response_json: JsonValue = serde_json::from_slice(&stdout)
        .map_err(|err| Error::Eval(format!("runner/process returned invalid json: {err}")))?;
    let mut budget = DecodeBudget::new(Default::default());
    let response_expr = json_to_expr(CodecId(0), &response_json, &mut budget, 0)?;
    ModelResponse::try_from(response_expr)
}