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,21 @@
+# WebSocket
+
+Simple WebSocket implementation.
+
+## Prerequisites
+
+- [Rivet CLI](https://rivet.gg/docs/setup)
+
+## Deploying
+
+```sh
+rivet login
+rivet deploy
+```
+
+## Testing
+
+```sh
+rivet deno --populate-env run -A ws_test.ts
+```
+

docker/dev-full/docker-compose.yml

@@ -0,0 +1,9 @@
+{
+	"name": "example-functions",
+	"version": "1.0.0",
+	"private": true,
+	"dependencies": {
+		"@rivet-gg/actor": "^5.1.2",
+		"hono": "^4.6.17"
+	}
+}

examples/functions/README.md

@@ -0,0 +1,7 @@
+{
+	"functions": {
+		"simple": {
+			"script": "ws.ts"
+		}
+	}
+}

examples/functions/package.json

@@ -0,0 +1,13 @@
+{
+	"compilerOptions": {
+		"target": "ESNext",
+		"module": "ESNext",
+		"moduleResolution": "bundler",
+		"types": ["node", "deno"],
+		"allowSyntheticDefaultImports": true,
+		"esModuleInterop": true,
+		"noEmit": true,
+		"isolatedModules": true
+	},
+	"include": ["**/*.ts"]
+}

examples/functions/rivet.json

@@ -0,0 +1,33 @@
+import type { ActorContext } from "@rivet-gg/actor-core";
+import { Hono } from "hono";
+import { upgradeWebSocket } from "hono/deno";
+
+// Setup Hono app
+const app = new Hono();
+
+app.get("/", (c) => {
+	return c.text("ok");
+});
+
+
+app.get("/health", (c) => {
+	return c.text("ok");
+});
+
+
+// Start server
+export default {
+	async start(ctx: ActorContext) {
+		// Find port
+		const portEnv = Deno.env.get("PORT_HTTP");
+		if (!portEnv) {
+			throw new Error("missing PORT_HTTP");
+		}
+		const port = Number.parseInt(portEnv);
+
+		// Start server
+		console.log(`Listening on port ${port}`);
+		const server = Deno.serve({ port }, app.fetch);
+		await server.finished;
+	},
+};