pajlada
032f290767
This change enforces strict include grouping using IncludeCategories
In addition to adding this to the .clang-format file and applying it in the tests/src and src directories, I also did the following small changes:
In ChatterSet.hpp, I changed lrucache to a <>include
In Irc2.hpp, I change common/SignalVector.hpp to a "project-include"
In AttachedWindow.cpp, NativeMessaging.cpp, WindowsHelper.hpp, BaseWindow.cpp, and StreamerMode.cpp, I disabled clang-format for the windows-includes
In WindowDescriptors.hpp, I added the missing vector include. It was previously not needed because the include was handled by another file that was previously included first.
clang-format minimum version has been bumped, so Ubuntu version used in the check-formatting job has been bumped to 22.04 (which is the latest LTS)
104 lines
3.6 KiB
C++
104 lines
3.6 KiB
C++
#include "providers/seventv/SeventvEventAPI.hpp"
|
|
|
|
#include <boost/optional.hpp>
|
|
#include <gtest/gtest.h>
|
|
#include <QString>
|
|
|
|
using namespace chatterino;
|
|
using namespace std::chrono_literals;
|
|
|
|
const QString EMOTE_SET_A = "60b39e943e203cc169dfc106";
|
|
const QString EMOTE_SET_B = "60bca831e7ecd2f892c9b9ab";
|
|
const QString TARGET_USER_ID = "60b39e943e203cc169dfc106";
|
|
|
|
TEST(SeventvEventAPI, AllEvents)
|
|
{
|
|
const QString host("wss://127.0.0.1:9050/liveupdates/seventv/all-events");
|
|
auto *eventAPI = new SeventvEventAPI(host, std::chrono::milliseconds(1000));
|
|
eventAPI->start();
|
|
|
|
boost::optional<SeventvEventAPIEmoteAddDispatch> addDispatch;
|
|
boost::optional<SeventvEventAPIEmoteUpdateDispatch> updateDispatch;
|
|
boost::optional<SeventvEventAPIEmoteRemoveDispatch> removeDispatch;
|
|
boost::optional<SeventvEventAPIUserConnectionUpdateDispatch> userDispatch;
|
|
|
|
eventAPI->signals_.emoteAdded.connect([&](const auto &d) {
|
|
addDispatch = d;
|
|
});
|
|
eventAPI->signals_.emoteUpdated.connect([&](const auto &d) {
|
|
updateDispatch = d;
|
|
});
|
|
eventAPI->signals_.emoteRemoved.connect([&](const auto &d) {
|
|
removeDispatch = d;
|
|
});
|
|
eventAPI->signals_.userUpdated.connect([&](const auto &d) {
|
|
userDispatch = d;
|
|
});
|
|
|
|
std::this_thread::sleep_for(50ms);
|
|
eventAPI->subscribeUser("", EMOTE_SET_A);
|
|
std::this_thread::sleep_for(500ms);
|
|
|
|
ASSERT_EQ(eventAPI->diag.connectionsOpened, 1);
|
|
ASSERT_EQ(eventAPI->diag.connectionsClosed, 0);
|
|
ASSERT_EQ(eventAPI->diag.connectionsFailed, 0);
|
|
|
|
auto add = *addDispatch;
|
|
ASSERT_EQ(add.emoteSetID, EMOTE_SET_A);
|
|
ASSERT_EQ(add.actorName, QString("nerixyz"));
|
|
ASSERT_EQ(add.emoteID, QString("621d13967cc2d4e1953838ed"));
|
|
|
|
auto upd = *updateDispatch;
|
|
ASSERT_EQ(upd.emoteSetID, EMOTE_SET_A);
|
|
ASSERT_EQ(upd.actorName, QString("nerixyz"));
|
|
ASSERT_EQ(upd.emoteID, QString("621d13967cc2d4e1953838ed"));
|
|
ASSERT_EQ(upd.oldEmoteName, QString("Chatterinoge"));
|
|
ASSERT_EQ(upd.emoteName, QString("Chatterino"));
|
|
|
|
auto rem = *removeDispatch;
|
|
ASSERT_EQ(rem.emoteSetID, EMOTE_SET_A);
|
|
ASSERT_EQ(rem.actorName, QString("nerixyz"));
|
|
ASSERT_EQ(rem.emoteName, QString("Chatterino"));
|
|
ASSERT_EQ(rem.emoteID, QString("621d13967cc2d4e1953838ed"));
|
|
|
|
ASSERT_EQ(userDispatch.has_value(), false);
|
|
addDispatch = boost::none;
|
|
updateDispatch = boost::none;
|
|
removeDispatch = boost::none;
|
|
|
|
eventAPI->subscribeUser(TARGET_USER_ID, "");
|
|
std::this_thread::sleep_for(50ms);
|
|
|
|
ASSERT_EQ(addDispatch.has_value(), false);
|
|
ASSERT_EQ(updateDispatch.has_value(), false);
|
|
ASSERT_EQ(removeDispatch.has_value(), false);
|
|
|
|
auto user = *userDispatch;
|
|
ASSERT_EQ(user.userID, TARGET_USER_ID);
|
|
ASSERT_EQ(user.actorName, QString("nerixyz"));
|
|
ASSERT_EQ(user.oldEmoteSetID, EMOTE_SET_A);
|
|
ASSERT_EQ(user.emoteSetID, EMOTE_SET_B);
|
|
ASSERT_EQ(user.connectionIndex, 0);
|
|
|
|
eventAPI->stop();
|
|
ASSERT_EQ(eventAPI->diag.connectionsOpened, 1);
|
|
ASSERT_EQ(eventAPI->diag.connectionsClosed, 1);
|
|
ASSERT_EQ(eventAPI->diag.connectionsFailed, 0);
|
|
}
|
|
|
|
TEST(SeventvEventAPI, NoHeartbeat)
|
|
{
|
|
const QString host("wss://127.0.0.1:9050/liveupdates/seventv/no-heartbeat");
|
|
auto *eventApi = new SeventvEventAPI(host, std::chrono::milliseconds(1000));
|
|
eventApi->start();
|
|
|
|
std::this_thread::sleep_for(50ms);
|
|
eventApi->subscribeUser("", EMOTE_SET_A);
|
|
std::this_thread::sleep_for(1250ms);
|
|
ASSERT_EQ(eventApi->diag.connectionsOpened, 2);
|
|
ASSERT_EQ(eventApi->diag.connectionsClosed, 1);
|
|
ASSERT_EQ(eventApi->diag.connectionsFailed, 0);
|
|
|
|
eventApi->stop();
|
|
}
|