pctx_code_execution_runtime 0.2.2

JavaScript/TypeScript execution runtime for pctx
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

//! Deno ops for local tool callback functionality
//!
//! Callbacks are pre-registered callbacks that execute synchronously.
//! Callbacks handle their own execution logic (WebSocket RPC, MCP calls, etc.)

use deno_core::{OpState, op2};
use rmcp::model::JsonObject;
use std::cell::RefCell;
use std::rc::Rc;

use pctx_registry::{PctxRegistry, RegistryError};

#[op2(async)]
#[serde]
pub(crate) async fn op_invoke(
    state: Rc<RefCell<OpState>>,
    #[string] id: String,
    #[serde] arguments: Option<JsonObject>,
) -> Result<serde_json::Value, RegistryError> {
    let registry = {
        let borrowed = state.borrow();
        borrowed.borrow::<PctxRegistry>().clone()
    };

    registry.invoke(&id, arguments).await
}