remove api keys validation module (#6277)

Co-authored-by: Henry Fontanier <[email protected]>

core/bin/dust_api.rs

@@ -2,7 +2,7 @@ use anyhow::{anyhow, Result};
 use axum::{
     extract::{DefaultBodyLimit, Path, Query, State},
     http::header::HeaderMap,
-    middleware::from_fn,
+    // middleware::from_fn,
     response::{
         sse::{Event, KeepAlive, Sse},
         Json,
@@ -11,7 +11,7 @@ use axum::{
     Router,
 };
 use dust::{
-    api_keys::validate_api_key,
+    // api_keys::validate_api_key,
     app,
     blocks::block::BlockType,
     data_sources::{
@@ -2689,7 +2689,7 @@ fn main() {
 
         let sqlite_heartbeat_router = Router::new()
             .route("/sqlite_workers", post(sqlite_workers_heartbeat))
-            .layer(from_fn(validate_api_key))
+            // .layer(from_fn(validate_api_key))
             .with_state(state.clone());
 
         let health_check_router = Router::new().route("/", get(index));

core/src/api_keys.rs

@@ -8,7 +8,7 @@ use lazy_static::lazy_static;
 use serde::Deserialize;
 use std::{collections::HashMap, env, sync::Arc};
 use tokio::{fs, sync::OnceCell};
-use tracing::error;
+use tracing::{error, warn};
 
 lazy_static! {
     static ref DISABLE_API_KEY_CHECK: bool = env::var("DISABLE_API_KEY_CHECK")
@@ -31,8 +31,13 @@ async fn init_api_keys() -> Result<ApiKeyMap> {
         Err(_) => "[]".to_string(),
     };
 
-    let api_keys: Vec<ApiKeyEntry> = serde_json::from_str(&api_keys_json)
-        .map_err(|e| anyhow!("Failed to parse API keys JSON: {}", e))?;
+    let api_keys: Vec<ApiKeyEntry> = match serde_json::from_str(&api_keys_json) {
+        Ok(keys) => keys,
+        Err(e) => {
+            warn!("Failed to parse API keys: {}", e);
+            return Err(anyhow!("Failed to parse API keys"));
+        }
+    };
 
     let mut map = HashMap::new();
     for entry in api_keys {

core/src/lib.rs

@@ -92,4 +92,4 @@ pub mod oauth {
     }
 }
 
-pub mod api_keys;
+// pub mod api_keys;