mirror of
https://github.com/Chatterino/chatterino2.git
synced 2024-11-13 19:49:51 +01:00
99 lines
2.9 KiB
C++
99 lines
2.9 KiB
C++
#pragma once
|
|
|
|
#define TWITCH_MAX_MESSAGELENGTH 500
|
|
|
|
#include "messages/message.hpp"
|
|
#include "twitch/twitchuser.hpp"
|
|
|
|
#include <ircconnection.h>
|
|
#include <IrcMessage>
|
|
#include <QMap>
|
|
#include <QMutex>
|
|
#include <QNetworkAccessManager>
|
|
#include <QString>
|
|
#include <pajlada/signals/signal.hpp>
|
|
|
|
#include <memory>
|
|
#include <mutex>
|
|
|
|
namespace chatterino {
|
|
|
|
class ChannelManager;
|
|
class Resources;
|
|
class WindowManager;
|
|
|
|
class IrcManager : public QObject
|
|
{
|
|
Q_OBJECT
|
|
|
|
public:
|
|
IrcManager(ChannelManager &channelManager, Resources &resources, WindowManager &windowManager);
|
|
|
|
void connect();
|
|
void disconnect();
|
|
|
|
bool isTwitchBlockedUser(QString const &username);
|
|
bool tryAddIgnoredUser(QString const &username, QString &errorMessage);
|
|
void addIgnoredUser(QString const &username);
|
|
bool tryRemoveIgnoredUser(QString const &username, QString &errorMessage);
|
|
void removeIgnoredUser(QString const &username);
|
|
|
|
void sendMessage(const QString &channelName, QString message);
|
|
|
|
void joinChannel(const QString &channelName);
|
|
void partChannel(const QString &channelName);
|
|
|
|
void setUser(std::shared_ptr<twitch::TwitchUser> newAccount);
|
|
|
|
pajlada::Signals::Signal<Communi::IrcPrivateMessage *> onPrivateMessage;
|
|
void privateMessageReceived(Communi::IrcPrivateMessage *message);
|
|
|
|
ChannelManager &channelManager;
|
|
Resources &resources;
|
|
WindowManager &windowManager;
|
|
|
|
Communi::IrcConnection* getReadConnection();
|
|
private:
|
|
// variables
|
|
std::shared_ptr<twitch::TwitchUser> account = nullptr;
|
|
|
|
std::unique_ptr<Communi::IrcConnection> writeConnection = nullptr;
|
|
std::unique_ptr<Communi::IrcConnection> readConnection = nullptr;
|
|
|
|
std::mutex connectionMutex;
|
|
|
|
QMap<QString, bool> twitchBlockedUsers;
|
|
QMutex twitchBlockedUsersMutex;
|
|
|
|
QNetworkAccessManager networkAccessManager;
|
|
|
|
void initializeConnection(const std::unique_ptr<Communi::IrcConnection> &connection,
|
|
bool isReadConnection);
|
|
|
|
void refreshIgnoredUsers(const QString &username, const QString &oauthClient,
|
|
const QString &oauthToken);
|
|
|
|
void beginConnecting();
|
|
|
|
void messageReceived(Communi::IrcMessage *message);
|
|
|
|
void writeConnectionMessageReceived(Communi::IrcMessage *message);
|
|
|
|
void handleRoomStateMessage(Communi::IrcMessage *message);
|
|
void handleClearChatMessage(Communi::IrcMessage *message);
|
|
void handleUserStateMessage(Communi::IrcMessage *message);
|
|
void handleWhisperMessage(Communi::IrcMessage *message);
|
|
void handleUserNoticeMessage(Communi::IrcMessage *message);
|
|
void handleModeMessage(Communi::IrcMessage *message);
|
|
void handleNoticeMessage(Communi::IrcNoticeMessage *message);
|
|
void handleWriteConnectionNoticeMessage(Communi::IrcNoticeMessage *message);
|
|
|
|
void onConnected();
|
|
void onDisconnected();
|
|
|
|
private:
|
|
QByteArray messageSuffix;
|
|
};
|
|
|
|
} // namespace chatterino
|