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(',')
minTimestamp = dateFns.subDays(new Date(), 7)
recentMiners = {
const recentMinerSet = new Set()
for (const miner of Object.keys(minerPowerLatestReport.miners)) {
if (d3.isoParse(minerPowerLatestReport.miners[miner].timestamp) > minTimestamp) {
recentMinerSet.add(miner)
}
}
return [...recentMinerSet]
}
testMiner = 'f02620'
testMinerInfo = client.stateMinerInfo(testMiner, tipSetKey)
async function* minerInfoStream() {
const concurrency = 15
const callMinerInfoStream = transform(concurrency, async miner => {
try {
const minerInfo = (await client.stateMinerInfo(miner, tipSetKey))
let controlAddresses = minerInfo.ControlAddresses
let multiaddrs = minerInfo.Multiaddrs
let multiaddrsDecoded
if (multiaddrs) {
let decodedAddrs = []
for (const maddrBin of multiaddrs) {
try {
decodedAddrs.push(new Multiaddr(
Buffer.from(maddrBin, 'base64')
).toString())
} catch (e) {
console.error('Error decoding maddr', maddrBin, e)
}
}
if (decodedAddrs.length > 0) {
multiaddrsDecoded = decodedAddrs.sort()
}
multiaddrs.sort()
}
return {
miner,
owner: minerInfo.Owner,
worker: minerInfo.Worker,
newWorker: minerInfo.NewWorker,
controlAddresses,
workerChangeEpoch: minerInfo.workerChangeEpoch,
peerId: minerInfo.PeerId,
multiaddrs,
multiaddrsDecoded,
windowPoStProofType: minerInfo.WindowPoStProofType,
sectorSize: minerInfo.SectorSize,
windowPoStPartitionSectors: minerInfo.WindowPoStPartitionSectors,
consensusFaultElapsed: minerInfo.ConsensusFaultElapsed
}
} catch (e) {
console.error('Fetch error', e)
return {}
}
})
let counter = 0
let errors = 0
for await (const minerInfo of callMinerInfoStream(recentMiners)) {
if (minerInfo.miner) {
yield {
counter,
errors,
epoch: selectedEpoch,
...minerInfo
}
} else {
errors++
}
counter++
}
}
// minerInfoStream()
minerInfo = {
let records = []
let totalErrors = 0
const startTime = new Date()
for await (const {counter, errors, epoch, ...record} of minerInfoStream()) {
totalErrors = errors
if (epoch) {
records.push(record)
yield {
state: "streaming",
elapsed: ((new Date()) - startTime) / 1000,
recordsLength: records.length,
errors
}
}
}
const endTime = new Date()
yield {
state: "done",
elapsed: (endTime - startTime) / 1000,
records,
startTime,
endTime,
errors: totalErrors
}
}
minerInfo.state === 'done' && md`Miner | Sector Size | Peer ID | Control Addresses | Multiaddrs
---|---|---|---|---
${minerInfo.records.slice(0, maxRows).map(({ miner, sectorSize, peerId, controlAddresses, multiaddrs, multiaddrsDecoded }) => {
const controlCount = controlAddresses ? controlAddresses.length : ''
const multiaddrsFormatted = multiaddrs ? multiaddrsDecoded.join(' ') : ''
const peerIdFormatted = peerId ? peerId.slice(0, 10) + '...' + peerId.slice(-8) : ''
let lines = `${miner} | ${bytes(sectorSize, { mode: 'binary' })} | ${peerIdFormatted} | ${controlCount} | ${multiaddrsFormatted}\n`
return lines
})}
`
maxRows = 190
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 = {
return "wss://lotus.miner.report/mainnet_api/0/node/rpc/v0"
// return "https://api.node.glif.io/rpc/v0"
}
client = {
const provider = new BrowserProvider(endpointUrl)
return new LotusRPC(provider, { schema })
}
transform = (await import('streaming-iterables@7.1.0')).transform
import { epochToDate } from '@jbenet/filecoin-chain-time-calculator'
bytes = (await import('@jimpick/bytes-iec@3.1.0-2')).default
Multiaddr = (await require('https://bundle.run/multiaddr@9.0.1')).Multiaddr
Buffer = (await require('https://bundle.run/buffer@6.0.3')).Buffer
maddrBin = Buffer.from('BLaDBMMGf/g=', 'base64')
(new Multiaddr(maddrBin)).toString()
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.
