networking.h

Go to the documentation of this file.

/*
-------------------------------------------------------------------------------
                            PLEBBLE
-------------------------------------------------------------------------------
 Copyright (C) 2019-2020 KATLAS Technology. (http://katlastechnology.com)
 Copyright (C) 2017-2020 Marcos Mayorga. (mm@mm-studios.com)
 
 This file is part of our Plebble(R) Platform.
 
 The code below cannot be copied, used for any purpose other than the one
 agreed and/or distributed without the express permission of
 KATLAS Technology.
-------------------------------------------------------------------------------
 
 
*/
#ifndef USGOV_75e4bd922f2de31a967ff5ad48fd3c21a0df7b241765114881ed8761ed8ca7cd
#define USGOV_75e4bd922f2de31a967ff5ad48fd3c21a0df7b241765114881ed8761ed8ca7cd
 
#include <us/gov/net_daemon.h>
#include <vector>
#include <unordered_set>
#include <string>
#include "diff.h"
 
namespace us{ namespace gov {
namespace engine {
using namespace std;
 
    struct daemon;
 
    struct networking final:us::gov::net_daemon {
        typedef us::gov::net_daemon b;
        using b::keys;
        networking(engine::daemon* parent);
        networking(const networking&)=delete;
        networking& operator = (const networking&)=delete;
        networking(uint16_t port, uint16_t pport, uint8_t edges, uint8_t devices, int workers, engine::daemon* parent, const vector<pair<uint32_t,uint16_t>>& seed_nodes);
        ~networking() override;
        const function<bool(const socket::client&)>& sysop_filter() const;
        static const function<bool(const socket::client&)>& node_filter();
        static const function<bool(const socket::client&)>& non_sysop_filter();
        socket::client* create_client(int sock) override;
        const keys& get_keys() const override;
        bool process_work(socket::peer_t *c, datagram*d) override;
        bool process_evidence(evidence*) override;
        //void remote_port(const crypto::ec::keys::pub_t&,uint16_t port) override;
        string homedir() const override;
        bool process_work_sysop(peer::peer_t *c, datagram*d);
        using b::send;
        void send(const local_deltas&);
        void relay_local_deltas(datagram*, peer_t* exclude);
        void send_vote(datagram*);
        int relay_vote(datagram*, peer_t* exclude);
        void dump(const string& prefix, ostream& os) const;
        bool check_dfs_permission(const hash_t& addr) const override;
        bool check_relay_permission(const hash_t& addr) const override;
 
        engine::daemon* parent;
    };
 
}}
}
 
#endif