Peerplays_Blockchain/peerplays_migrated
1
0
Fork 0
Code Issues 35 Pull requests 4 Projects Releases 20 Packages Wiki Activity Actions

237-es7-fix - Add functions for getting ES version

Browse source
This commit is contained in:
Vladislav Dobromyslov 2022-01-05 19:29:22 +03:00
parent 46be31644b
commit df2696e49a
2 changed files with 31 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
libraries/utilities/elasticsearch.cpp
View file

@ -47,8 +47,36 @@ bool checkES(ES& es)
if(doCurl(curl_request).empty()) if(doCurl(curl_request).empty())
return false; return false;
return true; return true;
} }
const std::string getESVersion(ES& es)
{
graphene::utilities::CurlRequest curl_request;
curl_request.handler = es.curl;
curl_request.url = es.elasticsearch_url;
curl_request.auth = es.auth;
curl_request.type = "GET";
fc::variant response = fc::json::from_string(doCurl(curl_request));
return response["version"]["number"].as_string();
}
void checkESVersion7OrAbove(ES& es, bool& result) noexcept
{
static const int64_t version_7 = 7;
try {
const auto es_version = graphene::utilities::getESVersion(es);
auto dot_pos = es_version.find('.');
result = ( std::stoi(es_version.substr(0,dot_pos)) >= version_7 );
}
catch( ... )
{
wlog( "Unable to get ES version, assuming it is 7 or above" );
result = true;
}
}
const std::string simpleQuery(ES& es) const std::string simpleQuery(ES& es)
{ {
graphene::utilities::CurlRequest curl_request; graphene::utilities::CurlRequest curl_request;

2
libraries/utilities/include/graphene/utilities/elasticsearch.hpp
View file

@ -56,6 +56,8 @@ namespace graphene { namespace utilities {
bool SendBulk(ES& es); bool SendBulk(ES& es);
const std::vector<std::string> createBulk(const fc::mutable_variant_object& bulk_header, const std::string& data); const std::vector<std::string> createBulk(const fc::mutable_variant_object& bulk_header, const std::string& data);
bool checkES(ES& es); bool checkES(ES& es);
const std::string getESVersion(ES& es);
void checkESVersion7OrAbove(ES& es, bool& result) noexcept;
const std::string simpleQuery(ES& es); const std::string simpleQuery(ES& es);
bool deleteAll(ES& es); bool deleteAll(ES& es);
bool handleBulkResponse(long http_code, const std::string& CurlReadBuffer); bool handleBulkResponse(long http_code, const std::string& CurlReadBuffer);