Function llm_call_execute

crates/wasm/src/api/mod.rs:878–943

(
    name: &str,
    #[wasm_bindgen(unchecked_param_type = "Json")] request: JsValue,
    #[wasm_bindgen(unchecked_param_type = "(arg: Json) => any")] func: Function,
    #[wasm_bindgen(unchecked_par

#[allow(non_snake_case)]
#[wasm_bindgen(js_name = "llmCallExecute", unchecked_return_type = "unknown")]
pub async fn llm_call_execute(
    name: &str,
    #[wasm_bindgen(unchecked_param_type = "Json")] request: JsValue,
    #[wasm_bindgen(unchecked_param_type = "(arg: Json) => any")] func: Function,
    #[wasm_bindgen(unchecked_param_type = "ScopeHandle | null | undefined")] handle: JsValue,
    attributes: Option<u32>,
    #[wasm_bindgen(unchecked_param_type = "Json | null | undefined")] data: JsValue,
    #[wasm_bindgen(unchecked_param_type = "Json | null | undefined")] metadata: JsValue,
    #[wasm_bindgen(
        js_name = "modelName",
        unchecked_param_type = "string | null | undefined"
    )]
    model_name: Option<String>,
    #[wasm_bindgen(
        js_name = "codecDecode",
        unchecked_param_type = "((arg: Json) => any) | null | undefined"
    )]
    codec_decode: Option<Function>,
    #[wasm_bindgen(
        js_name = "codecEncode",
        unchecked_param_type = "((arg: Json) => any) | null | undefined"
    )]
    codec_encode: Option<Function>,
    #[wasm_bindgen(
        js_name = "responseCodecDecode",
        unchecked_param_type = "((arg: Json) => any) | null | undefined"
    )]
    response_codec_decode: Option<Function>,
) -> Result<JsValue, JsValue> {
    let request_json = js_to_json(&request)?;
    let llm_request: CoreLlmRequest = serde_json::from_value(request_json)
        .map_err(|e| to_js_err(FlowError::Internal(e.to_string())))?;
    let attrs = LlmAttributes::from_bits_truncate(attributes.unwrap_or(0));
    let parent_handle = clone_scope_handle_arg(&handle)?.unwrap_or_else(task_scope_top);
    let exec_fn = callable::wrap_js_llm_exec_fn(func);
    let default_fn: LlmExecutionNextFn = Arc::new(move |request| exec_fn(request));
    let codec = match (codec_decode, codec_encode) {
        (Some(d), Some(e)) => Some(callable::wrap_js_codec(d, e)),
        _ => None,
    };
    let response_codec = response_codec_decode.map(callable::wrap_js_response_codec);

    let scope_stack = current_scope_stack_handle();
    let data_json = opt_js_to_json(&data)?;
    let metadata_json = opt_js_to_json(&metadata)?;
    let result = TASK_SCOPE_STACK
        .scope(scope_stack, async move {
            let params = relay_llm_api::LlmCallExecuteParams::builder()
                .name(name)
                .request(llm_request)
                .func(default_fn)
                .parent(parent_handle)
                .attributes(attrs)
                .data_opt(data_json)
                .metadata_opt(metadata_json)
                .model_name_opt(model_name)
                .codec_opt(codec)
                .response_codec_opt(response_codec)