mirror of
https://github.com/denoland/deno.git
synced 2025-02-02 04:38:21 -05:00
4e1abb4f3a
To better reflect changes in error types in JS from #3662 this PR changes default error type used in ops from "ErrBox" to "OpError". "OpError" is a type that can be sent over to JSON; it has all information needed to construct error in JavaScript. That made "GetErrorKind" trait useless and so it was removed altogether. To provide compatibility with previous use of "ErrBox" an implementation of "From<ErrBox> for OpError" was added, however, it is an escape hatch and ops implementors should strive to use "OpError" directly.
102 lines
2.6 KiB
Rust
102 lines
2.6 KiB
Rust
use super::dispatch_json::{Deserialize, JsonOp, Value};
|
|
use crate::fs as deno_fs;
|
|
use crate::op_error::OpError;
|
|
use crate::ops::json_op;
|
|
use crate::state::State;
|
|
use deno_core::*;
|
|
use dlopen::symbor::Library;
|
|
use std::collections::HashMap;
|
|
use std::ffi::OsStr;
|
|
use std::path::Path;
|
|
use std::rc::Rc;
|
|
|
|
pub fn init(i: &mut Isolate, s: &State, r: Rc<deno_core::OpRegistry>) {
|
|
let r_ = r;
|
|
i.register_op(
|
|
"open_plugin",
|
|
s.core_op(json_op(s.stateful_op(move |state, args, zero_copy| {
|
|
op_open_plugin(&r_, state, args, zero_copy)
|
|
}))),
|
|
);
|
|
}
|
|
|
|
fn open_plugin<P: AsRef<OsStr>>(lib_path: P) -> Result<Library, OpError> {
|
|
debug!("Loading Plugin: {:#?}", lib_path.as_ref());
|
|
|
|
Library::open(lib_path).map_err(OpError::from)
|
|
}
|
|
|
|
struct PluginResource {
|
|
lib: Library,
|
|
ops: HashMap<String, OpId>,
|
|
}
|
|
|
|
struct InitContext {
|
|
ops: HashMap<String, Box<OpDispatcher>>,
|
|
}
|
|
|
|
impl PluginInitContext for InitContext {
|
|
fn register_op(&mut self, name: &str, op: Box<OpDispatcher>) {
|
|
let existing = self.ops.insert(name.to_string(), op);
|
|
assert!(
|
|
existing.is_none(),
|
|
format!("Op already registered: {}", name)
|
|
);
|
|
}
|
|
}
|
|
|
|
#[derive(Deserialize)]
|
|
#[serde(rename_all = "camelCase")]
|
|
struct OpenPluginArgs {
|
|
filename: String,
|
|
}
|
|
|
|
pub fn op_open_plugin(
|
|
registry: &Rc<deno_core::OpRegistry>,
|
|
state: &State,
|
|
args: Value,
|
|
_zero_copy: Option<ZeroCopyBuf>,
|
|
) -> Result<JsonOp, OpError> {
|
|
let args: OpenPluginArgs = serde_json::from_value(args)?;
|
|
let filename = deno_fs::resolve_from_cwd(Path::new(&args.filename))?;
|
|
|
|
state.check_plugin(&filename)?;
|
|
|
|
let lib = open_plugin(filename)?;
|
|
let plugin_resource = PluginResource {
|
|
lib,
|
|
ops: HashMap::new(),
|
|
};
|
|
let mut state_ = state.borrow_mut();
|
|
let rid = state_
|
|
.resource_table
|
|
.add("plugin", Box::new(plugin_resource));
|
|
let plugin_resource = state_
|
|
.resource_table
|
|
.get_mut::<PluginResource>(rid)
|
|
.unwrap();
|
|
|
|
let init_fn = *unsafe {
|
|
plugin_resource
|
|
.lib
|
|
.symbol::<PluginInitFn>("deno_plugin_init")
|
|
}?;
|
|
let mut init_context = InitContext {
|
|
ops: HashMap::new(),
|
|
};
|
|
init_fn(&mut init_context);
|
|
for op in init_context.ops {
|
|
// Register each plugin op in the `OpRegistry` with the name
|
|
// formated like this `plugin_{plugin_rid}_{name}`.
|
|
// The inclusion of prefix and rid is designed to avoid any
|
|
// op name collision beyond the bound of a single loaded
|
|
// plugin instance.
|
|
let op_id = registry
|
|
.register(&format!("plugin_{}_{}", rid, op.0), state.core_op(op.1));
|
|
plugin_resource.ops.insert(op.0, op_id);
|
|
}
|
|
|
|
Ok(JsonOp::Sync(
|
|
json!({ "rid": rid, "ops": plugin_resource.ops }),
|
|
))
|
|
}
|