fullstack-starter/src/orpc/handlers/todo.ts

import { implement, ORPCError } from '@orpc/server'
import { eq } from 'drizzle-orm'
import { todoTable } from '@/db/schema'
import { todoContract } from '@/orpc/contract'
import { dbProvider } from '@/orpc/middlewares'

export const list = implement(todoContract.list)
  .use(dbProvider)
  .handler(async ({ context }) => {
    const todos = await context.db.query.todoTable.findMany({
      orderBy: (todos, { desc }) => [desc(todos.createdAt)],
    })
    return todos
  })

export const create = implement(todoContract.create)
  .use(dbProvider)
  .handler(async ({ context, input }) => {
    const [newTodo] = await context.db
      .insert(todoTable)
      .values(input)
      .returning()

    if (!newTodo) {
      throw new ORPCError('NOT_FOUND')
    }

    return newTodo
  })

export const update = implement(todoContract.update)
  .use(dbProvider)
  .handler(async ({ context, input }) => {
    const [updatedTodo] = await context.db
      .update(todoTable)
      .set(input.data)
      .where(eq(todoTable.id, input.id))
      .returning()

    if (!updatedTodo) {
      throw new ORPCError('NOT_FOUND')
    }

    return updatedTodo
  })

export const remove = implement(todoContract.remove)
  .use(dbProvider)
  .handler(async ({ context, input }) => {
    await context.db.delete(todoTable).where(eq(todoTable.id, input.id))
  })