asymptotically
/
openmonero
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

some example rest methods added for tests

Browse Source
pull/1/head
moneroexamples 8 years ago
parent 7e18a14051
commit c2dd7f3b62
2 changed files with 163 additions and 24 deletions
Show Stats Download Patch File Download Diff File

3
CMakeLists.txt
Unescape View File

@ -19,4 +19,5 @@ add_executable(restbed_xmr
target_link_libraries(restbed_xmr
myext
restbed
pthread)
pthread
curl)

184
main.cpp
Unescape View File

@ -4,30 +4,156 @@
#include <cstdlib>
#include "ext/restbed/source/restbed"
#include "ext/date/tz.h"
#include "ext/json.hpp"
using namespace std;
using namespace restbed;
using namespace nlohmann;
string
get_current_time(const char* format = "%a, %d %b %Y %H:%M:%S %Z")
{
auto current_time = date::make_zoned(
date::current_zone(),
date::floor<chrono::seconds>(std::chrono::system_clock::now())
);
return date::format(format, current_time);
}
multimap<string, string>
make_headers(const multimap<string, string>& extra_headers = multimap<string, string>())
{
multimap<string, string> headers {
{"Date", get_current_time()},
{"Access-Control-Allow-Origin", "http://127.0.0.1"},
{"access-control-allow-headers", "*, DNT,X-CustomHeader,Keep-Alive,User-Agent,X-Requested-With,If-Modified-Since,Cache-Control,Content-Type,Set-Cookie"},
{"access-control-max-age", "86400, 1728000"},
{"access-control-allow-methods", "GET, POST, OPTIONS"},
{"access-control-allow-credentials", "true"},
{"Content-Type", "application/json"}
};
headers.insert(extra_headers.begin(), extra_headers.end());
return headers;
};
void
post_method_handler( const shared_ptr< Session > session )
generic_options_handler( const shared_ptr< Session > session )
{
const auto request = session->get_request( );
size_t content_length = request->get_header( "Content-Length", 0);
cout << "options_method_handler" << endl;
session->fetch(content_length, [ ]( const shared_ptr< Session > session, const Bytes & body )
{
string _body(reinterpret_cast<const char *>(body.data()), body.size());
cout << "requriest options_method_handler" << endl;
session->close( OK, string{}, make_headers());
} );
}
void
post_login_handler( const shared_ptr< Session > session )
{
const auto request = session->get_request( );
size_t content_length = request->get_header( "Content-Length", 0);
cout << "post_method_handler" << endl;
session->fetch(content_length, [ ]( const shared_ptr< Session > session, const Bytes & body )
{
string _body(reinterpret_cast<const char *>(body.data()), body.size());
cout << _body << endl;
string response_body {"test output"};
json j_response {{"new_address", true}};
string response_body = j_response.dump();
auto response_headers = make_headers({{ "Content-Length", to_string(response_body.size())}});
session->close( OK, response_body, {
{ "Content-Length", to_string(response_body.size()) },
{ "Content-Type", "application/json" }
} );
session->close( OK, response_body, response_headers);
} );
}
void
post_get_address_txs_handler( const shared_ptr< Session > session )
{
const auto request = session->get_request( );
size_t content_length = request->get_header( "Content-Length", 0);
cout << "post_get_address_txs_handler" << endl;
session->fetch(content_length, [ ]( const shared_ptr< Session > session, const Bytes & body )
{
string _body(reinterpret_cast<const char *>(body.data()), body.size());
cout << _body << endl;
json j_response {
{ "total_received", "0"},
{ "scanned_height", 2012455},
{ "scanned_block_height", 1195848},
{ "start_height", 2012455},
{ "transaction_height", 2012455},
{ "blockchain_height", 1195848}
};
string response_body = j_response.dump();
auto response_headers = make_headers({{ "Content-Length", to_string(response_body.size())}});
session->close( OK, response_body, response_headers);
} );
}
void
post_get_address_info_handler( const shared_ptr< Session > session )
{
const auto request = session->get_request( );
size_t content_length = request->get_header( "Content-Length", 0);
cout << "post_get_address_info_handler" << endl;
session->fetch(content_length, [ ]( const shared_ptr< Session > session, const Bytes & body )
{
string _body(reinterpret_cast<const char *>(body.data()), body.size());
cout << _body << endl;
json j_response {
{"locked_funds", "0"},
{"total_received", "0"},
{"total_sent", "0"},
{"scanned_height", 2012470},
{"scanned_block_height", 1195850},
{"start_height", 2012470},
{"transaction_height", 2012470},
{"blockchain_height", 1195850},
{"spent_outputs", nullptr}
};
string response_body = j_response.dump();
auto response_headers = make_headers({{ "Content-Length", to_string(response_body.size())}});
session->close( OK, response_body, response_headers);
} );
}
@ -35,34 +161,46 @@ int
main()
{
auto resource = make_shared< Resource >( );
resource->set_path( "/resource" );
resource->set_method_handler( "POST", post_method_handler );
auto resource_login = make_shared< Resource >( );
resource_login->set_path( "/login" );
resource_login->set_method_handler( "POST", post_login_handler );
resource_login->set_method_handler( "OPTIONS", generic_options_handler);
auto get_address_txs = make_shared< Resource >( );
get_address_txs->set_path( "/get_address_txs" );
get_address_txs->set_method_handler( "POST", post_get_address_txs_handler );
get_address_txs->set_method_handler( "OPTIONS", generic_options_handler);
// SSL based on this
// https://github.com/Corvusoft/restbed/blob/34187502642144ab9f749ab40f5cdbd8cb17a54a/example/https_service/source/example.cpp
auto ssl_settings = make_shared< SSLSettings >( );
ssl_settings->set_http_disabled( true );
ssl_settings->set_port( 1984 );
ssl_settings->set_private_key( Uri( "file:///tmp/server.key" ) );
ssl_settings->set_certificate( Uri( "file:///tmp/server.crt" ) );
ssl_settings->set_temporary_diffie_hellman( Uri( "file:///tmp/dh768.pem" ) );
auto get_address_info = make_shared< Resource >( );
get_address_info->set_path( "/get_address_info" );
get_address_info->set_method_handler( "POST", post_get_address_info_handler );
get_address_info->set_method_handler( "OPTIONS", generic_options_handler);
auto settings = make_shared< Settings >( );
settings->set_ssl_settings( ssl_settings );
//
// auto ssl_settings = make_shared< SSLSettings >( );
// ssl_settings->set_http_disabled( true );
// ssl_settings->set_port( 1984 );
// ssl_settings->set_private_key( Uri( "file:///tmp/server.key" ) );
// ssl_settings->set_certificate( Uri( "file:///tmp/server.crt" ) );
// ssl_settings->set_temporary_diffie_hellman( Uri( "file:///tmp/dh768.pem" ) );
//
//
// auto settings = make_shared< Settings >( );
// settings->set_ssl_settings( ssl_settings );
auto settings = make_shared< Settings >( );
settings->set_port( 1984 );
settings->set_default_header( "Connection", "close" );
cout << "Start the service at https://127.0.0.1:1984" << endl;
Service service;
service.publish( resource );
service.publish(resource_login);
service.publish(get_address_txs);
service.publish(get_address_info);
service.start( settings );
return EXIT_SUCCESS;
std::cout << "Hello, World!" << std::endl;
return 0;
}
Write Preview
Loading…
Cancel
Save