🤖 AI Fantasy Baseball Performance Analysis

Team: ${config.teamKey}

League: ${config.leagueId}

Analysis Date: ${new Date().toLocaleDateString()}

\n\n

📊 Performance Summary

\n`;\n\n if (analysisResult.analysis?.overall_assessment) {\n const assessment = analysisResult.analysis.overall_assessment;\n emailBody += `\n

Team Grade: ${assessment.team_grade || \"N/A\"}

Performance Rating: ${assessment.performance_rating || \"N/A\"}/100

Competitive Outlook: ${assessment.competitive_outlook || \"Analysis pending\"}

\n`;\n }\n\n if (hasRecommendations) {\n emailBody += `\n

🎯 Waiver Wire Recommendations

Found ${analysisResult.recommendations.length} potential pickups (${highConfidenceRecs.length} high-confidence)

\n`;\n\n if (highConfidenceRecs.length > 0) {\n emailBody += \"

High-Confidence Pickups:

${rec.player_name} (${rec.confidence}% confidence)\n
Position: ${rec.eligible_positions?.join(\", \") || \"N/A\"}\n
Reason: ${rec.reasoning || \"Analysis available in dashboard\"}\n

\";\n }\n } else {\n emailBody += `\n

✅ No Action Needed

Your team is performing well! No high-confidence waiver wire recommendations at this time.

\n`;\n }\n\n emailBody += `\n

This analysis was generated automatically. Access your full dashboard for detailed insights.

\n`;\n\n await email({\n subject,\n html: emailBody,\n });\n\n console.log(`📧 Email notification sent for ${config.userId}`);\n } catch (error) {\n console.error(\"Failed to send email notification:\", error);\n }\n}\n\n/**\n * Add or update a scheduler configuration\n */\nexport async function addSchedulerConfig(config: SchedulerConfig): Promise {\n try {\n const configs = await getSchedulerConfigs();\n\n // Remove existing config for same user/league if it exists\n const filteredConfigs = configs.filter(c => !(c.userId === config.userId && c.leagueId === config.leagueId));\n\n // Add new config\n filteredConfigs.push(config);\n\n await blob.setJSON(\"ai_performance_scheduler_configs\", filteredConfigs);\n console.log(`✅ Scheduler config added for user ${config.userId}`);\n } catch (error) {\n console.error(\"Failed to add scheduler config:\", error);\n throw error;\n }\n}\n\n/**\n * Remove a scheduler configuration\n */\nexport async function removeSchedulerConfig(userId: string, leagueId: string): Promise {\n try {\n const configs = await getSchedulerConfigs();\n const filteredConfigs = configs.filter(c => !(c.userId === userId && c.leagueId === leagueId));\n\n await blob.setJSON(\"ai_performance_scheduler_configs\", filteredConfigs);\n console.log(`✅ Scheduler config removed for user ${userId}`);\n } catch (error) {\n console.error(\"Failed to remove scheduler config:\", error);\n throw error;\n }\n}\n\n/**\n * Get latest analysis result for a user\n */\nexport async function getLatestAnalysis(userId: string): Promise {\n try {\n const key = `ai_analysis_latest_${userId}`;\n const result = await blob.getJSON(key);\n return result || null;\n } catch (error) {\n console.log(`No latest analysis found for user ${userId}`);\n return null;\n }\n}\n\n/**\n * Get scheduler execution summary\n */\nexport async function getSchedulerSummary(): Promise {\n try {\n const summary = await blob.getJSON(\"ai_scheduler_latest_summary\");\n return summary || { message: \"No scheduler runs found\" };\n } catch (error) {\n return { error: \"Failed to retrieve scheduler summary\" };\n }\n}",[],[151,213],{"_108":223,"_100":224,"_152":225,"_154":153,"_155":139,"_156":138,"_158":159,"_110":226,"_105":227,"_162":187,"_164":228,"_165":27,"_166":-5,"_167":229,"_103":230},"e0457732-4af3-11f0-b62b-76b3cceeab13","ai_performance_yahoo_integration.ts","8247ac30-4abd-11f0-9257-76b3cceeab13",["D",1750107174855],10,"// Lou Fantasy Baseball Performance Statistics Analyzer\n// Advanced analytics and performance insights for Yahoo Fantasy Baseball\n\nimport {\n FantasyStats,\n PlayerPerformanceStats,\n TeamPerformanceStats,\n WaiverWirePlayer,\n YahooAPIConfig,\n} from \"../daily_lineup_scheduler.tsx\";\nimport { LouTokenStorage } from \"../token_storage.tsx\";\n\nexport interface PerformanceAnalysisReport {\n team_analysis: {\n overall_performance: TeamPerformanceStats;\n strengths: string[];\n weaknesses: string[];\n improvement_suggestions: string[];\n };\n player_insights: {\n top_performers: PlayerPerformanceStats[];\n underperformers: PlayerPerformanceStats[];\n injury_concerns: PlayerPerformanceStats[];\n breakout_candidates: PlayerPerformanceStats[];\n };\n waiver_recommendations: {\n immediate_needs: WaiverWirePlayer[];\n long_term_targets: WaiverWirePlayer[];\n drop_candidates: PlayerPerformanceStats[];\n };\n competitive_analysis: {\n league_ranking: number;\n playoff_chances: number; // 0-100 percentage\n key_competitors: string[];\n points_gap: number;\n };\n}\n\nexport interface WeeklyTrends {\n week: number;\n batting_performance: {\n runs: number;\n home_runs: number;\n rbi: number;\n stolen_bases: number;\n batting_avg: number;\n };\n pitching_performance: {\n wins: number;\n saves: number;\n strikeouts: number;\n era: number;\n whip: number;\n innings_pitched: number;\n };\n fantasy_points: number;\n opponent: string;\n result: \"W\" | \"L\" | \"T\";\n}\n\nexport class LouPerformanceAnalyzer {\n private tokenStorage: LouTokenStorage;\n\n constructor() {\n this.tokenStorage = new LouTokenStorage();\n }\n\n /**\n * Generate comprehensive performance analysis report for a team\n * @param userId - User ID\n * @param leagueId - League ID\n * @param teamKey - Team key\n * @param weeks - Number of weeks to analyze (default: 5)\n * @returns Detailed performance analysis report\n */\n async generatePerformanceReport(\n userId: string,\n leagueId: string,\n teamKey: string,\n weeks: number = 5,\n ): Promise {\n try {\n console.log(`📊 Generating performance report for team ${teamKey} (${weeks} weeks)`);\n\n // Get user's valid tokens\n const tokenData = await this.tokenStorage.getTokens(userId);\n if (!tokenData) {\n console.log(`⚠️ No valid tokens for user ${userId}`);\n return null;\n }\n\n // Initialize Yahoo API client\n const yahooAPI = new YahooFantasyAPIClient(tokenData, this.tokenStorage, userId);\n\n // Gather comprehensive data\n const [teamStats, roster, standings, waiverPlayers] = await Promise.all([\n yahooAPI.getTeamPerformanceStats(teamKey, leagueId),\n yahooAPI.getTeamRoster(teamKey),\n this.getLeagueStandings(yahooAPI, leagueId),\n yahooAPI.getWaiverWirePlayers(leagueId),\n ]);\n\n if (!teamStats) {\n console.log(`❌ Could not retrieve team stats for ${teamKey}`);\n return null;\n }\n\n // Get detailed player performance for all roster players\n const playerPerformances = await this.analyzeRosterPerformance(yahooAPI, roster, leagueId);\n\n // Analyze team performance\n const teamAnalysis = this.analyzeTeamPerformance(teamStats, playerPerformances);\n\n // Analyze player insights\n const playerInsights = this.analyzePlayerInsights(playerPerformances);\n\n // Generate waiver recommendations\n const waiverRecommendations = this.generateWaiverRecommendations(\n playerPerformances,\n waiverPlayers,\n teamStats,\n );\n\n // Competitive analysis\n const competitiveAnalysis = this.analyzeCompetitivePosition(teamStats, standings);\n\n const report: PerformanceAnalysisReport = {\n team_analysis: teamAnalysis,\n player_insights: playerInsights,\n waiver_recommendations: waiverRecommendations,\n competitive_analysis: competitiveAnalysis,\n };\n\n console.log(`✅ Generated comprehensive performance report for ${teamStats.team_name}`);\n return report;\n } catch (error) {\n console.error(`❌ Error generating performance report:`, error);\n return null;\n }\n }\n\n /**\n * Get weekly performance trends for a team\n * @param userId - User ID\n * @param leagueId - League ID\n * @param teamKey - Team key\n * @param weeks - Number of weeks to analyze\n * @returns Array of weekly performance data\n */\n async getWeeklyTrends(\n userId: string,\n leagueId: string,\n teamKey: string,\n weeks: number = 10,\n ): Promise {\n try {\n console.log(`📈 Analyzing weekly trends for team ${teamKey} (${weeks} weeks)`);\n\n const tokenData = await this.tokenStorage.getTokens(userId);\n if (!tokenData) return [];\n\n const yahooAPI = new YahooFantasyAPIClient(tokenData, this.tokenStorage, userId);\n\n // Get team matchup history\n const matchupsResponse = await yahooAPI.makeRequest(`/team/${teamKey}/matchups`);\n\n const weeklyTrends: WeeklyTrends[] = [];\n const matchupsData = matchupsResponse?.fantasy_content?.team?.[1]?.matchups;\n\n if (!matchupsData) return [];\n\n // Parse recent weeks (limit to requested number)\n const matchupCount = Math.min(matchupsData.count || 0, weeks);\n for (let i = 0; i < matchupCount; i++) {\n const matchup = matchupsData[i.toString()]?.matchup;\n if (!matchup) continue;\n\n const weekTrend = this.parseWeeklyPerformance(matchup, teamKey);\n if (weekTrend) {\n weeklyTrends.push(weekTrend);\n }\n }\n\n // Sort by week (most recent first)\n weeklyTrends.sort((a, b) => b.week - a.week);\n\n console.log(`✅ Retrieved ${weeklyTrends.length} weeks of performance trends`);\n return weeklyTrends;\n } catch (error) {\n console.error(`❌ Error getting weekly trends:`, error);\n return [];\n }\n }\n\n /**\n * Compare performance against league averages\n * @param userId - User ID\n * @param leagueId - League ID\n * @param teamKey - Team key\n * @returns Performance comparison data\n */\n async compareToLeagueAverages(\n userId: string,\n leagueId: string,\n teamKey: string,\n ): Promise<\n {\n team_stats: Record;\n league_averages: Record;\n percentile_rankings: Record;\n category_ranks: Record;\n } | null\n > {\n try {\n console.log(`📊 Comparing team ${teamKey} to league averages`);\n\n const tokenData = await this.tokenStorage.getTokens(userId);\n if (!tokenData) return null;\n\n const yahooAPI = new YahooFantasyAPIClient(tokenData, this.tokenStorage, userId);\n\n // Get all teams in the league\n const standings = await this.getLeagueStandings(yahooAPI, leagueId);\n const teamStats = await yahooAPI.getTeamPerformanceStats(teamKey, leagueId);\n\n if (!teamStats || !standings) return null;\n\n // Calculate league averages\n const leagueAverages = this.calculateLeagueAverages(standings);\n\n // Calculate percentile rankings\n const percentileRankings = this.calculatePercentileRankings(teamStats, standings);\n\n // Get category rankings from standings\n const categoryRanks = this.extractCategoryRanks(teamStats, standings);\n\n return {\n team_stats: this.normalizeStats(teamStats.season_stats),\n league_averages: leagueAverages,\n percentile_rankings: percentileRankings,\n category_ranks: categoryRanks,\n };\n } catch (error) {\n console.error(`❌ Error comparing to league averages:`, error);\n return null;\n }\n }\n\n // ============================================================================\n // PRIVATE ANALYSIS METHODS\n // ============================================================================\n\n private async analyzeRosterPerformance(\n yahooAPI: any,\n roster: any[],\n leagueId: string,\n ): Promise {\n const playerPerformances: PlayerPerformanceStats[] = [];\n\n console.log(`📊 Analyzing performance for ${roster.length} roster players`);\n\n // Limit concurrent requests to avoid rate limiting\n const batchSize = 5;\n for (let i = 0; i < roster.length; i += batchSize) {\n const batch = roster.slice(i, i + batchSize);\n\n // For each player, try to get their stats but fallback to roster data\n for (const player of batch) {\n console.log(`🔍 Getting stats for: ${player.name} (${player.player_id})`);\n\n try {\n const playerStats = await yahooAPI.getPlayerPerformanceStats(player.player_id, leagueId);\n if (playerStats) {\n // Use the fetched stats but ensure the name is preserved from roster\n playerStats.name = player.name; // Override with roster name to ensure it's not \"Unknown Player\"\n playerPerformances.push(playerStats);\n console.log(`✅ Got stats for: ${player.name}`);\n } else {\n // Fallback: Create basic player performance from roster data\n console.log(`⚠️ No stats available for ${player.name}, using roster data`);\n playerPerformances.push({\n player_id: player.player_id,\n name: player.name, // Use roster name\n team: player.team,\n position_type: player.position_type === \"P\" ? \"P\" : \"B\",\n eligible_positions: player.eligible_positions || [],\n season_stats: {},\n performance_metrics: {\n games_played: 0,\n avg_fantasy_points: 0,\n consistency_score: 0,\n },\n });\n }\n } catch (error) {\n console.error(`❌ Error getting stats for ${player.name}:`, error);\n // Still add player with roster data so they appear in analysis\n playerPerformances.push({\n player_id: player.player_id,\n name: player.name,\n team: player.team,\n position_type: player.position_type === \"P\" ? \"P\" : \"B\",\n eligible_positions: player.eligible_positions || [],\n season_stats: {},\n performance_metrics: {\n games_played: 0,\n avg_fantasy_points: 0,\n consistency_score: 0,\n },\n });\n }\n }\n\n // Small delay between batches\n if (i + batchSize < roster.length) {\n await new Promise(resolve => setTimeout(resolve, 1000));\n }\n }\n\n console.log(`📈 Completed analysis for ${playerPerformances.length} players`);\n return playerPerformances;\n }\n\n private analyzeTeamPerformance(\n teamStats: TeamPerformanceStats,\n playerPerformances: PlayerPerformanceStats[],\n ): PerformanceAnalysisReport[\"team_analysis\"] {\n const strengths: string[] = [];\n const weaknesses: string[] = [];\n const suggestions: string[] = [];\n\n // Analyze win percentage\n if (teamStats.season_record.win_percentage > 0.6) {\n strengths.push(`Strong win percentage (${(teamStats.season_record.win_percentage * 100).toFixed(1)}%)`);\n } else if (teamStats.season_record.win_percentage < 0.4) {\n weaknesses.push(`Low win percentage (${(teamStats.season_record.win_percentage * 100).toFixed(1)}%)`);\n suggestions.push(\"Consider roster improvements and lineup optimization\");\n }\n\n // Analyze roster composition\n if (teamStats.roster_analysis.injured_players > 3) {\n weaknesses.push(`High injury count (${teamStats.roster_analysis.injured_players} players)`);\n suggestions.push(\"Monitor injury reports and consider adding depth\");\n }\n\n if (teamStats.roster_analysis.bench_strength < 3) {\n weaknesses.push(\"Weak bench depth\");\n suggestions.push(\"Add versatile bench players for flexibility\");\n }\n\n // Analyze recent performance\n const recentRecord = teamStats.recent_performance.last_5_weeks;\n const recentWins = recentRecord.filter(w => w.result === \"W\").length;\n if (recentWins >= 4) {\n strengths.push(`Hot streak (${recentWins}-${5 - recentWins} in last 5 weeks)`);\n } else if (recentWins <= 1) {\n weaknesses.push(`Cold streak (${recentWins}-${5 - recentWins} in last 5 weeks)`);\n suggestions.push(\"Analyze recent lineup decisions and consider changes\");\n }\n\n return {\n overall_performance: teamStats,\n strengths,\n weaknesses,\n improvement_suggestions: suggestions,\n };\n }\n\n private analyzePlayerInsights(\n playerPerformances: PlayerPerformanceStats[],\n ): PerformanceAnalysisReport[\"player_insights\"] {\n // Sort players by fantasy points\n const sortedByPoints = [...playerPerformances].sort(\n (a, b) => (b.performance_metrics?.avg_fantasy_points || 0) - (a.performance_metrics?.avg_fantasy_points || 0),\n );\n\n // Top performers (top 25%)\n const topPerformers = sortedByPoints.slice(0, Math.ceil(playerPerformances.length * 0.25));\n\n // Underperformers (bottom 25%)\n const underperformers = sortedByPoints.slice(-Math.ceil(playerPerformances.length * 0.25));\n\n // Injury concerns (players with low games played relative to season)\n const injuryConcerns = playerPerformances.filter(p => (p.performance_metrics?.games_played || 0) < 50 // Arbitrary threshold\n );\n\n // Breakout candidates (high consistency, growing performance)\n const breakoutCandidates = playerPerformances.filter(p =>\n (p.performance_metrics?.consistency_score || 0) > 70\n && (p.performance_metrics?.avg_fantasy_points || 0) > 5\n );\n\n return {\n top_performers: topPerformers,\n underperformers: underperformers,\n injury_concerns: injuryConcerns,\n breakout_candidates: breakoutCandidates,\n };\n }\n\n private generateWaiverRecommendations(\n playerPerformances: PlayerPerformanceStats[],\n waiverPlayers: WaiverWirePlayer[],\n teamStats: TeamPerformanceStats,\n ): PerformanceAnalysisReport[\"waiver_recommendations\"] {\n // Immediate needs (high-impact available players)\n const immediateNeeds = waiverPlayers\n .filter(p => p.add_recommendation === \"HIGH\")\n .slice(0, 5);\n\n // Long-term targets (decent options for future)\n const longTermTargets = waiverPlayers\n .filter(p => p.add_recommendation === \"MEDIUM\")\n .slice(0, 8);\n\n // Drop candidates (worst performing rostered players)\n const dropCandidates = playerPerformances\n .filter(p => (p.performance_metrics?.avg_fantasy_points || 0) < 2)\n .slice(0, 3);\n\n return {\n immediate_needs: immediateNeeds,\n long_term_targets: longTermTargets,\n drop_candidates: dropCandidates,\n };\n }\n\n private analyzeCompetitivePosition(\n teamStats: TeamPerformanceStats,\n standings: any[],\n ): PerformanceAnalysisReport[\"competitive_analysis\"] {\n // Find team's rank in standings\n const teamRank = standings.findIndex(team => team.team_id === teamStats.team_id) + 1;\n\n // Calculate playoff chances based on current position\n const totalTeams = standings.length;\n const playoffSpots = Math.ceil(totalTeams / 2); // Assume half make playoffs\n const playoffChances = teamRank <= playoffSpots ? 85 : Math.max(10, 100 - (teamRank - playoffSpots) * 15);\n\n // Identify key competitors (teams within 2 spots)\n const keyCompetitors = standings\n .slice(Math.max(0, teamRank - 3), teamRank + 2)\n .filter(team => team.team_id !== teamStats.team_id)\n .map(team => team.name)\n .slice(0, 3);\n\n // Calculate points gap to first place\n const firstPlacePoints = standings[0]?.points || 0;\n const teamPoints = teamStats.season_record.wins; // Use wins as proxy for points\n const pointsGap = firstPlacePoints - teamPoints;\n\n return {\n league_ranking: teamRank,\n playoff_chances: playoffChances,\n key_competitors: keyCompetitors,\n points_gap: pointsGap,\n };\n }\n\n private async getLeagueStandings(yahooAPI: any, leagueId: string): Promise {\n try {\n const standingsResponse = await yahooAPI.makeRequest(`/league/${leagueId}/standings`);\n const standings = standingsResponse?.fantasy_content?.league?.[1]?.standings;\n\n if (!standings) return [];\n\n const teams = [];\n for (let i = 0; i < (standings.count || 0); i++) {\n const teamData = standings[i.toString()]?.team;\n if (teamData && teamData[0] && teamData[1]) {\n const teamInfo = Array.isArray(teamData[0])\n ? teamData[0].reduce((acc, item) => ({ ...acc, ...item }), {})\n : teamData[0];\n const teamStandings = teamData[1].team_standings;\n\n teams.push({\n team_id: teamInfo.team_id,\n name: teamInfo.name,\n rank: parseInt(teamStandings.rank || \"0\"),\n wins: parseInt(teamStandings.outcome_totals?.wins || \"0\"),\n losses: parseInt(teamStandings.outcome_totals?.losses || \"0\"),\n ties: parseInt(teamStandings.outcome_totals?.ties || \"0\"),\n points: parseFloat(teamStandings.points_for || \"0\"),\n });\n }\n }\n\n return teams.sort((a, b) => a.rank - b.rank);\n } catch (error) {\n console.error(\"Error getting league standings:\", error);\n return [];\n }\n }\n\n private parseWeeklyPerformance(matchup: any, teamKey: string): WeeklyTrends | null {\n try {\n const week = parseInt(matchup.week || \"0\");\n const teams = matchup[\"0\"]?.teams;\n if (!teams) return null;\n\n // Find our team's stats\n let ourTeamStats = null;\n let opponentName = \"Unknown\";\n let result: \"W\" | \"L\" | \"T\" = \"L\";\n\n for (let i = 0; i < (teams.count || 0); i++) {\n const teamData = teams[i.toString()]?.team;\n if (!teamData) continue;\n\n const teamInfo = teamData[0];\n const teamMetadata = Array.isArray(teamInfo)\n ? teamInfo.reduce((acc, item) => ({ ...acc, ...item }), {})\n : teamInfo;\n\n if (teamMetadata.team_key === teamKey) {\n ourTeamStats = teamData[1];\n } else {\n opponentName = teamMetadata.name || \"Unknown\";\n }\n }\n\n if (!ourTeamStats?.team_stats) return null;\n\n // Parse stats\n const stats = this.parseTeamStats(ourTeamStats.team_stats.stats || []);\n\n // Calculate fantasy points\n const fantasyPoints = this.calculateWeeklyFantasyPoints(stats);\n\n // Determine result (simplified - would need opponent comparison)\n result = fantasyPoints > 50 ? \"W\" : \"L\"; // Rough estimate\n\n return {\n week,\n batting_performance: {\n runs: parseFloat(stats[\"7\"] || \"0\"),\n home_runs: parseFloat(stats[\"12\"] || \"0\"),\n rbi: parseFloat(stats[\"13\"] || \"0\"),\n stolen_bases: parseFloat(stats[\"16\"] || \"0\"),\n batting_avg: parseFloat(stats[\"3\"] || \"0\"),\n },\n pitching_performance: {\n wins: parseFloat(stats[\"28\"] || \"0\"),\n saves: parseFloat(stats[\"32\"] || \"0\"),\n strikeouts: parseFloat(stats[\"42\"] || \"0\"),\n era: parseFloat(stats[\"26\"] || \"0\"),\n whip: parseFloat(stats[\"27\"] || \"0\"),\n innings_pitched: parseFloat(stats[\"50\"] || \"0\"),\n },\n fantasy_points: fantasyPoints,\n opponent: opponentName,\n result,\n };\n } catch (error) {\n console.error(\"Error parsing weekly performance:\", error);\n return null;\n }\n }\n\n private parseTeamStats(statsArray: any[]): Record {\n const stats: Record = {};\n\n for (const statItem of statsArray) {\n if (statItem.stat) {\n stats[statItem.stat.stat_id] = statItem.stat.value;\n }\n }\n\n return stats;\n }\n\n private calculateWeeklyFantasyPoints(stats: Record): number {\n // Basic fantasy scoring calculation\n const runs = parseFloat(stats[\"7\"] || \"0\");\n const hrs = parseFloat(stats[\"12\"] || \"0\");\n const rbis = parseFloat(stats[\"13\"] || \"0\");\n const sbs = parseFloat(stats[\"16\"] || \"0\");\n const wins = parseFloat(stats[\"28\"] || \"0\");\n const saves = parseFloat(stats[\"32\"] || \"0\");\n const ks = parseFloat(stats[\"42\"] || \"0\");\n\n return runs + (hrs * 4) + rbis + (sbs * 2) + (wins * 5) + (saves * 5) + ks;\n }\n\n private calculateLeagueAverages(standings: any[]): Record {\n // Simplified league averages calculation\n const totalWins = standings.reduce((sum, team) => sum + team.wins, 0);\n const totalPoints = standings.reduce((sum, team) => sum + team.points, 0);\n\n return {\n avg_wins: totalWins / standings.length,\n avg_points: totalPoints / standings.length,\n avg_win_percentage: 0.5, // By definition in head-to-head\n };\n }\n\n private calculatePercentileRankings(\n teamStats: TeamPerformanceStats,\n standings: any[],\n ): Record {\n const teamRank = standings.findIndex(team => team.team_id === teamStats.team_id) + 1;\n const totalTeams = standings.length;\n\n const percentile = Math.round(((totalTeams - teamRank + 1) / totalTeams) * 100);\n\n return {\n overall_percentile: percentile,\n wins_percentile: percentile, // Simplified\n points_percentile: percentile,\n };\n }\n\n private extractCategoryRanks(\n teamStats: TeamPerformanceStats,\n standings: any[],\n ): Record {\n const teamRank = standings.findIndex(team => team.team_id === teamStats.team_id) + 1;\n\n // Simplified category ranks (would need actual category standings)\n return {\n overall_rank: teamRank,\n batting_rank: teamRank,\n pitching_rank: teamRank,\n };\n }\n\n private normalizeStats(stats: Record): Record {\n const normalized: Record = {};\n\n for (const [key, value] of Object.entries(stats)) {\n normalized[key] = typeof value === \"string\" ? parseFloat(value) || 0 : value;\n }\n\n return normalized;\n }\n}\n\n// Import the YahooFantasyAPIClient from the main scheduler file\n// This allows the analyzer to use the same API client\nimport { YahooFantasyAPIClient } from \"../daily_lineup_scheduler.tsx\";",[],[151,224],{"_108":232,"_100":233,"_152":234,"_154":153,"_155":139,"_156":235,"_158":159,"_110":236,"_105":237,"_162":187,"_164":238,"_165":27,"_166":-5,"_167":239,"_103":240},"4189c45c-4ac3-11f0-b986-76b3cceeab13","ai_team_performance_review.ts","872c1772-4a3b-11f0-bc05-76b3cceeab13",146,["D",1750086292700],18,"// Lou Fantasy Baseball AI Team Performance Review - Main Orchestrator\n// Comprehensive AI-powered team analysis and waiver wire recommendations\n// Val.town Compatible TypeScript Implementation\n\nimport {\n PlayerPerformanceStats,\n TeamPerformanceStats,\n WaiverWirePlayer,\n YahooFantasyAPIClient,\n} from \"../daily_lineup_scheduler.tsx\";\nimport { LouTokenStorage } from \"../token_storage.tsx\";\nimport {\n AIPerformanceAnalysis,\n createOpenAIClient,\n LouOpenAIClient,\n validatePerformanceData,\n validateWaiverData,\n WaiverRecommendation,\n} from \"./ai_performance_openai_client.ts\";\nimport {\n createPromptConfig,\n optimizePromptForModel,\n PERFORMANCE_ANALYSIS_PROMPT,\n PICKUP_RECOMMENDATION_PROMPT,\n} from \"./ai_performance_prompts.ts\";\nimport { LouPerformanceAnalyzer, PerformanceAnalysisReport } from \"./ai_performance_yahoo_integration.ts\";\n\n// ============================================================================\n// MAIN INTERFACES\n// ============================================================================\n\n/**\n * Configuration for AI team performance review\n */\nexport interface AITeamReviewConfig {\n // Analysis parameters\n analysisWeeks: number; // Number of weeks to analyze (default: 5)\n minConfidenceThreshold: number; // Minimum AI confidence for recommendations (0-100)\n maxWaiverCandidates: number; // Maximum waiver candidates to analyze (default: 15)\n\n // OpenAI configuration\n openai: {\n model: \"gpt-4-turbo-preview\" | \"gpt-4o\" | \"gpt-3.5-turbo\";\n maxTokens: number;\n temperature: number;\n };\n\n // Feature flags\n features: {\n includeLeagueComparison: boolean;\n includeWeeklyTrends: boolean;\n includeInjuryAnalysis: boolean;\n includeCompetitiveContext: boolean;\n };\n\n // Performance thresholds\n thresholds: {\n underperformerFantasyPoints: number; // Below this = underperformer\n highOwnershipPercentage: number; // Above this = widely owned\n minGamesPlayed: number; // Minimum games for reliable analysis\n };\n}\n\n/**\n * Comprehensive AI team performance review result\n */\nexport interface AITeamPerformanceReview {\n // Metadata\n analysis_metadata: {\n team_name: string;\n league_id: string;\n analysis_date: string;\n weeks_analyzed: number;\n confidence_score: number;\n analysis_version: string;\n };\n\n // Core analysis\n team_analysis: PerformanceAnalysisReport[\"team_analysis\"];\n ai_insights: AIPerformanceAnalysis;\n\n // Player analysis\n player_performance: {\n top_performers: PlayerPerformanceStats[];\n underperformers: PlayerPerformanceStats[];\n injury_risks: PlayerPerformanceStats[];\n breakout_candidates: PlayerPerformanceStats[];\n };\n\n // Waiver wire analysis\n waiver_analysis: {\n high_confidence_pickups: WaiverRecommendation[];\n medium_confidence_pickups: WaiverRecommendation[];\n deep_sleepers: WaiverRecommendation[];\n players_to_monitor: WaiverRecommendation[];\n };\n\n // Actionable recommendations\n action_plan: {\n immediate_actions: Array<{\n action: string;\n priority: \"CRITICAL\" | \"HIGH\" | \"MEDIUM\" | \"LOW\";\n rationale: string;\n expected_impact: string;\n confidence: number;\n }>;\n weekly_priorities: string[];\n long_term_strategy: string[];\n };\n\n // Risk assessment\n risk_analysis: {\n injury_concerns: Array<{\n player_name: string;\n risk_level: \"HIGH\" | \"MEDIUM\" | \"LOW\";\n mitigation_strategy: string;\n }>;\n performance_risks: string[];\n competitive_threats: string[];\n };\n\n // Additional context (optional)\n context?: {\n league_comparison?: any;\n weekly_trends?: any;\n competitive_analysis?: any;\n };\n}\n\n/**\n * Execution result with error handling\n */\nexport interface ReviewExecutionResult {\n success: boolean;\n review?: AITeamPerformanceReview;\n error?: {\n type: \"AUTH_ERROR\" | \"API_ERROR\" | \"ANALYSIS_ERROR\" | \"VALIDATION_ERROR\" | \"UNKNOWN_ERROR\";\n message: string;\n details?: any;\n };\n execution_stats: {\n duration_ms: number;\n api_calls_made: number;\n tokens_used?: number;\n rate_limited: boolean;\n };\n}\n\n// ============================================================================\n// MAIN ORCHESTRATOR CLASS\n// ============================================================================\n\n/**\n * AI Team Performance Review Orchestrator\n *\n * This class coordinates all components to provide comprehensive AI-powered\n * fantasy baseball team analysis and recommendations.\n */\nexport class AITeamPerformanceReviewer {\n private performanceAnalyzer: LouPerformanceAnalyzer;\n private openaiClient: LouOpenAIClient;\n private tokenStorage: LouTokenStorage;\n private config: AITeamReviewConfig;\n\n constructor(config?: Partial) {\n // Initialize configuration with defaults\n this.config = {\n analysisWeeks: 5,\n minConfidenceThreshold: 70,\n maxWaiverCandidates: 15,\n openai: {\n model: \"gpt-4-turbo-preview\",\n maxTokens: 4000,\n temperature: 0.7,\n },\n features: {\n includeLeagueComparison: true,\n includeWeeklyTrends: true,\n includeInjuryAnalysis: true,\n includeCompetitiveContext: true,\n },\n thresholds: {\n underperformerFantasyPoints: 4.0,\n highOwnershipPercentage: 75,\n minGamesPlayed: 20,\n },\n ...config,\n };\n\n // Initialize components\n this.performanceAnalyzer = new LouPerformanceAnalyzer();\n this.openaiClient = createOpenAIClient({\n model: this.config.openai.model,\n maxTokens: this.config.openai.maxTokens,\n temperature: this.config.openai.temperature,\n });\n this.tokenStorage = new LouTokenStorage();\n\n console.log(`🤖 AI Team Performance Reviewer initialized with model: ${this.config.openai.model}`);\n }\n\n /**\n * Execute comprehensive AI team performance review\n * @param userId - User ID for authentication\n * @param leagueId - League ID to analyze\n * @param teamKey - Team key to analyze (optional - will auto-detect if not provided)\n * @returns Complete AI team performance review\n */\n async executeReview(\n userId: string,\n leagueId: string,\n teamKey?: string,\n ): Promise {\n const startTime = Date.now();\n let apiCallsCounter = 0;\n let rateLimited = false;\n\n try {\n console.log(`🚀 Starting AI team performance review for user ${userId}, league ${leagueId}`);\n\n // Step 1: Validate authentication\n const tokenData = await this.tokenStorage.getTokens(userId);\n if (!tokenData) {\n return this.createErrorResult(\n \"AUTH_ERROR\",\n \"No valid authentication tokens found\",\n startTime,\n apiCallsCounter,\n rateLimited,\n );\n }\n\n // Step 2: Initialize Yahoo API client\n const yahooAPI = new YahooFantasyAPIClient(tokenData, this.tokenStorage, userId);\n\n // Step 3: Get team key if not provided\n if (!teamKey) {\n teamKey = await yahooAPI.getTeamKey(userId, leagueId);\n apiCallsCounter++;\n\n if (!teamKey) {\n return this.createErrorResult(\n \"API_ERROR\",\n \"Could not determine team key for user in league\",\n startTime,\n apiCallsCounter,\n rateLimited,\n );\n }\n }\n\n console.log(`🎯 Analyzing team ${teamKey} in league ${leagueId}`);\n\n // Step 4: Gather comprehensive performance data\n console.log(\"📊 Gathering performance data...\");\n const performanceData = await this.gatherPerformanceData(yahooAPI, teamKey, leagueId);\n apiCallsCounter += performanceData.apiCalls;\n rateLimited = rateLimited || performanceData.rateLimited;\n\n if (!performanceData.success) {\n return this.createErrorResult(\n \"API_ERROR\",\n \"Failed to gather performance data\",\n startTime,\n apiCallsCounter,\n rateLimited,\n performanceData.error,\n );\n }\n\n // Step 5: Validate data quality\n console.log(\"✅ Validating data quality...\");\n const validationResult = this.validateAnalysisData(performanceData.data!);\n if (!validationResult.valid) {\n return this.createErrorResult(\n \"VALIDATION_ERROR\",\n `Data validation failed: ${validationResult.errors.join(\", \")}`,\n startTime,\n apiCallsCounter,\n rateLimited,\n );\n }\n\n // Step 6: Generate performance analysis report\n console.log(\"📈 Generating performance analysis...\");\n const performanceReport = await this.performanceAnalyzer.generatePerformanceReport(\n userId,\n leagueId,\n teamKey,\n this.config.analysisWeeks,\n );\n\n if (!performanceReport) {\n return this.createErrorResult(\n \"ANALYSIS_ERROR\",\n \"Failed to generate performance analysis report\",\n startTime,\n apiCallsCounter,\n rateLimited,\n );\n }\n\n // Step 7: Execute AI analysis\n console.log(\"🤖 Executing AI analysis...\");\n const aiAnalysisResult = await this.executeAIAnalysis(performanceData.data!);\n if (!aiAnalysisResult.success) {\n return this.createErrorResult(\n \"ANALYSIS_ERROR\",\n \"AI analysis failed\",\n startTime,\n apiCallsCounter,\n rateLimited,\n aiAnalysisResult.error,\n );\n }\n\n // Step 8: Generate waiver wire recommendations\n console.log(\"🎯 Generating waiver recommendations...\");\n const waiverAnalysisResult = await this.generateWaiverRecommendations(\n performanceData.data!,\n performanceReport,\n );\n if (!waiverAnalysisResult.success) {\n return this.createErrorResult(\n \"ANALYSIS_ERROR\",\n \"Waiver analysis failed\",\n startTime,\n apiCallsCounter,\n rateLimited,\n waiverAnalysisResult.error,\n );\n }\n\n // Step 9: Compile comprehensive review\n console.log(\"📋 Compiling comprehensive review...\");\n const review = await this.compileComprehensiveReview(\n performanceData.data!,\n performanceReport,\n aiAnalysisResult.analysis!,\n waiverAnalysisResult.recommendations!,\n );\n\n const duration = Date.now() - startTime;\n console.log(`✅ AI team performance review completed in ${duration}ms`);\n\n return {\n success: true,\n review,\n execution_stats: {\n duration_ms: duration,\n api_calls_made: apiCallsCounter,\n rate_limited: rateLimited,\n },\n };\n } catch (error) {\n console.error(\"❌ AI team performance review failed:\", error);\n return this.createErrorResult(\n \"UNKNOWN_ERROR\",\n error instanceof Error ? error.message : \"Unknown error occurred\",\n startTime,\n apiCallsCounter,\n rateLimited,\n error,\n );\n }\n }\n\n /**\n * Get high-confidence waiver pickup recommendations only\n * Simplified interface for quick recommendations\n */\n async getHighConfidencePickups(\n userId: string,\n leagueId: string,\n teamKey?: string,\n ): Promise<{\n success: boolean;\n pickups: WaiverRecommendation[];\n error?: string;\n }> {\n try {\n console.log(\"🎯 Getting high-confidence pickup recommendations...\");\n\n const result = await this.executeReview(userId, leagueId, teamKey);\n\n if (!result.success || !result.review) {\n return {\n success: false,\n pickups: [],\n error: result.error?.message || \"Review execution failed\",\n };\n }\n\n // Filter for high-confidence recommendations\n const highConfidencePickups = result.review.waiver_analysis.high_confidence_pickups\n .filter(pickup => pickup.priority_score >= this.config.minConfidenceThreshold);\n\n console.log(`✅ Found ${highConfidencePickups.length} high-confidence pickup recommendations`);\n\n return {\n success: true,\n pickups: highConfidencePickups,\n };\n } catch (error) {\n console.error(\"❌ Failed to get high-confidence pickups:\", error);\n return {\n success: false,\n pickups: [],\n error: error instanceof Error ? error.message : \"Unknown error\",\n };\n }\n }\n\n /**\n * Test all system components\n */\n async runSystemTest(): Promise<{\n success: boolean;\n results: {\n authentication: boolean;\n yahooAPI: boolean;\n openAI: boolean;\n performanceAnalyzer: boolean;\n };\n errors: string[];\n }> {\n console.log(\"🧪 Running AI Team Performance Review system test...\");\n\n const results = {\n authentication: false,\n yahooAPI: false,\n openAI: false,\n performanceAnalyzer: false,\n };\n const errors: string[] = [];\n\n // Test 1: Authentication\n try {\n const testTokens = await this.tokenStorage.getTokens(\"test_user\");\n results.authentication = true; // If no error thrown, storage is working\n console.log(\"✅ Authentication test passed\");\n } catch (error) {\n errors.push(`Authentication test failed: ${error}`);\n console.log(\"❌ Authentication test failed\");\n }\n\n // Test 2: OpenAI API\n try {\n const openAITest = await this.openaiClient.testConnection();\n results.openAI = openAITest.success;\n if (!openAITest.success) {\n errors.push(`OpenAI test failed: ${openAITest.error}`);\n }\n console.log(openAITest.success ? \"✅ OpenAI test passed\" : \"❌ OpenAI test failed\");\n } catch (error) {\n errors.push(`OpenAI test failed: ${error}`);\n console.log(\"❌ OpenAI test failed\");\n }\n\n // Test 3: Performance Analyzer\n try {\n const analyzer = new LouPerformanceAnalyzer();\n results.performanceAnalyzer = true; // If instantiation succeeds\n console.log(\"✅ Performance Analyzer test passed\");\n } catch (error) {\n errors.push(`Performance Analyzer test failed: ${error}`);\n console.log(\"❌ Performance Analyzer test failed\");\n }\n\n // Test 4: Yahoo API (requires valid tokens, so just test instantiation)\n try {\n const testTokens = { access_token: \"test\", refresh_token: \"test\", expires_at: Date.now() + 3600000 };\n const yahooAPI = new YahooFantasyAPIClient(testTokens, this.tokenStorage, \"test_user\");\n results.yahooAPI = true; // If instantiation succeeds\n console.log(\"✅ Yahoo API test passed\");\n } catch (error) {\n errors.push(`Yahoo API test failed: ${error}`);\n console.log(\"❌ Yahoo API test failed\");\n }\n\n const allPassed = Object.values(results).every(result => result);\n console.log(allPassed ? \"✅ All system tests passed\" : \"❌ Some system tests failed\");\n\n return {\n success: allPassed,\n results,\n errors,\n };\n }\n\n // ============================================================================\n // PRIVATE HELPER METHODS\n // ============================================================================\n\n /**\n * Gather all performance data needed for analysis\n */\n private async gatherPerformanceData(\n yahooAPI: YahooFantasyAPIClient,\n teamKey: string,\n leagueId: string,\n ): Promise<{\n success: boolean;\n data?: {\n teamStats: TeamPerformanceStats;\n playerStats: PlayerPerformanceStats[];\n waiverPlayers: WaiverWirePlayer[];\n leagueContext?: any;\n };\n apiCalls: number;\n rateLimited: boolean;\n error?: any;\n }> {\n let apiCalls = 0;\n let rateLimited = false;\n\n try {\n // Get team performance stats\n const teamStats = await yahooAPI.getTeamPerformanceStats(teamKey, leagueId);\n apiCalls++;\n\n if (!teamStats) {\n throw new Error(\"Failed to retrieve team performance stats\");\n }\n\n // Get team roster\n const roster = await yahooAPI.getTeamRoster(teamKey);\n apiCalls++;\n\n // Get detailed player performance (batch process to avoid rate limits)\n const playerStats: PlayerPerformanceStats[] = [];\n const batchSize = 3; // Conservative to avoid rate limits\n\n for (let i = 0; i < roster.length; i += batchSize) {\n const batch = roster.slice(i, i + batchSize);\n const batchPromises = batch.map(player => yahooAPI.getPlayerPerformanceStats(player.player_id, leagueId));\n\n try {\n const batchResults = await Promise.allSettled(batchPromises);\n apiCalls += batch.length;\n\n for (const result of batchResults) {\n if (result.status === \"fulfilled\" && result.value) {\n playerStats.push(result.value);\n }\n }\n\n // Rate limiting delay\n if (i + batchSize < roster.length) {\n await new Promise(resolve => setTimeout(resolve, 2000)); // 2 second delay\n }\n } catch (error) {\n console.log(`⚠️ Batch processing error at index ${i}:`, error);\n rateLimited = true;\n }\n }\n\n // Get waiver wire players\n const waiverPlayers = await yahooAPI.getWaiverWirePlayers(\n leagueId,\n undefined, // No position filter\n undefined, // No ownership threshold\n );\n apiCalls++;\n\n // Limit waiver candidates to avoid token overflow\n const limitedWaiverPlayers = waiverPlayers\n .sort((a, b) => (b.fantasy_relevance_score || 0) - (a.fantasy_relevance_score || 0))\n .slice(0, this.config.maxWaiverCandidates);\n\n // Optional: Get league context if enabled\n let leagueContext = undefined;\n if (this.config.features.includeLeagueComparison) {\n try {\n leagueContext = await this.performanceAnalyzer.compareToLeagueAverages(\n teamStats.team_id,\n leagueId,\n teamKey,\n );\n // Note: This doesn't count as additional API calls since it uses cached data\n } catch (error) {\n console.log(\"⚠️ Could not gather league context:\", error);\n }\n }\n\n return {\n success: true,\n data: {\n teamStats,\n playerStats,\n waiverPlayers: limitedWaiverPlayers,\n leagueContext,\n },\n apiCalls,\n rateLimited,\n };\n } catch (error) {\n return {\n success: false,\n apiCalls,\n rateLimited,\n error,\n };\n }\n }\n\n /**\n * Validate that we have sufficient data for analysis\n */\n private validateAnalysisData(data: {\n teamStats: TeamPerformanceStats;\n playerStats: PlayerPerformanceStats[];\n waiverPlayers: WaiverWirePlayer[];\n }): { valid: boolean; errors: string[]; warnings: string[] } {\n const errors: string[] = [];\n const warnings: string[] = [];\n\n // Validate team stats\n if (!data.teamStats.team_name) {\n errors.push(\"Team name is missing\");\n }\n\n if (typeof data.teamStats.season_record.wins !== \"number\") {\n errors.push(\"Team wins data is invalid\");\n }\n\n // Validate player stats\n if (data.playerStats.length === 0) {\n errors.push(\"No player statistics found\");\n } else if (data.playerStats.length < 10) {\n warnings.push(\"Limited player data may reduce analysis quality\");\n }\n\n // Check for performance metrics\n const playersWithMetrics = data.playerStats.filter(p =>\n p.performance_metrics\n && p.performance_metrics.games_played\n && p.performance_metrics.games_played >= this.config.thresholds.minGamesPlayed\n );\n\n if (playersWithMetrics.length < data.playerStats.length * 0.5) {\n warnings.push(\"Many players have insufficient games played for reliable analysis\");\n }\n\n // Validate waiver players\n if (data.waiverPlayers.length === 0) {\n warnings.push(\"No waiver wire candidates found\");\n }\n\n return {\n valid: errors.length === 0,\n errors,\n warnings,\n };\n }\n\n /**\n * Execute AI analysis on performance data\n */\n private async executeAIAnalysis(data: {\n teamStats: TeamPerformanceStats;\n playerStats: PlayerPerformanceStats[];\n leagueContext?: any;\n }): Promise<{\n success: boolean;\n analysis?: AIPerformanceAnalysis;\n error?: any;\n }> {\n try {\n // Validate data for AI analysis\n const validation = validatePerformanceData({\n teamStats: data.teamStats,\n playerStats: data.playerStats,\n });\n\n if (!validation.valid) {\n throw new Error(`Performance data validation failed: ${validation.errors.join(\", \")}`);\n }\n\n // Execute AI analysis\n const analysis = await this.openaiClient.analyzeTeamPerformance({\n teamStats: data.teamStats,\n playerStats: data.playerStats,\n leagueContext: data.leagueContext,\n });\n\n if (!analysis) {\n throw new Error(\"AI analysis returned null result\");\n }\n\n // Validate confidence threshold\n if (analysis.confidence_score < this.config.minConfidenceThreshold) {\n console.log(\n `⚠️ AI analysis confidence (${analysis.confidence_score}%) below threshold (${this.config.minConfidenceThreshold}%)`,\n );\n }\n\n return { success: true, analysis };\n } catch (error) {\n return { success: false, error };\n }\n }\n\n /**\n * Generate waiver wire recommendations using AI\n */\n private async generateWaiverRecommendations(\n data: {\n teamStats: TeamPerformanceStats;\n playerStats: PlayerPerformanceStats[];\n waiverPlayers: WaiverWirePlayer[];\n },\n performanceReport: PerformanceAnalysisReport,\n ): Promise<{\n success: boolean;\n recommendations?: WaiverRecommendation[];\n error?: any;\n }> {\n try {\n // Identify underperformers\n const underperformers = data.playerStats.filter(player =>\n player.performance_metrics?.avg_fantasy_points\n && player.performance_metrics.avg_fantasy_points < this.config.thresholds.underperformerFantasyPoints\n );\n\n // Validate waiver data\n const validation = validateWaiverData(underperformers, data.waiverPlayers);\n if (!validation.valid) {\n throw new Error(`Waiver data validation failed: ${validation.errors.join(\", \")}`);\n }\n\n // Generate AI recommendations\n const recommendations = await this.openaiClient.getPickupRecommendations(\n underperformers,\n data.waiverPlayers,\n {\n teamName: data.teamStats.team_name,\n currentRecord: {\n wins: data.teamStats.season_record.wins,\n losses: data.teamStats.season_record.losses,\n ties: data.teamStats.season_record.ties,\n },\n rosterNeeds: this.identifyRosterNeeds(performanceReport),\n },\n );\n\n return { success: true, recommendations };\n } catch (error) {\n return { success: false, error };\n }\n }\n\n /**\n * Compile all analysis into comprehensive review\n */\n private async compileComprehensiveReview(\n data: {\n teamStats: TeamPerformanceStats;\n playerStats: PlayerPerformanceStats[];\n waiverPlayers: WaiverWirePlayer[];\n leagueContext?: any;\n },\n performanceReport: PerformanceAnalysisReport,\n aiAnalysis: AIPerformanceAnalysis,\n waiverRecommendations: WaiverRecommendation[],\n ): Promise {\n // Categorize waiver recommendations by confidence\n const highConfidence = waiverRecommendations.filter(r => r.priority_score >= 80);\n const mediumConfidence = waiverRecommendations.filter(r => r.priority_score >= 60 && r.priority_score < 80);\n const deepSleepers = waiverRecommendations.filter(r => r.priority_score >= 40 && r.priority_score < 60);\n const toMonitor = waiverRecommendations.filter(r => r.priority_score < 40);\n\n // Compile action plan\n const actionPlan = this.compileActionPlan(aiAnalysis, waiverRecommendations);\n\n // Compile risk analysis\n const riskAnalysis = this.compileRiskAnalysis(data.playerStats, aiAnalysis);\n\n // Gather additional context if enabled\n const context: any = {};\n if (this.config.features.includeLeagueComparison && data.leagueContext) {\n context.league_comparison = data.leagueContext;\n }\n\n if (this.config.features.includeWeeklyTrends) {\n try {\n context.weekly_trends = await this.performanceAnalyzer.getWeeklyTrends(\n data.teamStats.team_id,\n data.teamStats.league_id,\n `${data.teamStats.league_id}.t.${data.teamStats.team_id}`, // Construct team key\n this.config.analysisWeeks,\n );\n } catch (error) {\n console.log(\"⚠️ Could not gather weekly trends:\", error);\n }\n }\n\n return {\n analysis_metadata: {\n team_name: data.teamStats.team_name,\n league_id: data.teamStats.league_id,\n analysis_date: new Date().toISOString(),\n weeks_analyzed: this.config.analysisWeeks,\n confidence_score: aiAnalysis.confidence_score,\n analysis_version: \"1.0.0\",\n },\n team_analysis: performanceReport.team_analysis,\n ai_insights: aiAnalysis,\n player_performance: {\n top_performers: performanceReport.player_insights.top_performers,\n underperformers: performanceReport.player_insights.underperformers,\n injury_risks: performanceReport.player_insights.injury_concerns,\n breakout_candidates: performanceReport.player_insights.breakout_candidates,\n },\n waiver_analysis: {\n high_confidence_pickups: highConfidence,\n medium_confidence_pickups: mediumConfidence,\n deep_sleepers: deepSleepers,\n players_to_monitor: toMonitor,\n },\n action_plan: actionPlan,\n risk_analysis: riskAnalysis,\n context: Object.keys(context).length > 0 ? context : undefined,\n };\n }\n\n /**\n * Create standardized error result\n */\n private createErrorResult(\n type: ReviewExecutionResult[\"error\"][\"type\"],\n message: string,\n startTime: number,\n apiCalls: number,\n rateLimited: boolean,\n details?: any,\n ): ReviewExecutionResult {\n return {\n success: false,\n error: { type, message, details },\n execution_stats: {\n duration_ms: Date.now() - startTime,\n api_calls_made: apiCalls,\n rate_limited: rateLimited,\n },\n };\n }\n\n /**\n * Identify roster needs from performance report\n */\n private identifyRosterNeeds(report: PerformanceAnalysisReport): string[] {\n const needs: string[] = [];\n\n // Check for positional weaknesses\n if (report.waiver_recommendations.immediate_needs.length > 0) {\n const positions = report.waiver_recommendations.immediate_needs\n .map(p => p.eligible_positions)\n .flat()\n .filter((pos, index, arr) => arr.indexOf(pos) === index); // Unique positions\n\n needs.push(...positions);\n }\n\n // Check for category weaknesses\n if (report.team_analysis.weaknesses.some(w => w.toLowerCase().includes(\"power\"))) {\n needs.push(\"Power Hitting\");\n }\n\n if (report.team_analysis.weaknesses.some(w => w.toLowerCase().includes(\"pitching\"))) {\n needs.push(\"Pitching Depth\");\n }\n\n return needs.length > 0 ? needs : [\"General Depth\"];\n }\n\n /**\n * Compile actionable action plan\n */\n private compileActionPlan(\n aiAnalysis: AIPerformanceAnalysis,\n waiverRecommendations: WaiverRecommendation[],\n ): AITeamPerformanceReview[\"action_plan\"] {\n const immediateActions = [];\n\n // Add immediate waiver actions\n const mustAddPlayers = waiverRecommendations.filter(r => r.recommendation_type === \"MUST_ADD\");\n for (const player of mustAddPlayers.slice(0, 3)) { // Top 3 must-adds\n immediateActions.push({\n action: `Pick up ${player.player_name} (${player.position})`,\n priority: \"HIGH\" as const,\n rationale: player.analysis.fit_assessment,\n expected_impact: player.roster_impact.projected_improvement,\n confidence: player.priority_score,\n });\n }\n\n // Add AI strategic recommendations\n for (const action of aiAnalysis.strategic_recommendations.immediate_actions.slice(0, 2)) {\n immediateActions.push({\n action,\n priority: \"MEDIUM\" as const,\n rationale: \"AI strategic analysis recommendation\",\n expected_impact: \"Improved team performance\",\n confidence: aiAnalysis.confidence_score,\n });\n }\n\n return {\n immediate_actions: immediateActions,\n weekly_priorities: aiAnalysis.strategic_recommendations.weekly_focus,\n long_term_strategy: aiAnalysis.strategic_recommendations.long_term_strategy,\n };\n }\n\n /**\n * Compile risk analysis\n */\n private compileRiskAnalysis(\n playerStats: PlayerPerformanceStats[],\n aiAnalysis: AIPerformanceAnalysis,\n ): AITeamPerformanceReview[\"risk_analysis\"] {\n const injuryConcerns = aiAnalysis.roster_analysis.injury_concerns.map(concern => ({\n player_name: concern.player_name,\n risk_level: concern.injury_risk,\n mitigation_strategy: concern.recommendation,\n }));\n\n // Add performance-based injury risks\n const lowGamesPlayers = playerStats.filter(p =>\n p.performance_metrics?.games_played\n && p.performance_metrics.games_played < this.config.thresholds.minGamesPlayed\n );\n\n for (const player of lowGamesPlayers.slice(0, 3)) {\n if (!injuryConcerns.some(c => c.player_name === player.name)) {\n injuryConcerns.push({\n player_name: player.name,\n risk_level: \"MEDIUM\" as const,\n mitigation_strategy: \"Monitor playing time and consider replacement options\",\n });\n }\n }\n\n return {\n injury_concerns: injuryConcerns,\n performance_risks: aiAnalysis.key_insights.risks,\n competitive_threats: aiAnalysis.competitive_outlook.key_matchup_concerns,\n };\n }\n}\n\n// ============================================================================\n// CONVENIENCE FUNCTIONS\n// ============================================================================\n\n/**\n * Create AI Team Performance Reviewer with default configuration\n */\nexport function createAITeamReviewer(config?: Partial): AITeamPerformanceReviewer {\n return new AITeamPerformanceReviewer(config);\n}\n\n/**\n * Quick high-confidence pickup recommendations\n * Simplified interface for immediate use\n */\nexport async function getQuickPickupRecommendations(\n userId: string,\n leagueId: string,\n teamKey?: string,\n): Promise {\n const reviewer = createAITeamReviewer({\n maxWaiverCandidates: 10, // Limit for speed\n minConfidenceThreshold: 75, // High confidence only\n features: {\n includeLeagueComparison: false,\n includeWeeklyTrends: false,\n includeInjuryAnalysis: true,\n includeCompetitiveContext: false,\n },\n });\n\n const result = await reviewer.getHighConfidencePickups(userId, leagueId, teamKey);\n return result.success ? result.pickups : [];\n}\n\n/**\n * Comprehensive team analysis\n * Full-featured analysis with all bells and whistles\n */\nexport async function getComprehensiveTeamAnalysis(\n userId: string,\n leagueId: string,\n teamKey?: string,\n): Promise {\n const reviewer = createAITeamReviewer(); // Use all default features\n\n const result = await reviewer.executeReview(userId, leagueId, teamKey);\n return result.success ? result.review! : null;\n}\n\n/**\n * System health check\n * Test all components to ensure everything is working\n */\nexport async function performSystemHealthCheck(): Promise<{\n healthy: boolean;\n components: Record;\n errors: string[];\n}> {\n const reviewer = createAITeamReviewer();\n const testResult = await reviewer.runSystemTest();\n\n return {\n healthy: testResult.success,\n components: testResult.results,\n errors: testResult.errors,\n };\n}\n\n// ============================================================================\n// EXPORTS\n// ============================================================================\n\nexport { type AITeamPerformanceReview, type AITeamReviewConfig, type ReviewExecutionResult };\n\n// Default export for Val.town function use\nexport default AITeamPerformanceReviewer;",[],[151,233],[151],{"_108":243,"_100":244,"_152":245,"_154":-5,"_155":139,"_156":246,"_158":159,"_110":247,"_105":197,"_162":176,"_164":248,"_165":27,"_166":-5,"_167":249,"_103":250},"49d8af64-4876-11f0-9f4b-76b3cceeab13","api_scheduler_trigger.tsx","dd05d26e-47b1-11f0-9108-76b3cceeab13",53,["D",1749833333065],"// Lou Fantasy Baseball Manual Scheduler Trigger API\n// Val.town HTTP endpoint for manually triggering the daily scheduler\n\nimport { LouLineupScheduler } from \"./daily_lineup_scheduler.tsx\";\n\nexport default async function(req: Request): Promise {\n console.log(\"Manual scheduler trigger API called\");\n\n // Parse request\n const url = new URL(req.url);\n const method = req.method;\n\n // Handle preflight requests\n if (method === \"OPTIONS\") {\n return new Response(null, {\n status: 200,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n },\n });\n }\n\n try {\n // Validate required environment variables\n const requiredEnvVars = [\"YAHOO_CLIENT_ID\", \"YAHOO_CLIENT_SECRET\", \"YAHOO_REDIRECT_URI\"];\n const missingVars = requiredEnvVars.filter(varName => !Deno.env.get(varName));\n\n if (missingVars.length > 0) {\n return createErrorResponse(\n \"Configuration Error\",\n `Missing required environment variables: ${missingVars.join(\", \")}`,\n 400,\n );\n }\n\n // Handle different endpoints\n if (method === \"GET\") {\n return await handleGetRequest(url);\n } else if (method === \"POST\") {\n return await handlePostRequest(req);\n } else {\n return createErrorResponse(\"Method Not Allowed\", \"Only GET and POST methods are supported\", 405);\n }\n } catch (error) {\n console.error(\"API error:\", error);\n return createErrorResponse(\n \"Internal Server Error\",\n error instanceof Error ? error.message : \"Unknown error\",\n 500,\n );\n }\n}\n\nasync function handleGetRequest(url: URL): Promise {\n const path = url.pathname;\n\n if (path === \"/scheduler\" || path === \"/\") {\n // Return scheduler status and info\n return new Response(\n JSON.stringify({\n service: \"Lou Fantasy Baseball Scheduler\",\n version: \"1.0.0\",\n status: \"active\",\n endpoints: {\n \"GET /scheduler\": \"Get scheduler status and configuration\",\n \"GET /scheduler/trigger\": \"Trigger scheduler (GET endpoint)\",\n \"POST /scheduler/run\": \"Manually trigger scheduler\",\n \"GET /scheduler/status\": \"Get detailed status\",\n \"GET /scheduler/config\": \"Get configuration info\",\n },\n config: {\n yahoo_client_id: Deno.env.get(\"YAHOO_CLIENT_ID\") ? \"✓ Set\" : \"✗ Missing\",\n yahoo_client_secret: Deno.env.get(\"YAHOO_CLIENT_SECRET\") ? \"✓ Set\" : \"✗ Missing\",\n yahoo_redirect_uri: Deno.env.get(\"YAHOO_REDIRECT_URI\") || \"✗ Missing\",\n val_town_api_token: Deno.env.get(\"valtown\") ? \"✓ Set\" : \"✗ Missing\",\n },\n timestamp: new Date().toISOString(),\n }),\n {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n }\n\n if (path === \"/scheduler/config\") {\n // Return configuration status\n const requiredEnvVars = [\"YAHOO_CLIENT_ID\", \"YAHOO_CLIENT_SECRET\", \"YAHOO_REDIRECT_URI\"];\n const missingVars = requiredEnvVars.filter(varName => !Deno.env.get(varName));\n\n return new Response(\n JSON.stringify({\n configuration: {\n yahoo_client_id: Deno.env.get(\"YAHOO_CLIENT_ID\") ? \"✓ Set\" : \"✗ Missing\",\n yahoo_client_secret: Deno.env.get(\"YAHOO_CLIENT_SECRET\") ? \"✓ Set\" : \"✗ Missing\",\n yahoo_redirect_uri: Deno.env.get(\"YAHOO_REDIRECT_URI\") || \"✗ Missing\",\n val_town_api_token: Deno.env.get(\"VAL_TOWN_API_TOKEN\") ? \"✓ Set\" : \"✗ Missing\",\n default_user_id: Deno.env.get(\"DEFAULT_USER_ID\") || \"default_user\",\n },\n validation: {\n valid: missingVars.length === 0,\n errors: missingVars.map(v => `${v} environment variable is required`),\n },\n timestamp: new Date().toISOString(),\n }),\n {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n }\n\n if (path === \"/scheduler/status\") {\n // Return detailed scheduler status\n const scheduler = new LouLineupScheduler();\n\n try {\n // Get basic stats without running full scheduler\n const tokenStorage = scheduler.tokenStorage;\n const userCount = await tokenStorage.getTokenCount();\n const users = await tokenStorage.listUsers();\n\n return new Response(\n JSON.stringify({\n status: \"ready\",\n users: {\n total: userCount,\n details: users.map(u => ({\n user_id: u.user_id,\n created_at: new Date(u.created_at * 1000).toISOString(),\n updated_at: new Date(u.updated_at * 1000).toISOString(),\n })),\n },\n next_scheduled_run: \"Based on cron configuration\",\n last_manual_run: \"Available in logs\",\n timestamp: new Date().toISOString(),\n }),\n {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n } catch (error) {\n console.error(\"Error getting scheduler status:\", error);\n return createErrorResponse(\"Status Check Failed\", error instanceof Error ? error.message : \"Unknown error\", 500);\n }\n }\n\n if (path === \"/scheduler/trigger\") {\n // GET endpoint that triggers the scheduler\n console.log(\"🚀 Manual scheduler trigger initiated (via GET)\");\n\n try {\n const scheduler = new LouLineupScheduler();\n const results = await scheduler.runDailySchedule();\n\n console.log(\"✅ Manual scheduler run completed\");\n\n // Check if we have token errors and redirect to auth if needed\n const tokenErrors = results.errors.filter(e =>\n e.error.includes(\"No valid tokens found\")\n || e.error.includes(\"authentication\")\n );\n\n if (tokenErrors.length > 0 && url.searchParams.get(\"format\") !== \"json\") {\n // Redirect to OAuth login page\n const redirectUri = Deno.env.get(\"YAHOO_REDIRECT_URI\");\n if (redirectUri) {\n // Extract base URL and redirect to /auth\n const baseUrl = redirectUri.replace(\"/callback\", \"\");\n const authUrl = `${baseUrl}/auth`;\n\n return new Response(null, {\n status: 302,\n headers: {\n \"Location\": authUrl,\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n }\n\n return new Response(\n JSON.stringify({\n success: results.errors.length === 0,\n message:\n `Scheduled ${results.total_pitchers_scheduled} pitchers across ${results.leagues_processed.length} leagues`,\n triggered_at: new Date().toISOString(),\n schedule_date: results.date,\n results: results,\n ...(tokenErrors.length > 0 && {\n auth_required: true,\n auth_url: Deno.env.get(\"YAHOO_REDIRECT_URI\")?.replace(\"/callback\", \"/auth\"),\n }),\n }),\n {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n } catch (error) {\n console.error(\"❌ Manual scheduler run failed:\", error);\n return createErrorResponse(\"Scheduler Failed\", error instanceof Error ? error.message : \"Unknown error\", 500);\n }\n }\n\n return createErrorResponse(\"Not Found\", \"Endpoint not found\", 404);\n}\n\nasync function handlePostRequest(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname;\n\n if (path === \"/scheduler/run\") {\n // Manually trigger the scheduler\n console.log(\"🚀 Manual scheduler trigger initiated\");\n\n try {\n // Parse request body for options\n let scheduleDate: Date | undefined;\n try {\n const body = await req.json();\n if (body.date) {\n scheduleDate = new Date(body.date);\n if (isNaN(scheduleDate.getTime())) {\n return createErrorResponse(\"Invalid Date\", \"Provided date is not valid\", 400);\n }\n }\n } catch {\n // No body or invalid JSON - use default date\n }\n\n const scheduler = new LouLineupScheduler();\n const results = await scheduler.runDailySchedule(scheduleDate);\n\n console.log(\"✅ Manual scheduler run completed\");\n\n return new Response(\n JSON.stringify({\n success: results.errors.length === 0,\n message:\n `Scheduled ${results.total_pitchers_scheduled} pitchers across ${results.leagues_processed.length} leagues`,\n triggered_at: new Date().toISOString(),\n schedule_date: results.date,\n results: results,\n }),\n {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n } catch (error) {\n console.error(\"❌ Manual scheduler run failed:\", error);\n return createErrorResponse(\"Scheduler Failed\", error instanceof Error ? error.message : \"Unknown error\", 500);\n }\n }\n\n return createErrorResponse(\"Not Found\", \"Endpoint not found\", 404);\n}\n\nfunction createErrorResponse(title: string, message: string, status: number): Response {\n return new Response(\n JSON.stringify({\n error: title,\n message: message,\n timestamp: new Date().toISOString(),\n status: status,\n }),\n {\n status: status,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n}",[],[244],{"_108":252,"_100":253,"_152":254,"_154":-5,"_155":139,"_156":255,"_158":159,"_110":256,"_105":237,"_162":218,"_164":257,"_165":27,"_166":-5,"_167":258,"_103":259},"c8f9acba-4af3-11f0-9994-76b3cceeab13","daily_lineup_scheduler.tsx","791b7434-47b1-11f0-96fe-76b3cceeab13",166,["D",1750107135766],"// Lou Fantasy Baseball Daily Lineup Scheduler\n// Val.town Cron Function for Daily Pitcher Optimization\n\nimport { LouTokenStorage, StoredTokens } from \"./token_storage.tsx\";\n\nexport interface SchedulerResult {\n date: string;\n leagues_processed: Array<{\n league_id: string;\n league_name: string;\n team_key: string;\n pitchers_scheduled: number;\n success: boolean;\n details: any;\n }>;\n total_pitchers_scheduled: number;\n errors: Array<{\n league_id?: string;\n type?: string;\n error: string;\n }>;\n}\n\n// New TypeScript interfaces for Performance Statistics\nexport interface PlayerPerformanceStats {\n player_id: string;\n name: string;\n team: string;\n position_type: \"B\" | \"P\"; // Batter or Pitcher\n eligible_positions: string[];\n season_stats: Record;\n recent_stats?: Record; // Optional weekly/period stats\n performance_metrics?: {\n games_played?: number;\n avg_fantasy_points?: number;\n consistency_score?: number;\n };\n}\n\nexport interface TeamPerformanceStats {\n team_id: string;\n team_name: string;\n league_id: string;\n season_record: {\n wins: number;\n losses: number;\n ties: number;\n win_percentage: number;\n };\n season_stats: Record;\n recent_performance: {\n last_5_weeks: Array<{\n week: number;\n opponent: string;\n result: \"W\" | \"L\" | \"T\";\n points_for: number;\n points_against: number;\n category_wins?: number;\n category_losses?: number;\n }>;\n };\n roster_analysis: {\n total_players: number;\n batters: number;\n pitchers: number;\n injured_players: number;\n bench_strength: number;\n };\n}\n\nexport interface WaiverWirePlayer {\n player_id: string;\n name: string;\n team: string;\n position_type: \"B\" | \"P\";\n eligible_positions: string[];\n ownership_percentage: number;\n season_stats: Record;\n fantasy_relevance_score?: number;\n add_recommendation?: \"HIGH\" | \"MEDIUM\" | \"LOW\";\n}\n\nexport interface FantasyStats {\n stat_id: string;\n stat_name: string;\n display_name: string;\n value: string | number;\n position_type: \"B\" | \"P\";\n sort_order: \"0\" | \"1\"; // 0 = lower is better (ERA), 1 = higher is better (HR)\n}\n\nexport interface YahooAPIConfig {\n access_token: string;\n refresh_token: string;\n expires_at: number;\n}\n\nexport class LouLineupScheduler {\n private tokenStorage: LouTokenStorage;\n\n constructor() {\n this.tokenStorage = new LouTokenStorage();\n }\n\n async runDailySchedule(scheduleDate?: Date): Promise {\n const date = scheduleDate || new Date();\n const dateStr = date.toISOString().split(\"T\")[0];\n\n console.log(`🚀 Running daily pitcher scheduler for ${dateStr}`);\n\n const results: SchedulerResult = {\n date: dateStr,\n leagues_processed: [],\n total_pitchers_scheduled: 0,\n errors: [],\n };\n\n try {\n // Get all authenticated users\n const users = await this.tokenStorage.listUsers();\n console.log(`📋 Found ${users.length} authenticated users`);\n\n if (users.length === 0) {\n results.errors.push({\n type: \"no_users\",\n error: \"No authenticated users found. Please complete OAuth setup first.\",\n });\n return results;\n }\n\n // Process each user\n for (const user of users) {\n try {\n console.log(`👤 Processing user: ${user.user_id}`);\n await this.processUserLeagues(user.user_id, date, results);\n } catch (error) {\n console.error(`❌ Error processing user ${user.user_id}:`, error);\n results.errors.push({\n type: \"user_processing\",\n error: `User ${user.user_id}: ${error instanceof Error ? error.message : String(error)}`,\n });\n }\n }\n\n console.log(`✅ Daily schedule completed: ${results.total_pitchers_scheduled} pitchers scheduled`);\n } catch (error) {\n console.error(`💥 Fatal scheduler error:`, error);\n results.errors.push({\n type: \"fatal\",\n error: error instanceof Error ? error.message : String(error),\n });\n }\n\n return results;\n }\n\n private async processUserLeagues(userId: string, date: Date, results: SchedulerResult): Promise {\n // Get user's valid tokens\n const tokenData = await this.tokenStorage.getTokens(userId);\n if (!tokenData) {\n console.log(`⚠️ Skipping user ${userId}: tokens expired or not found`);\n results.errors.push({\n type: \"token_expired\",\n error: `User ${userId}: tokens expired - skipping (user needs to re-authenticate)`,\n });\n return;\n }\n\n // Initialize Yahoo Fantasy API client\n const yahooAPI = new YahooFantasyAPIClient(tokenData, this.tokenStorage, userId);\n\n // Get user's leagues\n const leagues = await yahooAPI.getUserLeagues(userId);\n console.log(`🏟️ Found ${leagues.length} leagues for user ${userId}`);\n\n for (const league of leagues) {\n try {\n console.log(`⚾ Processing league: ${league.name} (${league.league_id})`);\n\n // Get user's team in this league\n const teamKey = await yahooAPI.getTeamKey(userId, league.league_id);\n if (!teamKey) {\n throw new Error(`Could not find team key for league ${league.league_id}`);\n }\n\n // Schedule pitchers for today\n const scheduleResult = await this.schedulePitchersForTeam(yahooAPI, teamKey, date);\n\n results.leagues_processed.push({\n league_id: league.league_id,\n league_name: league.name,\n team_key: teamKey,\n pitchers_scheduled: scheduleResult.pitchers_scheduled.length,\n success: scheduleResult.success,\n details: scheduleResult,\n });\n\n results.total_pitchers_scheduled += scheduleResult.pitchers_scheduled.length;\n } catch (error) {\n console.error(`❌ Error processing league ${league.league_id}:`, error);\n results.errors.push({\n league_id: league.league_id,\n error: error instanceof Error ? error.message : String(error),\n });\n }\n }\n }\n\n private async schedulePitchersForTeam(yahooAPI: YahooFantasyAPIClient, teamKey: string, date: Date) {\n // Get today's probable pitchers from MLB API\n const probablePitchers = await this.getTodaysProbablePitchers(date);\n console.log(`🎯 Found ${probablePitchers.length} probable pitchers for ${date.toDateString()}`);\n\n // Get current team roster\n const roster = await yahooAPI.getTeamRoster(teamKey);\n console.log(`👥 Team roster has ${roster.length} players`);\n\n // Find matching pitchers on the roster\n const matchingPitchers = this.findMatchingPitchers(roster, probablePitchers);\n console.log(`✅ Found ${matchingPitchers.length} matching pitchers to schedule`);\n\n // Optimize lineup - prioritize SP slots over P slots\n const optimization = this.optimizeLineup(roster, matchingPitchers);\n console.log(`🔄 Optimization suggests ${optimization.changes.length} lineup changes`);\n\n // Apply lineup changes\n const results = {\n success: true,\n pitchers_scheduled: [],\n changes_made: [],\n errors: [],\n };\n\n for (const change of optimization.changes) {\n try {\n await yahooAPI.setPlayerPosition(teamKey, change.playerId, change.newPosition);\n results.pitchers_scheduled.push(change.playerId);\n results.changes_made.push(change);\n console.log(`🔄 Set ${change.playerName} to ${change.newPosition}`);\n } catch (error) {\n console.error(`❌ Failed to set ${change.playerName} position:`, error);\n results.errors.push({\n player: change.playerName,\n error: error instanceof Error ? error.message : String(error),\n });\n }\n }\n\n return results;\n }\n\n private async getTodaysProbablePitchers(\n date: Date,\n ): Promise> {\n try {\n // Call MLB Stats API for probable pitchers\n const dateStr = date.toISOString().split(\"T\")[0];\n const response = await fetch(\n `https://statsapi.mlb.com/api/v1/schedule?sportId=1&date=${dateStr}&hydrate=probablePitcher`,\n );\n\n if (!response.ok) {\n throw new Error(`MLB API error: ${response.status}`);\n }\n\n const data = await response.json();\n const pitchers = [];\n\n for (const game of data.dates?.[0]?.games || []) {\n // Home team probable pitcher\n if (game.teams?.home?.probablePitcher) {\n pitchers.push({\n name: game.teams.home.probablePitcher.fullName,\n team: game.teams.home.team.abbreviation,\n game_time: game.gameDate,\n });\n }\n\n // Away team probable pitcher\n if (game.teams?.away?.probablePitcher) {\n pitchers.push({\n name: game.teams.away.probablePitcher.fullName,\n team: game.teams.away.team.abbreviation,\n game_time: game.gameDate,\n });\n }\n }\n\n return pitchers;\n } catch (error) {\n console.error(`❌ Error fetching probable pitchers:`, error);\n return [];\n }\n }\n\n private findMatchingPitchers(roster: any[], probablePitchers: any[]): any[] {\n const matches = [];\n const pitcherPositions = [\"SP\", \"RP\", \"P\"];\n\n console.log(`🔍 Searching for matching pitchers among ${roster.length} roster players`);\n console.log(`🎯 Today's probable pitchers: ${probablePitchers.map(p => `${p.name} (${p.team})`).join(\", \")}`);\n\n for (const player of roster) {\n // Check if player is a pitcher (has any pitcher position)\n const isPitcher = pitcherPositions.some(pos =>\n player.eligible_positions?.includes(pos)\n || player.position_type === \"P\"\n );\n\n if (!isPitcher) continue;\n\n console.log(\n `🥎 Checking pitcher: ${player.name} (${player.team || \"N/A\"}) - Position: ${player.selected_position}`,\n );\n\n for (const probable of probablePitchers) {\n // Match by name and team\n if (\n this.namesMatch(player.name, probable.name)\n && this.teamsMatch(player.team, probable.team)\n ) {\n console.log(`✅ MATCH FOUND: ${player.name} is starting today!`);\n matches.push({\n ...player,\n probable_info: probable,\n is_starting: true,\n });\n break;\n }\n }\n }\n\n console.log(`🎯 Found ${matches.length} matching starting pitchers`);\n return matches;\n }\n\n private teamsMatch(yahooTeam: string, mlbTeam: string): boolean {\n if (!yahooTeam || !mlbTeam) return true; // Skip team check if missing data\n\n // Normalize team abbreviations\n const normalize = (team: string) => team.toUpperCase().trim();\n return normalize(yahooTeam) === normalize(mlbTeam);\n }\n\n private namesMatch(yahooName: string, mlbName: string): boolean {\n // Simple name matching logic\n const normalize = (name: string) => name.toLowerCase().replace(/[^a-z\\s]/g, \"\").trim();\n const yahoo = normalize(yahooName);\n const mlb = normalize(mlbName);\n\n // Exact match\n if (yahoo === mlb) return true;\n\n // Last name + first initial match\n const yahooWords = yahoo.split(\" \");\n const mlbWords = mlb.split(\" \");\n\n if (yahooWords.length >= 2 && mlbWords.length >= 2) {\n const yahooLastFirst = `${yahooWords[yahooWords.length - 1]} ${yahooWords[0]}`;\n const mlbLastFirst = `${mlbWords[mlbWords.length - 1]} ${mlbWords[0]}`;\n\n if (yahooLastFirst === mlbLastFirst) return true;\n }\n\n return false;\n }\n\n private optimizeLineup(roster: any[], matchingPitchers: any[]): { changes: any[] } {\n const changes = [];\n const pitcherPositions = [\"SP\", \"RP\", \"P\"];\n\n console.log(`\\n🔧 OPTIMIZATION: Starting lineup optimization`);\n console.log(`📊 Roster size: ${roster.length}, Starting pitchers found: ${matchingPitchers.length}`);\n\n // Get all pitchers from roster\n const allPitchers = roster.filter(player =>\n pitcherPositions.some(pos =>\n player.eligible_positions?.includes(pos)\n || player.position_type === \"P\"\n )\n );\n\n console.log(`🥎 Total pitchers on roster: ${allPitchers.length}`);\n\n // Current pitcher positions\n const currentSP = allPitchers.filter(p => p.selected_position === \"SP\");\n const currentP = allPitchers.filter(p => p.selected_position === \"P\");\n\n console.log(`📍 Current positions - SP: ${currentSP.length}, P: ${currentP.length}`);\n console.log(`📍 SP players: ${currentSP.map(p => p.name).join(\", \")}`);\n console.log(`📍 P players: ${currentP.map(p => p.name).join(\", \")}`);\n\n // Available positions (standard fantasy baseball setup)\n const maxSP = 2;\n const maxP = 2;\n\n // Create sets for quick lookup\n const startingPitcherIds = new Set(matchingPitchers.map(p => p.player_id));\n\n // Find probable starters who are currently on the bench and need a slot\n const benchedStarters = matchingPitchers.filter(p => p.selected_position === \"BN\");\n console.log(`🪑 Probable starters on bench: ${benchedStarters.map(p => p.name).join(\", \")}`);\n\n // Find non-starting pitchers currently in SP/P slots (potential swap targets)\n const nonStartersInActive = [...currentSP, ...currentP].filter(p => !startingPitcherIds.has(p.player_id));\n console.log(\n `🎯 Non-starters in active slots: ${\n nonStartersInActive.map(p => `${p.name} (${p.selected_position})`).join(\", \")\n }`,\n );\n\n // For each benched starter, try to find a slot or make a swap\n for (const benchedStarter of benchedStarters) {\n console.log(`\\n🔄 Processing benched starter: ${benchedStarter.name}`);\n\n // First, try to place in empty SP slot\n if (currentSP.length < maxSP) {\n console.log(`📈 Moving ${benchedStarter.name} from BN to SP (empty slot)`);\n changes.push({\n playerId: benchedStarter.player_id,\n playerName: benchedStarter.name,\n currentPosition: \"BN\",\n newPosition: \"SP\",\n reason: \"Starting pitcher - SP slot available\",\n });\n // Track that we've filled this SP slot\n currentSP.push(benchedStarter);\n continue;\n }\n\n // Then try empty P slot\n if (currentP.length < maxP) {\n console.log(`📈 Moving ${benchedStarter.name} from BN to P (empty slot)`);\n changes.push({\n playerId: benchedStarter.player_id,\n playerName: benchedStarter.name,\n currentPosition: \"BN\",\n newPosition: \"P\",\n reason: \"Starting pitcher - P slot available\",\n });\n // Track that we've filled this P slot\n currentP.push(benchedStarter);\n continue;\n }\n\n // If no empty slots, try to find a non-starter to swap with\n // Prefer swapping from SP first (SP typically scores more points)\n let swapTarget = nonStartersInActive.find(p => p.selected_position === \"SP\");\n let targetPosition = \"SP\";\n\n if (!swapTarget) {\n // No non-starter in SP, try P slot\n swapTarget = nonStartersInActive.find(p => p.selected_position === \"P\");\n targetPosition = \"P\";\n }\n\n if (swapTarget) {\n console.log(`🔄 SWAP: ${swapTarget.name} (${targetPosition}) ↔ ${benchedStarter.name} (BN)`);\n\n // Move non-starter to bench\n changes.push({\n playerId: swapTarget.player_id,\n playerName: swapTarget.name,\n currentPosition: targetPosition,\n newPosition: \"BN\",\n reason: `Not starting today - swap with ${benchedStarter.name}`,\n });\n\n // Move starter to active position\n changes.push({\n playerId: benchedStarter.player_id,\n playerName: benchedStarter.name,\n currentPosition: \"BN\",\n newPosition: targetPosition,\n reason: `Starting pitcher - swap with ${swapTarget.name}`,\n });\n\n // Remove the swapped player from non-starters list and update position tracking\n const targetIndex = nonStartersInActive.indexOf(swapTarget);\n if (targetIndex > -1) {\n nonStartersInActive.splice(targetIndex, 1);\n }\n\n // Update position tracking\n if (targetPosition === \"SP\") {\n const spIndex = currentSP.findIndex(p => p.player_id === swapTarget.player_id);\n if (spIndex > -1) {\n currentSP[spIndex] = benchedStarter;\n }\n } else {\n const pIndex = currentP.findIndex(p => p.player_id === swapTarget.player_id);\n if (pIndex > -1) {\n currentP[pIndex] = benchedStarter;\n }\n }\n } else {\n console.log(`⚠️ No swap available for ${benchedStarter.name} - all active slots occupied by starters`);\n }\n }\n\n console.log(`🔧 OPTIMIZATION COMPLETE: ${changes.length} changes suggested`);\n changes.forEach(change => {\n console.log(` 📝 ${change.playerName}: ${change.currentPosition} → ${change.newPosition} (${change.reason})`);\n });\n\n return { changes };\n }\n}\n\n// Simplified Yahoo Fantasy API client for Val.town\nexport class YahooFantasyAPIClient {\n private config: YahooAPIConfig;\n private baseUrl = \"https://fantasysports.yahooapis.com/fantasy/v2\";\n private tokenStorage: LouTokenStorage;\n private userId: string;\n\n constructor(config: YahooAPIConfig, tokenStorage: LouTokenStorage, userId: string) {\n this.config = config;\n this.tokenStorage = tokenStorage;\n this.userId = userId;\n }\n\n private async ensureValidToken(): Promise {\n const now = Math.floor(Date.now() / 1000);\n const bufferTime = 300; // Refresh 5 minutes before expiry\n\n if (this.config.expires_at <= now + bufferTime) {\n console.log(\"🔄 Access token expired/expiring, refreshing...\");\n await this.refreshAccessToken();\n }\n }\n\n private async refreshAccessToken(): Promise {\n try {\n const response = await fetch(\"https://api.login.yahoo.com/oauth2/get_token\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Accept\": \"application/json\",\n },\n body: new URLSearchParams({\n client_id: Deno.env.get(\"YAHOO_CLIENT_ID\") || \"\",\n client_secret: Deno.env.get(\"YAHOO_CLIENT_SECRET\") || \"\",\n refresh_token: this.config.refresh_token,\n grant_type: \"refresh_token\",\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Token refresh failed: ${response.status} ${response.statusText}`);\n }\n\n const tokenData = await response.json();\n\n // Update local config\n this.config.access_token = tokenData.access_token;\n this.config.expires_at = Math.floor(Date.now() / 1000) + (tokenData.expires_in || 3600);\n\n // If we got a new refresh token, use it\n if (tokenData.refresh_token) {\n this.config.refresh_token = tokenData.refresh_token;\n }\n\n // Store updated tokens\n await this.tokenStorage.storeTokens(this.userId, {\n access_token: this.config.access_token,\n refresh_token: this.config.refresh_token,\n expires_in: tokenData.expires_in || 3600,\n });\n\n console.log(\"✅ Tokens refreshed successfully\");\n } catch (error) {\n console.error(\"❌ Token refresh failed:\", error);\n throw new Error(`Failed to refresh Yahoo tokens: ${error instanceof Error ? error.message : String(error)}`);\n }\n }\n\n private async makeRequest(endpoint: string, params?: Record): Promise {\n // Ensure we have a valid token before making the request\n await this.ensureValidToken();\n\n // Remove leading slash if present\n endpoint = endpoint.replace(/^\\//, \"\");\n\n // Build URL with params\n const url = new URL(`${this.baseUrl}/${endpoint}`);\n\n // Always add format=json\n url.searchParams.set(\"format\", \"json\");\n\n // Add any additional params\n if (params) {\n Object.entries(params).forEach(([key, value]) => {\n url.searchParams.set(key, value);\n });\n }\n\n console.log(`🔍 Making request to: ${url.toString()}`);\n\n const response = await fetch(url.toString(), {\n headers: {\n \"Authorization\": `Bearer ${this.config.access_token}`,\n \"Accept\": \"application/json\",\n },\n });\n\n // If we get a 401, try refreshing token once\n if (response.status === 401) {\n console.log(\"🔄 Got 401, attempting token refresh...\");\n await this.refreshAccessToken();\n\n // Retry the request with new token\n const retryResponse = await fetch(url.toString(), {\n headers: {\n \"Authorization\": `Bearer ${this.config.access_token}`,\n \"Accept\": \"application/json\",\n },\n });\n\n if (!retryResponse.ok) {\n throw new Error(`Yahoo API error after refresh: ${retryResponse.status} ${retryResponse.statusText}`);\n }\n\n return retryResponse.json();\n }\n\n if (!response.ok) {\n throw new Error(`Yahoo API error: ${response.status} ${response.statusText}`);\n }\n\n return response.json();\n }\n\n async getUserLeagues(userId: string): Promise> {\n try {\n const season = new Date().getFullYear(); // 2025 for current season\n console.log(`🔍 Getting leagues for user ${userId}, season ${season}`);\n\n // First get the game key for MLB for current season\n const gamesResponse = await this.makeRequest(\"/games\", { \"game_codes\": \"mlb\" });\n let gameKey = null;\n\n // Parse the nested games structure to find current season MLB\n const gamesData = gamesResponse?.fantasy_content?.games;\n if (gamesData) {\n for (let idx = 0; idx < (gamesData.count || 0); idx++) {\n const gameContainer = gamesData[idx.toString()]?.game?.[0];\n if (gameContainer?.code === \"mlb\" && String(gameContainer.season) === String(season)) {\n gameKey = gameContainer.game_key;\n console.log(`🎯 Found game key ${gameKey} for season ${season}`);\n break;\n }\n }\n }\n\n if (!gameKey) {\n console.log(`❌ No MLB game found for season ${season}`);\n return [];\n }\n\n // Get user's leagues using the specific game key\n const leaguesEndpoint = `/users;use_login=1/games;game_keys=${gameKey}/leagues`;\n console.log(`🔍 Fetching leagues with endpoint: ${leaguesEndpoint}`);\n const leaguesResponse = await this.makeRequest(leaguesEndpoint);\n\n console.log(`📊 Leagues response:`, JSON.stringify(leaguesResponse, null, 2));\n\n // Parse the nested leagues structure (matches Python implementation)\n const leagues = [];\n try {\n // Navigate to the leagues data following Yahoo's structure\n const userGames = leaguesResponse?.fantasy_content?.users?.[\"0\"]?.user?.[1]?.games?.[\"0\"]?.game?.[1]?.leagues;\n\n if (userGames) {\n // Iterate through numbered league entries\n for (let idx = 0; idx < (userGames.count || 0); idx++) {\n const leagueData = userGames[idx.toString()]?.league?.[0];\n if (leagueData) {\n leagues.push({\n league_id: leagueData.league_key,\n name: leagueData.name || \"Unknown League\",\n });\n console.log(`✅ Added league: ${leagueData.name} (${leagueData.league_key})`);\n }\n }\n }\n } catch (parseError) {\n console.error(\"❌ Error parsing leagues response:\", parseError);\n console.log(\"📊 Full leagues response structure:\", JSON.stringify(leaguesResponse, null, 2));\n }\n\n console.log(`🏟️ Found ${leagues.length} leagues for user ${userId}`);\n return leagues;\n } catch (error) {\n console.error(\"❌ Error fetching user leagues:\", error);\n return [];\n }\n }\n\n async getTeamKey(userId: string, leagueId: string): Promise {\n // Hardcoded team mapping for known leagues\n // This will be replaced with proper team discovery in the future\n const teamMapping: Record = {\n \"458.l.33474\": \"458.l.33474.t.7\", // El Duque's Leg Kick - Return of the Zack\n \"458.l.102183\": \"458.l.102183.t.8\", // Scribs Ruins Everything - Pirates go Yarbrough\n };\n\n if (leagueId in teamMapping) {\n const teamKey = teamMapping[leagueId];\n console.log(`🎯 Using hardcoded team key ${teamKey} for league ${leagueId}`);\n return teamKey;\n }\n\n console.log(`⚠️ No hardcoded team mapping for league ${leagueId}, attempting dynamic discovery`);\n\n try {\n const data = await this.makeRequest(`/league/${leagueId}/teams`);\n\n // Find user's team in the league\n const teams = data?.fantasy_content?.league?.[1]?.teams;\n if (teams) {\n const teamCount = teams.count || 0;\n console.log(`🔍 Found ${teamCount} teams in league ${leagueId}`);\n\n for (let idx = 0; idx < teamCount; idx++) {\n const teamContainer = teams[idx.toString()]?.team;\n if (Array.isArray(teamContainer) && teamContainer[0]?.team_key) {\n const teamKey = teamContainer[0].team_key;\n const teamName = teamContainer[0].name || \"Unknown Team\";\n console.log(`🏟️ Found team: ${teamName} (${teamKey})`);\n\n // For now, return first team (in production, we'd check ownership)\n console.log(`🎯 Using first team found: ${teamKey}`);\n return teamKey;\n }\n }\n }\n\n console.log(`❌ No teams found in league ${leagueId}`);\n return null;\n } catch (error) {\n console.error(`❌ Error getting team key for league ${leagueId}:`, error);\n return null;\n }\n }\n\n async getTeamRoster(teamKey: string): Promise {\n try {\n const data = await this.makeRequest(`/team/${teamKey}/roster/players`);\n\n const players = [];\n const rosterData = data?.fantasy_content?.team?.[1]?.roster?.[\"0\"]?.players;\n\n if (rosterData) {\n const playerCount = rosterData.count || 0;\n for (let idx = 0; idx < playerCount; idx++) {\n const playerContainer = rosterData[idx.toString()];\n if (playerContainer?.player) {\n const playerArray = playerContainer.player;\n if (Array.isArray(playerArray) && playerArray.length >= 2) {\n // First element contains player metadata, second contains position info\n const playerMetadata = {};\n for (const item of playerArray[0]) {\n if (typeof item === \"object\" && item !== null) {\n Object.assign(playerMetadata, item);\n }\n }\n\n const selectedPositionContainer = playerArray[1];\n let selectedPosition = \"BN\";\n if (selectedPositionContainer?.selected_position) {\n const posData = selectedPositionContainer.selected_position;\n if (Array.isArray(posData) && posData[1]?.position) {\n selectedPosition = posData[1].position;\n }\n }\n\n // Extract eligible positions\n const eligiblePositions = [];\n if (playerMetadata.eligible_positions) {\n for (const pos of playerMetadata.eligible_positions) {\n if (typeof pos === \"object\" && pos.position) {\n eligiblePositions.push(pos.position);\n } else if (typeof pos === \"string\") {\n eligiblePositions.push(pos);\n }\n }\n }\n\n // Extract player name with multiple fallbacks\n let playerName = \"Unknown Player\";\n if (playerMetadata.name) {\n if (typeof playerMetadata.name === \"string\") {\n playerName = playerMetadata.name;\n } else if (playerMetadata.name.full) {\n playerName = playerMetadata.name.full;\n } else if (playerMetadata.name.first && playerMetadata.name.last) {\n playerName = `${playerMetadata.name.first} ${playerMetadata.name.last}`;\n }\n } else if (playerMetadata.full_name) {\n playerName = playerMetadata.full_name;\n } else if (playerMetadata.display_name) {\n playerName = playerMetadata.display_name;\n }\n\n console.log(\n `🔍 DEBUG: Roster player ${playerMetadata.player_key}: \"${playerName}\" from metadata:`,\n JSON.stringify(playerMetadata.name, null, 2),\n );\n\n players.push({\n player_id: playerMetadata.player_key || \"\",\n name: playerName,\n team: playerMetadata.editorial_team_abbr || playerMetadata.team_abbr || \"\",\n position_type: playerMetadata.position_type || \"\",\n eligible_positions: eligiblePositions,\n selected_position: selectedPosition,\n });\n }\n }\n }\n }\n\n return players;\n } catch (error) {\n console.error(`Error fetching roster for team ${teamKey}:`, error);\n return [];\n }\n }\n\n async setPlayerPosition(teamKey: string, playerId: string, position: string): Promise {\n // Ensure we have a valid token before making the request\n await this.ensureValidToken();\n\n // Yahoo Fantasy API requires XML for roster changes\n const dateStr = new Date().toISOString().split(\"T\")[0];\n\n const xmlBody = `\n\n \n date\n ${dateStr}\n \n \n ${playerId}\n ${position}\n \n \n \n`;\n\n console.log(`🔄 Setting player ${playerId} to position ${position} for team ${teamKey}`);\n console.log(`📝 XML body: ${xmlBody}`);\n\n const response = await fetch(`${this.baseUrl}/team/${teamKey}/roster`, {\n method: \"PUT\",\n headers: {\n \"Authorization\": `Bearer ${this.config.access_token}`,\n \"Content-Type\": \"application/xml\",\n \"Accept\": \"application/xml\",\n },\n body: xmlBody,\n });\n\n if (!response.ok) {\n const responseText = await response.text();\n console.error(`❌ Yahoo API error response: ${responseText}`);\n throw new Error(`Failed to set player position: ${response.status} ${response.statusText}`);\n }\n\n console.log(`✅ Successfully set player ${playerId} to position ${position}`);\n }\n\n // ============================================================================\n // NEW PERFORMANCE STATISTICS METHODS\n // ============================================================================\n\n /**\n * Get player performance statistics for a specific time period\n * @param playerId - Yahoo player key (e.g., \"458.p.8967\")\n * @param leagueId - League ID to get stats from\n * @param days - Number of days to look back (optional, defaults to season stats)\n * @returns PlayerPerformanceStats object with comprehensive player data\n */\n async getPlayerPerformanceStats(\n playerId: string,\n leagueId: string,\n days?: number,\n ): Promise {\n try {\n console.log(`📊 Getting performance stats for player ${playerId} in league ${leagueId}`);\n\n // Get player season stats (Yahoo doesn't support date range filtering directly)\n const playerStatsResponse = await this.makeRequest(`/league/${leagueId}/players;player_keys=${playerId}/stats`);\n\n if (!playerStatsResponse?.fantasy_content?.league?.[1]?.players?.[\"0\"]?.player) {\n console.log(`❌ No player data found for ${playerId}`);\n return null;\n }\n\n const playerData = playerStatsResponse.fantasy_content.league[1].players[\"0\"].player;\n const playerInfo = playerData[0][0]; // First array contains player metadata\n const playerStats = playerData[1]?.player_stats || {}; // Second array contains stats\n\n // Parse player metadata\n const playerMetadata = Array.isArray(playerInfo)\n ? playerInfo.reduce((acc, item) => ({ ...acc, ...item }), {})\n : playerInfo;\n\n // Debug: Log player metadata to see structure\n console.log(`🔍 DEBUG: Player metadata for ${playerId}:`, JSON.stringify(playerMetadata, null, 2));\n\n // Parse statistics\n const seasonStats: Record = {};\n if (playerStats.stats && Array.isArray(playerStats.stats)) {\n for (const statItem of playerStats.stats) {\n if (statItem.stat) {\n const statId = statItem.stat.stat_id.toString();\n seasonStats[statId] = statItem.stat.value;\n }\n }\n }\n\n // Determine position type\n const positionType: \"B\" | \"P\" = playerMetadata.position_type === \"P\" ? \"P\" : \"B\";\n\n // Extract eligible positions\n const eligiblePositions: string[] = [];\n if (playerMetadata.eligible_positions && Array.isArray(playerMetadata.eligible_positions)) {\n for (const pos of playerMetadata.eligible_positions) {\n if (typeof pos === \"object\" && pos.position) {\n eligiblePositions.push(pos.position);\n } else if (typeof pos === \"string\") {\n eligiblePositions.push(pos);\n }\n }\n }\n\n // Extract player name with multiple fallbacks\n let playerName = \"Unknown Player\";\n if (playerMetadata.name) {\n if (typeof playerMetadata.name === \"string\") {\n playerName = playerMetadata.name;\n } else if (playerMetadata.name.full) {\n playerName = playerMetadata.name.full;\n } else if (playerMetadata.name.first && playerMetadata.name.last) {\n playerName = `${playerMetadata.name.first} ${playerMetadata.name.last}`;\n }\n } else if (playerMetadata.full_name) {\n playerName = playerMetadata.full_name;\n } else if (playerMetadata.display_name) {\n playerName = playerMetadata.display_name;\n }\n\n console.log(`✅ Extracted player name: \"${playerName}\" from metadata`);\n\n const performanceStats: PlayerPerformanceStats = {\n player_id: playerId,\n name: playerName,\n team: playerMetadata.editorial_team_abbr || playerMetadata.team_abbr || \"N/A\",\n position_type: positionType,\n eligible_positions: eligiblePositions,\n season_stats: seasonStats,\n performance_metrics: {\n games_played: this.calculateGamesPlayed(seasonStats, positionType),\n avg_fantasy_points: this.calculateAvgFantasyPoints(seasonStats, positionType),\n consistency_score: this.calculateConsistencyScore(seasonStats, positionType),\n },\n };\n\n console.log(`✅ Retrieved performance stats for ${performanceStats.name} (${performanceStats.position_type})`);\n return performanceStats;\n } catch (error) {\n console.error(`❌ Error getting player performance stats for ${playerId}:`, error);\n return null;\n }\n }\n\n /**\n * Get comprehensive team performance statistics\n * @param teamKey - Yahoo team key (e.g., \"458.l.33474.t.7\")\n * @param leagueId - League ID\n * @param days - Number of days to analyze (optional, defaults to season)\n * @returns TeamPerformanceStats object with team analysis\n */\n async getTeamPerformanceStats(\n teamKey: string,\n leagueId: string,\n days?: number,\n ): Promise {\n try {\n console.log(`📊 Getting team performance stats for ${teamKey} in league ${leagueId}`);\n\n // Get team's season stats\n const teamStatsResponse = await this.makeRequest(`/team/${teamKey}/stats`);\n\n // Get team's matchup history\n const teamMatchupsResponse = await this.makeRequest(`/team/${teamKey}/matchups`);\n\n // Get team roster for analysis\n const teamRoster = await this.getTeamRoster(teamKey);\n\n // Get league standings for record\n const standingsResponse = await this.makeRequest(`/league/${leagueId}/standings`);\n\n if (!teamStatsResponse?.fantasy_content?.team?.[1]?.team_stats) {\n console.log(`❌ No team stats found for ${teamKey}`);\n return null;\n }\n\n // Parse team metadata and stats\n const teamInfo = teamStatsResponse.fantasy_content.team[0];\n const teamStats = teamStatsResponse.fantasy_content.team[1].team_stats;\n\n // Parse season statistics\n const seasonStats: Record = {};\n if (teamStats.stats && Array.isArray(teamStats.stats)) {\n for (const statItem of teamStats.stats) {\n if (statItem.stat) {\n const statId = statItem.stat.stat_id.toString();\n seasonStats[statId] = statItem.stat.value;\n }\n }\n }\n\n // Parse team record from standings\n let teamRecord = { wins: 0, losses: 0, ties: 0, win_percentage: 0 };\n if (standingsResponse?.fantasy_content?.league?.[1]?.standings) {\n const standings = standingsResponse.fantasy_content.league[1].standings;\n for (let i = 0; i < (standings.count || 0); i++) {\n const teamData = standings[i.toString()]?.team;\n if (teamData && teamData[0] && Array.isArray(teamData[0])) {\n // Find matching team\n const teamMetadata = teamData[0].reduce((acc, item) => ({ ...acc, ...item }), {});\n if (teamMetadata.team_key === teamKey && teamData[1]?.team_standings) {\n const standings = teamData[1].team_standings;\n teamRecord = {\n wins: parseInt(standings.outcome_totals?.wins || \"0\"),\n losses: parseInt(standings.outcome_totals?.losses || \"0\"),\n ties: parseInt(standings.outcome_totals?.ties || \"0\"),\n win_percentage: parseFloat(standings.outcome_totals?.percentage || \"0\"),\n };\n break;\n }\n }\n }\n }\n\n // Parse recent matchups (last 5 weeks)\n const recentPerformance = this.parseRecentMatchups(teamMatchupsResponse, teamKey);\n\n // Analyze roster composition\n const rosterAnalysis = this.analyzeRosterComposition(teamRoster);\n\n const teamPerformanceStats: TeamPerformanceStats = {\n team_id: teamInfo.team_id || \"\",\n team_name: teamInfo.name || \"Unknown Team\",\n league_id: leagueId,\n season_record: teamRecord,\n season_stats: seasonStats,\n recent_performance: recentPerformance,\n roster_analysis: rosterAnalysis,\n };\n\n console.log(`✅ Retrieved team performance stats for ${teamPerformanceStats.team_name}`);\n return teamPerformanceStats;\n } catch (error) {\n console.error(`❌ Error getting team performance stats for ${teamKey}:`, error);\n return null;\n }\n }\n\n /**\n * Get available players from the waiver wire\n * @param leagueId - League ID\n * @param position - Filter by position (optional)\n * @param minOwnedPercentage - Minimum ownership threshold (optional, 0-100)\n * @returns Array of available players with performance data\n */\n async getWaiverWirePlayers(\n leagueId: string,\n position?: string,\n minOwnedPercentage?: number,\n ): Promise {\n try {\n console.log(`🔍 Getting waiver wire players for league ${leagueId}${position ? ` (position: ${position})` : \"\"}`);\n\n // Build search parameters\n const params: Record = {};\n if (position) {\n params.position = position;\n }\n\n // Get available players\n const playersResponse = await this.makeRequest(`/league/${leagueId}/players`, params);\n\n if (!playersResponse?.fantasy_content?.league?.[1]?.players) {\n console.log(`❌ No players data found for league ${leagueId}`);\n return [];\n }\n\n const playersData = playersResponse.fantasy_content.league[1].players;\n const waiverPlayers: WaiverWirePlayer[] = [];\n\n // Parse each player\n for (let i = 0; i < (playersData.count || 0); i++) {\n const playerContainer = playersData[i.toString()];\n if (!playerContainer?.player) continue;\n\n const playerData = playerContainer.player[0];\n if (!Array.isArray(playerData)) continue;\n\n // Combine player metadata\n const playerMetadata = playerData.reduce((acc, item) => ({ ...acc, ...item }), {});\n\n // Skip if player doesn't meet ownership criteria\n const ownershipPercentage = this.estimateOwnershipPercentage(playerMetadata);\n if (minOwnedPercentage && ownershipPercentage < minOwnedPercentage) {\n continue;\n }\n\n // Extract eligible positions\n const eligiblePositions: string[] = [];\n if (playerMetadata.eligible_positions && Array.isArray(playerMetadata.eligible_positions)) {\n for (const pos of playerMetadata.eligible_positions) {\n if (typeof pos === \"object\" && pos.position) {\n eligiblePositions.push(pos.position);\n } else if (typeof pos === \"string\") {\n eligiblePositions.push(pos);\n }\n }\n }\n\n // Get player stats if available\n const seasonStats: Record = {};\n // Note: Individual player stats would require separate API calls\n // For waiver wire, we focus on basic availability and position info\n\n const waiverPlayer: WaiverWirePlayer = {\n player_id: playerMetadata.player_key || \"\",\n name: playerMetadata.name?.full || \"Unknown Player\",\n team: playerMetadata.editorial_team_abbr || \"N/A\",\n position_type: playerMetadata.position_type === \"P\" ? \"P\" : \"B\",\n eligible_positions: eligiblePositions,\n ownership_percentage: ownershipPercentage,\n season_stats: seasonStats,\n fantasy_relevance_score: this.calculateFantasyRelevance(playerMetadata),\n add_recommendation: this.getAddRecommendation(playerMetadata, ownershipPercentage),\n };\n\n waiverPlayers.push(waiverPlayer);\n }\n\n // Sort by fantasy relevance score (highest first)\n waiverPlayers.sort((a, b) => (b.fantasy_relevance_score || 0) - (a.fantasy_relevance_score || 0));\n\n console.log(`✅ Found ${waiverPlayers.length} waiver wire players for league ${leagueId}`);\n return waiverPlayers;\n } catch (error) {\n console.error(`❌ Error getting waiver wire players for league ${leagueId}:`, error);\n return [];\n }\n }\n\n /**\n * Check player ownership percentage and availability\n * @param playerId - Yahoo player key\n * @param leagueId - League ID\n * @returns Ownership percentage (0-100) and availability status\n */\n async getPlayerOwnershipPercentage(\n playerId: string,\n leagueId: string,\n ): Promise<{ ownership_percentage: number; is_available: boolean; owned_by?: string }> {\n try {\n console.log(`🔍 Checking ownership for player ${playerId} in league ${leagueId}`);\n\n // Search for the specific player in the league\n const playerResponse = await this.makeRequest(`/league/${leagueId}/players;player_keys=${playerId}`);\n\n if (!playerResponse?.fantasy_content?.league?.[1]?.players?.[\"0\"]?.player) {\n console.log(`❌ Player ${playerId} not found in league ${leagueId}`);\n return { ownership_percentage: 0, is_available: false };\n }\n\n const playerData = playerResponse.fantasy_content.league[1].players[\"0\"].player[0];\n const playerMetadata = Array.isArray(playerData)\n ? playerData.reduce((acc, item) => ({ ...acc, ...item }), {})\n : playerData;\n\n // Check if player has ownership information\n // Yahoo API doesn't directly provide ownership percentage, so we estimate based on availability\n let ownershipPercentage = 0;\n let isAvailable = true;\n let ownedBy = undefined;\n\n // If player has team ownership info, they're owned\n if (playerMetadata.ownership) {\n isAvailable = false;\n ownershipPercentage = 100; // If we can see ownership, assume full ownership in this league\n ownedBy = playerMetadata.ownership.owner_team_name || \"Unknown Team\";\n } else {\n // Player is available on waivers/free agency\n isAvailable = true;\n ownershipPercentage = this.estimateOwnershipPercentage(playerMetadata);\n }\n\n console.log(`✅ Player ${playerId} ownership: ${ownershipPercentage}% (Available: ${isAvailable})`);\n return {\n ownership_percentage: ownershipPercentage,\n is_available: isAvailable,\n owned_by: ownedBy,\n };\n } catch (error) {\n console.error(`❌ Error checking ownership for player ${playerId}:`, error);\n return { ownership_percentage: 0, is_available: false };\n }\n }\n\n // ============================================================================\n // HELPER METHODS FOR PERFORMANCE ANALYSIS\n // ============================================================================\n\n // Yahoo Fantasy Baseball Stat ID Mapping\n private readonly STAT_ID_MAP: Record = {\n // Batting Stats\n \"1\": \"GP\", // Games Played\n \"2\": \"AB\", // At Bats\n \"3\": \"AVG\", // Batting Average\n \"4\": \"OBP\", // On-Base Percentage\n \"5\": \"SLG\", // Slugging Percentage\n \"6\": \"OPS\", // On-Base Plus Slugging\n \"7\": \"R\", // Runs\n \"8\": \"H\", // Hits\n \"9\": \"2B\", // Doubles\n \"10\": \"3B\", // Triples\n \"11\": \"TB\", // Total Bases\n \"12\": \"HR\", // Home Runs\n \"13\": \"RBI\", // Runs Batted In\n \"14\": \"BB\", // Walks\n \"15\": \"IBB\", // Intentional Walks\n \"16\": \"SB\", // Stolen Bases\n \"17\": \"CS\", // Caught Stealing\n \"18\": \"HBP\", // Hit By Pitch\n \"19\": \"SAC\", // Sacrifice Hits\n \"20\": \"SF\", // Sacrifice Flies\n \"21\": \"K\", // Strikeouts (Batting)\n\n // Pitching Stats\n \"25\": \"GS\", // Games Started\n \"26\": \"ERA\", // Earned Run Average\n \"27\": \"WHIP\", // Walks and Hits per Inning Pitched\n \"28\": \"W\", // Wins\n \"29\": \"L\", // Losses\n \"30\": \"SV\", // Saves\n \"31\": \"BS\", // Blown Saves\n \"32\": \"HD\", // Holds\n \"33\": \"CG\", // Complete Games\n \"34\": \"SHO\", // Shutouts\n \"35\": \"NH\", // No Hitters\n \"36\": \"PG\", // Perfect Games\n \"37\": \"QS\", // Quality Starts\n \"38\": \"TBF\", // Total Batters Faced\n \"39\": \"P_H\", // Hits Allowed\n \"40\": \"P_BB\", // Walks Allowed\n \"41\": \"HBP_P\", // Hit Batters\n \"42\": \"K_P\", // Strikeouts (Pitching)\n \"43\": \"WP\", // Wild Pitches\n \"44\": \"BK\", // Balks\n \"45\": \"R_P\", // Runs Allowed\n \"46\": \"ER\", // Earned Runs\n \"47\": \"HR_P\", // Home Runs Allowed\n \"48\": \"P_G\", // Games Pitched\n \"49\": \"P_GF\", // Games Finished\n \"50\": \"IP\", // Innings Pitched\n \"51\": \"P_SV\", // Saves (Alt)\n \"52\": \"P_HD\", // Holds (Alt)\n \"60\": \"APP\", // Appearances\n };\n\n private getReadableStatName(statId: string): string {\n return this.STAT_ID_MAP[statId] || `Stat_${statId}`;\n }\n\n private calculateGamesPlayed(stats: Record, positionType: \"B\" | \"P\"): number {\n // Debug: Log available stats\n const availableStats = Object.keys(stats).map(id => `${id}(${this.getReadableStatName(id)}):${stats[id]}`).join(\n \", \",\n );\n console.log(`🔍 DEBUG: Available stats for ${positionType}: ${availableStats}`);\n\n // Estimate games played based on position and key stats\n if (positionType === \"P\") {\n // For pitchers, try multiple stats in order of preference\n const gamesPlayed = parseInt(stats[\"1\"]?.toString() || \"0\"); // GP\n const gamesPitched = parseInt(stats[\"48\"]?.toString() || \"0\"); // P_G\n const gamesStarted = parseInt(stats[\"25\"]?.toString() || \"0\"); // GS\n const ip = parseFloat(stats[\"50\"]?.toString() || \"0\"); // Innings Pitched\n\n if (gamesPlayed > 0) return gamesPlayed;\n if (gamesPitched > 0) return gamesPitched;\n if (gamesStarted > 0) return gamesStarted;\n if (ip > 0) return Math.round(ip / 6); // Estimate ~6 IP per game\n return 0;\n } else {\n // For batters, try multiple stats in order of preference\n const gamesPlayed = parseInt(stats[\"1\"]?.toString() || \"0\"); // GP\n const atBats = parseInt(stats[\"2\"]?.toString() || \"0\"); // At Bats\n const hits = parseInt(stats[\"8\"]?.toString() || \"0\"); // Hits\n\n if (gamesPlayed > 0) return gamesPlayed;\n if (atBats > 0) return Math.round(atBats / 4); // Estimate ~4 AB per game\n if (hits > 0) return Math.round(hits / 1.5); // Estimate ~1.5 hits per game\n return 0;\n }\n }\n\n private calculateAvgFantasyPoints(stats: Record, positionType: \"B\" | \"P\"): number {\n // Simple fantasy points calculation based on common scoring\n let totalPoints = 0;\n\n if (positionType === \"P\") {\n // Pitcher scoring: W=5, SV=5, K=1, IP=1, ERA/WHIP penalties\n const wins = parseInt(stats[\"28\"]?.toString() || \"0\");\n const saves = parseInt(stats[\"32\"]?.toString() || \"0\");\n const strikeouts = parseInt(stats[\"42\"]?.toString() || \"0\");\n const ip = parseFloat(stats[\"50\"]?.toString() || \"0\");\n\n totalPoints = (wins * 5) + (saves * 5) + strikeouts + ip;\n } else {\n // Batter scoring: R=1, HR=4, RBI=1, SB=2, AVG bonus\n const runs = parseInt(stats[\"7\"]?.toString() || \"0\");\n const hr = parseInt(stats[\"12\"]?.toString() || \"0\");\n const rbi = parseInt(stats[\"13\"]?.toString() || \"0\");\n const sb = parseInt(stats[\"16\"]?.toString() || \"0\");\n\n totalPoints = runs + (hr * 4) + rbi + (sb * 2);\n }\n\n const gamesPlayed = this.calculateGamesPlayed(stats, positionType);\n return gamesPlayed > 0 ? totalPoints / gamesPlayed : 0;\n }\n\n private calculateConsistencyScore(stats: Record, positionType: \"B\" | \"P\"): number {\n // Simplified consistency calculation (would need weekly data for true consistency)\n // Higher scores indicate more consistent performance\n if (positionType === \"P\") {\n const era = parseFloat(stats[\"26\"]?.toString() || \"10.00\");\n const whip = parseFloat(stats[\"27\"]?.toString() || \"2.00\");\n // Lower ERA/WHIP = higher consistency (invert scale)\n return Math.max(0, 100 - ((era - 3.00) * 20) - ((whip - 1.20) * 30));\n } else {\n const avg = parseFloat(stats[\"3\"]?.toString() || \"0.200\");\n // Higher average = higher consistency\n return Math.min(100, (avg - 0.200) * 500);\n }\n }\n\n private parseRecentMatchups(matchupsResponse: any, teamKey: string): { last_5_weeks: Array } {\n const recentWeeks: Array = [];\n\n try {\n const matchupsData = matchupsResponse?.fantasy_content?.team?.[1]?.matchups;\n if (!matchupsData) return { last_5_weeks: [] };\n\n // Get last 5 matchups\n const matchupCount = Math.min(matchupsData.count || 0, 5);\n for (let i = 0; i < matchupCount; i++) {\n const matchup = matchupsData[i.toString()]?.matchup;\n if (!matchup) continue;\n\n const week = parseInt(matchup.week || \"0\");\n const teams = matchup[\"0\"]?.teams;\n if (!teams) continue;\n\n // Find our team and opponent\n let ourTeamStats = null;\n let opponentStats = null;\n let opponentName = \"Unknown\";\n\n for (let j = 0; j < (teams.count || 0); j++) {\n const teamData = teams[j.toString()]?.team;\n if (!teamData) continue;\n\n const teamInfo = teamData[0];\n const teamMetadata = Array.isArray(teamInfo)\n ? teamInfo.reduce((acc, item) => ({ ...acc, ...item }), {})\n : teamInfo;\n\n if (teamMetadata.team_key === teamKey) {\n ourTeamStats = teamData[1];\n } else {\n opponentName = teamMetadata.name || \"Unknown\";\n opponentStats = teamData[1];\n }\n }\n\n if (ourTeamStats) {\n // Determine result based on points or category wins\n let result: \"W\" | \"L\" | \"T\" = \"L\";\n let pointsFor = 0;\n let pointsAgainst = 0;\n\n if (ourTeamStats.team_points && opponentStats?.team_points) {\n pointsFor = parseFloat(ourTeamStats.team_points.total || \"0\");\n pointsAgainst = parseFloat(opponentStats.team_points.total || \"0\");\n result = pointsFor > pointsAgainst ? \"W\" : pointsFor === pointsAgainst ? \"T\" : \"L\";\n }\n\n recentWeeks.push({\n week,\n opponent: opponentName,\n result,\n points_for: pointsFor,\n points_against: pointsAgainst,\n });\n }\n }\n } catch (error) {\n console.error(\"Error parsing recent matchups:\", error);\n }\n\n return { last_5_weeks: recentWeeks.slice(-5) };\n }\n\n private analyzeRosterComposition(roster: any[]): any {\n let totalPlayers = roster.length;\n let batters = 0;\n let pitchers = 0;\n let injuredPlayers = 0;\n let benchStrength = 0;\n\n for (const player of roster) {\n if (player.position_type === \"P\") {\n pitchers++;\n } else {\n batters++;\n }\n\n if (player.status && player.status.includes(\"DL\")) {\n injuredPlayers++;\n }\n\n if (player.selected_position === \"BN\") {\n benchStrength++;\n }\n }\n\n return {\n total_players: totalPlayers,\n batters,\n pitchers,\n injured_players: injuredPlayers,\n bench_strength: benchStrength,\n };\n }\n\n private estimateOwnershipPercentage(playerMetadata: any): number {\n // Estimate ownership based on player attributes\n // This is a simplified estimation since Yahoo doesn't provide exact ownership %\n let ownership = 50; // Base 50%\n\n // Adjust based on player attributes\n if (playerMetadata.is_undroppable === \"1\") ownership += 40;\n if (playerMetadata.position_type === \"P\") ownership -= 10; // Pitchers generally owned less\n if (playerMetadata.display_position === \"SP\") ownership += 10; // Starting pitchers more valuable\n\n return Math.max(0, Math.min(100, ownership));\n }\n\n private calculateFantasyRelevance(playerMetadata: any): number {\n // Calculate fantasy relevance score (0-100)\n let score = 50; // Base score\n\n // Position value adjustments\n if (playerMetadata.position_type === \"P\") {\n if (playerMetadata.display_position === \"SP\") score += 20;\n if (playerMetadata.display_position === \"RP\") score += 10;\n } else {\n // Batter positions\n const positions = playerMetadata.eligible_positions || [];\n if (positions.some(p => p.position === \"C\")) score += 15; // Catchers scarce\n if (positions.some(p => p.position === \"SS\")) score += 10; // SS valuable\n }\n\n // Team quality (rough estimation based on team abbreviation)\n const topTeams = [\"LAD\", \"HOU\", \"ATL\", \"NYY\", \"BOS\"];\n if (topTeams.includes(playerMetadata.editorial_team_abbr)) {\n score += 15;\n }\n\n return Math.max(0, Math.min(100, score));\n }\n\n private getAddRecommendation(playerMetadata: any, ownershipPercentage: number): \"HIGH\" | \"MEDIUM\" | \"LOW\" {\n const relevanceScore = this.calculateFantasyRelevance(playerMetadata);\n\n if (relevanceScore >= 75 && ownershipPercentage < 25) return \"HIGH\";\n if (relevanceScore >= 60 && ownershipPercentage < 50) return \"MEDIUM\";\n return \"LOW\";\n }\n}\n\n// Val.town Cron Handler - This function will be called by Val.town's cron scheduler\nexport default async function(): Promise {\n console.log(\"🕒 Daily lineup scheduler cron job triggered\");\n\n try {\n const scheduler = new LouLineupScheduler();\n const results = await scheduler.runDailySchedule();\n\n // Log results\n console.log(\"📊 Schedule Results:\", JSON.stringify(results, null, 2));\n\n // Store results in Val.town's blob storage for history\n await fetch(\"https://api.val.town/v1/blob/scheduler_results\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${Deno.env.get(\"valtown\")}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n timestamp: new Date().toISOString(),\n results: results,\n }),\n });\n\n return new Response(\n JSON.stringify({\n success: results.errors.length === 0,\n message:\n `Scheduled ${results.total_pitchers_scheduled} pitchers across ${results.leagues_processed.length} leagues`,\n results: results,\n }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n } catch (error) {\n console.error(\"💥 Cron job failed:\", error);\n\n return new Response(\n JSON.stringify({\n success: false,\n error: error instanceof Error ? error.message : String(error),\n timestamp: new Date().toISOString(),\n }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n}",[],[253],{"_108":261,"_100":262,"_152":263,"_154":-5,"_155":139,"_156":161,"_158":159,"_110":264,"_105":31,"_162":187,"_164":73,"_165":27,"_166":-5,"_167":265,"_103":266},"04b4c0ec-46e8-11f0-9754-76b3cceeab13","main.tsx","04b4c182-46e8-11f0-9754-76b3cceeab13",["D",1749662277374],[],[262],{"_108":268,"_100":269,"_152":270,"_154":-5,"_155":139,"_156":271,"_158":159,"_110":272,"_105":227,"_162":176,"_164":273,"_165":27,"_166":-5,"_167":274,"_103":275},"a27ca1e0-47b1-11f0-9362-76b3cceeab13","oauth_auth.tsx","9852e3c2-46f9-11f0-b210-76b3cceeab13",41,["D",1749748870923],"// Lou Fantasy Baseball OAuth Auth Endpoint\nimport { LouOAuthHandler } from \"./oauth_handler.tsx\";\n\nexport default async function(req: Request): Promise {\n console.log(\"OAuth auth endpoint called\");\n\n try {\n const oauthHandler = new LouOAuthHandler();\n const { authUrl, state } = oauthHandler.getAuthorizationUrl();\n\n console.log(`Generated auth URL: ${authUrl}`);\n console.log(`State parameter: ${state}`);\n\n // Create response with redirect and set state cookie\n const response = new Response(null, {\n status: 302,\n headers: {\n \"Location\": authUrl,\n \"Set-Cookie\": `oauth_state=${state}; Secure; HttpOnly; SameSite=Lax; Path=/; Max-Age=600`,\n },\n });\n\n return response;\n } catch (error) {\n console.error(\"OAuth auth error:\", error);\n\n const errorMessage = error instanceof Error ? error.message : \"Unknown error\";\n\n return new Response(\n `\n \n \n \n OAuth Error\n \n \n \n

❌ OAuth Setup Error

Failed to initiate Yahoo Fantasy authentication.

Error: ${errorMessage}

Please check the configuration and try again.

\n Try Again\n

\n \n \n `,\n {\n status: 500,\n headers: { \"Content-Type\": \"text/html\" },\n },\n );\n }\n}",[],[269],{"_108":277,"_100":278,"_152":279,"_154":-5,"_155":139,"_156":280,"_158":159,"_110":281,"_105":217,"_162":176,"_164":282,"_165":27,"_166":-5,"_167":283,"_103":284},"9bd293f4-47b1-11f0-96fe-76b3cceeab13","oauth_callback.tsx","a97ae23a-46f9-11f0-b53f-76b3cceeab13",39,["D",1749748859742],"// Lou Fantasy Baseball OAuth Callback Endpoint\nimport { LouOAuthHandler } from \"./oauth_handler.tsx\";\nimport { LouTokenStorage } from \"./token_storage.tsx\";\n\nexport default async function(req: Request): Promise {\n console.log(\"OAuth callback endpoint called\");\n\n try {\n const url = new URL(req.url);\n const code = url.searchParams.get(\"code\");\n const state = url.searchParams.get(\"state\");\n const error = url.searchParams.get(\"error\");\n const errorDescription = url.searchParams.get(\"error_description\");\n\n // Handle OAuth errors from Yahoo\n if (error) {\n console.error(\"OAuth error from Yahoo:\", error, errorDescription);\n return createErrorResponse(\n \"Yahoo OAuth Error\",\n `Yahoo Fantasy API returned an error: ${error}${errorDescription ? ` - ${errorDescription}` : \"\"}`,\n \"Please try the authentication process again.\",\n );\n }\n\n // Validate required parameters\n if (!code || !state) {\n console.error(\"Missing code or state parameter\", { code: !!code, state: !!state });\n return createErrorResponse(\n \"Invalid OAuth Response\",\n \"Missing required parameters from Yahoo.\",\n \"Please try the authentication process again.\",\n );\n }\n\n // Validate state parameter (basic validation for demo)\n if (state.length < 10) {\n console.error(\"Invalid state parameter format:\", state);\n return createErrorResponse(\n \"Security Error\",\n \"Invalid state parameter received.\",\n \"This could indicate a security issue. Please try again.\",\n );\n }\n\n console.log(`Processing OAuth callback - State: ${state}, Code: ${code.substring(0, 10)}...`);\n\n // Initialize handlers\n const oauthHandler = new LouOAuthHandler();\n const tokenStorage = new LouTokenStorage();\n\n // Exchange code for tokens\n console.log(\"Exchanging authorization code for access tokens...\");\n const tokenData = await oauthHandler.exchangeCodeForTokens(code, state);\n console.log(\"Token exchange successful\");\n\n // Generate user ID (in production, you'd determine this from Yahoo user data)\n const userId = `yahoo_user_${Date.now()}_${Math.random().toString(36).substring(2, 8)}`;\n\n // Store tokens securely\n const stored = await tokenStorage.storeTokens(userId, tokenData);\n if (!stored) {\n throw new Error(\"Failed to store authentication tokens\");\n }\n\n console.log(`Tokens stored successfully for user: ${userId}`);\n\n // Get token count for display\n const tokenCount = await tokenStorage.getTokenCount();\n\n // Return success page with detailed information\n return new Response(\n `\n \n \n \n Authentication Success\n \n \n \n

✅ Yahoo Fantasy Authentication Successful!

Your Yahoo Fantasy Sports account has been successfully connected to Lou Fantasy Baseball Manager.

\n \n

🔐 Authentication Details

\n User ID:\n ${userId}\n

\n Access Token:\n ${tokenData.access_token.substring(0, 20)}...***\n

\n Token Type:\n ${tokenData.token_type || \"Bearer\"}\n

\n Expires:\n ${\n new Date(Date.now() + ((tokenData.expires_in || 3600) * 1000)).toLocaleString()\n }\n

\n Scope:\n ${tokenData.scope || \"fspt-r fspt-w\"}\n

\n Total Users:\n ${tokenCount}\n

\n\n

🚀 Next Steps

Your authentication is complete! You can now:

Access your Yahoo Fantasy leagues and teams
Use the Lou Fantasy Baseball Manager features
Set up automated pitcher scheduling
View league standings and player stats

\n\n

Keep this User ID safe: ${userId}

You'll need it to access your fantasy data through the API.

\n \n \n `,\n {\n status: 200,\n headers: { \"Content-Type\": \"text/html\" },\n },\n );\n } catch (error) {\n console.error(\"OAuth callback error:\", error);\n\n const errorMessage = error instanceof Error ? error.message : \"Unknown error occurred\";\n\n return createErrorResponse(\n \"Authentication Failed\",\n `Failed to complete Yahoo Fantasy authentication: ${errorMessage}`,\n \"Please try the authentication process again. If the problem persists, contact support.\",\n );\n }\n}\n\nfunction createErrorResponse(title: string, message: string, suggestion: string): Response {\n return new Response(\n `\n \n \n \n ${title}\n \n \n \n

❌ ${title}

${message}

${suggestion}

\n Try Authentication Again\n

\n \n \n `,\n {\n status: 400,\n headers: { \"Content-Type\": \"text/html\" },\n },\n );\n}",[],[278],{"_108":286,"_100":287,"_152":288,"_154":-5,"_155":139,"_156":289,"_158":159,"_110":290,"_105":227,"_162":187,"_164":291,"_165":27,"_166":-5,"_167":292,"_103":293},"5ade6394-4885-11f0-8e42-76b3cceeab13","oauth_handler.tsx","11674512-46f7-11f0-8299-76b3cceeab13",55,["D",1749839804077],"// Lou Fantasy Baseball OAuth Handler\nexport interface TokenResponse {\n access_token: string;\n refresh_token: string;\n expires_in: number;\n token_type: string;\n scope?: string;\n}\n\nexport interface AuthUrlResult {\n authUrl: string;\n state: string;\n}\n\nexport class LouOAuthHandler {\n private readonly clientId: string;\n private readonly clientSecret: string;\n private readonly redirectUri: string;\n private readonly baseUrl: string;\n\n constructor() {\n this.clientId = Deno.env.get(\"YAHOO_CLIENT_ID\") || \"\";\n this.clientSecret = Deno.env.get(\"YAHOO_CLIENT_SECRET\") || \"\";\n this.redirectUri = Deno.env.get(\"YAHOO_REDIRECT_URI\") || \"\";\n this.baseUrl = \"https://api.login.yahoo.com/oauth2\";\n\n if (!this.clientId || !this.clientSecret) {\n throw new Error(\"Missing required environment variables: YAHOO_CLIENT_ID, YAHOO_CLIENT_SECRET\");\n }\n }\n\n generateState(): string {\n return Math.random().toString(36).substring(2, 15)\n + Math.random().toString(36).substring(2, 15);\n }\n\n getAuthorizationUrl(): AuthUrlResult {\n const state = this.generateState();\n const params = new URLSearchParams({\n client_id: this.clientId,\n redirect_uri: this.redirectUri,\n response_type: \"code\",\n scope: \"fspt-w\",\n state: state,\n });\n\n return {\n authUrl: `${this.baseUrl}/request_auth?${params.toString()}`,\n state: state,\n };\n }\n\n async exchangeCodeForTokens(code: string, state: string): Promise {\n const tokenUrl = `${this.baseUrl}/get_token`;\n\n const body = new URLSearchParams({\n client_id: this.clientId,\n client_secret: this.clientSecret,\n redirect_uri: this.redirectUri,\n code: code,\n grant_type: \"authorization_code\",\n });\n\n const response = await fetch(tokenUrl, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Accept\": \"application/json\",\n },\n body: body.toString(),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(`Token exchange failed: ${response.status} ${response.statusText} - ${errorText}`);\n }\n\n const tokenData = await response.json() as TokenResponse;\n\n console.log(\"Raw token response from Yahoo:\", JSON.stringify(tokenData, null, 2));\n\n // Validate required fields\n if (!tokenData.access_token) {\n throw new Error(\"Invalid token response: missing access_token\");\n }\n\n if (!tokenData.refresh_token) {\n console.warn(\"No refresh_token in response - Yahoo may not provide refresh tokens in this flow\");\n console.log(\"Available fields:\", Object.keys(tokenData));\n }\n\n return tokenData;\n }\n\n async refreshToken(refreshToken: string): Promise {\n const tokenUrl = `${this.baseUrl}/get_token`;\n\n const body = new URLSearchParams({\n client_id: this.clientId,\n client_secret: this.clientSecret,\n refresh_token: refreshToken,\n grant_type: \"refresh_token\",\n });\n\n const response = await fetch(tokenUrl, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Accept\": \"application/json\",\n },\n body: body.toString(),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(`Token refresh failed: ${response.status} ${response.statusText} - ${errorText}`);\n }\n\n const tokenData = await response.json() as TokenResponse;\n\n // Validate required fields\n if (!tokenData.access_token) {\n throw new Error(\"Invalid refresh response: missing access_token\");\n }\n\n return tokenData;\n }\n}",[],[287],{"_108":295,"_100":296,"_152":297,"_154":-5,"_155":139,"_156":298,"_158":159,"_110":299,"_105":217,"_162":187,"_164":300,"_165":27,"_166":-5,"_167":301,"_103":302},"2c0ba840-4891-11f0-a242-76b3cceeab13","token_storage.tsx","823723e6-46f9-11f0-a200-76b3cceeab13",59,["D",1749844879479],"// Lou Fantasy Baseball Token Storage\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { LouOAuthHandler } from \"./oauth_handler.tsx\";\n\nexport interface StoredTokens {\n user_id: string;\n access_token: string;\n refresh_token: string;\n expires_at: number;\n created_at?: number;\n updated_at?: number;\n}\n\nexport interface TokenData {\n access_token: string;\n refresh_token: string;\n expires_in?: number;\n}\n\nexport interface UserRecord {\n user_id: string;\n created_at: number;\n updated_at: number;\n}\n\nexport class LouTokenStorage {\n private readonly blobKey = \"lou_oauth_tokens\";\n\n constructor() {\n console.log(\"LouTokenStorage initialized with Val.town blob storage\");\n }\n\n private encryptToken(token: string): string {\n // Simple base64 encoding for demo - use proper encryption in production\n return btoa(token);\n }\n\n private decryptToken(encryptedToken: string): string {\n // Simple base64 decoding for demo - use proper decryption in production\n return atob(encryptedToken);\n }\n\n async storeTokens(userId: string, tokenData: TokenData): Promise {\n try {\n // Calculate expiration time (default to 1 hour if not provided)\n const now = Math.floor(Date.now() / 1000);\n const expiresAt = now + (tokenData.expires_in || 3600);\n\n // Get existing tokens from blob storage\n let allTokens: Record = {};\n try {\n const existingData = await blob.getJSON(this.blobKey);\n if (existingData) {\n allTokens = existingData;\n }\n } catch (error) {\n // Blob doesn't exist yet, start with empty object\n console.log(\"No existing tokens found, creating new storage\");\n }\n\n // Log refresh token status\n console.log(`Storing tokens for ${userId}:`);\n console.log(`- access_token: ${tokenData.access_token ? \"PRESENT\" : \"MISSING\"}`);\n console.log(`- refresh_token: ${tokenData.refresh_token ? \"PRESENT\" : \"MISSING\"}`);\n console.log(`- refresh_token value: ${tokenData.refresh_token}`);\n console.log(`- expires_in: ${tokenData.expires_in}`);\n\n // Create stored token object\n const storedTokens: StoredTokens = {\n user_id: userId,\n access_token: this.encryptToken(tokenData.access_token),\n refresh_token: this.encryptToken(tokenData.refresh_token || \"\"),\n expires_at: expiresAt,\n created_at: allTokens[userId]?.created_at || now,\n updated_at: now,\n };\n\n // Store updated tokens\n allTokens[userId] = storedTokens;\n await blob.setJSON(this.blobKey, allTokens);\n\n console.log(`Stored tokens for user: ${userId}, expires at: ${new Date(expiresAt * 1000).toISOString()}`);\n return true;\n } catch (error) {\n console.error(`Failed to store tokens for user ${userId}:`, error);\n return false;\n }\n }\n\n async getTokens(userId: string): Promise {\n try {\n // Get all tokens from blob storage\n const allTokens = await blob.getJSON(this.blobKey) as Record;\n\n if (!allTokens || !allTokens[userId]) {\n console.log(`No tokens found for user: ${userId}`);\n return null;\n }\n\n const storedTokens = allTokens[userId];\n\n // Check if tokens are expired\n const now = Math.floor(Date.now() / 1000);\n if (storedTokens.expires_at <= now) {\n console.log(\n `Tokens expired for user: ${userId} (expired at: ${new Date(storedTokens.expires_at * 1000).toISOString()})`,\n );\n\n // Attempt to refresh tokens using the refresh token\n console.log(`Attempting to refresh tokens for user: ${userId}`);\n const refreshToken = this.decryptToken(storedTokens.refresh_token);\n\n if (!refreshToken || refreshToken === \"\") {\n console.log(`No refresh token available for user: ${userId}`);\n return null;\n }\n\n try {\n // Use the OAuth handler for refresh\n const oauthHandler = new LouOAuthHandler();\n\n console.log(`Calling refresh token API for user: ${userId}`);\n const newTokenData = await oauthHandler.refreshToken(refreshToken);\n console.log(`Token refresh successful for user: ${userId}`);\n\n // Store the new tokens\n const stored = await this.storeTokens(userId, newTokenData);\n if (!stored) {\n console.error(`Failed to store refreshed tokens for user: ${userId}`);\n return null;\n }\n\n console.log(`Refreshed tokens stored successfully for user: ${userId}`);\n\n // Return the new tokens\n return {\n user_id: userId,\n access_token: newTokenData.access_token,\n refresh_token: newTokenData.refresh_token || refreshToken, // Use new or keep old\n expires_at: now + (newTokenData.expires_in || 3600),\n created_at: storedTokens.created_at,\n updated_at: now,\n };\n } catch (error) {\n console.error(`Failed to refresh tokens for user: ${userId}:`, error);\n return null;\n }\n }\n\n // Decrypt tokens\n const decryptedRefreshToken = this.decryptToken(storedTokens.refresh_token);\n console.log(`Retrieved tokens for ${userId}:`);\n console.log(`- refresh_token stored: ${storedTokens.refresh_token ? \"PRESENT\" : \"MISSING\"}`);\n console.log(`- refresh_token decrypted: ${decryptedRefreshToken ? \"PRESENT\" : \"MISSING\"}`);\n console.log(`- refresh_token value: ${decryptedRefreshToken}`);\n\n return {\n user_id: storedTokens.user_id,\n access_token: this.decryptToken(storedTokens.access_token),\n refresh_token: decryptedRefreshToken,\n expires_at: storedTokens.expires_at,\n created_at: storedTokens.created_at,\n updated_at: storedTokens.updated_at,\n };\n } catch (error) {\n console.error(`Failed to get tokens for user ${userId}:`, error);\n return null;\n }\n }\n\n async updateTokens(userId: string, tokenData: TokenData): Promise {\n return await this.storeTokens(userId, tokenData);\n }\n\n async deleteTokens(userId: string): Promise {\n try {\n // Get all tokens from blob storage\n const allTokens = await blob.getJSON(this.blobKey) as Record;\n\n if (allTokens && allTokens[userId]) {\n delete allTokens[userId];\n await blob.setJSON(this.blobKey, allTokens);\n console.log(`Deleted tokens for user: ${userId}`);\n }\n\n return true;\n } catch (error) {\n console.error(`Failed to delete tokens for user ${userId}:`, error);\n return false;\n }\n }\n\n async listUsers(): Promise {\n try {\n const allTokens = await blob.getJSON(this.blobKey) as Record;\n\n if (!allTokens) {\n return [];\n }\n\n return Object.values(allTokens).map(tokens => ({\n user_id: tokens.user_id,\n created_at: tokens.created_at || 0,\n updated_at: tokens.updated_at || 0,\n })).sort((a, b) => b.updated_at - a.updated_at);\n } catch (error) {\n console.error(\"Failed to list users:\", error);\n return [];\n }\n }\n\n async getTokenCount(): Promise {\n try {\n const allTokens = await blob.getJSON(this.blobKey) as Record;\n return allTokens ? Object.keys(allTokens).length : 0;\n } catch (error) {\n console.error(\"Failed to get token count:\", error);\n return 0;\n }\n }\n}",[],[296],"files",[149,169,180,191,201,211,222,231,242,251,260,267,276,285,294],"counts",{"_307":31,"_308":161,"_309":31,"_310":311},"pulls","branches","forks","envVars",5,"contents",[],"file",{"_108":232,"_100":233,"_152":234,"_154":153,"_155":139,"_156":235,"_158":159,"_110":316,"_105":237,"_162":187,"_164":238,"_165":27,"_166":-5,"_103":317},["D",1750086292700],[151,233],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","routes/_app.x.$handle.$name.code.$",{"_98":99,"_100":101,"_102":42,"_105":-7,"_103":104,"_106":324,"_147":328,"_303":374,"_314":375,"_312":377,"_378":-5,"_379":27,"_380":-5,"_381":-5,"_382":-5,"_383":384},{"_108":109,"_100":101,"_110":325,"_112":-5,"_113":27,"_114":115,"_116":-5,"_117":-5,"_12":118,"_119":-5,"_120":27,"_121":-5,"_122":31,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_132":27,"_21":326,"_136":327},["D",1749662277362],{"_98":99,"_134":135},{"_105":138,"_100":42,"_108":139,"_140":109,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":101,"_146":99},[329,353,356,359,362,365,368,371],{"_108":150,"_100":151,"_152":153,"_154":-5,"_155":139,"_156":157,"_158":159,"_110":160,"_105":161,"_162":163,"_164":-5,"_165":27,"_166":-5,"_167":330,"_103":352},[331,334,337,340,343,346,349],{"_108":170,"_100":171,"_152":172,"_154":153,"_155":139,"_156":173,"_158":159,"_110":174,"_105":175,"_162":176,"_164":177,"_165":27,"_166":-5,"_167":332,"_103":333},[],[151,171],{"_108":181,"_100":182,"_152":183,"_154":153,"_155":139,"_156":184,"_158":159,"_110":185,"_105":186,"_162":187,"_164":188,"_165":27,"_166":-5,"_167":335,"_103":336},[],[151,182],{"_108":192,"_100":193,"_152":194,"_154":153,"_155":139,"_156":195,"_158":159,"_110":196,"_105":197,"_162":187,"_164":198,"_165":27,"_166":-5,"_167":338,"_103":339},[],[151,193],{"_108":202,"_100":203,"_152":204,"_154":153,"_155":139,"_156":205,"_158":159,"_110":206,"_105":207,"_162":187,"_164":208,"_165":27,"_166":-5,"_167":341,"_103":342},[],[151,203],{"_108":212,"_100":213,"_152":214,"_154":153,"_155":139,"_156":215,"_158":159,"_110":216,"_105":217,"_162":218,"_164":219,"_165":27,"_166":-5,"_167":344,"_103":345},[],[151,213],{"_108":223,"_100":224,"_152":225,"_154":153,"_155":139,"_156":138,"_158":159,"_110":226,"_105":227,"_162":187,"_164":228,"_165":27,"_166":-5,"_167":347,"_103":348},[],[151,224],{"_108":232,"_100":233,"_152":234,"_154":153,"_155":139,"_156":235,"_158":159,"_110":236,"_105":237,"_162":187,"_164":238,"_165":27,"_166":-5,"_167":350,"_103":351},[],[151,233],[151],{"_108":243,"_100":244,"_152":245,"_154":-5,"_155":139,"_156":246,"_158":159,"_110":247,"_105":197,"_162":176,"_164":248,"_165":27,"_166":-5,"_167":354,"_103":355},[],[244],{"_108":252,"_100":253,"_152":254,"_154":-5,"_155":139,"_156":255,"_158":159,"_110":256,"_105":237,"_162":218,"_164":257,"_165":27,"_166":-5,"_167":357,"_103":358},[],[253],{"_108":261,"_100":262,"_152":263,"_154":-5,"_155":139,"_156":161,"_158":159,"_110":264,"_105":31,"_162":187,"_164":73,"_165":27,"_166":-5,"_167":360,"_103":361},[],[262],{"_108":268,"_100":269,"_152":270,"_154":-5,"_155":139,"_156":271,"_158":159,"_110":272,"_105":227,"_162":176,"_164":273,"_165":27,"_166":-5,"_167":363,"_103":364},[],[269],{"_108":277,"_100":278,"_152":279,"_154":-5,"_155":139,"_156":280,"_158":159,"_110":281,"_105":217,"_162":176,"_164":282,"_165":27,"_166":-5,"_167":366,"_103":367},[],[278],{"_108":286,"_100":287,"_152":288,"_154":-5,"_155":139,"_156":289,"_158":159,"_110":290,"_105":227,"_162":187,"_164":291,"_165":27,"_166":-5,"_167":369,"_103":370},[],[287],{"_108":295,"_100":296,"_152":297,"_154":-5,"_155":139,"_156":298,"_158":159,"_110":299,"_105":217,"_162":187,"_164":300,"_165":27,"_166":-5,"_167":372,"_103":373},[],[296],[329,331,334,337,340,343,346,349,353,356,359,362,365,368,371],{"_108":232,"_100":233,"_152":234,"_154":153,"_155":139,"_156":235,"_158":159,"_110":316,"_105":237,"_162":187,"_164":238,"_165":27,"_166":-5,"_103":376},[151,233],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"routes/_app","actionData","errors"]