fix(auth): fix MsgPack serialization by adding missing feature in backend and reverting to individual arguments

chore: remove db files from git and update gitignore
fix(setup): add logging and error details for setup debugging
2026-02-11 22:03:46 +03:00 · 2026-02-11 21:54:15 +03:00 · 2026-02-11 21:53:53 +03:00
12 changed files with 58 additions and 34 deletions
--- a/.gitignore
+++ b/.gitignore
@@ -8,3 +8,9 @@ backend.log
 .runner
 .env
 backend/.env
+*.db
+*.db-shm
+*.db-wal
+*.sqlite
+*.sqlite-shm
+*.sqlite-wal
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -3761,6 +3761,7 @@ dependencies = [
 "struct-patch",
 "thiserror 2.0.18",
 "tokio",
+ "tracing",
 "utoipa",
 ]

--- a/backend/Cargo.toml
+++ b/backend/Cargo.toml
@@ -44,6 +44,6 @@ tower_governor = "0.8.0"
 governor = "0.10.4"

 # Leptos
-leptos = { version = "0.8.15", features = ["nightly"] }
+leptos = { version = "0.8.15", features = ["nightly", "msgpack"] }
 leptos_axum = { version = "0.8.7" }
 jsonwebtoken = "9"
--- a/backend/src/main.rs
+++ b/backend/src/main.rs
@@ -52,22 +52,18 @@ async fn auth_middleware(
    request: Request<Body>,
    next: Next,
 ) -> Result<Response, StatusCode> {
-    // Skip auth for public server functions
+    // Skip auth for public paths
    let path = request.uri().path();
-    if path.starts_with("/api/server_fns/Login") 
-       || path.starts_with("/api/server_fns/login")
+    if path.starts_with("/api/server_fns/Login") // Login server fn
       || path.starts_with("/api/server_fns/GetSetupStatus")
-       || path.starts_with("/api/server_fns/get_setup_status")
       || path.starts_with("/api/server_fns/Setup")
-       || path.starts_with("/api/server_fns/setup")
       || path.starts_with("/swagger-ui")
       || path.starts_with("/api-docs")
-       || !path.starts_with("/api/") 
+       || !path.starts_with("/api/") // Allow static files (frontend)
    {
        return Ok(next.run(request).await);
    }

-
    // Check token
    if let Some(token) = jar.get("auth_token") {
        use jsonwebtoken::{decode, Validation, DecodingKey};
@@ -225,18 +221,6 @@ async fn main() {
    tracing::info!("Socket: {}", args.socket);
    tracing::info!("Port: {}", args.port);

-    // Force linking of server functions from shared crate for registration on Mac
-    {
-        use shared::server_fns::auth::*;
-        let _ = get_setup_status;
-        let _ = setup;
-        let _ = login;
-        let _ = logout;
-        let _ = get_user;
-        tracing::info!("Server functions linked successfully.");
-    }
-
-
    // ... rest of the main function ...
    // Startup Health Check
    let socket_path = std::path::Path::new(&args.socket);
--- a/frontend/Cargo.toml
+++ b/frontend/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 crate-type = ["cdylib", "rlib"]

 [dependencies]
-leptos = { version = "0.8.15", features = ["csr", "msgpack", "nightly"] }
+leptos = { version = "0.8.15", features = ["csr", "msgpack"] }
 leptos_router = { version = "0.8.11" }

 console_error_panic_hook = "0.1"
--- a/frontend/src/components/auth/setup.rs
+++ b/frontend/src/components/auth/setup.rs
@@ -41,7 +41,8 @@ pub fn Setup() -> impl IntoView {
                }
                Err(e) => {
                    log::error!("Setup failed: {:?}", e);
-                    error.1.set(Some("Kurulum sırasında bir hata oluştu".to_string()));
+                    // Hatanın sadece mesaj kısmını almaya çalışalım, yoksa full struct basılabilir
+                    error.1.set(Some(format!("Hata: {}", e)));
                    loading.1.set(false);
                }
            }
--- a/shared/Cargo.toml
+++ b/shared/Cargo.toml
@@ -10,6 +10,7 @@ struct-patch = "0.5"
 rmp-serde = "1.3"
 bytes = "1"
 http = "1"
+tracing = "0.1"

 # Leptos 0.8.7
 leptos = { version = "0.8.15", features = ["nightly", "msgpack"] }
--- a/shared/src/db.rs
+++ b/shared/src/db.rs
@@ -28,8 +28,17 @@ impl Db {
    }

    async fn run_migrations(&self) -> Result<()> {
-        sqlx::migrate!("./migrations").run(&self.pool).await?;
-        Ok(())
+        tracing::info!("Starting database migrations...");
+        match sqlx::migrate!("./migrations").run(&self.pool).await {
+            Ok(_) => {
+                tracing::info!("Database migrations completed successfully.");
+                Ok(())
+            }
+            Err(e) => {
+                tracing::error!("Database migration failed: {}", e);
+                Err(e.into())
+            }
+        }
    }

    // --- User Operations ---
--- a/shared/src/server_fns/auth.rs
+++ b/shared/src/server_fns/auth.rs
@@ -20,42 +20,64 @@ pub struct SetupStatus {
    pub completed: bool,
 }

-#[server(GetSetupStatus, "/api/server_fns", input = MsgPack, output = MsgPack)]
+#[server(GetSetupStatus, "/api/server_fns/GetSetupStatus", input = MsgPack, output = MsgPack)]
 pub async fn get_setup_status() -> Result<SetupStatus, ServerFnError> {
    use crate::DbContext;

-    let db_context = use_context::<DbContext>().ok_or_else(|| ServerFnError::new("DB Context missing"))?;
+    tracing::info!("Checking setup status...");
+    let db_context = use_context::<DbContext>().ok_or_else(|| {
+        tracing::error!("DB Context missing in GetSetupStatus");
+        ServerFnError::new("DB Context missing")
+    })?;
+    
    let has_users = db_context.db.has_users().await
-        .map_err(|e| ServerFnError::new(format!("DB error: {}", e)))?;
+        .map_err(|e| {
+            tracing::error!("DB error in GetSetupStatus: {}", e);
+            ServerFnError::new(format!("DB error: {}", e))
+        })?;
+    
+    tracing::info!("Setup status: completed={}", has_users);

    Ok(SetupStatus {
        completed: has_users,
    })
 }

-#[server(Setup, "/api/server_fns", input = MsgPack, output = MsgPack)]
+#[server(Setup, "/api/server_fns/Setup", input = MsgPack, output = MsgPack)]
 pub async fn setup(username: String, password: String) -> Result<(), ServerFnError> {
    use crate::DbContext;

-    let db_context = use_context::<DbContext>().ok_or_else(|| ServerFnError::new("DB Context missing"))?;
+    tracing::info!("Attempting setup for user: {}", username);
+    let db_context = use_context::<DbContext>().ok_or_else(|| {
+        tracing::error!("DB Context missing in Setup");
+        ServerFnError::new("DB Context missing")
+    })?;
    
    // Check if setup is already done
    let has_users = db_context.db.has_users().await.unwrap_or(false);
    if has_users {
+        tracing::warn!("Setup attempt blocked: Setup already completed");
        return Err(ServerFnError::new("Setup already completed"));
    }

    // Hash password (low cost for MIPS)
    let password_hash = bcrypt::hash(&password, 6)
-        .map_err(|_| ServerFnError::new("Hashing error"))?;
+        .map_err(|e| {
+            tracing::error!("Hashing error: {}", e);
+            ServerFnError::new("Hashing error")
+        })?;

    db_context.db.create_user(&username, &password_hash).await
-        .map_err(|e| ServerFnError::new(format!("DB error: {}", e)))?;
+        .map_err(|e| {
+            tracing::error!("Failed to create user: {}", e);
+            ServerFnError::new(format!("DB error: {}", e))
+        })?;

+    tracing::info!("Setup completed successfully for user: {}", username);
    Ok(())
 }

-#[server(Login, "/api/server_fns", input = MsgPack, output = MsgPack)]
+#[server(Login, "/api/server_fns/Login", input = MsgPack, output = MsgPack)]
 pub async fn login(username: String, password: String) -> Result<UserResponse, ServerFnError> {
    use crate::DbContext;
    use leptos_axum::ResponseOptions;
@@ -111,7 +133,7 @@ pub async fn login(username: String, password: String) -> Result<UserResponse, S
    }
 }

-#[server(Logout, "/api/server_fns", input = MsgPack, output = MsgPack)]
+#[server(Logout, "/api/server_fns/Logout", input = MsgPack, output = MsgPack)]
 pub async fn logout() -> Result<(), ServerFnError> {
    use leptos_axum::ResponseOptions;
    use cookie::{Cookie, SameSite};
@@ -132,7 +154,7 @@ pub async fn logout() -> Result<(), ServerFnError> {
    Ok(())
 }

-#[server(GetUser, "/api/server_fns", input = MsgPack, output = MsgPack)]
+#[server(GetUser, "/api/server_fns/GetUser", input = MsgPack, output = MsgPack)]
 pub async fn get_user() -> Result<Option<UserResponse>, ServerFnError> {
    use axum::http::HeaderMap;
    use leptos_axum::extract;
--- a/vibetorrent.db
+++ b/vibetorrent.db
--- a/vibetorrent.db-shm
+++ b/vibetorrent.db-shm
--- a/vibetorrent.db-wal
+++ b/vibetorrent.db-wal
Author	SHA1	Message	Date
spinline	09a4c69282	fix(auth): fix MsgPack serialization by adding missing feature in backend and reverting to individual arguments All checks were successful Build MIPS Binary / build (push) Successful in 5m15s Details	2026-02-11 22:03:46 +03:00
spinline	a877e0c393	chore: remove db files from git and update gitignore All checks were successful Build MIPS Binary / build (push) Successful in 5m13s Details	2026-02-11 21:54:15 +03:00
spinline	fd65df2962	fix(setup): add logging and error details for setup debugging Some checks failed Build MIPS Binary / build (push) Has been cancelled Details	2026-02-11 21:53:53 +03:00