CHANGE_HISTORY.md

bds-bch

init.cpp

Modify SetupServerArgs method to support some new commands about kafka related startup commands.

validation.h/validation.cpp

Add new methods

//get block data
UniValue myBlockToJSON(const CBlock& block, const CBlockIndex* blockindex, bool txDetails);

//get vout value
UniValue myValueFromAmount(const Amount& amount);

//get block by height
UniValue myGetBlock(const int height);

//get block
CBlock myGetBlockChecked(const CBlockIndex* pblockindex);

//get transaction data
void myTxToUniv(const CTransaction& tx, const uint256& hashBlock, UniValue& entry, bool include_hex, int serialize_flags);

//get script public key
void myScriptPubKeyToUniv(const CScript& scriptPubKey, UniValue& out, bool fIncludeHex);

//send block data to kafka order by height
void myPrintBlockOrderByHeight(int& kafkaHeightRange);

//get asm by script
std::string myScriptToAsmStr(const CScript& script, const bool fAttemptSighashDecode=false);

//get blocks by height
std::vector<UniValue> myGetBlockbatch(const int heightStart, const int heightEnd);

//send http post
int post(const std::string& host, const std::string& port, const std::string& page, const std::string& data, std::string& response_data);

Modify ProcessNewBlock method to send new block to kafka by order.

client.cpp

CRPCConvertParam vRPCConvertParams method array is added two new methods:

//add sendblock and sendbatchblock
{ "sendblock", 0, "height" },
{ "sendbatchblock", 0, "start_height" },
{ "sendbatchblock", 1, "end_height" },

blockchain.cpp

Add new methods:

//rpc : send block to kafka by height
static UniValue sendblock(const JSONRPCRequest& request)

//rpc : send batch blocks to kafka by height
static UniValue sendbatchblock(const JSONRPCRequest& request)