Admin get admin tweets

.env.example

@@ -0,0 +1,3 @@
+PORT = 
+JWT_SECRET = 
+IMGUR_CLIENTID = 

.eslintrc.js

@@ -0,0 +1,32 @@
+module.exports = {
+  env: {
+    browser: true,
+    es2021: true
+  },
+  extends: [
+    'standard',
+    'plugin:react/recommended'
+  ],
+  overrides: [
+    {
+      env: {
+        node: true
+      },
+      files: [
+        '.eslintrc.{js,cjs}'
+      ],
+      parserOptions: {
+        sourceType: 'script'
+      }
+    }
+  ],
+  parserOptions: {
+    ecmaVersion: 'latest',
+    sourceType: 'module'
+  },
+  plugins: [
+    'react'
+  ],
+  rules: {
+  }
+}

.gitignore

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

.vscode/settings.json

@@ -0,0 +1,8 @@
+{
+  "cSpell.words": [
+    "blongs",
+    "Followship",
+    "Followships",
+    "imgur"
+  ]
+}

Procfile

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

_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,24 @@
+if (process.env.NODE_ENV !== 'production') {
+  require('dotenv').config()
+}
+
 const express = require('express')
-const helpers = require('./_helpers');
+const helpers = require('./_helpers')
+const routes = require('./routes')
 
 const app = express()
-const port = 3000
+const port = process.env.PORT || 3000
+
+app.use(express.urlencoded({ extended: true }))
+app.use(express.json())
+
+app.use((req, res, next) => {
+  res.locals.user = helpers.getUser(req)
+  next()
+})
 
-// use helpers.getUser(req) to replace req.user
-function authenticated(req, res, next){
-  // passport.authenticate('jwt', { ses...
-};
+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

@@ -15,11 +15,7 @@
     "logging": false
   },
   "production": {
-    "username": "root",
-    "password": null,
-    "database": "database_production",
-    "host": "127.0.0.1",
-    "dialect": "mysql"
+    "use_env_variable": "MYSQL_DATABASE_URL"
   },
   "travis": {
     "username": "travis",

config/passport.js

@@ -1,5 +1,27 @@
 const passport = require('passport')
+const passportJWT = require('passport-jwt')
+const JWTStrategy = passportJWT.Strategy
+const ExtractJWT = passportJWT.ExtractJwt
+const { User, Tweet } = require('../models')
 
+const jwtOptions = {
+  jwtFromRequest: ExtractJWT.fromAuthHeaderAsBearerToken(),
+  secretOrKey: process.env.JWT_SECRET
+}
+passport.use(new JWTStrategy(jwtOptions, async (jwtPayload, cb) => {
+  try {
+    const user = await User.findByPk(jwtPayload.id, {
+      include: [
+        Tweet,
+        { model: Tweet, as: 'LikeTweets' },
+        { model: User, as: 'Followings' },
+        { model: User, as: 'Followers' }
+      ]
+    })
+    cb(null, user)
+  } catch (err) {
+    cb(err)
+  }
+}))
 
-
-module.exports = passport
+module.exports = passport

controllers/admin-controller.js

@@ -0,0 +1,18 @@
+const adminServices = require('../services/admin-services')
+
+const adminController = {
+  signIn: (req, res, next) => {
+    adminServices.signIn(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  getUsers: (req, res, next) => {
+    adminServices.getUsers(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  getAdminTweets: (req, res, next) => {
+    adminServices.getAdminTweets(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  deleteTweet: (req, res, next) => {
+    adminServices.deleteTweet(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  }
+}
+
+module.exports = adminController

controllers/followship-controller.js

@@ -0,0 +1,12 @@
+const followshipServices = require('../services/followship-services')
+
+const followshipController = {
+  addFollowing: (req, res, next) => {
+    followshipServices.addFollowing(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  removeFollowing: (req, res, next) => {
+    followshipServices.removeFollowing(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  }
+}
+
+module.exports = followshipController

controllers/reply-controller.js

@@ -0,0 +1,12 @@
+const replyServices = require('../services/reply-services')
+
+const replyController = {
+  getReplies: (req, res, next) => {
+    replyServices.getReplies(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  postReply: (req, res, next) => {
+    replyServices.postReply(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  }
+}
+
+module.exports = replyController

controllers/tweet-controller.js

@@ -0,0 +1,21 @@
+const tweetServices = require('../services/tweet-services')
+
+const tweetController = {
+  getTweets: (req, res, next) => {
+    tweetServices.getTweets(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  getTweet: (req, res, next) => {
+    tweetServices.getTweet(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  postTweet: (req, res, next) => {
+    tweetServices.postTweet(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  addLike: (req, res, next) => {
+    tweetServices.addLike(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  removeLike: (req, res, next) => {
+    tweetServices.removeLike(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  }
+}
+
+module.exports = tweetController

controllers/user-controller.js

@@ -0,0 +1,24 @@
+const userServices = require('../services/user-services')
+
+const userController = {
+  signIn: (req, res, next) => {
+    userServices.signIn(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  signUp: (req, res, next) => {
+    userServices.signUp(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  getUser: (req, res, next) => {
+    userServices.getUser(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  putUser: (req, res, next) => {
+    userServices.putUser(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  getUserTweets: (req, res, next) => {
+    userServices.getUserTweets(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  },
+  getUserRepliedTweets: (req, res, next) => {
+    userServices.getUserRepliedTweets(req, (err, data) => err ? next(err) : res.status(200).json(data))
+  }
+}
+
+module.exports = userController

helpers/day-helpers.js

@@ -0,0 +1,7 @@
+const dayjs = require('dayjs')
+const relativeTime = require('dayjs/plugin/relativeTime')
+dayjs.extend(relativeTime)
+
+module.exports = {
+  relativeTimeFormat: createdAt => dayjs(createdAt).fromNow()
+}

helpers/file-helpers.js

@@ -0,0 +1,20 @@
+const imgur = require('imgur')
+imgur.setClientId(process.env.IMGUR_CLIENTID)
+
+const imgurFileHandler = async (files) => {
+  const uploadPromises = []
+  const images = [files?.avatar?.[0]?.path, files?.banner?.[0]?.path]
+  try {
+    for (const file of images) {
+      if (!file) return uploadPromises.push(null)
+      const img = await imgur.uploadFile(file)
+      uploadPromises.push(img?.link || null)
+    }
+  } catch (err) {
+    console.log(err.message)
+  }
+  return uploadPromises
+}
+module.exports = {
+  imgurFileHandler
+}

middleware/auth.js

@@ -0,0 +1,31 @@
+const passport = require('../config/passport')
+const helpers = require('../_helpers')
+
+const authenticated = (req, res, next) => { // 用jwt策略驗證
+  passport.authenticate('jwt', { session: false }, (err, user) => {
+    if (err || !user) return res.status(401).json({ status: 'error', message: '沒登入' })
+    req.user = user // 用cb之後變成req.logIn函式處理所以要自己處理驗證成功時放入req.user
+    next()
+  })(req, res, next)
+}
+
+const authenticatedAdmin = (req, res, next) => {
+  if (helpers.getUser(req) && helpers.getUser(req).role === 'admin') {
+    next()
+  } else {
+    return res.status(403).json({ status: 'error', message: '帳號不存在！' })
+  }
+}
+const authenticatedUser = (req, res, next) => {
+  if (helpers.getUser(req) && helpers.getUser(req).role === 'user') {
+    next()
+  } else {
+    return res.status(403).json({ status: 'error', message: '帳號不存在！' })
+  }
+}
+
+module.exports = {
+  authenticated,
+  authenticatedAdmin,
+  authenticatedUser
+}

middleware/error-handler.js

@@ -0,0 +1,18 @@
+const apiErrorHandler = (err, req, res, next) => {
+  if (err instanceof Error) {
+    res.status(err.status || 500).json({
+      status: 'error',
+      message: `${err.name}: ${err.message}`
+    })
+  } else {
+    res.status(500).json({
+      status: 'error',
+      message: `${err}`
+    })
+  }
+  next(err)
+}
+
+module.exports = {
+  apiErrorHandler
+}

middleware/multer.js

@@ -0,0 +1,4 @@
+const multer = require('multer')
+// 使用者上傳的圖片站存到temp資料夾中
+const upload = multer({ dest: 'temp/' })
+module.exports = upload

migrations/20190115071418-create-followship.js

@@ -1,4 +1,4 @@
-'use strict';
+'use strict'
 module.exports = {
   up: (queryInterface, Sequelize) => {
     return queryInterface.createTable('Followships', {
@@ -22,9 +22,9 @@ module.exports = {
         allowNull: false,
         type: Sequelize.DATE
       }
-    });
+    })
   },
   down: (queryInterface, Sequelize) => {
-    return queryInterface.dropTable('Followships');
+    return queryInterface.dropTable('Followships')
   }
-};
+}

migrations/20190115071419-create-like.js

@@ -1,4 +1,4 @@
-'use strict';
+'use strict'
 module.exports = {
   up: (queryInterface, Sequelize) => {
     return queryInterface.createTable('Likes', {
@@ -22,9 +22,9 @@ module.exports = {
         allowNull: false,
         type: Sequelize.DATE
       }
-    });
+    })
   },
   down: (queryInterface, Sequelize) => {
-    return queryInterface.dropTable('Likes');
+    return queryInterface.dropTable('Likes')
   }
-};
+}

migrations/20190115071420-create-reply.js

@@ -1,4 +1,4 @@
-'use strict';
+'use strict'
 module.exports = {
   up: (queryInterface, Sequelize) => {
     return queryInterface.createTable('Replies', {
@@ -25,9 +25,9 @@ module.exports = {
         allowNull: false,
         type: Sequelize.DATE
       }
-    });
+    })
   },
   down: (queryInterface, Sequelize) => {
-    return queryInterface.dropTable('Replies');
+    return queryInterface.dropTable('Replies')
   }
-};
+}