chore: pricing page

packages/common/universalpubsub/src/driver/memory/mod.rs

@@ -4,7 +4,7 @@ use std::time::Duration;
 
 use anyhow::*;
 use async_trait::async_trait;
-use tokio::sync::{mpsc, RwLock};
+use tokio::sync::{RwLock, mpsc};
 use uuid::Uuid;
 
 use crate::driver::{PubSubDriver, SubscriberDriver, SubscriberDriverHandle};

packages/core/pegboard-gateway/src/lib.rs

@@ -4,7 +4,7 @@ use bytes::Bytes;
 use futures_util::{SinkExt, StreamExt};
 use gas::prelude::*;
 use http_body_util::{BodyExt, Full};
-use hyper::{body::Incoming as BodyIncoming, Request, Response, StatusCode};
+use hyper::{Request, Response, StatusCode, body::Incoming as BodyIncoming};
 use hyper_tungstenite::HyperWebsocket;
 use pegboard::pubsub_subjects::{
 	TunnelHttpResponseSubject, TunnelHttpRunnerSubject, TunnelHttpWebSocketSubject,
@@ -16,21 +16,22 @@ use rivet_guard_core::{
 	request_context::RequestContext,
 };
 use rivet_tunnel_protocol::{
-	versioned, MessageBody, StreamFinishReason, ToServerRequestFinish, ToServerRequestStart,
+	MessageBody, StreamFinishReason, ToServerRequestFinish, ToServerRequestStart,
 	ToServerWebSocketClose, ToServerWebSocketMessage, ToServerWebSocketOpen, TunnelMessage,
+	versioned,
 };
 use rivet_util::serde::HashableMap;
 use std::result::Result::Ok as ResultOk;
 use std::{
 	collections::HashMap,
 	sync::{
-		atomic::{AtomicU64, Ordering},
 		Arc,
+		atomic::{AtomicU64, Ordering},
 	},
 	time::Duration,
 };
 use tokio::{
-	sync::{oneshot, Mutex},
+	sync::{Mutex, oneshot},
 	time::timeout,
 };
 use tokio_tungstenite::tungstenite::Message;

packages/core/pegboard-tunnel/src/lib.rs

@@ -9,18 +9,18 @@ use gas::prelude::*;
 use http_body_util::Full;
 use hyper::body::{Bytes, Incoming as BodyIncoming};
 use hyper::{Request, Response, StatusCode};
-use hyper_tungstenite::tungstenite::protocol::frame::coding::CloseCode as WsCloseCode;
-use hyper_tungstenite::tungstenite::protocol::frame::CloseFrame as WsCloseFrame;
 use hyper_tungstenite::tungstenite::Utf8Bytes as WsUtf8Bytes;
-use hyper_tungstenite::{tungstenite::Message as WsMessage, HyperWebsocket};
+use hyper_tungstenite::tungstenite::protocol::frame::CloseFrame as WsCloseFrame;
+use hyper_tungstenite::tungstenite::protocol::frame::coding::CloseCode as WsCloseCode;
+use hyper_tungstenite::{HyperWebsocket, tungstenite::Message as WsMessage};
 use pegboard::pubsub_subjects::{
 	TunnelHttpResponseSubject, TunnelHttpRunnerSubject, TunnelHttpWebSocketSubject,
 };
 use rivet_guard_core::custom_serve::CustomServeTrait;
 use rivet_guard_core::proxy_service::ResponseBody;
 use rivet_guard_core::request_context::RequestContext;
 use rivet_pools::Pools;
-use rivet_tunnel_protocol::{versioned, MessageBody, TunnelMessage};
+use rivet_tunnel_protocol::{MessageBody, TunnelMessage, versioned};
 use rivet_util::Id;
 use std::net::SocketAddr;
 use tokio::net::TcpListener;

packages/services/pegboard/src/workflows/actor/actor_keys.rs

@@ -6,7 +6,7 @@ use futures_util::TryStreamExt;
 use gas::prelude::*;
 use rivet_key_data::converted::ActorByKeyKeyData;
 use udb_util::prelude::*;
-use universaldb::{self as udb, options::StreamingMode, FdbBindingError};
+use universaldb::{self as udb, FdbBindingError, options::StreamingMode};
 
 use crate::keys;