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

// Copyright (C) 2019-2020 Aleo Systems Inc.
// This file is part of the snarkOS library.

// The snarkOS library is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// The snarkOS library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.

// You should have received a copy of the GNU General Public License
// along with the snarkOS library. If not, see <https://www.gnu.org/licenses/>.

use crate::address_book::AddressBook;
use snarkos_errors::network::ServerError;
use snarkos_models::{algorithms::LoadableMerkleParameters, objects::Transaction};
use snarkos_storage::Ledger;

use chrono::{DateTime, Utc};
use std::{collections::HashMap, net::SocketAddr};

/// Stores connected, disconnected, and known peers.
#[derive(Clone, Debug, Eq, PartialEq)]
pub struct PeerBook {
    /// Connected peers
    connected: AddressBook,

    /// Disconnected peers
    disconnected: AddressBook,

    /// Gossiped but uncontacted peers
    gossiped: AddressBook,
}

impl PeerBook {
    pub fn new() -> Self {
        Self {
            connected: AddressBook::new(),
            disconnected: AddressBook::new(),
            gossiped: AddressBook::new(),
        }
    }

    /// Returns copy of connected peers.
    pub fn get_connected(&self) -> HashMap<SocketAddr, DateTime<Utc>> {
        self.connected.get_addresses()
    }

    /// Returns copy of gossiped peers.
    pub fn get_gossiped(&self) -> HashMap<SocketAddr, DateTime<Utc>> {
        self.gossiped.get_addresses()
    }

    /// Returns true if address is a connected peer.
    pub fn connected_contains(&self, address: &SocketAddr) -> bool {
        self.connected.contains(address)
    }

    /// Returns true if address is a disconnected peer.
    pub fn disconnected_contains(&self, address: &SocketAddr) -> bool {
        self.disconnected.contains(address)
    }

    /// Returns true if address is a gossiped peer.
    pub fn gossiped_contains(&self, address: &SocketAddr) -> bool {
        self.gossiped.contains(address)
    }

    /// Move a peer from disconnected/gossiped to connected peers.
    pub fn update_connected(&mut self, address: SocketAddr, date: DateTime<Utc>) -> bool {
        self.disconnected.remove(&address);
        self.gossiped.remove(&address);
        self.connected.update(address, date)
    }

    /// Move a peer from connected/disconnected to gossiped peers.
    pub fn update_gossiped(&mut self, address: SocketAddr, date: DateTime<Utc>) -> bool {
        self.connected.remove(&address);
        self.disconnected.remove(&address);
        self.gossiped.update(address, date)
    }

    /// Move a peer from connected peers to disconnected peers.
    pub fn disconnect_peer(&mut self, address: SocketAddr) -> bool {
        self.connected.remove(&address);
        self.gossiped.remove(&address);
        self.disconnected.update(address, Utc::now())
    }

    /// Returns the number of connected peers.
    pub fn connected_total(&self) -> u16 {
        self.connected.length()
    }

    /// Writes connected peers to storage.
    pub fn store<T: Transaction, P: LoadableMerkleParameters>(
        &self,
        storage: &Ledger<T, P>,
    ) -> Result<(), ServerError> {
        Ok(storage.store_to_peer_book(bincode::serialize(&self.get_connected())?)?)
    }
}