server.js

require("dotenv").config();
const path=require('path');
const express = require("express");
const app = express();
const http = require('http')
const cors = require('cors')
const connectDB = require("./db.js");
const morgan = require("morgan");
const bodyParser = require("body-parser");
const multer = require('multer');

//Allow CORS
app.use(cors());


const server = http.createServer(app);

const port=process.env.PORT || 5000;
server.listen(port, () => console.log(`server is running on port ${port}`));

//importing Models
const Book = require('./Models/Book');
const Author = require('./Models/Author');
const Reader = require('./Models/Reader');


//Logging
if (process.env.NODE_ENV === "Development") {
  app.use(morgan("dev"));
}

connectDB();

// parse application/x-www-form-urlencoded
app.use(bodyParser.urlencoded({ extended: false }));
// parse application/json
app.use(bodyParser.json());



// Set Disk Storage
const storage = multer.diskStorage({
  destination: function (req, file, cb) {
  cb(null, 'books')
},
  filename: function (req, file, cb) {
  cb(null, req.query.docID)
}
});

const upload = multer({ storage: storage });


//Handling Upload Request
app.post('/uploadbook', upload.single('book'), (req, res, next) => {
  const file = req.file
  console.log(file);
  if (!file) {
    const error = new Error('Please upload a file')
    error.httpStatusCode = 400
    return next(error)
  }
    res.send(file)
  
});

//Handling Get File Request
app.get('/book',(req,res,next)=>{
  const name = req.query.docID;
  res.download(`./books/${name}`);

});



//Routes

app.post('/addreader', (req, res) => {
//  console.log(req);
  console.log(req.body);
  const email=req.body.email;
  console.log(email);
  const newReader = {
    email: req.body.email,
    GID: req.body.GID,
    name: req.body.name,
  };
  Reader.find({ email }, (err, user) => {
    console.log(err);
    console.log(user);
    console.log(user.length);

    if(user.length > 0){
      console.log("user : " , user.length);
      res.send('Already Added')
    }
    else{
      console.log("not");
      Reader.create(newReader)
        .then((res) => console.log(res))
        .catch((err) => console.log(err));

      res.send('success');
    }
  });
});

app.get('/checkauthor', (req, res) => {
  const email = req.query.email;
  Author.find({ email }, (err, user) => {
    console.log(err);
    console.log(user);
    user.length !== 0 ? res.send(user) : res.send(false);
  });
});

app.post('/addauthor', (req, res) => {
  console.log(req.cookies);
  console.log(req.body.name);

  const newAuthor = {
    email: req.body.email,
    GID: req.body.GID,
    Fname: req.body.fname,
    Lname: req.body.lname,
    Mnumber : req.body.mobile,
    Twitter : req.body.twitter,
    City : req.body.city,
    State : req.body.state,
    Country : req.body.country,
    Company : req.body.company,
    Clocation : req.body.location,
    Bio : req.body.AboutYourself,
    Website : req.body.website,
    picUrl: req.body.imgUrl,
    linkedInUrl: req.body.linkedInUrl,
  };
  console.log(newAuthor);

  Author.find({ email: req.body.email }, (err, user) => {
    console.log(err);
    if(user.length > 0){
      Author.updateOne(
        {email : req.body.email},
        {
          $set : {
             ...user, ...newAuthor 
          },
        }
      )
      .then((res)=> console.log(res))
      .catch((err)=> console.log(err));
    }
    else{
      Author.create(newAuthor)
        .then((res) => console.log(res))
        .catch((err) => console.log(err));
    }
    res.send('success');
  });
});

app.get('/profile', (req, res) => {
  const email = req.query.email;
  Author.find({ email })
    .populate('books')
    .exec((err, user) => {
      if (err) {
        console.log(err);
      }
      user.length !== 0 ? res.send(user) : res.send(false);
    });
});


app.get('/home', (req, res) => {
  const genre = req.query.genre;

  Book.find(genre ? { genres: genre , state : "Published"} : {state : "Published"})
    .sort({ date: -1 })
    .populate('author')
    .exec((err, books) => {
      if (err) {
        console.log(err);
      }
      res.send(books);
    });
});

app.get('/pendingrequest', (req, res) => {

  Book.find( {state : "Pending"})
    .sort({ date: -1 })
    .populate('author')
    .exec((err, books) => {
      if (err) {
        console.log(err);
      }
      res.send(books);
    });
});

app.post('/startwriting', async (req, res) => {
  const email = req.query.email;

  let bookId;
  let authorId = req.body.authorId;
  if (!authorId) {
    await Author.findOne({ email }, (err, user) => {
      if (err) console.log(err);
      authorId = user._id;
      console.log(authorId);
    });
  }

  const newBook = {
    author: authorId,
    imageUrl: req.body.imageUrl,
    title: req.body.title,
    description: req.body.description,
    genres: req.body.genres,
    state: "Editing",
    docID : req.body.docID,
    pdfUrl : req.body.pdfurl,
    editor : [req.query.email]
  };

  await Book.create(newBook)
    .then((res) => {
      console.log(res);
      bookId = res._id;
    })
    .catch((err) => console.log(err));

  await Book.findOne({ _id: bookId })
    .populate('author')
    .exec((err, book) => {
      if (err) console.log("Error : ",err);
      console.log(book);
    });

  const updatedAuthor = await Author.update(
    { _id: authorId },
    {
      $push: { books: bookId },
    }
  );
  console.log(updatedAuthor);

  res.send('successfully added book');
});

app.post('/submit', async (req, res) => {
  let docID = req.query.docID;

  Book.updateOne(
    { docID },
    {
      $set: {
        imageUrl: req.body.imageUrl,
        title: req.body.title,
        description: req.body.description,
        genres: req.body.genres,
        pdfUrl: req.body.pdfurl,
        state: "Pending",
      },
    }
  )
    .then((res) => {
      console.log(res);
    })
    .catch((err) => console.log(err));
  res.send('success');
});

app.post('/publish', async (req, res) => {
  let docID = req.query.docID;

  Book.updateOne(
    { docID },
    {
      $set: {
        state: "Published",
      },
    }
  )
    .then((res) => {
      console.log(res);
    })
    .catch((err) => console.log(err));
  res.send('success');
});

app.post('/addchapter', async (req, res) => {
  let docID = req.query.docID;

  Book.updateOne(
    { docID },
    {
      $push: {
        chapters : req.body.cname
      },
    }
  )
    .then((res) => {
      console.log(res);
    })
    .catch((err) => console.log(err));
  res.send('success');
});


app.post('/addeditor', async (req, res) => {
  let docID = req.query.docID;

  Book.updateOne(
    { docID },
    {
      $push: {
        editor : req.body.email
      },
    }
  )
    .then((res) => {
      console.log(res);
    })
    .catch((err) => console.log(err));
  res.send('success');
});



app.post('/handlelike', async (req, res) => {
  let updatedBook;

  const bookId = req.query._id;
  const authorId = req.body.authorId;
  const liked = req.body.liked;
  console.log(bookId);

  if (liked && authorId) {
    updatedBook = await Book.updateOne(
      { _id: BookId },
      { $push: { 'likes.likers': authorId } }
    );
    console.log(updatedBook);
  } else {
    updatedBook = await Book.updateOne(
      { _id: req.query._id },
      { $pull: { 'likes.likers': authorId } }
    );
    console.log(updatedBook);
  }

  res.send('success');
});

app.post('/addcomment', (req, res) => {
  Book.updateOne(
    { _id: req.body.BookId },
    {
      $push: {
        comments: {
          commentBy: req.body.userId,
          comment: req.body.comment,
          Gname: req.body.Gname,
          GID: req.body.GID,
        },
      },
    }
  )
    .then((res) => {
      console.log(res);
    })
    .catch((err) => console.log(err));
  res.send('success');
});