|
1 | 1 | use std::borrow::Cow;
|
2 | 2 | use std::collections::HashMap;
|
3 | 3 | use std::hash::BuildHasher;
|
| 4 | +use std::sync::{Arc, Mutex}; |
4 | 5 |
|
5 | 6 | use config::Config;
|
| 7 | + |
6 | 8 | use libs::base64::engine::{general_purpose::STANDARD as standard_b64, Engine};
|
| 9 | +use libs::regex::Regex; |
7 | 10 | use libs::tera::{
|
8 | 11 | to_value, try_get_value, Error as TeraError, Filter as TeraFilter, Result as TeraResult, Tera,
|
9 | 12 | Value,
|
@@ -78,6 +81,53 @@ pub fn base64_decode<S: BuildHasher>(
|
78 | 81 | Ok(to_value(as_str).unwrap())
|
79 | 82 | }
|
80 | 83 |
|
| 84 | +#[derive(Debug)] |
| 85 | +pub struct RegexReplaceFilter { |
| 86 | + re_cache: Arc<Mutex<HashMap<String, Regex>>>, |
| 87 | +} |
| 88 | + |
| 89 | +impl RegexReplaceFilter { |
| 90 | + pub fn new() -> Self { |
| 91 | + return Self { re_cache: Arc::new(Mutex::new(HashMap::new())) }; |
| 92 | + } |
| 93 | +} |
| 94 | + |
| 95 | +impl TeraFilter for RegexReplaceFilter { |
| 96 | + fn filter(&self, value: &Value, args: &HashMap<String, Value>) -> TeraResult<Value> { |
| 97 | + let text = try_get_value!("regex_replace", "value", String, value); |
| 98 | + let pattern = match args.get("pattern") { |
| 99 | + Some(val) => try_get_value!("regex_replace", "pattern", String, val), |
| 100 | + None => { |
| 101 | + return Err(TeraError::msg( |
| 102 | + "Filter `regex_replace` expected an arg called `pattern`", |
| 103 | + )) |
| 104 | + } |
| 105 | + }; |
| 106 | + let rep = match args.get("rep") { |
| 107 | + Some(val) => try_get_value!("regex_replace", "rep", String, val), |
| 108 | + None => { |
| 109 | + return Err(TeraError::msg("Filter `regex_replace` expected an arg called `rep`")) |
| 110 | + } |
| 111 | + }; |
| 112 | + |
| 113 | + let mut cache = self.re_cache.lock().expect("re_cache lock"); |
| 114 | + let replaced = { |
| 115 | + match cache.get(&pattern) { |
| 116 | + Some(pat) => pat.replace_all(&text, &rep), |
| 117 | + None => { |
| 118 | + let pat = Regex::new(&pattern) |
| 119 | + .map_err(|e| format!("`regex_replace`: failed to compile regex: {}", e))?; |
| 120 | + let replaced = pat.replace_all(&text, &rep); |
| 121 | + cache.insert(pattern, pat); |
| 122 | + replaced |
| 123 | + } |
| 124 | + } |
| 125 | + }; |
| 126 | + |
| 127 | + Ok(to_value(replaced).unwrap()) |
| 128 | + } |
| 129 | +} |
| 130 | + |
81 | 131 | #[derive(Debug)]
|
82 | 132 | pub struct NumFormatFilter {
|
83 | 133 | default_language: String,
|
@@ -114,7 +164,9 @@ mod tests {
|
114 | 164 |
|
115 | 165 | use libs::tera::{to_value, Filter, Tera};
|
116 | 166 |
|
117 |
| - use super::{base64_decode, base64_encode, MarkdownFilter, NumFormatFilter}; |
| 167 | + use super::{ |
| 168 | + base64_decode, base64_encode, MarkdownFilter, NumFormatFilter, RegexReplaceFilter, |
| 169 | + }; |
118 | 170 | use config::Config;
|
119 | 171 |
|
120 | 172 | #[test]
|
@@ -251,6 +303,22 @@ mod tests {
|
251 | 303 | }
|
252 | 304 | }
|
253 | 305 |
|
| 306 | + #[test] |
| 307 | + fn regex_replace_filter() { |
| 308 | + let value = "Springsteen, Bruce"; |
| 309 | + let expected = "Bruce Springsteen"; |
| 310 | + let pattern = r"(?P<last>[^,\s]+),\s+(?P<first>\S+)"; |
| 311 | + let rep = "$first $last"; |
| 312 | + let mut args = HashMap::new(); |
| 313 | + args.insert("pattern".to_string(), to_value(pattern).unwrap()); |
| 314 | + args.insert("rep".to_string(), to_value(rep).unwrap()); |
| 315 | + let regex_replace = RegexReplaceFilter::new(); |
| 316 | + let result = regex_replace.filter(&to_value(value).unwrap(), &args); |
| 317 | + assert!(result.is_ok()); |
| 318 | + assert_eq!(result.unwrap(), to_value(expected).unwrap()); |
| 319 | + assert!(regex_replace.re_cache.lock().unwrap().contains_key(pattern)); |
| 320 | + } |
| 321 | + |
254 | 322 | #[test]
|
255 | 323 | fn num_format_filter() {
|
256 | 324 | let tests = vec![
|
|
0 commit comments