remove unnecessary mutex

Author: DolceTriade

src/main.rs

@@ -11,7 +11,6 @@ async fn main() -> anyhow::Result<()> {
     dotenvy::dotenv().ok();
     let config = crate::server::ServerConfig::parse();
 
-    use tokio::sync::Mutex;
     // Initialize logging system with colored output
     use tracing_subscriber::prelude::__tracing_subscriber_SubscriberExt;
     use tracing_subscriber::util::SubscriberInitExt;
@@ -47,7 +46,7 @@ async fn main() -> anyhow::Result<()> {
         .await
         .context("failed to connect to postgres")?;
 
-    let state = Arc::new(Mutex::new(pointer::server::AppState { pool }));
+    let state = Arc::new(pointer::server::AppState { pool });
     let file_state = state.clone();
     let render_state = state.clone();
 

src/mcp/tools.rs

@@ -76,10 +76,7 @@ pub async fn execute_file_content(
     payload: FileContentToolRequest,
 ) -> Result<FileContentToolResponse, String> {
     let state = leptos::prelude::expect_context::<crate::server::GlobalAppState>();
-    let pool = {
-        let state = state.lock().await;
-        state.pool.clone()
-    };
+    let pool = state.pool.clone();
     let db = PostgresDb::new(pool);
 
     let commit = db
@@ -173,10 +170,7 @@ pub async fn execute_file_list(
     payload: FileListToolRequest,
 ) -> Result<FileListToolResponse, String> {
     let state = leptos::prelude::expect_context::<crate::server::GlobalAppState>();
-    let pool = {
-        let state = state.lock().await;
-        state.pool.clone()
-    };
+    let pool = state.pool.clone();
     let db = PostgresDb::new(pool.clone());
 
     let commit = db

src/pages/file_viewer.rs

@@ -104,7 +104,6 @@ pub async fn get_file_viewer_data(
     use std::path::Path;
 
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
 
     let commit = db
@@ -216,7 +215,6 @@ pub async fn search_repo_paths(
     }
 
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
 
     let commit = db
@@ -246,7 +244,6 @@ pub async fn fetch_symbol_insights(
     }
 
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
 
     let commit = db

src/pages/repo_detail.rs

@@ -26,7 +26,6 @@ pub async fn get_repo_branches(repo: String) -> Result<Vec<RepoBranchDisplay>, S
     use crate::db::{Database, postgres::PostgresDb};
 
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
 
     let branches = db

src/server.rs

@@ -2,7 +2,6 @@ use std::sync::Arc;
 
 use clap::Parser;
 use sqlx::postgres::PgPool;
-use tokio::sync::Mutex;
 
 #[derive(Debug, Parser)]
 pub struct ServerConfig {
@@ -22,4 +21,4 @@ pub struct AppState {
     pub pool: PgPool,
 }
 
-pub type GlobalAppState = Arc<Mutex<AppState>>;
+pub type GlobalAppState = Arc<AppState>;

src/services/repo_service.rs

@@ -7,7 +7,6 @@ use crate::db::{Database, postgres::PostgresDb};
 #[server]
 pub async fn get_repositories(limit: usize) -> Result<Vec<RepoSummary>, ServerFnError> {
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
 
     // Create a database instance using the pool
     let db = PostgresDb::new(state.pool.clone());

src/services/search_service.rs

@@ -21,7 +21,6 @@ pub async fn search(query: String, page: u32) -> Result<SearchResultsPage, Serve
         TextSearchRequest::from_query_str_with_page(&query, normalized_page, DEFAULT_PAGE_SIZE)
             .map_err(|e| ServerFnError::new(e.to_string()))?;
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
     db.text_search(&request)
         .await
@@ -34,7 +33,6 @@ pub async fn autocomplete_repositories(
     limit: i64,
 ) -> Result<Vec<String>, ServerFnError> {
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
     let normalized_limit = limit.max(1).min(20);
     db.autocomplete_repositories(term.trim(), normalized_limit)
@@ -49,7 +47,6 @@ pub async fn autocomplete_paths(
     limit: i64,
 ) -> Result<Vec<String>, ServerFnError> {
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
     let normalized_limit = limit.max(1).min(20);
     let repos: Vec<String> = repositories
@@ -72,7 +69,6 @@ pub async fn autocomplete_symbols(
         return Ok(Vec::new());
     }
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
     let normalized_limit = limit.max(1).min(20);
     db.autocomplete_symbols(trimmed, normalized_limit)
@@ -87,7 +83,6 @@ pub async fn autocomplete_languages(
     limit: i64,
 ) -> Result<Vec<String>, ServerFnError> {
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
     let normalized_limit = limit.max(1).min(20);
     let repos: Vec<String> = repositories
@@ -107,7 +102,6 @@ pub async fn autocomplete_branches(
     limit: i64,
 ) -> Result<Vec<String>, ServerFnError> {
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
     let normalized_limit = limit.max(1).min(20);
     let repos: Vec<String> = repositories
@@ -127,7 +121,6 @@ pub async fn autocomplete_files(
     limit: i64,
 ) -> Result<Vec<String>, ServerFnError> {
     let state = expect_context::<crate::server::GlobalAppState>();
-    let state = state.lock().await;
     let db = PostgresDb::new(state.pool.clone());
     let normalized_limit = limit.max(1).min(20);
     let repos: Vec<String> = repositories