mod build;
mod custom;
mod dispatch;
mod docs;
mod policy;
pub(crate) mod types;
use std::collections::HashMap;
use std::sync::LazyLock;
use crate::parse::Token;
use crate::verdict::Verdict;
pub use build::{build_registry, load_toml};
pub use dispatch::dispatch_spec;
pub use types::{CommandSpec, OwnedPolicy};
use types::DispatchKind;
type HandlerFn = fn(&[Token]) -> Verdict;
static CMD_HANDLERS: LazyLock<HashMap<&'static str, HandlerFn>> =
LazyLock::new(crate::handlers::custom_cmd_handlers);
static SUB_HANDLERS: LazyLock<HashMap<&'static str, HandlerFn>> =
LazyLock::new(crate::handlers::custom_sub_handlers);
static TOML_REGISTRY: LazyLock<HashMap<String, CommandSpec>> = LazyLock::new(||
include!(concat!(env!("OUT_DIR"), "/toml_includes.rs"))
);
static CUSTOM_REGISTRY: LazyLock<HashMap<String, CommandSpec>> = LazyLock::new(|| {
let mut map = HashMap::new();
custom::apply_custom(&mut map);
map
});
pub fn toml_dispatch(tokens: &[Token]) -> Option<Verdict> {
let cmd = tokens[0].command_name();
TOML_REGISTRY.get(cmd).map(|spec| dispatch_spec(tokens, spec))
}
pub fn custom_dispatch(tokens: &[Token]) -> Option<Verdict> {
let cmd = tokens[0].command_name();
CUSTOM_REGISTRY.get(cmd).map(|spec| dispatch_spec(tokens, spec))
}
pub fn toml_command_names() -> Vec<&'static str> {
TOML_REGISTRY
.keys()
.map(|k| k.as_str())
.collect()
}
pub fn try_sub_dispatch(cmd_name: &str, tokens: &[Token]) -> Option<Verdict> {
let spec = handler_spec(cmd_name)?;
let DispatchKind::Custom { subs, .. } = &spec.kind else {
return None;
};
let arg = tokens.get(1)?.as_str();
let sub = subs.iter().find(|s| s.name == arg)?;
Some(dispatch::dispatch_sub_kind(&tokens[1..], &sub.kind))
}
pub fn try_fallback_grammar(cmd_name: &str, tokens: &[Token]) -> Option<Verdict> {
let spec = handler_spec(cmd_name)?;
let DispatchKind::Custom { fallback, .. } = &spec.kind else {
return None;
};
let f = fallback.as_ref()?;
Some(dispatch::dispatch_fallback(tokens, f))
}
pub fn try_matrix_dispatch(cmd_name: &str, tokens: &[Token]) -> Option<Verdict> {
let spec = handler_spec(cmd_name)?;
let DispatchKind::Custom { matrices, handler_policies, .. } = &spec.kind else {
return None;
};
let parent = tokens.get(1)?.as_str();
let action = tokens.get(2)?.as_str();
for matrix in matrices {
if !matrix.parents.iter().any(|p| p == parent) {
continue;
}
let Some(action_spec) = matrix.actions.get(action) else { continue; };
if let Some(long) = action_spec.guard.as_deref()
&& !crate::parse::has_flag(&tokens[2..], action_spec.guard_short.as_deref(), Some(long))
{
return Some(Verdict::Denied);
}
let Some(policy) = handler_policies.get(&action_spec.policy_key) else {
return Some(Verdict::Denied);
};
return Some(dispatch::dispatch_matrix_action(&tokens[2..], policy, matrix.level));
}
None
}
pub fn check_handler_policy(cmd_name: &str, key: &str, tokens: &[Token]) -> bool {
let Some(spec) = handler_spec(cmd_name) else { return false; };
let DispatchKind::Custom { handler_policies, .. } = &spec.kind else {
return false;
};
let Some(policy) = handler_policies.get(key) else { return false; };
dispatch::check_handler_policy_owned(tokens, policy)
}
fn handler_spec(cmd_name: &str) -> Option<&'static CommandSpec> {
CUSTOM_REGISTRY
.get(cmd_name)
.or_else(|| TOML_REGISTRY.get(cmd_name))
}
pub fn is_eval_safe_invocation(tokens: &[Token]) -> bool {
if tokens.is_empty() {
return false;
}
let cmd = tokens[0].command_name();
let Some(spec) = CUSTOM_REGISTRY.get(cmd).or_else(|| TOML_REGISTRY.get(cmd)) else {
return false;
};
is_eval_safe_for_spec(spec, tokens)
}
pub(crate) fn is_eval_safe_for_spec(spec: &CommandSpec, tokens: &[Token]) -> bool {
if tokens.is_empty() {
return false;
}
walk_to_eval_safe_leaf(
&tokens[1..],
&spec.kind,
spec.eval_safe,
&spec.eval_safe_flags,
&spec.eval_safe_flag_values,
&spec.eval_safe_required_flags,
)
}
fn walk_to_eval_safe_leaf(
remaining: &[Token],
kind: &DispatchKind,
eval_safe: bool,
eval_safe_flags: &[String],
eval_safe_flag_values: &std::collections::HashMap<String, Vec<String>>,
eval_safe_required_flags: &[String],
) -> bool {
let subs_opt = match kind {
DispatchKind::Branching { subs, .. } | DispatchKind::Custom { subs, .. } => Some(subs),
_ => None,
};
if let Some(subs) = subs_opt
&& let Some(arg) = remaining.first()
&& let Some(sub) = subs.iter().find(|s| s.name == arg.as_str())
{
return walk_to_eval_safe_leaf(
&remaining[1..],
&sub.kind,
sub.eval_safe,
&sub.eval_safe_flags,
&sub.eval_safe_flag_values,
&sub.eval_safe_required_flags,
);
}
if !eval_safe {
return false;
}
let mut i = 0;
let mut seen_required = false;
while i < remaining.len() {
let s = remaining[i].as_str();
if !s.starts_with('-') {
i += 1;
continue;
}
let (bare, eq_value) = match s.split_once('=') {
Some((k, v)) => (k, Some(v)),
None => (s, None),
};
if !eval_safe_flags.iter().any(|f| f == bare) {
return false;
}
if eval_safe_required_flags.iter().any(|f| f == bare) {
seen_required = true;
}
if let Some(allowed) = eval_safe_flag_values.get(bare) {
let value: &str = if let Some(v) = eq_value {
v
} else if let Some(next) = remaining.get(i + 1) {
let v = next.as_str();
i += 1;
v
} else {
return false;
};
if value.is_empty() {
return false;
}
if !allowed.is_empty() && !allowed.iter().any(|av| av == value) {
return false;
}
}
i += 1;
}
if !eval_safe_required_flags.is_empty() && !seen_required {
return false;
}
true
}
pub fn toml_command_docs() -> Vec<crate::docs::CommandDoc> {
TOML_REGISTRY
.iter()
.filter(|(key, spec)| *key == &spec.name)
.map(|(_, spec)| spec.to_command_doc())
.collect()
}
#[cfg(test)]
mod tests;