use serde::{Serialize, Deserialize};
use std::net::{SocketAddr, ToSocketAddrs, IpAddr, Ipv4Addr, Ipv6Addr, SocketAddrV4, SocketAddrV6};
use std::io::{self};
#[derive(Serialize, Deserialize, Clone, PartialEq, Eq, Hash, Debug)]
pub enum RemoteAddr {
Socket(SocketAddr),
Str(String),
}
impl RemoteAddr {
pub fn is_socket_addr(&self) -> bool {
matches!(self, RemoteAddr::Socket(_))
}
pub fn is_string(&self) -> bool {
matches!(self, RemoteAddr::Socket(_))
}
pub fn socket_addr(&self) -> &SocketAddr {
match self {
RemoteAddr::Socket(addr) => addr,
_ => panic!("The RemoteAddr must be a SocketAddr"),
}
}
pub fn string(&self) -> &str {
match self {
RemoteAddr::Str(addr) => addr,
_ => panic!("The RemoteAddr must be a String"),
}
}
}
impl ToSocketAddrs for RemoteAddr {
type Iter = std::option::IntoIter<SocketAddr>;
fn to_socket_addrs(&self) -> io::Result<Self::Iter> {
match self {
RemoteAddr::Socket(addr) => addr.to_socket_addrs(),
RemoteAddr::Str(_) => Err(io::Error::new(
io::ErrorKind::InvalidInput,
"The RemoteAddr is not a SocketAddr",
)),
}
}
}
impl std::fmt::Display for RemoteAddr {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match self {
RemoteAddr::Socket(addr) => write!(f, "{addr}"),
RemoteAddr::Str(string) => write!(f, "{string}"),
}
}
}
pub trait ToRemoteAddr {
fn to_remote_addr(&self) -> io::Result<RemoteAddr>;
}
impl ToRemoteAddr for &str {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(match self.parse() {
Ok(addr) => RemoteAddr::Socket(addr),
Err(_) => RemoteAddr::Str(self.to_string()),
})
}
}
impl ToRemoteAddr for String {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
(self as &str).to_remote_addr()
}
}
impl ToRemoteAddr for &String {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
(self as &str).to_remote_addr()
}
}
impl ToRemoteAddr for SocketAddr {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(RemoteAddr::Socket(*self))
}
}
impl ToRemoteAddr for SocketAddrV4 {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(RemoteAddr::Socket(SocketAddr::V4(*self)))
}
}
impl ToRemoteAddr for SocketAddrV6 {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(RemoteAddr::Socket(SocketAddr::V6(*self)))
}
}
impl ToRemoteAddr for RemoteAddr {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(self.clone())
}
}
impl ToRemoteAddr for (&str, u16) {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(RemoteAddr::Socket(self.to_socket_addrs().unwrap().next().unwrap()))
}
}
impl ToRemoteAddr for (String, u16) {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(RemoteAddr::Socket(self.to_socket_addrs().unwrap().next().unwrap()))
}
}
impl ToRemoteAddr for (IpAddr, u16) {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(RemoteAddr::Socket(self.to_socket_addrs().unwrap().next().unwrap()))
}
}
impl ToRemoteAddr for (Ipv4Addr, u16) {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(RemoteAddr::Socket(self.to_socket_addrs().unwrap().next().unwrap()))
}
}
impl ToRemoteAddr for (Ipv6Addr, u16) {
fn to_remote_addr(&self) -> io::Result<RemoteAddr> {
Ok(RemoteAddr::Socket(self.to_socket_addrs().unwrap().next().unwrap()))
}
}
#[cfg(test)]
mod tests {
use super::*;
use std::net::{IpAddr, Ipv4Addr};
#[test]
fn str_to_string() {
let string = "ws://domain:1234/socket";
assert_eq!(string, string.to_remote_addr().unwrap().string());
}
#[test]
fn string_to_string() {
let string = String::from("ws://domain:1234/socket");
assert_eq!(&string, string.to_remote_addr().unwrap().string());
}
#[test]
fn str_to_socket_addr() {
assert!("127.0.0.1:80".to_remote_addr().unwrap().is_socket_addr());
}
#[test]
fn string_to_socket_addr() {
assert!(String::from("127.0.0.1:80").to_remote_addr().unwrap().is_socket_addr());
}
#[test]
fn socket_addr_to_socket_addr() {
let socket_addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 8080);
assert!(socket_addr.to_remote_addr().unwrap().is_socket_addr());
}
}