R02-Mao

.github/workflows/ci.yml

@@ -1,6 +1,7 @@
 name: Node.js test
 
 on:
+<<<<<<< HEAD
   pull_request_target:
     branches:
       - main
@@ -11,6 +12,14 @@ on:
 #      - '*-test'
 #  pull_request:
 #    branches:
+=======
+  push:
+    branches:
+#      - main
+      - '*-test'
+  pull_request:
+    branches:
+>>>>>>> origin/R01-test
 #      - main
 
 env:
@@ -38,11 +47,15 @@ jobs:
           # mysql user: 'github'                 # Required if "mysql root password" is empty, default is empty. The superuser for the specified database. Can use secrets, too
           # mysql password: 'password'           # Required if "mysql user" exists. The password for the "mysql user"
       - run: mysql --version
+<<<<<<< HEAD
       - run: echo "checkout head ${{ github.event.pull_request.head.sha }}"
       - run: echo "base ${{ github.event.pull_request.base.sha }}"
       - uses: actions/checkout@v4
         with:
           ref: ${{ github.event.pull_request.head.sha }}
+=======
+      - uses: actions/checkout@v3
+>>>>>>> origin/R01-test
       - name: Use Node.js ${{ matrix.node-version }}
         uses: actions/setup-node@v3
         with:

app.js

@@ -1,13 +1,42 @@
-const express = require('express')
-const routes = require('./routes')
+const path = require("path"); // 引入 path 套件
+const express = require("express");
+const handlebars = require("express-handlebars"); // 引入 express-handlebars
+const flash = require("connect-flash");
+const methodOverride = require("method-override");
+const session = require("express-session");
+const passport = require("./config/passport");
+const handlebarsHelpers = require("./helpers/handlebars-helpers"); // 引入 handlebars-helpers
+const { getUser } = require("./helpers/auth-helpers");
+const routes = require("./routes");
 
-const app = express()
-const port = process.env.PORT || 3000
+const app = express();
+const port = process.env.PORT || 3000;
+const SESSION_SECRET = "secret";
+const db = require("./models"); // 暫時新增這行，引入資料庫，檢查完可刪
+// 註冊 Handlebars 樣板引擎，並指定副檔名為 .hbs
+app.engine("hbs", handlebars({ extname: ".hbs", helpers: handlebarsHelpers }));
+// 設定使用 Handlebars 做為樣板引擎
+app.set("view engine", "hbs");
+app.use(express.urlencoded({ extended: true }));
+app.use(
+  session({ secret: SESSION_SECRET, resave: false, saveUninitialized: false })
+);
+app.use(passport.initialize()); // 增加這行，初始化 Passport
+app.use(passport.session()); // 增加這行，啟動 session 功能
+app.use(flash()); // 掛載套件
+app.use(methodOverride("_method"));
+app.use("/upload", express.static(path.join(__dirname, "upload"))); 
+app.use((req, res, next) => {
+  res.locals.success_messages = req.flash("success_messages"); // 設定 success_msg 訊息
+  res.locals.error_messages = req.flash("error_messages"); // 設定 warning_msg 訊息
+  res.locals.user = getUser(req);
+  next();
+});
 
-app.use(routes)
+app.use(routes);
 
 app.listen(port, () => {
-  console.info(`Example app listening on port ${port}!`)
-})
+  console.info(`Example app listening on port ${port}!`);
+});
 
-module.exports = app
+module.exports = app;

config/passport.js

@@ -0,0 +1,47 @@
+const passport = require("passport");
+const LocalStrategy = require("passport-local");
+const bcrypt = require("bcryptjs");
+const db = require("../models");
+const User = db.User;
+// set up Passport strategy
+passport.use(
+  new LocalStrategy(
+    // customize user field
+    {
+      usernameField: "email",
+      passwordField: "password",
+      passReqToCallback: true,
+    },
+    // authenticate user
+    (req, email, password, cb) => {
+      User.findOne({ where: { email } }).then((user) => {
+        if (!user)
+          return cb(
+            null,
+            false,
+            req.flash("error_messages", "帳號或密碼輸入錯誤！")
+          );
+        bcrypt.compare(password, user.password).then((res) => {
+          if (!res)
+            return cb(
+              null,
+              false,
+              req.flash("error_messages", "帳號或密碼輸入錯誤！")
+            );
+          return cb(null, user);
+        });
+      });
+    }
+  )
+);
+// serialize and deserialize user
+passport.serializeUser((user, cb) => {
+  cb(null, user.id);
+});
+passport.deserializeUser((id, cb) => {
+  User.findByPk(id).then((user) => {
+    user = user.toJSON();
+    return cb(null, user);
+  });
+});
+module.exports = passport;

controllers/admin-controller.js

@@ -0,0 +1,132 @@
+const { Restaurant, User, Category } = require("../models");
+const { localFileHandler } = require("../helpers/file-helpers"); // 將 file-helper
+
+const adminController = {
+  getRestaurants: (req, res, next) => {
+    return Restaurant.findAll({
+      raw: true,
+      nest: true,
+      include: [Category],
+    })
+      .then((restaurants) => res.render("admin/restaurants", { restaurants }))
+      .catch((err) => next(err));
+  },
+  createRestaurant: (req, res) => {
+    return Category.findAll({
+      raw: true
+    })
+      .then(categories => res.render('admin/create-restaurant', { categories }))
+      .catch(err => next(err))
+  },
+  postRestaurant: (req, res, next) => {
+    const { name, tel, address, openingHours, description, categoryId } = req.body;
+    if (!name) throw new Error("Restaurant name is required!");
+    const { file } = req; // 把檔案取出來
+    return localFileHandler(file)
+      .then((filePath) =>
+        Restaurant.create({
+          name,
+          tel,
+          address,
+          openingHours,
+          description,
+          image: filePath || null,
+          categoryId
+        })
+      )
+      .then(() => {
+        req.flash("success_messages", "restaurant was successfully created");
+        res.redirect("/admin/restaurants");
+      })
+      .catch((err) => next(err));
+  },
+  getRestaurant: (req, res, next) => {
+    return Restaurant.findByPk(req.params.id, {
+      //去資料庫用 id 找一筆資料
+      raw: true, // 找到以後整理格式再回傳
+      nest: true, 
+      include: [Category]
+    })
+      .then((restaurant) => {
+        if (!restaurant) throw new Error("Restaurant didn't exist!"); //  如果找不到，回傳錯誤訊息，後面不執行
+        res.render("admin/restaurant", { restaurant });
+      })
+      .catch((err) => next(err));
+  },
+  editRestaurant: (req, res, next) => {
+    Promise.all([ 
+      Restaurant.findByPk(req.params.id, { raw: true }),
+      Category.findAll({ raw: true })
+    ])
+
+      .then(([restaurant, categories]) => {
+        if (!restaurant) throw new Error("Restaurant didn't exist!");
+        res.render("admin/edit-restaurant", { restaurant, categories });
+      })
+      .catch((err) => next(err));
+  },
+  putRestaurant: (req, res, next) => {
+    const { name, tel, address, openingHours, description, categoryId } = req.body;
+    if (!name) throw new Error("Restaurant name is required!");
+    const { file } = req;
+
+    return Promise.all([
+      Restaurant.findByPk(req.params.id),
+      localFileHandler(file),
+    ])
+      .then(([restaurant, filePath]) => {
+        if (!restaurant) throw new Error("Restaurant didn't exist!");
+
+        return restaurant.update({
+          name,
+          tel,
+          address,
+          openingHours,
+          description,
+          image: filePath || restaurant.image,
+          categoryId
+        });
+      })
+      .then(() => {
+        req.flash("success_messages", "restaurant was successfully to update");
+        res.redirect("/admin/restaurants");
+      })
+      .catch((err) => next(err));
+  },
+
+  deleteRestaurant: (req, res, next) => {
+    return Restaurant.findByPk(req.params.id)
+      .then((restaurant) => {
+        if (!restaurant) throw new Error("Restaurant didn't exist!");
+        return restaurant.destroy();
+      })
+      .then(() => res.redirect("/admin/restaurants"))
+      .catch((err) => next(err));
+  },
+
+  getUsers: (req, res, next) => {
+    return User.findAll({ raw: true })
+      .then((users) => res.render("admin/users", { users }))
+      .catch((err) => next(err));
+  },
+
+    patchUser: (req, res, next) => {
+      return User.findByPk(req.params.id)
+        .then(user => {
+          if (!user) throw new Error("User didn't exist!")
+          if (user.email === 'root@example.com') {
+            req.flash('error_messages', '禁止變更 root 權限')
+            return res.redirect('back')
+          }
+
+          return user.update({ isAdmin: !user.isAdmin })
+        })
+        .then(() => {
+          req.flash('success_messages', '使用者權限變更成功')
+          res.redirect('/admin/users')
+        })
+        .catch(err => next(err))
+    }
+  }
+
+module.exports = adminController;

controllers/category-controller.js

@@ -0,0 +1,41 @@
+const { Category } = require("../models");
+const categoryController = {
+  getCategories: (req, res, next) => {
+    return Promise.all([
+      Category.findAll({ raw: true }),
+      req.params.id ? Category.findByPk(req.params.id, { raw:true }) : null
+    ])
+      .then(([categories, category]) => res.render("admin/categories", { categories,category }))
+      .catch((err) => next(err));
+  },
+  postCategory: (req, res, next) => {
+    const { name } = req.body
+    if (!name) throw new Error("Category name is required!");
+
+    return Category.create({ name })
+      .then(() => res.redirect("/admin/categories"))
+      .catch((err) => next(err));
+  },
+  putCategory: (req, res, next) => {
+    const { name } = req.body
+    if (!name) throw new Error("Category name is required!");
+
+    return Category.findByPk(req.params.id)
+      .then(category => {
+        if (!category) throw new error("Category doesn't exist!")
+        return category.update({ name })
+      })
+      .then(() => res.redirect("/admin/categories"))
+      .catch((err) => next(err));
+  },
+  deleteCategory: (req, res, next) => {
+    Category.findByPk(req.params.id)
+      .then(category => {
+        if (!category) throw new error("Category doesn't exist!")
+        return category.destroy( )
+      })
+      .then(() => res.redirect("/admin/categories"))
+      .catch((err) => next(err));
+  }
+}  
+module.exports = categoryController;

controllers/restaurant-controller.js

@@ -0,0 +1,59 @@
+const { Restaurant, Category } = require("../models");
+const restaurantController = {
+  getRestaurants: (req, res, next) => {
+    const categoryId = Number(req.query.categoryId) || ""; // 新增這裡，從網址上拿下來的參數是字串，先轉成 Number 再操作
+    return Promise.all([
+      Restaurant.findAll({
+        include: Category,
+        where: {
+          ...(categoryId ? { categoryId } : {}), // 檢查 categoryId 是否為空值
+        },
+        nest: true,
+        raw: true,
+      }),
+      Category.findAll({ raw: true }),
+    ])
+      .then(([restaurants, categories]) => {
+        const data = restaurants.map((r) => ({
+          ...r,
+          description: r.description.substring(0, 50),
+        }));
+        return res.render("restaurants", {
+          restaurants: data,
+          categories,
+          categoryId,
+        });
+      })
+      .catch((err) => next(err)); 
+  },
+  getRestaurant: (req, res, next) => {
+    return Restaurant.findByPk(req.params.id, {
+      include: Category,
+    })
+      .then((restaurant) => {
+        if (!restaurant) throw new Error("This restaurant didn't exist.");
+
+        return restaurant.increment("viewCount");
+      })
+      .then((restaurant) => {
+        return res.render("restaurant", {
+          restaurant: restaurant.toJSON(),
+        });
+      })
+      .catch((err) => next(err));
+  },
+  getDashboard: (req, res, next) => {
+    return Restaurant.findByPk(req.params.id, {
+      include: Category,
+      nest: true,
+      raw: true,
+    })
+      .then((restaurant) => {
+        if (!restaurant) throw new Error("This restaurant didn't exist.");
+
+        return res.render("dashboard", { restaurant });
+      })
+      .catch((err) => next(err));
+  },
+}; 
+module.exports = restaurantController;