[Graphite MQ] Draft PR GROUP:spec_773ca1 (PRs 1358)

examples/hono-bun/README.md

@@ -0,0 +1,37 @@
+# Hono + Bun Integration for RivetKit
+
+Example project demonstrating Hono web framework with Bun runtime integration with [RivetKit](https://rivetkit.org).
+
+[Learn More →](https://github.com/rivet-dev/rivetkit)
+
+[Discord](https://rivet.dev/discord) — [Documentation](https://rivetkit.org) — [Issues](https://github.com/rivet-dev/rivetkit/issues)
+
+## Getting Started
+
+### Prerequisites
+
+- Bun
+
+### Installation
+
+```sh
+git clone https://github.com/rivet-dev/rivetkit
+cd rivetkit/examples/hono-bun
+npm install
+```
+
+### Development
+
+```sh
+npm run dev
+```
+
+Test the server by running:
+
+```sh
+curl -X POST http://localhost:8080/increment/test
+```
+
+## License
+
+Apache 2.0

examples/hono-bun/package.json

@@ -0,0 +1,28 @@
+{
+  "name": "example-hono-bun",
+  "version": "2.0.9",
+  "private": true,
+  "type": "module",
+  "scripts": {
+    "dev": "bun --watch src/server.ts",
+    "check-types": "tsc --noEmit",
+    "connect": "tsx scripts/connect.ts"
+  },
+  "devDependencies": {
+    "@types/bun": "^1.1.15",
+    "rivetkit": "workspace:*",
+    "typescript": "^5.5.2"
+  },
+  "dependencies": {
+    "hono": "^4.7.0"
+  },
+  "keywords": [
+    "rivetkit",
+    "hono",
+    "bun",
+    "actor",
+    "stateful",
+    "example"
+  ],
+  "stableVersion": "0.8.0"
+}

examples/hono-bun/scripts/connect.ts

@@ -0,0 +1,22 @@
+import { createClient } from "rivetkit/client";
+import type { Registry } from "../src/registry";
+
+async function main() {
+	const client = createClient<Registry>("http://localhost:8080/rivet");
+
+	const counter = client.counter.getOrCreate().connect();
+
+	counter.on("newCount", (count: number) => console.log("Event:", count));
+
+	for (let i = 0; i < 5; i++) {
+		const out = await counter.increment(5);
+		console.log("RPC:", out);
+
+		await new Promise((resolve) => setTimeout(resolve, 1000));
+	}
+
+	await new Promise((resolve) => setTimeout(resolve, 10000));
+	await counter.dispose();
+}
+
+main();

examples/hono-bun/src/registry.ts

@@ -0,0 +1,15 @@
+import { actor, setup } from "rivetkit";
+
+export const counter = actor({
+	state: { count: 0 },
+	actions: {
+		increment: (c, x: number) => {
+			c.state.count += x;
+			return c.state.count;
+		},
+	},
+});
+
+export const registry = setup({
+	use: { counter },
+});

examples/hono-bun/src/server.ts

@@ -0,0 +1,38 @@
+import { Hono } from "hono";
+import { upgradeWebSocket, websocket } from "hono/bun";
+import { registry } from "./registry";
+
+const { client, fetch } = registry.start({
+	basePath: "/rivet",
+	// Hono requires using Hono.serve
+	disableDefaultServer: true,
+	// Override endpoint
+	overrideServerAddress: "http://localhost:8080/rivet",
+	// Specify Hono-specific upgradeWebSocket
+	getUpgradeWebSocket: () => upgradeWebSocket,
+});
+
+// Setup router
+const app = new Hono();
+
+app.use("/rivet/*", async (c) => {
+	return await fetch(c.req.raw, c.env);
+});
+
+// Example HTTP endpoint
+app.post("/increment/:name", async (c) => {
+	const name = c.req.param("name");
+
+	const counter = client.counter.getOrCreate(name);
+	const newCount = await counter.increment(1);
+
+	return c.text(`New Count: ${newCount}`);
+});
+
+Bun.serve({
+	port: 8080,
+	fetch: app.fetch,
+	websocket,
+});
+
+console.log("Listening at http://localhost:8080");

examples/hono-bun/tsconfig.json

@@ -0,0 +1,43 @@
+{
+  "compilerOptions": {
+    /* Visit https://aka.ms/tsconfig.json to read more about this file */
+
+    /* Set the JavaScript language version for emitted JavaScript and include compatible library declarations. */
+    "target": "esnext",
+    /* Specify a set of bundled library declaration files that describe the target runtime environment. */
+    "lib": ["esnext"],
+    /* Specify what JSX code is generated. */
+    "jsx": "react-jsx",
+
+    /* Specify what module code is generated. */
+    "module": "esnext",
+    /* Specify how TypeScript looks up a file from a given module specifier. */
+    "moduleResolution": "bundler",
+    /* Specify type package names to be included without being referenced in a source file. */
+    "types": ["bun"],
+    /* Enable importing .json files */
+    "resolveJsonModule": true,
+
+    /* Allow JavaScript files to be a part of your program. Use the `checkJS` option to get errors from these files. */
+    "allowJs": true,
+    /* Enable error reporting in type-checked JavaScript files. */
+    "checkJs": false,
+
+    /* Disable emitting files from a compilation. */
+    "noEmit": true,
+
+    /* Ensure that each file can be safely transpiled without relying on other imports. */
+    "isolatedModules": true,
+    /* Allow 'import x from y' when a module doesn't have a default export. */
+    "allowSyntheticDefaultImports": true,
+    /* Ensure that casing is correct in imports. */
+    "forceConsistentCasingInFileNames": true,
+
+    /* Enable all strict type-checking options. */
+    "strict": true,
+
+    /* Skip type checking all .d.ts files. */
+    "skipLibCheck": true
+  },
+  "include": ["src/**/*"]
+}

examples/hono-bun/turbo.json

@@ -0,0 +1,4 @@
+{
+  "$schema": "https://turbo.build/schema.json",
+  "extends": ["//"]
+}