alamin/websurfx
alamin/websurfx
0
0
Fork 0
mirror of https://github.com/neon-mmd/websurfx.git synced 2024-11-22 14:08:23 -05:00
Code Issues Releases Activity

🧹 chore: make github actions happy (#203)

Browse Source
This commit is contained in:
neon_arch 2023-09-11 20:16:42 +03:00
parent 30ca95a217
commit b9d651c378
1 changed files with 37 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
src/config/parser.rs
View File

@ -36,6 +36,7 @@ pub struct Config {
pub request_timeout: u8, pub request_timeout: u8,
pub threads: u8, pub threads: u8,
pub rate_limiter: RateLimiter, pub rate_limiter: RateLimiter,
pub safe_search: u8,
} }
impl Config { impl Config {
@ -79,33 +80,44 @@ impl Config {
parsed_threads parsed_threads
}; };
let rate_limiter = globals.get::<_,HashMap<String, u8>>("rate_limiter")?; let rate_limiter = globals.get::<_, HashMap<String, u8>>("rate_limiter")?;
Ok(Config { let parsed_safe_search: u8 = globals.get::<_, u8>("safe_search")?;
port: globals.get::<_, u16>("port")?, let safe_search: u8 = match parsed_safe_search {
binding_ip: globals.get::<_, String>("binding_ip")?, 0..=4 => parsed_safe_search,
style: Style::new( _ => {
globals.get::<_, String>("theme")?, log::error!("Config Error: The value of `safe_search` option should be a non zero positive integer from 0 to 4.");
globals.get::<_, String>("colorscheme")?, log::error!("Falling back to using the value `1` for the option");
), 1
redis_url: globals.get::<_, String>("redis_url")?,
aggregator: AggregatorConfig {
random_delay: globals.get::<_, bool>("production_use")?,
},
logging,
debug,
upstream_search_engines: globals
.get::<_, HashMap<String, bool>>("upstream_search_engines")?
.into_iter()
.filter_map(|(key, value)| value.then_some(key))
.filter_map(|engine| crate::engines::engine_models::EngineHandler::new(&engine))
.collect(),
request_timeout: globals.get::<_, u8>("request_timeout")?,
threads,
rate_limiter: RateLimiter {
number_of_requests: rate_limiter["number_of_requests"],
time_limit: rate_limiter["time_limit"],
} }
};
Ok(Config {
port: globals.get::<_, u16>("port")?,
binding_ip: globals.get::<_, String>("binding_ip")?,
style: Style::new(
globals.get::<_, String>("theme")?,
globals.get::<_, String>("colorscheme")?,
),
redis_url: globals.get::<_, String>("redis_url")?,
aggregator: AggregatorConfig {
random_delay: globals.get::<_, bool>("production_use")?,
},
logging,
debug,
upstream_search_engines: globals
.get::<_, HashMap<String, bool>>("upstream_search_engines")?
.into_iter()
.filter_map(|(key, value)| value.then_some(key))
.filter_map(|engine| crate::engines::engine_models::EngineHandler::new(&engine))
.collect(),
request_timeout: globals.get::<_, u8>("request_timeout")?,
threads,
rate_limiter: RateLimiter {
number_of_requests: rate_limiter["number_of_requests"],
time_limit: rate_limiter["time_limit"],
},
safe_search,
}) })
} }
} }