Method touch_file

crates/opencode-lsp/src/lib.rs:852–886

Opens or refreshes a file in all matching LSP clients. Mirrors the TS `LSP.touchFile(input, waitForDiagnostics)`. - Reads the file content from disk - For each registered client whose id matches the file's language, calls `open_document` (which internally handles didOpen vs didChange) - If `wait_for_diagnostics` is true, waits briefly for diagnostics to arrive

(
        &self,
        path: &Path,
        wait_for_diagnostics: bool,
    )

    ///   calls `open_document` (which internally handles didOpen vs didChange)
    /// - If `wait_for_diagnostics` is true, waits briefly for diagnostics to arrive
    pub async fn touch_file(
        &self,
        path: &Path,
        wait_for_diagnostics: bool,
    ) -> Result<(), LspError> {
        let language = detect_language(path);
        let content = tokio::fs::read_to_string(path)
            .await
            .map_err(|e| LspError::IoError(e))?;

        let clients = self.clients.read().await;
        let matching: Vec<Arc<LspClient>> = clients
            .iter()
            .filter(|(id, _)| id.contains(language))
            .map(|(_, c)| c.clone())
            .collect();
        drop(clients);

        for client in &matching {
            if let Err(e) = client.open_document(path, &content, language).await {
                error!("Failed to touch file {:?} in LSP: {}", path, e);
            }
        }

        if wait_for_diagnostics && !matching.is_empty() {
            // Give LSP servers a moment to produce diagnostics.
            // The TS version uses client.waitForDiagnostics which listens
            // for a publishDiagnostics notification. We approximate this
            // with a short sleep, since the broadcast-based event system
            // already stores diagnostics as they arrive.
            tokio::time::sleep(std::time::Duration::from_millis(200)).await;
        }

        Ok(())
    }
}

impl Default for LspClientRegistry {