/
githubmirror
/
deno
Обзор
Документация
Войти
/
githubmirror
/
deno
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
runtime/permissions/lib.rs
11 329 строк
319 KB
Nathan Whitaker
fix(cjs): use loader sources for recursive analysis (#36111)
30 июл 2026, 23:13
Не верифицирован
30 июл 2026, 23:13
786225a
Код
Авторство
О чём код?
// Copyright 2018-2026 the Deno authors. MIT license. use std::borrow::Cow; use std::cmp::Ordering; use std::ffi::OsStr; use std::fmt; use std::fmt::Debug; use std::hash::Hash; use std::io::Write; use std::net::IpAddr; use std::net::Ipv6Addr; use std::net::SocketAddr; use std::ops::Deref; use std::path::Path; use std::path::PathBuf; use std::string::ToString; use std::sync::Arc; use std::sync::OnceLock; use capacity_builder::StringBuilder; use deno_path_util::normalize_path; use deno_path_util::url_to_file_path; use deno_terminal::colors; use deno_unsync::sync::AtomicFlag; use fqdn::FQDN; use ipnet::IpNet; use once_cell::sync::Lazy; use parking_lot::Mutex; use serde::Deserialize; use serde::Deserializer; use serde::Serialize; use serde::de; use url::Url; pub mod broker; mod ipc_pipe; pub mod prompter; mod runtime_descriptor_parser; pub mod which; use prompter::MAYBE_CURRENT_STACKTRACE; use prompter::PERMISSION_EMOJI; use prompter::permission_prompt; pub use runtime_descriptor_parser::RuntimePermissionDescriptorParser; use self::prompter::PromptResponse; use self::which::WhichSys; #[derive(Debug, Eq, PartialEq)] pub enum BrokerResponse { Allow, Deny { message: Option<String> }, } use self::broker::has_broker; use self::broker::maybe_check_with_broker; pub type OtelAuditFn = fn(permission: &str, value: &str, stack: Option<&[String]>); pub enum AuditSink { File(Mutex<std::fs::File>), Otel(OtelAuditFn), } pub static AUDIT_SINK: OnceLock<AuditSink> = OnceLock::new(); #[derive(Debug, thiserror::Error, deno_error::JsError)] #[error("{}", custom_message.as_ref().cloned().unwrap_or_else(|| format!("Requires {access}, {}", format_permission_error(.name))))] #[class("NotCapable")] pub struct PermissionDeniedError { pub access: String, pub name: &'static str, pub custom_message: Option<String>, pub state: PermissionState, } fn format_permission_error(name: &'static str) -> String { if is_standalone() { format!( "specify the required permissions during compilation using `deno compile --allow-{name}`" ) } else { format!("run again with the --allow-{name} flag") } } fn write_audit<T>(flag_name: &str, value: T) where T: Serialize, { let Some(sink) = AUDIT_SINK.get() else { return; }; let get_stack = MAYBE_CURRENT_STACKTRACE.lock(); let stack = get_stack.as_ref().map(|s| s()); match sink { AuditSink::File(file) => { let mut file = file.lock(); let mut map = serde_json::Map::with_capacity(6); let _ = map.insert("v".into(), serde_json::Value::Number(1.into())); let _ = map.insert( "datetime".into(), #[allow( clippy::disallowed_methods, reason = "TODO: support passing in a sys here" )] serde_json::Value::String( chrono::Utc::now().to_rfc3339_opts(chrono::SecondsFormat::Secs, true), ), ); let _ = map.insert( "permission".into(), serde_json::to_value(flag_name).unwrap(), ); let _ = map.insert("value".into(), serde_json::to_value(&value).unwrap()); if let Some(ref stack) = stack { let _ = map.insert("stack".into(), serde_json::to_value(stack).unwrap()); } let _ = file.write_all( format!("{}\n", serde_json::to_string(&map).unwrap()).as_bytes(), ); } AuditSink::Otel(report_fn) => { let value_str = serde_json::to_value(&value) .map(|v| match v { serde_json::Value::String(s) => s, other => other.to_string(), }) .unwrap_or_default(); report_fn(flag_name, &value_str, stack.as_deref()); } } } /// Fast exit from permission check routines if this permission /// is in the "fully-granted" state. macro_rules! audit_and_skip_check_if_is_permission_fully_granted { ($this:expr, $flag_name:expr, $value:expr) => { write_audit($flag_name, $value); if $this.is_allow_all() { return Ok(()); } }; } static DEBUG_LOG_ENABLED: Lazy<bool> = 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, DeniedPartial = 4, Ignored = 5, } #[derive(Debug, Clone, Copy, PartialEq, Eq)] pub enum OpenAccessKind { Read, ReadNoFollow, Write, WriteNoFollow, ReadWrite, ReadWriteNoFollow, } impl OpenAccessKind { pub fn is_no_follow(&self) -> bool { match self { OpenAccessKind::ReadNoFollow | OpenAccessKind::WriteNoFollow | OpenAccessKind::ReadWriteNoFollow => true, OpenAccessKind::Read | OpenAccessKind::Write | OpenAccessKind::ReadWrite => false, } } pub fn is_read(&self) -> bool { match self { OpenAccessKind::Read | OpenAccessKind::ReadNoFollow | OpenAccessKind::ReadWrite | OpenAccessKind::ReadWriteNoFollow => true, OpenAccessKind::Write | OpenAccessKind::WriteNoFollow => false, } } pub fn is_write(&self) -> bool { match self { OpenAccessKind::Read | OpenAccessKind::ReadNoFollow => false, OpenAccessKind::Write | OpenAccessKind::WriteNoFollow | OpenAccessKind::ReadWrite | OpenAccessKind::ReadWriteNoFollow => true, } } } #[derive(Debug)] pub struct PathWithRequested<'a> { pub path: Cow<'a, Path>, /// Custom requested display name when differs from resolved. pub requested: Option<Cow<'a, str>>, } impl<'a> PathWithRequested<'a> { pub fn only_path(path: Cow<'a, Path>) -> Self { Self { path, requested: None, } } pub fn display(&self) -> std::path::Display<'_> { match &self.requested { Some(requested) => Path::new(requested.as_ref()).display(), None => self.path.display(), } } pub fn as_owned(&self) -> PathBufWithRequested { PathBufWithRequested { path: self.path.to_path_buf(), requested: self.requested.as_ref().map(|r| r.to_string()), } } pub fn into_owned(self) -> PathBufWithRequested { PathBufWithRequested { path: self.path.into_owned(), requested: self.requested.map(|r| r.into_owned()), } } } impl Deref for PathWithRequested<'_> { type Target = Path; fn deref(&self) -> &Self::Target { &self.path } } impl AsRef<Path> for PathWithRequested<'_> { fn as_ref(&self) -> &Path { &self.path } } impl<'a> AsRef<PathWithRequested<'a>> for PathWithRequested<'a> { fn as_ref(&self) -> &PathWithRequested<'a> { self } } #[derive(Debug, Clone)] pub struct PathBufWithRequested { pub path: PathBuf, /// Custom requested display name when differs from resolved. pub requested: Option<String>, } impl PathBufWithRequested { pub fn only_path(path: PathBuf) -> Self { Self { path, requested: None, } } pub fn as_path_with_requested(&self) -> PathWithRequested<'_> { PathWithRequested { path: Cow::Borrowed(self.path.as_path()), requested: self.requested.as_deref().map(Cow::Borrowed), } } } impl Deref for PathBufWithRequested { type Target = Path; fn deref(&self) -> &Self::Target { &self.path } } #[derive(Debug)] pub struct CheckedPath<'a> { // these are private to prevent someone constructing this outside the crate path: PathWithRequested<'a>, canonicalized: bool, } impl<'a> CheckedPath<'a> { pub fn unsafe_new(path: Cow<'a, Path>) -> Self { Self { path: PathWithRequested { path, requested: None, }, canonicalized: false, } } pub fn canonicalized(&self) -> bool { self.canonicalized } pub fn display(&self) -> std::path::Display<'_> { self.path.display() } pub fn into_path_with_requested(self) -> PathWithRequested<'a> { self.path } pub fn as_owned(&self) -> CheckedPathBuf { CheckedPathBuf { path: self.path.as_owned(), canonicalized: self.canonicalized, } } pub fn into_owned(self) -> CheckedPathBuf { CheckedPathBuf { path: self.path.into_owned(), canonicalized: self.canonicalized, } } pub fn into_path(self) -> Cow<'a, Path> { self.path.path } pub fn into_owned_path(self) -> PathBuf { self.path.path.into_owned() } } impl<'a> AsRef<PathWithRequested<'a>> for CheckedPath<'a> { fn as_ref(&self) -> &PathWithRequested<'a> { &self.path } } impl Deref for CheckedPath<'_> { type Target = Path; fn deref(&self) -> &Self::Target { &self.path.path } } impl AsRef<Path> for CheckedPath<'_> { fn as_ref(&self) -> &Path { &self.path.path } } #[derive(Debug, Clone)] pub struct CheckedPathBuf { path: PathBufWithRequested, canonicalized: bool, } impl CheckedPathBuf { pub fn unsafe_new(path: PathBuf) -> Self { Self { path: PathBufWithRequested::only_path(path), canonicalized: false, } } pub fn as_checked_path(&self) -> CheckedPath<'_> { CheckedPath { path: self.path.as_path_with_requested(), canonicalized: self.canonicalized, } } pub fn into_path_buf(self) -> PathBuf { self.path.path } } impl Deref for CheckedPathBuf { type Target = Path; fn deref(&self) -> &Self::Target { &self.path.path } } impl AsRef<Path> for CheckedPathBuf { fn as_ref(&self) -> &Path { &self.path.path } } /// `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, Copy, Clone, Eq, PartialEq)] #[allow(clippy::enum_variant_names, reason = "more clear")] enum AllowPartial { TreatAsGranted, TreatAsDenied, TreatAsPartialGranted, } impl From<bool> for AllowPartial { fn from(value: bool) -> Self { if value { Self::TreatAsGranted } else { Self::TreatAsDenied } } } struct PromptOptions<'a> { name: &'static str, msg: &'a str, api_name: Option<&'a str>, info: Option<&'a str>, is_unary: bool, } impl PermissionState { #[inline(always)] fn log_perm_access( name: &'static str, info: impl FnOnce() -> Option<String>, ) { // 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().as_deref()) )) ); } } fn fmt_access(name: &'static str, info: Option<&str>) -> String { format!( "{} access{}", name, info.map(|info| format!(" to {info}")).unwrap_or_default(), ) } fn permission_denied_error( name: &'static str, info: Option<&str>, state: PermissionState, ) -> PermissionDeniedError { PermissionDeniedError { access: Self::fmt_access(name, info), name, custom_message: None, state, } } fn prompt( options: PromptOptions<'_>, ) -> (Result<(), PermissionDeniedError>, bool) { let PromptOptions { name, msg, api_name, info, is_unary, } = options; match permission_prompt(msg, name, api_name, is_unary) { PromptResponse::Allow => { Self::log_perm_access(name, || info.map(|i| i.to_string())); (Ok(()), false) } PromptResponse::AllowAll => { Self::log_perm_access(name, || info.map(|i| i.to_string())); (Ok(()), true) } PromptResponse::Deny => ( Err(Self::permission_denied_error( name, info, PermissionState::Denied, )), false, ), } } #[inline] fn check( self, name: &'static str, api_name: Option<&str>, stringify_value_fn: impl Fn() -> Option<String>, info: impl Fn() -> Option<String>, prompt: bool, ) -> (Result<(), PermissionDeniedError>, bool, bool) { if let Some(resp) = maybe_check_with_broker(name, &stringify_value_fn) { match resp { BrokerResponse::Allow => { Self::log_perm_access(name, info); return (Ok(()), false, false); } BrokerResponse::Deny { message } => { return ( Err(PermissionDeniedError { access: Self::fmt_access(name, info().as_deref()), name, custom_message: message, state: PermissionState::Denied, }), false, false, ); } } } match self { PermissionState::Granted => { Self::log_perm_access(name, info); (Ok(()), false, false) } PermissionState::Prompt if prompt => { let info = info(); let msg = StringBuilder::<String>::build(|builder| { builder.append(name); builder.append(" access"); if let Some(info) = &info { builder.append(" to "); builder.append(info); } }) .unwrap(); let (result, is_allow_all) = Self::prompt(PromptOptions { name, msg: &msg, api_name, info: info.as_deref(), is_unary: true, }); (result, true, is_allow_all) } state => { let err = Self::permission_denied_error(name, info().as_deref(), state); (Err(err), false, false) } } } } #[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, stringify_value_fn: impl Fn() -> Option<String>, info: impl Fn() -> Option<String>, ) -> Result<(), PermissionDeniedError> { let (result, prompted, _is_allow_all) = self .state .check(self.name, None, stringify_value_fn, info, 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, Ord, PartialOrd)] pub struct EnvVarName { inner: String, } impl EnvVarName { pub fn new(env: Cow<'_, str>) -> Self { EnvVarNameRef::new(env).into_owned() } pub fn as_env_var_name_ref(&self) -> EnvVarNameRef<'static> { EnvVarNameRef { inner: Cow::Owned(self.inner.clone()), } } } impl AsRef<str> for EnvVarName { fn as_ref(&self) -> &str { self.inner.as_ref() } } /// 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)] pub struct EnvVarNameRef<'a> { inner: Cow<'a, str>, } impl<'a> EnvVarNameRef<'a> { pub fn new(env: Cow<'a, str>) -> Self { Self { inner: if cfg!(windows) { Cow::Owned(env.to_uppercase()) } else { env }, } } pub fn into_owned(self) -> EnvVarName { EnvVarName { inner: self.inner.into_owned(), } } } impl AsRef<str> for EnvVarNameRef<'_> { fn as_ref(&self) -> &str { self.inner.as_ref() } } impl PartialEq<EnvVarNameRef<'_>> for EnvVarName { fn eq(&self, other: &EnvVarNameRef<'_>) -> bool { self.inner == other.inner } } pub trait AllowDescriptor: Debug + Eq + Clone + Hash { type QueryDesc<'a>: QueryDescriptor<AllowDesc = Self, DenyDesc = Self::DenyDesc>; type DenyDesc: DenyDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering; fn cmp_deny(&self, other: &Self::DenyDesc) -> Ordering; } pub trait DenyDescriptor: Debug + Eq + Clone + Hash { fn cmp_deny(&self, other: &Self) -> Ordering; } pub trait QueryDescriptor: Debug { type AllowDesc: AllowDescriptor; type DenyDesc: DenyDescriptor; fn flag_name() -> &'static str; fn display_name(&self) -> Cow<'_, str>; fn from_allow(allow: &Self::AllowDesc) -> Self; fn as_allow(&self) -> Option<Self::AllowDesc>; fn as_deny(&self) -> Self::DenyDesc; /// Generic check function to check this descriptor against a `UnaryPermission`. fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError>; fn matches_allow(&self, other: &Self::AllowDesc) -> bool; fn matches_deny(&self, other: &Self::DenyDesc) -> bool; /// Gets if this query descriptor should revoke the provided allow descriptor. fn revokes(&self, other: &Self::AllowDesc) -> bool; fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool; fn overlaps_deny(&self, other: &Self::DenyDesc) -> bool; } fn format_display_name(display_name: Cow<'_, str>) -> Cow<'_, str> { if display_name.starts_with('<') && display_name.ends_with('>') { display_name } else { Cow::Owned(format!("\"{}\"", display_name)) } } #[derive(Debug, Clone, Eq, PartialEq)] enum AllowOrDenyDescRef<'a, TAllowDesc: AllowDescriptor> { Allow(&'a TAllowDesc), Deny { desc: &'a TAllowDesc::DenyDesc, order: u8, }, } #[derive(Debug, Clone, Eq, PartialEq)] enum UnaryPermissionDesc<TAllowDesc: AllowDescriptor> { Granted(TAllowDesc), FlagDenied(TAllowDesc::DenyDesc), FlagIgnored(TAllowDesc::DenyDesc), PromptDenied(TAllowDesc::DenyDesc), } impl<TAllowDesc: AllowDescriptor> std::cmp::PartialOrd for UnaryPermissionDesc<TAllowDesc> { fn partial_cmp(&self, other: &Self) -> Option<Ordering> { Some(self.cmp(other)) } } impl<TAllowDesc: AllowDescriptor> std::cmp::Ord for UnaryPermissionDesc<TAllowDesc> { fn cmp(&self, other: &Self) -> Ordering { match self.allow_or_deny_desc() { AllowOrDenyDescRef::Allow(self_desc) => { match other.allow_or_deny_desc() { AllowOrDenyDescRef::Allow(other_desc) => { self_desc.cmp_allow(other_desc) } AllowOrDenyDescRef::Deny { desc: other_desc, .. } => match self_desc.cmp_deny(other_desc) { Ordering::Equal => { self.kind_precedence().cmp(&other.kind_precedence()) } ord => ord, }, } } AllowOrDenyDescRef::Deny { desc: self_desc, order: self_order, } => { match other.allow_or_deny_desc() { AllowOrDenyDescRef::Allow(other_desc) => { match other_desc.cmp_deny(self_desc) { Ordering::Equal => { self.kind_precedence().cmp(&other.kind_precedence()) } // flip because we compared the other to self above Ordering::Less => Ordering::Greater, Ordering::Greater => Ordering::Less, } } AllowOrDenyDescRef::Deny { desc: other_desc, order: other_order, } => match self_desc.cmp_deny(other_desc) { Ordering::Equal => self_order.cmp(&other_order), ordering => ordering, }, } } } } } impl<TAllowDesc: AllowDescriptor> UnaryPermissionDesc<TAllowDesc> { fn allow_or_deny_desc(&self) -> AllowOrDenyDescRef<'_, TAllowDesc> { match self { UnaryPermissionDesc::Granted(desc) => AllowOrDenyDescRef::Allow(desc), UnaryPermissionDesc::FlagDenied(desc) => { AllowOrDenyDescRef::Deny { desc, order: 0 } } UnaryPermissionDesc::PromptDenied(desc) => { AllowOrDenyDescRef::Deny { desc, order: 1 } } UnaryPermissionDesc::FlagIgnored(desc) => { AllowOrDenyDescRef::Deny { desc, order: 2 } } } } fn kind_precedence(&self) -> u8 { match self { UnaryPermissionDesc::FlagDenied(_) => 0, UnaryPermissionDesc::PromptDenied(_) => 1, UnaryPermissionDesc::FlagIgnored(_) => 2, UnaryPermissionDesc::Granted(_) => 3, } } } #[derive(Debug, Clone, Eq, PartialEq)] struct UnaryPermissionDescriptors<TAllowDesc: AllowDescriptor> { inner: Vec<UnaryPermissionDesc<TAllowDesc>>, has_flag_denied: bool, has_prompt_denied: bool, has_flag_ignored: bool, } impl<TAllowDesc: AllowDescriptor> Default for UnaryPermissionDescriptors<TAllowDesc> { fn default() -> Self { Self { inner: Default::default(), has_flag_denied: false, has_prompt_denied: false, has_flag_ignored: false, } } } impl<TAllowDesc: AllowDescriptor> UnaryPermissionDescriptors<TAllowDesc> { pub fn with_capacity(capacity: usize) -> Self { Self { inner: Vec::with_capacity(capacity), ..Default::default() } } pub fn iter(&self) -> impl Iterator<Item = &UnaryPermissionDesc<TAllowDesc>> { self.inner.iter() } pub fn has_any_denied_or_ignored(&self) -> bool { self.has_flag_denied || self.has_prompt_denied || self.has_flag_ignored } pub fn has_prompt_denied(&self) -> bool { self.has_prompt_denied } pub fn insert(&mut self, item: UnaryPermissionDesc<TAllowDesc>) { match &item { UnaryPermissionDesc::Granted(_) => {} UnaryPermissionDesc::FlagDenied(_) => { self.has_flag_denied = true; } UnaryPermissionDesc::FlagIgnored(_) => { self.has_flag_ignored = true; } UnaryPermissionDesc::PromptDenied(_) => { self.has_prompt_denied = true; } } if let Err(insert_index) = self.inner.binary_search(&item) { self.inner.insert(insert_index, item); } } pub fn revoke_granted(&mut self, desc: &TAllowDesc::QueryDesc<'_>) { self.inner.retain(|v| match v { UnaryPermissionDesc::Granted(v) => !desc.revokes(v), UnaryPermissionDesc::FlagDenied(_) | UnaryPermissionDesc::FlagIgnored(_) | UnaryPermissionDesc::PromptDenied(_) => true, }) } pub fn revoke_all_granted(&mut self) { self.inner.retain(|v| match v { UnaryPermissionDesc::Granted(_) => false, UnaryPermissionDesc::FlagDenied(_) | UnaryPermissionDesc::FlagIgnored(_) | UnaryPermissionDesc::PromptDenied(_) => true, }) } } #[derive(Debug, Eq, PartialEq)] pub struct UnaryPermission<TAllowDesc: AllowDescriptor> { granted_global: bool, flag_denied_global: bool, flag_ignored_global: bool, prompt_denied_global: bool, descriptors: UnaryPermissionDescriptors<TAllowDesc>, prompt: bool, } impl<TAllowDesc: AllowDescriptor> Default for UnaryPermission<TAllowDesc> { fn default() -> Self { UnaryPermission { granted_global: Default::default(), flag_denied_global: Default::default(), flag_ignored_global: Default::default(), prompt_denied_global: Default::default(), descriptors: Default::default(), prompt: Default::default(), } } } impl<TAllowDesc: AllowDescriptor> Clone for UnaryPermission<TAllowDesc> { fn clone(&self) -> Self { Self { granted_global: self.granted_global, flag_denied_global: self.flag_denied_global, flag_ignored_global: self.flag_ignored_global, prompt_denied_global: self.prompt_denied_global, descriptors: self.descriptors.clone(), prompt: self.prompt, } } } impl< TAllowDesc: AllowDescriptor<DenyDesc = TDenyDesc>, TDenyDesc: DenyDescriptor, > UnaryPermission<TAllowDesc> { pub fn allow_all() -> Self { Self { granted_global: true, ..Default::default() } } pub fn is_allow_all(&self) -> bool { self.granted_global && !self.flag_denied_global && !self.prompt_denied_global && !self.flag_ignored_global && !self.descriptors.has_any_denied_or_ignored() && !has_broker() } pub fn check_all_api( &mut self, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, TAllowDesc::QueryDesc::flag_name(), () ); self.check_desc(None, false, api_name) } fn check_desc( &mut self, desc: Option<&TAllowDesc::QueryDesc<'_>>, assert_non_partial: bool, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { let (result, prompted, is_allow_all) = self .query_desc(desc, AllowPartial::from(!assert_non_partial)) .check( TAllowDesc::QueryDesc::flag_name(), api_name, || desc.map(|d| d.display_name().to_string()), || desc.map(|d| format_display_name(d.display_name()).into_owned()), self.prompt, ); if prompted { if result.is_ok() { if is_allow_all { self.insert_granted(None); } else { self.insert_granted(desc); } } else { self.insert_prompt_denied(desc.map(|d| d.as_deny())); } } result } fn query_desc( &self, desc: Option<&TAllowDesc::QueryDesc<'_>>, allow_partial: AllowPartial, ) -> PermissionState { if let Some(state) = self.query_allowed_desc_for_exact_match(desc, allow_partial) { state } else if self.flag_ignored_global { PermissionState::Ignored } else if matches!(allow_partial, AllowPartial::TreatAsDenied) && self.is_partial_flag_denied(desc) { PermissionState::DeniedPartial } else if self.flag_denied_global || desc.is_none() && (self.prompt_denied_global || self.descriptors.has_prompt_denied()) { PermissionState::Denied } else if self.granted_global { self.query_allowed_desc(desc, allow_partial) } else { PermissionState::Prompt } } fn query_allowed_desc_for_exact_match( &self, desc: Option<&TAllowDesc::QueryDesc<'_>>, allow_partial: AllowPartial, ) -> Option<PermissionState> { let desc = desc?; for item in self.descriptors.iter() { match item { UnaryPermissionDesc::Granted(v) => { if desc.matches_allow(v) { return Some(self.query_allowed_desc(Some(desc), allow_partial)); } } UnaryPermissionDesc::FlagDenied(v) => { if desc.matches_deny(v) { return Some(PermissionState::Denied); } } UnaryPermissionDesc::FlagIgnored(v) => { if desc.matches_deny(v) { return Some(PermissionState::Ignored); } } UnaryPermissionDesc::PromptDenied(v) => { if desc.stronger_than_deny(v) { return Some(PermissionState::Denied); } } } } None } fn query_allowed_desc( &self, desc: Option<&TAllowDesc::QueryDesc<'_>>, allow_partial: AllowPartial, ) -> PermissionState { match allow_partial { AllowPartial::TreatAsGranted => PermissionState::Granted, AllowPartial::TreatAsDenied => { if self.is_partial_flag_denied(desc) { PermissionState::DeniedPartial } else { PermissionState::Granted } } AllowPartial::TreatAsPartialGranted => { if self.is_partial_flag_denied(desc) { PermissionState::GrantedPartial } else { PermissionState::Granted } } } } fn request_desc( &mut self, desc: Option<&TAllowDesc::QueryDesc<'_>>, ) -> PermissionState { let state = self.query_desc(desc, AllowPartial::TreatAsPartialGranted); if state == PermissionState::Granted { self.insert_granted(desc); return state; } if state != PermissionState::Prompt { return state; } if !self.prompt { return PermissionState::Denied; } let maybe_formatted_display_name = desc.map(|d| format_display_name(d.display_name())); let message = StringBuilder::<String>::build(|builder| { builder.append(TAllowDesc::QueryDesc::flag_name()); builder.append(" access"); if let Some(display_name) = &maybe_formatted_display_name { builder.append(" to "); builder.append(display_name) } }) .unwrap(); match permission_prompt( &message, TAllowDesc::QueryDesc::flag_name(), Some("Deno.permissions.request()"), true, ) { PromptResponse::Allow => { self.insert_granted(desc); PermissionState::Granted } PromptResponse::Deny => { self.insert_prompt_denied(desc.map(|d| d.as_deny())); PermissionState::Denied } PromptResponse::AllowAll => { self.insert_granted(None); PermissionState::Granted } } } fn revoke_desc( &mut self, desc: Option<&TAllowDesc::QueryDesc<'_>>, ) -> PermissionState { match desc { Some(desc) => { self.descriptors.revoke_granted(desc); } 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.descriptors.revoke_all_granted(); } } self.query_desc(desc, AllowPartial::TreatAsPartialGranted) } fn is_partial_flag_denied( &self, query: Option<&TAllowDesc::QueryDesc<'_>>, ) -> bool { match query { None => { self.descriptors.has_flag_denied || self.descriptors.has_flag_ignored } Some(query) => self.descriptors.iter().any(|desc| match desc { UnaryPermissionDesc::FlagIgnored(v) | UnaryPermissionDesc::FlagDenied(v) => query.overlaps_deny(v), UnaryPermissionDesc::Granted(_) | UnaryPermissionDesc::PromptDenied(_) => false, }), } } fn insert_granted( &mut self, query: Option<&TAllowDesc::QueryDesc<'_>>, ) -> bool { let desc = match query.map(|q| q.as_allow()) { Some(Some(allow_desc)) => Some(allow_desc), Some(None) => { // the user was prompted for this descriptor in order to not // expose anything about the system to the program, but the // descriptor wasn't valid so no permission was raised return false; } None => None, }; Self::list_insert( desc.map(UnaryPermissionDesc::Granted), &mut self.granted_global, &mut self.descriptors, ); true } fn insert_prompt_denied(&mut self, desc: Option<TDenyDesc>) { Self::list_insert( desc.map(UnaryPermissionDesc::PromptDenied), &mut self.prompt_denied_global, &mut self.descriptors, ); } fn list_insert( desc: Option<UnaryPermissionDesc<TAllowDesc>>, list_global: &mut bool, descriptors: &mut UnaryPermissionDescriptors<TAllowDesc>, ) { match desc { Some(desc) => { descriptors.insert(desc); } None => *list_global = true, } } fn create_child_permissions<E>( &mut self, flag: ChildUnaryPermissionArg, parse: impl Fn(&str) -> Result<Option<TAllowDesc>, E>, ) -> Result<UnaryPermission<TAllowDesc>, ChildPermissionError> where ChildPermissionError: From<E>, { let mut perms = Self::default(); match flag { ChildUnaryPermissionArg::Inherit => { perms.clone_from(self); } ChildUnaryPermissionArg::Granted => { if self.check_all_api(None).is_err() { return Err(ChildPermissionError::Escalation); } perms.granted_global = true; } ChildUnaryPermissionArg::NotGranted => {} ChildUnaryPermissionArg::GrantedList(granted_list) => { for result in granted_list.iter().filter_map(|i| parse(i).transpose()) { let desc = result?; if TAllowDesc::QueryDesc::from_allow(&desc) .check_in_permission(self, None) .is_err() { return Err(ChildPermissionError::Escalation); } perms.descriptors.insert(UnaryPermissionDesc::Granted(desc)); } } } perms.flag_denied_global = self.flag_denied_global; perms.prompt_denied_global = self.prompt_denied_global; perms.prompt = self.prompt; perms.flag_ignored_global = self.flag_ignored_global; for item in self.descriptors.iter() { match item { UnaryPermissionDesc::Granted(_) => { // ignore } UnaryPermissionDesc::FlagDenied(_) | UnaryPermissionDesc::FlagIgnored(_) | UnaryPermissionDesc::PromptDenied(_) => { perms.descriptors.insert(item.clone()); } } } Ok(perms) } } #[derive(Clone, Debug)] pub struct PathQueryDescriptor<'a> { path: Cow<'a, Path>, /// Lowercased on Windows for case-insensitive comparison; same as `path` on /// other platforms. Used by PartialEq, starts_with, etc. cmp_path: PathBuf, /// Custom requested display name when differs from resolved. requested: Option<String>, is_windows_device_path: bool, } impl PartialEq for PathQueryDescriptor<'_> { fn eq(&self, other: &Self) -> bool { self.cmp_path == other.cmp_path } } impl Eq for PathQueryDescriptor<'_> {} impl PartialEq<PathDescriptor> for PathQueryDescriptor<'_> { fn eq(&self, other: &PathDescriptor) -> bool { self.cmp_path == other.cmp_path } } /// Returns a normalized copy of the path for filesystem-aware comparison. /// /// - Windows (NTFS): ASCII-lowercased for case-insensitive matching. /// - macOS (APFS/HFS+): NFKD-normalized and Unicode-case-folded, because /// APFS resolves Unicode-equivalent and case-differing paths to the same /// inode (e.g. `ß`/`ss`, `fi`/`fi`, NFC/NFD forms, upper/lower). /// - Other platforms: returns a clone (case-sensitive, no normalization). #[inline] #[cfg(windows)] fn comparison_path(path: &Path) -> PathBuf { PathBuf::from(path.to_string_lossy().to_ascii_lowercase()) } #[inline] #[cfg(target_os = "macos")] fn comparison_path(path: &Path) -> PathBuf { use unicode_normalization::UnicodeNormalization; // NFKD handles canonical decomposition (NFC->NFD) and compatibility // decomposition (ligatures like fi->fi). Uppercase then lowercase // approximates Unicode case folding (maps ss->SS->ss, etc.). let s = path.to_string_lossy(); let normalized: String = s.nfkd().collect(); PathBuf::from(normalized.to_uppercase().to_lowercase()) } #[inline] #[cfg(not(any(windows, target_os = "macos")))] fn comparison_path(path: &Path) -> PathBuf { path.to_path_buf() } /// On Windows, strips a `\\?\` verbatim (extended-length) prefix from a path /// when it can be losslessly represented without it, so that the permission /// system treats `\\?\C:\foo` and `C:\foo` as the same path. The two forms /// refer to the same file, so a grant for one must apply to the other (see /// denoland/deno#18597). /// /// `dunce::simplified` only strips the prefix when it is actually safe to do /// so: it leaves verbatim paths that contain `.`/`..` components (taken /// literally in verbatim mode), reserved device names (e.g. `CON`), or that /// are too long to be expressed as a regular path, because those forms are /// *not* equivalent to their stripped counterparts. #[cfg(windows)] #[inline] fn strip_verbatim_prefix(path: Cow<'_, Path>) -> Cow<'_, Path> { let simplified = dunce::simplified(path.as_ref()); if simplified.as_os_str().len() == path.as_os_str().len() { path } else { Cow::Owned(simplified.to_path_buf()) } } #[cfg(not(windows))] #[inline] fn strip_verbatim_prefix(path: Cow<'_, Path>) -> Cow<'_, Path> { path } impl<'a> PathQueryDescriptor<'a> { pub fn new( sys: &impl sys_traits::EnvCurrentDir, path: Cow<'a, Path>, ) -> Result<Self, PathResolveError> { let path_bytes = path.as_os_str().as_encoded_bytes(); if path_bytes.is_empty() { return Err(PathResolveError::EmptyPath); } let path = strip_verbatim_prefix(path); let path_bytes = path.as_os_str().as_encoded_bytes(); let is_windows_device_path = cfg!(windows) && path_bytes.starts_with(br"\\.\") && !path_bytes.contains(&b':'); let (path, requested) = if is_windows_device_path { // On Windows, normalize_path doesn't work with device-prefix-style // paths. We pass these through. (path, None) } else if path.is_absolute() { (normalize_path(path), None) } else { let cwd = sys .env_current_dir() .map_err(PathResolveError::CwdResolve)?; ( normalize_path(Cow::Owned(cwd.join(path.as_ref()))), Some(path.to_string_lossy().into_owned()), ) }; let cmp_path = comparison_path(&path); Ok(Self { path, cmp_path, requested, is_windows_device_path, }) } pub fn new_known_absolute(path: Cow<'a, Path>) -> Self { let path = strip_verbatim_prefix(path); let path_bytes = path.as_os_str().as_encoded_bytes(); let is_windows_device_path = cfg!(windows) && path_bytes.starts_with(br"\\.\") && !path_bytes.contains(&b':'); let path = if is_windows_device_path { // On Windows, normalize_path doesn't work with device-prefix-style // paths. We pass these through. path } else { normalize_path(path) }; let cmp_path = comparison_path(&path); Self { path, cmp_path, requested: None, is_windows_device_path, } } pub fn with_requested(self, requested: String) -> Self { Self { requested: Some(requested), ..self } } pub fn starts_with(&self, base: &PathDescriptor) -> bool { self.cmp_path.starts_with(&base.cmp_path) } pub fn display_name(&self) -> Cow<'_, str> { match &self.requested { Some(requested) => Cow::Borrowed(requested.as_str()), None => self.path.to_string_lossy(), } } pub fn as_descriptor(&self) -> PathDescriptor { PathDescriptor { path: self.path.to_path_buf(), cmp_path: self.cmp_path.clone(), requested: self.requested.clone(), is_windows_device_path: self.is_windows_device_path, } } pub fn into_descriptor(self) -> PathDescriptor { PathDescriptor { path: self.path.into_owned(), cmp_path: self.cmp_path, requested: self.requested, is_windows_device_path: self.is_windows_device_path, } } pub fn into_ffi(self) -> FfiQueryDescriptor<'a> { FfiQueryDescriptor(self) } pub fn into_read(self) -> ReadQueryDescriptor<'a> { ReadQueryDescriptor(self) } pub fn into_write(self) -> WriteQueryDescriptor<'a> { WriteQueryDescriptor(self) } } #[derive(Clone, Debug)] pub struct ReadQueryDescriptor<'a>(pub PathQueryDescriptor<'a>); impl QueryDescriptor for ReadQueryDescriptor<'_> { type AllowDesc = ReadDescriptor; type DenyDesc = ReadDescriptor; fn flag_name() -> &'static str { "read" } fn display_name(&self) -> Cow<'_, str> { self.0.display_name() } fn from_allow(allow: &Self::AllowDesc) -> Self { allow.0.as_query_descriptor().into_read() } fn as_allow(&self) -> Option<Self::AllowDesc> { Some(self.0.as_descriptor().into_read()) } fn as_deny(&self) -> Self::DenyDesc { self.0.as_descriptor().into_read() } fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( perm, Self::flag_name(), () ); perm.check_desc(Some(self), true, api_name) } fn matches_allow(&self, other: &Self::AllowDesc) -> bool { self.0.starts_with(&other.0) } fn matches_deny(&self, other: &Self::DenyDesc) -> bool { self.0.starts_with(&other.0) } fn revokes(&self, other: &Self::AllowDesc) -> bool { self.matches_allow(other) } fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool { other.0.starts_with(&self.0) } fn overlaps_deny(&self, other: &Self::DenyDesc) -> bool { self.stronger_than_deny(other) } } #[derive(Clone, Debug)] pub struct PathDescriptor { path: PathBuf, /// Lowercased on Windows for case-insensitive comparison; same as `path` on /// other platforms. Used by PartialEq, Hash, starts_with, cmp_*. cmp_path: PathBuf, /// Custom requested display name when differs from resolved. requested: Option<String>, is_windows_device_path: bool, } impl PartialEq for PathDescriptor { fn eq(&self, other: &Self) -> bool { self.cmp_path == other.cmp_path } } impl Eq for PathDescriptor {} impl Hash for PathDescriptor { fn hash<H: std::hash::Hasher>(&self, state: &mut H) { self.cmp_path.hash(state); } } impl PathDescriptor { pub fn new( sys: &impl sys_traits::EnvCurrentDir, path: Cow<'_, Path>, ) -> Result<Self, PathResolveError> { PathQueryDescriptor::new(sys, path).map(|p| p.into_descriptor()) } pub fn new_known_cwd(path: Cow<'_, Path>, cwd: &Path) -> Self { let path = strip_verbatim_prefix(path); let path_bytes = path.as_os_str().as_encoded_bytes(); let is_windows_device_path = cfg!(windows) && path_bytes.starts_with(br"\\.\") && !path_bytes.contains(&b':'); let (path, display) = if is_windows_device_path { // On Windows, normalize_path doesn't work with device-prefix-style // paths. We pass these through. (path, None) } else if path.is_absolute() { (normalize_path(path), None) } else { ( normalize_path(Cow::Owned(cwd.join(path.as_ref()))), Some(path.to_string_lossy().into_owned()), ) }; let cmp_path = comparison_path(&path); Self { path: path.into_owned(), cmp_path, requested: display, is_windows_device_path, } } pub fn new_known_absolute(path: Cow<'_, Path>) -> Self { PathQueryDescriptor::new_known_absolute(path).into_descriptor() } pub fn starts_with(&self, base: &PathQueryDescriptor) -> bool { self.cmp_path.starts_with(&base.cmp_path) } pub fn display_name(&self) -> Cow<'_, str> { match &self.requested { Some(requested) => Cow::Borrowed(requested.as_str()), None => self.path.to_string_lossy(), } } pub fn as_query_descriptor(&self) -> PathQueryDescriptor<'static> { PathQueryDescriptor { path: Cow::Owned(self.path.clone()), cmp_path: self.cmp_path.clone(), requested: self.requested.clone(), is_windows_device_path: self.is_windows_device_path, } } pub fn into_ffi(self) -> FfiDescriptor { FfiDescriptor(self) } pub fn into_read(self) -> ReadDescriptor { ReadDescriptor(self) } pub fn into_write(self) -> WriteDescriptor { WriteDescriptor(self) } pub fn into_path_buf(self) -> PathBuf { self.path } fn cmp_allow_allow(&self, other: &PathDescriptor) -> Ordering { if self.cmp_path == other.cmp_path { Ordering::Equal } else if other.cmp_path.starts_with(&self.cmp_path) { Ordering::Greater } else if self.cmp_path.starts_with(&other.cmp_path) { Ordering::Less } else { self.cmp_path.cmp(&other.cmp_path) } } fn cmp_allow_deny(&self, other: &PathDescriptor) -> Ordering { if other.cmp_path.starts_with(&self.cmp_path) { Ordering::Greater } else if self.cmp_path.starts_with(&other.cmp_path) { Ordering::Less } else { Ordering::Greater } } fn cmp_deny_deny(&self, other: &PathDescriptor) -> Ordering { self.cmp_allow_allow(other) } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct ReadDescriptor(pub PathDescriptor); impl AllowDescriptor for ReadDescriptor { type QueryDesc<'a> = ReadQueryDescriptor<'a>; type DenyDesc = ReadDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering { self.0.cmp_allow_allow(&other.0) } fn cmp_deny(&self, other: &Self::DenyDesc) -> Ordering { self.0.cmp_allow_deny(&other.0) } } impl DenyDescriptor for ReadDescriptor { fn cmp_deny(&self, other: &Self) -> Ordering { self.0.cmp_deny_deny(&other.0) } } #[derive(Clone, Debug)] pub struct WriteQueryDescriptor<'a>(pub PathQueryDescriptor<'a>); impl QueryDescriptor for WriteQueryDescriptor<'_> { type AllowDesc = WriteDescriptor; type DenyDesc = WriteDescriptor; fn flag_name() -> &'static str { "write" } fn display_name(&self) -> Cow<'_, str> { self.0.display_name() } fn from_allow(allow: &Self::AllowDesc) -> Self { WriteQueryDescriptor(allow.0.as_query_descriptor()) } fn as_allow(&self) -> Option<Self::AllowDesc> { Some(WriteDescriptor(self.0.as_descriptor())) } fn as_deny(&self) -> Self::DenyDesc { WriteDescriptor(self.0.as_descriptor()) } fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( perm, Self::flag_name(), () ); perm.check_desc(Some(self), true, api_name) } fn matches_allow(&self, other: &Self::AllowDesc) -> bool { self.0.starts_with(&other.0) } fn matches_deny(&self, other: &Self::DenyDesc) -> bool { self.0.starts_with(&other.0) } fn revokes(&self, other: &Self::AllowDesc) -> bool { self.matches_allow(other) } fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool { other.0.starts_with(&self.0) } fn overlaps_deny(&self, other: &Self::DenyDesc) -> bool { self.stronger_than_deny(other) } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct WriteDescriptor(pub PathDescriptor); impl AllowDescriptor for WriteDescriptor { type QueryDesc<'a> = WriteQueryDescriptor<'a>; type DenyDesc = WriteDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering { self.0.cmp_allow_allow(&other.0) } fn cmp_deny(&self, other: &Self::DenyDesc) -> Ordering { self.0.cmp_allow_deny(&other.0) } } impl DenyDescriptor for WriteDescriptor { fn cmp_deny(&self, other: &Self) -> Ordering { self.0.cmp_deny_deny(&other.0) } } #[derive(Debug, Default, Clone, Copy, Eq, PartialEq)] pub enum SubdomainWildcards { Enabled, #[default] Disabled, } /// Normalize IPv4-mapped IPv6 addresses (e.g. `::ffff:127.0.0.1`) to /// their IPv4 equivalent so that permission checks treat them identically /// to the bare IPv4 form. fn normalize_ip(ip: IpAddr) -> IpAddr { match ip { IpAddr::V6(v6) => match v6.to_ipv4_mapped() { Some(v4) => IpAddr::V4(v4), None => IpAddr::V6(v6), }, ip => ip, } } #[derive(Clone, Eq, PartialEq, Hash, Debug, PartialOrd, Ord)] pub enum Host { Fqdn(FQDN), FqdnWithSubdomainWildcard(FQDN), Ip(IpAddr), Vsock(u32), IpSubnet(IpNet), UnixSocket(PathBuf), } #[derive(Debug, thiserror::Error, deno_error::JsError)] #[class(uri)] pub enum HostParseError { #[error("invalid IPv6 address: '{0}'")] InvalidIpv6(String), #[error("invalid host: '{0}'")] InvalidHost(String), #[error("invalid empty host: '{0}'")] InvalidEmptyHost(String), #[error("invalid host '{host}': {error}")] Fqdn { #[source] error: fqdn::Error, host: String, }, } /// Strip IPv6 zone index from an address string if present. /// (e.g., fe80::1%eth0 or fe80::1%18) fn strip_ipv6_zone_index(addr: &str) -> &str { if let Some(idx) = addr.find('%') { &addr[..idx] } else { addr } } impl Host { fn parse_for_query(s: &str) -> Result<Self, HostParseError> { Self::parse_inner(s, SubdomainWildcards::Disabled) } #[cfg(test)] fn parse_for_list(s: &str) -> Result<Self, HostParseError> { Self::parse_inner(s, SubdomainWildcards::Enabled) } fn parse_inner( s: &str, subdomain_wildcards: SubdomainWildcards, ) -> Result<Self, HostParseError> { if s.starts_with('[') && s.ends_with(']') { let ip_str = &s[1..s.len() - 1]; let ip = strip_ipv6_zone_index(ip_str) .parse::<Ipv6Addr>() .map_err(|_| HostParseError::InvalidIpv6(s.to_string()))?; return Ok(Host::Ip(normalize_ip(IpAddr::V6(ip)))); } let (without_trailing_dot, has_trailing_dot) = s.strip_suffix('.').map_or((s, false), |s| (s, true)); let ip_result = strip_ipv6_zone_index(without_trailing_dot).parse::<IpAddr>(); if let Ok(ip) = ip_result { if has_trailing_dot { return Err(HostParseError::InvalidHost( without_trailing_dot.to_string(), )); } Ok(Host::Ip(normalize_ip(ip))) } else if let Ok(ip_subnet) = s.parse::<IpNet>() { Ok(Host::IpSubnet(ip_subnet)) } else { let lower = if s.chars().all(|c| c.is_ascii_lowercase()) { Cow::Borrowed(s) } else { Cow::Owned(s.to_ascii_lowercase()) }; let mut host_or_suffix = lower.as_ref(); let mut has_subdomain_wildcard = false; if matches!(subdomain_wildcards, SubdomainWildcards::Enabled) && let Some(suffix) = lower.strip_prefix("*.") { host_or_suffix = suffix; has_subdomain_wildcard = true; } let fqdn = { use std::str::FromStr; FQDN::from_str(host_or_suffix).map_err(|e| HostParseError::Fqdn { error: e, host: s.to_string(), })? }; if fqdn.is_root() { return Err(HostParseError::InvalidEmptyHost(s.to_string())); } if has_subdomain_wildcard { Ok(Host::FqdnWithSubdomainWildcard(fqdn)) } else { Ok(Host::Fqdn(fqdn)) } } } #[cfg(test)] #[track_caller] fn must_parse(s: &str) -> Self { Self::parse_for_list(s).unwrap() } } #[derive(Clone, Eq, PartialEq, Hash, Debug, PartialOrd, Ord)] pub struct NetDescriptor(pub Host, pub Option<u32>); impl QueryDescriptor for NetDescriptor { type AllowDesc = NetDescriptor; type DenyDesc = NetDescriptor; fn flag_name() -> &'static str { "net" } fn display_name(&self) -> Cow<'_, str> { Cow::from(format!("{}", self)) } fn from_allow(allow: &Self::AllowDesc) -> Self { allow.clone() } fn as_allow(&self) -> Option<Self::AllowDesc> { Some(self.clone()) } fn as_deny(&self) -> Self::DenyDesc { self.clone() } fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( perm, Self::flag_name(), () ); perm.check_desc(Some(self), false, api_name) } fn matches_allow(&self, other: &Self::AllowDesc) -> bool { if other.1.is_some() && self.1 != other.1 { return false; } match (&other.0, &self.0) { (Host::Fqdn(a), Host::Fqdn(b)) => a == b, (Host::FqdnWithSubdomainWildcard(a), Host::Fqdn(b)) => { b.is_subdomain_of(a) } ( Host::FqdnWithSubdomainWildcard(a), Host::FqdnWithSubdomainWildcard(b), ) => a == b, (Host::Ip(a), Host::Ip(b)) => a == b, (Host::Vsock(a), Host::Vsock(b)) => a == b, (Host::UnixSocket(a), Host::UnixSocket(b)) => a == b, (Host::IpSubnet(a), Host::Ip(b)) => a.contains(b), _ => false, } } fn matches_deny(&self, other: &Self::DenyDesc) -> bool { self.matches_allow(other) } fn revokes(&self, other: &Self::AllowDesc) -> bool { self.matches_allow(other) } fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool { self.matches_deny(other) } fn overlaps_deny(&self, _other: &Self::DenyDesc) -> bool { false } } impl AllowDescriptor for NetDescriptor { type QueryDesc<'a> = NetDescriptor; type DenyDesc = NetDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering { match (self.1.is_some(), other.1.is_some()) { (true, false) => Ordering::Less, (false, true) => Ordering::Greater, (true, true) | (false, false) => match self.0.cmp(&other.0) { Ordering::Equal => self.1.cmp(&other.1), ordering => ordering, }, } } fn cmp_deny(&self, other: &Self::DenyDesc) -> Ordering { match self.cmp_allow(other) { Ordering::Equal => Ordering::Greater, ordering => ordering, } } } impl DenyDescriptor for NetDescriptor { fn cmp_deny(&self, other: &Self) -> Ordering { self.cmp_allow(other) } } impl NetDescriptor { pub fn into_import(self) -> ImportDescriptor { ImportDescriptor(self) } } #[derive(Debug, thiserror::Error)] pub enum NetDescriptorParseError { #[error("invalid value '{0}': URLs are not supported, only domains and IPs")] Url(String), #[error("invalid IPv6 address in '{hostname}': '{ip}'")] InvalidIpv6 { hostname: String, ip: String }, #[error("invalid port in '{hostname}': '{port}'")] InvalidPort { hostname: String, port: String }, #[error("invalid host: '{0}'")] InvalidHost(String), #[error("invalid empty port in '{0}'")] EmptyPort(String), #[error("ipv6 addresses must be enclosed in square brackets: '{0}'")] Ipv6MissingSquareBrackets(String), #[error("{0}")] Host(#[from] HostParseError), #[error("invalid vsock: '{0}'")] InvalidVsock(String), #[error("invalid unix socket: '{0}' (path must be absolute and non-empty)")] InvalidUnixSocket(String), } #[derive(Debug, thiserror::Error, deno_error::JsError)] pub enum NetDescriptorFromUrlParseError { #[class(type)] #[error("Missing host in url: '{0}'")] MissingHost(Url), #[class(inherit)] #[error("{0}")] Host(#[from] HostParseError), } impl NetDescriptor { pub fn parse_for_query( hostname: &str, ) -> Result<Self, NetDescriptorParseError> { Self::parse_inner(hostname, SubdomainWildcards::Disabled) } pub fn parse_for_list( hostname: &str, ) -> Result<Self, NetDescriptorParseError> { Self::parse_inner(hostname, SubdomainWildcards::Enabled) } fn parse_inner( hostname: &str, subdomain_wildcards: SubdomainWildcards, ) -> Result<Self, NetDescriptorParseError> { #[cfg(unix)] if let Some(vsock) = hostname.strip_prefix("vsock:") { let mut split = vsock.split(':'); let Some(cid) = split.next().and_then(|c| { if c == "-1" { Some(u32::MAX) } else { c.parse().ok() } }) else { return Err(NetDescriptorParseError::InvalidVsock(hostname.into())); }; let Some(port) = split.next().and_then(|p| p.parse().ok()) else { return Err(NetDescriptorParseError::InvalidVsock(hostname.into())); }; return Ok(NetDescriptor(Host::Vsock(cid), Some(port))); } if let Some(rest) = hostname.strip_prefix("unix:") { let path = PathBuf::from(rest); if rest.is_empty() || !path.is_absolute() { return Err(NetDescriptorParseError::InvalidUnixSocket( hostname.to_string(), )); } // Lexically normalize `.`/`..` components (without resolving symlinks) // so the rule matches the path produced by the call side, which goes // through the same `normalize_path` in `PathQueryDescriptor`. Otherwise // `unix:/var/run/../run/foo.sock` would silently never match. let path = normalize_path(Cow::Owned(path)).into_owned(); return Ok(NetDescriptor(Host::UnixSocket(path), None)); } if hostname.starts_with("http://") || hostname.starts_with("https://") { return Err(NetDescriptorParseError::Url(hostname.to_string())); } if let Ok(socket) = hostname.parse::<SocketAddr>() { return Ok(NetDescriptor( Host::Ip(normalize_ip(socket.ip())), Some(socket.port().into()), )); } // If this is a IPv6 address enclosed in square brackets, parse it as such. if hostname.starts_with('[') { if let Some((ip, after)) = hostname.split_once(']') { let ip_str = &ip[1..]; let ip = strip_ipv6_zone_index(ip_str) .parse::<Ipv6Addr>() .map_err(|_| NetDescriptorParseError::InvalidIpv6 { hostname: hostname.to_string(), ip: ip_str.to_string(), })?; let port = if let Some(port) = after.strip_prefix(':') { let port = port.parse::<u16>().map_err(|_| { NetDescriptorParseError::InvalidPort { hostname: hostname.to_string(), port: port.to_string(), } })?; Some(port) } else if after.is_empty() { None } else { return Err(NetDescriptorParseError::InvalidHost( hostname.to_string(), )); }; return Ok(NetDescriptor( Host::Ip(normalize_ip(IpAddr::V6(ip))), port.map(Into::into), )); } else { return Err(NetDescriptorParseError::InvalidHost(hostname.to_string())); } } // Otherwise it is an IPv4 address or a FQDN with an optional port. let (host, port) = match hostname.split_once(':') { Some((_, "")) => { return Err(NetDescriptorParseError::EmptyPort(hostname.to_string())); } Some((host, port)) => (host, port), None => (hostname, ""), }; let host = Host::parse_inner(host, subdomain_wildcards)?; let port = if port.is_empty() { None } else { let port = port.parse::<u16>().map_err(|_| { // If the user forgot to enclose an IPv6 address in square brackets, we // should give them a hint. There are always at least two colons in an // IPv6 address, so this heuristic finds likely a bare IPv6 address. if port.contains(':') { NetDescriptorParseError::Ipv6MissingSquareBrackets( hostname.to_string(), ) } else { NetDescriptorParseError::InvalidPort { hostname: hostname.to_string(), port: port.to_string(), } } })?; Some(port) }; Ok(NetDescriptor(host, port.map(Into::into))) } pub fn from_url(url: &Url) -> Result<Self, NetDescriptorFromUrlParseError> { let host = url.host_str().ok_or_else(|| { NetDescriptorFromUrlParseError::MissingHost(url.clone()) })?; let host = Host::parse_for_query(host)?; let port = url.port_or_known_default(); Ok(NetDescriptor(host, port.map(Into::into))) } pub fn from_vsock( cid: u32, port: u32, ) -> Result<Self, NetDescriptorParseError> { Ok(NetDescriptor(Host::Vsock(cid), Some(port))) } } impl fmt::Display for NetDescriptor { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { match &self.0 { Host::Fqdn(fqdn) => write!(f, "{fqdn}"), Host::FqdnWithSubdomainWildcard(fqdn) => write!(f, "*.{fqdn}"), Host::IpSubnet(ip_subnet) => write!(f, "{ip_subnet}"), Host::Ip(IpAddr::V4(ip)) => write!(f, "{ip}"), Host::Ip(IpAddr::V6(ip)) => write!(f, "[{ip}]"), Host::Vsock(cid) => write!(f, "vsock:{cid}"), Host::UnixSocket(path) => write!(f, "unix:{}", path.display()), }?; if let Some(port) = self.1 { write!(f, ":{}", port)?; } Ok(()) } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct ImportDescriptor(NetDescriptor); impl QueryDescriptor for ImportDescriptor { type AllowDesc = ImportDescriptor; type DenyDesc = ImportDescriptor; fn flag_name() -> &'static str { "import" } fn display_name(&self) -> Cow<'_, str> { self.0.display_name() } fn from_allow(allow: &Self::AllowDesc) -> Self { Self(NetDescriptor::from_allow(&allow.0)) } fn as_allow(&self) -> Option<Self::AllowDesc> { self.0.as_allow().map(ImportDescriptor) } fn as_deny(&self) -> Self::DenyDesc { Self(self.0.as_deny()) } fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( perm, Self::flag_name(), () ); perm.check_desc(Some(self), false, api_name) } fn matches_allow(&self, other: &Self::AllowDesc) -> bool { self.0.matches_allow(&other.0) } fn matches_deny(&self, other: &Self::DenyDesc) -> bool { self.0.matches_deny(&other.0) } fn revokes(&self, other: &Self::AllowDesc) -> bool { self.0.revokes(&other.0) } fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool { self.0.stronger_than_deny(&other.0) } fn overlaps_deny(&self, other: &Self::DenyDesc) -> bool { self.0.overlaps_deny(&other.0) } } impl ImportDescriptor { pub fn parse_for_list( specifier: &str, ) -> Result<Self, NetDescriptorParseError> { Ok(ImportDescriptor(NetDescriptor::parse_for_list(specifier)?)) } pub fn from_url(url: &Url) -> Result<Self, NetDescriptorFromUrlParseError> { Ok(ImportDescriptor(NetDescriptor::from_url(url)?)) } } impl AllowDescriptor for ImportDescriptor { type QueryDesc<'a> = ImportDescriptor; type DenyDesc = ImportDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering { self.0.cmp_allow(&other.0) } fn cmp_deny(&self, other: &Self::DenyDesc) -> Ordering { AllowDescriptor::cmp_deny(&self.0, &other.0) } } impl DenyDescriptor for ImportDescriptor { fn cmp_deny(&self, other: &Self) -> Ordering { DenyDescriptor::cmp_deny(&self.0, &other.0) } } #[derive(Debug, thiserror::Error)] #[error("Empty env not allowed")] pub struct EnvDescriptorParseError; #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub enum EnvDescriptor { Name(EnvVarName), PrefixPattern(EnvVarName), } fn cmp_env_descriptor(a: &EnvDescriptor, b: &EnvDescriptor) -> Ordering { match a { EnvDescriptor::Name(self_name) => match b { EnvDescriptor::Name(other_name) => self_name.cmp(other_name), EnvDescriptor::PrefixPattern(_) => Ordering::Less, }, EnvDescriptor::PrefixPattern(self_pattern) => match b { EnvDescriptor::Name(_) => Ordering::Greater, // for patterns, prefer more specific items first EnvDescriptor::PrefixPattern(other_pattern) => { other_pattern.cmp(self_pattern) } }, } } impl EnvDescriptor { pub fn new(env: Cow<'_, str>) -> Self { if let Some(prefix_pattern) = env.as_ref().strip_suffix('*') { Self::PrefixPattern(EnvVarName::new(Cow::Borrowed(prefix_pattern))) } else { Self::Name(EnvVarName::new(env)) } } } impl AllowDescriptor for EnvDescriptor { type QueryDesc<'a> = EnvQueryDescriptor<'a>; type DenyDesc = EnvDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering { cmp_env_descriptor(self, other) } fn cmp_deny(&self, other: &Self::DenyDesc) -> Ordering { match cmp_env_descriptor(self, other) { Ordering::Equal => Ordering::Greater, ordering => ordering, } } } impl DenyDescriptor for EnvDescriptor { fn cmp_deny(&self, other: &Self) -> Ordering { cmp_env_descriptor(self, other) } } #[derive(Clone, Debug)] enum EnvQueryDescriptorInner<'a> { Name(EnvVarNameRef<'a>), PrefixPattern(EnvVarNameRef<'a>), } #[derive(Clone, Debug)] pub struct EnvQueryDescriptor<'a>(EnvQueryDescriptorInner<'a>); impl<'a> EnvQueryDescriptor<'a> { pub fn new(env: Cow<'a, str>) -> Self { Self(EnvQueryDescriptorInner::Name(EnvVarNameRef::new(env))) } } impl QueryDescriptor for EnvQueryDescriptor<'_> { type AllowDesc = EnvDescriptor; type DenyDesc = EnvDescriptor; fn flag_name() -> &'static str { "env" } fn display_name(&self) -> Cow<'_, str> { Cow::from(match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => env_var_name.as_ref(), EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { env_var_name.as_ref() } }) } fn from_allow(allow: &Self::AllowDesc) -> Self { match allow { Self::AllowDesc::Name(s) => { Self(EnvQueryDescriptorInner::Name(s.as_env_var_name_ref())) } Self::AllowDesc::PrefixPattern(s) => Self( EnvQueryDescriptorInner::PrefixPattern(s.as_env_var_name_ref()), ), } } fn as_allow(&self) -> Option<Self::AllowDesc> { Some(match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => { Self::AllowDesc::Name(env_var_name.clone().into_owned()) } EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { Self::AllowDesc::PrefixPattern(env_var_name.clone().into_owned()) } }) } fn as_deny(&self) -> Self::DenyDesc { match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => { Self::DenyDesc::Name(env_var_name.clone().into_owned()) } EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { Self::DenyDesc::PrefixPattern(env_var_name.clone().into_owned()) } } } fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( perm, Self::flag_name(), () ); perm.check_desc(Some(self), false, api_name) } fn matches_allow(&self, other: &Self::AllowDesc) -> bool { match other { Self::AllowDesc::Name(n) => match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => n == env_var_name, EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { env_var_name.as_ref().starts_with(n.as_ref()) } }, Self::AllowDesc::PrefixPattern(p) => match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => { env_var_name.as_ref().starts_with(p.as_ref()) } EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { env_var_name.as_ref().starts_with(p.as_ref()) } }, } } fn matches_deny(&self, other: &Self::DenyDesc) -> bool { match other { Self::AllowDesc::Name(n) => match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => n == env_var_name, EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { env_var_name.as_ref().starts_with(n.as_ref()) } }, Self::AllowDesc::PrefixPattern(p) => match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => { env_var_name.as_ref().starts_with(p.as_ref()) } EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { p == env_var_name } }, } } fn revokes(&self, other: &Self::AllowDesc) -> bool { match other { Self::AllowDesc::Name(n) => match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => n == env_var_name, EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { env_var_name.as_ref().starts_with(n.as_ref()) } }, Self::AllowDesc::PrefixPattern(p) => match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => { env_var_name.as_ref().starts_with(p.as_ref()) } EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { p == env_var_name } }, } } fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool { match other { Self::AllowDesc::Name(n) => match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => n == env_var_name, EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { env_var_name.as_ref().starts_with(n.as_ref()) } }, Self::AllowDesc::PrefixPattern(p) => match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => { env_var_name.as_ref().starts_with(p.as_ref()) } EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { p == env_var_name } }, } } fn overlaps_deny(&self, _other: &Self::DenyDesc) -> bool { false } } impl AsRef<str> for EnvQueryDescriptor<'_> { fn as_ref(&self) -> &str { match &self.0 { EnvQueryDescriptorInner::Name(env_var_name) => env_var_name.as_ref(), EnvQueryDescriptorInner::PrefixPattern(env_var_name) => { env_var_name.as_ref() } } } } #[derive(Clone, Debug)] pub enum RunQueryDescriptor<'a> { Path(PathQueryDescriptor<'a>), /// This variant won't actually grant permissions because the path of /// the executable is unresolved. It's mostly used so that prompts and /// everything works the same way as when the command is resolved, /// meaning that a script can't tell /// if a command is resolved or not based on how long something /// takes to ask for permissions. Name(String), } #[derive(Debug, thiserror::Error, deno_error::JsError)] pub enum PathResolveError { #[class(inherit)] #[error("failed resolving cwd: {0}")] CwdResolve(#[source] std::io::Error), #[class(inherit)] #[error(transparent)] Canonicalize(std::io::Error), #[class(inherit)] #[error(transparent)] NotFound(std::io::Error), #[class(generic)] #[error("Empty path is not allowed")] EmptyPath, } impl PathResolveError { pub fn kind(&self) -> std::io::ErrorKind { match self { Self::CwdResolve(e) | Self::Canonicalize(e) | Self::NotFound(e) => { e.kind() } Self::EmptyPath => std::io::ErrorKind::InvalidData, } } pub fn into_io_error(self) -> std::io::Error { match self { Self::CwdResolve(e) | Self::Canonicalize(e) | Self::NotFound(e) => e, PathResolveError::EmptyPath => { std::io::Error::new(self.kind(), format!("{}", self)) } } } } impl<'a> RunQueryDescriptor<'a> { pub fn parse( requested: &'a str, sys: &impl which::WhichSys, ) -> Result<Self, PathResolveError> { if AllowRunDescriptor::is_path(requested) { let path = Path::new(requested); let resolved = PathQueryDescriptor::new(sys, Cow::Borrowed(path))?; Ok(RunQueryDescriptor::Path(resolved)) } else { let cwd = sys .env_current_dir() .map_err(PathResolveError::CwdResolve)?; match which::which_in(sys.clone(), requested, sys.env_var_os("PATH"), cwd) { Ok(resolved) => { let cmp_path = comparison_path(&resolved); Ok(RunQueryDescriptor::Path(PathQueryDescriptor { path: Cow::Owned(resolved), cmp_path, requested: Some(requested.to_string()), is_windows_device_path: false, })) } Err(_) => Ok(RunQueryDescriptor::Name(requested.to_string())), } } } } impl QueryDescriptor for RunQueryDescriptor<'_> { type AllowDesc = AllowRunDescriptor; type DenyDesc = DenyRunDescriptor; fn flag_name() -> &'static str { "run" } fn display_name(&self) -> Cow<'_, str> { match self { RunQueryDescriptor::Path(path) => path.display_name(), RunQueryDescriptor::Name(name) => Cow::Borrowed(name), } } fn from_allow(allow: &Self::AllowDesc) -> Self { RunQueryDescriptor::Path(allow.0.as_query_descriptor()) } fn as_allow(&self) -> Option<Self::AllowDesc> { match self { RunQueryDescriptor::Path(path) => { Some(AllowRunDescriptor(path.as_descriptor())) } RunQueryDescriptor::Name(_) => None, } } fn as_deny(&self) -> Self::DenyDesc { match self { RunQueryDescriptor::Path(path) => match &path.requested { Some(requested) => { if requested.contains('/') || (cfg!(windows) && requested.contains("\\")) { DenyRunDescriptor::Path(path.as_descriptor()) } else { DenyRunDescriptor::Name(requested.clone()) } } None => DenyRunDescriptor::Path(path.as_descriptor()), }, RunQueryDescriptor::Name(name) => DenyRunDescriptor::Name(name.clone()), } } fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( perm, Self::flag_name(), () ); perm.check_desc(Some(self), false, api_name) } fn matches_allow(&self, other: &Self::AllowDesc) -> bool { match self { RunQueryDescriptor::Path(path) => *path == other.0, RunQueryDescriptor::Name(_) => false, } } fn matches_deny(&self, other: &Self::DenyDesc) -> bool { match other { DenyRunDescriptor::Name(deny_desc) => match self { RunQueryDescriptor::Path(path) => { denies_run_name(deny_desc, &path.path) } RunQueryDescriptor::Name(query) => query == deny_desc, }, DenyRunDescriptor::Path(deny_desc) => match self { RunQueryDescriptor::Path(path) => path.starts_with(deny_desc), RunQueryDescriptor::Name(query) => { denies_run_name(query, &deny_desc.path) } }, } } fn revokes(&self, other: &Self::AllowDesc) -> bool { match self { RunQueryDescriptor::Path(path) => { if *path == other.0 { return true; } match &path.requested { Some(requested) if AllowRunDescriptor::is_path(requested) => false, None => false, // is path Some(requested) => denies_run_name(requested, &other.0.path), } } RunQueryDescriptor::Name(query) => denies_run_name(query, &other.0.path), } } fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool { self.matches_deny(other) } fn overlaps_deny(&self, _other: &Self::DenyDesc) -> bool { false } } pub enum RunDescriptorArg { Name(String), Path(PathBuf), } pub enum AllowRunDescriptorParseResult { /// An error occurred getting the descriptor that should /// be surfaced as a warning when launching deno, but should /// be ignored when creating a worker. Unresolved(Box<which::Error>), Descriptor(AllowRunDescriptor), } #[derive(Debug, thiserror::Error, deno_error::JsError)] pub enum RunDescriptorParseError { #[class(generic)] #[error("{0}")] Which(#[from] which::Error), #[class(inherit)] #[error("{0}")] PathResolve(#[from] PathResolveError), #[class(generic)] #[error("Empty run query is not allowed")] EmptyRunQuery, } #[derive(Debug, Clone, Hash, Eq, PartialEq)] pub struct AllowRunDescriptor(pub PathDescriptor); impl AllowRunDescriptor { pub fn parse( text: &str, cwd: &Path, sys: &impl WhichSys, ) -> Result<AllowRunDescriptorParseResult, which::Error> { let is_path = Self::is_path(text); let path = if is_path { Cow::Borrowed(Path::new(text)) } else { match which::which_in( sys.clone(), text, sys.env_var_os("PATH"), cwd.to_path_buf(), ) { Ok(path) => Cow::Owned(path), Err(err) => match err { which::Error::CannotGetCurrentDirAndPathListEmpty => { return Err(err); } which::Error::CannotFindBinaryPath | which::Error::CannotCanonicalize => { return Ok(AllowRunDescriptorParseResult::Unresolved(Box::new( err, ))); } }, } }; let path = PathDescriptor::new_known_cwd(path, cwd); Ok(AllowRunDescriptorParseResult::Descriptor( AllowRunDescriptor(path), )) } pub fn is_path(text: &str) -> bool { if cfg!(windows) { text.contains('/') || text.contains('\\') || Path::new(text).is_absolute() } else { text.contains('/') } } } impl AllowDescriptor for AllowRunDescriptor { type QueryDesc<'a> = RunQueryDescriptor<'a>; type DenyDesc = DenyRunDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering { self.0.cmp_allow_allow(&other.0) } fn cmp_deny(&self, other: &Self::DenyDesc) -> Ordering { match other { DenyRunDescriptor::Name(_) => Ordering::Less, DenyRunDescriptor::Path(_) => Ordering::Greater, } } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub enum DenyRunDescriptor { /// 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(PathDescriptor), } impl DenyDescriptor for DenyRunDescriptor { fn cmp_deny(&self, other: &Self) -> Ordering { match self { DenyRunDescriptor::Name(self_name) => match other { DenyRunDescriptor::Name(other_name) => self_name.cmp(other_name), DenyRunDescriptor::Path(_) => Ordering::Greater, }, DenyRunDescriptor::Path(self_path) => match other { DenyRunDescriptor::Name(_) => Ordering::Less, DenyRunDescriptor::Path(other_path) => { self_path.cmp_deny_deny(other_path) } }, } } } impl DenyRunDescriptor { pub fn parse(text: &str, cwd: &Path) -> Self { if text.contains('/') || cfg!(windows) && text.contains('\\') { let path = PathDescriptor::new_known_cwd(Cow::Borrowed(Path::new(&text)), cwd); DenyRunDescriptor::Path(path) } else { DenyRunDescriptor::Name(text.to_string()) } } } fn denies_run_name(name: &str, cmd_path: &Path) -> bool { let Some(file_stem) = cmd_path.file_stem() else { return false; }; let Some(file_stem) = file_stem.to_str() else { return false; }; if file_stem.len() < name.len() { return false; } let (prefix, suffix) = file_stem.split_at(name.len()); if !prefix.eq_ignore_ascii_case(name) { return false; } // be broad and consider anything like `deno.something` as matching deny perms suffix.is_empty() || suffix.starts_with('.') } pub struct SpecialFilePathQueryDescriptor<'a> { path: Cow<'a, Path>, requested: Option<String>, canonicalized: bool, } impl<'a> SpecialFilePathQueryDescriptor<'a> { /// Construct from a `PathQueryDescriptor` without resolving symlinks. /// /// Used by no-follow access modes (lstat, readlink, readdir, etc.) where /// canonicalizing would change semantics by resolving the final path /// component. The /proc, /dev, /sys prefix guard in `check_special_file` /// still applies — it just uses the un-resolved path. pub fn from_path_query_no_canonicalize( path: PathQueryDescriptor<'a>, ) -> Self { let PathQueryDescriptor { path, requested, .. } = path; Self { path, requested, canonicalized: false, } } pub fn parse( sys: &impl sys_traits::FsCanonicalize, path: PathQueryDescriptor<'a>, ) -> Result<Self, PathResolveError> { let PathQueryDescriptor { is_windows_device_path, path, cmp_path: _, requested, } = path; // On Linux, /proc may contain magic links that we don't want to resolve let is_linux_special_path = cfg!(target_os = "linux") && (path.starts_with("/proc") || path.starts_with("/dev")); let needs_canonicalization = !is_windows_device_path && !is_linux_special_path; if needs_canonicalization { let original_path = path; let new_path = deno_path_util::fs::canonicalize_path_maybe_not_exists( sys, &original_path, ) .map_err(PathResolveError::Canonicalize)?; Ok(Self { requested: requested .or_else(|| Some(original_path.to_string_lossy().into_owned())), path: Cow::Owned(new_path), canonicalized: true, }) } else { Ok(Self { path, requested, canonicalized: false, }) } } } #[derive(Debug, thiserror::Error, deno_error::JsError)] pub enum SysDescriptorParseError { #[class(type)] #[error("unknown system info kind \"{0}\"")] InvalidKind(String), #[class(generic)] #[error("Empty sys not allowed")] Empty, // Error } #[derive(Clone, Eq, PartialEq, Hash, Debug, PartialOrd, Ord)] pub struct SysDescriptor(String); impl SysDescriptor { pub fn parse(kind: String) -> Result<Self, SysDescriptorParseError> { match kind.as_str() { "hostname" | "inspector" | "osRelease" | "osUptime" | "loadavg" | "networkInterfaces" | "systemMemoryInfo" | "uid" | "gid" | "cpus" | "homedir" | "getegid" | "statfs" | "getPriority" | "setPriority" | "userInfo" | "setegid" | "seteuid" | "setgid" | "setuid" | "ca" | "umask" => Ok(Self(kind)), // the underlying permission check changed to `userInfo` to better match the API, // alias this to avoid breaking existing projects with `--allow-sys=username` "username" => Ok(Self("userInfo".into())), _ => Err(SysDescriptorParseError::InvalidKind(kind)), } } pub fn into_string(self) -> String { self.0 } } impl QueryDescriptor for SysDescriptor { type AllowDesc = SysDescriptor; type DenyDesc = SysDescriptor; fn flag_name() -> &'static str { "sys" } fn display_name(&self) -> Cow<'_, str> { Cow::from(self.0.to_string()) } fn from_allow(allow: &Self::AllowDesc) -> Self { allow.clone() } fn as_allow(&self) -> Option<Self::AllowDesc> { Some(self.clone()) } fn as_deny(&self) -> Self::DenyDesc { self.clone() } fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( perm, Self::flag_name(), () ); perm.check_desc(Some(self), false, api_name) } fn matches_allow(&self, other: &Self::AllowDesc) -> bool { self == other } fn matches_deny(&self, other: &Self::DenyDesc) -> bool { self == other } fn revokes(&self, other: &Self::AllowDesc) -> bool { self == other } fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool { self == other } fn overlaps_deny(&self, _other: &Self::DenyDesc) -> bool { false } } impl AllowDescriptor for SysDescriptor { type QueryDesc<'a> = SysDescriptor; type DenyDesc = SysDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering { self.cmp(other) } fn cmp_deny(&self, _other: &Self::DenyDesc) -> Ordering { Ordering::Greater } } impl DenyDescriptor for SysDescriptor { fn cmp_deny(&self, other: &Self) -> Ordering { self.cmp(other) } } #[derive(Clone, Eq, PartialEq, Debug)] pub struct FfiQueryDescriptor<'a>(pub PathQueryDescriptor<'a>); impl QueryDescriptor for FfiQueryDescriptor<'_> { type AllowDesc = FfiDescriptor; type DenyDesc = FfiDescriptor; fn flag_name() -> &'static str { "ffi" } fn display_name(&self) -> Cow<'_, str> { self.0.display_name() } fn from_allow(allow: &Self::AllowDesc) -> Self { allow.0.as_query_descriptor().into_ffi() } fn as_allow(&self) -> Option<Self::AllowDesc> { Some(FfiDescriptor(self.0.as_descriptor())) } fn as_deny(&self) -> Self::DenyDesc { FfiDescriptor(self.0.as_descriptor()) } fn check_in_permission( &self, perm: &mut UnaryPermission<Self::AllowDesc>, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( perm, Self::flag_name(), () ); perm.check_desc(Some(self), true, api_name) } fn matches_allow(&self, other: &Self::AllowDesc) -> bool { self.0.starts_with(&other.0) } fn matches_deny(&self, other: &Self::DenyDesc) -> bool { self.0.starts_with(&other.0) } fn revokes(&self, other: &Self::AllowDesc) -> bool { self.matches_allow(other) } fn stronger_than_deny(&self, other: &Self::DenyDesc) -> bool { other.0.starts_with(&self.0) } fn overlaps_deny(&self, other: &Self::DenyDesc) -> bool { self.stronger_than_deny(other) } } #[derive(Clone, Eq, PartialEq, Hash, Debug)] pub struct FfiDescriptor(pub PathDescriptor); impl AllowDescriptor for FfiDescriptor { type QueryDesc<'a> = FfiQueryDescriptor<'a>; type DenyDesc = FfiDescriptor; fn cmp_allow(&self, other: &Self) -> Ordering { self.0.cmp_allow_allow(&other.0) } fn cmp_deny(&self, other: &Self::DenyDesc) -> Ordering { self.0.cmp_allow_deny(&other.0) } } impl DenyDescriptor for FfiDescriptor { fn cmp_deny(&self, other: &Self) -> Ordering { self.0.cmp_deny_deny(&other.0) } } impl UnaryPermission<ReadDescriptor> { pub fn query(&self, desc: Option<&ReadQueryDescriptor>) -> PermissionState { self.query_desc(desc, AllowPartial::TreatAsPartialGranted) } pub fn request( &mut self, path: Option<&ReadQueryDescriptor>, ) -> PermissionState { self.request_desc(path) } pub fn revoke( &mut self, desc: Option<&ReadQueryDescriptor>, ) -> PermissionState { self.revoke_desc(desc) } pub fn check( &mut self, desc: &ReadQueryDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, ReadQueryDescriptor::flag_name(), desc.display_name() ); self.check_desc(Some(desc), true, api_name) } #[inline] pub fn check_partial( &mut self, desc: &ReadQueryDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, ReadQueryDescriptor::flag_name(), desc.display_name() ); self.check_desc(Some(desc), false, api_name) } pub fn check_all( &mut self, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, ReadQueryDescriptor::flag_name(), () ); self.check_desc(None, false, api_name) } } impl UnaryPermission<WriteDescriptor> { pub fn query(&self, path: Option<&WriteQueryDescriptor>) -> PermissionState { self.query_desc(path, AllowPartial::TreatAsPartialGranted) } pub fn request( &mut self, path: Option<&WriteQueryDescriptor>, ) -> PermissionState { self.request_desc(path) } pub fn revoke( &mut self, path: Option<&WriteQueryDescriptor>, ) -> PermissionState { self.revoke_desc(path) } pub fn check( &mut self, path: &WriteQueryDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, WriteQueryDescriptor::flag_name(), path.display_name() ); self.check_desc(Some(path), true, api_name) } #[inline] pub fn check_partial( &mut self, path: &WriteQueryDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, WriteQueryDescriptor::flag_name(), path.display_name() ); self.check_desc(Some(path), false, api_name) } pub fn check_all( &mut self, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, WriteQueryDescriptor::flag_name(), () ); self.check_desc(None, false, api_name) } } impl UnaryPermission<NetDescriptor> { pub fn query(&self, host: Option<&NetDescriptor>) -> PermissionState { self.query_desc(host, AllowPartial::TreatAsPartialGranted) } pub fn request(&mut self, host: Option<&NetDescriptor>) -> PermissionState { self.request_desc(host) } pub fn revoke(&mut self, host: Option<&NetDescriptor>) -> PermissionState { self.revoke_desc(host) } pub fn check( &mut self, host: &NetDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, NetDescriptor::flag_name(), host.display_name() ); self.check_desc(Some(host), false, api_name) } pub fn check_all(&mut self) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, NetDescriptor::flag_name(), () ); self.check_desc(None, false, None) } /// Check if a resolved IP address is explicitly denied. /// /// This is used after DNS resolution to ensure that deny rules written as /// IP literals (e.g. `--deny-net=127.0.0.1`) also block connections made /// via hostname aliases that resolve to the denied IP (e.g. numeric forms /// like `2130706433` which the OS resolver maps to `127.0.0.1`). /// /// Only checks deny rules — the allow check has already been performed /// against the original hostname. pub fn check_resolved_ip_deny( &mut self, desc: &NetDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { let info = format_display_name(desc.display_name()).into_owned(); let denied = || { PermissionState::permission_denied_error( NetDescriptor::flag_name(), Some(info.as_str()), PermissionState::Denied, ) }; if self.flag_denied_global { return Err(denied()); } for item in self.descriptors.iter() { match item { UnaryPermissionDesc::FlagDenied(v) | UnaryPermissionDesc::FlagIgnored(v) if desc.matches_deny(v) => { return Err(denied()); } _ => {} } } let _ = api_name; Ok(()) } } impl UnaryPermission<ImportDescriptor> { pub fn query(&self, host: Option<&ImportDescriptor>) -> PermissionState { self.query_desc(host, AllowPartial::TreatAsPartialGranted) } pub fn request( &mut self, host: Option<&ImportDescriptor>, ) -> PermissionState { self.request_desc(host) } pub fn revoke(&mut self, host: Option<&ImportDescriptor>) -> PermissionState { self.revoke_desc(host) } pub fn check( &mut self, host: &ImportDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, ImportDescriptor::flag_name(), host.display_name() ); self.check_desc(Some(host), false, api_name) } pub fn check_all(&mut self) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, ImportDescriptor::flag_name(), () ); self.check_desc(None, false, None) } } impl UnaryPermission<EnvDescriptor> { pub fn query(&self, env: Option<&str>) -> PermissionState { self.query_desc( env .map(|env| EnvQueryDescriptor::new(Cow::Borrowed(env))) .as_ref(), AllowPartial::TreatAsPartialGranted, ) } pub fn request(&mut self, env: Option<&str>) -> PermissionState { self.request_desc( env .map(|env| EnvQueryDescriptor::new(Cow::Borrowed(env))) .as_ref(), ) } pub fn revoke(&mut self, env: Option<&str>) -> PermissionState { self.revoke_desc( env .map(|env| EnvQueryDescriptor::new(Cow::Borrowed(env))) .as_ref(), ) } pub fn check( &mut self, env: &str, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, EnvQueryDescriptor::flag_name(), env ); self.check_desc( Some(&EnvQueryDescriptor::new(Cow::Borrowed(env))), false, api_name, ) } pub fn check_all(&mut self) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, EnvQueryDescriptor::flag_name(), () ); self.check_desc(None, true, None) } } impl UnaryPermission<SysDescriptor> { pub fn query(&self, kind: Option<&SysDescriptor>) -> PermissionState { self.query_desc(kind, AllowPartial::TreatAsPartialGranted) } pub fn request(&mut self, kind: Option<&SysDescriptor>) -> PermissionState { self.request_desc(kind) } pub fn revoke(&mut self, kind: Option<&SysDescriptor>) -> PermissionState { self.revoke_desc(kind) } pub fn check( &mut self, kind: &SysDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, SysDescriptor::flag_name(), kind.display_name() ); self.check_desc(Some(kind), false, api_name) } pub fn check_all(&mut self) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, SysDescriptor::flag_name(), () ); self.check_desc(None, false, None) } } impl UnaryPermission<AllowRunDescriptor> { pub fn query(&self, cmd: Option<&RunQueryDescriptor>) -> PermissionState { self.query_desc(cmd, AllowPartial::TreatAsPartialGranted) } pub fn request( &mut self, cmd: Option<&RunQueryDescriptor>, ) -> PermissionState { self.request_desc(cmd) } pub fn revoke( &mut self, cmd: Option<&RunQueryDescriptor>, ) -> PermissionState { self.revoke_desc(cmd) } pub fn check( &mut self, cmd: &RunQueryDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { self.check_desc(Some(cmd), false, api_name) } pub fn check_all( &mut self, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { self.check_desc(None, false, api_name) } /// Queries without prompting pub fn query_all(&mut self, api_name: Option<&str>) -> bool { if self.is_allow_all() { return true; } let (result, _prompted, _is_allow_all) = self.query_desc(None, AllowPartial::TreatAsDenied).check( RunQueryDescriptor::flag_name(), api_name, || None, || None, /* prompt */ false, ); result.is_ok() } } impl UnaryPermission<FfiDescriptor> { pub fn query(&self, path: Option<&FfiQueryDescriptor>) -> PermissionState { self.query_desc(path, AllowPartial::TreatAsPartialGranted) } pub fn request( &mut self, path: Option<&FfiQueryDescriptor>, ) -> PermissionState { self.request_desc(path) } pub fn revoke( &mut self, path: Option<&FfiQueryDescriptor>, ) -> PermissionState { self.revoke_desc(path) } pub fn check( &mut self, path: &FfiQueryDescriptor, api_name: Option<&str>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, FfiQueryDescriptor::flag_name(), path.display_name() ); self.check_desc(Some(path), true, api_name) } pub fn check_partial( &mut self, path: Option<&FfiQueryDescriptor>, ) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, FfiQueryDescriptor::flag_name(), path.as_ref().map(|path| path.display_name()) ); self.check_desc(path, false, None) } pub fn check_all(&mut self) -> Result<(), PermissionDeniedError> { audit_and_skip_check_if_is_permission_fully_granted!( self, FfiQueryDescriptor::flag_name(), () ); self.check_desc(None, false, Some("all")) } } #[derive(Clone, Debug, Eq, PartialEq)] pub struct Permissions { // WARNING: update the methods below if ever adding anything here pub read: UnaryPermission<ReadDescriptor>, pub write: UnaryPermission<WriteDescriptor>, pub net: UnaryPermission<NetDescriptor>, pub env: UnaryPermission<EnvDescriptor>, pub sys: UnaryPermission<SysDescriptor>, pub run: UnaryPermission<AllowRunDescriptor>, pub ffi: UnaryPermission<FfiDescriptor>, pub import: UnaryPermission<ImportDescriptor>, } impl Permissions { pub fn all_granted(&self) -> bool { self.read.is_allow_all() && self.write.is_allow_all() && self.net.is_allow_all() && self.env.is_allow_all() && self.sys.is_allow_all() && self.run.is_allow_all() && self.ffi.is_allow_all() && self.import.is_allow_all() } fn disable_prompting(&mut self) { self.read.prompt = false; self.write.prompt = false; self.net.prompt = false; self.env.prompt = false; self.sys.prompt = false; self.run.prompt = false; self.ffi.prompt = false; self.import.prompt = false; } } #[derive(Clone, Debug, Eq, PartialEq, Default, Serialize, Deserialize)] pub struct PermissionsOptions { pub allow_env: Option<Vec<String>>, pub deny_env: Option<Vec<String>>, pub ignore_env: Option<Vec<String>>, pub allow_net: Option<Vec<String>>, pub deny_net: Option<Vec<String>>, pub allow_ffi: Option<Vec<String>>, pub deny_ffi: Option<Vec<String>>, pub allow_read: Option<Vec<String>>, pub deny_read: Option<Vec<String>>, pub ignore_read: Option<Vec<String>>, pub allow_run: Option<Vec<String>>, pub deny_run: Option<Vec<String>>, pub allow_sys: Option<Vec<String>>, pub deny_sys: Option<Vec<String>>, pub allow_write: Option<Vec<String>>, pub deny_write: Option<Vec<String>>, pub allow_import: Option<Vec<String>>, pub deny_import: Option<Vec<String>>, pub prompt: bool, } #[derive(Debug, thiserror::Error)] pub enum PermissionsFromOptionsError { #[error("{0}")] PathResolve(#[from] PathResolveError), #[error("{0}")] SysDescriptorParse(#[from] SysDescriptorParseError), #[error("{0}")] NetDescriptorParse(#[from] NetDescriptorParseError), #[error("{0}")] EnvDescriptorParse(#[from] EnvDescriptorParseError), #[error("{0}")] RunDescriptorParse(#[from] RunDescriptorParseError), #[error("Empty command name not allowed in --allow-run=...")] RunEmptyCommandName, } impl Permissions { pub fn new_unary_with_ignore<TAllow: AllowDescriptor>( allow_list: Option<Vec<TAllow>>, deny_list: Option<Vec<TAllow::DenyDesc>>, ignore_list: Option<Vec<TAllow::DenyDesc>>, prompt: bool, ) -> UnaryPermission<TAllow> { let mut descriptors = UnaryPermissionDescriptors::with_capacity( allow_list.as_ref().map(|v| v.len()).unwrap_or(0) + ignore_list.as_ref().map(|v| v.len()).unwrap_or(0) + deny_list.as_ref().map(|v| v.len()).unwrap_or(0), ); let granted_global = global_from_option(allow_list.as_ref()); let flag_denied_global = global_from_option(deny_list.as_ref()); let flag_ignored_global = global_from_option(ignore_list.as_ref()); for item in allow_list.unwrap_or_default() { descriptors.insert(UnaryPermissionDesc::Granted(item)); } for item in deny_list.unwrap_or_default() { descriptors.insert(UnaryPermissionDesc::FlagDenied(item)); } for item in ignore_list.unwrap_or_default() { descriptors.insert(UnaryPermissionDesc::FlagIgnored(item)); } UnaryPermission::<TAllow> { granted_global, flag_denied_global, flag_ignored_global, descriptors, prompt, ..Default::default() } } pub fn new_unary<TAllow: AllowDescriptor>( allow_list: Option<Vec<TAllow>>, deny_list: Option<Vec<TAllow::DenyDesc>>, prompt: bool, ) -> UnaryPermission<TAllow> { Self::new_unary_with_ignore(allow_list, deny_list, None, prompt) } pub const fn new_all(allow_state: bool) -> UnitPermission { unit_permission_from_flag_bools( allow_state, false, "all", "all", false, // never prompt for all ) } pub fn from_options( parser: &dyn PermissionDescriptorParser, opts: &PermissionsOptions, ) -> Result<Self, PermissionsFromOptionsError> { fn resolve_allow_run( parser: &dyn PermissionDescriptorParser, allow_run: &[String], ) -> Result<Vec<AllowRunDescriptor>, PermissionsFromOptionsError> { let mut new_allow_run = Vec::with_capacity(allow_run.len()); for unresolved in allow_run { if unresolved.is_empty() { return Err(PermissionsFromOptionsError::RunEmptyCommandName); } match parser.parse_allow_run_descriptor(unresolved)? { AllowRunDescriptorParseResult::Descriptor(descriptor) => { new_allow_run.push(descriptor); } AllowRunDescriptorParseResult::Unresolved(err) => { log::info!( "{} Failed to resolve '{}' for allow-run: {}", colors::gray("Info"), unresolved, err ); } } } Ok(new_allow_run) } fn parse_maybe_vec<T: Eq + PartialEq + Hash, E>( items: Option<&[String]>, parse: impl Fn(&str) -> Result<T, E>, ) -> Result<Option<Vec<T>>, PermissionsFromOptionsError> where PermissionsFromOptionsError: From<E>, { match items { Some(items) => Ok(Some( items .iter() .map(|item| parse(item)) .collect::<Result<Vec<_>, _>>()?, )), None => Ok(None), } } let mut deny_write = parse_maybe_vec(opts.deny_write.as_deref(), |item| { parser.parse_write_descriptor(item) })?; let allow_run = opts .allow_run .as_ref() .and_then(|raw_allow_run| { match resolve_allow_run(parser, raw_allow_run) { Ok(resolved_allow_run) => { if resolved_allow_run.is_empty() && !raw_allow_run.is_empty() { None // convert to no permissions if now empty } else { Some(Ok(resolved_allow_run)) } } Err(err) => Some(Err(err)), } }) .transpose()?; // add the allow_run list to deny_write if let Some(allow_run_vec) = &allow_run && !allow_run_vec.is_empty() { let deny_write = deny_write.get_or_insert_with(Default::default); deny_write.extend( allow_run_vec .iter() .map(|item| WriteDescriptor(item.0.clone())), ); } Ok(Self { read: Permissions::new_unary_with_ignore( parse_maybe_vec(opts.allow_read.as_deref(), |item| { parser.parse_read_descriptor(item) })?, parse_maybe_vec(opts.deny_read.as_deref(), |item| { parser.parse_read_descriptor(item) })?, parse_maybe_vec(opts.ignore_read.as_deref(), |text| { parser.parse_read_descriptor(text) })?, opts.prompt, ), write: Permissions::new_unary( parse_maybe_vec(opts.allow_write.as_deref(), |item| { parser.parse_write_descriptor(item) })?, deny_write, opts.prompt, ), net: Permissions::new_unary( parse_maybe_vec(opts.allow_net.as_deref(), |item| { parser.parse_net_descriptor(item) })?, parse_maybe_vec(opts.deny_net.as_deref(), |item| { parser.parse_net_descriptor(item) })?, opts.prompt, ), env: Permissions::new_unary_with_ignore( parse_maybe_vec(opts.allow_env.as_deref(), |item| { parser.parse_env_descriptor(item) })?, parse_maybe_vec(opts.deny_env.as_deref(), |text| { parser.parse_env_descriptor(text) })?, parse_maybe_vec(opts.ignore_env.as_deref(), |text| { parser.parse_env_descriptor(text) })?, opts.prompt, ), sys: Permissions::new_unary( parse_maybe_vec(opts.allow_sys.as_deref(), |text| { parser.parse_sys_descriptor(text) })?, parse_maybe_vec(opts.deny_sys.as_deref(), |text| { parser.parse_sys_descriptor(text) })?, opts.prompt, ), run: Permissions::new_unary( allow_run, parse_maybe_vec(opts.deny_run.as_deref(), |text| { parser.parse_deny_run_descriptor(text) })?, opts.prompt, ), ffi: Permissions::new_unary( parse_maybe_vec(opts.allow_ffi.as_deref(), |text| { parser.parse_ffi_descriptor(text) })?, parse_maybe_vec(opts.deny_ffi.as_deref(), |text| { parser.parse_ffi_descriptor(text) })?, opts.prompt, ), import: Permissions::new_unary( parse_maybe_vec(opts.allow_import.as_deref(), |item| { parser.parse_import_descriptor(item) })?, parse_maybe_vec(opts.deny_import.as_deref(), |item| { parser.parse_import_descriptor(item) })?, opts.prompt, ), }) } /// Create a set of permissions that explicitly allow everything. pub fn allow_all() -> Self { Self { read: UnaryPermission::allow_all(), write: UnaryPermission::allow_all(), net: UnaryPermission::allow_all(), env: UnaryPermission::allow_all(), sys: UnaryPermission::allow_all(), run: UnaryPermission::allow_all(), ffi: UnaryPermission::allow_all(), import: UnaryPermission::allow_all(), } } /// Create a set of permissions that enable nothing, but will allow prompting. pub fn none_with_prompt() -> Self { Self::none(true) } /// Create a set of permissions that enable nothing, and will not allow prompting. pub fn none_without_prompt() -> Self { Self::none(false) } fn none(prompt: bool) -> Self { Self { read: Permissions::new_unary(None, None, prompt), write: Permissions::new_unary(None, None, prompt), net: Permissions::new_unary(None, None, prompt), env: Permissions::new_unary(None, None, prompt), sys: Permissions::new_unary(None, None, prompt), run: Permissions::new_unary(None, None, prompt), ffi: Permissions::new_unary(None, None, prompt), import: Permissions::new_unary(None, None, prompt), } } } #[derive(Debug, Clone, Copy, Eq, PartialEq)] pub enum CheckSpecifierKind { Static, Dynamic, } #[derive(Debug, thiserror::Error, deno_error::JsError)] pub enum ChildPermissionError { #[class("NotCapable")] #[error("Can't escalate parent thread permissions")] Escalation, #[class(inherit)] #[error("{0}")] PathResolve(#[from] PathResolveError), #[class(uri)] #[error("{0}")] NetDescriptorParse(#[from] NetDescriptorParseError), #[class(generic)] #[error("{0}")] EnvDescriptorParse(#[from] EnvDescriptorParseError), #[class(inherit)] #[error("{0}")] SysDescriptorParse(#[from] SysDescriptorParseError), #[class(inherit)] #[error("{0}")] RunDescriptorParse(#[from] RunDescriptorParseError), } #[derive(Debug, thiserror::Error, deno_error::JsError)] pub enum PermissionCheckError { #[class(inherit)] #[error(transparent)] PermissionDenied(#[from] PermissionDeniedError), #[class(uri)] #[error("Invalid file path.\n Specifier: {0}")] InvalidFilePath(Url), #[class(inherit)] #[error(transparent)] NetDescriptorForUrlParse(#[from] NetDescriptorFromUrlParseError), #[class(inherit)] #[error(transparent)] SysDescriptorParse(#[from] SysDescriptorParseError), #[class(inherit)] #[error(transparent)] PathResolve(#[from] PathResolveError), #[class(uri)] #[error(transparent)] HostParse(#[from] HostParseError), #[class(inherit)] #[error(transparent)] Io(std::io::Error), } fn ignored_to_not_found(err: PermissionDeniedError) -> PermissionCheckError { #[cfg(target_arch = "wasm32")] fn not_found() -> std::io::Error { std::io::Error::new( std::io::ErrorKind::NotFound, "No such file or directory (os error 2)", ) } #[cfg(all(not(windows), not(target_arch = "wasm32")))] fn not_found() -> std::io::Error { std::io::Error::from_raw_os_error(libc::ENOENT) } #[cfg(windows)] fn not_found() -> std::io::Error { std::io::Error::from_raw_os_error( windows_sys::Win32::Foundation::ERROR_FILE_NOT_FOUND as i32, ) } if err.state == PermissionState::Ignored { PermissionCheckError::Io(not_found()) } else { PermissionCheckError::PermissionDenied(err) } } impl PermissionCheckError { pub fn kind(&self) -> std::io::ErrorKind { match self { PermissionCheckError::PermissionDenied(_) => std::io::ErrorKind::Other, PermissionCheckError::InvalidFilePath(_) => std::io::ErrorKind::Other, PermissionCheckError::NetDescriptorForUrlParse(_) | PermissionCheckError::HostParse(_) | PermissionCheckError::SysDescriptorParse(_) => { std::io::ErrorKind::Other } PermissionCheckError::PathResolve(e) => e.kind(), PermissionCheckError::Io(e) => e.kind(), } } pub fn into_io_error(self) -> std::io::Error { match self { Self::PermissionDenied(_) | Self::InvalidFilePath(_) | Self::NetDescriptorForUrlParse(_) | Self::SysDescriptorParse(_) | Self::HostParse(_) => { std::io::Error::new(self.kind(), format!("{}", self)) } Self::PathResolve(e) => e.into_io_error(), Self::Io(e) => e, } } } /// 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 { descriptor_parser: Arc<dyn PermissionDescriptorParser>, inner: Arc<Mutex<Permissions>>, } impl PermissionsContainer { pub fn new( descriptor_parser: Arc<dyn PermissionDescriptorParser>, perms: Permissions, ) -> Self { Self { descriptor_parser, inner: Arc::new(Mutex::new(perms)), } } pub fn deep_clone(&self) -> PermissionsContainer { Self { descriptor_parser: self.descriptor_parser.clone(), inner: Arc::new(Mutex::new(self.inner.lock().clone())), } } /// Creates an independent snapshot with user prompting disabled. /// /// Existing grants and denials are preserved, but the snapshot does not /// observe later permission changes. Permission brokers are still consulted /// when the snapshot is checked. pub fn deep_clone_without_prompt(&self) -> PermissionsContainer { let mut permissions = self.inner.lock().clone(); permissions.disable_prompting(); Self { descriptor_parser: self.descriptor_parser.clone(), inner: Arc::new(Mutex::new(permissions)), } } pub fn allow_all( descriptor_parser: Arc<dyn PermissionDescriptorParser>, ) -> Self { Self::new(descriptor_parser, Permissions::allow_all()) } pub fn create_child_permissions( &self, child_permissions_arg: ChildPermissionsArg, ) -> Result<PermissionsContainer, ChildPermissionError> { let mut worker_perms = Permissions::none_without_prompt(); let mut inner = self.inner.lock(); // WARNING: When adding a permission here, ensure it is handled // in the worker_perms.all block above worker_perms.read = inner.read.create_child_permissions( child_permissions_arg.read, |text| { Ok::<_, PathResolveError>(Some( self.descriptor_parser.parse_read_descriptor(text)?, )) }, )?; worker_perms.write = inner.write.create_child_permissions( child_permissions_arg.write, |text| { Ok::<_, PathResolveError>(Some( self.descriptor_parser.parse_write_descriptor(text)?, )) }, )?; worker_perms.import = inner.import.create_child_permissions( child_permissions_arg.import, |text| { Ok::<_, NetDescriptorParseError>(Some( self.descriptor_parser.parse_import_descriptor(text)?, )) }, )?; worker_perms.net = inner.net.create_child_permissions( child_permissions_arg.net, |text| { Ok::<_, NetDescriptorParseError>(Some( self.descriptor_parser.parse_net_descriptor(text)?, )) }, )?; worker_perms.env = inner.env.create_child_permissions( child_permissions_arg.env, |text| { Ok::<_, EnvDescriptorParseError>(Some( self.descriptor_parser.parse_env_descriptor(text)?, )) }, )?; worker_perms.sys = inner.sys.create_child_permissions( child_permissions_arg.sys, |text| { Ok::<_, SysDescriptorParseError>(Some( self.descriptor_parser.parse_sys_descriptor(text)?, )) }, )?; worker_perms.run = inner.run.create_child_permissions( child_permissions_arg.run, |text| match self.descriptor_parser.parse_allow_run_descriptor(text)? { AllowRunDescriptorParseResult::Unresolved(_) => { Ok::<_, RunDescriptorParseError>(None) } AllowRunDescriptorParseResult::Descriptor(desc) => Ok(Some(desc)), }, )?; worker_perms.ffi = inner.ffi.create_child_permissions( child_permissions_arg.ffi, |text| { Ok::<_, PathResolveError>(Some( self.descriptor_parser.parse_ffi_descriptor(text)?, )) }, )?; Ok(PermissionsContainer::new( self.descriptor_parser.clone(), worker_perms, )) } #[inline(always)] pub fn check_specifier( &self, specifier: &Url, kind: CheckSpecifierKind, ) -> Result<(), PermissionCheckError> { let mut inner = self.inner.lock(); match specifier.scheme() { "file" => { if inner.read.is_allow_all() { if kind != CheckSpecifierKind::Static { write_audit(ReadQueryDescriptor::flag_name(), specifier); } return Ok(()); } if kind == CheckSpecifierKind::Static { return Ok(()); } match url_to_file_path(specifier) { Ok(path) => inner .read .check( // a file: specifier will always go to absolute &PathQueryDescriptor::new_known_absolute(Cow::Owned(path)) .into_read(), Some("import()"), ) .map_err(ignored_to_not_found), Err(_) => { Err(PermissionCheckError::InvalidFilePath(specifier.clone())) } } } "data" => Ok(()), "blob" => Ok(()), _ => { if inner.import.is_allow_all() { write_audit(ImportDescriptor::flag_name(), specifier); return Ok(()); // avoid allocation below } let desc = self .descriptor_parser .parse_import_descriptor_from_url(specifier)?; inner.import.check(&desc, Some("import()"))?; Ok(()) } } } #[must_use = "the resolved return value to mitigate time-of-check to time-of-use issues"] #[inline(always)] pub fn check_open<'a>( &self, path: Cow<'a, Path>, access_kind: OpenAccessKind, api_name: Option<&str>, ) -> Result<CheckedPath<'a>, PermissionCheckError> { self.check_open_with_requested(path, access_kind, None, api_name) } /// As `check_open()`, but permission error messages will anonymize the path /// by replacing it with the given `display`. #[must_use = "the resolved return value to mitigate time-of-check to time-of-use issues"] #[inline(always)] pub fn check_open_blind<'a>( &self, path: Cow<'a, Path>, access_kind: OpenAccessKind, display: &str, api_name: Option<&str>, ) -> Result<CheckedPath<'a>, PermissionCheckError> { self.check_open_with_requested(path, access_kind, Some(display), api_name) } #[inline(always)] fn check_open_with_requested<'a>( &self, path: Cow<'a, Path>, access_kind: OpenAccessKind, blind_requested: Option<&str>, api_name: Option<&str>, ) -> Result<CheckedPath<'a>, PermissionCheckError> { let path = { let mut inner = self.inner.lock(); if inner.all_granted() { write_audit(ReadQueryDescriptor::flag_name(), &path); write_audit(WriteQueryDescriptor::flag_name(), &path); return Ok(CheckedPath { path: PathWithRequested { path, requested: None, }, canonicalized: false, }); } let should_check_read = access_kind.is_read() && !inner.read.is_allow_all(); let should_check_write = access_kind.is_write() && !inner.write.is_allow_all(); let path_descriptor = self.descriptor_parser.parse_path_query(path.clone())?; let path_descriptor = match blind_requested { Some(display) => { path_descriptor.with_requested(format!("<{}>", display)) } None => path_descriptor, }; if !should_check_read && !should_check_write { write_audit(ReadQueryDescriptor::flag_name(), &path); write_audit(WriteQueryDescriptor::flag_name(), &path); drop(inner); path_descriptor } else { // Use partial-deny semantics here: the operations gated by // `check_open` (open, stat, lstat, readDir, readFile, writeFile, …) // act on a single path and do not recurse, so a deny scope that lies // *under* the queried path should not block the operation. The strict // `check` (which fails on partial denies inside the requested scope) // remains in use for recursive operations like `fs::remove_all`. let path = if should_check_read { let inner = &mut inner.read; let desc = path_descriptor.into_read(); inner .check_partial(&desc, api_name) .map_err(ignored_to_not_found)?; desc.0 } else { path_descriptor }; if should_check_write { let inner = &mut inner.write; let desc = path.into_write(); inner.check_partial(&desc, api_name)?; desc.0 } else { path } } }; let special_path = if access_kind.is_no_follow() { // Don't canonicalize: lstat/readlink/readdir need to operate on the // un-resolved path. The /proc, /dev, /sys prefix guard inside // `check_special_file` still fires when the caller-supplied path is // itself a kernel-magic location (e.g. `/proc/self/root/...`). SpecialFilePathQueryDescriptor::from_path_query_no_canonicalize(path) } else { self.descriptor_parser.parse_special_file_descriptor(path)? }; self.check_special_file(special_path, access_kind, api_name) } #[inline(always)] pub fn check_read_all( &self, api_name: &str, ) -> Result<(), PermissionCheckError> { self .inner .lock() .read .check_all(Some(api_name)) .map_err(ignored_to_not_found) } #[inline(always)] pub fn query_read_all(&self) -> bool { self.inner.lock().read.query(None) == PermissionState::Granted } #[inline(always)] pub fn check_write_all( &self, api_name: &str, ) -> Result<(), PermissionCheckError> { self.inner.lock().write.check_all(Some(api_name))?; Ok(()) } #[inline(always)] pub fn check_write_partial<'a>( &self, path: Cow<'a, Path>, api_name: &str, ) -> Result<CheckedPath<'a>, PermissionCheckError> { let mut inner = self.inner.lock(); let inner = &mut inner.write; if inner.is_allow_all() { write_audit(WriteQueryDescriptor::flag_name(), &path); Ok(CheckedPath { path: PathWithRequested { path, requested: None, }, canonicalized: false, }) } else { let desc = self.descriptor_parser.parse_path_query(path)?.into_write(); inner.check_partial(&desc, Some(api_name))?; // skip checking for special permissions because we consider // write_partial as WriteNoFollow because it's only used for // fs::remove Ok(CheckedPath { path: PathWithRequested { path: desc.0.path, requested: desc.0.requested.map(Cow::Owned), }, canonicalized: false, }) } } /// Strict counterpart of [`Self::check_write_partial`]: every path below the /// query must be allowed. Use this for recursive write operations such as /// `fs::remove_all`, where a deny scope *inside* the requested tree must still /// block the operation. (`check_open` deliberately uses partial semantics, so /// recursive callers must not route through it.) #[inline(always)] pub fn check_write<'a>( &self, path: Cow<'a, Path>, api_name: &str, ) -> Result<CheckedPath<'a>, PermissionCheckError> { let mut inner = self.inner.lock(); let inner = &mut inner.write; if inner.is_allow_all() { write_audit(WriteQueryDescriptor::flag_name(), &path); Ok(CheckedPath { path: PathWithRequested { path, requested: None, }, canonicalized: false, }) } else { let desc = self.descriptor_parser.parse_path_query(path)?.into_write(); inner.check(&desc, Some(api_name))?; // skip checking for special permissions because this is treated as // WriteNoFollow (it's only used for the recursive `fs::remove` path) Ok(CheckedPath { path: PathWithRequested { path: desc.0.path, requested: desc.0.requested.map(Cow::Owned), }, canonicalized: false, }) } } #[inline(always)] pub fn check_run( &self, cmd: &RunQueryDescriptor, api_name: &str, ) -> Result<(), PermissionCheckError> { self.inner.lock().run.check(cmd, Some(api_name))?; Ok(()) } #[inline(always)] pub fn check_run_all( &mut self, api_name: &str, ) -> Result<(), PermissionCheckError> { self.inner.lock().run.check_all(Some(api_name))?; Ok(()) } #[inline(always)] pub fn query_run_all(&mut self, api_name: &str) -> bool { self.inner.lock().run.query_all(Some(api_name)) } #[inline(always)] pub fn check_sys( &self, kind: &str, api_name: &str, ) -> Result<(), PermissionCheckError> { self.inner.lock().sys.check( &self.descriptor_parser.parse_sys_descriptor(kind)?, Some(api_name), )?; Ok(()) } #[inline(always)] pub fn check_env(&self, var: &str) -> Result<(), PermissionCheckError> { self.inner.lock().env.check(var, None)?; Ok(()) } #[inline(always)] pub fn check_env_all(&self) -> Result<(), PermissionCheckError> { self.inner.lock().env.check_all()?; Ok(()) } #[inline(always)] pub fn check_sys_all(&self) -> Result<(), PermissionCheckError> { self.inner.lock().sys.check_all()?; Ok(()) } #[inline(always)] pub fn check_ffi_all(&self) -> Result<(), PermissionCheckError> { self.inner.lock().ffi.check_all()?; Ok(()) } #[inline(always)] pub fn check_has_all_permissions( &self, context_path: &Path, ) -> Result<(), PermissionCheckError> { let inner = self.inner.lock(); if inner.all_granted() { Ok(()) } else { let display_name = format_display_name(context_path.to_string_lossy()); Err( PermissionState::permission_denied_error( "all", Some(display_name.as_ref()), PermissionState::Denied, ) .into(), ) } } /// Checks special file access, returning the failed permission type if /// not successful. #[must_use = "the resolved return value to mitigate time-of-check to time-of-use issues"] pub fn check_special_file<'a>( &self, path: SpecialFilePathQueryDescriptor<'a>, access_kind: OpenAccessKind, _api_name: Option<&str>, ) -> Result<CheckedPath<'a>, PermissionCheckError> { let requested = path.requested; let canonicalized = path.canonicalized; let path = path.path; // Safe files with no major additional side-effects. if cfg!(unix) && (path == OsStr::new("/dev/random") || path == OsStr::new("/dev/urandom") || path == OsStr::new("/dev/zero") || path == OsStr::new("/dev/null")) { return Ok(CheckedPath { path: PathWithRequested { path, requested: requested.map(Cow::Owned), }, canonicalized, }); } // We allow /dev/tty access specifically for checking isatty() or reading input, // but we BLOCK write access to prevent permission prompt spoofing attacks. if cfg!(unix) && path == OsStr::new("/dev/tty") && !access_kind.is_write() { return Ok(CheckedPath { path: PathWithRequested { path, requested: requested.map(Cow::Owned), }, canonicalized, }); } /// We'll allow opening /proc/self/fd/{n} without additional permissions under the following conditions: /// /// 1. n > 2. This allows for opening bash-style redirections, but not stdio /// 2. the fd referred to by n is a pipe #[cfg(unix)] fn is_fd_file_is_pipe(path: &Path) -> bool { if let Some(fd) = path.file_name() && let Ok(s) = std::str::from_utf8(fd.as_encoded_bytes()) && let Ok(n) = s.parse::<i32>() && n > 2 { // SAFETY: This is proper use of the stat syscall unsafe { let mut stat = std::mem::zeroed::<libc::stat>(); if libc::fstat(n, &mut stat as _) == 0 && ((stat.st_mode & libc::S_IFMT) & libc::S_IFIFO) != 0 { return true; } }; } false } // On unixy systems, we allow opening /dev/fd/XXX for valid FDs that // are pipes. #[cfg(unix)] if path.starts_with("/dev/fd") && is_fd_file_is_pipe(&path) { return Ok(CheckedPath { path: PathWithRequested { path, requested: requested.map(Cow::Owned), }, canonicalized, }); } if cfg!(target_os = "linux") { // On Linux, we also allow opening /proc/self/fd/XXX for valid FDs that // are pipes. #[cfg(unix)] if path.starts_with("/proc/self/fd") && is_fd_file_is_pipe(&path) { return Ok(CheckedPath { path: PathWithRequested { path, requested: requested.map(Cow::Owned), }, canonicalized, }); } if path.starts_with("/dev") || path.starts_with("/proc") || path.starts_with("/sys") { if path.ends_with("/environ") { self.check_env_all()?; } else if path.starts_with("/proc/pressure/") { // Allow /proc/pressure/* files with just --allow-read since they are // read-only system monitoring files that only expose performance metrics } else { self.check_has_all_permissions(&path)?; } } } else if cfg!(unix) { if path.starts_with("/dev") { self.check_has_all_permissions(&path)?; } } else if cfg!(target_os = "windows") { // \\.\nul is allowed let s = path.as_os_str().as_encoded_bytes(); if s.eq_ignore_ascii_case(br#"\\.\nul"#) { return Ok(CheckedPath { path: PathWithRequested { path, requested: requested.map(Cow::Owned), }, canonicalized, }); } fn is_normalized_windows_drive_path(path: &Path) -> bool { let s = path.as_os_str().as_encoded_bytes(); if s.starts_with(br#"\\"#) { // \\?\X:\ if s.starts_with(br#"\\?\"#) && s.len() >= 7 { s[4].is_ascii_alphabetic() && s[5] == b':' && s[6] == b'\\' } else { false } } else { // the input path was normalized with strip_unc_prefix, so it's a // normalized windows drive path true } } // If this is a normalized drive path, accept it if !is_normalized_windows_drive_path(&path) { self.check_has_all_permissions(&path)?; } } else { unimplemented!() } Ok(CheckedPath { path: PathWithRequested { path, requested: requested.map(Cow::Owned), }, canonicalized, }) } #[inline(always)] pub fn check_net_url( &mut self, url: &Url, api_name: &str, ) -> Result<(), PermissionCheckError> { let mut inner = self.inner.lock(); audit_and_skip_check_if_is_permission_fully_granted!( inner.net, NetDescriptor::flag_name(), url ); let desc = self.descriptor_parser.parse_net_descriptor_from_url(url)?; inner.net.check(&desc, Some(api_name))?; Ok(()) } #[inline(always)] pub fn check_net<T: AsRef<str>>( &mut self, host: &(T, Option<u16>), api_name: &str, ) -> Result<(), PermissionCheckError> { let mut inner = self.inner.lock(); let inner = &mut inner.net; audit_and_skip_check_if_is_permission_fully_granted!( inner, NetDescriptor::flag_name(), { let hostname = Host::parse_for_query(host.0.as_ref())?; let descriptor = NetDescriptor(hostname, host.1.map(Into::into)); descriptor.display_name().into_owned() } ); let hostname = Host::parse_for_query(host.0.as_ref())?; let descriptor = NetDescriptor(hostname, host.1.map(Into::into)); inner.check(&descriptor, Some(api_name))?; Ok(()) } /// After resolving a hostname to an IP address, check that the resolved /// IP is not in the deny list. This prevents bypassing IP-literal deny /// rules via numeric hostname aliases or attacker-controlled DNS. #[inline(always)] pub fn check_net_resolved( &mut self, resolved_ip: &std::net::IpAddr, port: u16, api_name: &str, ) -> Result<(), PermissionCheckError> { let mut inner = self.inner.lock(); let desc = NetDescriptor(Host::Ip(*resolved_ip), Some(port.into())); inner.net.check_resolved_ip_deny(&desc, Some(api_name))?; Ok(()) } #[inline(always)] pub fn check_net_vsock( &mut self, cid: u32, port: u32, api_name: &str, ) -> Result<(), PermissionCheckError> { let mut inner = self.inner.lock(); audit_and_skip_check_if_is_permission_fully_granted!( inner.net, NetDescriptor::flag_name(), format!("{cid}:{port}") ); let desc = NetDescriptor(Host::Vsock(cid), Some(port)); inner.net.check(&desc, Some(api_name))?; Ok(()) } /// Network permission check for Unix domain socket endpoints. /// /// `path` must already be resolved to an absolute path (typically by the /// caller's earlier `check_open` pass). Matched lexically against /// `--allow-net=unix:<absolute-path>` rules. Both sides are lexically /// normalized (`.`/`..` components removed; rules at parse time, the query /// path by `check_open`), but symlinks are deliberately not resolved, /// mirroring `check_open`'s symlink-location semantics: a rule scopes the /// socket *location*, not the inode it points at. /// /// Abstract socket paths (Linux, leading NUL) are not absolute, so they /// cannot be expressed as a scoped `unix:` rule and are only reachable via /// an unscoped `--allow-net` grant. pub fn check_net_unix_socket( &mut self, path: &Path, api_name: Option<&str>, ) -> Result<(), PermissionCheckError> { let mut inner = self.inner.lock(); audit_and_skip_check_if_is_permission_fully_granted!( inner.net, NetDescriptor::flag_name(), format!("unix:{}", path.display()) ); let desc = NetDescriptor(Host::UnixSocket(path.to_path_buf()), None); inner.net.check(&desc, api_name)?; Ok(()) } #[inline(always)] pub fn check_ffi<'a>( &mut self, path: Cow<'a, Path>, ) -> Result<Cow<'a, Path>, PermissionCheckError> { let mut inner = self.inner.lock(); let inner = &mut inner.ffi; if inner.is_allow_all() { write_audit(FfiQueryDescriptor::flag_name(), &path); Ok(path) } else { let desc = self.descriptor_parser.parse_path_query(path)?.into_ffi(); inner.check(&desc, None)?; Ok(desc.0.path) } } #[must_use = "the resolved return value to mitigate time-of-check to time-of-use issues"] #[inline(always)] pub fn check_ffi_partial_no_path( &mut self, ) -> Result<(), PermissionCheckError> { let mut inner = self.inner.lock(); let inner = &mut inner.ffi; if !inner.is_allow_all() { inner.check_partial(None)?; } else { write_audit(FfiQueryDescriptor::flag_name(), ()); } Ok(()) } #[must_use = "the resolved return value to mitigate time-of-check to time-of-use issues"] #[inline(always)] pub fn check_ffi_partial_with_path<'a>( &mut self, path: Cow<'a, Path>, ) -> Result<Cow<'a, Path>, PermissionCheckError> { let mut inner = self.inner.lock(); let inner = &mut inner.ffi; if inner.is_allow_all() { write_audit(FfiQueryDescriptor::flag_name(), &path); Ok(path) } else { let desc = self.descriptor_parser.parse_path_query(path)?.into_ffi(); inner.check_partial(Some(&desc))?; Ok(desc.0.path) } } // query #[inline(always)] pub fn query_read( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { let inner = self.inner.lock(); let permission = &inner.read; if permission.is_allow_all() { return Ok(PermissionState::Granted); } Ok( permission.query( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_read(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn query_write( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { let inner = self.inner.lock(); let permission = &inner.write; if permission.is_allow_all() { return Ok(PermissionState::Granted); } Ok( permission.query( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_write(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn query_net( &self, host: Option<&str>, ) -> Result<PermissionState, NetDescriptorParseError> { let inner = self.inner.lock(); let permission = &inner.net; if permission.is_allow_all() { return Ok(PermissionState::Granted); } Ok( permission.query( match host { None => None, Some(h) => Some(self.descriptor_parser.parse_net_query(h)?), } .as_ref(), ), ) } #[inline(always)] pub fn query_env(&self, var: Option<&str>) -> PermissionState { let inner = self.inner.lock(); let permission = &inner.env; if permission.is_allow_all() { return PermissionState::Granted; } permission.query(var) } #[inline(always)] pub fn query_sys( &self, kind: Option<&str>, ) -> Result<PermissionState, SysDescriptorParseError> { let inner = self.inner.lock(); let permission = &inner.sys; if permission.is_allow_all() { return Ok(PermissionState::Granted); } Ok( permission.query( kind .map(|kind| self.descriptor_parser.parse_sys_descriptor(kind)) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn query_run( &self, cmd: Option<&str>, ) -> Result<PermissionState, RunDescriptorParseError> { let inner = self.inner.lock(); let permission = &inner.run; if permission.is_allow_all() { return Ok(PermissionState::Granted); } Ok( permission.query( cmd .map(|request| self.descriptor_parser.parse_run_query(request)) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn query_ffi( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { let inner = self.inner.lock(); let permission = &inner.ffi; if permission.is_allow_all() { return Ok(PermissionState::Granted); } Ok( permission.query( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_ffi(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn query_import( &self, host: Option<&str>, ) -> Result<PermissionState, NetDescriptorParseError> { let inner = self.inner.lock(); let permission = &inner.import; if permission.is_allow_all() { return Ok(PermissionState::Granted); } Ok( permission.query( match host { None => None, Some(h) => { Some(self.descriptor_parser.parse_net_query(h)?.into_import()) } } .as_ref(), ), ) } // revoke #[inline(always)] pub fn revoke_read( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { Ok( self.inner.lock().read.revoke( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_read(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn revoke_write( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { Ok( self.inner.lock().write.revoke( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_write(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn revoke_net( &self, host: Option<&str>, ) -> Result<PermissionState, NetDescriptorParseError> { Ok( self.inner.lock().net.revoke( match host { None => None, Some(h) => Some(self.descriptor_parser.parse_net_query(h)?), } .as_ref(), ), ) } #[inline(always)] pub fn revoke_env(&self, var: Option<&str>) -> PermissionState { self.inner.lock().env.revoke(var) } #[inline(always)] pub fn revoke_sys( &self, kind: Option<&str>, ) -> Result<PermissionState, SysDescriptorParseError> { Ok( self.inner.lock().sys.revoke( kind .map(|kind| self.descriptor_parser.parse_sys_descriptor(kind)) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn revoke_run( &self, cmd: Option<&str>, ) -> Result<PermissionState, RunDescriptorParseError> { Ok( self.inner.lock().run.revoke( cmd .map(|request| self.descriptor_parser.parse_run_query(request)) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn revoke_ffi( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { Ok( self.inner.lock().ffi.revoke( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_ffi(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn revoke_import( &self, host: Option<&str>, ) -> Result<PermissionState, NetDescriptorParseError> { Ok( self.inner.lock().import.revoke( match host { None => None, Some(h) => { Some(self.descriptor_parser.parse_net_query(h)?.into_import()) } } .as_ref(), ), ) } // request #[inline(always)] pub fn request_read( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { Ok( self.inner.lock().read.request( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_read(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn request_write( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { Ok( self.inner.lock().write.request( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_write(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn request_net( &self, host: Option<&str>, ) -> Result<PermissionState, NetDescriptorParseError> { Ok( self.inner.lock().net.request( match host { None => None, Some(h) => Some(self.descriptor_parser.parse_net_query(h)?), } .as_ref(), ), ) } #[inline(always)] pub fn request_env(&self, var: Option<&str>) -> PermissionState { self.inner.lock().env.request(var) } #[inline(always)] pub fn request_sys( &self, kind: Option<&str>, ) -> Result<PermissionState, SysDescriptorParseError> { Ok( self.inner.lock().sys.request( kind .map(|kind| self.descriptor_parser.parse_sys_descriptor(kind)) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn request_run( &self, cmd: Option<&str>, ) -> Result<PermissionState, RunDescriptorParseError> { Ok( self.inner.lock().run.request( cmd .map(|request| self.descriptor_parser.parse_run_query(request)) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn request_ffi( &self, path: Option<&str>, ) -> Result<PermissionState, PathResolveError> { Ok( self.inner.lock().ffi.request( path .map(|path| { Ok::<_, PathResolveError>( self .descriptor_parser .parse_path_query(Cow::Borrowed(Path::new(path)))? .into_ffi(), ) }) .transpose()? .as_ref(), ), ) } #[inline(always)] pub fn request_import( &self, host: Option<&str>, ) -> Result<PermissionState, NetDescriptorParseError> { Ok( self.inner.lock().import.request( match host { None => None, Some(h) => { Some(self.descriptor_parser.parse_net_query(h)?.into_import()) } } .as_ref(), ), ) } } const 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<T>(flag: Option<&Vec<T>>) -> bool { matches!(flag, Some(v) if v.is_empty()) } #[derive(Debug, Eq, PartialEq)] pub enum ChildUnitPermissionArg { Inherit, Granted, NotGranted, } impl<'de> Deserialize<'de> for ChildUnitPermissionArg { fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> where D: Deserializer<'de>, { struct ChildUnitPermissionArgVisitor; impl de::Visitor<'_> for ChildUnitPermissionArgVisitor { type Value = ChildUnitPermissionArg; fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result { formatter.write_str("\"inherit\" or boolean") } fn visit_unit<E>(self) -> Result<ChildUnitPermissionArg, E> where E: de::Error, { Ok(ChildUnitPermissionArg::NotGranted) } fn visit_str<E>(self, v: &str) -> Result<ChildUnitPermissionArg, E> where E: de::Error, { if v == "inherit" { Ok(ChildUnitPermissionArg::Inherit) } else { Err(de::Error::invalid_value(de::Unexpected::Str(v), &self)) } } fn visit_bool<E>(self, v: bool) -> Result<ChildUnitPermissionArg, E> 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<String>), } impl<'de> Deserialize<'de> for ChildUnaryPermissionArg { fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> 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<E>(self) -> Result<ChildUnaryPermissionArg, E> where E: de::Error, { Ok(ChildUnaryPermissionArg::NotGranted) } fn visit_str<E>(self, v: &str) -> Result<ChildUnaryPermissionArg, E> where E: de::Error, { if v == "inherit" { Ok(ChildUnaryPermissionArg::Inherit) } else { Err(de::Error::invalid_value(de::Unexpected::Str(v), &self)) } } fn visit_bool<E>(self, v: bool) -> Result<ChildUnaryPermissionArg, E> where E: de::Error, { match v { true => Ok(ChildUnaryPermissionArg::Granted), false => Ok(ChildUnaryPermissionArg::NotGranted), } } fn visit_seq<V>( self, mut v: V, ) -> Result<ChildUnaryPermissionArg, V::Error> where V: de::SeqAccess<'de>, { let mut granted_list = vec![]; while let Some(value) = v.next_element::<String>()? { 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, net: ChildUnaryPermissionArg, ffi: ChildUnaryPermissionArg, import: ChildUnaryPermissionArg, read: ChildUnaryPermissionArg, run: ChildUnaryPermissionArg, sys: ChildUnaryPermissionArg, write: ChildUnaryPermissionArg, } impl ChildPermissionsArg { pub fn inherit() -> Self { ChildPermissionsArg { env: ChildUnaryPermissionArg::Inherit, net: ChildUnaryPermissionArg::Inherit, ffi: ChildUnaryPermissionArg::Inherit, import: ChildUnaryPermissionArg::Inherit, read: ChildUnaryPermissionArg::Inherit, run: ChildUnaryPermissionArg::Inherit, sys: ChildUnaryPermissionArg::Inherit, write: ChildUnaryPermissionArg::Inherit, } } pub fn none() -> Self { ChildPermissionsArg { env: ChildUnaryPermissionArg::NotGranted, net: ChildUnaryPermissionArg::NotGranted, ffi: ChildUnaryPermissionArg::NotGranted, import: ChildUnaryPermissionArg::NotGranted, read: ChildUnaryPermissionArg::NotGranted, run: ChildUnaryPermissionArg::NotGranted, sys: ChildUnaryPermissionArg::NotGranted, write: ChildUnaryPermissionArg::NotGranted, } } } impl<'de> Deserialize<'de> for ChildPermissionsArg { fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> 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<E>(self) -> Result<ChildPermissionsArg, E> where E: de::Error, { Ok(ChildPermissionsArg::inherit()) } fn visit_str<E>(self, v: &str) -> Result<ChildPermissionsArg, E> 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<V>(self, mut v: V) -> Result<ChildPermissionsArg, V::Error> where V: de::MapAccess<'de>, { let mut child_permissions_arg = ChildPermissionsArg::none(); while let Some((key, value)) = v.next_entry::<String, serde_json::Value>()? { if key == "env" { let arg = serde_json::from_value::<ChildUnaryPermissionArg>(value); child_permissions_arg.env = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.env) {e}")) })?; } else if key == "net" { let arg = serde_json::from_value::<ChildUnaryPermissionArg>(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::<ChildUnaryPermissionArg>(value); child_permissions_arg.ffi = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.ffi) {e}")) })?; } else if key == "import" { let arg = serde_json::from_value::<ChildUnaryPermissionArg>(value); child_permissions_arg.import = arg.map_err(|e| { de::Error::custom(format!("(deno.permissions.import) {e}")) })?; } else if key == "read" { let arg = serde_json::from_value::<ChildUnaryPermissionArg>(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::<ChildUnaryPermissionArg>(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::<ChildUnaryPermissionArg>(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::<ChildUnaryPermissionArg>(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) } } /// Parses and normalizes permissions. /// /// This trait is necessary because this crate doesn't have access /// to the file system. pub trait PermissionDescriptorParser: Debug + Send + Sync { fn parse_read_descriptor( &self, text: &str, ) -> Result<ReadDescriptor, PathResolveError>; fn parse_write_descriptor( &self, text: &str, ) -> Result<WriteDescriptor, PathResolveError>; fn parse_net_descriptor( &self, text: &str, ) -> Result<NetDescriptor, NetDescriptorParseError>; fn parse_net_descriptor_from_url( &self, url: &Url, ) -> Result<NetDescriptor, NetDescriptorFromUrlParseError> { NetDescriptor::from_url(url) } fn parse_import_descriptor( &self, text: &str, ) -> Result<ImportDescriptor, NetDescriptorParseError>; fn parse_import_descriptor_from_url( &self, url: &Url, ) -> Result<ImportDescriptor, NetDescriptorFromUrlParseError> { ImportDescriptor::from_url(url) } fn parse_env_descriptor( &self, text: &str, ) -> Result<EnvDescriptor, EnvDescriptorParseError>; fn parse_sys_descriptor( &self, text: &str, ) -> Result<SysDescriptor, SysDescriptorParseError>; fn parse_allow_run_descriptor( &self, text: &str, ) -> Result<AllowRunDescriptorParseResult, RunDescriptorParseError>; fn parse_deny_run_descriptor( &self, text: &str, ) -> Result<DenyRunDescriptor, PathResolveError>; fn parse_ffi_descriptor( &self, text: &str, ) -> Result<FfiDescriptor, PathResolveError>; // queries fn parse_path_query<'a>( &self, path: Cow<'a, Path>, ) -> Result<PathQueryDescriptor<'a>, PathResolveError>; fn parse_special_file_descriptor<'a>( &self, path: PathQueryDescriptor<'a>, ) -> Result<SpecialFilePathQueryDescriptor<'a>, PathResolveError>; fn parse_net_query( &self, text: &str, ) -> Result<NetDescriptor, NetDescriptorParseError>; fn parse_run_query<'a>( &self, requested: &'a str, ) -> Result<RunQueryDescriptor<'a>, RunDescriptorParseError>; } static IS_STANDALONE: AtomicFlag = AtomicFlag::lowered(); pub fn mark_standalone() { IS_STANDALONE.raise(); } pub fn is_standalone() -> bool { IS_STANDALONE.is_raised() } #[cfg(test)] mod tests { use std::net::Ipv4Addr; use fqdn::fqdn; use prompter::tests::*; use serde_json::json; use sys_traits::EnvCurrentDir; use super::*; use crate::prompter::set_prompter; // Creates vector of strings, Vec<String> macro_rules! svec { ($($x:expr),*) => (vec![$($x.to_string()),*]); } #[derive(Debug, Clone)] struct TestPermissionDescriptorParser; impl TestPermissionDescriptorParser { fn join_path_with_root(&self, path: &str) -> PathDescriptor { let path = if path.starts_with("C:\\") { PathBuf::from(path) } else { PathBuf::from("/").join(path) }; let cmp_path = comparison_path(&path); PathDescriptor { path, cmp_path, requested: None, is_windows_device_path: false, } } } impl PermissionDescriptorParser for TestPermissionDescriptorParser { fn parse_read_descriptor( &self, text: &str, ) -> Result<ReadDescriptor, PathResolveError> { Ok(ReadDescriptor(self.join_path_with_root(text))) } fn parse_write_descriptor( &self, text: &str, ) -> Result<WriteDescriptor, PathResolveError> { Ok(WriteDescriptor(self.join_path_with_root(text))) } fn parse_net_descriptor( &self, text: &str, ) -> Result<NetDescriptor, NetDescriptorParseError> { NetDescriptor::parse_for_list(text) } fn parse_import_descriptor( &self, text: &str, ) -> Result<ImportDescriptor, NetDescriptorParseError> { ImportDescriptor::parse_for_list(text) } fn parse_env_descriptor( &self, text: &str, ) -> Result<EnvDescriptor, EnvDescriptorParseError> { Ok(EnvDescriptor::new(Cow::Borrowed(text))) } fn parse_sys_descriptor( &self, text: &str, ) -> Result<SysDescriptor, SysDescriptorParseError> { SysDescriptor::parse(text.to_string()) } fn parse_allow_run_descriptor( &self, text: &str, ) -> Result<AllowRunDescriptorParseResult, RunDescriptorParseError> { Ok(AllowRunDescriptorParseResult::Descriptor( AllowRunDescriptor(self.join_path_with_root(text)), )) } fn parse_deny_run_descriptor( &self, text: &str, ) -> Result<DenyRunDescriptor, PathResolveError> { if text.contains("/") { Ok(DenyRunDescriptor::Path(self.join_path_with_root(text))) } else { Ok(DenyRunDescriptor::Name(text.to_string())) } } fn parse_ffi_descriptor( &self, text: &str, ) -> Result<FfiDescriptor, PathResolveError> { Ok(FfiDescriptor(self.join_path_with_root(text))) } fn parse_path_query<'a>( &self, path: Cow<'a, Path>, ) -> Result<PathQueryDescriptor<'a>, PathResolveError> { let cmp_path = comparison_path(&path); Ok(PathQueryDescriptor { path, cmp_path, requested: None, is_windows_device_path: false, }) } fn parse_net_query( &self, text: &str, ) -> Result<NetDescriptor, NetDescriptorParseError> { NetDescriptor::parse_for_query(text) } fn parse_run_query<'a>( &self, requested: &'a str, ) -> Result<RunQueryDescriptor<'a>, RunDescriptorParseError> { RunQueryDescriptor::parse(requested, &sys_traits::impls::RealSys) .map_err(Into::into) } fn parse_special_file_descriptor<'a>( &self, path: PathQueryDescriptor<'a>, ) -> Result<SpecialFilePathQueryDescriptor<'a>, PathResolveError> { Ok(SpecialFilePathQueryDescriptor { path: path.path, requested: None, canonicalized: false, }) } } #[test] fn deep_clone_without_prompt_preserves_state_without_prompting() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let permissions = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/allowed"]), deny_read: Some(svec!["/denied"]), prompt: true, ..Default::default() }, ) .unwrap(); let permissions = PermissionsContainer::new(Arc::new(parser), permissions); let snapshot = permissions.deep_clone_without_prompt(); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(true); assert!( snapshot .check_open( Cow::Borrowed(Path::new("/unresolved")), OpenAccessKind::Read, None, ) .is_err() ); assert!( snapshot .check_open( Cow::Borrowed(Path::new("/allowed/file")), OpenAccessKind::Read, None, ) .is_ok() ); assert!( snapshot .check_open( Cow::Borrowed(Path::new("/denied/file")), OpenAccessKind::Read, None, ) .is_err() ); assert_eq!( permissions.query_read(Some("/unresolved")).unwrap(), PermissionState::Prompt ); assert!( permissions .check_open( Cow::Borrowed(Path::new("/unresolved")), OpenAccessKind::Read, None, ) .is_ok() ); assert_eq!( snapshot.query_read(Some("/unresolved")).unwrap(), PermissionState::Prompt ); } #[test] fn check_paths() { set_prompter(Box::new(TestPrompter)); let allowlist = svec!["/a/specific/dir/name", "/a/specific", "/b/c"]; let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(allowlist.clone()), allow_write: Some(allowlist.clone()), allow_ffi: Some(allowlist), ..Default::default() }, ) .unwrap(); let mut perms = PermissionsContainer::new(Arc::new(parser), perms); let cases = [ // Inside of /a/specific and /a/specific/dir/name ("/a/specific/dir/name", true), // Inside of /a/specific but outside of /a/specific/dir/name ("/a/specific/dir", true), // Inside of /a/specific and /a/specific/dir/name ("/a/specific/dir/name/inner", true), // Inside of /a/specific but outside of /a/specific/dir/name ("/a/specific/other/dir", true), // Exact match with /b/c ("/b/c", true), // Sub path within /b/c ("/b/c/sub/path", true), // Sub path within /b/c, needs normalizing ("/b/c/sub/path/../path/.", true), // Inside of /b but outside of /b/c ("/b/e", false), // Inside of /a but outside of /a/specific ("/a/b", false), ]; for (path, is_ok) in cases { assert_eq!( perms .check_open( Cow::Borrowed(Path::new(path)), OpenAccessKind::Read, Some("api") ) .is_ok(), is_ok ); assert_eq!( perms .check_open( Cow::Borrowed(Path::new(path)), OpenAccessKind::Write, Some("api") ) .is_ok(), is_ok ); assert_eq!( perms.check_ffi(Cow::Borrowed(Path::new(path))).is_ok(), is_ok ); } } #[test] #[cfg(target_os = "macos")] fn check_paths_macos_unicode_normalization() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; // Deny a path containing ß — on APFS this is the same file as one with "ss" let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/data"]), deny_read: Some(svec!["/data/file_\u{00df}.txt"]), allow_write: Some(svec!["/data"]), deny_write: Some(svec!["/data/file_\u{00df}.txt"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); // Access via "ss" form must also be denied (APFS treats ß and ss as same file) assert!( perms .check_open( Cow::Borrowed(Path::new("/data/file_ss.txt")), OpenAccessKind::Read, Some("api") ) .is_err(), "deny-read bypass via ß/ss equivalence" ); assert!( perms .check_open( Cow::Borrowed(Path::new("/data/file_ss.txt")), OpenAccessKind::Write, Some("api") ) .is_err(), "deny-write bypass via ß/ss equivalence" ); // NFC é (U+00E9) vs NFD e + combining accent (U+0065 U+0301) let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/data"]), deny_read: Some(svec!["/data/file_\u{00e9}.txt"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); assert!( perms .check_open( Cow::Borrowed(Path::new("/data/file_e\u{0301}.txt")), OpenAccessKind::Read, Some("api") ) .is_err(), "deny-read bypass via NFC/NFD equivalence" ); // Case insensitivity: APFS is case-insensitive by default let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/data"]), deny_read: Some(svec!["/data/SECRET.txt"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); assert!( perms .check_open( Cow::Borrowed(Path::new("/data/secret.txt")), OpenAccessKind::Read, Some("api") ) .is_err(), "deny-read bypass via case insensitivity" ); // fi ligature (U+FB01) vs "fi" — NFKD compatibility decomposition let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/data"]), deny_read: Some(svec!["/data/file_\u{fb01}.txt"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); assert!( perms .check_open( Cow::Borrowed(Path::new("/data/file_fi.txt")), OpenAccessKind::Read, Some("api") ) .is_err(), "deny-read bypass via fi ligature equivalence" ); } #[test] fn test_check_net_with_values() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &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", "*.discord.gg" ]), ..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), ("discord.gg", 0, true), ("foo.discord.gg", 0, 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 { let host = Host::parse_for_query(host).unwrap(); let descriptor = NetDescriptor(host, Some(port)); assert_eq!( is_ok, perms.net.check(&descriptor, None).is_ok(), "{descriptor}", ); } } #[test] fn test_check_net_only_flag() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &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_str, port) in domain_tests { let host = Host::parse_for_query(host_str).unwrap(); let descriptor = NetDescriptor(host, Some(port)); assert!( perms.net.check(&descriptor, None).is_ok(), "expected {host_str}:{port} to pass" ); } } #[test] fn test_check_net_no_flag() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &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_str, port) in domain_tests { let host = Host::parse_for_query(host_str).unwrap(); let descriptor = NetDescriptor(host, Some(port)); assert!( perms.net.check(&descriptor, None).is_err(), "expected {host_str}:{port} to fail" ); } } #[test] fn test_check_net_deny_resolved_ip() { // Regression test: deny rules written as IP literals must also block // connections after DNS resolution, preventing bypasses via numeric // hostname aliases (e.g. 2130706433 → 127.0.0.1). set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(svec![]), deny_net: Some(svec!["127.0.0.1"]), ..Default::default() }, ) .unwrap(); // The resolved IP 127.0.0.1 should be denied regardless of original // hostname. let denied_ip = std::net::IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)); let desc = NetDescriptor(Host::Ip(denied_ip), Some(12345)); assert!( perms.net.check_resolved_ip_deny(&desc, None).is_err(), "resolved 127.0.0.1 should be denied" ); // A different IP should not be denied. let allowed_ip = std::net::IpAddr::V4(Ipv4Addr::new(192, 168, 1, 1)); let desc = NetDescriptor(Host::Ip(allowed_ip), Some(12345)); assert!( perms.net.check_resolved_ip_deny(&desc, None).is_ok(), "resolved 192.168.1.1 should not be denied" ); } #[test] fn test_check_net_deny_resolved_ip_subnet() { // Regression test: subnet-based deny rules (e.g. --deny-net=127.0.0.0/8) // must also block resolved IPs that fall within the subnet, preventing // bypasses via numeric hostname aliases (e.g. 2130706433 → 127.0.0.1). set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(svec![]), deny_net: Some(svec!["127.0.0.0/8"]), ..Default::default() }, ) .unwrap(); // 127.0.0.1 falls within the 127.0.0.0/8 subnet — should be denied. let denied_ip = std::net::IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)); let desc = NetDescriptor(Host::Ip(denied_ip), Some(8000)); assert!( perms.net.check_resolved_ip_deny(&desc, None).is_err(), "resolved 127.0.0.1 should be denied by 127.0.0.0/8 subnet rule" ); // 127.1.2.3 also falls within 127.0.0.0/8 — should be denied. let denied_ip2 = std::net::IpAddr::V4(Ipv4Addr::new(127, 1, 2, 3)); let desc = NetDescriptor(Host::Ip(denied_ip2), Some(9000)); assert!( perms.net.check_resolved_ip_deny(&desc, None).is_err(), "resolved 127.1.2.3 should be denied by 127.0.0.0/8 subnet rule" ); // 192.168.1.1 is outside the subnet — should not be denied. let allowed_ip = std::net::IpAddr::V4(Ipv4Addr::new(192, 168, 1, 1)); let desc = NetDescriptor(Host::Ip(allowed_ip), Some(8000)); assert!( perms.net.check_resolved_ip_deny(&desc, None).is_ok(), "resolved 192.168.1.1 should not be denied by 127.0.0.0/8 subnet rule" ); } #[test] fn test_check_net_url() { let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &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 mut perms = PermissionsContainer::new(Arc::new(parser), perms); 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::parse(url_str).unwrap(); assert_eq!(is_ok, perms.check_net_url(&u, "api()").is_ok(), "{}", u); } } #[test] fn check_specifiers() { set_prompter(Box::new(TestPrompter)); let read_allowlist = if cfg!(target_os = "windows") { svec!["C:\\a"] } else { svec!["/a"] }; let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(read_allowlist), allow_import: Some(svec!["localhost"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); let mut fixtures = vec![ ( Url::parse("http://localhost:4545/mod.ts").unwrap(), CheckSpecifierKind::Static, true, ), ( Url::parse("http://localhost:4545/mod.ts").unwrap(), CheckSpecifierKind::Dynamic, true, ), ( Url::parse("http://deno.land/x/mod.ts").unwrap(), CheckSpecifierKind::Dynamic, false, ), ( Url::parse("data:text/plain,Hello%2C%20Deno!").unwrap(), CheckSpecifierKind::Dynamic, true, ), ]; if cfg!(target_os = "windows") { fixtures.push(( Url::parse("file:///C:/a/mod.ts").unwrap(), CheckSpecifierKind::Dynamic, true, )); fixtures.push(( Url::parse("file:///C:/b/mod.ts").unwrap(), CheckSpecifierKind::Static, true, )); fixtures.push(( Url::parse("file:///C:/b/mod.ts").unwrap(), CheckSpecifierKind::Dynamic, false, )); } else { fixtures.push(( Url::parse("file:///a/mod.ts").unwrap(), CheckSpecifierKind::Dynamic, true, )); fixtures.push(( Url::parse("file:///b/mod.ts").unwrap(), CheckSpecifierKind::Static, true, )); fixtures.push(( Url::parse("file:///b/mod.ts").unwrap(), CheckSpecifierKind::Dynamic, false, )); } for (specifier, kind, expected) in fixtures { assert_eq!( perms.check_specifier(&specifier, kind).is_ok(), expected, "{}", specifier, ); } } #[test] fn test_query() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let perms1 = Permissions::allow_all(); let perms2 = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo"]), allow_write: Some(svec!["/foo"]), allow_ffi: Some(svec!["/foo"]), allow_net: Some(svec!["127.0.0.1:8000"]), allow_env: Some(svec!["HOME"]), allow_sys: Some(svec!["hostname"]), allow_run: Some(svec!["/deno"]), ..Default::default() }, ) .unwrap(); let perms3 = Permissions::from_options( &parser, &PermissionsOptions { deny_read: Some(svec!["/foo"]), deny_write: Some(svec!["/foo"]), deny_ffi: Some(svec!["/foo"]), deny_net: Some(svec!["127.0.0.1:8000"]), deny_env: Some(svec!["HOME"]), deny_sys: Some(svec!["hostname"]), deny_run: Some(svec!["deno"]), deny_import: Some(svec!["example.com:443"]), ..Default::default() }, ) .unwrap(); let perms4 = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), deny_read: Some(svec!["/foo"]), allow_write: Some(vec![]), deny_write: Some(svec!["/foo"]), allow_ffi: Some(vec![]), deny_ffi: Some(svec!["/foo"]), allow_net: Some(vec![]), deny_net: Some(svec!["127.0.0.1:8000"]), allow_env: Some(vec![]), deny_env: Some(svec!["HOME"]), allow_sys: Some(vec![]), deny_sys: Some(svec!["hostname"]), allow_run: Some(vec![]), deny_run: Some(svec!["deno"]), allow_import: Some(vec![]), deny_import: Some(svec!["example.com:443"]), ..Default::default() }, ) .unwrap(); let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; let write_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_write() }; let ffi_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_ffi() }; #[rustfmt::skip] { assert_eq!(perms1.read.query(None), PermissionState::Granted); assert_eq!(perms1.read.query(Some(&read_query("/foo"))), PermissionState::Granted); assert_eq!(perms2.read.query(None), PermissionState::Prompt); assert_eq!(perms2.read.query(Some(&read_query("/foo"))), PermissionState::Granted); assert_eq!(perms2.read.query(Some(&read_query("/foo/bar"))), PermissionState::Granted); assert_eq!(perms3.read.query(None), PermissionState::Prompt); assert_eq!(perms3.read.query(Some(&read_query("/foo"))), PermissionState::Denied); assert_eq!(perms3.read.query(Some(&read_query("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.read.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.read.query(Some(&read_query("/foo"))), PermissionState::Denied); assert_eq!(perms4.read.query(Some(&read_query("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.read.query(Some(&read_query("/bar"))), PermissionState::Granted); assert_eq!(perms1.write.query(None), PermissionState::Granted); assert_eq!(perms1.write.query(Some(&write_query("/foo"))), PermissionState::Granted); assert_eq!(perms2.write.query(None), PermissionState::Prompt); assert_eq!(perms2.write.query(Some(&write_query("/foo"))), PermissionState::Granted); assert_eq!(perms2.write.query(Some(&write_query("/foo/bar"))), PermissionState::Granted); assert_eq!(perms3.write.query(None), PermissionState::Prompt); assert_eq!(perms3.write.query(Some(&write_query("/foo"))), PermissionState::Denied); assert_eq!(perms3.write.query(Some(&write_query("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.write.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.write.query(Some(&write_query("/foo"))), PermissionState::Denied); assert_eq!(perms4.write.query(Some(&write_query("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.write.query(Some(&write_query("/bar"))), PermissionState::Granted); assert_eq!(perms1.ffi.query(None), PermissionState::Granted); assert_eq!(perms1.ffi.query(Some(&ffi_query("/foo"))), PermissionState::Granted); assert_eq!(perms2.ffi.query(None), PermissionState::Prompt); assert_eq!(perms2.ffi.query(Some(&ffi_query("/foo"))), PermissionState::Granted); assert_eq!(perms2.ffi.query(Some(&ffi_query("/foo/bar"))), PermissionState::Granted); assert_eq!(perms3.ffi.query(None), PermissionState::Prompt); assert_eq!(perms3.ffi.query(Some(&ffi_query("/foo"))), PermissionState::Denied); assert_eq!(perms3.ffi.query(Some(&ffi_query("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.ffi.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.ffi.query(Some(&ffi_query("/foo"))), PermissionState::Denied); assert_eq!(perms4.ffi.query(Some(&ffi_query("/foo/bar"))), PermissionState::Denied); assert_eq!(perms4.ffi.query(Some(&ffi_query("/bar"))), PermissionState::Granted); assert_eq!(perms1.net.query(None), PermissionState::Granted); assert_eq!(perms1.net.query(Some(&NetDescriptor(Host::must_parse("127.0.0.1"), None))), PermissionState::Granted); assert_eq!(perms2.net.query(None), PermissionState::Prompt); assert_eq!(perms2.net.query(Some(&NetDescriptor(Host::must_parse("127.0.0.1"), Some(8000)))), PermissionState::Granted); assert_eq!(perms3.net.query(None), PermissionState::Prompt); assert_eq!(perms3.net.query(Some(&NetDescriptor(Host::must_parse("127.0.0.1"), Some(8000)))), PermissionState::Denied); assert_eq!(perms4.net.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.net.query(Some(&NetDescriptor(Host::must_parse("127.0.0.1"), Some(8000)))), PermissionState::Denied); assert_eq!(perms4.net.query(Some(&NetDescriptor(Host::must_parse("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); let sys_desc = |name: &str| SysDescriptor::parse(name.to_string()).unwrap(); assert_eq!(perms1.sys.query(None), PermissionState::Granted); assert_eq!(perms1.sys.query(Some(&sys_desc("osRelease"))), PermissionState::Granted); assert_eq!(perms2.sys.query(None), PermissionState::Prompt); assert_eq!(perms2.sys.query(Some(&sys_desc("hostname"))), PermissionState::Granted); assert_eq!(perms3.sys.query(None), PermissionState::Prompt); assert_eq!(perms3.sys.query(Some(&sys_desc("hostname"))), PermissionState::Denied); assert_eq!(perms4.sys.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.sys.query(Some(&sys_desc("hostname"))), PermissionState::Denied); assert_eq!(perms4.sys.query(Some(&sys_desc("uid"))), PermissionState::Granted); assert_eq!(perms1.run.query(None), PermissionState::Granted); let deno_run_query = RunQueryDescriptor::Path(PathQueryDescriptor::new_known_absolute(Cow::Owned(PathBuf::from("/deno"))).with_requested("deno".to_string())); let node_run_query = RunQueryDescriptor::Path( PathQueryDescriptor::new_known_absolute(Cow::Owned(PathBuf::from("/node"))).with_requested("node".to_string()) ); assert_eq!(perms1.run.query(Some(&deno_run_query)), PermissionState::Granted); assert_eq!(perms1.write.query(Some(&write_query("/deno"))), PermissionState::Granted); assert_eq!(perms2.run.query(None), PermissionState::Prompt); assert_eq!(perms2.run.query(Some(&deno_run_query)), PermissionState::Granted); assert_eq!(perms2.write.query(Some(&write_query("/deno"))), PermissionState::Denied); assert_eq!(perms3.run.query(None), PermissionState::Prompt); assert_eq!(perms3.run.query(Some(&deno_run_query)), PermissionState::Denied); assert_eq!(perms4.run.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.run.query(Some(&deno_run_query)), PermissionState::Denied); assert_eq!(perms4.run.query(Some(&node_run_query)), PermissionState::Granted); assert_eq!(perms3.import.query(None), PermissionState::Prompt); assert_eq!(perms3.import.query(Some(&ImportDescriptor(NetDescriptor(Host::must_parse("example.com"), Some(443))))), PermissionState::Denied); assert_eq!(perms4.import.query(None), PermissionState::GrantedPartial); assert_eq!(perms4.import.query(Some(&ImportDescriptor(NetDescriptor(Host::must_parse("example.com"), Some(443))))), PermissionState::Denied); assert_eq!(perms4.import.query(Some(&ImportDescriptor(NetDescriptor(Host::must_parse("deno.land"), Some(443))))), PermissionState::Granted); }; #[rustfmt::skip] { let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo/specific"]), deny_read: Some(svec!["/foo"]), allow_write: Some(svec!["/foo/specific"]), deny_write: Some(svec!["/foo"]), allow_ffi: Some(svec!["/foo/specific"]), deny_ffi: Some(svec!["/foo"]), ..Default::default() }, ) .unwrap(); assert_eq!(perms.read.query(Some(&read_query("/foo"))), PermissionState::Denied); assert_eq!(perms.read.query(Some(&read_query("/"))), PermissionState::Prompt); assert_eq!(perms.read.query(Some(&read_query("/foo/specific"))), PermissionState::Granted); assert_eq!(perms.read.query(Some(&read_query("/foo/specific/data.txt"))), PermissionState::Granted); assert_eq!(perms.write.query(Some(&write_query("/foo"))), PermissionState::Denied); assert_eq!(perms.write.query(Some(&write_query("/foo/specific"))), PermissionState::Granted); assert_eq!(perms.ffi.query(Some(&ffi_query("/foo"))), PermissionState::Denied); assert_eq!(perms.ffi.query(Some(&ffi_query("/foo/specific"))), PermissionState::Granted); }; #[rustfmt::skip] { // flipped above let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo"]), deny_read: Some(svec!["/foo/specific"]), allow_write: Some(svec!["/foo"]), deny_write: Some(svec!["/foo/specific"]), allow_ffi: Some(svec!["/foo"]), deny_ffi: Some(svec!["/foo/specific"]), ..Default::default() }, ) .unwrap(); assert_eq!(perms.read.query(Some(&read_query("/foo"))), PermissionState::GrantedPartial); assert_eq!(perms.read.query(Some(&read_query("/foo/bar"))), PermissionState::Granted); assert_eq!(perms.read.query(Some(&read_query("/"))), PermissionState::Prompt); assert_eq!(perms.read.query(Some(&read_query("/foo/specific"))), PermissionState::Denied); assert_eq!(perms.read.query(Some(&read_query("/foo/specific/data.txt"))), PermissionState::Denied); assert_eq!(perms.write.query(Some(&write_query("/foo"))), PermissionState::GrantedPartial); assert_eq!(perms.write.query(Some(&write_query("/foo/bar"))), PermissionState::Granted); assert_eq!(perms.write.query(Some(&write_query("/foo/specific"))), PermissionState::Denied); assert_eq!(perms.ffi.query(Some(&ffi_query("/foo"))), PermissionState::GrantedPartial); assert_eq!(perms.ffi.query(Some(&ffi_query("/foo/bar"))), PermissionState::Granted); assert_eq!(perms.ffi.query(Some(&ffi_query("/foo/specific"))), PermissionState::Denied); }; } #[test] fn test_request() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let mut perms: Permissions = Permissions::none_with_prompt(); let mut perms_no_prompt: Permissions = Permissions::none_without_prompt(); let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; let write_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_write() }; let ffi_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_ffi() }; #[rustfmt::skip] { let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(true); assert_eq!(perms.read.request(Some(&read_query("/foo"))), PermissionState::Granted); assert_eq!(perms.read.query(None), PermissionState::Prompt); prompt_value.set(false); assert_eq!(perms.read.request(Some(&read_query("/foo/bar"))), PermissionState::Granted); prompt_value.set(false); assert_eq!(perms.write.request(Some(&write_query("/foo"))), PermissionState::Denied); assert_eq!(perms.write.query(Some(&write_query("/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(&ffi_query("/foo"))), PermissionState::Denied); assert_eq!(perms.ffi.query(Some(&ffi_query("/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(&NetDescriptor(Host::must_parse("127.0.0.1"), None))), PermissionState::Granted); prompt_value.set(false); assert_eq!(perms.net.request(Some(&NetDescriptor(Host::must_parse("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); let sys_desc = |name: &str| SysDescriptor::parse(name.to_string()).unwrap(); assert_eq!(perms.sys.request(Some(&sys_desc("hostname"))), PermissionState::Granted); assert_eq!(perms.sys.query(None), PermissionState::Prompt); prompt_value.set(false); assert_eq!(perms.sys.request(Some(&sys_desc("hostname"))), PermissionState::Granted); prompt_value.set(true); let run_query = RunQueryDescriptor::Path(PathQueryDescriptor::new_known_absolute(Cow::Owned(PathBuf::from("/deno"))).with_requested("deno".to_string())); assert_eq!(perms.run.request(Some(&run_query)), PermissionState::Granted); assert_eq!(perms.run.query(None), PermissionState::Prompt); prompt_value.set(false); assert_eq!(perms.run.request(Some(&run_query)), PermissionState::Granted); assert_eq!(perms_no_prompt.read.request(Some(&read_query("/foo"))), PermissionState::Denied); }; } #[test] fn test_revoke() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo", "/foo/baz"]), allow_write: Some(svec!["/foo", "/foo/baz"]), allow_ffi: Some(svec!["/foo", "/foo/baz"]), allow_net: Some(svec!["127.0.0.1", "127.0.0.1:8000"]), allow_env: Some(svec!["HOME"]), allow_sys: Some(svec!["hostname"]), allow_run: Some(svec!["/deno"]), ..Default::default() }, ) .unwrap(); let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; let write_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_write() }; let ffi_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_ffi() }; #[rustfmt::skip] { assert_eq!(perms.read.revoke(Some(&read_query("/foo/bar"))), PermissionState::Prompt); assert_eq!(perms.read.query(Some(&read_query("/foo"))), PermissionState::Prompt); assert_eq!(perms.read.query(Some(&read_query("/foo/baz"))), PermissionState::Granted); assert_eq!(perms.write.revoke(Some(&write_query("/foo/bar"))), PermissionState::Prompt); assert_eq!(perms.write.query(Some(&write_query("/foo"))), PermissionState::Prompt); assert_eq!(perms.write.query(Some(&write_query("/foo/baz"))), PermissionState::Granted); assert_eq!(perms.ffi.revoke(Some(&ffi_query("/foo/bar"))), PermissionState::Prompt); assert_eq!(perms.ffi.query(Some(&ffi_query("/foo"))), PermissionState::Prompt); assert_eq!(perms.ffi.query(Some(&ffi_query("/foo/baz"))), PermissionState::Granted); assert_eq!(perms.net.revoke(Some(&NetDescriptor(Host::must_parse("127.0.0.1"), Some(9000)))), PermissionState::Prompt); assert_eq!(perms.net.query(Some(&NetDescriptor(Host::must_parse("127.0.0.1"), None))), PermissionState::Prompt); assert_eq!(perms.net.query(Some(&NetDescriptor(Host::must_parse("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); let run_query = RunQueryDescriptor::Path(PathQueryDescriptor::new_known_absolute(Cow::Owned(PathBuf::from("/deno"))).with_requested("deno".to_string())); assert_eq!(perms.run.revoke(Some(&run_query)), PermissionState::Prompt); }; } #[test] fn test_check() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions::none_with_prompt(); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); let parser = TestPermissionDescriptorParser; let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; let write_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_write() }; let ffi_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_ffi() }; prompt_value.set(true); assert!(perms.read.check(&read_query("/foo"), None).is_ok()); prompt_value.set(false); assert!(perms.read.check(&read_query("/foo"), None).is_ok()); assert!(perms.read.check(&read_query("/bar"), None).is_err()); prompt_value.set(true); assert!(perms.write.check(&write_query("/foo"), None).is_ok()); prompt_value.set(false); assert!(perms.write.check(&write_query("/foo"), None).is_ok()); assert!(perms.write.check(&write_query("/bar"), None).is_err()); prompt_value.set(true); assert!(perms.ffi.check(&ffi_query("/foo"), None).is_ok()); prompt_value.set(false); assert!(perms.ffi.check(&ffi_query("/foo"), None).is_ok()); assert!(perms.ffi.check(&ffi_query("/bar"), None).is_err()); prompt_value.set(true); assert!( perms .net .check( &NetDescriptor(Host::must_parse("127.0.0.1"), Some(8000)), None ) .is_ok() ); prompt_value.set(false); assert!( perms .net .check( &NetDescriptor(Host::must_parse("127.0.0.1"), Some(8000)), None ) .is_ok() ); assert!( perms .net .check( &NetDescriptor(Host::must_parse("127.0.0.1"), Some(8001)), None ) .is_err() ); assert!( perms .net .check(&NetDescriptor(Host::must_parse("127.0.0.1"), None), None) .is_err() ); assert!( perms .net .check( &NetDescriptor(Host::must_parse("deno.land"), Some(8000)), None ) .is_err() ); assert!( perms .net .check(&NetDescriptor(Host::must_parse("deno.land"), None), None) .is_err() ); let cwd = sys_traits::impls::RealSys.env_current_dir().unwrap(); prompt_value.set(true); assert!( perms .run .check( &RunQueryDescriptor::Path( PathQueryDescriptor::new_known_absolute(Cow::Owned( cwd.join("cat") )) .with_requested("cat".to_string()), ), None ) .is_ok() ); prompt_value.set(false); assert!( perms .run .check( &RunQueryDescriptor::Path( PathQueryDescriptor::new_known_absolute(Cow::Owned( cwd.join("cat") )) .with_requested("cat".to_string()) ), None ) .is_ok() ); assert!( perms .run .check( &RunQueryDescriptor::Path( PathQueryDescriptor::new_known_absolute(Cow::Owned(cwd.join("ls"))) .with_requested("ls".to_string()) ), None ) .is_err() ); prompt_value.set(true); assert!(perms.env.check("HOME", None).is_ok()); prompt_value.set(false); assert!(perms.env.check("HOME", None).is_ok()); assert!(perms.env.check("PATH", None).is_err()); prompt_value.set(true); assert!(perms.env.check("hostname", None).is_ok()); prompt_value.set(false); assert!(perms.env.check("hostname", None).is_ok()); assert!(perms.env.check("osRelease", None).is_err()); } #[test] fn test_check_fail() { set_prompter(Box::new(TestPrompter)); let mut perms = Permissions::none_with_prompt(); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); let parser = TestPermissionDescriptorParser; let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; let write_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_write() }; let ffi_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_ffi() }; prompt_value.set(false); assert!(perms.read.check(&read_query("/foo"), None).is_err()); prompt_value.set(true); assert!(perms.read.check(&read_query("/foo"), None).is_err()); assert!(perms.read.check(&read_query("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.read.check(&read_query("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.write.check(&write_query("/foo"), None).is_err()); prompt_value.set(true); assert!(perms.write.check(&write_query("/foo"), None).is_err()); assert!(perms.write.check(&write_query("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.write.check(&write_query("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.ffi.check(&ffi_query("/foo"), None).is_err()); prompt_value.set(true); assert!(perms.ffi.check(&ffi_query("/foo"), None).is_err()); assert!(perms.ffi.check(&ffi_query("/bar"), None).is_ok()); prompt_value.set(false); assert!(perms.ffi.check(&ffi_query("/bar"), None).is_ok()); prompt_value.set(false); assert!( perms .net .check( &NetDescriptor(Host::must_parse("127.0.0.1"), Some(8000)), None ) .is_err() ); prompt_value.set(true); assert!( perms .net .check( &NetDescriptor(Host::must_parse("127.0.0.1"), Some(8000)), None ) .is_err() ); assert!( perms .net .check( &NetDescriptor(Host::must_parse("127.0.0.1"), Some(8001)), None ) .is_ok() ); assert!( perms .net .check( &NetDescriptor(Host::must_parse("deno.land"), Some(8000)), None ) .is_ok() ); prompt_value.set(false); assert!( perms .net .check( &NetDescriptor(Host::must_parse("127.0.0.1"), Some(8001)), None ) .is_ok() ); assert!( perms .net .check( &NetDescriptor(Host::must_parse("deno.land"), Some(8000)), None ) .is_ok() ); prompt_value.set(false); let cwd = sys_traits::impls::RealSys.env_current_dir().unwrap(); assert!( perms .run .check( &RunQueryDescriptor::Path( PathQueryDescriptor::new_known_absolute(Cow::Owned( cwd.join("cat") )) .with_requested("cat".to_string()) ), None ) .is_err() ); prompt_value.set(true); assert!( perms .run .check( &RunQueryDescriptor::Path( PathQueryDescriptor::new_known_absolute(Cow::Owned( cwd.join("cat") )) .with_requested("cat".to_string()) ), None ) .is_err() ); assert!( perms .run .check( &RunQueryDescriptor::Path( PathQueryDescriptor::new_known_absolute(Cow::Owned(cwd.join("ls"))) .with_requested("ls".to_string()) ), None ) .is_ok() ); prompt_value.set(false); assert!( perms .run .check( &RunQueryDescriptor::Path( PathQueryDescriptor::new_known_absolute(Cow::Owned(cwd.join("ls"))) .with_requested("ls".to_string()) ), None ) .is_ok() ); prompt_value.set(false); assert!(perms.env.check("HOME", None).is_err()); prompt_value.set(true); assert!(perms.env.check("HOME", None).is_err()); assert!(perms.env.check("PATH", None).is_ok()); prompt_value.set(false); assert!(perms.env.check("PATH", None).is_ok()); prompt_value.set(false); let sys_desc = |name: &str| SysDescriptor::parse(name.to_string()).unwrap(); assert!(perms.sys.check(&sys_desc("hostname"), None).is_err()); prompt_value.set(true); assert!(perms.sys.check(&sys_desc("hostname"), None).is_err()); assert!(perms.sys.check(&sys_desc("osRelease"), None).is_ok()); prompt_value.set(false); assert!(perms.sys.check(&sys_desc("osRelease"), None).is_ok()); } #[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_unary( Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("HOME"))])), None, false, ) }; prompt_value.set(true); assert!(perms.env.check("HOME", None).is_ok()); prompt_value.set(false); assert!(perms.env.check("HOME", None).is_ok()); assert!(perms.env.check("hOmE", None).is_ok()); assert_eq!(perms.env.revoke(Some("HomE")), PermissionState::Prompt); } #[test] fn test_env_wildcards() { 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_unary( Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("HOME_*"))])), None, false, ) }; assert_eq!(perms.env.query(Some("HOME")), PermissionState::Prompt); assert_eq!(perms.env.query(Some("HOME_")), PermissionState::Granted); assert_eq!(perms.env.query(Some("HOME_TEST")), PermissionState::Granted); // assert no privilege escalation let parser = TestPermissionDescriptorParser; assert!( perms .env .create_child_permissions( ChildUnaryPermissionArg::GrantedList(vec!["HOME_SUB".to_string()]), |value| parser.parse_env_descriptor(value).map(Some), ) .is_ok() ); assert!( perms .env .create_child_permissions( ChildUnaryPermissionArg::GrantedList(vec!["HOME*".to_string()]), |value| parser.parse_env_descriptor(value).map(Some), ) .is_err() ); assert!( perms .env .create_child_permissions( ChildUnaryPermissionArg::GrantedList(vec!["OUTSIDE".to_string()]), |value| parser.parse_env_descriptor(value).map(Some), ) .is_err() ); assert!( perms .env .create_child_permissions( // ok because this is a subset of HOME_* ChildUnaryPermissionArg::GrantedList(vec!["HOME_S*".to_string()]), |value| parser.parse_env_descriptor(value).map(Some), ) .is_ok() ); { let mut perms = Permissions::none_without_prompt(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_unary( Some(Vec::from([ EnvDescriptor::new(Cow::Borrowed("PREFIX_ALLOWED*")), EnvDescriptor::new(Cow::Borrowed("PREFIX_EXPLICIT_ALLOWED")), ])), Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("PREFIX*"))])), false, ) }; assert_eq!( perms.env.query(Some("PREFIX_TEST")), PermissionState::Denied ); assert_eq!( perms.env.query(Some("PREFIX_ALLOWED_TEST")), PermissionState::Granted ); assert_eq!( perms.env.query(Some("PREFIX_EXPLICIT_ALLOWED")), PermissionState::Granted ); } } #[test] fn test_env_ignore() { set_prompter(Box::new(TestPrompter)); let _prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); { let mut perms = Permissions::none_without_prompt(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_unary_with_ignore( Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("ALLOWED_*"))])), Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("DENIED_*"))])), Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("IGNORED_*"))])), false, ) }; assert_eq!( perms.env.query(Some("ALLOWED_TEST")), PermissionState::Granted ); assert_eq!( perms.env.query(Some("IGNORED_TEST")), PermissionState::Ignored ); assert_eq!( perms.env.query(Some("DENIED_TEST")), PermissionState::Denied ); } { let mut perms = Permissions::none_without_prompt(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_unary_with_ignore( Some(Vec::from([EnvDescriptor::new(Cow::Borrowed( "PREFIX_ALLOWED*", ))])), Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("PREFIX*"))])), Some(Vec::from([EnvDescriptor::new(Cow::Borrowed( "PREFIX_IGNORED*", ))])), false, ) }; assert_eq!( perms.env.query(Some("PREFIX_TEST")), PermissionState::Denied ); assert_eq!( perms.env.query(Some("PREFIX_IGNORED_TEST")), PermissionState::Ignored ); assert_eq!( perms.env.query(Some("PREFIX_ALLOWED_TEST")), PermissionState::Granted ); } } #[test] fn test_read_ignore() { set_prompter(Box::new(TestPrompter)); let _prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); let parser = TestPermissionDescriptorParser; { let mut perms = Permissions::none_without_prompt(); perms.read = UnaryPermission { granted_global: false, ..Permissions::new_unary_with_ignore( Some(Vec::from([ReadDescriptor( parser.join_path_with_root("allowed"), )])), Some(Vec::from([ReadDescriptor( parser.join_path_with_root("denied"), )])), Some(Vec::from([ReadDescriptor( parser.join_path_with_root("ignored"), )])), false, ) }; let allowed_query = parser .parse_path_query(Cow::Borrowed(Path::new("/allowed"))) .unwrap() .into_read(); assert_eq!( perms.read.query(Some(&allowed_query)), PermissionState::Granted ); let ignored_query = parser .parse_path_query(Cow::Borrowed(Path::new("/ignored"))) .unwrap() .into_read(); assert_eq!( perms.read.query(Some(&ignored_query)), PermissionState::Ignored ); let denied_query = parser .parse_path_query(Cow::Borrowed(Path::new("/denied"))) .unwrap() .into_read(); assert_eq!( perms.read.query(Some(&denied_query)), PermissionState::Denied ); } { let mut perms = Permissions::none_without_prompt(); perms.read = UnaryPermission { granted_global: false, ..Permissions::new_unary_with_ignore( Some(Vec::from([ReadDescriptor( parser.join_path_with_root("prefix/allowed"), )])), Some(Vec::from([ReadDescriptor( parser.join_path_with_root("prefix"), )])), Some(Vec::from([ReadDescriptor( parser.join_path_with_root("prefix/ignored"), )])), false, ) }; let denied_query = parser .parse_path_query(Cow::Borrowed(Path::new("/prefix/test"))) .unwrap() .into_read(); assert_eq!( perms.read.query(Some(&denied_query)), PermissionState::Denied ); let ignored_query = parser .parse_path_query(Cow::Borrowed(Path::new("/prefix/ignored/test"))) .unwrap() .into_read(); assert_eq!( perms.read.query(Some(&ignored_query)), PermissionState::Ignored ); let allowed_query = parser .parse_path_query(Cow::Borrowed(Path::new("/prefix/allowed/test"))) .unwrap() .into_read(); assert_eq!( perms.read.query(Some(&allowed_query)), PermissionState::Granted ); } } #[test] fn test_check_partial_denied() { let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_write: Some(vec![]), deny_write: Some(svec!["/foo/bar"]), ..Default::default() }, ) .unwrap(); let write_query = parser .parse_path_query(Cow::Borrowed(Path::new("/foo"))) .unwrap() .into_write(); perms.write.check_partial(&write_query, None).unwrap(); assert!(perms.write.check(&write_query, None).is_err()); } // Regression test for https://github.com/denoland/deno/issues/27622. // Querying a path that is an ancestor of a denied path must succeed for // single-path read/write operations (`check_partial`), even though the // strict `check` continues to reject it. #[test] fn test_check_partial_ancestor_of_deny() { let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), deny_read: Some(svec!["/mnt"]), allow_write: Some(vec![]), deny_write: Some(svec!["/foo/bar"]), ..Default::default() }, ) .unwrap(); let root_read = parser .parse_path_query(Cow::Borrowed(Path::new("/"))) .unwrap() .into_read(); perms.read.check_partial(&root_read, None).unwrap(); assert!(perms.read.check(&root_read, None).is_err()); let foo_write = parser .parse_path_query(Cow::Borrowed(Path::new("/foo"))) .unwrap() .into_write(); perms.write.check_partial(&foo_write, None).unwrap(); assert!(perms.write.check(&foo_write, None).is_err()); // The actually-denied path is still denied under partial semantics. let mnt_read = parser .parse_path_query(Cow::Borrowed(Path::new("/mnt"))) .unwrap() .into_read(); assert!(perms.read.check_partial(&mnt_read, None).is_err()); let mnt_sub_read = parser .parse_path_query(Cow::Borrowed(Path::new("/mnt/sub"))) .unwrap() .into_read(); assert!(perms.read.check_partial(&mnt_sub_read, None).is_err()); } // Recursive remove must keep strict deny semantics: `check_write` rejects an // ancestor of a denied path, while the partial checks used by single-path ops // (`check_write_partial`, `check_open`) allow it. Without this, a recursive // `Deno.remove("/foo", { recursive: true })` under `--deny-write=/foo/bar` // would delete the denied descendant. #[test] fn test_check_write_strict_for_recursive_remove() { let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_write: Some(vec![]), deny_write: Some(svec!["/foo/bar"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); // Strict write check (used by recursive remove) rejects the ancestor. assert!( perms .check_write(Cow::Borrowed(Path::new("/foo")), "Deno.removeSync()") .is_err(), "recursive remove of an ancestor of a denied path must be blocked" ); // Partial checks (used by non-recursive remove and other single-path ops) // allow the ancestor. perms .check_write_partial( Cow::Borrowed(Path::new("/foo")), "Deno.removeSync()", ) .unwrap(); perms .check_open( Cow::Borrowed(Path::new("/foo")), OpenAccessKind::WriteNoFollow, Some("api"), ) .unwrap(); // The denied path itself is rejected by every variant. assert!( perms .check_write(Cow::Borrowed(Path::new("/foo/bar")), "Deno.removeSync()") .is_err() ); assert!( perms .check_write_partial( Cow::Borrowed(Path::new("/foo/bar")), "Deno.removeSync()" ) .is_err() ); } #[test] fn test_check_allow_global_deny_global() { let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), deny_read: Some(vec![]), allow_write: Some(vec![]), deny_write: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(perms.read.check_all(None).is_err()); let read_query = parser .parse_path_query(Cow::Borrowed(Path::new("/foo"))) .unwrap() .into_read(); assert!(perms.read.check(&read_query, None).is_err()); assert!(perms.write.check_all(None).is_err()); let write_query = parser .parse_path_query(Cow::Borrowed(Path::new("/foo"))) .unwrap() .into_write(); assert!(perms.write.check(&write_query, None).is_err()); } #[test] fn test_net_fully_qualified_domain_name() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(svec!["allowed.domain", "1.1.1.1"]), deny_net: Some(svec!["denied.domain", "2.2.2.2"]), ..Default::default() }, ) .unwrap(); let mut perms = PermissionsContainer::new(Arc::new(parser), perms); let cases = [ ("allowed.domain.", true), ("1.1.1.1", true), ("denied.domain.", false), ("2.2.2.2", false), ]; for (host, is_ok) in cases { assert_eq!(perms.check_net(&(host, None), "api").is_ok(), is_ok); } } #[test] fn test_net_ip_subnet() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(svec!["10.0.0.0/24"]), deny_net: Some(svec!["192.168.1.0/24", "172.16.0.0/12"]), ..Default::default() }, ) .unwrap(); let mut perms = PermissionsContainer::new(Arc::new(parser), perms); let cases = [ ("10.0.0.1", true), ("192.168.1.1", false), ("172.16.0.1", false), ]; for (host, is_ok) in cases { assert_eq!(perms.check_net(&(host, None), "api").is_ok(), is_ok); } } #[test] fn test_net_ipv4_mapped_ipv6() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; // Deny an IPv4 address, verify IPv4-mapped IPv6 form is also denied let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(vec![]), deny_net: Some(svec!["127.0.0.1"]), ..Default::default() }, ) .unwrap(); let mut perms = PermissionsContainer::new(Arc::new(parser), perms); // Direct IPv4 is denied assert!(perms.check_net(&("127.0.0.1", None), "api").is_err()); // IPv4-mapped IPv6 form must also be denied assert!(perms.check_net(&("::ffff:127.0.0.1", None), "api").is_err()); // Regular IPv6 loopback is a different address, should be allowed assert!(perms.check_net(&("::1", None), "api").is_ok()); // Other IPv4 addresses should be allowed assert!(perms.check_net(&("192.168.1.1", None), "api").is_ok()); // Allow an IPv4-mapped IPv6, verify it's accessible via IPv4 too let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(svec!["[::ffff:10.0.0.1]"]), ..Default::default() }, ) .unwrap(); let mut perms = PermissionsContainer::new(Arc::new(parser), perms); assert!(perms.check_net(&("10.0.0.1", None), "api").is_ok()); assert!(perms.check_net(&("::ffff:10.0.0.1", None), "api").is_ok()); // Port-qualified: deny 127.0.0.1:8080, verify IPv4-mapped form // with port is also denied (exercises the SocketAddr parse path) let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(vec![]), deny_net: Some(svec!["127.0.0.1:8080"]), ..Default::default() }, ) .unwrap(); let mut perms = PermissionsContainer::new(Arc::new(parser), perms); assert!(perms.check_net(&("127.0.0.1", Some(8080)), "api").is_err()); assert!( perms .check_net(&("::ffff:127.0.0.1", Some(8080)), "api") .is_err() ); // Different port should be allowed assert!( perms .check_net(&("::ffff:127.0.0.1", Some(9090)), "api") .is_ok() ); } #[test] fn test_deserialize_child_permissions_arg() { set_prompter(Box::new(TestPrompter)); assert_eq!( ChildPermissionsArg::inherit(), ChildPermissionsArg { env: ChildUnaryPermissionArg::Inherit, net: ChildUnaryPermissionArg::Inherit, ffi: ChildUnaryPermissionArg::Inherit, import: ChildUnaryPermissionArg::Inherit, read: ChildUnaryPermissionArg::Inherit, run: ChildUnaryPermissionArg::Inherit, sys: ChildUnaryPermissionArg::Inherit, write: ChildUnaryPermissionArg::Inherit, } ); assert_eq!( ChildPermissionsArg::none(), ChildPermissionsArg { env: ChildUnaryPermissionArg::NotGranted, net: ChildUnaryPermissionArg::NotGranted, ffi: ChildUnaryPermissionArg::NotGranted, import: ChildUnaryPermissionArg::NotGranted, read: ChildUnaryPermissionArg::NotGranted, run: ChildUnaryPermissionArg::NotGranted, sys: ChildUnaryPermissionArg::NotGranted, write: ChildUnaryPermissionArg::NotGranted, } ); assert_eq!( serde_json::from_value::<ChildPermissionsArg>(json!("inherit")).unwrap(), ChildPermissionsArg::inherit() ); assert_eq!( serde_json::from_value::<ChildPermissionsArg>(json!("none")).unwrap(), ChildPermissionsArg::none() ); assert_eq!( serde_json::from_value::<ChildPermissionsArg>(json!({})).unwrap(), ChildPermissionsArg::none() ); assert_eq!( serde_json::from_value::<ChildPermissionsArg>(json!({ "env": ["foo", "bar"], })) .unwrap(), ChildPermissionsArg { env: ChildUnaryPermissionArg::GrantedList(svec!["foo", "bar"]), ..ChildPermissionsArg::none() } ); assert_eq!( serde_json::from_value::<ChildPermissionsArg>(json!({ "env": true, "net": true, "ffi": true, "import": true, "read": true, "run": true, "sys": true, "write": true, })) .unwrap(), ChildPermissionsArg { env: ChildUnaryPermissionArg::Granted, net: ChildUnaryPermissionArg::Granted, ffi: ChildUnaryPermissionArg::Granted, import: ChildUnaryPermissionArg::Granted, read: ChildUnaryPermissionArg::Granted, run: ChildUnaryPermissionArg::Granted, sys: ChildUnaryPermissionArg::Granted, write: ChildUnaryPermissionArg::Granted, } ); assert_eq!( serde_json::from_value::<ChildPermissionsArg>(json!({ "env": false, "net": false, "ffi": false, "import": false, "read": false, "run": false, "sys": false, "write": false, })) .unwrap(), ChildPermissionsArg { env: ChildUnaryPermissionArg::NotGranted, net: ChildUnaryPermissionArg::NotGranted, ffi: ChildUnaryPermissionArg::NotGranted, import: ChildUnaryPermissionArg::NotGranted, read: ChildUnaryPermissionArg::NotGranted, run: ChildUnaryPermissionArg::NotGranted, sys: ChildUnaryPermissionArg::NotGranted, write: ChildUnaryPermissionArg::NotGranted, } ); assert_eq!( serde_json::from_value::<ChildPermissionsArg>(json!({ "env": ["foo", "bar"], "net": ["foo", "bar:8000"], "ffi": ["foo", "file:///bar/baz"], "import": ["example.com"], "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" ]), import: ChildUnaryPermissionArg::GrantedList(svec!["example.com"]), 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" ]), } ); } #[test] fn test_create_child_permissions() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let main_perms = Permissions::from_options( &parser, &PermissionsOptions { allow_env: Some(vec![]), allow_net: Some(svec!["*.foo", "bar"]), ..Default::default() }, ) .unwrap(); let main_perms = PermissionsContainer::new(Arc::new(parser), main_perms); assert_eq!( main_perms .create_child_permissions(ChildPermissionsArg { env: ChildUnaryPermissionArg::Inherit, net: ChildUnaryPermissionArg::GrantedList(svec!["foo"]), ffi: ChildUnaryPermissionArg::NotGranted, ..ChildPermissionsArg::none() }) .unwrap() .inner .lock() .clone(), Permissions { env: Permissions::new_unary(Some(Vec::new()), None, false), net: Permissions::new_unary( Some(Vec::from([NetDescriptor::parse_for_list("foo").unwrap()])), None, false ), ..Permissions::none_without_prompt() } ); assert!( main_perms .create_child_permissions(ChildPermissionsArg { net: ChildUnaryPermissionArg::Granted, ..ChildPermissionsArg::none() }) .is_err() ); assert!( main_perms .create_child_permissions(ChildPermissionsArg { net: ChildUnaryPermissionArg::GrantedList(svec!["foo", "bar", "baz"]), ..ChildPermissionsArg::none() }) .is_err() ); assert!( main_perms .create_child_permissions(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 main_perms = Permissions::from_options( &TestPermissionDescriptorParser, &PermissionsOptions { prompt: true, ..Default::default() }, ) .unwrap(); let main_perms = PermissionsContainer::new( Arc::new(TestPermissionDescriptorParser), main_perms, ); prompt_value.set(true); let worker_perms = main_perms .create_child_permissions(ChildPermissionsArg { read: ChildUnaryPermissionArg::Granted, run: ChildUnaryPermissionArg::GrantedList(svec!["foo", "bar"]), ..ChildPermissionsArg::none() }) .unwrap(); assert_eq!( main_perms.inner.lock().clone(), worker_perms.inner.lock().clone() ); assert_eq!( main_perms .inner .lock() .run .descriptors .iter() .filter_map(|d| match d { UnaryPermissionDesc::Granted(d) => Some(d.clone()), _ => None, }) .collect::<Vec<_>>(), Vec::from([ AllowRunDescriptor(PathDescriptor::new_known_absolute(Cow::Owned( PathBuf::from("/bar") ))), AllowRunDescriptor(PathDescriptor::new_known_absolute(Cow::Owned( PathBuf::from("/foo") ))), ]) ); } #[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 parser = TestPermissionDescriptorParser; let main_perms = Permissions::from_options( &parser, &PermissionsOptions { prompt: true, ..Default::default() }, ) .unwrap(); let main_perms = PermissionsContainer::new(Arc::new(parser.clone()), main_perms); prompt_value.set(false); assert!( main_perms .inner .lock() .write .check( &parser .parse_path_query(Cow::Borrowed(Path::new("foo"))) .unwrap() .into_write(), None ) .is_err() ); let worker_perms = main_perms .create_child_permissions(ChildPermissionsArg::none()) .unwrap(); assert_eq!( worker_perms .inner .lock() .write .descriptors .iter() .filter_map(|d| match d { UnaryPermissionDesc::FlagDenied(d) => Some(d.clone()), _ => None, }) .collect::<Vec<_>>(), main_perms .inner .lock() .write .descriptors .iter() .filter_map(|d| match d { UnaryPermissionDesc::FlagDenied(d) => Some(d.clone()), _ => None, }) .collect::<Vec<_>>() ); } #[test] fn test_host_parse_for_query() { let hosts = &[ ("deno.land", Some(Host::Fqdn(fqdn!("deno.land")))), ("DENO.land", Some(Host::Fqdn(fqdn!("deno.land")))), ("deno.land.", Some(Host::Fqdn(fqdn!("deno.land")))), ( "1.1.1.1", Some(Host::Ip(IpAddr::V4(Ipv4Addr::new(1, 1, 1, 1)))), ), ( "::1", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1)))), ), ( "[::1]", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1)))), ), ("[::1", None), ("::1]", None), ("deno. land", None), ("1. 1.1.1", None), ("1.1.1.1.", None), ("1::1.", None), ("deno.land.", Some(Host::Fqdn(fqdn!("deno.land")))), (".deno.land", None), ("*.deno.land", None), // IPv4-mapped IPv6 addresses are normalized to IPv4 ( "::ffff:1.1.1.1", Some(Host::Ip(IpAddr::V4(Ipv4Addr::new(1, 1, 1, 1)))), ), ( "[::ffff:127.0.0.1]", Some(Host::Ip(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)))), ), // IPv6 addresses with zone indices ( "fe80::1%18", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new( 0xfe80, 0, 0, 0, 0, 0, 0, 1, )))), ), ( "[fe80::1%18]", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new( 0xfe80, 0, 0, 0, 0, 0, 0, 1, )))), ), ( "fe80::1%eth0", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new( 0xfe80, 0, 0, 0, 0, 0, 0, 1, )))), ), ( "[fe80::1%eth0]", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new( 0xfe80, 0, 0, 0, 0, 0, 0, 1, )))), ), ]; for (host_str, expected) in hosts { assert_eq!( Host::parse_for_query(host_str).ok(), *expected, "{host_str}" ); } } #[test] fn test_host_parse_for_list() { let hosts = &[ ("deno.land", Some(Host::Fqdn(fqdn!("deno.land")))), ( "*.deno.land", Some(Host::FqdnWithSubdomainWildcard(fqdn!("deno.land"))), ), ("DENO.land", Some(Host::Fqdn(fqdn!("deno.land")))), ("deno.land.", Some(Host::Fqdn(fqdn!("deno.land")))), ( "1.1.1.1", Some(Host::Ip(IpAddr::V4(Ipv4Addr::new(1, 1, 1, 1)))), ), ( "::1", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1)))), ), ( "[::1]", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1)))), ), ("[::1", None), ("::1]", None), ("deno. land", None), ("1. 1.1.1", None), ("1.1.1.1.", None), ("1::1.", None), ("deno.land.", Some(Host::Fqdn(fqdn!("deno.land")))), (".deno.land", None), // IPv4-mapped IPv6 addresses are normalized to IPv4 ( "::ffff:1.1.1.1", Some(Host::Ip(IpAddr::V4(Ipv4Addr::new(1, 1, 1, 1)))), ), ( "[::ffff:127.0.0.1]", Some(Host::Ip(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)))), ), // IPv6 addresses with zone indices ( "fe80::1%18", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new( 0xfe80, 0, 0, 0, 0, 0, 0, 1, )))), ), ( "[fe80::1%18]", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new( 0xfe80, 0, 0, 0, 0, 0, 0, 1, )))), ), ( "fe80::1%eth0", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new( 0xfe80, 0, 0, 0, 0, 0, 0, 1, )))), ), ( "[fe80::1%eth0]", Some(Host::Ip(IpAddr::V6(Ipv6Addr::new( 0xfe80, 0, 0, 0, 0, 0, 0, 1, )))), ), ]; for (host_str, expected) in hosts { assert_eq!(Host::parse_for_list(host_str).ok(), *expected, "{host_str}"); } } #[test] fn test_net_descriptor_parse_for_query() { let cases = &[ ( "deno.land", Some(NetDescriptor(Host::Fqdn(fqdn!("deno.land")), None)), ), ( "DENO.land", Some(NetDescriptor(Host::Fqdn(fqdn!("deno.land")), None)), ), ( "deno.land:8000", Some(NetDescriptor(Host::Fqdn(fqdn!("deno.land")), Some(8000))), ), ("*.deno.land", None), ("deno.land:", None), ("deno.land:a", None), ("deno. land:a", None), ("deno.land.: a", None), ( "1.1.1.1", Some(NetDescriptor( Host::Ip(IpAddr::V4(Ipv4Addr::new(1, 1, 1, 1))), None, )), ), ("1.1.1.1.", None), ("1.1.1.1..", None), ( "1.1.1.1:8000", Some(NetDescriptor( Host::Ip(IpAddr::V4(Ipv4Addr::new(1, 1, 1, 1))), Some(8000), )), ), ("::", None), (":::80", None), ("::80", None), ( "[::]", Some(NetDescriptor( Host::Ip(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 0))), None, )), ), ("[::1", None), ("::1]", None), ("::1]", None), ("[::1]:", None), ("[::1]:a", None), ( "[::1]:443", Some(NetDescriptor( Host::Ip(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1))), Some(443), )), ), ("", None), ("deno.land..", None), // IPv6 addresses with zone indices (bracketed with port) ( "[fe80::1%18]:1234", Some(NetDescriptor( Host::Ip(IpAddr::V6(Ipv6Addr::new(0xfe80, 0, 0, 0, 0, 0, 0, 1))), Some(1234), )), ), ( "[fe80::1%eth0]:8080", Some(NetDescriptor( Host::Ip(IpAddr::V6(Ipv6Addr::new(0xfe80, 0, 0, 0, 0, 0, 0, 1))), Some(8080), )), ), ]; for (input, expected) in cases { assert_eq!( NetDescriptor::parse_for_query(input).ok(), *expected, "'{input}'" ); } } #[test] fn test_net_descriptor_parse_for_list() { let cases = &[ ( "deno.land", Some(NetDescriptor(Host::Fqdn(fqdn!("deno.land")), None)), ), ( "DENO.land", Some(NetDescriptor(Host::Fqdn(fqdn!("deno.land")), None)), ), ( "deno.land:8000", Some(NetDescriptor(Host::Fqdn(fqdn!("deno.land")), Some(8000))), ), ( "*.deno.land", Some(NetDescriptor( Host::FqdnWithSubdomainWildcard(fqdn!("deno.land")), None, )), ), ("deno.land:", None), ("deno.land:a", None), ("deno. land:a", None), ("deno.land.: a", None), ( "1.1.1.1", Some(NetDescriptor( Host::Ip(IpAddr::V4(Ipv4Addr::new(1, 1, 1, 1))), None, )), ), ("1.1.1.1.", None), ("1.1.1.1..", None), ( "1.1.1.1:8000", Some(NetDescriptor( Host::Ip(IpAddr::V4(Ipv4Addr::new(1, 1, 1, 1))), Some(8000), )), ), ("::", None), (":::80", None), ("::80", None), ( "[::]", Some(NetDescriptor( Host::Ip(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 0))), None, )), ), ("[::1", None), ("::1]", None), ("::1]", None), ("[::1]:", None), ("[::1]:a", None), ( "[::1]:443", Some(NetDescriptor( Host::Ip(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1))), Some(443), )), ), ("", None), ("deno.land..", None), // IPv6 addresses with zone indices (bracketed with port) ( "[fe80::1%18]:1234", Some(NetDescriptor( Host::Ip(IpAddr::V6(Ipv6Addr::new(0xfe80, 0, 0, 0, 0, 0, 0, 1))), Some(1234), )), ), ( "[fe80::1%eth0]:8080", Some(NetDescriptor( Host::Ip(IpAddr::V6(Ipv6Addr::new(0xfe80, 0, 0, 0, 0, 0, 0, 1))), Some(8080), )), ), // Unix socket rules are lexically normalized at parse time (`.`/`..` // removed, symlinks not resolved) to match the call-side path, which // goes through the same normalization in `check_open`. #[cfg(unix)] ( "unix:/var/run/docker.sock", Some(NetDescriptor( Host::UnixSocket(PathBuf::from("/var/run/docker.sock")), None, )), ), #[cfg(unix)] ( "unix:/var/run/../run/./docker.sock", Some(NetDescriptor( Host::UnixSocket(PathBuf::from("/var/run/docker.sock")), None, )), ), ("unix:", None), ("unix:relative.sock", None), ]; for (input, expected) in cases { assert_eq!( NetDescriptor::parse_for_list(input).ok(), *expected, "'{input}'" ); } } #[test] fn test_denies_run_name() { let cases = [ #[cfg(windows)] ("deno", "C:\\deno.exe", true), #[cfg(windows)] ("deno", "C:\\sub\\deno.cmd", true), #[cfg(windows)] ("deno", "C:\\sub\\DeNO.cmd", true), #[cfg(windows)] ("DEno", "C:\\sub\\deno.cmd", true), #[cfg(windows)] ("deno", "C:\\other\\sub\\deno.batch", true), #[cfg(windows)] ("deno", "C:\\other\\sub\\deno", true), #[cfg(windows)] ("denort", "C:\\other\\sub\\deno.exe", false), ("deno", "/home/test/deno", true), ("deno", "/home/test/denot", false), ]; for (name, cmd_path, denies) in cases { assert_eq!( denies_run_name(name, Path::new(cmd_path)), denies, "{} {}", name, cmd_path ); } } #[test] fn test_env_check_all() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_env: Some(vec![]), deny_env: Some(svec!["FOO"]), ..Default::default() }, ) .unwrap(); assert!(perms.env.check_all().is_err()); } #[test] fn test_env_sorting() { let mut items = vec![ EnvDescriptor::new("TEST".into()), EnvDescriptor::new("TEST*".into()), EnvDescriptor::new("TEST2*".into()), EnvDescriptor::new("TEST_TEST".into()), ]; items.sort_by(|a, b| a.cmp_allow(b)); assert_eq!( items .into_iter() .map(|i| match i { EnvDescriptor::Name(name) => name.inner, EnvDescriptor::PrefixPattern(name) => format!("{}*", name.inner), }) .collect::<Vec<_>>(), vec![ "TEST".to_string(), "TEST_TEST".to_string(), "TEST2*".to_string(), "TEST*".to_string(), ] ) } #[test] fn test_format_display_name() { assert_eq!(format_display_name(Cow::Borrowed("123")), "\"123\""); assert_eq!(format_display_name(Cow::Borrowed("<other>")), "<other>"); } #[test] fn test_path_ordering_multiple_allows_and_denies() { let parser = TestPermissionDescriptorParser; let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; // Test multiple overlapping allows and denies let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo/bar/baz", "/foo/qux"]), deny_read: Some(svec!["/foo/bar", "/foo"]), ..Default::default() }, ) .unwrap(); // Most specific allow wins over less specific denies assert_eq!( perms.read.query(Some(&read_query("/foo/bar/baz"))), PermissionState::Granted ); assert_eq!( perms.read.query(Some(&read_query("/foo/bar/baz/file.txt"))), PermissionState::Granted ); // Deny /foo/bar blocks this assert_eq!( perms.read.query(Some(&read_query("/foo/bar"))), PermissionState::Denied ); assert_eq!( perms.read.query(Some(&read_query("/foo/bar/other"))), PermissionState::Denied ); // Allow /foo/qux works despite deny /foo assert_eq!( perms.read.query(Some(&read_query("/foo/qux"))), PermissionState::Granted ); assert_eq!( perms.read.query(Some(&read_query("/foo/qux/file.txt"))), PermissionState::Granted ); // Deny /foo blocks everything else under /foo assert_eq!( perms.read.query(Some(&read_query("/foo"))), PermissionState::Denied ); assert_eq!( perms.read.query(Some(&read_query("/foo/other"))), PermissionState::Denied ); // Unrelated path is prompt assert_eq!( perms.read.query(Some(&read_query("/bar"))), PermissionState::Prompt ); } #[test] fn test_env_ordering_multiple_patterns() { // Test multiple overlapping env patterns let mut perms = Permissions::none_without_prompt(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_unary( Some(Vec::from([ EnvDescriptor::new(Cow::Borrowed("NODE_ENV")), EnvDescriptor::new(Cow::Borrowed("NODE_DEBUG_*")), EnvDescriptor::new(Cow::Borrowed("DENO_*")), ])), Some(Vec::from([ EnvDescriptor::new(Cow::Borrowed("NODE_*")), EnvDescriptor::new(Cow::Borrowed("DENO_SECRET")), ])), true, ) }; // Exact match NODE_ENV beats pattern NODE_* assert_eq!(perms.env.query(Some("NODE_ENV")), PermissionState::Granted); // More specific pattern NODE_DEBUG_* beats less specific NODE_* assert_eq!( perms.env.query(Some("NODE_DEBUG_NATIVE")), PermissionState::Granted ); // NODE_* deny blocks other NODE_ vars assert_eq!(perms.env.query(Some("NODE_PATH")), PermissionState::Denied); assert_eq!( perms.env.query(Some("NODE_OPTIONS")), PermissionState::Denied ); // DENO_* allow works for most vars assert_eq!(perms.env.query(Some("DENO_DIR")), PermissionState::Granted); // But DENO_SECRET exact deny overrides DENO_* allow assert_eq!( perms.env.query(Some("DENO_SECRET")), PermissionState::Denied ); assert_eq!(perms.env.query(Some("PATH")), PermissionState::Prompt); } #[test] fn test_env_ordering_nested_patterns() { // Test increasingly specific patterns let mut perms = Permissions::none_without_prompt(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_unary( Some(Vec::from([ EnvDescriptor::new(Cow::Borrowed("PREFIX_SUBPREFIX_ALLOWED*")), EnvDescriptor::new(Cow::Borrowed("PREFIX_ALLOWED*")), ])), Some(Vec::from([ EnvDescriptor::new(Cow::Borrowed("PREFIX_SUBPREFIX*")), EnvDescriptor::new(Cow::Borrowed("PREFIX*")), ])), false, ) }; // Most specific allow pattern wins assert_eq!( perms.env.query(Some("PREFIX_SUBPREFIX_ALLOWED_VAR")), PermissionState::Granted ); // Less specific deny blocks this assert_eq!( perms.env.query(Some("PREFIX_SUBPREFIX_OTHER")), PermissionState::Denied ); // Medium specific allow wins assert_eq!( perms.env.query(Some("PREFIX_ALLOWED_VAR")), PermissionState::Granted ); // Least specific deny blocks everything else assert_eq!( perms.env.query(Some("PREFIX_OTHER")), PermissionState::Denied ); } #[test] fn test_net_ordering_with_ports() { let parser = TestPermissionDescriptorParser; // Test that host:port combinations are properly ordered let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(svec!["example.com:8080", "example.com:443"]), deny_net: Some(svec!["example.com"]), ..Default::default() }, ) .unwrap(); assert_eq!( perms.net.query(Some(&NetDescriptor( Host::must_parse("example.com"), Some(8080) ))), PermissionState::Granted ); assert_eq!( perms.net.query(Some(&NetDescriptor( Host::must_parse("example.com"), Some(443) ))), PermissionState::Granted ); assert_eq!( perms.net.query(Some(&NetDescriptor( Host::must_parse("example.com"), Some(20) ))), PermissionState::Denied ); assert_eq!( perms .net .query(Some(&NetDescriptor(Host::must_parse("example.com"), None))), PermissionState::Denied ); } #[test] fn test_path_ordering_same_specificity() { let parser = TestPermissionDescriptorParser; let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; // When allow and deny have the same path, deny should win let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo/bar"]), deny_read: Some(svec!["/foo/bar"]), ..Default::default() }, ) .unwrap(); // Deny should take precedence when specificity is equal assert_eq!( perms.read.query(Some(&read_query("/foo/bar"))), PermissionState::Denied ); assert_eq!( perms.read.query(Some(&read_query("/foo/bar/file.txt"))), PermissionState::Denied ); } #[test] fn test_env_ordering_same_specificity() { // When allow and deny have the same env var, deny should win let mut perms = Permissions::none_without_prompt(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_unary( Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("TEST_VAR"))])), Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("TEST_VAR"))])), false, ) }; // Deny should take precedence assert_eq!(perms.env.query(Some("TEST_VAR")), PermissionState::Denied); } #[test] fn test_env_ordering_pattern_same_specificity() { // When allow and deny have the same pattern, deny should win let mut perms = Permissions::none_without_prompt(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_unary( Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("TEST_*"))])), Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("TEST_*"))])), false, ) }; // Deny should take precedence assert_eq!(perms.env.query(Some("TEST_VAR")), PermissionState::Denied); assert_eq!( perms.env.query(Some("TEST_ANOTHER")), PermissionState::Denied ); } #[test] fn test_path_ordering_sibling_directories() { let parser = TestPermissionDescriptorParser; let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; // Test sibling directories (unrelated paths) let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo/a"]), deny_read: Some(svec!["/foo/b"]), ..Default::default() }, ) .unwrap(); assert_eq!( perms.read.query(Some(&read_query("/foo/a"))), PermissionState::Granted ); assert_eq!( perms.read.query(Some(&read_query("/foo/a/file.txt"))), PermissionState::Granted ); assert_eq!( perms.read.query(Some(&read_query("/foo/b"))), PermissionState::Denied ); assert_eq!( perms.read.query(Some(&read_query("/foo/b/file.txt"))), PermissionState::Denied ); assert_eq!( perms.read.query(Some(&read_query("/foo/c"))), PermissionState::Prompt ); } #[test] fn test_write_ordering_deep_nesting() { let parser = TestPermissionDescriptorParser; let write_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_write() }; // Test deeply nested paths with multiple levels let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_write: Some(svec!["/a/b/c/d/e/f"]), deny_write: Some(svec!["/a/b/c", "/a/b/c/d/e"]), ..Default::default() }, ) .unwrap(); // Most specific allow wins assert_eq!( perms.write.query(Some(&write_query("/a/b/c/d/e/f"))), PermissionState::Granted ); assert_eq!( perms.write.query(Some(&write_query("/a/b/c/d/e/f/g"))), PermissionState::Granted ); // Deny at /a/b/c/d/e blocks this level assert_eq!( perms.write.query(Some(&write_query("/a/b/c/d/e"))), PermissionState::Denied ); assert_eq!( perms.write.query(Some(&write_query("/a/b/c/d/e/other"))), PermissionState::Denied ); // Deny at /a/b/c blocks broader access assert_eq!( perms.write.query(Some(&write_query("/a/b/c"))), PermissionState::Denied ); assert_eq!( perms.write.query(Some(&write_query("/a/b/c/d"))), PermissionState::Denied ); // Parent paths are prompt assert_eq!( perms.write.query(Some(&write_query("/a/b"))), PermissionState::Prompt ); } #[test] fn test_ffi_ordering_similar_paths() { let parser = TestPermissionDescriptorParser; let ffi_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_ffi() }; // Test paths that share common prefixes but aren't ancestors let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_ffi: Some(svec!["/usr/lib/custom", "/usr/lib64"]), deny_ffi: Some(svec!["/usr/lib"]), ..Default::default() }, ) .unwrap(); // Allow should work for specific paths assert_eq!( perms.ffi.query(Some(&ffi_query("/usr/lib/custom"))), PermissionState::Granted ); assert_eq!( perms .ffi .query(Some(&ffi_query("/usr/lib/custom/mylib.so"))), PermissionState::Granted ); // /usr/lib64 is not under /usr/lib, so should be prompt (not denied) assert_eq!( perms.ffi.query(Some(&ffi_query("/usr/lib64"))), PermissionState::Granted ); // Deny blocks /usr/lib assert_eq!( perms.ffi.query(Some(&ffi_query("/usr/lib"))), PermissionState::Denied ); assert_eq!( perms.ffi.query(Some(&ffi_query("/usr/lib/other.so"))), PermissionState::Denied ); } #[test] fn test_env_ordering_empty_prefix_pattern() { // Test edge case: what if someone tries a pattern that matches everything? let mut perms = Permissions::none_without_prompt(); perms.env = UnaryPermission { granted_global: false, ..Permissions::new_unary( Some(Vec::from([EnvDescriptor::new(Cow::Borrowed( "ALLOWED_VAR", ))])), Some(Vec::from([EnvDescriptor::new(Cow::Borrowed("ALLOWED_*"))])), false, ) }; // Exact name ALLOWED_VAR should win over pattern ALLOWED_* assert_eq!( perms.env.query(Some("ALLOWED_VAR")), PermissionState::Granted ); // Pattern ALLOWED_* should deny others assert_eq!( perms.env.query(Some("ALLOWED_OTHER")), PermissionState::Denied ); } #[test] fn test_cmp_read_descriptors() { let parser = TestPermissionDescriptorParser; let parse_granted = |text: &str| { UnaryPermissionDesc::Granted(parser.parse_read_descriptor(text).unwrap()) }; let parse_flag_denied = |text: &str| { UnaryPermissionDesc::FlagDenied::<ReadDescriptor>( parser.parse_read_descriptor(text).unwrap(), ) }; let parse_prompt_denied = |text: &str| { UnaryPermissionDesc::PromptDenied::<ReadDescriptor>( parser.parse_read_descriptor(text).unwrap(), ) }; // Test path hierarchy: child < parent for granted check_comparison( &parse_granted("/foo/bar"), &parse_granted("/foo"), Ordering::Less, ); check_comparison( &parse_granted("/foo/bar/baz"), &parse_granted("/foo/bar"), Ordering::Less, ); check_comparison( &parse_granted("/a/b/c/d"), &parse_granted("/a"), Ordering::Less, ); // Test path hierarchy: child < parent for flag denied check_comparison( &parse_flag_denied("/foo/bar"), &parse_flag_denied("/foo"), Ordering::Less, ); check_comparison( &parse_flag_denied("/foo/bar/baz"), &parse_flag_denied("/foo/bar"), Ordering::Less, ); // Test path hierarchy: child < parent for prompt denied check_comparison( &parse_prompt_denied("/foo/bar"), &parse_prompt_denied("/foo"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/foo/bar/baz"), &parse_prompt_denied("/foo/bar"), Ordering::Less, ); // Test equal paths with same type check_comparison( &parse_granted("/foo/bar"), &parse_granted("/foo/bar"), Ordering::Equal, ); check_comparison( &parse_flag_denied("/foo/bar"), &parse_flag_denied("/foo/bar"), Ordering::Equal, ); check_comparison( &parse_prompt_denied("/foo/bar"), &parse_prompt_denied("/foo/bar"), Ordering::Equal, ); // Test unrelated paths (lexicographic ordering) check_comparison( &parse_granted("/aaa"), &parse_granted("/bbb"), Ordering::Less, ); check_comparison( &parse_granted("/xyz"), &parse_granted("/abc"), Ordering::Greater, ); check_comparison( &parse_flag_denied("/aaa"), &parse_flag_denied("/zzz"), Ordering::Less, ); // Test different types with same path // FlagDenied < PromptDenied < Granted (by kind_precedence) check_comparison( &parse_flag_denied("/foo"), &parse_granted("/foo"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/foo"), &parse_granted("/foo"), Ordering::Less, ); check_comparison( &parse_flag_denied("/foo"), &parse_prompt_denied("/foo"), Ordering::Less, ); // Test different types with parent/child relationship check_comparison( &parse_granted("/foo/bar"), &parse_flag_denied("/foo"), Ordering::Less, ); check_comparison( &parse_granted("/foo"), &parse_flag_denied("/foo/bar"), Ordering::Greater, ); check_comparison( &parse_prompt_denied("/foo/bar"), &parse_granted("/foo"), Ordering::Less, ); // Test root vs subdirectories check_comparison( &parse_granted("/"), &parse_granted("/foo"), Ordering::Greater, ); check_comparison( &parse_flag_denied("/"), &parse_flag_denied("/foo"), Ordering::Greater, ); // Test deeply nested paths check_comparison( &parse_granted("/a/b/c/d/e/f"), &parse_granted("/a/b/c"), Ordering::Less, ); check_comparison( &parse_granted("/a/b/c"), &parse_granted("/a/b/d"), Ordering::Less, ); // Test paths with similar prefixes but different branches check_comparison( &parse_granted("/foo/bar"), &parse_granted("/foo/baz"), Ordering::Less, ); check_comparison( &parse_granted("/prefix123"), &parse_granted("/prefix456"), Ordering::Less, ); // Test two deny types with different descriptors (non-equal paths) check_comparison( &parse_flag_denied("/aaa"), &parse_prompt_denied("/bbb"), Ordering::Less, ); check_comparison( &parse_flag_denied("/xyz"), &parse_prompt_denied("/abc"), Ordering::Greater, ); check_comparison( &parse_prompt_denied("/foo/bar"), &parse_flag_denied("/foo/baz"), Ordering::Less, ); // Test transitivity: FlagDenied < PromptDenied < Granted with same path check_comparison( &parse_flag_denied("/test"), &parse_prompt_denied("/test"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/test"), &parse_granted("/test"), Ordering::Less, ); // Transitive: FlagDenied < Granted check_comparison( &parse_flag_denied("/test"), &parse_granted("/test"), Ordering::Less, ); // Test mixed types with sibling paths check_comparison( &parse_granted("/foo/bar"), &parse_prompt_denied("/foo/baz"), Ordering::Greater, ); check_comparison( &parse_flag_denied("/foo/aaa"), &parse_granted("/foo/zzz"), Ordering::Less, ); // Test PromptDenied(child) vs FlagDenied(parent) check_comparison( &parse_prompt_denied("/foo/bar/baz"), &parse_flag_denied("/foo"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/a/b/c"), &parse_flag_denied("/a/b"), Ordering::Less, ); } #[test] fn test_cmp_write_descriptors() { let parser = TestPermissionDescriptorParser; let parse_granted = |text: &str| { UnaryPermissionDesc::Granted(parser.parse_write_descriptor(text).unwrap()) }; let parse_flag_denied = |text: &str| { UnaryPermissionDesc::FlagDenied::<WriteDescriptor>( parser.parse_write_descriptor(text).unwrap(), ) }; let parse_prompt_denied = |text: &str| { UnaryPermissionDesc::PromptDenied::<WriteDescriptor>( parser.parse_write_descriptor(text).unwrap(), ) }; // Test path hierarchy: child < parent for granted check_comparison( &parse_granted("/foo/bar"), &parse_granted("/foo"), Ordering::Less, ); check_comparison( &parse_granted("/foo/bar/baz"), &parse_granted("/foo/bar"), Ordering::Less, ); check_comparison( &parse_granted("/a/b/c/d"), &parse_granted("/a"), Ordering::Less, ); // Test path hierarchy: child < parent for flag denied check_comparison( &parse_flag_denied("/foo/bar"), &parse_flag_denied("/foo"), Ordering::Less, ); check_comparison( &parse_flag_denied("/foo/bar/baz"), &parse_flag_denied("/foo/bar"), Ordering::Less, ); // Test path hierarchy: child < parent for prompt denied check_comparison( &parse_prompt_denied("/foo/bar"), &parse_prompt_denied("/foo"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/foo/bar/baz"), &parse_prompt_denied("/foo/bar"), Ordering::Less, ); // Test equal paths with same type check_comparison( &parse_granted("/foo/bar"), &parse_granted("/foo/bar"), Ordering::Equal, ); check_comparison( &parse_flag_denied("/foo/bar"), &parse_flag_denied("/foo/bar"), Ordering::Equal, ); check_comparison( &parse_prompt_denied("/foo/bar"), &parse_prompt_denied("/foo/bar"), Ordering::Equal, ); // Test unrelated paths (lexicographic ordering) check_comparison( &parse_granted("/aaa"), &parse_granted("/bbb"), Ordering::Less, ); check_comparison( &parse_granted("/xyz"), &parse_granted("/abc"), Ordering::Greater, ); check_comparison( &parse_flag_denied("/aaa"), &parse_flag_denied("/zzz"), Ordering::Less, ); // Test different types with same path // FlagDenied < PromptDenied < Granted (by kind_precedence) check_comparison( &parse_flag_denied("/foo"), &parse_granted("/foo"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/foo"), &parse_granted("/foo"), Ordering::Less, ); check_comparison( &parse_flag_denied("/foo"), &parse_prompt_denied("/foo"), Ordering::Less, ); // Test different types with parent/child relationship check_comparison( &parse_granted("/foo/bar"), &parse_flag_denied("/foo"), Ordering::Less, ); check_comparison( &parse_granted("/foo"), &parse_flag_denied("/foo/bar"), Ordering::Greater, ); check_comparison( &parse_prompt_denied("/foo/bar"), &parse_granted("/foo"), Ordering::Less, ); // Test root vs subdirectories check_comparison( &parse_granted("/"), &parse_granted("/foo"), Ordering::Greater, ); check_comparison( &parse_flag_denied("/"), &parse_flag_denied("/foo"), Ordering::Greater, ); // Test deeply nested paths check_comparison( &parse_granted("/a/b/c/d/e/f"), &parse_granted("/a/b/c"), Ordering::Less, ); check_comparison( &parse_granted("/a/b/c"), &parse_granted("/a/b/d"), Ordering::Less, ); // Test paths with similar prefixes but different branches check_comparison( &parse_granted("/foo/bar"), &parse_granted("/foo/baz"), Ordering::Less, ); check_comparison( &parse_granted("/prefix123"), &parse_granted("/prefix456"), Ordering::Less, ); // Test two deny types with different descriptors check_comparison( &parse_flag_denied("/aaa"), &parse_prompt_denied("/bbb"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/foo/bar"), &parse_flag_denied("/foo/baz"), Ordering::Less, ); // Test PromptDenied(child) vs FlagDenied(parent) check_comparison( &parse_prompt_denied("/foo/bar/baz"), &parse_flag_denied("/foo"), Ordering::Less, ); } #[test] fn test_cmp_net_descriptors() { let parser = TestPermissionDescriptorParser; let parse_granted = |text: &str| { UnaryPermissionDesc::Granted(parser.parse_net_descriptor(text).unwrap()) }; let parse_flag_denied = |text: &str| { UnaryPermissionDesc::FlagDenied::<NetDescriptor>( parser.parse_net_descriptor(text).unwrap(), ) }; let parse_prompt_denied = |text: &str| { UnaryPermissionDesc::PromptDenied::<NetDescriptor>( parser.parse_net_descriptor(text).unwrap(), ) }; // Test host hierarchy: more specific < less specific for granted check_comparison( &parse_granted("example.com:8080"), &parse_granted("example.com"), Ordering::Less, ); check_comparison( &parse_granted("sub.example.com"), &parse_granted("example.com"), Ordering::Less, ); // Test host hierarchy: more specific < less specific for flag denied check_comparison( &parse_flag_denied("example.com:8080"), &parse_flag_denied("example.com"), Ordering::Less, ); check_comparison( &parse_flag_denied("sub.example.com"), &parse_flag_denied("example.com"), Ordering::Less, ); // Test host hierarchy: more specific < less specific for prompt denied check_comparison( &parse_prompt_denied("example.com:8080"), &parse_prompt_denied("example.com"), Ordering::Less, ); check_comparison( &parse_prompt_denied("sub.example.com"), &parse_prompt_denied("example.com"), Ordering::Less, ); // Test equal descriptors with same type check_comparison( &parse_granted("example.com:8080"), &parse_granted("example.com:8080"), Ordering::Equal, ); check_comparison( &parse_flag_denied("example.com"), &parse_flag_denied("example.com"), Ordering::Equal, ); check_comparison( &parse_prompt_denied("example.com:443"), &parse_prompt_denied("example.com:443"), Ordering::Equal, ); // Test unrelated hosts (lexicographic ordering) check_comparison( &parse_granted("aaa.com"), &parse_granted("bbb.com"), Ordering::Less, ); check_comparison( &parse_granted("xyz.org"), &parse_granted("abc.org"), Ordering::Greater, ); check_comparison( &parse_flag_denied("aaa.com"), &parse_flag_denied("zzz.com"), Ordering::Less, ); // Test different types with same descriptor // FlagDenied < PromptDenied < Granted (by kind_precedence) check_comparison( &parse_flag_denied("example.com"), &parse_granted("example.com"), Ordering::Less, ); check_comparison( &parse_prompt_denied("example.com"), &parse_granted("example.com"), Ordering::Less, ); check_comparison( &parse_flag_denied("example.com"), &parse_prompt_denied("example.com"), Ordering::Less, ); // Test different types with hierarchy relationship check_comparison( &parse_granted("example.com:8080"), &parse_flag_denied("example.com"), Ordering::Less, ); check_comparison( &parse_granted("example.com"), &parse_flag_denied("example.com:8080"), Ordering::Greater, ); check_comparison( &parse_prompt_denied("example.com:8080"), &parse_granted("example.com"), Ordering::Less, ); // Test port variations check_comparison( &parse_granted("example.com:80"), &parse_granted("example.com:443"), Ordering::Less, ); check_comparison( &parse_granted("example.com:9000"), &parse_granted("example.com:8080"), Ordering::Greater, ); // Test IP addresses check_comparison( &parse_granted("127.0.0.1:8080"), &parse_granted("127.0.0.1"), Ordering::Less, ); check_comparison( &parse_granted("192.168.1.1"), &parse_granted("10.0.0.1"), Ordering::Greater, ); // Test IPv6 addresses check_comparison( &parse_granted("[::1]:8080"), &parse_granted("[::1]"), Ordering::Less, ); check_comparison( &parse_granted("[2001:db8::1]"), &parse_granted("[::1]"), Ordering::Greater, ); // Test two deny types with different hosts check_comparison( &parse_flag_denied("aaa.com"), &parse_prompt_denied("bbb.com"), Ordering::Less, ); check_comparison( &parse_prompt_denied("example.com:8080"), &parse_flag_denied("example.com:9000"), Ordering::Less, ); // Test PromptDenied(specific) vs FlagDenied(general) check_comparison( &parse_prompt_denied("sub.example.com"), &parse_flag_denied("example.com"), Ordering::Less, ); } #[test] fn test_cmp_env_descriptors() { let parser = TestPermissionDescriptorParser; let parse_granted = |text: &str| { UnaryPermissionDesc::Granted(parser.parse_env_descriptor(text).unwrap()) }; let parse_flag_denied = |text: &str| { UnaryPermissionDesc::FlagDenied::<EnvDescriptor>( parser.parse_env_descriptor(text).unwrap(), ) }; let parse_prompt_denied = |text: &str| { UnaryPermissionDesc::PromptDenied::<EnvDescriptor>( parser.parse_env_descriptor(text).unwrap(), ) }; // Test variable name ordering for granted check_comparison( &parse_granted("AAA"), &parse_granted("BBB"), Ordering::Less, ); check_comparison( &parse_granted("XYZ"), &parse_granted("ABC"), Ordering::Greater, ); // Test variable name ordering for flag denied check_comparison( &parse_flag_denied("HOME"), &parse_flag_denied("PATH"), Ordering::Less, ); check_comparison( &parse_flag_denied("ZZZ"), &parse_flag_denied("AAA"), Ordering::Greater, ); // Test variable name ordering for prompt denied check_comparison( &parse_prompt_denied("FOO"), &parse_prompt_denied("BAR"), Ordering::Greater, ); check_comparison( &parse_prompt_denied("TEST_VAR"), &parse_prompt_denied("TEST_VAR2"), Ordering::Less, ); // Test equal descriptors with same type check_comparison( &parse_granted("PATH"), &parse_granted("PATH"), Ordering::Equal, ); check_comparison( &parse_flag_denied("HOME"), &parse_flag_denied("HOME"), Ordering::Equal, ); check_comparison( &parse_prompt_denied("USER"), &parse_prompt_denied("USER"), Ordering::Equal, ); // Test different types with same variable // FlagDenied < PromptDenied < Granted (by kind_precedence) check_comparison( &parse_flag_denied("PATH"), &parse_granted("PATH"), Ordering::Less, ); check_comparison( &parse_prompt_denied("PATH"), &parse_granted("PATH"), Ordering::Less, ); check_comparison( &parse_flag_denied("PATH"), &parse_prompt_denied("PATH"), Ordering::Less, ); // Test different types with different variables check_comparison( &parse_granted("AAA"), &parse_flag_denied("BBB"), Ordering::Less, ); check_comparison( &parse_flag_denied("AAA"), &parse_granted("BBB"), Ordering::Less, ); check_comparison( &parse_prompt_denied("XXX"), &parse_granted("AAA"), Ordering::Greater, ); // Test common environment variables check_comparison( &parse_granted("HOME"), &parse_granted("PATH"), Ordering::Less, ); check_comparison( &parse_granted("USER"), &parse_granted("HOME"), Ordering::Greater, ); // Test two deny types with different variables check_comparison( &parse_flag_denied("AAA"), &parse_prompt_denied("ZZZ"), Ordering::Less, ); check_comparison( &parse_prompt_denied("HOME"), &parse_flag_denied("PATH"), Ordering::Less, ); } #[test] fn test_cmp_sys_descriptors() { let parser = TestPermissionDescriptorParser; let parse_granted = |text: &str| { UnaryPermissionDesc::Granted(parser.parse_sys_descriptor(text).unwrap()) }; let parse_flag_denied = |text: &str| { UnaryPermissionDesc::FlagDenied::<SysDescriptor>( parser.parse_sys_descriptor(text).unwrap(), ) }; let parse_prompt_denied = |text: &str| { UnaryPermissionDesc::PromptDenied::<SysDescriptor>( parser.parse_sys_descriptor(text).unwrap(), ) }; // Test system info kind ordering for granted check_comparison( &parse_granted("hostname"), &parse_granted("osRelease"), Ordering::Less, ); check_comparison( &parse_granted("uid"), &parse_granted("hostname"), Ordering::Greater, ); // Test system info kind ordering for flag denied check_comparison( &parse_flag_denied("cpus"), &parse_flag_denied("loadavg"), Ordering::Less, ); check_comparison( &parse_flag_denied("osRelease"), &parse_flag_denied("cpus"), Ordering::Greater, ); // Test system info kind ordering for prompt denied check_comparison( &parse_prompt_denied("hostname"), &parse_prompt_denied("loadavg"), Ordering::Less, ); check_comparison( &parse_prompt_denied("uid"), &parse_prompt_denied("gid"), Ordering::Greater, ); // Test equal descriptors with same type check_comparison( &parse_granted("hostname"), &parse_granted("hostname"), Ordering::Equal, ); check_comparison( &parse_flag_denied("osRelease"), &parse_flag_denied("osRelease"), Ordering::Equal, ); check_comparison( &parse_prompt_denied("cpus"), &parse_prompt_denied("cpus"), Ordering::Equal, ); // Test different types with same kind // FlagDenied < PromptDenied < Granted (by kind_precedence) check_comparison( &parse_flag_denied("hostname"), &parse_granted("hostname"), Ordering::Less, ); check_comparison( &parse_prompt_denied("hostname"), &parse_granted("hostname"), Ordering::Less, ); check_comparison( &parse_flag_denied("hostname"), &parse_prompt_denied("hostname"), Ordering::Less, ); // Test different types with different kinds check_comparison( &parse_granted("cpus"), &parse_flag_denied("loadavg"), Ordering::Greater, ); check_comparison( &parse_flag_denied("cpus"), &parse_granted("loadavg"), Ordering::Less, ); check_comparison( &parse_prompt_denied("uid"), &parse_granted("hostname"), Ordering::Less, ); // Test various system info kinds check_comparison( &parse_granted("gid"), &parse_granted("uid"), Ordering::Less, ); check_comparison( &parse_granted("loadavg"), &parse_granted("hostname"), Ordering::Greater, ); // Test two deny types with different kinds check_comparison( &parse_flag_denied("cpus"), &parse_prompt_denied("uid"), Ordering::Less, ); check_comparison( &parse_prompt_denied("hostname"), &parse_flag_denied("osRelease"), Ordering::Less, ); } #[test] fn test_cmp_ffi_descriptors() { let parser = TestPermissionDescriptorParser; let parse_granted = |text: &str| { UnaryPermissionDesc::Granted(parser.parse_ffi_descriptor(text).unwrap()) }; let parse_flag_denied = |text: &str| { UnaryPermissionDesc::FlagDenied::<FfiDescriptor>( parser.parse_ffi_descriptor(text).unwrap(), ) }; let parse_prompt_denied = |text: &str| { UnaryPermissionDesc::PromptDenied::<FfiDescriptor>( parser.parse_ffi_descriptor(text).unwrap(), ) }; // Test path hierarchy: child < parent for granted check_comparison( &parse_granted("/foo/bar"), &parse_granted("/foo"), Ordering::Less, ); check_comparison( &parse_granted("/foo/bar/baz.so"), &parse_granted("/foo/bar"), Ordering::Less, ); check_comparison( &parse_granted("/lib/native/module.so"), &parse_granted("/lib"), Ordering::Less, ); // Test path hierarchy: child < parent for flag denied check_comparison( &parse_flag_denied("/foo/bar"), &parse_flag_denied("/foo"), Ordering::Less, ); check_comparison( &parse_flag_denied("/foo/bar/baz.dylib"), &parse_flag_denied("/foo/bar"), Ordering::Less, ); // Test path hierarchy: child < parent for prompt denied check_comparison( &parse_prompt_denied("/foo/bar"), &parse_prompt_denied("/foo"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/foo/bar/baz.dll"), &parse_prompt_denied("/foo/bar"), Ordering::Less, ); // Test equal paths with same type check_comparison( &parse_granted("/lib/native.so"), &parse_granted("/lib/native.so"), Ordering::Equal, ); check_comparison( &parse_flag_denied("/lib/native.so"), &parse_flag_denied("/lib/native.so"), Ordering::Equal, ); check_comparison( &parse_prompt_denied("/lib/native.so"), &parse_prompt_denied("/lib/native.so"), Ordering::Equal, ); // Test unrelated paths (lexicographic ordering) check_comparison( &parse_granted("/aaa/lib.so"), &parse_granted("/bbb/lib.so"), Ordering::Less, ); check_comparison( &parse_granted("/xyz/lib.so"), &parse_granted("/abc/lib.so"), Ordering::Greater, ); check_comparison( &parse_flag_denied("/aaa/lib.so"), &parse_flag_denied("/zzz/lib.so"), Ordering::Less, ); // Test different types with same path // FlagDenied < PromptDenied < Granted (by kind_precedence) check_comparison( &parse_flag_denied("/lib/native.so"), &parse_granted("/lib/native.so"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/lib/native.so"), &parse_granted("/lib/native.so"), Ordering::Less, ); check_comparison( &parse_flag_denied("/lib/native.so"), &parse_prompt_denied("/lib/native.so"), Ordering::Less, ); // Test different types with parent/child relationship check_comparison( &parse_granted("/foo/bar/lib.so"), &parse_flag_denied("/foo"), Ordering::Less, ); check_comparison( &parse_granted("/foo"), &parse_flag_denied("/foo/bar/lib.so"), Ordering::Greater, ); check_comparison( &parse_prompt_denied("/foo/bar/lib.so"), &parse_granted("/foo"), Ordering::Less, ); // Test root vs subdirectories check_comparison( &parse_granted("/"), &parse_granted("/foo"), Ordering::Greater, ); check_comparison( &parse_flag_denied("/"), &parse_flag_denied("/foo"), Ordering::Greater, ); // Test deeply nested paths check_comparison( &parse_granted("/a/b/c/d/e/f.so"), &parse_granted("/a/b/c"), Ordering::Less, ); check_comparison( &parse_granted("/a/b/c"), &parse_granted("/a/b/d"), Ordering::Less, ); // Test paths with similar prefixes but different branches check_comparison( &parse_granted("/foo/bar.so"), &parse_granted("/foo/baz.so"), Ordering::Less, ); check_comparison( &parse_granted("/lib/native1.so"), &parse_granted("/lib/native2.so"), Ordering::Less, ); // Test two deny types with different paths check_comparison( &parse_flag_denied("/aaa/lib.so"), &parse_prompt_denied("/bbb/lib.so"), Ordering::Less, ); check_comparison( &parse_prompt_denied("/foo/bar.so"), &parse_flag_denied("/foo/baz.so"), Ordering::Less, ); // Test PromptDenied(child) vs FlagDenied(parent) check_comparison( &parse_prompt_denied("/foo/bar/lib.so"), &parse_flag_denied("/foo"), Ordering::Less, ); } #[test] fn test_cmp_import_descriptors() { let parser = TestPermissionDescriptorParser; let parse_granted = |text: &str| { UnaryPermissionDesc::Granted( parser.parse_import_descriptor(text).unwrap(), ) }; let parse_flag_denied = |text: &str| { UnaryPermissionDesc::FlagDenied::<ImportDescriptor>( parser.parse_import_descriptor(text).unwrap(), ) }; let parse_prompt_denied = |text: &str| { UnaryPermissionDesc::PromptDenied::<ImportDescriptor>( parser.parse_import_descriptor(text).unwrap(), ) }; // Test host hierarchy: more specific < less specific for granted check_comparison( &parse_granted("example.com:8080"), &parse_granted("example.com"), Ordering::Less, ); check_comparison( &parse_granted("sub.example.com"), &parse_granted("example.com"), Ordering::Less, ); // Test host hierarchy: more specific < less specific for flag denied check_comparison( &parse_flag_denied("example.com:8080"), &parse_flag_denied("example.com"), Ordering::Less, ); check_comparison( &parse_flag_denied("sub.example.com"), &parse_flag_denied("example.com"), Ordering::Less, ); // Test host hierarchy: more specific < less specific for prompt denied check_comparison( &parse_prompt_denied("example.com:8080"), &parse_prompt_denied("example.com"), Ordering::Less, ); check_comparison( &parse_prompt_denied("sub.example.com"), &parse_prompt_denied("example.com"), Ordering::Less, ); // Test equal descriptors with same type check_comparison( &parse_granted("deno.land"), &parse_granted("deno.land"), Ordering::Equal, ); check_comparison( &parse_flag_denied("deno.land"), &parse_flag_denied("deno.land"), Ordering::Equal, ); check_comparison( &parse_prompt_denied("deno.land:443"), &parse_prompt_denied("deno.land:443"), Ordering::Equal, ); // Test unrelated hosts (lexicographic ordering) check_comparison( &parse_granted("aaa.com"), &parse_granted("bbb.com"), Ordering::Less, ); check_comparison( &parse_granted("xyz.org"), &parse_granted("abc.org"), Ordering::Greater, ); check_comparison( &parse_flag_denied("aaa.com"), &parse_flag_denied("zzz.com"), Ordering::Less, ); // Test different types with same descriptor // FlagDenied < PromptDenied < Granted (by kind_precedence) check_comparison( &parse_flag_denied("deno.land"), &parse_granted("deno.land"), Ordering::Less, ); check_comparison( &parse_prompt_denied("deno.land"), &parse_granted("deno.land"), Ordering::Less, ); check_comparison( &parse_flag_denied("deno.land"), &parse_prompt_denied("deno.land"), Ordering::Less, ); // Test different types with hierarchy relationship check_comparison( &parse_granted("deno.land:8080"), &parse_flag_denied("deno.land"), Ordering::Less, ); check_comparison( &parse_granted("deno.land"), &parse_flag_denied("deno.land:8080"), Ordering::Greater, ); check_comparison( &parse_prompt_denied("deno.land:8080"), &parse_granted("deno.land"), Ordering::Less, ); // Test port variations check_comparison( &parse_granted("deno.land:80"), &parse_granted("deno.land:443"), Ordering::Less, ); check_comparison( &parse_granted("deno.land:9000"), &parse_granted("deno.land:8080"), Ordering::Greater, ); // Test two deny types with different hosts check_comparison( &parse_flag_denied("aaa.land"), &parse_prompt_denied("zzz.land"), Ordering::Less, ); check_comparison( &parse_prompt_denied("deno.land:8080"), &parse_flag_denied("deno.land:9000"), Ordering::Less, ); // Test PromptDenied(specific) vs FlagDenied(general) check_comparison( &parse_prompt_denied("sub.deno.land"), &parse_flag_denied("deno.land"), Ordering::Less, ); } #[track_caller] fn check_comparison<TAllowDesc: AllowDescriptor>( first: &UnaryPermissionDesc<TAllowDesc>, second: &UnaryPermissionDesc<TAllowDesc>, expected: Ordering, ) { assert_eq!(first.cmp(second), expected); assert_eq!( second.cmp(first), match expected { Ordering::Less => Ordering::Greater, Ordering::Greater => Ordering::Less, Ordering::Equal => Ordering::Equal, }, "failed second to first" ); } #[test] #[cfg(windows)] fn check_path_case_insensitive() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["C:\\Users\\Admin"]), deny_read: Some(svec!["C:\\Users\\Admin\\Secret"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); // Matching case should be allowed assert!( perms .check_open( Cow::Borrowed(Path::new("C:\\Users\\Admin\\file.txt")), OpenAccessKind::Read, Some("api"), ) .is_ok() ); // Different case should also be allowed assert!( perms .check_open( Cow::Borrowed(Path::new("c:\\users\\admin\\file.txt")), OpenAccessKind::Read, Some("api"), ) .is_ok() ); // Deny with matching case should block assert!( perms .check_open( Cow::Borrowed(Path::new("C:\\Users\\Admin\\Secret\\data.txt")), OpenAccessKind::Read, Some("api"), ) .is_err() ); // Deny with different case should also block assert!( perms .check_open( Cow::Borrowed(Path::new("c:\\users\\admin\\secret\\data.txt")), OpenAccessKind::Read, Some("api"), ) .is_err() ); } #[test] #[cfg(windows)] fn path_descriptor_verbatim_prefix_equivalent() { // A `\\?\` verbatim (extended-length) path and its regular form refer to // the same file, so the permission system must treat them as equal // (denoland/deno#18597). let regular = PathDescriptor::new_known_absolute(Cow::Borrowed(Path::new( "C:\\Users\\Admin", ))); let verbatim = PathDescriptor::new_known_absolute(Cow::Borrowed( Path::new("\\\\?\\C:\\Users\\Admin"), )); assert_eq!(regular, verbatim); // The stored path is the simplified form, not the verbatim one. assert_eq!(verbatim.path, PathBuf::from("C:\\Users\\Admin")); // A `\\?\` query is contained by a grant made with the regular path... let query = PathQueryDescriptor::new_known_absolute(Cow::Borrowed( Path::new("\\\\?\\C:\\Users\\Admin\\file.txt"), )); assert!(query.starts_with(®ular)); // ...and a regular query is contained by a grant made with a `\\?\` path. let query = PathQueryDescriptor::new_known_absolute(Cow::Borrowed( Path::new("C:\\Users\\Admin\\file.txt"), )); assert!(query.starts_with(&verbatim)); // An unrelated verbatim path is not contained. let query = PathQueryDescriptor::new_known_absolute(Cow::Borrowed( Path::new("\\\\?\\C:\\Other\\file.txt"), )); assert!(!query.starts_with(®ular)); } #[test] fn test_is_allow_all_edge_cases() { let parser = TestPermissionDescriptorParser; // granted_global alone => is_allow_all true let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(perms.read.is_allow_all()); // granted_global + flag_ignored_global => is_allow_all false let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), ignore_read: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(!perms.read.is_allow_all()); // granted_global + flag_denied_global => is_allow_all false let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), deny_read: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(!perms.read.is_allow_all()); // granted_global + specific deny descriptor => is_allow_all false let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), deny_read: Some(svec!["/secret"]), ..Default::default() }, ) .unwrap(); assert!(!perms.read.is_allow_all()); // granted_global + specific ignore descriptor => is_allow_all false let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), ignore_read: Some(svec!["/secret"]), ..Default::default() }, ) .unwrap(); assert!(!perms.read.is_allow_all()); // specific allow only (not global) => is_allow_all false let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo"]), ..Default::default() }, ) .unwrap(); assert!(!perms.read.is_allow_all()); // no permissions at all => is_allow_all false let perms = Permissions::from_options( &parser, &PermissionsOptions { ..Default::default() }, ) .unwrap(); assert!(!perms.read.is_allow_all()); } #[test] fn test_revoke_and_requery_state_transitions() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; // Revoke specific path, then query child path let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo"]), ..Default::default() }, ) .unwrap(); assert_eq!( perms.read.query(Some(&read_query("/foo/bar"))), PermissionState::Granted ); perms.read.revoke(Some(&read_query("/foo"))); // After revoking /foo, child path /foo/bar should also be prompt assert_eq!( perms.read.query(Some(&read_query("/foo/bar"))), PermissionState::Prompt ); // Revoke after prompt-granted let mut perms = Permissions::none_with_prompt(); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(true); assert_eq!( perms.read.request(Some(&read_query("/foo"))), PermissionState::Granted ); assert_eq!( perms.read.query(Some(&read_query("/foo"))), PermissionState::Granted ); perms.read.revoke(Some(&read_query("/foo"))); assert_eq!( perms.read.query(Some(&read_query("/foo"))), PermissionState::Prompt ); // Revoke global, then check specific descriptor still denied let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), deny_read: Some(svec!["/secret"]), ..Default::default() }, ) .unwrap(); assert_eq!( perms.read.query(Some(&read_query("/foo"))), PermissionState::Granted ); perms.read.revoke(None); // /secret should still be denied (flag deny persists after revoke) assert_eq!( perms.read.query(Some(&read_query("/secret"))), PermissionState::Denied ); // Other paths should be prompt after global revoke assert_eq!( perms.read.query(Some(&read_query("/foo"))), PermissionState::Prompt ); } #[test] fn test_prompt_denied_accumulation_and_stronger_than() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; let mut perms = Permissions::none_with_prompt(); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); // Deny /foo at prompt, then check /foo/bar // Unlike flag denials, prompt denials use stronger_than_deny which only // blocks when the query path encompasses the denied path (parent of // denied), not child paths. prompt_value.set(false); assert_eq!( perms.read.request(Some(&read_query("/foo"))), PermissionState::Denied ); // /foo/bar is a child of prompt-denied /foo, but prompt denials don't // propagate to children -- only flag denials do assert_eq!( perms.read.query(Some(&read_query("/foo/bar"))), PermissionState::Prompt ); // /foo itself should still be denied assert_eq!( perms.read.query(Some(&read_query("/foo"))), PermissionState::Denied ); // Deny /bar/baz at prompt, then check /bar (parent) -- parent // encompasses the denied child, so stronger_than_deny returns true prompt_value.set(false); assert_eq!( perms.read.request(Some(&read_query("/bar/baz"))), PermissionState::Denied ); // Parent path /bar is "stronger than" prompt-deny of /bar/baz, so it // is also denied assert_eq!( perms.read.query(Some(&read_query("/bar"))), PermissionState::Denied ); // Multiple prompt denials accumulate prompt_value.set(false); assert_eq!( perms.read.request(Some(&read_query("/x"))), PermissionState::Denied ); prompt_value.set(false); assert_eq!( perms.read.request(Some(&read_query("/y"))), PermissionState::Denied ); // Both should remain denied assert_eq!( perms.read.query(Some(&read_query("/x"))), PermissionState::Denied ); assert_eq!( perms.read.query(Some(&read_query("/y"))), PermissionState::Denied ); // Unrelated path still promptable assert_eq!( perms.read.query(Some(&read_query("/z"))), PermissionState::Prompt ); } #[test] fn test_allow_deny_ignore_three_way_interaction() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let read_query = |path: &str| { parser .parse_path_query(Cow::Owned(PathBuf::from(path))) .unwrap() .into_read() }; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/home"]), deny_read: Some(svec!["/home/secret"]), ignore_read: Some(svec!["/home/.cache"]), ..Default::default() }, ) .unwrap(); // Regular file under /home => allowed assert_eq!( perms.read.query(Some(&read_query("/home/file.txt"))), PermissionState::Granted ); // File under /home/secret => denied assert_eq!( perms.read.query(Some(&read_query("/home/secret/key"))), PermissionState::Denied ); // File under /home/.cache => ignored (stealth deny) assert_eq!( perms.read.query(Some(&read_query("/home/.cache/data"))), PermissionState::Ignored ); // /home itself => GrantedPartial (has deny and ignore holes) assert_eq!( perms.read.query(Some(&read_query("/home"))), PermissionState::GrantedPartial ); // Outside /home => prompt assert_eq!( perms.read.query(Some(&read_query("/etc/passwd"))), PermissionState::Prompt ); } #[test] fn test_check_all_api_with_specific_allows_only() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; // Specific allows only (not global) => check_all should fail // (no prompt available) let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/foo"]), prompt: false, ..Default::default() }, ) .unwrap(); assert!(perms.read.check_all(None).is_err()); // Global allow => check_all should succeed let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(perms.read.check_all(None).is_ok()); // Global allow + specific deny => check_all still succeeds because // check_desc uses AllowPartial::TreatAsGranted for non-partial checks let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), deny_read: Some(svec!["/secret"]), ..Default::default() }, ) .unwrap(); assert!(perms.read.check_all(None).is_ok()); // Global allow + global deny => check_all should fail let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), deny_read: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(perms.read.check_all(None).is_err()); // Prompt-granted paths only => check_all should fail (not global, // no prompt) let mut perms = Permissions::none_with_prompt(); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(true); let read_query = parser .parse_path_query(Cow::Owned(PathBuf::from("/foo"))) .unwrap() .into_read(); assert!(perms.read.check(&read_query, None).is_ok()); // Even though /foo was granted via prompt, check_all queries global // state. With prompt enabled it will try to prompt for global, and // the prompter returns true, so it grants global prompt_value.set(false); // Now prompter will deny the global prompt assert!(perms.read.check_all(None).is_err()); } #[test] fn test_import_permission_check_and_deny() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; // Import with allow and deny let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_import: Some(svec!["deno.land:443", "jsr.io:443"]), deny_import: Some(svec!["evil.com:443"]), ..Default::default() }, ) .unwrap(); // Allowed host assert!( perms .import .check( &ImportDescriptor(NetDescriptor( Host::must_parse("deno.land"), Some(443) )), None, ) .is_ok() ); // Denied host assert!( perms .import .check( &ImportDescriptor(NetDescriptor( Host::must_parse("evil.com"), Some(443) )), None, ) .is_err() ); // Not in allow list => denied (no prompt) assert!( perms .import .check( &ImportDescriptor(NetDescriptor( Host::must_parse("unknown.com"), Some(443) )), None, ) .is_err() ); // Global import allow with deny override let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_import: Some(vec![]), deny_import: Some(svec!["evil.com:443"]), ..Default::default() }, ) .unwrap(); // Allowed (global grant) assert!( perms .import .check( &ImportDescriptor(NetDescriptor( Host::must_parse("deno.land"), Some(443) )), None, ) .is_ok() ); // Denied (explicit deny overrides global allow) assert!( perms .import .check( &ImportDescriptor(NetDescriptor( Host::must_parse("evil.com"), Some(443) )), None, ) .is_err() ); // check_all with global allow + specific deny succeeds because // check_desc uses AllowPartial::TreatAsGranted assert!(perms.import.check_all().is_ok()); // check_all with global allow + global deny fails let mut perms = Permissions::from_options( &parser, &PermissionsOptions { allow_import: Some(vec![]), deny_import: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(perms.import.check_all().is_err()); } #[test] fn test_check_open_read_write() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; // ReadWrite requires both read AND write let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/data"]), allow_write: Some(svec!["/data"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); // ReadWrite on allowed path => ok assert!( perms .check_open( Cow::Borrowed(Path::new("/data/file.txt")), OpenAccessKind::ReadWrite, Some("api"), ) .is_ok() ); // ReadWrite on path with only read => err let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(svec!["/readonly"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); assert!( perms .check_open( Cow::Borrowed(Path::new("/readonly/file.txt")), OpenAccessKind::ReadWrite, Some("api"), ) .is_err() ); // ReadWrite on path with only write => err let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_write: Some(svec!["/writeonly"]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); assert!( perms .check_open( Cow::Borrowed(Path::new("/writeonly/file.txt")), OpenAccessKind::ReadWrite, Some("api"), ) .is_err() ); } #[test] fn test_allow_run_auto_deny_write() { let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_run: Some(svec!["/usr/bin/node"]), allow_write: Some(vec![]), ..Default::default() }, ) .unwrap(); let perms = PermissionsContainer::new(Arc::new(parser), perms); // Writing to allowed run path should be denied assert!( perms .check_open( Cow::Borrowed(Path::new("/usr/bin/node")), OpenAccessKind::Write, Some("api"), ) .is_err() ); // Writing to other paths should be allowed (global write is granted) assert!( perms .check_open( Cow::Borrowed(Path::new("/tmp/file.txt")), OpenAccessKind::Write, Some("api"), ) .is_ok() ); } #[test] fn test_net_fqdn_with_subdomain_wildcard() { set_prompter(Box::new(TestPrompter)); let parser = TestPermissionDescriptorParser; let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(svec!["*.example.com"]), deny_net: Some(svec!["*.evil.com"]), ..Default::default() }, ) .unwrap(); let mut perms = PermissionsContainer::new(Arc::new(parser), perms); // Subdomain should match wildcard allow assert!(perms.check_net(&("sub.example.com", None), "api").is_ok()); assert!( perms .check_net(&("deep.sub.example.com", None), "api") .is_ok() ); // Bare domain DOES match wildcard: *.example.com matches example.com // because the fqdn crate's is_subdomain_of is inclusive (a domain is a // subdomain of itself). This is intentional and consistent with the // existing test_check_net_with_values test for *.discord.gg. assert!(perms.check_net(&("example.com", None), "api").is_ok()); // Subdomain of denied wildcard should be denied assert!(perms.check_net(&("sub.evil.com", None), "api").is_err()); // Bare domain also matches wildcard deny (same inclusive semantics) assert!(perms.check_net(&("evil.com", None), "api").is_err()); // Unrelated domain should prompt (denied since no-prompt by default // in test) assert!(perms.check_net(&("other.com", None), "api").is_err()); } #[test] fn test_empty_descriptor_edge_cases() { let parser = TestPermissionDescriptorParser; // Some(vec![]) means "grant all" (global grant) let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_read: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(perms.read.is_allow_all()); // None means "no grant" (prompt mode) let perms = Permissions::from_options( &parser, &PermissionsOptions { ..Default::default() }, ) .unwrap(); assert!(!perms.read.is_allow_all()); let read_query = parser .parse_path_query(Cow::Owned(PathBuf::from("/foo"))) .unwrap() .into_read(); assert_eq!(perms.read.query(Some(&read_query)), PermissionState::Prompt); // Some(vec![]) for env means "grant all env" let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_env: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(perms.env.is_allow_all()); assert_eq!(perms.env.query(None), PermissionState::Granted); // Some(vec![]) for net means "grant all net" let perms = Permissions::from_options( &parser, &PermissionsOptions { allow_net: Some(vec![]), ..Default::default() }, ) .unwrap(); assert!(perms.net.is_allow_all()); assert_eq!(perms.net.query(None), PermissionState::Granted); } mod proptests { use std::cmp::Ordering; use std::net::Ipv4Addr; use proptest::prelude::*; use super::*; // -- Strategies -- fn arb_host() -> impl Strategy<Value = Host> { prop_oneof![ any::<[u8; 4]>().prop_map(|b| Host::Ip(IpAddr::V4(Ipv4Addr::new( b[0], b[1], b[2], b[3] )))), "[a-z]{1,5}(\\.[a-z]{1,5}){1,3}".prop_filter_map("valid fqdn", |s| { use std::str::FromStr; fqdn::FQDN::from_str(&s).ok().map(Host::Fqdn) }), ] } fn arb_port() -> impl Strategy<Value = Option<u32>> { prop_oneof![Just(None), (1u32..=65535).prop_map(Some),] } fn arb_net_descriptor() -> impl Strategy<Value = NetDescriptor> { (arb_host(), arb_port()).prop_map(|(h, p)| NetDescriptor(h, p)) } fn arb_env_descriptor() -> impl Strategy<Value = EnvDescriptor> { prop_oneof![ "[A-Z_]{1,10}" .prop_map(|s| EnvDescriptor::Name(EnvVarName::new(Cow::Owned(s)))), "[A-Z_]{1,10}".prop_map(|s| EnvDescriptor::PrefixPattern( EnvVarName::new(Cow::Owned(s)) )), ] } fn arb_unary_perm_desc_net() -> impl Strategy<Value = UnaryPermissionDesc<NetDescriptor>> { (arb_net_descriptor(), 0..4u8).prop_map(|(desc, kind)| match kind { 0 => UnaryPermissionDesc::Granted(desc), 1 => UnaryPermissionDesc::FlagDenied(desc), 2 => UnaryPermissionDesc::FlagIgnored(desc), _ => UnaryPermissionDesc::PromptDenied(desc), }) } fn arb_unary_perm_desc_env() -> impl Strategy<Value = UnaryPermissionDesc<EnvDescriptor>> { (arb_env_descriptor(), 0..4u8).prop_map(|(desc, kind)| match kind { 0 => UnaryPermissionDesc::Granted(desc), 1 => UnaryPermissionDesc::FlagDenied(desc.clone()), 2 => UnaryPermissionDesc::FlagIgnored(desc.clone()), _ => UnaryPermissionDesc::PromptDenied(desc.clone()), }) } // -- 1. Descriptor ordering invariants -- // Transitivity: if a <= b and b <= c then a <= c proptest! { #[test] fn net_descriptor_ord_transitivity( a in arb_unary_perm_desc_net(), b in arb_unary_perm_desc_net(), c in arb_unary_perm_desc_net(), ) { let ab = a.cmp(&b); let bc = b.cmp(&c); let ac = a.cmp(&c); if ab != Ordering::Greater && bc != Ordering::Greater { prop_assert_ne!(ac, Ordering::Greater, "transitivity violated: a={:?}, b={:?}, c={:?}", a, b, c); } if ab != Ordering::Less && bc != Ordering::Less { prop_assert_ne!(ac, Ordering::Less, "transitivity violated: a={:?}, b={:?}, c={:?}", a, b, c); } } #[test] fn env_descriptor_ord_transitivity( a in arb_unary_perm_desc_env(), b in arb_unary_perm_desc_env(), c in arb_unary_perm_desc_env(), ) { let ab = a.cmp(&b); let bc = b.cmp(&c); let ac = a.cmp(&c); if ab != Ordering::Greater && bc != Ordering::Greater { prop_assert_ne!(ac, Ordering::Greater, "transitivity violated: a={:?}, b={:?}, c={:?}", a, b, c); } if ab != Ordering::Less && bc != Ordering::Less { prop_assert_ne!(ac, Ordering::Less, "transitivity violated: a={:?}, b={:?}, c={:?}", a, b, c); } } // Antisymmetry: if a <= b and b <= a then a == b #[test] fn net_descriptor_ord_antisymmetry( a in arb_unary_perm_desc_net(), b in arb_unary_perm_desc_net(), ) { let ab = a.cmp(&b); let ba = b.cmp(&a); match (ab, ba) { (Ordering::Less, Ordering::Less) => { prop_assert!(false, "antisymmetry violated: a < b and b < a, a={:?}, b={:?}", a, b); } (Ordering::Greater, Ordering::Greater) => { prop_assert!(false, "antisymmetry violated: a > b and b > a, a={:?}, b={:?}", a, b); } (Ordering::Equal, other) => { prop_assert_eq!(other, Ordering::Equal, "antisymmetry violated: a == b but b != a, a={:?}, b={:?}", a, b); } (_, Ordering::Equal) => { prop_assert_eq!(ab, Ordering::Equal, "antisymmetry violated: b == a but a != b, a={:?}, b={:?}", a, b); } _ => {} // Less/Greater is fine } } // Reflexivity: a == a #[test] fn net_descriptor_ord_reflexivity( a in arb_unary_perm_desc_net(), ) { prop_assert_eq!(a.cmp(&a), Ordering::Equal, "reflexivity violated: a={:?}", a); } // Binary search correctness: after inserting into descriptors, // the vec remains sorted #[test] fn net_descriptors_remain_sorted_after_inserts( descs in prop::collection::vec(arb_unary_perm_desc_net(), 1..20), ) { let mut descriptors = UnaryPermissionDescriptors::<NetDescriptor>::default(); for d in &descs { descriptors.insert(d.clone()); } let inner = &descriptors.inner; for i in 1..inner.len() { prop_assert!(inner[i - 1] <= inner[i], "not sorted at index {}: {:?} > {:?}", i, inner[i-1], inner[i]); } } #[test] fn env_descriptors_remain_sorted_after_inserts( descs in prop::collection::vec(arb_unary_perm_desc_env(), 1..20), ) { let mut descriptors = UnaryPermissionDescriptors::<EnvDescriptor>::default(); for d in &descs { descriptors.insert(d.clone()); } let inner = &descriptors.inner; for i in 1..inner.len() { prop_assert!(inner[i - 1] <= inner[i], "not sorted at index {}: {:?} > {:?}", i, inner[i-1], inner[i]); } } } // -- 2. Allow/deny resolution consistency -- // query_desc() should never return Granted when a matching FlagDenied // descriptor exists in the list. proptest! { #[test] fn net_query_never_granted_when_flag_denied( allow_descs in prop::collection::vec(arb_net_descriptor(), 0..5), deny_descs in prop::collection::vec(arb_net_descriptor(), 1..5), query in arb_net_descriptor(), ) { set_prompter(Box::new(TestPrompter)); let mut perm = UnaryPermission::<NetDescriptor>::default(); for d in &allow_descs { perm.descriptors.insert(UnaryPermissionDesc::Granted(d.clone())); } for d in &deny_descs { perm.descriptors.insert(UnaryPermissionDesc::FlagDenied(d.clone())); } // If the query matches any deny descriptor, the result must not be Granted let matches_any_deny = deny_descs.iter().any(|d| query.matches_deny(d)); if matches_any_deny { let state = perm.query_desc( Some(&query), AllowPartial::TreatAsPartialGranted, ); prop_assert_ne!(state, PermissionState::Granted, "query returned Granted despite matching FlagDenied: query={:?}, deny={:?}", query, deny_descs); prop_assert_ne!(state, PermissionState::GrantedPartial, "query returned GrantedPartial despite matching FlagDenied: query={:?}, deny={:?}", query, deny_descs); } } } // -- 3. Path containment symmetry -- // For paths: matches_allow(allow) && stronger_than_deny(deny_at_same_path) // should be consistent with containment direction. proptest! { #[test] fn path_containment_properties( base_segments in prop::collection::vec("[a-z]{1,5}", 1..5), extra_segments in prop::collection::vec("[a-z]{1,5}", 0..3), ) { let parser = TestPermissionDescriptorParser; let base_path = format!("/{}", base_segments.join("/")); let child_path = if extra_segments.is_empty() { base_path.clone() } else { format!("{}/{}", base_path, extra_segments.join("/")) }; let base_desc = parser.parse_read_descriptor(&base_path).unwrap(); let child_allow_desc = parser.parse_read_descriptor(&child_path).unwrap(); let child_query = parser.parse_path_query( Cow::Owned(PathBuf::from(&child_path)), ).unwrap().into_read(); let base_query = parser.parse_path_query( Cow::Owned(PathBuf::from(&base_path)), ).unwrap().into_read(); // A child path should match_allow on a base (parent) allow descriptor prop_assert!(child_query.matches_allow(&base_desc), "child {} should match_allow base {}", child_path, base_path); // A base path should be stronger_than_deny of a child deny prop_assert!(base_query.stronger_than_deny(&child_allow_desc), "base {} should be stronger_than_deny of child {}", base_path, child_path); // If child matches allow on base, then child matches deny on base too // (because matches_deny delegates to same containment check for paths) prop_assert!(child_query.matches_deny(&base_desc), "matches_deny should agree with matches_allow for paths"); // overlaps_deny is same as stronger_than_deny for paths prop_assert_eq!( base_query.overlaps_deny(&child_allow_desc), base_query.stronger_than_deny(&child_allow_desc), "overlaps_deny should agree with stronger_than_deny for paths" ); } } // -- 4. Child permission escalation -- // Child processes should never obtain permissions that the parent's // check() method would deny. proptest! { #[test] fn child_net_permissions_cannot_escalate( parent_allow in prop::collection::vec(arb_net_descriptor(), 0..5), parent_deny in prop::collection::vec(arb_net_descriptor(), 0..3), child_request in prop::collection::vec(arb_net_descriptor(), 0..5), query in arb_net_descriptor(), ) { set_prompter(Box::new(TestPrompter)); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(false); // Build parent permissions let mut parent = UnaryPermission::<NetDescriptor>::default(); for d in &parent_allow { parent.descriptors.insert(UnaryPermissionDesc::Granted(d.clone())); } for d in &parent_deny { parent.descriptors.insert(UnaryPermissionDesc::FlagDenied(d.clone())); } // Try to create child permissions with the requested list let child_strs: Vec<String> = child_request.iter().map(|d| d.to_string()).collect(); let child_result = parent.create_child_permissions( ChildUnaryPermissionArg::GrantedList(child_strs), |s| NetDescriptor::parse_for_list(s).map(Some), ); if let Ok(child) = child_result { // For any query: if parent would deny, child must also deny let parent_state = parent.query_desc( Some(&query), AllowPartial::TreatAsDenied, ); let child_state = child.query_desc( Some(&query), AllowPartial::TreatAsDenied, ); if parent_state == PermissionState::Denied { prop_assert_ne!(child_state, PermissionState::Granted, "child escalated! query={:?}, parent_state={:?}, child_state={:?}", query, parent_state, child_state); } } // If child creation failed (Escalation), that's the correct behavior } #[test] fn child_inherit_preserves_denials( parent_allow in prop::collection::vec(arb_net_descriptor(), 0..3), parent_deny in prop::collection::vec(arb_net_descriptor(), 1..3), query in arb_net_descriptor(), ) { set_prompter(Box::new(TestPrompter)); let mut parent = UnaryPermission::<NetDescriptor>::default(); for d in &parent_allow { parent.descriptors.insert(UnaryPermissionDesc::Granted(d.clone())); } for d in &parent_deny { parent.descriptors.insert(UnaryPermissionDesc::FlagDenied(d.clone())); } let child = parent.create_child_permissions( ChildUnaryPermissionArg::Inherit, |s: &str| NetDescriptor::parse_for_list(s).map(Some), ).unwrap(); // Inherited child should have identical query results let parent_state = parent.query_desc(Some(&query), AllowPartial::TreatAsDenied); let child_state = child.query_desc(Some(&query), AllowPartial::TreatAsDenied); prop_assert_eq!(parent_state, child_state, "inherited child diverged from parent: query={:?}", query); } } // -- 5. Net descriptor round-trip -- // Parsing display_name() back through parse should yield an equivalent // descriptor. proptest! { #[test] fn net_descriptor_display_roundtrip( desc in arb_net_descriptor(), ) { let display = desc.display_name().to_string(); // parse_for_list supports wildcards (superset of parse_for_query) if let Ok(parsed) = NetDescriptor::parse_for_list(&display) { prop_assert_eq!(&parsed, &desc, "round-trip failed: display={:?}, original={:?}, parsed={:?}", display, desc, parsed); } // If parsing fails, skip (some edge cases with subnet display may differ) } // Also test with port #[test] fn net_descriptor_display_roundtrip_with_port( host in arb_host(), port in 1u32..=65535, ) { let desc = NetDescriptor(host, Some(port)); let display = desc.display_name().to_string(); if let Ok(parsed) = NetDescriptor::parse_for_list(&display) { prop_assert_eq!(&parsed, &desc, "round-trip with port failed: display={:?}", display); } } } // -- 6. Global flag_denied overrides granted descriptors -- proptest! { #[test] fn global_deny_overrides_all_grants_net( allow_descs in prop::collection::vec(arb_net_descriptor(), 1..5), query in arb_net_descriptor(), ) { set_prompter(Box::new(TestPrompter)); let mut perm = UnaryPermission::<NetDescriptor> { flag_denied_global: true, ..Default::default() }; for d in &allow_descs { perm.descriptors.insert(UnaryPermissionDesc::Granted(d.clone())); } let state = perm.query_desc(Some(&query), AllowPartial::TreatAsDenied); prop_assert_eq!(state, PermissionState::Denied, "flag_denied_global should deny everything: query={:?}", query); // Also check global query (None) let state_global = perm.query_desc(None, AllowPartial::TreatAsDenied); prop_assert_eq!(state_global, PermissionState::Denied, "flag_denied_global should deny global query too"); } #[test] fn global_deny_overrides_granted_global_net( query in arb_net_descriptor(), ) { set_prompter(Box::new(TestPrompter)); let perm = UnaryPermission::<NetDescriptor> { granted_global: true, flag_denied_global: true, ..Default::default() }; let state = perm.query_desc(Some(&query), AllowPartial::TreatAsDenied); prop_assert_eq!(state, PermissionState::Denied, "flag_denied_global should override granted_global: query={:?}", query); } } // -- 7. Revoke consistency -- // After revoke_desc(), query_desc() should never return Granted for // the revoked descriptor. proptest! { #[test] fn revoke_prevents_granted_net( allow_descs in prop::collection::vec(arb_net_descriptor(), 1..5), revoke_idx in 0usize..5, ) { set_prompter(Box::new(TestPrompter)); let mut perm = UnaryPermission::<NetDescriptor>::default(); for d in &allow_descs { perm.descriptors.insert(UnaryPermissionDesc::Granted(d.clone())); } let idx = revoke_idx % allow_descs.len(); let to_revoke = &allow_descs[idx]; perm.revoke_desc(Some(to_revoke)); // After revoking, the descriptor should not be Granted let state = perm.query_desc( Some(to_revoke), AllowPartial::TreatAsDenied, ); prop_assert_ne!(state, PermissionState::Granted, "revoked descriptor still Granted: {:?}", to_revoke); } #[test] fn revoke_global_clears_all_grants_net( allow_descs in prop::collection::vec(arb_net_descriptor(), 1..5), query in arb_net_descriptor(), ) { set_prompter(Box::new(TestPrompter)); let mut perm = UnaryPermission::<NetDescriptor> { granted_global: true, ..Default::default() }; for d in &allow_descs { perm.descriptors.insert(UnaryPermissionDesc::Granted(d.clone())); } // Revoke global perm.revoke_desc(None); prop_assert!(!perm.granted_global, "granted_global should be false after global revoke"); // No descriptor should be Granted anymore (should be Prompt) let state = perm.query_desc(Some(&query), AllowPartial::TreatAsDenied); prop_assert_ne!(state, PermissionState::Granted, "query still Granted after global revoke: {:?}", query); } } // -- 8. Idempotent insert -- // Inserting the same descriptor twice should not change the vec length. proptest! { #[test] fn idempotent_insert_net( desc in arb_unary_perm_desc_net(), ) { let mut descriptors = UnaryPermissionDescriptors::<NetDescriptor>::default(); descriptors.insert(desc.clone()); let len_after_first = descriptors.inner.len(); descriptors.insert(desc.clone()); let len_after_second = descriptors.inner.len(); prop_assert_eq!(len_after_first, len_after_second, "duplicate insert changed vec length: desc={:?}", desc); } #[test] fn idempotent_insert_env( desc in arb_unary_perm_desc_env(), ) { let mut descriptors = UnaryPermissionDescriptors::<EnvDescriptor>::default(); descriptors.insert(desc.clone()); let len_after_first = descriptors.inner.len(); descriptors.insert(desc.clone()); let len_after_second = descriptors.inner.len(); prop_assert_eq!(len_after_first, len_after_second, "duplicate insert changed vec length: desc={:?}", desc); } } // -- 9. Net matches_allow reflexivity -- // Any NetDescriptor should matches_allow itself. proptest! { #[test] fn net_matches_allow_reflexive( desc in arb_net_descriptor(), ) { prop_assert!(desc.matches_allow(&desc), "descriptor should match its own allow: {:?}", desc); } #[test] fn net_matches_deny_reflexive( desc in arb_net_descriptor(), ) { prop_assert!(desc.matches_deny(&desc), "descriptor should match its own deny: {:?}", desc); } #[test] fn net_stronger_than_deny_reflexive( desc in arb_net_descriptor(), ) { prop_assert!(desc.stronger_than_deny(&desc), "descriptor should be stronger_than_deny of itself: {:?}", desc); } } // -- 10. Child NotGranted has no grants -- // A child created with NotGranted should never return Granted. proptest! { #[test] fn child_not_granted_denies_everything_net( parent_allow in prop::collection::vec(arb_net_descriptor(), 1..5), query in arb_net_descriptor(), ) { set_prompter(Box::new(TestPrompter)); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(false); let mut parent = UnaryPermission::<NetDescriptor>::default(); for d in &parent_allow { parent.descriptors.insert(UnaryPermissionDesc::Granted(d.clone())); } let child = parent.create_child_permissions( ChildUnaryPermissionArg::NotGranted, |s: &str| NetDescriptor::parse_for_list(s).map(Some), ).unwrap(); let state = child.query_desc(Some(&query), AllowPartial::TreatAsDenied); prop_assert_ne!(state, PermissionState::Granted, "NotGranted child returned Granted: query={:?}", query); prop_assert_ne!(state, PermissionState::GrantedPartial, "NotGranted child returned GrantedPartial: query={:?}", query); } #[test] fn child_not_granted_global_not_granted_net( parent_allow in prop::collection::vec(arb_net_descriptor(), 0..3), ) { set_prompter(Box::new(TestPrompter)); let prompt_value = PERMISSION_PROMPT_STUB_VALUE_SETTER.lock(); prompt_value.set(false); let mut parent = UnaryPermission::<NetDescriptor> { granted_global: true, ..Default::default() }; for d in &parent_allow { parent.descriptors.insert(UnaryPermissionDesc::Granted(d.clone())); } let child = parent.create_child_permissions( ChildUnaryPermissionArg::NotGranted, |s: &str| NetDescriptor::parse_for_list(s).map(Some), ).unwrap(); prop_assert!(!child.granted_global, "NotGranted child should not have granted_global"); let state = child.query_desc(None, AllowPartial::TreatAsDenied); prop_assert_ne!(state, PermissionState::Granted, "NotGranted child global query returned Granted"); } } } }