Finish mongoose CRUD

.gitignore

@@ -0,0 +1,2 @@
+.DS_Store
+node_modules

app.js

@@ -0,0 +1,26 @@
+const express = require('express');
+const bodyParser = require('body-parser');
+const mongoose = require('mongoose');
+
+const url = 'mongodb://localhost:27017/library2';
+
+const booksRoute = require('./routes/books');
+const customersRoute = require('./routes/customers');
+const transactionsRoute = require('./routes/transactions');
+
+const app = express();
+
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: false }));
+
+app.use('/api/books', booksRoute);
+app.use('/api/customers', customersRoute);
+app.use('/api/transactions', transactionsRoute);
+
+mongoose.connect(url);
+
+const db = mongoose.connection;
+db.on('error', console.error.bind(console, 'connection error:'));
+db.once('open', function() {
+  app.listen(3000);
+});

controllers/books.js

@@ -0,0 +1,56 @@
+const Book = require('../models/Book');
+
+exports.find = (req, res) => {
+  Book.find((err, books) => {
+    res.send(books);
+  });
+};
+
+exports.create = (req, res) => {
+  const bookOptions = req.body;
+  const book = new Book(bookOptions);
+  book.save((err) => {
+    if (!err) {
+      res.send({ result: 'CREATE_OK' });
+    } else {
+      console.log(err);
+      res.status(500).send('Error');
+    }
+  });
+};
+
+exports.update = (req, res) => {
+  const isbn = req.params.isbn;
+  const bookOptions = req.body;
+  Book.find({ isbn }, (err, books) => {
+    const book = books[0];
+    book.title = bookOptions.title;
+    book.author = bookOptions.author;
+    book.category = bookOptions.category;
+    book.stock = bookOptions.stock;
+
+    book.save((saveErr) => {
+      if (!saveErr) {
+        res.send({ result: 'UPDATE_OK' });
+      } else {
+        console.log(saveErr);
+        res.status(500).send('Error');
+      }
+    });
+  });
+};
+
+exports.delete = (req, res) => {
+  const isbn = req.params.isbn;
+  Book.find({ isbn }, (err, books) => {
+    const book = books[0];
+    book.remove((saveErr) => {
+      if (!saveErr) {
+        res.send({ result: 'DELETE_OK' });
+      } else {
+        console.log(saveErr);
+        res.status(500).send('Error');
+      }
+    });
+  });
+};

controllers/customers.js

@@ -0,0 +1,57 @@
+const Customer = require('../models/Customer');
+
+exports.find = (req, res) => {
+  Customer.find((err, customers) => {
+    res.send(customers);
+  });
+};
+
+exports.create = (req, res) => {
+  const customerOptions = req.body;
+  const customer = new Customer(customerOptions);
+  customer.save((err) => {
+    if (!err) {
+      res.send({ result: 'CREATE_OK' });
+    } else {
+      console.log(err);
+      res.status(500).send('Error');
+    }
+  });
+};
+
+exports.update = (req, res) => {
+  const memberId = req.params.memberId;
+  const customerOptions = req.body;
+  Customer.find({ memberId }, (err, customers) => {
+    const customer = customers[0];
+    customer.memberId = customerOptions.memberId;
+    customer.name = customerOptions.name;
+    customer.zipCode = customerOptions.zipCode;
+    customer.phone = customerOptions.phone;
+    customer.address = customerOptions.address;
+
+    customer.save((saveErr) => {
+      if (!saveErr) {
+        res.send({ result: 'UPDATE_OK' });
+      } else {
+        console.log(saveErr);
+        res.status(500).send('Error');
+      }
+    });
+  });
+};
+
+exports.delete = (req, res) => {
+  const memberId = req.params.memberId;
+  Customer.find({ memberId }, (err, customers) => {
+    const customer = customers[0];
+    customer.remove((saveErr) => {
+      if (!saveErr) {
+        res.send({ result: 'DELETE_OK' });
+      } else {
+        console.log(saveErr);
+        res.status(500).send('Error');
+      }
+    });
+  });
+};

controllers/transactions.js

@@ -0,0 +1,95 @@
+const Transaction = require('../models/Transaction');
+const Customer = require('../models/Customer');
+const Book = require('../models/Book');
+
+exports.find = (req, res) => {
+  Transaction.find()
+  .populate('member books')
+  .exec((err, transactions) => {
+    res.send(transactions);
+  });
+};
+
+exports.create = (req, res) => {
+
+  const isbns = req.body.isbns.split(',');
+
+  Customer.findOne({ memberId: req.body.memberId })
+  .exec((err, customer) => {
+    Book.find({ isbn: { $in: isbns } })
+    .exec((errFindBoos, books) => {
+      const bookIds = books.map((book) => {
+        return book._id;
+      });
+
+      const transactionOptions = {
+        member: customer._id,
+        days: req.body.days,
+        outDate: new Date(req.body.outDate),
+        dueDate: new Date(req.body.dueDate),
+        inDate: new Date(req.body.inDate),
+        fine: req.body.fine,
+        books: bookIds,
+      };
+      const transaction = new Transaction(transactionOptions);
+      transaction.save((err) => {
+        if (!err) {
+          res.send({ result: 'CREATE_OK' });
+        } else {
+          console.log(err);
+          res.status(500).send('Error');
+        }
+      });
+    });
+  });
+};
+
+exports.update = (req, res) => {
+
+  const transactionId = req.params.transactionId;
+  const isbns = req.body.isbns.split(',');
+
+  Customer.findOne({ memberId: req.body.memberId })
+  .exec((err, customer) => {
+    Book.find({ isbn: { $in: isbns } })
+    .exec((errFindBooks, books) => {
+      const bookIds = books.map((book) => {
+        return book._id;
+      });
+
+      Transaction.findOne({ _id: transactionId })
+      .exec((errFindTransaction, transaction) => {
+        transaction.member = customer._id;
+        transaction.days = req.body.days;
+        transaction.outDate = new Date(req.body.outDate);
+        transaction.dueDate = new Date(req.body.dueDate);
+        transaction.inDate = new Date(req.body.inDate);
+        transaction.fine = req.body.fine;
+        transaction.books = bookIds;
+
+        transaction.save((errSave) => {
+          if (!errSave) {
+            res.send({ result: 'UPDATE_OK' });
+          } else {
+            console.log(errSave);
+            res.status(500).send('Error');
+          }
+        });
+      });
+    });
+  });
+};
+
+exports.delete = (req, res) => {
+  const transactionId = req.params.transactionId;
+  Transaction.findOne({ _id: transactionId }, (err, transaction) => {
+    transaction.remove((saveErr) => {
+      if (!saveErr) {
+        res.send({ result: 'DELETE_OK' });
+      } else {
+        console.log(saveErr);
+        res.status(500).send('Error');
+      }
+    });
+  });
+};

models/Book.js

@@ -0,0 +1,13 @@
+const mongoose = require('mongoose');
+
+const bookSchema = mongoose.Schema({
+  isbn: String,
+  title: String,
+  author: String,
+  category: String,
+  stock: Number,
+}, { timestamps: true });
+
+const BookModel = mongoose.model('Book', bookSchema);
+
+module.exports = BookModel;

models/Customer.js

@@ -0,0 +1,13 @@
+const mongoose = require('mongoose');
+
+const customerSchema = mongoose.Schema({
+  memberId: String,
+  name: String,
+  zipCode: String,
+  phone: String,
+  address: String,
+}, { timestamps: true });
+
+const CustomerModel = mongoose.model('Customer', customerSchema);
+
+module.exports = CustomerModel;

models/Transaction.js

@@ -0,0 +1,15 @@
+const mongoose = require('mongoose');
+
+const transactionSchema = mongoose.Schema({
+  member: { type: mongoose.Schema.Types.ObjectId, ref: 'Customer' },
+  days: Number,
+  outDate: Date,
+  dueDate: Date,
+  inDate: Date,
+  fine: Number,
+  books: [{ type: mongoose.Schema.Types.ObjectId, ref: 'Book' }],
+}, { timestamps: true });
+
+const TransactionModel = mongoose.model('Transaction', transactionSchema);
+
+module.exports = TransactionModel;

package.json

@@ -0,0 +1,26 @@
+{
+  "name": "mongoose-crud",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "start": "nodemon app.js",
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/yusufhacktiv8/mongoose-crud.git"
+  },
+  "author": "",
+  "license": "ISC",
+  "bugs": {
+    "url": "https://github.com/yusufhacktiv8/mongoose-crud/issues"
+  },
+  "homepage": "https://github.com/yusufhacktiv8/mongoose-crud#readme",
+  "dependencies": {
+    "body-parser": "^1.17.2",
+    "express": "^4.15.3",
+    "mongodb": "^2.2.29",
+    "mongoose": "^4.10.7"
+  }
+}

routes/books.js

@@ -0,0 +1,12 @@
+const express = require('express');
+
+const router = express.Router();
+
+const bookController = require('../controllers/books');
+
+router.get('/', bookController.find);
+router.post('/', bookController.create);
+router.put('/:isbn', bookController.update);
+router.delete('/:isbn', bookController.delete);
+
+module.exports = router;

routes/customers.js

@@ -0,0 +1,12 @@
+const express = require('express');
+
+const router = express.Router();
+
+const customerController = require('../controllers/customers');
+
+router.get('/', customerController.find);
+router.post('/', customerController.create);
+router.put('/:memberId', customerController.update);
+router.delete('/:memberId', customerController.delete);
+
+module.exports = router;

routes/index.js

@@ -0,0 +1,5 @@
+const express = require('express');
+
+const router = express.Router();
+
+module.exports = router;

routes/transactions.js

@@ -0,0 +1,12 @@
+const express = require('express');
+
+const router = express.Router();
+
+const transactionController = require('../controllers/transactions');
+
+router.get('/', transactionController.find);
+router.post('/', transactionController.create);
+router.put('/:transactionId', transactionController.update);
+router.delete('/:transactionId', transactionController.delete);
+
+module.exports = router;