const database = require('./../database'); class Game { constructor(id, date, team1ID, team2ID, team1Score, team2Score, divisionID, seasonID) { this.id = id; this.date = date; this.team1ID = team1ID; this.team2ID = team2ID; this.team1Score = team1Score; this.team2Score = team2Score; this.divisionID = divisionID; this.seasonID = seasonID; } } async function add(divisionID, seasonID, date, team1ID, team2ID, team1Score, team2Score) { const query = `INSERT INTO scores.games(division_id, season_id, game_date, team1_id, team2_id, team1_score, team2_score) VALUES($1, $2, $3, $4, $5, $6, $7) RETURNING game_id;`; const dateISO = date.format('YYYY-MM-DD'); const id = (await database.executeQuery(query, [divisionID, seasonID, dateISO, team1ID, team2ID, team1Score, team2Score]))[0][0]; return new Game(id, date, team1ID, team2ID, team1Score, team2Score); } async function remove(id) { const query = `DELETE FROM scores.games WHERE game_id = $1 RETURNING * ;`; const row = (await database.executeQuery(query, [id]))[0]; return new Game(id, row[3], row[4], row[5], row[6], row[7]); } async function retrieve(teamID, divisionID, seasonID) { let table; if(teamID && divisionID && seasonID) { const query = `SELECT game_id, division_id, season_id, game_date, team1_id, team2_id, team1_score, team2_score FROM scores.games WHERE (team1_id = $1 OR team2_id = $1) AND division_id = $2 AND season_id = $3 ORDER BY game_date DESC;`; table = await database.executeQuery(query, [teamID,divisionID,seasonID]); } else { const query = `SELECT game_id, division_id, season_id, game_date, team1_id, team2_id, team1_score, team2_score FROM scores.games ORDER BY game_date DESC;`; table = await database.executeQuery(query); } const gamesList = []; table.forEach((row) => { opponentIsTeam2 = teamID != row[5]; opponentID = opponentIsTeam2 ? row[5] : row[4]; teamScore = opponentIsTeam2 ? row[6] : row[7]; opponentScore = opponentIsTeam2 ? row[7] : row[6]; gamesList.push(new Game(row[0], row[3].toISOString().slice(0,10), teamID, opponentID, teamScore, opponentScore, row[1], row[2])); }); return gamesList; } exports.add = add; exports.remove = remove; exports.retrieve = retrieve;