chore(core): update keys -> key

Author: NathanFlurry

packages/core/package.json

@@ -172,7 +172,7 @@
     "@hono/node-server": "^1.18.2",
     "@hono/node-ws": "^1.1.1",
     "@rivet-gg/actor-core": "^25.1.0",
-    "@rivetkit/engine-runner": "https://pkg.pr.new/rivet-gg/engine/@rivetkit/engine-runner@7f23f3a",
+    "@rivetkit/engine-runner": "https://pkg.pr.new/rivet-gg/engine/@rivetkit/engine-runner@f8860f3",
     "@types/invariant": "^2",
     "@types/node": "^22.13.1",
     "@types/ws": "^8",

packages/core/src/drivers/engine/actor-driver.ts

@@ -178,7 +178,10 @@ export class EngineActorDriver implements ActorDriver {
 		// TODO: Use alarm on sleep
 		// TODO: Send alarm to runner
 
-		throw new Error("Alarms not implemented for engine driver");
+		const delay = Math.max(timestamp - Date.now(), 0);
+		setTimeout(() => {
+			actor.onAlarm();
+		}, delay);
 	}
 
 	async getDatabase(_actorId: string): Promise<unknown | undefined> {

packages/core/src/drivers/engine/api-endpoints.ts

@@ -1,23 +1,16 @@
-import { CreateRequest } from "@/client/mod";
 import { apiCall } from "./api-utils";
 import type { Config } from "./config";
 import { serializeActorKey } from "./keys";
 
 // MARK: Common types
 export type RivetId = string;
 
-export interface ActorLifecycle {
-	kill_timeout_ms: number;
-	durable: boolean;
-}
-
 export interface Actor {
 	actor_id: RivetId;
 	name: string;
-	keys: string[];
+	key: string;
 	namespace_id: RivetId;
 	runner_name_selector: string;
-	lifecycle: ActorLifecycle;
 	create_ts: number;
 	connectable_ts?: number | null;
 	destroy_ts?: number | null;
@@ -46,9 +39,9 @@ export interface ActorsGetOrCreateByIdResponse {
 export interface ActorsCreateRequest {
 	name: string;
 	runner_name_selector: string;
-	keys?: string[] | null;
+	crash_policy: string;
+	key?: string | null;
 	input?: string | null;
-	durable?: boolean | null;
 }
 
 export interface ActorsCreateResponse {
@@ -86,10 +79,10 @@ export async function getActorById(
 // MARK: Get or create actor by id
 export interface ActorsGetOrCreateByIdRequest {
 	name: string;
-	keys: string[];
+	key: string;
 	runner_name_selector: string;
+	crash_policy: "restart";
 	input?: string | null;
-	durable?: boolean | null;
 }
 
 export async function getOrCreateActorById(

packages/core/src/drivers/engine/manager-driver.ts

@@ -157,7 +157,7 @@ export class EngineManagerDriver implements ManagerDriver {
 				return undefined;
 			}
 
-			const keyRaw = response.actor.keys[0];
+			const keyRaw = response.actor.key;
 			invariant(keyRaw, `actor ${actorId} should have key`);
 			const key = deserializeActorKey(keyRaw);
 
@@ -233,10 +233,10 @@ export class EngineManagerDriver implements ManagerDriver {
 
 		const response = await getOrCreateActorById(this.#config, {
 			name,
-			keys: [serializeActorKey(key)],
+			key: serializeActorKey(key),
 			runner_name_selector: this.#config.runnerName,
 			input: input ? cbor.encode(actorInput).toString("base64") : undefined,
-			durable: true,
+			crash_policy: "restart",
 		});
 
 		const actorId = response.actor_id;
@@ -273,9 +273,9 @@ export class EngineManagerDriver implements ManagerDriver {
 		const result = await createActor(this.#config, {
 			name,
 			runner_name_selector: this.#config.runnerName,
-			keys: [serializeActorKey(key)],
+			key: serializeActorKey(key),
 			input: input ? cbor.encode(input).toString("base64") : null,
-			durable: true,
+			crash_policy: "restart",
 		});
 		const actorId = result.actor.actor_id;
 

packages/core/tsup.config.ts

@@ -1,6 +1,4 @@
 import { defineConfig } from "tsup";
 import defaultConfig from "../../tsup.base.ts";
 
-export default defineConfig({
-	...defaultConfig,
-});
+export default defineConfig(defaultConfig);