ircchannel.hpp

Go to the documentation of this file.

#pragma once
#include <chrono>
#include "channel.hpp"
#include "hub.hpp"

namespace ircChannel {

  constexpr size_t irc_message_max = 256;
  constexpr std::chrono::duration<double> max_timeout(5.0);
  class IrcChannel: public channeling::Channel {

    const std::string _server;                           
    const uint32_t _port;                                
    const std::string _channel;                          
    std::chrono::time_point<std::chrono::high_resolution_clock> _ping_time; 
    mutable std::mutex _pong_time_mutex;                 
    mutable std::chrono::time_point<std::chrono::high_resolution_clock> _last_pong_time; 
    mutable std::atomic_bool _connection_issue ;

    void registerConnection();
    void ping();
    void pong() const;
    void checkTimeout();
    std::future<void> activate() override;
    const messaging::message_ptr parse(const char* line) const override;

    static const channeling::ChannelCreatorImpl<IrcChannel> creator;
    const messaging::message_ptr parseImpl(const std::string& toParse) const;
  public:
    explicit IrcChannel(Hub::Hub* hub, const std::string& config);
    ~IrcChannel();

    std::string type() const override {return "irc"; };

  protected:
    void tick() override;

    void incoming(const messaging::message_ptr&& msg) override;
  };
  const channeling::ChannelCreatorImpl<IrcChannel> IrcChannel::creator("irc");
}