The avatar for @jimpick
Jim Pick
Freelance Filecoin developer in Victoria, Canada
Public
Filecoin Virtual Machine
Edited
Oct 17, 2022
Fork of FVM Actor Code Playground - "Simple Faucet"
1 star
Filecoin Virtual Machine
FVM Actor Code Playground - "Hello World"FVM Actor Code Playground - SimpleCoin EVM ContractFVM Actor Code Playground - ERC20 Sans EventsFVM Actor Code Playground - ERC20 Sans Events - Hyperspace TestnetFVM Actor Code Playground - ERC20 Sans Events - Wallaby TestnetFVM Actor Code Playground - "Simple Faucet"FVM Actor Code Playground - "List Miners" Investigation
FVM Actor Code Playground - "Bounties for Deals"
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
// combinedCode()
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
bounties = {
if (!bountiesCall?.MsgRct?.Return) return
const result = cbor.decode(bountiesCall.MsgRct.Return, 'base64')
const mappedResult = result.map(({ piece_cid, address, amount }) => {
const cid = multiformats.CID.decode(piece_cid.value.slice(1)).toString()
const decodedAddress = filecoinAddress.newAddress(address[0], address.slice(1), 't').toString()
const decodedAmount = new filecoinNumber.FilecoinNumber(bytesToBig(amount).toString(), 'attofil')
const phrase = pieceCidToPhraseMap.get(cid)
return { piece_cid: cid, phrase, address: decodedAddress, amount: decodedAmount }
})
return mappedResult
}
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
new FilecoinNumber('5', 'attofil')
Insert cell
cbor.encode([new FilecoinNumber('5', 'attofil')]).toString('base64')
Insert cell
function bigToBytes(num) {
// https://github.com/Zondax/filecoin-signing-tools/blob/5a126fa599695dac720c692cb286a8c572187f88/signer-npm/js/src/index.js#L54
// https://github.com/spacegap/spacegap.github.io/blob/ccfa30a3e5303c4538c59f3a23186882eddf810e/src/services/filecoin/index.js#L145

if (num === '0' || num === 0) {
return new Uint8Array(0)
}
const numBigInt = (typeof num === 'object') ? (new BN(num.toAttoFil(), 10)) : (new BN(num, 10))
const numArray = numBigInt.toArrayLike(Array, 'be', numBigInt.byteLength())
if (numBigInt.isNeg()) {
numArray.unshift(1)
} else {
numArray.unshift(0)
}
return new Uint8Array(numArray)
}
Insert cell
bigToBytes(-1234)
Insert cell
bigToBytes(1234)
Insert cell
bigToBytes(new FilecoinNumber(1234, 'attofil'))
Insert cell
({ x: 1 }).toString()
Insert cell
bigToBytes("1234")
Insert cell
bigToBytes("12345678901234567890")
Insert cell
bigToBytes(12345678901234567890n)
Insert cell
function bytesToBig (p) { // https://github.com/spacegap/spacegap.github.io/blob/ccfa30a3e5303c4538c59f3a23186882eddf810e/src/services/filecoin/index.js#L145
let sign = p[0]
let acc = new BN(0)
for (let i = 1; i < p.length; i++) {
acc = acc.mul(new BN(256))
acc = acc.add(new BN(p[i]))
}
if (sign === 1) {
return -acc
} else if (sign === 0) {
return acc
} else {
throw new Error('Unexpected value for first byte, expected 0 or 1 for sign')
}
}
Insert cell
bytesToBig(bigToBytes(12345678901234567890n)).toString()
Insert cell
bytesToBig(bigToBytes(-1234)).toString()
Insert cell
Insert cell
Insert cell
Insert cell
skypack = (library) => import(`https://cdn.skypack.dev/${library}?min`)
Insert cell
LotusRPC = (await import('@filecoin-shipyard/lotus-client-rpc')).LotusRPC
Insert cell
BrowserProvider = (await import('@filecoin-shipyard/lotus-client-provider-browser')).BrowserProvider
Insert cell
schema = (await import('@filecoin-shipyard/lotus-client-schema')).mainnet.fullNode
Insert cell
stripAnsi = (await import('https://unpkg.com/strip-ansi@7.0.1/index.js?module')).default
Insert cell
cbor = import('https://cdn.skypack.dev/pin/borc@v3.0.0-uvbwT4SVvOaMhkLqIBOF/mode=imports,min/optimized/borc.js')
Insert cell
CID = (await import('https://jspm.dev/cids')).default
Insert cell
import {button} from '@jimpick/download-data-button-with-wasm-support'
Insert cell
filecoinJsSigner = import('https://jspm.dev/@blitslabs/filecoin-js-signer')
Insert cell
FilecoinClient = filecoinJsSigner.FilecoinClient
Insert cell
FilecoinSigner = filecoinJsSigner.FilecoinSigner
Insert cell
Insert cell
filecoinNumber = import('https://cdn.skypack.dev/pin/@glif/filecoin-number@v2.0.0-beta.0-iQnBkhznGjB3HsyiyYB8/mode=imports,min/optimized/@glif/filecoin-number.js')
Insert cell
FilecoinNumber = filecoinNumber.FilecoinNumber
Insert cell
BN = require('https://bundle.run/bn.js@5.2.0')
Insert cell
Insert cell
filecoinAddress = import('https://cdn.skypack.dev/pin/@glif/filecoin-address@v2.0.0-beta.3-EOQV1pNtsg3BOYA74Vst/mode=imports,min/optimized/@glif/filecoin-address.js')
Insert cell
multiformats = import('https://cdn.skypack.dev/pin/multiformats@v9.6.5-93rn6JH3zqEZdoz77NBu/mode=imports,min/optimized/multiformats.js')
Insert cell
buffer = require('https://bundle.run/buffer@6.0.3')
Insert cell
Insert cell
Insert cell
initialCode = (await fetch(initialCodeUrl)).text()
Insert cell
stateObjectCode = `
#[derive(Serialize, Deserialize, Debug)]
pub struct BountyKey {
pub piece_cid: Cid,
pub address: Address,
}

#[derive(Serialize, Deserialize, PartialEq, Debug)]
pub struct BountyValue {
#[serde(with = "bigint_ser")]
pub amount: TokenAmount,
}

/// The state object.
#[derive(Serialize_tuple, Deserialize_tuple, Clone, Debug)]
pub struct State {
pub trusted_address: Address,
pub bounties_map: Cid,
}
`.trim()
Insert cell
methodsCode = `
/// The constructor populates the initial state.
///
/// Method num 1. This is part of the Filecoin calling convention.
/// InitActor#Exec will call the constructor on method_num = 1.
pub fn constructor(params: u32) -> Option<RawBytes> {
let params = sdk::message::params_raw(params).unwrap().1;
let trusted_address = Address::from_bytes(&params).unwrap();

// This constant should be part of the SDK.
const INIT_ACTOR_ADDR: ActorID = 1;

// Should add SDK sugar to perform ACL checks more succinctly.
// i.e. the equivalent of the validate_* builtin-actors runtime methods.
// https://github.com/filecoin-project/builtin-actors/blob/master/actors/runtime/src/runtime/fvm.rs#L110-L146
if sdk::message::caller() != INIT_ACTOR_ADDR {
abort!(USR_FORBIDDEN, "constructor invoked by non-init actor");
}

let mut state = State {
trusted_address,
bounties_map: Cid::default(),
};
let mut bounties: Hamt<Blockstore, BountyValue, BytesKey> = Hamt::new(Blockstore);
let bounties_cid = match bounties.flush() {
Ok(map) => map,
Err(_e) => abort!(USR_ILLEGAL_STATE, "failed to create bounties hamt"),
};
state.bounties_map = bounties_cid;
state.save();
None
}

#[derive(Debug, Deserialize_tuple)]
pub struct PostBountyParams {
pub piece_cid: Cid,
pub address: Address,
}

/// Method num 2.
pub fn post_bounty(params: u32) -> Option<RawBytes> {
let params = sdk::message::params_raw(params).unwrap().1;
let params = RawBytes::new(params);
let params: PostBountyParams = params.deserialize().unwrap();

let mut state = State::load();

let mut bounties =
match Hamt::<Blockstore, BountyValue, BytesKey>::load(&state.bounties_map, Blockstore) {
Ok(map) => map,
Err(err) => abort!(USR_ILLEGAL_STATE, "failed to load bounties hamt: {:?}", err),
};

let key = BountyKey {
piece_cid: params.piece_cid,
address: params.address,
};
let raw_bytes = RawBytes::serialize(&key).unwrap();
let bytes = raw_bytes.bytes();
let key = BytesKey::from(bytes);

let mut amount = match bounties.get(&key) {
Ok(Some(bounty_value)) => bounty_value.amount.clone(),
Ok(None) => TokenAmount::from(0),
Err(err) => abort!(
USR_ILLEGAL_STATE,
"failed to query hamt when getting bounty balance: {:?}",
err
),
};
amount += sdk::message::value_received();

if amount > TokenAmount::from(0) {
let bounty_value = BountyValue { amount: amount };
bounties.set(key, bounty_value).unwrap();

// Flush the HAMT to generate the new root CID to update the actor's state.
let cid = match bounties.flush() {
Ok(cid) => cid,
Err(err) => abort!(USR_ILLEGAL_STATE, "failed to flush hamt: {:?}", err),
};

// Update the actor's state.
state.bounties_map = cid;
state.save();
}

None
}

#[derive(Debug, Serialize)]
pub struct PostedBounty {
pub piece_cid: Cid,
pub address: Address,
#[serde(with = "bigint_ser")]
pub amount: TokenAmount,
}

/// Method num 3.
pub fn list_bounties() -> Option<RawBytes> {
let mut bounties_vec = Vec::new();

let state = State::load();
let bounties =
match Hamt::<Blockstore, BountyValue, BytesKey>::load(&state.bounties_map, Blockstore) {
Ok(map) => map,
Err(err) => abort!(USR_ILLEGAL_STATE, "failed to load bounties hamt: {:?}", err),
};
bounties
.for_each(|k, v: &BountyValue| {
let raw_bytes = RawBytes::new(k.as_slice().to_vec());
let key: BountyKey = raw_bytes.deserialize().unwrap();
let posted_bounty = PostedBounty {
piece_cid: key.piece_cid,
address: key.address,
amount: v.amount.clone(),
};
bounties_vec.push(posted_bounty);
Ok(())
})
.unwrap();

Some(RawBytes::serialize(&bounties_vec).unwrap())
}

/// Method num 4.
pub fn lookup_bounty(params: u32) -> Option<RawBytes> {
let params = sdk::message::params_raw(params).unwrap().1;
let params = RawBytes::new(params);
let params: PostBountyParams = params.deserialize().unwrap();

let state = State::load();
let bounties =
match Hamt::<Blockstore, BountyValue, BytesKey>::load(&state.bounties_map, Blockstore) {
Ok(map) => map,
Err(err) => abort!(USR_ILLEGAL_STATE, "failed to load bounties hamt: {:?}", err),
};

let key = BountyKey {
piece_cid: params.piece_cid,
address: params.address,
};
let raw_bytes = RawBytes::serialize(&key).unwrap();
let bytes = raw_bytes.bytes();
let key = BytesKey::from(bytes);
let amount = match bounties.get(&key) {
Ok(Some(bounty_value)) => bounty_value.amount.clone(),
Ok(None) => TokenAmount::from(0),
Err(err) => abort!(
USR_ILLEGAL_STATE,
"failed to query hamt when getting bounty balance: {:?}",
err
),
};
let bounty_value = BountyValue { amount: amount };
Some(RawBytes::serialize(&bounty_value).unwrap())
}

#[derive(Debug, Deserialize_tuple)]
pub struct AwardBountyParams {
pub piece_cid: Cid,
pub address: Address,
pub payout_address: Address,
}

/// Method num 5.
pub fn award_bounty(params: u32) -> Option<RawBytes> {
let params = sdk::message::params_raw(params).unwrap().1;
let params = RawBytes::new(params);
let params: AwardBountyParams = params.deserialize().unwrap();

let mut state = State::load();

let caller = sdk::message::caller();
let address = Address::new_id(caller);
if state.trusted_address != address.clone() {
abort!(
USR_FORBIDDEN,
"caller not trusted {:?} != {:?} (trusted)",
address,
&state.trusted_address
);
}

let mut bounties =
match Hamt::<Blockstore, BountyValue, BytesKey>::load(&state.bounties_map, Blockstore) {
Ok(map) => map,
Err(err) => abort!(USR_ILLEGAL_STATE, "failed to load bounties hamt: {:?}", err),
};

let key = BountyKey {
piece_cid: params.piece_cid,
address: params.address,
};
let raw_bytes = RawBytes::serialize(&key).unwrap();
let bytes = raw_bytes.bytes();
let key = BytesKey::from(bytes);

let amount = match bounties.get(&key) {
Ok(Some(bounty_value)) => bounty_value.amount.clone(),
Ok(None) => TokenAmount::from(0),
Err(err) => abort!(
USR_ILLEGAL_STATE,
"failed to query hamt when getting bounty balance: {:?}",
err
),
};

if amount > TokenAmount::from(0) {
let send_params = RawBytes::default();
let _receipt =
fvm_sdk::send::send(&params.payout_address, METHOD_SEND, send_params, amount).unwrap();

bounties.delete(&key).unwrap();

// Flush the HAMT to generate the new root CID to update the actor's state.
let cid = match bounties.flush() {
Ok(cid) => cid,
Err(err) => abort!(USR_ILLEGAL_STATE, "failed to flush hamt: {:?}", err),
};

// Update the actor's state.
state.bounties_map = cid;
state.save();
}

None
}
`.trim()
Insert cell
templateStart = {
const code = initialCode
.replace('pub fn invoke(_: u32)', 'pub fn invoke(params: u32)')
.replace('constructor()', 'constructor(params)')
.replace('say_hello()', 'post_bounty(params)')
.replace(/\/\/\/ The state object.[^}]*}/s, '%%stateObjectCode%%')
.replace(/\/\/\/ The constructor populates the initial state.*/s, '')
.split('\n')

const insertAt = code.findIndex(line => line.match(/post_bounty/)) + 1
code.splice(
insertAt, 0,
' 3 => list_bounties(),',
' 4 => lookup_bounty(params),',
' 5 => award_bounty(params),',
)
code.splice(
10, 0,
'use serde::{Serialize, Deserialize};',
'use fvm_shared::METHOD_SEND;',
'use fvm_shared::address::Address;',
'use fvm_shared::bigint::bigint_ser;',
'use fvm_shared::econ::TokenAmount;',
'use fvm_ipld_hamt::{BytesKey, Hamt};',
)
return code.join('\n')
}
Insert cell
Insert cell
initialCargoToml = (await fetch(initialCargoTomlUrl)).text()
Insert cell
patchedCargoToml = {
function gitVersion (version) {
const rev = '297a7694'
return `{ version = "${version}", git = "https://github.com/filecoin-project/ref-fvm", rev = "${rev}" }`
}
const replaced = initialCargoToml
.replace(/fvm_sdk = .*/, `fvm_sdk = ${gitVersion('0.6.1')}`)
.replace(/fvm_shared = .*/, `fvm_shared = ${gitVersion('0.6.1')}`)
.replace(/fvm_ipld_blockstore = .*/, `fvm_ipld_blockstore = ${gitVersion('0.1.0')}`)
.replace(/fvm_ipld_encoding = .*/, `fvm_ipld_encoding = ${gitVersion('0.2.0')}`)
const lines = replaced.split('\n')
const insertAt = lines.findIndex(line => line.match(/dev-dependencies/)) - 1
lines.splice(
insertAt, 0,
`fvm_ipld_hamt = ${gitVersion('0.5.1')}`,
)
return lines.join('\n')
}
Insert cell
Insert cell
Insert cell
Insert cell
client = {
const provider = new BrowserProvider(`${baseUrl}/rpc/v0`, { token })
return new LotusRPC(provider, { schema })
}
Insert cell
filecoin_client = new FilecoinClient(`${baseUrl}/rpc/v0`, token)
Insert cell
async function *heightStream () {
let last
while (true) {
try {
const newHeight = (await client.chainHead()).Height
if (newHeight !== last) {
yield newHeight
last = newHeight
}
} catch (e) {
yield 0
}
await Promises.delay(4000)
}
}
Insert cell
mutable ready = false
Insert cell
mutable invalidatedAt = new Date()
Insert cell
providerIds = ready && (await client.stateListMiners([])).sort(sortMiners)
Insert cell
sortMiners = (a, b) => Number(a.slice(1)) - Number(b.slice(1))
Insert cell
async function *heightReadyTapStream () {
let lastReady = false
let enoughProviders = false
for await (const height of heightStream()) {
const newReady = height > 7
if (newReady && !enoughProviders) {
const providerIds = await client.stateListMiners([])
enoughProviders = providerIds.length >= 3
}
if (enoughProviders && newReady !== lastReady) {
mutable ready = newReady
lastReady = newReady
}
yield height
}
}
Insert cell
currentHeight = heightReadyTapStream()
Insert cell
walletDefaultAddress = ready && client.walletDefaultAddress()
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell

One platform to build and deploy the best data apps

Experiment and prototype by building visualizations in live JavaScript notebooks. Collaborate with your team and decide which concepts to build out.
Use Observable Framework to build data apps locally. Use data loaders to build in any language or library, including Python, SQL, and R.
Seamlessly deploy to Observable. Test before you ship, use automatic deploy-on-commit, and ensure your projects are always up-to-date.
Learn more