api/src/party/audio-question-generator.ts

@@ -86,8 +86,8 @@ export async function buildAudioMetadataQuestion(
 				question: {
 					type: "choice",
 					text: "What song is currently playing?",
-					options: currentSongOptions.options,
+					options: currentSongOptions,
-					correct: currentSongOptions.correct,
+					correct: 0,
 					points: 10,
 					song: topSong ?? undefined,
 					hideSongTitle: true,
@@ -96,27 +96,27 @@ export async function buildAudioMetadataQuestion(
 		}
 	}
 
-	const genreNames = buildOrderedOptions(getMostSharedGenreNames(analytics), 4);
+	const genreOptions = buildOrderedOptions(
-	if (genreNames) {
+		getMostSharedGenreNames(analytics),
-		const topGenre = genreNames[0];
+		4,
-		if (topGenre) {
+	);
-			const genreOptions = buildOptionsWithCorrect(topGenre, genreNames, 4);
 	if (genreOptions) {
+		const topGenre = genreOptions[0];
+		if (topGenre) {
 			questions.push({
 				key: `audio:genre:${topGenre}`,
 				subjectKey: `genre:${topGenre}`,
 				question: {
 					type: "choice",
 					text: "Which genre appears most in the party analytics?",
-						options: genreOptions.options,
+					options: genreOptions,
-						correct: genreOptions.correct,
+					correct: 0,
 					points: 10,
 					song: topSong ?? undefined,
 				},
 			});
 		}
 	}
-	}
 
 	const topArtistEntities = getFairQuestionArtists(analytics, members, history);
 	const topArtists = topArtistEntities.map((artist) => artist.name);
@@ -135,8 +135,8 @@ export async function buildAudioMetadataQuestion(
 				question: {
 					type: "choice",
 					text: "Which artist shows up most often in the shared audio data?",
-					options: artistOptions.options,
+					options: artistOptions,
-					correct: artistOptions.correct,
+					correct: 0,
 					points: 10,
 					song: topSong ?? undefined,
 				},
@@ -161,8 +161,8 @@ export async function buildAudioMetadataQuestion(
 						getTrackFairness(topTrack, members, history).memberCount > 1
 							? "Which track looks most shared across the party?"
 							: "Which track stands out in the party analytics?",
-					options: trackOptions.options,
+					options: trackOptions,
-					correct: trackOptions.correct,
+					correct: 0,
 					points: 10,
 					song: topSong ?? undefined,
 				},
@@ -184,8 +184,8 @@ export async function buildAudioMetadataQuestion(
 				question: {
 					type: "choice",
 					text: `Which artist appears on "${topTrack.albumName}"?`,
-					options: artistOptions.options,
+					options: artistOptions,
-					correct: artistOptions.correct,
+					correct: 0,
 					points: 10,
 					song: topSong ?? undefined,
 				},
@@ -226,8 +226,8 @@ export async function buildAudioMetadataQuestion(
 					question: {
 						type: "choice",
 						text: "Which of these tracks came out first?",
-						options: options.options,
+						options,
-						correct: options.correct,
+						correct: 0,
 						points: 10,
 						song: topSong ?? undefined,
 					},
@@ -250,8 +250,8 @@ export async function buildAudioMetadataQuestion(
 					question: {
 						type: "choice",
 						text: "Which of these tracks came out most recently?",
-						options: options.options,
+						options,
-						correct: options.correct,
+						correct: 0,
 						points: 10,
 						song: topSong ?? undefined,
 					},
@@ -294,8 +294,8 @@ export async function buildAudioMetadataQuestion(
 				question: {
 					type: "choice",
 					text: `What's the longest track by ${artistName}?`,
-					options: options.options,
+					options,
-					correct: options.correct,
+					correct: 0,
 					points: 10,
 					song: topSong ?? undefined,
 				},
@@ -326,8 +326,8 @@ export async function buildAudioMetadataQuestion(
 					question: {
 						type: "choice",
 						text: `Who performs "${topTrack.name}"?`,
-						options: artistOptions.options,
+						options: artistOptions,
-						correct: artistOptions.correct,
+						correct: 0,
 						points: 10,
 						song: trackSong ?? topSong ?? undefined,
 					},
@@ -348,9 +348,8 @@ export async function buildAudioMetadataQuestion(
 					question: {
 						type: "choice",
 						text: `What is the name of this track by ${correctArtist}?`,
-						options: trackNameOptions.options,
+						options: trackNameOptions,
-						correct: trackNameOptions.correct,
+						correct: 0,
-						hideSongTitle: true,
 						points: 10,
 						song: trackSong ?? topSong ?? undefined,
 					},
@@ -370,8 +369,8 @@ export async function buildAudioMetadataQuestion(
 						question: {
 							type: "choice",
 							text: "Which song is this audio clip from?",
-							options: alternateSongOptions.options,
+							options: alternateSongOptions,
-							correct: alternateSongOptions.correct,
+							correct: 0,
 							points: 10,
 							song: topSong ?? undefined,
 							hideSongTitle: true,
@@ -398,8 +397,8 @@ export async function buildAudioMetadataQuestion(
 					question: {
 						type: "choice",
 						text: `"${topTrack.name}" appears on which album?`,
-						options: albumOptions.options,
+						options: albumOptions,
-						correct: albumOptions.correct,
+						correct: 0,
 						points: 10,
 						song: trackSong ?? topSong ?? undefined,
 					},

api/src/party/question-utils.ts

@@ -745,28 +745,14 @@ export function buildOptionsWithCorrect(
 	correct: string,
 	candidates: string[],
 	desiredCount: number,
-): { options: string[]; correct: number } | null {
+): string[] | null {
 	if (!isUsableText(correct)) return null;
 	const options = uniqueStrings([
 		correct,
 		...candidates.filter((c) => isUsableText(c) && c !== correct),
 	]);
 	const optionCount = getAvailableOptionCount(options.length, desiredCount);
-	if (!optionCount) return null;
+	return optionCount ? options.slice(0, optionCount) : null;
-	const shuffled = shuffleOptions(options.slice(0, optionCount));
-	return { options: shuffled, correct: shuffled.indexOf(correct) };
-}
-
-function shuffleOptions(options: string[]): string[] {
-	const shuffled = options.slice();
-	for (let i = shuffled.length - 1; i > 0; i--) {
-		const j = Math.floor(Math.random() * (i + 1));
-		const value = shuffled[i];
-		if (value === undefined) continue;
-		shuffled[i] = shuffled[j] ?? value;
-		shuffled[j] = value;
-	}
-	return shuffled;
 }
 
 export function pickRandom<T>(items: T[]): T | null {

api/src/party/social-question-generator.ts

@@ -3,7 +3,6 @@ import type { Question, QuizState } from "../party-types";
 import {
 	buildMemberOptions,
 	buildMemberPairOptions,
-	buildOptionsWithCorrect,
 	buildQuestionWindow,
 	getCurrentLeader,
 	getFairQuestionTracks,
@@ -35,18 +34,15 @@ export async function buildSocialQuestion(
 	if (hasMultipleMembers && hasClearLeader(quizState)) {
 		const leader = getCurrentLeader(quizState, members);
 		const options = buildMemberOptions(leader, members);
-		const choices = options
+		if (options) {
-			? buildOptionsWithCorrect(leader.name, options, options.length)
-			: null;
-		if (choices) {
 			questions.push({
 				key: "social:leader",
 				subjectKey: `member:${leader.userId}`,
 				question: {
 					type: "choice",
 					text: "Who is leading the quiz right now?",
-					options: choices.options,
+					options,
-					correct: choices.correct,
+					correct: 0,
 					points: 10,
 					song: topSong ?? undefined,
 				},
@@ -58,18 +54,15 @@ export async function buildSocialQuestion(
 		const diverse = getMostDiverseMember(analytics, members);
 		if (diverse) {
 			const options = buildMemberOptions(diverse, members);
-			const choices = options
+			if (options) {
-				? buildOptionsWithCorrect(diverse.name, options, options.length)
-				: null;
-			if (choices) {
 				questions.push({
 					key: "social:diverse",
 					subjectKey: `member:${diverse.userId}`,
 					question: {
 						type: "choice",
 						text: "Who looks like the most diverse listener in the party?",
-						options: choices.options,
+						options,
-						correct: choices.correct,
+						correct: 0,
 						points: 10,
 						song: topSong ?? undefined,
 					},
@@ -105,10 +98,7 @@ export async function buildSocialQuestion(
 				albumName: topTrack.albumName,
 			});
 			const options = buildMemberOptions(topListener, members);
-			const choices = options
+			if (options) {
-				? buildOptionsWithCorrect(topListener.name, options, options.length)
-				: null;
-			if (choices) {
 				questions.push({
 					key: `social:track-listener:${topTrack.name}`,
 					subjectKey: `track:${topTrack.name}`,
@@ -116,8 +106,8 @@ export async function buildSocialQuestion(
 					question: {
 						type: "choice",
 						text: `Who listens the most to "${topTrack.name}"?`,
-						options: choices.options,
+						options,
-						correct: choices.correct,
+						correct: 0,
 						points: 10,
 						song: trackSong ?? topSong ?? undefined,
 					},
@@ -133,18 +123,15 @@ export async function buildSocialQuestion(
 		if (memberA && memberB) {
 			const correctPair = `${memberA.name} & ${memberB.name}`;
 			const pairOptions = buildMemberPairOptions(members, correctPair);
-			const pairChoices = pairOptions
+			if (pairOptions) {
-				? buildOptionsWithCorrect(correctPair, pairOptions, pairOptions.length)
-				: null;
-			if (pairChoices) {
 				questions.push({
 					key: `social:pair:${memberA.userId}:${memberB.userId}`,
 					subjectKey: `pair:${[memberA.userId, memberB.userId].sort().join("|")}`,
 					question: {
 						type: "choice",
 						text: "Which two players share the most musical taste?",
-						options: pairChoices.options,
+						options: pairOptions,
-						correct: pairChoices.correct,
+						correct: 0,
 						points: 10,
 						song: topSong ?? undefined,
 					},

api/src/party/state.ts

@@ -1,7 +1,7 @@
 import { eq } from "drizzle-orm";
 import type { db as Db } from "../db";
 import { party } from "../db/schema";
-import type { PartySocketEvent, PartyStatus, QuizState } from "../party-types";
+import type { PartySocketEvent, QuizState } from "../party-types";
 import { publishDeviceEventForUser } from "../routes/device-socket";
 import { pubsub } from "../routes/party-socket";
 
@@ -9,7 +9,6 @@ export async function updatePartyData(
 	db: typeof Db,
 	id: string,
 	data: QuizState,
-	status?: PartyStatus,
 ) {
 	const members = await db.query.partyMember.findMany({
 		where: {
@@ -25,29 +24,22 @@ export async function updatePartyData(
 		},
 	});
 	if (!partyObject) throw new Error("Missing party");
-	const updatedParty = {
-		...partyObject,
-		status: status ?? partyObject.status,
-		data,
-	};
-	await db
-		.update(party)
-		.set({
-			data,
-			...(status ? { status } : {}),
-			lastUpdated: new Date(),
-		})
-		.where(eq(party.id, id));
 
 	pubsub.publishPartyData(id, {
 		type: "party_status",
-		party: updatedParty,
+		party: {
+			...partyObject,
+			data,
+		},
 		members,
 	});
 
 	const event: PartySocketEvent = {
 		type: "party_status",
-		party: updatedParty,
+		party: {
+			...partyObject,
+			data,
+		},
 		members,
 	};
 	for (const member of members) {
@@ -56,10 +48,20 @@ export async function updatePartyData(
 			`user:${member.userId}`,
 			JSON.stringify({
 				type: "party_status",
-				party: updatedParty,
+				party: {
+					...partyObject,
+					data,
+				},
 				members,
 			}),
 		);
 		void publishDeviceEventForUser(member.userId, event);
 	}
+	await db
+		.update(party)
+		.set({
+			data: data,
+			lastUpdated: new Date(),
+		})
+		.where(eq(party.id, id));
 }

api/src/routes/device-socket.ts

@@ -73,15 +73,6 @@ function isDeviceQuizResponsePayload(
 	);
 }
 
-function isValidAnswer(quizData: QuizState, selected: number): boolean {
-	const question = quizData.currentQuestion;
-	if (!question) return false;
-	if (question.type === "choice") {
-		return selected >= 0 && selected < question.options.length;
-	}
-	return selected >= question.range.min && selected <= question.range.max;
-}
-
 function sendDeviceEvent(deviceId: string, event: DeviceProxyEvent) {
 	if (!devProxySocket) {
 		console.log("[device-socket] no dev proxy for event", deviceId, event.type);
@@ -244,13 +235,6 @@ async function forwardDevicePayload(deviceId: string, payload: unknown) {
 		});
 		return;
 	}
-	if (!isValidAnswer(quizData, payload.QuizResponse)) {
-		sendDeviceEvent(deviceId, {
-			type: "error",
-			message: "Invalid answer.",
-		});
-		return;
-	}
 
 	await DBOS.send(
 		quizData.workflowId,

api/src/routes/party-socket.ts

@@ -4,7 +4,7 @@ import { betterAuthElysia } from "../auth";
 
 import { db } from "../db";
 import { getMemberRecord, getPartyStatus } from "../party-data";
-import type { PartySocketEvent } from "../party-types";
+import type { PartySocketEvent, QuizState } from "../party-types";
 
 export function userTopic(userId: string) {
 	return `user:${userId}`;
@@ -63,6 +63,31 @@ async function subscribeWsToParty(
 	return nextPartyId;
 }
 
+export async function broadcastQuizState(
+	ws: { publish: (topic: string, message: string) => void },
+	partyId: string,
+) {
+	const partyRecord = await db.query.party.findFirst({
+		where: { id: partyId },
+	});
+
+	if (!partyRecord) return;
+
+	const quizData = ((partyRecord.data ?? {}) as Record<string, unknown>).quiz as
+		| QuizState
+		| undefined;
+	if (!quizData) return;
+	if (!quizData) return;
+
+	ws.publish(
+		partyTopic(partyId),
+		JSON.stringify({
+			type: "quiz_state",
+			quiz: quizData,
+		}),
+	);
+}
+
 export const topic = {
 	user: userTopic,
 	party: partyTopic,
@@ -93,6 +118,8 @@ export const partySocketApp = new Elysia()
 						);
 						return;
 					}
+
+					await broadcastQuizState(ws, subscribedPartyId);
 				},
 				message: async (ws, message) => {
 					const data = ws.data;

api/src/routes/quiz.ts

@@ -26,15 +26,6 @@ function broadcastStatusToMembers(
 
 const quizWf = new QuizWorkflow();
 
-function isValidAnswer(quizData: QuizState, selected: number): boolean {
-	const question = quizData.currentQuestion;
-	if (!question) return false;
-	if (question.type === "choice") {
-		return selected >= 0 && selected < question.options.length;
-	}
-	return selected >= question.range.min && selected <= question.range.max;
-}
-
 export const quizRoutes = new Elysia()
 	.use(betterAuthElysia)
 	.group("/party/:partyId/quiz", (app) =>
@@ -60,6 +51,11 @@ export const quizRoutes = new Elysia()
 						return { error: "Quiz already running" };
 					}
 
+					const handle = await DBOS.startWorkflow(quizWf.startQuiz, {
+						queueName: quizQueue.name,
+						enqueueOptions: { queuePartitionKey: params.partyId },
+					})(params.partyId);
+
 					await db
 						.update(party)
 						.set({
@@ -69,11 +65,6 @@ export const quizRoutes = new Elysia()
 						})
 						.where(eq(party.id, params.partyId));
 
-					const handle = await DBOS.startWorkflow(quizWf.startQuiz, {
-						queueName: quizQueue.name,
-						enqueueOptions: { queuePartitionKey: params.partyId },
-					})(params.partyId);
-
 					const status = await getPartyStatus(params.partyId);
 					broadcastStatusToMembers(status);
 
@@ -136,12 +127,6 @@ export const quizRoutes = new Elysia()
 			.post(
 				"/response",
 				async ({ user, body, params, set }) => {
-					const membership = await getMemberRecord(db, user.id);
-					if (!membership || membership.partyId !== params.partyId) {
-						set.status = 403;
-						return { error: "Not a member of this party" };
-					}
-
 					const party = await db.query.party.findFirst({
 						where: {
 							id: params.partyId,
@@ -163,25 +148,10 @@ export const quizRoutes = new Elysia()
 						set.status = 500;
 						return { error: "Workflow ID not found" };
 					}
-					if (
-						body.questionIndex !== undefined &&
-						body.questionIndex !== quizData.questionIndex
-					) {
-						set.status = 409;
-						return { error: "Stale question response" };
-					}
-					if (!isValidAnswer(quizData, body.selected)) {
-						set.status = 400;
-						return { error: "Invalid answer" };
-					}
 
 					await DBOS.send(
 						quizData.workflowId,
-						{
+						{ playerId: user.id, selected: body.selected },
-							playerId: user.id,
-							selected: body.selected,
-							questionIndex: body.questionIndex,
-						},
 						"quiz_responses",
 					);
 
@@ -191,7 +161,6 @@ export const quizRoutes = new Elysia()
 					auth: true,
 					body: t.Object({
 						selected: t.Integer(),
-						questionIndex: t.Optional(t.Integer()),
 					}),
 				},
 			),

api/src/workflows/quiz.ts

@@ -24,7 +24,6 @@ export const quizQueue = new WorkflowQueue("quiz_queue", {
 type Response = {
 	playerId: string;
 	selected: number;
-	questionIndex?: number;
 };
 
 export class QuizWorkflow extends ConfiguredInstance {
@@ -54,15 +53,15 @@ export class QuizWorkflow extends ConfiguredInstance {
 			history: [],
 		};
 
+		// Initialize quiz state
+		await QuizWorkflow.updatePartyData(partyId, quizState);
+
 		// Get party members to initialize scores
 		let members = await QuizWorkflow.getPartyMembers(partyId);
 		for (const member of members) {
 			quizState.scores[member.userId] = 0;
 		}
 
-		// Initialize quiz state after scores are ready.
-		await QuizWorkflow.updatePartyData(partyId, quizState);
-
 		for (let i = 0; i < TOTAL_QUESTIONS; i++) {
 			quizState.status = "running";
 			quizState.questionIndex = i;
@@ -97,7 +96,7 @@ export class QuizWorkflow extends ConfiguredInstance {
 
 				if (response === null) {
 					// Timeout - fill in missing players with no answer
-					const now = await DBOS.now();
+					const now = Date.now();
 					if (now < question.endTimestamp) continue;
 					for (const memberId of memberIds) {
 						if (!receivedPlayers.has(memberId)) {
@@ -117,17 +116,10 @@ export class QuizWorkflow extends ConfiguredInstance {
 					break;
 				}
 
-				if (!memberIds.has(response.playerId)) continue;
-				if (
-					response.questionIndex !== undefined &&
-					response.questionIndex !== i
-				) {
-					continue;
-				}
 				if (receivedPlayers.has(response.playerId)) continue;
 
 				receivedPlayers.add(response.playerId);
-				const answeredAt = await DBOS.now();
+				const answeredAt = Date.now();
 				const selectedValue = response.selected;
 				const isCorrect = selectedValue === question.correct;
 				const quizResponse: QuizResponse = {
@@ -156,16 +148,15 @@ export class QuizWorkflow extends ConfiguredInstance {
 
 		// Quiz complete
 		quizState.status = "results";
-		await QuizWorkflow.updatePartyData(partyId, quizState, "ended");
+		await QuizWorkflow.updatePartyData(partyId, quizState);
 	}
 
 	@DBOS.step()
 	private static async updatePartyData(
 		partyId: string,
 		quizState: QuizState,
-		status?: "created" | "started" | "ended",
 	): Promise<void> {
-		await updatePartyData(db, partyId, quizState, status);
+		await updatePartyData(db, partyId, quizState);
 	}
 
 	@DBOS.step()
@@ -224,9 +215,10 @@ export class QuizWorkflow extends ConfiguredInstance {
 		}
 
 		if (groups.length <= 1) {
-			const onlyDistance = groups[0]?.distance ?? Number.POSITIVE_INFINITY;
+			return ordered.map(({ response }) => [
-			const gained = onlyDistance === 0 ? round.question.points : 0;
+				response.playerId,
-			return ordered.map(({ response }) => [response.playerId, gained]);
+				round.question.points,
+			]);
 		}
 
 		const scoredAnswers = groups.flatMap((group, index) => {

web/src/components/party/question.tsx

@@ -55,11 +55,6 @@ export function Question() {
 	const [isSubmitting, setIsSubmitting] = useState(false);
 	const question = party?.data?.currentQuestion;
 	const questionStartTimestamp = question?.startTimestamp ?? null;
-	const questionResetKey = question
-		? `${party?.data?.questionIndex ?? 0}:${question.startTimestamp}`
-		: null;
-	const numericInitialValue =
-		question?.type === "numeric" ? question.range.min : null;
 	const questionAnnouncement = question
 		? getQuestionAnnouncement(question)
 		: null;
@@ -73,10 +68,10 @@ export function Question() {
 	}, []);
 
 	useEffect(() => {
-		if (!questionResetKey) return;
+		if (!question) return;
 		setSelected(null);
-		setSelectedValue(numericInitialValue);
+		setSelectedValue(question.type === "numeric" ? question.range.min : null);
-	}, [questionResetKey, numericInitialValue]);
+	}, [question]);
 
 	useEffect(() => {
 		if (
@@ -106,7 +101,6 @@ export function Question() {
 		);
 
 	const partyId = party.id;
-	const questionIndex = party.data.questionIndex;
 	const timeLeft = formatTimeLeft(question.endTimestamp - now);
 	const answeredCount = Object.keys(party.data.answers).length;
 	const hasResponded = user ? party.data.answers[user.id] != null : false;
@@ -134,7 +128,6 @@ export function Question() {
 		try {
 			await client.api.party({ partyId }).quiz.response.post({
 				selected: optionIndex,
-				questionIndex,
 			});
 		} finally {
 			setIsSubmitting(false);
@@ -149,7 +142,6 @@ export function Question() {
 		try {
 			await client.api.party({ partyId }).quiz.response.post({
 				selected: value,
-				questionIndex,
 			});
 		} finally {
 			setIsSubmitting(false);

web/src/hooks/use-party-socket.ts

@@ -50,12 +50,7 @@ export function usePartySocket({
 			};
 
 			ws.onmessage = (event) => {
-				let parsed: PartySocketEvent;
+				const parsed = JSON.parse(event.data) as PartySocketEvent;
-				try {
-					parsed = JSON.parse(event.data) as PartySocketEvent;
-				} catch {
-					return;
-				}
 				handlerRef.current?.(parsed);
 			};
 

web/vite.config.ts

@@ -23,7 +23,7 @@ const config = defineConfig({
 		}),
 	],
 	server: {
-		allowedHosts: ["aura.rpi1.danbulant.cloud", "fern.rpi1.danbulant.cloud"],
+		allowedHosts: ["aura.rpi1.danbulant.cloud"],
 		proxy: {
 			"/api": {
 				target: "http://localhost:4000",