-
Notifications
You must be signed in to change notification settings - Fork 0
/
cache.js
109 lines (93 loc) · 2.03 KB
/
cache.js
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
const Lru = require('lru-cache');
module.exports = function(app, options = {}) {
const { prefix = 'koa-cache:', expire = options.expire, maxLength = Infinity } = options
const globalCache = {
get: null,
set: null
}
const pageCache = new Lru({
maxAge: expire * 1000, // ms
max: maxLength,
})
app.context.cache = {
get: (key) => {
if (key) {
let value = pageCache.get(key)
if (value) {
value = value + ''
}
return value
}
},
set: (key, value) => {
if (!value || value === 'undefined') {
value = ''
}
if (typeof value === 'object') {
value = JSON.stringify(value)
}
if (key) {
return pageCache.set(key, value)
}
},
globalCache: globalCache
}
globalCache.get = (key) => {
if (key) {
return pageCache.get(key)
}
}
globalCache.set = (key, value) => {
if (!value || value === 'undefined') {
value = ''
}
if (typeof value === 'object') {
value = JSON.stringify(value)
}
if (key) {
return pageCache.set(key, value)
}
}
async function getCache(ctx, key) {
const value = await globalCache.get(key)
let ok = false
if (value) {
ctx.response.status = 200
ctx.response.set({
'X-Koa-Cache': 'true',
})
try {
ctx.state.data = JSON.parse(value)
} catch (e) {
ctx.state.data = {}
}
ok = true
}
return ok
}
async function setCache(ctx, key) {
if (ctx.response.get('Cache-Control') !== 'no-cache' && ctx.state && ctx.state.data) {
const body = JSON.stringify(ctx.state.data)
await globalCache.set(key, body)
}
}
return async function cache(ctx, next) {
const url = ctx.request.url
const key = prefix + url
let ok = false
try {
ok = await getCache(ctx, key)
} catch (e) {
ok = false
}
await next()
if (ok) {
return
}
try {
setCache(ctx, key)
} catch (e) {
//
}
}
}