import { NextRequest, NextResponse } from 'next/server';
import db from '@/lib/astradb'; // Import the initialized Db instance
import logger from '@/lib/logger';
import { PlayerState } from '../game/types'; // Import core types
// Define interface for Player DB record, adding _id and userId
interface PlayerRecord extends PlayerState {
_id: string;
userId: string; // Add userId here
}
// Get typed collection instance
const playersCollection = db.collection<PlayerRecord>('game_players');
/**
* GET /api/leaderboard
* Retrieves the leaderboard data (player progress) for a specific story.
* Required for MCP tool operation (MCP 'getLeaderboard' operation).
* Also used by the frontend for leaderboard display.
*/
// GET /api/leaderboard?storyId=...
export async function GET(request: NextRequest) {
try {
// Read storyId from query parameters
const url = new URL(request.url);
const storyId = url.searchParams.get('storyId');
if (!storyId) {
return NextResponse.json({ error: 'Story ID query parameter is required' }, { status: 400 });
}
logger.debug(`Fetching leaderboard data for story: ${storyId}...`);
// Fetch players for the relevant story using the provided storyId
const cursor = playersCollection.find({ storyId: storyId });
// Define sort order
cursor.sort({ 'gameProgress.storyProgress': -1 }); // -1 for descending
// Optionally limit the leaderboard size
// cursor.limit(10);
const players = await cursor.toArray();
if (players.length > 0) {
logger.debug(`Found ${players.length} players for leaderboard.`);
}
// Defensive winner logic
let goalRoomId: string | undefined;
let requiredArtifacts: string[] = [];
if (players.length > 0) {
// Fetch the story to get goalRoomId and requiredArtifacts
let story = await db.collection('game_stories').findOne({ id: storyId });
if (!story) {
story = await db.collection('game_stories').findOne({ _id: storyId });
}
if (story) {
goalRoomId = story.goalRoomId;
requiredArtifacts = story.requiredArtifacts || [];
}
}
// Map player data to the format expected by the client/frontend
const leaderboardData = players.map(player => {
const inGoalRoom = goalRoomId && player.currentLocation === goalRoomId;
const hasAllArtifacts = requiredArtifacts.length > 0 ? requiredArtifacts.every((artifactId: string) => player.inventory.includes(artifactId)) : true;
const isWinner = player.status === 'winner' && inGoalRoom && hasAllArtifacts;
return {
id: player.userId, // Use userId instead of id
room: player.currentLocation, // Use currentLocation for room
inventory: player.inventory,
reachedGoal: player.gameProgress.storyProgress >= 100,
score: player.gameProgress.storyProgress,
isWinner,
status: player.status || 'playing',
};
});
return NextResponse.json(leaderboardData);
} catch (error) {
logger.error('Error fetching leaderboard:', error);
return NextResponse.json(
{ error: 'Failed to fetch leaderboard data' },
{ status: 500 }
);
}
}
