tokenbridge/oracle/scripts/compute-stats.js
Przemyslaw Rzad 40be5a5f8e
Extend line width to 120 (#174)
* Extend line width to 120

* Lint fixes
2019-08-01 15:10:22 +02:00

70 lines
2.3 KiB
JavaScript

const fs = require('fs')
const path = require('path')
const ndjson = require('ndjson')
const { mean, median, min, max } = require('simple-statistics')
const readFile = (...paths) => {
const a = []
const filename = path.join(...paths)
return new Promise(resolve => {
fs.createReadStream(filename)
.pipe(ndjson.parse())
.on('data', obj => a.push(obj))
.on('end', () => resolve(a))
})
}
function computeSignatureRequestStats(signatureRequests, senderHome) {
const processingLogs = signatureRequests.filter(x => x.eventTransactionHash)
const txSentMap = senderHome.filter(x => x.eventTransactionHash).reduce((acc, x) => {
acc[x.eventTransactionHash] = x
return acc
}, {})
const times = processingLogs.map(x => txSentMap[x.eventTransactionHash].time - x.time)
return {
count: times.length,
mean: mean(times),
median: median(times),
min: min(times),
max: max(times)
}
}
function computeCollectedSignaturesStats(collectedSignatures, senderForeign) {
const processingLogs = collectedSignatures.filter(x => x.eventTransactionHash)
const txSentMap = senderForeign.filter(x => x.eventTransactionHash).reduce((acc, x) => {
acc[x.eventTransactionHash] = x
return acc
}, {})
const times = processingLogs.map(x => txSentMap[x.eventTransactionHash].time - x.time)
return {
count: times.length,
mean: mean(times),
median: median(times),
min: min(times),
max: max(times)
}
}
async function main() {
const signatureRequests = await readFile(__dirname, '../logs/signature-request-watcher.txt')
const collectedSignatures = await readFile(__dirname, '../logs/collected-signatures-watcher.txt')
// const affirmationRequests = await readFile(__dirname, '../logs/affirmation-request-watcher.txt')
const senderHome = await readFile(__dirname, '../logs/home-sender.txt')
const senderForeign = await readFile(__dirname, '../logs/foreign-sender.txt')
const signatureRequestsStats = computeSignatureRequestStats(signatureRequests, senderHome)
console.log('Signature Requests')
console.log(signatureRequestsStats)
const collectedSignaturesStats = computeCollectedSignaturesStats(collectedSignatures, senderForeign)
console.log('Collected Signatures')
console.log(collectedSignaturesStats)
}
main().catch(console.error)