refactor: resolve backend warnings and clean up unused code

Author: vipmax

anycode-backend/src/acp.rs

@@ -1641,16 +1641,6 @@ impl AcpAgent {
         Ok(())
     }
 
-    /// Get all available checkpoints
-    pub async fn get_checkpoints(&self) -> Vec<String> {
-        let manager = self.history_manager.read().await;
-        manager
-            .get_all_checkpoints()
-            .iter()
-            .map(|cp| cp.prompt.clone())
-            .collect()
-    }
-
     pub async fn cancel_prompt(&self) -> Result<()> {
         let cancel_sender_guard = self.cancel_sender.lock().await;
         let cancel_tx = match cancel_sender_guard.as_ref() {
@@ -1846,14 +1836,4 @@ impl AcpManager {
 
         agent.restore_to_checkpoint_id(checkpoint_id).await
     }
-
-    /// Get all checkpoints for an agent. Returns Vec of prompts
-    pub async fn get_checkpoints(&self, agent_id: &str) -> Result<Vec<String>> {
-        let agent = self
-            .agents
-            .get(agent_id)
-            .ok_or_else(|| anyhow!("Agent {} not found", agent_id))?;
-
-        Ok(agent.get_checkpoints().await)
-    }
 }

anycode-backend/src/acp_fs.rs

@@ -139,7 +139,7 @@ async fn handle_write(
         if !lsp_changes.is_empty() {
             let mut lsp = lsp_manager.lock().await;
             if let Some(lsp) = lsp.get(&lang).await {
-                if let Err(e) = lsp.did_change_multi(&abs_path, lsp_changes).await {
+                if let Err(e) = lsp.did_change(&abs_path, lsp_changes).await {
                     error!(
                         "ACP write: failed to notify LSP didChange for {}: {}",
                         abs_path, e

anycode-backend/src/acp_history.rs

@@ -8,7 +8,6 @@ use tracing::{debug, info, warn};
 pub struct Checkpoint {
     pub commit_hash: String,
     pub prompt: String,
-    pub created_at: chrono::DateTime<chrono::Utc>,
 }
 
 /// AcpHistoryManager - manages undo/redo using a shadow git repository
@@ -221,8 +220,6 @@ impl AcpHistoryManager {
                 checkpoints.push(Checkpoint {
                     commit_hash: oid.to_string(),
                     prompt: prompt.clone(),
-                    created_at: chrono::DateTime::from_timestamp(commit.time().seconds(), 0)
-                        .unwrap_or_else(chrono::Utc::now),
                 });
             }
         }
@@ -287,7 +284,6 @@ impl AcpHistoryManager {
         let checkpoint = Checkpoint {
             commit_hash: hash.clone(),
             prompt: prompt.to_string(),
-            created_at: chrono::Utc::now(),
         };
 
         self.checkpoints.push(checkpoint);
@@ -335,6 +331,7 @@ impl AcpHistoryManager {
     }
 
     /// Get all checkpoints
+    #[allow(dead_code)]
     pub fn get_all_checkpoints(&self) -> &[Checkpoint] {
         &self.checkpoints
     }

anycode-backend/src/code.rs

@@ -66,6 +66,7 @@ impl Code {
         self.text.to_string()
     }
 
+    #[allow(dead_code)]
     pub fn from_str(text: &str) -> Self {
         let mut code = Self::new();
         code.applying_history = false;
@@ -136,6 +137,7 @@ impl Code {
         self.file_name = file_name;
     }
 
+    #[allow(dead_code)]
     pub fn position(&self, offset: usize) -> (usize, usize) {
         let line_idx = self.text.char_to_line(offset);
         let line_char_index = self.text.line_to_char(line_idx);
@@ -146,6 +148,7 @@ impl Code {
         self.text.utf16_cu_to_char(utf16_offset)
     }
 
+    #[allow(dead_code)]
     pub fn char_to_utf16_offset(&self, char_offset: usize) -> usize {
         self.text.char_to_utf16_cu(char_offset)
     }

anycode-backend/src/config.rs

@@ -18,13 +18,15 @@ pub struct Dist;
 pub struct Themes;
 
 #[derive(Debug, Deserialize, Clone)]
+#[allow(dead_code)]
 pub struct Config {
     pub theme: String,
     pub language: Vec<Language>,
     pub terminal: Option<Terminal>,
 }
 
 impl Config {
+    #[allow(dead_code)]
     pub fn default() -> Self {
         Config {
             theme: "default".to_string(),
@@ -35,6 +37,7 @@ impl Config {
 }
 
 #[derive(Debug, Deserialize, Clone)]
+#[allow(dead_code)]
 pub struct Language {
     pub name: String,
     pub types: Vec<String>,
@@ -47,11 +50,13 @@ pub struct Language {
 }
 
 #[derive(Debug, Deserialize, Clone)]
+#[allow(dead_code)]
 pub struct IndentConfig {
     pub width: i32,
     pub unit: String,
 }
 
+#[cfg(test)]
 pub fn get_config(conf_path: &str) -> Config {
     let error_message = format!("Unable to read config.toml file from path {}", conf_path);
     let toml_str = std::fs::read_to_string(conf_path).expect(&error_message);
@@ -97,6 +102,7 @@ pub fn read_assets_config() -> anyhow::Result<String> {
 }
 
 #[derive(Debug, Deserialize, Clone)]
+#[allow(dead_code)]
 pub struct Terminal {
     pub command: String,
 }

anycode-backend/src/handlers/io_handler.rs

@@ -370,7 +370,7 @@ pub async fn handle_file_change(
         let mut lsp_manager = state.lsp_manager.lock().await;
         if let Some(lsp) = lsp_manager.get(&lang).await {
             if !lsp_changes.is_empty() {
-                if let Err(e) = lsp.did_change_multi(&abs_path, lsp_changes).await {
+                if let Err(e) = lsp.did_change(&abs_path, lsp_changes).await {
                     error!("Failed to notify LSP didChange for {}: {:?}", abs_path, e);
                 }
             }

anycode-backend/src/handlers/watch_handler.rs

@@ -365,7 +365,7 @@ async fn handle_file_modification(
     if sync_lsp && !lsp_changes.is_empty() {
         let mut lsp = lsp_manager.lock().await;
         if let Some(lsp) = lsp.get(&lang).await {
-            if let Err(e) = lsp.did_change_multi(path_str, lsp_changes).await {
+            if let Err(e) = lsp.did_change(path_str, lsp_changes).await {
                 error!("Failed to notify LSP didChange for {}: {:?}", path_str, e);
             }
             if let Err(e) = lsp.did_save(path_str) {

anycode-backend/src/lsp.rs

@@ -296,10 +296,6 @@ impl Lsp {
         self.ready.load(Ordering::SeqCst)
     }
 
-    pub fn lsp_name(&self) -> Option<&str> {
-        self.lsp_name.as_deref()
-    }
-
     pub fn initialized(&mut self) {
         let params = InitializedParams {};
         self.send_notification::<Initialized>(params);
@@ -361,39 +357,14 @@ impl Lsp {
     }
 
     pub async fn did_change(
-        &mut self,
-        start_line: usize,
-        start_column: usize,
-        end_line: usize,
-        end_column: usize,
-        path: &str,
-        text: &str,
-    ) -> Result<()> {
-        self.did_change_multi(
-            path,
-            vec![TextDocumentContentChangeEvent {
-                range: Some(Range {
-                    start: Position::new(start_line as u32, start_column as u32),
-                    end: Position::new(end_line as u32, end_column as u32),
-                }),
-                range_length: None,
-                text: text.to_string(),
-            }],
-        )
-        .await
-    }
-
-    pub async fn did_change_multi(
         &mut self,
         path: &str,
         content_changes: Vec<TextDocumentContentChangeEvent>,
     ) -> Result<()> {
         let uri = path_to_uri(path)?;
+        let version = self.get_next_version(path) as i32;
         let params = DidChangeTextDocumentParams {
-            text_document: VersionedTextDocumentIdentifier {
-                uri,
-                version: self.get_next_version(path) as i32,
-            },
+            text_document: VersionedTextDocumentIdentifier { uri, version },
             content_changes,
         };
 
@@ -576,7 +547,7 @@ mod tests {
         assert!(references_str.contains("fast.py"));
         assert!(references_str.contains("Position { line: 0, character: 30 }"));
 
-        lsp.stop().await;
+        let _ = lsp.stop().await;
         Ok(())
     }
 }
@@ -589,8 +560,6 @@ pub mod lsp_messages {
 
     #[derive(Deserialize)]
     pub struct LspRawResponse {
-        pub jsonrpc: String,
-        pub id: Value,
         pub result: Option<Value>,
         pub error: Option<Value>,
     }
@@ -723,6 +692,7 @@ pub mod lsp_messages {
             None
         };
 
+        #[allow(deprecated)]
         let params = InitializeParams {
             process_id: Some(std::process::id() as u32),
             root_path: Some(dir.to_string()),
@@ -813,26 +783,6 @@ impl LspManager {
         self.lang2lsp.insert(lang, lsp);
     }
 
-    pub fn notify_configuration_changed(&mut self, lang: &str, dir: &str) {
-        if let Some(lsp) = self.lang2lsp.get_mut(lang) {
-            if let Some(lsp_name) = lsp.lsp_name() {
-                if let Some(settings) = lsp_messages::read_vscode_settings(lsp_name, dir) {
-                    lsp.did_change_configuration(settings);
-                }
-            }
-        }
-    }
-
-    pub fn notify_all_configuration_changed(&mut self, dir: &str) {
-        for lsp in self.lang2lsp.values_mut() {
-            if let Some(lsp_name) = lsp.lsp_name() {
-                if let Some(settings) = lsp_messages::read_vscode_settings(lsp_name, dir) {
-                    lsp.did_change_configuration(settings);
-                }
-            }
-        }
-    }
-
     pub async fn stop(&mut self, lang: &str) {
         if let Some(mut lsp) = self.lang2lsp.remove(lang) {
             let _ = lsp.stop().await;

anycode-backend/src/search.rs

@@ -303,6 +303,7 @@ pub async fn global_search(
     Ok(())
 }
 
+#[cfg(test)]
 pub mod search_exp {
     use super::*;
 

anycode-backend/src/terminal.rs

@@ -6,17 +6,15 @@ use std::path::{Path, PathBuf};
 use tokio::sync::mpsc;
 
 pub struct Terminal {
-    name: String,
-    session_id: String,
     pty_input_tx: mpsc::Sender<String>,
     pty_resize_tx: mpsc::Sender<(u16, u16)>,
     kill_tx: mpsc::Sender<()>,
 }
 
 impl Terminal {
     pub async fn new(
-        name: String,
-        session_id: String,
+        _name: String,
+        _session_id: String,
         rows: u16,
         cols: u16,
         cmd: Option<String>,
@@ -53,8 +51,6 @@ impl Terminal {
         Self::spawn_terminal_task(child, writer, pair, pty_input_rx, pty_resize_rx, kill_rx);
 
         Ok(Self {
-            name,
-            session_id,
             pty_input_tx,
             pty_resize_tx,
             kill_tx,