server.js

require('dotenv/config')
const express = require('express')
const bodyParser = require('body-parser')
const path = require('path')
const HTTPError = require('./util/HTTPError')

const Mailchimp = require('mailchimp-api-v3')
const mailchimp = new Mailchimp(process.env.MAILCHIMP_API_KEY)

const db = require('./db/models')
const jwt = require('jsonwebtoken')
const passport = require('passport')
require('./config/passport')
const authenticate = passport.authenticate('jwt', { session: false })

const app = express()
const PORT = process.env.PORT || 8080

app.use(bodyParser.json())
app.use(bodyParser.urlencoded({extended: true}))
app.use(express.static('public'))
app.use(passport.initialize())

db.sequelize.sync()
.then(()=> {
	app.listen(PORT, ()=> {
		console.log(`Listening on port:${PORT}`)
	})
})

const asyncMiddleware = fn => (req, res, next) => { Promise.resolve(fn(req, res, next)).catch(next) }

//------------------->
// Mailchimp
//------------------->

app.post('/mailing-list', (req, res)=> {
	mailchimp.post(`/lists/${process.env.MEMBER_LIST}/members`, {
		email_address: req.body.email_address,
		status: 'subscribed',
	    merge_fields: {
	    	FNAME: req.body.FNAME,
	    	LNAME: req.body.LNAME
	    }
	})
	.then((response) => {
		return res.status(200).json({ response })
	})
	.catch((err)=> {
		console.log(err)
		return res.status(err.status).json({ error: err.detail })
	})
})

//----------->
// User Routes
//----------->

app.get('/api', (req, res)=> {
	res.send('Welcome to the rr2 API')
})

app.get('/api/users', authenticate, asyncMiddleware(async (req, res)=> {
	let r = await db.User.findAll()
	res.json(r)
}))

app.post('/api/signup', (req, res)=> {
	db.User.create({
		firstName: req.body.firstName,
		lastName: req.body.lastName,
		email: req.body.email,
		password: req.body.password,
	}).then(user=> {
		res.status(200).json(user)
	}).catch(err=> {
		console.log(err)
		res.json(err)
	})
})

app.post("/api/login", asyncMiddleware(async function(req, res, next) {
	console.log(req.body)
	const { user, info } = await passportAuthenticateAsync('local', req, res, next)
	if (!user) {
        throw new HTTPError(403, 'Username or password is invalid')
	} 

    const { token } = await reqLoginAsync(req, user)
    return res.status(200).json({ token, user })
}))

app.get('/api/users/:id', authenticate, asyncMiddleware(async (req, res)=> {
	let r = await db.User.findAll({where: {id: req.params.id}})
	res.json(r)
}))



//----------->
// Blog Routes
//----------->

app.get('/api/blogs', async (req, res)=> {
	console.log(req.body)
	let r = await db.Blog.findAll()
	res.json(r)
})

app.get('/api/blogs/:id', authenticate, asyncMiddleware(async (req, res)=> {
	let r = await db.Blog.findAll({where: {id: req.params.id}})
	
	res.json(r)
}))

app.get('/api/blogs/user/:id', async (req, res)=> {
	console.log(req.body)
	let r = await db.Blog.findAll({where: {userId: req.params.id}})
	res.json(r)
})

app.patch('/api/blogs/:id', async (req, res)=> {
	console.log(req.body)
	let r = await db.Blog.update({
		title: req.body.title,
		body: req.body.body,
		headerImg: req.body.headerImg,
		uri: req.body.uri,
		category: req.body.category,
		description: req.body.description,
		render: req.body.render,
		}, {where: {id: req.params.id}})
	res.json(r)
})

app.post('/api/blogs/create', authenticate, asyncMiddleware(async (req, res)=> {
	console.log(req.body)
	db.Blog.create({
		title: req.body.title,
		body: req.body.body,
		description: req.body.description,
		uri: req.body.uri,
		category: req.body.category,
		headerImg: req.body.headerImg,
		render: req.body.render,
		userId: req.body.userId,
	}).then(blog=> {
		res.status(200).json(blog)
	}).catch(err=> {
		console.log(err)
		res.status(500).json(err)
	})
}))

app.delete('/api/blogs/delete/:id', authenticate, asyncMiddleware(async (req, res)=> {
	console.log(req.body)
	db.Blog.destroy({where: {id: req.params.id}})
	.then(()=> {
		res.status(200).json({'message': 'your blog has been deleted successfully'})
	}).catch(err=> {
		console.log(err)
		res.status(500).json(err)
	})
}))

//------------------->
// Auth Routes + Funcs
//------------------->

app.get("/checktoken", authenticate, async (req, res) => {
	res.json(req.user)
})

function passportAuthenticateAsync(strategy, req, res, next) {
    return new Promise((resolve, reject) => {
        passport.authenticate(strategy, {session: false}, (err, user, info) => {
            if (err) return reject(err)
            return resolve({ user, info })
        })(req, res, next)
    })
}

function reqLoginAsync(req, user) {
    return new Promise((resolve, reject) => {
        req.login(user, {session: false}, err => {
            if (err) return reject(err)
            const token = jwt.sign({ email: user.email }, process.env.JWT_SECRET)

            return resolve({ token })
        })
    })
}

// error handler
app.use((err, req, res, next) => {
    if (process.env.NODE_ENV === 'development') {
        console.error(err)
    }

    if (err.statusCode) {
        res.status(err.statusCode).json({ error: err.message })
    } else {
        res.status(500).json({ error: `Unhandled error: ${err.toString()}` })
    }
})