refactor(app): implement command pattern for lsp actions

Author: tembleking

src/app/lsp_interactor.rs

@@ -0,0 +1,59 @@
+use tower_lsp::{
+    jsonrpc::Result,
+    lsp_types::{Diagnostic, MessageType},
+};
+
+use super::{InMemoryDocumentDatabase, LSPClient};
+
+pub struct LspInteractor<C> {
+    client: C,
+    document_database: InMemoryDocumentDatabase,
+}
+
+impl<C> LspInteractor<C> {
+    pub fn new(client: C, document_database: InMemoryDocumentDatabase) -> Self {
+        Self {
+            client,
+            document_database,
+        }
+    }
+}
+
+impl<C> LspInteractor<C>
+where
+    C: LSPClient,
+{
+    pub async fn update_document_with_text(&self, uri: &str, text: &str) {
+        self.document_database.write_document_text(uri, text).await;
+        self.document_database.remove_diagnostics(uri).await;
+        let _ = self.publish_all_diagnostics().await;
+    }
+
+    pub async fn show_message(&self, message_type: MessageType, message: &str) {
+        self.client.show_message(message_type, message).await;
+    }
+
+    pub async fn publish_all_diagnostics(&self) -> Result<()> {
+        let all_diagnostics = self.document_database.all_diagnostics().await;
+        for (url, diagnostics) in all_diagnostics {
+            self.client
+                .publish_diagnostics(&url, diagnostics, None)
+                .await;
+        }
+        Ok(())
+    }
+
+    pub async fn read_document_text(&self, uri: &str) -> Option<String> {
+        self.document_database.read_document_text(uri).await
+    }
+
+    pub async fn remove_diagnostics(&self, uri: &str) {
+        self.document_database.remove_diagnostics(uri).await
+    }
+
+    pub async fn append_document_diagnostics(&self, uri: &str, diagnostics: &[Diagnostic]) {
+        self.document_database
+            .append_document_diagnostics(uri, diagnostics)
+            .await
+    }
+}