// 1.導(dǎo)入express
const express = require('express');
// 2.創(chuàng)建服務(wù)器的實(shí)例對(duì)象
const app = express();
 
// 3.啟動(dòng)服務(wù)器
app.listen(8088, () => {
    console.log('api server running at http:127.0.0.1:8088');
});

// 1.1 導(dǎo)入并配置cors中間件
const cors = require('cors');
app.use(cors());
 
// 1.2 配置解析表單數(shù)據(jù)的中間件, 這個(gè)中間件只能解析 application/x-www-form-urlencoded 格式的表單數(shù)據(jù)
app.use(express.urlencoded({ extended: false }));
 
// 1.3 只能解析parse application/json 格式
app.use(express.json());

// 1.導(dǎo)入express
var express = require('express');
// 對(duì)body-parser進(jìn)行配置，獲取前端傳送過來的數(shù)據(jù)
var bodyParser = require('body-parser');
// 2.創(chuàng)建服務(wù)器的實(shí)例對(duì)象
const app = express();
 
// 1.1 導(dǎo)入并配置cors中間件
const cors = require('cors');
app.use(cors());
 
// 1.2 配置解析表單數(shù)據(jù)的中間件, 這個(gè)中間件只能解析 application/x-www-form-urlencoded 格式的表單數(shù)據(jù)
app.use(bodyParser.urlencoded({ extended: false }));
 
// 1.3 只能解析parse application/json 格式
app.use(bodyParser.json());
 
//雖然請(qǐng)求體的格式不同,但是經(jīng)過node解析后,他們最終得到的都是json格式的對(duì)象。

// 1.導(dǎo)入 express 模塊
const express = require('express');
// 2.創(chuàng)建路由對(duì)象
const router = express.Router();
 
// 5.導(dǎo)入用戶路由處理函數(shù)對(duì)應(yīng)的模塊
const user_handler = require('../router_handler/user')
 
// 3.掛載路由
// 注冊(cè)新用戶
router.post('/reg', user_handler.reg);
// 登錄
router.post('/login', user_handler.login);
 
// 4.暴露router模塊
module.exports = router;

// 注冊(cè)新用戶的處理函數(shù)
exports.reg = (req, res) => {
    res.send('reg ok')
}
 
// 登陸的處理函數(shù)
exports.login = (req, res) => {
    res.send('login ok')
}

// 導(dǎo)入并使用用戶router模塊
const userRouter = require('./router/user');
app.use('/api', userRouter);

// 1.導(dǎo)入mysql模塊
const mysql = require('mysql')
 
// 2.創(chuàng)建數(shù)據(jù)庫連接對(duì)象
const db = mysql.createPool({
    host: '127.0.0.1',
    user: 'root',
    password: '123456',
    datebase: 'my_dv'
})
 
// 3.向外共享 數(shù)據(jù)庫的連接對(duì)象
module.exports = db

// 一定要在路由之前封裝res.cc函數(shù)
app.use((req, res, next) => {
    // status 默認(rèn)值為 1，表示失敗的情況
    // err的值，可能是錯(cuò)誤對(duì)象，也可能是錯(cuò)誤的描述字符串
    res.cc = function (err, status = 1) {
        res.send({
            status,
            message: err instanceof Error ? err.message : err,
        });
    };
    next();
});

// 1.導(dǎo)入加密功能的bcrypt.js
const bcrypt = require('bcryptjs');
 
//2.在處理函數(shù)中使用
 
// 注冊(cè)用戶的處理函數(shù)，如果用戶名可用，則調(diào)用bcrypt.hashSync() 對(duì)密碼進(jìn)行加密
userinfo.password = bcrypt.hashSync(userinfo.password, 10);
 
// 登錄用戶的處理函數(shù)，判斷密碼是否正確
const compareResult = bcrypt.compareSync(userinfo.password, results[0].password);
if (!compareResult) return res.cc('登陸失??！');

// 1. 導(dǎo)入定義驗(yàn)證規(guī)則的包
const joi = require('joi')
// string() 值必須是字符串
// alphanum() 值只能包含a-zA-Z的字符串
// min(1).max(10) 最大長度， 最小長度
// required() 值是必填項(xiàng)
// pattern() 值必須符合正則表達(dá)式
 
// 2. 定義用戶名和密碼的驗(yàn)證規(guī)則
const username = joi.string().alphanum().min(1).max(10).required()
const password = joi.string().pattern(/^[\S]{6,12}/).required()
 
 
// 3. 對(duì)外共享定義驗(yàn)證注冊(cè)和登錄表單數(shù)據(jù)的規(guī)則對(duì)象
exports.reg_login_schema = {
    body: {
        username,
        password
    }
}
 

const express = require('express');
const router = express.Router();
 
// 導(dǎo)入用戶路由處理函數(shù)對(duì)應(yīng)的模塊
const user_handler = require('../router_handler/user')
 
// 1.導(dǎo)入驗(yàn)證數(shù)據(jù)的中間件
const expressJoi = require('@escook/express-joi')
// 2.導(dǎo)入需要驗(yàn)證的規(guī)則對(duì)象
const { reg_login_schema } = require('../schema/user')
 
// 注冊(cè)新用戶        3.校驗(yàn)用戶名和密碼是否合法
router.post('/reg', expressJoi(reg_login_schema),user_handler.reg);
// 登錄
router.post('/login', expressJoi(reg_login_schema),user_handler.login);
 
module.exports = router;

// 1. 導(dǎo)入 joi 模塊
const joi = require('joi')
 
// 導(dǎo)入并注冊(cè)路由模塊
const userRouter = require('./router/user')
app.use('/api',userRouter)
 
//2.定義錯(cuò)誤級(jí)別的中間件
app.use((err, reg, res, next) => {
    // 注意 此處一定要加return 終止 不然會(huì)連續(xù)調(diào)用兩次res.send()程序，會(huì)報(bào)錯(cuò)
    if(err instanceof joi.ValidationError) return res.cc(err); 
    // 未知的錯(cuò)誤
    res.cc(err);
})

// 注冊(cè)用戶的處理函數(shù)
exports.reg = (req, res) => {
    // 1.獲取客戶端提交到服務(wù)器的用戶表單信息
    const userinfo = req.body;
    // 2.對(duì)表單中的數(shù)據(jù)進(jìn)行合法性的校驗(yàn)
    if (!userinfo.username || !userinfo.password) {
        // return res.send({ status: 1, message: '用戶名或者密碼不合法！' });
        return res.cc('用戶名或者密碼不合法！');
    }
 
    // 3.定義sql語句，查詢用戶名是否被占用
    const sqlStr = 'select * from ev_users where username=?';
    db.query(sqlStr, userinfo.username, (err, results) => {
        // 3.1 執(zhí)行sql語句失敗
        if (err) return res.cc(err);
        // 3.2 判斷用戶名是否被占用
        if (results.length > 0) {
            return res.cc('用戶名已存在，請(qǐng)更換！');
        }
        // 3.3 用戶名可用
        // 調(diào)用bcrypt.hashSync() 對(duì)密碼進(jìn)行加密
        userinfo.password = bcrypt.hashSync(userinfo.password, 10);
 
        // 4. 定義插入新用戶的sql語句
        const sql = 'insert into ev_users set ?';
        // 4.1 調(diào)用db.query()執(zhí)行sql語句
        db.query(sql, { username: userinfo.username, password: userinfo.password }, (err, results) => {
            // 4.2 判斷sql語句是否執(zhí)行成功
            if (err) return res.cc(err);
            // if (err) return res.send({ status: 1, message: err.message });
            // 4.3 判斷影響行數(shù)是否為1
            if (results.affectedRows !== 1) return res.cc('用戶注冊(cè)失敗，請(qǐng)稍后再試');
            // 5.注冊(cè)用戶成功
            res.send({ status: 0, message: '注冊(cè)成功' });
        });
    });
};

// 這是一個(gè)全局的配置文件
module.exports = {
    // 加密和解密token的密鑰
    jwtSecretKey: 'lemon likes web',
    // token的有效期
    expiresIn: '10h',
};

// 一定要在路由之前配置解析token的中間件
const expressJWT = require('express-jwt');
const config = require('./config');
 
app.use(expressJWT({ secret: config.jwtSecretKey }).unless({ path: [/^\/api/] }));
 
// 1.3 導(dǎo)入并使用用戶router模塊
const userRouter = require('./router/user');

// 1. 導(dǎo)入生成token的包
const jwt = require('jsonwebtoken');
 
// 2. 登錄用戶的處理函數(shù)
exports.login = (req, res) => {
    // 1. 接收表單數(shù)據(jù)
    const userinfo = req.body;
    // 2. 定義sql語句
    const sql = 'select * from ev_users where username=?';
    // 3. 執(zhí)行sql語句，根據(jù)用戶名查詢用戶信息
    db.query(sql, userinfo.username, (err, results) => {
        // 3.1 執(zhí)行sql語句失敗
        if (err) return res.cc(err);
        console.log(results.length);
        // 3.2 執(zhí)行sql語句成功，但是獲取到的數(shù)據(jù)條數(shù)不等于1,則表示沒有該數(shù)據(jù)
        if (results.length !== 1) return res.cc('登錄失??！');
 
        // 4. 判斷密碼是否正確
        const compareResult = bcrypt.compareSync(userinfo.password, results[0].password);
        if (!compareResult) return res.cc('登陸失敗！');
 
        // 5. 在服務(wù)器端生成 Token的字符串
        const user = { ...results[0], password: '', user_pic: '' };
        // 6. 對(duì)用戶信息進(jìn)行加密，生成Token字符串
        const tokenStr = jwt.sign(user, config.jwtSecretKey, { expiresIn: config.expiresIn });
        // 7. 調(diào)用res.send()將token響應(yīng)給客戶端
        res.send({
            status: 0,
            message: '登陸成功!',
            token: 'Bearer ' + tokenStr,
        });
    });
};