// ***************************************************** // // ***************************************************** const express = require('express'); // To build an application server or API const app = express(); const handlebars = require('express-handlebars'); const Handlebars = require('handlebars'); const path = require('path'); const pgp = require('pg-promise')(); // To connect to the Postgres DB from the node server const bodyParser = require('body-parser'); const session = require('express-session'); // To set the session object. To store or access session data, use the `req.session`, which is (generally) serialized as JSON by the store. const bcrypt = require('bcryptjs'); // To hash passwords const axios = require('axios'); // To make HTTP requests from our server. We'll learn more about it in Part C. const moment = require('moment'); // To extract current time data // ***************************************************** // // ***************************************************** // create `ExpressHandlebars` instance and configure the layouts and partials dir. const hbs = handlebars.create({ extname: 'hbs', layoutsDir: __dirname + '/views/layouts', partialsDir: __dirname + '/views/partials', }); // database configuration const dbConfig = { host: 'db', // the database server port: 5432, // the database port database: process.env.POSTGRES_DB, // the database name user: process.env.POSTGRES_USER, // the user account to connect with password: process.env.POSTGRES_PASSWORD, // the password of the user account }; const db = pgp(dbConfig); // test your database db.connect() .then(obj => { console.log('Database connection successful'); // you can view this message in the docker compose logs obj.done(); // success, release the connection; }) .catch(error => { console.log('ERROR:', error.message || error); }); // ***************************************************** // // ***************************************************** // Register `hbs` as our view engine using its bound `engine()` function. app.engine('hbs', hbs.engine); app.set('view engine', 'hbs'); app.set('views', path.join(__dirname, 'views')); app.use(bodyParser.json()); // specify the usage of JSON for parsing request body. // initialize session variables app.get('/welcome', (req, res) => { res.json({status: 'success', message: 'Welcome!'}); }); app.use( session({ secret: process.env.SESSION_SECRET, saveUninitialized: false, resave: false, }) ); app.use( bodyParser.urlencoded({ extended: true, }) ); // Serve static files from the 'public' directory app.use(express.static(path.join(__dirname, 'resources'))); // ***************************************************** // // ***************************************************** // Middleware to automatically update live scoreboard const fetchMatchesData = require('./resources/middleware/navigation-bar/current-match-information'); app.use(fetchMatchesData); //Middleware to automatically update in-game time abbreviations const convert_time = require('./resources/middleware/navigation-bar/convert-time'); app.use(convert_time); // Leagues Page Middleware const fetchLeaguesData = require('./resources/middleware/leagues-page/get-current-league-information'); const fetchLeagueScorerData = require('./resources/middleware/leagues-page/get-current-league-top-scorers'); app.get('/league/:leagueID', [fetchLeaguesData, fetchLeagueScorerData], (req, res) => { // Render the Handlebars view with league data res.render('pages/leagues-page', { leagueID: req.params.leagueID, leagues: res.locals.leagues, scorers: res.locals.topScorers // Assuming fetchLeagueScorerData sets the data in res.locals.scorers }); }); // Clubs Page Middleware const fetchClubsData = require('./resources/middleware/clubs-page/get-current-club-information'); app.get('/league/:leagueID', [fetchLeaguesData, fetchLeagueScorerData], (req, res) => { // Render the Handlebars view with league data res.render('pages/clubs-page', { clubID: req.params.clubID, clubs: res.locals.clubs, }); }); // ***************************************************** // // ***************************************************** /************************ Login Page Routes *************************/ // Redirect to the /login endpoint app.get('/', (req, res) => { res.redirect('/home'); }); // Render login page for /login route app.get('/login', (req, res) => { res.render('pages/home'); }); // Trigger login form to check database for matching username and password app.post('/login', async (req, res) => { try { // Check if username exists in DB const user = await db.oneOrNone('SELECT * FROM users WHERE username = $1', req.body.username); if (!user) { // Redirect user to login screen if no user is found with the provided username return res.redirect('/register'); } // Check if password from request matches with password in DB const match = await bcrypt.compare(req.body.password, user.password); // Check if match returns no data if (!match) { // Render the login page with the message parameter return res.render('pages/home', { message: 'Password does not match' }); } // Save user information in the session variable req.session.user = user; req.session.save(); // Redirect user to the home page res.redirect('/home'); } catch (error) { // Direct user to login screen if no user is found with matching password res.redirect('/register'); } }); /************************ Registration Page Routes *************************/ // Render registration page for /register route app.get('/register', (req, res) => { res.render('pages/register'); }); // Trigger Registration Form to Post app.post('/register', async (req, res) => { try { if (!req.body.username || !req.body.password) { // If username or password is missing, respond with status 400 and an error message return res.status(400).json({ status: 'error', message: 'Invalid input' }); } // Hash the password using bcrypt library const hash = await bcrypt.hash(req.body.password, 10); // Insert username and hashed password into the 'users' table await db.none('INSERT INTO users (username, password) VALUES ($1, $2)', [req.body.username, hash]); // Redirect user to the login page after successful registration res.status(200).json({ status: 'success', message: 'Registration successful' }); } catch (error) { // If an error occurs during registration, respond with status 500 and an error message res.status(500).json({ status: 'error', message: 'An error occurred during registration' }); } }); /************************ Home Page Routes *************************/ app.get('/home', (req, res) => { res.render('pages/home'); }); /************************ League Page Routes *************************/ // Import and call generateLeagueRoutes function const generateLeagueRoutes = require('./resources/routes/league-pages/generate-league-routes'); generateLeagueRoutes(app); // ***************************************************** // // ***************************************************** // starting the server and keeping the connection open to listen for more requests module.exports = app.listen(3000); console.log('Server is listening on port 3000');