// *****************************************************
// <!-- Section 1 : Import Dependencies -->
// *****************************************************

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

// *****************************************************
// <!-- Section 2 : Connect to DB -->
// *****************************************************

// create `ExpressHandlebars` instance and configure the layouts and partials dir.
const hbs = handlebars.create({
  extname: 'hbs',
  layoutsDir: __dirname + '/src/views/layouts',
  partialsDir: __dirname + '/src/views/partials',
});

// database configuration
// database configuration
const dbConfig = {
  host: 'db', // the database server
  port: 5432, // the database port
  database: "users_db", // the database name
  user: "postgres", // the user account to connect with
  password: "pwd", // 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);
  });

// *****************************************************
// <!-- Section 3 : App Settings -->
// *****************************************************

// 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, '/src/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,
  })
);
app.use(async function(req, res, next) {
  res.locals.user = req.session.user; 

  if(res.locals.user) {
    try {
      res.locals.fav_teams = await getFavoriteTeamsForUser(res.locals.user.userid);
    } catch (error) {
      console.error('Error fetching favorite teams:', error);
    }
  }

  next();
});

// Serve static files from the 'public' directory
app.use(express.static(path.join(__dirname, '/src/assets')));

// *****************************************************
// <!-- Section 4 : Middleware -->
// *****************************************************

// Middleware to automatically update live scoreboard
const fetchMatchesData = require('./src/assets/middleware/navigation-bar/current-match-information');
app.use(fetchMatchesData);

//Middleware to automatically update in-game time abbreviations

const convert_time = require('./src/assets/middleware/navigation-bar/convert-time');
app.use(convert_time);


// Leagues Page Middleware

const fetchLeaguesData = require('./src/assets/middleware/leagues-page/get-current-league-information');
const fetchLeagueScorerData = require('./src/assets/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('./src/assets/middleware/clubs-page/get-current-club-information');

app.get('/club/:clubID', [fetchClubsData], (req, res) => {
    // Render the Handlebars view with league data

      var isFav = false;
      var fav_teams = res.locals.fav_teams;
      if(res.locals.user && fav_teams)
      {
      const isTeamIDInFavTeams = fav_teams.some(team => {
        const teamIdInt = parseInt(team.teamid);
        const clubIdInt = parseInt(req.params.clubID);
        console.log('Checking team:', teamIdInt);
        console.log('equal to', clubIdInt);
        return teamIdInt === clubIdInt;
    });
      if (isTeamIDInFavTeams) {
        isFav = true
      } 
      }
    res.render('pages/clubs-page', {
        isFav: isFav,
        clubID: req.params.clubID,
        clubs: res.locals.club
    });
});

// *****************************************************
// <!-- Section 5 : API Routes -->
// *****************************************************

/************************ 
 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('/');
});
  
// 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('/', { message: 'Password does not match' });
        }
        else{
        // Save user information in the session variable
        req.session.user = user;
        req.session.save();
  
        // Redirect user to the home page
        res.redirect('/');
        }
    } 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.redirect('/');
});

// 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' });
      }

      // Check if the username already exists in the database
      const existingUser = await db.oneOrNone('SELECT * FROM users WHERE username = $1', req.body.username);
      if (existingUser) {
          // If a user with the same username already exists, respond with status 409 and an error message
          return res.status(409).json({ status: 'error', message: 'Username already exists' });
      }

      // 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]);
      const user = await db.oneOrNone('SELECT * FROM users WHERE username = $1', req.body.username);
      req.session.user = user;
      req.session.save();
      // Redirect user to the home page
      res.redirect('/home');
  } 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) => {
  const loggedIn = req.session.user ? true : false;
   res.render('pages/home');
});

app.get('/logout', (req, res) => {
  req.session.destroy(err => {
      if (err) {
          console.error('Error destroying session:', err);
          res.status(500).send('Internal Server Error');
      } else {
          // Redirect to the same page after destroying the session
          res.redirect('/'); // You can change '/' to the desired page if it's not the home page
      }
  });
});

/************************ 
 League Page Routes
*************************/

// Import and call generateLeagueRoutes function
const generateLeagueRoutes = require('./src/assets/routes/league-pages/generate-league-routes');
generateLeagueRoutes(app);

/************************ 
 Club Page Routes
*************************/

// Import and call generateLeagueRoutes function
const generateClubRoutes = require('./src/assets/routes/club-pages/generate-club-routes');
generateClubRoutes(app);

/************************ 
 Favorite Team Database
*************************/

// Function to add a new row to the FavoriteTeams table
// database configuration

app.post('/favteam/add', async (req, res, next) => {
  try {
      const { userID, teamID, teamName, teamLogo } = req.body;

      // Check if the user is logged in
      if (!req.session.user) {
          return res.status(400).json({ message: 'Login or register to add a favorite team.' });
      }

      // Insert the new favorite team into the database
      const query = {
          text: 'INSERT INTO FavoriteTeams (UserID, TeamID, TeamName, TeamLogo) VALUES ($1, $2, $3, $4)',
          values: [userID, teamID, teamName, teamLogo],
      };

      await db.none(query);
      console.log('New favorite team added successfully.');
      return res.status(200).json({ message: 'New favorite team added successfully.' });
  } catch (error) {
      console.error('Error adding favorite team:', error);
      return res.status(500).json({ error: 'Error adding favorite team' });
  }
});

app.post('/favteam/remove', async (req, res) => {
  try {
    const { userID, teamID } = req.body;

    // Check if the team exists for the user
    const existingTeam = await db.oneOrNone(
      'SELECT * FROM FavoriteTeams WHERE UserID = $1 AND TeamID = $2',
      [userID, teamID]
    );

    // If the team does not exist for the user, return a 404 error
    if (!existingTeam) {
      return res.status(404).json({ message: 'This team is not in your favorites.' });
    }

    // Remove the favorite team from the database
    await db.none(
      'DELETE FROM FavoriteTeams WHERE UserID = $1 AND TeamID = $2',
      [userID, teamID]
    );

    console.log('Favorite team removed successfully.');
    return res.status(200).json({ message: 'Favorite team removed successfully.' });
  } catch (error) {
    console.error('Error removing favorite team:', error);
    
    // If the error is a database error, return a 500 error
    if (error instanceof QueryResultError) {
      return res.status(500).json({ error: 'Database error occurred while removing favorite team' });
    }
    
    // If the error is a generic error, return a 400 error
    return res.status(400).json({ error: 'Error occurred while removing favorite team' });
  }
});

async function getFavoriteTeamsForUser(userId) {
  try {
    // Execute the SQL query
    const favoriteTeams = await db.any(`
      SELECT * FROM FavoriteTeams
      WHERE UserID = $1;
    `, userId);`a`
    
    // Return the result
    return favoriteTeams;
  } catch (error) {
    console.error('Error fetching favorite teams:', error);
    throw error; // Rethrow the error for handling at a higher level
  }
}

// *****************************************************
// <!-- Section 5 : Start Server-->
// *****************************************************
// 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');