peer_t.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_e71c29d5f8c07b8000435dfe6a5f1e49605b1b2041dad14a3ac898464ed5dd49
#define USGOV_e71c29d5f8c07b8000435dfe6a5f1e49605b1b2041dad14a3ac898464ed5dd49
 
#include <us/gov/auth/peer_t.h>
#include <vector>
#include <thread>
#include <iostream>
#include <algorithm>
#include <sstream>
#include <chrono>
#include <cassert>
#include <array>
#include <unordered_set>
#include <us/gov/config.h>
 
namespace us { namespace gov {
namespace peer {
    using namespace std;
    struct daemon;
    using us::ko;
 
    struct peer_t: auth::peer_t {
        typedef auth::peer_t b;
        using datagram=socket::datagram;
 
        enum stage_t {
            stage_disconnected=0,
            stage_connected,
            stage_exceed_latency,
            stage_service,
            stage_disconnecting,
            num_stages
        };
        constexpr static array<const char*,num_stages> stagestr={"disconnected", "connected", "latency", "service", "disconnecting"};
        constexpr static chrono::seconds auth_window{socket::peer_t::stall+5s};
        constexpr static uint64_t maxidle_ms{180000};
        static const char* finished_reason_1;
 
        peer_t(int sock);
        ~peer_t() override;
        ko connect(uint32_t host, uint16_t port, uint16_t pport, role_t, bool block) override;
        void disconnect(uint16_t seq, const string& reason) override;
        void dump_all(const string& prefix, ostream& os) const override;
        pair<security_level_t,string> security_level() const override;
        bool check_auth_not_granted() const;
        bool check_idle() const;
        void dump(const string& prefix, ostream& os) const;
        bool authorize(const pub_t& p, uint16_t pin) const override;
 
        stage_t stage;
    };
 
}
}}
 
#endif