use crate::error::AnyError; use crate::{OpFn, OpState}; pub type SourcePair = (&'static str, Box); pub type SourceLoadFn = dyn Fn() -> Result; pub type OpPair = (&'static str, Box); pub type OpMiddlewareFn = dyn Fn(&'static str, Box) -> Box; pub type OpStateFn = dyn Fn(&mut OpState) -> Result<(), AnyError>; #[derive(Default)] pub struct Extension { js_files: Option>, ops: Option>, opstate_fn: Option>, middleware_fn: Option>, initialized: bool, } // Note: this used to be a trait, but we "downgraded" it to a single concrete type // for the initial iteration, it will likely become a trait in the future impl Extension { pub fn builder() -> ExtensionBuilder { Default::default() } /// returns JS source code to be loaded into the isolate (either at snapshotting, /// or at startup). as a vector of a tuple of the file name, and the source code. pub fn init_js(&self) -> &[SourcePair] { match &self.js_files { Some(files) => files, None => &[], } } /// Called at JsRuntime startup to initialize ops in the isolate. pub fn init_ops(&mut self) -> Option> { // TODO(@AaronO): maybe make op registration idempotent if self.initialized { panic!("init_ops called twice: not idempotent or correct"); } self.initialized = true; self.ops.take() } /// Allows setting up the initial op-state of an isolate at startup. pub fn init_state(&self, state: &mut OpState) -> Result<(), AnyError> { match &self.opstate_fn { Some(ofn) => ofn(state), None => Ok(()), } } /// init_middleware lets us middleware op registrations, it's called before init_ops pub fn init_middleware(&mut self) -> Option> { self.middleware_fn.take() } } // Provides a convenient builder pattern to declare Extensions #[derive(Default)] pub struct ExtensionBuilder { js: Vec, ops: Vec, state: Option>, middleware: Option>, } impl ExtensionBuilder { pub fn js(&mut self, js_files: Vec) -> &mut Self { self.js.extend(js_files); self } pub fn ops(&mut self, ops: Vec) -> &mut Self { self.ops.extend(ops); self } pub fn state(&mut self, opstate_fn: F) -> &mut Self where F: Fn(&mut OpState) -> Result<(), AnyError> + 'static, { self.state = Some(Box::new(opstate_fn)); self } pub fn middleware(&mut self, middleware_fn: F) -> &mut Self where F: Fn(&'static str, Box) -> Box + 'static, { self.middleware = Some(Box::new(middleware_fn)); self } pub fn build(&mut self) -> Extension { let js_files = Some(std::mem::take(&mut self.js)); let ops = Some(std::mem::take(&mut self.ops)); Extension { js_files, ops, opstate_fn: self.state.take(), middleware_fn: self.middleware.take(), initialized: false, } } } /// Helps embed JS files in an extension. Returns Vec<(&'static str, Box)> /// representing the filename and source code. This is only meant for extensions /// that will be snapshotted, as code will be loaded at runtime. /// /// Example: /// ```ignore /// include_js_files!( /// prefix "deno:extensions/hello", /// "01_hello.js", /// "02_goodbye.js", /// ) /// ``` #[macro_export] macro_rules! include_js_files { (prefix $prefix:literal, $($file:literal,)+) => { vec![ $(( concat!($prefix, "/", $file), Box::new(|| { let c = std::path::PathBuf::from(env!("CARGO_MANIFEST_DIR")); let path = c.join($file); println!("cargo:rerun-if-changed={}", path.display()); let src = std::fs::read_to_string(path)?; Ok(src) }), ),)+ ] }; }