groups.js

const express = require('express');
const app = express.Router();

const init = connection => {
	app.use((req, res, next) => {
		if(!req.session.user) {
			res.redirect('/');
		} else {
			next();
		};
	});

	// Rota Raiz do Projeto.
	// Metodo GET
	app.get('/', async(req, res) => {
		const [ groups, fields ] = await connection.execute('select groups.*, groups_users.role from groups left join groups_users on groups.id = groups_users.group_id and groups_users.user_id = ?', [
			req.session.user.id,
		]);
		res.render('groups', {
			groups
		});
	});

	// Lista grupos do usuário logado
	app.get('/:id', async(req, res) => {
		const [ group ]  = await connection.execute('select groups.*, groups_users.role from groups left join groups_users on groups_users.group_id = groups.id and groups_users.user_id = ? where groups.id = ?', [
			req.session.user.id,
			req.params.id
		]);
		const [pendings] = await connection.execute('select groups_users.*, users.name from groups_users inner join users on groups_users.user_id = users.id and groups_users.role like "pending" and groups_users.group_id = ?', [
			req.params.id
		]);
		const [games] = await connection.execute(`
					SELECT 
						games.*, 
						guessings.result_a as guess_a, 
						guessings.result_b as guess_b,
						guessings.score,
						(select flag_img from teams where name=games.team_a) as flag_team_a,
						(select flag_img from teams where name=games.team_b) as flag_team_b					
					FROM games 
					LEFT JOIN guessings 
						ON  games.id           = guessings.game_id 
						AND guessings.user_id  = ?
						AND guessings.group_id = ?`
		, [
			req.session.user.id,
			req.params.id
		]);
		res.render('group', { 
			pendings,
			group: group[0],
			games
		});
	});

	app.post('/:id', async(req, res) => {
		const guessings = [];
		Object
			.keys(req.body)
			.forEach(team => {
				const parts = team.split('_');
				const game  = {
					game_id: parts[1],
					result_a: req.body[team].a,
					result_b: req.body[team].b
				};
				guessings.push(game);
			});
		
		const batch = guessings.map(guess => {
			return connection.execute('insert into guessings (result_a, result_b, game_id, group_id, user_id) values (?,?,?,?,?)', [
				guess.result_a,
				guess.result_b,
				guess.game_id,
				req.params.id,
				req.session.user.id
			]);
		});
		await Promise.all(batch);
		res.redirect('/groups/' + req.params.id);
	});

	// Permite ou Nega a entrada num grupo do usuário logado
	app.get('/:id/pending/:idGU/:op', async(req, res) => {
		
		const [ group ]  = await connection.execute('select groups.*, groups_users.role from groups left join groups_users on groups_users.group_id = groups.id and groups_users.user_id = ? where groups.id = ?', [
			req.session.user.id,
			req.params.id
		]);

		if(group.length === 0 || group[0].role === 'owner'){
			if(req.params.op === 'yes'){
				await connection.execute('UPDATE groups_users SET role="user" where id = ? limit 1', [
					req.params.idGU
				]);
				res.redirect('/groups/' + req.params.id);
			} else {
				await connection.execute('DELETE FROM groups_users WHERE id = ? limit 1', [
					req.params.idGU
				]);
				res.redirect('/groups/' + req.params.id);
			};
		};
	});

	app.get('/:id/join', async(req, res) => {
		const [ rows, fields ] = await connection.execute('select * from groups_users where user_id = ? and group_id = ?', [
			req.session.user.id,
			req.params.id
		]);

		if(rows.length > 0) {
			res.redirect('/groups');
		} else {
			await connection.execute('insert into groups_users (group_id, user_id, role) values (?,?,?)', [
				req.params.id,
				req.session.user.id,
				'pending'
			]);
			res.redirect('/groups');
		};
	});

	app.get('/delete/:id', async(req, res) => {
		await connection.execute('delete from groups where id = ? limit 1', [
			req.params.id
		]);
    res.redirect('/groups');
	});

    
	// Metodo POST
	app.post('/', async(req, res) => {
		const [ inserted, insertFields ] = await connection.execute('insert into groups (name) values (?)', [
			req.body.name
		]);

		await connection.execute('insert into groups_users (group_id, user_id, role) values (?,?,?)', [
			inserted.insertId,
			req.session.user.id,
			'owner'
		]);

		res.redirect('/groups');
	});
    
  return app
};

module.exports = init;