diff --git a/lib/api-helper/build/src/start.rs b/lib/api-helper/build/src/start.rs index 11446109fa..5733ab83f5 100644 --- a/lib/api-helper/build/src/start.rs +++ b/lib/api-helper/build/src/start.rs @@ -67,12 +67,10 @@ where .unwrap(); // A `MakeService` that produces a `Service` to handle each connection - let health_check_config = Arc::new(health_check_config); let make_service = make_service_fn(move |conn: &AddrStream| { let shared_client = shared_client.clone(); let pools = pools.clone(); let cache = cache.clone(); - let health_check_config = health_check_config.clone(); // Create a `Service` for responding to the request let remote_addr = conn.remote_addr(); @@ -82,7 +80,6 @@ where let shared_client = shared_client.clone(); let pools = pools.clone(); let cache = cache.clone(); - let health_check_config = health_check_config.clone(); // Handle request let ray_id = Uuid::new_v4(); diff --git a/lib/util/core/src/timestamp.rs b/lib/util/core/src/timestamp.rs index 78986516e3..cba2c5e4bc 100644 --- a/lib/util/core/src/timestamp.rs +++ b/lib/util/core/src/timestamp.rs @@ -15,7 +15,7 @@ pub fn end_of_month(ts: i64) -> GlobalResult { let nanos = (ts % 1000 * 1_000_000).try_into()?; // Get year and month of current month - let current_date = unwrap!(NaiveDateTime::from_timestamp_opt(ts / 1000, nanos)); + let current_date = unwrap!(DateTime::from_timestamp(ts / 1000, nanos)); let year = current_date.year(); let month = current_date.month(); diff --git a/svc/pkg/load-test/standalone/sqlx/src/lib.rs b/svc/pkg/load-test/standalone/sqlx/src/lib.rs index d99de90aaa..00b7009854 100644 --- a/svc/pkg/load-test/standalone/sqlx/src/lib.rs +++ b/svc/pkg/load-test/standalone/sqlx/src/lib.rs @@ -1,4 +1,3 @@ -use futures_util::StreamExt; use rivet_operation::prelude::*; #[tracing::instrument(skip_all)] @@ -32,8 +31,6 @@ pub async fn run_from_env(_ts: i64) -> GlobalResult<()> { } }); } - - Ok(()) } async fn exec(ctx: OperationContext<()>) -> GlobalResult<()> { diff --git a/svc/pkg/mm/worker/src/workers/lobby_create/mod.rs b/svc/pkg/mm/worker/src/workers/lobby_create/mod.rs index 254e602a81..1635e60e10 100644 --- a/svc/pkg/mm/worker/src/workers/lobby_create/mod.rs +++ b/svc/pkg/mm/worker/src/workers/lobby_create/mod.rs @@ -1,4 +1,4 @@ -use std::{collections::hash_map::DefaultHasher, hash::Hasher, net::IpAddr, ops::Deref}; +use std::{collections::hash_map::DefaultHasher, hash::Hasher, net::IpAddr}; use chirp_worker::prelude::*; use proto::backend::{self, pkg::*}; @@ -353,9 +353,7 @@ async fn fetch_mm_namespace_config( }) .await?; - let namespace = unwrap!(get_res.namespaces.first(), "namespace not found") - .deref() - .clone(); + let namespace = unwrap!(get_res.namespaces.first(), "namespace not found").clone(); let namespace_config = unwrap_ref!(namespace.config).clone(); Ok(namespace_config) diff --git a/svc/pkg/user-presence/worker/src/workers/leave.rs b/svc/pkg/user-presence/worker/src/workers/leave.rs index 249ebf7ff8..07941f13f9 100644 --- a/svc/pkg/user-presence/worker/src/workers/leave.rs +++ b/svc/pkg/user-presence/worker/src/workers/leave.rs @@ -1,6 +1,5 @@ use chirp_worker::prelude::*; use proto::backend::{self, pkg::*}; -use redis::AsyncCommands; const DEFAULT_USER_SET_STATUS: i32 = backend::user::Status::Online as i32;