Jędrzej Stuczyński
5a07b73375
* removed mnemonic from gateway config struct scaffolding for common mixnet listener running verloc unconditionally in a nym-node remove filtering by mixnode extracted verloc to separate crate integrated nym-node-http-server more tightly with the binary most logic for handling forward packets running all mixnode-related tasks natively inside nymnode removed gateway storage trait in favour of the only concrete implementation most logic for handling final hop packets using nym-node owned socket listener for gateways utility for sending plain message through mixnet + gateway fix using common packet forwarding in both modes nifying nym-node metrics reproduce behaviour of the console logger cleaned up cli args redesigned gateway tasks startup procedure removing dead code scaffolding for old config v6 config migration implemented MixnetMetricsCleaner * clippy * require entry/exit for wireguard * removed dead code in migration code * updated config template * use custom user agent for verloc queries * fixed premature shutdown of gateway tasks * hidden nym-api flag to allow illegal node ips * experiment: final hop handing with wireguard * added additional startup logs * typo * fixed legacy stats endpoint data * additional logs * apply review comments * fixed local testnet manager
91 lines
3.0 KiB
Rust
91 lines
3.0 KiB
Rust
// Copyright 2024 - Nym Technologies SA <contact@nymtech.net>
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
use nym_credentials_interface::TicketType;
|
|
use nym_sphinx::DestinationAddressBytes;
|
|
use time::OffsetDateTime;
|
|
|
|
/// Channel for receiving incoming Stats events
|
|
pub type GatewayStatsReceiver = tokio::sync::mpsc::UnboundedReceiver<GatewayStatsEvent>;
|
|
|
|
/// Channel allowing for generic statistics events to be reported to a stats event aggregator.
|
|
#[derive(Clone)]
|
|
pub struct GatewayStatsReporter {
|
|
stats_tx: tokio::sync::mpsc::UnboundedSender<GatewayStatsEvent>,
|
|
}
|
|
|
|
impl GatewayStatsReporter {
|
|
/// Construct a new gateway statistics event reporter
|
|
pub fn new(stats_tx: tokio::sync::mpsc::UnboundedSender<GatewayStatsEvent>) -> Self {
|
|
Self { stats_tx }
|
|
}
|
|
|
|
/// Report a gateway statistivs event using the reporter
|
|
pub fn report(&self, event: GatewayStatsEvent) {
|
|
self.stats_tx.send(event).unwrap_or_else(|err| {
|
|
log::error!("Failed to report gateway stat event : {err}");
|
|
});
|
|
}
|
|
}
|
|
|
|
/// Gateway Statistics events
|
|
pub enum GatewayStatsEvent {
|
|
/// Events in the lifecycle of an established client tunnel
|
|
SessionStatsEvent(GatewaySessionEvent),
|
|
}
|
|
|
|
/// Events in the lifecycle of an established client tunnel
|
|
#[derive(Debug, Clone, Copy)]
|
|
pub enum GatewaySessionEvent {
|
|
/// A new session between this gateway and the client remote has successfully opened
|
|
SessionStart {
|
|
/// The timestamp of the session open event
|
|
start_time: OffsetDateTime,
|
|
/// Address of the remote client opening the connection
|
|
client: DestinationAddressBytes,
|
|
},
|
|
/// An existing session with the client remote has ended
|
|
SessionStop {
|
|
/// Timestamp of the session end event
|
|
stop_time: OffsetDateTime,
|
|
/// Address of the remote client opening the connection
|
|
client: DestinationAddressBytes,
|
|
},
|
|
/// A new ecash ticket has been added / requested
|
|
EcashTicket {
|
|
/// Type of ecash ticket that has been created as part of the session
|
|
ticket_type: TicketType,
|
|
/// Address of the remote client opening the connection
|
|
client: DestinationAddressBytes,
|
|
},
|
|
}
|
|
|
|
impl GatewaySessionEvent {
|
|
/// A new session between this gateway and the client remote has successfully opened
|
|
pub fn new_session_start(client: DestinationAddressBytes) -> GatewaySessionEvent {
|
|
GatewaySessionEvent::SessionStart {
|
|
start_time: OffsetDateTime::now_utc(),
|
|
client,
|
|
}
|
|
}
|
|
|
|
/// An existing session with the client remote has ended
|
|
pub fn new_session_stop(client: DestinationAddressBytes) -> GatewaySessionEvent {
|
|
GatewaySessionEvent::SessionStop {
|
|
stop_time: OffsetDateTime::now_utc(),
|
|
client,
|
|
}
|
|
}
|
|
|
|
/// A new ecash ticket has been added / requested
|
|
pub fn new_ecash_ticket(
|
|
client: DestinationAddressBytes,
|
|
ticket_type: TicketType,
|
|
) -> GatewaySessionEvent {
|
|
GatewaySessionEvent::EcashTicket {
|
|
ticket_type,
|
|
client,
|
|
}
|
|
}
|
|
}
|