Confused about bun / hono implementation

import { serve } from "@hono/node-server";
import { Hono } from "hono";
import { registry } from "./registry";

// Start RivetKit
const { client } = registry.start();

// Setup router
const app = new Hono();

// 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}`);
});

serve({ fetch: app.fetch, port: 8080 });
console.log("Listening on port 8080");

import { serve } from "@hono/node-server";
import { Hono } from "hono";
import { registry } from "./registry";

// Start RivetKit
const { client } = registry.start();

// Setup router
const app = new Hono();

// 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}`);
});

serve({ fetch: app.fetch, port: 8080 });
console.log("Listening on port 8080");

import { upgradeWebSocket } from "hono/deno";
import { registry } from "./registry.ts";

const { fetch } = registry.start({
    // Deno requires using Deno.serve
    disableServer: true,
    // Specify Deno-specific upgradeWebSocket
    getUpgradeWebSocket: () => upgradeWebSocket,
});

// Start server
Deno.serve({ port: 8080 }, fetch);

import { upgradeWebSocket } from "hono/deno";
import { registry } from "./registry.ts";

const { fetch } = registry.start({
    // Deno requires using Deno.serve
    disableServer: true,
    // Specify Deno-specific upgradeWebSocket
    getUpgradeWebSocket: () => upgradeWebSocket,
});

// Start server
Deno.serve({ port: 8080 }, fetch);

const { fetch } = registry.start();

Bun.serve({
  // `routes` requires Bun v1.2.3+
  routes: {
     /* your routes */
  },
  fetch(req, ...args) {
    return fetch(req, ...args);
  },
});

const { fetch } = registry.start();

Bun.serve({
  // `routes` requires Bun v1.2.3+
  routes: {
     /* your routes */
  },
  fetch(req, ...args) {
    return fetch(req, ...args);
  },
});

const { upgradeWebSocket, websocket } = createBunWebSocket()
const { fetch } = registry.start({
   basePath: "/registry",
   dislabeServer: true,
   getUpgradeWebSocket: () => upgradeWebSocket
});


Bun.serve({
  fetch(req, server) {
     if(req.url.startsWith("/registry")) {
        return fetch(req);
     }
     return app.fetch(req, { ...env, server })
  },
  websocket,
});

const { upgradeWebSocket, websocket } = createBunWebSocket()
const { fetch } = registry.start({
   basePath: "/registry",
   dislabeServer: true,
   getUpgradeWebSocket: () => upgradeWebSocket
});


Bun.serve({
  fetch(req, server) {
     if(req.url.startsWith("/registry")) {
        return fetch(req);
     }
     return app.fetch(req, { ...env, server })
  },
  websocket,
});

Bun.serve({
  fetch(req, server) {
     if(req.url.startsWith("/registry")) {
        return fetch(req);
     }
     return app.fetch(req, { ...env, server })
  },
  websocket,
});

Bun.serve({
  fetch(req, server) {
     if(req.url.startsWith("/registry")) {
        return fetch(req);
     }
     return app.fetch(req, { ...env, server })
  },
  websocket,
});

app.use("/rivet/*", async (c) => {
    return await fetch(c.req.raw, c.env);
});

app.use("/rivet/*", async (c) => {
    return await fetch(c.req.raw, c.env);
});

// server.ts bun entry

import app from './app'
import createServer from '@/utils/create-server'
import { websocket } from 'hono/bun'
import { isDev, env } from './env'

const server = createServer({
  development: isDev,
  port: env.PORT,
  websocket,
  fetch: (req, server) => {
    return app.fetch(req, { ...env, server })
  },
})

// server.ts bun entry

import app from './app'
import createServer from '@/utils/create-server'
import { websocket } from 'hono/bun'
import { isDev, env } from './env'

const server = createServer({
  development: isDev,
  port: env.PORT,
  websocket,
  fetch: (req, server) => {
    return app.fetch(req, { ...env, server })
  },
})

// app.ts - hono entry

import { env } from './env'
import { contextStorage } from 'hono/context-storage'
import { notFound, onError } from 'stoker/middlewares'
import { cors, corsOptions } from './middleware'
import { clerk } from './middleware/clerk'
import { createApp } from './utils/create-app'
import { createRivetRegistry } from '@/lib/rivetkit'
// workers
import '@/workers'
import '@/workers/events'

const { fetch } = createRivetRegistry({
  basePath: '/rivet',
  cors: corsOptions,
  disableServer: true,
})

const app = createApp()

app.use(cors)
app.use(contextStorage())
app.use(clerk({ machineSecretKey: undefined }))

app.onError(onError)
app.notFound(notFound)

app.use('/rivet/*', async c => {
  return await fetch(c.req.raw, c.env)
})

export default app

// app.ts - hono entry

import { env } from './env'
import { contextStorage } from 'hono/context-storage'
import { notFound, onError } from 'stoker/middlewares'
import { cors, corsOptions } from './middleware'
import { clerk } from './middleware/clerk'
import { createApp } from './utils/create-app'
import { createRivetRegistry } from '@/lib/rivetkit'
// workers
import '@/workers'
import '@/workers/events'

const { fetch } = createRivetRegistry({
  basePath: '/rivet',
  cors: corsOptions,
  disableServer: true,
})

const app = createApp()

app.use(cors)
app.use(contextStorage())
app.use(clerk({ machineSecretKey: undefined }))

app.onError(onError)
app.notFound(notFound)

app.use('/rivet/*', async c => {
  return await fetch(c.req.raw, c.env)
})

export default app

import {
  createMemoryDriver,
  createFileSystemDriver,
  type RunConfigInput,
} from 'rivetkit'
import { upgradeWebSocket } from 'hono/bun'
import { registry } from '@/actors'

// const driver = createMemoryDriver()
const createDriver = (type: 'memory' | 'fs') => {
  if (type === 'fs') {
    return createFileSystemDriver()
  }
  return createMemoryDriver()
}

export const createRivetRegistry = (
  config: RunConfigInput & { driverType?: 'memory' | 'fs' }
) => {
  const server = registry.start({
    driver: createDriver(config.driverType || 'fs'),
    ...config,
    getUpgradeWebSocket: () => upgradeWebSocket,
  })
  return server
}

import {
  createMemoryDriver,
  createFileSystemDriver,
  type RunConfigInput,
} from 'rivetkit'
import { upgradeWebSocket } from 'hono/bun'
import { registry } from '@/actors'

// const driver = createMemoryDriver()
const createDriver = (type: 'memory' | 'fs') => {
  if (type === 'fs') {
    return createFileSystemDriver()
  }
  return createMemoryDriver()
}

export const createRivetRegistry = (
  config: RunConfigInput & { driverType?: 'memory' | 'fs' }
) => {
  const server = registry.start({
    driver: createDriver(config.driverType || 'fs'),
    ...config,
    getUpgradeWebSocket: () => upgradeWebSocket,
  })
  return server
}