+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 | 1x + + + + + | module.exports = {
+ paymentTemplate: 'd-66a2ce523e89461eb90b499d7cffe10a',
+ accountVerificationTemplate: 'd-e4b6aa6a05744c0689953f70995abf11',
+ proAccountTemplate: 'd-d39047ffe8324992ad23c3b539f7b43d'
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 | 1x + +1x + + + + + + + + + + + | const Sequelize = require('sequelize')
+
+module.exports = new Sequelize(process.env.DATABASE_URL, {
+ dialect: 'mysql',
+ logging: console.log,
+ benchmark: true,
+ pool: {
+ max: 5,
+ min: 0,
+ acquire: 30000,
+ idle: 10000
+ }
+})
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| constant.js | +100% | +1/1 | +100% | +0/0 | +100% | +0/0 | +100% | +1/1 | +|
| dbConnection.js | +100% | +2/2 | +100% | +0/0 | +100% | +0/0 | +100% | +2/2 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 | 1x +1x + + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +1x +1x +1x + + +1x + | const { Model, DataTypes } = require('sequelize')
+const sequelize = require('../dbConnection')
+
+class Articles extends Model {}
+
+Articles.init(
+ {
+ id: {
+ type: DataTypes.INTEGER,
+ unique: true,
+ allowNull: false,
+ primaryKey: true,
+ autoIncrement: true
+ },
+ title: {
+ type: DataTypes.STRING,
+ allowNull: false
+ },
+ content: {
+ type: DataTypes.STRING,
+ allowNull: false
+ },
+ picture: {
+ type: DataTypes.STRING,
+ allowNull: true
+ },
+ createdAt: {
+ type: DataTypes.DATE,
+ defaultValue: DataTypes.NOW,
+ allowNull: false,
+ field: 'created_at'
+ },
+ updatedAt: {
+ type: DataTypes.DATE,
+ defaultValue: DataTypes.NOW,
+ allowNull: false,
+ field: 'updated_at'
+ },
+ publishedAt: {
+ type: DataTypes.DATE,
+ defaultValue: DataTypes.NOW,
+ allowNull: false,
+ field: 'published_at'
+ },
+ authorId: {
+ type: DataTypes.INTEGER,
+ field: 'author_id'
+ }
+ },
+ {
+ sequelize,
+ modelName: 'articles'
+ }
+)
+
+Articles.associate = models => {
+ Articles.belongsTo(models.Users, { as: 'author', foreignKey: 'authorId' })
+ Articles.hasMany(models.Comments, { as: 'comments', foreignKey: 'articleId' })
+}
+
+module.exports = Articles
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 | 1x +1x + + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +1x +1x +1x + + +1x + | const { Model, DataTypes } = require('sequelize')
+const sequelize = require('../dbConnection')
+
+class Comments extends Model {}
+
+Comments.init(
+ {
+ id: {
+ type: DataTypes.INTEGER,
+ unique: true,
+ allowNull: false,
+ primaryKey: true,
+ autoIncrement: true
+ },
+ content: {
+ type: DataTypes.STRING,
+ allowNull: false
+ },
+ authorId: {
+ type: DataTypes.INTEGER,
+ field: 'author_id'
+ },
+ articleId: {
+ type: DataTypes.INTEGER,
+ allowNull: false,
+ field: 'article_id'
+ },
+ createdAt: {
+ type: DataTypes.DATE,
+ defaultValue: DataTypes.NOW,
+ allowNull: false,
+ field: 'created_at'
+ }
+ },
+ {
+ sequelize,
+ timestamps: false,
+ modelName: 'comments'
+ }
+)
+
+Comments.associate = models => {
+ Comments.belongsTo(models.Users, { as: 'author', foreignKey: 'authorId' })
+ Comments.belongsTo(models.Articles, { as: 'article', foreignKey: 'articleId' })
+}
+
+module.exports = Comments
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 | 1x +1x + + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +1x +1x + + + + + +1x + | const { Model, DataTypes } = require('sequelize')
+const sequelize = require('../dbConnection')
+
+class Providers extends Model {}
+
+Providers.init(
+ {
+ id: {
+ type: DataTypes.INTEGER,
+ unique: true,
+ allowNull: false,
+ primaryKey: true,
+ autoIncrement: true
+ },
+ userId: {
+ type: DataTypes.INTEGER,
+ allowNull: false,
+ field: 'user_id'
+ },
+ provider: {
+ type: DataTypes.STRING,
+ allowNull: false
+ },
+ providerUserId: {
+ type: DataTypes.INTEGER,
+ allowNull: false,
+ field: 'provider_user_id'
+ }
+ },
+ {
+ sequelize,
+ timestamps: false,
+ modelName: 'oauth_accounts'
+ }
+)
+
+Providers.associate = models => {
+ Providers.belongsTo(models.Users, {
+ as: 'user',
+ foreignKey: 'userId'
+ })
+}
+
+module.exports = Providers
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 | 1x +1x +1x + + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +1x +1x +1x +1x + + +1x + | const { Model, DataTypes } = require('sequelize')
+const sequelize = require('../dbConnection')
+const { hashPassword } = require('../../services/hashPsw')
+
+class Users extends Model {}
+
+Users.init(
+ {
+ id: {
+ type: DataTypes.INTEGER,
+ unique: true,
+ allowNull: false,
+ primaryKey: true,
+ autoIncrement: true
+ },
+ firstName: {
+ type: DataTypes.STRING,
+ allowNull: false,
+ field: 'first_name'
+ },
+ lastName: {
+ type: DataTypes.STRING,
+ allowNull: false,
+ field: 'last_name'
+ },
+ email: {
+ type: DataTypes.STRING,
+ allowNull: false,
+ field: 'email'
+ },
+ password: {
+ type: DataTypes.STRING,
+ allowNull: false,
+ field: 'password'
+ },
+ picture: {
+ type: DataTypes.STRING
+ },
+ createdAt: {
+ type: DataTypes.DATE,
+ defaultValue: DataTypes.NOW,
+ allowNull: false,
+ field: 'created_at'
+ },
+ updatedAt: {
+ type: DataTypes.DATE,
+ defaultValue: DataTypes.NOW,
+ allowNull: false,
+ field: 'updated_at'
+ },
+ isVerified: {
+ type: DataTypes.BOOLEAN,
+ defaultValue: 0,
+ allowNull: false,
+ field: 'is_verified'
+ },
+ is_pro: {
+ type: DataTypes.BOOLEAN,
+ defaultValue: 0,
+ allowNull: false,
+ field: 'is_pro'
+ },
+ stripe_customer_id: {
+ type: DataTypes.BOOLEAN,
+ defaultValue: null,
+ allowNull: true,
+ field: 'stripe_customer_id'
+ },
+ stripe_card_id: {
+ type: DataTypes.BOOLEAN,
+ defaultValue: null,
+ allowNull: true,
+ field: 'stripe_card_id'
+ }
+ },
+ {
+ sequelize,
+ modelName: 'users',
+ defaultScope: {
+ attributes: { exclude: ['password'] }
+ },
+ hooks: {
+ beforeCreate: hashPassword,
+ beforeUpdate: hashPassword
+ }
+ }
+)
+
+Users.associate = models => {
+ Users.hasMany(models.Articles, { as: 'articles', foreignKey: 'authorId' })
+ Users.hasMany(models.Providers, { as: 'oauth_accounts', foreignKey: 'userId' })
+ Users.hasMany(models.Comments, { as: 'comments', foreignKey: 'authorId' })
+}
+
+module.exports = Users
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| Articles.js | +100% | +7/7 | +100% | +0/0 | +100% | +1/1 | +100% | +7/7 | +|
| Comments.js | +100% | +7/7 | +100% | +0/0 | +100% | +1/1 | +100% | +7/7 | +|
| Providers.js | +100% | +6/6 | +100% | +0/0 | +100% | +1/1 | +100% | +6/6 | +|
| Users.js | +100% | +9/9 | +100% | +0/0 | +100% | +1/1 | +100% | +9/9 | +|
| index.js | +100% | +6/6 | +50% | +1/2 | +100% | +1/1 | +100% | +6/6 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 | 1x + + + + + + +1x + +1x +4x +4x + + + +1x + | const models = {
+ Users: require('./Users'),
+ Articles: require('./Articles'),
+ Providers: require('./Providers'),
+ Comments: require('./Comments')
+}
+
+const modelNames = Object.keys(models)
+
+modelNames.forEach(modelName => {
+ Eif (models[modelName].associate) {
+ models[modelName].associate(models)
+ }
+})
+
+module.exports = models
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| index.js | +84.09% | +37/44 | +25% | +1/4 | +40% | +2/5 | +86.05% | +37/43 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 | 1x +1x +1x +1x +1x + + +1x + + +1x +1x + +1x +1x +1x + + +1x + +1x +1x + + +1x +1x + + + + + + + + +1x +1x + +1x + +1x +1x +1x +1x +1x + + +1x + + +1x +1x + + +1x + + + + +1x + + + + +1x + +1x +1x + + +1x + +1x +1x +1x + + + + +1x + | require('dotenv').config()
+const http = require('http')
+const express = require('express')
+const session = require('express-session')
+const passport = require('passport')
+
+// logger
+const { errorLogger } = require('./services/logger')
+
+// Databases
+const db = require('./db/dbConnection')
+require('./mongodb/mongoConnection')
+
+const connectRedis = require('connect-redis')
+const RSessionStore = connectRedis(session)
+const client = require('./services/redisConnectService')
+
+// app
+const app = express()
+
+app.use(express.urlencoded({ extended: true, limit: '1mb' }))
+app.use(express.json())
+
+// authentication
+const rStore = new RSessionStore({ client, prefix: 'denis:sess:' })
+app.use(
+ session({
+ store: rStore,
+ secret: process.env.SESSION_SECRET,
+ saveUninitialized: false,
+ rolling: false,
+ resave: false
+ })
+)
+app.use(passport.initialize())
+app.use(passport.session())
+
+app.set('trust proxy', 1)
+// apply Limiters
+const { limiter, loginLimiter, wsLimiter } = require('./services/rateLimitService')(client)
+app.use('/api/v1/blog', limiter)
+app.use('/api/v1/users', limiter)
+app.use('/api/v1/profile', limiter)
+app.use('/api/v1/login', loginLimiter)
+
+// docs
+require('./docs/swagger-config')(app)
+
+// routes
+const routes = require('./routes')
+app.use(routes)
+
+// error handlers
+app.use((req, res, next) => {
+ const error = new Error('Not found')
+ error.status = 404
+ next(error)
+})
+app.use((error, req, res, next) => {
+ res.status(error.status || 500)
+ res.json({ data: error })
+})
+
+const server = http.createServer(app)
+// WS
+const io = require('./services/socketService')(server, rStore, wsLimiter)
+app.set('socketio', io)
+
+// Connect to DB and run the server
+db.authenticate()
+ .then(() => {
+ server.listen(process.env.PORT, err => {
+ Iif (err) errorLogger.error(`Some problem with server running`, { metadata: err })
+ console.log('server listening port 8803')
+ })
+ })
+ .catch(err => errorLogger.error(`Some problem with MySQL connection`, { metadata: err }))
+
+module.exports = app
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| mongoConnection.js | +83.33% | +5/6 | +100% | +0/0 | +100% | +1/1 | +83.33% | +5/6 | +|
| queries.js | +28.13% | +9/32 | +100% | +0/0 | +16.67% | +1/6 | +28.13% | +9/32 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 | 1x +1x + +1x + +1x + + + + + + + +1x + + + + +1x + + + + + +1x + + + + +1x + + +1x + + + +1x + + + +1x + | const mongoose = require('mongoose')
+const { Schema } = mongoose
+
+const { mongooseLogger } = require('../../services/logger')
+
+const articlesViews = new Schema({
+ articleId: Number,
+ authorId: Number,
+ views: Number,
+ updatedAt: Date,
+ createdAt: Date
+})
+
+articlesViews.pre('updateOne', function(next) {
+ this.set({ updatedAt: new Date() })
+ next()
+})
+
+articlesViews.pre('save', function(next) {
+ this.set({ createdAt: new Date() })
+ next()
+})
+
+// logging changes in mongoDB
+articlesViews.post('find', function(docs) {
+ const ids = docs.map(doc => doc.articleId)
+ mongooseLogger.info(`The articles were requested with ids: ${ids}`)
+})
+
+articlesViews.post('findOneAndUpdate', function(doc) {
+ mongooseLogger.info(`An article was updated with id: ${doc.articleId}`)
+})
+articlesViews.post('findOneAndDelete', function(doc) {
+ mongooseLogger.info(`An article was deleted with id: ${doc.articleId}`)
+})
+
+articlesViews.post('save', function(doc) {
+ mongooseLogger.info(`An article was created with id: ${doc.articleId}`)
+})
+
+module.exports = mongoose.model('articles_view', articlesViews)
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| ArticlesViews.js | +52.38% | +11/21 | +100% | +0/0 | +0% | +0/7 | +55% | +11/20 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 | 1x + + + +1x +1x + + + + + + + + +1x + +1x + | const mongoose = require('mongoose')
+
+class MDatabase {
+ static async connect() {
+ try {
+ return mongoose.connect(process.env.CONNECTION_STR, {
+ useNewUrlParser: true,
+ useUnifiedTopology: true
+ })
+ } catch (e) {
+ throw e
+ }
+ }
+}
+MDatabase.connect()
+
+module.exports = MDatabase
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 | 1x +1x + +1x +1x + + +1x + + + + + + + + + +1x + + + + + + + + + +1x + + + + + + + + + + + + +1x + + + + + + + + +1x + | const ArticlesViews = require('./models/ArticlesViews')
+const { articlesLogger, errorLogger, mongooseLogger } = require('./../services/logger')
+
+ArticlesViews.createCollection()
+ .then(() => mongooseLogger.info(`The collection is ready to use.`))
+ .catch(e => errorLogger.error(`An error on CreateCollection method`, { metadata: e }))
+
+const insertView = async data => {
+ try {
+ await ArticlesViews(data).save()
+ mongooseLogger.info(`Added a new article`, { metadata: { articleId: data.articleId } })
+ } catch (error) {
+ errorLogger.error(`An error on MongoDB's transaction`, { metadata: error })
+ throw error
+ }
+}
+
+const removeView = async articleId => {
+ try {
+ await ArticlesViews.findOneAndDelete({ articleId: articleId })
+ mongooseLogger.info(`Removed an article`, { metadata: { articleId: articleId } })
+ } catch (error) {
+ errorLogger.error(`An error on MongoDB's transaction`, { metadata: error })
+ throw error
+ }
+}
+
+const getView = async articleId => {
+ try {
+ const viewsResult = await ArticlesViews.findOneAndUpdate({ articleId: articleId }, { $inc: { views: 1 } })
+ const views = viewsResult._doc.views + 1
+ mongooseLogger.info(`Updated an article`, { metadata: { articleId: articleId } })
+ articlesLogger.info(`Viewed an article`, { metadata: { articleId: articleId } })
+ return views
+ } catch (error) {
+ errorLogger.error(`An error on MongoDB's transaction`, { metadata: error })
+ throw error
+ }
+}
+
+const getViews = async () => {
+ try {
+ return await ArticlesViews.find()
+ } catch (error) {
+ errorLogger.error(`An error on MongoDB's transaction`, { metadata: error })
+ throw error
+ }
+}
+
+module.exports = { insertView, removeView, getView, getViews }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 | + + + + + + +1x +1x +1x +1x +1x + +1x +1x +1x +1x +1x +1x + +1x + + + +1x +1x + + + +1x + + + + + +1x +1x +1x +1x +1x +1x + + + +1x + + + + + +1x +1x +1x +1x +1x +1x +1x +1x +1x + + + + + + +1x + + + + + + + + +1x + + + + +1x + + + + + +1x + + + + + + + + + + + + + + + + + + + + + + +1x + | /*
+ POST /api/v1/registration
+ POST /api/v1/registration/verify
+ POST /api/v1/login
+ POST /api/v1/logout
+*/
+
+const express = require('express')
+const router = express.Router()
+const asyncHandler = require('express-async-handler')
+const passport = require('passport')
+const jwt = require('jsonwebtoken')
+
+const { Users } = require('../db/models/index.js')
+require('../services/passportService')(passport)
+const { logOut, getFormattedUrl } = require('../services/helpers')
+const { userCreationValidation, loginValidation } = require('../services/validationService')
+const { SendgridService } = require('../services/emailService')
+const emailTemplates = require('../db/constant')
+
+router.post(
+ '/registration',
+ userCreationValidation,
+ asyncHandler(async (req, res) => {
+ const userData = await Users.findOne({ where: { email: req.body.email } })
+ Iif (userData) {
+ res.status(500)
+ res.send('{ error: "User with this email already exist"}').end()
+ } else {
+ const userItem = {
+ firstName: req.body.firstName,
+ lastName: req.body.lastName,
+ email: req.body.email,
+ password: req.body.password
+ }
+ const newUser = await Users.create(userItem)
+ const createdUser = newUser.get({ plain: true })
+ jwt.sign({ uid: createdUser.id }, 'secretkey', { expiresIn: '1h' }, async (err, token) => {
+ Iif (err) return res.status(403).send({ error: err })
+ const verifyLink = `${getFormattedUrl(req)}/verify?token=${token}`
+ await SendgridService.sendEmail(createdUser.email, 'internship@zazmic.com', emailTemplates.accountVerificationTemplate, {
+ verifyLink: verifyLink,
+ name: createdUser.firstName
+ })
+ res.send({ data: newUser })
+ })
+ }
+ })
+)
+
+router.post('/registration/verify', async (req, res) => {
+ try {
+ const { uid } = await jwt.verify(req.body.token, 'secretkey')
+ const userData = await Users.findByPk(uid)
+ await userData.update({ isVerified: true })
+ let user = userData.get({ plain: true })
+ await req.logIn(user, err => {
+ Iif (err) res.status(500).send({ error: err })
+ res.send({ data: user })
+ })
+ } catch (e) {
+ return res.status(403).json({ errors: [{ msg: 'Try to register again' }] })
+ }
+})
+
+router.post(
+ '/login',
+ loginValidation,
+ passport.authenticate('local', {
+ failureRedirect: '/login'
+ }),
+ (req, res) => res.send({ data: req.user })
+)
+
+router.post('/logout', (req, res) => logOut(req, res))
+
+// JWT test
+// FORMAT OF TOKEN
+// Authorization: Bearer <access_token>
+router.post('/jwt/protected-info', verifyToken, (req, res) => {
+ jwt.verify(req.token, 'secretkey', (err, authData) => {
+ err ? res.sendStatus(403) : res.json({ message: 'Info have been got...', authData })
+ })
+})
+
+router.post('/jwt/login', (req, res) => {
+ const user = { id: 1, userName: 'David', email: 'david@gmail.com' }
+ req.query = { ...user }
+ jwt.sign({ userName: req.query.userName }, 'secretkey', { expiresIn: '60s' }, (err, token) => {
+ err ? res.sendStatus(403) : res.json({ token })
+ })
+})
+
+function verifyToken(req, res, next) {
+ // Get auth header value
+ const bearerHeader = req.headers['authorization']
+ if (typeof bearerHeader !== 'undefined') {
+ // Split at the space and get token from array
+ const bearer = bearerHeader.split(' ')
+ const bearerToken = bearer[1]
+ req.token = bearerToken
+ next()
+ } else {
+ // Forbidden
+ res.sendStatus(403)
+ }
+}
+
+module.exports = router
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 | + + + + + + + + + + +1x +1x +1x + +1x +1x +1x +1x +1x +1x +1x +1x + +1x + + + + + + + + + +1x + + + + + + + + + + + + +1x + + + + + + + + + + + + + + + + + +1x + + + + + + + + + + + + +1x + + + + + + + + + + + + + + + + +1x + + + + + + + +1x + + + + + + + + + + + + + + + + +1x + + + + + + + + + + + + + + + +1x + | /*
+ GET /api/v1/blog - get all blogs
+ POST /api/v1/blog - add a new blog
+ GET /api/v1/blog/:id - get the blog by id
+ PUT /api/v1/blog/:id - update the blog by id
+ DELETE /api/v1/blog/:id - delete the blog by id
+ GET /blog/:articleId/comments - get all comments
+ POST /blog/:articleId/comments - add a new comment
+ DELETE /blog/:articleId/comments/:id - delete the comments
+*/
+
+const express = require('express')
+const router = express.Router()
+const asyncHandler = require('express-async-handler')
+
+const { Articles, Users, Comments } = require('../db/models/index.js')
+const { insertView, removeView: removeArticlesView, getView, getViews } = require('../mongodb/queries')
+const { combineArticles2Views } = require('../services/helpers')
+const authCheck = require('../services/middlewares/authCheck')
+const { articlesMulter } = require('../services/multer')
+const { gcArticlesIMGRemover } = require('../services/gcRemovalService')
+const { getArticles, getComments } = require('../services/queryHelperService')
+const { articleValidation, commentValidation } = require('../services/validationService')
+
+router.get(
+ '/',
+ asyncHandler(async (req, res) => {
+ const articles = await getArticles(req.query.after, null)
+ const views = await getViews()
+ combineArticles2Views(articles, views)
+ res.send({ data: articles })
+ })
+)
+
+router.post(
+ '/',
+ [authCheck, articlesMulter.single('picture'), articleValidation],
+ asyncHandler(async (req, res) => {
+ let newArticle = null
+ req.body.authorId = req.user.id
+ if (req.file) req.body.picture = req.file.path
+ newArticle = await Articles.create({ ...req.body })
+ await insertView({ articleId: newArticle.id, authorId: newArticle.authorId, views: 0 })
+ newArticle.view = 0
+ res.send({ data: newArticle })
+ })
+)
+router.put(
+ '/:id',
+ [authCheck, articlesMulter.single('picture'), articleValidation],
+ asyncHandler(async (req, res) => {
+ const data = await Articles.findByPk(req.params.id, { attributes: ['authorId', 'picture'] })
+ const articleData = data.get({ plain: true })
+ if (articleData.authorId === req.user.id) {
+ let updatedArticle = null
+ if (req.file) req.body.picture = req.file.path
+ if (articleData.picture) await gcArticlesIMGRemover.remove(articleData.picture)
+ updatedArticle = await Articles.update({ ...req.body }, { where: { id: req.params.id } })
+ return updatedArticle > 0 ? res.status(200).send({}) : res.sendStatus(500)
+ } else {
+ res.sendStatus(403)
+ }
+ })
+)
+
+router.get(
+ '/:id',
+ asyncHandler(async (req, res) => {
+ const article = await Articles.findByPk(req.params.id, {
+ order: [['createdAt', 'DESC']],
+ include: [{ model: Users, as: 'author' }]
+ })
+ const views = await getView(+req.params.id)
+ article.dataValues.views = views
+ res.send({ data: article })
+ })
+)
+
+router.delete(
+ '/:id',
+ asyncHandler(async (req, res) => {
+ const data = await Articles.findByPk(req.params.id, { attributes: ['authorId', 'picture'] })
+ const articleData = data.get({ plain: true })
+ if (articleData.authorId === req.user.id) {
+ const destroyedArticle = await Articles.destroy({ where: { id: req.params.id } })
+ await removeArticlesView(req.params.id)
+ if (articleData.picture) await gcArticlesIMGRemover.remove(articleData.picture)
+ destroyedArticle > 0 ? res.send({ data: articleData }) : res.sendStatus(500)
+ } else {
+ res.sendStatus(403)
+ }
+ })
+)
+
+// Comments
+router.get(
+ '/:id/comments',
+ asyncHandler(async (req, res) => {
+ const comments = await getComments(req.params.id, +req.query.after)
+ res.send({ data: comments })
+ })
+)
+
+router.post(
+ '/:id/comments',
+ authCheck,
+ commentValidation,
+ asyncHandler(async (req, res) => {
+ req.body.authorId = req.user.id
+ req.body.articleId = +req.params.id
+ const newComment = await Comments.create(req.body)
+ const comment = newComment.get({ plain: true })
+ comment.author = req.user
+ // sockets
+ const io = req.app.get('socketio')
+ io.to(`room-${req.params.id}`).emit('comment', { action: 'create', data: { comment } })
+ res.send({ data: comment })
+ })
+)
+
+router.delete(
+ '/:articleId/comments/:id',
+ authCheck,
+ asyncHandler(async (req, res) => {
+ req.body.id = req.params.id
+ const comment = await Comments.findByPk(req.params.id)
+ if (comment) {
+ await comment.destroy()
+ const io = req.app.get('socketio')
+ io.to(`room-${req.params.articleId}`).emit('comment', { action: 'destroy', data: { comment } })
+ return res.sendStatus(200)
+ }
+ res.sendStatus(404)
+ })
+)
+
+module.exports = router
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 | + + + + +1x +1x +1x + +1x +1x +1x +1x +1x +1x + +1x + + + + + + + + + + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +1x + | /*
+ GET /api/v1/fees - user fees
+ PUT /api/v1/fees - make a payment to reach a pro-account
+*/
+
+const express = require('express')
+const router = express.Router()
+const asyncHandler = require('express-async-handler')
+
+const authCheck = require('../services/middlewares/authCheck')
+const { createCharge, getChargesAmount } = require('../services/stripeService')
+const { sgMail } = require('../services/emailService')
+const emailTemplates = require('../db/constant')
+const totalBill = 100 // the sum needs to become a pro
+const cents = 100
+
+router.get(
+ '/',
+ authCheck,
+ asyncHandler(async (req, res) => {
+ const user = req.user.get({ plain: true })
+ if (user.is_pro) return res.send({ data: { amount: 0 } })
+ if (!user.stripe_customer_id) return res.send({ data: { amount: 100 } })
+ const total = await getChargesAmount(user.stripe_customer_id)
+ res.send({ data: { amount: totalBill - total } })
+ })
+)
+
+router.put(
+ '/',
+ authCheck,
+ asyncHandler(async (req, res) => {
+ const user = req.user.get({ plain: true })
+ const chargeReport = await createCharge(user.stripe_customer_id, user.stripe_card_id, req.body.amount * cents, user.email)
+ const total = await getChargesAmount(user.stripe_customer_id)
+ sgMail.send({
+ to: user.email,
+ from: 'internship@zazmic.com',
+ template_id: emailTemplates.paymentTemplate,
+ dynamic_template_data: {
+ chargeReport: chargeReport,
+ sum: req.body.amount,
+ rest: total < totalBill ? totalBill - total : 0
+ }
+ })
+ // if user reach a pro
+ if (!user.is_pro && total >= totalBill) {
+ await req.user.update({ is_pro: true })
+ sgMail.send({
+ to: user.email,
+ from: 'internship@zazmic.com',
+ template_id: emailTemplates.proAccountTemplate
+ })
+ }
+ res.send({ data: { amount: totalBill - total, user: user } })
+ })
+)
+
+module.exports = router
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| auth.js | +66.07% | +37/56 | +25% | +3/12 | +45.45% | +5/11 | +67.92% | +36/53 | +|
| blogs.js | +27.03% | +20/74 | +0% | +0/18 | +0% | +0/8 | +28.57% | +20/70 | +|
| fees.js | +44.44% | +12/27 | +0% | +0/10 | +0% | +0/2 | +48% | +12/25 | +|
| index.js | +80.95% | +17/21 | +100% | +0/0 | +0% | +0/2 | +85% | +17/20 | +|
| oauth.js | +80% | +8/10 | +100% | +0/0 | +0% | +0/2 | +80% | +8/10 | +|
| profile.js | +45.45% | +15/33 | +0% | +0/8 | +0% | +0/4 | +51.72% | +15/29 | +|
| users.js | +46.43% | +13/28 | +0% | +0/2 | +0% | +0/5 | +48.15% | +13/27 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 | 1x +1x + +1x +1x +1x +1x +1x +1x + +1x + +1x +1x +1x +1x +1x +1x + +1x + + + + + +1x + | const https = require('https')
+const router = require('express').Router()
+
+const auth = require('./auth')
+const oauth = require('./oauth')
+const blog = require('./blogs')
+const user = require('./users')
+const profile = require('./profile')
+const fees = require('./fees')
+
+const { mongooseLogger } = require('../services/logger')
+
+router.use('/api/v1/oauth', oauth)
+router.use('/api/v1', auth)
+router.use('/api/v1/profile', profile)
+router.use('/api/v1/users', user)
+router.use('/api/v1/blog', blog)
+router.use('/api/v1/fees', fees)
+
+router.get('*', (req, res) => {
+ https.get(process.env.FRONTEND_URL, response => response.pipe(res))
+ const date = new Date()
+ mongooseLogger.info(`App: incoming ${req.method} request at ${date}`)
+})
+
+module.exports = router
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 | + + + + + +1x +1x +1x + +1x + +1x + +1x + + + +1x + + + +1x + | /*
+ GET /api/v1/oauth/google
+ POST /api/v1/oauth/google/callback
+ GET /api/v1/oauth/facebook
+ POST /api/v1/oauth/facebook/callback
+*/
+const express = require('express')
+const router = express.Router()
+const passport = require('passport')
+
+router.get('/google', passport.authenticate('google', { scope: ['profile', 'email'] }))
+
+router.get('/facebook', passport.authenticate('facebook', { scope: ['email'] }))
+
+router.post('/google/callback', passport.authenticate('google'), (req, res) => {
+ res.send({ data: req.user })
+})
+
+router.post('/facebook/callback', passport.authenticate('facebook'), (req, res) => {
+ res.send({ data: req.user })
+})
+
+module.exports = router
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 | + + + + + +1x +1x +1x + +1x +1x +1x +1x +1x +1x +1x + +1x + + + + + + + + + +1x + + + + + + + + + + + + +1x + + + + + + + + + + +1x + + + + + + + + + +1x + | /*
+ PUT /api/v1/profile - update user
+ DELETE /api/v1/profile - delete user
+ PUT /api/v1/picture - update or add users picture
+*/
+
+const express = require('express')
+const router = express.Router()
+const asyncHandler = require('express-async-handler')
+
+const { Users, Articles } = require('../db/models/index.js')
+const authCheck = require('../services/middlewares/authCheck')
+const { logOut } = require('../services/helpers')
+const { avatarMulter } = require('../services/multer')
+const { gcUserIMGRemover } = require('../services/gcRemovalService')
+const { editUserValidation } = require('../services/validationService')
+const { createCustomer } = require('../services/stripeService')
+
+router.put(
+ '/',
+ authCheck,
+ editUserValidation,
+ asyncHandler(async (req, res) => {
+ await req.user.update({ firstName: req.body.firstName, lastName: req.body.lastName })
+ res.send({ data: req.user })
+ })
+)
+
+router.delete(
+ '/',
+ authCheck,
+ asyncHandler(async (req, res) => {
+ const imgs = await Articles.findAll({ where: { authorId: req.user.id }, raw: true, attributes: ['picture'] })
+ if (req.user.picture) imgs.push({ picture: req.user.picture })
+ if (imgs.length) await gcUserIMGRemover.remove(imgs)
+ const destroyedUser = await Users.destroy({ where: { id: req.user.id } })
+ if (destroyedUser > 0) return logOut(req, res)
+ res.sendStatus(500)
+ })
+)
+
+router.put(
+ '/picture',
+ authCheck,
+ avatarMulter.single('picture'),
+ asyncHandler(async (req, res) => {
+ if (!req.file) return res.status(400).send('No file uploaded.')
+ await req.user.update({ picture: req.file.path })
+ res.send({ data: { picture: req.file.path } })
+ })
+)
+
+router.put(
+ '/card',
+ authCheck,
+ asyncHandler(async (req, res) => {
+ const user = req.user.get({ plain: true })
+ const updatedData = await createCustomer(req.body.token, user)
+ res.send({ data: { ...user, ...updatedData } })
+ })
+)
+
+module.exports = router
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 | + + + + + + + +1x +1x +1x + +1x +1x + +1x +1x +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +1x + + + + + + + +1x + + + + + + + + + +1x + | /*
+ GET /api/v1/users - get all users
+ POST /api/v1/users - add a new user
+ GET /api/v1/users/:id - get the user by id
+ PUT /api/v1/users/:id - update the user by id
+ DELETE /api/v1/users/:id - delete the user by id
+*/
+
+const express = require('express')
+const router = express.Router()
+const asyncHandler = require('express-async-handler')
+
+const { Users } = require('../db/models/index.js')
+const db = require('../db/dbConnection')
+
+const { getViews } = require('../mongodb/queries')
+const { combineArticles2Views } = require('../services/helpers')
+const authCheck = require('../services/middlewares/authCheck')
+const { getArticles } = require('../services/queryHelperService')
+
+router.get(
+ '/',
+ authCheck,
+ asyncHandler(async (req, res) => {
+ const users = await db.query(
+ `
+ SELECT
+ users.id,
+ users.email,
+ users.first_name AS firstName,
+ users.last_name AS lastName,
+ users.last_name AS lastName,
+ users.is_pro,
+ COUNT(articles.id) AS articlesCount
+ FROM users
+ LEFT JOIN articles ON articles.author_id = users.id
+ GROUP BY users.id`,
+ { type: db.QueryTypes.SELECT }
+ )
+ const views = await getViews()
+ users.forEach(item => {
+ let viewsCount = 0
+ views.forEach(view => {
+ if (item.id === view.authorId) viewsCount += view.views
+ })
+ item.viewsCount = viewsCount
+ })
+ res.send({ data: users })
+ })
+)
+
+router.get(
+ '/:id',
+ asyncHandler(async (req, res) => {
+ const user = await Users.findByPk(req.params.id)
+ res.send({ data: user })
+ })
+)
+
+router.get(
+ '/:id/blog',
+ asyncHandler(async (req, res) => {
+ const articles = await getArticles(req.query.after, req.params.id)
+ const views = await getViews(req.params.id)
+ combineArticles2Views(articles, views)
+ res.send({ data: articles })
+ })
+)
+
+module.exports = router
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 | 1x +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +1x + | const { errorLogger } = require('./logger')
+const { Users, Providers } = require('../db/models/index.js')
+
+class AuthService {
+ static async findOrCreateOauthProvider({ provider, email, firstName, lastName, providerUserId }) {
+ try {
+ const userData = await Users.findOne({ where: { email } })
+ if (userData) {
+ await userData.update({ isVerified: true })
+ const user = userData.get({ plain: true })
+ const hasAccount = await Providers.findOne({ where: { providerUserId } })
+ if (!hasAccount) await this.createOauthAccount(user.id, provider, providerUserId)
+ return user
+ } else {
+ const newUser = await this.createUser(firstName, lastName, email)
+ await newUser.update({ isVerified: true })
+ await this.createOauthAccount(newUser.dataValues.id, provider, providerUserId)
+ return newUser.get({ plain: true })
+ }
+ } catch (err) {
+ errorLogger.error(`An error on MySQL request`, { metadata: err })
+ }
+ }
+
+ static async createOauthAccount(userId, provider, providerUserId) {
+ await Providers.create({ userId, provider, providerUserId })
+ }
+
+ static async createUser(firstName, lastName, email) {
+ return await Users.create({ firstName, lastName, email, password: '123qwe' })
+ }
+}
+
+module.exports = { AuthService }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 | 1x +1x + + + + + + + + + + + + +1x + | const sgMail = require('@sendgrid/mail')
+sgMail.setApiKey(process.env.SENDGRID_API_KEY)
+
+class SendgridService {
+ static async sendEmail(to, from, templateId = '', dynamicData = {}) {
+ await sgMail.send({
+ to,
+ from,
+ template_id: templateId,
+ dynamic_template_data: dynamicData
+ })
+ }
+}
+
+module.exports = { sgMail, SendgridService }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 | 1x +1x + + + +2x +2x + + + + + + + + + + + + + + + + + +1x +1x + +1x + | const { avatarStorage, articlesStorage } = require('./gcStorageService')
+const { errorLogger } = require('./logger')
+
+class GCRemoverTool {
+ constructor(storage, bucket) {
+ this.gcStorage = storage
+ this.gcsBucket = bucket
+ }
+ remove(data) {
+ Array.isArray(data) ? this.removeMany(data) : this.removeOne(data)
+ }
+
+ async removeMany(urls) {
+ await Promise.all(urls.map(url => this.removeOne(url.picture)))
+ }
+
+ async removeOne(url) {
+ const filePath = new URL(url).pathname
+ const fileName = filePath.replace(new RegExp(`${this.gcsBucket.name}/`, 'g'), '')
+ const gcFile = this.gcsBucket.file(fileName.slice(1))
+ await gcFile.delete().catch(e => errorLogger.error(`Some problem with pictures removing`, { metadata: e }))
+ }
+}
+
+const gcUserIMGRemover = new GCRemoverTool(avatarStorage.gcStorage, avatarStorage.gcsBucket)
+const gcArticlesIMGRemover = new GCRemoverTool(articlesStorage.gcStorage, articlesStorage.gcsBucket)
+
+module.exports = { gcUserIMGRemover, gcArticlesIMGRemover }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 | 1x +1x +1x +1x + + + +2x +2x +2x +2x +2x +2x +2x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +1x + + + + + + +1x + + + + + + +1x + | const { Storage } = require('@google-cloud/storage')
+const path = require('path')
+const sharp = require('sharp')
+const { errorLogger } = require('./logger')
+
+class GCStorage {
+ constructor(opts) {
+ Iif (!opts.bucket) throw new Error('You have to specify bucket for GCStorage.')
+ Iif (!opts.keyFilename) throw new Error('You have to specify credentials key file for GCStorage.')
+ this.getDestination = opts.destination || this.getDestination
+ this.getFilename = opts.filename || this.getFilename
+ this.gcStorage = new Storage({ keyFilename: opts.keyFilename })
+ this.gcsBucket = this.gcStorage.bucket(opts.bucket)
+ this.options = opts
+ }
+
+ getDestination(req, file, cb) {
+ cb(null, `${this.options.prefix}/${this.options.size.width}x${this.options.size.height}/`)
+ }
+
+ getFilename(req, file, cb) {
+ const prefix = Date.now()
+ cb(null, `${prefix}-${file.originalname}`)
+ }
+
+ _handleFile(req, file, cb) {
+ this.getDestination(req, file, (err, destination) => {
+ if (err) return cb(err)
+ this.getFilename(req, file, async (err, filename) => {
+ if (err) return cb(err)
+ const finalPath = path.join(destination, filename)
+ let gcFile = this.gcsBucket.file(finalPath)
+ const streamOpts = { predefinedAcl: this.options.acl || 'publicread' }
+ const sharpResizer = sharp().resize(this.options.size.width, this.options.size.height)
+ file.stream
+ .pipe(sharpResizer)
+ .pipe(gcFile.createWriteStream(streamOpts))
+ .on('error', err => {
+ errorLogger.error(`Error while file uploading`, { metadata: err })
+ cb(err)
+ })
+ .on('finish', () => {
+ cb(null, {
+ path: `https://storage.googleapis.com/${this.options.bucket}/${finalPath}`,
+ filename: filename
+ })
+ })
+ })
+ })
+ }
+
+ _removeFile(req, file, cb) {
+ this.gcsBucket.file(file.filename).delete()
+ }
+}
+
+const avatarStorage = new GCStorage({
+ prefix: `denis/avatars`,
+ bucket: process.env.BUCKET_NAME,
+ keyFilename: path.join(__dirname, '../service-key.json'),
+ size: { width: 180, height: 180 }
+})
+
+const articlesStorage = new GCStorage({
+ prefix: `denis/articles`,
+ bucket: process.env.BUCKET_NAME,
+ keyFilename: path.join(__dirname, '../service-key.json'),
+ size: { width: 1200, height: 630 }
+})
+
+module.exports = { avatarStorage, articlesStorage }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 | 1x +1x +1x + +1x +2x +2x +1x + + + + + + +1x + +1x + | const bcrypt = require('bcrypt')
+const { errorLogger } = require('./logger')
+const saltRound = 10
+
+const hashPassword = async user => {
+ try {
+ if (user.changed('password')) {
+ user.password = await bcrypt.hash(user.password, saltRound)
+ }
+ } catch (err) {
+ errorLogger.error(`Some problem with passwords hashing`, { metadata: err })
+ }
+}
+
+const checkPsw = (psw, hash) => bcrypt.compare(psw, hash)
+
+module.exports = { hashPassword, checkPsw }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 | 1x + +1x + + + + + + + +1x +1x +1x +1x + + +1x + +1x + | const url = require('url')
+
+const combineArticles2Views = (articles, views) => {
+ articles.forEach(item => {
+ views.forEach(view => {
+ if (item.dataValues.id === view.articleId) item.dataValues.views = view.views
+ })
+ })
+}
+
+const logOut = (req, res) => {
+ req.logout()
+ req.session.destroy()
+ res.send({})
+}
+
+const getFormattedUrl = req => url.format({ protocol: req.protocol, host: req.get('host') })
+
+module.exports = { combineArticles2Views, logOut, getFormattedUrl }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| AuthService.js | +15.79% | +3/19 | +0% | +0/4 | +0% | +0/3 | +16.67% | +3/18 | +|
| emailService.js | +75% | +3/4 | +0% | +0/2 | +0% | +0/1 | +75% | +3/4 | +|
| gcRemovalService.js | +46.67% | +7/15 | +0% | +0/2 | +16.67% | +1/6 | +53.85% | +7/13 | +|
| gcStorageService.js | +41.18% | +14/34 | +42.86% | +6/14 | +11.11% | +1/9 | +46.67% | +14/30 | +|
| hashPsw.js | +81.82% | +9/11 | +100% | +2/2 | +50% | +1/2 | +90% | +9/10 | +|
| helpers.js | +69.23% | +9/13 | +0% | +0/2 | +40% | +2/5 | +72.73% | +8/11 | +|
| logger.js | +78.57% | +11/14 | +100% | +0/0 | +0% | +0/2 | +84.62% | +11/13 | +|
| multer.js | +100% | +5/5 | +100% | +0/0 | +100% | +0/0 | +100% | +5/5 | +|
| passportService.js | +44.74% | +17/38 | +0% | +0/4 | +50% | +3/6 | +45.71% | +16/35 | +|
| queryHelperService.js | +35.71% | +5/14 | +0% | +0/6 | +0% | +0/2 | +38.46% | +5/13 | +|
| rateLimitService.js | +100% | +8/8 | +100% | +0/0 | +100% | +1/1 | +100% | +8/8 | +|
| redisConnectService.js | +83.33% | +5/6 | +100% | +0/0 | +0% | +0/1 | +83.33% | +5/6 | +|
| socketService.js | +38.46% | +10/26 | +0% | +0/4 | +10% | +1/10 | +43.48% | +10/23 | +|
| stripeService.js | +41.18% | +7/17 | +0% | +0/4 | +0% | +0/4 | +41.18% | +7/17 | +|
| validationService.js | +68% | +17/25 | +37.5% | +3/8 | +33.33% | +1/3 | +85% | +17/20 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 | 1x +1x +1x + +1x + +1x + + + + + + + + + + + + + + + + + + +1x + + + + + + + + + + + + + + + + + + + +1x + + + + + + + + + + + + + + + + + + + +1x + + + + +1x +1x + +1x + + + + + | const winston = require('winston')
+require('winston-mongodb')
+require('../mongodb/mongoConnection')
+
+const { format, transports, createLogger } = winston
+
+const mongooseLogger = createLogger({
+ format: format.combine(format.splat(), format.simple()),
+ transports: [
+ new transports.MongoDB({
+ db: process.env.CONNECTION_STR,
+ collection: 'mongoose_logs',
+ decolorize: true,
+ options: {
+ useUnifiedTopology: true,
+ useNewUrlParser: true
+ }
+ }),
+ new transports.Console({
+ json: false,
+ colorize: true
+ })
+ ]
+})
+
+const errorLogger = createLogger({
+ transports: [
+ new transports.Console({
+ level: 'info',
+ format: format.combine(format.splat(), format.simple()),
+ colorize: true,
+ handleExceptions: true
+ }),
+ new transports.MongoDB({
+ level: 'error',
+ db: process.env.CONNECTION_STR,
+ collection: 'error_logs',
+ options: {
+ useUnifiedTopology: true,
+ useNewUrlParser: true
+ }
+ })
+ ]
+})
+
+const articlesLogger = createLogger({
+ transports: [
+ new transports.Console({
+ level: 'info',
+ format: format.combine(format.splat(), format.simple()),
+ colorize: true,
+ handleExceptions: true
+ }),
+ new transports.MongoDB({
+ level: 'info',
+ db: process.env.CONNECTION_STR,
+ collection: 'articles_logs',
+ options: {
+ useUnifiedTopology: true,
+ useNewUrlParser: true
+ }
+ })
+ ]
+})
+
+const exceptionLogger = error => {
+ errorLogger.error('Uncaught exception', { metadata: error })
+ errorLogger.end(() => process.exit(1))
+}
+
+process.on('uncaughtException', exceptionLogger)
+process.on('unhandledRejection', exceptionLogger)
+
+module.exports = {
+ mongooseLogger,
+ errorLogger,
+ articlesLogger
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 | +1x + + + + | // route middleware to make sure a user is logged in +module.exports = (req, res, next) => { + if (req.isAuthenticated()) return next() + res.status(401).send('You have to be authenticated.') +} + |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| authCheck.js | +25% | +1/4 | +0% | +0/2 | +0% | +0/1 | +33.33% | +1/3 | +|
| validation.js | +88.89% | +8/9 | +50% | +1/2 | +100% | +2/2 | +100% | +8/8 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 | 1x + +1x +5x + + +1x +1x +1x + + +5x + + +1x + | const { validationResult } = require('express-validator')
+
+const validation = rules => {
+ const middlewares = [
+ ...rules,
+ (req, res, next) => {
+ const errors = validationResult(req)
+ Iif (!errors.isEmpty()) return res.status(422).json({ errors: errors.array() })
+ next()
+ }
+ ]
+ return middlewares
+}
+
+module.exports = { validation }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 | 1x + +1x + +1x + + + + + + +1x + + + + + + +1x + | const Multer = require('multer')
+
+const { avatarStorage, articlesStorage } = require('./gcStorageService')
+
+const avatarMulter = Multer({
+ storage: avatarStorage,
+ limits: {
+ fileSize: 5 * 1024 * 1024
+ }
+})
+
+const articlesMulter = Multer({
+ storage: articlesStorage,
+ limits: {
+ fileSize: 5 * 1024 * 1024
+ }
+})
+
+module.exports = { avatarMulter, articlesMulter }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 | 1x +1x +1x + +1x +1x +1x +1x + +1x +1x + +1x +1x +1x +1x + + + + + + +1x + + + + + + + + + + + + + + + +1x + + + + + + + + + + + + + + + + + + + + + + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + | const LocalStrategy = require('passport-local').Strategy
+const GoogleStrategy = require('passport-google-oauth20')
+const FacebookStrategy = require('passport-facebook').Strategy
+
+const { errorLogger } = require('./logger')
+const { checkPsw } = require('./hashPsw')
+const { Users } = require('../db/models/index.js')
+const { AuthService } = require('./AuthService')
+
+module.exports = passport => {
+ passport.serializeUser((user, done) => done(null, user.id))
+
+ passport.deserializeUser(async (id, done) => {
+ try {
+ const user = await Users.findByPk(id)
+ return done(null, user)
+ } catch (err) {
+ done(err)
+ errorLogger.error(`An error on MySQL request`, { metadata: err })
+ }
+ })
+
+ passport.use(
+ new LocalStrategy({ usernameField: 'email', passwordField: 'password' }, async (email, password, done) => {
+ try {
+ const userData = await Users.unscoped().findOne({ where: { email: email } })
+ const user = userData.get({ plain: true })
+ if (!user.isVerified) done({ error: 'You should verify your account. Check your email.' })
+ const match = await checkPsw(password, user.password)
+ if (match) return done(null, user)
+ return done(null, {})
+ } catch (err) {
+ done(err)
+ errorLogger.error(`An error on MySQL request`, { metadata: err })
+ }
+ })
+ )
+
+ passport.use(
+ new GoogleStrategy(
+ {
+ clientID: process.env.GOOGLE_CLIENT_ID,
+ clientSecret: process.env.GOOGLE_CLIENT_SECRET,
+ callbackURL: process.env.GOOGLE_CALLBACK_URL
+ },
+ async (accessToken, refreshToken, profile, done) => {
+ try {
+ const user = await AuthService.findOrCreateOauthProvider({
+ provider: 'google',
+ email: profile._json.email,
+ firstName: profile._json.given_name,
+ lastName: profile._json.family_name,
+ providerUserId: profile.id
+ })
+ done(null, user)
+ } catch (e) {
+ done(e)
+ }
+ }
+ )
+ )
+
+ passport.use(
+ 'facebook-strategy',
+ new FacebookStrategy(
+ {
+ clientID: process.env.FACEBOOK_CLIENT_ID,
+ clientSecret: process.env.FACEBOOK_CLIENT_SECRET,
+ callbackURL: process.env.FACEBOOK_CALLBACK_URL,
+ profileFields: ['id', 'email', 'first_name', 'last_name']
+ },
+ async (accessToken, refreshToken, profile, done) => {
+ try {
+ const user = await AuthService.findOrCreateOauthProvider({
+ provider: 'facebook',
+ email: profile._json.email,
+ firstName: profile.name.givenName,
+ lastName: profile.name.familyName,
+ providerUserId: profile.id
+ })
+ done(null, user)
+ } catch (error) {
+ done(error)
+ }
+ }
+ )
+ )
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 | 1x +1x + +1x + + + + + + + + + + + + + + +1x + + + + + + + + + +1x + | const Op = require('sequelize').Op
+const { Articles, Users, Comments } = require('../db/models/index')
+
+const getArticles = async (after, authorId) => {
+ let whereObj = {}
+ if (after) {
+ const [timestamp, id] = after.split('_')
+ whereObj = { id: { [Op.lte]: +id }, publishedAt: { [Op.lt]: timestamp } }
+ }
+ if (authorId) whereObj.authorId = authorId
+ return await Articles.findAll({
+ where: whereObj,
+ limit: 5,
+ order: [['publishedAt', 'DESC'], ['id', 'ASC']],
+ include: [{ model: Users, as: 'author' }]
+ })
+}
+
+const getComments = async (articleId, continuation) => {
+ let whereObj = !continuation ? { articleId } : { id: { [Op.lt]: continuation }, articleId }
+ return await Comments.findAll({
+ where: whereObj,
+ limit: 5,
+ order: [['id', 'DESC']],
+ include: [{ model: Users, as: 'author', attributes: ['id', 'firstName', 'lastName', 'picture'] }]
+ })
+}
+
+module.exports = { getArticles, getComments }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 | 1x +1x +1x + +1x +1x + + + + + + + + +1x + + + + + + + + + +1x + + + + + + +1x + + | const RateLimit = require('express-rate-limit')
+const RLimitStore = require('rate-limit-redis')
+const { RateLimiterRedis } = require('rate-limiter-flexible')
+
+module.exports = client => {
+ const limiter = new RateLimit({
+ store: new RLimitStore({
+ client: client,
+ prefix: 'denis:limits:'
+ }),
+ max: 200,
+ delayMs: 0
+ })
+
+ const loginLimiter = new RateLimit({
+ store: new RLimitStore({
+ client: client,
+ prefix: 'denis:loginLimits:'
+ }),
+ windowMs: 10 * 60 * 1000,
+ max: 20,
+ delayMs: 0
+ })
+
+ const wsLimiter = new RateLimiterRedis({
+ redis: client,
+ keyPrefix: 'denis:socket:rl:',
+ points: 15,
+ duration: 30
+ })
+
+ return { limiter, loginLimiter, wsLimiter }
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 | 1x +1x +1x + +1x + + + +1x + | const R = require('ioredis')
+const client = new R(process.env.REDIS_URL)
+const { errorLogger } = require('./logger')
+
+client.on('error', err => {
+ errorLogger.error(`An error on Redis`, { metadata: err })
+})
+
+module.exports = client
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 | 1x +1x +1x + +1x + +1x +1x +1x +1x + + + + + + + +1x + + + + + + + + + + + + + + + + + + + +1x + + | const socketio = require('socket.io')
+const passportSocketIo = require('passport.socketio')
+const adapter = require('socket.io-redis')
+
+const { errorLogger } = require('./logger')
+
+module.exports = (server, rStore, wsLimiter) => {
+ const io = socketio(server)
+ io.adapter(adapter(process.env.REDIS_URL))
+ io.use(
+ passportSocketIo.authorize({
+ secret: process.env.SESSION_SECRET,
+ store: rStore,
+ fail: (data, message, error, accept) => accept()
+ })
+ )
+
+ io.on('connection', function(socket) {
+ io.of('/').adapter.clients((err, clients) => {
+ if (err) errorLogger.error(`Some problem with socket connection`, { metadata: err })
+ })
+ const ip = socket.request.connection.remoteAddress
+ socket.use((packet, next) => {
+ wsLimiter
+ .consume(ip)
+ .then(consume => next())
+ .catch(consume => next(new Error('Rate limit error')))
+ })
+ if (socket.request.user.logged_in) {
+ socket.on('watch-comments', articleId => socket.join(`room-${articleId}`))
+ socket.on('unwatch-comments', articleId => socket.leave(`room-${articleId}`))
+
+ socket.on('comment-typing', articleId => {
+ socket.to(`room-${articleId}`).emit('comment-typing', { action: 'typing' })
+ })
+ }
+ })
+ return io
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 | 1x +1x +1x + +1x + + + + + + + + +1x + + + + + + + + + + +1x + + + + + + + + +1x + | const stripe = require('stripe')(process.env.STRIPE_SK)
+const asyncHandler = require('express-async-handler')
+const { Users } = require('../db/models/index')
+
+const createCustomer = asyncHandler(async (token, user) => {
+ const customer = await stripe.customers.create({ email: user.email, source: token })
+ const updated = await Users.update(
+ { stripe_customer_id: customer.id, stripe_card_id: customer.default_source },
+ { where: { id: user.id } }
+ )
+ return updated ? { stripe_customer_id: customer.id, stripe_card_id: customer.default_source } : null
+})
+
+const createCharge = asyncHandler(async (customerID, cardID, amount, email) => {
+ const charge = await stripe.charges.create({
+ customer: customerID,
+ amount: amount,
+ currency: 'usd',
+ description: `Charge Pro for ${email}`,
+ source: cardID
+ })
+ return charge ? charge.receipt_url : null
+})
+
+const getChargesAmount = asyncHandler(async customerID => {
+ const charges = await stripe.charges.list({ customer: customerID })
+ let sum = 0
+ charges.data.forEach(item => {
+ sum += item.amount
+ })
+ return sum / 100
+})
+
+module.exports = { createCustomer, createCharge, getChargesAmount }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 | 1x + +1x + +1x +1x +1x +1x +1x +1x +1x + + +1x + +1x + + + + + + + + + + + + + + + + + + +1x + + + + + + + + + + + + +1x + + + + + +1x + + + + + + + + + + + + + +1x + + + + + + + + +1x + + + + + + + +1x + | const { body } = require('express-validator')
+
+const { validation } = require('../services/middlewares/validation')
+
+const isPass = value => {
+ const letters = /[a-zA-Z]/
+ const numbers = /[0-9]/
+ Iif (value.length < 6) return false
+ Iif (!letters.test(value)) return false
+ Iif (!numbers.test(value)) return false
+ return true
+}
+
+const checkCommentLength = value => value.length >= 2
+
+const userCreationValidation = validation([
+ body('firstName')
+ .exists({ checkFalsy: true })
+ .withMessage('First name is required'),
+ body('lastName')
+ .exists({ checkFalsy: true })
+ .withMessage('Last name is required'),
+ body('email')
+ .exists({ checkFalsy: true })
+ .withMessage('Email is required')
+ .isEmail()
+ .withMessage('Should be an email'),
+ body('password')
+ .exists({ checkFalsy: true })
+ .withMessage('Password is required')
+ .custom(isPass)
+ .withMessage('Password must have at least 6 symbols and digits.')
+])
+
+const loginValidation = validation([
+ body('email')
+ .exists({ checkFalsy: true })
+ .withMessage('Email is required')
+ .isEmail()
+ .withMessage('Should be an email'),
+ body('password')
+ .exists({ checkFalsy: true })
+ .withMessage('Password is required')
+ .custom(isPass)
+ .withMessage('Password must have at least 6 symbols and digits.')
+])
+
+const isValidDate = value => {
+ const date = new Date(value)
+ if (date.getDate) return true
+ return false
+}
+
+const articleValidation = validation([
+ body('title')
+ .exists({ checkFalsy: true })
+ .withMessage('Title is required'),
+ body('content')
+ .exists({ checkFalsy: true })
+ .withMessage('Content is required'),
+ body('publishedAt')
+ .exists({ checkFalsy: true })
+ .withMessage('publishedAt is required')
+ .custom(isValidDate)
+ .withMessage('publishedAt must be valid')
+])
+
+const editUserValidation = validation([
+ body('firstName')
+ .exists({ checkFalsy: true })
+ .withMessage('First name is required'),
+ body('lastName')
+ .exists({ checkFalsy: true })
+ .withMessage('Last name is required')
+])
+
+const commentValidation = validation([
+ body('content')
+ .exists({ checkFalsy: true })
+ .withMessage('Content is required')
+ .custom(checkCommentLength)
+ .withMessage('Content must have at least 2 symbols')
+])
+
+module.exports = { userCreationValidation, articleValidation, loginValidation, editUserValidation, commentValidation }
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 | +1x +1x +1x +1x +1x + +1x + +1x +1x +1x +1x +1x + +1x +1x +1x +1x + +1x +1x +1x + +1x + + + | /* eslint-disable */
+const faker = require('faker')
+const supertest = require('supertest')
+const app = require('../index')
+const { SendgridService } = require('../services/emailService')
+const request = supertest(app)
+
+module.exports = {
+ registerUser: async () => {
+ const firstName = faker.name.firstName()
+ const lastName = faker.name.lastName()
+ const email = faker.internet.email()
+ const password = faker.internet.password()
+ const sendEmailSpy = jest.spyOn(SendgridService, 'sendEmail').mockImplementation()
+
+ await request.post('/api/v1/registration').send({ firstName, lastName, email, password })
+ const { verifyLink } = sendEmailSpy.mock.calls[0][3]
+ const token = verifyLink.split('token=').pop()
+ const response = await request.post('/api/v1/registration/verify').send({ token })
+
+ sendEmailSpy.mockReset()
+ const user = response.body.data
+ user.authCookie = response.headers['set-cookie'][0].split(';').shift()
+
+ return user
+ }
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| helpers.js | +100% | +19/19 | +100% | +0/0 | +100% | +1/1 | +100% | +19/19 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| hw5 | +84.09% | +37/44 | +25% | +1/4 | +40% | +2/5 | +86.05% | +37/43 | +|
| hw5/db | +100% | +3/3 | +100% | +0/0 | +100% | +0/0 | +100% | +3/3 | +|
| hw5/db/models | +100% | +35/35 | +50% | +1/2 | +100% | +5/5 | +100% | +35/35 | +|
| hw5/mongodb | +36.84% | +14/38 | +100% | +0/0 | +28.57% | +2/7 | +36.84% | +14/38 | +|
| hw5/mongodb/models | +52.38% | +11/21 | +100% | +0/0 | +0% | +0/7 | +55% | +11/20 | +|
| hw5/routes | +49% | +122/249 | +6% | +3/50 | +14.71% | +5/34 | +51.71% | +121/234 | +|
| hw5/services | +52.21% | +130/249 | +21.15% | +11/52 | +20% | +11/55 | +56.64% | +128/226 | +|
| hw5/services/middlewares | +69.23% | +9/13 | +25% | +1/4 | +66.67% | +2/3 | +81.82% | +9/11 | +|
| hw5/tests | +100% | +19/19 | +100% | +0/0 | +100% | +1/1 | +100% | +19/19 | +