add parse method to Parseable trait for easy parsing

Parsing version numbers to u64s could cause an panic on int overflow
with very large versions.

Cargo.lock

@@ -40,7 +40,7 @@ dependencies = [
 [[package]]
 name = "mon"
 version = "0.1.0"
-source = "git+https://jturnerusa.dev/cgit/mon/?rev=34d8eeb989012b0f20041b11a60ced24ca702527#34d8eeb989012b0f20041b11a60ced24ca702527"
+source = "git+https://jturnerusa.dev/cgit/mon/?rev=67861a4df8a5abdd70651d47cf265b20c41d2acc#67861a4df8a5abdd70651d47cf265b20c41d2acc"
 
 [[package]]
 name = "proc-macro2"

Cargo.toml

@@ -4,18 +4,7 @@ version = "0.1.0"
 edition = "2024"
 
 [dependencies]
-mon = { git = "https://jturnerusa.dev/cgit/mon/", rev = "34d8eeb989012b0f20041b11a60ced24ca702527" }
+mon = { git = "https://jturnerusa.dev/cgit/mon/", rev = "67861a4df8a5abdd70651d47cf265b20c41d2acc" }
 get = { git = "https://jturnerusa.dev/cgit/get/", rev = "cd5f75b65777a855ab010c3137304ac05f2e56b8" }
 itertools = "0.14.0"
 thiserror = "2.0.17"
-
-[profile.dev]
-debug = true
-
-[[bin]]
-path = "fuzz/gencorpus.rs"
-name = "gencorpus"
-
-[[test]]
-path = "fuzz/fuzz.rs"
-name = "fuzz"

check.sh

@@ -1,26 +1,22 @@
 #!/bin/bash
 
 source /etc/profile
+source /lib/gentoo/functions.sh
 
-export CC=clang CXX=clang++
+export PATH="${HOME}/.local/bin:${PATH}" CC=clang CXX=clang++
 
-cargo fmt --check || exit $?
+lld=$(command -v lld)
 
-cargo clippy || exit $?
+if [[ -n ${ldd} ]]; then
+    export LDFLAGS=-fuse-ld=${lld}
+fi
 
-cargo test -r || exit $?
+if [[ ! -d build ]]; then
+    meson setup -Dfuzz=enabled -Dtests=enabled -Dbuildtype=debugoptimized -Ddocs=enabled build || exit $?
+fi
 
-cargo build --all --all-features || exit $?
+meson compile -C build || exit $?
 
-build=$(mktemp -d)
+ebegin "running check commands"
-
+parallel --halt soon,fail=1 --keep-order -j$(nproc) < check_commands.txt
-meson setup ${build} || exit $?
+eend $? || exit $?
-
-meson compile -C ${build} || exit $?
-
-meson test -C ${build} || exit $?
-
-rm -rf ${build}
-
-# hack to make sure we use the system meson, since meson format from git is broken
-/usr/bin/meson format --recursive --check-only || exit $?

check_commands.txt

@@ -0,0 +1,5 @@
+/usr/bin/meson format --recursive --check-only
+rustfmt --edition 2024 --check $(find src -type f -name '*.rs')
+ninja rustdoc -C build
+ninja clippy -C build
+meson test unittests doctests '*repo*' '*porthole*' -C build

fuzz/atom/meson.build

@@ -0,0 +1,2 @@
+subdir('parser')
+subdir('vercmp')

fuzz/atom/parser/fuzz.rs

@@ -0,0 +1,100 @@
+use core::slice;
+use gentoo_utils::{Parseable, atom::Atom};
+use mon::{Parser, ParserFinishedError, input::InputIter};
+use std::{
+    io::{BufRead, BufReader, Write},
+    process::{ChildStdin, ChildStdout, Command, Stdio},
+    sync::{LazyLock, Mutex},
+};
+
+struct PyProcess {
+    stdin: Mutex<ChildStdin>,
+    stdout: Mutex<BufReader<ChildStdout>>,
+    buffer: Mutex<String>,
+}
+
+#[allow(clippy::missing_safety_doc, clippy::needless_return)]
+#[unsafe(no_mangle)]
+pub unsafe extern "C" fn LLVMFuzzerTestOneInput(input: *const u8, len: usize) -> i32 {
+    static PY_PROCESS: LazyLock<PyProcess> = LazyLock::new(|| {
+        #[allow(clippy::zombie_processes)]
+        let mut proc = Command::new("atom.py")
+            .stdin(Stdio::piped())
+            .stdout(Stdio::piped())
+            .stderr(Stdio::inherit())
+            .spawn()
+            .expect("failed to spawn atom.py");
+
+        let stdin = Mutex::new(proc.stdin.take().unwrap());
+        let stdout = Mutex::new(BufReader::new(proc.stdout.take().unwrap()));
+
+        PyProcess {
+            stdin,
+            stdout,
+            buffer: Mutex::new(String::new()),
+        }
+    });
+
+    let slice = unsafe { slice::from_raw_parts(input, len) };
+
+    if slice.iter().any(|b| !b.is_ascii_graphic()) {
+        return -1;
+    }
+
+    let str = match str::from_utf8(slice) {
+        Ok(str) => str,
+        Err(_) => return -1,
+    };
+
+    let atom = str.trim();
+
+    let mut stdin = PY_PROCESS.stdin.lock().expect("failed to get stdin lock");
+
+    writeln!(&mut stdin, "{atom}").expect("failed to write to python stdin");
+
+    let mut stdout = PY_PROCESS.stdout.lock().expect("failed to get stdout lock");
+
+    let mut buffer = PY_PROCESS.buffer.lock().expect("failed to get buffer lock");
+
+    buffer.clear();
+
+    stdout
+        .read_line(&mut buffer)
+        .expect("failed to readline from python");
+
+    let portage_result = match buffer.as_str().trim() {
+        "0" => true,
+        "1" => false,
+        result => panic!("got unexpected result from python: {result}"),
+    };
+
+    let gentoo_utils_result = Atom::parser().parse_finished(InputIter::new(atom));
+
+    match (portage_result, gentoo_utils_result) {
+        (true, Ok(_)) => {
+            eprintln!("agreement that {atom} is valid");
+        }
+        (false, Err(_)) => {
+            eprintln!("agreement that {atom} is invalid");
+        }
+        (true, Err(ParserFinishedError::Err(it) | ParserFinishedError::Unfinished(it))) => {
+            panic!("rejected valid atom: {atom}: {}", it.rest());
+        }
+        (false, Ok(atom))
+            if atom.usedeps().iter().any(|usedep| {
+                atom.usedeps()
+                    .iter()
+                    .filter(|u| usedep.flag() == u.flag())
+                    .count()
+                    > 1
+            }) =>
+        {
+            eprintln!("disagreement due to duplicates in usedeps");
+        }
+        (false, Ok(_)) => {
+            panic!("accpeted invalid atom: {atom}")
+        }
+    }
+
+    return 0;
+}

fuzz/atom/parser/gencorpus.rs

@@ -8,7 +8,7 @@ use std::{
 
 use gentoo_utils::{
     atom::Atom,
-    ebuild::{Depend, repo::Repo},
+    repo::{Repo, ebuild::Depend},
 };
 
 fn main() -> Result<(), Box<dyn Error>> {

fuzz/atom/parser/meson.build

@@ -0,0 +1,6 @@
+fuzzers += {
+    'atom_parser': [
+        meson.current_source_dir() / 'gencorpus.rs',
+        meson.current_source_dir() / 'fuzz.rs',
+    ],
+}

fuzz/atom/vercmp/fuzz.rs

@@ -0,0 +1,114 @@
+use core::slice;
+use gentoo_utils::{
+    Parseable,
+    atom::{Atom, Version},
+};
+use mon::{Parser, ParserFinishedError, input::InputIter};
+use std::{
+    cmp::Ordering,
+    io::{BufRead, BufReader, Write},
+    process::{ChildStdin, ChildStdout, Command, Stdio},
+    sync::{LazyLock, Mutex},
+};
+
+struct PyProcess {
+    stdin: Mutex<ChildStdin>,
+    stdout: Mutex<BufReader<ChildStdout>>,
+    buffer: Mutex<String>,
+}
+
+#[allow(clippy::missing_safety_doc, clippy::needless_return)]
+#[unsafe(no_mangle)]
+pub unsafe extern "C" fn LLVMFuzzerTestOneInput(input: *const u8, len: usize) -> i32 {
+    static PY_PROCESS: LazyLock<PyProcess> = LazyLock::new(|| {
+        #[allow(clippy::zombie_processes)]
+        let mut proc = Command::new("vercmp.py")
+            .stdin(Stdio::piped())
+            .stdout(Stdio::piped())
+            .stderr(Stdio::inherit())
+            .spawn()
+            .expect("failed to spawn vercmp.py");
+
+        let stdin = Mutex::new(proc.stdin.take().unwrap());
+        let stdout = Mutex::new(BufReader::new(proc.stdout.take().unwrap()));
+
+        PyProcess {
+            stdin,
+            stdout,
+            buffer: Mutex::new(String::new()),
+        }
+    });
+
+    let control = Version::parser()
+        .parse_finished(InputIter::new("1.2.0a_alpha1_beta2-r1"))
+        .unwrap();
+
+    let slice = unsafe { slice::from_raw_parts(input, len) };
+
+    if slice.iter().any(|b| !b.is_ascii_graphic()) {
+        return -1;
+    }
+
+    let str = match str::from_utf8(slice) {
+        Ok(str) => str,
+        Err(_) => return -1,
+    };
+
+    let version_str = match str.split_ascii_whitespace().next() {
+        Some(lhs) => lhs,
+        None => return -1,
+    };
+
+    let version = match Version::parser().parse_finished(InputIter::new(version_str)) {
+        Ok(a) => a,
+        Err(_) => return -1,
+    };
+
+    if version.build_id().is_some() {
+        return -1;
+    }
+
+    let gentoo_utils = control.cmp(&version);
+
+    let portage_result = portage_vercmp(&PY_PROCESS, &control, &version);
+
+    match portage_result {
+        Ok(portage) if portage == gentoo_utils => {
+            eprintln!("agreement on {control} cmp {version} == {portage:?}");
+        }
+        Ok(portage) => {
+            panic!(
+                "disagreement on {control} == {version}:\nportage:{portage:?} gentoo_utils:{gentoo_utils:?}"
+            )
+        }
+        Err(_) => {
+            panic!("parsed invalid versions: {control} | {version}")
+        }
+    }
+
+    return 0;
+}
+
+fn portage_vercmp(pyproc: &PyProcess, a: &Version, b: &Version) -> Result<Ordering, ()> {
+    let mut stdin = pyproc.stdin.lock().expect("failed to get stdin lock");
+    let mut stdout = pyproc.stdout.lock().expect("failed to get stdout lock");
+    let mut buffer = pyproc.buffer.lock().expect("failed to get buffer lock");
+
+    writeln!(&mut stdin, "{a} {b}").expect("failed to write line to python process");
+
+    stdin.flush().unwrap();
+
+    buffer.clear();
+
+    stdout
+        .read_line(&mut buffer)
+        .expect("failed to read line from python process");
+
+    match buffer.as_str().trim() {
+        "0" => Ok(Ordering::Equal),
+        "1" => Ok(Ordering::Greater),
+        "-1" => Ok(Ordering::Less),
+        "err" => Err(()),
+        other => panic!("unexpected result from python: {other}"),
+    }
+}

fuzz/atom/vercmp/gencorpus.rs

@@ -0,0 +1,43 @@
+use std::{
+    env,
+    error::Error,
+    fs::{self, OpenOptions},
+    io::Write,
+    path::PathBuf,
+};
+
+use gentoo_utils::repo::Repo;
+
+fn main() -> Result<(), Box<dyn Error>> {
+    let corpus_dir = PathBuf::from(
+        env::args()
+            .nth(1)
+            .expect("expected corpus directory as first argument"),
+    );
+
+    fs::create_dir_all(&corpus_dir)?;
+
+    let repo = Repo::new("/var/db/repos/gentoo");
+    let mut versions = Vec::new();
+
+    for category in repo.categories()? {
+        for ebuild in category?.ebuilds()? {
+            let version = ebuild?.version().clone();
+
+            versions.push(version);
+        }
+    }
+
+    for (i, version) in versions.iter().enumerate() {
+        let path = corpus_dir.as_path().join(i.to_string());
+        let mut file = OpenOptions::new()
+            .write(true)
+            .truncate(true)
+            .create(true)
+            .open(path)?;
+
+        write!(file, "{version}")?;
+    }
+
+    Ok(())
+}

fuzz/atom/vercmp/meson.build

@@ -0,0 +1,6 @@
+fuzzers += {
+    'atom_vercmp': [
+        meson.current_source_dir() / 'gencorpus.rs',
+        meson.current_source_dir() / 'fuzz.rs',
+    ],
+}

fuzz/fuzz.rs

@@ -1,50 +0,0 @@
-use core::slice;
-use gentoo_utils::{Parseable, atom::Atom};
-use mon::{Parser, ParserFinishedError, input::InputIter};
-use std::{
-    io::Write,
-    process::{Command, Stdio},
-};
-
-#[allow(clippy::missing_safety_doc, clippy::needless_return)]
-#[unsafe(no_mangle)]
-pub unsafe extern "C" fn LLVMFuzzerTestOneInput(input: *const u8, len: usize) -> i32 {
-    let slice = unsafe { slice::from_raw_parts(input, len) };
-
-    let atom = match str::from_utf8(slice) {
-        Ok(str) => str.trim(),
-        _ => return -1,
-    };
-
-    let mut proc = Command::new("atom.py")
-        .stdin(Stdio::piped())
-        .spawn()
-        .expect("failed to start atom.py");
-
-    proc.stdin
-        .as_mut()
-        .unwrap()
-        .write_all(atom.as_bytes())
-        .unwrap();
-
-    let status = proc.wait().unwrap();
-
-    let result = Atom::parser().check_finished(InputIter::new(atom));
-
-    match (status.success(), result) {
-        (true, Ok(_)) => {
-            eprintln!("agreement that {atom} is valid");
-            return 0;
-        }
-        (true, Err(ParserFinishedError::Err(it) | ParserFinishedError::Unfinished(it))) => {
-            panic!("gentoo-utils rejected valid atom: {atom}: {}", it.rest());
-        }
-        (false, Err(_)) => {
-            eprintln!("agreement that {atom} is invalid");
-            return -1;
-        }
-        (false, Ok(_)) => {
-            panic!("gentoo-utils accepted invalid atom: {atom}");
-        }
-    }
-}

fuzz/meson.build

@@ -1,30 +1,38 @@
 cbindgen = find_program('cbindgen')
 
-gencorpus = executable(
+fuzzers = {}
-    'gencorpus',
+
-    'gencorpus.rs',
+subdir('atom')
+
+foreach fuzzer, sources : fuzzers
+    gencorpus_rs = sources[0]
+    fuzz_rs = sources[1]
+
+    gencorpus = executable(
+        fuzzer + '_' + 'gencorpus',
+        gencorpus_rs,
         dependencies: [mon],
         link_with: [gentoo_utils],
-)
+    )
 
-corpus_directory = meson.current_build_dir() / 'corpus'
+    corpus_directory = fuzzer + '_' + 'corpus'
 
-corpus = custom_target(
+    corpus = custom_target(
-    'corpus',
+        fuzzer + '_' + 'corpus',
-    output: 'corpus',
+        output: fuzzer + '_' + 'corpus',
         command: [gencorpus, corpus_directory],
-)
+    )
 
-fuzz_h = custom_target(
+    fuzz_h = custom_target(
-    'fuzz_h',
+        fuzzer + '_' + 'fuzz_h',
-    input: 'fuzz.rs',
+        input: fuzz_rs,
-    output: 'fuzz.h',
+        output: fuzzer + '_' + 'fuzz.h',
         command: [cbindgen, '@INPUT@', '-o', '@OUTPUT'],
-)
+    )
 
-fuzz_rs = static_library(
+    fuzz_rs = static_library(
-    'fuzz_rs',
+        fuzzer + '.rs',
-    'fuzz.rs',
+        fuzz_rs,
         rust_abi: 'c',
         rust_args: [
             '-Cpasses=sancov-module',
@@ -33,8 +41,19 @@ fuzz_rs = static_library(
         ],
         dependencies: [mon],
         link_with: [gentoo_utils],
-)
+    )
 
-fuzz = executable('fuzz', link_args: ['-fsanitize=fuzzer'], link_with: [fuzz_rs])
+    fuzz = executable(
+        fuzzer + '_' + 'fuzzer',
+        link_args: ['-fsanitize=fuzzer'],
+        link_with: [fuzz_rs],
+    )
 
-test('fuzz', fuzz, args: [corpus_directory], depends: [corpus], timeout: 0)
+    test(
+        fuzzer + '_' + 'fuzz',
+        fuzz,
+        args: [corpus_directory],
+        depends: [corpus],
+        timeout: 0,
+    )
+endforeach

meson.build

@@ -20,6 +20,21 @@ gentoo_utils = static_library(
     link_with: [thiserror],
 )
 
+if get_option('tests').enabled()
+    rust.test('unittests', gentoo_utils)
+    subdir('tests')
+endif
+
 if get_option('fuzz').enabled()
     subdir('fuzz')
 endif
+
+if get_option('docs').enabled()
+    rust.doctest(
+        'doctests',
+        gentoo_utils,
+        dependencies: [mon, get, itertools],
+        link_with: [thiserror],
+        args: ['--nocapture'],
+    )
+endif

meson.options

@@ -1 +1,3 @@
 option('fuzz', type: 'feature', value: 'disabled')
+option('tests', type: 'feature', value: 'disabled')
+option('docs', type: 'feature', value: 'disabled')

scripts/atom.py

@@ -1,13 +1,13 @@
 #!/usr/bin/env python3
 
 import sys
-import portage.dep as dep
+from portage.dep import Atom
 
-input = sys.stdin.read().strip()
+for line in sys.stdin.buffer:
-
+    try:
-try:
+        Atom(line.decode().strip())
-    dep.Atom(input)
+        sys.stdout.buffer.write(b"0\n")
-except Exception as e:
+    except:
-    sys.exit(1)
+        sys.stdout.buffer.write(b"1\n")
-
+    finally:
-sys.exit(0)
+        sys.stdout.buffer.flush()

scripts/vercmp.py

@@ -0,0 +1,14 @@
+#!/usr/bin/env python3
+
+import sys
+import portage
+
+for line in sys.stdin.buffer:
+    a, b = line.decode().split(" ")
+
+    try:        
+        sys.stdout.buffer.write(f"{portage.vercmp(a, b)}\n".encode())
+    except:
+        sys.stdout.buffer.write(b"err\n")
+    finally:
+        sys.stdout.buffer.flush()

src/atom/mod.rs

@@ -10,15 +10,15 @@ use get::Get;
 
 use itertools::Itertools;
 
-pub mod parsers;
+mod parsers;
 
-#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
 pub enum Blocker {
     Weak,
     Strong,
 }
 
-#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
 pub enum VersionOperator {
     Lt,
     Gt,
@@ -28,19 +28,19 @@ pub enum VersionOperator {
     Roughly,
 }
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct Category(#[get(method = "get", kind = "deref")] String);
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct Name(#[get(method = "get", kind = "deref")] String);
 
-#[derive(Clone, Debug, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct VersionNumber(#[get(method = "get", kind = "deref")] String);
 
-#[derive(Debug, Clone, Get)]
+#[derive(Debug, Clone, PartialEq, Eq, Hash, Get)]
 struct VersionNumbers(#[get(method = "get", kind = "deref")] Vec<VersionNumber>);
 
-#[derive(Clone, Copy, Debug, PartialEq, Eq, PartialOrd, Ord)]
+#[derive(Clone, Copy, Debug, PartialEq, Eq, PartialOrd, Ord, Hash)]
 pub enum VersionSuffixKind {
     Alpha,
     Beta,
@@ -49,58 +49,75 @@ pub enum VersionSuffixKind {
     P,
 }
 
-#[derive(Clone, Debug, Get)]
+#[derive(Clone, Debug, Hash, PartialEq, Eq, Get)]
 pub struct VersionSuffix {
     kind: VersionSuffixKind,
     number: Option<VersionNumber>,
 }
 
-#[derive(Debug, Clone, Get)]
+#[derive(Debug, Clone, PartialEq, Eq, Hash, Get)]
 pub struct VersionSuffixes(#[get(method = "get", kind = "deref")] Vec<VersionSuffix>);
 
-#[derive(Clone, Debug, Get)]
+#[derive(Debug, Clone, Get, PartialEq, Eq, Hash)]
+pub struct BuildId(#[get(method = "get", kind = "deref")] String);
+
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct Version {
     numbers: VersionNumbers,
     letter: Option<char>,
     suffixes: VersionSuffixes,
     rev: Option<VersionNumber>,
+    build_id: Option<BuildId>,
 }
 
-#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
+pub struct Wildcard;
+
+#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
 pub enum SlotOperator {
     Eq,
     Star,
 }
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct SlotName(#[get(method = "name", kind = "deref")] String);
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash)]
-pub struct Slot {
+pub enum Slot {
-    primary: Option<SlotName>,
+    Wildcard,
+    Equal,
+    NameEqual {
+        primary: SlotName,
         sub: Option<SlotName>,
-    operator: Option<SlotOperator>,
+    },
+    Name {
+        primary: SlotName,
+        sub: Option<SlotName>,
+    },
 }
 
-#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
 pub enum UseDepNegate {
     Minus,
     Exclamation,
 }
 
-#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
 pub enum UseDepSign {
     Enabled,
     Disabled,
 }
 
-#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
 pub enum UseDepCondition {
     Eq,
     Question,
 }
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash)]
+pub struct Repo(String);
+
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct UseDep {
     negate: Option<UseDepNegate>,
     flag: UseFlag,
@@ -108,13 +125,13 @@ pub struct UseDep {
     condition: Option<UseDepCondition>,
 }
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct Cp {
     category: Category,
     name: Name,
 }
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct Cpv {
     category: Category,
     name: Name,
@@ -122,13 +139,14 @@ pub struct Cpv {
     slot: Option<Slot>,
 }
 
-#[derive(Clone, Debug, Get, PartialEq, Eq)]
+#[derive(Clone, Debug, Get, PartialEq, Eq, Hash)]
 pub struct Atom {
     blocker: Option<Blocker>,
     category: Category,
     name: Name,
-    version: Option<(VersionOperator, Version)>,
+    version: Option<(VersionOperator, Version, Option<Wildcard>)>,
     slot: Option<Slot>,
+    repo: Option<Repo>,
     #[get(kind = "deref")]
     usedeps: Vec<UseDep>,
 }
@@ -146,7 +164,7 @@ impl Cpv {
 impl Atom {
     #[must_use]
     pub fn version_operator(&self) -> Option<VersionOperator> {
-        self.version.clone().map(|(oper, _)| oper)
+        self.version.clone().map(|(oper, _, _)| oper)
     }
 
     #[must_use]
@@ -160,7 +178,7 @@ impl Atom {
     #[must_use]
     pub fn into_cpv(self) -> Option<Cpv> {
         match self.version {
-            Some((_, version)) => Some(Cpv {
+            Some((_, version, _)) => Some(Cpv {
                 category: self.category,
                 name: self.name,
                 version,
@@ -171,20 +189,43 @@ impl Atom {
     }
 }
 
-impl PartialEq for VersionSuffix {
+impl VersionNumber {
-    fn eq(&self, other: &Self) -> bool {
+    #[must_use]
-        self.kind == other.kind
+    pub fn cmp_as_ints(&self, other: &Self) -> Ordering {
-            && match (&self.number, &other.number) {
+        let a = self.get().trim_start_matches('0');
-                (Some(a), Some(b)) => a.0 == b.0,
+        let b = other.get().trim_start_matches('0');
-                (Some(a), None) if a.get().chars().all(|c| c == '0') => true,
+
-                (None, Some(b)) if b.get().chars().all(|c| c == '0') => true,
+        a.len().cmp(&b.len()).then_with(|| a.cmp(b))
-                (Some(_), None) | (None, Some(_)) => false,
+    }
-                (None, None) => true,
+
+    #[must_use]
+    pub fn cmp_as_str(&self, other: &Self) -> Ordering {
+        if self.get().starts_with('0') || other.get().starts_with('0') {
+            let a = self.get().trim_end_matches('0');
+            let b = other.get().trim_end_matches('0');
+
+            a.cmp(b)
+        } else {
+            self.cmp_as_ints(other)
         }
     }
 }
 
-impl Eq for VersionSuffix {}
+impl PartialOrd for BuildId {
+    fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
+        Some(self.cmp(other))
+    }
+}
+
+impl Ord for BuildId {
+    fn cmp(&self, other: &Self) -> Ordering {
+        // build-id may not start with a zero so we dont need to strip them
+        self.get()
+            .len()
+            .cmp(&other.get().len())
+            .then_with(|| self.get().cmp(other.get()))
+    }
+}
 
 impl PartialOrd for VersionSuffix {
     fn partial_cmp(&self, other: &Self) -> Option<std::cmp::Ordering> {
@@ -198,11 +239,7 @@ impl Ord for VersionSuffix {
             Ordering::Less => Ordering::Less,
             Ordering::Greater => Ordering::Greater,
             Ordering::Equal => match (&self.number, &other.number) {
-                (Some(a), Some(b)) => {
+                (Some(a), Some(b)) => a.cmp_as_ints(b),
-                    a.0.parse::<u64>()
-                        .unwrap()
-                        .cmp(&b.0.parse::<u64>().unwrap())
-                }
                 (Some(a), None) if a.get().chars().all(|c| c == '0') => Ordering::Equal,
                 (None, Some(b)) if b.get().chars().all(|c| c == '0') => Ordering::Equal,
                 (Some(_), None) => Ordering::Greater,
@@ -213,23 +250,6 @@ impl Ord for VersionSuffix {
     }
 }
 
-impl PartialEq for VersionSuffixes {
-    fn eq(&self, other: &Self) -> bool {
-        let mut a = self.get().iter();
-        let mut b = other.get().iter();
-
-        loop {
-            match (a.next(), b.next()) {
-                (Some(a), Some(b)) if a == b => (),
-                (Some(_) | None, Some(_)) | (Some(_), None) => break false,
-                (None, None) => break true,
-            }
-        }
-    }
-}
-
-impl Eq for VersionSuffixes {}
-
 impl PartialOrd for VersionSuffixes {
     fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
         Some(self.cmp(other))
@@ -260,41 +280,6 @@ impl Ord for VersionSuffixes {
     }
 }
 
-impl PartialEq for VersionNumbers {
-    fn eq(&self, other: &Self) -> bool {
-        self.get().first().unwrap().get().parse::<u64>().unwrap()
-            == other.get().first().unwrap().get().parse().unwrap()
-            && {
-                let mut a = self.get().iter().skip(1);
-                let mut b = other.get().iter().skip(1);
-
-                loop {
-                    match (a.next(), b.next()) {
-                        (Some(a), Some(b)) if a.get().starts_with('0') => {
-                            let a = a.get().trim_end_matches('0');
-                            let b = b.get().trim_end_matches('0');
-
-                            if a != b {
-                                break false;
-                            }
-                        }
-                        (Some(a), Some(b)) => {
-                            if a.get().parse::<u64>().unwrap() != b.get().parse::<u64>().unwrap() {
-                                break false;
-                            }
-                        }
-                        (Some(a), None) if a.get().chars().all(|c| c == '0') => (),
-                        (None, Some(b)) if b.get().chars().all(|c| c == '0') => (),
-                        (None, None) => break true,
-                        _ => break false,
-                    }
-                }
-            }
-    }
-}
-
-impl Eq for VersionNumbers {}
-
 impl PartialOrd for VersionNumbers {
     fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
         Some(self.cmp(other))
@@ -307,10 +292,7 @@ impl Ord for VersionNumbers {
             .get()
             .first()
             .unwrap()
-            .get()
+            .cmp_as_ints(other.get().first().unwrap())
-            .parse::<u64>()
-            .unwrap()
-            .cmp(&other.get().first().unwrap().get().parse::<u64>().unwrap())
         {
             Ordering::Less => Ordering::Less,
             Ordering::Greater => Ordering::Greater,
@@ -320,24 +302,7 @@ impl Ord for VersionNumbers {
 
                 loop {
                     match (a.next(), b.next()) {
-                        (Some(a), Some(b))
+                        (Some(a), Some(b)) => match a.cmp_as_str(b) {
-                            if a.get().starts_with('0') || b.get().starts_with('0') =>
-                        {
-                            let a = a.get().trim_end_matches('0');
-                            let b = b.get().trim_end_matches('0');
-
-                            match a.cmp(b) {
-                                Ordering::Less => break Ordering::Less,
-                                Ordering::Greater => break Ordering::Greater,
-                                Ordering::Equal => (),
-                            }
-                        }
-                        (Some(a), Some(b)) => match a
-                            .get()
-                            .parse::<u64>()
-                            .unwrap()
-                            .cmp(&b.get().parse::<u64>().unwrap())
-                        {
                             Ordering::Less => break Ordering::Less,
                             Ordering::Greater => break Ordering::Greater,
                             Ordering::Equal => (),
@@ -353,25 +318,6 @@ impl Ord for VersionNumbers {
     }
 }
 
-impl PartialEq for Version {
-    fn eq(&self, other: &Self) -> bool {
-        self.numbers == other.numbers
-            && self.suffixes == other.suffixes
-            && self.letter == other.letter
-            && match (&self.rev, &other.rev) {
-                (Some(a), Some(b)) => {
-                    a.get().parse::<u64>().unwrap() == b.get().parse::<u64>().unwrap()
-                }
-                (Some(a), None) if a.get().chars().all(|c| c == '0') => true,
-                (None, Some(b)) if b.get().chars().all(|c| c == '0') => true,
-                (Some(_), None) | (None, Some(_)) => false,
-                (None, None) => true,
-            }
-    }
-}
-
-impl Eq for Version {}
-
 impl PartialOrd for Version {
     fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
         Some(self.cmp(other))
@@ -386,12 +332,6 @@ impl Ord for Version {
             Ordering::Equal => (),
         }
 
-        match self.suffixes.cmp(&other.suffixes) {
-            Ordering::Less => return Ordering::Less,
-            Ordering::Greater => return Ordering::Greater,
-            Ordering::Equal => (),
-        }
-
         match (self.letter, other.letter) {
             (Some(a), Some(b)) if a < b => return Ordering::Less,
             (Some(a), Some(b)) if a > b => return Ordering::Greater,
@@ -402,15 +342,28 @@ impl Ord for Version {
             _ => unreachable!(),
         }
 
+        match self.suffixes.cmp(&other.suffixes) {
+            Ordering::Less => return Ordering::Less,
+            Ordering::Greater => return Ordering::Greater,
+            Ordering::Equal => (),
+        }
+
         match (&self.rev, &other.rev) {
-            (Some(a), Some(b)) => a
+            (Some(a), Some(b)) => match a.cmp_as_ints(b) {
-                .get()
+                Ordering::Less => return Ordering::Less,
-                .parse::<u64>()
+                Ordering::Greater => return Ordering::Greater,
-                .unwrap()
+                Ordering::Equal => (),
-                .cmp(&b.get().parse().unwrap()),
+            },
-            (Some(a), None) if a.get().chars().all(|c| c == '0') => Ordering::Equal,
+            (Some(a), None) if a.get().chars().all(|c| c == '0') => (),
+            (Some(_), None) => return Ordering::Greater,
+            (None, Some(b)) if b.get().chars().all(|c| c == '0') => (),
+            (None, Some(_)) => return Ordering::Less,
+            (None, None) => (),
+        }
+
+        match (&self.build_id, &other.build_id) {
+            (Some(a), Some(b)) => a.cmp(b),
             (Some(_), None) => Ordering::Greater,
-            (None, Some(b)) if b.get().chars().all(|c| c == '0') => Ordering::Equal,
             (None, Some(_)) => Ordering::Less,
             (None, None) => Ordering::Equal,
         }
@@ -467,6 +420,12 @@ impl fmt::Display for VersionNumber {
     }
 }
 
+impl fmt::Display for BuildId {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "{}", self.get())
+    }
+}
+
 impl fmt::Display for VersionSuffixKind {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         match self {
@@ -523,6 +482,10 @@ impl fmt::Display for Version {
             write!(f, "-r{rev}")?;
         }
 
+        if let Some(build_id) = self.build_id.as_ref() {
+            write!(f, "-{build_id}")?;
+        }
+
         Ok(())
     }
 }
@@ -544,20 +507,31 @@ impl fmt::Display for SlotName {
 
 impl fmt::Display for Slot {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
-        if let Some(slot) = self.primary.as_ref() {
+        match self {
-            write!(f, "{slot}")?;
+            Self::Wildcard => write!(f, "*"),
+            Self::Equal => {
+                write!(f, "=")
             }
+            Self::NameEqual { primary, sub } => {
+                write!(f, "{primary}")?;
 
-        if let Some(sub) = self.sub.as_ref() {
+                if let Some(sub) = sub {
                     write!(f, "/{sub}")?;
                 }
 
-        if let Some(operator) = self.operator.as_ref() {
+                write!(f, "=")
-            write!(f, "{operator}")?;
+            }
+            Self::Name { primary, sub } => {
+                write!(f, "{primary}")?;
+
+                if let Some(sub) = sub {
+                    write!(f, "/{sub}")?;
                 }
 
                 Ok(())
             }
+        }
+    }
 }
 
 impl fmt::Display for UseDepNegate {
@@ -639,8 +613,10 @@ impl fmt::Display for Atom {
         write!(f, "/")?;
         write!(f, "{}", self.name)?;
 
-        if let Some((_, version)) = self.version.as_ref() {
+        if let Some((_, version, None)) = self.version() {
             write!(f, "-{version}")?;
+        } else if let Some((_, version, Some(_))) = self.version() {
+            write!(f, "-{version}*")?;
         }
 
         if let Some(slot) = self.slot.as_ref() {
@@ -710,38 +686,6 @@ mod test {
         assert_eq!(atom.to_string().as_str(), s);
     }
 
-    #[test]
-    fn test_version_suffix_eq() {
-        let a = VersionSuffix::parser()
-            .parse_finished(InputIter::new("alpha0"))
-            .unwrap();
-        let b = VersionSuffix::parser()
-            .parse_finished(InputIter::new("alpha"))
-            .unwrap();
-
-        assert_eq_display!(a, b);
-    }
-
-    #[test]
-    fn test_version_eq() {
-        let versions = [
-            ("1", "1"),
-            ("1", "1.0.0"),
-            ("1.0", "1.0.0"),
-            ("1.0.0_alpha0", "1.0.0_alpha"),
-            ("1.0.0", "1.0.0-r0"),
-        ];
-
-        for (a, b) in versions.map(|(a, b)| {
-            (
-                Version::parser().parse_finished(InputIter::new(a)).unwrap(),
-                Version::parser().parse_finished(InputIter::new(b)).unwrap(),
-            )
-        }) {
-            assert_eq_display!(a, b);
-        }
-    }
-
     #[test]
     fn test_version_cmp() {
         let versions = [
@@ -750,6 +694,7 @@ mod test {
             ("1.0.0_alpha", "1.0.0_alpha_p", Ordering::Less),
             ("1.0.0-r0", "1.0.0", Ordering::Equal),
             ("1.0.0-r0000", "1.0.0", Ordering::Equal),
+            ("1.0.0-r1-1", "1.0.0-r1-2", Ordering::Less),
         ];
 
         for (a, b, ordering) in versions.iter().map(|(a, b, ordering)| {
@@ -816,4 +761,19 @@ mod test {
 
         assert_cmp_display!(a, b, Ordering::Greater);
     }
+
+    #[test]
+    fn test_fuzzer_cases() {
+        let control = Version::parser()
+            .parse_finished(InputIter::new("1.2.0a_alpha1_beta2-r1-8"))
+            .unwrap();
+
+        for (version_str, expected) in [("1.2.0", Ordering::Greater)] {
+            let version = Version::parser()
+                .parse_finished(InputIter::new(version_str))
+                .unwrap();
+
+            assert_cmp_display!(control, version, expected);
+        }
+    }
 }

src/atom/parsers.rs

@@ -1,13 +1,16 @@
 use core::option::Option::None;
 
-use mon::{Parser, ParserIter, alphanumeric, r#if, numeric1, one_of, tag};
+use mon::{
+    Parser, ParserIter, ascii_alphanumeric, ascii_numeric, ascii_numeric1, eof, r#if,
+    input::InputIter, one_of, tag,
+};
 
 use crate::{
     Parseable,
     atom::{
-        Atom, Blocker, Category, Cp, Cpv, Name, Slot, SlotName, SlotOperator, UseDep,
+        Atom, Blocker, BuildId, Category, Cp, Cpv, Name, Repo, Slot, SlotName, SlotOperator,
-        UseDepCondition, UseDepNegate, UseDepSign, Version, VersionNumber, VersionNumbers,
+        UseDep, UseDepCondition, UseDepNegate, UseDepSign, Version, VersionNumber, VersionNumbers,
-        VersionOperator, VersionSuffix, VersionSuffixKind, VersionSuffixes,
+        VersionOperator, VersionSuffix, VersionSuffixKind, VersionSuffixes, Wildcard,
     },
     useflag::UseFlag,
 };
@@ -40,7 +43,22 @@ impl<'a> Parseable<'a, &'a str> for VersionNumber {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        numeric1().map(|output: &str| VersionNumber(output.to_string()))
+        ascii_numeric1().map(|output: &str| VersionNumber(output.to_string()))
+    }
+}
+
+impl<'a> Parseable<'a, &'a str> for BuildId {
+    type Parser = impl Parser<&'a str, Output = Self>;
+
+    fn parser() -> Self::Parser {
+        let start = ascii_numeric().and_not(tag("0"));
+        let rest = ascii_numeric().repeated().many();
+
+        start
+            .and(rest)
+            .recognize()
+            .or(tag("0"))
+            .map(|output: &str| BuildId(output.to_string()))
     }
 }
 
@@ -72,9 +90,6 @@ impl<'a> Parseable<'a, &'a str> for VersionNumbers {
 
     fn parser() -> Self::Parser {
         VersionNumber::parser()
-            .followed_by(tag("*").opt())
-            .recognize()
-            .map(|output: &str| VersionNumber(output.to_string()))
             .separated_by(tag("."))
             .at_least(1)
             .map(VersionNumbers)
@@ -97,16 +112,19 @@ impl<'a> Parseable<'a, &'a str> for Version {
 
     fn parser() -> Self::Parser {
         let rev = VersionNumber::parser().preceded_by(tag("-r"));
+        let build_id = BuildId::parser().preceded_by(tag("-"));
 
         VersionNumbers::parser()
             .and(r#if(|c: &char| c.is_ascii_alphabetic() && c.is_ascii_lowercase()).opt())
             .and(VersionSuffixes::parser().preceded_by(tag("_")).opt())
             .and(rev.opt())
-            .map(|(((numbers, letter), suffixes), rev)| Version {
+            .and(build_id.opt())
+            .map(|((((numbers, letter), suffixes), rev), build_id)| Version {
                 numbers,
                 letter,
                 suffixes: suffixes.unwrap_or(VersionSuffixes(Vec::new())),
                 rev,
+                build_id,
             })
     }
 }
@@ -115,8 +133,11 @@ impl<'a> Parseable<'a, &'a str> for Category {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        let start = alphanumeric().or(one_of("_".chars()));
+        let start = ascii_alphanumeric().or(one_of("_".chars()));
-        let rest = alphanumeric().or(one_of("+_.-".chars())).repeated().many();
+        let rest = ascii_alphanumeric()
+            .or(one_of("+_.-".chars()))
+            .repeated()
+            .many();
 
         start
             .and(rest)
@@ -129,21 +150,31 @@ impl<'a> Parseable<'a, &'a str> for Name {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        let start = alphanumeric().or(one_of("_".chars()));
+        let start = || ascii_alphanumeric().or(one_of("_".chars()));
 
-        let rest = alphanumeric()
+        let rest = ascii_alphanumeric()
             .or(one_of("_+".chars()))
             .or(one_of("-".chars()).and_not(
                 Version::parser()
                     .preceded_by(tag("-"))
-                    .followed_by(alphanumeric().or(one_of("_+-".chars())).not()),
+                    .followed_by(ascii_alphanumeric().or(one_of("_+-".chars())).not()),
             ))
             .repeated()
             .many();
 
-        start
+        let verify = ascii_alphanumeric()
+            .or(one_of("_+".chars()))
+            .or(one_of("-".chars())
+                .and_not(Version::parser().preceded_by(tag("-")).followed_by(eof())))
+            .repeated()
+            .many();
+
+        start()
             .and(rest)
             .recognize()
+            .verify_output(move |output: &&str| {
+                verify.check_finished(InputIter::new(*output)).is_ok()
+            })
             .map(|output: &str| Name(output.to_string()))
     }
 }
@@ -162,8 +193,11 @@ impl<'a> Parseable<'a, &'a str> for SlotName {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        let start = alphanumeric().or(one_of("_".chars()));
+        let start = ascii_alphanumeric().or(one_of("_".chars()));
-        let rest = alphanumeric().or(one_of("+_.-".chars())).repeated().many();
+        let rest = ascii_alphanumeric()
+            .or(one_of("+_.-".chars()))
+            .repeated()
+            .many();
 
         start
             .and(rest)
@@ -176,15 +210,17 @@ impl<'a> Parseable<'a, &'a str> for Slot {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        SlotName::parser()
+        let wildcard = tag("*").map(|_| Slot::Wildcard);
-            .opt()
+        let equal = tag("=").map(|_| Slot::Equal);
+        let name_equal = SlotName::parser()
             .and(SlotName::parser().preceded_by(tag("/")).opt())
-            .and(SlotOperator::parser().opt())
+            .followed_by(tag("="))
-            .map(|((primary, sub), operator)| Slot {
+            .map(|(primary, sub)| Slot::NameEqual { primary, sub });
-                primary,
+        let name = SlotName::parser()
-                sub,
+            .and(SlotName::parser().preceded_by(tag("/")).opt())
-                operator,
+            .map(|(primary, sub)| Self::Name { primary, sub });
-            })
+
+        wildcard.or(equal).or(name_equal).or(name)
     }
 }
 
@@ -198,6 +234,28 @@ impl<'a> Parseable<'a, &'a str> for UseDepSign {
     }
 }
 
+impl<'a> Parseable<'a, &'a str> for Repo {
+    type Parser = impl Parser<&'a str, Output = Self>;
+
+    fn parser() -> Self::Parser {
+        let start = ascii_alphanumeric().or(one_of("_".chars()));
+        let rest = ascii_alphanumeric()
+            .or(one_of("_-".chars()))
+            .repeated()
+            .many();
+
+        start
+            .and(rest)
+            .recognize()
+            .verify_output(move |output: &&str| {
+                Name::parser()
+                    .check_finished(InputIter::new(*output))
+                    .is_ok()
+            })
+            .map(|output: &str| Repo(output.to_string()))
+    }
+}
+
 impl<'a> Parseable<'a, &'a str> for UseDep {
     type Parser = impl Parser<&'a str, Output = Self>;
 
@@ -275,7 +333,7 @@ impl<'a> Parseable<'a, &'a str> for Atom {
         let usedeps = || {
             UseDep::parser()
                 .separated_by(tag(","))
-                .many()
+                .at_least(1)
                 .delimited_by(tag("["), tag("]"))
                 .opt()
         };
@@ -285,15 +343,19 @@ impl<'a> Parseable<'a, &'a str> for Atom {
             .and(Category::parser())
             .and(Name::parser().preceded_by(tag("/")))
             .and(Slot::parser().preceded_by(tag(":")).opt())
+            .and(Repo::parser().preceded_by(tag("::")).opt())
             .and(usedeps())
-            .map(|((((blocker, category), name), slot), usedeps)| Atom {
+            .map(
+                |(((((blocker, category), name), slot), repo), usedeps)| Atom {
                     blocker,
                     category,
                     name,
                     version: None,
                     slot,
+                    repo,
                     usedeps: usedeps.unwrap_or(Vec::new()),
-            });
+                },
+            );
 
         let with_version = Blocker::parser()
             .opt()
@@ -301,33 +363,37 @@ impl<'a> Parseable<'a, &'a str> for Atom {
             .and(Category::parser())
             .and(Name::parser().preceded_by(tag("/")))
             .and(Version::parser().preceded_by(tag("-")))
+            .and(tag("*").map(|_| Wildcard).opt())
             .and(Slot::parser().preceded_by(tag(":")).opt())
+            .and(Repo::parser().preceded_by(tag("::")).opt())
             .and(usedeps())
+            .verify_output(
+                |((((((((_, version_operator), _), _), version), star), _), _), _)| {
+                    matches!(
+                        (version_operator, star),
+                        (VersionOperator::Eq, Some(_) | None) | (_, None)
+                    ) && matches!((version.build_id(), star), (Some(_), None) | (None, _))
+                },
+            )
             .map(
-                |((((((blocker, version_operator), category), name), version), slot), usedeps)| {
+                |(
+                    (
+                        ((((((blocker, version_operator), category), name), version), star), slot),
+                        repo,
+                    ),
+                    usedeps,
+                )| {
                     Atom {
                         blocker,
                         category,
                         name,
-                        version: Some((version_operator, version)),
+                        version: Some((version_operator, version, star)),
                         slot,
+                        repo,
                         usedeps: usedeps.unwrap_or(Vec::new()),
                     }
                 },
-            )
+            );
-            .verify_output(|atom| match &atom.version {
-                Some((VersionOperator::Eq, _)) => true,
-                Some((_, version))
-                    if !version
-                        .numbers()
-                        .get()
-                        .iter()
-                        .any(|number| number.get().contains('*')) =>
-                {
-                    true
-                }
-                _ => false,
-            });
 
         with_version.or(without_version)
     }
@@ -420,9 +486,9 @@ mod test {
 
     #[test]
     fn test_empty_slot() {
-        let it = InputIter::new("foo/bar:=");
+        let it = InputIter::new("=dev-ml/uucp-17*:");
 
-        Atom::parser().check_finished(it).unwrap();
+        assert!(Atom::parser().check_finished(it).is_err());
     }
 
     #[test]
@@ -494,4 +560,40 @@ mod test {
 
         assert!(Cpv::parser().parse_finished(it).is_err());
     }
+
+    #[test]
+    fn test_empty_slot_with_operator() {
+        let it = InputIter::new("foo/bar:=");
+
+        Atom::parser().check_finished(it).unwrap();
+    }
+
+    #[test]
+    fn test_with_repo() {
+        let it = InputIter::new("=foo/bar-1.0.0:slot/sub=::gentoo[a,b,c]");
+
+        Atom::parser().check_finished(it).unwrap();
+    }
+
+    #[test]
+    fn test_against_fuzzer_false_positives() {
+        let atoms = [
+            "media-libs/libsdl2[haptitick(+),sound(+)vd,eio(+)]",
+            "=kde-frameworks/kcodecs-6.19*86",
+            "=dev-ml/stdio-0.17*t:=[ocamlopt?]",
+            ">=dev-libs/libgee-0-8.5:0..8=",
+            "<dev-haskell/wai-3.3:=[]",
+            ">=kde-frameworks/kcrash-2.16.0:6*",
+            "0-f/merreka+m::k+",
+            "iev-a/h:/n=",
+            "=dev-ml/stdio-0-17*:=[ocamlopt?]",
+        ];
+
+        for atom in atoms {
+            assert!(
+                Atom::parser().check_finished(InputIter::new(atom)).is_err(),
+                "{atom}"
+            );
+        }
+    }
 }

src/lib.rs

@@ -1,15 +1,91 @@
+//! Gentoo and PMS related utils.
+//!
+//! Currently implements:
+//! - parsers for atoms and DEPEND expressions
+//! - strongly typed representations of atoms, versions, etc
+//! - version comparison and equality impls
+//! - iterator over repos categories and ebuilds
+//!
+//! Planned features
+//! - profile evaluation
+//! - vdb reader
+//! - sourcing ebuilds with bash
+//!
+
 #![deny(clippy::pedantic, unused_imports)]
-#![allow(dead_code, unstable_name_collisions, clippy::missing_errors_doc)]
+#![allow(
+    dead_code,
+    unstable_name_collisions,
+    clippy::missing_errors_doc,
+    clippy::missing_panics_doc
+)]
 #![feature(impl_trait_in_assoc_type)]
 
-use mon::{Parser, input::Input};
+use mon::{
+    Parser,
+    input::{Input, InputIter},
+};
 
 pub trait Parseable<'a, I: Input + 'a> {
     type Parser: Parser<I, Output = Self>;
 
     fn parser() -> Self::Parser;
+
+    fn parse(input: I) -> Result<Self, I>
+    where
+        Self: Sized,
+    {
+        Self::parser()
+            .parse_finished(InputIter::new(input))
+            .map_err(|e| e.rest())
+    }
 }
 
+/// Strongly typed atom and cpv representations.
+///
+/// Create atoms from parsers:
+/// ```
+/// use gentoo_utils::{Parseable, atom::Atom};
+///
+/// let emacs = Atom::parse("=app-editors/emacs-31.0-r1")
+///    .expect("failed to parse atom");
+///
+/// assert_eq!(emacs.to_string(), "=app-editors/emacs-31.0-r1");
+/// ````
+///
+/// Compare versions:
+/// ```
+/// use gentoo_utils::{Parseable, atom::Cpv};
+///
+/// let a = Cpv::parse("foo/bar-1.0").unwrap();
+/// let b = Cpv::parse("foo/bar-2.0").unwrap();
+///
+/// assert!(a < b);
+/// ```
 pub mod atom;
-pub mod ebuild;
+
+/// Access to repos and ebuilds.
+///
+/// ```
+/// use gentoo_utils::repo::Repo;
+///
+/// let repo = Repo::new("/var/db/repos/gentoo");
+///
+/// for result in repo.categories().expect("failed to read categories") {
+///    let category = result.expect("failed to read category");
+///
+///    for result in category.ebuilds().expect("failed to read ebuilds") {
+///        let ebuild = result.expect("failed to read ebuild");
+///
+///        println!(
+///            "{}-{}: {}",
+///            ebuild.name(),
+///            ebuild.version(),
+///            ebuild.description().clone().unwrap_or("no description available".to_string())
+///        );
+///    }
+/// }
+///
+/// ```
+pub mod repo;
 pub mod useflag;

src/repo/ebuild/mod.rs

@@ -6,8 +6,7 @@ use crate::{
     useflag::{IUseFlag, UseFlag},
 };
 
-pub mod parsers;
+mod parsers;
-pub mod repo;
 
 #[derive(Clone, Debug)]
 pub enum Conditional {
@@ -59,26 +58,26 @@ pub struct Eclass(#[get(method = "get", kind = "deref")] String);
 
 #[derive(Debug, Clone, Get)]
 pub struct Ebuild {
-    name: Name,
+    pub(super) name: Name,
-    version: Version,
+    pub(super) version: Version,
-    slot: Option<Slot>,
+    pub(super) slot: Option<Slot>,
-    homepage: Option<String>,
+    pub(super) homepage: Option<String>,
     #[get(kind = "deref")]
-    src_uri: Vec<Depend<SrcUri>>,
+    pub(super) src_uri: Vec<Depend<SrcUri>>,
-    eapi: Option<Eapi>,
+    pub(super) eapi: Option<Eapi>,
     #[get(kind = "deref")]
-    inherit: Vec<Eclass>,
+    pub(super) inherit: Vec<Eclass>,
     #[get(kind = "deref")]
-    iuse: Vec<IUseFlag>,
+    pub(super) iuse: Vec<IUseFlag>,
     #[get(kind = "deref")]
-    license: Vec<Depend<License>>,
+    pub(super) license: Vec<Depend<License>>,
-    description: Option<String>,
+    pub(super) description: Option<String>,
     #[get(kind = "deref")]
-    depend: Vec<Depend<Atom>>,
+    pub(super) depend: Vec<Depend<Atom>>,
     #[get(kind = "deref")]
-    bdepend: Vec<Depend<Atom>>,
+    pub(super) bdepend: Vec<Depend<Atom>>,
     #[get(kind = "deref")]
-    rdepend: Vec<Depend<Atom>>,
+    pub(super) rdepend: Vec<Depend<Atom>>,
     #[get(kind = "deref")]
-    idepend: Vec<Depend<Atom>>,
+    pub(super) idepend: Vec<Depend<Atom>>,
 }

src/repo/ebuild/parsers.rs

@@ -1,10 +1,12 @@
 use std::path::PathBuf;
 
-use mon::{Parser, ParserIter, alpha1, alphanumeric, r#if, one_of, tag, whitespace1};
+use mon::{
+    Parser, ParserIter, ascii_alpha1, ascii_alphanumeric, ascii_whitespace1, r#if, one_of, tag,
+};
 
 use crate::{
     Parseable,
-    ebuild::{Conditional, Depend, Eapi, Eclass, License, SrcUri, Uri, UriPrefix},
+    repo::ebuild::{Conditional, Depend, Eapi, Eclass, License, SrcUri, Uri, UriPrefix},
     useflag::UseFlag,
 };
 
@@ -22,7 +24,7 @@ impl<'a> Parseable<'a, &'a str> for Uri {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        let protocol = alpha1::<&str>()
+        let protocol = ascii_alpha1::<&str>()
             .followed_by(tag("://"))
             .map(|output: &str| output.to_string());
         let path = r#if(|c: &char| !c.is_ascii_whitespace())
@@ -67,8 +69,11 @@ impl<'a> Parseable<'a, &'a str> for License {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        let start = alphanumeric().or(one_of("_".chars()));
+        let start = ascii_alphanumeric().or(one_of("_".chars()));
-        let rest = alphanumeric().or(one_of("+_.-".chars())).repeated().many();
+        let rest = ascii_alphanumeric()
+            .or(one_of("+_.-".chars()))
+            .repeated()
+            .many();
 
         start
             .and(rest)
@@ -81,8 +86,11 @@ impl<'a> Parseable<'a, &'a str> for Eapi {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        let start = alphanumeric().or(one_of("_".chars()));
+        let start = ascii_alphanumeric().or(one_of("_".chars()));
-        let rest = alphanumeric().or(one_of("+_.-".chars())).repeated().many();
+        let rest = ascii_alphanumeric()
+            .or(one_of("+_.-".chars()))
+            .repeated()
+            .many();
 
         start
             .and(rest)
@@ -116,23 +124,23 @@ where
         |it| {
             let exprs = || {
                 Depend::parser()
-                    .separated_by_with_trailing(whitespace1())
+                    .separated_by_with_trailing(ascii_whitespace1())
                     .at_least(1)
-                    .delimited_by(tag("(").followed_by(whitespace1()), tag(")"))
+                    .delimited_by(tag("(").followed_by(ascii_whitespace1()), tag(")"))
             };
 
             let all_of_group = exprs().map(|exprs| Depend::AllOf(exprs));
 
             let any_of_group = exprs()
-                .preceded_by(tag("||").followed_by(whitespace1()))
+                .preceded_by(tag("||").followed_by(ascii_whitespace1()))
                 .map(|exprs| Depend::AnyOf(exprs));
 
             let one_of_group = exprs()
-                .preceded_by(tag("^^").followed_by(whitespace1()))
+                .preceded_by(tag("^^").followed_by(ascii_whitespace1()))
                 .map(|exprs| Depend::OneOf(exprs));
 
             let conditional_group = Conditional::parser()
-                .followed_by(whitespace1())
+                .followed_by(ascii_whitespace1())
                 .and(exprs())
                 .map(|(conditional, exprs)| Depend::ConditionalGroup(conditional, exprs));
 
@@ -166,7 +174,7 @@ mod test {
 
     use mon::{ParserIter, input::InputIter};
 
-    use crate::{atom::Atom, ebuild::Depend};
+    use crate::{atom::Atom, repo::ebuild::Depend};
 
     use super::*;
 
@@ -189,7 +197,7 @@ mod test {
         let it = InputIter::new("flag? ( || ( foo/bar foo/bar ) )");
 
         Depend::<Atom>::parser()
-            .separated_by(whitespace1())
+            .separated_by(ascii_whitespace1())
             .many()
             .check_finished(it)
             .unwrap();

src/repo/mod.rs

@@ -5,15 +5,17 @@ use std::{
 
 use get::Get;
 
-use mon::{Parser, ParserIter, input::InputIter, tag, whitespace1};
+use mon::{Parser, ParserIter, ascii_whitespace1, input::InputIter, tag};
 
 use crate::{
     Parseable,
     atom::{self, Atom},
-    ebuild::{Depend, Eapi, Ebuild, Eclass, License, SrcUri},
+    repo::ebuild::{Depend, Eapi, Ebuild, Eclass, License, SrcUri},
     useflag::IUseFlag,
 };
 
+pub mod ebuild;
+
 #[derive(Debug, thiserror::Error)]
 pub enum Error {
     #[error("io error: {0}")]
@@ -208,7 +210,7 @@ fn read_src_uri(input: &str) -> Option<Result<Vec<Depend<SrcUri>>, Error>> {
         .find_map(|line| line.strip_prefix("SRC_URI="))?;
 
     match Depend::<SrcUri>::parser()
-        .separated_by(whitespace1())
+        .separated_by(ascii_whitespace1())
         .many()
         .parse_finished(InputIter::new(line))
     {
@@ -232,7 +234,7 @@ fn read_inherit(input: &str) -> Option<Result<Vec<Eclass>, Error>> {
         .find_map(|line| line.strip_prefix("INHERIT="))?;
 
     match Eclass::parser()
-        .separated_by(whitespace1())
+        .separated_by(ascii_whitespace1())
         .many()
         .parse_finished(InputIter::new(line))
     {
@@ -245,7 +247,7 @@ fn read_iuse(input: &str) -> Option<Result<Vec<IUseFlag>, Error>> {
     let line = input.lines().find_map(|line| line.strip_prefix("IUSE="))?;
 
     match IUseFlag::parser()
-        .separated_by(whitespace1())
+        .separated_by(ascii_whitespace1())
         .many()
         .parse_finished(InputIter::new(line))
     {
@@ -260,7 +262,7 @@ fn read_license(input: &str) -> Option<Result<Vec<Depend<License>>, Error>> {
         .find_map(|line| line.strip_suffix("LICENSE="))?;
 
     match Depend::<License>::parser()
-        .separated_by(whitespace1())
+        .separated_by(ascii_whitespace1())
         .many()
         .parse_finished(InputIter::new(line))
     {
@@ -309,7 +311,7 @@ fn read_idepend(input: &str) -> Option<Result<Vec<Depend<Atom>>, Error>> {
 
 fn parse_depends(line: &str) -> Result<Vec<Depend<Atom>>, Error> {
     Depend::<Atom>::parser()
-        .separated_by(whitespace1())
+        .separated_by(ascii_whitespace1())
         .many()
         .parse_finished(InputIter::new(line))
         .map_err(|_| Error::Parser(line.to_string()))

src/useflag/mod.rs

@@ -2,12 +2,12 @@ use core::fmt;
 
 use get::Get;
 
-pub mod parsers;
+mod parsers;
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct UseFlag(#[get(method = "name", kind = "deref")] String);
 
-#[derive(Clone, Debug, PartialEq, Eq, Get)]
+#[derive(Clone, Debug, PartialEq, Eq, Hash, Get)]
 pub struct IUseFlag {
     default: bool,
     flag: UseFlag,

src/useflag/parsers.rs

@@ -1,4 +1,4 @@
-use mon::{Parser, ParserIter, alphanumeric, one_of, tag};
+use mon::{Parser, ParserIter, ascii_alphanumeric, one_of, tag};
 
 use crate::{
     Parseable,
@@ -9,8 +9,11 @@ impl<'a> Parseable<'a, &'a str> for UseFlag {
     type Parser = impl Parser<&'a str, Output = Self>;
 
     fn parser() -> Self::Parser {
-        let start = alphanumeric();
+        let start = ascii_alphanumeric();
-        let rest = alphanumeric().or(one_of("+_@-".chars())).repeated().many();
+        let rest = ascii_alphanumeric()
+            .or(one_of("+_@-".chars()))
+            .repeated()
+            .many();
 
         start
             .and(rest)

tests/meson.build

@@ -1 +1,19 @@
-subdir('fuzz')
+tests = {}
+
+subdir('porthole')
+subdir('repo')
+
+foreach test, test_args : tests
+    stem = fs.stem(test)
+
+    test(
+        f'test_@stem@',
+        executable(
+            f'test_@stem@',
+            test,
+            dependencies: [mon, itertools],
+            link_with: [gentoo_utils],
+        ),
+        args: test_args,
+    )
+endforeach

tests/porthole/meson.build

@@ -0,0 +1,5 @@
+tests += {
+    meson.current_source_dir() / 'porthole.rs': [
+        meson.current_source_dir() / 'porthole.txt',
+    ],
+}

tests/porthole/porthole.rs

@@ -1,4 +1,4 @@
-use std::cmp::Ordering;
+use std::{cmp::Ordering, env, fs};
 
 use gentoo_utils::{
     Parseable,
@@ -6,11 +6,6 @@ use gentoo_utils::{
 };
 use mon::{Parser, input::InputIter, tag};
 
-static PORTHOLE_TXT: &'static str = include_str!(concat!(
-    env!("CARGO_MANIFEST_DIR"),
-    "/testdata/porthole.txt"
-));
-
 enum Operator {
     Comment,
     Yes,
@@ -31,16 +26,21 @@ fn parse_operator<'a>() -> impl Parser<&'a str, Output = Operator> {
     comment.or(yes).or(no).or(eq).or(gt).or(lt)
 }
 
-#[test]
+fn main() {
-fn test_porthole() {
+    let path = env::args()
-    for line in PORTHOLE_TXT.lines() {
+        .nth(1)
+        .expect("pass path to porthole.txt as first parameter");
+
+    let porthole_txt = fs::read_to_string(&path).expect("failed to open porthole.txt");
+
+    for line in porthole_txt.lines() {
         if line.is_empty() {
             continue;
         }
 
         let operator = parse_operator()
             .parse_finished(InputIter::new(
-                line.split_ascii_whitespace().nth(0).unwrap(),
+                line.split_ascii_whitespace().next().unwrap(),
             ))
             .unwrap();
 

tests/repo/meson.build

@@ -0,0 +1 @@
+tests += {meson.current_source_dir() / 'repo.rs': []}

tests/repo/repo.rs

@@ -0,0 +1,17 @@
+use std::error::Error;
+
+use gentoo_utils::repo::Repo;
+
+fn main() -> Result<(), Box<dyn Error>> {
+    let repo = Repo::new("/var/db/repos/gentoo");
+
+    for result in repo.categories()? {
+        let cat = result?;
+
+        for result in cat.ebuilds()? {
+            let _ = result?;
+        }
+    }
+
+    Ok(())
+}