fuel-core 0.48.0

Fuel client library is aggregation of all fuels service. It contains the all business logic of the fuel protocol.
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

use super::P2PAdapter;
use fuel_core_chain_config::ConsensusConfig;
use fuel_core_services::stream::BoxStream;
use fuel_core_tx_status_manager::{
    ports::P2PPreConfirmationGossipData,
    service::ProtocolPublicKey,
};
use fuel_core_types::{
    fuel_tx::Address,
    services::p2p::{
        GossipsubMessageAcceptance,
        GossipsubMessageInfo,
    },
};

#[cfg(feature = "p2p")]
impl fuel_core_tx_status_manager::ports::P2PSubscriptions for P2PAdapter {
    type GossipedStatuses = P2PPreConfirmationGossipData;

    fn gossiped_tx_statuses(&self) -> BoxStream<Self::GossipedStatuses> {
        use tokio_stream::{
            StreamExt,
            wrappers::BroadcastStream,
        };

        match &self.service {
            Some(service) => Box::pin(
                BroadcastStream::new(service.subscribe_preconfirmations())
                    .filter_map(|result| result.ok()),
            ),
            _ => fuel_core_services::stream::IntoBoxStream::into_boxed(
                tokio_stream::pending(),
            ),
        }
    }

    fn notify_gossip_transaction_validity(
        &self,
        message_info: GossipsubMessageInfo,
        validity: GossipsubMessageAcceptance,
    ) -> anyhow::Result<()> {
        match &self.service {
            Some(service) => {
                service.notify_gossip_transaction_validity(message_info, validity)
            }
            _ => Ok(()),
        }
    }
}

#[cfg(not(feature = "p2p"))]
impl fuel_core_tx_status_manager::ports::P2PSubscriptions for P2PAdapter {
    type GossipedStatuses = P2PPreConfirmationGossipData;

    fn gossiped_tx_statuses(&self) -> BoxStream<Self::GossipedStatuses> {
        Box::pin(fuel_core_services::stream::pending())
    }

    fn notify_gossip_transaction_validity(
        &self,
        _message_info: GossipsubMessageInfo,
        _validity: GossipsubMessageAcceptance,
    ) -> anyhow::Result<()> {
        Ok(())
    }
}

pub struct ConsensusConfigProtocolPublicKey {
    inner: ConsensusConfig,
}

impl ConsensusConfigProtocolPublicKey {
    pub fn new(inner: ConsensusConfig) -> Self {
        Self { inner }
    }
}

impl ProtocolPublicKey for ConsensusConfigProtocolPublicKey {
    fn latest_address(&self) -> Address {
        match &self.inner {
            ConsensusConfig::PoA { signing_key } => *signing_key,
            ConsensusConfig::PoAV2(poa_v2) => poa_v2.latest_address(),
        }
    }
}