feat: serverless

Author: MasterPtato

examples/next-js/src/app/api/registry/[...all]/route.ts renamed to examples/next-js/src/app/api/rivet/[...all]/route.ts

@@ -1,4 +1,4 @@
 import { toNextHandler } from "@rivetkit/next-js";
 import { registry } from "@/rivet/registry";
 
-export const { GET, POST, HEAD, PATCH, OPTIONS } = toNextHandler(registry);
+export const { GET, POST, PUT, PATCH, HEAD, OPTIONS } = toNextHandler(registry);

packages/next-js/src/mod.ts

@@ -9,11 +9,22 @@ export const toNextHandler = (
 
 	const { fetch } = registry.start(inputConfig);
 
+	const fetchWrapper = async (request: Request, { params }: { params: Promise<{ all: string[] }> }) => {
+		const { all } = await params;
+
+		const newUrl = new URL(request.url);
+		newUrl.pathname = all.join('/');
+		const newReq = new Request(newUrl, request);
+
+		return await fetch(newReq);
+	};
+
 	return {
-		GET: fetch,
-		POST: fetch,
-		PATCH: fetch,
-		HEAD: fetch,
-		OPTIONS: fetch,
+		GET: fetchWrapper,
+		POST: fetchWrapper,
+		PUT: fetchWrapper,
+		PATCH: fetchWrapper,
+		HEAD: fetchWrapper,
+		OPTIONS: fetchWrapper,
 	};
 };

packages/rivetkit/src/common/versioned-data.ts

@@ -13,7 +13,7 @@ export interface VersionedDataConfig<T> {
 }
 
 export class VersionedDataHandler<T> {
-	constructor(private config: VersionedDataConfig<T>) {}
+	constructor(private config: VersionedDataConfig<T>) { }
 
 	serializeWithEmbeddedVersion(data: T): Uint8Array {
 		const versioned: VersionedData<Uint8Array> = {
@@ -63,8 +63,8 @@ export class VersionedDataHandler<T> {
 	}
 
 	private embedVersion(data: VersionedData<Uint8Array>): Uint8Array {
-		const versionBytes = new Uint8Array(4);
-		new DataView(versionBytes.buffer).setUint32(0, data.version, true);
+		const versionBytes = new Uint8Array(2);
+		new DataView(versionBytes.buffer).setUint16(0, data.version, true);
 
 		const result = new Uint8Array(versionBytes.length + data.data.length);
 		result.set(versionBytes);
@@ -74,15 +74,15 @@ export class VersionedDataHandler<T> {
 	}
 
 	private extractVersion(bytes: Uint8Array): VersionedData<Uint8Array> {
-		if (bytes.length < 4) {
+		if (bytes.length < 2) {
 			throw new Error("Invalid versioned data: too short");
 		}
 
-		const version = new DataView(bytes.buffer, bytes.byteOffset).getUint32(
+		const version = new DataView(bytes.buffer, bytes.byteOffset).getUint16(
 			0,
 			true,
 		);
-		const data = bytes.slice(4);
+		const data = bytes.slice(2);
 
 		return { version, data };
 	}

packages/rivetkit/src/manager/router.ts

@@ -54,10 +54,10 @@ function buildOpenApiResponses<T>(schema: T, validateBody: boolean) {
 			description: "Success",
 			content: validateBody
 				? {
-						"application/json": {
-							schema,
-						},
-					}
+					"application/json": {
+						schema,
+					},
+				}
 				: {},
 		},
 		400: {
@@ -151,6 +151,7 @@ export function createManagerRouter(
 				method: c.req.raw.method,
 				headers: proxyHeaders,
 				body: c.req.raw.body,
+				duplex: "half",
 				signal: c.req.raw.signal,
 			});
 
@@ -211,10 +212,10 @@ export function createManagerRouter(
 				body: {
 					content: validateBody
 						? {
-								"application/json": {
-									schema: ActorsGetOrCreateByIdRequestSchema,
-								},
-							}
+							"application/json": {
+								schema: ActorsGetOrCreateByIdRequestSchema,
+							},
+						}
 						: {},
 				},
 			},
@@ -323,10 +324,10 @@ export function createManagerRouter(
 				body: {
 					content: validateBody
 						? {
-								"application/json": {
-									schema: ActorsCreateRequestSchema,
-								},
-							}
+							"application/json": {
+								schema: ActorsCreateRequestSchema,
+							},
+						}
 						: {},
 				},
 			},
@@ -500,6 +501,7 @@ export function createManagerRouter(
 						method: c.req.method,
 						headers: c.req.raw.headers,
 						body: c.req.raw.body,
+						duplex: "half",
 					}),
 				);
 
@@ -598,9 +600,9 @@ async function createTestWebSocketProxy(
 			onOpen: (_evt, serverWs) => {
 				serverWs.close(1011, "Failed to establish connection");
 			},
-			onMessage: () => {},
-			onError: () => {},
-			onClose: () => {},
+			onMessage: () => { },
+			onError: () => { },
+			onClose: () => { },
 		};
 	}
 

packages/rivetkit/src/remote-manager-driver/actor-http-client.ts

@@ -17,7 +17,6 @@ export async function sendHttpRequestToActor(
 	const guardHeaders = buildGuardHeadersForHttp(actorRequest, actorId);
 
 	if (
-		actorRequest.body &&
 		actorRequest.method !== "GET" &&
 		actorRequest.method !== "HEAD"
 	) {
@@ -27,17 +26,19 @@ export async function sendHttpRequestToActor(
 
 		// TODO: This buffers the entire request in memory every time. We
 		// need to properly implement streaming bodies.
-		// Clone and read the body to ensure it can be sent
-		const clonedRequest = actorRequest.clone();
-		bodyToSend = await clonedRequest.arrayBuffer();
+		const reqBody = await actorRequest.arrayBuffer();
 
-		// If this is a streaming request, we need to convert the headers
-		// for the basic array buffer
-		guardHeaders.delete("transfer-encoding");
-		guardHeaders.set(
-			"content-length",
-			String((bodyToSend as ArrayBuffer).byteLength),
-		);
+		if (reqBody.byteLength != 0) {
+			bodyToSend = reqBody;
+
+			// If this is a streaming request, we need to convert the headers
+			// for the basic array buffer
+			guardHeaders.delete("transfer-encoding");
+			guardHeaders.set(
+				"content-length",
+				String(bodyToSend.byteLength),
+			);
+		}
 	}
 
 	const guardRequest = new Request(guardUrl, {

packages/rivetkit/src/remote-manager-driver/mod.ts

@@ -149,7 +149,7 @@ export class RemoteManagerDriver implements ManagerDriver {
 			name,
 			key: serializeActorKey(key),
 			runner_name_selector: this.#config.runnerName,
-			input: input ? cbor.encode(actorInput).toString("base64") : undefined,
+			input: actorInput ? cbor.encode(actorInput).toString("base64") : undefined,
 			crash_policy: "sleep",
 		});
 

scripts/nuke-cache.sh

@@ -0,0 +1,74 @@
+#!/bin/bash
+
+# Clear JavaScript-related cache folders recursively
+# Usage: ./clear_js_cache.sh [directory]
+
+# Set the target directory (default to current directory)
+TARGET_DIR="${1:-.}"
+
+# Colors for output
+RED='\033[0;31m'
+GREEN='\033[0;32m'
+YELLOW='\033[1;33m'
+NC='\033[0m' # No Color
+
+echo -e "${YELLOW}Clearing JavaScript cache folders in: $TARGET_DIR${NC}"
+
+# Counter for removed folders
+removed_count=0
+
+# Function to safely remove directory
+remove_dir() {
+    local dir="$1"
+    if [ -d "$dir" ]; then
+        echo -e "Removing: ${RED}$dir${NC}"
+        rm -rf "$dir"
+        ((removed_count++))
+    fi
+}
+
+# Find and remove cache folders
+while IFS= read -r -d '' dir; do
+    remove_dir "$dir"
+done < <(find "$TARGET_DIR" -type d \( \
+    -name "node_modules" -o \
+    -name ".next" -o \
+    -name ".nuxt" -o \
+    -name "dist" -o \
+    -name "build" -o \
+    -name ".cache" -o \
+    -name ".parcel-cache" -o \
+    -name ".webpack" -o \
+    -name ".rollup.cache" -o \
+    -name ".vite" -o \
+    -name ".turbo" -o \
+    -name ".nx" -o \
+    -name "coverage" -o \
+    -name ".nyc_output" -o \
+    -name "out" -o \
+    -name ".output" -o \
+    -name ".vercel" -o \
+    -name ".netlify" -o \
+    -name "storybook-static" \
+\) -print0)
+
+# Also remove common cache files
+echo -e "${YELLOW}Removing cache files...${NC}"
+find "$TARGET_DIR" -type f \( \
+    -name "*.log" -o \
+    -name ".DS_Store" -o \
+    -name "Thumbs.db" -o \
+    -name "*.tmp" -o \
+    -name "*.temp" \
+\) -delete 2>/dev/null
+
+# Remove package-lock.json and yarn.lock (optional - uncomment if needed)
+# find "$TARGET_DIR" -name "package-lock.json" -delete 2>/dev/null
+# find "$TARGET_DIR" -name "yarn.lock" -delete 2>/dev/null
+
+echo -e "${GREEN}✓ Cleanup complete! Removed $removed_count cache folders.${NC}"
+
+# Optional: Show disk space freed (requires du command)
+if command -v du >/dev/null 2>&1; then
+    echo -e "${YELLOW}Disk space check completed.${NC}"
+fi