sendou.ink/app/features/scrims/core/ScrimMapByMap.ts

import type { Tables } from "~/db/tables";
import * as MapList from "~/features/map-list-generator/core/MapList";
import { MapPool } from "~/features/map-list-generator/core/map-pool";
import type { MapPoolObject } from "~/features/map-list-generator/core/map-pool-serializer/types";
import { modesShort } from "~/modules/in-game-lists/modes";
import type { ModeShort, StageId } from "~/modules/in-game-lists/types";

type ResolvedMapListRow = {
	mapList: Array<{ mode: ModeShort; stageId: StageId }>;
};

type ScrimMapRow = Pick<
	Tables["ScrimMap"],
	"index" | "mode" | "stageId" | "winnerSide" | "reportedAt"
>;

/**
 * Merges the submitted map lists into a single deduplicated MapPool.
 */
export function unionPool(lists: ResolvedMapListRow[]): MapPool {
	const buckets: Record<ModeShort, Set<StageId>> = {
		TW: new Set(),
		SZ: new Set(),
		TC: new Set(),
		RM: new Set(),
		CB: new Set(),
	};

	for (const list of lists) {
		for (const { mode, stageId } of list.mapList) {
			buckets[mode].add(stageId);
		}
	}

	const merged: MapPoolObject = {
		TW: [...buckets.TW],
		SZ: [...buckets.SZ],
		TC: [...buckets.TC],
		RM: [...buckets.RM],
		CB: [...buckets.CB],
	};

	return new MapPool(merged);
}

/**
 * Generates the next single map for the scrim, keeping the pool's mode order
 * stable across calls and avoiding already-played `(mode, stage)` pairs.
 */
export function generateNextMap(args: {
	pool: MapPool;
	history: Pick<Tables["ScrimMap"], "mode" | "stageId">[];
}): { mode: ModeShort; stageId: StageId } {
	if (args.pool.isEmpty()) {
		throw new Error("Cannot generate map from empty pool");
	}

	const generator = MapList.resume({
		mapPool: args.pool,
		history: args.history,
	});

	generator.next();
	const result = generator.next({ amount: 1 }).value;

	if (!result || result.length === 0) {
		throw new Error("Failed to generate map");
	}

	return { mode: result[0].mode, stageId: result[0].stageId };
}

/**
 * Returns true when the given map is the most recently reported one and is
 * therefore eligible to be undone.
 */
export function canUndo(
	map: ScrimMapRow | undefined,
	history: ScrimMapRow[],
): boolean {
	if (!map || map.reportedAt === null) return false;

	for (const other of history) {
		if (other.reportedAt === null) continue;
		if (other.index > map.index) return false;
	}

	return true;
}

export type StatsRow = {
	key: string;
	wins: number;
	losses: number;
};

export type Stats = {
	byMode: StatsRow[];
	byStage: StatsRow[];
	byStageMode: StatsRow[];
};

/**
 * Aggregates per-mode, per-stage, and per-(stage, mode) win/loss counts from
 * the viewer's perspective. Maps outside `restrictToPool` (when provided) are
 * skipped, as are unreported maps. Empty rows are filtered out.
 */
export function stats(
	maps: ScrimMapRow[],
	viewerSide: "ALPHA" | "BRAVO",
	opts: { restrictToPool?: MapPool } = {},
): Stats {
	const byMode = new Map<ModeShort, StatsRow>();
	const byStage = new Map<StageId, StatsRow>();
	const byStageMode = new Map<string, StatsRow>();

	const stageModeKey = (mode: ModeShort, stageId: StageId) =>
		`${stageId}-${mode}`;

	const bump = <K>(
		bucket: Map<K, StatsRow>,
		key: K,
		display: string,
		isWin: boolean,
	) => {
		const existing = bucket.get(key);
		if (existing) {
			if (isWin) existing.wins += 1;
			else existing.losses += 1;
			return;
		}
		bucket.set(key, {
			key: display,
			wins: isWin ? 1 : 0,
			losses: isWin ? 0 : 1,
		});
	};

	for (const map of maps) {
		if (map.reportedAt === null || map.winnerSide === null) continue;
		if (
			opts.restrictToPool &&
			!opts.restrictToPool.has({ mode: map.mode, stageId: map.stageId })
		) {
			continue;
		}

		const isWin = map.winnerSide === viewerSide;

		bump(byMode, map.mode, map.mode, isWin);
		bump(byStage, map.stageId, String(map.stageId), isWin);
		bump(
			byStageMode,
			stageModeKey(map.mode, map.stageId),
			stageModeKey(map.mode, map.stageId),
			isWin,
		);
	}

	const filterEmpty = (rows: StatsRow[]) =>
		rows.filter((r) => r.wins + r.losses > 0);

	const orderedByMode: StatsRow[] = [];
	for (const mode of modesShort) {
		const row = byMode.get(mode);
		if (row) orderedByMode.push(row);
	}

	return {
		byMode: filterEmpty(orderedByMode),
		byStage: filterEmpty([...byStage.values()]),
		byStageMode: filterEmpty([...byStageMode.values()]),
	};
}