tailspin 6.0.0

A log file highlighter
Documentation
use memchr::memchr;
use regex::{Regex, RegexBuilder};
use std::net::Ipv6Addr;

use crate::style::Style;

use super::super::span::{Collector, Finder};

#[derive(Debug)]
pub(crate) struct IpV6Finder {
    regex: Regex,
    number: Style,
    letter: Style,
    separator: Style,
}

impl IpV6Finder {
    pub fn new(number: Style, letter: Style, separator: Style) -> Self {
        let pattern = r"([0-9a-fA-F:.]{3,})(?:(/)(\d{1,3}))?";
        let regex = RegexBuilder::new(pattern)
            .unicode(false)
            .build()
            .expect("hardcoded IPv6 regex must compile");

        Self {
            regex,
            number,
            letter,
            separator,
        }
    }
}

impl Finder for IpV6Finder {
    fn find_spans(&self, input: &str, collector: &mut Collector) {
        if memchr(b':', input.as_bytes()).is_none() {
            return;
        }

        for caps in self.regex.captures_iter(input) {
            if caps[1].parse::<Ipv6Addr>().is_ok() {
                let addr_match = caps.get(1).unwrap();
                let addr = addr_match.as_str();
                let offset = addr_match.start();

                for (i, c) in addr.char_indices() {
                    let style = match c {
                        '0'..='9' => self.number,
                        'a'..='f' | 'A'..='F' => self.letter,
                        ':' | '.' => self.separator,
                        _ => continue,
                    };
                    collector.push(offset + i, offset + i + c.len_utf8(), style);
                }

                if let (Some(slash), Some(netmask)) = (caps.get(2), caps.get(3)) {
                    collector.push(slash.start(), slash.end(), self.separator);
                    collector.push(netmask.start(), netmask.end(), self.number);
                }
            }
        }
    }
}

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

    fn make_finder() -> IpV6Finder {
        IpV6Finder::new(
            Style::new().fg(Color::Blue),
            Style::new().fg(Color::Yellow),
            Style::new().fg(Color::Red),
        )
    }

    fn span_count(input: &str) -> usize {
        let mut collector = Collector::new(0);
        make_finder().find_spans(input, &mut collector);
        collector.into_spans().len()
    }

    fn matched_range(input: &str) -> Option<(usize, usize)> {
        let mut collector = Collector::new(0);
        make_finder().find_spans(input, &mut collector);
        let spans = collector.into_spans();
        if spans.is_empty() {
            None
        } else {
            Some((spans.first().unwrap().start, spans.last().unwrap().end))
        }
    }

    #[test]
    fn full_ipv6() {
        assert!(span_count("2001:db8:0:0:0:ff00:42:8329") > 0);
    }

    #[test]
    fn compressed_ipv6() {
        assert!(span_count("2001:db8::ff00:42:8329") > 0);
    }

    #[test]
    fn loopback() {
        assert!(span_count("::1") > 0);
    }

    #[test]
    fn ipv4_mapped() {
        assert!(span_count("::ffff:127.0.0.1") > 0);
    }

    #[test]
    fn cidr_notation() {
        let input = "fe80::/10";
        let (start, end) = matched_range(input).unwrap();
        assert_eq!(start, 0);
        assert_eq!(end, input.len());
    }

    #[test]
    fn dual_stack_ipv4_in_ipv6() {
        assert!(span_count("2001:db8:85a3::8a2e:192.0.2.33") > 0);
    }

    #[test]
    fn plain_ipv4_no_match() {
        assert_eq!(span_count("Not ipv4: 192.168.0.1"), 0);
    }

    #[test]
    fn time_like_no_match() {
        assert_eq!(span_count("11:47:39:850"), 0);
    }

    #[test]
    fn slash_separated_no_match() {
        assert_eq!(span_count("123/234/345/456"), 0);
    }
}