1 В избранное 0 Ответвления 0

OSCHINA-MIRROR/jdcloud-bds-bds-btc

Присоединиться к Gitlife
Откройте для себя и примите участие в публичных проектах с открытым исходным кодом с участием более 10 миллионов разработчиков. Приватные репозитории также полностью бесплатны :)
Присоединиться бесплатно
Клонировать/Скачать
CHANGE_HISTORY.md 2.4 КБ
Копировать Редактировать Web IDE Исходные данные Просмотреть построчно История
gitlife-traslator Отправлено 28.11.2024 10:27 d52b694

init.cpp

Модифицируйте метод SetupServerArgs для поддержки новых команд, связанных с запуском Kafka.

validation.h/validation.cpp

Добавьте новые методы:

// Получить данные блока
UniValue myBlockToJSON(const CBlock& block, const CBlockIndex* blockindex, bool txDetails);

// Получить значение vout
UniValue myValueFromAmount(const CAmount& amount);

// Получить блок по высоте
UniValue myGetBlock(const int height);

// Получить проверенный блок
CBlock myGetBlockChecked(const CBlockIndex* pblockindex);

// Получить данные транзакции
void myTxToUniv(const CTransaction& tx, const uint256& hashBlock, UniValue& entry, bool include_hex, int serialize_flags);

// Получить публичный ключ скрипта
void myScriptPubKeyToUniv(const CScript& scriptPubKey, UniValue& out, bool fIncludeHex);

// Отправить данные блока в Kafka в порядке по высоте
void myPrintBlockOrderByHeight(int& kafkaHeightRange);

// Преобразовать скрипт в строку ассемблера
std::string myScriptToAsmStr(const CScript& script, const bool fAttemptSighashDecode=false);

// Получить блоки по диапазону высот
std::vector<UniValue> myGetBlockbatch(const int heightStart, const int heightEnd);

// Отправить HTTP-запрос POST
int post(const std::string& host, const std::string& port, const std::string& page, const std::string& data, std::string& response_data);

Измените метод ProcessNewBlock для отправки нового блока в Kafka по порядку.

client.cpp

В массив метода CRPCConvertParam vRPCConvertParams добавлены два новых метода:

// Добавить sendblock и sendbatchblock
{ "sendblock", 0, "height" },
{ "sendbatchblock", 0, "start_height" },
{ "sendbatchblock", 1, "end_height" }

blockchain.cpp

Добавлены новые методы:

// RPC: отправить блок в Kafka по высоте
static UniValue sendblock(const JSONRPCRequest& request)

// RPC: отправить пакет блоков в Kafka по диапазону высот
static UniValue sendbatchblock(const JSONRPCRequest& request)

Опубликовать ( 0 )

Вы можете оставить комментарий после Вход в систему

1
https://api.gitlife.ru/oschina-mirror/jdcloud-bds-bds-btc.git
git@api.gitlife.ru:oschina-mirror/jdcloud-bds-bds-btc.git
oschina-mirror
jdcloud-bds-bds-btc
jdcloud-bds-bds-btc
master