forked from skylersaleh/SkyEmu
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
4 changed files
with
213 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,144 @@ | ||
| extern "C" { | ||
| #include "retro_achievements.h" | ||
| } | ||
| #include "rcheevos/include/rc_client.h" | ||
| #include "httplib.h" | ||
| #include <stdio.h> | ||
| #include <future> | ||
| #include <memory> | ||
|
|
||
| rc_client_t* ra_client = NULL; | ||
|
|
||
| // httplib doesn't have a way to make async requests, so we need to do it ourselves | ||
| struct AsyncRequest | ||
| { | ||
| std::unique_ptr<httplib::Client> client; | ||
| std::future<httplib::Result> result_future; | ||
| rc_client_server_callback_t callback; | ||
| void* callback_data; | ||
| }; | ||
|
|
||
| std::vector<std::unique_ptr<AsyncRequest>> async_requests; | ||
|
|
||
| static void server_callback(const rc_api_request_t* request, | ||
| rc_client_server_callback_t callback, void* callback_data, rc_client_t* client) | ||
| { | ||
| // RetroAchievements may not allow hardcore unlocks if we don't properly identify ourselves. | ||
| const char* user_agent = "SkyEmu/4.0"; | ||
|
|
||
| std::unique_ptr<AsyncRequest> async_request(new AsyncRequest); | ||
|
|
||
| // Unfortunately request->url gives us the full URL, so we need to extract the GET parameters | ||
| // to pass to httplib | ||
| // TODO: switch to SSLClient and https, needs OpenSSL | ||
| std::string full_url = request->url; | ||
| std::string host = "http://retroachievements.org"; | ||
| std::string get_params; | ||
| std::string::size_type last_slash = full_url.find_last_of('/'); | ||
| if (last_slash != std::string::npos) | ||
| { | ||
| get_params = full_url.substr(last_slash); | ||
| } | ||
| else | ||
| { | ||
| printf("[rcheevos]: could not parse URL: %s\n", request->url); | ||
| return; | ||
| } | ||
|
|
||
| async_request->client.reset(new httplib::Client(host)); | ||
| async_request->callback = callback; | ||
| async_request->callback_data = callback_data; | ||
|
|
||
| // Copy it here as request is destroyed as soon as we return | ||
| std::string content_type = request->content_type; | ||
| std::string post_data = request->post_data; | ||
| if(request->post_data) | ||
| { | ||
| httplib::Result (httplib::Client::*gf)(const std::string&, const std::string&, const std::string&) = &httplib::Client::Post; | ||
| async_request->result_future = std::async(std::launch::async, gf, async_request->client.get(), get_params, post_data, content_type); | ||
| async_requests.push_back(std::move(async_request)); | ||
| } | ||
| else | ||
| { | ||
| httplib::Result (httplib::Client::*gf)(const std::string&) = &httplib::Client::Get; | ||
| async_request->result_future = std::async(std::launch::async, gf, async_request->client.get(), get_params); | ||
| async_requests.push_back(std::move(async_request)); | ||
| } | ||
| } | ||
|
|
||
| static void log_message(const char* message, const rc_client_t* client) | ||
| { | ||
| printf("[rcheevos]: %s\n", message); | ||
| } | ||
|
|
||
| void ra_initialize_client(rc_client_read_memory_func_t memory_read_func) | ||
| { | ||
| if(ra_client) | ||
| { | ||
| printf("[rcheevos]: client already initialized!\n"); | ||
| } | ||
| else | ||
| { | ||
| ra_client = rc_client_create(memory_read_func, server_callback); | ||
| #ifndef NDEBUG | ||
| rc_client_enable_logging(ra_client, RC_CLIENT_LOG_LEVEL_VERBOSE, log_message); | ||
| #endif | ||
| // TODO: should probably be an option after we're finished testing | ||
| rc_client_set_hardcore_enabled(ra_client, 0); | ||
| } | ||
| } | ||
|
|
||
| void ra_shutdown_client() | ||
| { | ||
| if(ra_client) | ||
| { | ||
| rc_client_destroy(ra_client); | ||
| ra_client = nullptr; | ||
| } | ||
| } | ||
|
|
||
| bool ra_is_logged_in() | ||
| { | ||
| return rc_client_get_user_info(ra_client) != NULL; | ||
| } | ||
|
|
||
| void ra_login_credentials(const char* username, const char* password, rc_client_callback_t login_callback) | ||
| { | ||
| rc_client_begin_login_with_password(ra_client, username, password, login_callback, NULL); | ||
| } | ||
|
|
||
| void ra_poll_requests() | ||
| { | ||
| // Check if any of our asynchronous requests have finished, and if so, call the callback | ||
| auto it = async_requests.begin(); | ||
| while(it != async_requests.end()) | ||
| { | ||
| const std::unique_ptr<AsyncRequest>& request = *it; | ||
| if (request->result_future.wait_for(std::chrono::seconds(0)) == std::future_status::ready) | ||
| { | ||
| httplib::Result result = request->result_future.get(); | ||
| if(result.error() == httplib::Error::Success) | ||
| { | ||
| rc_api_server_response_t response; | ||
| response.body = result->body.c_str(); | ||
| response.body_length = result->body.length(); | ||
| response.http_status_code = result->status; | ||
| request->callback(&response, request->callback_data); | ||
| } | ||
| else | ||
| { | ||
| printf("[rcheevos]: http request failed: %s\n", to_string(result.error()).c_str()); | ||
| } | ||
| it = async_requests.erase(it); | ||
| } | ||
| else | ||
| { | ||
| ++it; | ||
| } | ||
| } | ||
| } | ||
|
|
||
| void ra_login_token(const char* username, const char* token, rc_client_callback_t login_callback) | ||
| { | ||
| rc_client_begin_login_with_token(ra_client, username, token, login_callback, NULL); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,19 @@ | ||
| #ifndef RETRO_ACHIEVEMENTS | ||
| #define RETRO_ACHIEVEMENTS | ||
| #include <stdint.h> | ||
| #include <stddef.h> | ||
| #include <stdbool.h> | ||
|
|
||
| struct rc_client_t; | ||
| typedef struct rc_client_t rc_client_t; | ||
|
|
||
| typedef uint32_t (*rc_client_read_memory_func_t)(uint32_t address, uint8_t* buffer, uint32_t num_bytes, rc_client_t* client); | ||
| typedef void (*rc_client_callback_t)(int result, const char* error_message, rc_client_t* client, void* userdata); | ||
|
|
||
| bool ra_is_logged_in(); | ||
| void ra_initialize_client(rc_client_read_memory_func_t memory_read_func); | ||
| void ra_login_credentials(const char* username, const char* password, rc_client_callback_t login_callback); | ||
| void ra_login_token(const char* username, const char* token, rc_client_callback_t login_callback); | ||
| void ra_poll_requests(); | ||
| void ra_shutdown_client(); | ||
| #endif |