const { Injectable } = require('flitter-di') /** * A data patch which fetches all of the player stats for a range of * weeks and creates WeeklyPlayerStat records for all players for all * weeks. * * This builds the base of data we need to calculate the weekly team * standings. * * @example * P = require('./app/SeedWeeklyPlayerData.patch') * p = _di.make(P) * await p.run() * * @extends Injectable */ class SeedWeeklyPlayerDataPatch extends Injectable { static get services() { return [...super.services, 'models', 'sports_data', 'output'] } /** * Run the patch. * @return {Promise} */ async run() { const Player = this.models.get('Player') const WeeklyPlayerStat = this.models.get('WeeklyPlayerStat') const start_week = 1 const end_week = 17 // Clear existing data await WeeklyPlayerStat.deleteMany() // Populate the weekly player stats for all weeks in the range for ( let week = start_week; week <= end_week; week += 1 ) { this.output.info(`Building weekly player stats for week ${week}...`) const player_stats = await this.sports_data.get_week_player_stats(week) this.output.info(` - processing ${player_stats.length} stats`) for ( const stat of player_stats ) { const player = await Player.findOne({ 'patch_data.player_id': stat.PlayerID, }) if ( player ) { const weekly_stat = new WeeklyPlayerStat({ player_id: player.id, patch_player_id: stat.PlayerID, week_num: week, fantasy_points: stat.FantasyPoints, passing_attempts: stat.PassingAttempts, passing_completions: stat.PassingCompletions, passing_yards: stat.PassingYards, fumbles: stat.Fumbles, kick_returns: stat.KickReturns, sacks: stat.Sacks, }) await weekly_stat.save() if ( week === 1 || !player.seed_stats || Object.values(player.seed_stats).length < 1 ) { player.seed_stats = await weekly_stat.to_api() } } else { this.output.warn(` - Player ID ${stat.PlayerID} does not exist.`) } } this.output.success(` - complete`) } this.output.success('Complete!') } } module.exports = exports = SeedWeeklyPlayerDataPatch