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 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82
// Copyright (C) 2019-2023 Aleo Systems Inc.
// This file is part of the snarkOS library.
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at:
// http://www.apache.org/licenses/LICENSE-2.0
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
use crate::{messages::Message, Heartbeat, Inbound, Outbound};
use snarkos_node_tcp::{
protocols::{Disconnect, Handshake, OnConnect},
P2P,
};
use snarkvm::prelude::Network;
use core::time::Duration;
#[async_trait]
pub trait Routing<N: Network>:
P2P + Disconnect + OnConnect + Handshake + Inbound<N> + Outbound<N> + Heartbeat<N>
{
/// Initialize the routing.
async fn initialize_routing(&self) {
// Enable the TCP protocols.
self.enable_handshake().await;
self.enable_reading().await;
self.enable_writing().await;
self.enable_disconnect().await;
self.enable_on_connect().await;
// Enable the TCP listener. Note: This must be called after the above protocols.
self.enable_listener().await;
// Initialize the heartbeat.
self.initialize_heartbeat();
// Initialize the report.
#[cfg(not(feature = "test"))]
self.initialize_report();
}
// Start listening for inbound connections.
async fn enable_listener(&self) {
self.tcp().enable_listener().await.expect("Failed to enable the TCP listener");
}
/// Initialize a new instance of the heartbeat.
fn initialize_heartbeat(&self) {
let self_clone = self.clone();
self.router().spawn(async move {
loop {
// Process a heartbeat in the router.
self_clone.heartbeat();
// Sleep for `HEARTBEAT_IN_SECS` seconds.
tokio::time::sleep(Duration::from_secs(Self::HEARTBEAT_IN_SECS)).await;
}
});
}
/// Initialize a new instance of the report.
fn initialize_report(&self) {
let self_clone = self.clone();
self.router().spawn(async move {
loop {
// Prepare the report.
let mut report = std::collections::HashMap::new();
report.insert("message_version".to_string(), Message::<N>::VERSION.to_string());
report.insert("node_address".to_string(), self_clone.router().address().to_string());
report.insert("node_type".to_string(), self_clone.router().node_type().to_string());
report.insert("is_dev".to_string(), self_clone.router().is_dev().to_string());
// Transmit the report.
let url = "https://vm.aleo.org/testnet3/report";
let _ = reqwest::Client::new().post(url).json(&report).send().await;
// Sleep for a fixed duration in seconds.
tokio::time::sleep(Duration::from_secs(6 * 60 * 60)).await;
}
});
}
}