hermes-cli 0.1.0

Hermes: IBC Relayer in Rust
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

use core::fmt;

pub use ibc_relayer::chain::counterparty::PendingPackets;
use ibc_relayer_types::core::ics04_channel::packet::Sequence;
use ibc_relayer_types::Height;
use serde::Serialize;

pub mod collate;
use collate::{Collated, CollatedIterExt};

#[derive(Serialize)]
pub struct CollatedPendingPackets {
    pub unreceived_packets: Vec<Collated<u64>>,
    pub unreceived_acks: Vec<Collated<u64>>,
}

impl fmt::Debug for CollatedPendingPackets {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("PendingPackets")
            .field("unreceived_packets", &self.unreceived_packets)
            .field("unreceived_acks", &self.unreceived_acks)
            .finish()
    }
}

impl CollatedPendingPackets {
    pub fn new(pending: PendingPackets) -> Self {
        Self {
            unreceived_packets: pending
                .unreceived_packets
                .into_iter()
                .map(u64::from)
                .collated()
                .collect(),
            unreceived_acks: pending
                .unreceived_acks
                .into_iter()
                .map(u64::from)
                .collated()
                .collect(),
        }
    }
}

#[derive(Serialize, Debug)]
pub struct PacketSequences {
    pub height: Height,
    pub sequences: Vec<u64>,
}

impl PacketSequences {
    pub fn new(height: Height, sequences: Vec<Sequence>) -> Self {
        Self {
            height,
            sequences: sequences.into_iter().map(u64::from).collect(),
        }
    }

    pub fn collated(self) -> CollatedPacketSequences {
        CollatedPacketSequences {
            height: self.height,
            sequences: self.sequences.into_iter().collated().collect(),
        }
    }
}

#[derive(Serialize)]
pub struct CollatedPacketSequences {
    pub height: Height,
    pub sequences: Vec<Collated<u64>>,
}

impl fmt::Debug for CollatedPacketSequences {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("PacketSequences")
            .field("height", &self.height)
            .field("sequences", &self.sequences)
            .finish()
    }
}