Cloudflare Adapter

import { RPCHandler } from '@orpc/server/fetch'
import { CORSPlugin } from '@orpc/server/plugins'
import { router } from './router'

const handler = new RPCHandler(router, {
  plugins: [new CORSPlugin()],
})

export default {
  async fetch(
    request: Request,
    env: Env,
    ctx: ExecutionContext,
  ): Promise<Response> {
    const result = await handler.handle(request, {
      context: { env, ctx },
    })

    if (!result.matched) {
      return new Response('Not found', { status: 404 })
    }

    return result.response
  },
}

// types.ts
export interface Env {
  DB: D1Database
  KV: KVNamespace
  BUCKET: R2Bucket
}

// orpc.ts
import { os } from '@orpc/server'
import type { Env } from './types'

export const base = os.$context<{ env: Env }>()

// procedures/planet.ts
import { base } from '../orpc'
import * as z from 'zod'

export const listPlanets = base
  .input(z.object({ limit: z.number().optional() }))
  .handler(async ({ input, context }) => {
    const { results } = await context.env.DB
      .prepare('SELECT * FROM planets LIMIT ?')
      .bind(input.limit ?? 10)
      .all()
    return results
  })

import { EventPublisher } from '@orpc/server'

export class PlanetDO implements DurableObject {
  publisher = new EventPublisher<{ updated: { id: number; name: string } }>()

  async fetch(request: Request): Promise<Response> {
    // Handle WebSocket upgrade or publishing events
    if (request.url.endsWith('/notify')) {
      const body = await request.json()
      this.publisher.publish('updated', body)
      return new Response('OK')
    }

    return new Response('Not found', { status: 404 })
  }
}