opal/pipeline/

rules.rs

// TODO: This should be a rules engine that can evaluate rules, but is split without any logic
// between structs and free floating functions.
use crate::git;
use crate::gitlab::rules::{JobRule, RuleChangesRaw, RuleExistsRaw};
use crate::gitlab::{Job, PipelineFilters};
use crate::model::{JobSpec, PipelineFilterSpec};
use crate::naming::job_name_slug;
use anyhow::{Context, Result, anyhow, bail};
use globset::{Glob, GlobSetBuilder};
use regex::RegexBuilder;
use std::collections::HashMap;
use std::path::{Path, PathBuf};
use std::str::FromStr;
use std::time::Duration;

#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum RuleWhen {
    #[default]
    OnSuccess,
    Manual,
    Delayed,
    Never,
    Always,
    OnFailure,
}

impl RuleWhen {
    pub fn requires_success(self) -> bool {
        matches!(self, RuleWhen::OnSuccess | RuleWhen::Delayed)
    }

    pub fn runs_when_failed(self) -> bool {
        matches!(self, RuleWhen::Always | RuleWhen::OnFailure)
    }
}

#[derive(Debug, Default, Clone)]
pub struct RuleEvaluation {
    pub included: bool,
    pub when: RuleWhen,
    pub allow_failure: bool,
    pub start_in: Option<Duration>,
    pub variables: HashMap<String, String>,
    pub manual_auto_run: bool,
    pub manual_reason: Option<String>,
}

impl RuleEvaluation {
    fn default() -> Self {
        Self {
            included: true,
            when: RuleWhen::OnSuccess,
            allow_failure: false,
            start_in: None,
            variables: HashMap::new(),
            manual_auto_run: false,
            manual_reason: None,
        }
    }
}

#[derive(Debug, Clone)]
pub struct RuleContext {
    pub workspace: PathBuf,
    pub env: HashMap<String, String>,
    run_manual: bool,
    default_compare_to: Option<String>,
    tag_resolution_error: Option<String>,
}

pub trait RuleJob {
    fn rules(&self) -> &[JobRule];
}

pub trait RuleFilters {
    fn only_filters(&self) -> &[String];
    fn except_filters(&self) -> &[String];
}

impl RuleJob for Job {
    fn rules(&self) -> &[JobRule] {
        &self.rules
    }
}

impl RuleJob for JobSpec {
    fn rules(&self) -> &[JobRule] {
        &self.rules
    }
}

impl RuleFilters for JobSpec {
    fn only_filters(&self) -> &[String] {
        &self.only
    }

    fn except_filters(&self) -> &[String] {
        &self.except
    }
}

impl RuleFilters for PipelineFilters {
    fn only_filters(&self) -> &[String] {
        &self.only
    }

    fn except_filters(&self) -> &[String] {
        &self.except
    }
}

impl RuleFilters for PipelineFilterSpec {
    fn only_filters(&self) -> &[String] {
        &self.only
    }

    fn except_filters(&self) -> &[String] {
        &self.except
    }
}

impl RuleContext {
    pub fn new(workspace: &Path) -> Self {
        let run_manual = std::env::var("OPAL_RUN_MANUAL").is_ok_and(|v| v == "1");
        Self::from_env(workspace, std::env::vars().collect(), run_manual)
    }

    pub fn from_env(workspace: &Path, mut env: HashMap<String, String>, run_manual: bool) -> Self {
        let mut tag_resolution_error = None;
        if !env.contains_key("CI_PIPELINE_SOURCE") {
            env.insert("CI_PIPELINE_SOURCE".into(), "push".into());
        }
        if env
            .get("CI_COMMIT_TAG")
            .is_none_or(|value| value.is_empty())
            && let Some(tag) = env
                .get("GIT_COMMIT_TAG")
                .filter(|value| !value.is_empty())
                .cloned()
        {
            env.insert("CI_COMMIT_TAG".into(), tag);
        }
        if !env.contains_key("CI_COMMIT_BRANCH")
            && env.get("CI_COMMIT_TAG").is_none_or(|tag| tag.is_empty())
            && let Ok(branch) = git::current_branch(workspace)
        {
            env.insert("CI_COMMIT_BRANCH".into(), branch);
        }
        if env.get("CI_COMMIT_TAG").is_none_or(|tag| tag.is_empty()) {
            match git::current_tag(workspace) {
                Ok(tag) => {
                    env.insert("CI_COMMIT_TAG".into(), tag);
                }
                Err(err) => {
                    let message = err.to_string();
                    if message.contains("multiple tags point at HEAD") {
                        tag_resolution_error = Some(message);
                    }
                }
            }
        }
        if !env.contains_key("CI_COMMIT_REF_NAME") {
            if let Some(tag) = env
                .get("CI_COMMIT_TAG")
                .filter(|tag| !tag.is_empty())
                .cloned()
            {
                env.insert("CI_COMMIT_REF_NAME".into(), tag);
            } else if let Some(branch) = env
                .get("CI_COMMIT_BRANCH")
                .filter(|branch| !branch.is_empty())
                .cloned()
            {
                env.insert("CI_COMMIT_REF_NAME".into(), branch);
            }
        }
        if !env.contains_key("CI_COMMIT_REF_SLUG")
            && let Some(ref_name) = env.get("CI_COMMIT_REF_NAME").cloned()
        {
            let slug = job_name_slug(&ref_name);
            if !slug.is_empty() {
                env.insert("CI_COMMIT_REF_SLUG".into(), slug);
            }
        }
        if !env.contains_key("CI_DEFAULT_BRANCH")
            && let Ok(branch) = git::default_branch(workspace)
        {
            env.insert("CI_DEFAULT_BRANCH".into(), branch);
        }
        let default_compare_to = env.get("CI_DEFAULT_BRANCH").cloned();
        Self {
            workspace: workspace.to_path_buf(),
            env,
            run_manual,
            default_compare_to,
            tag_resolution_error,
        }
    }

    pub fn env_value(&self, name: &str) -> Option<&str> {
        self.env.get(name).map(|s| s.as_str())
    }

    pub fn var_value(&self, name: &str) -> String {
        self.env
            .get(name)
            .cloned()
            .unwrap_or_else(|| std::env::var(name).unwrap_or_default())
    }

    pub fn pipeline_source(&self) -> &str {
        self.env_value("CI_PIPELINE_SOURCE").unwrap_or("push")
    }

    pub fn tag_resolution_error(&self) -> Option<&str> {
        self.tag_resolution_error.as_deref()
    }

    pub fn ensure_valid_tag_context(&self) -> Result<()> {
        if let Some(message) = self.tag_resolution_error() {
            bail!("{message}");
        }
        Ok(())
    }

    pub fn compare_reference(&self, override_ref: Option<&str>) -> Option<String> {
        if let Some(raw) = override_ref {
            let expanded = self.expand_variables(raw);
            if expanded.is_empty() {
                None
            } else {
                Some(expanded)
            }
        } else {
            self.inferred_compare_reference()
        }
    }

    pub fn head_reference(&self) -> Option<String> {
        self.env_value("CI_COMMIT_SHA")
            .filter(|sha| !sha.is_empty())
            .map(|sha| sha.to_string())
            .or_else(|| git::head_ref(&self.workspace).ok())
    }

    fn expand_variables(&self, value: &str) -> String {
        let mut output = String::new();
        let chars: Vec<char> = value.chars().collect();
        let mut idx = 0;
        while idx < chars.len() {
            let ch = chars[idx];
            if ch == '$' {
                if idx + 1 < chars.len() && chars[idx + 1] == '{' {
                    let mut end = idx + 2;
                    while end < chars.len() && chars[end] != '}' {
                        end += 1;
                    }
                    if end < chars.len() {
                        let name: String = chars[idx + 2..end].iter().collect();
                        output.push_str(self.env_value(&name).unwrap_or(""));
                        idx = end + 1;
                        continue;
                    }
                } else {
                    let mut end = idx + 1;
                    while end < chars.len()
                        && (chars[end].is_ascii_alphanumeric() || chars[end] == '_')
                    {
                        end += 1;
                    }
                    if end > idx + 1 {
                        let name: String = chars[idx + 1..end].iter().collect();
                        output.push_str(self.env_value(&name).unwrap_or(""));
                        idx = end;
                        continue;
                    }
                }
            }
            output.push(ch);
            idx += 1;
        }
        output
    }

    fn inferred_compare_reference(&self) -> Option<String> {
        let source = self.pipeline_source();
        let inferred = match source {
            "merge_request_event" => self
                .env_value("CI_MERGE_REQUEST_DIFF_BASE_SHA")
                .or_else(|| self.env_value("CI_MERGE_REQUEST_TARGET_BRANCH_SHA"))
                .map(|s| s.to_string())
                .or_else(|| {
                    self.env_value("CI_MERGE_REQUEST_TARGET_BRANCH_NAME")
                        .map(|branch| format!("origin/{branch}"))
                }),
            "push" | "schedule" | "pipeline" | "web" => {
                if let Some(before) = self
                    .env_value("CI_COMMIT_BEFORE_SHA")
                    .filter(|sha| !Self::is_zero_sha(sha))
                    .map(|s| s.to_string())
                {
                    Some(before)
                } else if let Some(default_branch) = &self.default_compare_to {
                    git::merge_base(
                        &self.workspace,
                        default_branch,
                        self.head_reference().as_deref(),
                    )
                    .ok()
                    .flatten()
                } else {
                    None
                }
            }
            _ => None,
        };
        inferred.or_else(|| self.default_compare_to.clone())
    }

    fn is_zero_sha(value: &str) -> bool {
        !value.is_empty() && value.chars().all(|ch| ch == '0')
    }
}

pub fn evaluate_rules(job: &impl RuleJob, ctx: &RuleContext) -> Result<RuleEvaluation> {
    if job.rules().is_empty() {
        return Ok(RuleEvaluation::default());
    }

    for rule in job.rules() {
        if !rule_matches(rule, ctx)? {
            continue;
        }
        return Ok(apply_rule(rule, ctx));
    }

    Ok(RuleEvaluation {
        included: false,
        when: RuleWhen::Never,
        ..RuleEvaluation::default()
    })
}

pub fn evaluate_workflow(rules: &[JobRule], ctx: &RuleContext) -> Result<bool> {
    if rules.is_empty() {
        return Ok(true);
    }
    for rule in rules {
        if !rule_matches(rule, ctx)? {
            continue;
        }
        let evaluation = apply_rule(rule, ctx);
        return Ok(evaluation.included);
    }
    Ok(false)
}

fn rule_matches(rule: &JobRule, ctx: &RuleContext) -> Result<bool> {
    if let Some(if_expr) = &rule.if_expr
        && !eval_if_expr(if_expr, ctx)?
    {
        return Ok(false);
    }
    if let Some(changes) = &rule.changes
        && !matches_changes(changes, ctx)?
    {
        return Ok(false);
    }
    if let Some(exists) = &rule.exists
        && !matches_exists(exists, ctx)?
    {
        return Ok(false);
    }
    Ok(true)
}

fn apply_rule(rule: &JobRule, ctx: &RuleContext) -> RuleEvaluation {
    let mut result = RuleEvaluation::default();
    result.variables = rule.variables.clone();
    if let Some(allow) = rule.allow_failure {
        result.allow_failure = allow;
    }
    result.manual_auto_run = ctx.run_manual;
    apply_when_config(
        &mut result,
        rule.when.as_deref(),
        rule.start_in.as_deref(),
        Some("manual job (rules)"),
    );

    result
}

pub(crate) fn apply_when_config(
    result: &mut RuleEvaluation,
    when: Option<&str>,
    start_in: Option<&str>,
    manual_reason: Option<&str>,
) {
    if let Some(when) = when {
        match when {
            "manual" => {
                result.when = RuleWhen::Manual;
                result.manual_reason = manual_reason.map(str::to_string);
            }
            "delayed" => {
                result.when = RuleWhen::Delayed;
                if let Some(start) = start_in
                    && let Some(dur) = parse_duration(start)
                {
                    result.start_in = Some(dur);
                }
            }
            "never" => {
                result.when = RuleWhen::Never;
                result.included = false;
            }
            "always" => {
                result.when = RuleWhen::Always;
            }
            "on_failure" => {
                result.when = RuleWhen::OnFailure;
            }
            _ => {
                result.when = RuleWhen::OnSuccess;
            }
        }
    }
}

fn matches_changes(changes: &RuleChangesRaw, ctx: &RuleContext) -> Result<bool> {
    let paths = changes.paths();
    if paths.is_empty() {
        return Ok(false);
    }
    let compare_ref = ctx.compare_reference(changes.compare_to());
    let head_ref = ctx.head_reference();
    let changed = git::changed_files(&ctx.workspace, compare_ref.as_deref(), head_ref.as_deref())?;
    if changed.is_empty() {
        return Ok(false);
    }
    let mut builder = GlobSetBuilder::new();
    for pattern in paths {
        builder.add(Glob::new(pattern).with_context(|| format!("invalid glob '{pattern}'"))?);
    }
    let glob = builder.build()?;
    for path in changed {
        if glob.is_match(&path) {
            return Ok(true);
        }
    }
    Ok(false)
}

fn matches_exists(exists: &RuleExistsRaw, ctx: &RuleContext) -> Result<bool> {
    let paths = exists.paths();
    if paths.is_empty() {
        return Ok(false);
    }
    for pattern in paths {
        let matched = if pattern.contains('*') || pattern.contains('?') {
            let glob = Glob::new(pattern)
                .with_context(|| format!("invalid exists pattern '{pattern}'"))?
                .compile_matcher();
            walk_paths(&ctx.workspace, &glob)?
        } else {
            vec![ctx.workspace.join(pattern)]
        };
        if matched.iter().any(|path| path.exists()) {
            return Ok(true);
        }
    }
    Ok(false)
}

fn walk_paths(root: &Path, matcher: &globset::GlobMatcher) -> Result<Vec<PathBuf>> {
    let mut matches = Vec::new();
    for entry in walkdir::WalkDir::new(root).follow_links(false) {
        let entry = entry?;
        let rel = entry
            .path()
            .strip_prefix(root)
            .unwrap_or(entry.path())
            .to_path_buf();
        if matcher.is_match(rel) {
            matches.push(entry.path().to_path_buf());
        }
    }
    Ok(matches)
}

fn parse_duration(value: &str) -> Option<Duration> {
    humantime::Duration::from_str(value).map(|d| d.into()).ok()
}

fn eval_if_expr(expr: &str, ctx: &RuleContext) -> Result<bool> {
    let mut parser = ExprParser::new(expr, ctx);
    let value = parser.parse_expression()?;
    Ok(value)
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::git::test_support::{init_repo_with_commit_and_tag, init_repo_with_commit_and_tags};
    use anyhow::Result;
    use std::collections::HashMap;
    use tempfile::tempdir;

    #[test]
    fn infers_commit_tag_from_repo_when_env_is_missing() -> Result<()> {
        let dir = init_repo_with_commit_and_tag("v1.2.3")?;

        let ctx = RuleContext::from_env(dir.path(), HashMap::new(), false);

        assert_eq!(ctx.env_value("CI_COMMIT_TAG"), Some("v1.2.3"));
        assert_eq!(ctx.env_value("CI_COMMIT_REF_NAME"), Some("v1.2.3"));
        Ok(())
    }

    #[test]
    fn maps_git_commit_tag_to_ci_commit_tag() {
        let dir = tempdir().expect("tempdir");
        let ctx = RuleContext::from_env(
            dir.path(),
            HashMap::from([("GIT_COMMIT_TAG".into(), "opal-recheck-123".into())]),
            false,
        );

        assert_eq!(ctx.env_value("CI_COMMIT_TAG"), Some("opal-recheck-123"));
        assert_eq!(
            ctx.env_value("CI_COMMIT_REF_NAME"),
            Some("opal-recheck-123")
        );
        assert_eq!(
            ctx.env_value("CI_COMMIT_REF_SLUG"),
            Some("opal-recheck-123")
        );
        assert!(ctx.env_value("CI_COMMIT_BRANCH").is_none());
    }

    #[test]
    fn captures_error_for_ambiguous_git_tag_context() -> Result<()> {
        let dir = init_repo_with_commit_and_tags(&["v0.1.2", "v0.1.3"])?;
        let ctx = RuleContext::from_env(dir.path(), HashMap::new(), false);

        assert!(ctx.env_value("CI_COMMIT_TAG").is_none());
        assert!(
            ctx.tag_resolution_error()
                .is_some_and(|err| err.contains("multiple tags point at HEAD"))
        );
        Ok(())
    }

    #[test]
    fn explicit_tag_overrides_ambiguous_git_tag_context() -> Result<()> {
        let dir = init_repo_with_commit_and_tags(&["v0.1.2", "v0.1.3"])?;
        let ctx = RuleContext::from_env(
            dir.path(),
            HashMap::from([("GIT_COMMIT_TAG".into(), "v0.1.3".into())]),
            false,
        );

        assert_eq!(ctx.env_value("CI_COMMIT_TAG"), Some("v0.1.3"));
        assert!(ctx.tag_resolution_error().is_none());
        Ok(())
    }

    #[test]
    fn empty_ci_commit_tag_still_records_ambiguous_git_tag_error() -> Result<()> {
        let dir = init_repo_with_commit_and_tags(&["v0.1.2", "v0.1.3"])?;
        let ctx = RuleContext::from_env(
            dir.path(),
            HashMap::from([("CI_COMMIT_TAG".into(), String::new())]),
            false,
        );

        assert!(
            ctx.env_value("CI_COMMIT_TAG")
                .is_none_or(|tag| tag.is_empty())
        );
        assert!(
            ctx.tag_resolution_error()
                .is_some_and(|err| err.contains("multiple tags point at HEAD"))
        );
        Ok(())
    }

    #[test]
    fn ensure_valid_tag_context_errors_for_ambiguous_git_tags() -> Result<()> {
        let dir = init_repo_with_commit_and_tags(&["v0.1.2", "v0.1.3"])?;
        let ctx = RuleContext::from_env(dir.path(), HashMap::new(), false);

        let err = ctx
            .ensure_valid_tag_context()
            .expect_err("ambiguous tag context should fail");
        assert!(err.to_string().contains("multiple tags point at HEAD"));
        Ok(())
    }
}

struct ExprParser {
    tokens: Vec<Token>,
    pos: usize,
}

impl ExprParser {
    fn new(input: &str, ctx: &RuleContext) -> Self {
        let tokens = tokenize(input, ctx);
        Self { tokens, pos: 0 }
    }

    fn parse_expression(&mut self) -> Result<bool> {
        self.parse_or()
    }

    fn parse_or(&mut self) -> Result<bool> {
        let mut value = self.parse_and()?;
        while self.matches(TokenKind::Or) {
            value = value || self.parse_and()?;
        }
        Ok(value)
    }

    fn parse_and(&mut self) -> Result<bool> {
        let mut value = self.parse_not()?;
        while self.matches(TokenKind::And) {
            value = value && self.parse_not()?;
        }
        Ok(value)
    }

    fn parse_not(&mut self) -> Result<bool> {
        if self.matches(TokenKind::Not) {
            return Ok(!self.parse_not()?);
        }
        self.parse_comparison()
    }

    fn parse_comparison(&mut self) -> Result<bool> {
        if self.matches(TokenKind::LParen) {
            let value = self.parse_expression()?;
            self.consume(TokenKind::RParen)?;
            return Ok(value);
        }
        let left = self.parse_operand()?;
        if let Some(op) = self.peek_operator() {
            self.advance();
            let right = self.parse_operand()?;
            return self.evaluate_comparator(op, left, right);
        }
        Ok(!left.is_empty())
    }

    fn evaluate_comparator(&self, op: TokenKind, left: String, right: String) -> Result<bool> {
        match op {
            TokenKind::Eq => Ok(left == right),
            TokenKind::Ne => Ok(left != right),
            TokenKind::RegexEq => Ok(match_regex(&left, &right)?),
            TokenKind::RegexNe => Ok(!match_regex(&left, &right)?),
            _ => Err(anyhow!("unsupported comparator")),
        }
    }

    fn parse_operand(&mut self) -> Result<String> {
        if self.matches(TokenKind::Variable) {
            return Ok(self.last_token_value().unwrap_or_default());
        }
        if self.matches(TokenKind::Literal) {
            return Ok(self.last_token_value().unwrap_or_default());
        }
        Err(anyhow!("expected operand"))
    }

    fn matches(&mut self, kind: TokenKind) -> bool {
        if self.check(kind) {
            self.advance();
            true
        } else {
            false
        }
    }

    fn check(&self, kind: TokenKind) -> bool {
        self.tokens
            .get(self.pos)
            .map(|t| t.kind == kind)
            .unwrap_or(false)
    }

    fn advance(&mut self) {
        self.pos += 1;
    }

    fn consume(&mut self, kind: TokenKind) -> Result<()> {
        if self.check(kind) {
            self.advance();
            Ok(())
        } else {
            Err(anyhow!("expected token"))
        }
    }

    fn peek_operator(&self) -> Option<TokenKind> {
        self.tokens.get(self.pos).and_then(|t| match t.kind {
            TokenKind::Eq | TokenKind::Ne | TokenKind::RegexEq | TokenKind::RegexNe => Some(t.kind),
            _ => None,
        })
    }

    fn last_token_value(&self) -> Option<String> {
        self.tokens.get(self.pos - 1).and_then(|t| t.value.clone())
    }
}

#[derive(Debug, Clone, Copy, PartialEq)]
enum TokenKind {
    And,
    Or,
    Not,
    LParen,
    RParen,
    Eq,
    Ne,
    RegexEq,
    RegexNe,
    Variable,
    Literal,
}

#[derive(Debug, Clone)]
struct Token {
    kind: TokenKind,
    value: Option<String>,
}

fn tokenize(input: &str, ctx: &RuleContext) -> Vec<Token> {
    let mut tokens = Vec::new();
    let chars: Vec<char> = input.chars().collect();
    let mut idx = 0;
    while idx < chars.len() {
        match chars[idx] {
            ' ' | '\t' | '\n' => idx += 1,
            '&' if idx + 1 < chars.len() && chars[idx + 1] == '&' => {
                tokens.push(Token {
                    kind: TokenKind::And,
                    value: None,
                });
                idx += 2;
            }
            '|' if idx + 1 < chars.len() && chars[idx + 1] == '|' => {
                tokens.push(Token {
                    kind: TokenKind::Or,
                    value: None,
                });
                idx += 2;
            }
            '!' if idx + 1 < chars.len() && chars[idx + 1] == '=' => {
                tokens.push(Token {
                    kind: TokenKind::Ne,
                    value: None,
                });
                idx += 2;
            }
            '=' if idx + 1 < chars.len() && chars[idx + 1] == '=' => {
                tokens.push(Token {
                    kind: TokenKind::Eq,
                    value: None,
                });
                idx += 2;
            }
            '=' if idx + 1 < chars.len() && chars[idx + 1] == '~' => {
                tokens.push(Token {
                    kind: TokenKind::RegexEq,
                    value: None,
                });
                idx += 2;
            }
            '!' if idx + 1 < chars.len() && chars[idx + 1] == '~' => {
                tokens.push(Token {
                    kind: TokenKind::RegexNe,
                    value: None,
                });
                idx += 2;
            }
            '!' => {
                tokens.push(Token {
                    kind: TokenKind::Not,
                    value: None,
                });
                idx += 1;
            }
            '(' => {
                tokens.push(Token {
                    kind: TokenKind::LParen,
                    value: None,
                });
                idx += 1;
            }
            ')' => {
                tokens.push(Token {
                    kind: TokenKind::RParen,
                    value: None,
                });
                idx += 1;
            }
            '$' => {
                let start = idx + 1;
                idx = start;
                while idx < chars.len()
                    && (chars[idx].is_ascii_alphanumeric()
                        || chars[idx] == '_'
                        || chars[idx] == ':')
                {
                    idx += 1;
                }
                let name = input[start..idx].to_string();
                let value = ctx.var_value(&name);
                tokens.push(Token {
                    kind: TokenKind::Variable,
                    value: Some(value),
                });
            }
            '\'' | '"' => {
                let quote = chars[idx];
                idx += 1;
                let start = idx;
                while idx < chars.len() && chars[idx] != quote {
                    idx += 1;
                }
                let value = input[start..idx].to_string();
                idx += 1;
                tokens.push(Token {
                    kind: TokenKind::Literal,
                    value: Some(value),
                });
            }
            _ => {
                let start = idx;
                while idx < chars.len()
                    && !chars[idx].is_whitespace()
                    && !matches!(chars[idx], '(' | ')' | '&' | '|' | '=' | '!')
                {
                    idx += 1;
                }
                let value = input[start..idx].to_string();
                tokens.push(Token {
                    kind: TokenKind::Literal,
                    value: Some(value),
                });
            }
        }
    }
    tokens
}

fn match_regex(value: &str, pattern: &str) -> Result<bool> {
    let (body, flags) = if let Some(stripped) = pattern.strip_prefix('/') {
        if let Some(end) = stripped.rfind('/') {
            let body = &stripped[..end];
            let flag = &stripped[end + 1..];
            (body.to_string(), flag.to_string())
        } else {
            (pattern.to_string(), String::new())
        }
    } else {
        (pattern.to_string(), String::new())
    };
    let mut builder = RegexBuilder::new(&body);
    if flags.contains('i') {
        builder.case_insensitive(true);
    }
    let regex = builder.build()?;
    Ok(regex.is_match(value))
}

pub fn filters_allow(filters: &impl RuleFilters, ctx: &RuleContext) -> bool {
    if filters.only_filters().is_empty() {
        if filters
            .except_filters()
            .iter()
            .any(|filter| filter_matches(filter, ctx))
        {
            return false;
        }
        return true;
    }
    let passes_only = filters
        .only_filters()
        .iter()
        .any(|filter| filter_matches(filter, ctx));
    if !passes_only {
        return false;
    }
    !filters
        .except_filters()
        .iter()
        .any(|filter| filter_matches(filter, ctx))
}

fn filter_matches(filter: &str, ctx: &RuleContext) -> bool {
    if let Some(expr) = filter.strip_prefix("__opal_variables__:") {
        return eval_if_expr(expr, ctx).unwrap_or(false);
    }
    match filter {
        "branches" => ctx
            .env_value("CI_COMMIT_BRANCH")
            .map(|s| !s.is_empty())
            .unwrap_or(false),
        "tags" => ctx
            .env_value("CI_COMMIT_TAG")
            .map(|s| !s.is_empty())
            .unwrap_or(false),
        "merge_requests" => ctx.pipeline_source() == "merge_request_event",
        "schedules" => ctx.pipeline_source() == "schedule",
        "pushes" => ctx.pipeline_source() == "push",
        "api" => ctx.pipeline_source() == "api",
        "web" => ctx.pipeline_source() == "web",
        "triggers" => ctx.pipeline_source() == "trigger",
        "pipelines" => matches!(ctx.pipeline_source(), "pipeline" | "parent_pipeline"),
        "external_pull_requests" => ctx.pipeline_source() == "external_pull_request_event",
        pattern => {
            if let Some(ref_name) = ctx
                .env_value("CI_COMMIT_REF_NAME")
                .filter(|s| !s.is_empty())
                .or_else(|| ctx.env_value("CI_COMMIT_BRANCH").filter(|s| !s.is_empty()))
                .or_else(|| ctx.env_value("CI_COMMIT_TAG").filter(|s| !s.is_empty()))
            {
                if pattern.starts_with('/') {
                    match_regex(ref_name, pattern).unwrap_or_default()
                } else {
                    ref_name == pattern
                }
            } else {
                false
            }
        }
    }
}