chore: fmt

Author: ovr

packages/cubejs-backend-native/src/channel.rs

@@ -398,8 +398,8 @@ impl SqlGenerator for NodeSqlGenerator {
 impl Drop for NodeSqlGenerator {
     fn drop(&mut self) {
         let channel = self.channel.clone();
-        /// Safety: Safe, because on_track take is used only for dropping
-        let sql_generator_obj = self.sql_generator_obj.take().unwrap();
+        // Safety: Safe, because on_track take is used only for dropping
+        let sql_generator_obj = self.sql_generator_obj.take().expect("Unable to take sql_generator_object while dropping NodeSqlGenerator, it was already taken");
 
         channel.send(move |mut cx| {
             let _ = match Arc::try_unwrap(sql_generator_obj) {

packages/cubejs-backend-native/src/gateway/auth_middleware.rs

@@ -1,12 +1,8 @@
 use crate::gateway::http_error::HttpError;
 use crate::gateway::state::ApiGatewayStateRef;
-use crate::gateway::{
-    ApiGatewayState, GatewayAuthContextRef, GatewayAuthService, GatewayCheckAuthRequest,
-};
+use crate::gateway::{GatewayAuthContextRef, GatewayAuthService, GatewayCheckAuthRequest};
 use axum::extract::State;
-use axum::http::{header, HeaderMap, HeaderValue, Response, StatusCode};
 use axum::response::IntoResponse;
-use std::sync::Arc;
 
 #[derive(Debug, Clone)]
 pub struct AuthExtension {

packages/cubejs-backend-native/src/gateway/handlers/stream.rs

@@ -1,7 +1,6 @@
 use crate::gateway::auth_middleware::AuthExtension;
 use crate::gateway::http_error::HttpError;
 use crate::gateway::state::ApiGatewayStateRef;
-use crate::gateway::{ApiGatewayRouterBuilder, ApiGatewayState};
 use axum::extract::State;
 use axum::http::StatusCode;
 use axum::response::IntoResponse;

packages/cubejs-backend-native/src/gateway/router.rs

@@ -1,10 +1,9 @@
+use crate::gateway::gateway_auth_middleware;
 use crate::gateway::handlers::stream_handler_v2;
 use crate::gateway::state::ApiGatewayStateRef;
-use crate::gateway::{gateway_auth_middleware, ApiGatewayState};
 use axum::handler::Handler;
 use axum::routing::{get, MethodRouter};
 use axum::Router;
-use tower::ServiceBuilder;
 
 #[derive(Debug, Clone)]
 pub struct ApiGatewayRouterBuilder {

packages/cubejs-backend-native/src/gateway/server.rs

@@ -1,13 +1,11 @@
 use crate::gateway::state::ApiGatewayStateRef;
-use crate::gateway::{ApiGatewayRouterBuilder, ApiGatewayState};
+use crate::gateway::ApiGatewayRouterBuilder;
 use async_trait::async_trait;
-use cubesql::config::injection::Injector;
 use cubesql::config::processing_loop::{ProcessingLoop, ShutdownMode};
 use cubesql::CubeError;
 use std::sync::Arc;
 use tokio::net::TcpListener;
 use tokio::sync::{watch, Mutex};
-use tower::ServiceBuilder;
 
 pub trait ApiGatewayServer: ProcessingLoop {}
 

packages/cubejs-backend-native/src/lib.rs

@@ -23,11 +23,9 @@ pub mod transport;
 pub mod utils;
 
 use crate::config::NodeConfigurationImpl;
-use cubesql::telemetry::{LocalReporter, ReportingLogger};
 use cubesql::CubeError;
 use neon::prelude::*;
 use once_cell::sync::OnceCell;
-use simple_logger::SimpleLogger;
 use tokio::runtime::{Builder, Runtime};
 
 pub fn tokio_runtime_node<'a, C: Context<'a>>(cx: &mut C) -> NeonResult<&'static Runtime> {

packages/cubejs-backend-native/src/logger.rs

@@ -35,7 +35,7 @@ impl LogReporter for NodeBridgeLogger {
         let extra = serde_json::to_string(&EventBox { event: props }).unwrap();
 
         let channel = self.channel.clone();
-        /// Safety: Safe, because on_track take is used only for dropping
+        // Safety: Safe, because on_track take is used only for dropping
         let on_track = self
             .on_track
             .as_ref()
@@ -52,10 +52,9 @@ impl LogReporter for NodeBridgeLogger {
 impl Drop for NodeBridgeLogger {
     fn drop(&mut self) {
         let channel = self.channel.clone();
-        let on_track = self
-            .on_track
-            .take()
-            .expect("NodeBridgeLogger.on_track was t already dropped");
+        let on_track = self.on_track.take().expect(
+            "Unable to take on_track while dropping NodeBridgeLogger, it was already taken",
+        );
 
         channel.send(move |mut cx| {
             let _ = match Arc::try_unwrap(on_track) {