mirror of
https://github.com/Chatterino/chatterino2.git
synced 2024-11-13 19:49:51 +01:00
83 lines
2.5 KiB
C++
83 lines
2.5 KiB
C++
#pragma once
|
|
|
|
#include "common/Atomic.hpp"
|
|
#include "common/Channel.hpp"
|
|
#include "common/Singleton.hpp"
|
|
#include "pajlada/signals/signalholder.hpp"
|
|
#include "providers/bttv/BttvEmotes.hpp"
|
|
#include "providers/ffz/FfzEmotes.hpp"
|
|
#include "providers/irc/AbstractIrcServer.hpp"
|
|
#include "providers/twitch/TwitchBadges.hpp"
|
|
|
|
#include <chrono>
|
|
#include <memory>
|
|
#include <queue>
|
|
|
|
namespace chatterino {
|
|
|
|
class Settings;
|
|
class Paths;
|
|
class PubSub;
|
|
class TwitchChannel;
|
|
|
|
class TwitchServer final : public AbstractIrcServer, public Singleton
|
|
{
|
|
public:
|
|
TwitchServer();
|
|
virtual ~TwitchServer() override = default;
|
|
|
|
virtual void initialize(Settings &settings, Paths &paths) override;
|
|
|
|
void forEachChannelAndSpecialChannels(std::function<void(ChannelPtr)> func);
|
|
|
|
std::shared_ptr<Channel> getChannelOrEmptyByID(const QString &channelID);
|
|
|
|
Atomic<QString> lastUserThatWhisperedMe;
|
|
|
|
const ChannelPtr whispersChannel;
|
|
const ChannelPtr mentionsChannel;
|
|
IndirectChannel watchingChannel;
|
|
|
|
PubSub *pubsub;
|
|
|
|
const BttvEmotes &getBttvEmotes() const;
|
|
const FfzEmotes &getFfzEmotes() const;
|
|
|
|
protected:
|
|
virtual void initializeConnection(IrcConnection *connection, bool isRead,
|
|
bool isWrite) override;
|
|
virtual std::shared_ptr<Channel> createChannel(
|
|
const QString &channelName) override;
|
|
|
|
virtual void privateMessageReceived(
|
|
Communi::IrcPrivateMessage *message) override;
|
|
virtual void messageReceived(Communi::IrcMessage *message) override;
|
|
virtual void writeConnectionMessageReceived(
|
|
Communi::IrcMessage *message) override;
|
|
|
|
virtual std::shared_ptr<Channel> getCustomChannel(
|
|
const QString &channelname) override;
|
|
|
|
virtual QString cleanChannelName(const QString &dirtyChannelName) override;
|
|
virtual bool hasSeparateWriteConnection() const override;
|
|
|
|
private:
|
|
void onMessageSendRequested(TwitchChannel *channel, const QString &message,
|
|
bool &sent);
|
|
|
|
std::mutex lastMessageMutex_;
|
|
std::queue<std::chrono::steady_clock::time_point> lastMessagePleb_;
|
|
std::queue<std::chrono::steady_clock::time_point> lastMessageMod_;
|
|
std::chrono::steady_clock::time_point lastErrorTimeSpeed_;
|
|
std::chrono::steady_clock::time_point lastErrorTimeAmount_;
|
|
|
|
bool singleConnection_ = false;
|
|
TwitchBadges twitchBadges;
|
|
BttvEmotes bttv;
|
|
FfzEmotes ffz;
|
|
|
|
pajlada::Signals::SignalHolder signalHolder_;
|
|
};
|
|
|
|
} // namespace chatterino
|