libs/gateway/Websocket.hpp

@@ -183,12 +183,12 @@ public:
     int getIntents() const {
         return WebSocket::intents;
     }
-    void on(const int event, std::function<void(const json&&)> handler) {
+    void on(const int event, std::function<void(const json&)> handler) {
         eventHandlers[events[event].second] = [handler](const json& message) {
             handler(message.get<json>());
         };
     }
-    void once(const int event, std::function<void(const json&&)> handler) {
+    void once(const int event, std::function<void(const json&)> handler) {
         eventHandlers[events[event].second] = [event, handler, isCalled = false](const json& message) mutable {
             isCalled == false ? isCalled = true : 0, handler(message.get<json>());
         };

libs/tls/Network.hpp

@@ -68,23 +68,32 @@ private:
             createSSLConnection("discord.com", "443");
         }
     }
-    std::string extract(const std::string& httpResponse) {
+    std::string parseJson(const std::string& response) {
-        unsigned long pos = httpResponse.find("\r\n\r\n");
+        unsigned long jsonStart = response.find("\r\n\r\n");
-        if (pos != std::string::npos) {
+        if (jsonStart == std::string::npos) {
-            std::string json, chunkSizeStr;
-            std::istringstream stream(httpResponse.substr(pos + 4));
-            while (std::getline(stream, chunkSizeStr)) {
-                unsigned long chunkSize = std::stoul(chunkSizeStr, nullptr, 16);
-                if (chunkSize == 0) break;
-                std::string chunk(chunkSize, '\0');
-                stream.read(&chunk[0], chunkSize);
-                json.append(chunk);
-                stream.ignore(2);
-            }
-            return json;
-        }
             return "";
         }
+        jsonStart += 4;
+        std::string jsonString = response.substr(jsonStart);
+        unsigned long jsonBegin = jsonString.find('['), jsonEnd = jsonString.rfind(']');
+        if (jsonBegin == std::string::npos || jsonEnd == std::string::npos || jsonEnd < jsonBegin) {
+            return "";
+        }
+        jsonString = jsonString.substr(jsonBegin, jsonEnd - jsonBegin + 1);
+        jsonString.erase(std::remove(jsonString.begin(), jsonString.end(), '\r'), jsonString.end());
+        jsonString.erase(std::remove(jsonString.begin(), jsonString.end(), '\t'), jsonString.end());
+        jsonString.erase(std::remove(jsonString.begin(), jsonString.end(), '\n'), jsonString.end());
+        jsonString.erase(std::remove(jsonString.begin(), jsonString.end(), '\\'), jsonString.end());
+        jsonString.erase(std::remove(jsonString.begin(), jsonString.end(), '\''), jsonString.end());
+        jsonString.erase(std::remove(jsonString.begin(), jsonString.end(), ' '), jsonString.end());
+        try {
+            nlohmann::json jsonData = nlohmann::json::parse(jsonString);
+            return jsonData.dump();
+        }
+        catch (const nlohmann::json::parse_error& e) {
+            return "";
+        }
+    }
 public:
     static NetworkManager& getInstance() {
         Logs::create(WARNING, NETWORK, "Instance event");
@@ -95,28 +104,25 @@ public:
         if (ctx) SSL_CTX_free(ctx);
         close(sock);
     }
-    std::string request(const std::string& method, const std::string& path, const std::string& data = "", bool closeConnection = true) {
+    std::string request(const std::string& method, const std::string& path, const std::string& data = "") {
-        if (closeConnection) createSSLConnection("discord.com", "443");
+    #ifdef DEBUG
-        auto net = [this, method, path, data, closeConnection, result = std::string("")]() mutable -> std::string {
+        createSSLConnection("discord.com", "443");
-            std::string request = method + " " + path + " HTTP/1.1\r\n";
+    #endif
-            request += "Host: discord.com\r\n";
+        auto net = [this, method, path, data, result = std::string("")]() mutable -> std::string {
-            request += "Accept: application/json\r\n";
+            std::string request = method + " " + path + " HTTP/1.1\r\nHost: discord.com\r\nAccept: application/json\r\nContent-Type: application/json\r\n";
-            request += "Content-Type: application/json\r\n";
+            request += "Authorization: " + web.getToken() + "\r\nContent-Length: " + std::to_string(data.length()) + "\r\n";
-            request += "Authorization: " + web.getToken() + "\r\n";
+        #ifdef DEBUG
-            request += "Content-Length: " + std::to_string(data.length()) + "\r\n";
-            if (closeConnection) {
             request += "Connection: close\r\n\r\n";
-            } else {
+        #elif defined(RELEASE)
             request += "Connection: keep-alive\r\n\r\n";
-            }
+        #endif
             request += data;
             if (SSL_write(ssl.get(), request.c_str(), request.length()) <= 0) {
                 Logs::create(ERROR, NETWORK, "Failed to send request");
                 handleSSLInitErrors();
-                return "";
             }
             Logs::create(INFO, NETWORK, "Request " + method + " " + path);
-            if (closeConnection) {
+        #ifdef DEBUG
             std::vector<char> buffer(1024);
             int bytesRead;
             while ((bytesRead = SSL_read(ssl.get(), buffer.data(), buffer.size())) > 0) {
@@ -125,8 +131,10 @@ public:
                     buffer.resize(buffer.size() * 2);
                 }
             }
-            }
+            return parseJson(result);
-            return extract(result);
+        #elif defined(RELEASE)
+            return result;
+        #endif
         };
         return net();
     }

libs/utils/enums.hpp

@@ -98,8 +98,7 @@ enum GatewayIntents {
     GuildScheduledEvents = 65536,
     GuildVoiceStates = 128,
     GuildWebhooks = 32,
-    MessageContent = 32768,
+    MessageContent = 32768
-    AllIntents = 131071
 };
 enum UserStatus {
     Offline,

libs/utils/logs.hpp

@@ -11,7 +11,6 @@ enum type { WEBSOCKET, NETWORK };
 class Logs {
 public:
     static void create(level lvl, type t, const std::string& message) {
-        #ifdef DEBUG
         std::string color;
         switch (lvl) {
         case INFO:
@@ -28,7 +27,6 @@ public:
         break;
         }
         std::cout << color << "[" << getCurrentTime() << "][" << str(t) << "][" << str(lvl) << "] \033[37m" << message << "\033[0m" << std::endl;
-        #endif
     }
 private:
     static std::string getCurrentTime() {

sources/main.cpp

@@ -2,15 +2,10 @@
 #include <includes.h>
 int main(int argc, char* argv[]) {
     if (argc != 3) return -1;
-    WebSocket* bot = &WebSocket::getInstance(argv[2], GatewayIntents::AllIntents);
+    WebSocket* bot = &WebSocket::getInstance(argv[2], 131071);
-    bot->on(GatewayEvents::READY, [](const Bot<Message, User, Author>& msg) {
-        if (!g(2, msg.net)->isBot()) {
-            cout << g(0, msg.net)->send("939957962972229634", j("content", "asd")) << endl;
-        }
-    });
     bot->on(GatewayEvents::MESSAGE_CREATE, [](const Bot<Message, User, Author>& msg) {
         if (!g(2, msg.net)->isBot()) {
-            cout << g(0, msg.net)->send("939957962972229634", j("content", g(2, msg.net)->content())) << endl;
+            g(0, msg.net)->send("939957962972229634", j("content", g(2, msg.net)->content()));
         }
     });
     bot->start();