shader_language_server 1.3.0

use std::collections::HashMap;

use log::info;
use lsp_types::{
    Diagnostic, DiagnosticSeverity, DiagnosticTag, DocumentDiagnosticReport,
    DocumentDiagnosticReportKind, DocumentDiagnosticReportResult, FullDocumentDiagnosticReport,
    PublishDiagnosticsParams, RelatedFullDocumentDiagnosticReport, Url,
};

use shader_sense::shader_error::ShaderDiagnosticSeverity;

use crate::server::common::{shader_range_to_lsp_range, ServerLanguageError};

use crate::server::ServerLanguage;

impl ServerLanguage {
    pub fn publish_diagnostic(&mut self, uri: &Url, version: Option<i32>) {
        match self.recolt_diagnostic(uri) {
            Ok(diagnostics) => {
                info!("Publishing diagnostic for {} files", diagnostics.len());
                for (diagnostic_url, diagnostics) in diagnostics {
                    info!(
                        "Publishing diagnostic for file {} ({} diags)",
                        uri,
                        diagnostics.len()
                    );
                    let publish_diagnostics_params = PublishDiagnosticsParams {
                        uri: diagnostic_url,
                        diagnostics: diagnostics,
                        version: version,
                    };
                    self.connection
                        .send_notification::<lsp_types::notification::PublishDiagnostics>(
                            publish_diagnostics_params,
                        );
                }
            }
            Err(err) => self.connection.send_notification_error(format!(
                "Failed to compute diagnostic for file {}: {}",
                uri, err
            )),
        }
    }
    pub fn recolt_document_diagnostic(
        &mut self,
        uri: &Url,
    ) -> Result<DocumentDiagnosticReportResult, ServerLanguageError> {
        let mut diagnostics = self.recolt_diagnostic(&uri)?;
        let main_diagnostic = match diagnostics.remove(&uri) {
            Some(diag) => diag,
            None => vec![],
        };
        Ok(DocumentDiagnosticReportResult::Report(
            DocumentDiagnosticReport::Full(RelatedFullDocumentDiagnosticReport {
                related_documents: Some(
                    diagnostics
                        .into_iter()
                        .map(|diagnostic| {
                            (
                                diagnostic.0,
                                DocumentDiagnosticReportKind::Full(FullDocumentDiagnosticReport {
                                    result_id: None,
                                    items: diagnostic.1,
                                }),
                            )
                        })
                        .collect(),
                ),
                full_document_diagnostic_report: FullDocumentDiagnosticReport {
                    result_id: None,
                    items: main_diagnostic,
                },
            }),
        ))
    }

    pub fn clear_diagnostic(&self, uri: &Url) {
        // TODO: check it exist ?
        info!("Clearing diagnostic for file {}", uri);
        let publish_diagnostics_params = PublishDiagnosticsParams {
            uri: uri.clone(),
            diagnostics: Vec::new(),
            version: None,
        };
        self.connection
            .send_notification::<lsp_types::notification::PublishDiagnostics>(
                publish_diagnostics_params,
            );
    }
    fn get_lsp_severity(severity: &ShaderDiagnosticSeverity) -> lsp_types::DiagnosticSeverity {
        match severity {
            ShaderDiagnosticSeverity::Hint => lsp_types::DiagnosticSeverity::HINT,
            ShaderDiagnosticSeverity::Information => lsp_types::DiagnosticSeverity::INFORMATION,
            ShaderDiagnosticSeverity::Warning => lsp_types::DiagnosticSeverity::WARNING,
            ShaderDiagnosticSeverity::Error => lsp_types::DiagnosticSeverity::ERROR,
        }
    }
    pub fn recolt_diagnostic(
        &mut self,
        uri: &Url,
    ) -> Result<HashMap<Url, Vec<Diagnostic>>, ServerLanguageError> {
        let cached_file = self.get_cachable_file(&uri)?;
        let data = cached_file.get_data();
        // Diagnostic for included file stored in main cache.
        let mut diagnostics: HashMap<Url, Vec<Diagnostic>> = HashMap::new();
        // Only take diagnostics if required
        if self.config.get_validate() {
            let diagnostic_cache = &data.diagnostic_cache;

            for diagnostic in &diagnostic_cache.diagnostics {
                let uri = Url::from_file_path(&diagnostic.range.file_path).unwrap();
                if diagnostic.severity.is_required(self.config.get_severity()) {
                    let diagnostic = Diagnostic {
                        range: shader_range_to_lsp_range(&diagnostic.range.range),
                        severity: Some(Self::get_lsp_severity(&diagnostic.severity)),
                        message: if diagnostic.error.is_empty() {
                            "No message.".into() // vscode extension send error when empty message.
                        } else {
                            diagnostic.error.clone()
                        },
                        source: Some("shader-validator".to_string()),
                        ..Default::default()
                    };
                    match diagnostics.get_mut(&uri) {
                        Some(value) => value.push(diagnostic),
                        None => {
                            diagnostics.insert(uri, vec![diagnostic]);
                        }
                    };
                }
            }
            // Clear diagnostic if no errors.
            if diagnostics.get(&uri).is_none() {
                info!(
                    "No issue found for main file. Clearing previous diagnostic {}",
                    uri
                );
                diagnostics.insert(uri.clone(), vec![]);
            }
            // Add empty diagnostics to dependencies without errors to clear them.
            data.symbol_cache.visit_includes(&mut |include| {
                let include_uri = Url::from_file_path(&include.get_absolute_path()).unwrap();
                if diagnostics.get(&include_uri).is_none() {
                    info!("Clearing diagnostic for deps file {}", include_uri);
                    diagnostics.insert(include_uri.clone(), vec![]);
                }
            });
        } else {
            info!("Diagnostic disabled.");
        }

        // Add inactive regions to diag for open file.
        // For current file
        let inactive_diagnostics: Vec<Diagnostic> = cached_file
            .get_data()
            .symbol_cache
            .get_preprocessor()
            .regions
            .iter()
            .filter_map(|region| {
                (!region.is_active).then_some(Diagnostic {
                    range: shader_range_to_lsp_range(&region.range),
                    severity: Some(DiagnosticSeverity::HINT),
                    message: "Code disabled by currently used macros".into(),
                    source: Some("shader-validator".to_string()),
                    tags: Some(vec![DiagnosticTag::UNNECESSARY]),
                    ..Default::default()
                })
            })
            .collect();
        // For includes.
        data.symbol_cache.visit_includes(&mut |include| {
            let include_uri = Url::from_file_path(&include.get_absolute_path()).unwrap();
            if let Some(include_cached_file) = self.watched_files.files.get(&include_uri) {
                if include_cached_file.is_cachable_file() {
                    let include_inactive_diagnostics: Vec<Diagnostic> = include_cached_file
                        .get_data()
                        .symbol_cache
                        .get_preprocessor()
                        .regions
                        .iter()
                        .filter_map(|region| {
                            (!region.is_active).then_some(Diagnostic {
                                range: shader_range_to_lsp_range(&region.range),
                                severity: Some(DiagnosticSeverity::HINT),
                                message: "Code disabled by currently used macros".into(),
                                source: Some("shader-validator".to_string()),
                                tags: Some(vec![DiagnosticTag::UNNECESSARY]),
                                ..Default::default()
                            })
                        })
                        .collect();
                    match diagnostics.get_mut(&include_uri) {
                        Some(diagnostics) => {
                            diagnostics.extend(include_inactive_diagnostics);
                        }
                        None => {
                            diagnostics.insert(include_uri, include_inactive_diagnostics);
                        }
                    }
                }
            }
        });

        match diagnostics.get_mut(&uri) {
            Some(diagnostics) => {
                if self.config.get_symbol_diagnostics() {
                    diagnostics.extend(
                        data.symbol_cache
                            .get_preprocessor()
                            .diagnostics
                            .iter()
                            .map(|d| Diagnostic {
                                range: shader_range_to_lsp_range(&d.range.range),
                                severity: Some(Self::get_lsp_severity(&d.severity)),
                                message: d.error.clone(),
                                source: Some("shader-validator".to_string()),
                                ..Default::default()
                            }),
                    );
                }
                diagnostics.extend(inactive_diagnostics);
            }
            None => {} // If we disable diag, this might be reached.
        }
        Ok(diagnostics)
    }
}