app.js

const dbConnection = require('./database/dbConnection');
const generateToken = require('./util/generateToken')
//NEED TO ADD RANK TO USERS
//NEED TO ADD DUE DATE AND COMPLETION STATUS TO THE TASKS
const knex = require("knex");
const express = require("express");
const morgan = require("morgan");
const app = express();
const cors = require('cors');


//getPasswordHash, getAll, getAllTasks, getPrivId, createUser, updateTask, postTask, getTaskById, removeTask, getAllTasks, updateUser, removeUser, addUser
//Page imports
const { getPasswordHash, getAll, getSpecificItem, addTask, deleteItem, updateTask } = require("./database/controllers");


//middleware
app.use(morgan("tiny"));
app.use(express.json());
app.use(cors());

//HASHING
const bcrypt = require ('bcryptjs');


  //CREATE (POST)

   // Register
   app.post('/register', async (req, res) => {
    try{
      const { work_email, password, rank, first_name, last_name, role,} = req.body;
      const hashed_password = await bcrypt.hash(password, 12);
      await dbConnection.insert({ work_email: work_email, hashed_password: hashed_password, rank: rank, first_name: first_name, last_name: last_name,  role: role}).from('users');
      res.status(201).json({
        work_email: work_email,
        role:role,
        token:generateToken(work_email)
       });
    } catch(e) {
      console.log(e)
      res.status(500).send('Something Went Wrong');
    }
  });


  // login
  app.post('/users/login', async(req, res) => {

    try{
      const {work_email, password} = req.body;
      user = await dbConnection.select('*').where({work_email: work_email}).from('users')
      if (user.length){
        console.log(user)
        const validPass = await bcrypt.compare(password, user[0].hashed_password);
        if(validPass) {
          res.status(201).json({
            id: user[0].id,
            rank: user[0].rank,
            lastName: user[0].last_name,
            workEmail: user[0].work_email,
            role: user[0].role,
            sponsorID: user[0].sponsor_id,
            token:generateToken(work_email)
           });
        }
        else{
          res.status(404).res.json('Wrong Password')
        }
      }
      else {
        res.status(404).json('User not found')
      }
      }

      catch(e) {
      console.log(e)
      res.status(500).send('Something Went Wrong');
      }
    });

    app.post("/tasks", (req, res) => {
      const u_id = req.body.user_id ? req.body.user_id : '';
      const newTask = req.body.task ? req.body.task : '';
      
      console.log('post log', req.body)
      
      addTask(u_id, newTask)
          .then((data) => 
              res.status(200).json({message: `The task was posted successfully`})
              )
          .catch((err) => 
              res.status(422).json({message: `Failure to post task. ERROR: ${err}`})
          )
  })

  //getting all tasks for an inbound user
  app.get('/tasks/user/:id', function(req, res){
    dbConnection
    .select('*')
    .from('tasks')
    .where({user_id: req.params.id})
    .then(data => res.status(200).json(data))
    .catch(err =>
      res.status(404).json({
          message:
            'The data you are looking for could not be found. Please try again'
      }))
});

//getting the sponsor info for user
app.get('/sponsor/:id', function(req, res){
  dbConnection
  .select('*')
  .where({id: req.params.id})
  .from('users')
  .then(data => res.status(200).json(data))
  .catch(err =>
    res.status(404).json({
        message:
          'The data you are looking for could not be found. Please try again'
    }))
});

//getting all inbounds for one sponsor
app.get('/sponsor/user/:id', function(req, res){
  dbConnection
  .select('*')
  .where({sponsor_id: req.params.id})
  .from('users')
  .then(data => res.status(200).json(data))
  .catch(err =>
    res.status(404).json({
        message:
          'The data you are looking for could not be found. Please try again'
    }))
});

//adding a new task to an inbound as a sponsor
app.post('/sponsor/addtask', function(req, res){
  dbConnection
  .insert({ user_id: req.body.user_id, task: req.body.task, due_date: req.body.due_date, task_status: req.body.task_status }).from('tasks')
      .then((data) => res.status(201).json(data))
      .catch((err) => {
        // console.error(err);
        res.status(404).json({ message: "Something is wrong."})
    })
  });

  //adding/changing an inbound's sponsor id
  app.patch('/admin/sponsorid', function(req, res){
    dbConnection
    .update({sponsor_id: req.body.sponsor_id})
    .where({id: req.body.id})
    .from('users')
    .then((data) => res.status(201).json(data))
    .catch((err) => {
          // console.error(err);
          res.status(404).json({ message: "Something is wrong."})
      })
    });


  app.get('/admin/getsponsors', function(req, res){
    dbConnection
    .select('*')
    .where({role: 'sponsor'})
    .from('users')
    .then(data => res.status(200).json(data))
    .catch((err) => {
          // console.error(err);
          res.status(404).json({ message: "Something is wrong."})
      })
    });

    //getting the sponsor for a selected user in ViewChecklist
    app.get('/users/sponsor/:id', function(req, res){
      dbConnection
      .select('*')
      .where({id: req.params.id})
      .from('users')
      .then(data => res.status(200).json(data))
      .catch((err) => {
            // console.error(err);
            res.status(404).json({ message: "Something is wrong."})
        })
      });




  // READ (GET)

  //Get by specific ID g2g

//   app.get("/:table/:id", (req, res) => {
//     getSpecificItem(req.params.table, req.params.id)
//         .then((data) => res.send(data))
//         .catch((err) => 
//             res.status(404).json({message: `${req.params.table} does not exist.`})
//         )
// })

  // //getting specific user by ID
  // app.get('/posts/users/:user_id', function(req, res) {
  //   dbConnection
  //     getAllTasks(req.params.user_id)
  //     .then(data => res.status(200).json(data))
  //     .catch(err =>
  //       res.status(404).json({
  //         message:
  //           'The data you are looking for could not be found. Please try again'
  //       })
  //     );
  // });

  //   //get by id 
  // app.get('/:table/:id', function(req, res) {
  //   dbConnection
  //     .select('*')
  //     .from(req.params.table)
  //     .where({id: req.params.id})
  //     .then(data => res.status(200).json(data))
  //     .catch(err =>
  //       res.status(404).json({
  //         message:
  //           'The data you are looking for could not be found. Please try again'
  //       })
  //     );
  // });

  //UPDATE (PUT, PATCH)
  app.patch('/tasks/:id', function(req, res) {
    let {user_id, task} = req.body;
    // dbConnection
  // ('tasks').where({ id: req.params.id}).update({user_id: req.body.user_id, task: req.body.task})
  console.log(req.body)
  updateTask(req.params.id, req.params.body)
    .then((data) => res.status(200).json(data))
      .catch((err) => {
        console.error(err);
        res.status(404).json({ message: "Something is wrong." })
    })
  });
  


  //DELETE by ID g2g
  app.delete("/:table/:id", (req, res) => {
    deleteItem(req.params.table, req.params.id)
    .then((data) => 
        res.status(200).json({message: `Deleted successfully`})
    )
    .catch((err) =>
        res.status(404).json({message: `${req.params.table} does not exist.`})
        
    )   
})

  // LIST (GET) g2g

  app.get("/:table", (req, res) => {
    console.log('asdfasdf')
    getAll(req.params.table)
        .then((data) => res.send(data))
        .catch((err) =>
            // res.status(404).json({ message: `${req.params.table} does not exist.` })
            res.status(404).json({message: `Failure to post data. ERROR: ${err}`})       
            );
  });

module.exports = app;