diff.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_5be98661b464a5d857a59dc71f31d27ce8d4c8f8f678e03cca8653a2a3372b9f
#define USGOV_5be98661b464a5d857a59dc71f31d27ce8d4c8f8f678e03cca8653a2a3372b9f
 
#include <vector>
#include <cassert>
#include <unordered_map>
#include <thread>
#include <us/gov/socket.h>
#include <us/gov/auth.h>
#include <map>
#include <set>
#include <us/gov/crypto/hash.h>
#include <us/gov/crypto/ec.h>
#include "app.h"
#include "signed_data.h"
 
namespace us { namespace gov {
namespace engine {
    using namespace std;
    using socket::datagram;
    struct peer_t;
    using crypto::ripemd160;
    typedef crypto::ec::keys keys;
    typedef keys::pub_t pubkey_t;
    typedef pubkey_t::hash_t pubkeyh_t;
    struct diff;
 
    static constexpr char streams_version{'5'};
 
    struct local_deltas final: map<int,app::local_delta*>, signed_data {
        local_deltas(): id(0) {}
        local_deltas(const local_deltas& other)=delete;
        virtual ~local_deltas();
        void hash_data_to_sign(crypto::ec::sigmsg_hasher_t&) const override;
        void hash_data(ripemd160&) const override;
        void dump(ostream&) const;
        void to_stream(ostream&) const override;
        static local_deltas* from_stream(istream&);
        static local_deltas* from_stream_prev(istream&);
        static local_deltas* load(istream& is);
        void save(ostream&) const;
 
        uint64_t id;
    };
 
    struct pow_t final:map<pubkey_t::hash_t, uint64_t> {
        uint64_t sum() const;
        void dump(ostream&os) const;
    };
 
    struct diff final: map<int,app::delta*> {
        typedef map<int,app::delta*> b;
        typedef app::hasher_t hasher_t;
        typedef app::hash_t hash_t;
 
        diff() {}
        diff(const diff&)=delete;
        ~diff() { for (auto& i:*this) delete i.second; }
 
        void dump(ostream&) const;
        uint64_t add(int appid, app::local_delta* g);
        bool add(local_deltas*);
        void close();
        static hash_t hash(const string&);
        const hash_t& hash() const;
        void to_stream(ostream&) const;
        static diff* create(istream&);
 
        mutable hash_t hash_cached;
        mutable bool h{false};
        hash_t prev;
        uint64_t id;
        mutex mx;
        pow_t proof_of_work;
        mutex mx_proof_of_work;
    };
 
    typedef diff base;
 
}}
}
 
#endif