cargo fmt

Author: sxlijin

engine/language_server/src/cors_bypass_proxy.rs

@@ -1,3 +1,5 @@
+use std::collections::HashMap;
+
 use anyhow::Result;
 use axum::{
     body::Body,
@@ -9,7 +11,6 @@ use axum::{
 };
 use mime_guess::from_path;
 use serde::Deserialize;
-use std::collections::HashMap;
 use tokio::{fs, net::TcpListener};
 use tower_http::cors::{Any, CorsLayer};
 
@@ -102,8 +103,10 @@ impl ProxyError {
 }
 
 pub fn create_proxy_router() -> Router<ProxyConfig> {
-    use axum::http::header::{AUTHORIZATION, CONTENT_TYPE};
-    use axum::http::HeaderName;
+    use axum::http::{
+        header::{AUTHORIZATION, CONTENT_TYPE},
+        HeaderName,
+    };
 
     // Create CORS layer that allows all origins and methods
     let cors = CorsLayer::new()

engine/language_server/src/server.rs

@@ -19,6 +19,7 @@ use lsp_types::{
     TextDocumentSyncKind, TextDocumentSyncOptions, TextDocumentSyncSaveOptions, Url,
     WorkspaceClientCapabilities, WorkspaceFoldersServerCapabilities, WorkspaceServerCapabilities,
 };
+use playground_server::{FrontendMessage, LangServerToWasmMessage, PreLangServerToWasmMessage};
 use schedule::Task;
 use serde::{Deserialize, Serialize};
 use tokio::sync::{broadcast, RwLock};
@@ -27,8 +28,6 @@ use self::{
     connection::{Connection, ConnectionInitializer},
     schedule::event_loop_thread,
 };
-use playground_server::{FrontendMessage, LangServerToWasmMessage, PreLangServerToWasmMessage};
-
 use crate::{
     baml_project::file_utils::{find_baml_src, find_top_level_parent},
     session::{AllSettings, ClientSettings, Session},

engine/language_server/src/server/api/requests/diagnostic.rs

@@ -1,13 +1,12 @@
 use std::{borrow::Cow, sync::Arc};
 
-use parking_lot::Mutex;
-
 use lsp_types::{
     request::DocumentDiagnosticRequest, DocumentDiagnosticParams, DocumentDiagnosticReport,
     DocumentDiagnosticReportResult, FullDocumentDiagnosticReport,
     RelatedFullDocumentDiagnosticReport, RelatedUnchangedDocumentDiagnosticReport,
     UnchangedDocumentDiagnosticReport, Url,
 };
+use parking_lot::Mutex;
 
 use crate::{
     baml_project::Project,

engine/language_server/src/server/api/traits.rs

@@ -1,11 +1,11 @@
 //! A stateful LSP implementation that calls into the Ruff API.
 
-use parking_lot::Mutex;
 use std::sync::Arc;
 
 // use crate::baml_project::ProjectDatabase;
 use lsp_types::notification::Notification as LSPNotification;
 use lsp_types::request::Request;
+use parking_lot::Mutex;
 
 use super::notifications::DidSaveTextDocument;
 use crate::{

engine/playground-server/src/bin/playground_barebones.rs

@@ -1,8 +1,9 @@
+use std::collections::HashMap;
+
 use playground_server::{
     pick_ports, AppState, FrontendMessage, LangServerToWasmMessage, PlaygroundServer,
     PortConfiguration, PreLangServerToWasmMessage,
 };
-use std::collections::HashMap;
 use tokio::io::AsyncBufReadExt;
 use tracing_subscriber::EnvFilter;
 

engine/playground-server/src/handlers/websocket_rpc.rs

@@ -3,7 +3,6 @@ use axum::{
     response::IntoResponse,
 };
 use futures::{SinkExt, StreamExt};
-
 use serde_json::Value;
 
 use crate::{definitions::PreLangServerToWasmMessage, server::AppState};

engine/playground-server/src/server.rs

@@ -1,10 +1,9 @@
+use std::{io::Cursor, path::PathBuf, time::Duration};
+
 use anyhow::Context;
 use axum::{routing::get, Router};
 use flate2::read::GzDecoder;
 use sha2::{Digest, Sha256};
-use std::io::Cursor;
-use std::path::PathBuf;
-use std::time::Duration;
 use tar::Archive;
 use tokio::{net::TcpListener, sync::broadcast};
 use tower_http::services::ServeDir;

engine/tools/src/bin/language-server-hot-reload.rs

@@ -1,17 +1,23 @@
+use std::{
+    collections::VecDeque,
+    io::{self, Write},
+    path::Path,
+    process::{Child, Command, Stdio},
+    sync::{mpsc, Arc, Mutex},
+    time::{Duration, SystemTime},
+};
+
 use anyhow::Result;
-use notify_debouncer_full::notify::Watcher;
 use notify_debouncer_full::{
-    new_debouncer, notify::RecursiveMode, DebounceEventResult, Debouncer, FileIdMap,
+    new_debouncer,
+    notify::{RecursiveMode, Watcher},
+    DebounceEventResult, Debouncer, FileIdMap,
+};
+use tokio::{
+    io::{AsyncBufReadExt, AsyncRead, AsyncReadExt, AsyncWriteExt, BufReader},
+    process::{Child as TokioChild, Command as TokioCommand},
+    sync::watch,
 };
-use std::collections::VecDeque;
-use std::io::{self, Write};
-use std::path::Path;
-use std::process::{Child, Command, Stdio};
-use std::sync::{mpsc, Arc, Mutex};
-use std::time::{Duration, SystemTime};
-use tokio::io::{AsyncBufReadExt, AsyncRead, AsyncReadExt, AsyncWriteExt, BufReader};
-use tokio::process::{Child as TokioChild, Command as TokioCommand};
-use tokio::sync::watch;
 use tracing::{info, warn};
 use tracing_subscriber::{EnvFilter, FmtSubscriber};