use std::borrow::Cow;
use std::path::Path;
use std::rc::Rc;
use deno_core::{JsRuntime, OpState, RuntimeOptions, ZeroCopyBuf};
use serde::de::DeserializeOwned;
use serde::Serialize;
use crate::{AnyError, JsValue};
pub struct Script {
runtime: JsRuntime,
last_rid: u32,
}
impl Script {
const DEFAULT_FILENAME: &'static str = "sandboxed.js";
pub fn from_string(js_code: &str) -> Result<Self, AnyError> {
let all_code = "const console = { log: function(expr) { Deno.core.print(expr + '\\n', false); } };".to_string() + js_code;
Self::create_script(&all_code, Self::DEFAULT_FILENAME)
}
pub fn from_file(file: impl AsRef<Path>) -> Result<Self, AnyError> {
let filename = file
.as_ref()
.file_name()
.and_then(|s| s.to_str())
.unwrap_or(Self::DEFAULT_FILENAME)
.to_owned();
match std::fs::read_to_string(file) {
Ok(js_code) => Self::create_script(&js_code, &filename),
Err(e) => Err(AnyError::from(e)),
}
}
pub fn call<P, R>(&mut self, fn_name: &str, args: &P) -> Result<R, AnyError>
where
P: Serialize,
R: DeserializeOwned,
{
let json_args = serde_json::to_value(args)?;
let json_result = self.call_json(fn_name, &json_args)?;
let result: R = serde_json::from_value(json_result)?;
Ok(result)
}
pub(crate) fn call_json(&mut self, fn_name: &str, args: &JsValue) -> Result<JsValue, AnyError> {
let js_code = format!("{{
let __rust_result = {f}({a});
if (typeof __rust_result === 'undefined')
__rust_result = null;
Deno.core.ops();
Deno.core.opSync(\"__rust_return\", __rust_result);\
}}", f = fn_name, a = args);
self.runtime.execute(Self::DEFAULT_FILENAME, &js_code)?;
let state_rc = self.runtime.op_state();
let mut state = state_rc.borrow_mut();
let table = &mut state.resource_table;
let entry: Rc<ResultResource> = table.take(self.last_rid).expect("Resource entry must be present");
let extracted = Rc::try_unwrap(entry).expect("Rc must hold single strong ref to resource entry");
self.last_rid += 1;
Ok(extracted.json_value)
}
fn create_script(js_code: &str, js_filename: &str) -> Result<Self, AnyError> {
let options = RuntimeOptions::default();
let mut runtime = JsRuntime::new(options);
runtime.execute(js_filename, &js_code)?;
runtime.register_op("__rust_return", deno_core::op_sync(Self::op_return));
Ok(Script { runtime, last_rid: 0 })
}
fn op_return(
state: &mut OpState,
args: JsValue,
_buf: Option<ZeroCopyBuf>,
) -> Result<JsValue, AnyError> {
let entry = ResultResource { json_value: args };
let resource_table = &mut state.resource_table;
let _rid = resource_table.add(entry);
Ok(serde_json::Value::Null)
}
}
#[derive(Debug)]
struct ResultResource {
json_value: JsValue
}
impl deno_core::Resource for ResultResource {
fn name(&self) -> Cow<str> {
"__rust_Result".into()
}
}