Jędrzej Stuczyński
e5afd54ce0
* Basic storage stub * New models for new node status api * Route handling * Mounting new routes * Missing selective commit * Moved network monitor related files to separate package * Starting to see some sqlx action * Schema updates * Log statement upon finished migration * Removed old diesel related imports * Converted mixnode cache initialisation into a fairing * Moved cache related functionalities to separate package Also defined staging there * Created run method for validator cache + removed unwrap * Removed old node-status-api types and left bunch of todo placeholders in their place * Fixed managing validatorcache * Status reports are starting to get constructed * Submitting some dummy results to the database * Removing duplicate code for generating reports * Removed statuses older than 48h * Initial attempt at trying to obtain reports for all active nodes * Removed duplicates from the full report * Grabbing uptime history * Updating historical uptimes of active nodes * Updated sqlx-data.json * Removed all placeholder foomp owner values * Changed Layer serde behaviour for easier usage * Extended validator api config * Initial (seems working !) integration with network monitor * Added database path configuration to config * Using ValidatorCache in NetworkMonitor * Flag indicating whether validator cache has been initialised * Introduced a locla-only route for reward script to perform daily chores * Flag to save config to a file * Moved spawning of receiving future to run method rather than new * Removed arguments that dont make sense to be configured via CLI * Removed dead code from config file * More dead code removal * Added validator API to CI * Corrected manifest-path arguments * Constructing network monitor by passing config * Combined validator API CI with the main CI file * Using query_as for NodeStatus * Checking if historical uptimes were already calculated on particular day * Making id field NOT NULL * More query_as! action * Updated sqlx-data.json * Removed unused chrono feature * Renamed the migration file * Changed default validator endpoint to point to local validator * Removing unnecessary clone * More appropriate naming * Removed dead code * Lock file updates * Updated network monitor address in contract code * Don't stage node status api if network monitor is disabled * cargo fmt * Updated all license notices to SPDX
77 lines
2.7 KiB
Rust
77 lines
2.7 KiB
Rust
// Copyright 2021 - Nym Technologies SA <contact@nymtech.net>
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
use std::fmt::{self, Display, Formatter};
|
|
use std::io;
|
|
|
|
#[derive(Debug)]
|
|
pub enum RttError {
|
|
UnexpectedEchoPacketSize,
|
|
UnexpectedReplyPacketSize,
|
|
|
|
MalformedSenderIdentity,
|
|
|
|
MalformedEchoSignature,
|
|
MalformedReplySignature,
|
|
|
|
InvalidEchoSignature,
|
|
InvalidReplySignature,
|
|
|
|
UnreachableNode(String, io::Error),
|
|
UnexpectedConnectionFailureWrite(String, io::Error),
|
|
UnexpectedConnectionFailureRead(String, io::Error),
|
|
ConnectionReadTimeout(String),
|
|
ConnectionWriteTimeout(String),
|
|
|
|
UnexpectedReplySequence,
|
|
}
|
|
|
|
impl Display for RttError {
|
|
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
|
|
match self {
|
|
RttError::UnexpectedEchoPacketSize => {
|
|
write!(f, "The received echo packet had unexpected size")
|
|
}
|
|
RttError::UnexpectedReplyPacketSize => {
|
|
write!(f, "The received reply packet had unexpected size")
|
|
}
|
|
RttError::MalformedSenderIdentity => {
|
|
write!(f, "The received echo packet had malformed sender")
|
|
}
|
|
RttError::MalformedEchoSignature => {
|
|
write!(f, "The received echo packet had malformed signature")
|
|
}
|
|
RttError::MalformedReplySignature => {
|
|
write!(f, "The received reply packet had malformed signature")
|
|
}
|
|
RttError::InvalidEchoSignature => {
|
|
write!(f, "The received echo packet had invalid signature")
|
|
}
|
|
RttError::InvalidReplySignature => {
|
|
write!(f, "The received reply packet had invalid signature")
|
|
}
|
|
RttError::UnreachableNode(id, err) => {
|
|
write!(f, "Could not establish connection to {} - {}", id, err)
|
|
}
|
|
RttError::UnexpectedConnectionFailureWrite(id, err) => {
|
|
write!(f, "Failed to write echo packet to {} - {}", id, err)
|
|
}
|
|
RttError::UnexpectedConnectionFailureRead(id, err) => {
|
|
write!(f, "Failed to read reply packet from {} - {}", id, err)
|
|
}
|
|
RttError::ConnectionReadTimeout(id) => {
|
|
write!(f, "Timed out while trying to read reply packet from {}", id)
|
|
}
|
|
RttError::ConnectionWriteTimeout(id) => {
|
|
write!(f, "Timed out while trying to write echo packet to {}", id)
|
|
}
|
|
RttError::UnexpectedReplySequence => write!(
|
|
f,
|
|
"The received reply packet had an unexpected sequence number"
|
|
),
|
|
}
|
|
}
|
|
}
|
|
|
|
impl std::error::Error for RttError {}
|