Привет, ${recipientName}!
+Студент ${studentName} задал новый вопрос:
+ ${quote(questionTitle)} +Откройте панель, чтобы ответить:
+ ${btn(`${BASE_URL}/admin/questions`, "Перейти к вопросам")} + `, school), + }).catch((e) => console.error("[email] sendQuestionCreatedEmail:", e)); +} + +export async function sendQuestionReplyEmail( + to: string, + studentName: string, + questionTitle: string, + questionId: string, +) { + const school = await getSchoolName(); + await getResend().emails.send({ + from: FROM, + to, + subject: `Ответ на ваш вопрос`, + html: base(` +Привет, ${studentName}!
+Школа ответила на ваш вопрос:
+ ${quote(questionTitle)} +Откройте тред чтобы прочитать ответ:
+ ${btn(`${BASE_URL}/questions/${questionId}`, "Читать ответ")} + `, school), + }).catch((e) => console.error("[email] sendQuestionReplyEmail:", e)); +} + +export async function sendHomeworkUpdatedEmail( + to: string, + recipientName: string, + studentName: string, + lessonTitle: string, + submissionId: string, +) { + const school = await getSchoolName(); + await getResend().emails.send({ + from: FROM, + to, + subject: `Студент обновил работу — ${lessonTitle}`, + html: base(` +Привет, ${recipientName}!
+Студент ${studentName} обновил работу по уроку «${lessonTitle}».
+Откройте работу чтобы проверить изменения:
+ ${btn(`${BASE_URL}/curator/homework/${submissionId}`, "Открыть работу")} + `, school), + }).catch((e) => console.error("[email] sendHomeworkUpdatedEmail:", e)); +} +``` + +- [ ] **Step 2: Type-check** + +```bash +npm run type-check +``` + +- [ ] **Step 3: Commit** + +```bash +git add src/lib/email.ts +git commit -m "Add question and homework-update email helpers" +``` + +--- + +## Task 3: API — Questions List + Create + +**Files:** +- New: `src/app/api/questions/route.ts` + +- [ ] **Step 1: Create the file** + +```typescript +import { NextRequest, NextResponse } from "next/server"; +import { headers } from "next/headers"; +import { auth } from "@/lib/auth"; +import { prisma } from "@/lib/prisma"; +import { sendQuestionCreatedEmail } from "@/lib/email"; + +export async function GET() { + const session = await auth.api.getSession({ headers: await headers() }); + if (!session) return NextResponse.json({ error: "Unauthorized" }, { status: 401 }); + + const isStaff = session.user.role === "admin" || session.user.role === "curator"; + + const questions = await prisma.studentQuestion.findMany({ + where: isStaff ? undefined : { userId: session.user.id }, + include: { + user: { select: { id: true, name: true, email: true } }, + course: { select: { id: true, title: true } }, + _count: { + select: { + messages: { + where: isStaff + ? { isRead: false, author: { role: "student" } } + : { isRead: false, NOT: { authorId: session.user.id } }, + }, + }, + }, + }, + orderBy: { updatedAt: "desc" }, + }); + + return NextResponse.json( + questions.map((q) => ({ + id: q.id, + title: q.title, + status: q.status, + createdAt: q.createdAt, + updatedAt: q.updatedAt, + user: q.user, + course: q.course, + unreadCount: q._count.messages, + })) + ); +} + +export async function POST(req: NextRequest) { + const session = await auth.api.getSession({ headers: await headers() }); + if (!session) return NextResponse.json({ error: "Unauthorized" }, { status: 401 }); + if (session.user.role !== "student") { + return NextResponse.json({ error: "Forbidden" }, { status: 403 }); + } + + const body = await req.json(); + const { title, text, courseId } = body as { + title: string; + text: string; + courseId?: string; + }; + + if (!title?.trim() || !text?.trim()) { + return NextResponse.json({ error: "title and text are required" }, { status: 400 }); + } + + const question = await prisma.studentQuestion.create({ + data: { + userId: session.user.id, + courseId: courseId ?? null, + title: title.trim(), + messages: { + create: { + authorId: session.user.id, + text: text.trim(), + }, + }, + }, + }); + + const staff = await prisma.user.findMany({ + where: { role: { in: ["admin", "curator"] } }, + select: { email: true, name: true }, + }); + await Promise.all( + staff.map((s) => + sendQuestionCreatedEmail(s.email, s.name, session.user.name, title.trim()) + ) + ); + + return NextResponse.json(question, { status: 201 }); +} +``` + +- [ ] **Step 2: Type-check** + +```bash +npm run type-check +``` + +- [ ] **Step 3: Smoke test (manual)** + +Start dev server: `npm run dev` + +```bash +# Get session cookie first by logging in at http://localhost:3000/login, then: +curl -s http://localhost:3000/api/questions \ + -H "Cookie:+ У вас ещё нет вопросов. +
+ )} + ++ {q.messages.length > 0 + ? `${q.messages.length > 1 ? "сообщений" : "сообщение"} · последнее от ${lastMsg.author.name}` + : ""} +
+ )} + + ); + })} +