Server Actions: Мутации данных и работа с формами

import { db } from '@/lib/db';
import { posts } from '@/lib/schema';
import { revalidatePath } from 'next/cache';

export default function PostsPage() {
  // Асинхронная функция внутри Server Component
  async function createPost(formData: FormData): Promise<void> {
    'use server'; // Директива в начале тела функции объявляет ее Server Action
    
    const title = formData.get('title');
    if (typeof title !== 'string' || !title.trim()) {
      return;
    }

    await db.insert(posts).values({ title });
    
    // Инвалидация кэша для немедленного отображения нового поста
    revalidatePath('/posts');
  }

  return (
    <main className="p-6">
      <form action={createPost} className="flex gap-2">
        <input type="text" name="title" required className="border p-2 rounded" />
        <button type="submit" className="bg-blue-600 text-white px-4 py-2 rounded">
          Создать пост
        </button>
      </form>
    </main>
  );
}

'use server'; // Применяется ко всем экспортируемым функциям модуля

import { db } from '@/lib/db';
import { posts } from '@/lib/schema';
import { eq } from 'drizzle-orm';
import { revalidatePath } from 'next/cache';

export async function deletePostAction(postId: string): Promise<{ success: boolean }> {
  await db.delete(posts).where(eq(posts.id, postId));
  revalidatePath('/posts');
  return { success: true };
}

'use client';

import { useActionState } from 'react';
import { createUserAction, type FormState } from '@/app/actions/users';

const initialState: FormState = {
  success: false,
  message: '',
  errors: undefined,
};

export function UserForm() {
  // state — текущее состояние, возвращенное экшеном
  // formAction — прокси-функция для передачи в <form action={...}>
  // isPending — флаг асинхронного выполнения запроса
  const [state, formAction, isPending] = useActionState(createUserAction, initialState);

  return (
    <form action={formAction} className="space-y-4 max-w-md">
      <div>
        <label htmlFor="email" className="block text-sm font-medium">Email</label>
        <input
          id="email"
          name="email"
          type="email"
          required
          className="w-full border rounded p-2"
        />
        {state.errors?.email && (
          <p className="text-red-500 text-xs mt-1">{state.errors.email[0]}</p>
        )}
      </div>

      <button
        type="submit"
        disabled={isPending}
        className="w-full bg-blue-600 text-white py-2 rounded disabled:opacity-50"
      >
        {isPending ? 'Сохранение...' : 'Зарегистрировать'}
      </button>

      {state.message && (
        <p className={`text-sm ${state.success ? 'text-green-600' : 'text-red-600'}`}>
          {state.message}
        </p>
      )}
    </form>
  );
}

'use client';

import { useFormStatus } from 'react-dom';

export function SubmitButton({ label = 'Отправить' }: { label?: string }) {
  // Хук читает контекст ближайшей родительской формы <form>
  const { pending, data, method } = useFormStatus();

  return (
    <button
      type="submit"
      disabled={pending}
      className="px-4 py-2 rounded bg-accent-cyan text-black font-semibold disabled:opacity-50 transition-opacity"
    >
      {pending ? 'Обработка запроса...' : label}
    </button>
  );
}

'use client';

import { useOptimistic, startTransition } from 'react';
import { likePostAction } from '@/app/actions/posts';

interface LikeButtonProps {
  postId: string;
  initialLikes: number;
}

export function LikeButton({ postId, initialLikes }: LikeButtonProps) {
  const [optimisticLikes, addOptimisticLike] = useOptimistic(
    initialLikes,
    (currentLikes: number, increment: number) => currentLikes + increment
  );

  const handleLike = () => {
    startTransition(async () => {
      // 1. Мгновенно обновляем интерфейс на клиенте
      addOptimisticLike(1);
      // 2. Отправляем запрос на сервер
      await likePostAction(postId);
    });
  };

  return (
    <button
      type="button"
      onClick={handleLike}
      className="border border-border px-3 py-1.5 rounded-lg hover:border-accent-cyan"
    >
      Нравится: {optimisticLikes}
    </button>
  );
}

'use client';

import { deleteUserAction } from '@/app/actions/users';

interface UserDTO {
  id: string;
  name: string;
}

interface UserListProps {
  user: UserDTO;
}

export function UserItem({ user }: UserListProps) {
  // Привязываем аргумент userId первым параметром Server Action
  const deleteWithUserId = deleteUserAction.bind(null, user.id);

  return (
    <div className="flex items-center justify-between p-3 border rounded">
      <span>{user.name}</span>
      <form action={deleteWithUserId}>
        <button type="submit" className="text-red-500 hover:underline">
          Удалить
        </button>
      </form>
    </div>
  );
}

'use server';

import { cookies } from 'next/headers';
import { verifySessionToken } from '@/lib/auth';

export async function executeAdminTask(data: FormData): Promise<{ success: boolean; error?: string }> {
  // Асинхронное чтение cookies в соответствии со стандартом Next.js 15+
  const cookieStore = await cookies();
  const token = cookieStore.get('session_token')?.value;

  if (!token) {
    return { success: false, error: 'Unauthorized: Сессия отсутствует' };
  }

  const session = await verifySessionToken(token);
  if (!session || session.role !== 'admin') {
    return { success: false, error: 'Forbidden: Недостаточно прав доступа' };
  }

  // Бизнес-логика задачи администратора...
  return { success: true };
}

// ❌ ОШИБКА: redirect перехвачен блоком catch
'use server';
import { redirect } from 'next/navigation';

export async function createPostAction(prevState: unknown, formData: FormData) {
  try {
    await db.insert(posts).values({ title: formData.get('title') });
    redirect('/posts'); // Выбрасывает исключение NEXT_REDIRECT!
  } catch (err: unknown) {
    // Редирект пойман здесь, пользователь видит ошибку вместо перехода!
    return { error: 'Не удалось создать пост' };
  }
}

// ✅ ПРАВИЛЬНО: Вызывать redirect ПОСЛЕ блока try/catch
export async function createPostAction(prevState: unknown, formData: FormData) {
  try {
    await db.insert(posts).values({ title: formData.get('title') });
  } catch (err: unknown) {
    return { error: 'Не удалось создать пост' };
  }
  
  redirect('/posts'); // Выполняется успешно вне блока перехвата
}

// ❌ ОПАСНО: В action захвачен весь объект heavyUser с приватными данными
export default async function ProfilePage() {
  const heavyUser = await db.getUser(); // Содержит passwordHash, secretKeys, 100 полей

  async function updateStatus() {
    'use server';
    // Хотя используется только id, Next.js зашифрует и передаст на клиент ВЕСЬ heavyUser!
    await db.updateUserStatus(heavyUser.id, 'online');
  }

  return <form action={updateStatus}><button>Online</button></form>;
}

// ✅ ПРАВИЛЬНО: Выносите экшены в actions.ts и передавайте только скалярные ID
// app/actions.ts:
// export async function updateStatus(userId: string) { 'use server'; ... }