chore(site): fix generating examples

.gitattributes

@@ -19,6 +19,7 @@ engine/sdks/schema/** linguist-generated=false
 website/public/llms.txt linguist-generated=true
 website/public/llms-full.txt linguist-generated=true
 website/public/docs/**/*.md linguist-generated=true
+website/public/typedoc/**/* linguist-generated=true
 **/Cargo.lock linguist-generated=true
 
 # I refuse to admit there's more TypeScript than Rust in the codebase

biome.json

@@ -43,5 +43,56 @@
 				"noExplicitAny": "off"
 			}
 		}
-	}
+	},
+	"overrides": [
+		{
+			"includes": [
+				"rivetkit-typescript/packages/rivetkit/src/**/*",
+				"!rivetkit-typescript/packages/rivetkit/src/test/**/*"
+			],
+			"linter": {
+				"rules": {
+					"style": {
+						"noRestrictedImports": {
+							"level": "error",
+							"options": {
+								"paths": {
+									"node:crypto": "Use '@/utils/node' getNodeCrypto() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"node:fs": "Use '@/utils/node' getNodeFsSync() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"node:fs/promises": "Use '@/utils/node' getNodeFs() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"node:path": "Use '@/utils/node' getNodePath() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"node:os": "Use '@/utils/node' getNodeOs() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"node:child_process": "Use '@/utils/node' getNodeChildProcess() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"node:stream": "Use '@/utils/node' getNodeStream() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"node:net": "Use '@/utils/node' instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"node:url": "Use '@/utils/node' instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"crypto": "Use '@/utils/node' getNodeCrypto() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"fs": "Use '@/utils/node' getNodeFsSync() or getNodeFs() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"fs/promises": "Use '@/utils/node' getNodeFs() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"path": "Use '@/utils/node' getNodePath() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"os": "Use '@/utils/node' getNodeOs() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"child_process": "Use '@/utils/node' getNodeChildProcess() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"stream": "Use '@/utils/node' getNodeStream() instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"net": "Use '@/utils/node' instead. Direct Node.js imports are only allowed in src/utils/node.ts",
+									"url": "Use '@/utils/node' instead. Direct Node.js imports are only allowed in src/utils/node.ts"
+								}
+							}
+						}
+					}
+				}
+			}
+		},
+		{
+			"includes": [
+				"rivetkit-typescript/packages/rivetkit/src/utils/node.ts"
+			],
+			"linter": {
+				"rules": {
+					"style": {
+						"noRestrictedImports": "off"
+					}
+				}
+			}
+		}
+	]
 }

engine/package.json

@@ -1,28 +1,11 @@
 {
 	"name": "@rivetkit/engine",
-	"private": true,
+	"version": "1.0.0",
+	"keywords": [],
+	"author": "",
+	"license": "ISC",
 	"packageManager": "pnpm@10.13.1",
-	"scripts": {
-		"start": "npx turbo watch build",
-		"build": "npx turbo build",
-		"test": "npx turbo test",
-		"test:watch": "npx turbo watch test",
-		"check-types": "npx turbo check-types",
-		"fmt": "pnpm biome check --write --diagnostic-level=error ."
-	},
-	"devDependencies": {
-		"@bare-ts/tools": "0.15.0",
-		"@biomejs/biome": "^2.2.3",
-		"lefthook": "^1.12.4",
-		"tsup": "^8.5.0",
-		"turbo": "^2.5.6",
-		"typescript": "^5.9.2"
-	},
 	"dependencies": {
-		"@sentry/vite-plugin": "^2.23.1"
-	},
-	"resolutions": {
-		"rivetkit": "workspace:*",
-		"@clerk/shared": "3.27.1"
+		"@vbare/compiler": "^0.0.3"
 	}
 }

engine/packages/api-peer/Cargo.toml

@@ -8,6 +8,7 @@ license.workspace = true
 [dependencies]
 anyhow.workspace = true
 axum.workspace = true
+base64.workspace = true
 gas.workspace = true
 epoxy.workspace = true
 futures-util.workspace = true
@@ -27,6 +28,7 @@ tokio.workspace = true
 tracing.workspace = true
 namespace.workspace = true
 pegboard.workspace = true
+pegboard-actor-kv.workspace = true
 universalpubsub.workspace = true
 uuid.workspace = true
 utoipa.workspace = true

engine/packages/api-peer/src/actors/kv_get.rs

@@ -0,0 +1,67 @@
+use anyhow::*;
+use base64::prelude::BASE64_STANDARD;
+use base64::Engine;
+use pegboard_actor_kv as actor_kv;
+use rivet_api_builder::ApiCtx;
+use rivet_util::Id;
+use serde::{Deserialize, Serialize};
+use utoipa::ToSchema;
+
+#[derive(Deserialize)]
+#[serde(deny_unknown_fields)]
+pub struct KvGetPath {
+	pub actor_id: Id,
+	pub key: String,
+}
+
+#[derive(Debug, Deserialize, Serialize)]
+#[serde(deny_unknown_fields)]
+pub struct KvGetQuery {}
+
+#[derive(Serialize, ToSchema)]
+#[schema(as = ActorsKvGetResponse)]
+pub struct KvGetResponse {
+	/// Value encoded in base 64.
+	pub value: String,
+	pub update_ts: i64,
+}
+
+#[utoipa::path(
+	get,
+	operation_id = "actors_kv_get",
+	path = "/actors/{actor_id}/kv/keys/{key}",
+	params(
+		("actor_id" = Id, Path),
+		("key" = String, Path),
+	),
+	responses(
+		(status = 200, body = KvGetResponse),
+	),
+)]
+#[tracing::instrument(skip_all)]
+pub async fn kv_get(ctx: ApiCtx, path: KvGetPath, _query: KvGetQuery) -> Result<KvGetResponse> {
+	// Decode base64 key
+	let key_bytes = BASE64_STANDARD
+		.decode(&path.key)
+		.context("failed to decode base64 key")?;
+
+	// Get the KV value
+	let udb = ctx.pools().udb()?;
+	let (keys, values, metadata) =
+		actor_kv::get(&*udb, path.actor_id, vec![key_bytes.clone()]).await?;
+
+	// Check if key was found
+	if keys.is_empty() {
+		return Err(pegboard::errors::Actor::KvKeyNotFound.build());
+	}
+
+	// Encode value as base64
+	let value_base64 = BASE64_STANDARD.encode(&values[0]);
+
+	Ok(KvGetResponse {
+		value: value_base64,
+		// NOTE: Intentionally uses different name in public API. `create_ts` is actually
+		// `update_ts`.
+		update_ts: metadata[0].create_ts,
+	})
+}

engine/packages/api-peer/src/actors/mod.rs

@@ -1,4 +1,5 @@
 pub mod create;
 pub mod delete;
+pub mod kv_get;
 pub mod list;
 pub mod list_names;

engine/packages/api-peer/src/router.rs

@@ -26,6 +26,10 @@ pub async fn router(
 			.route("/actors", post(actors::create::create))
 			.route("/actors/{actor_id}", delete(actors::delete::delete))
 			.route("/actors/names", get(actors::list_names::list_names))
+			.route(
+				"/actors/{actor_id}/kv/keys/{key}",
+				get(actors::kv_get::kv_get),
+			)
 			// MARK: Runners
 			.route("/runners", get(runners::list))
 			.route("/runners/names", get(runners::list_names))

engine/packages/api-public/Cargo.toml

@@ -30,6 +30,7 @@ serde.workspace = true
 tokio.workspace = true
 tower-http.workspace = true
 tracing.workspace = true
+urlencoding.workspace = true
 utoipa.workspace = true
 
 [build-dependencies]

engine/packages/api-public/src/actors/kv_get.rs

@@ -0,0 +1,75 @@
+use anyhow::Result;
+use axum::response::{IntoResponse, Response};
+use rivet_api_builder::{
+	ApiError,
+	extract::{Extension, Path},
+};
+use rivet_api_util::request_remote_datacenter_raw;
+use rivet_util::Id;
+use serde::{Deserialize, Serialize};
+use utoipa::ToSchema;
+
+use crate::ctx::ApiCtx;
+
+#[derive(Deserialize)]
+#[serde(deny_unknown_fields)]
+pub struct KvGetPath {
+	pub actor_id: Id,
+	pub key: String,
+}
+
+#[derive(Serialize, ToSchema)]
+#[schema(as = ActorsKvGetResponse)]
+pub struct KvGetResponse {
+	pub value: String,
+	pub update_ts: i64,
+}
+
+#[utoipa::path(
+	get,
+	operation_id = "actors_kv_get",
+	path = "/actors/{actor_id}/kv/keys/{key}",
+	params(
+		("actor_id" = Id, Path),
+		("key" = String, Path),
+	),
+	responses(
+		(status = 200, body = KvGetResponse),
+	),
+	security(("bearer_auth" = [])),
+)]
+#[tracing::instrument(skip_all)]
+pub async fn kv_get(Extension(ctx): Extension<ApiCtx>, Path(path): Path<KvGetPath>) -> Response {
+	match kv_get_inner(ctx, path).await {
+		Ok(response) => response,
+		Err(err) => ApiError::from(err).into_response(),
+	}
+}
+
+#[tracing::instrument(skip_all)]
+async fn kv_get_inner(ctx: ApiCtx, path: KvGetPath) -> Result<Response> {
+	use axum::Json;
+
+	ctx.auth().await?;
+
+	if path.actor_id.label() == ctx.config().dc_label() {
+		let peer_path = rivet_api_peer::actors::kv_get::KvGetPath {
+			actor_id: path.actor_id,
+			key: path.key,
+		};
+		let peer_query = rivet_api_peer::actors::kv_get::KvGetQuery {};
+		let res = rivet_api_peer::actors::kv_get::kv_get(ctx.into(), peer_path, peer_query).await?;
+
+		Ok(Json(res).into_response())
+	} else {
+		request_remote_datacenter_raw(
+			&ctx,
+			path.actor_id.label(),
+			&format!("/actors/{}/kv/keys/{}", path.actor_id, urlencoding::encode(&path.key)),
+			axum::http::Method::GET,
+			Option::<&()>::None,
+			Option::<&()>::None,
+		)
+		.await
+	}
+}