credData = {
if (!credGraph) return;
const intervals = credGraph
.intervals()
.map(i => new Date(i.startTimeMs).toDateString())
.reverse();
return Array.from(credGraph.participants())
.map(p => {
const result = {
id: p.id,
name: p.description,
totalCred: p.cred
};
p.credPerInterval
.reverse()
.forEach((c, i) => (result[intervals[i]] = c.toFixed(4)));
return result;
})
.sort((a, b) => b.totalCred - a.totalCred);
}
grainData = {
if (!ledger || !credGraph) return;
const intervals = credGraph
.intervals()
.map(i => new Date(i.endTimeMs).toDateString())
.reverse();
return ledger
.accounts()
.map(a => {
const result = {
id: a.identity.id,
name: a.identity.name,
totalGrainPaid: a.paid / 1000000000000000000
};
const gpi = _calculateGrainEarnedPerInterval(a, credGraph.intervals())
.reverse()
.forEach((g, i) => (result[intervals[i]] = g / 1000000000000000000));
return result;
})
.sort((a, b) => b.totalGrainPaid - a.totalGrainPaid);
}
_calculateGrainEarnedPerInterval = (account, intervals) => {
let allocationIndex = 0;
return intervals.map(interval => {
let grain = sc.ledger.grain.ZERO;
while (
account.allocationHistory.length - 1 >= allocationIndex &&
interval.startTimeMs <
account.allocationHistory[allocationIndex].credTimestampMs &&
account.allocationHistory[allocationIndex].credTimestampMs <=
interval.endTimeMs
) {
grain = sc.ledger.grain.add(
grain,
account.allocationHistory[allocationIndex].grainReceipt.amount
);
allocationIndex++;
}
return grain;
});
}
import { serialize } from "@palewire/saving-csv"
//failing due to missing CORS headers??
//weightedGraph = loadWeightedGraph(repoAndBranch);
credGraph = loadCredGraph(repoAndBranch)
ledger = loadLedger(repoAndBranch)
Purpose-built for displays of data
Observable is your go-to platform for exploring data and creating expressive data visualizations. Use reactive JavaScript notebooks for prototyping and a collaborative canvas for visual data exploration and dashboard creation.
