forked from Risk-DAO/bad-debt-leaderboard
-
Notifications
You must be signed in to change notification settings - Fork 1
/
badDebtCache.js
63 lines (53 loc) · 1.46 KB
/
badDebtCache.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
const {listJsonFiles, getJsonFile} = require('./s3Client')
const badDebtCache = {}
const badDebtSubJobsCache = {}
/**
* reads bad debt from disk or s3
* stores it in ram
*/
const init = async () => {
try{
// fetching from S3
const { Contents: fileNames } = await listJsonFiles()
for(obj of fileNames){
const file = await getJsonFile(obj.Key)
if(obj.Key.indexOf('subjob') === -1){
badDebtCache[obj.Key.replace('.json', '')] = JSON.parse(file.Body.toString())
} else {
const key = obj.Key.replace('.json', '').replace('subjob', '')
const platform = key.split('_')[1]
const platformSubJobs = badDebtSubJobsCache[platform] = badDebtSubJobsCache[platform] || {}
platformSubJobs[key] = JSON.parse(file.Body.toString())
}
}
console.log('badDebtCache done')
} catch (err) {
console.error(err)
process.exit(1)
}
}
const getBadDebtBy = (platform) => {
return badDebtCache[platform]
}
const getBadDebt = () => {
return badDebtCache
}
const getBadDebtSubJobsBy = (platform) => {
return badDebtSubJobsCache[platform]
}
const getBadDebtSubJobsByMarket = (market) => {
const [,platform,] = market.split('_')
const cached = badDebtSubJobsCache[platform] || {}
return cached[market]
}
const getBadDebtSubJobs = () => {
return badDebtSubJobsCache
}
module.exports = {
init,
getBadDebt,
getBadDebtBy,
getBadDebtSubJobsBy,
getBadDebtSubJobsByMarket,
getBadDebtSubJobs
}