summaryrefslogtreecommitdiff
path: root/vendor/ipnet/src/parser.rs
diff options
context:
space:
mode:
authormo khan <mo@mokhan.ca>2025-07-15 16:37:08 -0600
committermo khan <mo@mokhan.ca>2025-07-17 16:30:22 -0600
commit45df4d0d9b577fecee798d672695fe24ff57fb1b (patch)
tree1b99bf645035b58e0d6db08c7a83521f41f7a75b /vendor/ipnet/src/parser.rs
parentf94f79608393d4ab127db63cc41668445ef6b243 (diff)
feat: migrate from Cedar to SpiceDB authorization system
This is a major architectural change that replaces the Cedar policy-based authorization system with SpiceDB's relation-based authorization. Key changes: - Migrate from Rust to Go implementation - Replace Cedar policies with SpiceDB schema and relationships - Switch from envoy `ext_authz` with Cedar to SpiceDB permission checks - Update build system and dependencies for Go ecosystem - Maintain Envoy integration for external authorization This change enables more flexible permission modeling through SpiceDB's Google Zanzibar inspired relation-based system, supporting complex hierarchical permissions that were difficult to express in Cedar. Breaking change: Existing Cedar policies and Rust-based configuration will no longer work and need to be migrated to SpiceDB schema.
Diffstat (limited to 'vendor/ipnet/src/parser.rs')
-rw-r--r--vendor/ipnet/src/parser.rs351
1 files changed, 0 insertions, 351 deletions
diff --git a/vendor/ipnet/src/parser.rs b/vendor/ipnet/src/parser.rs
deleted file mode 100644
index d21fe60d..00000000
--- a/vendor/ipnet/src/parser.rs
+++ /dev/null
@@ -1,351 +0,0 @@
-//! A private parser implementation of IPv4 and IPv6 network addresses.
-//!
-//! The existing `std::net::parser` module cannot be extended because it
-//! is private. It is copied and extended here with methods for parsing
-//! IP network addresses.
-
-use alloc::{str::FromStr, boxed::Box};
-use core::fmt;
-#[cfg(not(feature = "std"))]
-use core::error::Error;
-#[cfg(feature = "std")]
-use std::error::Error;
-#[cfg(not(feature = "std"))]
-use core::net::{Ipv4Addr, Ipv6Addr};
-#[cfg(feature = "std")]
-use std::net::{Ipv4Addr, Ipv6Addr};
-
-use crate::ipnet::{IpNet, Ipv4Net, Ipv6Net};
-
-pub struct Parser<'a> {
- // parsing as ASCII, so can use byte array
- s: &'a [u8],
- pos: usize,
-}
-
-impl<'a> Parser<'a> {
- fn new(s: &'a str) -> Parser<'a> {
- Parser {
- s: s.as_bytes(),
- pos: 0,
- }
- }
-
- fn is_eof(&self) -> bool {
- self.pos == self.s.len()
- }
-
- // Commit only if parser returns Some
- fn read_atomically<T, F>(&mut self, cb: F) -> Option<T> where
- F: FnOnce(&mut Parser) -> Option<T>,
- {
- let pos = self.pos;
- let r = cb(self);
- if r.is_none() {
- self.pos = pos;
- }
- r
- }
-
- // Commit only if parser read till EOF
- fn read_till_eof<T, F>(&mut self, cb: F) -> Option<T> where
- F: FnOnce(&mut Parser) -> Option<T>,
- {
- self.read_atomically(move |p| {
- match cb(p) {
- Some(x) => if p.is_eof() {Some(x)} else {None},
- None => None,
- }
- })
- }
-
- // Return result of first successful parser
- fn read_or<T>(&mut self, parsers: &mut [Box<dyn FnMut(&mut Parser) -> Option<T> + 'static>])
- -> Option<T> {
- for pf in parsers {
- if let Some(r) = self.read_atomically(|p: &mut Parser| pf(p)) {
- return Some(r);
- }
- }
- None
- }
-
- // Apply 3 parsers sequentially
- fn read_seq_3<A, B, C, PA, PB, PC>(&mut self,
- pa: PA,
- pb: PB,
- pc: PC)
- -> Option<(A, B, C)> where
- PA: FnOnce(&mut Parser) -> Option<A>,
- PB: FnOnce(&mut Parser) -> Option<B>,
- PC: FnOnce(&mut Parser) -> Option<C>,
- {
- self.read_atomically(move |p| {
- let a = pa(p);
- let b = if a.is_some() { pb(p) } else { None };
- let c = if b.is_some() { pc(p) } else { None };
- match (a, b, c) {
- (Some(a), Some(b), Some(c)) => Some((a, b, c)),
- _ => None
- }
- })
- }
-
- // Read next char
- fn read_char(&mut self) -> Option<char> {
- if self.is_eof() {
- None
- } else {
- let r = self.s[self.pos] as char;
- self.pos += 1;
- Some(r)
- }
- }
-
- // Return char and advance iff next char is equal to requested
- fn read_given_char(&mut self, c: char) -> Option<char> {
- self.read_atomically(|p| {
- match p.read_char() {
- Some(next) if next == c => Some(next),
- _ => None,
- }
- })
- }
-
- // Read digit
- fn read_digit(&mut self, radix: u8) -> Option<u8> {
- fn parse_digit(c: char, radix: u8) -> Option<u8> {
- let c = c as u8;
- // assuming radix is either 10 or 16
- if c >= b'0' && c <= b'9' {
- Some(c - b'0')
- } else if radix > 10 && c >= b'a' && c < b'a' + (radix - 10) {
- Some(c - b'a' + 10)
- } else if radix > 10 && c >= b'A' && c < b'A' + (radix - 10) {
- Some(c - b'A' + 10)
- } else {
- None
- }
- }
-
- self.read_atomically(|p| {
- p.read_char().and_then(|c| parse_digit(c, radix))
- })
- }
-
- fn read_number_impl(&mut self, radix: u8, max_digits: u32, upto: u32) -> Option<u32> {
- let mut r = 0;
- let mut digit_count = 0;
- loop {
- match self.read_digit(radix) {
- Some(d) => {
- r = r * (radix as u32) + (d as u32);
- digit_count += 1;
- if digit_count > max_digits || r >= upto {
- return None
- }
- }
- None => {
- if digit_count == 0 {
- return None
- } else {
- return Some(r)
- }
- }
- };
- }
- }
-
- // Read number, failing if max_digits of number value exceeded
- fn read_number(&mut self, radix: u8, max_digits: u32, upto: u32) -> Option<u32> {
- self.read_atomically(|p| p.read_number_impl(radix, max_digits, upto))
- }
-
- fn read_ipv4_addr_impl(&mut self) -> Option<Ipv4Addr> {
- let mut bs = [0; 4];
- let mut i = 0;
- while i < 4 {
- if i != 0 && self.read_given_char('.').is_none() {
- return None;
- }
-
- let octet = self.read_number(10, 3, 0x100).map(|n| n as u8);
- match octet {
- Some(d) => bs[i] = d,
- None => return None,
- };
- i += 1;
- }
- Some(Ipv4Addr::new(bs[0], bs[1], bs[2], bs[3]))
- }
-
- // Read IPv4 address
- fn read_ipv4_addr(&mut self) -> Option<Ipv4Addr> {
- self.read_atomically(|p| p.read_ipv4_addr_impl())
- }
-
- fn read_ipv6_addr_impl(&mut self) -> Option<Ipv6Addr> {
- fn ipv6_addr_from_head_tail(head: &[u16], tail: &[u16]) -> Ipv6Addr {
- assert!(head.len() + tail.len() <= 8);
- let mut gs = [0; 8];
- gs[..head.len()].copy_from_slice(head);
- gs[(8 - tail.len()) .. 8].copy_from_slice(tail);
- Ipv6Addr::new(gs[0], gs[1], gs[2], gs[3], gs[4], gs[5], gs[6], gs[7])
- }
-
- fn read_groups(p: &mut Parser, groups: &mut [u16; 8], limit: usize)
- -> (usize, bool) {
- let mut i = 0;
- while i < limit {
- if i < limit - 1 {
- let ipv4 = p.read_atomically(|p| {
- if i == 0 || p.read_given_char(':').is_some() {
- p.read_ipv4_addr()
- } else {
- None
- }
- });
- if let Some(v4_addr) = ipv4 {
- let octets = v4_addr.octets();
- groups[i + 0] = ((octets[0] as u16) << 8) | (octets[1] as u16);
- groups[i + 1] = ((octets[2] as u16) << 8) | (octets[3] as u16);
- return (i + 2, true);
- }
- }
-
- let group = p.read_atomically(|p| {
- if i == 0 || p.read_given_char(':').is_some() {
- p.read_number(16, 4, 0x10000).map(|n| n as u16)
- } else {
- None
- }
- });
- match group {
- Some(g) => groups[i] = g,
- None => return (i, false)
- }
- i += 1;
- }
- (i, false)
- }
-
- let mut head = [0; 8];
- let (head_size, head_ipv4) = read_groups(self, &mut head, 8);
-
- if head_size == 8 {
- return Some(Ipv6Addr::new(
- head[0], head[1], head[2], head[3],
- head[4], head[5], head[6], head[7]))
- }
-
- // IPv4 part is not allowed before `::`
- if head_ipv4 {
- return None
- }
-
- // read `::` if previous code parsed less than 8 groups
- if !self.read_given_char(':').is_some() || !self.read_given_char(':').is_some() {
- return None;
- }
-
- let mut tail = [0; 8];
- let (tail_size, _) = read_groups(self, &mut tail, 8 - head_size);
- Some(ipv6_addr_from_head_tail(&head[..head_size], &tail[..tail_size]))
- }
-
- fn read_ipv6_addr(&mut self) -> Option<Ipv6Addr> {
- self.read_atomically(|p| p.read_ipv6_addr_impl())
- }
-
- /* Additions for IpNet below. */
-
- // Read IPv4 network
- fn read_ipv4_net(&mut self) -> Option<Ipv4Net> {
- let ip_addr = |p: &mut Parser| p.read_ipv4_addr();
- let slash = |p: &mut Parser| p.read_given_char('/');
- let prefix_len = |p: &mut Parser| {
- p.read_number(10, 2, 33).map(|n| n as u8)
- };
-
- self.read_seq_3(ip_addr, slash, prefix_len).map(|t| {
- let (ip, _, prefix_len): (Ipv4Addr, char, u8) = t;
- Ipv4Net::new(ip, prefix_len).unwrap()
- })
- }
-
- // Read Ipv6 network
- fn read_ipv6_net(&mut self) -> Option<Ipv6Net> {
- let ip_addr = |p: &mut Parser| p.read_ipv6_addr();
- let slash = |p: &mut Parser| p.read_given_char('/');
- let prefix_len = |p: &mut Parser| {
- p.read_number(10, 3, 129).map(|n| n as u8)
- };
-
- self.read_seq_3(ip_addr, slash, prefix_len).map(|t| {
- let (ip, _, prefix_len): (Ipv6Addr, char, u8) = t;
- Ipv6Net::new(ip, prefix_len).unwrap()
- })
- }
-
- fn read_ip_net(&mut self) -> Option<IpNet> {
- let ipv4_net = |p: &mut Parser| p.read_ipv4_net().map(IpNet::V4);
- let ipv6_net = |p: &mut Parser| p.read_ipv6_net().map(IpNet::V6);
- self.read_or(&mut [Box::new(ipv4_net), Box::new(ipv6_net)])
- }
-
- /* Additions for IpNet above. */
-}
-
-/* Additions for IpNet below. */
-
-impl FromStr for IpNet {
- type Err = AddrParseError;
- fn from_str(s: &str) -> Result<IpNet, AddrParseError> {
- match Parser::new(s).read_till_eof(|p| p.read_ip_net()) {
- Some(s) => Ok(s),
- None => Err(AddrParseError(()))
- }
- }
-}
-
-impl FromStr for Ipv4Net {
- type Err = AddrParseError;
- fn from_str(s: &str) -> Result<Ipv4Net, AddrParseError> {
- match Parser::new(s).read_till_eof(|p| p.read_ipv4_net()) {
- Some(s) => Ok(s),
- None => Err(AddrParseError(()))
- }
- }
-}
-
-impl FromStr for Ipv6Net {
- type Err = AddrParseError;
- fn from_str(s: &str) -> Result<Ipv6Net, AddrParseError> {
- match Parser::new(s).read_till_eof(|p| p.read_ipv6_net()) {
- Some(s) => Ok(s),
- None => Err(AddrParseError(()))
- }
- }
-}
-
-/* Additions for IpNet above. */
-
-/// An error which can be returned when parsing an IP network address.
-///
-/// This error is used as the error type for the [`FromStr`] implementation for
-/// [`IpNet`], [`Ipv4Net`], and [`Ipv6Net`].
-///
-/// [`FromStr`]: https://doc.rust-lang.org/std/str/trait.FromStr.html
-/// [`IpNet`]: enum.IpNet.html
-/// [`Ipv4Net`]: struct.Ipv4Net.html
-/// [`Ipv6Net`]: struct.Ipv6Net.html
-#[derive(Debug, Clone, PartialEq, Eq)]
-pub struct AddrParseError(());
-
-impl fmt::Display for AddrParseError {
- fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
- fmt.write_str("invalid IP address syntax")
- }
-}
-
-impl Error for AddrParseError {}