Method collect_document_diagnostics

src/diagnostics/lsp/client.rs:182–280

(
        &mut self,
        project_root: &Path,
        documents: Vec<LspDocument>,
        timeouts: LspRefreshTimeouts,
    )

    }

    pub async fn collect_document_diagnostics(
        &mut self,
        project_root: &Path,
        documents: Vec<LspDocument>,
        timeouts: LspRefreshTimeouts,
    ) -> Result<Vec<CodeDiagnostic>> {
        let mut uri_to_document = BTreeMap::new();
        for document in &documents {
            let uri = file_uri(&project_root.join(&document.relative_path));
            uri_to_document.insert(uri.clone(), document.clone());
            let next_version = self.document_versions.get(&uri).copied().unwrap_or(0) + 1;
            if next_version == 1 {
                write_message_with_timeout(
                    &mut self.stdin,
                    json!({
                        "jsonrpc": "2.0",
                        "method": "textDocument/didOpen",
                        "params": {
                            "textDocument": {
                                "uri": uri,
                                "languageId": document.language_id,
                                "version": next_version,
                                "text": document.text,
                            }
                        }
                    }),
                    timeouts.message_io,
                )
                .await?;
            }
            let change_version = next_version + 1;
            write_message_with_timeout(
                &mut self.stdin,
                json!({
                    "jsonrpc": "2.0",
                    "method": "textDocument/didChange",
                    "params": {
                        "textDocument": {
                            "uri": uri,
                            "version": change_version
                        },
                        "contentChanges": [{
                            "text": document.text,
                        }]
                    }
                }),
                timeouts.message_io,
            )
            .await?;
            self.document_versions.insert(uri, change_version);
        }

        let mut diagnostics_by_uri: BTreeMap<String, Vec<CodeDiagnostic>> = BTreeMap::new();
        let quiet_deadline = tokio::time::Instant::now() + timeouts.diagnostics_quiet;
        loop {
            let now = tokio::time::Instant::now();
            if now >= quiet_deadline {
                break;