Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 0 additions & 3 deletions lib/api-helper/build/src/start.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand All @@ -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();
Expand Down
2 changes: 1 addition & 1 deletion lib/util/core/src/timestamp.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ pub fn end_of_month(ts: i64) -> GlobalResult<NaiveDateTime> {
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();

Expand Down
3 changes: 0 additions & 3 deletions svc/pkg/load-test/standalone/sqlx/src/lib.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
use futures_util::StreamExt;
use rivet_operation::prelude::*;

#[tracing::instrument(skip_all)]
Expand Down Expand Up @@ -32,8 +31,6 @@ pub async fn run_from_env(_ts: i64) -> GlobalResult<()> {
}
});
}

Ok(())
}

async fn exec(ctx: OperationContext<()>) -> GlobalResult<()> {
Expand Down
6 changes: 2 additions & 4 deletions svc/pkg/mm/worker/src/workers/lobby_create/mod.rs
Original file line number Diff line number Diff line change
@@ -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::*};
Expand Down Expand Up @@ -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)
Expand Down
1 change: 0 additions & 1 deletion svc/pkg/user-presence/worker/src/workers/leave.rs
Original file line number Diff line number Diff line change
@@ -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;

Expand Down