From 59e17037ecab935a021cafd55fbd48d05f7b3728 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: Sat, 15 Sep 2018 01:46:20 +0100
Subject: [PATCH] webhook multicurl, longer timeout, fixes

---
 Constants.h |  2 +-
 SC2Data.h   |  3 ---
 Webhook.cpp | 58 +++++++++++++++++++++++++++++++++++++++++------------
 3 files changed, 46 insertions(+), 17 deletions(-)

diff --git a/Constants.h b/Constants.h
index 7c6d9bd..6ba24e6 100644
--- a/Constants.h
+++ b/Constants.h
@@ -36,4 +36,4 @@ const int APP_LOADING = 13;
 
 const int GAME_INGAME = 14;
 const int GAME_OBS = 15;
-const int GAME_REPLAY = 16;
+const int GAME_REPLAY = 16;
\ No newline at end of file
diff --git a/SC2Data.h b/SC2Data.h
index 03df10a..74f0b24 100644
--- a/SC2Data.h
+++ b/SC2Data.h
@@ -16,9 +16,6 @@ class SC2Data : public QObject {
   	SC2State* state;
   	QTimer* timer;
 	vector<Observer*> watchers;
-  	//QNetworkAccessManager networkManager;
-	//QUrl uiUrl;
-	//QUrl gameUrl;
 
   public:
     explicit SC2Data(QObject* parent = Q_NULLPTR);
diff --git a/Webhook.cpp b/Webhook.cpp
index bd62489..d08bef3 100644
--- a/Webhook.cpp
+++ b/Webhook.cpp
@@ -37,15 +37,22 @@ void Webhook::notify(SC2State*& previous, SC2State*& current) {
 
  void Webhook::sendRequest(SC2State*& game, std::string event) {
  	if(!game->fullState.isReplay) {
-	 	CURL *curl;
-		CURLcode res;
-		
 		Config* cfg = Config::Current();
+
+		int still_running = 0;
+		int repeats = 0;
+		CURLM *multi_handle;
+		multi_handle = curl_multi_init();
  		
- 		// todo: make this a multi curl 
+		// vector of handles 
+		vector<CURL*> handles;
+
  		for (string &url : cfg->webhookURLList) {
-		 	curl = curl_easy_init();
-			if (curl) {
+			CURL *handle;
+			handle = curl_easy_init();
+			if (handle) {
+				curl_multi_add_handle(multi_handle, handle);
+				handles.push_back(handle);
 			 	std::string qdelim = "?";
 		 	  	std::size_t found = url.find(qdelim);
 				if (found!=std::string::npos) {
@@ -53,16 +60,41 @@ void Webhook::notify(SC2State*& previous, SC2State*& current) {
 				}
 
 				std::string resp = getJSONStringFromSC2State(game, event);
-			 	std::string c_url = url + qdelim + "json=" + curl_easy_escape(curl, resp.c_str(), 0);
-				curl_easy_setopt(curl, CURLOPT_URL, c_url.c_str());
-				curl_easy_setopt(curl, CURLOPT_TIMEOUT_MS, 150);
-				res = curl_easy_perform(curl);
-				curl_easy_cleanup(curl);
-				if (res != CURLE_OK) {
-					// pass
+			 	std::string c_url = url + qdelim + "json=" + curl_easy_escape(handle, resp.c_str(), 0);
+				curl_easy_setopt(handle, CURLOPT_URL, c_url.c_str());
+				curl_easy_setopt(handle, CURLOPT_TIMEOUT_MS, 500);
+			}
+		}
+
+		curl_multi_perform(multi_handle, &still_running);
+		while(still_running) {
+			CURLMcode mc; /* curl_multi_wait() return code */ 
+			int numfds;
+			mc = curl_multi_wait(multi_handle, NULL, 0, 1000, &numfds);
+
+			if(mc != CURLM_OK) {
+				break;
+			}
+
+			if(!numfds) {
+				repeats++;
+				if(repeats > 1) {
+					break;
 				}
 			}
+			else {
+				repeats = 0;
+			}
+
+			curl_multi_perform(multi_handle, &still_running);
+		}
+
+		// clean up each handle
+		for (CURL* &handle : handles) {
+			curl_multi_remove_handle(multi_handle, handle);
+  			curl_easy_cleanup(handle);
 		}
+		curl_multi_cleanup(multi_handle);
 	}
  }