const express=require('express');
const app=express();
const router=express.Router();
const upload=require('./uploadMiddleware');
const path=require('path');
const morgan=require('morgan');
const jwt=require('jsonwebtoken');
const config     = require('./config');
const fs=require('fs');
const tokenList  = {};
const connection = require('./conn');

var idData='';

router.get('/upload',async function (req,res) {
    await res.render('index');
});

router.post('/updatefoto',upload.single('image'), async function (req,res) {
    //await console.log('post');
    const imagePath=path.join(__dirname,'/public/images');
    const FileUpload=imagePath;
    if (!req.file){
        res.status(401).json({error:'No Image Found'});
    }
    const filename = await FileUpload.save(req.file.buffer);
    const postData = req.body;

    var email = postData.email;
    var reqtoken = postData.token;
    connection.query("update user set profile_foto_url = ? where email = ?", [filename, email], function (error, results, field) {
        return res.status(200).json({name: filename});
    });
});

router.post('/generateApiKey', (req, res) => {
    const postData = req.body;
    var email = postData.email;
    var password = postData.password;
    if (email && password)
    {
        const user     = {
            "email" : email,
            "password"  : password
        };
        const token        = jwt.sign(user, config.secret, { expiresIn : config.tokenLife });
        connection.query('SELECT * FROM USER', function (error, results, fields) {
            idData = parseInt(results.length)+1;
            idData = idData+"id";
            connection.query('insert into user values (?,?,?,?,?,?,?,?,?,?,?)',[password, idData.toString(), 'asd', email, '2019-01-01', '2019-01-01','asd','1','asd','1',token], function (error, results, field) {
                if(error) throw console.log(error);
                const response     = {
                    "status"       : "Success"
                };
                res.status(200).json(response);
            });
        });
    }
});

router.get('/listsubscriber' , (req, res) => {
    const postData = req.body;
    var email = postData.email;
    var tempid = '';
    connection.query('SELECT id_user from user where email = ?', [email], function (error,results,field) {
         tempid = results[0].id_user;
         console.log(field);
         connection.query("SELECT u.nama_user, u.email from d_subscribe d, user u where id_user2_subscribed = ? and u.id_user = d.id_user_subscriber",[tempid], function (error,results,field) {
             res.status(200).json(results);
             console.log(results);
         });
    });
});

router.get('/search/:keyword' , (req, res) => {
    var keyword = req.params.keyword;
    const postData = req.body;
    connection.query("select * from video where judul_video like '%"+keyword+"%'", function (error, results, field) {
        res.status(200).json(results);
    });

});

router.post('/subscribeChannel', (req,res) => {
    const postData = req.body;
    connection.query('INSERT INTO d_subscribe values(?,?)',[postData.id1, postData.id2], function (error, results, fields) {
        const response     = {
            "status"       : "Sukses"
        };
        if (error) throw (error);
        res.status(200).json(response);
    });
});

router.post('/login', (req, res) => {
    const postData = req.body;
    var email = postData.email;
    var password = postData.password;
    if(email && password)
    {
        connection.query('SELECT * FROM user WHERE email = ? AND password = ?', [email, password], function(error, results, fields){
            if (results.length > 0){
                const user     = {
                    "email" : email,
                    "password"  : password
                };
                const token        = jwt.sign(user, config.secret, { expiresIn : config.tokenLife });
                const refreshToken = jwt.sign(user, config.refreshTokenSecret, { expiresIn: config.refreshTokenLife });
                const response     = {
                    "status"       : "Logged in",
                    "token"        : token,
                    "refreshToken" : refreshToken,
                };
                tokenList[refreshToken] = response;
                res.status(200).json(response);
            }else{
                const response     = {
                    "status"       : "Username / Password SALAH !"
                };
                res.status(401).json(response);
            }
        });
    }else{
        const response     = {
            "status"       : "Error"
        };
        res.status(401).json(response);
    }
});

router.use(require('./tokenChecker'));
router.get('/secure', (req, res) => {
    res.send('Secure access');
});

module.exports=router;