summaryrefslogtreecommitdiff
path: root/discord/httpclient.cpp
diff options
context:
space:
mode:
authorDylam De La Torre <DyXel04@gmail.com>2021-11-23 05:21:56 +0100
committerGitHub <noreply@github.com>2021-11-23 04:21:56 +0000
commita51a54bc5979a2491f152abc47ad54e6b63f27c8 (patch)
treece67092b2f6df366033a65a6111e4650866766b2 /discord/httpclient.cpp
parentd88079000a79e6bcbe51c5a2868d57b303b5fcb6 (diff)
downloadabaddon-portaudio-a51a54bc5979a2491f152abc47ad54e6b63f27c8.tar.gz
abaddon-portaudio-a51a54bc5979a2491f152abc47ad54e6b63f27c8.zip
Restructure source and resource files (#46)
importantly, res is now res/res and css is now res/css
Diffstat (limited to 'discord/httpclient.cpp')
-rw-r--r--discord/httpclient.cpp139
1 files changed, 0 insertions, 139 deletions
diff --git a/discord/httpclient.cpp b/discord/httpclient.cpp
deleted file mode 100644
index 05474df..0000000
--- a/discord/httpclient.cpp
+++ /dev/null
@@ -1,139 +0,0 @@
-#include "httpclient.hpp"
-
-//#define USE_LOCAL_PROXY
-HTTPClient::HTTPClient() {
- m_dispatcher.connect(sigc::mem_fun(*this, &HTTPClient::RunCallbacks));
-}
-
-void HTTPClient::SetBase(const std::string &url) {
- m_api_base = url;
-}
-
-void HTTPClient::SetUserAgent(std::string agent) {
- m_agent = agent;
-}
-
-void HTTPClient::SetAuth(std::string auth) {
- m_authorization = auth;
-}
-
-void HTTPClient::MakeDELETE(const std::string &path, std::function<void(http::response_type r)> cb) {
- printf("DELETE %s\n", path.c_str());
- m_futures.push_back(std::async(std::launch::async, [this, path, cb] {
- http::request req(http::REQUEST_DELETE, m_api_base + path);
- req.set_header("Authorization", m_authorization);
- req.set_user_agent(m_agent != "" ? m_agent : "Abaddon");
-#ifdef USE_LOCAL_PROXY
- req.set_proxy("http://127.0.0.1:8888");
- req.set_verify_ssl(false);
-#endif
-
- auto res = req.execute();
-
- OnResponse(res, cb);
- }));
-}
-
-void HTTPClient::MakePATCH(const std::string &path, const std::string &payload, std::function<void(http::response_type r)> cb) {
- printf("PATCH %s\n", path.c_str());
- m_futures.push_back(std::async(std::launch::async, [this, path, cb, payload] {
- http::request req(http::REQUEST_PATCH, m_api_base + path);
- req.set_header("Authorization", m_authorization);
- req.set_header("Content-Type", "application/json");
- req.set_user_agent(m_agent != "" ? m_agent : "Abaddon");
- req.set_body(payload);
-#ifdef USE_LOCAL_PROXY
- req.set_proxy("http://127.0.0.1:8888");
- req.set_verify_ssl(false);
-#endif
-
- auto res = req.execute();
-
- OnResponse(res, cb);
- }));
-}
-
-void HTTPClient::MakePOST(const std::string &path, const std::string &payload, std::function<void(http::response_type r)> cb) {
- printf("POST %s\n", path.c_str());
- m_futures.push_back(std::async(std::launch::async, [this, path, cb, payload] {
- http::request req(http::REQUEST_POST, m_api_base + path);
- req.set_header("Authorization", m_authorization);
- req.set_header("Content-Type", "application/json");
- req.set_user_agent(m_agent != "" ? m_agent : "Abaddon");
- req.set_body(payload);
-#ifdef USE_LOCAL_PROXY
- req.set_proxy("http://127.0.0.1:8888");
- req.set_verify_ssl(false);
-#endif
-
- auto res = req.execute();
-
- OnResponse(res, cb);
- }));
-}
-
-void HTTPClient::MakePUT(const std::string &path, const std::string &payload, std::function<void(http::response_type r)> cb) {
- printf("PUT %s\n", path.c_str());
- m_futures.push_back(std::async(std::launch::async, [this, path, cb, payload] {
- http::request req(http::REQUEST_PUT, m_api_base + path);
- req.set_header("Authorization", m_authorization);
- if (payload != "")
- req.set_header("Content-Type", "application/json");
- req.set_user_agent(m_agent != "" ? m_agent : "Abaddon");
- req.set_body(payload);
-#ifdef USE_LOCAL_PROXY
- req.set_proxy("http://127.0.0.1:8888");
- req.set_verify_ssl(false);
-#endif
-
- auto res = req.execute();
-
- OnResponse(res, cb);
- }));
-}
-
-void HTTPClient::MakeGET(const std::string &path, std::function<void(http::response_type r)> cb) {
- printf("GET %s\n", path.c_str());
- m_futures.push_back(std::async(std::launch::async, [this, path, cb] {
- http::request req(http::REQUEST_GET, m_api_base + path);
- req.set_header("Authorization", m_authorization);
- req.set_header("Content-Type", "application/json");
- req.set_user_agent(m_agent != "" ? m_agent : "Abaddon");
-#ifdef USE_LOCAL_PROXY
- req.set_proxy("http://127.0.0.1:8888");
- req.set_verify_ssl(false);
-#endif
-
- auto res = req.execute();
-
- OnResponse(res, cb);
- }));
-}
-
-void HTTPClient::CleanupFutures() {
- for (auto it = m_futures.begin(); it != m_futures.end();) {
- if (it->wait_for(std::chrono::seconds(0)) == std::future_status::ready)
- it = m_futures.erase(it);
- else
- it++;
- }
-}
-
-void HTTPClient::RunCallbacks() {
- m_mutex.lock();
- m_queue.front()();
- m_queue.pop();
- m_mutex.unlock();
-}
-
-void HTTPClient::OnResponse(const http::response_type &r, std::function<void(http::response_type r)> cb) {
- CleanupFutures();
- try {
- m_mutex.lock();
- m_queue.push([this, r, cb] { cb(r); });
- m_dispatcher.emit();
- m_mutex.unlock();
- } catch (const std::exception &e) {
- fprintf(stderr, "error handling response (%s, code %d): %s\n", r.url.c_str(), r.status_code, e.what());
- }
-}