前後端分離組：eva, 橘皮, Ailsa, Lynn

.env.example

@@ -0,0 +1,3 @@
+JWT_SECRET=
+
+IMGUR_CLIENT_ID=

.eslintignore

@@ -0,0 +1,2 @@
+/node_modules/*
+/tests/*

.eslintrc.yml

@@ -0,0 +1,12 @@
+env:
+  browser: true
+  commonjs: true
+  es2021: true
+extends:
+  - standard
+parserOptions:
+  ecmaVersion: 12
+rules:
+  arrow-parens:
+    - warn
+    - as-needed

.gitignore

@@ -84,4 +84,8 @@ typings/
 .fusebox/
 
 # DynamoDB Local files
-.dynamodb/
+.dynamodb/
+
+# image upload
+temp/
+upload/

Procfile

@@ -0,0 +1 @@
+web: NODE_ENV=production node app.js

README.md

@@ -0,0 +1,64 @@
+# Simple Twitter
+
+## 簡介
+
+本專案作為 AC Simple Twitter 的後端 Web API 專案，提供使用者推文、回覆，對喜歡的推文按愛心，追蹤其他使用者等功能。
+
+前端畫面請參考：https://github.com/ailsayang999/my-simple-twitter
+
+## 環境建置
+
+使用 Ｎode.js 的 express 作為框架； MySQL Workbench 作為資料庫儲存資料；其他相關套件請見 package.json 檔案
+
+## 主要功能
+
+### 前台使用者
+
+使用者註冊登入後，可查看其他使用者的推文、發佈推文、對喜歡的推文按愛心、回覆某一則推文、觀看其他使用者追蹤以及被追蹤名單，還可以瀏覽推薦追蹤名單。
+
+```
+使用者帳號：user1
+使用者email: [email protected]
+使用者密碼：12345678
+```
+
+### 後台管理者
+
+管理者（admin）可以查看平台內所有使用者的暱稱、帳號、推文總數、被按讚次數、被多少人追蹤以及追蹤了多少人，也能瀏覽所有推文、刪除某一則推文。
+```
+管理者帳號：root
+管理者email: [email protected]
+管理者密碼：12345678
+```
+
+## 檔案執行
+
+1. 請先確保 local 端有安裝 Node.js、MySQL Workbench 及 npm。
+
+2. 將本專案下載至本地存放後，在專案內新增 temp 和 upload 資料夾（用以管理暫存圖片使用）， 再將 .env.example  檔案改名成  .env ，並根據檔案中使用到的環境變數名稱填入相應的資料。
+
+3. 在終端機輸入以下指令，一次安裝所有套件
+
+```
+npm install
+```
+4. 確認與 MySQL workbench 資料庫連線
+
+5. 可根據 package.json 中的預設指令執行本檔案
+
+6. 若出現以下訊息，代表可正式運作本專案
+
+```
+Example app listening on port 3000!
+```
+
+7. 若需要使用本專案的種子資料，請依序輸入：
+
+```js
+  // 生成種子資料
+  npx sequelize db:migrate
+  npx sequelize db:seed:all
+```
+
+此種子資料會生成假使用者、假推文、假回覆，以及追蹤和按讚等使用者關聯的假資料
+

_helpers.js

@@ -1,8 +1,7 @@
-
-function getUser(req) {
-  return req.user;
+function getUser (req) {
+  return req.user
 }
 
 module.exports = {
-  getUser,
-};
+  getUser
+}

app.js

@@ -1,15 +1,30 @@
+if (process.env.NODE_ENV !== 'production') {
+  require('dotenv').config()
+}
+const cors = require('cors')
+const path = require('path')
 const express = require('express')
-const helpers = require('./_helpers');
+const bodyParser = require('body-parser')
+const routes = require('./routes')
+const passport = require('./config/passport')
 
 const app = express()
-const port = 3000
 
-// use helpers.getUser(req) to replace req.user
-function authenticated(req, res, next){
-  // passport.authenticate('jwt', { ses...
-};
+app.use(cors())
+
+// bodyparser設定
+app.use(bodyParser.urlencoded({ extended: true }))
+app.use(bodyParser.json())
+// passport 初始化
+app.use(passport.initialize())
+app.use(passport.session())
+
+app.use('/upload', express.static(path.join(__dirname, 'upload')))
+
+const port = process.env.PORT || 3001
+
+app.use(routes)
 
-app.get('/', (req, res) => res.send('Hello World!'))
 app.listen(port, () => console.log(`Example app listening on port ${port}!`))
 
 module.exports = app

config/config.json

@@ -17,9 +17,10 @@
   "production": {
     "username": "root",
     "password": null,
-    "database": "database_production",
     "host": "127.0.0.1",
-    "dialect": "mysql"
+    "dialect": "mysql",
+    "database" : "railway",
+    "use_env_variable": "MYSQL_DATABASE_URL"
   },
   "travis": {
     "username": "travis",

config/passport.js

@@ -1,5 +1,27 @@
 const passport = require('passport')
+const db = require('../models')
+const { User } = db
+const passportJWT = require('passport-jwt')
+const JWTStrategy = passportJWT.Strategy
+const ExtractJWT = passportJWT.ExtractJwt
 
-
-
-module.exports = passport
+const jwtOptions = {
+  jwtFromRequest: ExtractJWT.fromAuthHeaderAsBearerToken(),
+  secretOrKey: process.env.JWT_SECRET || 'Secret'
+}
+passport.use(
+  new JWTStrategy(jwtOptions, (jwtPayload, cb) => {
+    User.findByPk(jwtPayload.id, {
+      include: [
+        { model: User, as: 'Followings' },
+        { model: User, as: 'Followers' }
+      ]
+    })
+      .then(user => {
+        if (!user) return cb(null, false)
+        cb(null, user.toJSON())
+      })
+      .catch(err => cb(err))
+  })
+)
+module.exports = passport

controllers/apis/admin-controller.js

@@ -0,0 +1,152 @@
+const bcrypt = require('bcryptjs')
+const db = require('../../models')
+const { User, Tweet, Like } = db
+const jwt = require('jsonwebtoken')
+const sequelize = require('sequelize')
+
+const adminController = {
+  getUsers: async (req, res, next) => {
+    try {
+      const options = {
+        raw: true,
+        attributes: [
+          'id',
+          'name',
+          'account',
+          'introduction',
+          'avatar',
+          'cover',
+          [
+            sequelize.literal(
+              '(SELECT COUNT(DISTINCT id) FROM Tweets WHERE Tweets.user_id = User.id)'
+            ),
+            'tweetCount'
+          ],
+          [
+            sequelize.literal(
+              '(SELECT COUNT(DISTINCT id) FROM Followships WHERE Followships.following_id = User.id)'
+            ),
+            'followerCount'
+          ],
+          [
+            sequelize.literal(
+              '(SELECT COUNT(DISTINCT id) FROM Followships WHERE Followships.follower_id = User.id)'
+            ),
+            'followingCount'
+          ],
+          [
+            sequelize.literal(
+              '(SELECT COUNT(DISTINCT id) FROM Likes WHERE Likes.user_id = User.id)'
+            ),
+            'likeCount'
+          ]
+        ],
+        order: [[sequelize.col('tweetCount'), 'DESC'], ['createdAt']]
+      }
+      const users = await User.findAll(options)
+
+      users.forEach(user => {
+        if (user.introduction) {
+          user.introduction = user.introduction.substring(0, 50)
+        }
+      })
+
+      res.status(200).json(users)
+    } catch (error) {
+      next(error)
+    }
+  },
+  getTweets: async (req, res, next) => {
+    try {
+      const options = {
+        raw: true,
+        nest: true,
+        attributes: ['id', 'description', 'createdAt'],
+        include: [
+          {
+            model: User,
+            attributes: ['id', 'account', 'name', 'avatar'],
+            as: 'author'
+          }
+        ]
+      }
+      const tweets = await Tweet.findAll(options)
+      tweets.forEach(tweet => {
+        tweet.description = tweet.description.substring(0, 50)
+      })
+      res.status(200).json(tweets)
+    } catch (err) {
+      next(err)
+    }
+  },
+
+  deleteTweet: async (req, res) => {
+    try {
+      const [tweet] = await Promise.all([
+        Tweet.destroy({
+          where: { id: req.params.id },
+          raw: true,
+          nest: true
+        }),
+        Like.destroy({
+          where: { TweetId: req.params.id },
+          raw: true,
+          nest: true
+        })
+      ])
+
+      if (!tweet) {
+        throw new Error(
+          '此貼文不存在，可能是 Parameters 的資料錯誤或已經被刪除'
+        )
+      }
+
+      return res.status(200).json({
+        status: 'success',
+        message: 'Successfully delete tweet.'
+      })
+    } catch (error) {
+      return res.status(500).json({
+        status: 'error',
+        message: error.message
+      })
+    }
+  },
+
+  signIn: async (req, res, next) => {
+    try {
+      const { account, password } = req.body
+      if (!account || !password) {
+        throw new Error('Please enter account and password')
+      }
+
+      const user = await User.findOne({ where: { account } })
+
+      if (!user) throw new Error('User does not exist')
+      if (user.role === 'user') throw new Error('帳號不存在')
+      if (!bcrypt.compareSync(password, user.password)) {
+        throw new Error('Incorrect password')
+      }
+
+      const payload = {
+        id: user.id,
+        account: user.account,
+        role: user.role
+      }
+      const token = jwt.sign(payload, process.env.JWT_SECRET, {
+        expiresIn: '30d'
+      })
+      return res.status(200).json({
+        status: 'success',
+        data: {
+          token,
+          user
+        }
+      })
+    } catch (err) {
+      next(err)
+    }
+  }
+}
+
+module.exports = adminController