2b:null 2c:["$","title",null,{"children":"FVM Actor Code Playground - \"Bounties for Deals\" | Jim Pick | Observable"}] 31:T8d6,This demo shows how to implement a minimalist "bounty actor" that can be sent funds be awarded (in the future) to anybody that makes a deal that satisfies certain criteria. * YouTube: [FVM Foundry Update: Learning & Using FVM Actors with Fil-der Jim Pick](https://www.youtube.com/watch?v=jTtZh1zqUr8) This notebook does the following: * Generates 2 client-side addresses + secrets for ["Alice and Bob"](https://en.wikipedia.org/wiki/Alice_and_Bob) using [filecoin-js-signer](https://github.com/blitslabs/filecoin-js-signer). The secrets are stored in your browser, not on the Lotus node. * Sends starter funds from Lotus to each client address (100 FIL each) * Compiles, installs and creates the "bounty actor" * Has a method to "post a bounty" - a bounty consists of a "Payload CID", "Piece CID", a Miner ID, and a reward * Has a method to list bounties * Has a method to lookup bounties by Piece CID + Miner ID * Has a method to claim a bounty. In order to claim a bounty, the "Deal ID" from a published deal is sent to the actor as a param. If the "Piece CID" and the Miner ID match the deal, the client who posted the deal is sent the reward. The bounty is removed from the list of active bounties. * Alice generates files consisting of random phrases (plus padding, so they will fit in a 2K sector), and calculates the "Piece CID". * Alice can choose to post bounties for the phrases, specifying the criteria - a Piece CID matching the phrase, a Provider ID + an amount of funds (sent to the bounty actor) which will be the reward. This is a minimal implementation -- a more complex bounty system might include additional criteria, eg. deal length, proving periods, deal pricing limits, etc. * Bob retrieves the list of bounties. * Bob encodes a random word into a file and calculates the Piece CID. Bob then makes a deal for each file, and transfers the data to the provider. * A trusted "watcher" process watches for published deals. For each new deal, it calls the lookup method with the Piece CID and the Miner ID. If there is a bounty, it invokes the method to claim the bounty, sending the Client ID who made the deal, and the client gets paid the reward! * Based on https://observablehq.com/@jimpick/fvm-actor-code-playground-simple-faucet32:T492,## Step 1: Edit Actor Code - src/lib.rc Feel free to modify this actor code (written in Rust). Don't worry, you can't break anything. This is from [src/lib.rc](https://github.com/raulk/fil-hello-world-actor/blob/master/src/lib.rs) in @raulk's [fil-hello-world-actor](https://github.com/raulk/fil-hello-world-actor) example. We use some JavaScript in this notebook to patch this subset of the code into the original code with some modifications. GitHub Code Links + useful API Docs: * https://github.com/raulk/fil-hello-world-actor * https://github.com/raulk/fil-hello-world-actor/blob/master/src/blockstore.rs * https://github.com/raulk/fil-hello-world-actor/blob/master/Cargo.toml * https://docs.rs/fvm_sdk/0.6.1/fvm_sdk/ * https://docs.rs/fvm_shared/0.6.1/fvm_shared/ * https://docs.rs/fvm_ipld_encoding/0.2.0/fvm_ipld_encoding/ * https://docs.rs/fvm_ipld_hamt/0.5.1/fvm_ipld_hamt/ * https://docs.rs/cid/0.8.4/cid/ * https://github.com/Schwartz10/sample-erc20-fvm-actor/blob/primary/src/lib.rs * https://github.com/jimpick/fvm-ipld-hamt-playground/blob/bounties/src/main.rs * https://github.com/jimpick/fil-hello-world-actor/blob/jim-bounties/src/lib.rs 33:T4e7,{ if (installActorStatus === undefined || !installActorStatus) { yield md`Status: Latest actor code is compiled to WASM, but not installed yet.` return } if (installActorStatus.installing) { while (true) { const elapsed = (Date.now() - installActorStatus.start) / 1000 yield md`Sending install actor message... (${elapsed.toFixed(1)}s)` await Promises.delay(1000) } } if (installActorStatus.response) { while (true) { let output = `

Install actor message sent

Message CID: ${installActorStatus.response.CID['/']}

` if (installActorStatus.waitResponse) { output += `

Message executed in block at height: ${installActorStatus.waitResponse.Height}

` output += `

Gas used: ${installActorStatus.waitResponse.Receipt.GasUsed}

` output += `

Code CID: ${installActorStatus.waitResponse.ReturnDec.CodeCid['/']}

` yield html`${output}` break } const elapsed = (Date.now() - installActorStatus.waitStart) / 1000 output += `

Waiting for message to be executed in a block... (${elapsed.toFixed(1)}s)

` yield html`${output}` await Promises.delay(1000) } } }34:T57e,{ if (createActorStatus === undefined || !createActorStatus) { yield md`Status: Instance of latest installed actor has not been created yet.` return } if (createActorStatus.creating) { while (true) { const elapsed = (Date.now() - createActorStatus.start) / 1000 yield md`Sending create actor message... (${elapsed.toFixed(1)}s)` await Promises.delay(1000) } } if (createActorStatus.response) { while (true) { let output = `

Create actor message sent

Code CID (Param): ${createActorButton}

Message CID: ${createActorStatus.response.CID['/']}

` if (createActorStatus.waitResponse) { output += `

Message executed in block at height: ${createActorStatus.waitResponse.Height}

` output += `

Gas used: ${createActorStatus.waitResponse.Receipt.GasUsed}

` output += `

Robust Address: ${createActorStatus.waitResponse.ReturnDec.RobustAddress}

` output += `ID Address: ${createActorStatus.waitResponse.ReturnDec.IDAddress}
` yield html`${output}` break } const elapsed = (Date.now() - createActorStatus.waitStart) / 1000 output += `

Waiting for message to be executed in a block... (${elapsed.toFixed(1)}s)

` yield html`${output}` await Promises.delay(1000) } } }35:T43a,createActorStatus = { if (createActorButton) { console.log('Create actor') const start = Date.now() yield { creating: true, start } const codeCid = new CID(createActorButton) // Needs a zero byte in front const codeCidBytes = new Uint8Array(codeCid.bytes.length + 1) codeCidBytes.set(codeCid.bytes, 1) const trustedAddressBytes = filecoinAddress.newFromString(walletDefaultId).str const params = cbor.encode([new cbor.Tagged(42, codeCidBytes), trustedAddressBytes]) // Sending create actor message... const messageBody = { To: 't01', From: walletDefaultAddress, Value: "0", Method: 2, Params: params.toString('base64') } console.log('messageBody', messageBody) const response = await client.mpoolPushMessage(messageBody, null) console.log('Jim response', response) const waitStart = Date.now() yield { waiting: true, waitStart, response } const waitResponse = await client.stateWaitMsg(response.CID, 0) yield { installed: true, response, waitResponse } } }36:T622,{ if (postBountyStatus === undefined || !postBountyStatus) { yield md`Status: Method has not been invoked yet.` return } if (postBountyStatus.invoking) { while (true) { const elapsed = (Date.now() - postBountyStatus.start) / 1000 yield md`Sending message to actor for method 2... (${elapsed.toFixed(1)}s)` await Promises.delay(1000) } } if (postBountyStatus.response) { while (true) { let output = `

Message sent to actor

To: ${bountyActorId} (Bounty Actor)

Method: 2

Message CID: ${postBountyStatus.response.CID['/']}

` if (postBountyStatus.waitResponse) { output += `

Message executed in block at height: ${postBountyStatus.waitResponse.Height}

` output += `

Gas used: ${postBountyStatus.waitResponse.Receipt.GasUsed}

` output += `

Exit Code: ${postBountyStatus.waitResponse.Receipt.ExitCode}

` output += `

Return: ${postBountyStatus.waitResponse.Receipt.Return} (Base64 encoded CBOR)

` // output += `

Decoded Result: ${JSON.stringify(postBountyStatus.decodedResult)}

` yield html`${output}` mutable invalidatedAt = new Date() break } const elapsed = (Date.now() - postBountyStatus.waitStart) / 1000 output += `

Waiting for message to be executed in a block... (${elapsed.toFixed(1)}s)

` yield html`${output}` await Promises.delay(1000) } } }37:T681,postBountyStatus = { if (postBountyButton) { const start = Date.now() console.log('Post Bounty', postBountyButton) yield { invoking: true, start } const pieceCid = multiformats.CID.parse(postBountyButton.pieceCid) const pieceCidBytes = new Uint8Array(pieceCid.bytes.length + 1) pieceCidBytes.set(pieceCid.bytes, 1) const providerAddressBytes = filecoinAddress.newFromString(postBountyButton.providerAddress).str const message = { To: bountyActorAddress, From: postBountyButton.clientAddress, Nonce: 0, Value: (new FilecoinNumber(postBountyButton.amount, 'fil')).toAttoFil(), GasLimit: 1000000000, GasFeeCap: new FilecoinNumber(0, 'attofil'), GasPremium: new FilecoinNumber(0, 'attofil'), Method: 2, Params: cbor.encode([ new cbor.Tagged(42, pieceCidBytes), providerAddressBytes ]).toString('base64') } const privateKey = keys.find(({ address }) => address === postBountyButton.clientAddress).privateKey console.log('message', message) const responseCID = await filecoin_client.tx.sendMessage( message, privateKey, true, // updateMsgNonce false // waitMsg ) const waitStart = Date.now() yield { waiting: true, waitStart, response: { CID: responseCID } } const waitResponse = await client.stateWaitMsg(responseCID, 0) let decodedResult if (waitResponse.Receipt && waitResponse.Receipt.Return) { decodedResult = cbor.decodeAll(waitResponse.Receipt.Return, 'base64') } yield { invoked: true, response: { CID: responseCID }, waitResponse, decodedResult } } }38:T5e0,makeDealStatus = { if (makeDealButton) { const start = Date.now() console.log('Make deal', makeDealButton) const filename = pieceCidToFilenameMap.get(makeDealButton.piece_cid) yield { dealInProgress: true, filename, start } const importResponse = await client.clientImport({ Path: filename, IsCar: false }) yield { dealInProgress: true, filename, importResponse, start } const payloadCid = importResponse.Root['/'] const dataRef = { Data: { TransferType: 'graphsync', Root: { '/': payloadCid }, PieceCid: null, PieceSize: 0 }, Wallet: bobAddress, // Wallet: walletDefaultAddress, Miner: makeDealButton.address, EpochPrice: "1000", MinBlocksDuration: (200 * 24 * 60 * 60) / 15, FastRetrieval: true, VerifiedDeal: false } try { const dealResponse = await client.clientStartDeal(dataRef) yield { dealCompleted: true, dealResponse } mutable dealList.push({ timestamp: new Date(start), proposalCid: dealResponse['/'], payloadCid, ...makeDealButton }) } catch (e) { yield { dealCompleted: true, error: e } mutable dealList.push({ timestamp: new Date(start), payloadCid, ...makeDealButton, error: e.message }) } mutable dealList = mutable dealList } }39:T81d,serviceStatus = { let lastDealId for await (const deal of DealsStream()) { if (deal.marketActorState.State.NextID - 1 !== lastDealId) { const nextLastDealId = deal.marketActorState.State.NextID - 1 for (let dealId = lastDealId + 1; dealId <= nextLastDealId; dealId++) { const dealData = await client.stateMarketStorageDeal(dealId, []) mutable observedDealList.push([dealId, dealData]) mutable observedDealList = mutable observedDealList if ((viewof awardOptions.value).includes('Automatically award bounties')) { const pieceCid = dealData.Proposal.PieceCID['/'] const provider = dealData.Proposal.Provider const clientAddress = dealData.Proposal.Client const phrase = pieceCidToPhraseMap.get(pieceCid) if (phrase) { const lookupAmount = await lookupBounty(pieceCid, provider) console.log(`Lookup "${phrase}"`, pieceCid, provider, `${lookupAmount.toFil()} FIL`) if (lookupAmount.toFil() !== "0") { console.log('Awarding bounty', pieceCid, provider, clientAddress) const start = Date.now() const response = await awardBounty(pieceCid, provider, clientAddress) console.log('Bounty awarded, msg id:', response) mutable awardedBountyList.push({ timestamp: new Date(start), pieceCid: pieceCid, provider, payoutAddress: clientAddress, amount: lookupAmount }) mutable awardedBountyList = mutable awardedBountyList async function invalidateAfterWaitMsg () { await client.stateWaitMsg(response.CID, 0) mutable invalidatedAt = new Date() } invalidateAfterWaitMsg() } } else { console.log(`Couldn't find phrase for ${pieceCid}, skipping.`) } } } lastDealId = nextLastDealId } yield { lastDealId, ...deal } } }3a:T62f,{ if (awardBountyStatus === undefined || !awardBountyStatus) { yield md`Status: Method has not been invoked yet.` return } if (awardBountyStatus.invoking) { while (true) { const elapsed = (Date.now() - awardBountyStatus.start) / 1000 yield md`Sending message to actor for method... (${elapsed.toFixed(1)}s)` await Promises.delay(1000) } } if (awardBountyStatus.response) { while (true) { let output = `

Message sent to actor

To: ${bountyActorId} (Bounty Actor)

Method: 5

Message CID: ${awardBountyStatus.response.CID['/']}

` if (awardBountyStatus.waitResponse) { output += `

Message executed in block at height: ${awardBountyStatus.waitResponse.Height}

` output += `

Gas used: ${awardBountyStatus.waitResponse.Receipt.GasUsed}

` output += `

Exit Code: ${awardBountyStatus.waitResponse.Receipt.ExitCode}

` output += `

Return: ${awardBountyStatus.waitResponse.Receipt.Return} (Base64 encoded CBOR)

` // output += `

Decoded Result: ${JSON.stringify(postBountyStatus.decodedResult)}

` yield html`${output}` // mutable invalidatedAt = new Date() break } const elapsed = (Date.now() - awardBountyStatus.waitStart) / 1000 output += `

Waiting for message to be executed in a block... (${elapsed.toFixed(1)}s)

` yield html`${output}` await Promises.delay(1000) } } }3b:T1d1c,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 { let params = sdk::message::params_raw(params).unwrap().1; let trusted_address = Address::from_bytes(¶ms).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 = 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 { 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::::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 { let mut bounties_vec = Vec::new(); let state = State::load(); let bounties = match Hamt::::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 { 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::::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 { 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::::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(¶ms.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()3c:[] 2f:{"id":"fbbd646d74c5a70c","slug":"fvm-actor-code-playground-bounties-for-deals","title":"FVM Actor Code Playground - \"Bounties for Deals\"","thumbnail":"dc5bf8b47f66fda1ddf981e51ac1b88a6d1eaa4bbe319f11e227a9143b81b08e","access_level":"public","create_time":"$D2022-05-11T01:38:31.377Z","update_time":"$D2022-10-17T00:45:38.632Z","view_time":null,"first_public_time":"$D2022-06-03T01:04:27.251Z","fork":{"id":"5fc7ffd98209cd6a","slug":"fvm-actor-code-playground-simple-faucet","title":"FVM Actor Code Playground - \"Simple Faucet\"","owner":{"id":"5252cea433451319","login":"jimpick","name":"Jim Pick"}},"stars":1,"starred":false,"owner":{"type":"team","id":"5252cea433451319","login":"jimpick","name":"Jim Pick","avatar_url":"https://avatars-next.observableusercontent.com/e8813527082139d5411445010e72fd85f99b04a26355e795d0ea26765425d0cd","tier":"starter_2024"},"version":2222,"publish_version":null,"role":null,"authored":false,"authors":[{"type":"individual","id":"bda4505ba9a55ac8","login":"jimpick","name":"Jim Pick","avatar_url":"https://avatars-next.observableusercontent.com/e8813527082139d5411445010e72fd85f99b04a26355e795d0ea26765425d0cd","tier":null}],"members":[{"type":"individual","id":"bda4505ba9a55ac8","login":"jimpick","name":"Jim Pick","avatar_url":"https://avatars-next.observableusercontent.com/e8813527082139d5411445010e72fd85f99b04a26355e795d0ea26765425d0cd","tier":null,"role":"editor"}],"comments":[],"custom_thumbnail":false,"trashed":false,"subscribed":null,"forks":3,"collection":{"id":"f63e6c307ab87e8f","slug":"filecoin-virtual-machine","title":"Filecoin Virtual Machine","owner":{"id":"5252cea433451319","login":"jimpick","name":"Jim Pick"}},"type":"notebook","body":{"title":"FVM Actor Code Playground - \"Bounties for Deals\"","cells":[{"id":0,"value":"# FVM Actor Code Playground - \"Bounties for Deals\"","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":717,"value":"$31","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":154,"value":"**Note:** The on-demand localnet will be reclaimed after 3 minutes of inactivity. Modifications to the blockchain state are ephemeral -- good for testing! Staying on this page will keep it alive, but if you navigate away and then return, it may get restarted with fresh state. If that happens, reload the web page. There is one instance of the localnet shared between all users.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":777,"value":"## Generate Client Side Addresses","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1206,"value":"We use `filecoin-js-signer` to generate a random mnemomic phrase. You could save this phrase and re-use it to generate the secrets. In this notebook, we just use different secrets on each page reload.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":772,"value":"randomMnemonic = {\n // https://github.com/blitslabs/filecoin-js-signer#filecoin-signer\n const strength = 128 // 128 => 12 words | 256 => 24 words\n return filecoin_signer.wallet.generateMnemonic(strength)\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":782,"value":"keys = {\n const keys = []\n for (let i = 0; i < 2; i++) {\n const network = 'testnet'\n\n const key = await filecoin_signer.wallet.keyDerive(randomMnemonic, `m/44'/461'/0'/0/${i}`, network)\n key.name = i == 0 ? 'Alice' : 'Bob'\n keys.push(key)\n }\n return keys\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":864,"value":"clientAddresses = keys.map(key => key.address)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":792,"value":"## Wait for Lotus to be ready, then transfer 100 FIL to each address","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1210,"value":"Be patient as it takes a little while for the funds to be sent via the Lotus JSON-RPC API when the notebook is first loaded.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1768,"value":"ready ? md`Lotus ready.` : md `Lotus not ready yet, please wait (this may take up to 60 seconds).`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1167,"value":"{\n if (transferFundsStatus === undefined || !transferFundsStatus) {\n yield md``\n return\n }\n if (transferFundsStatus.transferring || transferFundsStatus.waiting) {\n while (true) {\n const elapsed = (Date.now() - transferFundsStatus.start) / 1000\n yield md`Transferring initial funds to client accounts... (${elapsed.toFixed(1)}s)`\n await Promises.delay(1000)\n }\n }\n if (transferFundsStatus.transferred) {\n yield md`**Funds transferred**!`\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":798,"value":"transferFundsStatus = {\n if (walletDefaultAddress && keys) {\n const start = Date.now()\n yield {\n transferring: true,\n start\n }\n const responses = []\n for (const key of keys) {\n // Sending install actor message...\n const messageBody = {\n To: key.address,\n From: walletDefaultAddress,\n Value: \"100000000000000000000\",\n Method: 0\n }\n responses.push(await client.mpoolPushMessage(messageBody, null))\n }\n const waitStart = Date.now()\n yield { waiting: true, start, waitStart, responses }\n const promises = []\n for (const response of responses) {\n promises.push(client.stateWaitMsg(response.CID, 0))\n }\n const waitResponses = await Promise.all(promises)\n const lookups = {}\n for (const key of keys) {\n lookups[key.address] = await client.stateLookupID(key.address, [])\n }\n yield { transferred: true, responses, waitResponses, lookups }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1310,"value":"aliceId = transferFundsStatus?.transferred && transferFundsStatus.lookups[keys.find(({ name }) => name === 'Alice').address]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1315,"value":"bobId = transferFundsStatus?.transferred && transferFundsStatus.lookups[keys.find(({ name }) => name === 'Bob').address]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":818,"value":"## Initial Balances","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1217,"value":"Here are the addresses and IDs of the 2 clients we created, as well at their initial balances (should be 1 FIL each).","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":808,"value":"initialBalances = !transferFundsStatus ? md`Waiting...` : transferFundsStatus.transferred && getBalances(clientAddresses)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":825,"value":"Inputs.table(\n initialBalances ? initialBalances.map(({ address, balance }) => ({\n name: keys.find(({ address: keyAddress }) => address === keyAddress).name, \n id: transferFundsStatus.lookups[address],\n address,\n balance\n })) : [],\n {\n format: {\n balance: num => new FilecoinNumber(num, 'attofil').toFil()\n }\n }\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1479,"value":"aliceAddress = transferFundsStatus?.transferred && Object.entries(transferFundsStatus.lookups).find(([ address, id ]) => id === aliceId)[0]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1489,"value":"bobAddress = transferFundsStatus?.transferred && Object.entries(transferFundsStatus.lookups).find(([ address, id ]) => id === bobId)[0]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":805,"value":"async function getBalances (addresses) {\n return Promise.all(\n addresses\n .map(async address => {\n const response = await client.stateGetActor(address, [])\n return {\n address: address,\n balance: response.Balance\n }\n })\n )\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1861,"value":"## Import Bob's Private Key into the Lotus wallet","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1863,"value":"Bob is going to use the Lotus client to make deals and store files, so we need to import the private key there.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1865,"value":"bobKeyInfoImportResult = {\n if (!ready) return\n const privateKeyHex = keys.find(({ name }) => name === 'Bob').privateKey\n const privateKeyBytes = buffer.Buffer.from(privateKeyHex, 'hex')\n const privateKeyBase64 = privateKeyBytes.toString('base64')\n const keyInfoJson = { Type: \"secp256k1\", PrivateKey: privateKeyBase64 }\n // const keyInfoEncoded = buffer.Buffer.from(JSON.stringify(keyInfoJson)).toString('hex')\n const result = await client.walletImport(keyInfoJson)\n return result\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2082,"value":"## Transfer 1 FIL to Bob's Market Balance","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2084,"value":"This enables making deals faster if there is already a \"market\" balance.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2086,"value":"{\n if (!bobAddress) return\n const start = Date.now()\n yield {\n transferring: true,\n start\n }\n const response = await client.marketAddBalance(bobAddress, bobAddress, \"1000000000000000000\")\n const waitStart = Date.now()\n yield { waiting: true, start, waitStart, response }\n const waitResponse = await client.stateWaitMsg(response, 0)\n yield { transferred: true, response, waitResponse }\n mutable invalidatedAt = new Date()\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":243,"value":"$32","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":4,"value":"viewof editor = {\n const {EditorState, EditorView, basicSetup} = await skypack('@codemirror/next/basic-setup')\n const {rust} = await skypack('@codemirror/next/lang-rust')\n \n const updateViewOf = EditorView.updateListener.of((update) => {\n const {dom} = update.view\n dom.value = update\n dom.dispatchEvent(new CustomEvent('input'))\n })\n\n const initialCode = stateObjectCode + `\\n\\n// -- cut --\\n\\n` + methodsCode \n \n const view = new EditorView({\n state: EditorState.create({\n doc: initialCode,\n extensions: [basicSetup, rust(), updateViewOf]\n })\n })\n \n return view.dom\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":593,"value":"If you have changed the code and would like to save it for future use, you can use this button to save it to a file.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1418,"value":"combinedCode = () => {\n const codeChunks = editor.state.doc.toString().split('// -- cut --').map(chunk => chunk.trim())\n return templateStart.replace('%%stateObjectCode%%', codeChunks[0]) + '\\n' + codeChunks[1]\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1421,"value":"// combinedCode()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":589,"value":"html`Optional: ${button(combinedCode(), `lib.rs`)}`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":597,"value":"**Pro-tip:** *You can also \"fork\" this notebook and use the saved file as an attachment.*","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":222,"value":"## Step 2: Compile\n\nWe have implemented a [simple web service](https://github.com/jimpick/lotus-fvm-localnet-web/blob/main/server.mjs) that accepts a HTTP POST with the code above, and returns a compiled WASM binary (wrapped in a CBOR array, encoded in base64, ready to pass as a 'params' string). The code above is substituted for `src/lib.rs` into the [raulk/fil-hello-world-actor](https://github.com/raulk/fil-hello-world-actor) example and built using `cargo build`. It should compile in less than 70 seconds.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":178,"value":"viewof compileToWasmButton = Inputs.button('Compile to WASM', {value: null, reduce: () => combinedCode()})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":385,"value":"{\n if (compileStatus === undefined || !compileStatus) {\n yield md`Status: Code is ready to upload to the compiling service. Not compiled yet.`\n return\n }\n if (compileStatus.compiling) {\n while (true) {\n const elapsed = (Date.now() - compileStatus.start) / 1000\n yield md`Compiling on remote server... (${elapsed.toFixed(1)}s)`\n await Promises.delay(1000)\n }\n }\n if (compileStatus.success) {\n yield html`

Successfully compiled!

Compile time: ${(compileStatus.elapsed / 1000).toFixed(1)}s\n

Compile log:

${stripAnsi(compileStatus.logs)}

`\n }\n if (compileStatus.error) {\n yield html`

**Error!**

Compile log:

${stripAnsi(compileStatus.error)}

`\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":617,"value":"compileStatus && compileStatus.wasmBinary ? md`Optional: You can download the compiled WASM bundle here. (Not needed if you are just using it from this notebook)` : md``","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":606,"value":"compileStatus && compileStatus.wasmBinary ? html`Optional: ${button(compileStatus.wasmBinary, 'fil_bounties_actor.wasm')}` : md``","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":365,"value":"compileStatus = {\n if (compileToWasmButton) {\n const start = Date.now()\n yield {\n compiling: true,\n start\n }\n try {\n const response = await fetch(`${baseUrl}/compile`, {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json'\n },\n body: JSON.stringify({\n 'lib.rs': compileToWasmButton,\n 'Cargo.toml': patchedCargoToml\n })\n })\n const results = await response.json()\n results.elapsed = Date.now() - start\n if (results.success) {\n results.wasmBinary = cbor.decode(results.wasmBinaryParamsEncoded, 'base64')\n }\n yield results\n } catch (e) {\n yield {\n error: e.message\n }\n }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":216,"value":"## Step 3: Connect to Hosted \"localnet\"\n\nThis notebook connects to a [hosted instance](https://github.com/jimpick/lotus-fvm-localnet-web) of a Lotus \"localnet\" (started on demand) into which you can install the actor code, create an actor instance, and invoke methods against.\n\nIf the localnet is started and online, the following chain height should be increasing every 4-10 seconds (depending on system load):","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":251,"value":"md`**Height: ${currentHeight}**`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":255,"value":"If the connection is working, then proceed to the next step.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":230,"value":"## Step 4: Install the Actor Code","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":497,"value":"Before the actor code can be executed, it must be loaded into the Filecoin blockchain state.\n\n# 💾\n\nIf you are old enough to remember, imagine this step as inserting the [floppy disk](https://en.wikipedia.org/wiki/Floppy_disk) into the Filecoin global computer's floppy drive!\n\nAt the command line, this is the same as: `lotus chain install-actor `","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":180,"value":"viewof installActorButton = Inputs.button('Install Actor Code', {\n disabled: !compileStatus || !compileStatus.wasmBinaryParamsEncoded,\n value: null,\n reduce: () => compileStatus.wasmBinaryParamsEncoded\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":468,"value":"$33","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":369,"value":"installActorStatus = {\n if (installActorButton) {\n console.log('Install actor')\n const start = Date.now()\n yield {\n installing: true,\n start\n }\n // Sending install actor message...\n const messageBody = {\n To: 't01',\n From: walletDefaultAddress,\n Value: \"0\",\n Method: 3,\n Params: compileStatus.wasmBinaryParamsEncoded\n }\n const response = await client.mpoolPushMessage(messageBody, null)\n const waitStart = Date.now()\n yield { waiting: true, waitStart, response }\n const waitResponse = await client.stateWaitMsg(response.CID, 0)\n yield { installed: true, response, waitResponse }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":234,"value":"## Step 5: Create an Actor Instance for the Bounty Actor","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":655,"value":"If you have completed the previous step, you will have a \"Code CID\" for the WASM bundle you just installed. Now we can create an actor instance. It is possible to create lots and lots of actors using the same code, each will get assigned a unique \"ID Address\" (eg. t01001) to which messages and funds can be sent, as well as an equivalent \"Robust Address\" alias (eg. \"t2...\") which maps on the same address (but doesn't change in the event of a chain re-organization).","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":492,"value":"At the command line, this is the same as: `lotus chain create-actor `","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2048,"value":"We pass in a 'trusted address' (the Lotus default wallet address) as a parameter. This is used for security ... only a service calling methods from the trusted address can call the `award_bounty()` method to award bounties to clients that have stored data.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":184,"value":"viewof createActorButton = Inputs.button('Create Actor', {\n disabled: !installActorStatus ||\n !installActorStatus.waitResponse ||\n !installActorStatus.waitResponse.ReturnDec ||\n !installActorStatus.waitResponse.ReturnDec.CodeCid,\n value: null,\n reduce: () => installActorStatus.waitResponse.ReturnDec.CodeCid['/']\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":548,"value":"$34","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":485,"value":"$35","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1613,"value":"bountyActorId = createActorStatus?.waitResponse?.ReturnDec?.IDAddress","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1615,"value":"bountyActorAddress = createActorStatus?.waitResponse?.ReturnDec?.RobustAddress","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":841,"value":"## Step 6: Generate Random Phrases and Piece CIDs (aka. CommP)","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1599,"value":"Here we generate a list of random phrases - this is the raw file data that will be used to create storage deals. We're just using short strings here because we are limited to under 2K in a sector with the localnet.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1336,"value":"phrases = {\n const phrases = []\n for (let i = 0; i < 10; i++) {\n phrases.push(randomPhrase())\n }\n return phrases\n \n function getRandom (max) {\n return Math.floor(Math.random() * Math.floor(max))\n }\n \n function randomPhrase () {\n const adjective = protocolWords.adjectives[getRandom(protocolWords.adjectives.length)]\n const noun = protocolWords.nouns[getRandom(protocolWords.nouns.length)]\n return `${adjective} ${noun}`\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1341,"value":"phraseUploads = {\n const uploadPromises = []\n for (const phrase of phrases) {\n uploadPromises.push((async () => {\n try {\n const response = await fetch(`${baseUrl}/upload`, {\n method: 'POST',\n headers: {\n 'Content-Type': 'binary/octet-stream'\n },\n body: phrase +\n '\\n' + ' '.repeat(120) + '\\n' // padding\n })\n const uploadResults = await response.json()\n const inputFile = uploadResults.filename\n const carFile = uploadResults.filename + '.car'\n await client.clientGenCar(\n {Path: inputFile, IsCar: false},\n carFile\n )\n const calcCommP = await client.clientCalcCommP(carFile)\n return {\n filename: inputFile,\n calcCommP\n }\n } catch (e) {\n return { error: e }\n }\n })())\n }\n return Promise.all(uploadPromises)\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1382,"value":"Inputs.table(\n phrases.map((phrase, i) => ({ phrase, pieceCid: phraseUploads[i].calcCommP.Root['/'] })),\n { width: { phrase: 200 } }\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1656,"value":"pieceCidToPhraseMap = {\n const pieceCidToPhraseMap = new Map()\n phrases.forEach((phrase, i) => {\n pieceCidToPhraseMap.set(phraseUploads[i].calcCommP.Root['/'], phrase)\n })\n return pieceCidToPhraseMap\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1696,"value":"pieceCidToFilenameMap = {\n const pieceCidToFilenameMap = new Map()\n phrases.forEach((phrase, i) => {\n pieceCidToFilenameMap.set(phraseUploads[i].calcCommP.Root['/'], phraseUploads[i].filename)\n })\n return pieceCidToFilenameMap\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":238,"value":"## Step 7: Alice Posts Some Bounties","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":666,"value":"Now that we've got an actor running with an ID Address, alice can call the method to post a bounty. Pretend that you are Alice, and select a piece of data (a \"phrase\" that has a matching Piece CID), a provider ID (aka miner) that you want the data to be stored on, and an amount you will send to the bounty actor to act as a \"reward\" for whoever makes a deal to store the data.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":671,"value":"At the command line, this is the same as: `lotus chain invoke

`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":889,"value":"viewof postBountyForm = providerIds && phrases && Inputs.form([\n Inputs.select(\n phrases.map((phrase, i) => ({\n phrase,\n pieceCid: phraseUploads[i].calcCommP.Root['/']\n })),\n {\n label: 'Desired Data',\n format: x => `\"${x.phrase}\" CID: ${x.pieceCid.slice(0, 4)}...${x.pieceCid.slice(-4)}`\n }\n ),\n Inputs.select(providerIds, { label: \"Desired Provider\" }),\n Inputs.range([0, 10], {value: 1, step: 1, label: 'Amount for Reward'})\n])","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":901,"value":"viewof postBountyButton = Inputs.button('Post Bounty', {\n disabled: !createActorStatus ||\n !createActorStatus.waitResponse ||\n !createActorStatus.waitResponse.ReturnDec ||\n !createActorStatus.waitResponse.ReturnDec.IDAddress,\n value: null,\n reduce: () => ({\n pieceCid: postBountyForm[0].pieceCid,\n providerAddress: postBountyForm[1],\n amount: postBountyForm[2],\n clientAddress: aliceAddress\n })\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":678,"value":"$36","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1137,"value":"**Balances:**","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1664,"value":"After Alice posts a bounty, the Bounty Actor's balance should increase, and Alice's bounty should decrease by the amount of the bounty + gas fees.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2141,"value":"balancesTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1162,"value":"Inputs.button(\"Update\", { value: null, reduce: () => { mutable invalidatedAt = new Date() } })","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1151,"value":"balancesTable = async () => {\n invalidatedAt;\n if (!postBountyStatus || !postBountyStatus.invoked) {\n return md``\n }\n const balances = await getBalances([bountyActorAddress].concat(clientAddresses))\n \n return Inputs.table(\n balances.map(({ address, balance }) => ({\n name: address === bountyActorAddress ? 'Bounty Actor' : keys.find(({ address: keyAddress }) => address === keyAddress).name,\n id: address === bountyActorAddress ? bountyActorId :\n transferFundsStatus.lookups[address],\n address,\n balance\n })),\n {\n format: {\n balance: num => new FilecoinNumber(num, 'attofil').toFil()\n }\n }\n )\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":572,"value":"$37","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1549,"value":"## Step 8: List the available bounties","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1670,"value":"Here are all the unclaimed bounties that Alice has posted. Anybody can claim these by making a deal to store data with the same Piece CID at the Storage Provider address specified.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2135,"value":"availableBountiesTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1646,"value":"availableBountiesTable = () => Inputs.table(\n bounties,\n {\n columns: [ 'phrase', 'piece_cid', 'address', 'amount' ],\n format: {\n piece_cid: cid => `${cid.slice(0,4)}..${cid.slice(-4)}`\n },\n width: { phrase: 200 },\n sort: 'amount',\n reverse: true\n }\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1610,"value":"bountiesCall = {\n invalidatedAt;\n const messageBody = {\n To: bountyActorId,\n From: walletDefaultAddress,\n Value: \"0\",\n Method: 3,\n Params: null\n }\n return client.StateCall(messageBody, [])\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1630,"value":"bounties = {\n if (!bountiesCall?.MsgRct?.Return) return\n const result = cbor.decode(bountiesCall.MsgRct.Return, 'base64')\n const mappedResult = result.map(({ piece_cid, address, amount }) => {\n const cid = multiformats.CID.decode(piece_cid.value.slice(1)).toString()\n const decodedAddress = filecoinAddress.newAddress(address[0], address.slice(1), 't').toString()\n const decodedAmount = new filecoinNumber.FilecoinNumber(bytesToBig(amount).toString(), 'attofil')\n const phrase = pieceCidToPhraseMap.get(cid)\n return { piece_cid: cid, phrase, address: decodedAddress, amount: decodedAmount }\n })\n return mappedResult\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1552,"value":"## Step 9: Bob stores a file with a provider (and wins bounties)","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1678,"value":"Bob can take the list of bounties, and make deals to store files on Storage Providers so he can claim the bounties.\n\nWhen the deals are accepted by the Storage Providers and published to the chain, the off-chain service will see the deals, and award the bounty amount to whichever client made the deal.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1681,"value":"viewof selectedBounty = Inputs.select(\n bounties.sort((a, b) => b.amount - a.amount),\n {\n label: 'Select a bounty',\n format: x => `\"${x.phrase}\" => ${x.address} (${x.amount} FIL)`\n }\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1687,"value":"viewof makeDealButton = Inputs.button('Make a deal', {\n disabled: !selectedBounty,\n value: null,\n reduce: () => selectedBounty\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1828,"value":"Here is the list of deals + deal statuses. **Note:** The Lotus client in the localnet build seems to be a bit slow/buggy, so the deal statuses and deal IDs sometimes don't get updated right away even though the deal has been published. The service that watches all deals (below) will see when the deals are published.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1734,"value":"Inputs.table(\n dealList.map(deal => {\n const newDeal = {...deal}\n const watchedDeal = watchDeals.find(watched => watched.ProposalCid['/'] === deal.proposalCid)\n if (watchedDeal) {\n newDeal.status = watchedDeal.Status\n newDeal.deal_id = watchedDeal.DealID\n }\n return newDeal\n }),\n {\n columns: [ 'timestamp', 'phrase', 'address', 'status', 'deal_id' ],\n format: {\n timestamp: date => date.toISOString().slice(11, 19),\n proposalCid: cid => `${cid.slice(0,4)}..${cid.slice(-4)}`,\n payloadCid: cid => `${cid.slice(0,4)}..${cid.slice(-4)}`,\n piece_cid: cid => `${cid.slice(0,4)}..${cid.slice(-4)}`\n },\n width: {\n status: 250\n },\n sort: 'timestamp'\n }\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1690,"value":"makeDealButton","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1713,"value":"mutable dealList = []","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1694,"value":"$38","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1788,"value":"watchDeals = {\n const statusCodes = new Map()\n while (true) {\n if (dealList.length > 0) {\n const listDeals = await client.clientListDeals()\n for (const deal of listDeals) {\n if (statusCodes.has(deal.State)) {\n deal.Status = statusCodes.get(deal.State)\n } else {\n const status = await client.clientGetDealStatus(deal.State)\n statusCodes.set(deal.State, status)\n deal.Status = status\n }\n }\n yield listDeals\n }\n await Promises.delay(4000)\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1558,"value":"## Off-chain service to watch deals and award bounties","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1741,"value":"Because the bounty actor has no access to the state of the Markets system actor which tracks the on-chain deal status, and it doesn't currently expose useful methods we can call to check deals, we need to implement an external off-chain service that watches for deals, and if it sees a deal that satisfies a bounty, it will call a method on the deal to award the bounty to the client that made the deal.\n\nThe award method needs to be restricted so that only the deal monitoring service can call it, otherwise anybody could steal the funds.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1891,"value":"The miners in the localnet have been configured to publish the deals quickly. On mainnet, there is typically an hour delay or more before deals are published so providers can reduce their gas usage.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1857,"value":"Here is a list of the deals observed by the service:","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1831,"value":"Inputs.table(\n observedDealList.flatMap(([dealId, data]) => {\n const pieceCid = data.Proposal.PieceCID['/']\n const phrase = pieceCidToPhraseMap.get(pieceCid)\n if (!phrase) {\n return []\n }\n return [{\n dealId,\n client: data.Proposal.Client,\n provider: data.Proposal.Provider,\n pieceCid,\n phrase\n }]\n }),\n {\n format: {\n pieceCid: cid => `${cid.slice(0,4)}..${cid.slice(-4)}`\n },\n sort: \"dealId\"\n }\n)\n","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2012,"value":"If the following checkbox is checked, the service will automatically payout bounties to the client that performed any new matching deals.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1906,"value":"viewof awardOptions = Inputs.checkbox(['Automatically award bounties'], { value: ['Automatically award bounties'] })","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2005,"value":"Here is a list of the bounties that have been awarded, based on observed deals, or manually awarded (below):","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2168,"value":"awardedBountyListTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2058,"value":"awardedBountyListTable = () => Inputs.table(\n awardedBountyList.map(bounty => ({...bounty, phrase: pieceCidToPhraseMap.get(bounty.pieceCid)})),\n {\n format: {\n pieceCid: cid => `${cid.slice(0,4)}..${cid.slice(-4)}`,\n payoutAddress: address => address.length > 8 ? `${address.slice(0,4)}..${address.slice(-4)}` : address\n },\n sort: 'timestamp'\n }\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2007,"value":"mutable awardedBountyList = []","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1782,"value":"mutable observedDealList = []","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1747,"value":"async function *DealsStream () {\n for await (const height of heightStream()) {\n const marketActorState = await client.stateReadState('t05', [])\n yield { height, marketActorState }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1749,"value":"$39","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1987,"value":"async function lookupBounty (pieceCidString, address) {\n const pieceCid = multiformats.CID.parse(pieceCidString)\n const pieceCidBytes = new Uint8Array(pieceCid.bytes.length + 1)\n pieceCidBytes.set(pieceCid.bytes, 1)\n\n const providerAddressBytes = filecoinAddress.newFromString(address).str\n \n const messageBody = {\n To: bountyActorId,\n From: walletDefaultAddress,\n Value: \"0\",\n Method: 4,\n Params: cbor.encode([\n new cbor.Tagged(42, pieceCidBytes),\n providerAddressBytes \n ]).toString('base64')\n }\n console.log('Lookup bounty', messageBody)\n const response = await client.StateCall(messageBody, [])\n\n if (!response?.MsgRct?.Return) return response\n const amountBytes = cbor.decode(response.MsgRct.Return, 'base64').amount\n const decodedAmount = new filecoinNumber.FilecoinNumber(bytesToBig(amountBytes).toString(), 'attofil')\n return decodedAmount\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1915,"value":"## Extra Tool: Manually lookup bounty","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1919,"value":"viewof lookupBountySelection = Inputs.select(\n bounties.sort((a, b) => b.amount - a.amount),\n {\n label: 'Select a bounty',\n format: x => `\"${x.phrase}\" => ${x.address} (${x.amount} FIL)`\n }\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1924,"value":"viewof lookupBountyButton = Inputs.button('Lookup Bounty', {\n disabled: !lookupBountySelection,\n value: null,\n reduce: () => lookupBountySelection\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1941,"value":"lookup = {\n if (!lookupBountyButton) return md``\n // return lookupBountyButton\n\n const decodedAmount = await lookupBounty(lookupBountyButton.piece_cid, lookupBountyButton.address)\n return md `**Lookup results:** Piece CID \"${lookupBountyButton.piece_cid.slice(0, 4)}..${lookupBountyButton.piece_cid.slice(-4)}\" on ${lookupBountyButton.address} => ${decodedAmount.toFil()} FIL`\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1995,"value":"## Extra Tool: Manually award bounty","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1997,"value":"The service above should automatically award bounties. If the automatic mode is turned off, or a deal hasn't been published yet, you can use this tool to manually award bounties (paid out to the \"Bob\" actor).","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":1999,"value":"viewof awardBountySelection = Inputs.select(\n bounties.sort((a, b) => b.amount - a.amount),\n {\n label: 'Select a bounty',\n format: x => `\"${x.phrase}\" => ${x.address} (${x.amount} FIL)`\n }\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2002,"value":"viewof awardBountyButton = Inputs.button('Manually award bounty', {\n disabled: !awardBountySelection,\n value: null,\n reduce: () => awardBountySelection\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2148,"value":"$3a","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2120,"value":"After awarding the bounty, the bounty will be deleted from the list of bounties, and the balance of the Bounty Actor will decrease, and the balance of the account receiving the payout will increase by the amount of the bounty.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2109,"value":"Awarded bounties:","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2106,"value":"awardedBountyListTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2129,"value":"Available bounties:","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2131,"value":"availableBountiesTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2124,"value":"Balances:","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2126,"value":"balancesTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2020,"value":"awardBountyStatus = {\n if (awardBountyButton) {\n const start = Date.now()\n console.log('Award Bounty', awardBountyButton)\n yield {\n invoking: true,\n start\n }\n\n const response = await awardBounty(awardBountyButton.piece_cid, awardBountyButton.address, bobId)\n\n const waitStart = Date.now()\n yield { waiting: true, waitStart, response }\n const waitResponse = await client.stateWaitMsg(response.CID, 0)\n let decodedResult\n if (waitResponse.Receipt && waitResponse.Receipt.Return) {\n decodedResult = cbor.decodeAll(waitResponse.Receipt.Return, 'base64')\n }\n yield { invoked: true, response, waitResponse, decodedResult }\n mutable awardedBountyList.push({\n timestamp: new Date(start),\n pieceCid: awardBountyButton.piece_cid,\n provider: awardBountyButton.address,\n payoutAddress: bobAddress,\n amount: awardBountyButton.amount\n })\n mutable awardedBountyList = mutable awardedBountyList\n mutable invalidatedAt = new Date()\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2111,"value":"async function awardBounty (pieceCidString, providerAddress, payoutAddress) {\n const pieceCid = multiformats.CID.parse(pieceCidString)\n const pieceCidBytes = new Uint8Array(pieceCid.bytes.length + 1)\n pieceCidBytes.set(pieceCid.bytes, 1)\n\n const providerAddressBytes = filecoinAddress.newFromString(providerAddress).str\n const payoutAddressBytes = filecoinAddress.newFromString(payoutAddress).str\n\n const messageBody = {\n To: bountyActorAddress,\n From: walletDefaultAddress,\n Value: \"0\",\n Method: 5,\n Params: cbor.encode([\n new cbor.Tagged(42, pieceCidBytes),\n providerAddressBytes,\n payoutAddressBytes,\n ]).toString('base64')\n }\n console.log('Award bounty message', messageBody)\n const response = await client.mpoolPushMessage(messageBody, null)\n return response\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1133,"value":"## Serialize/Deserialize Filecoin Bigints","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":950,"value":"new FilecoinNumber('5', 'attofil')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":956,"value":"cbor.encode([new FilecoinNumber('5', 'attofil')]).toString('base64')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1013,"value":"function bigToBytes(num) {\n // https://github.com/Zondax/filecoin-signing-tools/blob/5a126fa599695dac720c692cb286a8c572187f88/signer-npm/js/src/index.js#L54\n // https://github.com/spacegap/spacegap.github.io/blob/ccfa30a3e5303c4538c59f3a23186882eddf810e/src/services/filecoin/index.js#L145\n\n if (num === '0' || num === 0) {\n return new Uint8Array(0)\n }\n const numBigInt = (typeof num === 'object') ? (new BN(num.toAttoFil(), 10)) : (new BN(num, 10))\n const numArray = numBigInt.toArrayLike(Array, 'be', numBigInt.byteLength())\n if (numBigInt.isNeg()) {\n numArray.unshift(1)\n } else {\n numArray.unshift(0)\n }\n return new Uint8Array(numArray)\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1026,"value":"bigToBytes(-1234)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1040,"value":"bigToBytes(1234)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1068,"value":"bigToBytes(new FilecoinNumber(1234, 'attofil'))","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1080,"value":"({ x: 1 }).toString()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1042,"value":"bigToBytes(\"1234\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1044,"value":"bigToBytes(\"12345678901234567890\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1049,"value":"bigToBytes(12345678901234567890n)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1018,"value":"function bytesToBig (p) { // https://github.com/spacegap/spacegap.github.io/blob/ccfa30a3e5303c4538c59f3a23186882eddf810e/src/services/filecoin/index.js#L145\n let sign = p[0]\n let acc = new BN(0)\n for (let i = 1; i < p.length; i++) {\n acc = acc.mul(new BN(256))\n acc = acc.add(new BN(p[i]))\n }\n if (sign === 1) {\n return -acc\n } else if (sign === 0) {\n return acc\n } else {\n throw new Error('Unexpected value for first byte, expected 0 or 1 for sign')\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1058,"value":"bytesToBig(bigToBytes(12345678901234567890n)).toString()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1064,"value":"bytesToBig(bigToBytes(-1234)).toString()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":693,"value":"# Final notes","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":695,"value":"Thank you for trying out this demo.\n\nIf the backend is not working, please get in touch with me. Feel free to fork this notebook to customize your own actors and build scenarios using the on-demand localnet that supports this early version of actors / smart contracts.\n\nI can also deploy custom instances of the localnet and the API for compiling actors ... feel free to contact me at @jimpick on the Filecoin Slack.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":150,"value":"## Imports","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":50,"value":"skypack = (library) => import(`https://cdn.skypack.dev/${library}?min`)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":198,"value":"LotusRPC = (await import('@filecoin-shipyard/lotus-client-rpc')).LotusRPC","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":205,"value":"BrowserProvider = (await import('@filecoin-shipyard/lotus-client-provider-browser')).BrowserProvider","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":211,"value":"schema = (await import('@filecoin-shipyard/lotus-client-schema')).mainnet.fullNode","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":402,"value":"stripAnsi = (await import('https://unpkg.com/strip-ansi@7.0.1/index.js?module')).default","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":501,"value":"cbor = import('https://cdn.skypack.dev/pin/borc@v3.0.0-uvbwT4SVvOaMhkLqIBOF/mode=imports,min/optimized/borc.js')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":503,"value":"CID = (await import('https://jspm.dev/cids')).default","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":584,"value":"import {button} from '@jimpick/download-data-button-with-wasm-support'","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":752,"value":"filecoinJsSigner = import('https://jspm.dev/@blitslabs/filecoin-js-signer')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":767,"value":"FilecoinClient = filecoinJsSigner.FilecoinClient","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":770,"value":"FilecoinSigner = filecoinJsSigner.FilecoinSigner","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":785,"value":"filecoin_signer = new FilecoinSigner()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":815,"value":"filecoinNumber = import('https://cdn.skypack.dev/pin/@glif/filecoin-number@v2.0.0-beta.0-iQnBkhznGjB3HsyiyYB8/mode=imports,min/optimized/@glif/filecoin-number.js')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":835,"value":"FilecoinNumber = filecoinNumber.FilecoinNumber","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1021,"value":"BN = require('https://bundle.run/bn.js@5.2.0')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1330,"value":"protocolWords = import('https://cdn.skypack.dev/protocol-words@0.0.7?min')","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1500,"value":"filecoinAddress = import('https://cdn.skypack.dev/pin/@glif/filecoin-address@v2.0.0-beta.3-EOQV1pNtsg3BOYA74Vst/mode=imports,min/optimized/@glif/filecoin-address.js')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1513,"value":"multiformats = import('https://cdn.skypack.dev/pin/multiformats@v9.6.5-93rn6JH3zqEZdoz77NBu/mode=imports,min/optimized/multiformats.js')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1874,"value":"buffer = require('https://bundle.run/buffer@6.0.3')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":721,"value":"## Boilerplate Code","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":171,"value":"initialCodeUrl = `https://raw.githubusercontent.com/raulk/fil-hello-world-actor/1b8aaab57ca82d296c041752b364c6685d57e84d/src/lib.rs`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":730,"value":"initialCode = (await fetch(initialCodeUrl)).text()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1409,"value":"stateObjectCode = `\n#[derive(Serialize, Deserialize, Debug)]\npub struct BountyKey {\n pub piece_cid: Cid,\n pub address: Address,\n}\n\n#[derive(Serialize, Deserialize, PartialEq, Debug)]\npub struct BountyValue {\n #[serde(with = \"bigint_ser\")]\n pub amount: TokenAmount,\n}\n\n/// The state object.\n#[derive(Serialize_tuple, Deserialize_tuple, Clone, Debug)]\npub struct State {\n pub trusted_address: Address,\n pub bounties_map: Cid,\n}\n`.trim()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":725,"value":"$3b","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":733,"value":"templateStart = {\n const code = initialCode\n .replace('pub fn invoke(_: u32)', 'pub fn invoke(params: u32)')\n .replace('constructor()', 'constructor(params)')\n .replace('say_hello()', 'post_bounty(params)')\n .replace(/\\/\\/\\/ The state object.[^}]*}/s, '%%stateObjectCode%%')\n .replace(/\\/\\/\\/ The constructor populates the initial state.*/s, '')\n .split('\\n')\n\n const insertAt = code.findIndex(line => line.match(/post_bounty/)) + 1\n code.splice(\n insertAt, 0,\n ' 3 => list_bounties(),',\n ' 4 => lookup_bounty(params),',\n ' 5 => award_bounty(params),', \n )\n code.splice(\n 10, 0,\n 'use serde::{Serialize, Deserialize};',\n 'use fvm_shared::METHOD_SEND;',\n 'use fvm_shared::address::Address;',\n 'use fvm_shared::bigint::bigint_ser;',\n 'use fvm_shared::econ::TokenAmount;',\n 'use fvm_ipld_hamt::{BytesKey, Hamt};',\n )\n return code.join('\\n')\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1185,"value":"initialCargoTomlUrl = 'https://raw.githubusercontent.com/raulk/fil-hello-world-actor/c0ea4bde7da49c6d5b0d3ba01d592f553dd9589c/Cargo.toml'","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1189,"value":"initialCargoToml = (await fetch(initialCargoTomlUrl)).text()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1191,"value":"patchedCargoToml = {\n function gitVersion (version) {\n const rev = '297a7694'\n return `{ version = \"${version}\", git = \"https://github.com/filecoin-project/ref-fvm\", rev = \"${rev}\" }`\n }\n const replaced = initialCargoToml\n .replace(/fvm_sdk = .*/, `fvm_sdk = ${gitVersion('0.6.1')}`)\n .replace(/fvm_shared = .*/, `fvm_shared = ${gitVersion('0.6.1')}`)\n .replace(/fvm_ipld_blockstore = .*/, `fvm_ipld_blockstore = ${gitVersion('0.1.0')}`)\n .replace(/fvm_ipld_encoding = .*/, `fvm_ipld_encoding = ${gitVersion('0.2.0')}`)\n const lines = replaced.split('\\n')\n const insertAt = lines.findIndex(line => line.match(/dev-dependencies/)) - 1\n lines.splice(\n insertAt, 0,\n `fvm_ipld_hamt = ${gitVersion('0.5.1')}`,\n )\n return lines.join('\\n')\n} ","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":270,"value":"## Lotus Utilities","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":373,"value":"baseUrl = \"https://fvm-2.default.knative.hex.camp\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":355,"value":"token = (await fetch(`${baseUrl}/public/token`)).text()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":209,"value":"client = {\n const provider = new BrowserProvider(`${baseUrl}/rpc/v0`, { token })\n return new LotusRPC(provider, { schema })\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":914,"value":"filecoin_client = new FilecoinClient(`${baseUrl}/rpc/v0`, token)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":303,"value":"async function *heightStream () {\n let last\n while (true) {\n try {\n const newHeight = (await client.chainHead()).Height\n if (newHeight !== last) {\n yield newHeight\n last = newHeight\n }\n } catch (e) {\n yield 0\n }\n await Promises.delay(4000)\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":328,"value":"mutable ready = false","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1573,"value":"mutable invalidatedAt = new Date()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1459,"value":"providerIds = ready && (await client.stateListMiners([])).sort(sortMiners)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1463,"value":"sortMiners = (a, b) => Number(a.slice(1)) - Number(b.slice(1))","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":312,"value":"async function *heightReadyTapStream () {\n let lastReady = false\n let enoughProviders = false\n for await (const height of heightStream()) {\n const newReady = height > 7\n if (newReady && !enoughProviders) {\n const providerIds = await client.stateListMiners([])\n enoughProviders = providerIds.length >= 3\n }\n if (enoughProviders && newReady !== lastReady) {\n mutable ready = newReady\n lastReady = newReady\n }\n yield height\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":308,"value":"currentHeight = heightReadyTapStream()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":353,"value":"walletDefaultAddress = ready && client.walletDefaultAddress()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2050,"value":"walletDefaultId = walletDefaultAddress && client.stateLookupID(walletDefaultAddress, [])","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2186,"value":"## Backups","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":2188,"value":"import {backups, backupNowButton} from '@jimpick/provider-quest-utils'","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2217,"value":"backups()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":2220,"value":"backupNowButton()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"}],"files":"$W3c","stdlib":"1","titling":"auto"}} 30:"$2f:body"