Koa cache server

cacheless-server.js

const koa = require('koa')
const Router = require('koa-router')
const request = require('request-promise')

const app = koa()

const router = new Router()

router.get('/', function *(next) {
	var body = yield request({
		uri: 'https://www.reddit.com/.json',
		json: true
	})

	this.body = body
})

router.get('/r/:subreddit', function *(next) {
	var body = yield request({
		uri: 'https://www.reddit.com/r/'+this.params.subreddit+'.json',
		json: true
	})

	this.body = body
})

app.use(router.routes())

app.listen(3000)

package.json

{
  "name": "koa-cache",
  "version": "1.0.0",
  "description": "",
  "main": "index.js",
  "scripts": {
    "test": "echo \"Error: no test specified\" && exit 1"
  },
  "author": "",
  "license": "ISC",
  "dependencies": {
    "bluebird": "^3.3.5",
    "koa": "^1.2.0",
    "koa-router": "^5.4.0",
    "redis": "^2.6.0-2",
    "request-promise": "^3.0.0"
  }
}

server.js

const koa = require('koa')
const Router = require('koa-router')
const request = require('request-promise')
const redis = require("redis")
const Bluebird = require('bluebird')

Bluebird.promisifyAll(redis.RedisClient.prototype);
Bluebird.promisifyAll(redis.Multi.prototype);

const app = koa()
const client = redis.createClient()

const router = new Router()

const timeToLive = 60
const cacheMiddleware = function *(next){
	var cacheBody = yield client.getAsync(this.request.path)
	if(cacheBody){
		console.log('Using cache body', this.request.path)
		return this.body = JSON.parse(cacheBody)
	}else{
		console.log('Requesting to reddit', this.request.path)
	}

	yield next
	
	client.setexAsync(this.request.path, timeToLive, JSON.stringify(this.body) )
}

router.get('/', cacheMiddleware, function *(next) {
	var body = yield request({
		uri: 'https://www.reddit.com/.json',
		json: true
	})

	this.body = body
})

router.get('/r/:subreddit', cacheMiddleware, function *(next) {
	var body = yield request({
		uri: 'https://www.reddit.com/r/'+this.params.subreddit+'.json',
		json: true
	})

	this.body = body
})

app.use(router.routes())

app.listen(3000)