var express = require('express');
var app = express();
var path = require('path');
var cors = require('cors');
var bodyParser = require('body-parser');
var expressValidator = require('express-validator');

app.set('views','./views');
app.set('view engine','ejs');

app.use(express.static(path.join(__dirname+'public')));
app.use(bodyParser.urlencoded({extended:true}));
app.use(bodyParser.json());
app.use(cors());
app.use(expressValidator());

app.get('/',(req,res)=>{
    res.send('welcome');
});

var mysql = require('mysql');
var connection = require('express-myconnection');

app.use(connection(mysql,{
    host:'127.0.0.1',
    port:3306,
    user:'Bacot123',
    password:'Naufal Inside123',
    database:'Data',
    debug:false
},'request'));

var router = express.Router();

router.use((req,res,next)=>{
    console.log(req.method,req.url);
    next();
});

var curut = router.route('/add');

curut.get(function(req,res,next){
    req.getConnection(function(err,conn){
        if(err) return next(err);
        conn.query('SELECT * FROM user',function(err,rows){
            if(err){
                console.log(err);
                return next(err);
            }
            res.render('datapage',{data:rows});
        });
    });
});

curut.post((req,res,next)=>{
    req.assert('id','not empty').notEmpty();
    req.assert('nama','not empty').notEmpty();
    var errors = req.validationErrors();
    if(errors){
        res.status(422).json(errors);
        return;
    }
    var data = {
        id:req.body.id,
        nama:req.body.nama
    };
    req.getConnection((err,conn)=>{
        if(err) return next(err);
        conn.query('INSERT INTO user SET ?',data,function(err,rows){
            if(err){
                console.log(err);
                return next(err);
            }
            res.redirect("http://127.0.0.1:2030/api/add");
        });
    });
});

var curut2 = router.route('/edit/:id');

curut2.all(function(req,res,next){
    console.log(req.params);
    next();
});

curut2.get(function(req,res,next){
    var Id = req.params.id;
    req.getConnection(function(err,conn){
        if(err) return next(err);
        conn.query('SELECT * FROM user WHERE id = ?',[Id],function(err,rows){
            if(err){
                console.log(err);
                return next(err);
            }
            res.render('editpage',{data:rows});
        });
    });
});

var curut3 = router.route('/adding/edit/(:id)');

curut3.all(function(req,res,next){
    console.log(req.params);
    next();
});

curut3.post((req,res,next)=>{
    req.assert('nama','not empty').notEmpty();
    var errors = req.validationErrors();
    if(errors){
        res.status(422).json(errors);
        return;
    }
    var data = {
        nama:req.body.nama
    };
    req.getConnection(function(err,conn){
        if(err) return next(err);
        conn.query('UPDATE user SET ? WHERE id = ' + req.params.id,data,function(err,rows){
            if(err){
                console.log(err);
                return next(err);
            }
            res.redirect('http://127.0.0.1:2030/api/add');
        });
    });
});

curut3.delete(function(req,res,next){
    var Id = req.params.id;
    req.getConnection(function(err,conn){
        if(err) return next(err);
        conn.query('DELETE FROM user WHERE id = ?',[Id],function(err,rows){
            if(err){
                console.log(err);
                return next(err);
            }
            res.sendStatus(200);
        });
    });
});

var crt = router.route('/hello');

crt.post(function(req,res,next){
    console.log(req.body.id);
    console.log(req.body.nama);
});

app.use('/api',router);

app.listen(2030,'127.0.0.1');

console.log('server starting...');