feat: routes

Author: NathanFlurry

CLAUDE.md

@@ -0,0 +1,2 @@
+- Do not use cat, hexdump, perl, or sed. Always edit files directly.
+- If attempting to use Cargo, use `nix-shell --command 'cargo ...'`

Cargo.lock

@@ -131,6 +131,7 @@ services:
     restart: unless-stopped
     command: /usr/bin/rivet-guard
     environment:
+      - RUST_LOG=debug
       - RUST_BACKTRACE=1
       - RUST_LOG_ANSI_COLOR=1
       - RIVET_OTEL_ENABLED=1

Cargo.toml

@@ -0,0 +1,26 @@
+# Build stage
+FROM node:22 as builder
+WORKDIR /app
+COPY package.json yarn.lock ./
+RUN yarn install
+COPY . .
+RUN yarn build
+
+# Production stage
+FROM node:22-slim
+WORKDIR /app
+
+# Create rivet user and set proper permissions
+RUN groupadd -r rivet && useradd -r -g rivet rivet
+COPY package.json yarn.lock ./
+RUN yarn install --production && \
+    chown -R rivet:rivet /app
+
+COPY --from=builder /app/dist ./dist
+RUN chown -R rivet:rivet /app/dist
+
+# Switch to non-root user
+USER rivet
+
+# Start the server
+CMD ["node", "dist/src/container/main.js"]

docker/dev-full/docker-compose.yml

@@ -0,0 +1,22 @@
+# System Test
+
+Actors for simple tests of E2E system functionality.
+
+## Prerequisites
+
+- [Rivet CLI](https://rivet.gg/docs/setup)
+
+## Deploying
+
+```sh
+rivet deploy
+```
+
+## Testing
+
+```sh
+BUILD=ws-isolate rivet shell -e "yarn test"
+# or
+BUILD=ws-container rivet shell -e "yarn test"
+```
+

examples/system-test/.dockerignore renamed to examples/system-test-actor/.dockerignore

@@ -0,0 +1,28 @@
+{
+	"name": "system-test-route",
+	"version": "1.0.0",
+	"private": true,
+	"type": "module",
+	"dependencies": {
+		"@hono/node-server": "^1.13.8",
+		"@hono/node-ws": "^1.1.0",
+		"hono": "^4.6.17"
+	},
+	"devDependencies": {
+		"@rivet-gg/actor-core": "^5.1.2",
+		"@rivet-gg/api-full": "workspace:*",
+		"@types/deno": "^2.2.0",
+		"@types/node": "^22.13.9",
+		"@types/ws": "^8.18.0",
+		"node-fetch": "^3.3.2",
+		"tsx": "^4.7.0",
+		"typescript": "^5.3.3",
+		"ws": "^8.18.1"
+	},
+	"scripts": {
+		"test-isolate": "BUILD=http-isolate tsx tests/client.ts",
+		"test-container": "BUILD=http-container tsx tests/client.ts",
+		"test": "npm run test-isolate",
+		"build": "tsc --outDir dist"
+	}
+}

examples/system-test/Dockerfile renamed to examples/system-test-actor/Dockerfile

@@ -0,0 +1,10 @@
+{
+	"builds": {
+		"http-isolate": {
+			"script": "src/isolate/main.ts"
+		},
+		"http-container": {
+			"dockerfile": "Dockerfile"
+		}
+	}
+}

examples/system-test/README.md renamed to examples/system-test-actor/README.md

@@ -0,0 +1,14 @@
+import { serve } from "@hono/node-server";
+import { createNodeWebSocket } from "@hono/node-ws";
+import { createAndStartServer } from "../shared/server.js";
+
+let injectWebSocket: any;
+const { app, port } = createAndStartServer((app) => {
+	// Get Node.js WebSocket handler
+	const result = createNodeWebSocket({ app });
+	injectWebSocket = result.injectWebSocket;
+	return result.upgradeWebSocket;
+});
+
+const server = serve({ fetch: app.fetch, port });
+injectWebSocket(server);

examples/system-test/package.json renamed to examples/system-test-actor/package.json

@@ -0,0 +1,22 @@
+import type { ActorContext } from "@rivet-gg/actor-core";
+import { upgradeWebSocket } from "hono/deno";
+import { createAndStartServer } from "../shared/server.js";
+
+// Start server
+export default {
+	async start(ctx: ActorContext) {
+		console.log("Isolate starting");
+
+		// Create and start server with Deno WebSocket upgrader
+		console.log("Starting HTTP server");
+		const { app, port } = createAndStartServer(() => upgradeWebSocket, ctx.metadata.actor.id);
+
+		const server = Deno.serve(
+			{
+				port,
+			},
+			app.fetch,
+		);
+		await server.finished;
+	},
+};

examples/system-test/rivet.jsonc renamed to examples/system-test-actor/rivet.jsonc

@@ -0,0 +1,54 @@
+import { type Context, Hono } from "hono";
+import type { UpgradeWebSocket } from "hono/ws";
+
+type GetUpgradeWebSocketFn = (app: Hono) => UpgradeWebSocket;
+
+export function createAndStartServer(
+	getUpgradeWebSocket: GetUpgradeWebSocketFn,
+	actorId: string,
+): { app: Hono; port: number } {
+	// Setup auto-exit timer
+	setTimeout(() => {
+		console.error(
+			"Actor should've been destroyed by now. Automatically exiting.",
+		);
+
+		if (typeof Deno !== "undefined") Deno.exit(1);
+		else process.exit(1);
+	}, 60 * 1000);
+
+	let tickIndex = 0;
+	setInterval(() => {
+		tickIndex++;
+		console.log("Tick", tickIndex);
+	}, 1000);
+
+	// Get port from environment
+	const portEnv =
+		typeof Deno !== "undefined"
+			? Deno.env.get("PORT_HTTP")
+			: process.env.PORT_HTTP;
+	if (!portEnv) {
+		throw new Error("missing PORT_HTTP");
+	}
+	const port = Number.parseInt(portEnv);
+
+	// Create app with health endpoint
+	const app = new Hono();
+
+	app.get("/health", (c) => c.text("ok"));
+	
+	// Add a catch-all route to handle any other path (for testing routeSubpaths)
+	app.all("*", (c) => {
+		console.log(`Received request to ${c.req.url} from ${c.req.header("x-forwarded-for") || "unknown"}`);
+		return c.json({ 
+			actorId, 
+			path: c.req.path,
+			query: c.req.query()
+		});
+	});
+
+	console.log(`Listening on port ${port}, Actor ID: ${actorId}`);
+
+	return { app, port };
+}