// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license. use crate::fs_util::resolve_from_cwd; use deno_core::error::custom_error; use deno_core::error::type_error; use deno_core::error::uri_error; use deno_core::error::AnyError; use deno_core::parking_lot::Mutex; use deno_core::serde::de; use deno_core::serde::Deserialize; use deno_core::serde::Deserializer; use deno_core::serde::Serialize; use deno_core::serde_json; use deno_core::url; use deno_core::url::Url; use deno_core::ModuleSpecifier; use deno_terminal::colors; use log; use once_cell::sync::Lazy; use std::borrow::Cow; use std::collections::HashSet; use std::fmt; use std::hash::Hash; use std::path::Path; use std::path::PathBuf; use std::str::FromStr; use std::string::ToString; use std::sync::Arc; use which::which; mod prompter; use prompter::permission_prompt; use prompter::PromptResponse; use prompter::PERMISSION_EMOJI; pub use prompter::set_prompt_callbacks; pub use prompter::PromptCallback; static DEBUG_LOG_ENABLED: Lazy = Lazy::new(|| log::log_enabled!(log::Level::Debug)); /// Quadri-state value for storing permission state #[derive( Eq, PartialEq, Default, Debug, Clone, Copy, Deserialize, PartialOrd, )] pub enum PermissionState { Granted = 0, GrantedPartial = 1, #[default] Prompt = 2, Denied = 3, } /// `AllowPartial` prescribes how to treat a permission which is partially /// denied due to a `--deny-*` flag affecting a subscope of the queried /// permission. /// /// `TreatAsGranted` is used in place of `TreatAsPartialGranted` when we don't /// want to wastefully check for partial denials when, say, checking read /// access for a file. #[derive(Debug, Eq, PartialEq)] #[allow(clippy::enum_variant_names)] enum AllowPartial { TreatAsGranted, TreatAsDenied, TreatAsPartialGranted, } impl From for AllowPartial { fn from(value: bool) -> Self { if value { Self::TreatAsGranted } else { Self::TreatAsDenied } } } impl PermissionState { #[inline(always)] fn log_perm_access(name: &str, info: impl FnOnce() -> Option) { // Eliminates log overhead (when logging is disabled), // log_enabled!(Debug) check in a hot path still has overhead // TODO(AaronO): generalize or upstream this optimization if *DEBUG_LOG_ENABLED { log::debug!( "{}", colors::bold(&format!( "{}️ Granted {}", PERMISSION_EMOJI, Self::fmt_access(name, info) )) ); } } fn fmt_access(name: &str, info: impl FnOnce() -> Option) -> String { format!( "{} access{}", name, info() .map(|info| { format!(" to {info}") }) .unwrap_or_default(), ) } fn error(name: &str, info: impl FnOnce() -> Option) -> AnyError { custom_error( "PermissionDenied", format!( "Requires {}, run again with the --allow-{} flag", Self::fmt_access(name, info), name ), ) } /// Check the permission state. bool is whether a prompt was issued. #[inline] fn check( self, name: &str, api_name: Option<&str>, info: Option<&str>, prompt: bool, ) -> (Result<(), AnyError>, bool, bool) { self.check2(name, api_name, || info.map(|s| s.to_string()), prompt) } #[inline] fn check2( self, name: &str, api_name: Option<&str>, info: impl Fn() -> Option, prompt: bool, ) -> (Result<(), AnyError>, bool, bool) { match self { PermissionState::Granted => { Self::log_perm_access(name, info); (Ok(()), false, false) } PermissionState::Prompt if prompt => { let msg = format!( "{} access{}", name, info() .map(|info| { format!(" to {info}") }) .unwrap_or_default(), ); match permission_prompt(&msg, name, api_name, true) { PromptResponse::Allow => { Self::log_perm_access(name, info); (Ok(()), true, false) } PromptResponse::AllowAll => { Self::log_perm_access(name, info); (Ok(()), true, true) } PromptResponse::Deny => (Err(Self::error(name, info)), true, false), } } _ => (Err(Self::error(name, info)), false, false), } } } impl fmt::Display for PermissionState { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { match self { PermissionState::Granted => f.pad("granted"), PermissionState::GrantedPartial => f.pad("granted-partial"), PermissionState::Prompt => f.pad("prompt"), PermissionState::Denied => f.pad("denied"), } } } #[derive(Clone, Debug, Eq, PartialEq)] pub struct UnitPermission { pub name: &'static str, pub description: &'static str, pub state: PermissionState, pub prompt: bool, } impl UnitPermission { pub fn query(&self) -> PermissionState { self.state } pub fn request(&mut self) -> PermissionState { if self.state == PermissionState::Prompt { if PromptResponse::Allow == permission_prompt( &format!("access to {}", self.description), self.name, Some("Deno.permissions.query()"), false, ) { self.state = PermissionState::Granted; } else { self.state = PermissionState::Denied; } } self.state } pub fn revoke(&mut self) -> PermissionState { if self.state == PermissionState::Granted { self.state = PermissionState::Prompt; } self.state } pub fn check(&mut self) -> Result<(), AnyError> { let (result, prompted, _is_allow_all) = self.state.check(self.name, None, None, self.prompt); if prompted { if result.is_ok() { self.state = PermissionState::Granted; } else { self.state = PermissionState::Denied; } } result } } /// A normalized environment variable name. On Windows this will /// be uppercase and on other platforms it will stay as-is. #[derive(Clone, Eq, PartialEq, Hash, Debug)] struct EnvVarName { inner: String, } impl EnvVarName { pub fn new(env: impl AsRef) -> Self { Self { inner: if cfg!(windows) { env.as_ref().to_uppercase() } else { env.as_ref().to_string() }, } } } impl AsRef for EnvVarName { fn as_ref(&self) -> &str { self.inner.as_str() } } pub trait Descriptor: Eq + Clone { fn flag_name() -> &'static str; fn name(&self) -> Cow; // By default, specifies no-stronger-than relationship. // As this is not strict, it's only true when descriptors are the same. fn stronger_than(&self, other: &Self) -> bool { self == other } fn aliases(&self) -> Vec { vec![] } } #[derive(Clone, Debug, Eq, PartialEq)] pub struct UnaryPermission { pub granted_global: bool, pub granted_list: HashSet, pub flag_denied_global: bool, pub flag_denied_list: HashSet, pub prompt_denied_global: bool, pub prompt_denied_list: HashSet, pub prompt: bool, } impl Default for UnaryPermission { fn default() -> Self { UnaryPermission { granted_global: Default::default(), granted_list: Default::default(), flag_denied_global: Default::default(), flag_denied_list: Default::default(), prompt_denied_global: Default::default(), prompt_denied_list: Default::default(), prompt: Default::default(), } } } impl UnaryPermission { fn check_desc( &mut self, desc: &Option, assert_non_partial: bool, api_name: Option<&str>, get_display_name: impl Fn() -> Option, ) -> Result<(), AnyError> { let (result, prompted, is_allow_all) = self .query_desc(desc, AllowPartial::from(assert_non_partial)) .check2( T::flag_name(), api_name, || match get_display_name() { Some(display_name) => Some(display_name), None => desc.as_ref().map(|d| format!("\"{}\"", d.name())), }, self.prompt, ); if prompted { if result.is_ok() { if is_allow_all { self.insert_granted(None); } else { self.insert_granted(desc.clone()); } } else { self.insert_prompt_denied(desc.clone()); } } result } fn query_desc( &self, desc: &Option, allow_partial: AllowPartial, ) -> PermissionState { let aliases = desc.as_ref().map_or(vec![], T::aliases); for desc in [desc] .into_iter() .chain(&aliases.into_iter().map(Some).collect::>()) { let state = if self.is_flag_denied(desc) || self.is_prompt_denied(desc) { PermissionState::Denied } else if self.is_granted(desc) { match allow_partial { AllowPartial::TreatAsGranted => PermissionState::Granted, AllowPartial::TreatAsDenied => { if self.is_partial_flag_denied(desc) { PermissionState::Denied } else { PermissionState::Granted } } AllowPartial::TreatAsPartialGranted => { if self.is_partial_flag_denied(desc) { PermissionState::GrantedPartial } else { PermissionState::Granted } } } } else if matches!(allow_partial, AllowPartial::TreatAsDenied) && self.is_partial_flag_denied(desc) { PermissionState::Denied } else { PermissionState::Prompt }; if state != PermissionState::Prompt { return state; } } PermissionState::Prompt } fn request_desc( &mut self, desc: &Option, get_display_name: impl Fn() -> Option, ) -> PermissionState { let state = self.query_desc(desc, AllowPartial::TreatAsPartialGranted); if state == PermissionState::Granted { self.insert_granted(desc.clone()); return state; } if state != PermissionState::Prompt { return state; } let mut message = String::with_capacity(40); message.push_str(&format!("{} access", T::flag_name())); match get_display_name() { Some(display_name) => { message.push_str(&format!(" to \"{}\"", display_name)) } None => match desc { Some(desc) => message.push_str(&format!(" to \"{}\"", desc.name())), None => {} }, } match permission_prompt( &message, T::flag_name(), Some("Deno.permissions.request()"), true, ) { PromptResponse::Allow => { self.insert_granted(desc.clone()); PermissionState::Granted } PromptResponse::Deny => { self.insert_prompt_denied(desc.clone()); PermissionState::Denied } PromptResponse::AllowAll => { self.insert_granted(None); PermissionState::Granted } } } fn revoke_desc(&mut self, desc: &Option) -> PermissionState { match desc.as_ref() { Some(desc) => { self.granted_list.retain(|v| !v.stronger_than(desc)); for alias in desc.aliases() { self.granted_list.retain(|v| !v.stronger_than(&alias)); } } None => { self.granted_global = false; // Revoke global is a special case where the entire granted list is // cleared. It's inconsistent with the granular case where only // descriptors stronger than the revoked one are purged. self.granted_list.clear(); } } self.query_desc(desc, AllowPartial::TreatAsPartialGranted) } fn is_granted(&self, desc: &Option) -> bool { Self::list_contains(desc, self.granted_global, &self.granted_list) } fn is_flag_denied(&self, desc: &Option) -> bool { Self::list_contains(desc, self.flag_denied_global, &self.flag_denied_list) } fn is_prompt_denied(&self, desc: &Option) -> bool { match desc.as_ref() { Some(desc) => self .prompt_denied_list .iter() .any(|v| desc.stronger_than(v)), None => self.prompt_denied_global || !self.prompt_denied_list.is_empty(), } } fn is_partial_flag_denied(&self, desc: &Option) -> bool { match desc { None => !self.flag_denied_list.is_empty(), Some(desc) => self.flag_denied_list.iter().any(|v| desc.stronger_than(v)), } } fn list_contains( desc: &Option, list_global: bool, list: &HashSet, ) -> bool { match desc.as_ref() { Some(desc) => list_global || list.iter().any(|v| v.stronger_than(desc)), None => list_global, } } fn insert_granted(&mut self, desc: Option) { Self::list_insert(desc, &mut self.granted_global, &mut self.granted_list); } fn insert_prompt_denied(&mut self, desc: Option) { Self::list_insert( desc, &mut self.prompt_denied_global, &mut self.prompt_denied_list, ); } fn list_insert( desc: Option, list_global: &mut bool, list: &mut HashSet, ) { match desc { Some(desc) => { let aliases = desc.aliases(); list.insert(desc); for alias in aliases { list.insert(alias); } } None => *list_global = true, } } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct ReadDescriptor(pub PathBuf); impl Descriptor for ReadDescriptor { fn flag_name() -> &'static str { "read" } fn name(&self) -> Cow { Cow::from(self.0.display().to_string()) } fn stronger_than(&self, other: &Self) -> bool { other.0.starts_with(&self.0) } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct WriteDescriptor(pub PathBuf); impl Descriptor for WriteDescriptor { fn flag_name() -> &'static str { "write" } fn name(&self) -> Cow { Cow::from(self.0.display().to_string()) } fn stronger_than(&self, other: &Self) -> bool { other.0.starts_with(&self.0) } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct NetDescriptor(pub String, pub Option); impl NetDescriptor { fn new>(host: &&(T, Option)) -> Self { NetDescriptor(host.0.as_ref().to_string(), host.1) } } impl Descriptor for NetDescriptor { fn flag_name() -> &'static str { "net" } fn name(&self) -> Cow { Cow::from(format!("{}", self)) } fn stronger_than(&self, other: &Self) -> bool { self.0 == other.0 && (self.1.is_none() || self.1 == other.1) } } impl FromStr for NetDescriptor { type Err = AnyError; fn from_str(s: &str) -> Result { // Set the scheme to `unknown` to parse the URL, as we really don't know // what the scheme is. We only using Url::parse to parse the host and port // and don't care about the scheme. let url = url::Url::parse(&format!("unknown://{s}"))?; let hostname = url .host_str() .ok_or(url::ParseError::EmptyHost)? .to_string(); Ok(NetDescriptor(hostname, url.port())) } } impl fmt::Display for NetDescriptor { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { f.write_str(&match self.1 { None => self.0.clone(), Some(port) => format!("{}:{}", self.0, port), }) } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct EnvDescriptor(EnvVarName); impl EnvDescriptor { pub fn new(env: impl AsRef) -> Self { Self(EnvVarName::new(env)) } } impl Descriptor for EnvDescriptor { fn flag_name() -> &'static str { "env" } fn name(&self) -> Cow { Cow::from(self.0.as_ref()) } } impl AsRef for EnvDescriptor { fn as_ref(&self) -> &str { self.0.as_ref() } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub enum RunDescriptor { /// Warning: You may want to construct with `RunDescriptor::from()` for case /// handling. Name(String), /// Warning: You may want to construct with `RunDescriptor::from()` for case /// handling. Path(PathBuf), } impl Descriptor for RunDescriptor { fn flag_name() -> &'static str { "run" } fn name(&self) -> Cow { Cow::from(self.to_string()) } fn aliases(&self) -> Vec { match self { RunDescriptor::Name(name) => match which(name) { Ok(path) => vec![RunDescriptor::Path(path)], Err(_) => vec![], }, RunDescriptor::Path(_) => vec![], } } } impl From for RunDescriptor { fn from(s: String) -> Self { #[cfg(windows)] let s = s.to_lowercase(); let is_path = s.contains('/'); #[cfg(windows)] let is_path = is_path || s.contains('\\') || Path::new(&s).is_absolute(); if is_path { Self::Path(resolve_from_cwd(Path::new(&s)).unwrap()) } else { Self::Name(s) } } } impl From for RunDescriptor { fn from(p: PathBuf) -> Self { #[cfg(windows)] let p = PathBuf::from(p.to_string_lossy().to_string().to_lowercase()); if p.is_absolute() { Self::Path(p) } else { Self::Path(resolve_from_cwd(&p).unwrap()) } } } impl ToString for RunDescriptor { fn to_string(&self) -> String { match self { RunDescriptor::Name(s) => s.clone(), RunDescriptor::Path(p) => p.to_string_lossy().to_string(), } } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct SysDescriptor(pub String); impl Descriptor for SysDescriptor { fn flag_name() -> &'static str { "sys" } fn name(&self) -> Cow { Cow::from(self.0.to_string()) } } pub fn parse_sys_kind(kind: &str) -> Result<&str, AnyError> { match kind { "hostname" | "osRelease" | "osUptime" | "loadavg" | "networkInterfaces" | "systemMemoryInfo" | "uid" | "gid" | "cpus" => Ok(kind), _ => Err(type_error(format!("unknown system info kind \"{kind}\""))), } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct FfiDescriptor(pub PathBuf); impl Descriptor for FfiDescriptor { fn flag_name() -> &'static str { "ffi" } fn name(&self) -> Cow { Cow::from(self.0.display().to_string()) } fn stronger_than(&self, other: &Self) -> bool { other.0.starts_with(&self.0) } } impl UnaryPermission { pub fn query(&self, path: Option<&Path>) -> PermissionState { self.query_desc( &path.map(|p| ReadDescriptor(resolve_from_cwd(p).unwrap())), AllowPartial::TreatAsPartialGranted, ) } pub fn request(&mut self, path: Option<&Path>) -> PermissionState { self.request_desc( &path.map(|p| ReadDescriptor(resolve_from_cwd(p).unwrap())), || Some(path?.display().to_string()), ) } pub fn revoke(&mut self, path: Option<&Path>) -> PermissionState { self .revoke_desc(&path.map(|p| ReadDescriptor(resolve_from_cwd(p).unwrap()))) } pub fn check( &mut self, path: &Path, api_name: Option<&str>, ) -> Result<(), AnyError> { self.check_desc( &Some(ReadDescriptor(resolve_from_cwd(path)?)), true, api_name, || Some(format!("\"{}\"", path.display())), ) } #[inline] pub fn check_partial( &mut self, path: &Path, api_name: Option<&str>, ) -> Result<(), AnyError> { let desc = ReadDescriptor(resolve_from_cwd(path)?); self.check_desc(&Some(desc), false, api_name, || { Some(format!("\"{}\"", path.display())) }) } /// As `check()`, but permission error messages will anonymize the path /// by replacing it with the given `display`. pub fn check_blind( &mut self, path: &Path, display: &str, api_name: &str, ) -> Result<(), AnyError> { let desc = ReadDescriptor(resolve_from_cwd(path)?); self.check_desc(&Some(desc), false, Some(api_name), || { Some(format!("<{display}>")) }) } pub fn check_all(&mut self, api_name: Option<&str>) -> Result<(), AnyError> { self.check_desc(&None, false, api_name, || None) } } impl UnaryPermission { pub fn query(&self, path: Option<&Path>) -> PermissionState { self.query_desc( &path.map(|p| WriteDescriptor(resolve_from_cwd(p).unwrap())), AllowPartial::TreatAsPartialGranted, ) } pub fn request(&mut self, path: Option<&Path>) -> PermissionState { self.request_desc( &path.map(|p| WriteDescriptor(resolve_from_cwd(p).unwrap())), || Some(path?.display().to_string()), ) } pub fn revoke(&mut self, path: Option<&Path>) -> PermissionState { self .revoke_desc(&path.map(|p| WriteDescriptor(resolve_from_cwd(p).unwrap()))) } pub fn check( &mut self, path: &Path, api_name: Option<&str>, ) -> Result<(), AnyError> { self.check_desc( &Some(WriteDescriptor(resolve_from_cwd(path)?)), true, api_name, || Some(format!("\"{}\"", path.display())), ) } #[inline] pub fn check_partial( &mut self, path: &Path, api_name: Option<&str>, ) -> Result<(), AnyError> { self.check_desc( &Some(WriteDescriptor(resolve_from_cwd(path)?)), false, api_name, || Some(format!("\"{}\"", path.display())), ) } /// As `check()`, but permission error messages will anonymize the path /// by replacing it with the given `display`. pub fn check_blind( &mut self, path: &Path, display: &str, api_name: &str, ) -> Result<(), AnyError> { let desc = WriteDescriptor(resolve_from_cwd(path)?); self.check_desc(&Some(desc), false, Some(api_name), || { Some(format!("<{display}>")) }) } pub fn check_all(&mut self, api_name: Option<&str>) -> Result<(), AnyError> { self.check_desc(&None, false, api_name, || None) } } impl UnaryPermission { pub fn query>( &self, host: Option<&(T, Option)>, ) -> PermissionState { self.query_desc( &host.map(|h| NetDescriptor::new(&h)), AllowPartial::TreatAsPartialGranted, ) } pub fn request>( &mut self, host: Option<&(T, Option)>, ) -> PermissionState { self.request_desc(&host.map(|h| NetDescriptor::new(&h)), || None) } pub fn revoke>( &mut self, host: Option<&(T, Option)>, ) -> PermissionState { self.revoke_desc(&host.map(|h| NetDescriptor::new(&h))) } pub fn check>( &mut self, host: &(T, Option), api_name: Option<&str>, ) -> Result<(), AnyError> { self.check_desc(&Some(NetDescriptor::new(&host)), false, api_name, || None) } pub fn check_url( &mut self, url: &url::Url, api_name: Option<&str>, ) -> Result<(), AnyError> { let hostname = url .host_str() .ok_or_else(|| uri_error("Missing host"))? .to_string(); let host = &(&hostname, url.port_or_known_default()); let display_host = match url.port() { None => hostname.clone(), Some(port) => format!("{hostname}:{port}"), }; self.check_desc(&Some(NetDescriptor::new(&host)), false, api_name, || { Some(format!("\"{}\"", display_host)) }) } pub fn check_all(&mut self) -> Result<(), AnyError> { self.check_desc(&None, false, None, || None) } } impl UnaryPermission { pub fn query(&self, env: Option<&str>) -> PermissionState { self.query_desc( &env.map(EnvDescriptor::new), AllowPartial::TreatAsPartialGranted, ) } pub fn request(&mut self, env: Option<&str>) -> PermissionState { self.request_desc(&env.map(EnvDescriptor::new), || None) } pub fn revoke(&mut self, env: Option<&str>) -> PermissionState { self.revoke_desc(&env.map(EnvDescriptor::new)) } pub fn check(&mut self, env: &str) -> Result<(), AnyError> { self.check_desc(&Some(EnvDescriptor::new(env)), false, None, || None) } pub fn check_all(&mut self) -> Result<(), AnyError> { self.check_desc(&None, false, None, || None) } } impl UnaryPermission { pub fn query(&self, kind: Option<&str>) -> PermissionState { self.query_desc( &kind.map(|k| SysDescriptor(k.to_string())), AllowPartial::TreatAsPartialGranted, ) } pub fn request(&mut self, kind: Option<&str>) -> PermissionState { self.request_desc(&kind.map(|k| SysDescriptor(k.to_string())), || None) } pub fn revoke(&mut self, kind: Option<&str>) -> PermissionState { self.revoke_desc(&kind.map(|k| SysDescriptor(k.to_string()))) } pub fn check( &mut self, kind: &str, api_name: Option<&str>, ) -> Result<(), AnyError> { self.check_desc( &Some(SysDescriptor(kind.to_string())), false, api_name, || None, ) } pub fn check_all(&mut self) -> Result<(), AnyError> { self.check_desc(&None, false, None, || None) } } impl UnaryPermission { pub fn query(&self, cmd: Option<&str>) -> PermissionState { self.query_desc( &cmd.map(|c| RunDescriptor::from(c.to_string())), AllowPartial::TreatAsPartialGranted, ) } pub fn request(&mut self, cmd: Option<&str>) -> PermissionState { self.request_desc(&cmd.map(|c| RunDescriptor::from(c.to_string())), || { Some(cmd?.to_string()) }) } pub fn revoke(&mut self, cmd: Option<&str>) -> PermissionState { self.revoke_desc(&cmd.map(|c| RunDescriptor::from(c.to_string()))) } pub fn check( &mut self, cmd: &str, api_name: Option<&str>, ) -> Result<(), AnyError> { self.check_desc( &Some(RunDescriptor::from(cmd.to_string())), false, api_name, || Some(format!("\"{}\"", cmd)), ) } pub fn check_all(&mut self, api_name: Option<&str>) -> Result<(), AnyError> { self.check_desc(&None, false, api_name, || None) } } impl UnaryPermission { pub fn query(&self, path: Option<&Path>) -> PermissionState { self.query_desc( &path.map(|p| FfiDescriptor(resolve_from_cwd(p).unwrap())), AllowPartial::TreatAsPartialGranted, ) } pub fn request(&mut self, path: Option<&Path>) -> PermissionState { self.request_desc( &path.map(|p| FfiDescriptor(resolve_from_cwd(p).unwrap())), || Some(path?.display().to_string()), ) } pub fn revoke(&mut self, path: Option<&Path>) -> PermissionState { self.revoke_desc(&path.map(|p| FfiDescriptor(resolve_from_cwd(p).unwrap()))) } pub fn check( &mut self, path: &Path, api_name: Option<&str>, ) -> Result<(), AnyError> { self.check_desc( &Some(FfiDescriptor(resolve_from_cwd(path)?)), true, api_name, || Some(format!("\"{}\"", path.display())), ) } pub fn check_partial(&mut self, path: Option<&Path>) -> Result<(), AnyError> { let desc = match path { Some(path) => Some(FfiDescriptor(resolve_from_cwd(path)?)), None => None, }; self.check_desc(&desc, false, None, || { Some(format!("\"{}\"", path?.display())) }) } pub fn check_all(&mut self) -> Result<(), AnyError> { self.check_desc(&None, false, Some("all"), || None) } } #[derive(Clone, Debug, Eq, PartialEq)] pub struct Permissions { pub read: UnaryPermission, pub write: UnaryPermission, pub net: UnaryPermission, pub env: UnaryPermission, pub sys: UnaryPermission, pub run: UnaryPermission, pub ffi: UnaryPermission, pub hrtime: UnitPermission, } impl Default for Permissions { fn default() -> Self { Self { read: Permissions::new_read(&None, &None, false).unwrap(), write: Permissions::new_write(&None, &None, false).unwrap(), net: Permissions::new_net(&None, &None, false).unwrap(), env: Permissions::new_env(&None, &None, false).unwrap(), sys: Permissions::new_sys(&None, &None, false).unwrap(), run: Permissions::new_run(&None, &None, false).unwrap(), ffi: Permissions::new_ffi(&None, &None, false).unwrap(), hrtime: Permissions::new_hrtime(false, false), } } } #[derive(Clone, Debug, Eq, PartialEq, Default, Serialize, Deserialize)] pub struct PermissionsOptions { pub allow_env: Option>, pub deny_env: Option>, pub allow_hrtime: bool, pub deny_hrtime: bool, pub allow_net: Option>, pub deny_net: Option>, pub allow_ffi: Option>, pub deny_ffi: Option>, pub allow_read: Option>, pub deny_read: Option>, pub allow_run: Option>, pub deny_run: Option>, pub allow_sys: Option>, pub deny_sys: Option>, pub allow_write: Option>, pub deny_write: Option>, pub prompt: bool, } impl Permissions { pub fn new_read( allow_list: &Option>, deny_list: &Option>, prompt: bool, ) -> Result, AnyError> { Ok(UnaryPermission:: { granted_global: global_from_option(allow_list), granted_list: parse_path_list(allow_list, ReadDescriptor)?, flag_denied_global: global_from_option(deny_list), flag_denied_list: parse_path_list(deny_list, ReadDescriptor)?, prompt, ..Default::default() }) } pub fn new_write( allow_list: &Option>, deny_list: &Option>, prompt: bool, ) -> Result, AnyError> { Ok(UnaryPermission { granted_global: global_from_option(allow_list), granted_list: parse_path_list(allow_list, WriteDescriptor)?, flag_denied_global: global_from_option(deny_list), flag_denied_list: parse_path_list(deny_list, WriteDescriptor)?, prompt, ..Default::default() }) } pub fn new_net( allow_list: &Option>, deny_list: &Option>, prompt: bool, ) -> Result, AnyError> { Ok(UnaryPermission:: { granted_global: global_from_option(allow_list), granted_list: parse_net_list(allow_list)?, flag_denied_global: global_from_option(deny_list), flag_denied_list: parse_net_list(deny_list)?, prompt, ..Default::default() }) } pub fn new_env( allow_list: &Option>, deny_list: &Option>, prompt: bool, ) -> Result, AnyError> { Ok(UnaryPermission:: { granted_global: global_from_option(allow_list), granted_list: parse_env_list(allow_list)?, flag_denied_global: global_from_option(deny_list), flag_denied_list: parse_env_list(deny_list)?, prompt, ..Default::default() }) } pub fn new_sys( allow_list: &Option>, deny_list: &Option>, prompt: bool, ) -> Result, AnyError> { Ok(UnaryPermission:: { granted_global: global_from_option(allow_list), granted_list: parse_sys_list(allow_list)?, flag_denied_global: global_from_option(deny_list), flag_denied_list: parse_sys_list(deny_list)?, prompt, ..Default::default() }) } pub fn new_run( allow_list: &Option>, deny_list: &Option>, prompt: bool, ) -> Result, AnyError> { Ok(UnaryPermission:: { granted_global: global_from_option(allow_list), granted_list: parse_run_list(allow_list)?, flag_denied_global: global_from_option(deny_list), flag_denied_list: parse_run_list(deny_list)?, prompt, ..Default::default() }) } pub fn new_ffi( allow_list: &Option>, deny_list: &Option>, prompt: bool, ) -> Result, AnyError> { Ok(UnaryPermission:: { granted_global: global_from_option(allow_list), granted_list: parse_path_list(allow_list, FfiDescriptor)?, flag_denied_global: global_from_option(deny_list), flag_denied_list: parse_path_list(deny_list, FfiDescriptor)?, prompt, ..Default::default() }) } pub fn new_hrtime(allow_state: bool, deny_state: bool) -> UnitPermission { unit_permission_from_flag_bools( allow_state, deny_state, "hrtime", "high precision time", false, // never prompt for hrtime ) } pub fn from_options(opts: &PermissionsOptions) -> Result { Ok(Self { read: Permissions::new_read( &opts.allow_read, &opts.deny_read, opts.prompt, )?, write: Permissions::new_write( &opts.allow_write, &opts.deny_write, opts.prompt, )?, net: Permissions::new_net(&opts.allow_net, &opts.deny_net, opts.prompt)?, env: Permissions::new_env(&opts.allow_env, &opts.deny_env, opts.prompt)?, sys: Permissions::new_sys(&opts.allow_sys, &opts.deny_sys, opts.prompt)?, run: Permissions::new_run(&opts.allow_run, &opts.deny_run, opts.prompt)?, ffi: Permissions::new_ffi(&opts.allow_ffi, &opts.deny_ffi, opts.prompt)?, hrtime: Permissions::new_hrtime(opts.allow_hrtime, opts.deny_hrtime), }) } pub fn allow_all() -> Self { Self { read: Permissions::new_read(&Some(vec![]), &None, false).unwrap(), write: Permissions::new_write(&Some(vec![]), &None, false).unwrap(), net: Permissions::new_net(&Some(vec![]), &None, false).unwrap(), env: Permissions::new_env(&Some(vec![]), &None, false).unwrap(), sys: Permissions::new_sys(&Some(vec![]), &None, false).unwrap(), run: Permissions::new_run(&Some(vec![]), &None, false).unwrap(), ffi: Permissions::new_ffi(&Some(vec![]), &None, false).unwrap(), hrtime: Permissions::new_hrtime(true, false), } } /// A helper function that determines if the module specifier is a local or /// remote, and performs a read or net check for the specifier. pub fn check_specifier( &mut self, specifier: &ModuleSpecifier, ) -> Result<(), AnyError> { match specifier.scheme() { "file" => match specifier.to_file_path() { Ok(path) => self.read.check(&path, Some("import()")), Err(_) => Err(uri_error(format!( "Invalid file path.\n Specifier: {specifier}" ))), }, "data" => Ok(()), "blob" => Ok(()), _ => self.net.check_url(specifier, Some("import()")), } } } /// Wrapper struct for `Permissions` that can be shared across threads. /// /// We need a way to have internal mutability for permissions as they might get /// passed to a future that will prompt the user for permission (and in such /// case might need to be mutated). Also for the Web Worker API we need a way /// to send permissions to a new thread. #[derive(Clone, Debug)] pub struct PermissionsContainer(pub Arc>); impl PermissionsContainer { pub fn new(perms: Permissions) -> Self { Self(Arc::new(Mutex::new(perms))) } pub fn allow_all() -> Self { Self::new(Permissions::allow_all()) } #[inline(always)] pub fn check_specifier( &self, specifier: &ModuleSpecifier, ) -> Result<(), AnyError> { self.0.lock().check_specifier(specifier) } #[inline(always)] pub fn check_read( &mut self, path: &Path, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().read.check(path, Some(api_name)) } #[inline(always)] pub fn check_read_blind( &mut self, path: &Path, display: &str, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().read.check_blind(path, display, api_name) } #[inline(always)] pub fn check_read_all(&mut self, api_name: &str) -> Result<(), AnyError> { self.0.lock().read.check_all(Some(api_name)) } #[inline(always)] pub fn check_write( &mut self, path: &Path, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().write.check(path, Some(api_name)) } #[inline(always)] pub fn check_write_all(&mut self, api_name: &str) -> Result<(), AnyError> { self.0.lock().write.check_all(Some(api_name)) } #[inline(always)] pub fn check_write_blind( &mut self, path: &Path, display: &str, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().write.check_blind(path, display, api_name) } #[inline(always)] pub fn check_run( &mut self, cmd: &str, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().run.check(cmd, Some(api_name)) } #[inline(always)] pub fn check_run_all(&mut self, api_name: &str) -> Result<(), AnyError> { self.0.lock().run.check_all(Some(api_name)) } #[inline(always)] pub fn check_sys( &mut self, kind: &str, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().sys.check(kind, Some(api_name)) } #[inline(always)] pub fn check_env(&mut self, var: &str) -> Result<(), AnyError> { self.0.lock().env.check(var) } #[inline(always)] pub fn check_env_all(&mut self) -> Result<(), AnyError> { self.0.lock().env.check_all() } } impl deno_node::NodePermissions for PermissionsContainer { #[inline(always)] fn check_net_url( &mut self, url: &Url, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().net.check_url(url, Some(api_name)) } #[inline(always)] fn check_read_with_api_name( &self, path: &Path, api_name: Option<&str>, ) -> Result<(), AnyError> { self.0.lock().read.check(path, api_name) } #[inline(always)] fn check_write_with_api_name( &self, path: &Path, api_name: Option<&str>, ) -> Result<(), AnyError> { self.0.lock().write.check(path, api_name) } fn check_sys(&self, kind: &str, api_name: &str) -> Result<(), AnyError> { self.0.lock().sys.check(kind, Some(api_name)) } } impl deno_net::NetPermissions for PermissionsContainer { #[inline(always)] fn check_net>( &mut self, host: &(T, Option), api_name: &str, ) -> Result<(), AnyError> { self.0.lock().net.check(host, Some(api_name)) } #[inline(always)] fn check_read( &mut self, path: &Path, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().read.check(path, Some(api_name)) } #[inline(always)] fn check_write( &mut self, path: &Path, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().write.check(path, Some(api_name)) } } impl deno_fetch::FetchPermissions for PermissionsContainer { #[inline(always)] fn check_net_url( &mut self, url: &url::Url, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().net.check_url(url, Some(api_name)) } #[inline(always)] fn check_read( &mut self, path: &Path, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().read.check(path, Some(api_name)) } } impl deno_web::TimersPermission for PermissionsContainer { #[inline(always)] fn allow_hrtime(&mut self) -> bool { self.0.lock().hrtime.check().is_ok() } } impl deno_websocket::WebSocketPermissions for PermissionsContainer { #[inline(always)] fn check_net_url( &mut self, url: &url::Url, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().net.check_url(url, Some(api_name)) } } impl deno_fs::FsPermissions for PermissionsContainer { fn check_read( &mut self, path: &Path, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().read.check(path, Some(api_name)) } fn check_read_blind( &mut self, path: &Path, display: &str, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().read.check_blind(path, display, api_name) } fn check_write( &mut self, path: &Path, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().write.check(path, Some(api_name)) } fn check_write_partial( &mut self, path: &Path, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().write.check_partial(path, Some(api_name)) } fn check_write_blind( &mut self, p: &Path, display: &str, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().write.check_blind(p, display, api_name) } fn check_read_all(&mut self, api_name: &str) -> Result<(), AnyError> { self.0.lock().read.check_all(Some(api_name)) } fn check_write_all(&mut self, api_name: &str) -> Result<(), AnyError> { self.0.lock().write.check_all(Some(api_name)) } } // NOTE(bartlomieju): for now, NAPI uses `--allow-ffi` flag, but that might // change in the future. impl deno_napi::NapiPermissions for PermissionsContainer { #[inline(always)] fn check(&mut self, path: Option<&Path>) -> Result<(), AnyError> { self.0.lock().ffi.check(path.unwrap(), None) } } impl deno_ffi::FfiPermissions for PermissionsContainer { #[inline(always)] fn check_partial(&mut self, path: Option<&Path>) -> Result<(), AnyError> { self.0.lock().ffi.check_partial(path) } } impl deno_kv::sqlite::SqliteDbHandlerPermissions for PermissionsContainer { #[inline(always)] fn check_read(&mut self, p: &Path, api_name: &str) -> Result<(), AnyError> { self.0.lock().read.check(p, Some(api_name)) } #[inline(always)] fn check_write(&mut self, p: &Path, api_name: &str) -> Result<(), AnyError> { self.0.lock().write.check(p, Some(api_name)) } } impl deno_kv::remote::RemoteDbHandlerPermissions for PermissionsContainer { #[inline(always)] fn check_env(&mut self, var: &str) -> Result<(), AnyError> { self.0.lock().env.check(var) } #[inline(always)] fn check_net_url( &mut self, url: &url::Url, api_name: &str, ) -> Result<(), AnyError> { self.0.lock().net.check_url(url, Some(api_name)) } } fn unit_permission_from_flag_bools( allow_flag: bool, deny_flag: bool, name: &'static str, description: &'static str, prompt: bool, ) -> UnitPermission { UnitPermission { name, description, state: if deny_flag { PermissionState::Denied } else if allow_flag { PermissionState::Granted } else { PermissionState::Prompt }, prompt, } } fn global_from_option(flag: &Option>) -> bool { matches!(flag, Some(v) if v.is_empty()) } fn parse_net_list( list: &Option>, ) -> Result, AnyError> { if let Some(v) = list { v.iter() .map(|x| NetDescriptor::from_str(x)) .collect::, AnyError>>() } else { Ok(HashSet::new()) } } fn parse_env_list( list: &Option>, ) -> Result, AnyError> { if let Some(v) = list { v.iter() .map(|x| { if x.is_empty() { Err(AnyError::msg("Empty path is not allowed")) } else { Ok(EnvDescriptor::new(x)) } }) .collect() } else { Ok(HashSet::new()) } } fn parse_path_list( list: &Option>, f: fn(PathBuf) -> T, ) -> Result, AnyError> { if let Some(v) = list { v.iter() .map(|raw_path| { if raw_path.as_os_str().is_empty() { Err(AnyError::msg("Empty path is not allowed")) } else { resolve_from_cwd(Path::new(&raw_path)).map(f) } }) .collect() } else { Ok(HashSet::new()) } } fn parse_sys_list( list: &Option>, ) -> Result, AnyError> { if let Some(v) = list { v.iter() .map(|x| { if x.is_empty() { Err(AnyError::msg("empty")) } else { Ok(SysDescriptor(x.to_string())) } }) .collect() } else { Ok(HashSet::new()) } } fn parse_run_list( list: &Option>, ) -> Result, AnyError> { let mut result = HashSet::new(); if let Some(v) = list { for s in v { if s.is_empty() { return Err(AnyError::msg("Empty path is not allowed")); } else { let desc = RunDescriptor::from(s.to_string()); let aliases = desc.aliases(); result.insert(desc); result.extend(aliases); } } } Ok(result) } fn escalation_error() -> AnyError { custom_error( "PermissionDenied", "Can't escalate parent thread permissions", ) } #[derive(Debug, Eq, PartialEq)] pub enum ChildUnitPermissionArg { Inherit, Granted, NotGranted, } impl<'de> Deserialize<'de> for ChildUnitPermissionArg { fn deserialize(deserializer: D) -> Result where D: Deserializer<'de>, { struct ChildUnitPermissionArgVisitor; impl<'de> de::Visitor<'de> for ChildUnitPermissionArgVisitor { type Value = ChildUnitPermissionArg; fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result { formatter.write_str("\"inherit\" or boolean") } fn visit_unit(self) -> Result where E: de::Error, { Ok(ChildUnitPermissionArg::NotGranted) } fn visit_str(self, v: &str) -> Result where E: de::Error, { if v == "inherit" { Ok(ChildUnitPermissionArg::Inherit) } else { Err(de::Error::invalid_value(de::Unexpected::Str(v), &self)) } } fn visit_bool(self, v: bool) -> Result where E: de::Error, { match v { true => Ok(ChildUnitPermissionArg::Granted), false => Ok(ChildUnitPermissionArg::NotGranted), } } } deserializer.deserialize_any(ChildUnitPermissionArgVisitor) } } #[derive(Debug, Eq, PartialEq)] pub enum ChildUnaryPermissionArg { Inherit, Granted, NotGranted, GrantedList(Vec), } impl<'de> Deserialize<'de> for ChildUnaryPermissionArg { fn deserialize(deserializer: D) -> Result where D: Deserializer<'de>, { struct ChildUnaryPermissionArgVisitor; impl<'de> de::Visitor<'de> for ChildUnaryPermissionArgVisitor { type Value = ChildUnaryPermissionArg; fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result { formatter.write_str("\"inherit\" or boolean or string[]") } fn visit_unit(self) -> Result where E: de::Error, { Ok(ChildUnaryPermissionArg::NotGranted) } fn visit_str(self, v: &str) -> Result where E: de::Error, { if v == "inherit" { Ok(ChildUnaryPermissionArg::Inherit) } else { Err(de::Error::invalid_value(de::Unexpected::Str(v), &self)) } } fn visit_bool(self, v: bool) -> Result where E: de::Error, { match v { true => Ok(ChildUnaryPermissionArg::Granted), false => Ok(ChildUnaryPermissionArg::NotGranted), } } fn visit_seq( self, mut v: V, ) -> Result where V: de::SeqAccess<'de>, { let mut granted_list = vec![]; while let Some(value) = v.next_element::()? { granted_list.push(value); } Ok(ChildUnaryPermissionArg::GrantedList(granted_list)) } } deserializer.deserialize_any(ChildUnaryPermissionArgVisitor) } } /// Directly deserializable from JS worker and test permission options. #[derive(Debug, Eq, PartialEq)] pub struct ChildPermissionsArg { env: ChildUnaryPermissionArg, hrtime: ChildUnitPermissionArg, net: ChildUnaryPermissionArg, ffi: ChildUnaryPermissionArg, read: ChildUnaryPermissionArg, run: ChildUnaryPermissionArg, sys: ChildUnaryPermissionArg, write: ChildUnaryPermissionArg, } impl ChildPermissionsArg { pub fn inherit() -> Self { ChildPermissionsArg { env: ChildUnaryPermissionArg::Inherit, hrtime: ChildUnitPermissionArg::Inherit, net: ChildUnaryPermissionArg::Inherit, ffi: ChildUnaryPermissionArg::Inherit, read: ChildUnaryPermissionArg::Inherit, run: ChildUnaryPermissionArg::Inherit, sys: ChildUnaryPermissionArg::Inherit, write: ChildUnaryPermissionArg::Inherit, } } pub fn none() -> Self { ChildPermissionsArg { env: ChildUnaryPermissionArg::NotGranted, hrtime: ChildUnitPermissionArg::NotGranted, net: ChildUnaryPermissionArg::NotGranted, ffi: ChildUnaryPermissionArg::NotGranted, read: ChildUnaryPermissionArg::NotGranted, run: ChildUnaryPermissionArg::NotGranted, sys: ChildUnaryPermissionArg::NotGranted, write: ChildUnaryPermissionArg::NotGranted, } } } impl<'de> Deserialize<'de> for ChildPermissionsArg { fn deserialize(deserializer: D) -> Result where D: Deserializer<'de>, { struct ChildPermissionsArgVisitor; impl<'de> de::Visitor<'de> for ChildPermissionsArgVisitor { type Value = ChildPermissionsArg; fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result { formatter.write_str("\"inherit\" or \"none\" or object") } fn visit_unit(self) -> Result where E: de::Error, { Ok(ChildPermissionsArg::inherit()) } fn visit_str(self, v: &str) -> Result where E: de::Error, { if v == "inherit" { Ok(ChildPermissionsArg::inherit()) } else if v == "none" { Ok(ChildPermissionsArg::none()) } else { Err(de::Error::invalid_value(de::Unexpected::Str(v), &self)) } } fn visit_map(self, mut v: V) -> Result where V: de::MapAccess<'de>, { let mut child_permissions_arg = ChildPermissionsArg::none(); while let Some((key, value)) = v.next_entry::()? { if key == "env" { let arg = serde_json::from_value::(value); child_permissions_arg.env = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.env) {e}")) })?; } else if key == "hrtime" { let arg = serde_json::from_value::(value); child_permissions_arg.hrtime = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.hrtime) {e}")) })?; } else if key == "net" { let arg = serde_json::from_value::(value); child_permissions_arg.net = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.net) {e}")) })?; } else if key == "ffi" { let arg = serde_json::from_value::(value); child_permissions_arg.ffi = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.ffi) {e}")) })?; } else if key == "read" { let arg = serde_json::from_value::(value); child_permissions_arg.read = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.read) {e}")) })?; } else if key == "run" { let arg = serde_json::from_value::(value); child_permissions_arg.run = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.run) {e}")) })?; } else if key == "sys" { let arg = serde_json::from_value::(value); child_permissions_arg.sys = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.sys) {e}")) })?; } else if key == "write" { let arg = serde_json::from_value::(value); child_permissions_arg.write = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.write) {e}")) })?; } else { return Err(de::Error::custom("unknown permission name")); } } Ok(child_permissions_arg) } } deserializer.deserialize_any(ChildPermissionsArgVisitor) } } pub fn create_child_permissions( main_perms: &mut Permissions, child_permissions_arg: ChildPermissionsArg, ) -> Result { let mut worker_perms = Permissions::default(); match child_permissions_arg.env { ChildUnaryPermissionArg::Inherit => { worker_perms.env = main_perms.env.clone(); } ChildUnaryPermissionArg::Granted => { if main_perms.env.check_all().is_err() { return Err(escalation_error()); } worker_perms.env.granted_global = true; } ChildUnaryPermissionArg::NotGranted => {} ChildUnaryPermissionArg::GrantedList(granted_list) => { worker_perms.env.granted_list = parse_env_list(&Some(granted_list))?; if !worker_perms .env .granted_list .iter() .all(|desc| main_perms.env.check(desc.as_ref()).is_ok()) { return Err(escalation_error()); } } } worker_perms.env.flag_denied_global = main_perms.env.flag_denied_global; worker_perms.env.flag_denied_list = main_perms.env.flag_denied_list.clone(); worker_perms.env.prompt_denied_global = main_perms.env.prompt_denied_global; worker_perms.env.prompt_denied_list = main_perms.env.prompt_denied_list.clone(); worker_perms.env.prompt = main_perms.env.prompt; match child_permissions_arg.sys { ChildUnaryPermissionArg::Inherit => { worker_perms.sys = main_perms.sys.clone(); } ChildUnaryPermissionArg::Granted => { if main_perms.sys.check_all().is_err() { return Err(escalation_error()); } worker_perms.sys.granted_global = true; } ChildUnaryPermissionArg::NotGranted => {} ChildUnaryPermissionArg::GrantedList(granted_list) => { worker_perms.sys.granted_list = parse_sys_list(&Some(granted_list))?; if !worker_perms .sys .granted_list .iter() .all(|desc| main_perms.sys.check(&desc.0, None).is_ok()) { return Err(escalation_error()); } } } worker_perms.sys.flag_denied_global = main_perms.sys.flag_denied_global; worker_perms.sys.flag_denied_list = main_perms.sys.flag_denied_list.clone(); worker_perms.sys.prompt_denied_global = main_perms.sys.prompt_denied_global; worker_perms.sys.prompt_denied_list = main_perms.sys.prompt_denied_list.clone(); worker_perms.sys.prompt = main_perms.sys.prompt; match child_permissions_arg.hrtime { ChildUnitPermissionArg::Inherit => { worker_perms.hrtime = main_perms.hrtime.clone(); } ChildUnitPermissionArg::Granted => { if main_perms.hrtime.check().is_err() { return Err(escalation_error()); } worker_perms.hrtime.state = PermissionState::Granted; } ChildUnitPermissionArg::NotGranted => {} } if main_perms.hrtime.state == PermissionState::Denied { worker_perms.hrtime.state = PermissionState::Denied; } worker_perms.hrtime.prompt = main_perms.hrtime.prompt; match child_permissions_arg.net { ChildUnaryPermissionArg::Inherit => { worker_perms.net = main_perms.net.clone(); } ChildUnaryPermissionArg::Granted => { if main_perms.net.check_all().is_err() { return Err(escalation_error()); } worker_perms.net.granted_global = true; } ChildUnaryPermissionArg::NotGranted => {} ChildUnaryPermissionArg::GrantedList(granted_list) => { worker_perms.net.granted_list = parse_net_list(&Some(granted_list))?; if !worker_perms .net .granted_list .iter() .all(|desc| main_perms.net.check(&(&desc.0, desc.1), None).is_ok()) { return Err(escalation_error()); } } } worker_perms.net.flag_denied_global = main_perms.net.flag_denied_global; worker_perms.net.flag_denied_list = main_perms.net.flag_denied_list.clone(); worker_perms.net.prompt_denied_global = main_perms.net.prompt_denied_global; worker_perms.net.prompt_denied_list = main_perms.net.prompt_denied_list.clone(); worker_perms.net.prompt = main_perms.net.prompt; match child_permissions_arg.ffi { ChildUnaryPermissionArg::Inherit => { worker_perms.ffi = main_perms.ffi.clone(); } ChildUnaryPermissionArg::Granted => { if main_perms.ffi.check_all().is_err() { return Err(escalation_error()); } worker_perms.ffi.granted_global = true; } ChildUnaryPermissionArg::NotGranted => {} ChildUnaryPermissionArg::GrantedList(granted_list) => { worker_perms.ffi.granted_list = parse_path_list( &Some(granted_list.iter().map(PathBuf::from).collect()), FfiDescriptor, )?; if !worker_perms .ffi .granted_list .iter() .all(|desc| main_perms.ffi.check(&desc.0, None).is_ok()) { return Err(escalation_error()); } } } worker_perms.ffi.flag_denied_global = main_perms.env.flag_denied_global; worker_perms.ffi.flag_denied_list = main_perms.ffi.flag_denied_list.clone(); worker_perms.ffi.prompt_denied_global = main_perms.ffi.prompt_denied_global; worker_perms.ffi.prompt_denied_list = main_perms.ffi.prompt_denied_list.clone(); worker_perms.ffi.prompt = main_perms.ffi.prompt; match child_permissions_arg.read { ChildUnaryPermissionArg::Inherit => { worker_perms.read = main_perms.read.clone(); } ChildUnaryPermissionArg::Granted => { if main_perms.read.check_all(None).is_err() { return Err(escalation_error()); } worker_perms.read.granted_global = true; } ChildUnaryPermissionArg::NotGranted => {} ChildUnaryPermissionArg::GrantedList(granted_list) => { worker_perms.read.granted_list = parse_path_list( &Some(granted_list.iter().map(PathBuf::from).collect()), ReadDescriptor, )?; if !worker_perms .read .granted_list .iter() .all(|desc| main_perms.read.check(&desc.0, None).is_ok()) { return Err(escalation_error()); } } } worker_perms.read.flag_denied_global = main_perms.read.flag_denied_global; worker_perms.read.flag_denied_list = main_perms.read.flag_denied_list.clone(); worker_perms.read.prompt_denied_global = main_perms.read.prompt_denied_global; worker_perms.read.prompt_denied_list = main_perms.read.prompt_denied_list.clone(); worker_perms.read.prompt = main_perms.read.prompt; match child_permissions_arg.run { ChildUnaryPermissionArg::Inherit => { worker_perms.run = main_perms.run.clone(); } ChildUnaryPermissionArg::Granted => { if main_perms.run.check_all(None).is_err() { return Err(escalation_error()); } worker_perms.run.granted_global = true; } ChildUnaryPermissionArg::NotGranted => {} ChildUnaryPermissionArg::GrantedList(granted_list) => { worker_perms.run.granted_list = parse_run_list(&Some(granted_list))?; if !worker_perms .run .granted_list .iter() .all(|desc| main_perms.run.check(&desc.to_string(), None).is_ok()) { return Err(escalation_error()); } } } worker_perms.run.flag_denied_global = main_perms.run.flag_denied_global; worker_perms.run.flag_denied_list = main_perms.run.flag_denied_list.clone(); worker_perms.run.prompt_denied_global = main_perms.run.prompt_denied_global; worker_perms.run.prompt_denied_list = main_perms.run.prompt_denied_list.clone(); worker_perms.run.prompt = main_perms.run.prompt; match child_permissions_arg.write { ChildUnaryPermissionArg::Inherit => { worker_perms.write = main_perms.write.clone(); } ChildUnaryPermissionArg::Granted => { if main_perms.write.check_all(None).is_err() { return Err(escalation_error()); } worker_perms.write.granted_global = true; } ChildUnaryPermissionArg::NotGranted => {} ChildUnaryPermissionArg::GrantedList(granted_list) => { worker_perms.write.granted_list = parse_path_list( &Some(granted_list.iter().map(PathBuf::from).collect()), WriteDescriptor, )?; if !worker_perms .write .granted_list .iter() .all(|desc| main_perms.write.check(&desc.0, None).is_ok()) { return Err(escalation_error()); } } } worker_perms.write.flag_denied_global = main_perms.write.flag_denied_global; worker_perms.write.flag_denied_list = main_perms.write.flag_denied_list.clone(); worker_perms.write.prompt_denied_global = main_perms.write.prompt_denied_global; worker_perms.write.prompt_denied_list = main_perms.write.prompt_denied_list.clone(); worker_perms.write.prompt = main_perms.write.prompt; Ok(worker_perms) } #[cfg(test)] mod tests { use super::*; use deno_core::serde_json::json; use prompter::tests::*; // Creates vector of strings, Vec macro_rules! svec { ($($x:expr),*) => (vec![$($x.to_string()),*]); } #[test] fn check_paths() { set_prompter(Box::new(TestPrompter)); let allowlist = vec![ PathBuf::from("/a/specific/dir/name"), PathBuf::from("/a/specific"), PathBuf::from("/b/c"), ]; let mut perms = Permissions::from_options(&PermissionsOptions { allow_read: Some(allowlist.clone()), allow_write: Some(allowlist.clone()), allow_ffi: Some(allowlist), ..Default::default() }) .unwrap(); // Inside of /a/specific and /a/specific/dir/name assert!(perms .read .check(Path::new("/a/specific/dir/name"), None) .is_ok()); assert!(perms .write .check(Path::new("/a/specific/dir/name"), None) .is_ok()); assert!(perms .ffi .check(Path::new("/a/specific/dir/name"), None) .is_ok()); // Inside of /a/specific but outside of /a/specific/dir/name assert!(perms.read.check(Path::new("/a/specific/dir"), None).is_ok()); assert!(perms .write .check(Path::new("/a/specific/dir"), None) .is_ok()); assert!(perms.ffi.check(Path::new("/a/specific/dir"), None).is_ok()); // Inside of /a/specific and /a/specific/dir/name assert!(perms .read .check(Path::new("/a/specific/dir/name/inner"), None) .is_ok()); assert!(perms .write .check(Path::new("/a/specific/dir/name/inner"), None) .is_ok()); assert!(perms .ffi .check(Path::new("/a/specific/dir/name/inner"), None) .is_ok()); // Inside of /a/specific but outside of /a/specific/dir/name assert!(perms .read .check(Path::new("/a/specific/other/dir"), None) .is_ok()); assert!(perms .write .check(Path::new("/a/specific/other/dir"), None) .is_ok()); assert!(perms .ffi .check(Path::new("/a/specific/other/dir"), None) .is_ok()); // Exact match with /b/c assert!(perms.read.check(Path::new("/b/c"), None).is_ok()); assert!(perms.write.check(Path::new("/b/c"), None).is_ok()); assert!(perms.ffi.check(Path::new("/b/c"), None).is_ok()); // Sub path within /b/c assert!(perms.read.check(Path::new("/b/c/sub/path"), None).is_ok()); assert!(perms.write.check(Path::new("/b/c/sub/path"), None).is_ok()); assert!(perms.ffi.check(Path::new("/b/c/sub/path"), None).is_ok()); // Sub path within /b/c, needs normalizing assert!(perms .read .check(Path::new("/b/c/sub/path/../path/."), None) .is_ok()); assert!(perms .write .check(Path::new("/b/c/sub/path/../path/."), None) .is_ok()); assert!(perms .ffi .check(Path::new("/b/c/sub/path/../path/."), None) .is_ok()); // Inside of /b but outside of /b/c assert!(perms.read.check(Path::new("/b/e"), None).is_err()); assert!(perms.write.check(Path::new("/b/e"), None).is_err()); assert!(perms.ffi.check(Path::new("/b/e"), None).is_err()); // Inside of /a but outside of /a/specific assert!(perms.read.check(Path::new("/a/b"), None).is_err()); assert!(perms.write.check(Path::new("/a/b"), None).is_err()); assert!(perms.ffi.check(Path::new("/a/b"), None).is_err()); } #[test] fn test_check_net_with_values() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions::from_options(&PermissionsOptions { allow_net: Some(svec![ "localhost", "deno.land", "github.com:3000", "127.0.0.1", "172.16.0.2:8000", "www.github.com:443", "80.example.com:80", "443.example.com:443" ]), ..Default::default() }) .unwrap(); let domain_tests = vec![ ("localhost", 1234, true), ("deno.land", 0, true), ("deno.land", 3000, true), ("deno.lands", 0, false), ("deno.lands", 3000, false), ("github.com", 3000, true), ("github.com", 0, false), ("github.com", 2000, false), ("github.net", 3000, false), ("127.0.0.1", 0, true), ("127.0.0.1", 3000, true), ("127.0.0.2", 0, false), ("127.0.0.2", 3000, false), ("172.16.0.2", 8000, true), ("172.16.0.2", 0, false), ("172.16.0.2", 6000, false), ("172.16.0.1", 8000, false), ("443.example.com", 444, false), ("80.example.com", 81, false), ("80.example.com", 80, true), // Just some random hosts that should err ("somedomain", 0, false), ("192.168.0.1", 0, false), ]; for (host, port, is_ok) in domain_tests { assert_eq!( is_ok, perms.net.check(&(host, Some(port)), None).is_ok(), "{}:{}", host, port, ); } } #[test] fn test_check_net_only_flag() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions::from_options(&PermissionsOptions { allow_net: Some(svec![]), // this means `--allow-net` is present without values following `=` sign ..Default::default() }) .unwrap(); let domain_tests = vec![ ("localhost", 1234), ("deno.land", 0), ("deno.land", 3000), ("deno.lands", 0), ("deno.lands", 3000), ("github.com", 3000), ("github.com", 0), ("github.com", 2000), ("github.net", 3000), ("127.0.0.1", 0), ("127.0.0.1", 3000), ("127.0.0.2", 0), ("127.0.0.2", 3000), ("172.16.0.2", 8000), ("172.16.0.2", 0), ("172.16.0.2", 6000), ("172.16.0.1", 8000), ("somedomain", 0), ("192.168.0.1", 0), ]; for (host, port) in domain_tests { assert!(perms.net.check(&(host, Some(port)), None).is_ok()); } } #[test] fn test_check_net_no_flag() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions::from_options(&PermissionsOptions { allow_net: None, ..Default::default() }) .unwrap(); let domain_tests = vec![ ("localhost", 1234), ("deno.land", 0), ("deno.land", 3000), ("deno.lands", 0), ("deno.lands", 3000), ("github.com", 3000), ("github.com", 0), ("github.com", 2000), ("github.net", 3000), ("127.0.0.1", 0), ("127.0.0.1", 3000), ("127.0.0.2", 0), ("127.0.0.2", 3000), ("172.16.0.2", 8000), ("172.16.0.2", 0), ("172.16.0.2", 6000), ("172.16.0.1", 8000), ("somedomain", 0), ("192.168.0.1", 0), ]; for (host, port) in domain_tests { assert!(perms.net.check(&(host, Some(port)), None).is_err()); } } #[test] fn test_check_net_url() { let mut perms = Permissions::from_options(&PermissionsOptions { allow_net: Some(svec![ "localhost", "deno.land", "github.com:3000", "127.0.0.1", "172.16.0.2:8000", "www.github.com:443" ]), ..Default::default() }) .unwrap(); let url_tests = vec![ // Any protocol + port for localhost should be ok, since we don't specify ("http://localhost", true), ("https://localhost", true), ("https://localhost:4443", true), ("tcp://localhost:5000", true), ("udp://localhost:6000", true), // Correct domain + any port and protocol should be ok incorrect shouldn't ("https://deno.land/std/example/welcome.ts", true), ("https://deno.land:3000/std/example/welcome.ts", true), ("https://deno.lands/std/example/welcome.ts", false), ("https://deno.lands:3000/std/example/welcome.ts", false), // Correct domain + port should be ok all other combinations should err ("https://github.com:3000/denoland/deno", true), ("https://github.com/denoland/deno", false), ("https://github.com:2000/denoland/deno", false), ("https://github.net:3000/denoland/deno", false), // Correct ipv4 address + any port should be ok others should err ("tcp://127.0.0.1", true), ("https://127.0.0.1", true), ("tcp://127.0.0.1:3000", true), ("https://127.0.0.1:3000", true), ("tcp://127.0.0.2", false), ("https://127.0.0.2", false), ("tcp://127.0.0.2:3000", false), ("https://127.0.0.2:3000", false), // Correct address + port should be ok all other combinations should err ("tcp://172.16.0.2:8000", true), ("https://172.16.0.2:8000", true), ("tcp://172.16.0.2", false), ("https://172.16.0.2", false), ("tcp://172.16.0.2:6000", false), ("https://172.16.0.2:6000", false), ("tcp://172.16.0.1:8000", false), ("https://172.16.0.1:8000", false), // Testing issue #6531 (Network permissions check doesn't account for well-known default ports) so we dont regress ("https://www.github.com:443/robots.txt", true), ]; for (url_str, is_ok) in url_tests { let u = url::Url::parse(url_str).unwrap(); assert_eq!(is_ok, perms.net.check_url(&u, None).is_ok(), "{}", u); } } #[test] fn check_specifiers() { set_prompter(Box::new(TestPrompter)); let read_allowlist = if cfg!(target_os = "windows") { vec![PathBuf::from("C:\\a")] } else { vec![PathBuf::from("/a")] }; let mut perms = Permissions::from_options(&PermissionsOptions { allow_read: Some(read_allowlist), allow_net: Some(svec!["localhost"]), ..Default::default() }) .unwrap(); let mut fixtures = vec![ ( ModuleSpecifier::parse("http://localhost:4545/mod.ts").unwrap(), true, ), ( ModuleSpecifier::parse("http://deno.land/x/mod.ts").unwrap(), false, ), ( ModuleSpecifier::parse("data:text/plain,Hello%2C%20Deno!").unwrap(), true, ), ]; if cfg!(target_os = "windows") { fixtures .push((ModuleSpecifier::parse("file:///C:/a/mod.ts").unwrap(), true)); fixtures.push(( ModuleSpecifier::parse("file:///C:/b/mod.ts").unwrap(), false, )); } else { fixtures .push((ModuleSpecifier::parse("file:///a/mod.ts").unwrap(), true)); fixtures .push((ModuleSpecifier::parse("file:///b/mod.ts").unwrap(), false)); } for (specifier, expected) in fixtures { assert_eq!( perms.check_specifier(&specifier).is_ok(), expected, "{}", specifier, ); } } #[test] fn check_invalid_specifiers() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions::allow_all(); let mut test_cases = vec![]; if cfg!(target_os = "windows") { test_cases.push("file://"); test_cases.push("file:///"); } else { test_cases.push("file://remotehost/"); } for url in test_cases { assert!(perms .check_specifier(&ModuleSpecifier::parse(url).unwrap()) .is_err()); } } #[test] fn test_query() { set_prompter(Box::new(TestPrompter)); let perms1 = Permissions::allow_all(); let perms2 = Permissions { read: Permissions::new_read( &Some(vec![PathBuf::from("/foo")]), &None, false, ) .unwrap(), write: Permissions::new_write( &Some(vec![PathBuf::from("/foo")]), &None, false, ) .unwrap(), ffi: Permissions::new_ffi( &Some(vec![PathBuf::from("/foo")]), &None, false, ) .unwrap(), net: Permissions::new_net(&Some(svec!["127.0.0.1:8000"]), &None, false) .unwrap(), env: Permissions::new_env(&Some(svec!["HOME"]), &None, false).unwrap(), sys: Permissions::new_sys(&Some(svec!["hostname"]), &None, false) .unwrap(), run: Permissions::new_run(&Some(svec!["deno"]), &None, false).unwrap(), hrtime: Permissions::new_hrtime(false, false), }; let perms3 = Permissions { read: Permissions::new_read( &None, &Some(vec![PathBuf::from("/foo")]), false, ) .unwrap(), write: Permissions::new_write( &None, &Some(vec![PathBuf::from("/foo")]), false, ) .unwrap(), ffi: Permissions::new_ffi( &None, &Some(vec![PathBuf::from("/foo")]), false, ) .unwrap(), net: Permissions::new_net(&None, &Some(svec!["127.0.0.1:8000"]), false) .unwrap(), env: Permissions::new_env(&None, &Some(svec!["HOME"]), false).unwrap(), sys: Permissions::new_sys(&None, &Some(svec!["hostname"]), false) .unwrap(), run: Permissions::new_run(&None, &Some(svec!["deno"]), false).unwrap(), hrtime: Permissions::new_hrtime(false, true), }; let perms4 = Permissions { read: Permissions::new_read( &Some(vec![]), &Some(vec![PathBuf::from("/foo")]), false, ) .unwrap(), write: Permissions::new_write( &Some(vec![]), &Some(vec![PathBuf::from("/foo")]), false, ) .unwrap(), ffi: Permissions::new_ffi( &Some(vec![]), &Some(vec![PathBuf::from("/foo")]), false, ) .unwrap(), net: Permissions::new_net( &Some(vec![]), &Some(svec!["127.0.0.1:8000"]), false, ) .unwrap(), env: Permissions::new_env(&Some(vec![]), &Some(svec!["HOME"]), false) .unwrap(), sys: Permissions::new_sys(&Some(vec![]), &Some(svec!["hostname"]), false) .unwrap(), run: Permissions::new_run(&Some(vec![]), &Some(svec!["deno"]), false) .unwrap(), hrtime: Permissions::new_hrtime(true, true), }; #[rustfmt::skip] { assert_eq!(perms1.read.query(None), PermissionState::Granted); assert_eq!(perms1.read.query(Some(Path::new("/foo"))), PermissionState::Granted); assert_eq!(perms2.read.query(None), PermissionState::Prompt); assert_eq!(perms2.read.query(Some(Path::new("/foo"))), PermissionState::Granted); assert_eq!(perms2.read.query(Some(Path::new("/foo/bar"))), PermissionState::Granted); assert_eq!(perms3.read.query(None), PermissionState::Prompt); assert_eq!(perms3.read.query(Some(Path::new("/foo"))), PermissionState::Denied); assert_eq!(perms3.read.query(Some(Path::new("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.read.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.read.query(Some(Path::new("/foo"))), PermissionState::Denied); assert_eq!(perms4.read.query(Some(Path::new("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.read.query(Some(Path::new("/bar"))), PermissionState::Granted); assert_eq!(perms1.write.query(None), PermissionState::Granted); assert_eq!(perms1.write.query(Some(Path::new("/foo"))), PermissionState::Granted); assert_eq!(perms2.write.query(None), PermissionState::Prompt); assert_eq!(perms2.write.query(Some(Path::new("/foo"))), PermissionState::Granted); assert_eq!(perms2.write.query(Some(Path::new("/foo/bar"))), PermissionState::Granted); assert_eq!(perms3.write.query(None), PermissionState::Prompt); assert_eq!(perms3.write.query(Some(Path::new("/foo"))), PermissionState::Denied); assert_eq!(perms3.write.query(Some(Path::new("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.write.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.write.query(Some(Path::new("/foo"))), PermissionState::Denied); assert_eq!(perms4.write.query(Some(Path::new("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.write.query(Some(Path::new("/bar"))), PermissionState::Granted); assert_eq!(perms1.ffi.query(None), PermissionState::Granted); assert_eq!(perms1.ffi.query(Some(Path::new("/foo"))), PermissionState::Granted); assert_eq!(perms2.ffi.query(None), PermissionState::Prompt); assert_eq!(perms2.ffi.query(Some(Path::new("/foo"))), PermissionState::Granted); assert_eq!(perms2.ffi.query(Some(Path::new("/foo/bar"))), PermissionState::Granted); assert_eq!(perms3.ffi.query(None), PermissionState::Prompt); assert_eq!(perms3.ffi.query(Some(Path::new("/foo"))), PermissionState::Denied); assert_eq!(perms3.ffi.query(Some(Path::new("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.ffi.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.ffi.query(Some(Path::new("/foo"))), PermissionState::Denied); assert_eq!(perms4.ffi.query(Some(Path::new("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.ffi.query(Some(Path::new("/bar"))), PermissionState::Granted); assert_eq!(perms1.net.query::<&str>(None), PermissionState::Granted); assert_eq!(perms1.net.query(Some(&("127.0.0.1", None))), PermissionState::Granted); assert_eq!(perms2.net.query::<&str>(None), PermissionState::Prompt); assert_eq!(perms2.net.query(Some(&("127.0.0.1", Some(8000)))), PermissionState::Granted); assert_eq!(perms3.net.query::<&str>(None), PermissionState::Prompt); assert_eq!(perms3.net.query(Some(&("127.0.0.1", Some(8000)))), PermissionState::Denied); assert_eq!(perms4.net.query::<&str>(None), PermissionState::GrantedPartial); assert_eq!(perms4.net.query(Some(&("127.0.0.1", Some(8000)))), PermissionState::Denied); assert_eq!(perms4.net.query(Some(&("192.168.0.1", Some(8000)))), PermissionState::Granted); assert_eq!(perms1.env.query(None), PermissionState::Granted); assert_eq!(perms1.env.query(Some("HOME")), PermissionState::Granted); assert_eq!(perms2.env.query(None), PermissionState::Prompt); assert_eq!(perms2.env.query(Some("HOME")), PermissionState::Granted); assert_eq!(perms3.env.query(None), PermissionState::Prompt); assert_eq!(perms3.env.query(Some("HOME")), PermissionState::Denied); assert_eq!(perms4.env.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.env.query(Some("HOME")), PermissionState::Denied); assert_eq!(perms4.env.query(Some("AWAY")), PermissionState::Granted); assert_eq!(perms1.sys.query(None), PermissionState::Granted); assert_eq!(perms1.sys.query(Some("HOME")), PermissionState::Granted); assert_eq!(perms2.sys.query(None), PermissionState::Prompt); assert_eq!(perms2.sys.query(Some("hostname")), PermissionState::Granted); assert_eq!(perms3.sys.query(None), PermissionState::Prompt); assert_eq!(perms3.sys.query(Some("hostname")), PermissionState::Denied); assert_eq!(perms4.sys.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.sys.query(Some("hostname")), PermissionState::Denied); assert_eq!(perms4.sys.query(Some("uid")), PermissionState::Granted); assert_eq!(perms1.run.query(None), PermissionState::Granted); assert_eq!(perms1.run.query(Some("deno")), PermissionState::Granted); assert_eq!(perms2.run.query(None), PermissionState::Prompt); assert_eq!(perms2.run.query(Some("deno")), PermissionState::Granted); assert_eq!(perms3.run.query(None), PermissionState::Prompt); assert_eq!(perms3.run.query(Some("deno")), PermissionState::Denied); assert_eq!(perms4.run.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.run.query(Some("deno")), PermissionState::Denied); assert_eq!(perms4.run.query(Some("node")), PermissionState::Granted); assert_eq!(perms1.hrtime.query(), PermissionState::Granted); assert_eq!(perms2.hrtime.query(), PermissionState::Prompt); assert_eq!(perms3.hrtime.query(), PermissionState::Denied); assert_eq!(perms4.hrtime.query(), PermissionState::Denied); }; } #[test] fn test_request() { set_prompter(Box::new(TestPrompter)); let mut perms: Permissions = Default::default(); #[rustfmt::skip] { let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(true); assert_eq!(perms.read.request(Some(Path::new("/foo"))), PermissionState::Granted); assert_eq!(perms.read.query(None), PermissionState::Prompt); prompt_value.set(false); assert_eq!(perms.read.request(Some(Path::new("/foo/bar"))), PermissionState::Granted); prompt_value.set(false); assert_eq!(perms.write.request(Some(Path::new("/foo"))), PermissionState::Denied); assert_eq!(perms.write.query(Some(Path::new("/foo/bar"))), PermissionState::Prompt); prompt_value.set(true); assert_eq!(perms.write.request(None), PermissionState::Denied); prompt_value.set(false); assert_eq!(perms.ffi.request(Some(Path::new("/foo"))), PermissionState::Denied); assert_eq!(perms.ffi.query(Some(Path::new("/foo/bar"))), PermissionState::Prompt); prompt_value.set(true); assert_eq!(perms.ffi.request(None), PermissionState::Denied); prompt_value.set(true); assert_eq!(perms.net.request(Some(&("127.0.0.1", None))), PermissionState::Granted); prompt_value.set(false); assert_eq!(perms.net.request(Some(&("127.0.0.1", Some(8000)))), PermissionState::Granted); prompt_value.set(true); assert_eq!(perms.env.request(Some("HOME")), PermissionState::Granted); assert_eq!(perms.env.query(None), PermissionState::Prompt); prompt_value.set(false); assert_eq!(perms.env.request(Some("HOME")), PermissionState::Granted); prompt_value.set(true); assert_eq!(perms.sys.request(Some("hostname")), PermissionState::Granted); assert_eq!(perms.sys.query(None), PermissionState::Prompt); prompt_value.set(false); assert_eq!(perms.sys.request(Some("hostname")), PermissionState::Granted); prompt_value.set(true); assert_eq!(perms.run.request(Some("deno")), PermissionState::Granted); assert_eq!(perms.run.query(None), PermissionState::Prompt); prompt_value.set(false); assert_eq!(perms.run.request(Some("deno")), PermissionState::Granted); prompt_value.set(false); assert_eq!(perms.hrtime.request(), PermissionState::Denied); prompt_value.set(true); assert_eq!(perms.hrtime.request(), PermissionState::Denied); }; } #[test] fn test_revoke() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions { read: Permissions::new_read( &Some(vec![PathBuf::from("/foo"), PathBuf::from("/foo/baz")]), &None, false, ) .unwrap(), write: Permissions::new_write( &Some(vec![PathBuf::from("/foo"), PathBuf::from("/foo/baz")]), &None, false, ) .unwrap(), ffi: Permissions::new_ffi( &Some(vec![PathBuf::from("/foo"), PathBuf::from("/foo/baz")]), &None, false, ) .unwrap(), net: Permissions::new_net( &Some(svec!["127.0.0.1", "127.0.0.1:8000"]), &None, false, ) .unwrap(), env: Permissions::new_env(&Some(svec!["HOME"]), &None, false).unwrap(), sys: Permissions::new_sys(&Some(svec!["hostname"]), &None, false) .unwrap(), run: Permissions::new_run(&Some(svec!["deno"]), &None, false).unwrap(), hrtime: Permissions::new_hrtime(false, true), }; #[rustfmt::skip] { assert_eq!(perms.read.revoke(Some(Path::new("/foo/bar"))), PermissionState::Prompt); assert_eq!(perms.read.query(Some(Path::new("/foo"))), PermissionState::Prompt); assert_eq!(perms.read.query(Some(Path::new("/foo/baz"))), PermissionState::Granted); assert_eq!(perms.write.revoke(Some(Path::new("/foo/bar"))), PermissionState::Prompt); assert_eq!(perms.write.query(Some(Path::new("/foo"))), PermissionState::Prompt); assert_eq!(perms.write.query(Some(Path::new("/foo/baz"))), PermissionState::Granted); assert_eq!(perms.ffi.revoke(Some(Path::new("/foo/bar"))), PermissionState::Prompt); assert_eq!(perms.ffi.query(Some(Path::new("/foo"))), PermissionState::Prompt); assert_eq!(perms.ffi.query(Some(Path::new("/foo/baz"))), PermissionState::Granted); assert_eq!(perms.net.revoke(Some(&("127.0.0.1", Some(9000)))), PermissionState::Prompt); assert_eq!(perms.net.query(Some(&("127.0.0.1", None))), PermissionState::Prompt); assert_eq!(perms.net.query(Some(&("127.0.0.1", Some(8000)))), PermissionState::Granted); assert_eq!(perms.env.revoke(Some("HOME")), PermissionState::Prompt); assert_eq!(perms.env.revoke(Some("hostname")), PermissionState::Prompt); assert_eq!(perms.run.revoke(Some("deno")), PermissionState::Prompt); assert_eq!(perms.hrtime.revoke(), PermissionState::Denied); }; } #[test] fn test_check() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions { read: Permissions::new_read(&None, &None, true).unwrap(), write: Permissions::new_write(&None, &None, true).unwrap(), net: Permissions::new_net(&None, &None, true).unwrap(), env: Permissions::new_env(&None, &None, true).unwrap(), sys: Permissions::new_sys(&None, &None, true).unwrap(), run: Permissions::new_run(&None, &None, true).unwrap(), ffi: Permissions::new_ffi(&None, &None, true).unwrap(), hrtime: Permissions::new_hrtime(false, false), }; let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(true); assert!(perms.read.check(Path::new("/foo"), None).is_ok()); prompt_value.set(false); assert!(perms.read.check(Path::new("/foo"), None).is_ok()); assert!(perms.read.check(Path::new("/bar"), None).is_err()); prompt_value.set(true); assert!(perms.write.check(Path::new("/foo"), None).is_ok()); prompt_value.set(false); assert!(perms.write.check(Path::new("/foo"), None).is_ok()); assert!(perms.write.check(Path::new("/bar"), None).is_err()); prompt_value.set(true); assert!(perms.ffi.check(Path::new("/foo"), None).is_ok()); prompt_value.set(false); assert!(perms.ffi.check(Path::new("/foo"), None).is_ok()); assert!(perms.ffi.check(Path::new("/bar"), None).is_err()); prompt_value.set(true); assert!(perms.net.check(&("127.0.0.1", Some(8000)), None).is_ok()); prompt_value.set(false); assert!(perms.net.check(&("127.0.0.1", Some(8000)), None).is_ok()); assert!(perms.net.check(&("127.0.0.1", Some(8001)), None).is_err()); assert!(perms.net.check(&("127.0.0.1", None), None).is_err()); assert!(perms.net.check(&("deno.land", Some(8000)), None).is_err()); assert!(perms.net.check(&("deno.land", None), None).is_err()); prompt_value.set(true); assert!(perms.run.check("cat", None).is_ok()); prompt_value.set(false); assert!(perms.run.check("cat", None).is_ok()); assert!(perms.run.check("ls", None).is_err()); prompt_value.set(true); assert!(perms.env.check("HOME").is_ok()); prompt_value.set(false); assert!(perms.env.check("HOME").is_ok()); assert!(perms.env.check("PATH").is_err()); prompt_value.set(true); assert!(perms.env.check("hostname").is_ok()); prompt_value.set(false); assert!(perms.env.check("hostname").is_ok()); assert!(perms.env.check("osRelease").is_err()); assert!(perms.hrtime.check().is_err()); } #[test] fn test_check_fail() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions { read: Permissions::new_read(&None, &None, true).unwrap(), write: Permissions::new_write(&None, &None, true).unwrap(), net: Permissions::new_net(&None, &None, true).unwrap(), env: Permissions::new_env(&None, &None, true).unwrap(), sys: Permissions::new_sys(&None, &None, true).unwrap(), run: Permissions::new_run(&None, &None, true).unwrap(), ffi: Permissions::new_ffi(&None, &None, true).unwrap(), hrtime: Permissions::new_hrtime(false, false), }; let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(false); assert!(perms.read.check(Path::new("/foo"), None).is_err()); prompt_value.set(true); assert!(perms.read.check(Path::new("/foo"), None).is_err()); assert!(perms.read.check(Path::new("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.read.check(Path::new("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.write.check(Path::new("/foo"), None).is_err()); prompt_value.set(true); assert!(perms.write.check(Path::new("/foo"), None).is_err()); assert!(perms.write.check(Path::new("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.write.check(Path::new("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.ffi.check(Path::new("/foo"), None).is_err()); prompt_value.set(true); assert!(perms.ffi.check(Path::new("/foo"), None).is_err()); assert!(perms.ffi.check(Path::new("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.ffi.check(Path::new("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.net.check(&("127.0.0.1", Some(8000)), None).is_err()); prompt_value.set(true); assert!(perms.net.check(&("127.0.0.1", Some(8000)), None).is_err()); assert!(perms.net.check(&("127.0.0.1", Some(8001)), None).is_ok()); assert!(perms.net.check(&("deno.land", Some(8000)), None).is_ok()); prompt_value.set(false); assert!(perms.net.check(&("127.0.0.1", Some(8001)), None).is_ok()); assert!(perms.net.check(&("deno.land", Some(8000)), None).is_ok()); prompt_value.set(false); assert!(perms.run.check("cat", None).is_err()); prompt_value.set(true); assert!(perms.run.check("cat", None).is_err()); assert!(perms.run.check("ls", None).is_ok()); prompt_value.set(false); assert!(perms.run.check("ls", None).is_ok()); prompt_value.set(false); assert!(perms.env.check("HOME").is_err()); prompt_value.set(true); assert!(perms.env.check("HOME").is_err()); assert!(perms.env.check("PATH").is_ok()); prompt_value.set(false); assert!(perms.env.check("PATH").is_ok()); prompt_value.set(false); assert!(perms.sys.check("hostname", None).is_err()); prompt_value.set(true); assert!(perms.sys.check("hostname", None).is_err()); assert!(perms.sys.check("osRelease", None).is_ok()); prompt_value.set(false); assert!(perms.sys.check("osRelease", None).is_ok()); prompt_value.set(false); assert!(perms.hrtime.check().is_err()); prompt_value.set(true); assert!(perms.hrtime.check().is_err()); } #[test] #[cfg(windows)] fn test_env_windows() { set_prompter(Box::new(TestPrompter)); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); let mut perms = Permissions::allow_all(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_env(&Some(svec!["HOME"]), &None, false).unwrap() }; prompt_value.set(true); assert!(perms.env.check("HOME").is_ok()); prompt_value.set(false); assert!(perms.env.check("HOME").is_ok()); assert!(perms.env.check("hOmE").is_ok()); assert_eq!(perms.env.revoke(Some("HomE")), PermissionState::Prompt); } #[test] fn test_deserialize_child_permissions_arg() { set_prompter(Box::new(TestPrompter)); assert_eq!( ChildPermissionsArg::inherit(), ChildPermissionsArg { env: ChildUnaryPermissionArg::Inherit, hrtime: ChildUnitPermissionArg::Inherit, net: ChildUnaryPermissionArg::Inherit, ffi: ChildUnaryPermissionArg::Inherit, read: ChildUnaryPermissionArg::Inherit, run: ChildUnaryPermissionArg::Inherit, sys: ChildUnaryPermissionArg::Inherit, write: ChildUnaryPermissionArg::Inherit, } ); assert_eq!( ChildPermissionsArg::none(), ChildPermissionsArg { env: ChildUnaryPermissionArg::NotGranted, hrtime: ChildUnitPermissionArg::NotGranted, net: ChildUnaryPermissionArg::NotGranted, ffi: ChildUnaryPermissionArg::NotGranted, read: ChildUnaryPermissionArg::NotGranted, run: ChildUnaryPermissionArg::NotGranted, sys: ChildUnaryPermissionArg::NotGranted, write: ChildUnaryPermissionArg::NotGranted, } ); assert_eq!( serde_json::from_value::(json!("inherit")).unwrap(), ChildPermissionsArg::inherit() ); assert_eq!( serde_json::from_value::(json!("none")).unwrap(), ChildPermissionsArg::none() ); assert_eq!( serde_json::from_value::(json!({})).unwrap(), ChildPermissionsArg::none() ); assert_eq!( serde_json::from_value::(json!({ "env": ["foo", "bar"], })) .unwrap(), ChildPermissionsArg { env: ChildUnaryPermissionArg::GrantedList(svec!["foo", "bar"]), ..ChildPermissionsArg::none() } ); assert_eq!( serde_json::from_value::(json!({ "hrtime": true, })) .unwrap(), ChildPermissionsArg { hrtime: ChildUnitPermissionArg::Granted, ..ChildPermissionsArg::none() } ); assert_eq!( serde_json::from_value::(json!({ "hrtime": false, })) .unwrap(), ChildPermissionsArg { hrtime: ChildUnitPermissionArg::NotGranted, ..ChildPermissionsArg::none() } ); assert_eq!( serde_json::from_value::(json!({ "env": true, "net": true, "ffi": true, "read": true, "run": true, "sys": true, "write": true, })) .unwrap(), ChildPermissionsArg { env: ChildUnaryPermissionArg::Granted, net: ChildUnaryPermissionArg::Granted, ffi: ChildUnaryPermissionArg::Granted, read: ChildUnaryPermissionArg::Granted, run: ChildUnaryPermissionArg::Granted, sys: ChildUnaryPermissionArg::Granted, write: ChildUnaryPermissionArg::Granted, ..ChildPermissionsArg::none() } ); assert_eq!( serde_json::from_value::(json!({ "env": false, "net": false, "ffi": false, "read": false, "run": false, "sys": false, "write": false, })) .unwrap(), ChildPermissionsArg { env: ChildUnaryPermissionArg::NotGranted, net: ChildUnaryPermissionArg::NotGranted, ffi: ChildUnaryPermissionArg::NotGranted, read: ChildUnaryPermissionArg::NotGranted, run: ChildUnaryPermissionArg::NotGranted, sys: ChildUnaryPermissionArg::NotGranted, write: ChildUnaryPermissionArg::NotGranted, ..ChildPermissionsArg::none() } ); assert_eq!( serde_json::from_value::(json!({ "env": ["foo", "bar"], "net": ["foo", "bar:8000"], "ffi": ["foo", "file:///bar/baz"], "read": ["foo", "file:///bar/baz"], "run": ["foo", "file:///bar/baz", "./qux"], "sys": ["hostname", "osRelease"], "write": ["foo", "file:///bar/baz"], })) .unwrap(), ChildPermissionsArg { env: ChildUnaryPermissionArg::GrantedList(svec!["foo", "bar"]), net: ChildUnaryPermissionArg::GrantedList(svec!["foo", "bar:8000"]), ffi: ChildUnaryPermissionArg::GrantedList(svec![ "foo", "file:///bar/baz" ]), read: ChildUnaryPermissionArg::GrantedList(svec![ "foo", "file:///bar/baz" ]), run: ChildUnaryPermissionArg::GrantedList(svec![ "foo", "file:///bar/baz", "./qux" ]), sys: ChildUnaryPermissionArg::GrantedList(svec![ "hostname", "osRelease" ]), write: ChildUnaryPermissionArg::GrantedList(svec![ "foo", "file:///bar/baz" ]), ..ChildPermissionsArg::none() } ); } #[test] fn test_create_child_permissions() { set_prompter(Box::new(TestPrompter)); let mut main_perms = Permissions { env: Permissions::new_env(&Some(vec![]), &None, false).unwrap(), hrtime: Permissions::new_hrtime(true, false), net: Permissions::new_net(&Some(svec!["foo", "bar"]), &None, false) .unwrap(), ..Default::default() }; assert_eq!( create_child_permissions( &mut main_perms.clone(), ChildPermissionsArg { env: ChildUnaryPermissionArg::Inherit, hrtime: ChildUnitPermissionArg::NotGranted, net: ChildUnaryPermissionArg::GrantedList(svec!["foo"]), ffi: ChildUnaryPermissionArg::NotGranted, ..ChildPermissionsArg::none() } ) .unwrap(), Permissions { env: Permissions::new_env(&Some(vec![]), &None, false).unwrap(), net: Permissions::new_net(&Some(svec!["foo"]), &None, false).unwrap(), ..Default::default() } ); assert!(create_child_permissions( &mut main_perms.clone(), ChildPermissionsArg { net: ChildUnaryPermissionArg::Granted, ..ChildPermissionsArg::none() } ) .is_err()); assert!(create_child_permissions( &mut main_perms.clone(), ChildPermissionsArg { net: ChildUnaryPermissionArg::GrantedList(svec!["foo", "bar", "baz"]), ..ChildPermissionsArg::none() } ) .is_err()); assert!(create_child_permissions( &mut main_perms, ChildPermissionsArg { ffi: ChildUnaryPermissionArg::GrantedList(svec!["foo"]), ..ChildPermissionsArg::none() } ) .is_err()); } #[test] fn test_create_child_permissions_with_prompt() { set_prompter(Box::new(TestPrompter)); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); let mut main_perms = Permissions::from_options(&PermissionsOptions { prompt: true, ..Default::default() }) .unwrap(); prompt_value.set(true); let worker_perms = create_child_permissions( &mut main_perms, ChildPermissionsArg { read: ChildUnaryPermissionArg::Granted, run: ChildUnaryPermissionArg::GrantedList(svec!["foo", "bar"]), ..ChildPermissionsArg::none() }, ) .unwrap(); assert_eq!(main_perms, worker_perms); } #[test] fn test_create_child_permissions_with_inherited_denied_list() { set_prompter(Box::new(TestPrompter)); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); let mut main_perms = Permissions::from_options(&PermissionsOptions { prompt: true, ..Default::default() }) .unwrap(); prompt_value.set(false); assert!(main_perms.write.check(&PathBuf::from("foo"), None).is_err()); let worker_perms = create_child_permissions( &mut main_perms.clone(), ChildPermissionsArg::none(), ) .unwrap(); assert_eq!( worker_perms.write.flag_denied_list, main_perms.write.flag_denied_list ); } #[test] fn test_handle_empty_value() { set_prompter(Box::new(TestPrompter)); assert!( Permissions::new_read(&Some(vec![PathBuf::new()]), &None, false).is_err() ); assert!( Permissions::new_env(&Some(vec![String::new()]), &None, false).is_err() ); assert!( Permissions::new_sys(&Some(vec![String::new()]), &None, false).is_err() ); assert!( Permissions::new_run(&Some(vec![String::new()]), &None, false).is_err() ); assert!( Permissions::new_ffi(&Some(vec![PathBuf::new()]), &None, false).is_err() ); assert!( Permissions::new_net(&Some(svec![String::new()]), &None, false).is_err() ); assert!( Permissions::new_write(&Some(vec![PathBuf::new()]), &None, false) .is_err() ); } }