daemon.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_56c4ea14fe04c13aabcd1dd5ef4f05856a66f6515dcb1855f3046da43eea737a
#define USGOV_56c4ea14fe04c13aabcd1dd5ef4f05856a66f6515dcb1855f3046da43eea737a
 
#include <us/gov/peer/daemon.h>
#include "peer_t.h"
#include <unordered_set>
#include <us/gov/crypto/ec.h>
#include <iostream>
#include <mutex>
#include <functional>
 
namespace us{ namespace gov {
namespace relay {
    using namespace std;
    using socket::datagram;
 
    struct evidence;
 
    struct daemon:peer::daemon {
        typedef peer::daemon b;
        typedef crypto::ec::keys::pub_t::hash_t hash_t;
        daemon();
        daemon(const daemon&)=delete;
        daemon& operator =(const daemon&)=delete;
        daemon(uint16_t port, uint16_t pport, uint8_t edges, uint8_t devices, int workers);
        ~daemon() override;
        bool process_work(socket::peer_t *c, datagram*d) override;
        bool process_evidence(const datagram&);
        void process_harvester_payload(const string& payload, string& ans);
        virtual bool process_evidence(evidence*)=0;
        void dump(const string& prefix, ostream&os) const;
        void send_evidence(datagram*);
        int send(int num, const socket::client* exclude, const datagram&);
        int send(int num, const socket::client* exclude, datagram*);
        int grid_devices_send(const datagram& d);
        int grid_devices_send(const datagram& d, const function<bool (const client&)>&);
        int grid_devices_send(const vector<datagram*>& v,  const function<bool (const client&)>& filter);
        void rollback(uint16_t timeout, string payload);
        void on_destroy(client&) override;
        virtual bool check_relay_permission(const hash_t& addr) const;
        virtual evidence* parse_custom_evidence(const string& payload) const;
 
        struct mem_t: unordered_map<hash_t,string> {
            mem_t();
            void flush_back(const hash_t& me);
            void init(id::peer_t*originator);
 
            mutex mx;
            size_t resps{0};
            string anspayload;
            id::peer_t *originator{nullptr};
        };
 
        mem_t _mem;
    };
}
}}
 
#endif