//! Lightweight Rust source scanner shared by the lifetime scripts: blanks comments and
//! string/char literals (keeping offsets and line numbers), then finds fn signatures,
//! struct/enum definitions and impl blocks. Not a full parser: it reads the shapes that
//! lifetime rules need. Not an entry point; pulled in with `mod rsparse;`.
#![allow(dead_code)]
pub struct Src {
pub orig: String,
/// Same length as `orig`; comments and literal contents replaced by spaces.
pub code: String,
line_starts: Vec<usize>,
}
pub struct FnSig {
pub off: usize,
pub name: String,
pub generics: String,
pub params: String,
pub ret: String,
pub where_: String,
pub body: String,
pub impl_idx: Option<usize>,
}
pub struct TypeDef {
pub off: usize,
pub kind: &'static str,
pub name: String,
pub generics: String,
pub body: String,
}
pub struct ImplBlock {
pub off: usize,
pub generics: String,
/// Text between the generics and `{`, e.g. `fmt::Display for Token<'a>`.
pub header: String,
pub where_: String,
pub body: String,
span: (usize, usize),
}
impl Src {
pub fn new(orig: String) -> Src {
let code = blank(&orig);
let mut line_starts = vec![0];
line_starts.extend(orig.match_indices('\n').map(|(i, _)| i + 1));
Src { orig, code, line_starts }
}
pub fn line_of(&self, off: usize) -> usize {
self.line_starts.partition_point(|&s| s <= off)
}
/// `// noqa: LT008` (or bare `// noqa`) on the item's line silences it.
pub fn noqa(&self, line: usize, id: &str) -> bool {
let start = self.line_starts[line - 1];
let end = self.line_starts.get(line).copied().unwrap_or(self.orig.len());
match self.orig[start..end].find("// noqa") {
Some(i) => {
let rest = &self.orig[start + i + 7..end];
!rest.trim_start().starts_with(':') || rest.contains(id)
}
None => false,
}
}
}
/// Replace comments and the contents of string/char literals with spaces.
fn blank(s: &str) -> String {
let b = s.as_bytes();
let mut out = b.to_vec();
let mut i = 0;
let wipe = |out: &mut Vec<u8>, from: usize, to: usize| {
for c in &mut out[from..to.min(b.len())] {
if *c != b'\n' {
*c = b' ';
}
}
};
while i < b.len() {
match b[i] {
b'/' if b.get(i + 1) == Some(&b'/') => {
let end = s[i..].find('\n').map_or(b.len(), |n| i + n);
wipe(&mut out, i, end);
i = end;
}
b'/' if b.get(i + 1) == Some(&b'*') => {
let (mut depth, mut j) = (1, i + 2);
while j < b.len() && depth > 0 {
if b[j] == b'/' && b.get(j + 1) == Some(&b'*') { depth += 1; j += 1; }
else if b[j] == b'*' && b.get(j + 1) == Some(&b'/') { depth -= 1; j += 1; }
j += 1;
}
wipe(&mut out, i, j);
i = j;
}
b'r' if (b.get(i + 1) == Some(&b'"') || b.get(i + 1) == Some(&b'#')) && !ident_before(b, i) => {
let hashes = b[i + 1..].iter().take_while(|&&c| c == b'#').count();
if b.get(i + 1 + hashes) != Some(&b'"') { i += 1; continue; }
let close = format!("\"{}", "#".repeat(hashes));
let start = i + 2 + hashes;
let end = s[start..].find(&close).map_or(b.len(), |n| start + n);
wipe(&mut out, start, end);
i = end + close.len();
}
b'"' => {
let mut j = i + 1;
while j < b.len() && b[j] != b'"' {
j += if b[j] == b'\\' { 2 } else { 1 };
}
wipe(&mut out, i + 1, j);
i = j + 1;
}
b'\'' => {
// char literal ('x', '\n', '\u{1F600}') vs lifetime ('a): a char closes with a quote.
let len = if b.get(i + 1) == Some(&b'\\') {
s[i + 2..].find('\'').map(|n| n + 2)
} else {
s[i + 1..].chars().next().map(char::len_utf8).filter(|&w| b.get(i + 1 + w) == Some(&b'\''))
};
match len {
Some(n) => { wipe(&mut out, i + 1, i + 1 + n); i += n + 2; }
None => i += 1,
}
}
_ => i += 1,
}
}
String::from_utf8(out).unwrap_or_default()
}
fn ident_before(b: &[u8], i: usize) -> bool {
i > 0 && (b[i - 1].is_ascii_alphanumeric() || b[i - 1] == b'_')
}
fn is_ident(c: u8) -> bool {
c.is_ascii_alphanumeric() || c == b'_'
}
/// Offsets of `word` as a whole word in `s`.
pub fn word_positions(s: &str, word: &str) -> Vec<usize> {
let b = s.as_bytes();
s.match_indices(word)
.map(|(i, _)| i)
.filter(|&i| !ident_before(b, i) && !b.get(i + word.len()).is_some_and(|&c| is_ident(c)))
.collect()
}
/// Index just past the bracket that closes the one at `open` (`<`, `(`, `{`, `[`).
/// `->` is not treated as a closing angle bracket.
pub fn close_of(s: &str, open: usize) -> usize {
let b = s.as_bytes();
let (o, c) = match b[open] { b'<' => (b'<', b'>'), b'(' => (b'(', b')'), b'[' => (b'[', b']'), _ => (b'{', b'}') };
let mut depth = 0i32;
for (j, &ch) in b.iter().enumerate().skip(open) {
if ch == o {
depth += 1;
} else if ch == c && !(c == b'>' && j > 0 && b[j - 1] == b'-') {
depth -= 1;
if depth == 0 {
return j + 1;
}
}
}
b.len()
}
fn skip_ws(s: &str, mut i: usize) -> usize {
let b = s.as_bytes();
while i < b.len() && b[i].is_ascii_whitespace() { i += 1; }
i
}
fn ident_at(s: &str, i: usize) -> (String, usize) {
let b = s.as_bytes();
let end = (i..b.len()).find(|&j| !is_ident(b[j])).unwrap_or(b.len());
(s[i..end].to_string(), end)
}
/// Optional `<...>` at `i`: (contents, index after it).
fn generics_at(s: &str, i: usize) -> (String, usize) {
if s.as_bytes().get(i) == Some(&b'<') {
let end = close_of(s, i);
(s[i + 1..end - 1].to_string(), end)
} else {
(String::new(), i)
}
}
/// Position of the first top-level `{` or `;` at or after `i` (and of `where`, if any, before it).
fn header_end(s: &str, i: usize) -> (usize, Option<usize>) {
let b = s.as_bytes();
let mut depth = 0i32;
let mut where_at = None;
let mut j = i;
while j < b.len() {
match b[j] {
b'(' | b'[' | b'<' => depth += 1,
b')' | b']' => depth -= 1,
b'>' if j == 0 || b[j - 1] != b'-' => depth -= 1,
b'{' | b';' if depth <= 0 => return (j, where_at),
b'w' if depth <= 0 && where_at.is_none() && s[j..].starts_with("where") && !ident_before(b, j)
&& !b.get(j + 5).is_some_and(|&c| is_ident(c)) => where_at = Some(j),
_ => {}
}
j += 1;
}
(b.len(), where_at)
}
/// Is `impl` at `i` an item (`impl<T> X for Y {`) rather than `impl Trait` in a type?
fn item_position(code: &str, i: usize) -> bool {
let before = code[..i].trim_end();
before.is_empty()
|| before.ends_with(['}', ';', '{', ']'])
|| before.ends_with("unsafe")
|| before.ends_with("default")
}
pub fn items(src: &Src) -> (Vec<FnSig>, Vec<TypeDef>, Vec<ImplBlock>) {
let code = &src.code;
let mut impls = Vec::new();
for i in word_positions(code, "impl") {
if !item_position(code, i) { continue; }
let (generics, after) = generics_at(code, skip_ws(code, i + 4));
let (end, where_at) = header_end(code, after);
if code.as_bytes().get(end) != Some(&b'{') { continue; }
let close = close_of(code, end);
impls.push(ImplBlock {
off: i,
generics,
header: code[after..where_at.unwrap_or(end)].trim().to_string(),
where_: where_at.map_or(String::new(), |w| code[w + 5..end].trim().to_string()),
body: code[end + 1..close - 1].to_string(),
span: (end, close),
});
}
let mut fns = Vec::new();
for i in word_positions(code, "fn") {
let name_at = skip_ws(code, i + 2);
let (name, after_name) = ident_at(code, name_at);
if name.is_empty() { continue; } // `fn(` pointer type
let (generics, after) = generics_at(code, skip_ws(code, after_name));
let p = skip_ws(code, after);
if code.as_bytes().get(p) != Some(&b'(') { continue; }
let pend = close_of(code, p);
let (end, where_at) = header_end(code, pend);
let sig_end = where_at.unwrap_or(end);
let between = code[pend..sig_end].trim();
let ret = between.strip_prefix("->").map_or(String::new(), |r| r.trim().to_string());
let body = if code.as_bytes().get(end) == Some(&b'{') {
code[end + 1..close_of(code, end) - 1].to_string()
} else {
String::new()
};
fns.push(FnSig {
off: i,
name,
generics,
params: code[p + 1..pend - 1].to_string(),
ret,
where_: where_at.map_or(String::new(), |w| code[w + 5..end].trim().to_string()),
body,
impl_idx: impls.iter().position(|b: &ImplBlock| b.span.0 < i && i < b.span.1),
});
}
let mut types = Vec::new();
for kind in ["struct", "enum", "union"] {
for i in word_positions(code, kind) {
let (name, after_name) = ident_at(code, skip_ws(code, i + kind.len()));
if name.is_empty() { continue; }
let (generics, after) = generics_at(code, skip_ws(code, after_name));
let j = skip_ws(code, after);
let body = match code.as_bytes().get(j) {
Some(b'(') => code[j + 1..close_of(code, j) - 1].to_string(),
_ => {
let (end, _) = header_end(code, j);
if code.as_bytes().get(end) == Some(&b'{') { code[end + 1..close_of(code, end) - 1].to_string() } else { String::new() }
}
};
let kind = match kind { "struct" => "struct", "enum" => "enum", _ => "union" };
types.push(TypeDef { off: i, kind, name, generics, body });
}
}
types.sort_by_key(|t| t.off);
(fns, types, impls)
}
/// Split at top-level commas (ignoring commas nested in <>, (), [], {}).
pub fn split_top(s: &str) -> Vec<String> {
let b = s.as_bytes();
let (mut depth, mut start, mut out) = (0i32, 0, Vec::new());
for (j, &c) in b.iter().enumerate() {
match c {
b'<' | b'(' | b'[' | b'{' => depth += 1,
b')' | b']' | b'}' => depth -= 1,
b'>' if j == 0 || b[j - 1] != b'-' => depth -= 1,
b',' if depth == 0 => { out.push(s[start..j].trim().to_string()); start = j + 1; }
_ => {}
}
}
let last = s[start..].trim();
if !last.is_empty() { out.push(last.to_string()); }
out
}
/// Every lifetime token (`'a`, `'_`, `'static`) in `s`, in order.
pub fn lifetimes_in(s: &str) -> Vec<String> {
let b = s.as_bytes();
let mut out = Vec::new();
for (i, _) in s.match_indices('\'') {
let (name, _) = ident_at(s, i + 1);
if !name.is_empty() && !ident_before(b, i) {
out.push(format!("'{name}"));
}
}
out
}
/// Lifetime parameters declared in a generics list: `'a, 'b: 'a, T` -> ["'a", "'b"].
pub fn declared_lifetimes(generics: &str) -> Vec<String> {
split_top(generics)
.iter()
.filter(|p| p.starts_with('\''))
.map(|p| p.split(':').next().unwrap_or("").trim().to_string())
.collect()
}
pub fn count_lifetime(s: &str, lt: &str) -> usize {
lifetimes_in(s).iter().filter(|l| *l == lt).count()
}
/// Blank out closure-trait sugar `Fn(..) -> T` / `fn(..) -> T`, whose references are
/// higher-ranked and never need a named lifetime. Keeps offsets.
pub fn strip_fn_sugar(s: &str) -> String {
let mut out = s.to_string();
for kw in ["FnOnce", "FnMut", "Fn", "fn"] {
for i in word_positions(&out.clone(), kw) {
let p = skip_ws(&out, i + kw.len());
if out.as_bytes().get(p) != Some(&b'(') { continue; }
let mut end = close_of(&out, p);
let rest = &out[end..];
if rest.trim_start().starts_with("->") {
// the return type runs to the next top-level `,`, `+`, `>` or `)`
let r = end + rest.find("->").unwrap() + 2;
let b = out.as_bytes();
let mut depth = 0i32;
end = b.len();
for (j, &c) in b.iter().enumerate().skip(r) {
match c {
b'<' | b'(' | b'[' => depth += 1,
b'>' | b')' | b']' | b',' | b'+' if depth == 0 => { end = j; break; }
b'>' | b')' | b']' => depth -= 1,
_ => {}
}
}
}
let blanked: String = out[p..end].bytes().map(|c| if c == b'\n' { '\n' } else { ' ' }).collect();
out.replace_range(p..end, &blanked);
}
}
out
}
/// Number of `&` references without a written lifetime (`&T`, `&mut T`, but not `&'a T`).
pub fn elided_refs(s: &str) -> usize {
let b = s.as_bytes();
(0..b.len())
.filter(|&i| b[i] == b'&' && b.get(i + 1) != Some(&b'&') && (i == 0 || b[i - 1] != b'&'))
.filter(|&i| b.get(skip_ws(s, i + 1)) != Some(&b'\''))
.count()
}
/// Collapse whitespace runs for one-line display.
pub fn one_line(s: &str) -> String {
s.split_whitespace().collect::<Vec<_>>().join(" ")
}
rust-borrow-checker-error-explainer
Explain and fix Rust borrow-checker, ownership, move and lifetime compiler errors: E0382 use of moved value, E0499 cannot borrow as mutable more than once, E0502 also borrowed as immutable, E0505, E0506, E0503, E0507 cannot move out of index/Rc/reference, E0515 return reference to local, E0597 does not live long enough, E0716 temporary value dropped while borrowed, E0373 closure may outlive (spawn needs move), E0521 borrowed data escapes, E0384, E0596, E0594, E0381, E0713, 'lifetime may not live long enough', RefCell 'already borrowed: BorrowMutError' panics. Ranks fixes from restructuring (split borrows, entry API, split_at_mut, get_disjoint_mut, mem::take, Option::take, indices, thread::scope) down to clone and Rc<RefCell>/Arc<Mutex>; never unsafe. Covers NLL limits (get-or-insert), iterator invalidation, closure captures, self-referential structs. Ships std-only Rust triage tools.
rust-cargo-workspace-designer
Design, review and fix Cargo workspaces: when to split a crate (compile time, boundaries, publishing, proc-macros), crates/* vs apps/ + crates/ layouts, virtual manifest vs root package, members/exclude/default-members, resolver 2 vs 3 (MSRV-aware, edition 2024), [workspace.package] and [workspace.dependencies] inheritance, [workspace.lints], root-only profiles (lto, codegen-units), additive features with dep: and weak ?/ syntax, feature unification pitfalls, internal path + version deps, publish = false, Cargo.lock and MSRV policy, xtask, CI with --locked, nextest, rust-cache, sccache, cargo-hack/deny/machete/udeps/semver-checks, and cargo build --timings. Ships a workspace auditor and crate-graph tool.
rust-error-handling-thiserror-anyhow-designer
Design and review Rust error handling with thiserror 2 and anyhow 1: library vs application split, typed error enums with #[from], #[source], #[error(transparent)] and #[non_exhaustive], ErrorKind patterns, context via .context()/.with_context(), bail!/ensure!, source() chains, {:#} and {:?} reports, RUST_BACKTRACE/RUST_LIB_BACKTRACE, Box<dyn Error + Send + Sync>, main -> anyhow::Result or ExitCode, unwrap/expect/panic policy, Option to Result, collecting iterators of Results, axum IntoResponse mapping, retryable errors, tracing, async Send bounds, testing with matches! and downcast_ref, no_std core::error::Error, and snafu, eyre/color-eyre, miette, error-stack.
rust-tokio-async-service-builder
Build and review production async Rust services on Tokio 1.x and axum 0.8: runtime choice (#[tokio::main] multi_thread vs current_thread, Builder), axum routing with /{id} paths, State, extractors, IntoResponse error types, axum::serve with_graceful_shutdown, tower/tower-http middleware (TraceLayer, TimeoutLayer, CorsLayer, ConcurrencyLimitLayer, RequestBodyLimitLayer), Arc<AppState>, std vs tokio Mutex, JoinSet, TaskTracker, CancellationToken, select! cancel safety, bounded mpsc, oneshot, broadcast, watch, actors, Semaphore, timeouts, retries, spawn_blocking, sqlx PgPool, reqwest Client reuse, tracing, tests with start_paused and oneshot, Dockerfile. Fixes 'future cannot be sent between threads safely', E0373, Rc or MutexGuard held across await, 'Cannot start a runtime from within a runtime', 'Path segments must not start with :'. Ships std-only Rust scanners and a compiling axum 0.8 scaffold.
rust-trait-design-reviewer
Review and design Rust traits and generic APIs: generics vs impl Trait vs dyn Trait (static vs dynamic dispatch), dyn compatibility / object safety (generic methods, Self returns, where Self: Sized, error[E0038] not dyn compatible / cannot be made into an object), associated types vs generic parameters, blanket impls, coherence and orphan rule (E0117, E0119, E0210), newtype, extension, sealed and marker traits, supertraits and trait upcasting (1.86), async fn in traits (1.75) and the Send bound problem (trait_variant, async-trait), RPITIT, GATs, From/Into/TryFrom/AsRef/Borrow, std trait checklist (Debug, Clone, PartialEq, Hash, Default, Display, Error, Send/Sync, serde feature), #[must_use], #[non_exhaustive], semver hazards, Deref abuse, builders, typestate, PhantomData, Box<dyn Error + Send + Sync>, Fn traits, mockall.
rust-unsafe-block-auditor
Audit unsafe Rust for soundness: inventory every unsafe block, unsafe fn, unsafe impl/trait, extern block and unsafe attribute, check // SAFETY: comments and # Safety docs, and classify each as sound, needs-justification or likely UB, proposing safe alternatives first. Covers the five unsafe superpowers, aliasing (Stacked/Tree Borrows), invalid values, MaybeUninit vs mem::zeroed/uninitialized, transmute, slice::from_raw_parts, Vec::set_len/from_raw_parts, get_unchecked, CString::as_ptr dangling, unsafe impl Send/Sync, Pin projection, FFI (extern "C", repr(C), C-unwind, Box::into_raw/from_raw), strict provenance, static mut and &raw, edition 2024 (unsafe extern, #[unsafe(no_mangle)], unsafe_op_in_unsafe_fn, env::set_var), Miri, sanitizers, cargo-fuzz, loom, cargo-geiger and clippy safety lints.