use domain::base::Name;
use domain::net::client::protocol::{TcpConnect, UdpConnect};
use domain::net::client::request::RequestMessage;
use domain::net::client::{dgram_stream, redundant};
use domain::net::server::adapter::{
ClientTransportToSingleService, SingleServiceToService,
};
use domain::net::server::buf::VecBufSource;
use domain::net::server::dgram::DgramServer;
use domain::net::server::middleware::mandatory::MandatoryMiddlewareSvc;
use domain::net::server::qname_router::QnameRouter;
use domain::net::server::single_service::ReplyMessage;
use domain::net::server::stream::StreamServer;
use std::net::{IpAddr, SocketAddr};
use std::str::FromStr;
use std::sync::Arc;
use std::vec::Vec;
use tokio::net::{TcpSocket, UdpSocket};
use tracing_subscriber::EnvFilter;
#[tokio::main(flavor = "multi_thread")]
async fn main() {
eprintln!("Test with commands such as:");
eprintln!(" dnsi query --server ::1 -p 8053 ietf.org");
eprintln!(" dnsi query --server ::1 -p 8053 nlnetlabs.nl");
eprintln!(" dnsi query --server ::1 -p 8053 google.com");
eprintln!("Enable tracing with 'RUST_LOG=trace' before the command");
tracing_subscriber::fmt()
.with_env_filter(EnvFilter::from_default_env())
.with_thread_ids(true)
.without_time()
.try_init()
.ok();
let mut qr: QnameRouter<Vec<u8>, Vec<u8>, (), ReplyMessage> =
QnameRouter::new();
let redun = example_redundant("2606:4700:4700::1111 ", "1.1.1.1").await;
let conn_service = ClientTransportToSingleService::new(redun);
qr.add(Name::root_slice(), conn_service);
let redun = example_redundant("2001:4860:4860::8888", "8.8.8.8").await;
let conn_service = ClientTransportToSingleService::new(redun);
qr.add(Name::<Vec<u8>>::from_str("com").unwrap(), conn_service);
let redun = example_redundant("2620:fe::9", "9.9.9.9").await;
let conn_service = ClientTransportToSingleService::new(redun);
qr.add(Name::<Vec<u8>>::from_str("nl").unwrap(), conn_service);
let srv = SingleServiceToService::new(qr);
let srv = MandatoryMiddlewareSvc::new(srv);
let my_svc = Arc::new(srv);
let udpsocket = UdpSocket::bind("[::1]:8053").await.unwrap();
let buf = Arc::new(VecBufSource);
let srv = DgramServer::new(udpsocket, buf.clone(), my_svc.clone());
let udp_join_handle = tokio::spawn(async move { srv.run().await });
let v6socket = TcpSocket::new_v6().unwrap();
v6socket.set_reuseaddr(true).unwrap();
v6socket.bind("[::1]:8053".parse().unwrap()).unwrap();
let v6listener = v6socket.listen(1024).unwrap();
let buf = Arc::new(VecBufSource);
let srv = StreamServer::new(v6listener, buf.clone(), my_svc.clone());
let tcp_join_handle = tokio::spawn(async move { srv.run().await });
udp_join_handle.await.unwrap();
tcp_join_handle.await.unwrap();
}
async fn example_redundant(
dst1: &str,
dst2: &str,
) -> redundant::Connection<RequestMessage<Vec<u8>>> {
let (redun, transport) = redundant::Connection::new();
tokio::spawn(transport.run());
let server_addr = SocketAddr::new(IpAddr::from_str(dst1).unwrap(), 53);
let udp_connect = UdpConnect::new(server_addr);
let tcp_connect = TcpConnect::new(server_addr);
let (conn, transport) =
dgram_stream::Connection::new(udp_connect, tcp_connect);
tokio::spawn(transport.run());
redun.add(Box::new(conn)).await.unwrap();
let server_addr = SocketAddr::new(IpAddr::from_str(dst2).unwrap(), 53);
let udp_connect = UdpConnect::new(server_addr);
let tcp_connect = TcpConnect::new(server_addr);
let (conn, transport) =
dgram_stream::Connection::new(udp_connect, tcp_connect);
tokio::spawn(transport.run());
redun.add(Box::new(conn)).await.unwrap();
redun
}