fix(engine/fe): remove addresses

.github/workflows/release.yaml

@@ -79,22 +79,22 @@ jobs:
       matrix:
         include:
           - platform: linux
-            runner: ubuntu-latest
+            runner: depot-ubuntu-24.04
             target: x86_64-unknown-linux-musl
             binary_ext: ""
             arch: x86_64
           - platform: windows
-            runner: ubuntu-latest
+            runner: depot-ubuntu-24.04
             target: x86_64-pc-windows-gnu
             binary_ext: ".exe"
             arch: x86_64
           - platform: macos
-            runner: ubuntu-latest
+            runner: depot-ubuntu-24.04
             target: x86_64-apple-darwin
             binary_ext: ""
             arch: x86_64
           - platform: macos
-            runner: ubuntu-latest
+            runner: depot-ubuntu-24.04
             target: aarch64-apple-darwin
             binary_ext: ""
             arch: aarch64
@@ -155,10 +155,10 @@ jobs:
         include:
           # TODO(RVT-4479): Add back ARM builder once manifest generation fixed
           # - platform: linux/arm64
-          #   runner: ubuntu-latest
+          #   runner: depot-ubuntu-24.04
           #   arch_suffix: -arm64
           - platform: linux/x86_64
-            runner: ubuntu-latest
+            runner: depot-ubuntu-24.04
             # TODO: Replace with appropriate arch_suffix when needed
             # arch_suffix: -amd64
             arch_suffix: ''
@@ -246,4 +246,4 @@ jobs:
               ./scripts/release/main.ts --version "${{ github.event.inputs.version }}" --completeCi
           else
               ./scripts/release/main.ts --version "${{ github.event.inputs.version }}" --no-latest --completeCi
-          fi
+          fi

.github/workflows/rust.yml

@@ -43,7 +43,7 @@ jobs:
 
   # clippy:
   #   name: Clippy
-  #   runs-on: ubuntu-latest
+  #   runs-on: depot-ubuntu-24.04
   #   steps:
   #     - uses: actions/checkout@v4
 
@@ -59,7 +59,7 @@ jobs:
 
   check:
     name: Check
-    runs-on: ubuntu-latest
+    runs-on: depot-ubuntu-24.04
     steps:
       - uses: actions/checkout@v4
 
@@ -77,7 +77,7 @@ jobs:
 
   test:
     name: Test
-    runs-on: ubuntu-latest
+    runs-on: depot-ubuntu-24.04
     steps:
       - uses: actions/checkout@v4
 

frontend/src/routes/_layout/ns.$namespace/runners.tsx

@@ -71,7 +71,6 @@ function RouteComponent() {
 								<TableRow>
 									<TableHead>ID</TableHead>
 									<TableHead>Name</TableHead>
-									<TableHead>HTTP</TableHead>
 									<TableHead>Slots</TableHead>
 									<TableHead>Last ping</TableHead>
 									<TableHead>Created</TableHead>
@@ -155,19 +154,11 @@ function RowSkeleton() {
 			<TableCell>
 				<Skeleton className="w-full h-4" />
 			</TableCell>
-			<TableCell>
-				<Skeleton className="w-full h-4" />
-			</TableCell>
 		</TableRow>
 	);
 }
 
-const MAX_TO_SHOW = 2;
-
 function Row(runner: Rivet.Runner) {
-	const [isExpanded, setExpanded] = useState(false);
-	const addresses = Object.values(runner.addressesHttp);
-
 	return (
 		<TableRow key={runner.runnerId}>
 			<TableCell>
@@ -186,36 +177,6 @@ function Row(runner: Rivet.Runner) {
 				</DiscreteCopyButton>
 			</TableCell>
 
-			<TableCell>
-				<div className="flex gap-1 flex-wrap">
-					{addresses
-						.slice(0, isExpanded ? addresses.length : MAX_TO_SHOW)
-						.map((http) => {
-							const address = `${http.hostname}:${http.port}`;
-							return (
-								<DiscreteCopyButton
-									className="justify-start"
-									size="sm"
-									key={address}
-									value={address}
-								>
-									{address}
-								</DiscreteCopyButton>
-							);
-						})}
-
-					{addresses.length > MAX_TO_SHOW && !isExpanded ? (
-						<Button
-							variant="ghost"
-							size="sm"
-							onClick={() => setExpanded(!isExpanded)}
-						>
-							+{addresses.length - MAX_TO_SHOW}
-						</Button>
-					) : null}
-				</div>
-			</TableCell>
-
 			<TableCell>
 				{runner.remainingSlots}/{runner.totalSlots}
 			</TableCell>

packages/common/test-deps-docker/src/lib.rs

@@ -73,6 +73,114 @@ impl DockerRunConfig {
 		Ok(true)
 	}
 
+	pub async fn restart(&self) -> Result<()> {
+		let container_id = self
+			.container_id
+			.as_ref()
+			.ok_or_else(|| anyhow!("No container ID found, container not started"))?;
+
+		tracing::debug!(
+			container_name = %self.container_name,
+			container_id = %container_id,
+			"restarting docker container"
+		);
+
+		let output = Command::new("docker")
+			.arg("restart")
+			.arg(container_id)
+			.output()
+			.await?;
+
+		if !output.status.success() {
+			let stderr = String::from_utf8_lossy(&output.stderr);
+			anyhow::bail!(
+				"Failed to restart container {}: {}",
+				self.container_name,
+				stderr
+			);
+		}
+
+		tracing::debug!(
+			container_name = %self.container_name,
+			container_id = %container_id,
+			"container restarted successfully"
+		);
+
+		Ok(())
+	}
+
+	pub async fn stop_container(&self) -> Result<()> {
+		let container_id = self
+			.container_id
+			.as_ref()
+			.ok_or_else(|| anyhow!("No container ID found, container not started"))?;
+
+		tracing::debug!(
+			container_name = %self.container_name,
+			container_id = %container_id,
+			"stopping docker container"
+		);
+
+		let output = Command::new("docker")
+			.arg("stop")
+			.arg(container_id)
+			.output()
+			.await?;
+
+		if !output.status.success() {
+			let stderr = String::from_utf8_lossy(&output.stderr);
+			anyhow::bail!(
+				"Failed to stop container {}: {}",
+				self.container_name,
+				stderr
+			);
+		}
+
+		tracing::debug!(
+			container_name = %self.container_name,
+			container_id = %container_id,
+			"container stopped successfully"
+		);
+
+		Ok(())
+	}
+
+	pub async fn start_container(&self) -> Result<()> {
+		let container_id = self
+			.container_id
+			.as_ref()
+			.ok_or_else(|| anyhow!("No container ID found, container not started"))?;
+
+		tracing::debug!(
+			container_name = %self.container_name,
+			container_id = %container_id,
+			"starting docker container"
+		);
+
+		let output = Command::new("docker")
+			.arg("start")
+			.arg(container_id)
+			.output()
+			.await?;
+
+		if !output.status.success() {
+			let stderr = String::from_utf8_lossy(&output.stderr);
+			anyhow::bail!(
+				"Failed to start container {}: {}",
+				self.container_name,
+				stderr
+			);
+		}
+
+		tracing::debug!(
+			container_name = %self.container_name,
+			container_id = %container_id,
+			"container started successfully"
+		);
+
+		Ok(())
+	}
+
 	pub fn container_id(&self) -> Option<&str> {
 		self.container_id.as_deref()
 	}

packages/common/universalpubsub/Cargo.toml

@@ -12,15 +12,16 @@ async-trait.workspace = true
 base64.workspace = true
 deadpool-postgres.workspace = true
 futures-util.workspace = true
-moka.workspace = true
 rivet-error.workspace = true
 rivet-ups-protocol.workspace = true
+rivet-util.workspace = true
 serde_json.workspace = true
 versioned-data-util.workspace = true
 serde.workspace = true
 sha2.workspace = true
 tokio-postgres.workspace = true
 tokio.workspace = true
+tokio-util.workspace = true
 tracing.workspace = true
 uuid.workspace = true