File Coverage

blib/lib/Eshu.pm

Criterion	Covered	Total	%
statement	131	146	89.7
branch	71	88	80.6
condition	18	24	75.0
subroutine	9	9	100.0
pod	0	2	0.0
total	229	269	85.1

package Eshu;

use 5.008003;
use strict;
use warnings;

our $VERSION = '0.01';

require XSLoader;
XSLoader::load('Eshu', $VERSION);

use File::Find ();
use File::Spec ();

my $MAX_FILE_SIZE = 1_048_576;  # 1MB

sub indent_file {
	my ($class, $path, %opts) = @_;

	my $result = {
		file   => $path,
		status => 'unchanged',
	};

	# Check file exists and is readable
	unless (-f $path && -r _) {
		$result->{status} = 'error';
		$result->{error}  = 'not a readable file';
		return $result;
	}

	# Check file size
	my $size = -s $path;
	if ($size > $MAX_FILE_SIZE) {
		$result->{status} = 'skipped';
		$result->{reason} = 'file too large';
		return $result;
	}

	# Read file
	open my $fh, '<', $path or do {
		$result->{status} = 'error';
		$result->{error}  = "cannot open: $!";
		return $result;
	};
	my $src = do { local $/; <$fh> };
	close $fh;

	# Binary detection: NUL in first 8KB
	if (length($src) > 0) {
		my $sample = substr($src, 0, 8192);
		if ($sample =~ /\0/) {
			$result->{status} = 'skipped';
			$result->{reason} = 'binary file';
			return $result;
		}
	}

	# Detect language
	my $lang = $opts{lang} || $class->detect_lang($path);
	unless (defined $lang) {
		$result->{status} = 'skipped';
		$result->{reason} = 'unrecognised extension';
		return $result;
	}

	# Build indent options
	my %indent_opts = (lang => $lang);
	for my $k (qw(indent_char indent_width indent_pp range_start range_end)) {
		$indent_opts{$k} = $opts{$k} if exists $opts{$k};
	}

	# Indent
	my $fixed = $class->indent_string($src, %indent_opts);

	if ($fixed eq $src) {
		$result->{status} = 'unchanged';
	} else {
		$result->{status} = $opts{fix} ? 'changed' : 'needs_fixing';
		if ($opts{fix}) {
			open my $out, '>', $path or do {
				$result->{status} = 'error';
				$result->{error}  = "cannot write: $!";
				return $result;
			};
			print $out $fixed;
			close $out;
		}
		$result->{diff} = _simple_diff($path, $src, $fixed) if $opts{diff};
	}
	$result->{lang} = $lang;
	return $result;
}

sub indent_dir {
	my ($class, $path, %opts) = @_;

	my $recursive = exists $opts{recursive} ? $opts{recursive} : 1;
	my $exclude   = $opts{exclude};
	my $include   = $opts{include};

	my @files;

	if (-f $path) {
		push @files, $path;
	} elsif (-d $path) {
		if ($recursive) {
			File::Find::find({
				wanted => sub {
					return unless -f $_;
					return if -l $File::Find::dir && $File::Find::dir ne $path;
					push @files, $File::Find::name;
				},
				follow_skip => 2,
				no_chdir    => 1,
			}, $path);
		} else {
			opendir my $dh, $path or die "Eshu: cannot opendir '$path': $!\n";
			while (my $entry = readdir $dh) {
				next if $entry =~ /^\./;
				my $full = File::Spec->catfile($path, $entry);
				push @files, $full if -f $full;
			}
			closedir $dh;
		}
	} else {
		die "Eshu: '$path' is not a file or directory\n";
	}

	@files = sort @files;

	my $report = {
		files_checked => 0,
		files_changed => 0,
		files_skipped => 0,
		files_errored => 0,
		changes       => [],
	};

	for my $file (@files) {
		# Apply exclude filter
		if (defined $exclude) {
			my @pats = ref $exclude eq 'ARRAY' ? @$exclude : ($exclude);
			my $skip = 0;
			for my $pat (@pats) {
				if ($file =~ $pat) { $skip = 1; last; }
			}
			if ($skip) {
				$report->{files_skipped}++;
				push @{$report->{changes}}, { file => $file, status => 'skipped', reason => 'excluded' };
				next;
			}
		}

		# Apply include filter
		if (defined $include) {
			my @pats = ref $include eq 'ARRAY' ? @$include : ($include);
			my $match = 0;
			for my $pat (@pats) {
				if ($file =~ $pat) { $match = 1; last; }
			}
			unless ($match) {
				$report->{files_skipped}++;
				push @{$report->{changes}}, { file => $file, status => 'skipped', reason => 'not included' };
				next;
			}
		}

		my $result = $class->indent_file($file, %opts);
		push @{$report->{changes}}, $result;

		if ($result->{status} eq 'changed' || $result->{status} eq 'needs_fixing') {
			$report->{files_changed}++;
			$report->{files_checked}++;
		} elsif ($result->{status} eq 'unchanged') {
			$report->{files_checked}++;
		} elsif ($result->{status} eq 'skipped') {
			$report->{files_skipped}++;
		} elsif ($result->{status} eq 'error') {
			$report->{files_errored}++;
		}
	}

	return $report;
}

sub _simple_diff {
	my ($label, $old, $new) = @_;
	my @old_lines = split /^/m, $old;
	my @new_lines = split /^/m, $new;
	my $out = "--- a/$label\n+++ b/$label\n";
	my $max = @old_lines > @new_lines ? scalar @old_lines : scalar @new_lines;
	my $hunk_start = -1;
	my (@hunk_old, @hunk_new);

	for (my $i = 0; $i <= $max; $i++) {
		my $ol = $i < @old_lines ? $old_lines[$i] : undef;
		my $nl = $i < @new_lines ? $new_lines[$i] : undef;
		my $same = defined $ol && defined $nl && $ol eq $nl;

		if (!$same && $hunk_start < 0) {
			$hunk_start = $i;
			@hunk_old = ();
			@hunk_new = ();
		}
		if ($hunk_start >= 0 && !$same) {
			push @hunk_old, $ol if defined $ol;
			push @hunk_new, $nl if defined $nl;
		}
		if ($same || $i == $max) {
			if ($hunk_start >= 0) {
				$out .= sprintf "@@ -%d,%d +%d,%d @@\n",
					$hunk_start + 1, scalar @hunk_old,
					$hunk_start + 1, scalar @hunk_new;
				for my $l (@hunk_old) {
					$l = "$l\n" unless $l =~ /\n$/;
					$out .= "-$l";
				}
				for my $l (@hunk_new) {
					$l = "$l\n" unless $l =~ /\n$/;
					$out .= "+$l";
				}
				$hunk_start = -1;
			}
		}
	}
	return $out;
}

1;

__END__