chore: pricing page

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

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

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

@@ -5,6 +5,11 @@ use futures_util::StreamExt;
 use gas::prelude::*;
 use http_body_util::{BodyExt, Full};
 use hyper::{Request, Response, StatusCode, header::HeaderName};
+use hyper_tungstenite::HyperWebsocket;
+use pegboard::pubsub_subjects::{
+	TunnelHttpResponseSubject, TunnelHttpRunnerSubject, TunnelHttpWebSocketSubject,
+};
+use rivet_error::*;
 use rivet_guard_core::{
 	WebSocketHandle,
 	custom_serve::CustomServeTrait,
@@ -13,8 +18,25 @@ use rivet_guard_core::{
 	request_context::RequestContext,
 };
 use rivet_runner_protocol as protocol;
+use rivet_tunnel_protocol::{
+	MessageBody, StreamFinishReason, ToServerRequestFinish, ToServerRequestStart,
+	ToServerWebSocketClose, ToServerWebSocketMessage, ToServerWebSocketOpen, TunnelMessage,
+	versioned,
+};
 use rivet_util::serde::HashableMap;
-use std::time::Duration;
+use std::result::Result::Ok as ResultOk;
+use std::{
+	collections::HashMap,
+	sync::{
+		Arc,
+		atomic::{AtomicU64, Ordering},
+	},
+	time::Duration,
+};
+use tokio::{
+	sync::{Mutex, oneshot},
+	time::timeout,
+};
 use tokio_tungstenite::tungstenite::Message;
 
 use crate::shared_state::{SharedState, TunnelMessageData};

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

@@ -4,9 +4,9 @@
 };
 use futures_util::TryStreamExt;
 use gas::prelude::*;
-use rivet_data::converted::ActorByKeyKeyData;
-use universaldb::options::StreamingMode;
-use universaldb::prelude::*;
+use rivet_key_data::converted::ActorByKeyKeyData;
+use udb_util::prelude::*;
+use universaldb::{self as udb, FdbBindingError, options::StreamingMode};
 
 use crate::keys;
 
@@ -81,7 +81,7 @@
 						name.clone(),
 						key.clone(),
 					)
 					.deserialize(&current_value)?;
 
 					handle_existing_reservation(
 						ctx,
@@ -156,7 +156,7 @@
 		.await?
 		.value;
 	if let Some(value) = value {
 		let reservation_id = reservation_key.deserialize(&value)?;
 		Ok(Some(reservation_id))
 	} else {
 		Ok(None)
@@ -190,7 +190,7 @@
 		input.name.clone(),
 		input.key.clone(),
 	);
 	let reservation_value = reservation_key.serialize(input.new_reservation_id)?;
 
 	let proposal_result = ctx
 		.op(epoxy::ops::propose::Input {
@@ -247,7 +247,7 @@
 					mode: StreamingMode::Iterator,
 					..(start, end).into()
 				},
 				Serializable,
 			);
 
 			while let Some(entry) = stream.try_next().await? {