fuel-core-client 0.48.0

use super::HexString;
use crate::client::schema::{
    U32,
    schema,
};

#[derive(cynic::QueryFragment, Clone, Debug)]
#[cynic(schema_path = "./assets/schema.sdl")]
pub struct StorageReadReplayEvent {
    pub column: U32,
    pub key: HexString,
    pub value: Option<HexString>,
}
impl From<StorageReadReplayEvent>
    for fuel_core_types::services::executor::StorageReadReplayEvent
{
    fn from(event: StorageReadReplayEvent) -> Self {
        fuel_core_types::services::executor::StorageReadReplayEvent {
            column: event.column.into(),
            key: event.key.into(),
            value: event.value.map(Into::into),
        }
    }
}
impl From<fuel_core_types::services::executor::StorageReadReplayEvent>
    for StorageReadReplayEvent
{
    fn from(event: fuel_core_types::services::executor::StorageReadReplayEvent) -> Self {
        StorageReadReplayEvent {
            column: event.column.into(),
            key: event.key.into(),
            value: event.value.map(Into::into),
        }
    }
}

#[derive(cynic::QueryVariables, Debug, Clone)]
pub struct StorageReadReplayArgs {
    pub height: U32,
}

/// Retrieves the transaction in opaque form
#[derive(cynic::QueryFragment, Clone, Debug)]
#[cynic(
    schema_path = "./assets/schema.sdl",
    graphql_type = "Query",
    variables = "StorageReadReplayArgs"
)]
pub struct StorageReadReplay {
    #[arguments(height: $height)]
    pub storage_read_replay: Vec<StorageReadReplayEvent>,
}

#[cfg(test)]
pub mod tests {
    use super::*;
    use fuel_core_types::fuel_types::BlockHeight;

    #[test]
    fn storage_read_replay_gql_output() {
        use cynic::QueryBuilder;
        let query = StorageReadReplay::build(StorageReadReplayArgs {
            height: BlockHeight::new(1234).into(),
        });
        insta::assert_snapshot!(query.query)
    }
}