30:[] 2e:{"title":"Lotus RLE example","cells":[{"id":160,"value":"md`# Lotus RLE example`","pinned":false,"hidden":false,"mode":"ojs"},{"id":14,"value":"miner = 't08399'","pinned":true,"hidden":false,"mode":"ojs"},{"id":232,"value":"head = client.ChainGetTipSetByHeight(2880*51, null)","pinned":true,"hidden":false,"mode":"ojs"},{"id":183,"value":"md`## Option 1: RPC API`","pinned":false,"hidden":false,"mode":"ojs"},{"id":195,"value":"partitions = (await client.StateMinerPartitions(miner, 0, head.Cids))","pinned":true,"hidden":false,"mode":"ojs"},{"id":199,"value":"partition0 = (await client.StateMinerPartitions(miner, 0, head.Cids))[0]","pinned":true,"hidden":false,"mode":"ojs"},{"id":220,"value":"decodeRLE3(partition0.AllSectors)","pinned":true,"hidden":false,"mode":"ojs"},{"id":251,"value":"decodeRLE3(partition0.ActiveSectors)","pinned":true,"hidden":false,"mode":"ojs"},{"id":188,"value":"md`## Option 2: Low level API`","pinned":false,"hidden":false,"mode":"ojs"},{"id":11,"value":"deadlines = (await client.chainGetNode(`${state}/1/@Ha:${miner}/1/12`)).Obj[0]","pinned":true,"hidden":false,"mode":"ojs"},{"id":30,"value":"partition = (await client.chainGetNode(deadlines[0]['/'])).Obj[0]","pinned":true,"hidden":false,"mode":"ojs"},{"id":225,"value":"(await client.chainGetNode(partition['/']))","pinned":true,"hidden":false,"mode":"ojs"},{"id":37,"value":"list = (await client.chainGetNode(partition['/'])).Obj[2][2]","pinned":true,"hidden":false,"mode":"ojs"},{"id":138,"value":"partitionSchema = ({\n Sectors: 'buffer',\n Unproven: 'buffer',\n Faults: 'buffer',\n Recoveries: 'buffer',\n Terminated: 'buffer',\n ExpirationEpochs: 'cid',\n EarlyTerminated: 'cid',\n LivePower: {\n a: 'bigint',\n b: 'bigint'\n },\n UnprovenPower: {\n a: 'bigint',\n b: 'bigint'\n },\n FaultyPower: {\n a: 'bigint',\n b: 'bigint'\n },\n RecoveringPower: {\n a: 'bigint',\n b: 'bigint'\n }\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":144,"value":"pObj = Fil.methods.decode(partitionSchema, list[0])","pinned":true,"hidden":false,"mode":"ojs"},{"id":148,"value":"decodeRLE2(pObj.Sectors)","pinned":true,"hidden":false,"mode":"ojs"},{"id":191,"value":"md`---`","pinned":false,"hidden":false,"mode":"ojs"},{"id":23,"value":"state = head.Blocks[0].ParentStateRoot['/']","pinned":false,"hidden":false,"mode":"ojs"},{"id":2,"value":"import {client, schema} from '@protocol/filecoin-playground'","pinned":false,"hidden":false,"mode":"ojs"},{"id":49,"value":"Object.keys(schema.methods).filter(d => d.includes('artitions'))","pinned":false,"hidden":false,"mode":"ojs"},{"id":128,"value":"function bytesToBig (p) {\n let acc = 0n\n for (let i = 0; i < p.length; i++) {\n acc *= 256n\n acc += window.BigInt(p[i])\n }\n return acc\n}\n","pinned":false,"hidden":false,"mode":"ojs"},{"id":130,"value":"BN = require('https://bundle.run/bn.js')","pinned":false,"hidden":false,"mode":"ojs"},{"id":134,"value":"function bytesToBigRev (p) {\n let acc = new BN(0)\n for (let i = 0; i < p.length; i++) {\n acc = acc.mul(new BN(256))\n acc = acc.add(new BN(p[p.length - i - 1]))\n }\n return acc\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":124,"value":"function nextBits (obj, n) {\n // if (obj.left < n) throw new Error(\"out of bits\")\n const res = obj.num.and(new BN(1).shln(n).sub(new BN(1)))\n obj.num = obj.num.shrn(n)\n obj.left -= n\n return res.toNumber()\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":122,"value":"function decodeRLE (buf) {\n const obj = {\n left: 8 * buf.length,\n num: bytesToBigRev(buf)\n }\n const version = nextBits(obj, 2)\n const first = nextBits(obj, 1)\n const res = []\n while (obj.left > 0) {\n let b1 = nextBits(obj, 1)\n if (b1 === 1) {\n res.push(1)\n continue\n }\n let b2 = nextBits(obj, 1)\n if (b2 === 1) {\n const a = nextBits(obj, 4)\n res.push(a)\n continue\n }\n let x = 0\n let s = 0\n for (let i = 0; true; i++) {\n if (i === 10) {\n throw new Error('run too long')\n }\n let b = nextBits(obj, 8)\n if (b < 0x80) {\n if (i > 9 || (i === 9 && b > 1)) {\n throw new Error('run too long')\n } else if (b === 0 && s > 0) {\n throw new Error('invalid run')\n }\n x |= b << s\n break\n }\n x |= (b & 0x7f) << s\n s += 7\n }\n res.push(x)\n }\n return { first, runs: res }\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":157,"value":"function decodeRLE3 (runs) {\n let cur = 0\n const res = []\n let acc = 0\n for (let r of runs) {\n for (let i = 0; i < r; i++) {\n if (cur === 1) res.push(acc)\n acc++\n }\n cur = 1 - cur\n }\n return res\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":120,"value":"function decodeRLE2 (buf) {\n const { first, runs } = decodeRLE(buf)\n let cur = first\n const res = []\n let acc = 0\n for (let r of runs) {\n for (let i = 0; i < r; i++) {\n if (cur === 1) res.push(acc)\n acc++\n }\n cur = 1 - cur\n }\n return res\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":136,"value":"Fil = require('https://bundle.run/js-hamt-filecoin@0.0.18')","pinned":false,"hidden":false,"mode":"ojs"}],"files":"$W30","stdlib":"1","titling":"auto"}