{isSlidesVisible ? (
diff --git a/src/socket/handlers/questionHandlers.ts b/src/socket/handlers/questionHandlers.ts
index 708923e..5ffc8a1 100644
--- a/src/socket/handlers/questionHandlers.ts
+++ b/src/socket/handlers/questionHandlers.ts
@@ -454,6 +454,124 @@ export function handleQuestionResolve(socket: Socket, io: Server): void {
});
}
+// ---------------------------------------------------------------------------
+// Unresolving
+// ---------------------------------------------------------------------------
+
+interface QuestionUnresolvePayload {
+ questionId: string;
+}
+
+/**
+ * Registers the `question:unresolve` event listener on the given socket.
+ *
+ * Only TA / PROFESSOR may unresolve. Reverts status to OPEN.
+ * Shares the same rate limit counter as resolve.
+ *
+ * Guard order (cheap-before-expensive):
+ * 1. Auth — socket.data.userId must exist
+ * 2. Payload shape — must be a non-null object with a string questionId
+ * 3. Rate limit — shared with resolve: 20 / 60 s per user
+ * 4. Question — must exist and currently be RESOLVED
+ * 5. Permission — TA/PROFESSOR only
+ * 6. Persist — question status updated to OPEN
+ * 7. Broadcast — emit unresolved status to the session room
+ */
+export function handleQuestionUnresolve(socket: Socket, io: Server): void {
+ socket.on("question:unresolve", async (payload: QuestionUnresolvePayload) => {
+ try {
+ // 1. Auth guard
+ const userId: string | undefined = socket.data?.userId;
+ if (!userId) {
+ socket.emit("question:error", { message: "Authentication required." });
+ return;
+ }
+
+ // 2. Payload shape guard
+ if (!payload || typeof payload !== "object") {
+ socket.emit("question:error", { message: "Invalid request." });
+ return;
+ }
+
+ const { questionId } = payload;
+ if (!questionId || typeof questionId !== "string") {
+ socket.emit("question:error", { message: "Question ID is required." });
+ return;
+ }
+
+ // 3. Rate limit (shared with resolve)
+ const isRateLimited = await checkResolveRateLimit(userId);
+ if (isRateLimited) {
+ socket.emit("question:error", {
+ message: "You are resolving too quickly. Please wait before trying again.",
+ });
+ return;
+ }
+
+ // 4. Fetch question
+ const question = await prisma.question.findUnique({
+ where: { id: questionId },
+ select: {
+ id: true,
+ sessionId: true,
+ status: true,
+ visibility: true,
+ session: { select: { courseId: true } },
+ },
+ });
+
+ if (!question) {
+ socket.emit("question:error", { message: "Question not found." });
+ return;
+ }
+
+ if (question.status !== "RESOLVED") {
+ socket.emit("question:error", { message: "Question is not resolved." });
+ return;
+ }
+
+ // 5. Permission check — only TA/PROFESSOR may unresolve
+ const enrollment = await prisma.courseEnrollment.findUnique({
+ where: {
+ userId_courseId: { userId, courseId: question.session.courseId },
+ },
+ select: { role: true },
+ });
+
+ const requesterRole = enrollment?.role ?? "STUDENT";
+
+ if (requesterRole !== "TA" && requesterRole !== "PROFESSOR") {
+ socket.emit("question:error", {
+ message: "You do not have permission to unresolve this question.",
+ });
+ return;
+ }
+
+ // 6. Update status back to OPEN
+ await prisma.question.update({
+ where: { id: questionId },
+ data: { status: "OPEN" },
+ });
+
+ // 7. Broadcast to the appropriate room
+ const targetRoom =
+ question.visibility === "INSTRUCTOR_ONLY"
+ ? `session:${question.sessionId}:instructors`
+ : `session:${question.sessionId}`;
+
+ io.to(targetRoom).emit("question:unresolved", {
+ id: questionId,
+ status: "OPEN",
+ });
+ } catch (error) {
+ console.error("[QuestionHandler] Failed to unresolve question:", error);
+ socket.emit("question:error", {
+ message: "An error occurred while unresolving the question.",
+ });
+ }
+ });
+}
+
// ---------------------------------------------------------------------------
// Deleting
// ---------------------------------------------------------------------------
diff --git a/src/socket/index.ts b/src/socket/index.ts
index 8a5f69f..27dcc7c 100644
--- a/src/socket/index.ts
+++ b/src/socket/index.ts
@@ -9,6 +9,7 @@ import {
handleQuestionCreate,
handleQuestionUpvote,
handleQuestionResolve,
+ handleQuestionUnresolve,
handleQuestionDelete,
} from "./handlers/questionHandlers";
import {
@@ -238,6 +239,7 @@ export async function initSocketIO(
handleQuestionCreate(socket, io!);
handleQuestionUpvote(socket, io!);
handleQuestionResolve(socket, io!);
+ handleQuestionUnresolve(socket, io!);
handleQuestionDelete(socket, io!);
handleAnswerCreate(socket, io!);
handleAnswerUpvote(socket, io!);
diff --git a/src/socket/types.ts b/src/socket/types.ts
index 9a5df5f..a76b815 100644
--- a/src/socket/types.ts
+++ b/src/socket/types.ts
@@ -110,6 +110,15 @@ export interface QuestionResolvedPayload {
status: "RESOLVED";
}
+export interface QuestionUnresolvePayload {
+ questionId: string;
+}
+
+export interface QuestionUnresolvedPayload {
+ id: string;
+ status: "OPEN";
+}
+
export interface QuestionAuthorRevealedPayload {
id: string;
authorId: string;
@@ -170,6 +179,7 @@ export interface ClientToServerEvents {
"question:upvote": (payload: QuestionUpvotePayload) => void;
"answer:upvote": (payload: AnswerUpvotePayload) => void;
"question:resolve": (payload: QuestionResolvePayload) => void;
+ "question:unresolve": (payload: QuestionUnresolvePayload) => void;
"question:delete": (payload: QuestionDeletePayload) => void;
"answer:delete": (payload: AnswerDeletePayload) => void;
"slide:change": (payload: SlideChangePayload) => void;
@@ -193,6 +203,7 @@ export interface ServerToClientEvents {
"question:updated": (payload: QuestionUpdatedPayload) => void;
"answer:updated": (payload: AnswerUpdatedPayload) => void;
"question:resolved": (payload: QuestionResolvedPayload) => void;
+ "question:unresolved": (payload: QuestionUnresolvedPayload) => void;
"question:deleted": (payload: QuestionDeletedPayload) => void;
"answer:deleted": (payload: AnswerDeletedPayload) => void;
"slide:changed": (payload: SlideChangedPayload) => void;
diff --git a/src/types/images.d.ts b/src/types/images.d.ts
new file mode 100644
index 0000000..b1d1ec0
--- /dev/null
+++ b/src/types/images.d.ts
@@ -0,0 +1,29 @@
+declare module "*.png" {
+ import type { StaticImageData } from "next/image";
+ const content: StaticImageData;
+ export default content;
+}
+
+declare module "*.jpg" {
+ import type { StaticImageData } from "next/image";
+ const content: StaticImageData;
+ export default content;
+}
+
+declare module "*.jpeg" {
+ import type { StaticImageData } from "next/image";
+ const content: StaticImageData;
+ export default content;
+}
+
+declare module "*.webp" {
+ import type { StaticImageData } from "next/image";
+ const content: StaticImageData;
+ export default content;
+}
+
+declare module "*.svg" {
+ import type { StaticImageData } from "next/image";
+ const content: StaticImageData;
+ export default content;
+}