【Better Auth】NextJs & tRPC 【#15 Create Post Route】

【#15 Create Post Route】

YouTube: https://youtu.be/daUXppelKnM
https://youtu.be/daUXppelKnM

今回はユーザーのIDと紐づいた
Postのデータを作成するルートを実装します。

https://orm.drizzle.team/docs/zod#insert-schema

npm i drizzle-zod

次回の動画で修正するのですが、
「postInsertSchema」が「content」以外の内容も含みますので、
「pick」を使用して「content」のみになるようにしてます。

src/db/schema.ts

import { nanoid } from 'nanoid'
import { pgTable, text, timestamp, boolean } from 'drizzle-orm/pg-core'
import { createInsertSchema } from 'drizzle-zod'

export const user = pgTable('user', {
  id: text('id').primaryKey(),
  name: text('name').notNull(),
  email: text('email').notNull().unique(),
  emailVerified: boolean('email_verified')
    .$defaultFn(() => false)
    .notNull(),
  image: text('image'),
  createdAt: timestamp('created_at')
    .$defaultFn(() => /* @__PURE__ */ new Date())
    .notNull(),
  updatedAt: timestamp('updated_at')
    .$defaultFn(() => /* @__PURE__ */ new Date())
    .notNull(),
})

export const session = pgTable('session', {
  id: text('id').primaryKey(),
  expiresAt: timestamp('expires_at').notNull(),
  token: text('token').notNull().unique(),
  createdAt: timestamp('created_at').notNull(),
  updatedAt: timestamp('updated_at').notNull(),
  ipAddress: text('ip_address'),
  userAgent: text('user_agent'),
  userId: text('user_id')
    .notNull()
    .references(() => user.id, { onDelete: 'cascade' }),
})

export const account = pgTable('account', {
  id: text('id').primaryKey(),
  accountId: text('account_id').notNull(),
  providerId: text('provider_id').notNull(),
  userId: text('user_id')
    .notNull()
    .references(() => user.id, { onDelete: 'cascade' }),
  accessToken: text('access_token'),
  refreshToken: text('refresh_token'),
  idToken: text('id_token'),
  accessTokenExpiresAt: timestamp('access_token_expires_at'),
  refreshTokenExpiresAt: timestamp('refresh_token_expires_at'),
  scope: text('scope'),
  password: text('password'),
  createdAt: timestamp('created_at').notNull(),
  updatedAt: timestamp('updated_at').notNull(),
})

export const verification = pgTable('verification', {
  id: text('id').primaryKey(),
  identifier: text('identifier').notNull(),
  value: text('value').notNull(),
  expiresAt: timestamp('expires_at').notNull(),
  createdAt: timestamp('created_at').$defaultFn(
    () => /* @__PURE__ */ new Date()
  ),
  updatedAt: timestamp('updated_at').$defaultFn(
    () => /* @__PURE__ */ new Date()
  ),
})

export const posts = pgTable('posts', {
  id: text('id')
    .primaryKey()
    .$defaultFn(() => nanoid()),
  userId: text('user_id')
    .notNull()
    .references(() => user.id, { onDelete: 'cascade' }),
  content: text('content').notNull(),
  createdAt: timestamp('created_at').notNull().defaultNow(),
  updatedAt: timestamp('updated_at').notNull().defaultNow(),
})

export const postInsertSchema = createInsertSchema(posts).pick({
  content: true,
})

src/trpc/routers/_app.ts

import { z } from 'zod'
import { baseProcedure, createTRPCRouter, protectedProcedure } from '../init'
import { postInsertSchema, posts } from '@/db/schema'
import { db } from '@/db'

export const appRouter = createTRPCRouter({
  hello: baseProcedure
    .input(
      z.object({
        text: z.string(),
      })
    )
    .query((opts) => {
      return {
        greeting: `hello ${opts.input.text}`,
      }
    }),
  createPost: protectedProcedure
    .input(postInsertSchema)
    .mutation(async ({ input, ctx }) => {
      const { content } = input
      const { id: userId } = ctx.auth.user

      const [createdPost] = await db
        .insert(posts)
        .values({
          content,
          userId,
        })
        .returning()

      return createdPost
    }),
})
// export type definition of API
export type AppRouter = typeof appRouter