forest-filecoin 0.33.2

Rust Filecoin implementation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

// Copyright 2019-2026 ChainSafe Systems
// SPDX-License-Identifier: Apache-2.0, MIT

use crate::rpc::error::ServerError;
use crate::rpc::mpool::MpoolPushMessage;
use crate::rpc::{ApiPaths, Ctx, Permission, RpcMethod};
use crate::shim::{address::Address, message::Message, message::MethodNum};
use cid::Cid;
use enumflags2::BitFlags;
use fvm_ipld_blockstore::Blockstore;
use fvm_ipld_encoding::RawBytes;
use num_bigint::BigInt;

const METHOD_ADD_BALANCE: MethodNum = 2;

pub enum MarketAddBalance {}
impl RpcMethod<3> for MarketAddBalance {
    const NAME: &'static str = "Filecoin.MarketAddBalance";
    const PARAM_NAMES: [&'static str; 3] = ["wallet", "address", "amount"];
    const API_PATHS: BitFlags<ApiPaths> = ApiPaths::all();
    const PERMISSION: Permission = Permission::Sign;

    type Params = (Address, Address, BigInt);
    type Ok = Cid;

    async fn handle(
        ctx: Ctx<impl Blockstore + Send + Sync + 'static>,
        (wallet, address, amount): Self::Params,
        ext: &http::Extensions,
    ) -> Result<Self::Ok, ServerError> {
        let bytes = fvm_ipld_encoding::to_vec(&address)?;
        let params = RawBytes::new(bytes);

        let message = Message {
            to: Address::MARKET_ACTOR,
            from: wallet,
            value: amount.into(),
            method_num: METHOD_ADD_BALANCE,
            params,
            ..Default::default()
        };

        let smsg = MpoolPushMessage::handle(ctx, (message, None), ext).await?;
        Ok(smsg.cid())
    }
}