DOM.download(
serialize(processedRedemptions),
"redemptions.csv",
"Download Redemption Data"
)
DOM.download(
serialize(processedDistributions),
"distributions.csv",
"Download Distribution Data"
)
BN = await require('bignumber.js')
sc = await require("sourcecred@latest")
async function loadCredView(repo) {
const credResultFile = `https://raw.githubusercontent.com/${repo}/gh-pages/output/credResult.json`;
const credResultRaw = await (await fetch(credResultFile)).json()
const credResult = sc.analysis.credResult.fromJSON(credResultRaw)
const credView = new sc.analysis.credView.CredView(credResult)
return credView;
}
async function loadLedger(repo) {
const ledgerFile = `https://raw.githubusercontent.com/${repo}/gh-pages/data/ledger.json`;
const ledgerRaw = await (await fetch(ledgerFile)).text();
return sc.ledger.ledger.Ledger.parse(ledgerRaw);
}
ledger = loadLedger("sourcecred/cred")
G = sc.ledger.grain
transfers = {
const logs = ledger.eventLog();
return (
logs
//.filter(x => x.ledgerTimestamp < END_TS && x.ledgerTimestamp > START_TS)
.filter((x) => x.action.type === "TRANSFER_GRAIN")
);
}
redemptions = transfers.filter(
(x) =>
x.action.to === sourcecredId ||
(x.action.to === protocolId && x.action.from !== sourcecredId)
)
processedRedemptions = redemptions.map((x) => ({
timestamp: x.ledgerTimestamp,
date: new Date(x.ledgerTimestamp),
amount: G.format(x.action.amount, 2, ""),
redeemer: idToName.get(x.action.from),
buyer: idToName.get(x.action.to)
}))
distributions = {
const logs = ledger.eventLog();
return (
logs
//.filter(x => x.ledgerTimestamp < END_TS && x.ledgerTimestamp > START_TS)
.filter((x) => x.action.type === "DISTRIBUTE_GRAIN")
);
}
participantDistributions = {
const results = [];
for (const { action, ledgerTimestamp } of distributions) {
for (const { receipts } of action.distribution.allocations) {
for (const { id, amount } of receipts) {
if (amount === "0") continue;
results.push({ id, amount, ledgerTimestamp });
}
}
}
return results;
}
processedDistributions = participantDistributions.map((x) => ({
id: x.id,
name: idToName.get(x.id),
amount: G.format(x.amount, 2, ""),
date: new Date(x.ledgerTimestamp),
timestamp: x.ledgerTimestamp
}))
distributions[0].action.distribution
ledger.accounts()
participantList = ledger.accounts().map(a => a.identity.name)
nameToId = {
const m = new Map();
for (const { identity } of ledger.accounts()) {
m.set(identity.name, identity.id);
}
return m;
}
idToName = {
const m = new Map();
for (const { identity } of ledger.accounts()) {
m.set(identity.id, identity.name);
}
return m;
}
sourcecredId = nameToId.get("sourcecred")
protocolId = nameToId.get("protocol")
json2csv = require("json2csv")
function serialize (data) {
let parser = new json2csv.Parser();
let csv = parser.parse(data);
return new Blob([csv], {type: "text/csv"})
}
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.
