@ -1,8 +1,6 @@
# include <iostream>
# include <string>
# include "../core/protocol/transport/zmq_client.hpp"
# include "../neroshop.hpp"
using namespace neroshop ;
namespace neroshop_tools = neroshop : : tools ;
@ -14,12 +12,12 @@ static void print_commands() {
{ " help " , " Display list of available commands " } ,
{ " exit " , " Exit CLI " } ,
{ " version " , " Show version " } ,
{ " monero_nodes " , " Display a list of monero nodes " } ,
{ " query " , " Execute an SQLite query " } ,
{ " curl_version " , " Show libcurl version " } ,
{ " send " , " Send a test message to the local daemon IPC server " }
/*,
{ " " , " " } */
{ " monero_nodes " , " Display a list of monero nodes " } ,
{ " query " , " Execute an SQLite query " } ,
{ " curl_version " , " Show libcurl version " } ,
{ " get " , " Get the value for a key from DHT network " } ,
{ " status " , " Get network status from local daemon server " }
//,{"", ""}
} ;
std : : cout < < " Usage: " < < " [COMMAND] ... \n \n " ;
for ( auto const & [ key , value ] : commands ) {
@ -31,7 +29,6 @@ static void print_commands() {
int main ( int argc , char * * argv ) {
//-------------------------------------------------------
// Connect to daemon server (daemon must be launched first)
# if !defined(NEROSHOP_USE_LIBZMQ)
neroshop : : Client * client = neroshop : : Client : : get_main_client ( ) ;
int port = NEROSHOP_IPC_DEFAULT_PORT ;
std : : string ip = " localhost " ; // 0.0.0.0 means anyone can connect to your server
@ -39,9 +36,6 @@ int main(int argc, char** argv) {
std : : cout < < " Please launch neromon first \n " ;
exit ( 0 ) ;
}
# else
neroshop : : ZmqClient client ( " tcp://localhost:5555 " ) ;
# endif
//-------------------------------------------------------
neroshop : : load_nodes_from_memory ( ) ;
@ -53,10 +47,6 @@ int main(int argc, char** argv) {
return 1 ;
}
std : : vector < std : : string > monero_nodes = Script : : get_table_string ( lua_state , " monero.nodes. " + network_type ) ;
if ( monero_nodes . empty ( ) ) {
std : : cout < < " failed to get nodes in the config file \n Check your config file in ~/.config/neroshop " < < std : : endl ;
}
//-------------------------------------------------------
char * line = NULL ;
while ( ( line = linenoise ( " neroshop-console> " ) ) ! = NULL ) {
@ -79,15 +69,28 @@ int main(int argc, char** argv) {
}
else if ( neroshop : : string : : starts_with ( command , " query " ) ) {
auto arg_count = neroshop : : string : : split ( command , " " ) . size ( ) ;
if ( arg_count = = 1 ) neroshop: : print ( " expected arguments after 'query' " , 1 ) ;
if ( arg_count = = 1 ) std: : cout < < " \033 [91mexpected arguments after 'query' \033 [0m \n " ;
if ( arg_count > 1 ) {
std : : size_t arg_pos = command . find_first_of ( " " ) ;
std : : string sql = neroshop : : string : : trim_left ( command . substr ( arg_pos + 1 ) ) ; ////trim_left(command.substr(std::string("query").length() + 1)); // <- this works too
assert ( neroshop : : string : : starts_with ( sql , " SELECT " , false ) & & " Only SELECT queries are allowed " ) ; // since the ability to run sql commands gives too much power to the user to alter the database anyhow, limit queries to select statements only
std : : string json = neroshop : : rpc : : json : : translate ( sql ) ;
// No need to call RPC server to access RPC functions when it can be done directly.
std : : cout < < neroshop : : rpc : : json : : process ( json ) < < " \n " ;
// Usage: query SELECT * FROM mappings;
std : : size_t arg_pos = command . find_first_of ( " " ) ;
std : : string sql = neroshop : : string : : trim_left ( command . substr ( arg_pos + 1 ) ) ; ////trim_left(command.substr(std::string("query").length() + 1)); // <- this works too
assert ( neroshop : : string : : starts_with ( sql , " SELECT " , false ) & & " Only SELECT queries are allowed " ) ; // since the ability to run sql commands gives too much power to the user to alter the database anyhow, limit queries to select statements only
std : : string json = neroshop : : rpc : : json : : translate ( sql ) ;
// No need to call RPC server to access RPC functions when it can be done directly.
std : : cout < < neroshop : : rpc : : json : : process ( json ) < < " \n " ;
// Usage: query SELECT * FROM mappings;
}
}
else if ( command = = " status " ) {
if ( client - > is_connected ( ) ) {
std : : string response ;
client - > get ( " status " , response ) ;
try {
nlohmann : : json json = nlohmann : : json : : parse ( response ) ;
std : : cout < < json . dump ( 4 ) < < " \033 [0m \n " ;
} catch ( const nlohmann : : detail : : parse_error & e ) {
std : : cerr < < " Parse error \n " ;
}
}
}
else if ( command = = " curl_version " ) {
@ -97,102 +100,23 @@ int main(int argc, char** argv) {
" . " + std : : to_string ( curl_version - > version_num & 0xff ) ;
std : : cout < < " libcurl version " < < curl_version_str < < std : : endl ;
}
else if ( command = = " send " ) { // This is only a test command
# if !defined(NEROSHOP_USE_LIBZMQ)
if ( client - > is_connected ( ) ) {
nlohmann : : json arguments_obj = {
{ " id " , " " } ,
} ; //nlohmann::json nested_array = {"item1", "item2", "item3"};
nlohmann : : json j = {
{ " version " , std : : string ( NEROSHOP_DHT_VERSION ) } ,
{ " query " , " ping " } ,
{ " args " , arguments_obj } ,
{ " tid " , 1234 } ,
} ;
// send packed data to POSIX server
std : : vector < uint8_t > packed = nlohmann : : json : : to_msgpack ( j ) ;
client - > send ( packed ) ; //client.send("Hello, POSIX Server!");
try {
std : : vector < uint8_t > response ; //std::string response;
client - > receive ( response ) ;
// Deserialize the response from MessagePack to a JSON object
nlohmann : : json j2 = nlohmann : : json : : from_msgpack ( response ) ;
std : : cout < < " Received response: " < < j2 . dump ( ) < < std : : endl ;
} catch ( const nlohmann : : detail : : parse_error & e ) {
std : : cerr < < " An error occurred: " < < " Server was disconnected " < < std : : endl ; //std::cout << "Failed to parse server response: " << e.what() << std::endl;
}
} else {
std : : cout < < " Failed to establish connection to server \n " ;
}
//------------------------------------------------------------
# else
nlohmann : : json j = {
{ " message " , " Hello, ZMQ Server! " } ,
{ " id " , 1234 }
} ;
// send packed data to ZMQ server
std : : vector < uint8_t > packed = nlohmann : : json : : to_msgpack ( j ) ;
client . send ( packed ) ; //client.send("Hello, ZMQ Server!");
std : : vector < uint8_t > response ; //std::string response;
client . receive ( response ) ;
// Deserialize the response from MessagePack to a JSON object
nlohmann : : json j2 = nlohmann : : json : : from_msgpack ( response ) ;
std : : cout < < " Received response: " < < j2 . dump ( ) < < std : : endl ; //std::cout << "Received response: " << response << std::endl;
# endif
}
else if ( command = = " put " ) { // This is only a test command
if ( client - > is_connected ( ) ) {
nlohmann : : json arguments_obj = {
{ " key " , " 63075a22aaed744829b33ed9e16bb3aa0f06121500861bbf8fcbdfee2e708a66 " } ,
{ " value " , " { \" name \" : \" Jack \" } " } , // {"name": "Jack"}
} ;
nlohmann : : json j = {
{ " version " , std : : string ( NEROSHOP_DHT_VERSION ) } ,
{ " query " , " put " } ,
{ " args " , arguments_obj } ,
{ " tid " , nullptr } , // tid is not needed. DHT server will automatically deal with this
} ;
// send packed data to POSIX server
std : : vector < uint8_t > packed = nlohmann : : json : : to_msgpack ( j ) ;
client - > send ( packed ) ; //client.send("Hello, POSIX Server!");
try {
std : : vector < uint8_t > response ; //std::string response;
client - > receive ( response ) ;
// Deserialize the response from MessagePack to a JSON object
nlohmann : : json j2 = nlohmann : : json : : from_msgpack ( response ) ;
std : : cout < < " Received response: " < < j2 . dump ( ) < < std : : endl ;
} catch ( const nlohmann : : detail : : parse_error & e ) {
std : : cerr < < " An error occurred: " < < " Server was disconnected " < < std : : endl ; //std::cout << "Failed to parse server response: " << e.what() << std::endl;
}
}
}
else if ( command = = " get " ) { // This is only a test command
if ( client - > is_connected ( ) ) {
nlohmann : : json arguments_obj = {
{ " key " , " 63075a22aaed744829b33ed9e16bb3aa0f06121500861bbf8fcbdfee2e708a66 " } ,
} ;
nlohmann : : json j = {
{ " version " , std : : string ( NEROSHOP_DHT_VERSION ) } ,
{ " query " , " get " } ,
{ " args " , arguments_obj } ,
{ " tid " , nullptr } ,
} ;
// send packed data to POSIX server
std : : vector < uint8_t > packed = nlohmann : : json : : to_msgpack ( j ) ;
client - > send ( packed ) ; //client.send("Hello, POSIX Server!");
try {
std : : vector < uint8_t > response ; //std::string response;
client - > receive ( response ) ;
// Deserialize the response from MessagePack to a JSON object
nlohmann : : json j2 = nlohmann : : json : : from_msgpack ( response ) ;
std : : cout < < " Received response: " < < j2 . dump ( ) < < std : : endl ;
} catch ( const nlohmann : : detail : : parse_error & e ) {
std : : cerr < < " An error occurred: " < < " Server was disconnected " < < std : : endl ; //std::cout << "Failed to parse server response: " << e.what() << std::endl;
else if ( neroshop : : string : : starts_with ( command , " get " ) ) {
auto arg_count = neroshop : : string : : split ( command , " " ) . size ( ) ;
if ( arg_count = = 1 ) std : : cout < < " \033 [91mexpected argument after 'get' \033 [0m \n " ;
if ( arg_count > 1 ) {
std : : size_t arg_pos = command . find_first_of ( " " ) ;
std : : string key = neroshop : : string : : trim ( command . substr ( arg_pos + 1 ) ) ;
if ( client - > is_connected ( ) ) {
std : : string response ;
client - > get ( key , response ) ;
try {
nlohmann : : json json = nlohmann : : json : : parse ( response ) ;
std : : cout < < ( json . contains ( " error " ) ? " \033 [91m " : " \033 [32m " ) < < json . dump ( 4 ) < < " \033 [0m \n " ;
} catch ( const nlohmann : : detail : : parse_error & e ) {
std : : cerr < < " Parse error \n " ;
}
}
}
}
@ -209,47 +133,16 @@ int main(int argc, char** argv) {
std : : string put_response ;
client - > put ( key , value , put_response ) ;
std : : cout < < " Received response: " < < put_response < < " \n " ;
}
else if ( command = = " search " ) { // This is only a test command
if ( client - > is_connected ( ) ) {
nlohmann : : json arguments_obj = {
{ " what " , " monero_address " } , //"*"},
{ " from " , " user " } ,
//{"condition", ""},
//{"", ""},
} ;
nlohmann : : json j = {
{ " version " , std : : string ( NEROSHOP_DHT_VERSION ) } ,
{ " query " , " search " } ,
{ " args " , arguments_obj } ,
{ " tid " , nullptr } ,
} ;
// send packed data to POSIX server
std : : vector < uint8_t > packed = nlohmann : : json : : to_msgpack ( j ) ;
client - > send ( packed ) ; //client.send("Hello, POSIX Server!");
try {
std : : vector < uint8_t > response ; //std::string response;
client - > receive ( response ) ;
// Deserialize the response from MessagePack to a JSON object
nlohmann : : json j2 = nlohmann : : json : : from_msgpack ( response ) ;
std : : cout < < " Received response: " < < j2 . dump ( ) < < std : : endl ;
} catch ( const nlohmann : : detail : : parse_error & e ) {
std : : cerr < < " An error occurred: " < < " Server was disconnected " < < std : : endl ; //std::cout << "Failed to parse server response: " << e.what() << std::endl;
}
}
}
}
/*else if(command == "") {
} */
else if ( command = = " exit " ) {
# if !defined(NEROSHOP_USE_LIBZMQ)
// close the connection
client - > disconnect ( ) ;
# endif
break ;
}
else {
std : : cerr < < std : : string ( " \033 [0;91mUnreco nized command: \033 [1;37m " ) < < command < < " \033 [0m " < < std : : endl ;
std : : cerr < < std : : string ( " \033 [0;91mUnrecognized command: \033 [1;37m " ) < < command < < " \033 [0m " < < std : : endl ;
}
linenoiseFree ( line ) ; // Or just free(line) if you use libc malloc.
}
layters
larteyoh