nraufu/politico

import '@babel/polyfill';
import bcrypt from 'bcrypt';
import { query } from '../models/connect';
import { responseHandler } from '../helpers/response';
import { assignToken } from '../helpers/assignToken';
import sendMail from '../helpers/sendEmail';
import queries from '../models/queries';

export class User {
    static async createUser(req, res) {
        try {
            const { fullName, email, phoneNumber, national_id, passportUrl, password} = req.body;
            const user = await query(queries.userExist, [national_id]);
            if(user.rows.length) return responseHandler(res, 409, {status: 409, Error: "User already Exists"});
            const hashPassword = bcrypt.hashSync(password, 5);
            const newUser = await query(queries.insertUser, [fullName, email, phoneNumber, national_id, passportUrl, hashPassword]);
            const newUserInfo = newUser.rows[0];
            const token = assignToken({ national_id : newUserInfo.national_id, isAdmin:newUserInfo.isadmin });
            return responseHandler(res, 201, {
                "status" : 201,
                "data": [{
                    "token": token,
                    "user": {
                        "Full name": newUserInfo.fullname,
                        "email": newUserInfo.email,
                        "phone Number": newUserInfo.phonenumber,
                        "national_id": newUserInfo.national_id,
                        "passport Url": newUserInfo.passporturl,
                        "Created On": newUserInfo.created_on
                    }
                }]
            });
        } catch (error) {
            return responseHandler(res, 500, { status: 500, Error: error.message });
        }
    }

    static async login(req, res) {
        try {
            const { national_id, password} = req.body;
            const user = await query(queries.userExist, [national_id]);
            if(!user.rows.length) return responseHandler(res, 404, {status:404, Error: "Account not registered"});
            const userInfo = user.rows[0];
            const isPasswordValid = bcrypt.compareSync(password, userInfo.password);
            if(!isPasswordValid) return responseHandler(res, 400, { status:400, Error: 'Incorrect Password'});
            const token = assignToken({ national_id : userInfo.national_id, isAdmin: userInfo.isadmin});
            return responseHandler(res, 200, {
                "status" : 200,
                "data": [{
                    "token": token,
                    "user": {
                        "Full name": userInfo.fullname,
                        "email": userInfo.email,
                        "phone Number": userInfo.phonenumber,
                        "national_id": userInfo.national_id,
                        "passport Url": userInfo.passporturl
                    }
                }]
            });
        } catch (error) {
            return responseHandler(res, 500, { status:500, Error: error.message });
        }
    }

    static async passwordReset(req, res) {
        try {
            const { email } = req.body;
            const getUserEmail = await query(queries.getEmail, [email]);
            if(!getUserEmail.rowCount) return responseHandler(res, 404, { status: 404, Error: 'No account found related to this email'});
            await sendMail(email);
            return responseHandler(res, 200, {
                "status": 200,
                "data": [{
                    "message": "check your email for password reset link",
                    "email": email
                }]
            })
        } catch (error) {
            return responseHandler(res, 500, { status:500, Error: error.message });
        }
    }

    static async writePetition(req, res) {
        try {
            const { officeId, createdBy, text, evidence } = req.body;
            const office = await query(queries.getOffice, [officeId]);
            if(!office.rowCount) return responseHandler(res, 404, {status: 404, Error: 'No government office found'});
            const petitionExist = await query(queries.petitions, [createdBy, officeId]);
            if(petitionExist.rowCount) return responseHandler(res, 409, {status: 409, Error: 'Petition already exist'});
            const petition = await query(queries.insertPetition, [officeId, createdBy, text, evidence]);
            return responseHandler(res, 200, {
                "status": 200,
                "data": petition.rows
            });
        } catch (error) {
            return responseHandler(res, 500, { status:500, Error: error.message });
        }
    }

    static async profileInfo(req, res){
        try {
            const user = await query(queries.userExist, [req.authorizedUser.national_id]);
            if(!user.rowCount) return responseHandler(res, 404, {status:404, Error: "No account found"});
            const votedFor = await query(queries.votedFor, [req.authorizedUser.national_id]);
            return responseHandler(res, 200, {
                "status": 200,
                "data": [{
                    userInfo: {
                        "Full name": user.rows[0].fullname,
                        "email": user.rows[0].email,
                        "phone Number": user.rows[0].phonenumber,
                        "national_id": user.rows[0].national_id,
                        "passport Url": user.rows[0].passporturl
                    }},{
                    votedFor: votedFor.rows
                    }
                ]
            })
        } catch (error) {
            return responseHandler(res, 500, { status:500, Error: error.message });
        }
    }
}