await client.version()
chainHead = await client.chainHead()
viewof interactiveEpoch = html`<input type=range max=${currentEpoch} value=${currentEpoch - 1} style="width: 100%">`
selectedEpoch = {
// return 142500
return interactiveEpoch
}
selectedDate = epochToDate(selectedEpoch).toISOString()
tipSet = [...tipSetKey].map(obj => obj['/']).sort().join(',')
Type JavaScript, then Shift-Enter. Ctrl-space for more options. Arrow ↑/↓ to switch modes.
allMiners = await client.stateListMiners(tipSetKey)
totalPower = (await client.stateMinerPower('<empty>', tipSetKey)).TotalPower
import { annotatedMinerIndexes as trackedMiners } from '@jimpick/miner-report-feeds'
trackedMiners
miners = {
const temp = new Set(allMiners)
for (const miner of trackedMiners) {
temp.delete(miner)
}
return d3.shuffle([...temp])
}
async function* minerPowerStream() {
const concurrency = 15
const callMinerPowerStream = transform(concurrency, async miner => {
try {
const minerPower = (await client.stateMinerPower(miner, tipSetKey)).MinerPower
return {
miner,
rawBytePower: Number(minerPower.RawBytePower),
qualityAdjPower: Number(minerPower.QualityAdjPower)
}
} catch (e) {
console.error('StateMinerPower error', e)
return {}
}
})
let counter = 0
for await (const { miner, rawBytePower, qualityAdjPower } of callMinerPowerStream(miners)) {
if (rawBytePower || qualityAdjPower) {
yield {
counter,
epoch: selectedEpoch,
miner,
rawBytePower,
qualityAdjPower
}
} else if (counter % 100 === 0) {
yield {
counter
}
}
if (++counter > scanMax) {
yield {
counter
}
break
}
}
}
// minerPowerStream()
minerPower = {
let records = []
const startTime = new Date()
for await (const {counter, ...record} of minerPowerStream()) {
if (record.epoch) {
records.push(record)
}
yield {
state: "streaming",
counter,
elapsed: ((new Date()) - startTime) / 1000,
records
}
if (records.length >= maxRows) break
}
const endTime = new Date()
yield {
state: "done",
elapsed: (endTime - startTime) / 1000,
records,
startTime,
endTime,
}
}
md`Miner | Raw Byte Power | Quality Adjusted Power
---|---|---
${minerPower.records.sort((a, b) => b.qualityAdjPower - a.qualityAdjPower).slice(0, maxRows).map(({ miner, rawBytePower, qualityAdjPower }) => {
let lines = `${miner} | ${bytes(rawBytePower)} | ${bytes(qualityAdjPower)}\n`
return lines
})}
`
maxRows = 50
LotusRPC = (await import('@filecoin-shipyard/lotus-client-rpc')).LotusRPC
BrowserProvider = (await import('@filecoin-shipyard/lotus-client-provider-browser')).BrowserProvider
schema = (await import('@filecoin-shipyard/lotus-client-schema')).mainnet.fullNode
Object.keys(schema.methods)
endpointUrl = "https://api.node.glif.io/rpc/v0"
client = {
const provider = new BrowserProvider(endpointUrl)
return new LotusRPC(provider, { schema })
}
transform = (await import('streaming-iterables')).transform
import { epochToDate } from '@jbenet/filecoin-chain-time-calculator'
bytes = (await import('@jimpick/bytes-iec@3.1.0-2')).default
d3 = require("d3-array@2", "d3-random@2")
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.
