nullnet-wallguard-server 0.1.0

A centralized management system for network firewalls
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

use crate::{datastore::DatastoreWrapper, proto::wallguard::Packets};

pub async fn worker_task(
    rx: async_channel::Receiver<Packets>,
    mut datastore: Option<DatastoreWrapper>,
) {
    loop {
        let message = match rx.recv().await {
            Ok(message) => message,
            Err(e) => {
                println!("Receiver error: {}. Task Id {:?}", e, tokio::task::id());
                continue;
            }
        };

        let Some(authentication) = message.auth.clone() else {
            eprintln!("Unauthenticated message. Skipping data transmission...");
            continue;
        };

        println!("Received {} packets", message.packets.len());

        let parsed_message = crate::parser::msg_parser::parse_message(message);
        if parsed_message.records.is_empty() {
            eprintln!("No valid packets in the message. Skipping...");
            continue;
        };

        let Some(datastore) = datastore.as_mut() else {
            continue;
        };

        match datastore
            .packets_insert(&authentication.token, parsed_message)
            .await
        {
            Ok(response) if !response.success => {
                let error = response.error;
                let message = response.message;
                eprintln!("Error saving a message: {error} {message}");
            }
            Ok(_) => {}
            Err(status) => {
                eprintln!("Error saving a message: {status}");
            }
        }
    }
}