lemmy_utils 1.0.0-beta.0

A link aggregator for the fediverse
Documentation 
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

use crate::rate_limit::ActionType;
use std::{
  future::Ready,
  net::{IpAddr, Ipv4Addr, SocketAddr},
  str::FromStr,
};

#[derive(Clone, Copy, PartialEq, Eq, Hash, Debug)]
pub struct LemmyInput(pub(crate) RateLimitIpAddr, pub(crate) ActionType);

pub(crate) type LemmyInputFuture = Ready<Result<LemmyInput, actix_web::Error>>;

#[derive(Clone, Copy, PartialEq, Eq, Hash, Debug)]
pub(crate) enum RateLimitIpAddr {
  V4(Ipv4Addr),
  V6([u16; 4]),
}

#[expect(clippy::expect_used)]
impl From<IpAddr> for RateLimitIpAddr {
  fn from(value: IpAddr) -> Self {
    match value {
      IpAddr::V4(addr) => RateLimitIpAddr::V4(addr),
      IpAddr::V6(addr) => RateLimitIpAddr::V6(
        addr.segments()[..4]
          .try_into()
          .expect("byte array is correct length"),
      ),
    }
  }
}

/// Generate a raw byte key for backend which uses less memory.
pub(crate) fn raw_ip_key(ip_str: Option<&str>) -> RateLimitIpAddr {
  parse_ip(ip_str).into()
}

fn parse_ip(addr: Option<&str>) -> IpAddr {
  if let Some(addr) = addr {
    if let Ok(ip) = IpAddr::from_str(addr) {
      return ip;
    } else if let Ok(socket) = SocketAddr::from_str(addr) {
      return socket.ip();
    }
  }
  Ipv4Addr::new(127, 0, 0, 1).into()
}

#[cfg(test)]
mod tests {
  use super::*;
  use crate::error::LemmyResult;

  #[test]
  fn test_get_ip() -> LemmyResult<()> {
    // Check that IPv4 addresses are preserved
    assert_eq!(
      raw_ip_key(Some("142.250.187.206")),
      "142.250.187.206".parse::<IpAddr>()?.into()
    );
    // Check that IPv6 addresses are grouped into /64 subnets
    assert_eq!(
      raw_ip_key(Some("2a00:1450:4009:81f::200e")),
      RateLimitIpAddr::V6([0x2a00, 0x1450, 0x4009, 0x81f])
    );
    assert_eq!(
      raw_ip_key(Some("[2a00:1450:4009:81f::200e]:123")),
      RateLimitIpAddr::V6([0x2a00, 0x1450, 0x4009, 0x81f])
    );
    Ok(())
  }
}