fix(rivetkit): isolate engine envoys and propagate startup failures

Author: NathanFlurry

engine/sdks/rust/envoy-client/src/envoy.rs

@@ -135,7 +135,10 @@ impl EnvoyContext {
 
 pub async fn start_envoy(config: EnvoyConfig) -> EnvoyHandle {
 	let handle = start_envoy_sync(config);
-	handle.started().await;
+	handle
+		.started()
+		.await
+		.expect("envoy failed to start before returning handle");
 	handle
 }
 

engine/sdks/rust/envoy-client/src/handle.rs

@@ -33,8 +33,13 @@ impl EnvoyHandle {
 		&self.shared.envoy_key
 	}
 
-	pub async fn started(&self) {
-		let _ = self.started_rx.clone().changed().await;
+	pub async fn started(&self) -> anyhow::Result<()> {
+		self.started_rx
+			.clone()
+			.changed()
+			.await
+			.map_err(|_| anyhow::anyhow!("envoy stopped before startup completed"))?;
+		Ok(())
 	}
 
 	pub fn sleep_actor(&self, actor_id: String, generation: Option<u32>) {
@@ -310,7 +315,7 @@ impl EnvoyHandle {
 		}
 
 		// Wait for envoy to be started before injecting
-		self.started().await;
+		self.started().await?;
 
 		tracing::debug!(
 			data = crate::stringify::stringify_to_envoy(&message),

rivetkit-typescript/packages/rivetkit-native/src/envoy_handle.rs

@@ -58,6 +58,7 @@ impl JsEnvoyHandle {
 		self.runtime
 			.spawn(async move { handle.started().await })
 			.await
+			.map_err(|e| napi::Error::from_reason(e.to_string()))?
 			.map_err(|e| napi::Error::from_reason(e.to_string()))
 	}
 

rivetkit-typescript/packages/rivetkit/src/drivers/engine/actor-driver.ts

@@ -185,6 +185,7 @@ export class EngineActorDriver implements ActorDriver {
 			token: config.token,
 			namespace: config.namespace,
 			poolName: config.envoy.poolName,
+			notGlobal: true,
 			metadata: {
 				rivetkit: { version: VERSION },
 			},
@@ -211,9 +212,14 @@ export class EngineActorDriver implements ActorDriver {
 
 		this.#envoy = envoy;
 
-		envoy.started().then(() => {
-			this.#envoyStarted.resolve();
-		});
+		envoy.started().then(
+			() => {
+				this.#envoyStarted.resolve();
+			},
+			(error) => {
+				this.#envoyStarted.reject(error);
+			},
+		);
 
 		logger().debug({
 			msg: "envoy client started",