crates/rule-executor/src/processor/rule.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
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!()
}