feat: [DT-033] - [F32] Move actor-keyed module-level maps off process globals in native.ts

Author: NathanFlurry

rivetkit-typescript/CLAUDE.md

@@ -82,6 +82,7 @@ The log name matches the key in `ActorMetrics.startup`. Internal phases use `per
 - On this branch, the native TS actor/conn persistence glue still lives in `packages/rivetkit/src/registry/native.ts`; PRD references to split `state-manager.ts` or `connection-manager.ts` files may be stale, so land equivalent behavior in `registry/native.ts` unless those modules reappear first.
 - Public TS actor `onWake` maps to the native callback bag's `onWake`; `onBeforeActorStart` is an internal driver/NAPI startup hook, not public actor config.
 - Static actor `state` values in `packages/rivetkit/src/registry/native.ts` must be `structuredClone(...)`d per actor instance; reusing the literal leaks mutations across different keyed actors.
+- JS-only native actor caches in `packages/rivetkit/src/registry/native.ts` should live on `ActorContext.runtimeState()`, not on actorId-keyed module globals. Same-key recreates must get a fresh bag.
 - Every `NativeConnAdapter` construction path in `packages/rivetkit/src/registry/native.ts` must keep the `CONN_STATE_MANAGER_SYMBOL` hookup; hibernatable conn mutations rely on core `ConnHandle::set_state` dirty tracking to request persistence.
 - Durable native actor saves in `packages/rivetkit/src/registry/native.ts` must use `ctx.requestSaveAndWait({ immediate: true })`; state bytes are collected only through the `serializeState` callback.
 - Opaque user payloads that must preserve JS `undefined` across Rust JSON/CBOR bridges should go through `encodeCborCompat` / `decodeCborCompat`; do not use those helpers on structural JSON envelopes where omitted fields must stay omitted.

rivetkit-typescript/packages/rivetkit-napi/index.d.ts

@@ -212,6 +212,7 @@ export declare class ActorContext {
   broadcast(name: string, args: Buffer): void
   waitUntil(promise: Promise<any>): Promise<void>
   registerTask(promise: Promise<any>): void
+  runtimeState(): object
 }
 export declare class NapiActorFactory {
   constructor(callbacks: object, config?: JsActorConfig | undefined | null)

rivetkit-typescript/packages/rivetkit-napi/src/actor_context.rs

@@ -13,7 +13,7 @@ use napi::bindgen_prelude::{Buffer, Promise};
 use napi::threadsafe_function::{
 	ErrorStrategy, ThreadSafeCallContext, ThreadsafeFunction, ThreadsafeFunctionCallMode,
 };
-use napi::{Env, JsFunction, JsObject};
+use napi::{Env, JsFunction, JsObject, Ref};
 use napi_derive::napi;
 use parking_lot::Mutex;
 use rivetkit_core::types::ActorKeySegment;
@@ -57,6 +57,7 @@ struct ActorContextShared {
 	abort_token: Mutex<Option<CoreCancellationToken>>,
 	run_restart: Mutex<Option<RunRestartHook>>,
 	task_sender: Mutex<Option<UnboundedSender<RegisteredTask>>>,
+	runtime_state: Mutex<Option<Ref<()>>>,
 	end_reason: Mutex<Option<EndReason>>,
 	websocket_callback_regions: Mutex<BTreeMap<u32, WebSocketCallbackRegion>>,
 	next_websocket_callback_region_id: AtomicU32,
@@ -630,6 +631,11 @@ impl ActorContext {
 			}))
 			.map_err(napi_anyhow_error)
 	}
+
+	#[napi]
+	pub fn runtime_state(&self, env: Env) -> napi::Result<JsObject> {
+		self.shared.runtime_state(env)
+	}
 }
 
 impl Drop for ActorContext {
@@ -692,6 +698,18 @@ impl ActorContextShared {
 		self.run_restart.lock().is_some()
 	}
 
+	fn runtime_state(&self, env: Env) -> napi::Result<JsObject> {
+		let mut runtime_state = self.runtime_state.lock();
+		if let Some(reference) = runtime_state.as_ref() {
+			return env.get_reference_value(reference);
+		}
+
+		let reference = env.create_reference(env.create_object()?)?;
+		let state = env.get_reference_value(&reference)?;
+		*runtime_state = Some(reference);
+		Ok(state)
+	}
+
 	#[allow(dead_code)]
 	fn set_end_reason(&self, reason: EndReason) {
 		*self.end_reason.lock() = Some(reason);
@@ -748,6 +766,7 @@ impl ActorContextShared {
 		*self.abort_token.lock() = None;
 		*self.run_restart.lock() = None;
 		*self.task_sender.lock() = None;
+		*self.runtime_state.lock() = None;
 		*self.end_reason.lock() = None;
 		*self.websocket_callback_regions.lock() = BTreeMap::new();
 		self.next_websocket_callback_region_id

rivetkit-typescript/packages/rivetkit/fixtures/driver-test-suite/destroy.ts

@@ -19,6 +19,7 @@ export const destroyObserver = actor({
 
 export const destroyActor = actor({
 	state: { value: 0, key: "" },
+	createVars: () => ({ ephemeral: "fresh" }),
 	queues: {
 		values: queue<number>(),
 	},
@@ -60,6 +61,13 @@ export const destroyActor = actor({
 		getValue: (c) => {
 			return c.state.value;
 		},
+		setEphemeral: (c, value: string) => {
+			c.vars.ephemeral = value;
+			return c.vars.ephemeral;
+		},
+		getEphemeral: (c) => {
+			return c.vars.ephemeral;
+		},
 		receiveValue: async (c) => {
 			const message = await c.queue.next({
 				names: ["values"],