39958913551

Committed 23 Oct 2026 12:44PM UTC coverage: 96.921% (-0.9%) from 97.773%

Build Type

push

github

Committed by

Commit Message

uses the Runner of nette/command-line WIP

Coverage Stats

8 of 8 new or added lines in 1 file covered. (100.0%)

278 existing lines in 25 files now uncovered.

24711 of 25496 relevant lines covered (96.92%)

0.97 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

97.56

/src/Engine/PassLoop.php

<?php declare(strict_types=1);

/**
 * This file is part of the DressCode, a coding style and upgrade tool for PHP (https://dresscode.run)
 * Copyright (c) 2026 David Grudl (https://davidgrudl.com)
 */

namespace DressCode\Engine;

use DressCode\{
        Analyses, ConfigurationException, ConvergenceException, NodeRule, Rule,
        RuleContext, RuleException, RuleInfo, Severity, Stage, Style, Violation,
};
use DressCode\Engine\Gaps\{Fixer, Resolver};
use PhpSyntax\{Node, Printer, Token, Traverser, Trivia};
use PhpSyntax\Nodes\FileNode;
use function count, strlen;


/**
 * Runs the rules over a file in passes until nothing mutates: each pass is one pre-order traversal per stage,
 * rules are dispatched by the type of the node or token, every mutation is paired with a report.
 * @internal
 */
final class PassLoop
{
        private const MaxPasses = 10;

        /**
         * @var array<string, array<class-string, list<array{NodeRule, RuleContext, class-string<NodeRule>}>>>  stage => node class =>
         * rules entering it, with their contexts and names
         */
        private array $entering = [];

        /** @var array<string, array<class-string, list<array{NodeRule, RuleContext, class-string<NodeRule>}>>>  the same for `leave()` */
        private array $leaving = [];

        /** @var array<class-string<Rule>, RuleContext> */
        private array $contexts = [];

        /** the gap rules, applied together along the traversal of the formatting stage */
        private readonly Resolver $gaps;

        /** @var array<class-string<Rule>, true>  rules that mutated the file in the current pass */
        private array $mutatedRules = [];

        /** @var array<string, Violation>  by fingerprint, so that a pass repeating a report adds nothing */
        private array $violations = [];

        /**
         * @var \WeakMap<Token, string>  a token whose line the fixer opened or closed => the fingerprint of the violation
         * it did it for, the first of its chain
         */
        private \WeakMap $opened;

        /** @var \WeakMap<Token, string>  a token whose line a rule moved => the fingerprint of the violation the move follows from */
        private \WeakMap $moved;

        /** @var list<array{string, Report, Severity}>  the reports of violations of the current pass: the rule, the report, its severity */
        private array $reported = [];

        /** @var list<string> */
        private array $warnings = [];

        private Fingerprints $fingerprints;

        /** @var list<int>  byte offset of the start of each line of the original code */
        private array $lineOffsets = [];
        private string $code = '';

        private FileNode $file;
        private string $path = '';


        public function __construct(
                private readonly RulePlan $plan,
                private readonly Analyses\Registry $analyses,
                private readonly ReportPolicy $policy = new ReportPolicy,
                private readonly ?Profiler $profiler = null,
        ) {
                $this->gaps = new Resolver($plan->claims);
        }


        /**
         * @param  array<string, true>  $acceptedRisks  fingerprints of the occurrences whose fix that may change what the code does is allowed
         * @throws RuleException|ConvergenceException|ConfigurationException
         */
        public function run(FileNode $file, string $code, string $path, Style $style, string $phpVersion, array $acceptedRisks = []): PassResult
        {
                $this->file = $file;
                $this->path = $path;
                $this->code = $code;
                $split = (array) preg_split('~\r\n|\r|\n~', $code, -1, PREG_SPLIT_OFFSET_CAPTURE);
                $lines = array_column($split, 0);
                $this->lineOffsets = array_column($split, 1);
                $this->violations = $this->warnings = $this->contexts = $this->entering = $this->leaving = [];
                $this->opened = new \WeakMap;
                $this->moved = new \WeakMap;
                $this->fingerprints = new Fingerprints($lines, $path, $this->policy->baseline);
                $suppression = Suppression::fromFile($file, $this->policy->expandName, $code, $this->policy->suppressionComments);
                foreach ($suppression->getUnknownNames() as $name => $comment) {
                        $this->warnings[] = 'Comment '
                                . Violation::formatCode($comment)
                                . " names `$name`, which is no decision, section or rule, so it silences nothing.";
                }

                $spans = new Spans($code);
                foreach ($this->plan->rules as $rule) {
                        $ruleClass = $rule::class;
                        $this->contexts[$ruleClass] = new RuleContext(
                                $file,
                                $path,
                                $style,
                                $phpVersion,
                                $this->analyses,
                                $suppression,
                                $this->fingerprints,
                                $acceptedRisks,
                                $this->policy,
                                $this->plan->gates[$ruleClass],
                                RuleInfo::fromRule($rule),
                                $spans,
                        );
                }

                $seen = [hash('xxh3', $code) => true];
                $last = $code;
                $passes = 0;
                $mutated = false;
                $mutatedRules = [];
                while (true) {
                        if ($passes++ === self::MaxPasses) {
                                throw new ConvergenceException($path, array_keys($this->mutatedRules), '');
                        }

                        $this->mutatedRules = $this->reported = [];
                        $this->fingerprints->beginPass();
                        foreach ($this->contexts as $context) {
                                $context->passStorage = [];
                        }

                        $start = $this->profiler ? hrtime(as_number: true) : 0;
                        $this->analyses->beginPass($file);
                        $this->profiler?->addPhase('analyses: begin pass', hrtime(as_number: true) - $start);
                        $revision = $file->revision;
                        foreach ($this->plan->stages as $stage => $rules) {
                                $this->runStage($stage, $rules, $style);
                        }

                        $failure = $this->analyses->findCreated($file, Analyses\Types::class)?->failure;
                        if ($failure !== null) {
                                $warning = "PHPStan fails on the file, so the rules asking for its types see none where it stopped: $failure";
                                $this->warnings = array_values(array_unique([...$this->warnings, $warning]));
                        }

                        if ($file->revision === $revision) {
                                $this->checkUnfixed();
                                break;
                        }

                        $mutated = true;
                        $mutatedRules += $this->mutatedRules;
                        $start = $this->profiler ? hrtime(as_number: true) : 0;
                        $output = Printer::print($file);
                        $this->profiler?->addPhase('print', hrtime(as_number: true) - $start);
                        $hash = hash('xxh3', $output);
                        if (isset($seen[$hash])) { // a state seen before: the rules cycle
                                throw new ConvergenceException($path, array_keys($this->mutatedRules), Diff::unified($last, $output, $path));
                        }

                        $seen[$hash] = true;
                        $last = $output;
                }

                $this->analyses->endFile($file);
                return new PassResult(
                        self::sortByPosition(array_values($this->violations)),
                        $this->warnings,
                        $passes,
                        $mutated,
                        $this->fingerprints->getBaselined(),
                        array_keys($mutatedRules),
                        // what the baseline holds is decided by the lines of the fixed text, which only another run has
                        remaining: $mutated && $this->policy->baseline === null ? $this->collectRemaining($last) : null,
                        output: $mutated ? $last : null,
                        removedImports: array_merge(
                                ...array_values(array_map(fn(RuleContext $context) => $context->takeRemovedImports(), $this->contexts)),
                        ),
                );
        }


        /**
         * The violations of the fixed text: what the last pass, which changed nothing, reported, identified by the lines
         * of that text as a run over it would identify them.
         * @return list<Violation>
         */
        private function collectRemaining(string $text): array
        {
                $fingerprints = new Fingerprints(preg_split('~\r\n|\r|\n~', $text) ?: [], $this->path);
                /** @var \WeakMap<Token, string> $opened */
                $opened = new \WeakMap;
                /** @var \WeakMap<Token, string> $moved */
                $moved = new \WeakMap;
                $violations = [];
                $spans = new Spans;
                foreach ($this->reported as [, $report, $severity]) {
                        $token = $report->at->getFirstToken();
                        $line = self::findCurrentLine($token, $report->trivia) + $report->lineInTrivia;
                        $fingerprint = $report->construct === null
                                ? $fingerprints->create($report->decision, $report->message, $line)
                                : $fingerprints->createFor($report->construct, $report->decision, $report->message, $line);
                        $violation = self::createViolation(
                                $report,
                                $fingerprint,
                                $line,
                                $token?->getCurrentColumn(),
                                $spans->find($report->at, $report->trivia, $report->lineInTrivia, $report->gap, $report->follows),
                                $this->findOriginalLines($report),
                                $severity,
                                $opened,
                                $moved,
                        );
                        $violations[$fingerprint] ??= $violation;
                }

                return self::sortByPosition(array_values($violations));
        }


        /**
         * The violation of the report, derived from what opened, closed or moved its line, and the line its fix opens
         * or closes marked for what follows.
         * @param ?array{int, int} $span  the offset and the length of what was reported
         * @param array{int, int} $originalLines  the first and the last line of what was reported in the original file
         * @param \WeakMap<Token, string> $opened
         * @param \WeakMap<Token, string> $moved
         */
        private static function createViolation(
                Report $report,
                string $fingerprint,
                int $line,
                ?int $column,
                ?array $span,
                array $originalLines,
                Severity $severity,
                \WeakMap $opened,
                \WeakMap $moved,
        ): Violation
        {
                $derivedFrom = self::findAncestor($report, $opened, $moved);
                self::markLine($report, $derivedFrom ?? $fingerprint, $opened, $moved);
                return new Violation(
                        $report->decision,
                        $report->message,
                        $line,
                        $report->trivia === null ? $column : null,
                        $severity,
                        fingerprint: $fingerprint,
                        fixable: $report->fixable,
                        risk: $report->risk,
                        refused: $report->refused,
                        because: $report->because,
                        derivedFrom: $derivedFrom === $fingerprint ? null : $derivedFrom,
                        offset: $span[0] ?? null,
                        length: $span[1] ?? null,
                        originalLines: $originalLines,
                );
        }


        /**
         * The line of the token or of its trivia in the current text; the trivia is counted back from the token, whose
         * line the index follows.
         */
        private static function findCurrentLine(?Token $token, ?Trivia $trivia): int
        {
                $line = $token?->getCurrentLine() ?? 1;
                if ($token === null || $trivia === null) {
                        return $line;
                }

                $leading = array_search($trivia, $token->leadingTrivia, strict: true);
                if ($leading !== false) {
                        foreach (array_slice($token->leadingTrivia, $leading) as $item) {
                                $line -= substr_count($item->text, "\n");
                        }

                        return $line;
                }

                $line += substr_count($token->text, "\n");
                foreach ($token->trailingTrivia as $item) {
                        if ($item === $trivia) {
                                break;
                        }

                        $line += substr_count($item->text, "\n");
                }

                return $line;
        }


        /**
         * The passes report by rule, the reader reads by position.
         * @param list<Violation> $violations
         * @return list<Violation>
         */
        private static function sortByPosition(array $violations): array
        {
                usort($violations, fn(Violation $a, Violation $b) => [$a->line, $a->column ?? 0] <=> [$b->line, $b->column ?? 0]);
                return $violations;
        }


        /** @param list<NodeRule> $rules */
        private function runStage(string $stage, array $rules, Style $style): void
        {
                // the gap rules ride along the traversal of the formatting stage and report under their decisions;
                // a rule is accounted for when it reported, the revision before the traversal standing for the whole of it
                $gaps = $stage === Stage::Formatting->name && !$this->plan->claims->isEmpty() ? $this->gaps : null;
                if ($rules === [] && $gaps === null) {
                        return;
                }

                foreach ($rules as $rule) {
                        $this->invoke($rule, fn(RuleContext $context) => $rule->beforePass($context));
                }

                // every gap holds the closure, which therefore must not hold the loop: through it a gap would reach and keep in
                // cycles everything the pass made
                [$analyses, $file, $path, $strict] = [$this->analyses, $this->file, $this->path, $this->policy->strict];
                $gaps?->beginPass(
                        $style,
                        new Fixer($this->contexts, stripos($this->code, '__LINE__') !== false),
                        static function (string $class, Rule $rule) use ($analyses, $file, $path, $strict): ?object {
                                if ($strict) {
                                        try {
                                                RuleInfo::fromRule($rule)->checkAnalysis($class);
                                        } catch (\LogicException $e) {
                                                throw new RuleException($rule::class, $path, $e);
                                        }
                                }

                                return $analyses->find($file, $class, $path);
                        },
                );
                $before = $this->file->revision;
                $enter = function (Node|Token $node) use ($stage, $gaps): void {
                        if (($this->entering[$stage][$node::class] ?? null) !== []) {
                                $this->visit($stage, $node, enter: true);
                        }

                        // a node a rule has just taken out of the tree has no gaps to decide
                        if ($gaps === null || ($node->parent === null && !$node instanceof FileNode)) {
                                return;
                        }

                        $start = $this->profiler ? hrtime(as_number: true) : 0;
                        try {
                                $node instanceof Token ? $gaps->enterToken($node) : $gaps->enterNode($node);
                                $this->profiler?->addPhase('gaps', hrtime(as_number: true) - $start);
                        } catch (ConfigurationException|RuleException $e) { // two claims deciding one gap, or a claim of the rule named failing
                                throw $e;
                        } catch (\Throwable $e) {
                                throw new RuleException(null, $this->path, $e);
                        }
                };
                // the traverser leaves every node it entered, a replaced one included; a rule sees only what is still in the tree
                $leave = fn(Node|Token $node) => ($this->leaving[$stage][$node::class] ?? null) === []
                        || ($node->parent === null && $node !== $this->file)
                        ? null
                        : $this->visit($stage, $node, enter: false);
                Traverser::traverse($this->file, $enter, $this->plan->leaves[$stage] ? $leave : null);

                if ($gaps !== null) {
                        foreach ($this->contexts as $ruleClass => $context) {
                                if ($context->hasReports()) {
                                        // the whitespace of a gap is written by the engine, always after a report of its own, so a mutation
                                        // without a report or after a denied one belongs to another rule of the same traversal
                                        $this->account($ruleClass, $context, $before, checkRevisions: false);
                                }
                        }
                }

                foreach ($rules as $rule) {
                        $this->invoke($rule, fn(RuleContext $context) => $rule->afterPass($context));
                }
        }


        private function visit(string $stage, Node|Token $node, bool $enter): void
        {
                $class = $node::class;
                $rules = ($enter ? $this->entering : $this->leaving)[$stage][$class] ?? $this->resolveRules($stage, $node, $enter);
                if ($rules === []) {
                        return;
                }

                $parent = $node->parent;
                $file = $this->file;
                $profiler = $this->profiler;
                foreach ($rules as [$rule, $context, $ruleClass]) {
                        $before = $file->revision;
                        $start = $profiler ? hrtime(as_number: true) : 0;
                        try {
                                $enter ? $rule->enter($node, $context) : $rule->leave($node, $context);
                        } catch (\Throwable $e) {
                                throw new RuleException($ruleClass, $this->path, $e);
                        }

                        $profiler?->addRule($ruleClass, hrtime(as_number: true) - $start, $file->revision !== $before);
                        if ($file->revision !== $before || $context->hasReports()) {
                                $this->account($ruleClass, $context, $before);
                        }

                        if ($node->parent !== $parent) { // replaced or removed: the rest of the chain never sees it
                                return;
                        }
                }
        }


        /**
         * The rules the plan dispatches the class of the node to, with their contexts in this file.
         * @return list<array{NodeRule, RuleContext, class-string<NodeRule>}>
         */
        private function resolveRules(string $stage, Node|Token $node, bool $enter): array
        {
                $rules = [];
                foreach ($this->plan->getRulesVisiting($stage, $node::class, $enter) as $rule) {
                        $ruleClass = $rule::class;
                        $rules[] = [$rule, $this->contexts[$ruleClass], $ruleClass];
                }

                if ($enter) {
                        $this->entering[$stage][$node::class] = $rules;
                } else {
                        $this->leaving[$stage][$node::class] = $rules;
                }

                return $rules;
        }


        /**
         * Calls a per-file callback of a rule and accounts for what it did.
         * @param \Closure(RuleContext): void $callback
         */
        private function invoke(NodeRule $rule, \Closure $callback): void
        {
                $ruleClass = $rule::class;
                $context = $this->contexts[$ruleClass];
                $before = $this->file->revision;
                $start = $this->profiler ? hrtime(as_number: true) : 0;
                try {
                        $callback($context);
                } catch (\Throwable $e) {
                        throw new RuleException($ruleClass, $this->path, $e);
                }

                $this->profiler?->addRule($ruleClass, hrtime(as_number: true) - $start, $this->file->revision !== $before);
                $this->account($ruleClass, $context, $before);
        }


        /**
         * Turns the reports of a callback into violations and checks that every mutation follows a report that returned
         * true; what the rule wrote after a denied report, up to its next one, it wrote for that report. After the last
         * report the rule may be fixing any of those it was allowed earlier, so that one is judged only where none was. A
         * report the baseline holds is not denied, only not recorded.
         * @param class-string<Rule> $ruleClass
         * @param int $before  the revision of the file before the callback
         * @param bool $checkRevisions  whether the revisions are the rule's doing, which along the gap traversal they need
         *                              not be, because they then cover every rule
         */
        private function account(string $ruleClass, RuleContext $context, int $before, bool $checkRevisions = true): void
        {
                $after = $this->file->revision;
                $reported = $allowed = false;
                $reports = $context->takeReports();
                foreach ($reports as $i => $report) {
                        $fingerprint = $report->fingerprint;
                        $denied = !$report->fixable || $report->silenced || $report->refused || $report->left;
                        $end = $reports[$i + 1]->revision ?? ($allowed ? null : $after);
                        if ($checkRevisions && $denied && $end !== null && $end > $report->revision) {
                                $this->violateContract($ruleClass, $report->fixable
                                        ? 'it changed the file although `report()` returned `false`'
                                        : 'it changed the file after a report with `fixable: false`');
                        }

                        $allowed = $allowed || !$denied;

                        if (!str_ends_with($report->message, '.')) {
                                $this->violateContract(
                                        $ruleClass,
                                        'it reported a message not ending with a period, ' . Violation::formatCode($report->message),
                                );
                        }

                        if ($report->silenced || $fingerprint === null) { // and then there is no violation to record
                                continue;
                        }

                        $reported = true;
                        $severity = isset($this->policy->warningDecisions[$report->decision]) || ($report->refused && $report->risk?->isResolvable())
                                ? Severity::Warning
                                : Severity::Error;
                        $this->reported[] = [$ruleClass, $report, $severity];
                        $violation = self::createViolation(
                                $report,
                                $fingerprint,
                                $report->line,
                                $this->findOriginalColumn($report->at),
                                $report->span,
                                $this->findOriginalLines($report),
                                $severity,
                                $this->opened,
                                $this->moved,
                        );
                        if (!$report->baselined) { // what the baseline holds is not recorded, though the rule may have fixed it
                                $this->violations[$fingerprint] ??= $violation;
                        }
                }

                // the lines of code a fix wrote anew are placed by it, as the lines of a gap the fixer broke are
                foreach ($context->takeRewritten() as [$fingerprint, $node]) {
                        $origin = $this->violations[$fingerprint]->derivedFrom ?? $fingerprint;
                        foreach ($node->getTokens() as $i => $token) {
                                if ($i === 0 || $token->startsLine()) {
                                        $this->moved[$token] ??= $origin;
                                }
                        }
                }

                if ($after > $before) {
                        $this->mutatedRules[$ruleClass] = true;
                        if (!$reported && $checkRevisions) {
                                $this->violateContract($ruleClass, 'it changed the file without reporting a violation');
                        }
                }
        }


        /**
         * The violation the report follows from: the one the fixer opened or closed the line of the reported gap
         * for, else the one that opened, closed or moved the line the reported whitespace is counted from. A report
         * about the shape of the line it stands on asks who opened or closed that line, and nothing about whitespace.
         * @param \WeakMap<Token, string> $opened
         * @param \WeakMap<Token, string> $moved
         */
        private static function findAncestor(Report $report, \WeakMap $opened, \WeakMap $moved): ?string
        {
                if ($report->byLine) {
                        $token = $report->at->getFirstToken();
                        return $token === null ? null : $opened[$token] ?? null;
                }

                if ($report->gap !== null && isset($opened[$report->gap])) {
                        return $opened[$report->gap];
                }

                $follows = $report->follows;
                return $follows === null ? null : $opened[$follows] ?? $moved[$follows] ?? null;
        }


        /**
         * What is placed by the line of the reported gap follows from what opened, closed or moved it, the first of the chain.
         * @param \WeakMap<Token, string> $opened
         * @param \WeakMap<Token, string> $moved
         */
        private static function markLine(Report $report, string $origin, \WeakMap $opened, \WeakMap $moved): void
        {
                if ($report->gap === null || $report->refused || $report->left) {
                        return;
                } elseif ($report->breaks) {
                        $opened[$report->gap] ??= $origin;
                } elseif ($report->follows !== null) {
                        $moved[$report->gap] ??= $origin;
                }
        }


        /**
         * A pass that changed nothing left every occurrence it reported as it was, so the rule had no fix for one it did not
         * report with `fixable: false`, refused as risky, or left as the file writes it.
         */
        private function checkUnfixed(): void
        {
                $rules = [];
                foreach ($this->reported as [$ruleClass, $report]) {
                        if ($report->fixable && !$report->refused && !$report->left && $report->gap === null) { // a gap is the engine's to fix, and a comment may keep it from that
                                $rules[$ruleClass] = true;
                        }
                }

                foreach (array_keys($rules) as $ruleClass) {
                        $this->violateContract($ruleClass, 'it reported an occurrence it then left unfixed without saying `fixable: false`');
                }
        }


        /** @param  string  $breach  what the rule did, as a clause */
        private function violateContract(string $ruleClass, string $breach): void
        {
                if ($this->policy->strict) {
                        throw new RuleException($ruleClass, $this->path, new \LogicException(ucfirst($breach) . '.'));
                }

                $this->warnings[] = "Rule `$ruleClass` is faulty: $breach.";
        }


        /**
         * Column in characters of the token in the original file, from its original offset and the start of its line.
         */
        private function findOriginalColumn(Node|Token $at): ?int
        {
                $token = $at->getFirstToken();
                if ($token === null || $token->pos < 0 || $token->line < 0) {
                        return null;
                }

                $lineStart = $this->lineOffsets[$token->line - 1] ?? 0;
                $before = substr($this->code, $lineStart, $token->pos - $lineStart);
                return strlen($before) - preg_match_all('~[\x80-\xBF]~', $before) + 1;
        }


        /**
         * The first and the last line of the original file the span of the report covers, or the line of the report where
         * it has no span.
         * @return array{int, int}
         */
        private function findOriginalLines(Report $report): array
        {
                if ($report->span === null) {
                        return [$report->line, $report->line];
                }

                [$offset, $length] = $report->span;
                return [$this->findOriginalLineAt($offset), $this->findOriginalLineAt($offset + max($length - 1, 0))];
        }


        /** The line of the original file the byte offset stands on, from 1. */
        private function findOriginalLineAt(int $offset): int
        {
                [$low, $high] = [0, count($this->lineOffsets) - 1];
                while ($low < $high) {
                        $middle = intdiv($low + $high + 1, 2);
                        if ($this->lineOffsets[$middle] <= $offset) {
                                $low = $middle;
                        } else {
                                $high = $middle - 1;
                        }
                }

                return $low + 1;
        }
}

dg / dresscode / 39958913551

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous