noury/mirror-chatterino2
1
0
Fork 0
mirror of https://github.com/Chatterino/chatterino2.git synced 2024-11-13 19:49:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add support for channel.ban v1 to replace pubsub

Browse source 
downside is it's broadcaster only, so it's not a good replacement yet
This commit is contained in:
Rasmus Karlsson 2023-11-18 14:35:53 +01:00
parent 41214cd531
commit d183f11fd6
1 changed files with 51 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

55
src/providers/twitch/EventSub.cpp
View file

@ -6,7 +6,10 @@
#include "eventsub/payloads/channel-ban-v1.hpp"
#include "eventsub/payloads/session-welcome.hpp"
#include "eventsub/session.hpp"
#include "messages/Message.hpp"
#include "messages/MessageBuilder.hpp"
#include "providers/twitch/api/Helix.hpp"
#include "providers/twitch/PubSubActions.hpp"
#include "providers/twitch/TwitchAccount.hpp"
#include "providers/twitch/TwitchChannel.hpp"
#include "providers/twitch/TwitchIrcServer.hpp"
@ -124,7 +127,7 @@ public:
condition.insert("user_id", sourceUserID);
getHelix()->createEventSubSubscription(
"channel.chat.notification", "beta", sessionID,
"channel.chat.notification", "1", sessionID,
condition,
[roomID](const auto &response) {
qDebug() << "Successfully subscribed to "
@ -159,7 +162,51 @@ public:
<< " reason=" << payload.event.reason
<< " userLogin=" << payload.event.userLogin
<< " moderatorLogin=" << payload.event.moderatorUserLogin
<< '\n';
<< " bannedAt=" << payload.event.bannedAt << '\n';
auto roomID = QString::fromStdString(payload.event.broadcasterUserID);
BanAction action{
//
};
action.timestamp = std::chrono::steady_clock::now();
action.roomID = roomID;
action.source = ActionUser{
.id = QString::fromStdString(payload.event.moderatorUserID),
.login = QString::fromStdString(payload.event.moderatorUserLogin),
.displayName =
QString::fromStdString(payload.event.moderatorUserName),
};
action.target = ActionUser{
.id = QString::fromStdString(payload.event.userID),
.login = QString::fromStdString(payload.event.userLogin),
.displayName = QString::fromStdString(payload.event.userName),
};
action.reason = QString::fromStdString(payload.event.reason);
if (payload.event.isPermanent)
{
action.duration = 0;
}
else
{
auto timeoutDuration = payload.event.timeoutDuration();
auto timeoutDurationInSeconds =
std::chrono::duration_cast<std::chrono::seconds>(
timeoutDuration)
.count();
action.duration = timeoutDurationInSeconds;
qDebug() << "TIMEOUT DURATION IN SECONDS: "
<< timeoutDurationInSeconds;
}
auto chan = getApp()->twitch->getChannelOrEmptyByID(roomID);
runInGuiThread([action{std::move(action)}, chan{std::move(chan)}] {
MessageBuilder msg(action);
msg->flags.set(MessageFlag::PubSub);
chan->addOrReplaceTimeout(msg.release());
});
}
void onStreamOnline(messages::Metadata metadata,
@ -180,11 +227,11 @@ public:
void onChannelChatNotification(
messages::Metadata metadata,
payload::channel_chat_notification::beta::Payload payload) override
payload::channel_chat_notification::v1::Payload payload) override
{
(void)metadata;
(void)payload;
std::cout << "Received channel.chat.notification beta\n";
std::cout << "Received channel.chat.notification v1\n";
}
void onChannelUpdate(messages::Metadata metadata,