prost-protovalidate-build 0.6.0

//! String rule code generation.

use proc_macro2::TokenStream;
use quote::quote;

use prost_protovalidate_types::rules_meta::string as meta;
use prost_protovalidate_types::{StringRules, string_rules};

#[allow(clippy::too_many_lines, clippy::cast_possible_truncation)]
pub(crate) fn generate(
    rules: &StringRules,
    value_access: &TokenStream,
    proto_name: &str,
) -> Vec<TokenStream> {
    let mut checks = Vec::new();

    // Const
    if let Some(ref c) = rules.r#const {
        let rule_id = meta::CONST_ID;
        let msg = meta::const_message(c);
        checks.push(quote! {
            if #value_access != #c {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Exact character length
    if let Some(len) = rules.len {
        let len_usize = len as usize;
        let rule_id = meta::LEN_ID;
        let msg = meta::len_message(len);
        checks.push(quote! {
            if #value_access.chars().count() != #len_usize {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Min length (characters)
    if let Some(min) = rules.min_len {
        let min_usize = min as usize;
        let rule_id = meta::MIN_LEN_ID;
        let msg = meta::min_len_message(min);
        checks.push(quote! {
            if #value_access.chars().count() < #min_usize {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Max length (characters)
    if let Some(max) = rules.max_len {
        let max_usize = max as usize;
        let rule_id = meta::MAX_LEN_ID;
        let msg = meta::max_len_message(max);
        checks.push(quote! {
            if #value_access.chars().count() > #max_usize {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Exact byte length
    if let Some(len) = rules.len_bytes {
        let len_usize = len as usize;
        let rule_id = meta::LEN_BYTES_ID;
        let msg = meta::len_bytes_message(len);
        checks.push(quote! {
            if #value_access.len() != #len_usize {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Min bytes
    if let Some(min) = rules.min_bytes {
        let min_usize = min as usize;
        let rule_id = meta::MIN_BYTES_ID;
        let msg = meta::min_bytes_message(min);
        checks.push(quote! {
            if #value_access.len() < #min_usize {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Max bytes
    if let Some(max) = rules.max_bytes {
        let max_usize = max as usize;
        let rule_id = meta::MAX_BYTES_ID;
        let msg = meta::max_bytes_message(max);
        checks.push(quote! {
            if #value_access.len() > #max_usize {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Pattern (regex).
    //
    // The capability analyzer (see `find_invalid_regex` in `codegen.rs`)
    // ensures only valid patterns reach codegen; the `expect` below
    // surfaces a future regex-crate regression loudly instead of
    // misreporting validation as a silent pattern mismatch.
    if let Some(ref pattern) = rules.pattern {
        let rule_id = meta::PATTERN_ID;
        let msg = meta::pattern_message(pattern);
        checks.push(quote! {
            {
                static RE: ::std::sync::LazyLock<::prost_protovalidate::regex::Regex> =
                    ::std::sync::LazyLock::new(|| {
                        ::prost_protovalidate::regex::Regex::new(#pattern)
                            .expect("pattern validated at codegen time")
                    });
                if !RE.is_match(&#value_access) {
                    violations.push(::prost_protovalidate::Violation::new(
                        #proto_name, #rule_id, #msg,
                    ));
                }
            }
        });
    }

    // Prefix
    if let Some(ref prefix) = rules.prefix {
        let rule_id = meta::PREFIX_ID;
        let msg = meta::prefix_message(prefix);
        checks.push(quote! {
            if !#value_access.starts_with(#prefix) {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Suffix
    if let Some(ref suffix) = rules.suffix {
        let rule_id = meta::SUFFIX_ID;
        let msg = meta::suffix_message(suffix);
        checks.push(quote! {
            if !#value_access.ends_with(#suffix) {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Contains
    if let Some(ref contains) = rules.contains {
        let rule_id = meta::CONTAINS_ID;
        let msg = meta::contains_message(contains);
        checks.push(quote! {
            if !#value_access.contains(#contains) {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // Not contains
    if let Some(ref not_contains) = rules.not_contains {
        let rule_id = meta::NOT_CONTAINS_ID;
        let msg = meta::not_contains_message(not_contains);
        checks.push(quote! {
            if #value_access.contains(#not_contains) {
                violations.push(::prost_protovalidate::Violation::new(
                    #proto_name, #rule_id, #msg,
                ));
            }
        });
    }

    // In list — sort to match the deterministic runtime format
    // (`format!("must be in list {sorted:?}")` where `sorted: Vec<&String>`).
    if !rules.r#in.is_empty() {
        let rule_id = meta::IN_ID;
        let msg = meta::in_message(&rules.r#in);
        let mut sorted: Vec<&String> = rules.r#in.iter().collect();
        sorted.sort();
        let vals = sorted;
        checks.push(quote! {
            {
                let _s: &str = &#value_access;
                if ![#(#vals),*].contains(&_s) {
                    violations.push(::prost_protovalidate::Violation::new(
                        #proto_name, #rule_id, #msg,
                    ));
                }
            }
        });
    }

    // Not-in list — same sorted format.
    if !rules.not_in.is_empty() {
        let rule_id = meta::NOT_IN_ID;
        let msg = meta::not_in_message(&rules.not_in);
        let mut sorted: Vec<&String> = rules.not_in.iter().collect();
        sorted.sort();
        let vals = sorted;
        checks.push(quote! {
            {
                let _s: &str = &#value_access;
                if [#(#vals),*].contains(&_s) {
                    violations.push(::prost_protovalidate::Violation::new(
                        #proto_name, #rule_id, #msg,
                    ));
                }
            }
        });
    }

    // Well-known format validators
    let strict = rules.strict.unwrap_or(true);
    if let Some(wk) = rules.well_known {
        checks.extend(generate_well_known(wk, value_access, proto_name, strict));
    }

    checks
}

/// Generate well-known string format checks.
#[allow(clippy::too_many_lines)]
fn generate_well_known(
    wk: string_rules::WellKnown,
    value_access: &TokenStream,
    proto_name: &str,
    strict: bool,
) -> Vec<TokenStream> {
    match wk {
        string_rules::WellKnown::Email(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "email",
                quote! { ::prost_protovalidate::validators::is_email(&#value_access) },
            )]
        }
        string_rules::WellKnown::Hostname(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "hostname",
                quote! { ::prost_protovalidate::validators::is_hostname(&#value_access) },
            )]
        }
        string_rules::WellKnown::Ip(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ip",
                quote! { ::prost_protovalidate::validators::is_ip(&#value_access) },
            )]
        }
        string_rules::WellKnown::Ipv4(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ipv4",
                quote! { ::prost_protovalidate::validators::is_ipv4(&#value_access) },
            )]
        }
        string_rules::WellKnown::Ipv6(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ipv6",
                quote! { ::prost_protovalidate::validators::is_ipv6(&#value_access) },
            )]
        }
        string_rules::WellKnown::Uri(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "uri",
                quote! { ::prost_protovalidate::validators::is_uri(&#value_access) },
            )]
        }
        string_rules::WellKnown::UriRef(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "uri_ref",
                quote! { ::prost_protovalidate::validators::is_uri_ref(&#value_access) },
            )]
        }
        string_rules::WellKnown::Uuid(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "uuid",
                quote! { ::prost_protovalidate::validators::is_uuid(&#value_access) },
            )]
        }
        string_rules::WellKnown::Tuuid(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "tuuid",
                quote! { ::prost_protovalidate::validators::is_tuuid(&#value_access) },
            )]
        }
        string_rules::WellKnown::Ulid(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ulid",
                quote! { ::prost_protovalidate::validators::is_ulid(&#value_access) },
            )]
        }
        string_rules::WellKnown::ProtobufFqn(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "protobuf_fqn",
                quote! { ::prost_protovalidate::validators::is_protobuf_fqn(&#value_access) },
            )]
        }
        string_rules::WellKnown::ProtobufDotFqn(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "protobuf_dot_fqn",
                quote! { ::prost_protovalidate::validators::is_protobuf_dot_fqn(&#value_access) },
            )]
        }
        string_rules::WellKnown::Address(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "address",
                quote! {
                    ::prost_protovalidate::validators::is_hostname(&#value_access)
                    || ::prost_protovalidate::validators::is_ip(&#value_access)
                },
            )]
        }
        string_rules::WellKnown::HostAndPort(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "host_and_port",
                quote! { ::prost_protovalidate::validators::is_host_and_port(&#value_access, false) },
            )]
        }
        string_rules::WellKnown::IpWithPrefixlen(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ip_with_prefixlen",
                quote! { ::prost_protovalidate::validators::is_ip_prefix(&#value_access, false) },
            )]
        }
        string_rules::WellKnown::Ipv4WithPrefixlen(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ipv4_with_prefixlen",
                quote! { ::prost_protovalidate::validators::is_ipv4_prefix(&#value_access, false) },
            )]
        }
        string_rules::WellKnown::Ipv6WithPrefixlen(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ipv6_with_prefixlen",
                quote! { ::prost_protovalidate::validators::is_ipv6_prefix(&#value_access, false) },
            )]
        }
        string_rules::WellKnown::IpPrefix(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ip_prefix",
                quote! { ::prost_protovalidate::validators::is_ip_prefix(&#value_access, true) },
            )]
        }
        string_rules::WellKnown::Ipv4Prefix(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ipv4_prefix",
                quote! { ::prost_protovalidate::validators::is_ipv4_prefix(&#value_access, true) },
            )]
        }
        string_rules::WellKnown::Ipv6Prefix(true) => {
            vec![format_check(
                value_access,
                proto_name,
                "ipv6_prefix",
                quote! { ::prost_protovalidate::validators::is_ipv6_prefix(&#value_access, true) },
            )]
        }
        string_rules::WellKnown::WellKnownRegex(kind) => {
            match prost_protovalidate_types::KnownRegex::try_from(kind) {
                Ok(prost_protovalidate_types::KnownRegex::HttpHeaderName) => {
                    let empty_id = meta::HEADER_NAME_EMPTY_ID;
                    let id = meta::HEADER_NAME_ID;
                    let path = meta::WELL_KNOWN_REGEX_PATH;
                    vec![quote! {
                        if !::prost_protovalidate::validators::is_http_header_name(&#value_access, #strict) {
                            let rule_id = if #value_access.is_empty() { #empty_id } else { #id };
                            violations.push(::prost_protovalidate::Violation::new_constraint(
                                #proto_name, rule_id, #path,
                            ));
                        }
                    }]
                }
                Ok(prost_protovalidate_types::KnownRegex::HttpHeaderValue) => {
                    let id = meta::HEADER_VALUE_ID;
                    let path = meta::WELL_KNOWN_REGEX_PATH;
                    vec![quote! {
                        if !::prost_protovalidate::validators::is_http_header_value(&#value_access, #strict) {
                            violations.push(::prost_protovalidate::Violation::new_constraint(
                                #proto_name, #id, #path,
                            ));
                        }
                    }]
                }
                _ => Vec::new(),
            }
        }
        _ => Vec::new(),
    }
}

/// Generate the standard two-phase format check:
/// 1. Empty string → `{format}_empty` violation
/// 2. Invalid format → `string.{format}` violation
#[allow(clippy::needless_pass_by_value)]
fn format_check(
    value_access: &TokenStream,
    proto_name: &str,
    format_name: &str,
    is_valid: TokenStream,
) -> TokenStream {
    let empty_rule_id = meta::well_known_empty_id(format_name);
    let format_rule_id = meta::well_known_id(format_name);
    let rule_path = meta::well_known_id(format_name);

    quote! {
        if #value_access.is_empty() {
            violations.push(::prost_protovalidate::Violation::new_constraint(
                #proto_name, #empty_rule_id, #rule_path,
            ));
        } else if !(#is_valid) {
            violations.push(::prost_protovalidate::Violation::new_constraint(
                #proto_name, #format_rule_id, #rule_path,
            ));
        }
    }
}