/
nsp.js
67 lines (54 loc) · 1.86 KB
/
nsp.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
var async = require("async")
, request = require("request")
, metaMarked = require("meta-marked")
, github = require("./github")
var ghOpts = {user: "nodesecurity", repo: "nodesecurity-www", path: "advisories"}
var rawUrl = "https://raw.githubusercontent.com/nodesecurity/nodesecurity-www/master/advisories"
var advisories = {}
function getAdvisories () {
return advisories
}
module.exports.getAdvisories = getAdvisories
function updateAdvisories (cb) {
cb = cb || function (er) {
if (er) console.error("Failed to update advisories", er)
}
var gh = github.getInstance()
gh.repos.getContent(ghOpts, function (er, files) {
if (er) return cb(er)
var tasks = files.filter(function (a) {
return a.name != "template.md"
}).map(function (a) {
return function (cb) {
request.get(rawUrl + "/" + a.name, function (er, res, md) {
if (er || res.statusCode != 200) {
console.warn("Failed to update advisory", a.name, er)
return cb()
}
var meta = metaMarked(md).meta
meta.nsp_url = "https://nodesecurity.io/advisories/" + a.name.replace(/\.md$/, "")
cb(null, meta)
})
}
})
async.parallel(tasks, function (er, metas) {
if (er) return cb(er)
advisories = metas.reduce(function (advs, m) {
if (m) {
advs[m.module_name] = advs[m.module_name] || []
advs[m.module_name].push(m)
}
return advs
}, {})
cb(null, advisories)
})
})
}
module.exports.updateAdvisories = updateAdvisories
var advisoriesUpdateIntervalId = null
function updateAdvisoriesPeriodically (interval) {
clearInterval(advisoriesUpdateIntervalId)
interval = interval || 3600000
advisoriesUpdateIntervalId = setInterval(updateAdvisories, interval)
}
module.exports.updateAdvisoriesPeriodically = updateAdvisoriesPeriodically