await client.version()
chainHead = await client.chainHead()
currentHeight = chainHead.Height
headTipSet = chainHead.Cids
selectedHeight
tipSet = (await client.chainGetTipSetByHeight(selectedHeight, headTipSet)).Cids
totalPower = (await client.stateMinerPower('<empty>', tipSet)).TotalPower
async function* minerPowerStream() {
for (const { miner, annotation, longitude, latitude } of routableMiners) {
const minerPower = (await client.stateMinerPower(miner, tipSet)).MinerPower
yield {
miner,
annotation,
longitude,
latitude,
rawBytePower: Number(minerPower.RawBytePower),
qualityAdjPower: Number(minerPower.QualityAdjPower),
}
}
}
minerPowerStream()
minerPower = {
let records = []
for await (const record of minerPowerStream()) {
records.push(record)
records.sort(({qualityAdjPower: a}, {qualityAdjPower: b}) => b - a)
yield records
}
}
mapboxgl = require('mapbox-gl')
chinaViewState = ({
latitude: 28.908332885027765,
longitude: 113.50569520637455,
zoom: 3.326570932673526,
bearing: 6.120265859126128,
pitch: 52.01540376375816,
minZoom: 1,
maxZoom: 20
})
deckgl = {
return new deck.DeckGL({
container,
map: mapboxgl,
mapboxAccessToken: '',
// This token is for demo-purpose only and rotated regularly. Get your token at https://www.mapbox.com
mapboxApiAccessToken: 'pk.eyJ1IjoidWJlcmRhdGEiLCJhIjoiY2pudzRtaWloMDAzcTN2bzN1aXdxZHB5bSJ9.2bkj3IiRC8wj3jLThvDGdA',
mapStyle: 'mapbox://styles/mapbox/dark-v10', // https://docs.mapbox.com/api/maps/#styles
initialViewState: chinaViewState,
controller: true,
layers: [ hexagonLayer ]
});
}
async function *dataStream() {
let power = 0
let count = 0
let records = []
for await (const record of minerPowerStream()) {
if (record.qualityAdjPower > 0) {
power += record.qualityAdjPower
count++
records.push(record)
}
}
yield { height: selectedHeight, count, power: bytes(power, { mode: 'binary' }), records }
}
data = dataStream()
hexagonLayer = new deck.HexagonLayer({
id: 'miners',
extruded: true,
data: data.records,
radius: 50000,
getPosition: d => [d.longitude, d.latitude],
getElevationWeight: d => d.qualityAdjPower,
elevationAggregation: 'SUM',
elevationScale: 400,
opacity: 0.4
})
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')).testnet.fullNode
Object.keys(schema.methods)
endpointUrl = "wss://lotus.testground.ipfs.team/calibration_api/0/node/rpc/v0"
client = {
const provider = new BrowserProvider(endpointUrl)
return new LotusRPC(provider, { schema })
}
bytes = (await import('@jimpick/bytes-iec@3.1.0-2')).default
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.
