Method phpcs_worker

src/diagnostics/mod.rs:1298–1426

Long-lived background task that runs PHPCS on pending files. Spawned once during `initialized`, alongside the main diagnostic worker and the PHPStan worker. This task is completely independent: native diagnostics and PHPStan are never blocked. ## Serialization guarantee At most one PHPCS process runs at a time. The worker loop: 1. Wait for a notification (new edit arrived). 2. Debounce: slee

(&self)

    /// notification and loops back to step 1, starting a fresh run
    /// with the latest content.
    pub(crate) async fn phpcs_worker(&self) {
        loop {
            if self.shutdown_flag.load(Ordering::Acquire) {
                return;
            }

            // ── Step 1: wait for work ───────────────────────────────
            self.phpcs_notify.notified().await;

            if self.shutdown_flag.load(Ordering::Acquire) {
                return;
            }

            // Drain any extra stored permits (same rationale as the
            // PHPStan worker).
            let _ =
                tokio::time::timeout(std::time::Duration::ZERO, self.phpcs_notify.notified()).await;

            // ── Step 2: debounce ────────────────────────────────────
            loop {
                let version_before = self.diag_version.load(Ordering::Acquire);
                tokio::time::sleep(std::time::Duration::from_millis(PHPCS_DEBOUNCE_MS)).await;
                let version_after = self.diag_version.load(Ordering::Acquire);
                if version_before == version_after {
                    break;
                }
                // More edits arrived — loop and debounce again.
            }

            // ── Step 3: snapshot the pending URI ────────────────────
            let uri = {
                let mut pending = self.phpcs_pending_uri.lock();
                pending.take()
            };
            let uri = match uri {
                Some(u) => u,
                None => continue,
            };

            // Snapshot the file content.
            let content = {
                let files = self.open_files.read();
                match files.get(&uri) {
                    Some(c) => c.clone(),
                    None => continue,
                }
            };

            // ── Step 4: resolve PHPCS binary ────────────────────────
            let config = self.config();
            if config.phpcs.is_disabled() {
                continue;
            }

            let file_path = match uri.parse::<Url>().ok().and_then(|u| u.to_file_path().ok()) {
                Some(p) => p,
                None => continue,
            };