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