rcxpony/sparkle
1
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Activity

.h -> .hpp

Browse Source
This commit is contained in:
fluttershy 2025-01-25 13:22:59 +05:00
parent ebdefba4e2
commit 2da2fb1ca2
14 changed files with 61 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
include/api.h → include/api.hpp
View File

@ -1,5 +1,5 @@
#ifndef INCLUDE_API_H_ #ifndef INCLUDE_API_HPP_
#define INCLUDE_API_H_ #define INCLUDE_API_HPP_
#include <api/Author.hpp> #include <api/Author.hpp>
#include <api/Message.hpp> #include <api/Message.hpp>
#include <api/Channel.hpp> #include <api/Channel.hpp>

4
include/includes.h → include/includes.hpp
View File

@ -1,5 +1,5 @@
#ifndef INCLUDE_INCLUDES_H_ #ifndef INCLUDE_INCLUDES_HPP_
#define INCLUDE_INCLUDES_H_ #define INCLUDE_INCLUDES_HPP_
#include <utils/types.hpp> #include <utils/types.hpp>
#include <utils/json.hpp> #include <utils/json.hpp>
#include <utils/log.hpp> #include <utils/log.hpp>

4
include/net.h → include/net.hpp
View File

@ -1,5 +1,5 @@
#ifndef INCLUDE_NET_H_ #ifndef INCLUDE_NET_HPP_
#define INCLUDE_NET_H_ #define INCLUDE_NET_HPP_
#include <gateway/Websocket.hpp> #include <gateway/Websocket.hpp>
#include <network/Network.hpp> #include <network/Network.hpp>
#endif #endif

9
libs/api/Author.hpp
View File

@ -1,11 +1,11 @@
#ifndef API_AUTHOR_HPP_ #ifndef API_AUTHOR_HPP_
#define API_AUTHOR_HPP_ #define API_AUTHOR_HPP_
#include <includes.h> #include <includes.hpp>
#include <net.h> #include <net.hpp>
class Author { class Author {
private: private:
nlohmann::json data; nlohmann::json data;
const nlohmann::json &d; const nlohmann::json& d;
WebSocket& web; WebSocket& web;
NetworkManager& req; NetworkManager& req;
public: public:
@ -25,7 +25,8 @@ public:
discriminator(d["author"]["discriminator"]), discriminator(d["author"]["discriminator"]),
message_id(d["id"]), message_id(d["id"]),
isPinned(d["pinned"]), isPinned(d["pinned"]),
isBot(d["author"].contains("bot") ? d["author"]["bot"].get<bool>() : false) {}; isBot(d["author"].contains("bot") ? d["author"]["bot"].get<bool>() : false) {
};
std::string send(const nlohmann::json& msg) { std::string send(const nlohmann::json& msg) {
return req.request(HttpMethods::POST, DiscordEndpoints::details::latest + "/channels/" + d["channel_id"].get<std::string>() + "/messages", msg.dump()); return req.request(HttpMethods::POST, DiscordEndpoints::details::latest + "/channels/" + d["channel_id"].get<std::string>() + "/messages", msg.dump());
} }

5
libs/api/Bot.hpp
View File

@ -1,6 +1,6 @@
#ifndef API_BOT_HPP_ #ifndef API_BOT_HPP_
#define API_BOT_HPP_ #define API_BOT_HPP_
#include <includes.h> #include <includes.hpp>
template<typename...Args> template<typename...Args>
class Discord { class Discord {
private: private:
@ -33,8 +33,7 @@ public:
bool isBot() const { bool isBot() const {
try { try {
return data["d"]["bot"]; return data["d"]["bot"];
} } catch (...) {
catch (...) {
return false; return false;
} }
} }

4
libs/api/Channel.hpp
View File

@ -1,7 +1,7 @@
#ifndef API_CHANNEL_HPP_ #ifndef API_CHANNEL_HPP_
#define API_CHANNEL_HPP_ #define API_CHANNEL_HPP_
#include <includes.h> #include <includes.hpp>
#include <net.h> #include <net.hpp>
class Channel { class Channel {
private: private:
nlohmann::json data; nlohmann::json data;

2
libs/api/Embed.hpp
View File

@ -1,6 +1,6 @@
#ifndef API_EMBED_HPP_ #ifndef API_EMBED_HPP_
#define API_EMBED_HPP_ #define API_EMBED_HPP_
#include <includes.h> #include <includes.hpp>
class EmbedBuilder { class EmbedBuilder {
private: private:
nlohmann::json embed = { nlohmann::json embed = {

4
libs/api/Guild.hpp
View File

@ -1,7 +1,7 @@
#ifndef API_GUILD_HPP_ #ifndef API_GUILD_HPP_
#define API_GUILD_HPP_ #define API_GUILD_HPP_
#include <includes.h> #include <includes.hpp>
#include <net.h> #include <net.hpp>
class Guild { class Guild {
private: private:
nlohmann::json data; nlohmann::json data;

9
libs/api/Message.hpp
View File

@ -1,7 +1,7 @@
#ifndef API_MESSAGE_HPP_ #ifndef API_MESSAGE_HPP_
#define API_MESSAGE_HPP_ #define API_MESSAGE_HPP_
#include <includes.h> #include <includes.hpp>
#include <net.h> #include <net.hpp>
class Message { class Message {
private: private:
nlohmann::json data; nlohmann::json data;
@ -15,8 +15,7 @@ public:
std::string getMessages(const std::string& id, const std::string& count, const std::string& before = "") { std::string getMessages(const std::string& id, const std::string& count, const std::string& before = "") {
if (before.empty()) { if (before.empty()) {
return req.request(HttpMethods::GET, DiscordEndpoints::details::latest + "/channels/" + id + "/messages?limit=" + count); return req.request(HttpMethods::GET, DiscordEndpoints::details::latest + "/channels/" + id + "/messages?limit=" + count);
} } else {
else {
return req.request(HttpMethods::GET, DiscordEndpoints::details::latest + "/channels/" + id + "/messages?before=" + before + "&limit=" + count); return req.request(HttpMethods::GET, DiscordEndpoints::details::latest + "/channels/" + id + "/messages?before=" + before + "&limit=" + count);
} }
return ""; return "";
@ -25,7 +24,7 @@ public:
return req.request(HttpMethods::DELETE, DiscordEndpoints::details::latest + "/channels/" + channel_id + "/messages/" + message_id); return req.request(HttpMethods::DELETE, DiscordEndpoints::details::latest + "/channels/" + channel_id + "/messages/" + message_id);
} }
nlohmann::json pack(const nlohmann::json& key, const std::string& value) const { nlohmann::json pack(const nlohmann::json& key, const std::string& value) const {
return {{ key, value }}; return { { key, value } };
} }
struct Api { struct Api {
nlohmann::json data; nlohmann::json data;

14
libs/api/User.hpp
View File

@ -1,7 +1,7 @@
#ifndef API_USER_HPP_ #ifndef API_USER_HPP_
#define API_USER_HPP_ #define API_USER_HPP_
#include <includes.h> #include <includes.hpp>
#include <net.h> #include <net.hpp>
#include <vector> #include <vector>
class User { class User {
private: private:
@ -10,7 +10,7 @@ private:
NetworkManager& req; NetworkManager& req;
public: public:
User(const nlohmann::json& data = "") : data(data), web(WebSocket::getInstance()), req(NetworkManager::getInstance()) {} User(const nlohmann::json& data = "") : data(data), web(WebSocket::getInstance()), req(NetworkManager::getInstance()) {}
#ifdef DEBUG #ifdef DEBUG
nlohmann::json extract(const std::vector<std::string>& keys) { nlohmann::json extract(const std::vector<std::string>& keys) {
std::vector<std::string> d = { "d" }; std::vector<std::string> d = { "d" };
d.insert(d.end(), keys.begin(), keys.end()); d.insert(d.end(), keys.begin(), keys.end());
@ -18,22 +18,20 @@ public:
for (const auto& key : d) { for (const auto& key : d) {
if (current.contains(key)) { if (current.contains(key)) {
current = current[key]; current = current[key];
} } else {
else {
return "Key not found."; return "Key not found.";
} }
} }
return current; return current;
} }
#endif #endif
std::string me() { std::string me() {
return req.request(HttpMethods::GET, DiscordEndpoints::details::latest + "/users/@me"); return req.request(HttpMethods::GET, DiscordEndpoints::details::latest + "/users/@me");
} }
bool isBot() const { bool isBot() const {
try { try {
return data["d"]["author"]["bot"]; return data["d"]["author"]["bot"];
} } catch (...) {
catch (...) {
return false; return false;
} }
} }

56
libs/gateway/Websocket.hpp
View File

@ -1,6 +1,6 @@
#ifndef GATEWAY_WEBSOCKET_HPP_ #ifndef GATEWAY_WEBSOCKET_HPP_
#define GATEWAY_WEBSOCKET_HPP_ #define GATEWAY_WEBSOCKET_HPP_
#include <includes.h> #include <includes.hpp>
#include <thread> #include <thread>
#include <ixwebsocket/IXNetSystem.h> #include <ixwebsocket/IXNetSystem.h>
#include <ixwebsocket/IXWebSocket.h> #include <ixwebsocket/IXWebSocket.h>
@ -30,19 +30,19 @@ private:
{"browser", "firefox"}, {"browser", "firefox"},
{"device", "firefox"} {"device", "firefox"}
}}, }},
//{"compress", 1}, //{"compress", 1},
{"presence", { {"presence", {
{"activities", nlohmann::json::array({ {"activities", nlohmann::json::array({
{ {
//{"name", "asdsadsadsadsa"}, //{"name", "asdsadsadsadsa"},
//{"type", 2} //{"type", 2}
} }
})}, })},
{"status", "idle"}, {"status", "idle"},
{"since", 91879201}, {"since", 91879201},
{"afk", false} {"afk", false}
}}
}} }}
}}
}; };
ix::initNetSystem(); ix::initNetSystem();
webSocket.setUrl("wss://gateway.discord.gg/?v=10&encoding=json"); webSocket.setUrl("wss://gateway.discord.gg/?v=10&encoding=json");
@ -53,22 +53,22 @@ private:
res = nlohmann::json::parse(msg->str); res = nlohmann::json::parse(msg->str);
Log::create(INFO, WEBSOCKET, res["op"].dump() + " " + res["t"].dump()); Log::create(INFO, WEBSOCKET, res["op"].dump() + " " + res["t"].dump());
switch (res["op"].get<int>()) { switch (res["op"].get<int>()) {
case 10: case 10:
heartbeat_interval = res["d"]["heartbeat_interval"].get<int>(); heartbeat_interval = res["d"]["heartbeat_interval"].get<int>();
!connected ? connected = true, webSocket.send(id.dump()) : 0; !connected ? connected = true, webSocket.send(id.dump()) : 0;
std::thread([this, &heartbeat_interval, &connected]() { std::thread([this, &heartbeat_interval, &connected]() {
while (connected && heartbeat_interval != -1) { while (connected && heartbeat_interval != -1) {
Log::create(INFO, WEBSOCKET, "Heartbeat " + std::to_string(heartbeat_interval)); Log::create(INFO, WEBSOCKET, "Heartbeat " + std::to_string(heartbeat_interval));
std::this_thread::sleep_for(milliseconds(heartbeat_interval)); std::this_thread::sleep_for(milliseconds(heartbeat_interval));
webSocket.send(payload.dump()); webSocket.send(payload.dump());
}
}).detach();
break;
case 0:
if (eventHandlers.find(res["t"].get<std::string>()) != eventHandlers.end()) {
eventHandlers[res["t"].get<std::string>()](res);
} }
}).detach(); break;
break;
case 0:
if (eventHandlers.find(res["t"].get<std::string>()) != eventHandlers.end()) {
eventHandlers[res["t"].get<std::string>()](res);
}
break;
} }
} }
}); });

2
libs/network/Network.hpp
View File

@ -1,6 +1,6 @@
#ifndef TLS_NETWORK_HPP_ #ifndef TLS_NETWORK_HPP_
#define TLS_NETWORK_HPP_ #define TLS_NETWORK_HPP_
#include <includes.h> #include <includes.hpp>
#include <gateway/Websocket.hpp> #include <gateway/Websocket.hpp>
#include <curl/curl.h> #include <curl/curl.h>
class NetworkManager { class NetworkManager {

4
sources/main.cpp
View File

@ -1,5 +1,5 @@
#include <api.h> #include <api.hpp>
#include <includes.h> #include <includes.hpp>
int main(int argc, char* argv[]) { int main(int argc, char* argv[]) {
if (argc != 3) return -1; if (argc != 3) return -1;
WebSocket* bot = &WebSocket::getInstance(argv[2], GatewayIntents::AllIntents); WebSocket* bot = &WebSocket::getInstance(argv[2], GatewayIntents::AllIntents);

4
tests/tests.cpp
View File

@ -1,6 +1,6 @@
#include <gtest/gtest.h> #include <gtest/gtest.h>
#include <includes.h> #include <includes.hpp>
#include <net.h> #include <net.hpp>
TEST(NetworkManagerTest, RequestReturnsExpectedValue) { TEST(NetworkManagerTest, RequestReturnsExpectedValue) {
NetworkManager& networkManager = NetworkManager::getInstance(); NetworkManager& networkManager = NetworkManager::getInstance();
EXPECT_FALSE(networkManager.request(HttpMethods::POST, DiscordEndpoints::details::latest + "/channels/939957962972229634/messages", { "content", "test" }).empty()); EXPECT_FALSE(networkManager.request(HttpMethods::POST, DiscordEndpoints::details::latest + "/channels/939957962972229634/messages", { "content", "test" }).empty());