aknuth/wm-projekt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rm logs + caching

Browse Source
This commit is contained in:
Andreas Knuth
2026-06-27 14:17:16 -05:00
parent 2b3cadfcb5
commit 89a9075391
3 changed files with 10 additions and 173 deletions
Download Patch File Download Diff File Expand all files Collapse all files

123
lib/feeds.ts
View File

@@ -267,7 +267,7 @@ function safeParse<T>(s: string, fallback: T): T {
// Holt alle WM-Spiele über den Series-Endpoint mit Pagination.
// Parst pro Event die drei Moneyline-Märkte (Heim/Draw/Auswärts).
export async function fetchOdds(): Promise<ParsedOdds[]> {
return cached("pm:odds", 120_000, async () => {
return cached("pm:odds", 300_000, async () => {
const allEvents: PmEvent[] = [];
for (let offset = 0; ; offset += 100) {
const url = `${PM_BASE}/events?series_id=${PM_SERIES}&active=true&closed=false&limit=100&offset=${offset}`;
@@ -321,22 +321,11 @@ export async function fetchOdds(): Promise<ParsedOdds[]> {
}
if (pHome > 0 || pDraw > 0 || pAway > 0) {
const rawStartDate = (ev as any).startDate ?? null;
const rawEndDate = (ev as any).endDate ?? null;
const rawGameStartTime = (ev as any).gameStartTime ?? null;
const startTime = marketGameStartTime ?? rawGameStartTime ?? rawEndDate ?? rawStartDate;
console.log(" [PM-RAW-ML]", ev.slug,
"| active:", (ev as any).active, "| closed:", (ev as any).closed,
"| startDate:", rawStartDate,
"| gameStartTime:", rawGameStartTime,
"| mkGameStartTime:", marketGameStartTime,
"| endDate:", rawEndDate);
const startTime = marketGameStartTime ?? (ev as any).gameStartTime ?? (ev as any).endDate ?? (ev as any).startDate;
parsed.push({ slug: ev.slug, homeCode, awayCode, homeName, awayName, pHome, pDraw, pAway, startTime });
}
}
console.log("[PM-RAW]", new Date().toISOString(), "| events gesamt:", allEvents.length);
console.log("[PM-LOAD]", new Date().toISOString(), "| moneyline-events:", parsed.length, "| events gesamt:", allEvents.length);
console.log("[polymarket] spiele:", parsed.length);
return parsed;
});
@@ -376,17 +365,6 @@ export function attachOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]):
oddsMatch.set(o, { homeId, awayId });
} else {
oddsMatch.set(o, null);
const feedMatchesWithTheseTeams = matches.filter(m =>
m.homeTeamId && m.awayTeamId &&
((m.homeTeamId === homeId && m.awayTeamId === awayId) ||
(m.homeTeamId === awayId && m.awayTeamId === homeId)),
);
console.log("[PM-NOMATCH]", o.homeName, "vs", o.awayName, "| slug:", o.slug);
console.log("[PM-NOMATCH-WHY]", o.homeName, "vs", o.awayName,
"| homeId gefunden:", !!homeId,
"| awayId gefunden:", !!awayId,
"| homeCode:", o.homeCode, "| awayCode:", o.awayCode,
"| feed-matches mit diesen teams:", feedMatchesWithTheseTeams.length);
}
}
@@ -402,10 +380,6 @@ export function attachOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]):
(ids.homeId === m.awayTeamId && ids.awayId === m.homeTeamId)) {
const swapped = ids.homeId === m.awayTeamId;
attachedOdds.add(o);
console.log("[PM-ATTACH]", o.homeName, "vs", o.awayName,
"| match gefunden:", true,
"| match.status:", m.status,
"| prob gesetzt:", true);
return {
...m,
prob: {
@@ -419,22 +393,6 @@ export function attachOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]):
return m;
});
for (const [o, ids] of oddsMatch) {
if (ids && !attachedOdds.has(o)) {
const matchingFeedMatch = matches.find(m =>
m.homeTeamId && m.awayTeamId &&
((m.homeTeamId === ids.homeId && m.awayTeamId === ids.awayId) ||
(m.homeTeamId === ids.awayId && m.awayTeamId === ids.homeId)),
);
console.log("[PM-NOMATCH]", o.homeName, "vs", o.awayName, "| slug:", o.slug);
console.log("[PM-NOMATCH-WHY]", o.homeName, "vs", o.awayName,
"| team-ids gematcht:", ids.homeId, "vs", ids.awayId,
"| feed-match mit diesen teams existiert:", !!matchingFeedMatch,
"| feed-match status:", matchingFeedMatch?.status ?? "—",
"| prob bereits gesetzt:", matchingFeedMatch?.prob ? "ja" : "nein");
}
}
return result;
}
@@ -484,13 +442,6 @@ function resolveR32Pairings(matches: Match[], teams: Team[]): Map<number, { home
}
}
console.log("[R32-PAIRS] aufgelöste Paarungen:", pairings.size);
for (const [num, p] of pairings) {
const h = teams.find(t=>t.id===p.homeTeamId)?.name ?? p.homeTeamId;
const a = teams.find(t=>t.id===p.awayTeamId)?.name ?? p.awayTeamId;
console.log(" [R32-PAIR]", "matchNumber:", num, "|", h, "vs", a);
}
return pairings;
}
@@ -515,10 +466,6 @@ function slugToDate(slug: string): string | null {
// Slug (Stufe 2) — KEINE chronologische Nummernvergabe.
// Mutiert matches in-place, setzt nur bei Matches OHNE bestehende prob.
export function attachKOOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]): Match[] {
const koOhneProb = matches.filter(m => m.group == null && m.prob == null).length;
console.log("[KO-ODDS] start | odds-events:", odds?.length ?? "undefined",
"| ko-matches ohne prob:", koOhneProb);
const pairings = resolveR32Pairings(matches, teams);
if (pairings.size === 0) return matches;
@@ -529,14 +476,9 @@ export function attachKOOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]
}
const idByCode = new Map(teams.map((t) => [t.code.toLowerCase(), t.id]));
console.log("[KO-LOOP] start | pairings:", pairings.size, "| odds-events:", odds?.length ?? "undef");
for (const [matchNum, pairing] of pairings) {
if (!pairing.homeTeamId || !pairing.awayTeamId) continue;
const hName = teams.find(t => t.id === pairing.homeTeamId)?.name ?? "?";
const aName = teams.find(t => t.id === pairing.awayTeamId)?.name ?? "?";
// Finde Polymarket-Event für dieses Team-Paar
let matchedEvent: ParsedOdds | null = null;
for (const o of odds) {
@@ -552,24 +494,15 @@ export function attachKOOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]
}
}
if (!matchedEvent) {
console.log("[KO-TRY]", "matchNumber:", matchNum,
"| teams:", `${hName} vs ${aName}`,
"| polymarket-event gefunden:", false,
"| ziel-feedmatch gefunden:", false,
"| stufe:", "keine");
continue;
}
if (!matchedEvent) continue;
// Ziel-Feed-Match identifizieren
let targetMatch: Match | undefined;
let stufe: string | undefined;
// Stufe 1: bereits nummeriertes R32-Match (via assignKONumbersBySlots Pass 1)
targetMatch = matches.find(m =>
m.stage === "R32" && m.group == null && m.matchNumber === matchNum,
);
if (targetMatch) stufe = "1 (nummeriert)";
// Stufe 2: Datums-Lookup aus Polymarket-Slug für unnummerierte Matches
if (!targetMatch) {
@@ -583,7 +516,6 @@ export function attachKOOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]
if (candidates.length === 1) {
targetMatch = candidates[0];
targetMatch.matchNumber = matchNum;
stufe = "2 (datum)";
} else if (candidates.length > 1) {
// Tie-breaker: falls Polymarket-Event eine Startzeit hat, nächstgelegenes Feed-Match
if (matchedEvent.startTime) {
@@ -598,48 +530,16 @@ export function attachKOOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]
if (best && bestDiff < 4 * 60 * 60 * 1000) {
targetMatch = best;
targetMatch.matchNumber = matchNum;
stufe = "2 (datum+tie)";
}
}
console.log("[KO-TIME]", "slot:", matchNum,
"| teams:", `${hName} vs ${aName}`,
"| pm-gameStartTime(UTC):", matchedEvent.startTime,
"| feed-kandidaten:", candidates.map(c =>
`${c.id}(${c.utcDate})`,
).join(", "),
"| gewählt:", targetMatch?.id ?? "keins");
if (!targetMatch) {
console.log("[KO-TIE]", "matchNumber:", matchNum,
"| slug:", matchedEvent.slug,
"| slugDate:", slugDate,
"| startTime:", matchedEvent.startTime,
"| candidates:", candidates.map(c =>
`${c.id}(${c.utcDate})`,
).join(", "));
}
}
}
}
if (!targetMatch) {
console.log("[KO-TRY]", "matchNumber:", matchNum,
"| teams:", `${hName} vs ${aName}`,
"| polymarket-event gefunden:", true,
"| ziel-feedmatch gefunden:", false,
"| stufe:", stufe ?? "keine");
continue;
}
if (!targetMatch) continue;
// prob nicht überschreiben, falls schon gesetzt
if (targetMatch.prob) {
console.log("[KO-TRY]", "matchNumber:", matchNum,
"| teams:", `${hName} vs ${aName}`,
"| polymarket-event gefunden:", true,
"| ziel-feedmatch gefunden:", true,
"| stufe:", stufe,
"| prob bereits gesetzt:", true);
continue;
}
if (targetMatch.prob) continue;
const homeIdFromEvent = idByName.get(normName(matchedEvent.homeName)) ??
idByCode.get(matchedEvent.homeCode);
@@ -650,17 +550,6 @@ export function attachKOOdds(matches: Match[], teams: Team[], odds: ParsedOdds[]
draw: matchedEvent.pDraw,
away: swapped ? matchedEvent.pHome : matchedEvent.pAway,
};
console.log("[PM-ATTACH]", matchedEvent.homeName, "vs", matchedEvent.awayName,
"| match gefunden via R32:", true,
"| match.status:", targetMatch.status,
"| matchNumber:", targetMatch.matchNumber,
"| prob gesetzt:", true);
console.log("[KO-TRY]", "matchNumber:", matchNum,
"| teams:", `${hName} vs ${aName}`,
"| polymarket-event gefunden:", !!matchedEvent,
"| ziel-feedmatch gefunden:", !!targetMatch,
"| stufe:", stufe);
}
return matches;
@@ -696,7 +585,7 @@ export async function fetchLiveScores(): Promise<LiveScore[]> {
const res = await fetch(`${WC26_BASE}/get/games`, {
cache: "no-store",
headers: { "User-Agent": "wm2026-board/1.0" },
signal: AbortSignal.timeout(8000),
signal: AbortSignal.timeout(5000),
});
if (!res.ok) throw new Error(`worldcup26 ${res.status}`);
const data = (await res.json()) as { games: Wc26Game[] };