Jedrzej Stuczynski
48 lines
1.4 KiB
Rust
48 lines
1.4 KiB
Rust
use crate::node;
|
|
use directory_client::presence::MixNodePresence;
|
|
use directory_client::requests::presence_mixnodes_post::PresenceMixNodesPoster;
|
|
use directory_client::DirectoryClient;
|
|
use log::{debug, error};
|
|
use std::time::Duration;
|
|
|
|
pub struct Notifier {
|
|
pub net_client: directory_client::Client,
|
|
presence: MixNodePresence,
|
|
}
|
|
|
|
impl Notifier {
|
|
pub fn new(node_config: &node::Config) -> Notifier {
|
|
let config = directory_client::Config {
|
|
base_url: node_config.directory_server.clone(),
|
|
};
|
|
let net_client = directory_client::Client::new(config);
|
|
let presence = MixNodePresence {
|
|
host: node_config.announce_address.clone(),
|
|
pub_key: node_config.public_key_string(),
|
|
layer: node_config.layer as u64,
|
|
last_seen: 0,
|
|
version: env!("CARGO_PKG_VERSION").to_string(),
|
|
};
|
|
Notifier {
|
|
net_client,
|
|
presence,
|
|
}
|
|
}
|
|
|
|
pub fn notify(&self) {
|
|
match self.net_client.presence_mix_nodes_post.post(&self.presence) {
|
|
Err(err) => error!("failed to send presence - {:?}", err),
|
|
Ok(_) => debug!("sent presence information"),
|
|
}
|
|
}
|
|
|
|
pub async fn run(self) {
|
|
let delay_duration = Duration::from_secs(5);
|
|
|
|
loop {
|
|
self.notify();
|
|
tokio::time::delay_for(delay_duration).await;
|
|
}
|
|
}
|
|
}
|