Code-MCP

// ============================================ // Prisma Client Instance - db.ts // ============================================ import { PrismaClient } from '@prisma/client' const globalForPrisma = globalThis as unknown as { prisma: PrismaClient | undefined } export const prisma = globalForPrisma.prisma ?? new PrismaClient({ log: process.env.NODE_ENV === 'development' ? ['query', 'error', 'warn'] : ['error'], }) if (process.env.NODE_ENV !== 'production') globalForPrisma.prisma = prisma // ============================================ // Schema (schema.prisma) // ============================================ /* generator client { provider = "prisma-client-js" } datasource db { provider = "postgresql" // or mysql, sqlite, sqlserver url = env("DATABASE_URL") } model User { id Int @id @default(autoincrement()) email String @unique name String password String // Hashed role Role @default(USER) posts Post[] profile Profile? createdAt DateTime @default(now()) updatedAt DateTime @updatedAt @@index([email]) } model Profile { id Int @id @default(autoincrement()) bio String? userId Int @unique user User @relation(fields: [userId], references: [id], onDelete: Cascade) } model Post { id Int @id @default(autoincrement()) title String content String? published Boolean @default(false) viewCount Int @default(0) authorId Int author User @relation(fields: [authorId], references: [id]) categories Category[] createdAt DateTime @default(now()) updatedAt DateTime @updatedAt @@index([authorId]) } model Category { id Int @id @default(autoincrement()) name String @unique posts Post[] } enum Role { USER ADMIN } */ // ============================================ // Services / Repositories // ============================================ export const userService = { async findByEmail(email: string) { return prisma.user.findUnique({ where: { email }, include: { profile: true }, }) }, async create(data: { email: string; name: string; password: string }) { return prisma.user.create({ data: { ...data, profile: { create: { bio: 'New user' }, }, }, }) }, async getFeed(userId: number) { // Get posts from authors followed by user (example logic) return prisma.post.findMany({ where: { published: true, authorId: { not: userId }, // Exclude own posts }, include: { author: { select: { name: true, email: true }, }, _count: { select: { categories: true }, }, }, orderBy: { createdAt: 'desc' }, take: 20, }) }, } export const postService = { async create(userId: number, title: string, content?: string) { return prisma.post.create({ data: { title, content, authorId: userId, }, }) }, async publish(postId: number, userId: number) { // Verify ownership and update const post = await prisma.post.findUnique({ where: { id: postId } }) if (!post) throw new Error('Post not found') if (post.authorId !== userId) throw new Error('Not authorized') return prisma.post.update({ where: { id: postId }, data: { published: true }, }) }, async delete(postId: number, userId: number) { return prisma.post.deleteMany({ where: { id: postId, authorId: userId, // Ensure ownership }, }) }, } // ============================================ // Transaction Example // ============================================ export async function transferOwnership(postId: number, newAuthorId: number) { return prisma.$transaction(async (tx) => { const post = await tx.post.findUniqueOrThrow({ where: { id: postId } }) // Log the transfer console.log(`Transferring post ${post.id} to user ${newAuthorId}`) const updated = await tx.post.update({ where: { id: postId }, data: { authorId: newAuthorId }, }) return updated }) } // ============================================ // Pagination Helper // ============================================ export async function getPostsPaginated(cursor?: number, limit = 10) { return prisma.post.findMany({ take: limit, skip: cursor ? 1 : 0, // Skip the cursor itself cursor: cursor ? { id: cursor } : undefined, orderBy: { id: 'desc' }, where: { published: true }, }) } // ============================================ // Middleware Example (Soft Delete) // ============================================ /* prisma.$use(async (params, next) => { // Check incoming query type if (params.model == 'Post' && params.action == 'delete') { // Change action to an update params.action = 'update' params.args['data'] = { deleted: true } } return next(params) }) */ // ============================================ // Clean Shutdown // ============================================ export async function disconnect() { await prisma.$disconnect() }