You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
218 lines
6.6 KiB
218 lines
6.6 KiB
#include "src/CmdLineOptions.h"
|
|
#include "src/MicroCore.h"
|
|
#include "src/YourMoneroRequests.h"
|
|
|
|
#include <iostream>
|
|
#include <memory>
|
|
#include <cstdlib>
|
|
|
|
|
|
using namespace std;
|
|
using namespace restbed;
|
|
|
|
using boost::filesystem::path;
|
|
|
|
int
|
|
main(int ac, const char* av[])
|
|
{
|
|
|
|
// get command line options
|
|
xmreg::CmdLineOptions opts {ac, av};
|
|
|
|
auto help_opt = opts.get_option<bool>("help");
|
|
|
|
// if help was chosen, display help text and finish
|
|
if (*help_opt)
|
|
{
|
|
return EXIT_SUCCESS;
|
|
}
|
|
|
|
auto do_not_relay_opt = opts.get_option<bool>("do-not-relay");
|
|
auto testnet_opt = opts.get_option<bool>("testnet");
|
|
auto port_opt = opts.get_option<string>("port");
|
|
auto config_file_opt = opts.get_option<string>("config-file");
|
|
|
|
|
|
bool testnet = *testnet_opt;
|
|
bool do_not_relay = *do_not_relay_opt;
|
|
|
|
|
|
// check if config-file provided exist
|
|
if (!boost::filesystem::exists(*config_file_opt))
|
|
{
|
|
cerr << "Config file " << *config_file_opt
|
|
<< " does not exist" << endl;
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
nlohmann::json config_json;
|
|
|
|
try
|
|
{
|
|
// try reading and parsing json config file provided
|
|
std::ifstream i(*config_file_opt);
|
|
i >> config_json;
|
|
}
|
|
catch (const std::exception& e)
|
|
{
|
|
cerr << "Error reading confing file "
|
|
<< *config_file_opt << ": "
|
|
<< e.what() << endl;
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
|
|
//cast port number in string to uint16
|
|
uint16_t app_port = boost::lexical_cast<uint16_t>(*port_opt);
|
|
|
|
// get blockchain path
|
|
// if confing.json paths are emtpy, defeault monero
|
|
// paths are going to be used
|
|
path blockchain_path = testnet
|
|
? path(config_json["blockchain-path"]["testnet"].get<string>())
|
|
: path(config_json["blockchain-path"]["mainnet"].get<string>());
|
|
|
|
|
|
if (!xmreg::get_blockchain_path(blockchain_path, testnet))
|
|
{
|
|
cerr << "Error getting blockchain path." << endl;
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
cout << "Blockchain path: " << blockchain_path.string() << endl;
|
|
|
|
|
|
|
|
string deamon_url = testnet
|
|
? config_json["daemon-url"]["testnet"]
|
|
: config_json["daemon-url"]["mainnet"];
|
|
|
|
// set mysql/mariadb connection details
|
|
xmreg::MySqlConnector::url = config_json["database"]["url"];
|
|
xmreg::MySqlConnector::username = config_json["database"]["user"];
|
|
xmreg::MySqlConnector::password = config_json["database"]["password"];
|
|
xmreg::MySqlConnector::dbname = config_json["database"]["dbname"];
|
|
|
|
// set blockchain status monitoring thread parameters
|
|
xmreg::CurrentBlockchainStatus::blockchain_path
|
|
= blockchain_path.string();
|
|
xmreg::CurrentBlockchainStatus::testnet
|
|
= testnet;
|
|
xmreg::CurrentBlockchainStatus::do_not_relay
|
|
= do_not_relay;
|
|
xmreg::CurrentBlockchainStatus::deamon_url
|
|
= deamon_url;
|
|
xmreg::CurrentBlockchainStatus::refresh_block_status_every_seconds
|
|
= config_json["refresh_block_status_every_seconds"];
|
|
xmreg::CurrentBlockchainStatus::max_number_of_blocks_to_import
|
|
= config_json["max_number_of_blocks_to_import"];
|
|
xmreg::CurrentBlockchainStatus::search_thread_life_in_seconds
|
|
= config_json["search_thread_life_in_seconds"];
|
|
xmreg::CurrentBlockchainStatus::import_fee
|
|
= config_json["wallet_import"]["fee"];
|
|
|
|
if (testnet)
|
|
{
|
|
xmreg::CurrentBlockchainStatus::import_payment_address_str
|
|
= config_json["wallet_import"]["testnet"]["address"];
|
|
xmreg::CurrentBlockchainStatus::import_payment_viewkey_str
|
|
= config_json["wallet_import"]["testnet"]["viewkey"];
|
|
}
|
|
else
|
|
{
|
|
xmreg::CurrentBlockchainStatus::import_payment_address_str
|
|
= config_json["wallet_import"]["mainnet"]["address"];
|
|
xmreg::CurrentBlockchainStatus::import_payment_viewkey_str
|
|
= config_json["wallet_import"]["mainnet"]["viewkey"];
|
|
}
|
|
|
|
|
|
// since CurrentBlockchainStatus class monitors current status
|
|
// of the blockchain (e.g., current height), its seems logical to
|
|
// make static objects for accessing the blockchain in this class.
|
|
// this way monero accessing blockchain variables (i.e. mcore and core_storage)
|
|
// are not passed around like crazy everywhere. Uri( "file:///tmp/dh2048.pem"
|
|
// There are here, and this is the only class that
|
|
// has direct access to blockchain and talks (using rpc calls)
|
|
// with the deamon.
|
|
if (!xmreg::CurrentBlockchainStatus::init_monero_blockchain())
|
|
{
|
|
cerr << "Error accessing blockchain." << endl;
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
// launch the status monitoring thread so that it keeps track of blockchain
|
|
// info, e.g., current height. Information from this thread is used
|
|
// by tx searching threads that are launched for each user independently,
|
|
// when they log back or create new account.
|
|
xmreg::CurrentBlockchainStatus::start_monitor_blockchain_thread();
|
|
|
|
|
|
// create REST JSON API services
|
|
|
|
xmreg::YourMoneroRequests open_monero(
|
|
shared_ptr<xmreg::MySqlAccounts>(new xmreg::MySqlAccounts{}));
|
|
|
|
// create Open Monero APIs
|
|
MAKE_RESOURCE(login);
|
|
MAKE_RESOURCE(get_address_txs);
|
|
MAKE_RESOURCE(get_address_info);
|
|
MAKE_RESOURCE(get_unspent_outs);
|
|
MAKE_RESOURCE(get_random_outs);
|
|
MAKE_RESOURCE(submit_raw_tx);
|
|
MAKE_RESOURCE(import_wallet_request);
|
|
MAKE_RESOURCE(import_recent_wallet_request);
|
|
MAKE_RESOURCE(get_version);
|
|
|
|
// restbed service
|
|
Service service;
|
|
|
|
// Publish the Open Monero API created so that front end can use it
|
|
service.publish(login);
|
|
service.publish(get_address_txs);
|
|
service.publish(get_address_info);
|
|
service.publish(get_unspent_outs);
|
|
service.publish(get_random_outs);
|
|
service.publish(submit_raw_tx);
|
|
service.publish(import_wallet_request);
|
|
service.publish(import_recent_wallet_request);
|
|
service.publish(get_version);
|
|
|
|
auto settings = make_shared<Settings>( );
|
|
|
|
if (config_json["ssl"]["enable"])
|
|
{
|
|
// based on the example provided at
|
|
// https://github.com/Corvusoft/restbed/blob/34187502642144ab9f749ab40f5cdbd8cb17a54a/example/https_service/source/example.cpp
|
|
auto ssl_settings = make_shared<SSLSettings>( );
|
|
|
|
Uri ssl_key = Uri(config_json["ssl"]["ssl-key"].get<string>());
|
|
Uri ssl_crt = Uri(config_json["ssl"]["ssl-crt"].get<string>());
|
|
Uri dh_pem = Uri(config_json["ssl"]["dh-pem"].get<string>());
|
|
|
|
ssl_settings->set_http_disabled(true);
|
|
ssl_settings->set_port(app_port);
|
|
ssl_settings->set_private_key(ssl_key);
|
|
ssl_settings->set_certificate(ssl_crt);
|
|
ssl_settings->set_temporary_diffie_hellman(dh_pem);
|
|
|
|
settings->set_ssl_settings(ssl_settings);
|
|
|
|
// can check using: curl -k -v -w'\n' -X POST 'https://127.0.0.1:1984/get_version'
|
|
|
|
cout << "Start the service at https://127.0.0.1:" << app_port << endl;
|
|
}
|
|
else
|
|
{
|
|
settings->set_port(app_port);
|
|
settings->set_default_header( "Connection", "close" );
|
|
|
|
cout << "Start the service at http://127.0.0.1:" << app_port << endl;
|
|
}
|
|
|
|
|
|
service.start(settings);
|
|
|
|
return EXIT_SUCCESS;
|
|
}
|