Remove redundant versioning checks

Author: dantleech

lib/Core/Diagnostics/DiagnosticsEngine.php

@@ -30,11 +30,6 @@ class DiagnosticsEngine
      */
     private array $diagnostics = [];
 
-    /**
-     * @var array<int|string,int|string>
-     */
-    private array $versions = [];
-
     /**
      * @var array<string,Deferred<bool>>
      */
@@ -78,9 +73,14 @@ public function run(CancellationToken $token): Promise
 
                 yield $this->awaitNextDocument();
 
+                $beforeDocument = $this->waiting;
                 $gracePeriod = abs($this->sleepTime - ((microtime(true) - $this->lastUpdatedAt) * 1000));
                 yield delay(intval($gracePeriod));
 
+                if ($beforeDocument !== $this->waiting) {
+                    continue;
+                }
+
                 $textDocument = $this->waiting;
                 $this->waiting = null;
                 // allow the next document update to resolve
@@ -99,8 +99,6 @@ public function run(CancellationToken $token): Promise
                 );
                 $this->diagnostics[$textDocument->uri] = [];
 
-                $this->versions[$textDocument->uri] = $textDocument->version;
-
                 $crashedProviders = [];
 
                 foreach ($this->providers as $providerId => $provider) {
@@ -144,15 +142,14 @@ public function run(CancellationToken $token): Promise
 
                         $elapsed = (int)round((microtime(true) - $start) / 1000);
 
-                        $this->diagnostics[$textDocument->uri] = array_merge(
-                            $this->diagnostics[$textDocument->uri] ?? [],
-                            $diagnostics
-                        );
-
                         if (!$this->isDocumentCurrent($textDocument)) {
                             return;
                         }
 
+                        $this->diagnostics[$textDocument->uri] = array_merge(
+                            $this->diagnostics[$textDocument->uri] ?? [],
+                            $diagnostics
+                        );
 
                         $this->clientApi->diagnostics()->publishDiagnostics(
                             $textDocument->uri,
@@ -188,7 +185,7 @@ public function enqueue(TextDocumentItem $textDocument): void
 
     private function isDocumentCurrent(TextDocumentItem $textDocument): bool
     {
-        return $textDocument->version === ($this->versions[$textDocument->uri] ?? -1);
+        return $this->waiting === null;
     }
 
     /**

tests/Unit/Core/Diagnostics/DiagnosticsEngineTest.php

@@ -67,7 +67,7 @@ public function testOnlyPublishesForMostRecentFile(): Generator
         $engine->enqueue(ProtocolFactory::textDocumentItem('file:///barfoo', 'foobar'));
         $engine->enqueue(ProtocolFactory::textDocumentItem('file:///bazbar', 'foobar'));
 
-        yield new Delayed(0);
+        yield new Delayed(1);
 
         $token->cancel();