11.159

app.js

@@ -1,30 +1,87 @@
-const path =  require('path');
+const path = require('path');
 
 const express = require('express');
 const bodyParser = require('body-parser');
 
-const adminData = require('./routes/admin');
+const adminRoutes = require('./routes/admin');
 const shopRoutes = require('./routes/shop');
 const rootDir = require('./util/path');
+const errorController = require('./controller/error');
+const sequelize = require('./util/database');
+
+// requiring both the models
+const Product = require('./model/product');
+const User = require('./model/user');
 
 const app = express();
 
-// no need to register the engin, as exoress auto register it
 app.set('view engine', 'ejs');
 app.set('views', 'views');
 
-app.use(bodyParser.urlencoded({extended : true}));
+app.use(bodyParser.urlencoded({ extended: true }));
 app.use(express.static(path.join(rootDir, 'public')));
 
-app.use('/admin',adminData.routes);
+// registering the new middleware, because we want to store that user in our request so that we can use it from anywhere in our app 
+app.use((req, res, next) => {
+  // now we want to reachout to our database and retrive the user 
+  // with the help of
+  // User.findByPk(1);
+
+  // IMPORTANT:
+  // you might think that will this ever return a user if are craeting down in sync() method
+  // app only registered the middleware function. so for incoming request, it will then execute this middleware function
+  // npm start will first run sequelize.sync() and then user ill get registed if it not there, then server runs
+  // once the server start running, request will be made and this function will get executed 
+
+  User.findByPk(1)
+  .then((user) => {
+    // we want to storethe user in request
+    req.user = user;
+    // we can do that, we are just adding the user field to "req" object
+    // we just have to amke sure, we dont overwrite the exisiting user  
+    // "req.user = user;" here user is undefined by default, so now we are storing user which we retrived from the database
+    // user which are reterving is not just a JS object with values stored in db and .Its a sequelize object with values stored in the database and with all the utility methods sequelize added like destroy. 
+    // thus, we are storing sequelize object in request object, not just JS object
+    // hence whenver we user now, we can operate sequelize methods on it.
+
+    // we need to call "next()" so taht we can continue with the next step if we get our user and store it.
+    next();
+  })
+  .catch(err => console.log(err));
+}); 
+
+app.use('/admin', adminRoutes);
 app.use(shopRoutes);
 
-app.use((req, res, next) => {
-  res.status(404);
-  res.setHeader('Content-type','text/html');
-  // passing the argument to templating engine doesnt change, it remains the same
-  // "path: 'Error'" we passed becasue ejs engin will check "path" argument in naviagation bar logic of template. if we will not provide, we will get an error
-  res.render('404', {pageTitle: "404", path: 'Error'});
-});
-
-app.listen(3000);
+app.use(errorController.get404);
+
+Product.belongsTo(User, {constraints: true, onDelete: 'CASCADE'});
+User.hasMany(Product);
+
+// sequelize.sync({force: true})
+sequelize.sync()
+.then(result => {
+  // craeting a dummy user, which is logged in as sooon as server starts.
+  return User.findByPk(1)
+})
+.then( user => {
+  if(!user) {
+    // here are passing promise
+    return User.create({name: 'max', email: 'test@t.com'});
+  }
+  // but here only object will be returned.
+  // return user;
+  // we should always return the same so that next "then()" can be executed
+  // so, returning user promise
+  // return Promise.resolve(user);
+  // but no need of that as whatever is returned from "then()" is wrapped inside promise itself. hence
+  return user;
+})
+.then(user => {
+  console.log(user);
+  // hence, user is registered successfully. and we can start the server
+  app.listen(3000);  
+})
+.catch(err => {
+  console.log('err', err);
+});

controller/admin.js

@@ -0,0 +1,99 @@
+const Product = require("../model/product");
+
+exports.getAddProduct = (req, res, next) => {
+  res.render("admin/edit-product", {
+    path: "/admin/add-product",
+    pageTitle: "Add Products",
+    editing: false
+  });
+};
+
+exports.postAddProduct = (req, res, next) => {
+  const title = req.body.title;
+  const imageUrl = req.body.imageUrl;
+  const description = req.body.description;
+  const price = req.body.price;
+
+  Product.create({
+    title: title,
+    imageUrl: imageUrl,
+    price: price,
+    description: description
+  })
+  .then(result => {
+    // console.log(result);
+    console.log('product saved ');
+    res.redirect('/admin/products');
+  })
+  .catch(err => {
+    console.log(err);
+  });
+
+};
+
+exports.getEditProduct = (req, res, next) => {
+  const editMode = req.query.edit
+  if(!editMode) {
+    res.redirect('/');
+  }
+  const productID = req.params.productID;
+
+  Product.findByPk(productID)
+  .then(product => {
+    res.render("admin/edit-product", {
+      path: "/admin/edit-product",
+      pageTitle: "Edit Products",
+      editing: editMode,
+      product: product
+    });
+  })
+  .catch(err => console.log(err));
+};
+
+exports.postEditProduct = (req, res, next) => {
+  const productID = req.body.productID;
+  const updatedTitle = req.body.title;
+  const updatedImageUrl = req.body.imageUrl;
+  const updatedPrice = req.body.price;
+  const upadatedDesciption = req.body.description;
+
+  Product.findByPk(productID)
+  .then(product => {
+    product.title = updatedTitle;
+    product.imageUrl = updatedImageUrl;
+    product.price = updatedPrice;
+    product.description = upadatedDesciption;
+
+    product.save()
+  })
+  .then(() => {
+    res.redirect('/admin/products');  
+  })
+  .catch(err => console.log(err));
+};
+
+exports.postDeleteProduct = (req, res, next) => {
+  const productID = req.body.productID;
+  Product.findByPk(productID)
+  .then(product => {
+    product.destroy()
+  })
+  .then(() => {
+    res.redirect('/admin/products');
+  })
+  .catch(err => console.log(err));
+};
+
+exports.getProducts = (req, res, next) => {
+  Product.findAll()
+  .then(products => {
+    res.render("admin/products", {
+      path: "/admin/products",
+      pageTitle: "Admin Add Products",
+      prods: products,
+    });
+  })
+  .catch(err => {
+    console.log(err);
+  });
+};

controller/error.js

@@ -0,0 +1,5 @@
+exports.get404 = (req, res, next) => {
+  res.status(404);
+  res.setHeader('Content-type', 'text/html');
+  res.render('404', { pageTitle: "404", path: 'Error' });
+};

controller/shop.js

@@ -0,0 +1,108 @@
+const Product = require('../model/product');
+const Cart = require('../model/cart');
+
+exports.getProduct = (req, res, next) => {
+  Product.findAll()
+  .then(products => {
+    res.render("shop/product-list", {
+      pageTitle: "Shop Products",
+      prods: products,
+      path: "/products"
+    });
+  })
+  .catch(err => console.log(err));
+};
+
+exports.getDetails = (req, res, next) => {
+  const productID = req.params.productId;
+
+  // Product.findByPk(productID)
+  // .then(product => {
+  //   console.log(product);
+  //   res.render(
+  //     'shop/product-detail',
+  //     { pageTitle: product.title,
+  //       product: product, 
+  //       path: '/products' 
+  //     }
+  //   );
+  // })
+  // .catch(err => console.log(err));
+
+  // or 
+
+  Product.findAll({where : 
+    {id: productID}
+  })
+  .then(product => {
+    res.render(
+        'shop/product-detail',
+        { 
+          pageTitle: product[0].title,
+          product: product[0], 
+          path: '/products' 
+        }
+      );
+  })
+  .catch(err => console.log(err));
+};
+
+exports.getCart = (req, res, next) => {
+  Cart.getCart(cart => {
+    Product.fetchAll(products => {
+      const cartProducts = [];
+      for(product of products) {
+        const CartproductData = cart.products.find(prod => prod.id === product.id)
+        if(CartproductData) {
+          cartProducts.push({productData: product, qty: CartproductData.qty});
+        }
+      }
+      res.render('shop/cart', {
+        pageTitle: 'Cart',
+        path: '/cart',
+        products: cartProducts
+      });
+    });     
+  }); 
+};
+
+exports.postCart = (req, res, next) => {
+  const productID = req.body.productID
+  console.log(productID);
+  Product.findById(productID, product => {
+    Cart.addProduct(productID, product.price);
+  })
+  res.redirect('/');
+}
+
+exports.postCartDeleteProduct = (req, res, next) => {
+  const productID = req.body.productID;
+  Product.findById(productID, product => {
+    Cart.deleteProduct(productID, product.price);
+    res.redirect('/cart');
+  });
+};
+
+exports.getOrders = (req, res, next) => {
+  res.render('shop/orders', {
+    pageTitle: 'Orders',
+    path: '/orders'
+  });
+};
+
+exports.getIndex = (req, res, next) => {
+  Product.findAll()
+  .then(products => {
+    res.render("shop/index", {
+      pageTitle: "Shop",
+      prods: products,
+      path: "/"
+    });
+  })
+  .catch(err => console.log(err));
+};
+
+
+
+
+

data/cart.json

@@ -0,0 +1 @@
+{"products":[],"totalPrice":null}

data/products.json

@@ -0,0 +1 @@
+[{"id":"0.21217683817981658","title":"book","imageUrl":"   data:image/jpeg;base64,/9j/4AAQSkZJRgABAQAAAQABAAD/2wCEAAkGBw8QDxIPDxAQEA8PDQ0PDw8PDw8PEBAPFREWFhUVFRUYHSggGBolHRUVITEhJSkrLi4uFx8zODMtNygtLisBCgoKDg0OGhAQGC8iHSUtLSsrLS0rLS0rMC4rLTAtLS0rLSstLS0tLS0rLS0tLzUtLS0tLSstLS0tLS0tLS0rK//AABEIALcBEwMBIgACEQEDEQH/xAAbAAACAgMBAAAAAAAAAAAAAAADBAACAQUGB//EAEkQAAIBAgIFBgoGCAYBBQAAAAECAAMRBCEFEjFBUQYTYXGBkQciMlKSobHB0fBCVHKT0uEWFyNDYoKj8RREU2Oy4lUVM0Vzg//EABkBAQEBAQEBAAAAAAAAAAAAAAABAgMEBf/EACgRAQACAQQBBAIBBQAAAAAAAAABAhEDEyFREjFBUmEUkQQiMkKBof/aAAwDAQACEQMRAD8A8vUQirIohVWBFWECyKsKqwMKsIqyyrCKsCqrCqksqQirAqqy4WXVYRUgUCS4SEVIQJAEElgkKElwkAISZCQ4SWCQF9SZ1IxqSakBbUk1IzqSakBXUmCkZ1JgpAVKShSNlJQpAUKShWNlIMpAUKyjLGmSDZYCrJBssaZYNlgKssEyxplg2WAqywTLGmWCZYC+rJCFZmBFWEVZFWFVYEVYVVmVWFVYGFWFVZlVhVWBhVhVSWRIVVgVVIRUl1SEVIFFSXCQqpCKkAQSXFOGCS4SAAU5YJGAksEgLakzqRnm5nm4CupMaka5uTm4ChSVKRwpKlICRpyhSOlINkgJMkoyRxkg2SAmywTJHGSCZICbLBsscZIFkgKMsEyxtlgmWAoywTLGmWCZYC1pIUrJAirCqswohkWBlFhVWRVhkWBFWGRZEWGVYGFWGVZlVhkSBVUhlSWVIZUgUVIRUnUaD0ErUi9UZ1B4o4Lxmv0loh6LcU3N8YyNWqQgpwqpCBIAAksKcOElwk","description":"1","price":"11"}]

model/cart.js

@@ -0,0 +1,72 @@
+const fs = require('fs');
+const path = require('path');
+
+const rootDir = require('../util/path');
+
+const p = path.join(rootDir, 'data', 'cart.json');
+
+module.exports = class Cart {
+  static addProduct(id, productPrice) {
+    // fetch the previous product
+    fs.readFile(p, (err, fileContent) => {
+      let cart = { products: [], totalPrice: 0 };
+      if (!err) {
+        cart = JSON.parse(fileContent);
+      }
+      const exisitingProductIndex = cart.products.findIndex(prod => prod.id === id);
+      const exisitingProduct = cart.products[exisitingProductIndex];
+      let updatedProduct;
+
+      // add new product / incraese the quantity
+      if (exisitingProduct) {
+        updatedProduct = { ...exisitingProduct };
+        updatedProduct.qty = updatedProduct.qty + 1;
+        cart.products = [...cart.products];
+        cart.products[exisitingProductIndex] = updatedProduct;
+      } else {
+        updatedProduct = { id: id, qty: 1 };
+        // updating the cart after adding new product to the cart
+        cart.products = [...cart.products, updatedProduct];
+      }
+      cart.totalPrice = cart.totalPrice + +productPrice;
+      fs.writeFile(p, JSON.stringify(cart), err => {
+        console.log(err);
+      });
+    });
+  }
+
+  static deleteProduct(id, productPrice) {
+    fs.readFile(p, (err, fileContent) => {
+      if (err) {
+        return;
+      }
+      const updatedProduct = { ...JSON.parse(fileContent) };
+      const product = updatedProduct.products.find(prods => prods.id === id);
+      // if we delete a product from admin page and that product is not inn the cart, then it will give us error.
+      // SOLUTION:- to delete, we first need to check if the given product is in cart, if it is not there then we simply need to return . we dont want to try to edit it as it is not there.
+      if(!product) {
+        return;
+      }
+      const productQty = product.qty;
+      updatedProduct.products = updatedProduct.products.filter(prods => prods.id !== id);
+      updatedProduct.totalPrice = updatedProduct - (productPrice * productQty);
+
+      fs.writeFile(p, JSON.stringify(updatedProduct), (err) => {
+        console.log(err);
+      });
+    });
+  }
+
+  static getCart(cb) {
+    fs.readFile(p, (err, fileContent) => {
+      const cart = JSON.parse(fileContent);
+      if(err) {
+        cb(null);
+      } else {
+        cb(cart);
+      }
+    });
+  }
+
+}
+