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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

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

use crate::utils::net::global_http_client;
use crate::utils::{RetryArgs, retry};
use crate::{
    daemon::bundle::load_actor_bundles,
    networks::{ChainConfig, Height, NetworkChain},
    shim::state_tree::StateRoot,
    state_migration::run_state_migrations,
};
use cid::Cid;
use futures::{AsyncWriteExt, TryStreamExt};
use fvm_ipld_encoding::CborStore;
use positioned_io::RandomAccessFile;
use pretty_assertions::assert_eq;
use std::path::PathBuf;
use std::time::Duration;
use std::{str::FromStr, sync::Arc};

#[ignore = "flaky"]
#[tokio::test]
async fn test_nv17_state_migration_calibnet() {
    // forest::state_migration: State migration at height Shark(epoch 16800) was successful,
    // Previous state: bafy2bzacedxtdhqjsrw2twioyaeomdk4z7umhgfv36vzrrotjb4woutphqgyg,
    // new state: bafy2bzacecrejypa2rqdh3geg2u3qdqdrejrfqvh2ykqcrnyhleehpiynh4k4.
    //
    // See <https://github.com/ChainSafe/forest/actions/runs/5579505385/jobs/10195488001#step:6:232>
    test_state_migration(
        Height::Shark,
        NetworkChain::Calibnet,
        Cid::from_str("bafy2bzacedxtdhqjsrw2twioyaeomdk4z7umhgfv36vzrrotjb4woutphqgyg").unwrap(),
        Cid::from_str("bafy2bzacecrejypa2rqdh3geg2u3qdqdrejrfqvh2ykqcrnyhleehpiynh4k4").unwrap(),
    )
    .await
}

#[ignore = "flaky"]
#[tokio::test]
async fn test_nv18_state_migration_calibnet() {
    // State migration at height Hygge(epoch 322354) was successful,
    // Previous state: bafy2bzacedjqwdqxlkyyuohmtcfciekl5qh2s4yf67neiuuhkibbteqoucvsm,
    // new state: bafy2bzacedhhgkmr26rbr3yujounnz2ufiwrlvamogyabgfv6uvwq3rlv4t2i.
    //
    // See <https://github.com/ChainSafe/forest/actions/runs/5579505385/jobs/10195488001#step:6:515>
    test_state_migration(
        Height::Hygge,
        NetworkChain::Calibnet,
        Cid::from_str("bafy2bzacedjqwdqxlkyyuohmtcfciekl5qh2s4yf67neiuuhkibbteqoucvsm").unwrap(),
        Cid::from_str("bafy2bzacedhhgkmr26rbr3yujounnz2ufiwrlvamogyabgfv6uvwq3rlv4t2i").unwrap(),
    )
    .await
}

#[ignore = "flaky"]
#[tokio::test]
async fn test_nv19_state_migration_calibnet() {
    // State migration at height Lightning(epoch 489094) was successful,
    // Previous state: bafy2bzacedgamjgha75e7w2cgklfdgtmumsj7nadqppnpz3wexl2wl6dexsle,
    // new state: bafy2bzacebhjx4uqtg6c65km46wiiq45dbbeckqhs2oontwdzba335nxk6bia.
    //
    // See <https://github.com/ChainSafe/forest/actions/runs/5579505385/jobs/10195488001#step:6:232>
    test_state_migration(
        Height::Lightning,
        NetworkChain::Calibnet,
        Cid::from_str("bafy2bzacedgamjgha75e7w2cgklfdgtmumsj7nadqppnpz3wexl2wl6dexsle").unwrap(),
        Cid::from_str("bafy2bzacebhjx4uqtg6c65km46wiiq45dbbeckqhs2oontwdzba335nxk6bia").unwrap(),
    )
    .await
}

async fn test_state_migration(
    height: Height,
    network: NetworkChain,
    old_state: Cid,
    expected_new_state: Cid,
) {
    // Car files are cached under data folder for Go test to pick up without network access
    let car_path = PathBuf::from(format!("./src/state_migration/tests/data/{old_state}.car"));
    if !car_path.is_file() {
        let tmp: tempfile::TempPath = tempfile::NamedTempFile::new_in(car_path.parent().unwrap())
            .unwrap()
            .into_temp_path();
        let timeout = Duration::from_secs(5);
        retry(
            RetryArgs {
                timeout: Some(timeout),
                max_retries: Some(15),
                ..Default::default()
            },
            || async {
                let response = global_http_client().get(format!(
                    "https://forest-continuous-integration.fra1.digitaloceanspaces.com/state_migration/state/{old_state}.car"
                )).timeout(timeout).send().await.unwrap();
                let reader = response
                    .bytes_stream()
                    .map_err(std::io::Error::other)
                    .into_async_read();
                let mut writer = futures::io::BufWriter::new(async_fs::File::create(&tmp).await.unwrap());
                futures::io::copy(reader, &mut writer).await.unwrap();
                writer.flush().await.unwrap();
                writer.close().await.unwrap();

                anyhow::Ok(())
            },
        )
        .await.unwrap();
        tmp.persist(&car_path).unwrap();
    }

    let store = Arc::new(
        crate::db::car::plain::PlainCar::new(RandomAccessFile::open(&car_path).unwrap()).unwrap(),
    );
    load_actor_bundles(&store, &network).await.unwrap();

    let chain_config = Arc::new(ChainConfig::from_chain(&network));
    let height_info = &chain_config.height_infos[&height];

    let state_root: StateRoot = store.get_cbor(&old_state).unwrap().unwrap();
    println!("Actor root (for Go test): {}", state_root.actors);

    let new_state =
        run_state_migrations(height_info.epoch, &chain_config, &store, &old_state).unwrap();

    assert_eq!(new_state, Some(expected_new_state));
}