forest/chain/
snapshot_format.rs

1// Copyright 2019-2026 ChainSafe Systems
2// SPDX-License-Identifier: Apache-2.0, MIT
3
4use crate::lotus_json::lotus_json_with_self;
5use cid::Cid;
6use itertools::Itertools as _;
7use num::FromPrimitive as _;
8use num_derive::FromPrimitive;
9use nunny::Vec as NonEmpty;
10use schemars::JsonSchema;
11use serde::{Deserialize, Serialize};
12
13#[derive(Debug, Copy, clap::ValueEnum, FromPrimitive, Clone, PartialEq, Eq, JsonSchema)]
14#[repr(u64)]
15pub enum FilecoinSnapshotVersion {
16    V1 = 1,
17    V2 = 2,
18}
19lotus_json_with_self!(FilecoinSnapshotVersion);
20
21impl Serialize for FilecoinSnapshotVersion {
22    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
23    where
24        S: serde::Serializer,
25    {
26        serializer.serialize_u64(*self as u64)
27    }
28}
29
30impl<'de> Deserialize<'de> for FilecoinSnapshotVersion {
31    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
32    where
33        D: serde::Deserializer<'de>,
34    {
35        let i = u64::deserialize(deserializer)?;
36        match FilecoinSnapshotVersion::from_u64(i) {
37            Some(v) => Ok(v),
38            None => Err(serde::de::Error::custom(format!(
39                "invalid snapshot version {i}"
40            ))),
41        }
42    }
43}
44
45/// Defined in <https://github.com/filecoin-project/FIPs/blob/98e33b9fa306959aa0131519eb4cc155522b2081/FRCs/frc-0108.md#snapshotmetadata>
46#[derive(Debug, Serialize, Deserialize, PartialEq, Eq, derive_more::Constructor)]
47#[serde(rename_all = "PascalCase")]
48pub struct FilecoinSnapshotMetadata {
49    /// Snapshot version
50    pub version: FilecoinSnapshotVersion,
51    /// Chain head tipset key
52    pub head_tipset_key: NonEmpty<Cid>,
53    /// F3 snapshot `CID`
54    pub f3_data: Option<Cid>,
55}
56
57impl FilecoinSnapshotMetadata {
58    pub fn new_v2(head_tipset_key: NonEmpty<Cid>, f3_data: Option<Cid>) -> Self {
59        Self::new(FilecoinSnapshotVersion::V2, head_tipset_key, f3_data)
60    }
61}
62
63impl std::fmt::Display for FilecoinSnapshotMetadata {
64    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
65        writeln!(f, "Snapshot version:           {}", self.version as u64)?;
66        let head_tipset_key_string = self
67            .head_tipset_key
68            .iter()
69            .map(Cid::to_string)
70            .join("\n                            ");
71        writeln!(f, "Head Tipset:                {head_tipset_key_string}")?;
72        write!(
73            f,
74            "F3 data:                    {}",
75            self.f3_data
76                .map(|c| c.to_string())
77                .unwrap_or_else(|| "not found".into())
78        )?;
79        Ok(())
80    }
81}
forest/chain/snapshot_format.rs

forest/chain/
snapshot_format.rs
