score-tracker/database/scores/games.js

const database = require('./../database');





class Game {
    constructor(id, date, team1ID, team2ID, team1Score, team2Score) {
        this.id = id;
        this.date = date;
        this.team1ID = team1ID;
        this.team2ID = team2ID;
        this.team1Score = team1Score;
        this.team2Score = team2Score;
    }
}



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 retrieveByTeamDivisionAndSeason(teamID, divisionID, seasonID) {
    const query = `SELECT *
            FROM scores.games
            WHERE (team1_id = $1 OR team2_id = $1) AND division_id = $2 AND season_id = $3
            ORDER BY game_date DESC;`;
    const table = (await database.executeQuery(query, [teamID,divisionID,seasonID]));

    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));
    });
    console.log(gamesList);
    return gamesList;
}





exports.add = add;
exports.remove = remove;
exports.retrieveByTeamDivisionAndSeason = retrieveByTeamDivisionAndSeason;