diff options
author | rtkay123 <dev@kanjala.com> | 2025-08-15 21:05:36 +0200 |
---|---|---|
committer | rtkay123 <dev@kanjala.com> | 2025-08-15 21:05:36 +0200 |
commit | 552300d437ed3a3c3ecf20049b0f96eb2a9a13c1 (patch) | |
tree | fd54a21b63cdf3ab11b74972c980b42d9024e65e /crates/rule-executor/src/processor/rule.rs | |
parent | 1968002d656383069a386bd874c9f0cc83e3116e (diff) | |
download | warden-552300d437ed3a3c3ecf20049b0f96eb2a9a13c1.tar.bz2 warden-552300d437ed3a3c3ecf20049b0f96eb2a9a13c1.zip |
feat(exec): get config
Diffstat (limited to 'crates/rule-executor/src/processor/rule.rs')
-rw-r--r-- | crates/rule-executor/src/processor/rule.rs | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/crates/rule-executor/src/processor/rule.rs b/crates/rule-executor/src/processor/rule.rs index 8b13789..8168c5a 100644 --- a/crates/rule-executor/src/processor/rule.rs +++ b/crates/rule-executor/src/processor/rule.rs @@ -1 +1,21 @@ +use std::sync::Arc; +use anyhow::Result; +mod configuration; + +use async_nats::jetstream::Message; +use warden_core::configuration::rule::RuleConfigurationRequest; + +use crate::state::AppHandle; + +pub async fn process_rule(message: Message, state: AppHandle) -> Result<()> { + let req = create_configuration_request(&message); + + let rule_configuration = configuration::get_configuration(req, Arc::clone(&state)).await?; + + Ok(()) +} + +fn create_configuration_request(message: &Message) -> RuleConfigurationRequest { + todo!() +} |