use std::path::Path;
use alint_core::{
Context, Error, FixSpec, Fixer, Level, PerFileRule, Result, Rule, RuleSpec, Scope, ScopeFilter,
Violation,
};
use serde::Deserialize;
use crate::fixers::{FileNormalizeLineEndingsFixer, LineEndingTarget};
#[derive(Debug, Deserialize)]
#[serde(deny_unknown_fields)]
struct Options {
target: TargetName,
}
#[derive(Debug, Clone, Copy, Deserialize)]
#[serde(rename_all = "lowercase")]
enum TargetName {
Lf,
Crlf,
}
impl From<TargetName> for LineEndingTarget {
fn from(t: TargetName) -> Self {
match t {
TargetName::Lf => LineEndingTarget::Lf,
TargetName::Crlf => LineEndingTarget::Crlf,
}
}
}
#[derive(Debug)]
pub struct LineEndingsRule {
id: String,
level: Level,
policy_url: Option<String>,
message: Option<String>,
scope: Scope,
scope_filter: Option<ScopeFilter>,
target: LineEndingTarget,
fixer: Option<FileNormalizeLineEndingsFixer>,
}
impl Rule for LineEndingsRule {
fn id(&self) -> &str {
&self.id
}
fn level(&self) -> Level {
self.level
}
fn policy_url(&self) -> Option<&str> {
self.policy_url.as_deref()
}
fn evaluate(&self, ctx: &Context<'_>) -> Result<Vec<Violation>> {
let mut violations = Vec::new();
for entry in ctx.index.files() {
if !self.scope.matches(&entry.path) {
continue;
}
if let Some(filter) = &self.scope_filter
&& !filter.matches(&entry.path, ctx.index)
{
continue;
}
let full = ctx.root.join(&entry.path);
let Ok(bytes) = std::fs::read(&full) else {
continue;
};
violations.extend(self.evaluate_file(ctx, &entry.path, &bytes)?);
}
Ok(violations)
}
fn fixer(&self) -> Option<&dyn Fixer> {
self.fixer.as_ref().map(|f| f as &dyn Fixer)
}
fn as_per_file(&self) -> Option<&dyn PerFileRule> {
Some(self)
}
fn scope_filter(&self) -> Option<&ScopeFilter> {
self.scope_filter.as_ref()
}
}
impl PerFileRule for LineEndingsRule {
fn path_scope(&self) -> &Scope {
&self.scope
}
fn evaluate_file(
&self,
_ctx: &Context<'_>,
path: &Path,
bytes: &[u8],
) -> Result<Vec<Violation>> {
let Some(line_no) = first_mismatched_line(bytes, self.target) else {
return Ok(Vec::new());
};
let msg = self.message.clone().unwrap_or_else(|| {
format!(
"line {line_no} does not use {} line endings",
self.target.name()
)
});
Ok(vec![
Violation::new(msg)
.with_path(std::sync::Arc::<Path>::from(path))
.with_location(line_no, 1),
])
}
}
fn first_mismatched_line(bytes: &[u8], target: LineEndingTarget) -> Option<usize> {
let mut line_no = 1usize;
let mut i = 0;
while i < bytes.len() {
if bytes[i] == b'\n' {
let prev_is_cr = i > 0 && bytes[i - 1] == b'\r';
match target {
LineEndingTarget::Lf if prev_is_cr => return Some(line_no),
LineEndingTarget::Crlf if !prev_is_cr => return Some(line_no),
_ => {}
}
line_no += 1;
}
i += 1;
}
None
}
pub fn build(spec: &RuleSpec) -> Result<Box<dyn Rule>> {
let paths = spec
.paths
.as_ref()
.ok_or_else(|| Error::rule_config(&spec.id, "line_endings requires a `paths` field"))?;
let opts: Options = spec
.deserialize_options()
.map_err(|e| Error::rule_config(&spec.id, format!("invalid options: {e}")))?;
let target: LineEndingTarget = opts.target.into();
let scope = Scope::from_paths_spec(paths)?;
let fixer = match &spec.fix {
Some(FixSpec::FileNormalizeLineEndings { .. }) => {
Some(FileNormalizeLineEndingsFixer::new(target))
}
Some(other) => {
return Err(Error::rule_config(
&spec.id,
format!(
"fix.{} is not compatible with line_endings",
other.op_name()
),
));
}
None => None,
};
Ok(Box::new(LineEndingsRule {
id: spec.id.clone(),
level: spec.level,
policy_url: spec.policy_url.clone(),
message: spec.message.clone(),
scope,
scope_filter: spec.parse_scope_filter()?,
target,
fixer,
}))
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn lf_target_accepts_pure_lf() {
assert_eq!(
first_mismatched_line(b"a\nb\nc\n", LineEndingTarget::Lf),
None
);
}
#[test]
fn lf_target_flags_first_crlf() {
assert_eq!(
first_mismatched_line(b"a\nb\r\nc\n", LineEndingTarget::Lf),
Some(2)
);
}
#[test]
fn crlf_target_accepts_pure_crlf() {
assert_eq!(
first_mismatched_line(b"a\r\nb\r\nc\r\n", LineEndingTarget::Crlf),
None
);
}
#[test]
fn crlf_target_flags_first_lf() {
assert_eq!(
first_mismatched_line(b"a\r\nb\nc\r\n", LineEndingTarget::Crlf),
Some(2)
);
}
#[test]
fn empty_file_is_ok() {
assert_eq!(first_mismatched_line(b"", LineEndingTarget::Lf), None);
}
#[test]
fn lone_cr_without_lf_is_not_a_line_ending() {
assert_eq!(first_mismatched_line(b"a\rb\n", LineEndingTarget::Lf), None);
}
}