Базы данных в Next.js: ORM, паттерны и Edge Runtime

import 'server-only';
import { PrismaClient } from '@prisma/client';

const prismaClientSingleton = () => {
  return new PrismaClient({
    log: process.env.NODE_ENV === 'development' ? ['query', 'error', 'warn'] : ['error'],
  });
};

type PrismaClientSingleton = ReturnType<typeof prismaClientSingleton>;

const globalForPrisma = globalThis as unknown as {
  prisma: PrismaClientSingleton | undefined;
};

// Переиспользуем клиент в development или создаем новый в production
export const db = globalForPrisma.prisma ?? prismaClientSingleton();

if (process.env.NODE_ENV !== 'production') {
  globalForPrisma.prisma = db;
}

import 'server-only';
import { neon } from '@neondatabase/serverless';
import { drizzle } from 'drizzle-orm/neon-http';
import { pgTable, serial, text, timestamp, integer } from 'drizzle-orm/pg-core';
import { eq } from 'drizzle-orm';

// Декларативная схема таблицы в чистом TypeScript
export const usersTable = pgTable('users', {
  id: serial('id').primaryKey(),
  name: text('name').notNull(),
  email: text('email').notNull().unique(),
  balance: integer('balance').default(0).notNull(),
  createdAt: timestamp('created_at').defaultNow().notNull(),
});

// Инициализация HTTP-клиента: не требует Singleton, не удерживает постоянный сокет
const sql = neon(process.env.DATABASE_URL!);
export const db = drizzle(sql);

// Типобезопасная выборка данных
export async function getActiveUsers() {
  return db
    .select({
      id: usersTable.id,
      name: usersTable.name,
      email: usersTable.email,
    })
    .from(usersTable)
    .limit(50);
}

import { db } from '@/lib/db';
import { Suspense } from 'react';

interface UsersPageProps {
  searchParams: Promise<{ role?: string }>;
}

export default async function UsersPage({ searchParams }: UsersPageProps) {
  // В Next.js 15+ searchParams являются асинхронным объектом
  const { role } = await searchParams;

  const users = await db.user.findMany({
    where: role ? { role } : undefined,
    orderBy: { createdAt: 'desc' },
    select: { id: true, name: true, email: true }, // Защита: выбираем только необходимые поля
    take: 50,
  });

  if (users.length === 0) {
    return (
      <div className="p-8 text-center text-text-muted">
        Пользователи не найдены.
      </div>
    );
  }

  return (
    <div className="space-y-4">
      <h1 className="text-2xl font-bold text-text-primary">Список пользователей</h1>
      <ul className="divide-y divide-border rounded-lg border border-border">
        {users.map((user) => (
          <li key={user.id} className="p-4 flex justify-between items-center">
            <span className="font-medium text-text-primary">{user.name}</span>
            <span className="text-xs text-text-muted font-mono">{user.email}</span>
          </li>
        ))}
      </ul>
    </div>
  );
}

'use server';

import { z } from 'zod';
import { db } from '@/lib/db';
import { auth } from '@/lib/auth'; // Внутренний хелпер получения сессии
import { revalidatePath } from 'next/cache';

const CheckoutSchema = z.object({
  amount: z.coerce.number().positive('Сумма должна быть больше нуля').max(1_000_000),
  description: z.string().min(3).max(255).optional(),
});

export type CheckoutState = {
  status: 'idle' | 'success' | 'error';
  message?: string;
};

export async function checkoutAction(
  prevState: CheckoutState,
  formData: FormData
): Promise<CheckoutState> {
  // 1. Извлекаем пользователя строго из сессии на сервере (защита от IDOR)
  const session = await auth();
  if (!session?.user?.id) {
    return { status: 'error', message: 'Требуется авторизация.' };
  }

  // 2. Валидация входных данных через Zod
  const validated = CheckoutSchema.safeParse({
    amount: formData.get('amount'),
    description: formData.get('description') || undefined,
  });

  if (!validated.success) {
    return {
      status: 'error',
      message: validated.error.issues[0].message,
    };
  }

  const { amount, description } = validated.data;
  const userId = session.user.id;

  try {
    // 3. Атомарная транзакция в базе данных
    await db.$transaction(async (tx) => {
      // Блокируем и проверяем текущий баланс
      const user = await tx.user.findUnique({
        where: { id: userId },
        select: { balance: true },
      });

      if (!user || user.balance < amount) {
        throw new Error('INSUFFICIENT_FUNDS'); // Вызывает немедленный ROLLBACK
      }

      // Списываем баланс
      await tx.user.update({
        where: { id: userId },
        data: { balance: { decrement: amount } },
      });

      // Фиксируем заказ
      await tx.order.create({
        data: {
          userId,
          amount,
          status: 'COMPLETED',
          description: description ?? 'Оплата заказа',
        },
      });
    });

    // 4. Инвалидация серверного кэша
    revalidatePath('/dashboard/orders');
    return { status: 'success', message: 'Заказ успешно оплачен!' };

  } catch (err: unknown) {
    const isFundsError = err instanceof Error && err.message === 'INSUFFICIENT_FUNDS';
    return {
      status: 'error',
      message: isFundsError ? 'Недостаточно средств на балансе.' : 'Ошибка проведения платежа.',
    };
  }
}

import 'server-only';
import { cache } from 'react';
import { db } from '@/lib/db';
import { auth } from '@/lib/auth';
import { redirect } from 'next/navigation';

// DTO интерфейс: строго определяет, какие поля уходят наружу
export interface UserProfileDTO {
  id: string;
  name: string;
  email: string;
  avatarUrl: string | null;
}

// React cache() кэширует результат промиса на время выполнения одного серверного рендера
export const getCurrentUser = cache(async (): Promise<UserProfileDTO | null> => {
  const session = await auth();
  if (!session?.user?.id) return null;

  const user = await db.user.findUnique({
    where: { id: session.user.id },
    select: {
      id: true,
      name: true,
      email: true,
      avatarUrl: true,
      // passwordHash: ИСКЛЮЧЕНО — никогда не попадет в RSC Flight Payload
    },
  });

  return user;
});

export const requireAdmin = cache(async () => {
  const session = await auth();
  if (!session?.user?.id) {
    redirect('/login');
  }

  const user = await db.user.findUnique({
    where: { id: session.user.id },
    select: { role: true },
  });

  if (user?.role !== 'ADMIN') {
    redirect('/unauthorized');
  }
});