Merge pull request #5 from cakedefi/feature_PoS_staker

PoS staker thread
DeFiCh · Sep 26, 2019 · 8d5a56e · 8d5a56e
2 parents 5b5ff6d + 91b71ea
commit 8d5a56e
Show file tree

Hide file tree

Showing 39 changed files with 601 additions and 468 deletions.
diff --git a/src/Makefile.am b/src/Makefile.am
@@ -169,7 +169,6 @@ BITCOIN_CORE_H = \
   policy/settings.h \
   pos.h \
   pos_kernel.h \
-  pow.h \
   protocol.h \
   psbt.h \
   random.h \
@@ -290,7 +289,6 @@ libbitcoin_server_a_SOURCES = \
   policy/settings.cpp \
   pos.cpp \
   pos_kernel.cpp \
-  pow.cpp \
   rest.cpp \
   rpc/blockchain.cpp \
   rpc/mining.cpp \

diff --git a/src/bench/duplicate_inputs.cpp b/src/bench/duplicate_inputs.cpp
@@ -7,7 +7,7 @@
 #include <coins.h>
 #include <consensus/merkle.h>
 #include <consensus/validation.h>
-#include <pow.h>
+#include <pos.h>
 #include <txmempool.h>
 #include <validation.h>
 
@@ -28,8 +28,8 @@ static void DuplicateInputs(benchmark::State& state)
     LOCK(cs_main);
     CBlockIndex* pindexPrev = ::ChainActive().Tip();
     assert(pindexPrev != nullptr);
-    block.nBits = GetNextWorkRequired(pindexPrev, &block, chainparams.GetConsensus());
-    block.nNonce = 0;
+    block.nBits = pos::GetNextWorkRequired(pindexPrev, &block, chainparams.GetConsensus().pos);
+    // block.nNonce = 0;
     auto nHeight = pindexPrev->nHeight + 1;
 
     // Make a coinbase TX

diff --git a/src/chain.cpp b/src/chain.cpp
@@ -144,7 +144,7 @@ int64_t GetBlockProofEquivalentTime(const CBlockIndex& to, const CBlockIndex& fr
         r = from.nChainWork - to.nChainWork;
         sign = -1;
     }
-    r = r * arith_uint256(params.nPowTargetSpacing) / GetBlockProof(tip);
+    r = r * arith_uint256(params.pos.nTargetSpacing) / GetBlockProof(tip);
     if (r.bits() > 63) {
         return sign * std::numeric_limits<int64_t>::max();
     }

diff --git a/src/chain.h b/src/chain.h
@@ -10,6 +10,7 @@
 #include <consensus/params.h>
 #include <flatfile.h>
 #include <primitives/block.h>
+#include <streams.h>
 #include <tinyformat.h>
 #include <uint256.h>
 
@@ -181,11 +182,13 @@ class CBlockIndex
     uint256 hashMerkleRoot;
     uint32_t nTime;
     uint32_t nBits;
-    uint32_t nNonce;
-    boost::optional<CBlockHeader::PoS> proofOfStakeBody;
 
     // proof-of-stake specific fields
+    uint64_t height;
+    uint64_t mintedBlocks;
     uint256 stakeModifier; // hash modifier for proof-of-stake
+    std::vector<unsigned char> sig;
+    CKeyID minter; // memory only
 
     //! (memory only) Sequential id assigned to distinguish order in which blocks are received.
     int32_t nSequenceId;
@@ -209,15 +212,14 @@ class CBlockIndex
         nSequenceId = 0;
         nTimeMax = 0;
 
-        // PoS
-        proofOfStakeBody = boost::optional<CBlockHeader::PoS>{};
-        stakeModifier = uint256{};
-
         nVersion       = 0;
         hashMerkleRoot = uint256();
         nTime          = 0;
         nBits          = 0;
-        nNonce         = 0;
+        stakeModifier  = uint256{};
+        height         = 0;
+        mintedBlocks   = 0;
+        sig            = {};
     }
 
     CBlockIndex()
@@ -233,9 +235,10 @@ class CBlockIndex
         hashMerkleRoot = block.hashMerkleRoot;
         nTime          = block.nTime;
         nBits          = block.nBits;
-        nNonce         = block.nNonce;
+        height         = block.height;
+        mintedBlocks   = block.mintedBlocks;
         stakeModifier  = block.stakeModifier;
-        proofOfStakeBody = block.proofOfStakeBody;
+        sig            = block.sig;
     }
 
     FlatFilePos GetBlockPos() const {
@@ -265,9 +268,10 @@ class CBlockIndex
         block.hashMerkleRoot = hashMerkleRoot;
         block.nTime          = nTime;
         block.nBits          = nBits;
-        block.nNonce         = nNonce;
         block.stakeModifier   = stakeModifier;
-        block.proofOfStakeBody = proofOfStakeBody;
+        block.height         = height;
+        block.mintedBlocks   = mintedBlocks;
+        block.sig            = sig;
         return block;
     }
 
@@ -343,14 +347,16 @@ class CBlockIndex
         return false;
     }
 
-    bool IsProofOfStake() const
-    {
-        return (bool) proofOfStakeBody;
-    }
-
     //! Build the skiplist pointer for this entry.
     void BuildSkip();
 
+    uint256 GetHashToSign() const
+    {
+        CDataStream ss(SER_GETHASH, 0);
+        ss << nVersion << pprev->GetBlockHash() << hashMerkleRoot << nTime << nBits << height << mintedBlocks << stakeModifier;
+        return Hash(ss.begin(), ss.end());
+    }
+
     //! Efficiently find an ancestor of this block.
     CBlockIndex* GetAncestor(int height);
     const CBlockIndex* GetAncestor(int height) const;
@@ -395,18 +401,15 @@ class CDiskBlockIndex : public CBlockIndex
         if (nStatus & BLOCK_HAVE_UNDO)
             READWRITE(VARINT(nUndoPos));
 
-        //PoS serialization
-        CBlockHeader::PoS loc_proofOfStake = proofOfStakeBody ? *proofOfStakeBody : CBlockHeader::PoS{};
-        READWRITE(loc_proofOfStake);
-        proofOfStakeBody = loc_proofOfStake;
-
         // block header
         READWRITE(this->nVersion);
         READWRITE(hashPrev);
         READWRITE(hashMerkleRoot);
         READWRITE(nTime);
         READWRITE(nBits);
-        READWRITE(nNonce);
+        READWRITE(height);
+        READWRITE(mintedBlocks);
+        READWRITE(sig);
     }
 
     uint256 GetBlockHash() const
@@ -417,9 +420,11 @@ class CDiskBlockIndex : public CBlockIndex
         block.hashMerkleRoot  = hashMerkleRoot;
         block.nTime           = nTime;
         block.nBits           = nBits;
-        block.nNonce          = nNonce;
-        block.stakeModifier    = stakeModifier;
-        block.proofOfStakeBody = proofOfStakeBody;
+        block.stakeModifier   = stakeModifier;
+        block.height          = height;
+        block.mintedBlocks    = mintedBlocks;
+        block.sig             = sig;
+
         return block.GetHash();
     }